anchor.diff:      scan_pid = nil,
       rep_start_pids = [],
       max_retries,
  -    live = []
  +    live = [],
  +    epoch = nil
   }).
   
   start_link() ->
  
positive.code: handle_call({rep_error, RepId, Error}, _From, State) ->
      {reply, ok, replication_error(State, RepId, Error)};
  
  handle_call({rep_db_checkpoint, DbName, EndSeq}, _From, State) ->
      Entry = case ets:lookup(?DB_TO_SEQ, DbName) of
          [] ->
              {DbName, EndSeq, false};
  
negative.code:     {ok, State}.
  
  
  start_changes_reader(DbName, Since, Epoch) ->
      spawn_link(?MODULE, changes_reader, [{self(), Epoch}, DbName, Since]).
  
  changes_reader({Server, Epoch}, DbName, Since) ->
      UserCtx = #user_ctx{roles = [<<"_admin">>, <<"_replicator">>]},
      DbOpenOptions = [{user_ctx, UserCtx}, sys_db],
      {ok, Db} = couch_db:open_int(DbName, DbOpenOptions),
  