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

Comparing EV/EV.pm (file contents):
Revision 1.78 by root, Sat Dec 22 11:50:04 2007 UTC vs.
Revision 1.96 by root, Thu May 22 02:44:57 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.41';
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
123 130
124=item $loop->loop_fork 131=item $loop->loop_fork
125 132
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 function automatically, at some performance loss (refer to the libev
129documentation). 136documentation).
137
138=item $loop->loop_verify
139
140Calls C<ev_verify> to make internal consistency checks (for debugging
141libev) and abort the program if any data structures wree found to be
142corrupted.
143
144=item $loop = EV::default_loop [$flags]
145
146Return the default loop (which is a singleton object). Since this module
147already creates the default loop with default flags, specifying flags here
148will not have any effect unless you destroy the default loop.
130 149
131=back 150=back
132 151
133 152
134=head1 BASIC INTERFACE 153=head1 BASIC INTERFACE
140Must contain a reference to a function that is called when a callback 159Must contain a reference to a function that is called when a callback
141throws an exception (with $@ containing the error). The default prints an 160throws an exception (with $@ containing the error). The default prints an
142informative message and continues. 161informative message and continues.
143 162
144If this callback throws an exception it will be silently ignored. 163If this callback throws an exception it will be silently ignored.
164
165=item $flags = EV::supported_backends
166
167=item $flags = EV::recommended_backends
168
169=item $flags = EV::embeddable_backends
170
171Returns the set (see C<EV::BACKEND_*> flags) of backends supported by this
172instance of EV, the set of recommended backends (supposed to be good) for
173this platform and the set of embeddable backends (see EMBED WATCHERS).
174
175=item EV::sleep $seconds
176
177Block the process for the given number of (fractional) seconds.
145 178
146=item $time = EV::time 179=item $time = EV::time
147 180
148Returns the current time in (fractional) seconds since the epoch. 181Returns the current time in (fractional) seconds since the epoch.
149 182
227 260
228=item EV::feed_signal_event ($signal) 261=item EV::feed_signal_event ($signal)
229 262
230Feed a signal event into EV. EV will react to this call as if the signal 263Feed a signal event into EV. EV will react to this call as if the signal
231specified by C<$signal> had occured. 264specified by C<$signal> had occured.
265
266=item EV::set_io_collect_interval $time
267
268=item $loop->set_io_collect_interval ($time)
269
270=item EV::set_timeout_collect_interval $time
271
272=item $loop->set_timeout_collect_interval ($time)
273
274These advanced functions set the minimum block interval when polling for I/O events and the minimum
275wait interval for timer events. See the libev documentation at
276L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#FUNCTIONS_CONTROLLING_THE_EVENT_LOOP> for
277a more detailed discussion.
232 278
233=back 279=back
234 280
235 281
236=head1 WATCHER OBJECTS 282=head1 WATCHER OBJECTS
502This time simply fires at the wallclock time C<$at> and doesn't repeat. It 548This 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 549will 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 550at January 1st 2011 then it will run when the system time reaches or
505surpasses this time. 551surpasses this time.
506 552
507=item * non-repeating interval timer ($interval > 0, $reschedule_cb = 0) 553=item * repeating interval timer ($interval > 0, $reschedule_cb = 0)
508 554
509In this mode the watcher will always be scheduled to time out at the 555In 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, 556next C<$at + N * $interval> time (for some integer N) and then repeat,
511regardless of any time jumps. 557regardless of any time jumps.
512 558
530time the periodic watcher gets scheduled, the reschedule callback 576time the periodic watcher gets scheduled, the reschedule callback
531($reschedule_cb) will be called with the watcher as first, and the current 577($reschedule_cb) will be called with the watcher as first, and the current
532time as second argument. 578time as second argument.
533 579
534I<This callback MUST NOT stop or destroy this or any other periodic 580I<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 581watcher, ever, and MUST NOT call any event loop functions or methods>. If
536afterwards. 582you need to stop it, return 1e30 and stop it afterwards. You may create
583and start a C<EV::prepare> watcher for this task.
537 584
538It must return the next time to trigger, based on the passed time value 585It 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 586(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 587argument). It will usually be called just before the callback will be
541might be called at other times, too. 588triggered, but might be called at other times, too.
542 589
543This can be used to create very complex timers, such as a timer that 590This 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 591triggers 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 592midnight, 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 593in about the same space (without requiring elaborate modules), drop me a
613 660
614=head3 CHILD WATCHERS - watch out for process status changes 661=head3 CHILD WATCHERS - watch out for process status changes
615 662
616=over 4 663=over 4
617 664
618=item $w = EV::child $pid, $callback 665=item $w = EV::child $pid, $trace, $callback
619 666
620=item $w = EV::child_ns $pid, $callback 667=item $w = EV::child_ns $pid, $trace, $callback
621 668
622=item $w = $loop->child ($pid, $callback) 669=item $w = $loop->child ($pid, $trace, $callback)
623 670
624=item $w = $loop->child_ns ($pid, $callback) 671=item $w = $loop->child_ns ($pid, $trace, $callback)
625 672
626Call the callback when a status change for pid C<$pid> (or any pid if 673Call 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 674if C<$pid> is 0) has been received (a status change happens when the
675process terminates or is killed, or, when trace is true, additionally when
676it is stopped or continued). More precisely: when the process receives
628a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all 677a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
629changed/zombie children and call the callback. 678changed/zombie children and call the callback.
630 679
631It is valid (and fully supported) to install a child watcher after a child 680It 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 681has 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 688You can have as many pid watchers per pid as you want, they will all be
640called. 689called.
641 690
642The C<child_ns> variant doesn't start (activate) the newly created watcher. 691The C<child_ns> variant doesn't start (activate) the newly created watcher.
643 692
644=item $w->set ($pid) 693=item $w->set ($pid, $trace)
645 694
646Reconfigures the watcher, see the constructor above for details. Can be called at 695Reconfigures the watcher, see the constructor above for details. Can be called at
647any time. 696any time.
648 697
649=item $current_pid = $w->pid 698=item $current_pid = $w->pid
650
651=item $old_pid = $w->pid ($new_pid)
652 699
653Returns the previously set process id and optionally set a new one. 700Returns the previously set process id and optionally set a new one.
654 701
655=item $exit_status = $w->rstatus 702=item $exit_status = $w->rstatus
656 703
886 933
887Call the callback before the event loop is resumed in the child process 934Call the callback before the event loop is resumed in the child process
888after a fork. 935after a fork.
889 936
890The C<fork_ns> variant doesn't start (activate) the newly created watcher. 937The C<fork_ns> variant doesn't start (activate) the newly created watcher.
938
939=back
940
941
942=head3 EMBED WATCHERS - when one backend isn't enough...
943
944This is a rather advanced watcher type that lets you embed one event loop
945into another (currently only IO events are supported in the embedded
946loop, other types of watchers might be handled in a delayed or incorrect
947fashion and must not be used).
948
949See the libev documentation at
950L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code_when_one_backend_>
951for more details.
952
953In short, this watcher is most useful on BSD systems without working
954kqueue to still be able to handle a large number of sockets:
955
956 my $socket_loop;
957
958 # check wether we use SELECT or POLL _and_ KQUEUE is supported
959 if (
960 (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
961 && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
962 ) {
963 # use kqueue for sockets
964 $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
965 }
966
967 # use the default loop otherwise
968 $socket_loop ||= EV::default_loop;
969
970=over 4
971
972=item $w = EV::embed $otherloop, $callback
973
974=item $w = EV::embed_ns $otherloop, $callback
975
976=item $w = $loop->embed ($otherloop, $callback)
977
978=item $w = $loop->embed_ns ($otherloop, $callback)
979
980Call the callback when the embedded event loop (C<$otherloop>) has any
981I/O activity. The C<$callback> should alwas be specified as C<undef> in
982this version of EV, which means the embedded event loop will be managed
983automatically.
984
985The C<embed_ns> variant doesn't start (activate) the newly created watcher.
986
987=back
988
989=head3 ASYNC WATCHERS - how to wake up another event loop
990
991Async watchers are provided by EV, but have little use in perl directly, as perl
992neither supports threads nor direct access to signal handlers or other
993contexts where they could be of value.
994
995It is, however, possible to use them from the XS level.
996
997Please see the libev documentation for further details.
998
999=over 4
1000
1001=item $w = EV::async $callback
1002
1003=item $w = EV::async_ns $callback
1004
1005=item $w->send
1006
1007=item $bool = $w->async_pending
891 1008
892=back 1009=back
893 1010
894 1011
895=head1 PERL SIGNALS 1012=head1 PERL SIGNALS
947 1064
948=head1 SEE ALSO 1065=head1 SEE ALSO
949 1066
950L<EV::ADNS> (asynchronous DNS), L<Glib::EV> (makes Glib/Gtk2 use EV as 1067L<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 1068event loop), L<EV::Glib> (embed Glib into EV), L<Coro::EV> (efficient
952coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP). 1069coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP), L<AnyEvent> for
1070event-loop agnostic and portable event driven programming.
953 1071
954=head1 AUTHOR 1072=head1 AUTHOR
955 1073
956 Marc Lehmann <schmorp@schmorp.de> 1074 Marc Lehmann <schmorp@schmorp.de>
957 http://home.schmorp.de/ 1075 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines