anchor.diff:                      Done = LastOpId
               end
       end,
  -    lager:info("Reset lastopid to ~p",[Done]),
       Done.
   
   filter_downstream(Ops) ->
  
positive.code:                                   commit_time={DcId, LocalClock},
                                    snapshot_time = vectorclock:from_list([])
                                   },
              _Payload=#operation{payload = #log_record
                                 {op_type=noop, op_payload=Op}},
              Done = LastOpId;
              %case inter_dc_communication_sender:propagate_sync(
              %       {replicate, [Payload]}, DCs) of
              %    ok ->
              %        Done = LastOpId;
              %    Other ->
              %        Done = LastOpId,
              %        lager:info(
              %          "Propagation error. Reason: ~p",[Other])
              %end;
              %Done = LastOpId; %%TODO:
          _ ->
              Downstreamops = filter_downstream(Ops),
              lager:info("Ops to replicate ~p",[Downstreamops]),
              case inter_dc_communication_sender:propagate_sync(
                     {replicate, Downstreamops}, DCs) of
                  ok ->
  
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),
       IndexNode = hd(Preflist),
  