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.286 by root, Fri Aug 21 11:59:25 2009 UTC vs.
Revision 1.300 by root, Tue Dec 1 17:56:28 2009 UTC

… …
363might affect timers and time-outs. 363might affect timers and time-outs.
364 364
365When this is the case, you can call this method, which will update the 365When this is the case, you can call this method, which will update the
366event loop's idea of "current time". 366event loop's idea of "current time".
367 367
368A typical example would be a script in a web server (e.g. C<mod_perl>) -
369when mod_perl executes the script, then the event loop will have the wrong
370idea about the "current time" (being potentially far in the past, when the
371script ran the last time). In that case you should arrange a call to C<<
372AnyEvent->now_update >> each time the web server process wakes up again
373(e.g. at the start of your script, or in a handler).
374
368Note that updating the time I<might> cause some events to be handled. 375Note that updating the time I<might> cause some events to be handled.
369 376
370=back 377=back
371 378
372=head2 SIGNAL WATCHERS 379=head2 SIGNAL WATCHERS
… …
395correctly. 402correctly.
396 403
397Example: exit on SIGINT 404Example: exit on SIGINT
398 405
399 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 }); 406 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 });
407
408=head3 Restart Behaviour
409
410While restart behaviour is up to the event loop implementation, most will
411not restart syscalls (that includes L<Async::Interrupt> and AnyEvent's
412pure perl implementation).
413
414=head3 Safe/Unsafe Signals
415
416Perl signals can be either "safe" (synchronous to opcode handling) or
417"unsafe" (asynchronous) - the former might get delayed indefinitely, the
418latter might corrupt your memory.
419
420AnyEvent signal handlers are, in addition, synchronous to the event loop,
421i.e. they will not interrupt your running perl program but will only be
422called as part of the normal event handling (just like timer, I/O etc.
423callbacks, too).
400 424
401=head3 Signal Races, Delays and Workarounds 425=head3 Signal Races, Delays and Workarounds
402 426
403Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching 427Many event loops (e.g. Glib, Tk, Qt, IO::Async) do not support attaching
404callbacks to signals in a generic way, which is a pity, as you cannot 428callbacks to signals in a generic way, which is a pity, as you cannot
… …
1106 1130
1107package AnyEvent; 1131package AnyEvent;
1108 1132
1109# basically a tuned-down version of common::sense 1133# basically a tuned-down version of common::sense
1110sub common_sense { 1134sub common_sense {
1111 # no warnings 1135 # from common:.sense 1.0
1112 ${^WARNING_BITS} ^= ${^WARNING_BITS}; 1136 ${^WARNING_BITS} = "\xfc\x3f\xf3\x00\x0f\xf3\xcf\xc0\xf3\xfc\x33\x03";
1113 # use strict vars subs 1137 # use strict vars subs
1114 $^H |= 0x00000600; 1138 $^H |= 0x00000600;
1115} 1139}
1116 1140
1117BEGIN { AnyEvent::common_sense } 1141BEGIN { AnyEvent::common_sense }
1118 1142
1119use Carp (); 1143use Carp ();
1120 1144
1121our $VERSION = '5.112'; 1145our $VERSION = '5.21';
1122our $MODEL; 1146our $MODEL;
1123 1147
1124our $AUTOLOAD; 1148our $AUTOLOAD;
1125our @ISA; 1149our @ISA;
1126 1150
1127our @REGISTRY; 1151our @REGISTRY;
1128
1129our $WIN32;
1130 1152
1131our $VERBOSE; 1153our $VERBOSE;
1132 1154
1133BEGIN { 1155BEGIN {
1134 eval "sub WIN32(){ " . (($^O =~ /mswin32/i)*1) ." }"; 1156 eval "sub WIN32(){ " . (($^O =~ /mswin32/i)*1) ." }";
… …
1343 1365
1344package AnyEvent::Base; 1366package AnyEvent::Base;
1345 1367
1346# default implementations for many methods 1368# default implementations for many methods
1347 1369
1348sub _time { 1370sub _time() {
1349 # probe for availability of Time::HiRes 1371 # probe for availability of Time::HiRes
1350 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") { 1372 if (eval "use Time::HiRes (); Time::HiRes::time (); 1") {
1351 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8; 1373 warn "AnyEvent: using Time::HiRes for sub-second timing accuracy.\n" if $VERBOSE >= 8;
1352 *_time = \&Time::HiRes::time; 1374 *_time = \&Time::HiRes::time;
1353 # if (eval "use POSIX (); (POSIX::times())... 1375 # if (eval "use POSIX (); (POSIX::times())...
… …
1373 1395
1374our $HAVE_ASYNC_INTERRUPT; 1396our $HAVE_ASYNC_INTERRUPT;
1375 1397
1376sub _have_async_interrupt() { 1398sub _have_async_interrupt() {
1377 $HAVE_ASYNC_INTERRUPT = 1*(!$ENV{PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT} 1399 $HAVE_ASYNC_INTERRUPT = 1*(!$ENV{PERL_ANYEVENT_AVOID_ASYNC_INTERRUPT}
1378 && eval "use Async::Interrupt 1.0 (); 1") 1400 && eval "use Async::Interrupt 1.02 (); 1")
1379 unless defined $HAVE_ASYNC_INTERRUPT; 1401 unless defined $HAVE_ASYNC_INTERRUPT;
1380 1402
1381 $HAVE_ASYNC_INTERRUPT 1403 $HAVE_ASYNC_INTERRUPT
1382} 1404}
1383 1405
… …
1386our ($SIG_COUNT, $SIG_TW); 1408our ($SIG_COUNT, $SIG_TW);
1387 1409
1388sub _signal_exec { 1410sub _signal_exec {
1389 $HAVE_ASYNC_INTERRUPT 1411 $HAVE_ASYNC_INTERRUPT
1390 ? $SIGPIPE_R->drain 1412 ? $SIGPIPE_R->drain
1391 : sysread $SIGPIPE_R, my $dummy, 9; 1413 : sysread $SIGPIPE_R, (my $dummy), 9;
1392 1414
1393 while (%SIG_EV) { 1415 while (%SIG_EV) {
1394 for (keys %SIG_EV) { 1416 for (keys %SIG_EV) {
1395 delete $SIG_EV{$_}; 1417 delete $SIG_EV{$_};
1396 $_->() for values %{ $SIG_CB{$_} || {} }; 1418 $_->() for values %{ $SIG_CB{$_} || {} };
… …
1912 warn "read: $input\n"; # output what has been read 1934 warn "read: $input\n"; # output what has been read
1913 $cv->send if $input =~ /^q/i; # quit program if /^q/i 1935 $cv->send if $input =~ /^q/i; # quit program if /^q/i
1914 }, 1936 },
1915 ); 1937 );
1916 1938
1917 my $time_watcher; # can only be used once
1918
1919 sub new_timer {
1920 $timer = AnyEvent->timer (after => 1, cb => sub { 1939 my $time_watcher = AnyEvent->timer (after => 1, interval => 1, cb => sub {
1921 warn "timeout\n"; # print 'timeout' about every second 1940 warn "timeout\n"; # print 'timeout' at most every second
1922 &new_timer; # and restart the time
1923 }); 1941 });
1924 }
1925
1926 new_timer; # create first timer
1927 1942
1928 $cv->recv; # wait until user enters /^q/i 1943 $cv->recv; # wait until user enters /^q/i
1929 1944
1930=head1 REAL-WORLD EXAMPLE 1945=head1 REAL-WORLD EXAMPLE
1931 1946
… …
2375As you can see, the AnyEvent + EV combination even beats the 2390As you can see, the AnyEvent + EV combination even beats the
2376hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl 2391hand-optimised "raw sockets benchmark", while AnyEvent + its pure perl
2377backend easily beats IO::Lambda and POE. 2392backend easily beats IO::Lambda and POE.
2378 2393
2379And even the 100% non-blocking version written using the high-level (and 2394And even the 100% non-blocking version written using the high-level (and
2380slow :) L<AnyEvent::Handle> abstraction beats both POE and IO::Lambda by a 2395slow :) L<AnyEvent::Handle> abstraction beats both POE and IO::Lambda
2381large margin, even though it does all of DNS, tcp-connect and socket I/O 2396higher level ("unoptimised") abstractions by a large margin, even though
2382in a non-blocking way. 2397it does all of DNS, tcp-connect and socket I/O in a non-blocking way.
2383 2398
2384The two AnyEvent benchmarks programs can be found as F<eg/ae0.pl> and 2399The two AnyEvent benchmarks programs can be found as F<eg/ae0.pl> and
2385F<eg/ae2.pl> in the AnyEvent distribution, the remaining benchmarks are 2400F<eg/ae2.pl> in the AnyEvent distribution, the remaining benchmarks are
2386part of the IO::lambda distribution and were used without any changes. 2401part of the IO::Lambda distribution and were used without any changes.
2387 2402
2388 2403
2389=head1 SIGNALS 2404=head1 SIGNALS
2390 2405
2391AnyEvent currently installs handlers for these signals: 2406AnyEvent currently installs handlers for these signals:
… …
2434 2449
2435That does not mean that AnyEvent won't take advantage of some additional 2450That does not mean that AnyEvent won't take advantage of some additional
2436modules if they are installed. 2451modules if they are installed.
2437 2452
2438This section epxlains which additional modules will be used, and how they 2453This section epxlains which additional modules will be used, and how they
2439affect AnyEvent's operetion. 2454affect AnyEvent's operation.
2440 2455
2441=over 4 2456=over 4
2442 2457
2443=item L<Async::Interrupt> 2458=item L<Async::Interrupt>
2444 2459
… …
2449catch the signals) with some delay (default is 10 seconds, look for 2464catch the signals) with some delay (default is 10 seconds, look for
2450C<$AnyEvent::MAX_SIGNAL_LATENCY>). 2465C<$AnyEvent::MAX_SIGNAL_LATENCY>).
2451 2466
2452If this module is available, then it will be used to implement signal 2467If this module is available, then it will be used to implement signal
2453catching, which means that signals will not be delayed, and the event loop 2468catching, which means that signals will not be delayed, and the event loop
2454will not be interrupted regularly, which is more efficient (And good for 2469will not be interrupted regularly, which is more efficient (and good for
2455battery life on laptops). 2470battery life on laptops).
2456 2471
2457This affects not just the pure-perl event loop, but also other event loops 2472This affects not just the pure-perl event loop, but also other event loops
2458that have no signal handling on their own (e.g. Glib, Tk, Qt). 2473that have no signal handling on their own (e.g. Glib, Tk, Qt).
2459 2474
… …
2480lot less memory), but otherwise doesn't affect guard operation much. It is 2495lot less memory), but otherwise doesn't affect guard operation much. It is
2481purely used for performance. 2496purely used for performance.
2482 2497
2483=item L<JSON> and L<JSON::XS> 2498=item L<JSON> and L<JSON::XS>
2484 2499
2485This module is required when you want to read or write JSON data via 2500One of these modules is required when you want to read or write JSON data
2486L<AnyEvent::Handle>. It is also written in pure-perl, but can take 2501via L<AnyEvent::Handle>. It is also written in pure-perl, but can take
2487advantage of the ultra-high-speed L<JSON::XS> module when it is installed. 2502advantage of the ultra-high-speed L<JSON::XS> module when it is installed.
2488 2503
2489In fact, L<AnyEvent::Handle> will use L<JSON::XS> by default if it is 2504In fact, L<AnyEvent::Handle> will use L<JSON::XS> by default if it is
2490installed. 2505installed.
2491 2506

Diff Legend

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