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

Comparing EV/EV.pm (file contents):
Revision 1.54 by root, Tue Nov 27 07:27:10 2007 UTC vs.
Revision 1.72 by root, Thu Dec 20 07:12:57 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 = '2.0';
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";
90
91@EV::Loop::Default::ISA = "EV::Loop";
87 92
88=head1 BASIC INTERFACE 93=head1 BASIC INTERFACE
89 94
90=over 4 95=over 4
91 96
92=item $EV::DIED 97=item $EV::DIED
93 98
94Must contain a reference to a function that is called when a callback 99Must contain a reference to a function that is called when a callback
95throws an exception (with $@ containing thr error). The default prints an 100throws an exception (with $@ containing the error). The default prints an
96informative message and continues. 101informative message and continues.
97 102
98If this callback throws an exception it will be silently ignored. 103If this callback throws an exception it will be silently ignored.
99 104
100=item $time = EV::time 105=item $time = EV::time
128When called with no arguments or an argument of EV::UNLOOP_ONE, makes the 133When called with no arguments or an argument of EV::UNLOOP_ONE, makes the
129innermost call to EV::loop return. 134innermost call to EV::loop return.
130 135
131When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as 136When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as
132fast as possible. 137fast as possible.
138
139=item $count = EV::loop_count
140
141Return the number of times the event loop has polled for new
142events. Sometiems useful as a generation counter.
133 143
134=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents) 144=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents)
135 145
136This function rolls together an I/O and a timer watcher for a single 146This function rolls together an I/O and a timer watcher for a single
137one-shot event without the need for managing a watcher object. 147one-shot event without the need for managing a watcher object.
152 162
153EV::once doesn't return anything: the watchers stay active till either 163EV::once doesn't return anything: the watchers stay active till either
154of them triggers, then they will be stopped and freed, and the callback 164of them triggers, then they will be stopped and freed, and the callback
155invoked. 165invoked.
156 166
167=item EV::feed_fd_event ($fd, $revents)
168
169Feed an event on a file descriptor into EV. EV will react to this call as
170if the readyness notifications specified by C<$revents> (a combination of
171C<EV::READ> and C<EV::WRITE>) happened on the file descriptor C<$fd>.
172
173=item EV::feed_signal_event ($signal)
174
175Feed a signal event into EV. EV will react to this call as if the signal
176specified by C<$signal> had occured.
177
157=back 178=back
179
158 180
159=head2 WATCHER OBJECTS 181=head2 WATCHER OBJECTS
160 182
161A watcher is an object that gets created to record your interest in some 183A watcher is an object that gets created to record your interest in some
162event. For instance, if you want to wait for STDIN to become readable, you 184event. For instance, if you want to wait for STDIN to become readable, you
173events. 195events.
174 196
175Each watcher type has its associated bit in revents, so you can use the 197Each 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 198same callback for multiple watchers. The event mask is named after the
177type, i..e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE, 199type, 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 200EV::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 201(which can set both EV::READ and EV::WRITE bits), and EV::timer (which
180uses EV::TIMEOUT). 202uses EV::TIMEOUT).
181 203
182In the rare case where one wants to create a watcher but not start it at 204In 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 205the same time, each constructor has a variant with a trailing C<_ns> in
205 227
206=item $w->stop 228=item $w->stop
207 229
208Stop a watcher if it is active. Also clear any pending events (events that 230Stop 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), 231have been received but that didn't yet result in a callback invocation),
210regardless of wether the watcher was active or not. 232regardless of whether the watcher was active or not.
211 233
212=item $bool = $w->is_active 234=item $bool = $w->is_active
213 235
214Returns true if the watcher is active, false otherwise. 236Returns true if the watcher is active, false otherwise.
215 237
245The default priority of any newly-created watcher is 0. 267The default priority of any newly-created watcher is 0.
246 268
247Note that the priority semantics have not yet been fleshed out and are 269Note that the priority semantics have not yet been fleshed out and are
248subject to almost certain change. 270subject to almost certain change.
249 271
250=item $w->trigger ($revents) 272=item $w->invoke ($revents)
251 273
252Call the callback *now* with the given event mask. 274Call the callback *now* with the given event mask.
275
276=item $w->feed_event ($revents)
277
278Feed some events on this watcher into EV. EV will react to this call as if
279the watcher had received the given C<$revents> mask.
280
281=item $revents = $w->clear_pending
282
283If the watcher is pending, this function returns clears its pending status
284and returns its C<$revents> bitset (as if its callback was invoked). If the
285watcher isn't pending it does nothing and returns C<0>.
253 286
254=item $previous_state = $w->keepalive ($bool) 287=item $previous_state = $w->keepalive ($bool)
255 288
256Normally, C<EV::loop> will return when there are no active watchers 289Normally, C<EV::loop> will return when there are no active watchers
257(which is a "deadlock" because no progress can be made anymore). This is 290(which is a "deadlock" because no progress can be made anymore). This is
270though your watcher is active, it won't keep C<EV::loop> from returning. 303though your watcher is active, it won't keep C<EV::loop> from returning.
271 304
272The initial value for keepalive is true (enabled), and you cna change it 305The initial value for keepalive is true (enabled), and you cna change it
273any time. 306any time.
274 307
275Example: Register an IO watcher for some UDP socket but do not keep the 308Example: Register an I/O watcher for some UDP socket but do not keep the
276event loop from running just because of that watcher. 309event loop from running just because of that watcher.
277 310
278 my $udp_socket = ... 311 my $udp_socket = ...
279 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 312 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
280 $udp_watcher->keepalive (0); 313 $udp_watcher->keepalive (0);
284 317
285=head2 WATCHER TYPES 318=head2 WATCHER TYPES
286 319
287Each of the following subsections describes a single watcher type. 320Each of the following subsections describes a single watcher type.
288 321
289=head3 IO WATCHERS - is this file descriptor readable or writable? 322=head3 I/O WATCHERS - is this file descriptor readable or writable?
290 323
291=over 4 324=over 4
292 325
293=item $w = EV::io $fileno_or_fh, $eventmask, $callback 326=item $w = EV::io $fileno_or_fh, $eventmask, $callback
294 327
463 496
464=item $w->again 497=item $w->again
465 498
466Simply stops and starts the watcher again. 499Simply stops and starts the watcher again.
467 500
501=item $time = $w->at
502
503Return the time that the watcher is expected to trigger next.
504
468=back 505=back
469 506
470 507
471=head3 SIGNAL WATCHERS - signal me when a signal gets signalled! 508=head3 SIGNAL WATCHERS - signal me when a signal gets signalled!
472 509
551watcher for all pids). 588watcher for all pids).
552 589
553=back 590=back
554 591
555 592
593=head3 STAT WATCHERS - did the file attributes just change?
594
595=over 4
596
597=item $w = EV::stat $path, $interval, $callback
598
599=item $w = EV::stat_ns $path, $interval, $callback
600
601Call the callback when a file status change has been detected on
602C<$path>. The C<$path> does not need to exist, changing from "path exists"
603to "path does not exist" is a status change like any other.
604
605The C<$interval> is a recommended polling interval for systems where
606OS-supported change notifications don't exist or are not supported. If
607you use C<0> then an unspecified default is used (which is highly
608recommended!), which is to be expected to be around five seconds usually.
609
610This watcher type is not meant for massive numbers of stat watchers,
611as even with OS-supported change notifications, this can be
612resource-intensive.
613
614The C<stat_ns> variant doesn't start (activate) the newly created watcher.
615
616=item ... = $w->stat
617
618This call is very similar to the perl C<stat> built-in: It stats (using
619C<lstat>) the path specified in the watcher and sets perls stat cache (as
620well as EV's idea of the current stat values) to the values found.
621
622In scalar context, a boolean is return indicating success or failure of
623the stat. In list context, the same 13-value list as with stat is returned
624(except that the blksize and blocks fields are not reliable).
625
626In the case of an error, errno is set to C<ENOENT> (regardless of the
627actual error value) and the C<nlink> value is forced to zero (if the stat
628was successful then nlink is guaranteed to be non-zero).
629
630See also the next two entries for more info.
631
632=item ... = $w->attr
633
634Just like C<< $w->stat >>, but without the initial stat'ing: this returns
635the values most recently detected by EV. See the next entry for more info.
636
637=item ... = $w->prev
638
639Just like C<< $w->stat >>, but without the initial stat'ing: this returns
640the previous set of values, before the change.
641
642That is, when the watcher callback is invoked, C<< $w->prev >> will be set
643to the values found I<before> a change was detected, while C<< $w->attr >>
644returns the values found leading to the change detection. The difference (if any)
645between C<prev> and C<attr> is what triggered the callback.
646
647If you did something to the filesystem object and do not want to trigger
648yet another change, you can call C<stat> to update EV's idea of what the
649current attributes are.
650
651=item $w->set ($path, $interval)
652
653Reconfigures the watcher, see the constructor above for details. Can be
654called at any time.
655
656=item $current_path = $w->path
657
658=item $old_path = $w->path ($new_path)
659
660Returns the previously set path and optionally set a new one.
661
662=item $current_interval = $w->interval
663
664=item $old_interval = $w->interval ($new_interval)
665
666Returns the previously set interval and optionally set a new one. Can be
667used to query the actual interval used.
668
669=back
670
671
556=head3 IDLE WATCHERS - when you've got nothing better to do... 672=head3 IDLE WATCHERS - when you've got nothing better to do...
557 673
558=over 4 674=over 4
559 675
560=item $w = EV::idle $callback 676=item $w = EV::idle $callback
561 677
562=item $w = EV::idle_ns $callback 678=item $w = EV::idle_ns $callback
563 679
564Call the callback when there are no pending io, timer/periodic, signal or 680Call the callback when there are no other pending watchers of the same or
565child events, i.e. when the process is idle. 681higher priority (excluding check, prepare and other idle watchers of the
682same or lower priority, of course). They are called idle watchers because
683when the watcher is the highest priority pending event in the process, the
684process is considered to be idle at that priority.
685
686If you want a watcher that is only ever called when I<no> other events are
687outstanding you have to set the priority to C<EV::MINPRI>.
566 688
567The process will not block as long as any idle watchers are active, and 689The process will not block as long as any idle watchers are active, and
568they will be called repeatedly until stopped. 690they will be called repeatedly until stopped.
691
692For example, if you have idle watchers at priority C<0> and C<1>, and
693an I/O watcher at priority C<0>, then the idle watcher at priority C<1>
694and the I/O watcher will always run when ready. Only when the idle watcher
695at priority C<1> is stopped and the I/O watcher at priority C<0> is not
696pending with the C<0>-priority idle watcher be invoked.
569 697
570The C<idle_ns> variant doesn't start (activate) the newly created watcher. 698The C<idle_ns> variant doesn't start (activate) the newly created watcher.
571 699
572=back 700=back
573 701
614 or return; 742 or return;
615 743
616 # make the dispatcher handle any outstanding stuff 744 # make the dispatcher handle any outstanding stuff
617 ... not shown 745 ... not shown
618 746
619 # create an IO watcher for each and every socket 747 # create an I/O watcher for each and every socket
620 @snmp_watcher = ( 748 @snmp_watcher = (
621 (map { EV::io $_, EV::READ, sub { } } 749 (map { EV::io $_, EV::READ, sub { } }
622 keys %{ $dispatcher->{_descriptors} }), 750 keys %{ $dispatcher->{_descriptors} }),
623 751
624 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE] 752 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
646 774
647The C<check_ns> variant doesn't start (activate) the newly created watcher. 775The C<check_ns> variant doesn't start (activate) the newly created watcher.
648 776
649=back 777=back
650 778
651=head3 STAT WATCHERS - did the file stats just change?
652 779
653=over 4 780=head3 FORK WATCHERS - the audacity to resume the event loop after a fork
654 781
655=item $w = EV::stat $path, $interval, $callback 782Fork watchers are called when a C<fork ()> was detected. The invocation
783is done before the event loop blocks next and before C<check> watchers
784are being called, and only in the child after the fork.
656 785
657=item $w = EV::stat_ns $path, $interval, $callback 786=over 4
658 787
659Call the callback when a file status change has been detected on 788=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 789
663The C<$interval> is a recommended polling interval for systems where 790=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 791
668This watcher type is not meant for massive numbers of stat watchers, 792Call the callback before the event loop is resumed in the child process
669as even with OS-supported change notifications, this can be 793after a fork.
670resource-intensive.
671 794
672The C<stat_ns> variant doesn't start (activate) the newly created watcher. 795The C<fork_ns> variant doesn't start (activate) the newly created watcher.
673 796
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 797=back
693 798
799
800=head1 PERL SIGNALS
801
802While Perl signal handling (C<%SIG>) is not affected by EV, the behaviour
803with EV is as the same as any other C library: Perl-signals will only be
804handled when Perl runs, which means your signal handler might be invoked
805only the next time an event callback is invoked.
806
807The solution is to use EV signal watchers (see C<EV::signal>), which will
808ensure proper operations with regards to other event watchers.
809
810If you cannot do this for whatever reason, you can also force a watcher
811to be called on every event loop iteration by installing a C<EV::check>
812watcher:
813
814 my $async_check = EV::check sub { };
815
816This ensures that perl shortly gets into control for a short time, and
817also ensures slower overall operation.
694 818
695=head1 THREADS 819=head1 THREADS
696 820
697Threads are not supported by this module in any way. Perl pseudo-threads 821Threads 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 822is evil stuff and must die. As soon as Perl gains real threads I will work
720our $DIED = sub { 844our $DIED = sub {
721 warn "EV: error in callback (ignoring): $@"; 845 warn "EV: error in callback (ignoring): $@";
722}; 846};
723 847
724default_loop 848default_loop
725 or die 'EV: cannot initialise libev backend. bad $ENV{LIBEV_METHODS}?'; 849 or die 'EV: cannot initialise libev backend. bad $ENV{LIBEV_FLAGS}?';
726 850
7271; 8511;
728 852
729=head1 SEE ALSO 853=head1 SEE ALSO
730 854
731L<EV::DNS>. 855L<EV::ADNS> (asynchronous dns), L<Glib::EV> (makes Glib/Gtk2 use EV as
856event loop), L<Coro::EV> (efficient coroutines with EV).
732 857
733=head1 AUTHOR 858=head1 AUTHOR
734 859
735 Marc Lehmann <schmorp@schmorp.de> 860 Marc Lehmann <schmorp@schmorp.de>
736 http://home.schmorp.de/ 861 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines