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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines