anchor.diff:              {reply, {error, timeout}, State}
       end;
   
  -handle_command({abort, TxId}, _Sender, #state{partition=_Partition, write_set=WriteSet}=State) ->
  -    Updates = ets:lookup(WriteSet, TxId),
  -    [{_,{Key,{_Op,_Actor}}} | _Rest] = Updates,
  -    LogId = log_utilities:get_logid_from_key(Key), %TODO: Modify this when get_logid_from_partition is fixed
  -                                                %LogId=log_utilities:get_logid_from_partition(Partition),
  +handle_command({abort, TxId}, _Sender, #state{partition=Partition}=State) ->                                              
  +    LogId=log_utilities:get_logid_from_partition(Partition),
       Result = floppy_rep_vnode:append(LogId, {TxId, aborted}), 
       case Result of
           {ok,_} ->
  
positive.code:             {reply, {error, timeout}, State}
      end;
  
  handle_command({prepare, Transaction}, _Sender, #state{ partition = _Partition,
                                                          active_tx=ActiveTx, committed_tx=CommittedTx,
                                                          active_txs_per_key=ActiveTxPerKey, prepared_tx=PreparedTx, write_set=WriteSet}=State) ->
      TxId = Transaction#transaction.txn_id,
  
negative.code:     end;
  
  handle_command({commit, Transaction, TxCommitTime}, _Sender, 
                 #state{partition = Partition, committed_tx=CommittedTx, write_set=WriteSet}=State) ->
      lager:info("ClockSI_Vnode: got commit message."),
      TxId = Transaction#transaction.txn_id,
      LogRecord=#log_record{tx_id=TxId, op_type=commit, op_payload=TxCommitTime},
      lager:info("ClockSI_Vnode: logging the following operation: ~p.", [LogRecord]),
      LogId=log_utilities:get_logid_from_partition(Partition),
      Result = floppy_rep_vnode:append(LogId, LogRecord),   
      case Result of
          {ok,_} ->
              %% gen_fsm:send_event(Sender, committed) %TODO: Return results to caller here,
              Updates = ets:lookup(WriteSet, TxId),
              lager:info("ClockSI_Vnode: sending updates to the downstream vnode layer: ~p", [Updates]),
              ets:insert(CommittedTx, {TxId, TxCommitTime}),
  