anchor.diff:      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),
  +    {ok, quiet} = mc_client_binary:tap_connect(Upstream, [{vbuckets, VBuckets},
  +                                                          {takeover, TakeOver}]),
  +    ok = inet:setopts(Upstream, [{active, once}]),
  +    ok = inet:setopts(Downstream, [{active, once}]),
  +    {ok, _TRef} = timer:send_interval(?TIMEOUT_CHECK_INTERVAL,
  +                                      check_for_timeout),
       State = #state{upstream=Upstream, downstream=Downstream,
                      vbuckets=sets:from_list(
                                 case VBuckets of
  
positive.code:                 validate_vbucket(VBucket, VBuckets),
                  State
          end,
      gen_tcp:send(Downstream, Packet),
      State1.
  
  
  
negative.code:                                 #state{}.
  process_downstream(<<?RES_MAGIC:8, _/binary>> = Packet,
                     State) ->
      ok = gen_tcp:send(State#state.upstream, Packet),
      State.
  
  
  