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.86 by root, Thu Aug 21 20:41: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;
49 49
50This module is a helper module to make it easier to do event-based I/O on 50This module is a helper module to make it easier to do event-based I/O on
51filehandles. For utility functions for doing non-blocking connects and accepts 51filehandles. For utility functions for doing non-blocking connects and accepts
52on sockets see L<AnyEvent::Util>. 52on sockets see L<AnyEvent::Util>.
53 53
54The L<AnyEvent::Intro> tutorial contains some well-documented
55AnyEvent::Handle examples.
56
54In the following, when the documentation refers to of "bytes" then this 57In the following, when the documentation refers to of "bytes" then this
55means characters. As sysread and syswrite are used for all I/O, their 58means characters. As sysread and syswrite are used for all I/O, their
56treatment of characters applies to this module as well. 59treatment of characters applies to this module as well.
57 60
58All callbacks will be invoked with the handle object as their first 61All callbacks will be invoked with the handle object as their first
70 73
71=item fh => $filehandle [MANDATORY] 74=item fh => $filehandle [MANDATORY]
72 75
73The filehandle this L<AnyEvent::Handle> object will operate on. 76The filehandle this L<AnyEvent::Handle> object will operate on.
74 77
75NOTE: The filehandle will be set to non-blocking (using 78NOTE: The filehandle will be set to non-blocking mode (using
76AnyEvent::Util::fh_nonblocking). 79C<AnyEvent::Util::fh_nonblocking>) by the constructor and needs to stay in
80that mode.
77 81
78=item on_eof => $cb->($handle) 82=item on_eof => $cb->($handle)
79 83
80Set the callback to be called when an end-of-file condition is detcted, 84Set 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 85i.e. in the case of a socket, when the other side has closed the
82connection cleanly. 86connection cleanly.
83 87
88For sockets, this just means that the other side has stopped sending data,
89you can still try to write data, and, in fact, one can return from the eof
90callback and continue writing data, as only the read part has been shut
91down.
92
84While not mandatory, it is highly recommended to set an eof callback, 93While 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 94otherwise you might end up with a closed socket while you are still
86waiting for data. 95waiting for data.
96
97If an EOF condition has been detected but no C<on_eof> callback has been
98set, then a fatal error will be raised with C<$!> set to <0>.
87 99
88=item on_error => $cb->($handle, $fatal) 100=item on_error => $cb->($handle, $fatal)
89 101
90This is the error callback, which is called when, well, some error 102This is the error callback, which is called when, well, some error
91occured, such as not being able to resolve the hostname, failure to 103occured, such as not being able to resolve the hostname, failure to
92connect or a read error. 104connect or a read error.
93 105
94Some errors are fatal (which is indicated by C<$fatal> being true). On 106Some 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 107fatal errors the handle object will be shut down and will not be usable
108(but you are free to look at the current C< ->rbuf >). Examples of fatal
109errors are an EOF condition with active (but unsatisifable) read watchers
110(C<EPIPE>) or I/O errors.
111
96usable. Non-fatal errors can be retried by simply returning, but it is 112Non-fatal errors can be retried by simply returning, but it is recommended
97recommended to simply ignore this parameter and instead abondon the handle 113to simply ignore this parameter and instead abondon the handle object
98object when this callback is invoked. 114when this callback is invoked. Examples of non-fatal errors are timeouts
115C<ETIMEDOUT>) or badly-formatted data (C<EBADMSG>).
99 116
100On callback entrance, the value of C<$!> contains the operating system 117On callback entrance, the value of C<$!> contains the operating system
101error (or C<ENOSPC>, C<EPIPE>, C<ETIMEDOUT> or C<EBADMSG>). 118error (or C<ENOSPC>, C<EPIPE>, C<ETIMEDOUT> or C<EBADMSG>).
102 119
103While not mandatory, it is I<highly> recommended to set this callback, as 120While 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 179be 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 180(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 181amount of data without a callback ever being called as long as the line
165isn't finished). 182isn't finished).
166 183
184=item autocork => <boolean>
185
186When disabled (the default), then C<push_write> will try to immediately
187write the data to the handle if possible. This avoids having to register
188a write watcher and wait for the next event loop iteration, but can be
189inefficient if you write multiple small chunks (this disadvantage is
190usually avoided by your kernel's nagle algorithm, see C<low_delay>).
191
192When enabled, then writes will always be queued till the next event loop
193iteration. This is efficient when you do many small writes per iteration,
194but less efficient when you do a single write only.
195
196=item no_delay => <boolean>
197
198When doing small writes on sockets, your operating system kernel might
199wait a bit for more data before actually sending it out. This is called
200the Nagle algorithm, and usually it is beneficial.
201
202In some situations you want as low a delay as possible, which cna be
203accomplishd by setting this option to true.
204
205The default is your opertaing system's default behaviour, this option
206explicitly enables or disables it, if possible.
207
167=item read_size => <bytes> 208=item read_size => <bytes>
168 209
169The default read block size (the amount of bytes this module will try to read 210The default read block size (the amount of bytes this module will try to read
170during each (loop iteration). Default: C<8192>. 211during each (loop iteration). Default: C<8192>.
171 212
186This will not work for partial TLS data that could not yet been 227This will not work for partial TLS data that could not yet been
187encoded. This data will be lost. 228encoded. This data will be lost.
188 229
189=item tls => "accept" | "connect" | Net::SSLeay::SSL object 230=item tls => "accept" | "connect" | Net::SSLeay::SSL object
190 231
191When this parameter is given, it enables TLS (SSL) mode, that means it 232When this parameter is given, it enables TLS (SSL) mode, that means
192will start making tls handshake and will transparently encrypt/decrypt 233AnyEvent will start a TLS handshake and will transparently encrypt/decrypt
193data. 234data.
194 235
195TLS mode requires Net::SSLeay to be installed (it will be loaded 236TLS mode requires Net::SSLeay to be installed (it will be loaded
196automatically when you try to create a TLS handle). 237automatically when you try to create a TLS handle).
197 238
198For the TLS server side, use C<accept>, and for the TLS client side of a 239Unlike TCP, TLS has a server and client side: for the TLS server side, use
199connection, use C<connect> mode. 240C<accept>, and for the TLS client side of a connection, use C<connect>
241mode.
200 242
201You can also provide your own TLS connection object, but you have 243You can also provide your own TLS connection object, but you have
202to make sure that you call either C<Net::SSLeay::set_connect_state> 244to 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 245or C<Net::SSLeay::set_accept_state> on it before you pass it to
204AnyEvent::Handle. 246AnyEvent::Handle.
205 247
206See the C<starttls> method if you need to start TLs negotiation later. 248See the C<starttls> method for when need to start TLS negotiation later.
207 249
208=item tls_ctx => $ssl_ctx 250=item tls_ctx => $ssl_ctx
209 251
210Use the given Net::SSLeay::CTX object to create the new TLS connection 252Use the given Net::SSLeay::CTX object to create the new TLS connection
211(unless a connection object was specified directly). If this parameter is 253(unless a connection object was specified directly). If this parameter is
214=item json => JSON or JSON::XS object 256=item json => JSON or JSON::XS object
215 257
216This is the json coder object used by the C<json> read and write types. 258This is the json coder object used by the C<json> read and write types.
217 259
218If you don't supply it, then AnyEvent::Handle will create and use a 260If you don't supply it, then AnyEvent::Handle will create and use a
219suitable one, which will write and expect UTF-8 encoded JSON texts. 261suitable one (on demand), which will write and expect UTF-8 encoded JSON
262texts.
220 263
221Note that you are responsible to depend on the JSON module if you want to 264Note that you are responsible to depend on the JSON module if you want to
222use this functionality, as AnyEvent does not have a dependency itself. 265use this functionality, as AnyEvent does not have a dependency itself.
223 266
224=item filter_r => $cb 267=item filter_r => $cb
246 } 289 }
247 290
248 $self->{_activity} = AnyEvent->now; 291 $self->{_activity} = AnyEvent->now;
249 $self->_timeout; 292 $self->_timeout;
250 293
251 $self->on_drain (delete $self->{on_drain}) if $self->{on_drain}; 294 $self->on_drain (delete $self->{on_drain}) if exists $self->{on_drain};
295 $self->no_delay (delete $self->{no_delay}) if exists $self->{no_delay};
252 296
253 $self->start_read 297 $self->start_read
254 if $self->{on_read}; 298 if $self->{on_read};
255 299
256 $self 300 $self
263 delete $self->{_rw}; 307 delete $self->{_rw};
264 delete $self->{_ww}; 308 delete $self->{_ww};
265 delete $self->{fh}; 309 delete $self->{fh};
266 310
267 $self->stoptls; 311 $self->stoptls;
312
313 delete $self->{on_read};
314 delete $self->{_queue};
268} 315}
269 316
270sub _error { 317sub _error {
271 my ($self, $errno, $fatal) = @_; 318 my ($self, $errno, $fatal) = @_;
272 319
318 365
319=cut 366=cut
320 367
321sub on_timeout { 368sub on_timeout {
322 $_[0]{on_timeout} = $_[1]; 369 $_[0]{on_timeout} = $_[1];
370}
371
372=item $handle->autocork ($boolean)
373
374Enables or disables the current autocork behaviour (see C<autocork>
375constructor argument).
376
377=cut
378
379=item $handle->no_delay ($boolean)
380
381Enables or disables the C<no_delay> setting (see constructor argument of
382the same name for details).
383
384=cut
385
386sub no_delay {
387 $_[0]{no_delay} = $_[1];
388
389 eval {
390 local $SIG{__DIE__};
391 setsockopt $_[0]{fh}, &Socket::IPPROTO_TCP, &Socket::TCP_NODELAY, int $_[1];
392 };
323} 393}
324 394
325############################################################################# 395#############################################################################
326 396
327=item $handle->timeout ($seconds) 397=item $handle->timeout ($seconds)
442 $self->_error ($!, 1); 512 $self->_error ($!, 1);
443 } 513 }
444 }; 514 };
445 515
446 # try to write data immediately 516 # try to write data immediately
447 $cb->(); 517 $cb->() unless $self->{autocork};
448 518
449 # if still data left in wbuf, we need to poll 519 # if still data left in wbuf, we need to poll
450 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb) 520 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb)
451 if length $self->{wbuf}; 521 if length $self->{wbuf};
452 }; 522 };
678 748
679 if ( 749 if (
680 defined $self->{rbuf_max} 750 defined $self->{rbuf_max}
681 && $self->{rbuf_max} < length $self->{rbuf} 751 && $self->{rbuf_max} < length $self->{rbuf}
682 ) { 752 ) {
683 return $self->_error (&Errno::ENOSPC, 1); 753 $self->_error (&Errno::ENOSPC, 1), return;
684 } 754 }
685 755
686 while () { 756 while () {
687 no strict 'refs';
688
689 my $len = length $self->{rbuf}; 757 my $len = length $self->{rbuf};
690 758
691 if (my $cb = shift @{ $self->{_queue} }) { 759 if (my $cb = shift @{ $self->{_queue} }) {
692 unless ($cb->($self)) { 760 unless ($cb->($self)) {
693 if ($self->{_eof}) { 761 if ($self->{_eof}) {
694 # no progress can be made (not enough data and no data forthcoming) 762 # no progress can be made (not enough data and no data forthcoming)
695 $self->_error (&Errno::EPIPE, 1), last; 763 $self->_error (&Errno::EPIPE, 1), return;
696 } 764 }
697 765
698 unshift @{ $self->{_queue} }, $cb; 766 unshift @{ $self->{_queue} }, $cb;
699 last; 767 last;
700 } 768 }
708 && !@{ $self->{_queue} } # and the queue is still empty 776 && !@{ $self->{_queue} } # and the queue is still empty
709 && $self->{on_read} # but we still have on_read 777 && $self->{on_read} # but we still have on_read
710 ) { 778 ) {
711 # no further data will arrive 779 # no further data will arrive
712 # so no progress can be made 780 # so no progress can be made
713 $self->_error (&Errno::EPIPE, 1), last 781 $self->_error (&Errno::EPIPE, 1), return
714 if $self->{_eof}; 782 if $self->{_eof};
715 783
716 last; # more data might arrive 784 last; # more data might arrive
717 } 785 }
718 } else { 786 } else {
720 delete $self->{_rw}; 788 delete $self->{_rw};
721 last; 789 last;
722 } 790 }
723 } 791 }
724 792
793 if ($self->{_eof}) {
794 if ($self->{on_eof}) {
725 $self->{on_eof}($self) 795 $self->{on_eof}($self)
726 if $self->{_eof} && $self->{on_eof}; 796 } else {
797 $self->_error (0, 1);
798 }
799 }
727 800
728 # may need to restart read watcher 801 # may need to restart read watcher
729 unless ($self->{_rw}) { 802 unless ($self->{_rw}) {
730 $self->start_read 803 $self->start_read
731 if $self->{on_read} || @{ $self->{_queue} }; 804 if $self->{on_read} || @{ $self->{_queue} };
857 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, ""); 930 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, "");
858 1 931 1
859 } 932 }
860}; 933};
861 934
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) 935=item line => [$eol, ]$cb->($handle, $line, $eol)
872 936
873The callback will be called only once a full line (including the end of 937The 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 938line 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 939marker) will be passed to the callback as second argument (C<$line>), and
890=cut 954=cut
891 955
892register_read_type line => sub { 956register_read_type line => sub {
893 my ($self, $cb, $eol) = @_; 957 my ($self, $cb, $eol) = @_;
894 958
895 $eol = qr|(\015?\012)| if @_ < 3; 959 if (@_ < 3) {
960 # this is more than twice as fast as the generic code below
961 sub {
962 $_[0]{rbuf} =~ s/^([^\015\012]*)(\015?\012)// or return;
963
964 $cb->($_[0], $1, $2);
965 1
966 }
967 } else {
896 $eol = quotemeta $eol unless ref $eol; 968 $eol = quotemeta $eol unless ref $eol;
897 $eol = qr|^(.*?)($eol)|s; 969 $eol = qr|^(.*?)($eol)|s;
898 970
899 sub { 971 sub {
900 $_[0]{rbuf} =~ s/$eol// or return; 972 $_[0]{rbuf} =~ s/$eol// or return;
901 973
902 $cb->($_[0], $1, $2); 974 $cb->($_[0], $1, $2);
975 1
903 1 976 }
904 } 977 }
905}; 978};
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 979
918=item regex => $accept[, $reject[, $skip], $cb->($handle, $data) 980=item regex => $accept[, $reject[, $skip], $cb->($handle, $data)
919 981
920Makes a regex match against the regex object C<$accept> and returns 982Makes a regex match against the regex object C<$accept> and returns
921everything up to and including the match. 983everything up to and including the match.
1042register_read_type packstring => sub { 1104register_read_type packstring => sub {
1043 my ($self, $cb, $format) = @_; 1105 my ($self, $cb, $format) = @_;
1044 1106
1045 sub { 1107 sub {
1046 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1108 # 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} }) 1109 defined (my $len = eval { unpack $format, $_[0]{rbuf} })
1048 or return; 1110 or return;
1049 1111
1112 $format = length pack $format, $len;
1113
1114 # bypass unshift if we already have the remaining chunk
1115 if ($format + $len <= length $_[0]{rbuf}) {
1116 my $data = substr $_[0]{rbuf}, $format, $len;
1117 substr $_[0]{rbuf}, 0, $format + $len, "";
1118 $cb->($_[0], $data);
1119 } else {
1050 # remove prefix 1120 # remove prefix
1051 substr $_[0]->{rbuf}, 0, (length pack $format, $len), ""; 1121 substr $_[0]{rbuf}, 0, $format, "";
1052 1122
1053 # read rest 1123 # read remaining chunk
1054 $_[0]->unshift_read (chunk => $len, $cb); 1124 $_[0]->unshift_read (chunk => $len, $cb);
1125 }
1055 1126
1056 1 1127 1
1057 } 1128 }
1058}; 1129};
1059 1130
1116 1187
1117 require Storable; 1188 require Storable;
1118 1189
1119 sub { 1190 sub {
1120 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1191 # 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} }) 1192 defined (my $len = eval { unpack "w", $_[0]{rbuf} })
1122 or return; 1193 or return;
1123 1194
1195 my $format = length pack "w", $len;
1196
1197 # bypass unshift if we already have the remaining chunk
1198 if ($format + $len <= length $_[0]{rbuf}) {
1199 my $data = substr $_[0]{rbuf}, $format, $len;
1200 substr $_[0]{rbuf}, 0, $format + $len, "";
1201 $cb->($_[0], Storable::thaw ($data));
1202 } else {
1124 # remove prefix 1203 # remove prefix
1125 substr $_[0]->{rbuf}, 0, (length pack "w", $len), ""; 1204 substr $_[0]{rbuf}, 0, $format, "";
1126 1205
1127 # read rest 1206 # read remaining chunk
1128 $_[0]->unshift_read (chunk => $len, sub { 1207 $_[0]->unshift_read (chunk => $len, sub {
1129 if (my $ref = eval { Storable::thaw ($_[1]) }) { 1208 if (my $ref = eval { Storable::thaw ($_[1]) }) {
1130 $cb->($_[0], $ref); 1209 $cb->($_[0], $ref);
1131 } else { 1210 } else {
1132 $self->_error (&Errno::EBADMSG); 1211 $self->_error (&Errno::EBADMSG);
1212 }
1133 } 1213 });
1134 }); 1214 }
1215
1216 1
1135 } 1217 }
1136}; 1218};
1137 1219
1138=back 1220=back
1139 1221
1400=over 4 1482=over 4
1401 1483
1402=item * all constructor arguments become object members. 1484=item * all constructor arguments become object members.
1403 1485
1404At least initially, when you pass a C<tls>-argument to the constructor it 1486At 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 1487will 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). 1488mutated later on (for example C<tls> will hold the TLS connection object).
1407 1489
1408=item * other object member names are prefixed with an C<_>. 1490=item * other object member names are prefixed with an C<_>.
1409 1491
1410All object members not explicitly documented (internal use) are prefixed 1492All object members not explicitly documented (internal use) are prefixed

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines