anchor.diff:              Deleted
       end.
   
  -handle_info({'DOWN', _Ref, _Type, {Server, RemoteNode}, Error},
  -            #state{remote_nodes = RemoteNodes} = State) ->
  -    ?log_warning("Remote server node ~p process down: ~p",
  -                 [{Server, RemoteNode}, Error]),
  -    {noreply, State#state{remote_nodes=RemoteNodes -- [RemoteNode]}};
  -handle_info(replicate_newnodes_docs, State) ->
  -    ?log_debug("doing replicate_newnodes_docs"),
  -    {noreply, replicate_newnodes_docs(State)};
  +handle_info(replicate_newnodes_docs, #state{bucket = Bucket,
  +                                            local_docs = Docs,
  +                                            ddoc_replicator = Replicator} = State) ->
  +    Replicator ! {replicate_newnodes_docs, get_remote_nodes(Bucket), Docs},
  +    {noreply, State};
   handle_info({update_ddoc, DDocId, Deleted0}, State) ->
       Deleted = aggregate_update_ddoc_messages(DDocId, Deleted0),
       ?log_info("Processing update_ddoc ~s (~p)", [DDocId, Deleted]),
  
positive.code:         {not_found, _} ->
              couch_db:create(MasterVBucket, [])
      end.
  
  replicate_change(#state{proxy_server_name = ServerName,
                          remote_nodes=Nodes}, Doc) ->
      [replicate_change_to_node(ServerName, Node, Doc) || Node <- Nodes],
      ok.
  
  save_doc(#doc{id = Id} = Doc,
           #state{bucket=Bucket, local_docs=Docs}=State) ->
  
negative.code:         _ ->
              ok
      end,
  
      erlang:exit(Replicator, kill),
      misc:wait_for_process(Replicator, infinity),
      ok.
  
  code_change(_OldVsn, State, _Extra) ->
  