anchor.diff:                  vbuckets,
                   takeover :: boolean(),
                   takeover_msgs_seen = 0 :: non_neg_integer(),
  -                last_seen}).
  +                last_seen,
  +                dump_file :: file:io_device() | undefined
  +               }).
   
   %% external API
   -export([start_link/3]).
  
positive.code:                                 #state{}.
  process_downstream(<<?RES_MAGIC:8, _/binary>> = Packet,
                     State) ->
      ok = gen_tcp:send(State#state.upstream, Packet),
      State.
  
  
negative.code:             {name, Name},
              {takeover, TakeOver}],
      ?log_info("Starting tap stream:~n~p~n", [Args]),
      {ok, quiet} = mc_client_binary:tap_connect(Upstream, Args),
      ok = inet:setopts(Upstream, [{active, once}]),
      ok = inet:setopts(Downstream, [{active, once}]),
  
  