… | |
… | |
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 | $AnyEvent::MP::Kernel::WARN->(9, "$self->{peerhost}:$self->{peerport} $msg");#d# |
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 | |
404 | (delete $self->{release})->() |
404 | (delete $self->{release})->() |
405 | if exists $self->{release}; |
405 | if exists $self->{release}; |
406 | |
406 | |
407 | # $AnyEvent::MP::Kernel::WARN->(7, "$self->{peerhost}:$self->{peerport}: $msg"); |
|
|
408 | $self->destroy; |
407 | $self->destroy; |
409 | } |
408 | } |
410 | |
409 | |
411 | sub connected { |
410 | sub connected { |
412 | my ($self) = @_; |
411 | my ($self) = @_; |
… | |
… | |
415 | |
414 | |
416 | if ($self->{protocol}) { |
415 | if ($self->{protocol}) { |
417 | $self->{hdl}->on_error (undef); |
416 | $self->{hdl}->on_error (undef); |
418 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
417 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
419 | } else { |
418 | } else { |
420 | $AnyEvent::MP::Kernel::WARN->(9, "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}"); |
419 | AE::log 9 => "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}"; |
421 | |
420 | |
422 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
421 | my $node = AnyEvent::MP::Kernel::add_node ($self->{remote_node}); |
423 | Scalar::Util::weaken ($self->{node} = $node); |
422 | Scalar::Util::weaken ($self->{node} = $node); |
424 | $node->transport_connect ($self); |
423 | $node->transport_connect ($self); |
425 | |
424 | |