anchor.diff:      IdsRevs = lists:map(fun(#doc_info{id=Id, revs=RevInfos}) ->
           {Id, [R || #rev_info{rev=R} <- RevInfos]}
       end, Infos),
  -    rexi_call(Node, {fabric_rpc, get_missing_revs, [Name, IdsRevs]}).
  +    Options = [{io_priority, {internal_repl, Name}}],
  +    rexi_call(Node, {fabric_rpc, get_missing_revs, [Name, IdsRevs, Options]}).
   
   open_docs(Db, Missing) ->
       lists:flatmap(fun({Id, Revs, _}) ->
  
positive.code: calculate_start_seq(Db, #shard{node=Node, name=Name}, LocalId) ->
      case couch_db:open_doc(Db, LocalId, []) of
      {ok, #doc{body = {SProps}}} ->
          try rexi_call(Node, {fabric_rpc, open_doc, [Name, LocalId, []]}) of
          #doc{body = {TProps}} ->
              SourceSeq = couch_util:get_value(<<"seq">>, SProps, 0),
              TargetSeq = couch_util:get_value(<<"seq">>, TProps, 0),
  
negative.code:         {<<"timestamp">>, list_to_binary(iso8601_timestamp())}
      ]}},
      {ok, _} = couch_db:update_doc(Db, Doc, []),
      Options = [{user_ctx, ?CTX}, {io_priority, {internal_repl, Name}}],
      rexi_call(Node, {fabric_rpc, update_docs, [Name, [Doc], Options]}).
  
  rexi_call(Node, MFA) ->
  