anchor.diff:                      Done = LastOpId
               end
       end,
  -    lager:info("Reset lastopid to ~p",[Done]),
       Done.
   
   filter_downstream(Ops) ->
  
positive.code:                 {ok, Ops} ->
                      OpDone = prepare_and_send_ops(Ops,Clock,State);
                  {error, _Reason} ->
                      OpDone = Last,
                      timer:sleep(?RETRY_TIME),
                      trigger({Partition, node()})
              end
      end,
      %trigger({Partition, node()})
  
negative.code: 
  %% public API
  trigger(IndexNode, Key) ->
      riak_core_vnode_master:sync_command(IndexNode, {trigger,Key},
                                     inter_dc_repl_vnode_master).
  trigger(Key) ->
       Preflist = log_utilities:get_preflist_from_key(Key),
  