anchor.diff:  -include("floppy.hrl").
   -include_lib("riak_core/include/riak_core_vnode.hrl").
   
  --record(dstate, {partition, last_commit_time, pending_operations}).
  +-record(dstate, {partition, last_commit_time, pending_operations, stable_time}).
   
   -export([start_vnode/1,
            trigger/2]).
  
positive.code:                              pending_operations = Pending}) ->
      Pending_operations = add_to_pending_operations(Pending, Write_set),
      lager:info("Pending Operations ~p",[Pending_operations]),
      From ! {ok, trigger_received},
      Node = {Partition, node()}, %% Send ack to caller and continue processing
  
      Stable_time = get_stable_time(Node, Last_commit_time),
      lager:info("Take updates before time : ~p",[Stable_time]),
      Sorted_ops = filter_operations(Pending_operations,
                                     Stable_time, Last_commit_time),
  
negative.code:                                  {_,{Key,{Op,Actor}}} = Update,
                                   Dc_id = dc_utilities:get_my_dc_id(),
                                   New_op = #clocksi_payload{
                                               key = Key, type = riak_dt_pncounter,
                                               op_param = {Op, Actor},
                                               snapshot_time = Vec_snapshot_time,
                                               commit_time = {Dc_id,Commit_time},
                                               txid = TxId},
                                   lists:append(Operations, [New_op])
                           end,
                           Pending, Updates);
  