ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/EV.pm
(Generate patch)

Comparing EV/EV.pm (file contents):
Revision 1.50 by root, Sat Nov 24 08:42:38 2007 UTC vs.
Revision 1.60 by root, Mon Dec 3 13:41:24 2007 UTC

39 39
40 my $w = EV::child 666, sub { 40 my $w = EV::child 666, sub {
41 my ($w, $revents) = @_; 41 my ($w, $revents) = @_;
42 my $status = $w->rstatus; 42 my $status = $w->rstatus;
43 }; 43 };
44
45 # STAT CHANGES
46 my $w = EV::stat "/etc/passwd", 10, sub {
47 my ($w, $revents) = @_;
48 warn $w->path, " has changed somehow.\n";
49 };
44 50
45 # MAINLOOP 51 # MAINLOOP
46 EV::loop; # loop until EV::unloop is called or all watchers stop 52 EV::loop; # loop until EV::unloop is called or all watchers stop
47 EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled 53 EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled
48 EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not block 54 EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not block
49 55
50=head1 DESCRIPTION 56=head1 DESCRIPTION
51 57
52This module provides an interface to libev 58This module provides an interface to libev
53(L<http://software.schmorp.de/pkg/libev.html>). 59(L<http://software.schmorp.de/pkg/libev.html>). While the documentation
60below is comprehensive, one might also consult the documentation of libev
61itself (L<http://cvs.schmorp.de/libev/ev.html>) for more subtle details on
62watcher semantics or some discussion on the available backends, or how to
63force a specific backend with C<LIBEV_FLAGS>.
54 64
55=cut 65=cut
56 66
57package EV; 67package EV;
58 68
59use strict; 69use strict;
60 70
61BEGIN { 71BEGIN {
62 our $VERSION = '1.2'; 72 our $VERSION = '1.6';
63 use XSLoader; 73 use XSLoader;
64 XSLoader::load "EV", $VERSION; 74 XSLoader::load "EV", $VERSION;
65} 75}
66 76
67@EV::IO::ISA = 77@EV::IO::ISA =
68@EV::Timer::ISA = 78@EV::Timer::ISA =
69@EV::Periodic::ISA = 79@EV::Periodic::ISA =
70@EV::Signal::ISA = 80@EV::Signal::ISA =
81@EV::Child::ISA =
82@EV::Stat::ISA =
71@EV::Idle::ISA = 83@EV::Idle::ISA =
72@EV::Prepare::ISA = 84@EV::Prepare::ISA =
73@EV::Check::ISA = 85@EV::Check::ISA =
74@EV::Child::ISA = "EV::Watcher"; 86@EV::Embed::ISA =
87@EV::Fork::ISA =
88 "EV::Watcher";
75 89
76=head1 BASIC INTERFACE 90=head1 BASIC INTERFACE
77 91
78=over 4 92=over 4
79 93
116When called with no arguments or an argument of EV::UNLOOP_ONE, makes the 130When called with no arguments or an argument of EV::UNLOOP_ONE, makes the
117innermost call to EV::loop return. 131innermost call to EV::loop return.
118 132
119When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as 133When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as
120fast as possible. 134fast as possible.
135
136=item $count = EV::loop_count
137
138Return the number of times the event loop has polled for new
139events. Sometiems useful as a generation counter.
121 140
122=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents) 141=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents)
123 142
124This function rolls together an I/O and a timer watcher for a single 143This function rolls together an I/O and a timer watcher for a single
125one-shot event without the need for managing a watcher object. 144one-shot event without the need for managing a watcher object.
142of them triggers, then they will be stopped and freed, and the callback 161of them triggers, then they will be stopped and freed, and the callback
143invoked. 162invoked.
144 163
145=back 164=back
146 165
147=head2 WATCHER 166=head2 WATCHER OBJECTS
148 167
149A watcher is an object that gets created to record your interest in some 168A watcher is an object that gets created to record your interest in some
150event. For instance, if you want to wait for STDIN to become readable, you 169event. For instance, if you want to wait for STDIN to become readable, you
151would create an EV::io watcher for that: 170would create an EV::io watcher for that:
152 171
177 196
178Also, all methods changing some aspect of a watcher (->set, ->priority, 197Also, all methods changing some aspect of a watcher (->set, ->priority,
179->fh and so on) automatically stop and start it again if it is active, 198->fh and so on) automatically stop and start it again if it is active,
180which means pending events get lost. 199which means pending events get lost.
181 200
182=head2 WATCHER TYPES 201=head2 COMMON WATCHER METHODS
183 202
184Now lets move to the existing watcher types and asociated methods. 203This section lists methods common to all watchers.
185
186The following methods are available for all watchers. Then followes a
187description of each watcher constructor (EV::io, EV::timer, EV::periodic,
188EV::signal, EV::child, EV::idle, EV::prepare and EV::check), followed by
189any type-specific methods (if any).
190 204
191=over 4 205=over 4
192 206
193=item $w->start 207=item $w->start
194 208
270 284
271 my $udp_socket = ... 285 my $udp_socket = ...
272 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 286 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
273 $udp_watcher->keepalive (0); 287 $udp_watcher->keepalive (0);
274 288
289=back
290
291
292=head2 WATCHER TYPES
293
294Each of the following subsections describes a single watcher type.
295
296=head3 IO WATCHERS - is this file descriptor readable or writable?
297
298=over 4
299
275=item $w = EV::io $fileno_or_fh, $eventmask, $callback 300=item $w = EV::io $fileno_or_fh, $eventmask, $callback
276 301
277=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback 302=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
278 303
279As long as the returned watcher object is alive, call the C<$callback> 304As long as the returned watcher object is alive, call the C<$callback>
280when the events specified in C<$eventmask>. 305when at least one of events specified in C<$eventmask> occurs.
281 306
282The $eventmask can be one or more of these constants ORed together: 307The $eventmask can be one or more of these constants ORed together:
283 308
284 EV::READ wait until read() wouldn't block anymore 309 EV::READ wait until read() wouldn't block anymore
285 EV::WRITE wait until write() wouldn't block anymore 310 EV::WRITE wait until write() wouldn't block anymore
301 326
302=item $old_eventmask = $w->events ($new_eventmask) 327=item $old_eventmask = $w->events ($new_eventmask)
303 328
304Returns the previously set event mask and optionally set a new one. 329Returns the previously set event mask and optionally set a new one.
305 330
331=back
332
333
334=head3 TIMER WATCHERS - relative and optionally repeating timeouts
335
336=over 4
306 337
307=item $w = EV::timer $after, $repeat, $callback 338=item $w = EV::timer $after, $repeat, $callback
308 339
309=item $w = EV::timer_ns $after, $repeat, $callback 340=item $w = EV::timer_ns $after, $repeat, $callback
310 341
311Calls the callback after C<$after> seconds. If C<$repeat> is non-zero, 342Calls the callback after C<$after> seconds (which may be fractional). If
312the timer will be restarted (with the $repeat value as $after) after the 343C<$repeat> is non-zero, the timer will be restarted (with the $repeat
313callback returns. 344value as $after) after the callback returns.
314 345
315This means that the callback would be called roughly after C<$after> 346This means that the callback would be called roughly after C<$after>
316seconds, and then every C<$repeat> seconds. The timer does his best not 347seconds, and then every C<$repeat> seconds. The timer does his best not
317to drift, but it will not invoke the timer more often then once per event 348to drift, but it will not invoke the timer more often then once per event
318loop iteration, and might drift in other cases. If that isn't acceptable, 349loop iteration, and might drift in other cases. If that isn't acceptable,
324 355
325The C<timer_ns> variant doesn't start (activate) the newly created watcher. 356The C<timer_ns> variant doesn't start (activate) the newly created watcher.
326 357
327=item $w->set ($after, $repeat) 358=item $w->set ($after, $repeat)
328 359
329Reconfigures the watcher, see the constructor above for details. Can be at 360Reconfigures the watcher, see the constructor above for details. Can be called at
330any time. 361any time.
331 362
332=item $w->again 363=item $w->again
333 364
334Similar to the C<start> method, but has special semantics for repeating timers: 365Similar to the C<start> method, but has special semantics for repeating timers:
345This behaviour is useful when you have a timeout for some IO 376This behaviour is useful when you have a timeout for some IO
346operation. You create a timer object with the same value for C<$after> and 377operation. You create a timer object with the same value for C<$after> and
347C<$repeat>, and then, in the read/write watcher, run the C<again> method 378C<$repeat>, and then, in the read/write watcher, run the C<again> method
348on the timeout. 379on the timeout.
349 380
381=back
382
383
384=head3 PERIODIC WATCHERS - to cron or not to cron?
385
386=over 4
350 387
351=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback 388=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback
352 389
353=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback 390=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
354 391
426 463
427The C<periodic_ns> variant doesn't start (activate) the newly created watcher. 464The C<periodic_ns> variant doesn't start (activate) the newly created watcher.
428 465
429=item $w->set ($at, $interval, $reschedule_cb) 466=item $w->set ($at, $interval, $reschedule_cb)
430 467
431Reconfigures the watcher, see the constructor above for details. Can be at 468Reconfigures the watcher, see the constructor above for details. Can be called at
432any time. 469any time.
433 470
434=item $w->again 471=item $w->again
435 472
436Simply stops and starts the watcher again. 473Simply stops and starts the watcher again.
437 474
475=back
476
477
478=head3 SIGNAL WATCHERS - signal me when a signal gets signalled!
479
480=over 4
438 481
439=item $w = EV::signal $signal, $callback 482=item $w = EV::signal $signal, $callback
440 483
441=item $w = EV::signal_ns $signal, $callback 484=item $w = EV::signal_ns $signal, $callback
442 485
443Call the callback when $signal is received (the signal can be specified 486Call the callback when $signal is received (the signal can be specified by
444by number or by name, just as with kill or %SIG). 487number or by name, just as with C<kill> or C<%SIG>).
445 488
446EV will grab the signal for the process (the kernel only allows one 489EV will grab the signal for the process (the kernel only allows one
447component to receive a signal at a time) when you start a signal watcher, 490component to receive a signal at a time) when you start a signal watcher,
448and removes it again when you stop it. Perl does the same when you 491and removes it again when you stop it. Perl does the same when you
449add/remove callbacks to %SIG, so watch out. 492add/remove callbacks to C<%SIG>, so watch out.
450 493
451You can have as many signal watchers per signal as you want. 494You can have as many signal watchers per signal as you want.
452 495
453The C<signal_ns> variant doesn't start (activate) the newly created watcher. 496The C<signal_ns> variant doesn't start (activate) the newly created watcher.
454 497
455=item $w->set ($signal) 498=item $w->set ($signal)
456 499
457Reconfigures the watcher, see the constructor above for details. Can be at 500Reconfigures the watcher, see the constructor above for details. Can be
458any time. 501called at any time.
459 502
460=item $current_signum = $w->signal 503=item $current_signum = $w->signal
461 504
462=item $old_signum = $w->signal ($new_signal) 505=item $old_signum = $w->signal ($new_signal)
463 506
464Returns the previously set signal (always as a number not name) and 507Returns the previously set signal (always as a number not name) and
465optionally set a new one. 508optionally set a new one.
466 509
510=back
511
512
513=head3 CHILD WATCHERS - watch out for process status changes
514
515=over 4
467 516
468=item $w = EV::child $pid, $callback 517=item $w = EV::child $pid, $callback
469 518
470=item $w = EV::child_ns $pid, $callback 519=item $w = EV::child_ns $pid, $callback
471 520
472Call the callback when a status change for pid C<$pid> (or any pid 521Call the callback when a status change for pid C<$pid> (or any pid if
473if C<$pid> is 0) has been received. More precisely: when the process 522C<$pid> is 0) has been received. More precisely: when the process receives
474receives a SIGCHLD, EV will fetch the outstanding exit/wait status for all 523a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
475changed/zombie children and call the callback. 524changed/zombie children and call the callback.
476 525
477You can access both status and pid by using the C<rstatus> and C<rpid> 526It is valid (and fully supported) to install a child watcher after a child
478methods on the watcher object. 527has exited but before the event loop has started its next iteration (for
528example, first you C<fork>, then the new child process might exit, and
529only then do you install a child watcher in the parent for the new pid).
479 530
531You can access both exit (or tracing) status and pid by using the
532C<rstatus> and C<rpid> methods on the watcher object.
533
480You can have as many pid watchers per pid as you want. 534You can have as many pid watchers per pid as you want, they will all be
535called.
481 536
482The C<child_ns> variant doesn't start (activate) the newly created watcher. 537The C<child_ns> variant doesn't start (activate) the newly created watcher.
483 538
484=item $w->set ($pid) 539=item $w->set ($pid)
485 540
486Reconfigures the watcher, see the constructor above for details. Can be at 541Reconfigures the watcher, see the constructor above for details. Can be called at
487any time. 542any time.
488 543
489=item $current_pid = $w->pid 544=item $current_pid = $w->pid
490 545
491=item $old_pid = $w->pid ($new_pid) 546=item $old_pid = $w->pid ($new_pid)
500=item $pid = $w->rpid 555=item $pid = $w->rpid
501 556
502Return the pid of the awaited child (useful when you have installed a 557Return the pid of the awaited child (useful when you have installed a
503watcher for all pids). 558watcher for all pids).
504 559
560=back
561
562
563=head3 STAT WATCHERS - did the file attributes just change?
564
565=over 4
566
567=item $w = EV::stat $path, $interval, $callback
568
569=item $w = EV::stat_ns $path, $interval, $callback
570
571Call the callback when a file status change has been detected on
572C<$path>. The C<$path> does not need to exist, changing from "path exists"
573to "path does not exist" is a status change like any other.
574
575The C<$interval> is a recommended polling interval for systems where
576OS-supported change notifications don't exist or are not supported. If
577you use C<0> then an unspecified default is used (which is highly
578recommended!), which is to be expected to be around five seconds usually.
579
580This watcher type is not meant for massive numbers of stat watchers,
581as even with OS-supported change notifications, this can be
582resource-intensive.
583
584The C<stat_ns> variant doesn't start (activate) the newly created watcher.
585
586=item ... = $w->stat
587
588This call is very similar to the perl C<stat> built-in: It stats (using
589C<lstat>) the path specified in the watcher and sets perls stat cache (as
590well as EV's idea of the current stat values) to the values found.
591
592In scalar context, a boolean is return indicating success or failure of
593the stat. In list context, the same 13-value list as with stat is returned
594(except that the blksize and blocks fields are not reliable).
595
596In the case of an error, errno is set to C<ENOENT> (regardless of the
597actual error value) and the C<nlink> value is forced to zero (if the stat
598was successful then nlink is guaranteed to be non-zero).
599
600See also the next two entries for more info.
601
602=item ... = $w->attr
603
604Just like C<< $w->stat >>, but without the initial stat'ing: this returns
605the values most recently detected by EV. See the next entry for more info.
606
607=item ... = $w->prev
608
609Just like C<< $w->stat >>, but without the initial stat'ing: this returns
610the previous set of values, before the change.
611
612That is, when the watcher callback is invoked, C<< $w->prev >> will be set
613to the values found I<before> a change was detected, while C<< $w->attr >>
614returns the values found leading to the change detection. The difference (if any)
615between C<prev> and C<attr> is what triggered the callback.
616
617If you did something to the filesystem object and do not want to trigger
618yet another change, you can call C<stat> to update EV's idea of what the
619current attributes are.
620
621=item $w->set ($path, $interval)
622
623Reconfigures the watcher, see the constructor above for details. Can be
624called at any time.
625
626=item $current_path = $w->path
627
628=item $old_path = $w->path ($new_path)
629
630Returns the previously set path and optionally set a new one.
631
632=item $current_interval = $w->interval
633
634=item $old_interval = $w->interval ($new_interval)
635
636Returns the previously set interval and optionally set a new one. Can be
637used to query the actual interval used.
638
639=back
640
641
642=head3 IDLE WATCHERS - when you've got nothing better to do...
643
644=over 4
505 645
506=item $w = EV::idle $callback 646=item $w = EV::idle $callback
507 647
508=item $w = EV::idle_ns $callback 648=item $w = EV::idle_ns $callback
509 649
513The process will not block as long as any idle watchers are active, and 653The process will not block as long as any idle watchers are active, and
514they will be called repeatedly until stopped. 654they will be called repeatedly until stopped.
515 655
516The C<idle_ns> variant doesn't start (activate) the newly created watcher. 656The C<idle_ns> variant doesn't start (activate) the newly created watcher.
517 657
658=back
659
660
661=head3 PREPARE WATCHERS - customise your event loop!
662
663=over 4
518 664
519=item $w = EV::prepare $callback 665=item $w = EV::prepare $callback
520 666
521=item $w = EV::prepare_ns $callback 667=item $w = EV::prepare_ns $callback
522 668
525 671
526See the EV::check watcher, below, for explanations and an example. 672See the EV::check watcher, below, for explanations and an example.
527 673
528The C<prepare_ns> variant doesn't start (activate) the newly created watcher. 674The C<prepare_ns> variant doesn't start (activate) the newly created watcher.
529 675
676=back
677
678
679=head3 CHECK WATCHERS - customise your event loop even more!
680
681=over 4
530 682
531=item $w = EV::check $callback 683=item $w = EV::check $callback
532 684
533=item $w = EV::check_ns $callback 685=item $w = EV::check_ns $callback
534 686
579first). 731first).
580 732
581The C<check_ns> variant doesn't start (activate) the newly created watcher. 733The C<check_ns> variant doesn't start (activate) the newly created watcher.
582 734
583=back 735=back
736
737
738=head3 FORK WATCHERS - the audacity to resume the event loop after a fork
739
740Fork watchers are called when a C<fork ()> was detected. The invocation
741is done before the event loop blocks next and before C<check> watchers
742are being called, and only in the child after the fork.
743
744=over 4
745
746=item $w = EV::fork $callback
747
748=item $w = EV::fork_ns $callback
749
750Call the callback before the event loop is resumed in the child process
751after a fork.
752
753The C<fork_ns> variant doesn't start (activate) the newly created watcher.
754
755=back
756
584 757
585=head1 THREADS 758=head1 THREADS
586 759
587Threads are not supported by this module in any way. Perl pseudo-threads 760Threads are not supported by this module in any way. Perl pseudo-threads
588is evil stuff and must die. As soon as Perl gains real threads I will work 761is evil stuff and must die. As soon as Perl gains real threads I will work
616 789
6171; 7901;
618 791
619=head1 SEE ALSO 792=head1 SEE ALSO
620 793
621 L<EV::DNS>. 794L<EV::ADNS> (asynchronous dns), L<Glib::EV> (makes Glib/Gtk2 use EV as
795event loop), L<Coro::EV> (efficient coroutines with EV).
622 796
623=head1 AUTHOR 797=head1 AUTHOR
624 798
625 Marc Lehmann <schmorp@schmorp.de> 799 Marc Lehmann <schmorp@schmorp.de>
626 http://home.schmorp.de/ 800 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines