anchor.diff:                               last_commit_time = LastCommitTime,
                                pending_operations = PendingOperations,
                                stable_time = Stable_time}) ->
  -    lager:info("Take updates before time : ~p",[Stable_time]),
       Sorted_ops = filter_operations(PendingOperations,
                                      Stable_time, LastCommitTime),
  -    lager:info("Generate downstream for ~p",[Sorted_ops]),
       {Remaining_operations, Last_processed_time} =
           lists:foldl( fun(X, {Ops, LCTS}) ->
                                case process_update(X) of
  
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:                   CommitTime > After
            end,
            Ops),
  
      %% remove operations which are not safer to process now,
      %% because there could be other operations with lesser timestamps
  