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.112 by root, Wed Jan 21 06:01:35 2009 UTC vs.
Revision 1.120 by root, Fri Mar 27 08:33:41 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.341;
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
… …
1172 my $rbuf = \$self->{rbuf}; 1181 my $rbuf = \$self->{rbuf};
1173 1182
1174 my $json = $self->{json} ||= JSON->new->utf8; 1183 my $json = $self->{json} ||= JSON->new->utf8;
1175 1184
1176 sub { 1185 sub {
1177 eval {
1178 my $ref = $json->incr_parse ($self->{rbuf}); 1186 my $ref = eval { $json->incr_parse ($self->{rbuf}) };
1179 1187
1180 if ($ref) { 1188 if ($ref) {
1181 $self->{rbuf} = $json->incr_text; 1189 $self->{rbuf} = $json->incr_text;
1182 $json->incr_text = ""; 1190 $json->incr_text = "";
1183 $cb->($self, $ref); 1191 $cb->($self, $ref);
1184
1185 1
1186 } else {
1187 $self->{rbuf} = "";
1188 ()
1189 }
1190 1192
1191 1 1193 1
1192 } or do { 1194 } elsif ($@) {
1193 # error case 1195 # error case
1194 $json->incr_skip; 1196 $json->incr_skip;
1195 1197
1196 $self->{rbuf} = $json->incr_text; 1198 $self->{rbuf} = $json->incr_text;
1197 $json->incr_text = ""; 1199 $json->incr_text = "";
1198 1200
1199 $self->_error (&Errno::EBADMSG); 1201 $self->_error (&Errno::EBADMSG);
1202
1203 ()
1204 } else {
1205 $self->{rbuf} = "";
1206
1207 ()
1200 }; 1208 }
1201 } 1209 }
1202}; 1210};
1203 1211
1204=item storable => $cb->($handle, $ref) 1212=item storable => $cb->($handle, $ref)
1205 1213
… …
1344 delete $self->{_rw}; 1352 delete $self->{_rw};
1345 $self->{_eof} = 1; 1353 $self->{_eof} = 1;
1346 &_freetls; 1354 &_freetls;
1347 } 1355 }
1348 1356
1349 $self->{rbuf} .= $tmp; 1357 $self->{_tls_rbuf} .= $tmp;
1350 $self->_drain_rbuf unless $self->{_in_drain}; 1358 $self->_drain_rbuf unless $self->{_in_drain};
1351 $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
1352 } 1360 }
1353 1361
1354 $tmp = Net::SSLeay::get_error ($self->{tls}, -1); 1362 $tmp = Net::SSLeay::get_error ($self->{tls}, -1);
1355 1363
1356 if ($tmp != Net::SSLeay::ERROR_WANT_READ ()) { 1364 if ($tmp != Net::SSLeay::ERROR_WANT_READ ()) {
1357 if ($tmp == Net::SSLeay::ERROR_SYSCALL ()) { 1365 if ($tmp == Net::SSLeay::ERROR_SYSCALL ()) {
1358 return $self->_error ($!, 1); 1366 return $self->_error ($!, 1);
1359 } elsif ($tmp == Net::SSLeay::ERROR_SSL ()) { 1367 } elsif ($tmp == Net::SSLeay::ERROR_SSL ()) {
1360 return $self->_error (&Errno::EIO, 1); 1368 return $self->_error (&Errno::EIO, 1);
1361 } 1369 }
1362 1370
1363 # all other errors are fine for our purposes 1371 # all other errors are fine for our purposes
1364 } 1372 }
… …
1465 1473
1466 delete @$self{qw(_rbio _wbio _tls_wbuf)}; 1474 delete @$self{qw(_rbio _wbio _tls_wbuf)};
1467} 1475}
1468 1476
1469sub DESTROY { 1477sub DESTROY {
1470 my $self = shift; 1478 my ($self) = @_;
1471 1479
1472 &_freetls; 1480 &_freetls;
1473 1481
1474 my $linger = exists $self->{linger} ? $self->{linger} : 3600; 1482 my $linger = exists $self->{linger} ? $self->{linger} : 3600;
1475 1483

Diff Legend

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