anchor.diff:      [] ->
           none
       end.
  +
  +stop_all_replications() ->
  +    ets:foldl(
  +        fun({_, RepId}, _) -> couch_rep:end_replication(RepId) end,
  +        ok,
  +        ?DOC_TO_REP_ID_MAP
  +    ),
  +    true = ets:delete_all_objects(?REP_ID_TO_DOC_ID_MAP),
  +    true = ets:delete_all_objects(?DOC_TO_REP_ID_MAP).
  
positive.code: -define(REP_ID_TO_DOC_ID_MAP, rep_id_to_rep_doc_id).
  
  -record(state, {
      changes_feed_loop,
      changes_queue,
      changes_processor
  }).
  
  
  
negative.code:     {ok, Pid}.
  
  
  db_update_notifier() ->
      Server = self(),
      {ok, Notifier} = couch_db_update_notifier:start_link(
          fun({created, DbName}) ->
              case ?l2b(couch_config:get("replicator", "db", "_replicator")) of
              DbName ->
                  ok = gen_server:cast(Server, rep_db_created);
              _ ->
                  ok
              end;
          (_) ->
              ok
          end
      ),
      Notifier.
  
  
  changes_processor(ChangesQueue) ->
      Pid = spawn_link(
          fun() ->
  