anchor.diff:                                 {ok, non_neg_integer()}.
   get_snapshot_time(ClientClock) ->
       Now=clocksi_vnode: now_milisec(erlang:now()),
  -    case (ClientClock > Now) of
  -        true->
  -            SnapshotTime = ClientClock + ?MIN;
  -        false ->
  -            SnapshotTime = Now
  +    SnapshotTime = case (ClientClock > Now) of
  +                    true->
  +                        ClientClock + ?MIN;
  +                    false ->
  +                        Now
       end,
       {ok, SnapshotTime}.
   
  
positive.code: %%      operation, wait for it to finish (synchronous) and go to the prepareOP
  %%       to execute the next operation.
  execute_op({Op_type, Args}, Sender,
             SD0=#state{transaction=Transaction, from=From,
                        updated_partitions=Updated_partitions}) ->
      case Op_type of
          prepare ->
              lager:info("ClockSI-Interactive-Coord: Sender ~w ~n ", [Sender]),
              {next_state, prepare, SD0#state{from=Sender}, 0};
          read ->
              {Key, Type}=Args,
              lager:info("ClockSI-Interactive-Coord: PID ~w ~n ", [self()]),
              lager:info("ClockSI-Interactive-Coord: Op ~w ~n ", [Args]),
              lager:info("ClockSI-Interactive-Coord: Sender ~w ~n ", [Sender]),
              lager:info("ClockSI-Interactive-Coord: getting leader for Key ~w",
                         [Key]),
              Preflist = log_utilities:get_preflist_from_key(Key),
              IndexNode = hd(Preflist),
              case clocksi_vnode:read_data_item(IndexNode, Transaction,
  
negative.code: 
  %% @doc Initialize the state.
  init([From, Clientclock]) ->
      {ok, SnapshotTime} = case Clientclock of
                              ignore -> get_snapshot_time();
                              _ -> get_snapshot_time(Clientclock)
                          end,
      TxId=#tx_id{snapshot_time=SnapshotTime, server_pid=self()},
      {ok, Vec_clock} = vectorclock:get_clock_node(node()),
      Dc_id = dc_utilities:get_my_dc_id(),
      Vec_snapshot_time = dict:update(Dc_id,
                                      fun (_Old) -> SnapshotTime end,
                                      SnapshotTime,
                                      Vec_clock),
      Transaction = #transaction{snapshot_time = SnapshotTime,
                                 vec_snapshot_time = Vec_snapshot_time,
                                 txn_id = TxId},
      SD = #state{
  