| … | |
… | |
| 329 | # now or in the past already? |
329 | # now or in the past already? |
| 330 | if ($after <= 0) { |
330 | if ($after <= 0) { |
| 331 | $self->{_activity} = $NOW; |
331 | $self->{_activity} = $NOW; |
| 332 | |
332 | |
| 333 | if ($self->{on_timeout}) { |
333 | if ($self->{on_timeout}) { |
| 334 | $self->{on_timeout}->($self); |
334 | $self->{on_timeout}($self); |
| 335 | } else { |
335 | } else { |
| 336 | $! = Errno::ETIMEDOUT; |
336 | $! = Errno::ETIMEDOUT; |
| 337 | $self->error; |
337 | $self->error; |
| 338 | } |
338 | } |
| 339 | |
339 | |
| … | |
… | |
| 445 | @_ = ($WH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::push_write") |
445 | @_ = ($WH{$type} or Carp::croak "unsupported type passed to AnyEvent::Handle::push_write") |
| 446 | ->($self, @_); |
446 | ->($self, @_); |
| 447 | } |
447 | } |
| 448 | |
448 | |
| 449 | if ($self->{filter_w}) { |
449 | if ($self->{filter_w}) { |
| 450 | $self->{filter_w}->($self, \$_[0]); |
450 | $self->{filter_w}($self, \$_[0]); |
| 451 | } else { |
451 | } else { |
| 452 | $self->{wbuf} .= $_[0]; |
452 | $self->{wbuf} .= $_[0]; |
| 453 | $self->_drain_wbuf; |
453 | $self->_drain_wbuf; |
| 454 | } |
454 | } |
| 455 | } |
455 | } |
| … | |
… | |
| 661 | delete $self->{_rw}; |
661 | delete $self->{_rw}; |
| 662 | return; |
662 | return; |
| 663 | } |
663 | } |
| 664 | } |
664 | } |
| 665 | |
665 | |
| 666 | if ($self->{_eof}) { |
|
|
| 667 | $self->_shutdown; |
|
|
| 668 | $self->{on_eof}($self) |
666 | $self->{on_eof}($self) |
| 669 | if $self->{on_eof}; |
667 | if $self->{_eof} && $self->{on_eof}; |
| 670 | } |
|
|
| 671 | } |
668 | } |
| 672 | |
669 | |
| 673 | =item $handle->on_read ($cb) |
670 | =item $handle->on_read ($cb) |
| 674 | |
671 | |
| 675 | This replaces the currently set C<on_read> callback, or clears it (when |
672 | This replaces the currently set C<on_read> callback, or clears it (when |
| … | |
… | |
| 1056 | |
1053 | |
| 1057 | if ($len > 0) { |
1054 | if ($len > 0) { |
| 1058 | $self->{_activity} = AnyEvent->now; |
1055 | $self->{_activity} = AnyEvent->now; |
| 1059 | |
1056 | |
| 1060 | $self->{filter_r} |
1057 | $self->{filter_r} |
| 1061 | ? $self->{filter_r}->($self, $rbuf) |
1058 | ? $self->{filter_r}($self, $rbuf) |
| 1062 | : $self->_drain_rbuf; |
1059 | : $self->_drain_rbuf; |
| 1063 | |
1060 | |
| 1064 | } elsif (defined $len) { |
1061 | } elsif (defined $len) { |
| 1065 | delete $self->{_rw}; |
1062 | delete $self->{_rw}; |
| 1066 | $self->{_eof} = 1; |
1063 | $self->{_eof} = 1; |
