anchor.diff:  dbinfo(Db) ->
       {ok, Info} = couch_db:get_db_info(Db),
       Info.
  +
  +do_terminate(State) ->
  +    #state{
  +        checkpoint_history = CheckpointHistory,
  +        committed_seq = NewSeq,
  +        listeners = Listeners,
  +        source = Source,
  +        target = Target,
  +        stats = Stats,
  +        source_log = #doc{body={OldHistory}}
  +    } = State,
  +    couch_task_status:update("Finishing"),
  +    ets:delete(Stats),
  +    close_db(Target),
  +    
  +    NewRepHistory = case CheckpointHistory of
  +    nil ->
  +        {[{<<"no_changes">>, true} | OldHistory]};
  +    _Else ->
  +        CheckpointHistory
  +    end,
  +
  +    %% reply to original requester
  +    [Original|OtherListeners] = lists:reverse(Listeners),
  +    gen_server:reply(Original, {ok, NewRepHistory}),
  +
  +    %% maybe trigger another replication. If this replicator uses a local
  +    %% source Db, changes to that Db since we started will not be included in
  +    %% this pass.
  +    case up_to_date(Source, NewSeq) of
  +        true ->
  +            [gen_server:reply(R, {ok, NewRepHistory}) || R <- OtherListeners];
  +        false ->
  +            [gen_server:reply(R, retry) || R <- OtherListeners]
  +    end,
  +    close_db(Source).
   
   has_session_id(_SessionId, []) ->
       false;
  
positive.code: 
  handle_info({writer_checkpoint, SourceSeq}, #state{committed_seq=N} = State)
          when SourceSeq > N ->
      MissingRevs = State#state.missing_revs,
      ok = gen_server:cast(MissingRevs, {update_committed_seq, SourceSeq}),
      couch_task_status:update("W Processed source update #~p", [SourceSeq]),
  
negative.code:     ?LOG_ERROR("exit of linked Pid ~p with reason ~p", [Pid, Reason]),
      {stop, Reason, State}.
  
  terminate(normal, #state{checkpoint_scheduled=nil} = State) ->
      do_terminate(State);
      
  terminate(normal, State) ->
      timer:cancel(State#state.checkpoint_scheduled),
      do_terminate(do_checkpoint(State));
  
  terminate(Reason, State) ->
      #state{
  