anchor.diff:          #rep_state{} ->
               ok
           end,
  -        true = ets:delete(?DOC_TO_REP, DocId);
  +        true = ets:delete(?DOC_TO_REP, {DbName, DocId});
       _ ->
           ok
       end.
   
   
  -rep_doc_deleted(DocId) ->
  -    case ets:lookup(?DOC_TO_REP, DocId) of
  -    [{DocId, RepId}] ->
  +rep_doc_deleted(DbName, DocId) ->
  +    case ets:lookup(?DOC_TO_REP, {DbName, DocId}) of
  +    [{{DbName, DocId}, RepId}] ->
           couch_replicator:cancel_replication(RepId),
           true = ets:delete(?REP_TO_STATE, RepId),
  -        true = ets:delete(?DOC_TO_REP, DocId),
  +        true = ets:delete(?DOC_TO_REP, {DbName, DocId}),
           twig:log(notice, "Stopped replication `~s` because replication document `~s`"
               " was deleted", [pp_rep_id(RepId), DocId]);
       [] ->
  
positive.code: 
  maybe_retry_replication(#rep_state{retries_left = 0} = RepState, Error, State) ->
      #rep_state{
          rep = #rep{id = RepId, doc_id = DocId},
          max_retries = MaxRetries
      } = RepState,
      couch_replicator:cancel_replication(RepId),
      true = ets:delete(?REP_TO_STATE, RepId),
      true = ets:delete(?DOC_TO_REP, DocId),
      twig:log(error, "Error in replication `~s` (triggered by document `~s`): ~s"
          "~nReached maximum retry attempts (~p).",
          [pp_rep_id(RepId), DocId, to_binary(error_reason(Error)), MaxRetries]),
  
negative.code:             max_retries = State#state.max_retries
          },
          true = ets:insert(?REP_TO_STATE, {RepId, RepState}),
          true = ets:insert(?DOC_TO_REP, {{DbName, DocId}, RepId}),
          twig:log(notice,"Attempting to start replication `~s` (document `~s`).",
              [pp_rep_id(RepId), DocId]),
          Pid = spawn_link(fun() -> start_replication(Rep, 0) end),
  