anchor.diff:          ok ->
               ok = xdcr_dcp_sockets_pool:put_socket(Bucket, S);
           stop ->
  -            ?log_debug("Got stop. Dropping socket on the floor")
  +            ?xdcr_debug("Got stop. Dropping socket on the floor")
       end.
   
   
  
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:                                SnapshotStart, SnapshotEnd, LastSeenSeqno,
                                 NewData);
          {'EXIT', _From, Reason} = 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
  