anchor.diff:      end, Missing).
   
   
  -save_on_target(Node, Name, Docs) ->
  -    Options = [replicated_changes, full_commit, {user_ctx, ?CTX},
  -        {io_priority, {internal_repl, Name}}],
  -    rexi_call(Node, {fabric_rpc, update_docs, [Name, Docs, Options]}),
  -    ok.
  +open_doc_revs(Db, #full_doc_info{id=Id, rev_tree=RevTree}, Revs) ->
  +    {FoundRevs, _} = couch_key_tree:get_key_leafs(RevTree, Revs),
  +    lists:map(fun({#leaf{deleted=IsDel, ptr=SummaryPtr}, FoundRevPath}) ->
  +                  couch_db:make_doc(Db, Id, IsDel, SummaryPtr, FoundRevPath)
  +    end, FoundRevs).
   
   
   update_locals(Acc) ->
  
positive.code:             <<>>
      end,
      <<"_local/shard-sync-", S/binary, "-", T/binary, F/binary>>.
  
  
  changes_enumerator(#doc_info{id=DocId}, Reds, #acc{db=Db}=Acc) ->
  
negative.code:     rexi_call(Node, {fabric_rpc, get_missing_revs, [Name, IdsRevs, Options]}).
  
  
  save_on_target(Node, Name, Docs) ->
      Options = [replicated_changes, full_commit, {user_ctx, ?CTX},
          {io_priority, {internal_repl, Name}}],
      rexi_call(Node, {fabric_rpc, update_docs, [Name, Docs, Options]}),
      ok.
  
  
  open_docs(#acc{source=Source, infos=Infos}, Missing) ->
      lists:flatmap(fun({Id, Revs, _}) ->
          FDI = lists:keyfind(Id, #full_doc_info.id, Infos),
  