anchor.diff:  
   %% public API
   trigger(IndexNode, Key) ->
  -    riak_core_vnode_master:command(IndexNode, {trigger,Key},
  -                                   inter_dc_repl_vnode_master).
  +    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),
  
positive.code:                     Done = LastOpId
              end
      end,
      lager:info("Reset lastopid to ~p",[Done]),
      Done.
  
  filter_downstream(Ops) ->
  
negative.code:                                   commit_time={DcId, LocalClock},
                                    snapshot_time = vectorclock:from_list([])
                                   },
              Payload=#operation{payload = #log_record
                                 {op_type=noop, op_payload=Op}},
              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;
          _ ->
              Downstreamops = filter_downstream(Ops),
              lager:error("X1 propagation ~p",[Downstreamops]),
              case inter_dc_communication_sender:propagate_sync(
                     {replicate, Downstreamops}, DCs) of
                  ok ->
  