anchor.diff:  
               {ok, #state{from=From, listen_addr=ListenAddr, channel=Channel, socket=Socket, peer=Peer}};
           Error ->
  -            lager:warning("unable to connect to ~p due to ~p",
  -                          [Peer, Error]),
  +            lager:warning("Pid ~p is unable to connect to ~p due to ~p", [self(), Peer, Error]),
               {stop, normal}
       end.
   
  
positive.code: %% @private
  -spec handle_info(term(), state_t()) -> {noreply, state_t()}.
  handle_info({Tag, _Socket, Data}, State0) when ?DATA_MSG(Tag) ->
      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]),
      {stop, normal, State};
  handle_info(Msg, State) ->
      lager:warning("Unhandled info messages at module ~p: ~p", [?MODULE, Msg]),
  
negative.code: -spec handle_cast(term(), state_t()) -> {noreply, state_t()}.
  %% @private
  handle_cast({send_message, Message}, #state{channel=_Channel, socket=Socket}=State) ->
      lager:info("Received cast: ~p", [Message]),
      case get({?MODULE, egress_delay}) of
          0 ->
              ok;
  