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

Comparing EV/EV.pm (file contents):
Revision 1.76 by root, Fri Dec 21 13:30:55 2007 UTC vs.
Revision 1.92 by root, Sun May 18 10:45:36 2008 UTC

35 warn "sigquit received\n"; 35 warn "sigquit received\n";
36 }; 36 };
37 37
38 # CHILD/PID STATUS CHANGES 38 # CHILD/PID STATUS CHANGES
39 39
40 my $w = EV::child 666, sub { 40 my $w = EV::child 666, 0, sub {
41 my ($w, $revents) = @_; 41 my ($w, $revents) = @_;
42 my $status = $w->rstatus; 42 my $status = $w->rstatus;
43 }; 43 };
44 44
45 # STAT CHANGES 45 # STAT CHANGES
56=head1 DESCRIPTION 56=head1 DESCRIPTION
57 57
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://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>) for more
62watcher semantics or some discussion on the available backends, or how to 62subtle details on watcher semantics or some discussion on the available
63force a specific backend with C<LIBEV_FLAGS>, or just about in any case 63backends, or how to force a specific backend with C<LIBEV_FLAGS>, or just
64because it has much more detailed information. 64about in any case because it has much more detailed information.
65
66This module is very fast and scalable. It is actually so fast that you
67can use it through the L<AnyEvent> module, stay portable to other event
68loops (if you don't rely on any watcher types not available through it)
69and still be faster than with any other event loop currently supported in
70Perl.
65 71
66=cut 72=cut
67 73
68package EV; 74package EV;
69 75
70use strict; 76use strict;
71 77
72BEGIN { 78BEGIN {
73 our $VERSION = '2.0'; 79 our $VERSION = '3.33';
74 use XSLoader; 80 use XSLoader;
75 XSLoader::load "EV", $VERSION; 81 XSLoader::load "EV", $VERSION;
76} 82}
77 83
78@EV::IO::ISA = 84@EV::IO::ISA =
84@EV::Idle::ISA = 90@EV::Idle::ISA =
85@EV::Prepare::ISA = 91@EV::Prepare::ISA =
86@EV::Check::ISA = 92@EV::Check::ISA =
87@EV::Embed::ISA = 93@EV::Embed::ISA =
88@EV::Fork::ISA = 94@EV::Fork::ISA =
95@EV::Async::ISA =
89 "EV::Watcher"; 96 "EV::Watcher";
90 97
91@EV::Loop::Default::ISA = "EV::Loop"; 98@EV::Loop::Default::ISA = "EV::Loop";
92 99
93=head1 EVENT LOOPS 100=head1 EVENT LOOPS
102selecting a working backend (which for example rules out kqueue on most 109selecting a working backend (which for example rules out kqueue on most
103BSDs). Modules should, unless they have "special needs" always use the 110BSDs). Modules should, unless they have "special needs" always use the
104default loop as this is fastest (perl-wise), best supported by other 111default loop as this is fastest (perl-wise), best supported by other
105modules (e.g. AnyEvent or Coro) and most portable event loop. 112modules (e.g. AnyEvent or Coro) and most portable event loop.
106 113
107For specific programs you cna create additional event loops dynamically. 114For specific programs you can create additional event loops dynamically.
108 115
109=over 4 116=over 4
110 117
111=item $loop = new EV::loop [$flags] 118=item $loop = new EV::loop [$flags]
112 119
126Must be called after a fork in the child, before entering or continuing 133Must be called after a fork in the child, before entering or continuing
127the event loop. An alternative is to use C<EV::FLAG_FORKCHECK> which calls 134the event loop. An alternative is to use C<EV::FLAG_FORKCHECK> which calls
128this fucntion automatically, at some performance loss (refer to the libev 135this fucntion automatically, at some performance loss (refer to the libev
129documentation). 136documentation).
130 137
138=item $loop = EV::default_loop [$flags]
139
140Return the default loop (which is a singleton object).
141
131=back 142=back
132 143
133 144
134=head1 BASIC INTERFACE 145=head1 BASIC INTERFACE
135 146
140Must contain a reference to a function that is called when a callback 151Must contain a reference to a function that is called when a callback
141throws an exception (with $@ containing the error). The default prints an 152throws an exception (with $@ containing the error). The default prints an
142informative message and continues. 153informative message and continues.
143 154
144If this callback throws an exception it will be silently ignored. 155If this callback throws an exception it will be silently ignored.
156
157=item $flags = EV::supported_backends
158
159=item $flags = EV::recommended_backends
160
161=item $flags = EV::embeddable_backends
162
163Returns the set (see C<EV::BACKEND_*> flags) of backends supported by this
164instance of EV, the set of recommended backends (supposed to be good) for
165this platform and the set of embeddable backends (see EMBED WATCHERS).
166
167=item EV::sleep $seconds
168
169Block the process for the given number of (fractional) seconds.
145 170
146=item $time = EV::time 171=item $time = EV::time
147 172
148Returns the current time in (fractional) seconds since the epoch. 173Returns the current time in (fractional) seconds since the epoch.
149 174
208If timeout is C<undef> or negative, then there will be no 233If timeout is C<undef> or negative, then there will be no
209timeout. Otherwise a EV::timer with this value will be started. 234timeout. Otherwise a EV::timer with this value will be started.
210 235
211When an error occurs or either the timeout or I/O watcher triggers, then 236When an error occurs or either the timeout or I/O watcher triggers, then
212the callback will be called with the received event set (in general 237the callback will be called with the received event set (in general
213you can expect it to be a combination of C<EV:ERROR>, C<EV::READ>, 238you can expect it to be a combination of C<EV::ERROR>, C<EV::READ>,
214C<EV::WRITE> and C<EV::TIMEOUT>). 239C<EV::WRITE> and C<EV::TIMEOUT>).
215 240
216EV::once doesn't return anything: the watchers stay active till either 241EV::once doesn't return anything: the watchers stay active till either
217of them triggers, then they will be stopped and freed, and the callback 242of them triggers, then they will be stopped and freed, and the callback
218invoked. 243invoked.
228=item EV::feed_signal_event ($signal) 253=item EV::feed_signal_event ($signal)
229 254
230Feed a signal event into EV. EV will react to this call as if the signal 255Feed a signal event into EV. EV will react to this call as if the signal
231specified by C<$signal> had occured. 256specified by C<$signal> had occured.
232 257
258=item EV::set_io_collect_interval $time
259
260=item $loop->set_io_collect_interval ($time)
261
262=item EV::set_timeout_collect_interval $time
263
264=item $loop->set_timeout_collect_interval ($time)
265
266These advanced functions set the minimum block interval when polling for I/O events and the minimum
267wait interval for timer events. See the libev documentation at
268L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#FUNCTIONS_CONTROLLING_THE_EVENT_LOOP> for
269a more detailed discussion.
270
233=back 271=back
234 272
235 273
236=head1 WATCHER OBJECTS 274=head1 WATCHER OBJECTS
237 275
239event. For instance, if you want to wait for STDIN to become readable, you 277event. For instance, if you want to wait for STDIN to become readable, you
240would create an EV::io watcher for that: 278would create an EV::io watcher for that:
241 279
242 my $watcher = EV::io *STDIN, EV::READ, sub { 280 my $watcher = EV::io *STDIN, EV::READ, sub {
243 my ($watcher, $revents) = @_; 281 my ($watcher, $revents) = @_;
244 warn "yeah, STDIN should not be readable without blocking!\n" 282 warn "yeah, STDIN should now be readable without blocking!\n"
245 }; 283 };
246 284
247All watchers can be active (waiting for events) or inactive (paused). Only 285All watchers can be active (waiting for events) or inactive (paused). Only
248active watchers will have their callbacks invoked. All callbacks will be 286active watchers will have their callbacks invoked. All callbacks will be
249called with at least two arguments: the watcher and a bitmask of received 287called with at least two arguments: the watcher and a bitmask of received
333Feed some events on this watcher into EV. EV will react to this call as if 371Feed some events on this watcher into EV. EV will react to this call as if
334the watcher had received the given C<$revents> mask. 372the watcher had received the given C<$revents> mask.
335 373
336=item $revents = $w->clear_pending 374=item $revents = $w->clear_pending
337 375
338If the watcher is pending, this function returns clears its pending status 376If the watcher is pending, this function clears its pending status and
339and returns its C<$revents> bitset (as if its callback was invoked). If the 377returns its C<$revents> bitset (as if its callback was invoked). If the
340watcher isn't pending it does nothing and returns C<0>. 378watcher isn't pending it does nothing and returns C<0>.
341 379
342=item $previous_state = $w->keepalive ($bool) 380=item $previous_state = $w->keepalive ($bool)
343 381
344Normally, C<EV::loop> will return when there are no active watchers 382Normally, C<EV::loop> will return when there are no active watchers
345(which is a "deadlock" because no progress can be made anymore). This is 383(which is a "deadlock" because no progress can be made anymore). This is
346convinient because it allows you to start your watchers (and your jobs), 384convinient because it allows you to start your watchers (and your jobs),
347call C<EV::loop> once and when it returns you know that all your jobs are 385call C<EV::loop> once and when it returns you know that all your jobs are
348finished (or they forgot to register some watchers for their task :). 386finished (or they forgot to register some watchers for their task :).
349 387
350Sometimes, however, this gets in your way, for example when you the module 388Sometimes, however, this gets in your way, for example when the module
351that calls C<EV::loop> (usually the main program) is not the same module 389that calls C<EV::loop> (usually the main program) is not the same module
352as a long-living watcher (for example a DNS client module written by 390as a long-living watcher (for example a DNS client module written by
353somebody else even). Then you might want any outstanding requests to be 391somebody else even). Then you might want any outstanding requests to be
354handled, but you would not want to keep C<EV::loop> from returning just 392handled, but you would not want to keep C<EV::loop> from returning just
355because you happen to have this long-running UDP port watcher. 393because you happen to have this long-running UDP port watcher.
502This time simply fires at the wallclock time C<$at> and doesn't repeat. It 540This time simply fires at the wallclock time C<$at> and doesn't repeat. It
503will not adjust when a time jump occurs, that is, if it is to be run 541will not adjust when a time jump occurs, that is, if it is to be run
504at January 1st 2011 then it will run when the system time reaches or 542at January 1st 2011 then it will run when the system time reaches or
505surpasses this time. 543surpasses this time.
506 544
507=item * non-repeating interval timer ($interval > 0, $reschedule_cb = 0) 545=item * repeating interval timer ($interval > 0, $reschedule_cb = 0)
508 546
509In this mode the watcher will always be scheduled to time out at the 547In this mode the watcher will always be scheduled to time out at the
510next C<$at + N * $interval> time (for some integer N) and then repeat, 548next C<$at + N * $interval> time (for some integer N) and then repeat,
511regardless of any time jumps. 549regardless of any time jumps.
512 550
613 651
614=head3 CHILD WATCHERS - watch out for process status changes 652=head3 CHILD WATCHERS - watch out for process status changes
615 653
616=over 4 654=over 4
617 655
618=item $w = EV::child $pid, $callback 656=item $w = EV::child $pid, $trace, $callback
619 657
620=item $w = EV::child_ns $pid, $callback 658=item $w = EV::child_ns $pid, $trace, $callback
621 659
622=item $w = $loop->child ($pid, $callback) 660=item $w = $loop->child ($pid, $trace, $callback)
623 661
624=item $w = $loop->child_ns ($pid, $callback) 662=item $w = $loop->child_ns ($pid, $trace, $callback)
625 663
626Call the callback when a status change for pid C<$pid> (or any pid if 664Call the callback when a status change for pid C<$pid> (or any pid
627C<$pid> is 0) has been received. More precisely: when the process receives 665if C<$pid> is 0) has been received (a status change happens when the
666process terminates or is killed, or, when trace is true, additionally when
667it is stopped or continued). More precisely: when the process receives
628a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all 668a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
629changed/zombie children and call the callback. 669changed/zombie children and call the callback.
630 670
631It is valid (and fully supported) to install a child watcher after a child 671It is valid (and fully supported) to install a child watcher after a child
632has exited but before the event loop has started its next iteration (for 672has exited but before the event loop has started its next iteration (for
639You can have as many pid watchers per pid as you want, they will all be 679You can have as many pid watchers per pid as you want, they will all be
640called. 680called.
641 681
642The C<child_ns> variant doesn't start (activate) the newly created watcher. 682The C<child_ns> variant doesn't start (activate) the newly created watcher.
643 683
644=item $w->set ($pid) 684=item $w->set ($pid, $trace)
645 685
646Reconfigures the watcher, see the constructor above for details. Can be called at 686Reconfigures the watcher, see the constructor above for details. Can be called at
647any time. 687any time.
648 688
649=item $current_pid = $w->pid 689=item $current_pid = $w->pid
650
651=item $old_pid = $w->pid ($new_pid)
652 690
653Returns the previously set process id and optionally set a new one. 691Returns the previously set process id and optionally set a new one.
654 692
655=item $exit_status = $w->rstatus 693=item $exit_status = $w->rstatus
656 694
886 924
887Call the callback before the event loop is resumed in the child process 925Call the callback before the event loop is resumed in the child process
888after a fork. 926after a fork.
889 927
890The C<fork_ns> variant doesn't start (activate) the newly created watcher. 928The C<fork_ns> variant doesn't start (activate) the newly created watcher.
929
930=back
931
932
933=head3 EMBED WATCHERS - when one backend isn't enough...
934
935This is a rather advanced watcher type that lets you embed one event loop
936into another (currently only IO events are supported in the embedded
937loop, other types of watchers might be handled in a delayed or incorrect
938fashion and must not be used).
939
940See the libev documentation at
941L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code_when_one_backend_>
942for more details.
943
944In short, this watcher is most useful on BSD systems without working
945kqueue to still be able to handle a large number of sockets:
946
947 my $socket_loop;
948
949 # check wether we use SELECT or POLL _and_ KQUEUE is supported
950 if (
951 (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
952 && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
953 ) {
954 # use kqueue for sockets
955 $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
956 }
957
958 # use the default loop otherwise
959 $socket_loop ||= EV::default_loop;
960
961=over 4
962
963=item $w = EV::embed $otherloop, $callback
964
965=item $w = EV::embed_ns $otherloop, $callback
966
967=item $w = $loop->embed ($otherloop, $callback)
968
969=item $w = $loop->embed_ns ($otherloop, $callback)
970
971Call the callback when the embedded event loop (C<$otherloop>) has any
972I/O activity. The C<$callback> should alwas be specified as C<undef> in
973this version of EV, which means the embedded event loop will be managed
974automatically.
975
976The C<embed_ns> variant doesn't start (activate) the newly created watcher.
977
978=back
979
980=head3 ASYNC WATCHERS - how to wake up another event loop
981
982Async watchers are provided by EV, but have little use in perl directly, as perl
983neither supports threads nor direct access to signal handlers or other
984contexts where they could be of value.
985
986It is, however, possible to use them from the XS level.
987
988Please see the libev documentation for further details.
989
990=over 4
991
992=item $w = EV::async $callback
993
994=item $w = EV::async_ns $callback
995
996=item $w->send
997
998=item $bool = $w->async_pending
891 999
892=back 1000=back
893 1001
894 1002
895=head1 PERL SIGNALS 1003=head1 PERL SIGNALS
947 1055
948=head1 SEE ALSO 1056=head1 SEE ALSO
949 1057
950L<EV::ADNS> (asynchronous DNS), L<Glib::EV> (makes Glib/Gtk2 use EV as 1058L<EV::ADNS> (asynchronous DNS), L<Glib::EV> (makes Glib/Gtk2 use EV as
951event loop), L<EV::Glib> (embed Glib into EV), L<Coro::EV> (efficient 1059event loop), L<EV::Glib> (embed Glib into EV), L<Coro::EV> (efficient
952coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP). 1060coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP), L<AnyEvent> for
1061event-loop agnostic and portable event driven programming.
953 1062
954=head1 AUTHOR 1063=head1 AUTHOR
955 1064
956 Marc Lehmann <schmorp@schmorp.de> 1065 Marc Lehmann <schmorp@schmorp.de>
957 http://home.schmorp.de/ 1066 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines