anchor.diff:  %% @doc Return smallest snapshot time of active transactions.
   %%      No new updates with smaller timestamp will occur in future.
   get_stable_time(Node, Prev_stable_time) ->
  -    lager:info("In get_stable_time"),
       case riak_core_vnode_master:sync_command(
              Node, {get_active_txns}, ?CLOCKSI_MASTER) of
           {ok, Active_txns} ->
  -            lager:info("Active txns before filtering ~p",[Active_txns]),
               lists:foldl(fun({_,{_TxId, Snapshot_time}}, Min_time) ->
                                   case Min_time > Snapshot_time of
                                       true ->
  
positive.code: 
  %%@doc Add updates in writeset ot Pending operations to process downstream
  add_to_pending_operations(Pending, WriteSet) ->
      lager:info("Writeset : ~p", [WriteSet]),
      case WriteSet of
          {TxId, Updates, Vec_snapshot_time, CommitTime} ->
              lists:foldl( fun(Update, Operations) ->
  
negative.code:           end,
            Unprocessed_ops),
  
      %% Sort operations in timestamp order
      Sorted_ops =
          lists:sort(
  