| … | |
… | |
| 304 | |
304 | |
| 305 | if ($protocol eq "aemp" and $self->{hdl}) { |
305 | if ($protocol eq "aemp" and $self->{hdl}) { |
| 306 | # listener-less node need to continuously probe |
306 | # listener-less node need to continuously probe |
| 307 | unless (@$AnyEvent::MP::Kernel::LISTENER) { |
307 | unless (@$AnyEvent::MP::Kernel::LISTENER) { |
| 308 | $self->{hdl}->wtimeout ($timeout); |
308 | $self->{hdl}->wtimeout ($timeout); |
| 309 | $self->{hdl}->on_wtimeout (sub { $self->send ([]) }); |
309 | $self->{hdl}->on_wtimeout (sub { $self->{send}->([]) }); |
| 310 | } |
310 | } |
| 311 | |
311 | |
| 312 | # receive handling |
312 | # receive handling |
| 313 | |
313 | |
| 314 | my $push_write = $hdl->can ("push_write"); |
314 | my $push_write = $hdl->can ("push_write"); |
