anchor.diff:      Vnode={Partition, node()},
   	Updates = ets:lookup(WriteSet, TxId),
       lager:info("ClockSI-Vnode: start a read fsm for key ~w. Previous updates:~p",[Key, Updates]),
  -<<<<<<< HEAD
  -    clockSI_readitem_fsm:start_link(Vnode, Sender, Txn, Key, Type, Updates),
  -    lager:info("ClockSI-Vnode: done."),
  -=======
       clockSI_readitem_fsm:start_link(Vnode, Sender, TxId, Key, Type, Updates),
       lager:info("ClockSI-Vnode: done. Reply to the coordinator."),
  ->>>>>>> parent of acfe61c... Enable clocksi functions to use vector-timestamps for inter dc replication
       {noreply, State};
   
   %% @doc handles an update operation at a Leader's partition
  
positive.code:         ok ->
              Updates = ets:lookup(WriteSet, TxId),
              lager:info("ClockSI_Vnode: issuing all updates to the logging layer: ~p", [Updates]),
              issue_updates(Updates, Transaction, TxCommitTime),
              ets:insert(CommittedTx, {TxId, TxCommitTime}),
              lager:info("ClockSI_Vnode: starting to clean state and Notifying pending read_FSMs (if any)."),
              clean_and_notify(TxId, State),
  
negative.code: 	internal_pending_txs(ListOfPendingTxs, SnapshotTime, PreparedTx, []).
  internal_pending_txs([], _ST, _PreparedTx, Result) -> Result;
  internal_pending_txs([H|T], ST, PreparedTx, Result) ->
      {_, TxId}=H,
      Lookup=ets:lookup(PreparedTx, TxId),
      case Lookup of 
  