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.183 by root, Wed Oct 1 07:40:39 2008 UTC vs.
Revision 1.195 by root, Wed Mar 25 17:33:11 2009 UTC

… …
825=item L<AnyEvent::IGS> 825=item L<AnyEvent::IGS>
826 826
827A non-blocking interface to the Internet Go Server protocol (used by 827A non-blocking interface to the Internet Go Server protocol (used by
828L<App::IGS>). 828L<App::IGS>).
829 829
830=item L<Net::IRC3> 830=item L<AnyEvent::IRC>
831 831
832AnyEvent based IRC client module family. 832AnyEvent based IRC client module family (replacing the older Net::IRC3).
833 833
834=item L<Net::XMPP2> 834=item L<Net::XMPP2>
835 835
836AnyEvent based XMPP (Jabber protocol) module family. 836AnyEvent based XMPP (Jabber protocol) module family.
837 837
… …
861no warnings; 861no warnings;
862use strict qw(vars subs); 862use strict qw(vars subs);
863 863
864use Carp; 864use Carp;
865 865
866our $VERSION = 4.3; 866our $VERSION = 4.341;
867our $MODEL; 867our $MODEL;
868 868
869our $AUTOLOAD; 869our $AUTOLOAD;
870our @ISA; 870our @ISA;
871 871
… …
1004# to support binding more than one watcher per filehandle (they usually 1004# to support binding more than one watcher per filehandle (they usually
1005# allow only one watcher per fd, so we dup it to get a different one). 1005# allow only one watcher per fd, so we dup it to get a different one).
1006sub _dupfh($$$$) { 1006sub _dupfh($$$$) {
1007 my ($poll, $fh, $r, $w) = @_; 1007 my ($poll, $fh, $r, $w) = @_;
1008 1008
1009 require Fcntl;
1010
1011 # cygwin requires the fh mode to be matching, unix doesn't 1009 # cygwin requires the fh mode to be matching, unix doesn't
1012 my ($rw, $mode) = $poll eq "r" ? ($r, "<") 1010 my ($rw, $mode) = $poll eq "r" ? ($r, "<")
1013 : $poll eq "w" ? ($w, ">") 1011 : $poll eq "w" ? ($w, ">")
1014 : Carp::croak "AnyEvent->io requires poll set to either 'r' or 'w'"; 1012 : Carp::croak "AnyEvent->io requires poll set to either 'r' or 'w'";
1015 1013
… …
1043 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar:: 1041 bless { @_ == 3 ? (_ae_cb => $_[2]) : () }, AnyEvent::CondVar::
1044} 1042}
1045 1043
1046# default implementation for ->signal 1044# default implementation for ->signal
1047 1045
1048our %SIG_CB; 1046our ($SIGPIPE_R, $SIGPIPE_W, %SIG_CB, %SIG_EV, $SIG_IO);
1047
1048sub _signal_exec {
1049 while (%SIG_EV) {
1050 sysread $SIGPIPE_R, my $dummy, 4;
1051 for (keys %SIG_EV) {
1052 delete $SIG_EV{$_};
1053 $_->() for values %{ $SIG_CB{$_} || {} };
1054 }
1055 }
1056}
1049 1057
1050sub signal { 1058sub signal {
1051 my (undef, %arg) = @_; 1059 my (undef, %arg) = @_;
1052 1060
1061 unless ($SIGPIPE_R) {
1062 if (AnyEvent::WIN32) {
1063 ($SIGPIPE_R, $SIGPIPE_W) = AnyEvent::Util::portable_pipe ();
1064 AnyEvent::Util::fh_nonblocking ($SIGPIPE_R) if $SIGPIPE_R;
1065 AnyEvent::Util::fh_nonblocking ($SIGPIPE_W) if $SIGPIPE_W; # just in case
1066 } else {
1067 pipe $SIGPIPE_R, $SIGPIPE_W;
1068 require Fcntl;
1069 fcntl $SIGPIPE_R, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_R;
1070 fcntl $SIGPIPE_W, &Fcntl::F_SETFL, &Fcntl::O_NONBLOCK if $SIGPIPE_W; # just in case
1071 }
1072
1073 $SIGPIPE_R
1074 or Carp::croak "AnyEvent: unable to create a signal reporting pipe: $!\n";
1075
1076 $SIG_IO = AnyEvent->io (fh => $SIGPIPE_R, poll => "r", cb => \&_signal_exec);
1077 }
1078
1053 my $signal = uc $arg{signal} 1079 my $signal = uc $arg{signal}
1054 or Carp::croak "required option 'signal' is missing"; 1080 or Carp::croak "required option 'signal' is missing";
1055 1081
1056 $SIG_CB{$signal}{$arg{cb}} = $arg{cb}; 1082 $SIG_CB{$signal}{$arg{cb}} = $arg{cb};
1057 $SIG{$signal} ||= sub { 1083 $SIG{$signal} ||= sub {
1058 $_->() for values %{ $SIG_CB{$signal} || {} }; 1084 syswrite $SIGPIPE_W, "\x00", 1 unless %SIG_EV;
1085 undef $SIG_EV{$signal};
1059 }; 1086 };
1060 1087
1061 bless [$signal, $arg{cb}], "AnyEvent::Base::Signal" 1088 bless [$signal, $arg{cb}], "AnyEvent::Base::Signal"
1062} 1089}
1063 1090
… …
1263used, and preference will be given to protocols mentioned earlier in the 1290used, and preference will be given to protocols mentioned earlier in the
1264list. 1291list.
1265 1292
1266This variable can effectively be used for denial-of-service attacks 1293This variable can effectively be used for denial-of-service attacks
1267against local programs (e.g. when setuid), although the impact is likely 1294against local programs (e.g. when setuid), although the impact is likely
1268small, as the program has to handle connection errors already- 1295small, as the program has to handle conenction and other failures anyways.
1269 1296
1270Examples: C<PERL_ANYEVENT_PROTOCOLS=ipv4,ipv6> - prefer IPv4 over IPv6, 1297Examples: C<PERL_ANYEVENT_PROTOCOLS=ipv4,ipv6> - prefer IPv4 over IPv6,
1271but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4> 1298but support both and try to use both. C<PERL_ANYEVENT_PROTOCOLS=ipv4>
1272- only support IPv4, never try to resolve or contact IPv6 1299- only support IPv4, never try to resolve or contact IPv6
1273addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or 1300addresses. C<PERL_ANYEVENT_PROTOCOLS=ipv6,ipv4> support either IPv4 or
… …
1533watcher. 1560watcher.
1534 1561
1535=head3 Results 1562=head3 Results
1536 1563
1537 name watchers bytes create invoke destroy comment 1564 name watchers bytes create invoke destroy comment
1538 EV/EV 400000 244 0.56 0.46 0.31 EV native interface 1565 EV/EV 400000 224 0.47 0.35 0.27 EV native interface
1539 EV/Any 100000 244 2.50 0.46 0.29 EV + AnyEvent watchers 1566 EV/Any 100000 224 2.88 0.34 0.27 EV + AnyEvent watchers
1540 CoroEV/Any 100000 244 2.49 0.44 0.29 coroutines + Coro::Signal 1567 CoroEV/Any 100000 224 2.85 0.35 0.28 coroutines + Coro::Signal
1541 Perl/Any 100000 513 4.92 0.87 1.12 pure perl implementation 1568 Perl/Any 100000 452 4.13 0.73 0.95 pure perl implementation
1542 Event/Event 16000 516 31.88 31.30 0.85 Event native interface 1569 Event/Event 16000 517 32.20 31.80 0.81 Event native interface
1543 Event/Any 16000 590 35.75 31.42 1.08 Event + AnyEvent watchers 1570 Event/Any 16000 590 35.85 31.55 1.06 Event + AnyEvent watchers
1544 Glib/Any 16000 1357 98.22 12.41 54.00 quadratic behaviour 1571 Glib/Any 16000 1357 102.33 12.31 51.00 quadratic behaviour
1545 Tk/Any 2000 1860 26.97 67.98 14.00 SEGV with >> 2000 watchers 1572 Tk/Any 2000 1860 27.20 66.31 14.00 SEGV with >> 2000 watchers
1546 POE/Event 2000 6644 108.64 736.02 14.73 via POE::Loop::Event 1573 POE/Event 2000 6328 109.99 751.67 14.02 via POE::Loop::Event
1547 POE/Select 2000 6343 94.13 809.12 565.96 via POE::Loop::Select 1574 POE/Select 2000 6027 94.54 809.13 579.80 via POE::Loop::Select
1548 1575
1549=head3 Discussion 1576=head3 Discussion
1550 1577
1551The benchmark does I<not> measure scalability of the event loop very 1578The benchmark does I<not> measure scalability of the event loop very
1552well. For example, a select-based event loop (such as the pure perl one) 1579well. For example, a select-based event loop (such as the pure perl one)
… …
1754watchers, as the management overhead dominates. 1781watchers, as the management overhead dominates.
1755 1782
1756=back 1783=back
1757 1784
1758 1785
1786=head1 SIGNALS
1787
1788AnyEvent currently installs handlers for these signals:
1789
1790=over 4
1791
1792=item SIGCHLD
1793
1794A handler for C<SIGCHLD> is installed by AnyEvent's child watcher
1795emulation for event loops that do not support them natively. Also, some
1796event loops install a similar handler.
1797
1798=item SIGPIPE
1799
1800A no-op handler is installed for C<SIGPIPE> when C<$SIG{PIPE}> is C<undef>
1801when AnyEvent gets loaded.
1802
1803The rationale for this is that AnyEvent users usually do not really depend
1804on SIGPIPE delivery (which is purely an optimisation for shell use, or
1805badly-written programs), but C<SIGPIPE> can cause spurious and rare
1806program exits as a lot of people do not expect C<SIGPIPE> when writing to
1807some random socket.
1808
1809The rationale for installing a no-op handler as opposed to ignoring it is
1810that this way, the handler will be restored to defaults on exec.
1811
1812Feel free to install your own handler, or reset it to defaults.
1813
1814=back
1815
1816=cut
1817
1818$SIG{PIPE} = sub { }
1819 unless defined $SIG{PIPE};
1820
1821
1759=head1 FORK 1822=head1 FORK
1760 1823
1761Most event libraries are not fork-safe. The ones who are usually are 1824Most event libraries are not fork-safe. The ones who are usually are
1762because they rely on inefficient but fork-safe C<select> or C<poll> 1825because they rely on inefficient but fork-safe C<select> or C<poll>
1763calls. Only L<EV> is fully fork-aware. 1826calls. Only L<EV> is fully fork-aware.

Diff Legend

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