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.84 by root, Thu Aug 21 19:13:05 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
201You can also provide your own TLS connection object, but you have 242You can also provide your own TLS connection object, but you have
202to make sure that you call either C<Net::SSLeay::set_connect_state> 243to 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 244or C<Net::SSLeay::set_accept_state> on it before you pass it to
204AnyEvent::Handle. 245AnyEvent::Handle.
205 246
206See the C<starttls> method if you need to start TLs negotiation later. 247See the C<starttls> method if you need to start TLS negotiation later.
207 248
208=item tls_ctx => $ssl_ctx 249=item tls_ctx => $ssl_ctx
209 250
210Use the given Net::SSLeay::CTX object to create the new TLS connection 251Use the given Net::SSLeay::CTX object to create the new TLS connection
211(unless a connection object was specified directly). If this parameter is 252(unless a connection object was specified directly). If this parameter is
246 } 287 }
247 288
248 $self->{_activity} = AnyEvent->now; 289 $self->{_activity} = AnyEvent->now;
249 $self->_timeout; 290 $self->_timeout;
250 291
251 $self->on_drain (delete $self->{on_drain}) if $self->{on_drain}; 292 $self->on_drain (delete $self->{on_drain}) if exists $self->{on_drain};
293 $self->no_delay (delete $self->{no_delay}) if exists $self->{no_delay};
252 294
253 $self->start_read 295 $self->start_read
254 if $self->{on_read}; 296 if $self->{on_read};
255 297
256 $self 298 $self
263 delete $self->{_rw}; 305 delete $self->{_rw};
264 delete $self->{_ww}; 306 delete $self->{_ww};
265 delete $self->{fh}; 307 delete $self->{fh};
266 308
267 $self->stoptls; 309 $self->stoptls;
310
311 delete $self->{on_read};
312 delete $self->{_queue};
268} 313}
269 314
270sub _error { 315sub _error {
271 my ($self, $errno, $fatal) = @_; 316 my ($self, $errno, $fatal) = @_;
272 317
318 363
319=cut 364=cut
320 365
321sub on_timeout { 366sub on_timeout {
322 $_[0]{on_timeout} = $_[1]; 367 $_[0]{on_timeout} = $_[1];
368}
369
370=item $handle->autocork ($boolean)
371
372Enables or disables the current autocork behaviour (see C<autocork>
373constructor argument).
374
375=cut
376
377=item $handle->no_delay ($boolean)
378
379Enables or disables the C<no_delay> setting (see constructor argument of
380the same name for details).
381
382=cut
383
384sub no_delay {
385 $_[0]{no_delay} = $_[1];
386
387 eval {
388 local $SIG{__DIE__};
389 setsockopt $_[0]{fh}, &Socket::IPPROTO_TCP, &Socket::TCP_NODELAY, int $_[1];
390 };
323} 391}
324 392
325############################################################################# 393#############################################################################
326 394
327=item $handle->timeout ($seconds) 395=item $handle->timeout ($seconds)
442 $self->_error ($!, 1); 510 $self->_error ($!, 1);
443 } 511 }
444 }; 512 };
445 513
446 # try to write data immediately 514 # try to write data immediately
447 $cb->(); 515 $cb->() unless $self->{autocork};
448 516
449 # if still data left in wbuf, we need to poll 517 # if still data left in wbuf, we need to poll
450 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb) 518 $self->{_ww} = AnyEvent->io (fh => $self->{fh}, poll => "w", cb => $cb)
451 if length $self->{wbuf}; 519 if length $self->{wbuf};
452 }; 520 };
678 746
679 if ( 747 if (
680 defined $self->{rbuf_max} 748 defined $self->{rbuf_max}
681 && $self->{rbuf_max} < length $self->{rbuf} 749 && $self->{rbuf_max} < length $self->{rbuf}
682 ) { 750 ) {
683 return $self->_error (&Errno::ENOSPC, 1); 751 $self->_error (&Errno::ENOSPC, 1), return;
684 } 752 }
685 753
686 while () { 754 while () {
687 no strict 'refs';
688
689 my $len = length $self->{rbuf}; 755 my $len = length $self->{rbuf};
690 756
691 if (my $cb = shift @{ $self->{_queue} }) { 757 if (my $cb = shift @{ $self->{_queue} }) {
692 unless ($cb->($self)) { 758 unless ($cb->($self)) {
693 if ($self->{_eof}) { 759 if ($self->{_eof}) {
694 # no progress can be made (not enough data and no data forthcoming) 760 # no progress can be made (not enough data and no data forthcoming)
695 $self->_error (&Errno::EPIPE, 1), last; 761 $self->_error (&Errno::EPIPE, 1), return;
696 } 762 }
697 763
698 unshift @{ $self->{_queue} }, $cb; 764 unshift @{ $self->{_queue} }, $cb;
699 last; 765 last;
700 } 766 }
708 && !@{ $self->{_queue} } # and the queue is still empty 774 && !@{ $self->{_queue} } # and the queue is still empty
709 && $self->{on_read} # but we still have on_read 775 && $self->{on_read} # but we still have on_read
710 ) { 776 ) {
711 # no further data will arrive 777 # no further data will arrive
712 # so no progress can be made 778 # so no progress can be made
713 $self->_error (&Errno::EPIPE, 1), last 779 $self->_error (&Errno::EPIPE, 1), return
714 if $self->{_eof}; 780 if $self->{_eof};
715 781
716 last; # more data might arrive 782 last; # more data might arrive
717 } 783 }
718 } else { 784 } else {
720 delete $self->{_rw}; 786 delete $self->{_rw};
721 last; 787 last;
722 } 788 }
723 } 789 }
724 790
791 if ($self->{_eof}) {
792 if ($self->{on_eof}) {
725 $self->{on_eof}($self) 793 $self->{on_eof}($self)
726 if $self->{_eof} && $self->{on_eof}; 794 } else {
795 $self->_error (0, 1);
796 }
797 }
727 798
728 # may need to restart read watcher 799 # may need to restart read watcher
729 unless ($self->{_rw}) { 800 unless ($self->{_rw}) {
730 $self->start_read 801 $self->start_read
731 if $self->{on_read} || @{ $self->{_queue} }; 802 if $self->{on_read} || @{ $self->{_queue} };
857 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, ""); 928 $cb->($_[0], substr $_[0]{rbuf}, 0, $len, "");
858 1 929 1
859 } 930 }
860}; 931};
861 932
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) 933=item line => [$eol, ]$cb->($handle, $line, $eol)
872 934
873The callback will be called only once a full line (including the end of 935The 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 936line 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 937marker) will be passed to the callback as second argument (C<$line>), and
890=cut 952=cut
891 953
892register_read_type line => sub { 954register_read_type line => sub {
893 my ($self, $cb, $eol) = @_; 955 my ($self, $cb, $eol) = @_;
894 956
895 $eol = qr|(\015?\012)| if @_ < 3; 957 if (@_ < 3) {
958 # this is more than twice as fast as the generic code below
959 sub {
960 $_[0]{rbuf} =~ s/^([^\015\012]*)(\015?\012)// or return;
961
962 $cb->($_[0], $1, $2);
963 1
964 }
965 } else {
896 $eol = quotemeta $eol unless ref $eol; 966 $eol = quotemeta $eol unless ref $eol;
897 $eol = qr|^(.*?)($eol)|s; 967 $eol = qr|^(.*?)($eol)|s;
898 968
899 sub { 969 sub {
900 $_[0]{rbuf} =~ s/$eol// or return; 970 $_[0]{rbuf} =~ s/$eol// or return;
901 971
902 $cb->($_[0], $1, $2); 972 $cb->($_[0], $1, $2);
973 1
903 1 974 }
904 } 975 }
905}; 976};
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 977
918=item regex => $accept[, $reject[, $skip], $cb->($handle, $data) 978=item regex => $accept[, $reject[, $skip], $cb->($handle, $data)
919 979
920Makes a regex match against the regex object C<$accept> and returns 980Makes a regex match against the regex object C<$accept> and returns
921everything up to and including the match. 981everything up to and including the match.
1042register_read_type packstring => sub { 1102register_read_type packstring => sub {
1043 my ($self, $cb, $format) = @_; 1103 my ($self, $cb, $format) = @_;
1044 1104
1045 sub { 1105 sub {
1046 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1106 # 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} }) 1107 defined (my $len = eval { unpack $format, $_[0]{rbuf} })
1048 or return; 1108 or return;
1049 1109
1110 $format = length pack $format, $len;
1111
1112 # bypass unshift if we already have the remaining chunk
1113 if ($format + $len <= length $_[0]{rbuf}) {
1114 my $data = substr $_[0]{rbuf}, $format, $len;
1115 substr $_[0]{rbuf}, 0, $format + $len, "";
1116 $cb->($_[0], $data);
1117 } else {
1050 # remove prefix 1118 # remove prefix
1051 substr $_[0]->{rbuf}, 0, (length pack $format, $len), ""; 1119 substr $_[0]{rbuf}, 0, $format, "";
1052 1120
1053 # read rest 1121 # read remaining chunk
1054 $_[0]->unshift_read (chunk => $len, $cb); 1122 $_[0]->unshift_read (chunk => $len, $cb);
1123 }
1055 1124
1056 1 1125 1
1057 } 1126 }
1058}; 1127};
1059 1128
1116 1185
1117 require Storable; 1186 require Storable;
1118 1187
1119 sub { 1188 sub {
1120 # when we can use 5.10 we can use ".", but for 5.8 we use the re-pack method 1189 # 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} }) 1190 defined (my $len = eval { unpack "w", $_[0]{rbuf} })
1122 or return; 1191 or return;
1123 1192
1193 my $format = length pack "w", $len;
1194
1195 # bypass unshift if we already have the remaining chunk
1196 if ($format + $len <= length $_[0]{rbuf}) {
1197 my $data = substr $_[0]{rbuf}, $format, $len;
1198 substr $_[0]{rbuf}, 0, $format + $len, "";
1199 $cb->($_[0], Storable::thaw ($data));
1200 } else {
1124 # remove prefix 1201 # remove prefix
1125 substr $_[0]->{rbuf}, 0, (length pack "w", $len), ""; 1202 substr $_[0]{rbuf}, 0, $format, "";
1126 1203
1127 # read rest 1204 # read remaining chunk
1128 $_[0]->unshift_read (chunk => $len, sub { 1205 $_[0]->unshift_read (chunk => $len, sub {
1129 if (my $ref = eval { Storable::thaw ($_[1]) }) { 1206 if (my $ref = eval { Storable::thaw ($_[1]) }) {
1130 $cb->($_[0], $ref); 1207 $cb->($_[0], $ref);
1131 } else { 1208 } else {
1132 $self->_error (&Errno::EBADMSG); 1209 $self->_error (&Errno::EBADMSG);
1210 }
1133 } 1211 });
1134 }); 1212 }
1213
1214 1
1135 } 1215 }
1136}; 1216};
1137 1217
1138=back 1218=back
1139 1219
1400=over 4 1480=over 4
1401 1481
1402=item * all constructor arguments become object members. 1482=item * all constructor arguments become object members.
1403 1483
1404At least initially, when you pass a C<tls>-argument to the constructor it 1484At 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 1485will 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). 1486mutated later on (for example C<tls> will hold the TLS connection object).
1407 1487
1408=item * other object member names are prefixed with an C<_>. 1488=item * other object member names are prefixed with an C<_>.
1409 1489
1410All object members not explicitly documented (internal use) are prefixed 1490All object members not explicitly documented (internal use) are prefixed

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines