anchor.diff:          target = Target,
           source_name = SourceName,
           target_name = TargetName,
  -        start_seq = StartSeq
  +        start_seq = StartSeq,
  +        source_seq = SourceCurSeq
       } = State = init_state(Rep),
   
       CopiersCount = get_value(worker_processes, Options),
  
positive.code:         target_db_compaction_notifier =
              start_db_compaction_notifier(Target, self()),
          source_monitor = db_monitor(Source),
          target_monitor = db_monitor(Target)
      },
      State#rep_state{timer = start_timer(State)}.
  
  
negative.code:     couch_db:monitor(Db);
  db_monitor(_HttpDb) ->
      nil.
  
  
  source_cur_seq(#rep_state{source = #httpdb{} = Db, source_seq = Seq}) ->
      case (catch couch_api_wrap:get_db_info(Db#httpdb{retries = 3})) of
      {ok, Info} ->
          get_value(<<"update_seq">>, Info, Seq);
      _ ->
          Seq
      end;
  source_cur_seq(#rep_state{source = Db, source_seq = Seq}) ->
      {ok, Info} = couch_api_wrap:get_db_info(Db),
      get_value(<<"update_seq">>, Info, Seq).
  