anchor.diff:          {failover_id, _FailoverUUID, StartSeqno, _, SnapshotStart, SnapshotEnd} = Evt ->
               {ok, Acc2} = Callback(Evt, Acc),
               consumer_loop_recv(Child, Callback, Acc2, 0,
  -                               SnapshotStart, SnapshotEnd, StartSeqno, <<>>)
  +                               SnapshotStart, SnapshotEnd, StartSeqno,
  +                               <<>>, 0, 0)
       end.
   
   consumer_loop_recv(Child, Callback, Acc, ConsumedSoFar0,
                      SnapshotStart, SnapshotEnd, LastSeenSeqno,
  -                   PrevData) ->
  +                   Data, Len, NeedLen) ->
       ConsumedSoFar =
           case ConsumedSoFar0 >= ?XDCR_DCP_BUFFER_SIZE div 3 of
               true ->
  
positive.code:             case Callback(OtherMsg, Acc) of
                  {ok, Acc2} ->
                      consumer_loop_recv(Child, Callback, Acc2, ConsumedSoFar,
                                         SnapshotStart, SnapshotEnd, LastSeenSeqno, PrevData);
                  {stop, RV} ->
                      consumer_loop_exit(Child, stop, []),
                      RV
              end
      end.
  
negative.code: 
  -export([test/0]).
  
  -export([encode_req/1, encode_res/1, read_message_loop/2]).
  
  encode_req(#dcp_packet{opcode = Opcode,
                         datatype = DT,
  