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.56 by root, Tue Nov 27 10:59: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 =
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
142of them triggers, then they will be stopped and freed, and the callback 156of them triggers, then they will be stopped and freed, and the callback
143invoked. 157invoked.
144 158
145=back 159=back
146 160
147=head2 WATCHER 161=head2 WATCHER OBJECTS
148 162
149A watcher is an object that gets created to record your interest in some 163A 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 164event. For instance, if you want to wait for STDIN to become readable, you
151would create an EV::io watcher for that: 165would create an EV::io watcher for that:
152 166
177 191
178Also, all methods changing some aspect of a watcher (->set, ->priority, 192Also, 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, 193->fh and so on) automatically stop and start it again if it is active,
180which means pending events get lost. 194which means pending events get lost.
181 195
182=head2 WATCHER TYPES 196=head2 COMMON WATCHER METHODS
183 197
184Now lets move to the existing watcher types and asociated methods. 198This 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 199
191=over 4 200=over 4
192 201
193=item $w->start 202=item $w->start
194 203
270 279
271 my $udp_socket = ... 280 my $udp_socket = ...
272 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 281 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
273 $udp_watcher->keepalive (0); 282 $udp_watcher->keepalive (0);
274 283
284=back
285
286
287=head2 WATCHER TYPES
288
289Each of the following subsections describes a single watcher type.
290
291=head3 IO WATCHERS - is this file descriptor readable or writable?
292
293=over 4
294
275=item $w = EV::io $fileno_or_fh, $eventmask, $callback 295=item $w = EV::io $fileno_or_fh, $eventmask, $callback
276 296
277=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback 297=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
278 298
279As long as the returned watcher object is alive, call the C<$callback> 299As long as the returned watcher object is alive, call the C<$callback>
280when the events specified in C<$eventmask>. 300when at least one of events specified in C<$eventmask> occurs.
281 301
282The $eventmask can be one or more of these constants ORed together: 302The $eventmask can be one or more of these constants ORed together:
283 303
284 EV::READ wait until read() wouldn't block anymore 304 EV::READ wait until read() wouldn't block anymore
285 EV::WRITE wait until write() wouldn't block anymore 305 EV::WRITE wait until write() wouldn't block anymore
301 321
302=item $old_eventmask = $w->events ($new_eventmask) 322=item $old_eventmask = $w->events ($new_eventmask)
303 323
304Returns the previously set event mask and optionally set a new one. 324Returns the previously set event mask and optionally set a new one.
305 325
326=back
327
328
329=head3 TIMER WATCHERS - relative and optionally repeating timeouts
330
331=over 4
306 332
307=item $w = EV::timer $after, $repeat, $callback 333=item $w = EV::timer $after, $repeat, $callback
308 334
309=item $w = EV::timer_ns $after, $repeat, $callback 335=item $w = EV::timer_ns $after, $repeat, $callback
310 336
311Calls the callback after C<$after> seconds. If C<$repeat> is non-zero, 337Calls the callback after C<$after> seconds (which may be fractional). If
312the timer will be restarted (with the $repeat value as $after) after the 338C<$repeat> is non-zero, the timer will be restarted (with the $repeat
313callback returns. 339value as $after) after the callback returns.
314 340
315This means that the callback would be called roughly after C<$after> 341This means that the callback would be called roughly after C<$after>
316seconds, and then every C<$repeat> seconds. The timer does his best not 342seconds, 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 343to 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, 344loop iteration, and might drift in other cases. If that isn't acceptable,
324 350
325The C<timer_ns> variant doesn't start (activate) the newly created watcher. 351The C<timer_ns> variant doesn't start (activate) the newly created watcher.
326 352
327=item $w->set ($after, $repeat) 353=item $w->set ($after, $repeat)
328 354
329Reconfigures the watcher, see the constructor above for details. Can be at 355Reconfigures the watcher, see the constructor above for details. Can be called at
330any time. 356any time.
331 357
332=item $w->again 358=item $w->again
333 359
334Similar to the C<start> method, but has special semantics for repeating timers: 360Similar to the C<start> method, but has special semantics for repeating timers:
345This behaviour is useful when you have a timeout for some IO 371This 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 372operation. 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 373C<$repeat>, and then, in the read/write watcher, run the C<again> method
348on the timeout. 374on the timeout.
349 375
376=back
377
378
379=head3 PERIODIC WATCHERS - to cron or not to cron?
380
381=over 4
350 382
351=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback 383=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback
352 384
353=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback 385=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
354 386
426 458
427The C<periodic_ns> variant doesn't start (activate) the newly created watcher. 459The C<periodic_ns> variant doesn't start (activate) the newly created watcher.
428 460
429=item $w->set ($at, $interval, $reschedule_cb) 461=item $w->set ($at, $interval, $reschedule_cb)
430 462
431Reconfigures the watcher, see the constructor above for details. Can be at 463Reconfigures the watcher, see the constructor above for details. Can be called at
432any time. 464any time.
433 465
434=item $w->again 466=item $w->again
435 467
436Simply stops and starts the watcher again. 468Simply stops and starts the watcher again.
437 469
470=back
471
472
473=head3 SIGNAL WATCHERS - signal me when a signal gets signalled!
474
475=over 4
438 476
439=item $w = EV::signal $signal, $callback 477=item $w = EV::signal $signal, $callback
440 478
441=item $w = EV::signal_ns $signal, $callback 479=item $w = EV::signal_ns $signal, $callback
442 480
443Call the callback when $signal is received (the signal can be specified 481Call the callback when $signal is received (the signal can be specified by
444by number or by name, just as with kill or %SIG). 482number or by name, just as with C<kill> or C<%SIG>).
445 483
446EV will grab the signal for the process (the kernel only allows one 484EV 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, 485component 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 486and removes it again when you stop it. Perl does the same when you
449add/remove callbacks to %SIG, so watch out. 487add/remove callbacks to C<%SIG>, so watch out.
450 488
451You can have as many signal watchers per signal as you want. 489You can have as many signal watchers per signal as you want.
452 490
453The C<signal_ns> variant doesn't start (activate) the newly created watcher. 491The C<signal_ns> variant doesn't start (activate) the newly created watcher.
454 492
455=item $w->set ($signal) 493=item $w->set ($signal)
456 494
457Reconfigures the watcher, see the constructor above for details. Can be at 495Reconfigures the watcher, see the constructor above for details. Can be
458any time. 496called at any time.
459 497
460=item $current_signum = $w->signal 498=item $current_signum = $w->signal
461 499
462=item $old_signum = $w->signal ($new_signal) 500=item $old_signum = $w->signal ($new_signal)
463 501
464Returns the previously set signal (always as a number not name) and 502Returns the previously set signal (always as a number not name) and
465optionally set a new one. 503optionally set a new one.
466 504
505=back
506
507
508=head3 CHILD WATCHERS - watch out for process status changes
509
510=over 4
467 511
468=item $w = EV::child $pid, $callback 512=item $w = EV::child $pid, $callback
469 513
470=item $w = EV::child_ns $pid, $callback 514=item $w = EV::child_ns $pid, $callback
471 515
472Call the callback when a status change for pid C<$pid> (or any pid 516Call 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 517C<$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 518a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
475changed/zombie children and call the callback. 519changed/zombie children and call the callback.
476 520
477You can access both status and pid by using the C<rstatus> and C<rpid> 521It is valid (and fully supported) to install a child watcher after a child
478methods on the watcher object. 522has exited but before the event loop has started its next iteration (for
523example, first you C<fork>, then the new child process might exit, and
524only then do you install a child watcher in the parent for the new pid).
479 525
526You can access both exit (or tracing) status and pid by using the
527C<rstatus> and C<rpid> methods on the watcher object.
528
480You can have as many pid watchers per pid as you want. 529You can have as many pid watchers per pid as you want, they will all be
530called.
481 531
482The C<child_ns> variant doesn't start (activate) the newly created watcher. 532The C<child_ns> variant doesn't start (activate) the newly created watcher.
483 533
484=item $w->set ($pid) 534=item $w->set ($pid)
485 535
486Reconfigures the watcher, see the constructor above for details. Can be at 536Reconfigures the watcher, see the constructor above for details. Can be called at
487any time. 537any time.
488 538
489=item $current_pid = $w->pid 539=item $current_pid = $w->pid
490 540
491=item $old_pid = $w->pid ($new_pid) 541=item $old_pid = $w->pid ($new_pid)
500=item $pid = $w->rpid 550=item $pid = $w->rpid
501 551
502Return the pid of the awaited child (useful when you have installed a 552Return the pid of the awaited child (useful when you have installed a
503watcher for all pids). 553watcher for all pids).
504 554
555=back
556
557
558=head3 STAT WATCHERS - did the file attributes just change?
559
560=over 4
561
562=item $w = EV::stat $path, $interval, $callback
563
564=item $w = EV::stat_ns $path, $interval, $callback
565
566Call the callback when a file status change has been detected on
567C<$path>. The C<$path> does not need to exist, changing from "path exists"
568to "path does not exist" is a status change like any other.
569
570The C<$interval> is a recommended polling interval for systems where
571OS-supported change notifications don't exist or are not supported. If
572you use C<0> then an unspecified default is used (which is highly
573recommended!), which is to be expected to be around five seconds usually.
574
575This watcher type is not meant for massive numbers of stat watchers,
576as even with OS-supported change notifications, this can be
577resource-intensive.
578
579The C<stat_ns> variant doesn't start (activate) the newly created watcher.
580
581=item $w->set ($path, $interval)
582
583Reconfigures the watcher, see the constructor above for details. Can be
584called at any time.
585
586=item $current_path = $w->path
587
588=item $old_path = $w->path ($new_path)
589
590Returns the previously set path and optionally set a new one.
591
592=item $current_interval = $w->interval
593
594=item $old_interval = $w->interval ($new_interval)
595
596Returns the previously set interval and optionally set a new one. Can be
597used to query the actual interval used.
598
599=back
600
601
602=head3 IDLE WATCHERS - when you've got nothing better to do...
603
604=over 4
505 605
506=item $w = EV::idle $callback 606=item $w = EV::idle $callback
507 607
508=item $w = EV::idle_ns $callback 608=item $w = EV::idle_ns $callback
509 609
513The process will not block as long as any idle watchers are active, and 613The process will not block as long as any idle watchers are active, and
514they will be called repeatedly until stopped. 614they will be called repeatedly until stopped.
515 615
516The C<idle_ns> variant doesn't start (activate) the newly created watcher. 616The C<idle_ns> variant doesn't start (activate) the newly created watcher.
517 617
618=back
619
620
621=head3 PREPARE WATCHERS - customise your event loop!
622
623=over 4
518 624
519=item $w = EV::prepare $callback 625=item $w = EV::prepare $callback
520 626
521=item $w = EV::prepare_ns $callback 627=item $w = EV::prepare_ns $callback
522 628
525 631
526See the EV::check watcher, below, for explanations and an example. 632See the EV::check watcher, below, for explanations and an example.
527 633
528The C<prepare_ns> variant doesn't start (activate) the newly created watcher. 634The C<prepare_ns> variant doesn't start (activate) the newly created watcher.
529 635
636=back
637
638
639=head3 CHECK WATCHERS - customise your event loop even more!
640
641=over 4
530 642
531=item $w = EV::check $callback 643=item $w = EV::check $callback
532 644
533=item $w = EV::check_ns $callback 645=item $w = EV::check_ns $callback
534 646
579first). 691first).
580 692
581The C<check_ns> variant doesn't start (activate) the newly created watcher. 693The C<check_ns> variant doesn't start (activate) the newly created watcher.
582 694
583=back 695=back
696
697
698=head3 FORK WATCHERS - the audacity to resume the event loop after a fork
699
700Fork watchers are called when a C<fork ()> was detected. The invocation
701is done before the event loop blocks next and before C<check> watchers
702are being called, and only in the child after the fork.
703
704=over 4
705
706=item $w = EV::fork $callback
707
708=item $w = EV::fork_ns $callback
709
710Call the callback before the event loop is resumed in the child process
711after a fork.
712
713The C<fork_ns> variant doesn't start (activate) the newly created watcher.
714
715=back
716
584 717
585=head1 THREADS 718=head1 THREADS
586 719
587Threads are not supported by this module in any way. Perl pseudo-threads 720Threads 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 721is evil stuff and must die. As soon as Perl gains real threads I will work
616 749
6171; 7501;
618 751
619=head1 SEE ALSO 752=head1 SEE ALSO
620 753
621 L<EV::DNS>. 754L<EV::DNS>.
622 755
623=head1 AUTHOR 756=head1 AUTHOR
624 757
625 Marc Lehmann <schmorp@schmorp.de> 758 Marc Lehmann <schmorp@schmorp.de>
626 http://home.schmorp.de/ 759 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines