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.54 by root, Tue Nov 27 07:27:10 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.4';
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 =
69@EV::Periodic::ISA = 79@EV::Periodic::ISA =
70@EV::Signal::ISA = 80@EV::Signal::ISA =
71@EV::Idle::ISA = 81@EV::Idle::ISA =
72@EV::Prepare::ISA = 82@EV::Prepare::ISA =
73@EV::Check::ISA = 83@EV::Check::ISA =
84@EV::Child::ISA =
85@EV::Embed::ISA =
74@EV::Child::ISA = "EV::Watcher"; 86@EV::Stat::ISA = "EV::Watcher";
75 87
76=head1 BASIC INTERFACE 88=head1 BASIC INTERFACE
77 89
78=over 4 90=over 4
79 91
142of them triggers, then they will be stopped and freed, and the callback 154of them triggers, then they will be stopped and freed, and the callback
143invoked. 155invoked.
144 156
145=back 157=back
146 158
147=head2 WATCHER 159=head2 WATCHER OBJECTS
148 160
149A watcher is an object that gets created to record your interest in some 161A 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 162event. For instance, if you want to wait for STDIN to become readable, you
151would create an EV::io watcher for that: 163would create an EV::io watcher for that:
152 164
177 189
178Also, all methods changing some aspect of a watcher (->set, ->priority, 190Also, 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, 191->fh and so on) automatically stop and start it again if it is active,
180which means pending events get lost. 192which means pending events get lost.
181 193
182=head2 WATCHER TYPES 194=head2 COMMON WATCHER METHODS
183 195
184Now lets move to the existing watcher types and asociated methods. 196This 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 197
191=over 4 198=over 4
192 199
193=item $w->start 200=item $w->start
194 201
270 277
271 my $udp_socket = ... 278 my $udp_socket = ...
272 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 279 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
273 $udp_watcher->keepalive (0); 280 $udp_watcher->keepalive (0);
274 281
282=back
283
284
285=head2 WATCHER TYPES
286
287Each of the following subsections describes a single watcher type.
288
289=head3 IO WATCHERS - is this file descriptor readable or writable?
290
291=over 4
292
275=item $w = EV::io $fileno_or_fh, $eventmask, $callback 293=item $w = EV::io $fileno_or_fh, $eventmask, $callback
276 294
277=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback 295=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
278 296
279As long as the returned watcher object is alive, call the C<$callback> 297As long as the returned watcher object is alive, call the C<$callback>
280when the events specified in C<$eventmask>. 298when at least one of events specified in C<$eventmask> occurs.
281 299
282The $eventmask can be one or more of these constants ORed together: 300The $eventmask can be one or more of these constants ORed together:
283 301
284 EV::READ wait until read() wouldn't block anymore 302 EV::READ wait until read() wouldn't block anymore
285 EV::WRITE wait until write() wouldn't block anymore 303 EV::WRITE wait until write() wouldn't block anymore
301 319
302=item $old_eventmask = $w->events ($new_eventmask) 320=item $old_eventmask = $w->events ($new_eventmask)
303 321
304Returns the previously set event mask and optionally set a new one. 322Returns the previously set event mask and optionally set a new one.
305 323
324=back
325
326
327=head3 TIMER WATCHERS - relative and optionally repeating timeouts
328
329=over 4
306 330
307=item $w = EV::timer $after, $repeat, $callback 331=item $w = EV::timer $after, $repeat, $callback
308 332
309=item $w = EV::timer_ns $after, $repeat, $callback 333=item $w = EV::timer_ns $after, $repeat, $callback
310 334
311Calls the callback after C<$after> seconds. If C<$repeat> is non-zero, 335Calls the callback after C<$after> seconds (which may be fractional). If
312the timer will be restarted (with the $repeat value as $after) after the 336C<$repeat> is non-zero, the timer will be restarted (with the $repeat
313callback returns. 337value as $after) after the callback returns.
314 338
315This means that the callback would be called roughly after C<$after> 339This means that the callback would be called roughly after C<$after>
316seconds, and then every C<$repeat> seconds. The timer does his best not 340seconds, 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 341to 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, 342loop iteration, and might drift in other cases. If that isn't acceptable,
324 348
325The C<timer_ns> variant doesn't start (activate) the newly created watcher. 349The C<timer_ns> variant doesn't start (activate) the newly created watcher.
326 350
327=item $w->set ($after, $repeat) 351=item $w->set ($after, $repeat)
328 352
329Reconfigures the watcher, see the constructor above for details. Can be at 353Reconfigures the watcher, see the constructor above for details. Can be called at
330any time. 354any time.
331 355
332=item $w->again 356=item $w->again
333 357
334Similar to the C<start> method, but has special semantics for repeating timers: 358Similar to the C<start> method, but has special semantics for repeating timers:
345This behaviour is useful when you have a timeout for some IO 369This 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 370operation. 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 371C<$repeat>, and then, in the read/write watcher, run the C<again> method
348on the timeout. 372on the timeout.
349 373
374=back
375
376
377=head3 PERIODIC WATCHERS - to cron or not to cron?
378
379=over 4
350 380
351=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback 381=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback
352 382
353=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback 383=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
354 384
426 456
427The C<periodic_ns> variant doesn't start (activate) the newly created watcher. 457The C<periodic_ns> variant doesn't start (activate) the newly created watcher.
428 458
429=item $w->set ($at, $interval, $reschedule_cb) 459=item $w->set ($at, $interval, $reschedule_cb)
430 460
431Reconfigures the watcher, see the constructor above for details. Can be at 461Reconfigures the watcher, see the constructor above for details. Can be called at
432any time. 462any time.
433 463
434=item $w->again 464=item $w->again
435 465
436Simply stops and starts the watcher again. 466Simply stops and starts the watcher again.
437 467
468=back
469
470
471=head3 SIGNAL WATCHERS - signal me when a signal gets signalled!
472
473=over 4
438 474
439=item $w = EV::signal $signal, $callback 475=item $w = EV::signal $signal, $callback
440 476
441=item $w = EV::signal_ns $signal, $callback 477=item $w = EV::signal_ns $signal, $callback
442 478
443Call the callback when $signal is received (the signal can be specified 479Call the callback when $signal is received (the signal can be specified by
444by number or by name, just as with kill or %SIG). 480number or by name, just as with C<kill> or C<%SIG>).
445 481
446EV will grab the signal for the process (the kernel only allows one 482EV 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, 483component 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 484and removes it again when you stop it. Perl does the same when you
449add/remove callbacks to %SIG, so watch out. 485add/remove callbacks to C<%SIG>, so watch out.
450 486
451You can have as many signal watchers per signal as you want. 487You can have as many signal watchers per signal as you want.
452 488
453The C<signal_ns> variant doesn't start (activate) the newly created watcher. 489The C<signal_ns> variant doesn't start (activate) the newly created watcher.
454 490
455=item $w->set ($signal) 491=item $w->set ($signal)
456 492
457Reconfigures the watcher, see the constructor above for details. Can be at 493Reconfigures the watcher, see the constructor above for details. Can be
458any time. 494called at any time.
459 495
460=item $current_signum = $w->signal 496=item $current_signum = $w->signal
461 497
462=item $old_signum = $w->signal ($new_signal) 498=item $old_signum = $w->signal ($new_signal)
463 499
464Returns the previously set signal (always as a number not name) and 500Returns the previously set signal (always as a number not name) and
465optionally set a new one. 501optionally set a new one.
466 502
503=back
504
505
506=head3 CHILD WATCHERS - watch out for process status changes
507
508=over 4
467 509
468=item $w = EV::child $pid, $callback 510=item $w = EV::child $pid, $callback
469 511
470=item $w = EV::child_ns $pid, $callback 512=item $w = EV::child_ns $pid, $callback
471 513
472Call the callback when a status change for pid C<$pid> (or any pid 514Call 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 515C<$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 516a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
475changed/zombie children and call the callback. 517changed/zombie children and call the callback.
476 518
477You can access both status and pid by using the C<rstatus> and C<rpid> 519It is valid (and fully supported) to install a child watcher after a child
478methods on the watcher object. 520has exited but before the event loop has started its next iteration (for
521example, first you C<fork>, then the new child process might exit, and
522only then do you install a child watcher in the parent for the new pid).
479 523
524You can access both exit (or tracing) status and pid by using the
525C<rstatus> and C<rpid> methods on the watcher object.
526
480You can have as many pid watchers per pid as you want. 527You can have as many pid watchers per pid as you want, they will all be
528called.
481 529
482The C<child_ns> variant doesn't start (activate) the newly created watcher. 530The C<child_ns> variant doesn't start (activate) the newly created watcher.
483 531
484=item $w->set ($pid) 532=item $w->set ($pid)
485 533
486Reconfigures the watcher, see the constructor above for details. Can be at 534Reconfigures the watcher, see the constructor above for details. Can be called at
487any time. 535any time.
488 536
489=item $current_pid = $w->pid 537=item $current_pid = $w->pid
490 538
491=item $old_pid = $w->pid ($new_pid) 539=item $old_pid = $w->pid ($new_pid)
500=item $pid = $w->rpid 548=item $pid = $w->rpid
501 549
502Return the pid of the awaited child (useful when you have installed a 550Return the pid of the awaited child (useful when you have installed a
503watcher for all pids). 551watcher for all pids).
504 552
553=back
554
555
556=head3 IDLE WATCHERS - when you've got nothing better to do...
557
558=over 4
505 559
506=item $w = EV::idle $callback 560=item $w = EV::idle $callback
507 561
508=item $w = EV::idle_ns $callback 562=item $w = EV::idle_ns $callback
509 563
513The process will not block as long as any idle watchers are active, and 567The process will not block as long as any idle watchers are active, and
514they will be called repeatedly until stopped. 568they will be called repeatedly until stopped.
515 569
516The C<idle_ns> variant doesn't start (activate) the newly created watcher. 570The C<idle_ns> variant doesn't start (activate) the newly created watcher.
517 571
572=back
573
574
575=head3 PREPARE WATCHERS - customise your event loop!
576
577=over 4
518 578
519=item $w = EV::prepare $callback 579=item $w = EV::prepare $callback
520 580
521=item $w = EV::prepare_ns $callback 581=item $w = EV::prepare_ns $callback
522 582
525 585
526See the EV::check watcher, below, for explanations and an example. 586See the EV::check watcher, below, for explanations and an example.
527 587
528The C<prepare_ns> variant doesn't start (activate) the newly created watcher. 588The C<prepare_ns> variant doesn't start (activate) the newly created watcher.
529 589
590=back
591
592
593=head3 CHECK WATCHERS - customise your event loop even more!
594
595=over 4
530 596
531=item $w = EV::check $callback 597=item $w = EV::check $callback
532 598
533=item $w = EV::check_ns $callback 599=item $w = EV::check_ns $callback
534 600
579first). 645first).
580 646
581The C<check_ns> variant doesn't start (activate) the newly created watcher. 647The C<check_ns> variant doesn't start (activate) the newly created watcher.
582 648
583=back 649=back
650
651=head3 STAT WATCHERS - did the file stats just change?
652
653=over 4
654
655=item $w = EV::stat $path, $interval, $callback
656
657=item $w = EV::stat_ns $path, $interval, $callback
658
659Call the callback when a file status change has been detected on
660C<$path>. The C<$path> does not need to exist, changing from "path exists"
661to "path does not exist" is a status change like any other.
662
663The C<$interval> is a recommended polling interval for systems where
664OS-supported change notifications don't exist or are not supported. If
665you use C<0> then an unspecified default is used (which is highly
666recommended!), which is to be expected to be around five seconds usually.
667
668This watcher type is not meant for massive numbers of stat watchers,
669as even with OS-supported change notifications, this can be
670resource-intensive.
671
672The C<stat_ns> variant doesn't start (activate) the newly created watcher.
673
674=item $w->set ($path, $interval)
675
676Reconfigures the watcher, see the constructor above for details. Can be
677called at any time.
678
679=item $current_path = $w->path
680
681=item $old_path = $w->path ($new_path)
682
683Returns the previously set path and optionally set a new one.
684
685=item $current_interval = $w->interval
686
687=item $old_interval = $w->interval ($new_interval)
688
689Returns the previously set interval and optionally set a new one. Can be
690used to query the actual interval used.
691
692=back
693
584 694
585=head1 THREADS 695=head1 THREADS
586 696
587Threads are not supported by this module in any way. Perl pseudo-threads 697Threads 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 698is evil stuff and must die. As soon as Perl gains real threads I will work
616 726
6171; 7271;
618 728
619=head1 SEE ALSO 729=head1 SEE ALSO
620 730
621 L<EV::DNS>. 731L<EV::DNS>.
622 732
623=head1 AUTHOR 733=head1 AUTHOR
624 734
625 Marc Lehmann <schmorp@schmorp.de> 735 Marc Lehmann <schmorp@schmorp.de>
626 http://home.schmorp.de/ 736 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines