anchor.diff:  %% @private
   -spec handle_info(term(), state_t()) -> {noreply, state_t()}.
   handle_info({Tag, _Socket, Data}, State0) when ?DATA_MSG(Tag) ->
  +    lager:info("Received info message at ~p: ~p", [self(), decode(Data)]),
       handle_message(decode(Data), State0);
  -handle_info({Tag, _Socket}, #state{peer = _Peer} = State) when ?CLOSED_MSG(Tag) ->
  -    % lager:info("connection to ~p has been closed", [Peer]),
  +handle_info({Tag, _Socket}, #state{peer = Peer} = State) when ?CLOSED_MSG(Tag) ->
  +    lager:info("Connection to ~p has been closed for pid ~p", [Peer, self()]),
       {stop, normal, State};
   handle_info(Msg, State) ->
       lager:warning("Unhandled info messages at module ~p: ~p", [?MODULE, Msg]),
  
positive.code: -spec handle_cast(term(), state_t()) -> {noreply, state_t()}.
  %% @private
  handle_cast({send_message, Message}, #state{channel=_Channel, socket=Socket}=State) ->
      case get({?MODULE, egress_delay}) of
          0 ->
              ok;
  
negative.code:             {noreply, State};
          _ ->
              %% If the peer isn't who it should be, abort.
              lager:error("Pid: ~p peer ~p isn't ~p.", [self(), Node, Peer]),
              {stop, {unexpected_peer, Node, Peer}, State}
      end;
  
  handle_message(Message, State) ->
      lager:info("Pid received invalid message: ~p", [self(), Message]),
      {stop, normal, State}.
  
  %% @private
  