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

Comparing EV/EV.pm (file contents):
Revision 1.77 by root, Sat Dec 22 11:44:50 2007 UTC vs.
Revision 1.94 by root, Tue May 20 23:54:05 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.4';
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
227 252
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.
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.
232 270
233=back 271=back
234 272
235 273
236=head1 WATCHER OBJECTS 274=head1 WATCHER OBJECTS
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
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
530time the periodic watcher gets scheduled, the reschedule callback 568time the periodic watcher gets scheduled, the reschedule callback
531($reschedule_cb) will be called with the watcher as first, and the current 569($reschedule_cb) will be called with the watcher as first, and the current
532time as second argument. 570time as second argument.
533 571
534I<This callback MUST NOT stop or destroy this or any other periodic 572I<This callback MUST NOT stop or destroy this or any other periodic
535watcher, ever>. If you need to stop it, return 1e30 and stop it 573watcher, ever, and MUST NOT call any event loop functions or methods>. If
536afterwards. 574you need to stop it, return 1e30 and stop it afterwards. You may create
575and start a C<EV::prepare> watcher for this task.
537 576
538It must return the next time to trigger, based on the passed time value 577It must return the next time to trigger, based on the passed time value
539(that is, the lowest time value larger than to the second argument). It 578(that is, the lowest time value larger than or equal to to the second
540will usually be called just before the callback will be triggered, but 579argument). It will usually be called just before the callback will be
541might be called at other times, too. 580triggered, but might be called at other times, too.
542 581
543This can be used to create very complex timers, such as a timer that 582This can be used to create very complex timers, such as a timer that
544triggers on each midnight, local time (actually 24 hours after the last 583triggers on each midnight, local time (actually 24 hours after the last
545midnight, to keep the example simple. If you know a way to do it correctly 584midnight, to keep the example simple. If you know a way to do it correctly
546in about the same space (without requiring elaborate modules), drop me a 585in about the same space (without requiring elaborate modules), drop me a
613 652
614=head3 CHILD WATCHERS - watch out for process status changes 653=head3 CHILD WATCHERS - watch out for process status changes
615 654
616=over 4 655=over 4
617 656
618=item $w = EV::child $pid, $callback 657=item $w = EV::child $pid, $trace, $callback
619 658
620=item $w = EV::child_ns $pid, $callback 659=item $w = EV::child_ns $pid, $trace, $callback
621 660
622=item $w = $loop->child ($pid, $callback) 661=item $w = $loop->child ($pid, $trace, $callback)
623 662
624=item $w = $loop->child_ns ($pid, $callback) 663=item $w = $loop->child_ns ($pid, $trace, $callback)
625 664
626Call the callback when a status change for pid C<$pid> (or any pid if 665Call 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 666if C<$pid> is 0) has been received (a status change happens when the
667process terminates or is killed, or, when trace is true, additionally when
668it is stopped or continued). More precisely: when the process receives
628a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all 669a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
629changed/zombie children and call the callback. 670changed/zombie children and call the callback.
630 671
631It is valid (and fully supported) to install a child watcher after a child 672It 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 673has 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 680You can have as many pid watchers per pid as you want, they will all be
640called. 681called.
641 682
642The C<child_ns> variant doesn't start (activate) the newly created watcher. 683The C<child_ns> variant doesn't start (activate) the newly created watcher.
643 684
644=item $w->set ($pid) 685=item $w->set ($pid, $trace)
645 686
646Reconfigures the watcher, see the constructor above for details. Can be called at 687Reconfigures the watcher, see the constructor above for details. Can be called at
647any time. 688any time.
648 689
649=item $current_pid = $w->pid 690=item $current_pid = $w->pid
650
651=item $old_pid = $w->pid ($new_pid)
652 691
653Returns the previously set process id and optionally set a new one. 692Returns the previously set process id and optionally set a new one.
654 693
655=item $exit_status = $w->rstatus 694=item $exit_status = $w->rstatus
656 695
886 925
887Call the callback before the event loop is resumed in the child process 926Call the callback before the event loop is resumed in the child process
888after a fork. 927after a fork.
889 928
890The C<fork_ns> variant doesn't start (activate) the newly created watcher. 929The C<fork_ns> variant doesn't start (activate) the newly created watcher.
930
931=back
932
933
934=head3 EMBED WATCHERS - when one backend isn't enough...
935
936This is a rather advanced watcher type that lets you embed one event loop
937into another (currently only IO events are supported in the embedded
938loop, other types of watchers might be handled in a delayed or incorrect
939fashion and must not be used).
940
941See the libev documentation at
942L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code_when_one_backend_>
943for more details.
944
945In short, this watcher is most useful on BSD systems without working
946kqueue to still be able to handle a large number of sockets:
947
948 my $socket_loop;
949
950 # check wether we use SELECT or POLL _and_ KQUEUE is supported
951 if (
952 (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
953 && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
954 ) {
955 # use kqueue for sockets
956 $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
957 }
958
959 # use the default loop otherwise
960 $socket_loop ||= EV::default_loop;
961
962=over 4
963
964=item $w = EV::embed $otherloop, $callback
965
966=item $w = EV::embed_ns $otherloop, $callback
967
968=item $w = $loop->embed ($otherloop, $callback)
969
970=item $w = $loop->embed_ns ($otherloop, $callback)
971
972Call the callback when the embedded event loop (C<$otherloop>) has any
973I/O activity. The C<$callback> should alwas be specified as C<undef> in
974this version of EV, which means the embedded event loop will be managed
975automatically.
976
977The C<embed_ns> variant doesn't start (activate) the newly created watcher.
978
979=back
980
981=head3 ASYNC WATCHERS - how to wake up another event loop
982
983Async watchers are provided by EV, but have little use in perl directly, as perl
984neither supports threads nor direct access to signal handlers or other
985contexts where they could be of value.
986
987It is, however, possible to use them from the XS level.
988
989Please see the libev documentation for further details.
990
991=over 4
992
993=item $w = EV::async $callback
994
995=item $w = EV::async_ns $callback
996
997=item $w->send
998
999=item $bool = $w->async_pending
891 1000
892=back 1001=back
893 1002
894 1003
895=head1 PERL SIGNALS 1004=head1 PERL SIGNALS
947 1056
948=head1 SEE ALSO 1057=head1 SEE ALSO
949 1058
950L<EV::ADNS> (asynchronous DNS), L<Glib::EV> (makes Glib/Gtk2 use EV as 1059L<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 1060event loop), L<EV::Glib> (embed Glib into EV), L<Coro::EV> (efficient
952coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP). 1061coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP), L<AnyEvent> for
1062event-loop agnostic and portable event driven programming.
953 1063
954=head1 AUTHOR 1064=head1 AUTHOR
955 1065
956 Marc Lehmann <schmorp@schmorp.de> 1066 Marc Lehmann <schmorp@schmorp.de>
957 http://home.schmorp.de/ 1067 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines