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

Comparing EV/EV.pm (file contents):
Revision 1.55 by root, Tue Nov 27 08:11:52 2007 UTC vs.
Revision 1.64 by root, Sat Dec 8 02:55:13 2007 UTC

58This module provides an interface to libev 58This module provides an interface to libev
59(L<http://software.schmorp.de/pkg/libev.html>). While the documentation 59(L<http://software.schmorp.de/pkg/libev.html>). While the documentation
60below is comprehensive, one might also consult the documentation of libev 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 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 62watcher semantics or some discussion on the available backends, or how to
63force a specific backend with C<LIBEV_FLAGS>. 63force a specific backend with C<LIBEV_FLAGS>, or just about in any case
64because it has much more detailed information.
64 65
65=cut 66=cut
66 67
67package EV; 68package EV;
68 69
69use strict; 70use strict;
70 71
71BEGIN { 72BEGIN {
72 our $VERSION = '1.4'; 73 our $VERSION = '1.8';
73 use XSLoader; 74 use XSLoader;
74 XSLoader::load "EV", $VERSION; 75 XSLoader::load "EV", $VERSION;
75} 76}
76 77
77@EV::IO::ISA = 78@EV::IO::ISA =
78@EV::Timer::ISA = 79@EV::Timer::ISA =
79@EV::Periodic::ISA = 80@EV::Periodic::ISA =
80@EV::Signal::ISA = 81@EV::Signal::ISA =
82@EV::Child::ISA =
83@EV::Stat::ISA =
81@EV::Idle::ISA = 84@EV::Idle::ISA =
82@EV::Prepare::ISA = 85@EV::Prepare::ISA =
83@EV::Check::ISA = 86@EV::Check::ISA =
84@EV::Child::ISA =
85@EV::Embed::ISA = 87@EV::Embed::ISA =
86@EV::Stat::ISA = "EV::Watcher"; 88@EV::Fork::ISA =
89 "EV::Watcher";
87 90
88=head1 BASIC INTERFACE 91=head1 BASIC INTERFACE
89 92
90=over 4 93=over 4
91 94
128When called with no arguments or an argument of EV::UNLOOP_ONE, makes the 131When called with no arguments or an argument of EV::UNLOOP_ONE, makes the
129innermost call to EV::loop return. 132innermost call to EV::loop return.
130 133
131When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as 134When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as
132fast as possible. 135fast as possible.
136
137=item $count = EV::loop_count
138
139Return the number of times the event loop has polled for new
140events. Sometiems useful as a generation counter.
133 141
134=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents) 142=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents)
135 143
136This function rolls together an I/O and a timer watcher for a single 144This function rolls together an I/O and a timer watcher for a single
137one-shot event without the need for managing a watcher object. 145one-shot event without the need for managing a watcher object.
173events. 181events.
174 182
175Each watcher type has its associated bit in revents, so you can use the 183Each watcher type has its associated bit in revents, so you can use the
176same callback for multiple watchers. The event mask is named after the 184same callback for multiple watchers. The event mask is named after the
177type, i..e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE, 185type, i..e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE,
178EV::periodic sets EV::PERIODIC and so on, with the exception of IO events 186EV::periodic sets EV::PERIODIC and so on, with the exception of I/O events
179(which can set both EV::READ and EV::WRITE bits), and EV::timer (which 187(which can set both EV::READ and EV::WRITE bits), and EV::timer (which
180uses EV::TIMEOUT). 188uses EV::TIMEOUT).
181 189
182In the rare case where one wants to create a watcher but not start it at 190In the rare case where one wants to create a watcher but not start it at
183the same time, each constructor has a variant with a trailing C<_ns> in 191the same time, each constructor has a variant with a trailing C<_ns> in
205 213
206=item $w->stop 214=item $w->stop
207 215
208Stop a watcher if it is active. Also clear any pending events (events that 216Stop a watcher if it is active. Also clear any pending events (events that
209have been received but that didn't yet result in a callback invocation), 217have been received but that didn't yet result in a callback invocation),
210regardless of wether the watcher was active or not. 218regardless of whether the watcher was active or not.
211 219
212=item $bool = $w->is_active 220=item $bool = $w->is_active
213 221
214Returns true if the watcher is active, false otherwise. 222Returns true if the watcher is active, false otherwise.
215 223
270though your watcher is active, it won't keep C<EV::loop> from returning. 278though your watcher is active, it won't keep C<EV::loop> from returning.
271 279
272The initial value for keepalive is true (enabled), and you cna change it 280The initial value for keepalive is true (enabled), and you cna change it
273any time. 281any time.
274 282
275Example: Register an IO watcher for some UDP socket but do not keep the 283Example: Register an I/O watcher for some UDP socket but do not keep the
276event loop from running just because of that watcher. 284event loop from running just because of that watcher.
277 285
278 my $udp_socket = ... 286 my $udp_socket = ...
279 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 287 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
280 $udp_watcher->keepalive (0); 288 $udp_watcher->keepalive (0);
284 292
285=head2 WATCHER TYPES 293=head2 WATCHER TYPES
286 294
287Each of the following subsections describes a single watcher type. 295Each of the following subsections describes a single watcher type.
288 296
289=head3 IO WATCHERS - is this file descriptor readable or writable? 297=head3 I/O WATCHERS - is this file descriptor readable or writable?
290 298
291=over 4 299=over 4
292 300
293=item $w = EV::io $fileno_or_fh, $eventmask, $callback 301=item $w = EV::io $fileno_or_fh, $eventmask, $callback
294 302
551watcher for all pids). 559watcher for all pids).
552 560
553=back 561=back
554 562
555 563
564=head3 STAT WATCHERS - did the file attributes just change?
565
566=over 4
567
568=item $w = EV::stat $path, $interval, $callback
569
570=item $w = EV::stat_ns $path, $interval, $callback
571
572Call the callback when a file status change has been detected on
573C<$path>. The C<$path> does not need to exist, changing from "path exists"
574to "path does not exist" is a status change like any other.
575
576The C<$interval> is a recommended polling interval for systems where
577OS-supported change notifications don't exist or are not supported. If
578you use C<0> then an unspecified default is used (which is highly
579recommended!), which is to be expected to be around five seconds usually.
580
581This watcher type is not meant for massive numbers of stat watchers,
582as even with OS-supported change notifications, this can be
583resource-intensive.
584
585The C<stat_ns> variant doesn't start (activate) the newly created watcher.
586
587=item ... = $w->stat
588
589This call is very similar to the perl C<stat> built-in: It stats (using
590C<lstat>) the path specified in the watcher and sets perls stat cache (as
591well as EV's idea of the current stat values) to the values found.
592
593In scalar context, a boolean is return indicating success or failure of
594the stat. In list context, the same 13-value list as with stat is returned
595(except that the blksize and blocks fields are not reliable).
596
597In the case of an error, errno is set to C<ENOENT> (regardless of the
598actual error value) and the C<nlink> value is forced to zero (if the stat
599was successful then nlink is guaranteed to be non-zero).
600
601See also the next two entries for more info.
602
603=item ... = $w->attr
604
605Just like C<< $w->stat >>, but without the initial stat'ing: this returns
606the values most recently detected by EV. See the next entry for more info.
607
608=item ... = $w->prev
609
610Just like C<< $w->stat >>, but without the initial stat'ing: this returns
611the previous set of values, before the change.
612
613That is, when the watcher callback is invoked, C<< $w->prev >> will be set
614to the values found I<before> a change was detected, while C<< $w->attr >>
615returns the values found leading to the change detection. The difference (if any)
616between C<prev> and C<attr> is what triggered the callback.
617
618If you did something to the filesystem object and do not want to trigger
619yet another change, you can call C<stat> to update EV's idea of what the
620current attributes are.
621
622=item $w->set ($path, $interval)
623
624Reconfigures the watcher, see the constructor above for details. Can be
625called at any time.
626
627=item $current_path = $w->path
628
629=item $old_path = $w->path ($new_path)
630
631Returns the previously set path and optionally set a new one.
632
633=item $current_interval = $w->interval
634
635=item $old_interval = $w->interval ($new_interval)
636
637Returns the previously set interval and optionally set a new one. Can be
638used to query the actual interval used.
639
640=back
641
642
556=head3 IDLE WATCHERS - when you've got nothing better to do... 643=head3 IDLE WATCHERS - when you've got nothing better to do...
557 644
558=over 4 645=over 4
559 646
560=item $w = EV::idle $callback 647=item $w = EV::idle $callback
561 648
562=item $w = EV::idle_ns $callback 649=item $w = EV::idle_ns $callback
563 650
564Call the callback when there are no pending io, timer/periodic, signal or 651Call the callback when there are no other pending watchers of the same or
565child events, i.e. when the process is idle. 652higher priority (excluding check, prepare and other idle watchers of the
653same or lower priority, of course). They are called idle watchers because
654when the watcher is the highest priority pending event in the process, the
655process is considered to be idle at that priority.
656
657If you want a watcher that is only ever called when I<no> other events are
658outstanding you have to set the priority to C<EV::MINPRI>.
566 659
567The process will not block as long as any idle watchers are active, and 660The process will not block as long as any idle watchers are active, and
568they will be called repeatedly until stopped. 661they will be called repeatedly until stopped.
662
663For example, if you have idle watchers at priority C<0> and C<1>, and
664an I/O watcher at priority C<0>, then the idle watcher at priority C<1>
665and the I/O watcher will always run when ready. Only when the idle watcher
666at priority C<1> is stopped and the I/O watcher at priority C<0> is not
667pending with the C<0>-priority idle watcher be invoked.
569 668
570The C<idle_ns> variant doesn't start (activate) the newly created watcher. 669The C<idle_ns> variant doesn't start (activate) the newly created watcher.
571 670
572=back 671=back
573 672
614 or return; 713 or return;
615 714
616 # make the dispatcher handle any outstanding stuff 715 # make the dispatcher handle any outstanding stuff
617 ... not shown 716 ... not shown
618 717
619 # create an IO watcher for each and every socket 718 # create an I/O watcher for each and every socket
620 @snmp_watcher = ( 719 @snmp_watcher = (
621 (map { EV::io $_, EV::READ, sub { } } 720 (map { EV::io $_, EV::READ, sub { } }
622 keys %{ $dispatcher->{_descriptors} }), 721 keys %{ $dispatcher->{_descriptors} }),
623 722
624 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE] 723 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
646 745
647The C<check_ns> variant doesn't start (activate) the newly created watcher. 746The C<check_ns> variant doesn't start (activate) the newly created watcher.
648 747
649=back 748=back
650 749
651=head3 STAT WATCHERS - did the file attributes just change?
652 750
653=over 4 751=head3 FORK WATCHERS - the audacity to resume the event loop after a fork
654 752
655=item $w = EV::stat $path, $interval, $callback 753Fork watchers are called when a C<fork ()> was detected. The invocation
754is done before the event loop blocks next and before C<check> watchers
755are being called, and only in the child after the fork.
656 756
657=item $w = EV::stat_ns $path, $interval, $callback 757=over 4
658 758
659Call the callback when a file status change has been detected on 759=item $w = EV::fork $callback
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 760
663The C<$interval> is a recommended polling interval for systems where 761=item $w = EV::fork_ns $callback
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 762
668This watcher type is not meant for massive numbers of stat watchers, 763Call the callback before the event loop is resumed in the child process
669as even with OS-supported change notifications, this can be 764after a fork.
670resource-intensive.
671 765
672The C<stat_ns> variant doesn't start (activate) the newly created watcher. 766The C<fork_ns> variant doesn't start (activate) the newly created watcher.
673 767
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 768=back
693 769
770
771=head1 PERL SIGNALS
772
773While Perl signal handling (C<%SIG>) is not affected by EV, the behaviour
774with EV is as the same as any other C library: Perl-signals will only be
775handled when Perl runs, which means your signal handler might be invoked
776only the next time an event callback is invoked.
777
778The solution is to use EV signal watchers (see C<EV::signal>), which will
779ensure proper operations with regards to other event watchers.
780
781If you cannot do this for whatever reason, you can also force a watcher
782to be called on every event loop iteration by installing a C<EV::check>
783watcher:
784
785 my $async_check = EV::check sub { };
786
787This ensures that perl shortly gets into control for a short time, and
788also ensures slower overall operation.
694 789
695=head1 THREADS 790=head1 THREADS
696 791
697Threads are not supported by this module in any way. Perl pseudo-threads 792Threads are not supported by this module in any way. Perl pseudo-threads
698is evil stuff and must die. As soon as Perl gains real threads I will work 793is evil stuff and must die. As soon as Perl gains real threads I will work
726 821
7271; 8221;
728 823
729=head1 SEE ALSO 824=head1 SEE ALSO
730 825
731L<EV::DNS>. 826L<EV::ADNS> (asynchronous dns), L<Glib::EV> (makes Glib/Gtk2 use EV as
827event loop), L<Coro::EV> (efficient coroutines with EV).
732 828
733=head1 AUTHOR 829=head1 AUTHOR
734 830
735 Marc Lehmann <schmorp@schmorp.de> 831 Marc Lehmann <schmorp@schmorp.de>
736 http://home.schmorp.de/ 832 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines