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

Comparing EV/EV.pm (file contents):
Revision 1.73 by root, Fri Dec 21 05:10:01 2007 UTC vs.
Revision 1.79 by root, Sat Dec 22 16:37:07 2007 UTC

102selecting a working backend (which for example rules out kqueue on most 102selecting a working backend (which for example rules out kqueue on most
103BSDs). Modules should, unless they have "special needs" always use the 103BSDs). Modules should, unless they have "special needs" always use the
104default loop as this is fastest (perl-wise), best supported by other 104default loop as this is fastest (perl-wise), best supported by other
105modules (e.g. AnyEvent or Coro) and most portable event loop. 105modules (e.g. AnyEvent or Coro) and most portable event loop.
106 106
107For specific programs you cna create additional event loops dynamically. 107For specific programs you can create additional event loops dynamically.
108 108
109=over 4 109=over 4
110 110
111=item $loop = new EV::loop [$flags] 111=item $loop = new EV::loop [$flags]
112 112
126Must be called after a fork in the child, before entering or continuing 126Must 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 127the event loop. An alternative is to use C<EV::FLAG_FORKCHECK> which calls
128this fucntion automatically, at some performance loss (refer to the libev 128this fucntion automatically, at some performance loss (refer to the libev
129documentation). 129documentation).
130 130
131=item $loop = EV::default_loop [$flags]
132
133Return the default loop (which is a singleton object).
134
131=back 135=back
132 136
133 137
134=head1 BASIC INTERFACE 138=head1 BASIC INTERFACE
135 139
140Must contain a reference to a function that is called when a callback 144Must contain a reference to a function that is called when a callback
141throws an exception (with $@ containing the error). The default prints an 145throws an exception (with $@ containing the error). The default prints an
142informative message and continues. 146informative message and continues.
143 147
144If this callback throws an exception it will be silently ignored. 148If this callback throws an exception it will be silently ignored.
149
150=item $flags = EV::supported_backends
151
152=item $flags = EV::recommended_backends
153
154=item $flags = EV::embeddable_backends
155
156Returns the set (see C<EV::BACKEND_*> flags) of backends supported by this
157instance of EV, the set of recommended backends (supposed to be good) for
158this platform and the set of embeddable backends (see EMBED WATCHERS).
145 159
146=item $time = EV::time 160=item $time = EV::time
147 161
148Returns the current time in (fractional) seconds since the epoch. 162Returns the current time in (fractional) seconds since the epoch.
149 163
208If timeout is C<undef> or negative, then there will be no 222If timeout is C<undef> or negative, then there will be no
209timeout. Otherwise a EV::timer with this value will be started. 223timeout. Otherwise a EV::timer with this value will be started.
210 224
211When an error occurs or either the timeout or I/O watcher triggers, then 225When 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 226the 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>, 227you can expect it to be a combination of C<EV::ERROR>, C<EV::READ>,
214C<EV::WRITE> and C<EV::TIMEOUT>). 228C<EV::WRITE> and C<EV::TIMEOUT>).
215 229
216EV::once doesn't return anything: the watchers stay active till either 230EV::once doesn't return anything: the watchers stay active till either
217of them triggers, then they will be stopped and freed, and the callback 231of them triggers, then they will be stopped and freed, and the callback
218invoked. 232invoked.
228=item EV::feed_signal_event ($signal) 242=item EV::feed_signal_event ($signal)
229 243
230Feed a signal event into EV. EV will react to this call as if the signal 244Feed a signal event into EV. EV will react to this call as if the signal
231specified by C<$signal> had occured. 245specified by C<$signal> had occured.
232 246
247=item EV::set_io_collect_interval $time
248
249=item $loop->set_io_collect_interval ($time)
250
251=item EV::set_timeout_collect_interval $time
252
253=item $loop->set_timeout_collect_interval ($time)
254
255These advanced functions set the minimum block interval when polling for I/O events and the minimum
256wait interval for timer events. See the libev documentation at
257L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#FUNCTIONS_CONTROLLING_THE_EVENT_LOOP> for
258a more detailed discussion.
259
233=back 260=back
234 261
235 262
236=head1 WATCHER OBJECTS 263=head1 WATCHER OBJECTS
237 264
239event. For instance, if you want to wait for STDIN to become readable, you 266event. For instance, if you want to wait for STDIN to become readable, you
240would create an EV::io watcher for that: 267would create an EV::io watcher for that:
241 268
242 my $watcher = EV::io *STDIN, EV::READ, sub { 269 my $watcher = EV::io *STDIN, EV::READ, sub {
243 my ($watcher, $revents) = @_; 270 my ($watcher, $revents) = @_;
244 warn "yeah, STDIN should not be readable without blocking!\n" 271 warn "yeah, STDIN should now be readable without blocking!\n"
245 }; 272 };
246 273
247All watchers can be active (waiting for events) or inactive (paused). Only 274All watchers can be active (waiting for events) or inactive (paused). Only
248active watchers will have their callbacks invoked. All callbacks will be 275active watchers will have their callbacks invoked. All callbacks will be
249called with at least two arguments: the watcher and a bitmask of received 276called 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 360Feed some events on this watcher into EV. EV will react to this call as if
334the watcher had received the given C<$revents> mask. 361the watcher had received the given C<$revents> mask.
335 362
336=item $revents = $w->clear_pending 363=item $revents = $w->clear_pending
337 364
338If the watcher is pending, this function returns clears its pending status 365If 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 366returns its C<$revents> bitset (as if its callback was invoked). If the
340watcher isn't pending it does nothing and returns C<0>. 367watcher isn't pending it does nothing and returns C<0>.
341 368
342=item $previous_state = $w->keepalive ($bool) 369=item $previous_state = $w->keepalive ($bool)
343 370
344Normally, C<EV::loop> will return when there are no active watchers 371Normally, 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 372(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), 373convinient 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 374call 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 :). 375finished (or they forgot to register some watchers for their task :).
349 376
350Sometimes, however, this gets in your way, for example when you the module 377Sometimes, 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 378that 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 379as a long-living watcher (for example a DNS client module written by
353somebody else even). Then you might want any outstanding requests to be 380somebody 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 381handled, but you would not want to keep C<EV::loop> from returning just
355because you happen to have this long-running UDP port watcher. 382because you happen to have this long-running UDP port watcher.
363Example: Register an I/O watcher for some UDP socket but do not keep the 390Example: Register an I/O watcher for some UDP socket but do not keep the
364event loop from running just because of that watcher. 391event loop from running just because of that watcher.
365 392
366 my $udp_socket = ... 393 my $udp_socket = ...
367 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 394 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
368 $udp_watcher->keepalive (0); 395 $1000udp_watcher->keepalive (0);
396
397=item $loop = $w->loop
398
399Return the loop that this watcher is attached to.
369 400
370=back 401=back
371 402
372 403
373=head1 WATCHER TYPES 404=head1 WATCHER TYPES
380 411
381=item $w = EV::io $fileno_or_fh, $eventmask, $callback 412=item $w = EV::io $fileno_or_fh, $eventmask, $callback
382 413
383=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback 414=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
384 415
385=item $w = $loop->io 8$fileno_or_fh, $eventmask, $callback) 416=item $w = $loop->io ($fileno_or_fh, $eventmask, $callback)
386 417
387=item $w = $loop->io_ns ($fileno_or_fh, $eventmask, $callback) 418=item $w = $loop->io_ns ($fileno_or_fh, $eventmask, $callback)
388 419
389As long as the returned watcher object is alive, call the C<$callback> 420As long as the returned watcher object is alive, call the C<$callback>
390when at least one of events specified in C<$eventmask> occurs. 421when at least one of events specified in C<$eventmask> occurs.
787 818
788=item $w = EV::prepare_ns $callback 819=item $w = EV::prepare_ns $callback
789 820
790=item $w = $loop->prepare ($callback) 821=item $w = $loop->prepare ($callback)
791 822
792=item $w = $loop->prepare_ns 8$callback) 823=item $w = $loop->prepare_ns ($callback)
793 824
794Call the callback just before the process would block. You can still 825Call the callback just before the process would block. You can still
795create/modify any watchers at this point. 826create/modify any watchers at this point.
796 827
797See the EV::check watcher, below, for explanations and an example. 828See the EV::check watcher, below, for explanations and an example.
886The C<fork_ns> variant doesn't start (activate) the newly created watcher. 917The C<fork_ns> variant doesn't start (activate) the newly created watcher.
887 918
888=back 919=back
889 920
890 921
922=head3 EMBED WATCHERS - when one backend isn't enough...
923
924This is a rather advanced watcher type that lets you embed one event loop
925into another (currently only IO events are supported in the embedded
926loop, other types of watchers might be handled in a delayed or incorrect
927fashion and must not be used).
928
929See the libev documentation at
930L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code_when_one_backend_>
931for more details.
932
933In short, this watcher is most useful on BSD systems without working
934kqueue to still be able to handle a large number of sockets:
935
936 my $socket_loop;
937
938 # check wether we use SELECT or POLL _and_ KQUEUE is supported
939 if (
940 (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
941 && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
942 ) {
943 # use kqueue for sockets
944 $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
945 }
946
947 # use the default loop otherwise
948 $socket_loop ||= EV::default_loop;
949
950=over 4
951
952=item $w = EV::embed $otherloop, $callback
953
954=item $w = EV::embed_ns $otherloop, $callback
955
956=item $w = $loop->embed ($otherloop, $callback)
957
958=item $w = $loop->embed_ns ($otherloop, $callback)
959
960Call the callback when the embedded event loop (C<$otherloop>) has any
961I/O activity. The C<$callback> should alwas be specified as C<undef> in
962this version of EV, which means the embedded event loop will be managed
963automatically.
964
965The C<embed_ns> variant doesn't start (activate) the newly created watcher.
966
967=back
968
969
891=head1 PERL SIGNALS 970=head1 PERL SIGNALS
892 971
893While Perl signal handling (C<%SIG>) is not affected by EV, the behaviour 972While Perl signal handling (C<%SIG>) is not affected by EV, the behaviour
894with EV is as the same as any other C library: Perl-signals will only be 973with EV is as the same as any other C library: Perl-signals will only be
895handled when Perl runs, which means your signal handler might be invoked 974handled when Perl runs, which means your signal handler might be invoked
902to be called on every event loop iteration by installing a C<EV::check> 981to be called on every event loop iteration by installing a C<EV::check>
903watcher: 982watcher:
904 983
905 my $async_check = EV::check sub { }; 984 my $async_check = EV::check sub { };
906 985
907This ensures that perl shortly gets into control for a short time, and 986This ensures that perl gets into control for a short time to handle any
908also ensures slower overall operation. 987pending signals, and also ensures (slightly) slower overall operation.
909 988
910=head1 THREADS 989=head1 THREADS
911 990
912Threads are not supported by this module in any way. Perl pseudo-threads 991Threads are not supported by this module in any way. Perl pseudo-threads
913is evil stuff and must die. As soon as Perl gains real threads I will work 992is evil stuff and must die. As soon as Perl gains real threads I will work

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines