| … | |
… | |
| 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 | |
