[ViewVC] Diff of: cvs/AnyEvent/lib/AnyEvent.pm

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.19 by root, Sun Dec 10 23:59:15 2006 UTC vs.
Revision 1.32 by root, Sat Nov 3 09:29:51 2007 UTC

 =back
 =head2 SIGNAL WATCHERS
 You can listen for signals using a signal watcher, C<signal> is the signal
-I<name> without any C<SIG> prefix.
+I<name> without any C<SIG> prefix. Multiple signals events can be clumped
+together into one callback invocation, and callback invocation might or
+might not be asynchronous.
 These watchers might use C<%SIG>, so programs overwriting those signals
 directly will likely not work correctly.
 Example: exit on SIGINT
    my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 });
+=head2 CHILD PROCESS WATCHERS
+You can also listen for the status of a child process specified by the
+C<pid> argument (or any child if the pid argument is 0). The watcher will
+trigger as often as status change for the child are received. This works
+by installing a signal handler for C<SIGCHLD>. The callback will be called with
+the pid and exit status (as returned by waitpid).
+Example: wait for pid 1333
+  my $w = AnyEvent->child (pid => 1333, cb => sub { warn "exit status $?" });
 =head1 GLOBALS
 =over 4
 C<AnyEvent::Impl:xxx> modules, but can be any other class in the case
 AnyEvent has been extended at runtime (e.g. in I<rxvt-unicode>).
 The known classes so far are:
+   EV::AnyEvent              based on EV (an interface to libev, best choice)
-   AnyEvent::Impl::Coro      based on Coro::Event, best choise.
+   AnyEvent::Impl::Coro      based on Coro::Event, second best choice.
-   AnyEvent::Impl::Event     based on Event, also best choice :)
+   AnyEvent::Impl::Event     based on Event, also second best choice :)
    AnyEvent::Impl::Glib      based on Glib, second-best choice.
    AnyEvent::Impl::Tk        based on Tk, very bad choice.
    AnyEvent::Impl::Perl      pure-perl implementation, inefficient.
 =item AnyEvent::detect
 package AnyEvent;
 no warnings;
 use strict;
 use Carp;
-our $VERSION = '2.5';
+our $VERSION = '2.55';
 our $MODEL;
 our $AUTOLOAD;
 our @ISA;
 our @REGISTRY;
 my @models = (
    [Coro::Event::          => AnyEvent::Impl::Coro::],
+   [EV::                   => EV::AnyEvent::],
    [Event::                => AnyEvent::Impl::Event::],
    [Glib::                 => AnyEvent::Impl::Glib::],
    [Tk::                   => AnyEvent::Impl::Tk::],
    [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::],
 );
       unless ($MODEL) {
          # try to load a model
          for (@REGISTRY, @models) {
             my ($package, $model) = @$_;
+            if (eval "require $package"
+                and ${"$package\::VERSION"} > 0
-            if (eval "require $model") {
+                and eval "require $model") {
                $MODEL = $model;
                warn "AnyEvent: autoprobed and loaded model '$model', using it.\n" if $verbose > 1;
                last;
             }
          }
    $class->$func (@_);
 }
 package AnyEvent::Base;
+# default implementation for ->condvar, ->wait, ->broadcast
+sub condvar {
+   bless \my $flag, "AnyEvent::Base::CondVar"
+}
+sub AnyEvent::Base::CondVar::broadcast {
+   ${$_[0]}++;
+}
+sub AnyEvent::Base::CondVar::wait {
+   AnyEvent->one_event while !${$_[0]};
+}
-# default implementation for signal
+# default implementation for ->signal
 our %SIG_CB;
 sub signal {
    my (undef, %arg) = @_;
    my $signal = uc $arg{signal}
       or Carp::croak "required option 'signal' is missing";
-   my $w = bless [$signal, $arg{cb}], "AnyEvent::Base::Signal";
    $SIG_CB{$signal}{$arg{cb}} = $arg{cb};
    $SIG{$signal} ||= sub {
-      $_->() for values %{ $SIG_CB{$signal} };
+      $_->() for values %{ $SIG_CB{$signal} || {} };
    };
-   $w
+   bless [$signal, $arg{cb}], "AnyEvent::Base::Signal"
 }
 sub AnyEvent::Base::Signal::DESTROY {
    my ($signal, $cb) = @{$_[0]};
    delete $SIG_CB{$signal}{$cb};
    $SIG{$signal} = 'DEFAULT' unless keys %{ $SIG_CB{$signal} };
+}
+# default implementation for ->child
+our %PID_CB;
+our $CHLD_W;
+our $PID_IDLE;
+our $WNOHANG;
+sub _child_wait {
+   while (0 <= (my $pid = waitpid -1, $WNOHANG)) {
+      $_->($pid, $?) for (values %{ $PID_CB{$pid} || {} }),
+                         (values %{ $PID_CB{0}    || {} });
+   }
+   undef $PID_IDLE;
+}
+sub child {
+   my (undef, %arg) = @_;
+   defined (my $pid = $arg{pid} + 0)
+      or Carp::croak "required option 'pid' is missing";
+   $PID_CB{$pid}{$arg{cb}} = $arg{cb};
+   unless ($WNOHANG) {
+      $WNOHANG = eval { require POSIX; &POSIX::WNOHANG } || 1;
+   }
+   unless ($CHLD_W) {
+      $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_child_wait);
+      # child could be a zombie already
+      $PID_IDLE ||= AnyEvent->timer (after => 0, cb => \&_child_wait);
+   }
+   bless [$pid, $arg{cb}], "AnyEvent::Base::Child"
+}
+sub AnyEvent::Base::Child::DESTROY {
+   my ($pid, $cb) = @{$_[0]};
+   delete $PID_CB{$pid}{$cb};
+   delete $PID_CB{$pid} unless keys %{ $PID_CB{$pid} };
+   undef $CHLD_W unless keys %PID_CB;
 }
 =head1 SUPPLYING YOUR OWN EVENT MODEL INTERFACE
 If you need to support another event library which isn't directly
 I<rxvt-unicode> distribution.
 I<rxvt-unicode> also cheats a bit by not providing blocking access to
 condition variables: code blocking while waiting for a condition will
 C<die>. This still works with most modules/usages, and blocking calls must
-not be in an interactive appliation, so it makes sense.
+not be in an interactive application, so it makes sense.
 =head1 ENVIRONMENT VARIABLES
 The following environment variables are used by this module:

Diff Legend

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

Comparing AnyEvent/lib/AnyEvent.pm (file contents): Revision 1.19 by root, Sun Dec 10 23:59:15 2006 UTC vs. Revision 1.32 by root, Sat Nov 3 09:29:51 2007 UTC

Diff Legend

Comparing AnyEvent/lib/AnyEvent.pm (file contents):
Revision 1.19 by root, Sun Dec 10 23:59:15 2006 UTC vs.
Revision 1.32 by root, Sat Nov 3 09:29:51 2007 UTC