ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/lib/AnyEvent/Handle.pm
(Generate patch)

Comparing AnyEvent/lib/AnyEvent/Handle.pm (file contents):
Revision 1.168 by root, Fri Jul 31 07:34:00 2009 UTC vs.
Revision 1.170 by root, Sat Aug 1 09:14:54 2009 UTC

11 11
12AnyEvent::Handle - non-blocking I/O on file handles via AnyEvent 12AnyEvent::Handle - non-blocking I/O on file handles via AnyEvent
13 13
14=cut 14=cut
15 15
16our $VERSION = 4.881; 16our $VERSION = 4.9;
17 17
18=head1 SYNOPSIS 18=head1 SYNOPSIS
19 19
20 use AnyEvent; 20 use AnyEvent;
21 use AnyEvent::Handle; 21 use AnyEvent::Handle;
994 994
995 # avoid recursion 995 # avoid recursion
996 return if $self->{_skip_drain_rbuf}; 996 return if $self->{_skip_drain_rbuf};
997 local $self->{_skip_drain_rbuf} = 1; 997 local $self->{_skip_drain_rbuf} = 1;
998 998
999 if (
1000 defined $self->{rbuf_max}
1001 && $self->{rbuf_max} < length $self->{rbuf}
1002 ) {
1003 $self->_error (Errno::ENOSPC, 1), return;
1004 }
1005
1006 while () { 999 while () {
1007 # we need to use a separate tls read buffer, as we must not receive data while 1000 # we need to use a separate tls read buffer, as we must not receive data while
1008 # we are draining the buffer, and this can only happen with TLS. 1001 # we are draining the buffer, and this can only happen with TLS.
1009 $self->{rbuf} .= delete $self->{_tls_rbuf} 1002 $self->{rbuf} .= delete $self->{_tls_rbuf}
1010 if exists $self->{_tls_rbuf}; 1003 if exists $self->{_tls_rbuf};
1049 $self->{on_eof} 1042 $self->{on_eof}
1050 ? $self->{on_eof}($self) 1043 ? $self->{on_eof}($self)
1051 : $self->_error (0, 1, "Unexpected end-of-file"); 1044 : $self->_error (0, 1, "Unexpected end-of-file");
1052 1045
1053 return; 1046 return;
1047 }
1048
1049 if (
1050 defined $self->{rbuf_max}
1051 && $self->{rbuf_max} < length $self->{rbuf}
1052 ) {
1053 $self->_error (Errno::ENOSPC, 1), return;
1054 } 1054 }
1055 1055
1056 # may need to restart read watcher 1056 # may need to restart read watcher
1057 unless ($self->{_rw}) { 1057 unless ($self->{_rw}) {
1058 $self->start_read 1058 $self->start_read

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines