| … | |
… | |
| 287 | $hdl->rbuf_max (undef); |
287 | $hdl->rbuf_max (undef); |
| 288 | my $queue = delete $self->{queue}; # we are connected |
288 | my $queue = delete $self->{queue}; # we are connected |
| 289 | |
289 | |
| 290 | $self->{hdl}->rtimeout ($self->{remote_greeting}{timeout}); |
290 | $self->{hdl}->rtimeout ($self->{remote_greeting}{timeout}); |
| 291 | $self->{hdl}->wtimeout ($arg{timeout} - LATENCY); |
291 | $self->{hdl}->wtimeout ($arg{timeout} - LATENCY); |
| 292 | $self->{hdl}->on_wtimeout (sub { $self->send (["", "devnull"]) }); |
292 | $self->{hdl}->on_wtimeout (sub { $self->send ([]) }); |
| 293 | |
293 | |
| 294 | $self->connected; |
294 | $self->connected; |
| 295 | |
295 | |
| 296 | # send queued messages |
296 | # send queued messages |
| 297 | $self->send ($_) |
297 | $self->send ($_) |
