ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent/lib/AnyEvent.pm
(Generate patch)

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.334 by root, Tue Oct 12 06:51:15 2010 UTC vs.
Revision 1.390 by root, Tue Oct 4 17:45:04 2011 UTC

1=head1 NAME 1=head1 NAME
2 2
3AnyEvent - the DBI of event loop programming 3AnyEvent - the DBI of event loop programming
4 4
5EV, Event, Glib, Tk, Perl, Event::Lib, Irssi, rxvt-unicode, IO::Async, Qt 5EV, Event, Glib, Tk, Perl, Event::Lib, Irssi, rxvt-unicode, IO::Async, Qt,
6and POE are various supported event loops/environments. 6FLTK and POE are various supported event loops/environments.
7 7
8=head1 SYNOPSIS 8=head1 SYNOPSIS
9 9
10 use AnyEvent; 10 use AnyEvent;
11 11
85that isn't them. What's worse, all the potential users of your 85that isn't them. What's worse, all the potential users of your
86module are I<also> forced to use the same event loop you use. 86module are I<also> forced to use the same event loop you use.
87 87
88AnyEvent is different: AnyEvent + POE works fine. AnyEvent + Glib works 88AnyEvent is different: AnyEvent + POE works fine. AnyEvent + Glib works
89fine. AnyEvent + Tk works fine etc. etc. but none of these work together 89fine. AnyEvent + Tk works fine etc. etc. but none of these work together
90with the rest: POE + IO::Async? No go. Tk + Event? No go. Again: if 90with the rest: POE + EV? No go. Tk + Event? No go. Again: if your module
91your module uses one of those, every user of your module has to use it, 91uses one of those, every user of your module has to use it, too. But if
92too. But if your module uses AnyEvent, it works transparently with all 92your module uses AnyEvent, it works transparently with all event models it
93event models it supports (including stuff like IO::Async, as long as those 93supports (including stuff like IO::Async, as long as those use one of the
94use one of the supported event loops. It is easy to add new event loops 94supported event loops. It is easy to add new event loops to AnyEvent, too,
95to AnyEvent, too, so it is future-proof). 95so it is future-proof).
96 96
97In addition to being free of having to use I<the one and only true event 97In addition to being free of having to use I<the one and only true event
98model>, AnyEvent also is free of bloat and policy: with POE or similar 98model>, AnyEvent also is free of bloat and policy: with POE or similar
99modules, you get an enormous amount of code and strict rules you have to 99modules, you get an enormous amount of code and strict rules you have to
100follow. AnyEvent, on the other hand, is lean and to the point, by only 100follow. AnyEvent, on the other hand, is lean and to the point, by only
121The interface itself is vaguely similar, but not identical to the L<Event> 121The interface itself is vaguely similar, but not identical to the L<Event>
122module. 122module.
123 123
124During the first call of any watcher-creation method, the module tries 124During the first call of any watcher-creation method, the module tries
125to detect the currently loaded event loop by probing whether one of the 125to detect the currently loaded event loop by probing whether one of the
126following modules is already loaded: L<EV>, L<AnyEvent::Impl::Perl>, 126following modules is already loaded: L<EV>, L<AnyEvent::Loop>,
127L<Event>, L<Glib>, L<Tk>, L<Event::Lib>, L<Qt>, L<POE>. The first one 127L<Event>, L<Glib>, L<Tk>, L<Event::Lib>, L<Qt>, L<POE>. The first one
128found is used. If none are detected, the module tries to load the first 128found is used. If none are detected, the module tries to load the first
129four modules in the order given; but note that if L<EV> is not 129four modules in the order given; but note that if L<EV> is not
130available, the pure-perl L<AnyEvent::Impl::Perl> should always work, so 130available, the pure-perl L<AnyEvent::Loop> should always work, so
131the other two are not normally tried. 131the other two are not normally tried.
132 132
133Because AnyEvent first checks for modules that are already loaded, loading 133Because AnyEvent first checks for modules that are already loaded, loading
134an event model explicitly before first using AnyEvent will likely make 134an event model explicitly before first using AnyEvent will likely make
135that model the default. For example: 135that model the default. For example:
142The I<likely> means that, if any module loads another event model and 142The I<likely> means that, if any module loads another event model and
143starts using it, all bets are off - this case should be very rare though, 143starts using it, all bets are off - this case should be very rare though,
144as very few modules hardcode event loops without announcing this very 144as very few modules hardcode event loops without announcing this very
145loudly. 145loudly.
146 146
147The pure-perl implementation of AnyEvent is called 147The pure-perl implementation of AnyEvent is called C<AnyEvent::Loop>. Like
148C<AnyEvent::Impl::Perl>. Like other event modules you can load it 148other event modules you can load it explicitly and enjoy the high
149explicitly and enjoy the high availability of that event loop :) 149availability of that event loop :)
150 150
151=head1 WATCHERS 151=head1 WATCHERS
152 152
153AnyEvent has the central concept of a I<watcher>, which is an object that 153AnyEvent has the central concept of a I<watcher>, which is an object that
154stores relevant data for each kind of event you are waiting for, such as 154stores relevant data for each kind of event you are waiting for, such as
356difference between C<< AnyEvent->time >> and C<< AnyEvent->now >> into 356difference between C<< AnyEvent->time >> and C<< AnyEvent->now >> into
357account. 357account.
358 358
359=item AnyEvent->now_update 359=item AnyEvent->now_update
360 360
361Some event loops (such as L<EV> or L<AnyEvent::Impl::Perl>) cache 361Some event loops (such as L<EV> or L<AnyEvent::Loop>) cache the current
362the current time for each loop iteration (see the discussion of L<< 362time for each loop iteration (see the discussion of L<< AnyEvent->now >>,
363AnyEvent->now >>, above). 363above).
364 364
365When a callback runs for a long time (or when the process sleeps), then 365When a callback runs for a long time (or when the process sleeps), then
366this "current" time will differ substantially from the real time, which 366this "current" time will differ substantially from the real time, which
367might affect timers and time-outs. 367might affect timers and time-outs.
368 368
415not restart syscalls (that includes L<Async::Interrupt> and AnyEvent's 415not restart syscalls (that includes L<Async::Interrupt> and AnyEvent's
416pure perl implementation). 416pure perl implementation).
417 417
418=head3 Safe/Unsafe Signals 418=head3 Safe/Unsafe Signals
419 419
420Perl signals can be either "safe" (synchronous to opcode handling) or 420Perl signals can be either "safe" (synchronous to opcode handling)
421"unsafe" (asynchronous) - the former might get delayed indefinitely, the 421or "unsafe" (asynchronous) - the former might delay signal delivery
422latter might corrupt your memory. 422indefinitely, the latter might corrupt your memory.
423 423
424AnyEvent signal handlers are, in addition, synchronous to the event loop, 424AnyEvent signal handlers are, in addition, synchronous to the event loop,
425i.e. they will not interrupt your running perl program but will only be 425i.e. they will not interrupt your running perl program but will only be
426called as part of the normal event handling (just like timer, I/O etc. 426called as part of the normal event handling (just like timer, I/O etc.
427callbacks, too). 427callbacks, too).
428 428
429=head3 Signal Races, Delays and Workarounds 429=head3 Signal Races, Delays and Workarounds
430 430
431Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching 431Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support
432callbacks to signals in a generic way, which is a pity, as you cannot 432attaching callbacks to signals in a generic way, which is a pity,
433do race-free signal handling in perl, requiring C libraries for 433as you cannot do race-free signal handling in perl, requiring
434this. AnyEvent will try to do its best, which means in some cases, 434C libraries for this. AnyEvent will try to do its best, which
435signals will be delayed. The maximum time a signal might be delayed is 435means in some cases, signals will be delayed. The maximum time
436specified in C<$AnyEvent::MAX_SIGNAL_LATENCY> (default: 10 seconds). This 436a signal might be delayed is 10 seconds by default, but can
437variable can be changed only before the first signal watcher is created, 437be overriden via C<$ENV{PERL_ANYEVENT_MAX_SIGNAL_LATENCY}> or
438and should be left alone otherwise. This variable determines how often 438C<$AnyEvent::MAX_SIGNAL_LATENCY> - see the Ö<ENVIRONMENT VARIABLES>
439AnyEvent polls for signals (in case a wake-up was missed). Higher values 439section for details.
440will cause fewer spurious wake-ups, which is better for power and CPU
441saving.
442 440
443All these problems can be avoided by installing the optional 441All these problems can be avoided by installing the optional
444L<Async::Interrupt> module, which works with most event loops. It will not 442L<Async::Interrupt> module, which works with most event loops. It will not
445work with inherently broken event loops such as L<Event> or L<Event::Lib> 443work with inherently broken event loops such as L<Event> or L<Event::Lib>
446(and not with L<POE> currently, as POE does its own workaround with 444(and not with L<POE> currently). For those, you just have to suffer the
447one-second latency). For those, you just have to suffer the delays. 445delays.
448 446
449=head2 CHILD PROCESS WATCHERS 447=head2 CHILD PROCESS WATCHERS
450 448
451 $w = AnyEvent->child (pid => <process id>, cb => <callback>); 449 $w = AnyEvent->child (pid => <process id>, cb => <callback>);
452 450
482thing in an AnyEvent program, you I<have> to create at least one 480thing in an AnyEvent program, you I<have> to create at least one
483watcher before you C<fork> the child (alternatively, you can call 481watcher before you C<fork> the child (alternatively, you can call
484C<AnyEvent::detect>). 482C<AnyEvent::detect>).
485 483
486As most event loops do not support waiting for child events, they will be 484As most event loops do not support waiting for child events, they will be
487emulated by AnyEvent in most cases, in which the latency and race problems 485emulated by AnyEvent in most cases, in which case the latency and race
488mentioned in the description of signal watchers apply. 486problems mentioned in the description of signal watchers apply.
489 487
490Example: fork a process and wait for it 488Example: fork a process and wait for it
491 489
492 my $done = AnyEvent->condvar; 490 my $done = AnyEvent->condvar;
493 491
860use. If EV is not installed, then AnyEvent will fall back to its own 858use. If EV is not installed, then AnyEvent will fall back to its own
861pure-perl implementation, which is available everywhere as it comes with 859pure-perl implementation, which is available everywhere as it comes with
862AnyEvent itself. 860AnyEvent itself.
863 861
864 AnyEvent::Impl::EV based on EV (interface to libev, best choice). 862 AnyEvent::Impl::EV based on EV (interface to libev, best choice).
865 AnyEvent::Impl::Perl pure-perl implementation, fast and portable. 863 AnyEvent::Impl::Perl pure-perl AnyEvent::Loop, fast and portable.
866 864
867=item Backends that are transparently being picked up when they are used. 865=item Backends that are transparently being picked up when they are used.
868 866
869These will be used if they are already loaded when the first watcher 867These will be used if they are already loaded when the first watcher
870is created, in which case it is assumed that the application is using 868is created, in which case it is assumed that the application is using
876 AnyEvent::Impl::Glib based on Glib, slow but very stable. 874 AnyEvent::Impl::Glib based on Glib, slow but very stable.
877 AnyEvent::Impl::Tk based on Tk, very broken. 875 AnyEvent::Impl::Tk based on Tk, very broken.
878 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse. 876 AnyEvent::Impl::EventLib based on Event::Lib, leaks memory and worse.
879 AnyEvent::Impl::POE based on POE, very slow, some limitations. 877 AnyEvent::Impl::POE based on POE, very slow, some limitations.
880 AnyEvent::Impl::Irssi used when running within irssi. 878 AnyEvent::Impl::Irssi used when running within irssi.
879 AnyEvent::Impl::IOAsync based on IO::Async.
880 AnyEvent::Impl::Cocoa based on Cocoa::EventLoop.
881 AnyEvent::Impl::FLTK based on FLTK (fltk 2 binding).
881 882
882=item Backends with special needs. 883=item Backends with special needs.
883 884
884Qt requires the Qt::Application to be instantiated first, but will 885Qt requires the Qt::Application to be instantiated first, but will
885otherwise be picked up automatically. As long as the main program 886otherwise be picked up automatically. As long as the main program
886instantiates the application before any AnyEvent watchers are created, 887instantiates the application before any AnyEvent watchers are created,
887everything should just work. 888everything should just work.
888 889
889 AnyEvent::Impl::Qt based on Qt. 890 AnyEvent::Impl::Qt based on Qt.
890
891Support for IO::Async can only be partial, as it is too broken and
892architecturally limited to even support the AnyEvent API. It also
893is the only event loop that needs the loop to be set explicitly, so
894it can only be used by a main program knowing about AnyEvent. See
895L<AnyEvent::Impl::IOAsync> for the gory details.
896
897 AnyEvent::Impl::IOAsync based on IO::Async, cannot be autoprobed.
898 891
899=item Event loops that are indirectly supported via other backends. 892=item Event loops that are indirectly supported via other backends.
900 893
901Some event loops can be supported via other modules: 894Some event loops can be supported via other modules:
902 895
938 931
939Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model 932Returns C<$AnyEvent::MODEL>, forcing autodetection of the event model
940if necessary. You should only call this function right before you would 933if necessary. You should only call this function right before you would
941have created an AnyEvent watcher anyway, that is, as late as possible at 934have created an AnyEvent watcher anyway, that is, as late as possible at
942runtime, and not e.g. during initialisation of your module. 935runtime, and not e.g. during initialisation of your module.
936
937The effect of calling this function is as if a watcher had been created
938(specifically, actions that happen "when the first watcher is created"
939happen when calling detetc as well).
943 940
944If you need to do some initialisation before AnyEvent watchers are 941If you need to do some initialisation before AnyEvent watchers are
945created, use C<post_detect>. 942created, use C<post_detect>.
946 943
947=item $guard = AnyEvent::post_detect { BLOCK } 944=item $guard = AnyEvent::post_detect { BLOCK }
1010 # AnyEvent not yet initialised, so make sure to load Coro::AnyEvent 1007 # AnyEvent not yet initialised, so make sure to load Coro::AnyEvent
1011 # as soon as it is 1008 # as soon as it is
1012 push @AnyEvent::post_detect, sub { require Coro::AnyEvent }; 1009 push @AnyEvent::post_detect, sub { require Coro::AnyEvent };
1013 } 1010 }
1014 1011
1012=item AnyEvent::postpone { BLOCK }
1013
1014Arranges for the block to be executed as soon as possible, but not before
1015the call itself returns. In practise, the block will be executed just
1016before the event loop polls for new events, or shortly afterwards.
1017
1018This function never returns anything (to make the C<return postpone { ...
1019}> idiom more useful.
1020
1021To understand the usefulness of this function, consider a function that
1022asynchronously does something for you and returns some transaction
1023object or guard to let you cancel the operation. For example,
1024C<AnyEvent::Socket::tcp_connect>:
1025
1026 # start a conenction attempt unless one is active
1027 $self->{connect_guard} ||= AnyEvent::Socket::tcp_connect "www.example.net", 80, sub {
1028 delete $self->{connect_guard};
1029 ...
1030 };
1031
1032Imagine that this function could instantly call the callback, for
1033example, because it detects an obvious error such as a negative port
1034number. Invoking the callback before the function returns causes problems
1035however: the callback will be called and will try to delete the guard
1036object. But since the function hasn't returned yet, there is nothing to
1037delete. When the function eventually returns it will assign the guard
1038object to C<< $self->{connect_guard} >>, where it will likely never be
1039deleted, so the program thinks it is still trying to connect.
1040
1041This is where C<AnyEvent::postpone> should be used. Instead of calling the
1042callback directly on error:
1043
1044 $cb->(undef), return # signal error to callback, BAD!
1045 if $some_error_condition;
1046
1047It should use C<postpone>:
1048
1049 AnyEvent::postpone { $cb->(undef) }, return # signal error to callback, later
1050 if $some_error_condition;
1051
1052=item AnyEvent::log $level, $msg[, @args]
1053
1054Log the given C<$msg> at the given C<$level>.
1055
1056If L<AnyEvent::Log> is not loaded then this function makes a simple test
1057to see whether the message will be logged. If the test succeeds it will
1058load AnyEvent::Log and call C<AnyEvent::Log::log> - consequently, look at
1059the L<AnyEvent::Log> documentation for details.
1060
1061If the test fails it will simply return. Right now this happens when a
1062numerical loglevel is used and it is larger than the level specified via
1063C<$ENV{PERL_ANYEVENT_VERBOSE}>.
1064
1065If you want to sprinkle loads of logging calls around your code, consider
1066creating a logger callback with the C<AnyEvent::Log::logger> function,
1067which can reduce typing, codesize and can reduce the logging overhead
1068enourmously.
1069
1015=back 1070=back
1016 1071
1017=head1 WHAT TO DO IN A MODULE 1072=head1 WHAT TO DO IN A MODULE
1018 1073
1019As a module author, you should C<use AnyEvent> and call AnyEvent methods 1074As a module author, you should C<use AnyEvent> and call AnyEvent methods
1052modules might create watchers when they are loaded, and AnyEvent will 1107modules might create watchers when they are loaded, and AnyEvent will
1053decide on the event model to use as soon as it creates watchers, and it 1108decide on the event model to use as soon as it creates watchers, and it
1054might choose the wrong one unless you load the correct one yourself. 1109might choose the wrong one unless you load the correct one yourself.
1055 1110
1056You can chose to use a pure-perl implementation by loading the 1111You can chose to use a pure-perl implementation by loading the
1057C<AnyEvent::Impl::Perl> module, which gives you similar behaviour 1112C<AnyEvent::Loop> module, which gives you similar behaviour
1058everywhere, but letting AnyEvent chose the model is generally better. 1113everywhere, but letting AnyEvent chose the model is generally better.
1059 1114
1060=head2 MAINLOOP EMULATION 1115=head2 MAINLOOP EMULATION
1061 1116
1062Sometimes (often for short test scripts, or even standalone programs who 1117Sometimes (often for short test scripts, or even standalone programs who
1075 1130
1076 1131
1077=head1 OTHER MODULES 1132=head1 OTHER MODULES
1078 1133
1079The following is a non-exhaustive list of additional modules that use 1134The following is a non-exhaustive list of additional modules that use
1080AnyEvent as a client and can therefore be mixed easily with other AnyEvent 1135AnyEvent as a client and can therefore be mixed easily with other
1081modules and other event loops in the same program. Some of the modules 1136AnyEvent modules and other event loops in the same program. Some of the
1082come as part of AnyEvent, the others are available via CPAN. 1137modules come as part of AnyEvent, the others are available via CPAN (see
1138L<http://search.cpan.org/search?m=module&q=anyevent%3A%3A*> for
1139a longer non-exhaustive list), and the list is heavily biased towards
1140modules of the AnyEvent author himself :)
1083 1141
1084=over 4 1142=over 4
1085 1143
1086=item L<AnyEvent::Util> 1144=item L<AnyEvent::Util>
1087 1145
1107=item L<AnyEvent::HTTP>, L<AnyEvent::IRC>, L<AnyEvent::XMPP>, L<AnyEvent::GPSD>, L<AnyEvent::IGS>, L<AnyEvent::FCP> 1165=item L<AnyEvent::HTTP>, L<AnyEvent::IRC>, L<AnyEvent::XMPP>, L<AnyEvent::GPSD>, L<AnyEvent::IGS>, L<AnyEvent::FCP>
1108 1166
1109Implement event-based interfaces to the protocols of the same name (for 1167Implement event-based interfaces to the protocols of the same name (for
1110the curious, IGS is the International Go Server and FCP is the Freenet 1168the curious, IGS is the International Go Server and FCP is the Freenet
1111Client Protocol). 1169Client Protocol).
1112
1113=item L<AnyEvent::Handle::UDP>
1114
1115Here be danger!
1116
1117As Pauli would put it, "Not only is it not right, it's not even wrong!" -
1118there are so many things wrong with AnyEvent::Handle::UDP, most notably
1119its use of a stream-based API with a protocol that isn't streamable, that
1120the only way to improve it is to delete it.
1121
1122It features data corruption (but typically only under load) and general
1123confusion. On top, the author is not only clueless about UDP but also
1124fact-resistant - some gems of his understanding: "connect doesn't work
1125with UDP", "UDP packets are not IP packets", "UDP only has datagrams, not
1126packets", "I don't need to implement proper error checking as UDP doesn't
1127support error checking" and so on - he doesn't even understand what's
1128wrong with his module when it is explained to him.
1129
1130=item L<AnyEvent::DBI>
1131
1132Executes L<DBI> requests asynchronously in a proxy process for you,
1133notifying you in an event-based way when the operation is finished.
1134 1170
1135=item L<AnyEvent::AIO> 1171=item L<AnyEvent::AIO>
1136 1172
1137Truly asynchronous (as opposed to non-blocking) I/O, should be in the 1173Truly asynchronous (as opposed to non-blocking) I/O, should be in the
1138toolbox of every event programmer. AnyEvent::AIO transparently fuses 1174toolbox of every event programmer. AnyEvent::AIO transparently fuses
1139L<IO::AIO> and AnyEvent together, giving AnyEvent access to event-based 1175L<IO::AIO> and AnyEvent together, giving AnyEvent access to event-based
1140file I/O, and much more. 1176file I/O, and much more.
1141 1177
1178=item L<AnyEvent::Filesys::Notify>
1179
1180AnyEvent is good for non-blocking stuff, but it can't detect file or
1181path changes (e.g. "watch this directory for new files", "watch this
1182file for changes"). The L<AnyEvent::Filesys::Notify> module promises to
1183do just that in a portbale fashion, supporting inotify on GNU/Linux and
1184some weird, without doubt broken, stuff on OS X to monitor files. It can
1185fall back to blocking scans at regular intervals transparently on other
1186platforms, so it's about as portable as it gets.
1187
1188(I haven't used it myself, but I haven't heard anybody complaining about
1189it yet).
1190
1191=item L<AnyEvent::DBI>
1192
1193Executes L<DBI> requests asynchronously in a proxy process for you,
1194notifying you in an event-based way when the operation is finished.
1195
1142=item L<AnyEvent::HTTPD> 1196=item L<AnyEvent::HTTPD>
1143 1197
1144A simple embedded webserver. 1198A simple embedded webserver.
1145 1199
1146=item L<AnyEvent::FastPing> 1200=item L<AnyEvent::FastPing>
1147 1201
1148The fastest ping in the west. 1202The fastest ping in the west.
1149 1203
1150=item L<Coro> 1204=item L<Coro>
1151 1205
1152Has special support for AnyEvent via L<Coro::AnyEvent>. 1206Has special support for AnyEvent via L<Coro::AnyEvent>, which allows you
1207to simply invert the flow control - don't call us, we will call you:
1208
1209 async {
1210 Coro::AnyEvent::sleep 5; # creates a 5s timer and waits for it
1211 print "5 seconds later!\n";
1212
1213 Coro::AnyEvent::readable *STDIN; # uses an I/O watcher
1214 my $line = <STDIN>; # works for ttys
1215
1216 AnyEvent::HTTP::http_get "url", Coro::rouse_cb;
1217 my ($body, $hdr) = Coro::rouse_wait;
1218 };
1153 1219
1154=back 1220=back
1155 1221
1156=cut 1222=cut
1157 1223
1158package AnyEvent; 1224package AnyEvent;
1159 1225
1160# basically a tuned-down version of common::sense 1226# basically a tuned-down version of common::sense
1161sub common_sense { 1227sub common_sense {
1162 # from common:.sense 3.3 1228 # from common:.sense 3.4
1163 ${^WARNING_BITS} ^= ${^WARNING_BITS} ^ "\x3c\x3f\x33\x00\x0f\xf3\x0f\xc0\xf0\xfc\x33\x00"; 1229 ${^WARNING_BITS} ^= ${^WARNING_BITS} ^ "\x3c\x3f\x33\x00\x0f\xf0\x0f\xc0\xf0\xfc\x33\x00";
1164 # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl) 1230 # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl)
1165 $^H |= 0x00000600; 1231 $^H |= 0x00000600;
1166} 1232}
1167 1233
1168BEGIN { AnyEvent::common_sense } 1234BEGIN { AnyEvent::common_sense }
1169 1235
1170use Carp (); 1236use Carp ();
1171 1237
1172our $VERSION = '5.271'; 1238our $VERSION = '6.1';
1173our $MODEL; 1239our $MODEL;
1174
1175our $AUTOLOAD;
1176our @ISA; 1240our @ISA;
1177
1178our @REGISTRY; 1241our @REGISTRY;
1179
1180our $VERBOSE; 1242our $VERBOSE;
1243our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred
1244our $MAX_SIGNAL_LATENCY = $ENV{PERL_ANYEVENT_MAX_SIGNAL_LATENCY} || 10; # executes after the BEGIN block below (tainting!)
1181 1245
1182BEGIN { 1246BEGIN {
1183 require "AnyEvent/constants.pl"; 1247 require "AnyEvent/constants.pl";
1184 1248
1185 eval "sub TAINT (){" . (${^TAINT}*1) . "}"; 1249 eval "sub TAINT (){" . (${^TAINT}*1) . "}";
1186 1250
1187 delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV} 1251 delete @ENV{grep /^PERL_ANYEVENT_/, keys %ENV}
1188 if ${^TAINT}; 1252 if ${^TAINT};
1189 1253
1190 $VERBOSE = $ENV{PERL_ANYEVENT_VERBOSE}*1; 1254 $ENV{"PERL_ANYEVENT_$_"} = $ENV{"AE_$_"}
1255 for grep s/^AE_// && !exists $ENV{"PERL_ANYEVENT_$_"}, keys %ENV;
1191 1256
1192} 1257 @ENV{grep /^PERL_ANYEVENT_/, keys %ENV} = ()
1258 if ${^TAINT};
1193 1259
1194our $MAX_SIGNAL_LATENCY = 10; 1260 # $ENV{PERL_ANYEVENT_xxx} now valid
1195 1261
1196our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred 1262 $VERBOSE = length $ENV{PERL_ANYEVENT_VERBOSE} ? $ENV{PERL_ANYEVENT_VERBOSE}*1 : 4;
1197 1263
1198{
1199 my $idx; 1264 my $idx;
1200 $PROTOCOL{$_} = ++$idx 1265 $PROTOCOL{$_} = ++$idx
1201 for reverse split /\s*,\s*/, 1266 for reverse split /\s*,\s*/,
1202 $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6"; 1267 $ENV{PERL_ANYEVENT_PROTOCOLS} || "ipv4,ipv6";
1203} 1268}
1204 1269
1270our @post_detect;
1271
1272sub post_detect(&) {
1273 my ($cb) = @_;
1274
1275 push @post_detect, $cb;
1276
1277 defined wantarray
1278 ? bless \$cb, "AnyEvent::Util::postdetect"
1279 : ()
1280}
1281
1282sub AnyEvent::Util::postdetect::DESTROY {
1283 @post_detect = grep $_ != ${$_[0]}, @post_detect;
1284}
1285
1286our $POSTPONE_W;
1287our @POSTPONE;
1288
1289sub _postpone_exec {
1290 undef $POSTPONE_W;
1291
1292 &{ shift @POSTPONE }
1293 while @POSTPONE;
1294}
1295
1296sub postpone(&) {
1297 push @POSTPONE, shift;
1298
1299 $POSTPONE_W ||= AE::timer (0, 0, \&_postpone_exec);
1300
1301 ()
1302}
1303
1304sub log($$;@) {
1305 # only load the big bloated module when we actually are about to log something
1306 if ($_[0] <= ($VERBOSE || 1)) { # also catches non-numeric levels(!) and fatal
1307 local ($!, $@);
1308 require AnyEvent::Log; # among other things, sets $VERBOSE to 9
1309 # AnyEvent::Log overwrites this function
1310 goto &log;
1311 }
1312
1313 0 # not logged
1314}
1315
1316sub _logger($;$) {
1317 my ($level, $renabled) = @_;
1318
1319 $$renabled = $level <= $VERBOSE;
1320
1321 my $logger = [(caller)[0], $level, $renabled];
1322
1323 $AnyEvent::Log::LOGGER{$logger+0} = $logger;
1324
1325# return unless defined wantarray;
1326#
1327# require AnyEvent::Util;
1328# my $guard = AnyEvent::Util::guard (sub {
1329# # "clean up"
1330# delete $LOGGER{$logger+0};
1331# });
1332#
1333# sub {
1334# return 0 unless $$renabled;
1335#
1336# $guard if 0; # keep guard alive, but don't cause runtime overhead
1337# require AnyEvent::Log unless $AnyEvent::Log::VERSION;
1338# package AnyEvent::Log;
1339# _log ($logger->[0], $level, @_) # logger->[0] has been converted at load time
1340# }
1341}
1342
1343if (length $ENV{PERL_ANYEVENT_LOG}) {
1344 require AnyEvent::Log; # AnyEvent::Log does the thing for us
1345}
1346
1205my @models = ( 1347our @models = (
1206 [EV:: => AnyEvent::Impl::EV:: , 1], 1348 [EV:: => AnyEvent::Impl::EV::],
1207 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl:: , 1], 1349 [AnyEvent::Loop:: => AnyEvent::Impl::Perl::],
1208 # everything below here will not (normally) be autoprobed 1350 # everything below here will not (normally) be autoprobed
1209 # as the pureperl backend should work everywhere 1351 # as the pure perl backend should work everywhere
1210 # and is usually faster 1352 # and is usually faster
1353 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package, so msut be near the top
1211 [Event:: => AnyEvent::Impl::Event::, 1], 1354 [Event:: => AnyEvent::Impl::Event::], # slow, stable
1212 [Glib:: => AnyEvent::Impl::Glib:: , 1], # becomes extremely slow with many watchers 1355 [Glib:: => AnyEvent::Impl::Glib::], # becomes extremely slow with many watchers
1356 # everything below here should not be autoloaded
1213 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 1357 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy
1214 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package
1215 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles 1358 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles
1216 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 1359 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
1217 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 1360 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
1218 [Wx:: => AnyEvent::Impl::POE::], 1361 [Wx:: => AnyEvent::Impl::POE::],
1219 [Prima:: => AnyEvent::Impl::POE::], 1362 [Prima:: => AnyEvent::Impl::POE::],
1220 # IO::Async is just too broken - we would need workarounds for its 1363 [IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # a bitch to autodetect
1221 # byzantine signal and broken child handling, among others. 1364 [Cocoa::EventLoop:: => AnyEvent::Impl::Cocoa::],
1222 # IO::Async is rather hard to detect, as it doesn't have any 1365 [FLTK:: => AnyEvent::Impl::FLTK::],
1223 # obvious default class.
1224 [IO::Async:: => AnyEvent::Impl::IOAsync::], # requires special main program
1225 [IO::Async::Loop:: => AnyEvent::Impl::IOAsync::], # requires special main program
1226 [IO::Async::Notifier:: => AnyEvent::Impl::IOAsync::], # requires special main program
1227 [AnyEvent::Impl::IOAsync:: => AnyEvent::Impl::IOAsync::], # requires special main program
1228); 1366);
1229 1367
1230our %method = map +($_ => 1), 1368our @isa_hook;
1369
1370sub _isa_set {
1371 my @pkg = ("AnyEvent", (map $_->[0], grep defined, @isa_hook), $MODEL);
1372
1373 @{"$pkg[$_-1]::ISA"} = $pkg[$_]
1374 for 1 .. $#pkg;
1375
1376 grep $_ && $_->[1], @isa_hook
1377 and AE::_reset ();
1378}
1379
1380# used for hooking AnyEvent::Strict and AnyEvent::Debug::Wrap into the class hierarchy
1381sub _isa_hook($$;$) {
1382 my ($i, $pkg, $reset_ae) = @_;
1383
1384 $isa_hook[$i] = $pkg ? [$pkg, $reset_ae] : undef;
1385
1386 _isa_set;
1387}
1388
1389# all autoloaded methods reserve the complete glob, not just the method slot.
1390# due to bugs in perls method cache implementation.
1231 qw(io timer time now now_update signal child idle condvar one_event DESTROY); 1391our @methods = qw(io timer time now now_update signal child idle condvar);
1232
1233our @post_detect;
1234
1235sub post_detect(&) {
1236 my ($cb) = @_;
1237
1238 push @post_detect, $cb;
1239
1240 defined wantarray
1241 ? bless \$cb, "AnyEvent::Util::postdetect"
1242 : ()
1243}
1244
1245sub AnyEvent::Util::postdetect::DESTROY {
1246 @post_detect = grep $_ != ${$_[0]}, @post_detect;
1247}
1248 1392
1249sub detect() { 1393sub detect() {
1394 return $MODEL if $MODEL; # some programs keep references to detect
1395
1396 # IO::Async::Loop::AnyEvent is extremely evil, refuse to work with it
1397 # the author knows about the problems and what it does to AnyEvent as a whole
1398 # (and the ability of others to use AnyEvent), but simply wants to abuse AnyEvent
1399 # anyway.
1400 AnyEvent::log fatal => "AnyEvent: IO::Async::Loop::AnyEvent detected - this module is broken by design,\n"
1401 . "abuses internals and breaks AnyEvent, will not continue."
1402 if exists $INC{"IO/Async/Loop/AnyEvent.pm"};
1403
1404 local $!; # for good measure
1405 local $SIG{__DIE__}; # we use eval
1406
1250 # free some memory 1407 # free some memory
1251 *detect = sub () { $MODEL }; 1408 *detect = sub () { $MODEL };
1409 # undef &func doesn't correctly update the method cache. grmbl.
1410 # so we delete the whole glob. grmbl.
1411 # otoh, perl doesn't let me undef an active usb, but it lets me free
1412 # a glob with an active sub. hrm. i hope it works, but perl is
1413 # usually buggy in this department. sigh.
1414 delete @{"AnyEvent::"}{@methods};
1415 undef @methods;
1252 1416
1253 local $!; # for good measure
1254 local $SIG{__DIE__};
1255
1256 if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z]+)$/) { 1417 if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z0-9:]+)$/) {
1257 my $model = "AnyEvent::Impl::$1"; 1418 my $model = $1;
1419 $model = "AnyEvent::Impl::$model" unless $model =~ s/::$//;
1258 if (eval "require $model") { 1420 if (eval "require $model") {
1421 AnyEvent::log 7 => "loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.";
1259 $MODEL = $model; 1422 $MODEL = $model;
1260 warn "AnyEvent: loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.\n" if $VERBOSE >= 2;
1261 } else { 1423 } else {
1262 warn "AnyEvent: unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@" if $VERBOSE; 1424 AnyEvent::log 4 => "unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@";
1263 } 1425 }
1264 } 1426 }
1265 1427
1266 # check for already loaded models 1428 # check for already loaded models
1267 unless ($MODEL) { 1429 unless ($MODEL) {
1268 for (@REGISTRY, @models) { 1430 for (@REGISTRY, @models) {
1269 my ($package, $model) = @$_; 1431 my ($package, $model) = @$_;
1270 if (${"$package\::VERSION"} > 0) { 1432 if (${"$package\::VERSION"} > 0) {
1271 if (eval "require $model") { 1433 if (eval "require $model") {
1434 AnyEvent::log 7 => "autodetected model '$model', using it.";
1272 $MODEL = $model; 1435 $MODEL = $model;
1273 warn "AnyEvent: autodetected model '$model', using it.\n" if $VERBOSE >= 2;
1274 last; 1436 last;
1275 } 1437 }
1276 } 1438 }
1277 } 1439 }
1278 1440
1279 unless ($MODEL) { 1441 unless ($MODEL) {
1280 # try to autoload a model 1442 # try to autoload a model
1281 for (@REGISTRY, @models) { 1443 for (@REGISTRY, @models) {
1282 my ($package, $model, $autoload) = @$_; 1444 my ($package, $model) = @$_;
1283 if ( 1445 if (
1284 $autoload
1285 and eval "require $package" 1446 eval "require $package"
1286 and ${"$package\::VERSION"} > 0 1447 and ${"$package\::VERSION"} > 0
1287 and eval "require $model" 1448 and eval "require $model"
1288 ) { 1449 ) {
1450 AnyEvent::log 7 => "autoloaded model '$model', using it.";
1289 $MODEL = $model; 1451 $MODEL = $model;
1290 warn "AnyEvent: autoloaded model '$model', using it.\n" if $VERBOSE >= 2;
1291 last; 1452 last;
1292 } 1453 }
1293 } 1454 }
1294 1455
1295 $MODEL 1456 $MODEL
1296 or die "No event module selected for AnyEvent and autodetect failed. Install any one of these modules: EV, Event or Glib.\n"; 1457 or AnyEvent::log fatal => "AnyEvent: backend autodetection failed - did you properly install AnyEvent?";
1297 } 1458 }
1298 } 1459 }
1299 1460
1300 @models = (); # free probe data 1461 # free memory only needed for probing
1462 undef @models;
1463 undef @REGISTRY;
1301 1464
1302 push @{"$MODEL\::ISA"}, "AnyEvent::Base"; 1465 push @{"$MODEL\::ISA"}, "AnyEvent::Base";
1303 unshift @ISA, $MODEL;
1304 1466
1305 # now nuke some methods that are overriden by the backend. 1467 # now nuke some methods that are overridden by the backend.
1306 # SUPER is not allowed. 1468 # SUPER usage is not allowed in these.
1307 for (qw(time signal child idle)) { 1469 for (qw(time signal child idle)) {
1308 undef &{"AnyEvent::Base::$_"} 1470 undef &{"AnyEvent::Base::$_"}
1309 if defined &{"$MODEL\::$_"}; 1471 if defined &{"$MODEL\::$_"};
1310 } 1472 }
1311 1473
1312 require AnyEvent::Strict if $ENV{PERL_ANYEVENT_STRICT}; 1474 _isa_set;
1475
1476 # we're officially open!
1477
1478 if ($ENV{PERL_ANYEVENT_STRICT}) {
1479 require AnyEvent::Strict;
1480 }
1481
1482 if ($ENV{PERL_ANYEVENT_DEBUG_WRAP}) {
1483 require AnyEvent::Debug;
1484 AnyEvent::Debug::wrap ($ENV{PERL_ANYEVENT_DEBUG_WRAP});
1485 }
1486
1487 if (length $ENV{PERL_ANYEVENT_DEBUG_SHELL}) {
1488 require AnyEvent::Socket;
1489 require AnyEvent::Debug;
1490
1491 my $shell = $ENV{PERL_ANYEVENT_DEBUG_SHELL};
1492 $shell =~ s/\$\$/$$/g;
1493
1494 my ($host, $service) = AnyEvent::Socket::parse_hostport ($shell);
1495 $AnyEvent::Debug::SHELL = AnyEvent::Debug::shell ($host, $service);
1496 }
1497
1498 # now the anyevent environment is set up as the user told us to, so
1499 # call the actual user code - post detects
1313 1500
1314 (shift @post_detect)->() while @post_detect; 1501 (shift @post_detect)->() while @post_detect;
1502 undef @post_detect;
1315 1503
1316 *post_detect = sub(&) { 1504 *post_detect = sub(&) {
1317 shift->(); 1505 shift->();
1318 1506
1319 undef 1507 undef
1320 }; 1508 };
1321 1509
1322 $MODEL 1510 $MODEL
1323} 1511}
1324 1512
1325sub AUTOLOAD { 1513for my $name (@methods) {
1326 (my $func = $AUTOLOAD) =~ s/.*://; 1514 *$name = sub {
1327
1328 $method{$func}
1329 or Carp::croak "$func: not a valid AnyEvent class method";
1330
1331 detect; 1515 detect;
1332 1516 # we use goto because
1333 my $class = shift; 1517 # a) it makes the thunk more transparent
1334 $class->$func (@_); 1518 # b) it allows us to delete the thunk later
1519 goto &{ UNIVERSAL::can AnyEvent => "SUPER::$name" }
1520 };
1335} 1521}
1336 1522
1337# utility function to dup a filehandle. this is used by many backends 1523# utility function to dup a filehandle. this is used by many backends
1338# to support binding more than one watcher per filehandle (they usually 1524# to support binding more than one watcher per filehandle (they usually
1339# allow only one watcher per fd, so we dup it to get a different one). 1525# allow only one watcher per fd, so we dup it to get a different one).
1363 1549
1364package AE; 1550package AE;
1365 1551
1366our $VERSION = $AnyEvent::VERSION; 1552our $VERSION = $AnyEvent::VERSION;
1367 1553
1554sub _reset() {
1555 eval q{
1368# fall back to the main API by default - backends and AnyEvent::Base 1556 # fall back to the main API by default - backends and AnyEvent::Base
1369# implementations can overwrite these. 1557 # implementations can overwrite these.
1370 1558
1371sub io($$$) { 1559 sub io($$$) {
1372 AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2]) 1560 AnyEvent->io (fh => $_[0], poll => $_[1] ? "w" : "r", cb => $_[2])
1373} 1561 }
1374 1562
1375sub timer($$$) { 1563 sub timer($$$) {
1376 AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2]) 1564 AnyEvent->timer (after => $_[0], interval => $_[1], cb => $_[2])
1377} 1565 }
1378 1566
1379sub signal($$) { 1567 sub signal($$) {
1380 AnyEvent->signal (signal => $_[0], cb => $_[1]) 1568 AnyEvent->signal (signal => $_[0], cb => $_[1])
1381} 1569 }
1382 1570
1383sub child($$) { 1571 sub child($$) {
1384 AnyEvent->child (pid => $_[0], cb => $_[1]) 1572 AnyEvent->child (pid => $_[0], cb => $_[1])
1385} 1573 }
1386 1574
1387sub idle($) { 1575 sub idle($) {
1388 AnyEvent->idle (cb => $_[0]) 1576 AnyEvent->idle (cb => $_[0]);
1389} 1577 }
1390 1578
1391sub cv(;&) { 1579 sub cv(;&) {
1392 AnyEvent->condvar (@_ ? (cb => $_[0]) : ()) 1580 AnyEvent->condvar (@_ ? (cb => $_[0]) : ())
1393} 1581 }
1394 1582
1395sub now() { 1583 sub now() {
1396 AnyEvent->now 1584 AnyEvent->now
1397} 1585 }
1398 1586
1399sub now_update() { 1587 sub now_update() {
1400 AnyEvent->now_update 1588 AnyEvent->now_update
1401} 1589 }
1402 1590
1403sub time() { 1591 sub time() {
1404 AnyEvent->time 1592 AnyEvent->time
1593 }
1594
1595 *postpone = \&AnyEvent::postpone;
1596 *log = \&AnyEvent::log;
1597 };
1598 die if $@;
1405} 1599}
1600
1601BEGIN { _reset }
1406 1602
1407package AnyEvent::Base; 1603package AnyEvent::Base;
1408 1604
1409# default implementations for many methods 1605# default implementations for many methods
1410 1606
1411sub time { 1607sub time {
1412 eval q{ # poor man's autoloading {} 1608 eval q{ # poor man's autoloading {}
1413 # probe for availability of Time::HiRes 1609 # probe for availability of Time::HiRes
1414 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") { 1610 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
1415 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8; 1611 *time = sub { Time::HiRes::time () };
1416 *AE::time = \&Time::HiRes::time; 1612 *AE::time = \& Time::HiRes::time ;
1613 *now = \&time;
1614 AnyEvent::log 8 => "AnyEvent: using Time::HiRes for sub-second timing accuracy.";
1417 # if (eval "use POSIX (); (POSIX::times())... 1615 # if (eval "use POSIX (); (POSIX::times())...
1418 } else { 1616 } else {
1617 *time = sub { CORE::time };
1618 *AE::time = sub (){ CORE::time };
1619 *now = \&time;
1419 warn "AnyEvent: using built-in time(), WARNING, no sub-second resolution!\n" if $VERBOSE; 1620 AnyEvent::log 3 => "using built-in time(), WARNING, no sub-second resolution!";
1420 *AE::time = sub (){ time }; # epic fail
1421 } 1621 }
1422
1423 *time = sub { AE::time }; # different prototypes
1424 }; 1622 };
1425 die if $@; 1623 die if $@;
1426 1624
1427 &time 1625 &time
1428} 1626}
1429 1627
1430*now = \&time; 1628*now = \&time;
1431
1432sub now_update { } 1629sub now_update { }
1433 1630
1631sub _poll {
1632 Carp::croak "$AnyEvent::MODEL does not support blocking waits. Caught";
1633}
1634
1434# default implementation for ->condvar 1635# default implementation for ->condvar
1636# in fact, the default should not be overwritten
1435 1637
1436sub condvar { 1638sub condvar {
1437 eval q{ # poor man's autoloading {} 1639 eval q{ # poor man's autoloading {}
1438 *condvar = sub { 1640 *condvar = sub {
1439 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, "AnyEvent::CondVar" 1641 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, "AnyEvent::CondVar"
1517 1719
1518sub signal { 1720sub signal {
1519 eval q{ # poor man's autoloading {} 1721 eval q{ # poor man's autoloading {}
1520 # probe for availability of Async::Interrupt 1722 # probe for availability of Async::Interrupt
1521 if (_have_async_interrupt) { 1723 if (_have_async_interrupt) {
1522 warn "AnyEvent: using Async::Interrupt for race-free signal handling.\n" if $VERBOSE >= 8; 1724 AnyEvent::log 8 => "using Async::Interrupt for race-free signal handling.";
1523 1725
1524 $SIGPIPE_R = new Async::Interrupt::EventPipe; 1726 $SIGPIPE_R = new Async::Interrupt::EventPipe;
1525 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec; 1727 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
1526 1728
1527 } else { 1729 } else {
1528 warn "AnyEvent: using emulated perl signal handling with latency timer.\n" if $VERBOSE >= 8; 1730 AnyEvent::log 8 => "using emulated perl signal handling with latency timer.";
1529 1731
1530 if (AnyEvent::WIN32) { 1732 if (AnyEvent::WIN32) {
1531 require AnyEvent::Util; 1733 require AnyEvent::Util;
1532 1734
1533 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe (); 1735 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
1609 : sysread $SIGPIPE_R, (my $dummy), 9; 1811 : sysread $SIGPIPE_R, (my $dummy), 9;
1610 1812
1611 while (%SIG_EV) { 1813 while (%SIG_EV) {
1612 for (keys %SIG_EV) { 1814 for (keys %SIG_EV) {
1613 delete $SIG_EV{$_}; 1815 delete $SIG_EV{$_};
1614 $_->() for values %{ $SIG_CB{$_} || {} }; 1816 &$_ for values %{ $SIG_CB{$_} || {} };
1615 } 1817 }
1616 } 1818 }
1617 }; 1819 };
1618 }; 1820 };
1619 die if $@; 1821 die if $@;
1624# default implementation for ->child 1826# default implementation for ->child
1625 1827
1626our %PID_CB; 1828our %PID_CB;
1627our $CHLD_W; 1829our $CHLD_W;
1628our $CHLD_DELAY_W; 1830our $CHLD_DELAY_W;
1629our $WNOHANG;
1630 1831
1631# used by many Impl's 1832# used by many Impl's
1632sub _emit_childstatus($$) { 1833sub _emit_childstatus($$) {
1633 my (undef, $rpid, $rstatus) = @_; 1834 my (undef, $rpid, $rstatus) = @_;
1634 1835
1641 eval q{ # poor man's autoloading {} 1842 eval q{ # poor man's autoloading {}
1642 *_sigchld = sub { 1843 *_sigchld = sub {
1643 my $pid; 1844 my $pid;
1644 1845
1645 AnyEvent->_emit_childstatus ($pid, $?) 1846 AnyEvent->_emit_childstatus ($pid, $?)
1646 while ($pid = waitpid -1, $WNOHANG) > 0; 1847 while ($pid = waitpid -1, WNOHANG) > 0;
1647 }; 1848 };
1648 1849
1649 *child = sub { 1850 *child = sub {
1650 my (undef, %arg) = @_; 1851 my (undef, %arg) = @_;
1651 1852
1652 defined (my $pid = $arg{pid} + 0) 1853 my $pid = $arg{pid};
1653 or Carp::croak "required option 'pid' is missing"; 1854 my $cb = $arg{cb};
1654 1855
1655 $PID_CB{$pid}{$arg{cb}} = $arg{cb}; 1856 $PID_CB{$pid}{$cb+0} = $cb;
1656
1657 # WNOHANG is almost cetrainly 1 everywhere
1658 $WNOHANG ||= $^O =~ /^(?:openbsd|netbsd|linux|freebsd|cygwin|MSWin32)$/
1659 ? 1
1660 : eval { local $SIG{__DIE__}; require POSIX; &POSIX::WNOHANG } || 1;
1661 1857
1662 unless ($CHLD_W) { 1858 unless ($CHLD_W) {
1663 $CHLD_W = AE::signal CHLD => \&_sigchld; 1859 $CHLD_W = AE::signal CHLD => \&_sigchld;
1664 # child could be a zombie already, so make at least one round 1860 # child could be a zombie already, so make at least one round
1665 &_sigchld; 1861 &_sigchld;
1666 } 1862 }
1667 1863
1668 bless [$pid, $arg{cb}], "AnyEvent::Base::child" 1864 bless [$pid, $cb+0], "AnyEvent::Base::child"
1669 }; 1865 };
1670 1866
1671 *AnyEvent::Base::child::DESTROY = sub { 1867 *AnyEvent::Base::child::DESTROY = sub {
1672 my ($pid, $cb) = @{$_[0]}; 1868 my ($pid, $icb) = @{$_[0]};
1673 1869
1674 delete $PID_CB{$pid}{$cb}; 1870 delete $PID_CB{$pid}{$icb};
1675 delete $PID_CB{$pid} unless keys %{ $PID_CB{$pid} }; 1871 delete $PID_CB{$pid} unless keys %{ $PID_CB{$pid} };
1676 1872
1677 undef $CHLD_W unless keys %PID_CB; 1873 undef $CHLD_W unless keys %PID_CB;
1678 }; 1874 };
1679 }; 1875 };
1692 1888
1693 my ($cb, $w, $rcb) = $arg{cb}; 1889 my ($cb, $w, $rcb) = $arg{cb};
1694 1890
1695 $rcb = sub { 1891 $rcb = sub {
1696 if ($cb) { 1892 if ($cb) {
1697 $w = _time; 1893 $w = AE::time;
1698 &$cb; 1894 &$cb;
1699 $w = _time - $w; 1895 $w = AE::time - $w;
1700 1896
1701 # never use more then 50% of the time for the idle watcher, 1897 # never use more then 50% of the time for the idle watcher,
1702 # within some limits 1898 # within some limits
1703 $w = 0.0001 if $w < 0.0001; 1899 $w = 0.0001 if $w < 0.0001;
1704 $w = 5 if $w > 5; 1900 $w = 5 if $w > 5;
1751 1947
1752sub _send { 1948sub _send {
1753 # nop 1949 # nop
1754} 1950}
1755 1951
1952sub _wait {
1953 AnyEvent->_poll until $_[0]{_ae_sent};
1954}
1955
1756sub send { 1956sub send {
1757 my $cv = shift; 1957 my $cv = shift;
1758 $cv->{_ae_sent} = [@_]; 1958 $cv->{_ae_sent} = [@_];
1759 (delete $cv->{_ae_cb})->($cv) if $cv->{_ae_cb}; 1959 (delete $cv->{_ae_cb})->($cv) if $cv->{_ae_cb};
1760 $cv->_send; 1960 $cv->_send;
1767 1967
1768sub ready { 1968sub ready {
1769 $_[0]{_ae_sent} 1969 $_[0]{_ae_sent}
1770} 1970}
1771 1971
1772sub _wait {
1773 $WAITING
1774 and !$_[0]{_ae_sent}
1775 and Carp::croak "AnyEvent::CondVar: recursive blocking wait detected";
1776
1777 local $WAITING = 1;
1778 AnyEvent->one_event while !$_[0]{_ae_sent};
1779}
1780
1781sub recv { 1972sub recv {
1973 unless ($_[0]{_ae_sent}) {
1974 $WAITING
1975 and Carp::croak "AnyEvent::CondVar: recursive blocking wait attempted";
1976
1977 local $WAITING = 1;
1782 $_[0]->_wait; 1978 $_[0]->_wait;
1979 }
1783 1980
1784 Carp::croak $_[0]{_ae_croak} if $_[0]{_ae_croak}; 1981 $_[0]{_ae_croak}
1785 wantarray ? @{ $_[0]{_ae_sent} } : $_[0]{_ae_sent}[0] 1982 and Carp::croak $_[0]{_ae_croak};
1983
1984 wantarray
1985 ? @{ $_[0]{_ae_sent} }
1986 : $_[0]{_ae_sent}[0]
1786} 1987}
1787 1988
1788sub cb { 1989sub cb {
1789 my $cv = shift; 1990 my $cv = shift;
1790 1991
1806 &{ $_[0]{_ae_end_cb} || sub { $_[0]->send } }; 2007 &{ $_[0]{_ae_end_cb} || sub { $_[0]->send } };
1807} 2008}
1808 2009
1809# undocumented/compatibility with pre-3.4 2010# undocumented/compatibility with pre-3.4
1810*broadcast = \&send; 2011*broadcast = \&send;
1811*wait = \&_wait; 2012*wait = \&recv;
1812 2013
1813=head1 ERROR AND EXCEPTION HANDLING 2014=head1 ERROR AND EXCEPTION HANDLING
1814 2015
1815In general, AnyEvent does not do any error handling - it relies on the 2016In general, AnyEvent does not do any error handling - it relies on the
1816caller to do that if required. The L<AnyEvent::Strict> module (see also 2017caller to do that if required. The L<AnyEvent::Strict> module (see also
1828$Event/EV::DIED->() >>, L<Glib> uses C<< install_exception_handler >> and 2029$Event/EV::DIED->() >>, L<Glib> uses C<< install_exception_handler >> and
1829so on. 2030so on.
1830 2031
1831=head1 ENVIRONMENT VARIABLES 2032=head1 ENVIRONMENT VARIABLES
1832 2033
1833The following environment variables are used by this module or its 2034AnyEvent supports a number of environment variables that tune the
1834submodules. 2035runtime behaviour. They are usually evaluated when AnyEvent is
2036loaded, initialised, or a submodule that uses them is loaded. Many of
2037them also cause AnyEvent to load additional modules - for example,
2038C<PERL_ANYEVENT_DEBUG_WRAP> causes the L<AnyEvent::Debug> module to be
2039loaded.
1835 2040
1836Note that AnyEvent will remove I<all> environment variables starting with 2041All the environment variables documented here start with
1837C<PERL_ANYEVENT_> from C<%ENV> when it is loaded while taint mode is 2042C<PERL_ANYEVENT_>, which is what AnyEvent considers its own
1838enabled. 2043namespace. Other modules are encouraged (but by no means required) to use
2044C<PERL_ANYEVENT_SUBMODULE> if they have registered the AnyEvent::Submodule
2045namespace on CPAN, for any submodule. For example, L<AnyEvent::HTTP> could
2046be expected to use C<PERL_ANYEVENT_HTTP_PROXY> (it should not access env
2047variables starting with C<AE_>, see below).
2048
2049All variables can also be set via the C<AE_> prefix, that is, instead
2050of setting C<PERL_ANYEVENT_VERBOSE> you can also set C<AE_VERBOSE>. In
2051case there is a clash btween anyevent and another program that uses
2052C<AE_something> you can set the corresponding C<PERL_ANYEVENT_something>
2053variable to the empty string, as those variables take precedence.
2054
2055When AnyEvent is first loaded, it copies all C<AE_xxx> env variables
2056to their C<PERL_ANYEVENT_xxx> counterpart unless that variable already
2057exists. If taint mode is on, then AnyEvent will remove I<all> environment
2058variables starting with C<PERL_ANYEVENT_> from C<%ENV> (or replace them
2059with C<undef> or the empty string, if the corresaponding C<AE_> variable
2060is set).
2061
2062The exact algorithm is currently:
2063
2064 1. if taint mode enabled, delete all PERL_ANYEVENT_xyz variables from %ENV
2065 2. copy over AE_xyz to PERL_ANYEVENT_xyz unless the latter alraedy exists
2066 3. if taint mode enabled, set all PERL_ANYEVENT_xyz variables to undef.
2067
2068This ensures that child processes will not see the C<AE_> variables.
2069
2070The following environment variables are currently known to AnyEvent:
1839 2071
1840=over 4 2072=over 4
1841 2073
1842=item C<PERL_ANYEVENT_VERBOSE> 2074=item C<PERL_ANYEVENT_VERBOSE>
1843 2075
1844By default, AnyEvent will be completely silent except in fatal 2076By default, AnyEvent will only log messages with loglevel C<3>
1845conditions. You can set this environment variable to make AnyEvent more 2077(C<critical>) or higher (see L<AnyEvent::Log>). You can set this
2078environment variable to a numerical loglevel to make AnyEvent more (or
1846talkative. 2079less) talkative.
1847 2080
2081If you want to do more than just set the global logging level
2082you should have a look at C<PERL_ANYEVENT_LOG>, which allows much more
2083complex specifications.
2084
2085When set to C<0> (C<off>), then no messages whatsoever will be logged with
2086the default logging settings.
2087
1848When set to C<1> or higher, causes AnyEvent to warn about unexpected 2088When set to C<5> or higher (C<warn>), causes AnyEvent to warn about
1849conditions, such as not being able to load the event model specified by 2089unexpected conditions, such as not being able to load the event model
1850C<PERL_ANYEVENT_MODEL>. 2090specified by C<PERL_ANYEVENT_MODEL>, or a guard callback throwing an
2091exception - this is the minimum recommended level.
1851 2092
1852When set to C<2> or higher, cause AnyEvent to report to STDERR which event 2093When set to C<7> or higher (info), cause AnyEvent to report which event model it
1853model it chooses. 2094chooses.
1854 2095
1855When set to C<8> or higher, then AnyEvent will report extra information on 2096When set to C<8> or higher (debug), then AnyEvent will report extra information on
1856which optional modules it loads and how it implements certain features. 2097which optional modules it loads and how it implements certain features.
2098
2099=item C<PERL_ANYEVENT_LOG>
2100
2101Accepts rather complex logging specifications. For example, you could log
2102all C<debug> messages of some module to stderr, warnings and above to
2103stderr, and errors and above to syslog, with:
2104
2105 PERL_ANYEVENT_LOG=Some::Module=debug,+log:filter=warn,+%syslog:%syslog=error,syslog
2106
2107For the rather extensive details, see L<AnyEvent::Log>.
2108
2109This variable is evaluated when AnyEvent (or L<AnyEvent::Log>) is loaded,
2110so will take effect even before AnyEvent has initialised itself.
2111
2112Note that specifying this environment variable causes the L<AnyEvent::Log>
2113module to be loaded, while C<PERL_ANYEVENT_VERBOSE> does not, so only
2114using the latter saves a few hundred kB of memory until the first message
2115is being logged.
1857 2116
1858=item C<PERL_ANYEVENT_STRICT> 2117=item C<PERL_ANYEVENT_STRICT>
1859 2118
1860AnyEvent does not do much argument checking by default, as thorough 2119AnyEvent does not do much argument checking by default, as thorough
1861argument checking is very costly. Setting this variable to a true value 2120argument checking is very costly. Setting this variable to a true value
1868Unlike C<use strict> (or its modern cousin, C<< use L<common::sense> 2127Unlike C<use strict> (or its modern cousin, C<< use L<common::sense>
1869>>, it is definitely recommended to keep it off in production. Keeping 2128>>, it is definitely recommended to keep it off in production. Keeping
1870C<PERL_ANYEVENT_STRICT=1> in your environment while developing programs 2129C<PERL_ANYEVENT_STRICT=1> in your environment while developing programs
1871can be very useful, however. 2130can be very useful, however.
1872 2131
2132=item C<PERL_ANYEVENT_DEBUG_SHELL>
2133
2134If this env variable is nonempty, then its contents will be interpreted by
2135C<AnyEvent::Socket::parse_hostport> and C<AnyEvent::Debug::shell> (after
2136replacing every occurance of C<$$> by the process pid). The shell object
2137is saved in C<$AnyEvent::Debug::SHELL>.
2138
2139This happens when the first watcher is created.
2140
2141For example, to bind a debug shell on a unix domain socket in
2142F<< /tmp/debug<pid>.sock >>, you could use this:
2143
2144 PERL_ANYEVENT_DEBUG_SHELL=/tmp/debug\$\$.sock perlprog
2145 # connect with e.g.: socat readline /tmp/debug123.sock
2146
2147Or to bind to tcp port 4545 on localhost:
2148
2149 PERL_ANYEVENT_DEBUG_SHELL=127.0.0.1:4545 perlprog
2150 # connect with e.g.: telnet localhost 4545
2151
2152Note that creating sockets in F</tmp> or on localhost is very unsafe on
2153multiuser systems.
2154
2155=item C<PERL_ANYEVENT_DEBUG_WRAP>
2156
2157Can be set to C<0>, C<1> or C<2> and enables wrapping of all watchers for
2158debugging purposes. See C<AnyEvent::Debug::wrap> for details.
2159
1873=item C<PERL_ANYEVENT_MODEL> 2160=item C<PERL_ANYEVENT_MODEL>
1874 2161
1875This can be used to specify the event model to be used by AnyEvent, before 2162This can be used to specify the event model to be used by AnyEvent, before
1876auto detection and -probing kicks in. It must be a string consisting 2163auto detection and -probing kicks in.
1877entirely of ASCII letters. The string C<AnyEvent::Impl::> gets prepended 2164
2165It normally is a string consisting entirely of ASCII letters (e.g. C<EV>
2166or C<IOAsync>). The string C<AnyEvent::Impl::> gets prepended and the
1878and the resulting module name is loaded and if the load was successful, 2167resulting module name is loaded and - if the load was successful - used as
1879used as event model. If it fails to load AnyEvent will proceed with 2168event model backend. If it fails to load then AnyEvent will proceed with
1880auto detection and -probing. 2169auto detection and -probing.
1881 2170
1882This functionality might change in future versions. 2171If the string ends with C<::> instead (e.g. C<AnyEvent::Impl::EV::>) then
2172nothing gets prepended and the module name is used as-is (hint: C<::> at
2173the end of a string designates a module name and quotes it appropriately).
1883 2174
1884For example, to force the pure perl model (L<AnyEvent::Impl::Perl>) you 2175For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you
1885could start your program like this: 2176could start your program like this:
1886 2177
1887 PERL_ANYEVENT_MODEL=Perl perl ... 2178 PERL_ANYEVENT_MODEL=Perl perl ...
1888 2179
1889=item C<PERL_ANYEVENT_PROTOCOLS> 2180=item C<PERL_ANYEVENT_PROTOCOLS>
1905but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4> 2196but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4>
1906- only support IPv4, never try to resolve or contact IPv6 2197- only support IPv4, never try to resolve or contact IPv6
1907addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or 2198addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or
1908IPv6, but prefer IPv6 over IPv4. 2199IPv6, but prefer IPv6 over IPv4.
1909 2200
2201=item C<PERL_ANYEVENT_HOSTS>
2202
2203This variable, if specified, overrides the F</etc/hosts> file used by
2204L<AnyEvent::Socket>C<::resolve_sockaddr>, i.e. hosts aliases will be read
2205from that file instead.
2206
1910=item C<PERL_ANYEVENT_EDNS0> 2207=item C<PERL_ANYEVENT_EDNS0>
1911 2208
1912Used by L<AnyEvent::DNS> to decide whether to use the EDNS0 extension 2209Used by L<AnyEvent::DNS> to decide whether to use the EDNS0 extension for
1913for DNS. This extension is generally useful to reduce DNS traffic, but 2210DNS. This extension is generally useful to reduce DNS traffic, especially
1914some (broken) firewalls drop such DNS packets, which is why it is off by 2211when DNSSEC is involved, but some (broken) firewalls drop such DNS
1915default. 2212packets, which is why it is off by default.
1916 2213
1917Setting this variable to C<1> will cause L<AnyEvent::DNS> to announce 2214Setting this variable to C<1> will cause L<AnyEvent::DNS> to announce
1918EDNS0 in its DNS requests. 2215EDNS0 in its DNS requests.
1919 2216
1920=item C<PERL_ANYEVENT_MAX_FORKS> 2217=item C<PERL_ANYEVENT_MAX_FORKS>
1926 2223
1927The default value for the C<max_outstanding> parameter for the default DNS 2224The default value for the C<max_outstanding> parameter for the default DNS
1928resolver - this is the maximum number of parallel DNS requests that are 2225resolver - this is the maximum number of parallel DNS requests that are
1929sent to the DNS server. 2226sent to the DNS server.
1930 2227
2228=item C<PERL_ANYEVENT_MAX_SIGNAL_LATENCY>
2229
2230Perl has inherently racy signal handling (you can basically choose between
2231losing signals and memory corruption) - pure perl event loops (including
2232C<AnyEvent::Loop>, when C<Async::Interrupt> isn't available) therefore
2233have to poll regularly to avoid losing signals.
2234
2235Some event loops are racy, but don't poll regularly, and some event loops
2236are written in C but are still racy. For those event loops, AnyEvent
2237installs a timer that regularly wakes up the event loop.
2238
2239By default, the interval for this timer is C<10> seconds, but you can
2240override this delay with this environment variable (or by setting
2241the C<$AnyEvent::MAX_SIGNAL_LATENCY> variable before creating signal
2242watchers).
2243
2244Lower values increase CPU (and energy) usage, higher values can introduce
2245long delays when reaping children or waiting for signals.
2246
2247The L<AnyEvent::Async> module, if available, will be used to avoid this
2248polling (with most event loops).
2249
1931=item C<PERL_ANYEVENT_RESOLV_CONF> 2250=item C<PERL_ANYEVENT_RESOLV_CONF>
1932 2251
1933The file to use instead of F</etc/resolv.conf> (or OS-specific 2252The absolute path to a F<resolv.conf>-style file to use instead of
1934configuration) in the default resolver. When set to the empty string, no 2253F</etc/resolv.conf> (or the OS-specific configuration) in the default
1935default config will be used. 2254resolver, or the empty string to select the default configuration.
1936 2255
1937=item C<PERL_ANYEVENT_CA_FILE>, C<PERL_ANYEVENT_CA_PATH>. 2256=item C<PERL_ANYEVENT_CA_FILE>, C<PERL_ANYEVENT_CA_PATH>.
1938 2257
1939When neither C<ca_file> nor C<ca_path> was specified during 2258When neither C<ca_file> nor C<ca_path> was specified during
1940L<AnyEvent::TLS> context creation, and either of these environment 2259L<AnyEvent::TLS> context creation, and either of these environment
1941variables exist, they will be used to specify CA certificate locations 2260variables are nonempty, they will be used to specify CA certificate
1942instead of a system-dependent default. 2261locations instead of a system-dependent default.
1943 2262
1944=item C<PERL_ANYEVENT_AVOID_GUARD> and C<PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT> 2263=item C<PERL_ANYEVENT_AVOID_GUARD> and C<PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT>
1945 2264
1946When these are set to C<1>, then the respective modules are not 2265When these are set to C<1>, then the respective modules are not
1947loaded. Mostly good for testing AnyEvent itself. 2266loaded. Mostly good for testing AnyEvent itself.
2279(even when used without AnyEvent), but most event loops have acceptable 2598(even when used without AnyEvent), but most event loops have acceptable
2280performance with or without AnyEvent. 2599performance with or without AnyEvent.
2281 2600
2282=item * The overhead AnyEvent adds is usually much smaller than the overhead of 2601=item * The overhead AnyEvent adds is usually much smaller than the overhead of
2283the actual event loop, only with extremely fast event loops such as EV 2602the actual event loop, only with extremely fast event loops such as EV
2284adds AnyEvent significant overhead. 2603does AnyEvent add significant overhead.
2285 2604
2286=item * You should avoid POE like the plague if you want performance or 2605=item * You should avoid POE like the plague if you want performance or
2287reasonable memory usage. 2606reasonable memory usage.
2288 2607
2289=back 2608=back
2588 2907
2589=item L<Time::HiRes> 2908=item L<Time::HiRes>
2590 2909
2591This module is part of perl since release 5.008. It will be used when the 2910This module is part of perl since release 5.008. It will be used when the
2592chosen event library does not come with a timing source of its own. The 2911chosen event library does not come with a timing source of its own. The
2593pure-perl event loop (L<AnyEvent::Impl::Perl>) will additionally use it to 2912pure-perl event loop (L<AnyEvent::Loop>) will additionally load it to
2594try to use a monotonic clock for timing stability. 2913try to use a monotonic clock for timing stability.
2595 2914
2596=back 2915=back
2597 2916
2598 2917
2664 2983
2665Tutorial/Introduction: L<AnyEvent::Intro>. 2984Tutorial/Introduction: L<AnyEvent::Intro>.
2666 2985
2667FAQ: L<AnyEvent::FAQ>. 2986FAQ: L<AnyEvent::FAQ>.
2668 2987
2669Utility functions: L<AnyEvent::Util>. 2988Utility functions: L<AnyEvent::Util> (misc. grab-bag), L<AnyEvent::Log>
2989(simply logging).
2670 2990
2671Event modules: L<EV>, L<EV::Glib>, L<Glib::EV>, L<Event>, L<Glib::Event>, 2991Development/Debugging: L<AnyEvent::Strict> (stricter checking),
2672L<Glib>, L<Tk>, L<Event::Lib>, L<Qt>, L<POE>. 2992L<AnyEvent::Debug> (interactive shell, watcher tracing).
2993
2994Supported event modules: L<AnyEvent::Loop>, L<EV>, L<EV::Glib>,
2995L<Glib::EV>, L<Event>, L<Glib::Event>, L<Glib>, L<Tk>, L<Event::Lib>,
2996L<Qt>, L<POE>, L<FLTK>.
2673 2997
2674Implementations: L<AnyEvent::Impl::EV>, L<AnyEvent::Impl::Event>, 2998Implementations: L<AnyEvent::Impl::EV>, L<AnyEvent::Impl::Event>,
2675L<AnyEvent::Impl::Glib>, L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>, 2999L<AnyEvent::Impl::Glib>, L<AnyEvent::Impl::Tk>, L<AnyEvent::Impl::Perl>,
2676L<AnyEvent::Impl::EventLib>, L<AnyEvent::Impl::Qt>, 3000L<AnyEvent::Impl::EventLib>, L<AnyEvent::Impl::Qt>,
2677L<AnyEvent::Impl::POE>, L<AnyEvent::Impl::IOAsync>, L<Anyevent::Impl::Irssi>. 3001L<AnyEvent::Impl::POE>, L<AnyEvent::Impl::IOAsync>, L<Anyevent::Impl::Irssi>,
3002L<AnyEvent::Impl::FLTK>.
2678 3003
2679Non-blocking file handles, sockets, TCP clients and 3004Non-blocking handles, pipes, stream sockets, TCP clients and
2680servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>. 3005servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>.
2681 3006
2682Asynchronous DNS: L<AnyEvent::DNS>. 3007Asynchronous DNS: L<AnyEvent::DNS>.
2683 3008
2684Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV L<Coro::Event >, 3009Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>.
2685 3010
2686Nontrivial usage examples: L<AnyEvent::GPSD>, L<AnyEvent::IRC>, 3011Nontrivial usage examples: L<AnyEvent::GPSD>, L<AnyEvent::IRC>,
2687L<AnyEvent::HTTP>. 3012L<AnyEvent::HTTP>.
2688 3013
2689 3014

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines