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.22 by root, Sun Dec 31 11:54:43 2006 UTC vs.
Revision 1.31 by root, Fri Nov 2 19:20:36 2007 UTC

… …
174 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 }); 174 my $w = AnyEvent->signal (signal => "INT", cb => sub { exit 1 });
175 175
176=head2 CHILD PROCESS WATCHERS 176=head2 CHILD PROCESS WATCHERS
177 177
178You can also listen for the status of a child process specified by the 178You can also listen for the status of a child process specified by the
179C<pid> argument. The watcher will only trigger once. This works by 179C<pid> argument (or any child if the pid argument is 0). The watcher will
180trigger as often as status change for the child are received. This works
180installing a signal handler for C<SIGCHLD>. 181by installing a signal handler for C<SIGCHLD>.
181 182
182Example: wait for pid 1333 183Example: wait for pid 1333
183 184
184 my $w = AnyEvent->child (pid => 1333, cb => sub { warn "exit status $?" }); 185 my $w = AnyEvent->child (pid => 1333, cb => sub { warn "exit status $?" });
185 186
… …
195C<AnyEvent::Impl:xxx> modules, but can be any other class in the case 196C<AnyEvent::Impl:xxx> modules, but can be any other class in the case
196AnyEvent has been extended at runtime (e.g. in I<rxvt-unicode>). 197AnyEvent has been extended at runtime (e.g. in I<rxvt-unicode>).
197 198
198The known classes so far are: 199The known classes so far are:
199 200
201 EV::AnyEvent based on EV (an interface to libev, best choice)
200 AnyEvent::Impl::Coro based on Coro::Event, best choise. 202 AnyEvent::Impl::Coro based on Coro::Event, second best choice.
201 AnyEvent::Impl::Event based on Event, also best choice :) 203 AnyEvent::Impl::Event based on Event, also second best choice :)
202 AnyEvent::Impl::Glib based on Glib, second-best choice. 204 AnyEvent::Impl::Glib based on Glib, second-best choice.
203 AnyEvent::Impl::Tk based on Tk, very bad choice. 205 AnyEvent::Impl::Tk based on Tk, very bad choice.
204 AnyEvent::Impl::Perl pure-perl implementation, inefficient. 206 AnyEvent::Impl::Perl pure-perl implementation, inefficient.
205 207
206=item AnyEvent::detect 208=item AnyEvent::detect
… …
245 247
246package AnyEvent; 248package AnyEvent;
247 249
248no warnings; 250no warnings;
249use strict; 251use strict;
252
250use Carp; 253use Carp;
251 254
252our $VERSION = '2.51'; 255our $VERSION = '2.55';
253our $MODEL; 256our $MODEL;
254 257
255our $AUTOLOAD; 258our $AUTOLOAD;
256our @ISA; 259our @ISA;
257 260
… …
259 262
260our @REGISTRY; 263our @REGISTRY;
261 264
262my @models = ( 265my @models = (
263 [Coro::Event:: => AnyEvent::Impl::Coro::], 266 [Coro::Event:: => AnyEvent::Impl::Coro::],
267 [EV:: => EV::AnyEvent::],
264 [Event:: => AnyEvent::Impl::Event::], 268 [Event:: => AnyEvent::Impl::Event::],
265 [Glib:: => AnyEvent::Impl::Glib::], 269 [Glib:: => AnyEvent::Impl::Glib::],
266 [Tk:: => AnyEvent::Impl::Tk::], 270 [Tk:: => AnyEvent::Impl::Tk::],
267 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::], 271 [AnyEvent::Impl::Perl:: => AnyEvent::Impl::Perl::],
268); 272);
… …
371our $PID_IDLE; 375our $PID_IDLE;
372our $WNOHANG; 376our $WNOHANG;
373 377
374sub _child_wait { 378sub _child_wait {
375 while (0 < (my $pid = waitpid -1, $WNOHANG)) { 379 while (0 < (my $pid = waitpid -1, $WNOHANG)) {
376 $_->() for values %{ (delete $PID_CB{$pid}) || {} }; 380 $_->() for (values %{ $PID_CB{$pid} || {} }),
381 (values %{ $PID_CB{0} || {} });
377 } 382 }
378 383
379 undef $PID_IDLE; 384 undef $PID_IDLE;
380} 385}
381 386
382sub child { 387sub child {
383 my (undef, %arg) = @_; 388 my (undef, %arg) = @_;
384 389
385 my $pid = uc $arg{pid} 390 defined (my $pid = $arg{pid} + 0)
386 or Carp::croak "required option 'pid' is missing"; 391 or Carp::croak "required option 'pid' is missing";
387 392
388 $PID_CB{$pid}{$arg{cb}} = $arg{cb}; 393 $PID_CB{$pid}{$arg{cb}} = $arg{cb};
389 394
390 unless ($WNOHANG) { 395 unless ($WNOHANG) {
391 $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_child_wait);
392 $WNOHANG = eval { require POSIX; &POSIX::WNOHANG } || 1; 396 $WNOHANG = eval { require POSIX; &POSIX::WNOHANG } || 1;
393 } 397 }
394 398
399 unless ($CHLD_W) {
400 $CHLD_W = AnyEvent->signal (signal => 'CHLD', cb => \&_child_wait);
395 # child could be a zombie already 401 # child could be a zombie already
396 $PID_IDLE ||= AnyEvent->timer (after => 0, cb => \&_child_wait); 402 $PID_IDLE ||= AnyEvent->timer (after => 0, cb => \&_child_wait);
403 }
397 404
398 bless [$pid, $arg{cb}], "AnyEvent::Base::Child" 405 bless [$pid, $arg{cb}], "AnyEvent::Base::Child"
399} 406}
400 407
401sub AnyEvent::Base::Child::DESTROY { 408sub AnyEvent::Base::Child::DESTROY {
… …
437I<rxvt-unicode> distribution. 444I<rxvt-unicode> distribution.
438 445
439I<rxvt-unicode> also cheats a bit by not providing blocking access to 446I<rxvt-unicode> also cheats a bit by not providing blocking access to
440condition variables: code blocking while waiting for a condition will 447condition variables: code blocking while waiting for a condition will
441C<die>. This still works with most modules/usages, and blocking calls must 448C<die>. This still works with most modules/usages, and blocking calls must
442not be in an interactive appliation, so it makes sense. 449not be in an interactive application, so it makes sense.
443 450
444=head1 ENVIRONMENT VARIABLES 451=head1 ENVIRONMENT VARIABLES
445 452
446The following environment variables are used by this module: 453The following environment variables are used by this module:
447 454

Diff Legend

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