anchor.diff:              app_helper:get_env(riak_core, platform_data_dir), TxLogFile),
       case dets:open_file(TxLogFile, [{file, TxLogPath}, {type, bag}]) of
           {ok, TxLog} ->
  -	    	PreparedTx=prepared_tx,
  +	    	PreparedTx=active_tx,
   			WaitingFsms=waiting_fsms,
   			ActiveTxsPerKey=active_txs_per_key,
   			WriteSet=write_set,
  
positive.code: %% 2. clean the state of the transaction. Namely:
  %% 	a. ActiteTxsPerKey,
  %% 	b. Waiting_Fsms,
  %% 	c. TxState
  clean_and_notify(timeout, TxId, #state{prepared_tx=PreparedTx, 
  					write_set=WriteSet, waiting_fsms=WaitingFsms, active_txs_per_key=ActiveTxsPerKey}) ->
  	notify_all(ets:lookup(WaitingFsms, TxId), TxId),
  	case ets:lookup(WriteSet, TxId) of
  
negative.code:     {next_state, clean_and_notify, TxId, State, 0};
  
  handle_command ({get_pending_txs, {Key, TxId}}, Sender, #state{
  			active_txs_per_key=ActiveTxsPerKey, waiting_fsms=WaitingFsms, prepared_tx=PreparedTx}=State) ->
  	Pending=pending_txs(ets:lookup(ActiveTxsPerKey, Key), TxId, PreparedTx),
  	case Pending of
  		[]->
  			{reply, {ok, empty}, State};
  