anchor.diff:      gen_server:reply(From, ok),
       case xdc_rep_utils:is_new_xdcr_path() of
           true ->
  -            %% note: that left-hand variables are bound
  -            [{Seq, SnapshotStart, SnapshotEnd}] = ets:lookup(erlang:get(work_seq_to_snapshot_seq), Seq),
  -            _ = ets:delete(erlang:get(work_seq_to_snapshot_seq), Seq),
  -
               true = (CurrentSnapshotSeq =< SnapshotStart);
           _ -> ok
       end,
  
positive.code:     gen_server:cast(Parent, {report_error, Err}),
      {noreply, State};
  
  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}}.
  
  
negative.code: init(#init_state{init_throttle = InitThrottle} = InitState) ->
      process_flag(trap_exit, true),
      %% signal to self to initialize
      ok = concurrency_throttle:send_back_when_can_go(InitThrottle, init),
      {ok, InitState}.
  
  