anchor.diff:      Timeout = proplists:get_value(timeout, Opts, ?TIMEOUT_CHECK_INTERVAL),
       {ok, _TRef} = timer:send_interval(Timeout, check_for_timeout),
   
  +    UpstreamSender = spawn_link(erlang, apply, [fun upstream_sender_loop/1, [Upstream]]),
  +    ?log_info("upstream_sender pid: ~p", [UpstreamSender]),
  +
       State = #state{
         upstream=Upstream,
         downstream=Downstream,
  +      upstream_sender = UpstreamSender,
         vbuckets=sets:from_list(ReadyVBuckets),
         last_seen=now(),
         takeover=TakeOver,
  
positive.code:      },
      erlang:process_flag(trap_exit, true),
      gen_server:enter_loop(?MODULE, [], maybe_setup_dumping(State, Args)).
  
  -spec maybe_setup_dumping(#state{}, term()) -> #state{}.
  maybe_setup_dumping(State, Args) ->
  
negative.code:         undefined -> ok;
          File -> file:write(File, Packet)
      end,
      State#state.upstream_sender ! Packet,
      State.
  
  
  