anchor.diff:      gen_server:cast(Parent, {report_error, Err}),
       {noreply, State};
   
  -handle_cast({report_seq, Seq, SnapshotStart, SnapshotEnd},
  +handle_cast({report_seq, Seq, _SnapshotStart, _SnapshotEnd},
               #rep_state{seqs_in_progress = SeqsInProgress} = State) ->
  -    case xdc_rep_utils:is_new_xdcr_path() of
  -        true ->
  -            ets:insert(erlang:get(work_seq_to_snapshot_seq),
  -                       {Seq, SnapshotStart, SnapshotEnd});
  -        _ ->
  -            ok
  -    end,
       NewSeqsInProgress = ordsets:add_element(Seq, SeqsInProgress),
       {noreply, State#rep_state{seqs_in_progress = NewSeqsInProgress}}.
   
  
positive.code: init(#init_state{init_throttle = InitThrottle} = InitState) ->
      process_flag(trap_exit, true),
      %% signal to self to initialize
      Tid = ets:new(work_seq_to_snapshot_seq, [private, set]),
      erlang:put(work_seq_to_snapshot_seq, Tid),
      ok = concurrency_throttle:send_back_when_can_go(InitThrottle, init),
      {ok, InitState}.
  
  
negative.code:     gen_server:reply(From, ok),
      case xdc_rep_utils:is_new_xdcr_path() of
          true ->
              true = (CurrentSnapshotSeq =< SnapshotStart);
          _ -> ok
      end,
  