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.410 by root, Fri Mar 1 06:03:21 2013 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 L<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
765 }; 763 };
766 } 764 }
767 765
768 $cv->end; 766 $cv->end;
769 767
768 ...
769
770 my $results = $cv->recv;
771
770This code fragment supposedly pings a number of hosts and calls 772This code fragment supposedly pings a number of hosts and calls
771C<send> after results for all then have have been gathered - in any 773C<send> after results for all then have have been gathered - in any
772order. To achieve this, the code issues a call to C<begin> when it starts 774order. To achieve this, the code issues a call to C<begin> when it starts
773each ping request and calls C<end> when it has received some result for 775each ping request and calls C<end> when it has received some result for
774it. Since C<begin> and C<end> only maintain a counter, the order in which 776it. Since C<begin> and C<end> only maintain a counter, the order in which
809 811
810In list context, all parameters passed to C<send> will be returned, 812In list context, all parameters passed to C<send> will be returned,
811in scalar context only the first one will be returned. 813in scalar context only the first one will be returned.
812 814
813Note that doing a blocking wait in a callback is not supported by any 815Note that doing a blocking wait in a callback is not supported by any
814event loop, that is, recursive invocation of a blocking C<< ->recv 816event loop, that is, recursive invocation of a blocking C<< ->recv >> is
815>> is not allowed, and the C<recv> call will C<croak> if such a 817not allowed and the C<recv> call will C<croak> if such a condition is
816condition is detected. This condition can be slightly loosened by using 818detected. This requirement can be dropped by relying on L<Coro::AnyEvent>
817L<Coro::AnyEvent>, which allows you to do a blocking C<< ->recv >> from 819, which allows you to do a blocking C<< ->recv >> from any thread
818any thread that doesn't run the event loop itself. 820that doesn't run the event loop itself. L<Coro::AnyEvent> is loaded
821automatically when L<Coro> is used with L<AnyEvent>, so code does not need
822to do anything special to take advantage of that: any code that would
823normally block your program because it calls C<recv>, be executed in an
824C<async> thread instead without blocking other threads.
819 825
820Not all event models support a blocking wait - some die in that case 826Not all event models support a blocking wait - some die in that case
821(programs might want to do that to stay interactive), so I<if you are 827(programs might want to do that to stay interactive), so I<if you are
822using this from a module, never require a blocking wait>. Instead, let the 828using this from a module, never require a blocking wait>. Instead, let the
823caller decide whether the call will block or not (for example, by coupling 829caller decide whether the call will block or not (for example, by coupling
1225 1231
1226package AnyEvent; 1232package AnyEvent;
1227 1233
1228# basically a tuned-down version of common::sense 1234# basically a tuned-down version of common::sense
1229sub common_sense { 1235sub common_sense {
1230 # from common:.sense 3.4 1236 # from common:.sense 3.5
1237 local $^W;
1231 ${^WARNING_BITS} ^= ${^WARNING_BITS} ^ "\x3c\x3f\x33\x00\x0f\xf0\x0f\xc0\xf0\xfc\x33\x00"; 1238 ${^WARNING_BITS} ^= ${^WARNING_BITS} ^ "\x3c\x3f\x33\x00\x0f\xf0\x0f\xc0\xf0\xfc\x33\x00";
1232 # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl) 1239 # use strict vars subs - NO UTF-8, as Util.pm doesn't like this atm. (uts46data.pl)
1233 $^H |= 0x00000600; 1240 $^H |= 0x00000600;
1234} 1241}
1235 1242
1236BEGIN { AnyEvent::common_sense } 1243BEGIN { AnyEvent::common_sense }
1237 1244
1238use Carp (); 1245use Carp ();
1239 1246
1240our $VERSION = '6.02'; 1247our $VERSION = '7.04';
1241our $MODEL; 1248our $MODEL;
1242our @ISA; 1249our @ISA;
1243our @REGISTRY; 1250our @REGISTRY;
1244our $VERBOSE; 1251our $VERBOSE;
1245our $MAX_SIGNAL_LATENCY = 10;
1246our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred 1252our %PROTOCOL; # (ipv4|ipv6) => (1|2), higher numbers are preferred
1253our $MAX_SIGNAL_LATENCY = $ENV{PERL_ANYEVENT_MAX_SIGNAL_LATENCY} || 10; # executes after the BEGIN block below (tainting!)
1247 1254
1248BEGIN { 1255BEGIN {
1249 require "AnyEvent/constants.pl"; 1256 require "AnyEvent/constants.pl";
1250 1257
1251 eval "sub TAINT (){" . (${^TAINT}*1) . "}"; 1258 eval "sub TAINT (){" . (${^TAINT}*1) . "}";
1304} 1311}
1305 1312
1306sub log($$;@) { 1313sub log($$;@) {
1307 # only load the big bloated module when we actually are about to log something 1314 # only load the big bloated module when we actually are about to log something
1308 if ($_[0] <= ($VERBOSE || 1)) { # also catches non-numeric levels(!) and fatal 1315 if ($_[0] <= ($VERBOSE || 1)) { # also catches non-numeric levels(!) and fatal
1316 local ($!, $@);
1309 require AnyEvent::Log; # among other things, sets $VERBOSE to 9 1317 require AnyEvent::Log; # among other things, sets $VERBOSE to 9
1310 # AnyEvent::Log overwrites this function 1318 # AnyEvent::Log overwrites this function
1311 goto &log; 1319 goto &log;
1312 } 1320 }
1313 1321
1314 0 # not logged 1322 0 # not logged
1315} 1323}
1316 1324
1317sub logger($;$) { 1325sub _logger($;$) {
1318 package AnyEvent::Log;
1319
1320 my ($level, $renabled) = @_; 1326 my ($level, $renabled) = @_;
1321 1327
1322 $$renabled = $level <= $VERBOSE; 1328 $$renabled = $level <= $VERBOSE;
1323 1329
1324 my $pkg = (caller)[0];
1325
1326 my $logger = [$pkg, $level, $renabled]; 1330 my $logger = [(caller)[0], $level, $renabled];
1327 1331
1328 our %LOGGER;
1329 $LOGGER{$logger+0} = $logger; 1332 $AnyEvent::Log::LOGGER{$logger+0} = $logger;
1330 1333
1334# return unless defined wantarray;
1335#
1331 require AnyEvent::Util; 1336# require AnyEvent::Util;
1332 my $guard = AnyEvent::Util::guard (sub { 1337# my $guard = AnyEvent::Util::guard (sub {
1333 # "clean up" 1338# # "clean up"
1334 delete $LOGGER{$logger+0}; 1339# delete $LOGGER{$logger+0};
1335 }); 1340# });
1336 1341#
1337 sub { 1342# sub {
1338 return 0 unless $$renabled; 1343# return 0 unless $$renabled;
1339 1344#
1340 $guard if 0; # keep guard alive, but don't cause runtime overhead 1345# $guard if 0; # keep guard alive, but don't cause runtime overhead
1341 require AnyEvent::Log unless $AnyEvent::Log::VERSION; 1346# require AnyEvent::Log unless $AnyEvent::Log::VERSION;
1342 package AnyEvent::Log; 1347# package AnyEvent::Log;
1343 _log ($logger->[0], $level, @_) # logger->[0] has been converted at load time 1348# _log ($logger->[0], $level, @_) # logger->[0] has been converted at load time
1344 } 1349# }
1345} 1350}
1346 1351
1347if (length $ENV{PERL_ANYEVENT_LOG}) { 1352if (length $ENV{PERL_ANYEVENT_LOG}) {
1348 require AnyEvent::Log; # AnyEvent::Log does the thing for us 1353 require AnyEvent::Log; # AnyEvent::Log does the thing for us
1349} 1354}
1350 1355
1351our @models = ( 1356our @models = (
1352 [EV:: => AnyEvent::Impl::EV:: , 1], 1357 [EV:: => AnyEvent::Impl::EV::],
1353 [AnyEvent::Loop:: => AnyEvent::Impl::Perl:: , 1], 1358 [AnyEvent::Loop:: => AnyEvent::Impl::Perl::],
1354 # everything below here will not (normally) be autoprobed 1359 # everything below here will not (normally) be autoprobed
1355 # as the pure perl backend should work everywhere 1360 # as the pure perl backend should work everywhere
1356 # and is usually faster 1361 # and is usually faster
1362 [Irssi:: => AnyEvent::Impl::Irssi::], # Irssi has a bogus "Event" package, so msut be near the top
1357 [Event:: => AnyEvent::Impl::Event::, 1], 1363 [Event:: => AnyEvent::Impl::Event::], # slow, stable
1358 [Glib:: => AnyEvent::Impl::Glib:: , 1], # becomes extremely slow with many watchers 1364 [Glib:: => AnyEvent::Impl::Glib::], # becomes extremely slow with many watchers
1365 # everything below here should not be autoloaded
1359 [Event::Lib:: => AnyEvent::Impl::EventLib::], # too buggy 1366 [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 1367 [Tk:: => AnyEvent::Impl::Tk::], # crashes with many handles
1362 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program 1368 [Qt:: => AnyEvent::Impl::Qt::], # requires special main program
1363 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza 1369 [POE::Kernel:: => AnyEvent::Impl::POE::], # lasciate ogni speranza
1364 [Wx:: => AnyEvent::Impl::POE::], 1370 [Wx:: => AnyEvent::Impl::POE::],
1365 [Prima:: => AnyEvent::Impl::POE::], 1371 [Prima:: => AnyEvent::Impl::POE::],
1394our @methods = qw(io timer time now now_update signal child idle condvar); 1400our @methods = qw(io timer time now now_update signal child idle condvar);
1395 1401
1396sub detect() { 1402sub detect() {
1397 return $MODEL if $MODEL; # some programs keep references to detect 1403 return $MODEL if $MODEL; # some programs keep references to detect
1398 1404
1405 # IO::Async::Loop::AnyEvent is extremely evil, refuse to work with it
1406 # the author knows about the problems and what it does to AnyEvent as a whole
1407 # (and the ability of others to use AnyEvent), but simply wants to abuse AnyEvent
1408 # anyway.
1409 AnyEvent::log fatal => "IO::Async::Loop::AnyEvent detected - that module is broken by\n"
1410 . "design, abuses internals and breaks AnyEvent - will not continue."
1411 if exists $INC{"IO/Async/Loop/AnyEvent.pm"};
1412
1399 local $!; # for good measure 1413 local $!; # for good measure
1400 local $SIG{__DIE__}; # we use eval 1414 local $SIG{__DIE__}; # we use eval
1401 1415
1402 # free some memory 1416 # free some memory
1403 *detect = sub () { $MODEL }; 1417 *detect = sub () { $MODEL };
1411 1425
1412 if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z0-9:]+)$/) { 1426 if ($ENV{PERL_ANYEVENT_MODEL} =~ /^([a-zA-Z0-9:]+)$/) {
1413 my $model = $1; 1427 my $model = $1;
1414 $model = "AnyEvent::Impl::$model" unless $model =~ s/::$//; 1428 $model = "AnyEvent::Impl::$model" unless $model =~ s/::$//;
1415 if (eval "require $model") { 1429 if (eval "require $model") {
1416 AnyEvent::log 7 => "loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it."; 1430 AnyEvent::log 7 => "Loaded model '$model' (forced by \$ENV{PERL_ANYEVENT_MODEL}), using it.";
1417 $MODEL = $model; 1431 $MODEL = $model;
1418 } else { 1432 } else {
1419 AnyEvent::log 4 => "unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@"; 1433 AnyEvent::log 4 => "Unable to load model '$model' (from \$ENV{PERL_ANYEVENT_MODEL}):\n$@";
1420 } 1434 }
1421 } 1435 }
1422 1436
1423 # check for already loaded models 1437 # check for already loaded models
1424 unless ($MODEL) { 1438 unless ($MODEL) {
1425 for (@REGISTRY, @models) { 1439 for (@REGISTRY, @models) {
1426 my ($package, $model) = @$_; 1440 my ($package, $model) = @$_;
1427 if (${"$package\::VERSION"} > 0) { 1441 if (${"$package\::VERSION"} > 0) {
1428 if (eval "require $model") { 1442 if (eval "require $model") {
1429 AnyEvent::log 7 => "autodetected model '$model', using it."; 1443 AnyEvent::log 7 => "Autodetected model '$model', using it.";
1444 $MODEL = $model;
1445 last;
1446 } else {
1447 AnyEvent::log 8 => "Detected event loop $package, but cannot load '$model', skipping: $@";
1448 }
1449 }
1450 }
1451
1452 unless ($MODEL) {
1453 # try to autoload a model
1454 for (@REGISTRY, @models) {
1455 my ($package, $model) = @$_;
1456 if (
1457 eval "require $package"
1458 and ${"$package\::VERSION"} > 0
1459 and eval "require $model"
1460 ) {
1461 AnyEvent::log 7 => "Autoloaded model '$model', using it.";
1430 $MODEL = $model; 1462 $MODEL = $model;
1431 last; 1463 last;
1432 } 1464 }
1433 } 1465 }
1434 }
1435
1436 unless ($MODEL) {
1437 # try to autoload a model
1438 for (@REGISTRY, @models) {
1439 my ($package, $model, $autoload) = @$_;
1440 if (
1441 $autoload
1442 and eval "require $package"
1443 and ${"$package\::VERSION"} > 0
1444 and eval "require $model"
1445 ) {
1446 AnyEvent::log 7 => "autoloaded model '$model', using it.";
1447 $MODEL = $model;
1448 last;
1449 }
1450 }
1451 1466
1452 $MODEL 1467 $MODEL
1453 or AnyEvent::log fatal => "AnyEvent: backend autodetection failed - did you properly install AnyEvent?"; 1468 or AnyEvent::log fatal => "Backend autodetection failed - did you properly install AnyEvent?";
1454 } 1469 }
1455 } 1470 }
1456 1471
1457 # free memory only needed for probing 1472 # free memory only needed for probing
1458 undef @models; 1473 undef @models;
1605 # probe for availability of Time::HiRes 1620 # probe for availability of Time::HiRes
1606 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") { 1621 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
1607 *time = sub { Time::HiRes::time () }; 1622 *time = sub { Time::HiRes::time () };
1608 *AE::time = \& Time::HiRes::time ; 1623 *AE::time = \& Time::HiRes::time ;
1609 *now = \&time; 1624 *now = \&time;
1610 AnyEvent::log 8 => "AnyEvent: using Time::HiRes for sub-second timing accuracy."; 1625 AnyEvent::log 8 => "using Time::HiRes for sub-second timing accuracy.";
1611 # if (eval "use POSIX (); (POSIX::times())... 1626 # if (eval "use POSIX (); (POSIX::times())...
1612 } else { 1627 } else {
1613 *time = sub { CORE::time }; 1628 *time = sub { CORE::time };
1614 *AE::time = sub (){ CORE::time }; 1629 *AE::time = sub (){ CORE::time };
1615 *now = \&time; 1630 *now = \&time;
1616 AnyEvent::log 3 => "using built-in time(), WARNING, no sub-second resolution!"; 1631 AnyEvent::log 3 => "Using built-in time(), no sub-second resolution!";
1617 } 1632 }
1618 }; 1633 };
1619 die if $@; 1634 die if $@;
1620 1635
1621 &time 1636 &time
1715 1730
1716sub signal { 1731sub signal {
1717 eval q{ # poor man's autoloading {} 1732 eval q{ # poor man's autoloading {}
1718 # probe for availability of Async::Interrupt 1733 # probe for availability of Async::Interrupt
1719 if (_have_async_interrupt) { 1734 if (_have_async_interrupt) {
1720 AnyEvent::log 8 => "using Async::Interrupt for race-free signal handling."; 1735 AnyEvent::log 8 => "Using Async::Interrupt for race-free signal handling.";
1721 1736
1722 $SIGPIPE_R = new Async::Interrupt::EventPipe; 1737 $SIGPIPE_R = new Async::Interrupt::EventPipe;
1723 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec; 1738 $SIG_IO = AE::io $SIGPIPE_R->fileno, 0, \&_signal_exec;
1724 1739
1725 } else { 1740 } else {
1726 AnyEvent::log 8 => "using emulated perl signal handling with latency timer."; 1741 AnyEvent::log 8 => "Using emulated perl signal handling with latency timer.";
1727 1742
1728 if (AnyEvent::WIN32) { 1743 if (AnyEvent::WIN32) {
1729 require AnyEvent::Util; 1744 require AnyEvent::Util;
1730 1745
1731 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe (); 1746 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
2067 2082
2068=over 4 2083=over 4
2069 2084
2070=item C<PERL_ANYEVENT_VERBOSE> 2085=item C<PERL_ANYEVENT_VERBOSE>
2071 2086
2072By default, AnyEvent will only log messages with loglevel C<3> 2087By default, AnyEvent will log messages with loglevel C<4> (C<error>) or
2073(C<critical>) or higher (see L<AnyEvent::Log>). You can set this 2088higher (see L<AnyEvent::Log>). You can set this environment variable to a
2074environment variable to a numerical loglevel to make AnyEvent more (or 2089numerical loglevel to make AnyEvent more (or less) talkative.
2075less) talkative.
2076 2090
2077If you want to do more than just set the global logging level 2091If you want to do more than just set the global logging level
2078you should have a look at C<PERL_ANYEVENT_LOG>, which allows much more 2092you should have a look at C<PERL_ANYEVENT_LOG>, which allows much more
2079complex specifications. 2093complex specifications.
2080 2094
2081When set to C<0> (C<off>), then no messages whatsoever will be logged with 2095When set to C<0> (C<off>), then no messages whatsoever will be logged with
2082the default logging settings. 2096everything else at defaults.
2083 2097
2084When set to C<5> or higher (C<warn>), causes AnyEvent to warn about 2098When set to C<5> or higher (C<warn>), AnyEvent warns about unexpected
2085unexpected conditions, such as not being able to load the event model 2099conditions, such as not being able to load the event model specified by
2086specified by C<PERL_ANYEVENT_MODEL>, or a guard callback throwing an 2100C<PERL_ANYEVENT_MODEL>, or a guard callback throwing an exception - this
2087exception - this is the minimum recommended level. 2101is the minimum recommended level for use during development.
2088 2102
2089When set to C<7> or higher (info), cause AnyEvent to report which event model it 2103When set to C<7> or higher (info), AnyEvent reports which event model it
2090chooses. 2104chooses.
2091 2105
2092When set to C<8> or higher (debug), then AnyEvent will report extra information on 2106When set to C<8> or higher (debug), then AnyEvent will report extra
2093which optional modules it loads and how it implements certain features. 2107information on which optional modules it loads and how it implements
2108certain features.
2094 2109
2095=item C<PERL_ANYEVENT_LOG> 2110=item C<PERL_ANYEVENT_LOG>
2096 2111
2097Accepts rather complex logging specifications. For example, you could log 2112Accepts rather complex logging specifications. For example, you could log
2098all C<debug> messages of some module to stderr, warnings and above to 2113all C<debug> messages of some module to stderr, warnings and above to
2105This variable is evaluated when AnyEvent (or L<AnyEvent::Log>) is loaded, 2120This variable is evaluated when AnyEvent (or L<AnyEvent::Log>) is loaded,
2106so will take effect even before AnyEvent has initialised itself. 2121so will take effect even before AnyEvent has initialised itself.
2107 2122
2108Note that specifying this environment variable causes the L<AnyEvent::Log> 2123Note that specifying this environment variable causes the L<AnyEvent::Log>
2109module to be loaded, while C<PERL_ANYEVENT_VERBOSE> does not, so only 2124module to be loaded, while C<PERL_ANYEVENT_VERBOSE> does not, so only
2110using the latter saves a few hundred kB of memory until the first message 2125using the latter saves a few hundred kB of memory unless a module
2111is being logged. 2126explicitly needs the extra features of AnyEvent::Log.
2112 2127
2113=item C<PERL_ANYEVENT_STRICT> 2128=item C<PERL_ANYEVENT_STRICT>
2114 2129
2115AnyEvent does not do much argument checking by default, as thorough 2130AnyEvent does not do much argument checking by default, as thorough
2116argument checking is very costly. Setting this variable to a true value 2131argument checking is very costly. Setting this variable to a true value
2171For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you 2186For example, to force the pure perl model (L<AnyEvent::Loop::Perl>) you
2172could start your program like this: 2187could start your program like this:
2173 2188
2174 PERL_ANYEVENT_MODEL=Perl perl ... 2189 PERL_ANYEVENT_MODEL=Perl perl ...
2175 2190
2191=item C<PERL_ANYEVENT_IO_MODEL>
2192
2193The current file I/O model - see L<AnyEvent::IO> for more info.
2194
2195At the moment, only C<Perl> (small, pure-perl, synchronous) and
2196C<IOAIO> (truly asynchronous) are supported. The default is C<IOAIO> if
2197L<AnyEvent::AIO> can be loaded, otherwise it is C<Perl>.
2198
2176=item C<PERL_ANYEVENT_PROTOCOLS> 2199=item C<PERL_ANYEVENT_PROTOCOLS>
2177 2200
2178Used by both L<AnyEvent::DNS> and L<AnyEvent::Socket> to determine preferences 2201Used by both L<AnyEvent::DNS> and L<AnyEvent::Socket> to determine preferences
2179for IPv4 or IPv6. The default is unspecified (and might change, or be the result 2202for IPv4 or IPv6. The default is unspecified (and might change, or be the result
2180of auto probing). 2203of auto probing).
2218=item C<PERL_ANYEVENT_MAX_OUTSTANDING_DNS> 2241=item C<PERL_ANYEVENT_MAX_OUTSTANDING_DNS>
2219 2242
2220The default value for the C<max_outstanding> parameter for the default DNS 2243The default value for the C<max_outstanding> parameter for the default DNS
2221resolver - this is the maximum number of parallel DNS requests that are 2244resolver - this is the maximum number of parallel DNS requests that are
2222sent to the DNS server. 2245sent to the DNS server.
2246
2247=item C<PERL_ANYEVENT_MAX_SIGNAL_LATENCY>
2248
2249Perl has inherently racy signal handling (you can basically choose between
2250losing signals and memory corruption) - pure perl event loops (including
2251C<AnyEvent::Loop>, when C<Async::Interrupt> isn't available) therefore
2252have to poll regularly to avoid losing signals.
2253
2254Some event loops are racy, but don't poll regularly, and some event loops
2255are written in C but are still racy. For those event loops, AnyEvent
2256installs a timer that regularly wakes up the event loop.
2257
2258By default, the interval for this timer is C<10> seconds, but you can
2259override this delay with this environment variable (or by setting
2260the C<$AnyEvent::MAX_SIGNAL_LATENCY> variable before creating signal
2261watchers).
2262
2263Lower values increase CPU (and energy) usage, higher values can introduce
2264long delays when reaping children or waiting for signals.
2265
2266The L<AnyEvent::Async> module, if available, will be used to avoid this
2267polling (with most event loops).
2223 2268
2224=item C<PERL_ANYEVENT_RESOLV_CONF> 2269=item C<PERL_ANYEVENT_RESOLV_CONF>
2225 2270
2226The absolute path to a F<resolv.conf>-style file to use instead of 2271The 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 2272F</etc/resolv.conf> (or the OS-specific configuration) in the default
2884This module is part of perl since release 5.008. It will be used when the 2929This module is part of perl since release 5.008. It will be used when the
2885chosen event library does not come with a timing source of its own. The 2930chosen event library does not come with a timing source of its own. The
2886pure-perl event loop (L<AnyEvent::Loop>) will additionally load it to 2931pure-perl event loop (L<AnyEvent::Loop>) will additionally load it to
2887try to use a monotonic clock for timing stability. 2932try to use a monotonic clock for timing stability.
2888 2933
2934=item L<AnyEvent::AIO> (and L<IO::AIO>)
2935
2936The default implementation of L<AnyEvent::IO> is to do I/O synchronously,
2937stopping programs while they access the disk, which is fine for a lot of
2938programs.
2939
2940Installing AnyEvent::AIO (and its IO::AIO dependency) makes it switch to
2941a true asynchronous implementation, so event processing can continue even
2942while waiting for disk I/O.
2943
2889=back 2944=back
2890 2945
2891 2946
2892=head1 FORK 2947=head1 FORK
2893 2948
2976L<AnyEvent::Impl::FLTK>. 3031L<AnyEvent::Impl::FLTK>.
2977 3032
2978Non-blocking handles, pipes, stream sockets, TCP clients and 3033Non-blocking handles, pipes, stream sockets, TCP clients and
2979servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>. 3034servers: L<AnyEvent::Handle>, L<AnyEvent::Socket>, L<AnyEvent::TLS>.
2980 3035
3036Asynchronous File I/O: L<AnyEvent::IO>.
3037
2981Asynchronous DNS: L<AnyEvent::DNS>. 3038Asynchronous DNS: L<AnyEvent::DNS>.
2982 3039
2983Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>. 3040Thread support: L<Coro>, L<Coro::AnyEvent>, L<Coro::EV>, L<Coro::Event>.
2984 3041
2985Nontrivial usage examples: L<AnyEvent::GPSD>, L<AnyEvent::IRC>, 3042Nontrivial usage examples: L<AnyEvent::GPSD>, L<AnyEvent::IRC>,
2987 3044
2988 3045
2989=head1 AUTHOR 3046=head1 AUTHOR
2990 3047
2991 Marc Lehmann <schmorp@schmorp.de> 3048 Marc Lehmann <schmorp@schmorp.de>
2992 http://home.schmorp.de/ 3049 http://anyevent.schmorp.de
2993 3050
2994=cut 3051=cut
2995 3052
29961 30531
2997 3054

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines