… | |
… | |
393 | delete $self->{keepalive}; |
393 | delete $self->{keepalive}; |
394 | |
394 | |
395 | if ($self->{protocol}) { |
395 | if ($self->{protocol}) { |
396 | $HOOK_PROTOCOL{$self->{protocol}}->($self, $msg); |
396 | $HOOK_PROTOCOL{$self->{protocol}}->($self, $msg); |
397 | } else { |
397 | } else { |
398 | AE::log 8 => "$self->{peerhost}:$self->{peerport} $msg"; |
398 | AE::log 8 => "$self->{peerhost}:$self->{peerport} $msg."; |
399 | |
399 | |
400 | $self->{node}->transport_error (transport_error => $self->{node}{id}, $msg) |
400 | $self->{node}->transport_error (transport_error => $self->{node}{id}, $msg) |
401 | if $self->{node} && $self->{node}{transport} == $self; |
401 | if $self->{node} && $self->{node}{transport} == $self; |
402 | } |
402 | } |
403 | |
403 | |
… | |
… | |
414 | |
414 | |
415 | if ($self->{protocol}) { |
415 | if ($self->{protocol}) { |
416 | $self->{hdl}->on_error (undef); |
416 | $self->{hdl}->on_error (undef); |
417 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
417 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
418 | } else { |
418 | } else { |
419 | AE::log 9 => "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}"; |
419 | AE::log 9 => "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}."; |
420 | |
420 | |
421 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
421 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
422 | Scalar::Util::weaken ($self->{node} = $node); |
422 | Scalar::Util::weaken ($self->{node} = $node); |
423 | $node->transport_connect ($self); |
423 | $node->transport_connect ($self); |
424 | |
424 | |