anchor.diff:                   #state{downstream=Downstream, vbuckets=VBuckets} = State) ->
       case Opcode of
           ?TAP_OPAQUE ->
  -            ok = gen_tcp:send(Downstream, Packet),
  +            ok = prim_inet:send(Downstream, Packet),
               case Rest of
                   <<?TAP_OPAQUE_INITIAL_VBUCKET_STREAM:32>> ->
                       (catch system_stats_collector:increment_counter(ebucketmigrator_backfill_starts, 1)),
  
positive.code:     end.
  
  read_tap_message(Sock) ->
      case gen_tcp:recv(Sock, ?HEADER_LEN) of
          {ok, <<_Magic:8, _Opcode:8, _KeyLen:16, _ExtLen:8, _DataType: 8,
                 _VBucket:16, BodyLen:32, _Opaque:32, _CAS:64>> = Packet} ->
              case BodyLen of
                  0 ->
                      {ok, Packet};
                  _ ->
                      case gen_tcp:recv(Sock, BodyLen) of
                          {ok, Extra} ->
                              {ok, <<Packet/binary, Extra/binary>>};
                          X1 ->
  
negative.code:                 end,
              case sets:is_element(VBucket, VBuckets) of
                  true ->
                      ok = prim_inet:send(Downstream, Packet),
                      State1#state{last_sent_seqno = Opaque};
                  false ->
                      %% Filter it out and count it
  