… | |
… | |
392 | delete $self->{keepalive}; |
392 | delete $self->{keepalive}; |
393 | |
393 | |
394 | if ($self->{protocol}) { |
394 | if ($self->{protocol}) { |
395 | $HOOK_PROTOCOL{$self->{protocol}}->($self, $msg); |
395 | $HOOK_PROTOCOL{$self->{protocol}}->($self, $msg); |
396 | } else { |
396 | } else { |
397 | AE::log 8 => "$self->{peerhost}:$self->{peerport} $msg."; |
397 | AE::log 9 => "$self->{peerhost}:$self->{peerport} $msg."; |
398 | |
398 | |
399 | $self->{node}->transport_error (transport_error => $self->{node}{id}, $msg) |
399 | $self->{node}->transport_error (transport_error => $self->{node}{id}, $msg) |
400 | if $self->{node} && $self->{node}{transport} == $self; |
400 | if $self->{node} && $self->{node}{transport} == $self; |
401 | } |
401 | } |
402 | |
402 | |