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.384 by root, Mon Sep 5 07:21:54 2011 UTC vs.
Revision 1.387 by root, Sat Oct 1 22:39:29 2011 UTC

… …
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
… …
1240our $VERSION = '6.02'; 1238our $VERSION = '6.02';
1241our $MODEL; 1239our $MODEL;
1242our @ISA; 1240our @ISA;
1243our @REGISTRY; 1241our @REGISTRY;
1244our $VERBOSE; 1242our $VERBOSE;
1245our $MAX_SIGNAL_LATENCY = 10;
1246our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred 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!)
1247 1245
1248BEGIN { 1246BEGIN {
1249 require "AnyEvent/constants.pl"; 1247 require "AnyEvent/constants.pl";
1250 1248
1251 eval "sub TAINT (){" . (${^TAINT}*1) . "}"; 1249 eval "sub TAINT (){" . (${^TAINT}*1) . "}";
… …
1347if (length $ENV{PERL_ANYEVENT_LOG}) { 1345if (length $ENV{PERL_ANYEVENT_LOG}) {
1348 require AnyEvent::Log; # AnyEvent::Log does the thing for us 1346 require AnyEvent::Log; # AnyEvent::Log does the thing for us
1349} 1347}
1350 1348
1351our @models = ( 1349our @models = (
1352 [EV:: => AnyEvent::Impl::EV:: , 1], 1350 [EV:: => AnyEvent::Impl::EV::],
1353 [AnyEvent::Loop:: => AnyEvent::Impl::Perl:: , 1], 1351 [AnyEvent::Loop:: => AnyEvent::Impl::Perl::],
1354 # everything below here will not (normally) be autoprobed 1352 # everything below here will not (normally) be autoprobed
1355 # as the pure perl backend should work everywhere 1353 # as the pure perl backend should work everywhere
1356 # and is usually faster 1354 # and is usually faster
1355 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package, so msut be near the top
1357 [Event:: => AnyEvent::Impl::Event::, 1], 1356 [Event:: => AnyEvent::Impl::Event::], # slow, stable
1358 [Glib:: => AnyEvent::Impl::Glib:: , 1], # becomes extremely slow with many watchers 1357 [Glib:: => AnyEvent::Impl::Glib::], # becomes extremely slow with many watchers
1358 # everything below here should not be autoloaded
1359 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 1359 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy
1360 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package
1361 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles 1360 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles
1362 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 1361 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
1363 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 1362 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
1364 [Wx:: => AnyEvent::Impl::POE::], 1363 [Wx:: => AnyEvent::Impl::POE::],
1365 [Prima:: => AnyEvent::Impl::POE::], 1364 [Prima:: => AnyEvent::Impl::POE::],
… …
1393# due to bugs in perls method cache implementation. 1392# due to bugs in perls method cache implementation.
1394our @methods = qw(io timer time now now_update signal child idle condvar); 1393our @methods = qw(io timer time now now_update signal child idle condvar);
1395 1394
1396sub detect() { 1395sub detect() {
1397 return $MODEL if $MODEL; # some programs keep references to detect 1396 return $MODEL if $MODEL; # some programs keep references to detect
1397
1398 # IO::Async::Loop::AnyEvent is extremely evil, refuse to work with it
1399 # the author knows about the problems and what it does to AnyEvent as a whole
1400 # (and the ability of others to use AnyEvent), but simply wants to abuse AnyEvent
1401 # anyway.
1402 AnyEvent::log fatal => "AnyEvent: IO::Async::Loop::AnyEvent detected - this module is broken by design,\n"
1403 . "abuses internals and breaks AnyEvent, will not continue."
1404 if exists $INC{"IO/Async/Loop/AnyEvent.pm"};
1398 1405
1399 local $!; # for good measure 1406 local $!; # for good measure
1400 local $SIG{__DIE__}; # we use eval 1407 local $SIG{__DIE__}; # we use eval
1401 1408
1402 # free some memory 1409 # free some memory
… …
1434 } 1441 }
1435 1442
1436 unless ($MODEL) { 1443 unless ($MODEL) {
1437 # try to autoload a model 1444 # try to autoload a model
1438 for (@REGISTRY, @models) { 1445 for (@REGISTRY, @models) {
1439 my ($package, $model, $autoload) = @$_; 1446 my ($package, $model) = @$_;
1440 if ( 1447 if (
1441 $autoload
1442 and eval "require $package" 1448 eval "require $package"
1443 and ${"$package\::VERSION"} > 0 1449 and ${"$package\::VERSION"} > 0
1444 and eval "require $model" 1450 and eval "require $model"
1445 ) { 1451 ) {
1446 AnyEvent::log 7 => "autoloaded model '$model', using it."; 1452 AnyEvent::log 7 => "autoloaded model '$model', using it.";
1447 $MODEL = $model; 1453 $MODEL = $model;
… …
2219 2225
2220The default value for the C<max_outstanding> parameter for the default DNS 2226The default value for the C<max_outstanding> parameter for the default DNS
2221resolver - this is the maximum number of parallel DNS requests that are 2227resolver - this is the maximum number of parallel DNS requests that are
2222sent to the DNS server. 2228sent to the DNS server.
2223 2229
2230=item C<PERL_ANYEVENT_MAX_SIGNAL_LATENCY>
2231
2232Perl has inherently racy signal handling (you can basically choose between
2233losing signals and memory corruption) - pure perl event loops (including
2234C<AnyEvent::Loop>, when C<Async::Interrupt> isn't available) therefore
2235have to poll regularly to avoid losing signals.
2236
2237Some event loops are racy, but don't poll regularly, and some event loops
2238are written in C but are still racy. For those event loops, AnyEvent
2239installs a timer that regularly wakes up the event loop.
2240
2241By default, the interval for this timer is C<10> seconds, but you can
2242override this delay with this environment variable (or by setting
2243the C<$AnyEvent::MAX_SIGNAL_LATENCY> variable before creating signal
2244watchers).
2245
2246Lower values increase CPU (and energy) usage, higher values can introduce
2247long delays when reaping children or waiting for signals.
2248
2249The L<AnyEvent::Async> module, if available, will be used to avoid this
2250polling (with most event loops).
2251
2224=item C<PERL_ANYEVENT_RESOLV_CONF> 2252=item C<PERL_ANYEVENT_RESOLV_CONF>
2225 2253
2226The absolute path to a F<resolv.conf>-style file to use instead of 2254The absolute path to a F<resolv.conf>-style file to use instead of
2227F</etc/resolv.conf> (or the OS-specific configuration) in the default 2255F</etc/resolv.conf> (or the OS-specific configuration) in the default
2228resolver, or the empty string to select the default configuration. 2256resolver, or the empty string to select the default configuration.

Diff Legend

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