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.113 by root, Wed Jan 21 06:02:21 2009 UTC vs.
Revision 1.118 by root, Thu Feb 12 17:33:38 2009 UTC

… …
14 14
15AnyEvent::Handle - non-blocking I/O on file handles via AnyEvent 15AnyEvent::Handle - non-blocking I/O on file handles via AnyEvent
16 16
17=cut 17=cut
18 18
19our $VERSION = 4.331; 19our $VERSION = 4.34;
20 20
21=head1 SYNOPSIS 21=head1 SYNOPSIS
22 22
23 use AnyEvent; 23 use AnyEvent;
24 use AnyEvent::Handle; 24 use AnyEvent::Handle;
… …
127and no read request is in the queue (unlike read queue callbacks, this 127and no read request is in the queue (unlike read queue callbacks, this
128callback will only be called when at least one octet of data is in the 128callback will only be called when at least one octet of data is in the
129read buffer). 129read buffer).
130 130
131To access (and remove data from) the read buffer, use the C<< ->rbuf >> 131To access (and remove data from) the read buffer, use the C<< ->rbuf >>
132method or access the C<$handle->{rbuf}> member directly. 132method or access the C<$handle->{rbuf}> member directly. Note that you
133must not enlarge or modify the read buffer, you can only remove data at
134the beginning from it.
133 135
134When an EOF condition is detected then AnyEvent::Handle will first try to 136When an EOF condition is detected then AnyEvent::Handle will first try to
135feed all the remaining data to the queued callbacks and C<on_read> before 137feed all the remaining data to the queued callbacks and C<on_read> before
136calling the C<on_eof> callback. If no progress can be made, then a fatal 138calling the C<on_eof> callback. If no progress can be made, then a fatal
137error will be raised (with C<$!> set to C<EPIPE>). 139error will be raised (with C<$!> set to C<EPIPE>).
… …
767 ) { 769 ) {
768 $self->_error (&Errno::ENOSPC, 1), return; 770 $self->_error (&Errno::ENOSPC, 1), return;
769 } 771 }
770 772
771 while () { 773 while () {
774 # we need to use a separate tls read buffer, as we must not receive data while
775 # we are draining the buffer, and this can only happen with TLS.
776 $self->{rbuf} .= delete $self->{_tls_rbuf} if exists $self->{_tls_rbuf};
777
772 my $len = length $self->{rbuf}; 778 my $len = length $self->{rbuf};
773 779
774 if (my $cb = shift @{ $self->{_queue} }) { 780 if (my $cb = shift @{ $self->{_queue} }) {
775 unless ($cb->($self)) { 781 unless ($cb->($self)) {
776 if ($self->{_eof}) { 782 if ($self->{_eof}) {
… …
837 843
838=item $handle->rbuf 844=item $handle->rbuf
839 845
840Returns the read buffer (as a modifiable lvalue). 846Returns the read buffer (as a modifiable lvalue).
841 847
842You can access the read buffer directly as the C<< ->{rbuf} >> member, if 848You can access the read buffer directly as the C<< ->{rbuf} >>
843you want. 849member, if you want. However, the only operation allowed on the
850read buffer (apart from looking at it) is removing data from its
851beginning. Otherwise modifying or appending to it is not allowed and will
852lead to hard-to-track-down bugs.
844 853
845NOTE: The read buffer should only be used or modified if the C<on_read>, 854NOTE: The read buffer should only be used or modified if the C<on_read>,
846C<push_read> or C<unshift_read> methods are used. The other read methods 855C<push_read> or C<unshift_read> methods are used. The other read methods
847automatically manage the read buffer. 856automatically manage the read buffer.
848 857
… …
1188 1197
1189 $self->{rbuf} = $json->incr_text; 1198 $self->{rbuf} = $json->incr_text;
1190 $json->incr_text = ""; 1199 $json->incr_text = "";
1191 1200
1192 $self->_error (&Errno::EBADMSG); 1201 $self->_error (&Errno::EBADMSG);
1202
1193 () 1203 ()
1194
1195 } else { 1204 } else {
1196 $self->{rbuf} = ""; 1205 $self->{rbuf} = "";
1206
1197 () 1207 ()
1198 } 1208 }
1199 } 1209 }
1200}; 1210};
1201 1211
… …
1342 delete $self->{_rw}; 1352 delete $self->{_rw};
1343 $self->{_eof} = 1; 1353 $self->{_eof} = 1;
1344 &_freetls; 1354 &_freetls;
1345 } 1355 }
1346 1356
1347 $self->{rbuf} .= $tmp; 1357 $self->{_tls_rbuf} .= $tmp;
1348 $self->_drain_rbuf unless $self->{_in_drain}; 1358 $self->_drain_rbuf unless $self->{_in_drain};
1349 $self->{tls} or return; # tls session might have gone away in callback 1359 $self->{tls} or return; # tls session might have gone away in callback
1350 } 1360 }
1351 1361
1352 $tmp = Net::SSLeay::get_error ($self->{tls}, -1); 1362 $tmp = Net::SSLeay::get_error ($self->{tls}, -1);
1353 1363
1354 if ($tmp != Net::SSLeay::ERROR_WANT_READ ()) { 1364 if ($tmp != Net::SSLeay::ERROR_WANT_READ ()) {
1355 if ($tmp == Net::SSLeay::ERROR_SYSCALL ()) { 1365 if ($tmp == Net::SSLeay::ERROR_SYSCALL ()) {
1356 return $self->_error ($!, 1); 1366 return $self->_error ($!, 1);
1357 } elsif ($tmp == Net::SSLeay::ERROR_SSL ()) { 1367 } elsif ($tmp == Net::SSLeay::ERROR_SSL ()) {
1358 return $self->_error (&Errno::EIO, 1); 1368 return $self->_error (&Errno::EIO, 1);
1359 } 1369 }
1360 1370
1361 # all other errors are fine for our purposes 1371 # all other errors are fine for our purposes
1362 } 1372 }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines