anchor.diff:          false ->
               {noreply, State}
       end;
  +handle_info({'EXIT', Pid, Reason}, #state{upstream_sender = SenderPid} = State) when Pid =:= SenderPid ->
  +    ?log_error("killing myself due to unexpected upstream sender exit with reason: ~p", [Reason]),
  +    {stop, {unexpected_upstream_sender_exit, Reason}, State};
   handle_info(Msg, State) ->
       ?log_info("handle_info(~p, ~p)", [Msg, State]),
       {noreply, State}.
  
positive.code:     Timeout = proplists:get_value(timeout, Opts, ?TIMEOUT_CHECK_INTERVAL),
      {ok, _TRef} = timer:send_interval(Timeout, check_for_timeout),
  
      State = #state{
        upstream=Upstream,
        downstream=Downstream,
        vbuckets=sets:from_list(ReadyVBuckets),
        last_seen=now(),
        takeover=TakeOver,
  
negative.code:         undefined -> ok;
          File -> file:write(File, Packet)
      end,
      State#state.upstream_sender ! Packet,
      State.
  
  
  