| … | |
… | |
| 356 | sub connected { |
356 | sub connected { |
| 357 | my ($self) = @_; |
357 | my ($self) = @_; |
| 358 | |
358 | |
| 359 | delete $self->{keepalive}; |
359 | delete $self->{keepalive}; |
| 360 | |
360 | |
| 361 | (delete $self->{release})->() |
|
|
| 362 | if exists $self->{release}; |
|
|
| 363 | |
|
|
| 364 | if ($self->{protocol}) { |
361 | if ($self->{protocol}) { |
| 365 | $self->{hdl}->on_error (undef); |
362 | $self->{hdl}->on_error (undef); |
| 366 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
363 | $HOOK_PROTOCOL{$self->{protocol}}->($self, undef); |
| 367 | } else { |
364 | } else { |
| 368 | $AnyEvent::MP::Kernel::WARN->(9, "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}"); |
365 | $AnyEvent::MP::Kernel::WARN->(9, "$self->{peerhost}:$self->{peerport} connected as $self->{remote_node}"); |
| … | |
… | |
| 371 | Scalar::Util::weaken ($self->{node} = $node); |
368 | Scalar::Util::weaken ($self->{node} = $node); |
| 372 | $node->transport_connect ($self); |
369 | $node->transport_connect ($self); |
| 373 | |
370 | |
| 374 | $_->($self) for @HOOK_CONNECTED; |
371 | $_->($self) for @HOOK_CONNECTED; |
| 375 | } |
372 | } |
|
|
373 | |
|
|
374 | (delete $self->{release})->() |
|
|
375 | if exists $self->{release}; |
| 376 | } |
376 | } |
| 377 | |
377 | |
| 378 | sub send { |
378 | sub send { |
| 379 | $_[0]{hdl}->push_write ($_[0]{s_framing} => $_[1]); |
379 | $_[0]{hdl}->push_write ($_[0]{s_framing} => $_[1]); |
| 380 | } |
380 | } |
