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:         target = Target,
          source_name = SourceName,
          target_name = TargetName,
          start_seq = StartSeq
      } = State = init_state(Rep),
  
      CopiersCount = get_value(worker_processes, Options),
  
negative.code:         "Seqs in progress were: ~p~nSeqs in progress are now: ~p",
          [Seq, ThroughSeq, NewThroughSeq, HighestDone,
              NewHighestDone, SeqsInProgress, NewSeqsInProgress]),
      SourceCurSeq = source_cur_seq(State),
      couch_task_status:update(
          "Processed ~p / ~p changes", [NewThroughSeq, SourceCurSeq]),
      NewState = State#rep_state{
          stats = sum_stats([Stats, StatsInc]),
          current_through_seq = NewThroughSeq,
          seqs_in_progress = NewSeqsInProgress,
          highest_seq_done = NewHighestDone,
          source_seq = SourceCurSeq
      },
      {noreply, NewState};
  
  