anchor.diff:      end.
   
   pull_rep(DbTarget, DbSource, SourceSeqNum) ->
  -    Parent = self(),
       SaveDocsPid = spawn_link(fun() ->
  -            save_docs_loop(Parent, DbTarget, 0) end),
  +            save_docs_loop(DbTarget, 0) end),
       OpenDocsPid = spawn_link(fun() ->
  -            open_doc_revs_loop(Parent, DbSource, SaveDocsPid, 0) end),
  +            open_doc_revs_loop(DbSource, SaveDocsPid, 0) end),
  +    OpenDocsPid ! got_it, % prime queue with got_it
       MissingRevsPid = spawn_link(fun() ->
  -            get_missing_revs_loop(Parent, DbTarget, OpenDocsPid, 0, 0) end),
  +            get_missing_revs_loop(DbTarget, OpenDocsPid, 0, 0) end),
  +    MissingRevsPid ! got_it, % prime queue with got_it
  +    self() ! got_it,
       {ok, NewSeq} = enum_docs_since(DbSource, SourceSeqNum,
           fun(SrcDocInfo, _, _) ->
               #doc_info{id=Id,
  
positive.code:                 tuple_to_list(proplists:get_value("deleted_conflicts", RowValueProps, {})),
              deleted = proplists:get_value("deleted", RowValueProps, false)}
          end, tuple_to_list(proplists:get_value("rows", Results))),
      {ok, enum_docs0(InFun, DocInfoList, InAcc)};
  enum_docs_since(DbSource, StartSeq, Fun, Acc) ->
      couch_db:enum_docs_since(DbSource, StartSeq, Fun, Acc).
  
  
negative.code: 
  
  enum_docs_since(DbUrl, StartSeq, InFun, InAcc) when is_list(DbUrl) ->
      Url = DbUrl ++ "_all_docs_by_seq?count=4&startkey=" ++ integer_to_list(StartSeq),
      {obj, Results} = do_http_request(Url, get),
      DocInfoList=
      lists:map(fun({obj, RowInfoList}) ->
  