anchor.diff:                  end,
                   {ok, Acc};
               ({stop, EndSeq}, Acc) ->
  -                ok = gen_server:call(Server, {rep_db_checkpoint, DbName, EndSeq}),
  +                ok = gen_server:call(Server, {rep_db_checkpoint, DbName, EndSeq}, infinity),
                   {ok, Acc};
               (_, Acc) ->
                   {ok, Acc}
  
positive.code: init(_) ->
      process_flag(trap_exit, true),
      net_kernel:monitor_nodes(true),
      ?DOC_TO_REP = ets:new(?DOC_TO_REP, [named_table, set, protected]),
      ?REP_TO_STATE = ets:new(?REP_TO_STATE, [named_table, set, protected]),
      ?DB_TO_SEQ = ets:new(?DB_TO_SEQ, [named_table, set, protected]),
      Server = self(),
      ok = couch_config:register(
          fun("replicator", "max_replication_retry_count", V) ->
  
negative.code:         fun({updated, DbName}) ->
              case IsReplicatorDbFun(DbName) of
              true ->
                  ok = gen_server:call(Server, {resume_scan, mem3:dbname(DbName)}, infinity);
              _ ->
                  ok
              end;
             ({deleted, DbName}) ->
              case IsReplicatorDbFun(DbName) of
              true ->
                  clean_up_replications(mem3:dbname(DbName));
              _ ->
                  ok
              end;
  