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:                     {next_state, abort, SD0};
                  {ok, Snapshot} ->
                      ReadResult = Type:value(Snapshot),
                      lager:info("ClockSI-Interactive-Coord: Read Result:  ~w ~n",
                                 [ReadResult]),
                      {reply, {ok, ReadResult}, execute_op, SD0}
              end;
          update ->
              {Key, Type, Param}=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: From ~w ~n ", [From]),
              lager:info("ClockSI-Interactive-Coord: getting leader for Key ~w ",
                         [Key]),
              Preflist = log_utilities:get_preflist_from_key(Key),
              IndexNode = hd(Preflist),
              case generate_downstream_op(Transaction, IndexNode, Key, Type, Param) of
  
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{
  