anchor.diff:          "Replication",
            io_lib:format("`~s`: `~s` -> `~s`",
               [BaseId ++ Ext, SourceName, TargetName]),
  -        "Starting" ++ case StartSeq of
  -            ?LOWEST_SEQ ->
  -                "";
  -            _ ->
  -                " (from source sequence " ++ integer_to_list(StartSeq) ++ ")"
  -            end),
  +         io_lib:format("Processed ~p / ~p changes", [StartSeq, SourceCurSeq])),
   
       % Until OTP R14B03:
       %
  
positive.code:         "Seqs in progress were: ~p~nSeqs in progress are now: ~p",
          [Seq, ThroughSeq, NewThroughSeq, HighestDone,
              NewHighestDone, SeqsInProgress, NewSeqsInProgress]),
      case NewThroughSeq of
      ThroughSeq ->
          ok;
      _ ->
          couch_task_status:update("Processed source seq ~p", [NewThroughSeq])
      end,
      NewState = State#rep_state{
          stats = sum_stats([Stats, StatsInc]),
          current_through_seq = NewThroughSeq,
          seqs_in_progress = NewSeqsInProgress,
          highest_seq_done = NewHighestDone
      },
      {noreply, NewState};
  
  
negative.code:         target_db_compaction_notifier =
              start_db_compaction_notifier(Target, self()),
          source_monitor = db_monitor(Source),
          target_monitor = db_monitor(Target),
          source_seq = get_value(<<"update_seq">>, SourceInfo, ?LOWEST_SEQ)
      },
      State#rep_state{timer = start_timer(State)}.
  
  