anchor.diff:                                 SnapshotStart, SnapshotEnd, LastSeenSeqno,
                                  NewData);
           {'EXIT', _From, Reason} = ExitMsg ->
  -            ?log_debug("Got exit signal: ~p", [ExitMsg]),
  +            ?xdcr_debug("Got exit signal: ~p", [ExitMsg]),
               exit(Reason);
           %% this is handling please_stop message for xdc_vbucket_rep
           %% changes reader loop efficiently, i.e. without selective
  
positive.code:                     SnapshotStart = ActualSnapshotStart,
                      {Data1, ActualSnapshotEnd0};
                  {_, EndPacket = #dcp_packet{opcode = ?DCP_STREAM_END}, <<>>, _} ->
                      ?log_debug("Got stream end without snapshot marker"),
                      %% it's only possible if all those values are same
                      %%
                      %% * immediate end stream is only possible if
  
negative.code:             proc_lib:init_ack({ok, self()}),
              socket_loop_enter(Socket, Callback, Acc, Data2, Parent);
          #dcp_packet{status = ?ROLLBACK, body = <<RollbackSeq:64>>} ->
              ?xdcr_debug("handling rollback to ~B", [RollbackSeq]),
              ?xdcr_debug("Request was: ~p", [{Vb, Opaque, StartSeqno, EndSeqno,
                                              FailoverId, SnapshotStart, SnapshotEnd}]),
              %% in case of xdcr we cannot rewind the destination. So we
              %% just "formally" rollback our start point to resume
  