anchor.diff:                  validate_vbucket(VBucket, VBuckets),
                   State
           end,
  -    gen_tcp:send(Downstream, Packet),
  +    ok = gen_tcp:send(Downstream, Packet),
       State1.
   
   
  
positive.code:     proc_lib:init_ack({ok, self()}),
      Downstream = connect(Dst, Username, Password, Bucket),
      Upstream = connect(Src, Username, Password, Bucket),
      mc_client_binary:tap_connect(Upstream, [{vbuckets, VBuckets},
                                              {takeover, TakeOver}]),
      inet:setopts(Upstream, [{active, once}]),
      inet:setopts(Downstream, [{active, once}]),
      timer:send_interval(?TIMEOUT_CHECK_INTERVAL, check_for_timeout),
      State = #state{upstream=Upstream, downstream=Downstream,
                     vbuckets=sets:from_list(
                                case VBuckets of
  
negative.code:                                 #state{}.
  process_downstream(<<?RES_MAGIC:8, _/binary>> = Packet,
                     State) ->
      ok = gen_tcp:send(State#state.upstream, Packet),
      State.
  
  
  