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.69 by root, Sun Jun 15 21:44:56 2008 UTC vs.
Revision 1.82 by root, Thu Aug 21 18:45:16 2008 UTC

1package AnyEvent::Handle; 1package AnyEvent::Handle;
2 2
3no warnings; 3no warnings;
4use strict; 4use strict qw(subs vars);
5 5
6use AnyEvent (); 6use AnyEvent ();
7use AnyEvent::Util qw(WSAEWOULDBLOCK); 7use AnyEvent::Util qw(WSAEWOULDBLOCK);
8use Scalar::Util (); 8use Scalar::Util ();
9use Carp (); 9use Carp ();
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.151; 19our $VERSION = 4.232;
20 20
21=head1 SYNOPSIS 21=head1 SYNOPSIS
22 22
23 use AnyEvent; 23 use AnyEvent;
24 use AnyEvent::Handle; 24 use AnyEvent::Handle;
75NOTE: The filehandle will be set to non-blocking (using 75NOTE: The filehandle will be set to non-blocking (using
76AnyEvent::Util::fh_nonblocking). 76AnyEvent::Util::fh_nonblocking).
77 77
78=item on_eof => $cb->($handle) 78=item on_eof => $cb->($handle)
79 79
80Set the callback to be called when an end-of-file condition is detcted, 80Set the callback to be called when an end-of-file condition is detected,
81i.e. in the case of a socket, when the other side has closed the 81i.e. in the case of a socket, when the other side has closed the
82connection cleanly. 82connection cleanly.
83 83
84For sockets, this just means that the other side has stopped sending data,
85you can still try to write data, and, in fact, one can return from the eof
86callback and continue writing data, as only the read part has been shut
87down.
88
84While not mandatory, it is highly recommended to set an eof callback, 89While not mandatory, it is I<highly> recommended to set an eof callback,
85otherwise you might end up with a closed socket while you are still 90otherwise you might end up with a closed socket while you are still
86waiting for data. 91waiting for data.
92
93If an EOF condition has been detected but no C<on_eof> callback has been
94set, then a fatal error will be raised with C<$!> set to <0>.
87 95
88=item on_error => $cb->($handle, $fatal) 96=item on_error => $cb->($handle, $fatal)
89 97
90This is the error callback, which is called when, well, some error 98This is the error callback, which is called when, well, some error
91occured, such as not being able to resolve the hostname, failure to 99occured, such as not being able to resolve the hostname, failure to
92connect or a read error. 100connect or a read error.
93 101
94Some errors are fatal (which is indicated by C<$fatal> being true). On 102Some errors are fatal (which is indicated by C<$fatal> being true). On
95fatal errors the handle object will be shut down and will not be 103fatal errors the handle object will be shut down and will not be usable
104(but you are free to look at the current C< ->rbuf >). Examples of fatal
105errors are an EOF condition with active (but unsatisifable) read watchers
106(C<EPIPE>) or I/O errors.
107
96usable. Non-fatal errors can be retried by simply returning, but it is 108Non-fatal errors can be retried by simply returning, but it is recommended
97recommended to simply ignore this parameter and instead abondon the handle 109to simply ignore this parameter and instead abondon the handle object
98object when this callback is invoked. 110when this callback is invoked. Examples of non-fatal errors are timeouts
111C<ETIMEDOUT>) or badly-formatted data (C<EBADMSG>).
99 112
100On callback entrance, the value of C<$!> contains the operating system 113On callback entrance, the value of C<$!> contains the operating system
101error (or C<ENOSPC>, C<EPIPE>, C<ETIMEDOUT> or C<EBADMSG>). 114error (or C<ENOSPC>, C<EPIPE>, C<ETIMEDOUT> or C<EBADMSG>).
102 115
103While not mandatory, it is I<highly> recommended to set this callback, as 116While not mandatory, it is I<highly> recommended to set this callback, as
162be configured to accept only so-and-so much data that it cannot act on 175be configured to accept only so-and-so much data that it cannot act on
163(for example, when expecting a line, an attacker could send an unlimited 176(for example, when expecting a line, an attacker could send an unlimited
164amount of data without a callback ever being called as long as the line 177amount of data without a callback ever being called as long as the line
165isn't finished). 178isn't finished).
166 179
180=item autocork => <boolean>
181
182When disabled (the default), then C<push_write> will try to immediately
183write the data to the handle if possible. This avoids having to register
184a write watcher and wait for the next event loop iteration, but can be
185inefficient if you write multiple small chunks (this disadvantage is
186usually avoided by your kernel's nagle algorithm, see C<low_delay>).
187
188When enabled, then writes will always be queued till the next event loop
189iteration. This is efficient when you do many small writes per iteration,
190but less efficient when you do a single write only.
191
192=item no_delay => <boolean>
193
194When doing small writes on sockets, your operating system kernel might
195wait a bit for more data before actually sending it out. This is called
196the Nagle algorithm, and usually it is beneficial.
197
198In some situations you want as low a delay as possible, which cna be
199accomplishd by setting this option to true.
200
201The default is your opertaing system's default behaviour, this option
202explicitly enables or disables it, if possible.
203
167=item read_size => <bytes> 204=item read_size => <bytes>
168 205
169The default read block size (the amount of bytes this module will try to read 206The default read block size (the amount of bytes this module will try to read
170during each (loop iteration). Default: C<8192>. 207during each (loop iteration). Default: C<8192>.
171 208
201You can also provide your own TLS connection object, but you have 238You can also provide your own TLS connection object, but you have
202to make sure that you call either C<Net::SSLeay::set_connect_state> 239to make sure that you call either C<Net::SSLeay::set_connect_state>
203or C<Net::SSLeay::set_accept_state> on it before you pass it to 240or C<Net::SSLeay::set_accept_state> on it before you pass it to
204AnyEvent::Handle. 241AnyEvent::Handle.
205 242
206See the C<starttls> method if you need to start TLs negotiation later. 243See the C<starttls> method if you need to start TLS negotiation later.
207 244
208=item tls_ctx => $ssl_ctx 245=item tls_ctx => $ssl_ctx
209 246
210Use the given Net::SSLeay::CTX object to create the new TLS connection 247Use the given Net::SSLeay::CTX object to create the new TLS connection
211(unless a connection object was specified directly). If this parameter is 248(unless a connection object was specified directly). If this parameter is
246 } 283 }
247 284
248 $self->{_activity} = AnyEvent->now; 285 $self->{_activity} = AnyEvent->now;
249 $self->_timeout; 286 $self->_timeout;
250 287
251 $self->on_drain (delete $self->{on_drain}) if $self->{on_drain}; 288 $self->on_drain (delete $self->{on_drain}) if exists $self->{on_drain};
289 $self->no_delay (delete $self->{no_delay}) if exists $self->{no_delay};
252 290
253 $self->start_read 291 $self->start_read
254 if $self->{on_read}; 292 if $self->{on_read};
255 293
256 $self 294 $self
263 delete $self->{_rw}; 301 delete $self->{_rw};
264 delete $self->{_ww}; 302 delete $self->{_ww};
265 delete $self->{fh}; 303 delete $self->{fh};
266 304
267 $self->stoptls; 305 $self->stoptls;
306
307 delete $self->{on_read};
308 delete $self->{_queue};
268} 309}
269 310
270sub _error { 311sub _error {
271 my ($self, $errno, $fatal) = @_; 312 my ($self, $errno, $fatal) = @_;
272 313
318 359
319=cut 360=cut
320 361
321sub on_timeout { 362sub on_timeout {
322 $_[0]{on_timeout} = $_[1]; 363 $_[0]{on_timeout} = $_[1];
364}
365
366=item $handle->autocork ($boolean)
367
368Enables or disables the current autocork behaviour (see C<autocork>
369constructor argument).
370
371=cut
372
373=item $handle->no_delay ($boolean)
374
375Enables or disables the C<no_delay> setting (see constructor argument of
376the same name for details).
377
378=cut
379
380sub no_delay {
381 $_[0]{no_delay} = $_[1];
382
383 eval {
384 local $SIG{__DIE__};
385 setsockopt $_[0]{fh}, &Socket::IPPROTO_TCP, &Socket::TCP_NODELAY, int $_[1];
386 };
323} 387}
324 388
325############################################################################# 389#############################################################################
326 390
327=item $handle->timeout ($seconds) 391=item $handle->timeout ($seconds)
442 $self->_error ($!, 1); 506 $self->_error ($!, 1);
443 } 507 }
444 }; 508 };
445 509
446 # try to write data immediately 510 # try to write data immediately
447 $cb->(); 511 $cb->() unless $self->{autocork};
448 512
449 # if still data left in wbuf, we need to poll 513 # if still data left in wbuf, we need to poll
450 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb) 514 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb)
451 if length $self->{wbuf}; 515 if length $self->{wbuf};
452 }; 516 };
678 742
679 if ( 743 if (
680 defined $self->{rbuf_max} 744 defined $self->{rbuf_max}
681 && $self->{rbuf_max} < length $self->{rbuf} 745 && $self->{rbuf_max} < length $self->{rbuf}
682 ) { 746 ) {
683 return $self->_error (&Errno::ENOSPC, 1); 747 $self->_error (&Errno::ENOSPC, 1), return;
684 } 748 }
685 749
686 while () { 750 while () {
687 no strict 'refs';
688
689 my $len = length $self->{rbuf}; 751 my $len = length $self->{rbuf};
690 752
691 if (my $cb = shift @{ $self->{_queue} }) { 753 if (my $cb = shift @{ $self->{_queue} }) {
692 unless ($cb->($self)) { 754 unless ($cb->($self)) {
693 if ($self->{_eof}) { 755 if ($self->{_eof}) {
694 # no progress can be made (not enough data and no data forthcoming) 756 # no progress can be made (not enough data and no data forthcoming)
695 $self->_error (&Errno::EPIPE, 1), last; 757 $self->_error (&Errno::EPIPE, 1), return;
696 } 758 }
697 759
698 unshift @{ $self->{_queue} }, $cb; 760 unshift @{ $self->{_queue} }, $cb;
699 last; 761 last;
700 } 762 }
708 && !@{ $self->{_queue} } # and the queue is still empty 770 && !@{ $self->{_queue} } # and the queue is still empty
709 && $self->{on_read} # but we still have on_read 771 && $self->{on_read} # but we still have on_read
710 ) { 772 ) {
711 # no further data will arrive 773 # no further data will arrive
712 # so no progress can be made 774 # so no progress can be made
713 $self->_error (&Errno::EPIPE, 1), last 775 $self->_error (&Errno::EPIPE, 1), return
714 if $self->{_eof}; 776 if $self->{_eof};
715 777
716 last; # more data might arrive 778 last; # more data might arrive
717 } 779 }
718 } else { 780 } else {
720 delete $self->{_rw}; 782 delete $self->{_rw};
721 last; 783 last;
722 } 784 }
723 } 785 }
724 786
787 if ($self->{_eof}) {
788 if ($self->{on_eof}) {
725 $self->{on_eof}($self) 789 $self->{on_eof}($self)
726 if $self->{_eof} && $self->{on_eof}; 790 } else {
791 $self->_error (0, 1);
792 }
793 }
727 794
728 # may need to restart read watcher 795 # may need to restart read watcher
729 unless ($self->{_rw}) { 796 unless ($self->{_rw}) {
730 $self->start_read 797 $self->start_read
731 if $self->{on_read} || @{ $self->{_queue} }; 798 if $self->{on_read} || @{ $self->{_queue} };
857 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, ""); 924 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, "");
858 1 925 1
859 } 926 }
860}; 927};
861 928
862# compatibility with older API
863sub push_read_chunk {
864 $_[0]->push_read (chunk => $_[1], $_[2]);
865}
866
867sub unshift_read_chunk {
868 $_[0]->unshift_read (chunk => $_[1], $_[2]);
869}
870
871=item line => [$eol, ]$cb->($handle, $line, $eol) 929=item line => [$eol, ]$cb->($handle, $line, $eol)
872 930
873The callback will be called only once a full line (including the end of 931The callback will be called only once a full line (including the end of
874line marker, C<$eol>) has been read. This line (excluding the end of line 932line marker, C<$eol>) has been read. This line (excluding the end of line
875marker) will be passed to the callback as second argument (C<$line>), and 933marker) will be passed to the callback as second argument (C<$line>), and
890=cut 948=cut
891 949
892register_read_type line => sub { 950register_read_type line => sub {
893 my ($self, $cb, $eol) = @_; 951 my ($self, $cb, $eol) = @_;
894 952
895 $eol = qr|(\015?\012)| if @_ < 3; 953 if (@_ < 3) {
954 # this is more than twice as fast as the generic code below
955 sub {
956 $_[0]{rbuf} =~ s/^([^\015\012]*)(\015?\012)// or return;
957
958 $cb->($_[0], $1, $2);
959 1
960 }
961 } else {
896 $eol = quotemeta $eol unless ref $eol; 962 $eol = quotemeta $eol unless ref $eol;
897 $eol = qr|^(.*?)($eol)|s; 963 $eol = qr|^(.*?)($eol)|s;
898 964
899 sub { 965 sub {
900 $_[0]{rbuf} =~ s/$eol// or return; 966 $_[0]{rbuf} =~ s/$eol// or return;
901 967
902 $cb->($_[0], $1, $2); 968 $cb->($_[0], $1, $2);
969 1
903 1 970 }
904 } 971 }
905}; 972};
906
907# compatibility with older API
908sub push_read_line {
909 my $self = shift;
910 $self->push_read (line => @_);
911}
912
913sub unshift_read_line {
914 my $self = shift;
915 $self->unshift_read (line => @_);
916}
917 973
918=item regex => $accept[, $reject[, $skip], $cb->($handle, $data) 974=item regex => $accept[, $reject[, $skip], $cb->($handle, $data)
919 975
920Makes a regex match against the regex object C<$accept> and returns 976Makes a regex match against the regex object C<$accept> and returns
921everything up to and including the match. 977everything up to and including the match.
1042register_read_type packstring => sub { 1098register_read_type packstring => sub {
1043 my ($self, $cb, $format) = @_; 1099 my ($self, $cb, $format) = @_;
1044 1100
1045 sub { 1101 sub {
1046 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1102 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method
1047 defined (my $len = eval { unpack $format, $_[0]->{rbuf} }) 1103 defined (my $len = eval { unpack $format, $_[0]{rbuf} })
1048 or return; 1104 or return;
1049 1105
1106 $format = length pack $format, $len;
1107
1108 # bypass unshift if we already have the remaining chunk
1109 if ($format + $len <= length $_[0]{rbuf}) {
1110 my $data = substr $_[0]{rbuf}, $format, $len;
1111 substr $_[0]{rbuf}, 0, $format + $len, "";
1112 $cb->($_[0], $data);
1113 } else {
1050 # remove prefix 1114 # remove prefix
1051 substr $_[0]->{rbuf}, 0, (length pack $format, $len), ""; 1115 substr $_[0]{rbuf}, 0, $format, "";
1052 1116
1053 # read rest 1117 # read remaining chunk
1054 $_[0]->unshift_read (chunk => $len, $cb); 1118 $_[0]->unshift_read (chunk => $len, $cb);
1119 }
1055 1120
1056 1 1121 1
1057 } 1122 }
1058}; 1123};
1059 1124
1116 1181
1117 require Storable; 1182 require Storable;
1118 1183
1119 sub { 1184 sub {
1120 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1185 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method
1121 defined (my $len = eval { unpack "w", $_[0]->{rbuf} }) 1186 defined (my $len = eval { unpack "w", $_[0]{rbuf} })
1122 or return; 1187 or return;
1123 1188
1189 my $format = length pack "w", $len;
1190
1191 # bypass unshift if we already have the remaining chunk
1192 if ($format + $len <= length $_[0]{rbuf}) {
1193 my $data = substr $_[0]{rbuf}, $format, $len;
1194 substr $_[0]{rbuf}, 0, $format + $len, "";
1195 $cb->($_[0], Storable::thaw ($data));
1196 } else {
1124 # remove prefix 1197 # remove prefix
1125 substr $_[0]->{rbuf}, 0, (length pack "w", $len), ""; 1198 substr $_[0]{rbuf}, 0, $format, "";
1126 1199
1127 # read rest 1200 # read remaining chunk
1128 $_[0]->unshift_read (chunk => $len, sub { 1201 $_[0]->unshift_read (chunk => $len, sub {
1129 if (my $ref = eval { Storable::thaw ($_[1]) }) { 1202 if (my $ref = eval { Storable::thaw ($_[1]) }) {
1130 $cb->($_[0], $ref); 1203 $cb->($_[0], $ref);
1131 } else { 1204 } else {
1132 $self->_error (&Errno::EBADMSG); 1205 $self->_error (&Errno::EBADMSG);
1206 }
1133 } 1207 });
1134 }); 1208 }
1209
1210 1
1135 } 1211 }
1136}; 1212};
1137 1213
1138=back 1214=back
1139 1215
1400=over 4 1476=over 4
1401 1477
1402=item * all constructor arguments become object members. 1478=item * all constructor arguments become object members.
1403 1479
1404At least initially, when you pass a C<tls>-argument to the constructor it 1480At least initially, when you pass a C<tls>-argument to the constructor it
1405will end up in C<< $handle->{tls} >>. Those members might be changes or 1481will end up in C<< $handle->{tls} >>. Those members might be changed or
1406mutated later on (for example C<tls> will hold the TLS connection object). 1482mutated later on (for example C<tls> will hold the TLS connection object).
1407 1483
1408=item * other object member names are prefixed with an C<_>. 1484=item * other object member names are prefixed with an C<_>.
1409 1485
1410All object members not explicitly documented (internal use) are prefixed 1486All object members not explicitly documented (internal use) are prefixed

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines