anchor.diff:  	%	clean_active_txs_per_key(TxId, [Op|Ops], ActiveTxsPerKey)
       %	end,
       ets:delete(PreparedTx, TxId),
  -    ets:delete_object(ActiveTx, {active,{TxId, TxId#tx_id.snapshot_time}}),
  +    ets:delete(ActiveTx, TxId),
       ets:delete(WriteSet, TxId),
       ets:delete(WaitingFsms, TxId).
   
  
positive.code:             {reply, {error, timeout}, State}
      end;
  
  handle_command({abort, TxId}, _Sender, #state{partition=Partition}=State) ->
  	Result = floppy_rep_vnode:append(Partition-1, {TxId, aborted}), 
      case Result of
          {ok,_} ->
          	clean_and_notify(TxId, State),
  		lager:info("Vnode: Recieved abort. State cleaned.");     
          {error, timeout} ->
              lager:info("Abort not written to all replica of log")
              
          	%% should we reply something here?
  
negative.code:     %%ActiveTxs = [{active,{TxId, Snapshottime}}]
      ActiveTxs = ets:lookup(Active, active),
      lager:info("ActiveTxs: ~p", [ActiveTxs]),
      %% ActiveTxsFiltered = lists:foldl( fun({active, {TxId, Snapshottime}}, Txns) ->
      %%                                          lists:append(Txns,[{TxId, Snapshottime}]) end,
      %%                                  [],
      %%                                  ActiveTxs),
      %% lager:info(" Active Txns after filtered ~p",[ActiveTxsFiltered]),
      {reply, {ok, ActiveTxs}, State};
  
  handle_command(Message, _Sender, State) ->
      ?PRINT({unhandled_command_logging, Message}),
  