ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/README
Revision: 1.32
Committed: Tue Apr 28 00:50:57 2009 UTC (15 years, 1 month ago) by root
Branch: MAIN
CVS Tags: rel-3_6
Changes since 1.31: +38 -1 lines
Log Message:
3.6

File Contents

# User Rev Content
1 root 1.1 NAME
2 root 1.6 EV - perl interface to libev, a high performance full-featured event
3     loop
4 root 1.1
5 root 1.2 SYNOPSIS
6 root 1.28 use EV;
7    
8     # TIMERS
9    
10     my $w = EV::timer 2, 0, sub {
11     warn "is called after 2s";
12     };
13    
14     my $w = EV::timer 2, 2, sub {
15     warn "is called roughly every 2s (repeat = 2)";
16     };
17    
18     undef $w; # destroy event watcher again
19    
20     my $w = EV::periodic 0, 60, 0, sub {
21     warn "is called every minute, on the minute, exactly";
22     };
23    
24     # IO
25    
26     my $w = EV::io *STDIN, EV::READ, sub {
27     my ($w, $revents) = @_; # all callbacks receive the watcher and event mask
28     warn "stdin is readable, you entered: ", <STDIN>;
29     };
30    
31     # SIGNALS
32    
33     my $w = EV::signal 'QUIT', sub {
34     warn "sigquit received\n";
35     };
36    
37     # CHILD/PID STATUS CHANGES
38    
39     my $w = EV::child 666, 0, sub {
40     my ($w, $revents) = @_;
41     my $status = $w->rstatus;
42     };
43    
44     # STAT CHANGES
45     my $w = EV::stat "/etc/passwd", 10, sub {
46     my ($w, $revents) = @_;
47     warn $w->path, " has changed somehow.\n";
48     };
49    
50     # MAINLOOP
51     EV::loop; # loop until EV::unloop is called or all watchers stop
52     EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled
53     EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not block
54 root 1.2
55     DESCRIPTION
56 root 1.5 This module provides an interface to libev
57 root 1.12 (<http://software.schmorp.de/pkg/libev.html>). While the documentation
58     below is comprehensive, one might also consult the documentation of
59 root 1.30 libev itself (<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod> or
60     perldoc EV::libev) for more subtle details on watcher semantics or some
61     discussion on the available backends, or how to force a specific backend
62     with "LIBEV_FLAGS", or just about in any case because it has much more
63 root 1.25 detailed information.
64    
65     This module is very fast and scalable. It is actually so fast that you
66     can use it through the AnyEvent module, stay portable to other event
67     loops (if you don't rely on any watcher types not available through it)
68     and still be faster than with any other event loop currently supported
69     in Perl.
70 root 1.2
71 root 1.30 MODULE EXPORTS
72     This module does not export any symbols.
73    
74 root 1.20 EVENT LOOPS
75     EV supports multiple event loops: There is a single "default event loop"
76     that can handle everything including signals and child watchers, and any
77     number of "dynamic event loops" that can use different backends (with
78     various limitations), but no child and signal watchers.
79    
80     You do not have to do anything to create the default event loop: When
81     the module is loaded a suitable backend is selected on the premise of
82     selecting a working backend (which for example rules out kqueue on most
83     BSDs). Modules should, unless they have "special needs" always use the
84     default loop as this is fastest (perl-wise), best supported by other
85     modules (e.g. AnyEvent or Coro) and most portable event loop.
86    
87 root 1.21 For specific programs you can create additional event loops dynamically.
88 root 1.20
89 root 1.31 If you want to take advantage of kqueue (which often works properly for
90 root 1.28 sockets only) even though the default loop doesn't enable it, you can
91     *embed* a kqueue loop into the default loop: running the default loop
92     will then also service the kqueue loop to some extent. See the example
93     in the section about embed watchers for an example on how to achieve
94     that.
95    
96 root 1.32 $loop = new EV::Loop [$flags]
97 root 1.20 Create a new event loop as per the specified flags. Please refer to
98     the "ev_loop_new ()" function description in the libev documentation
99     (<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#GLOBAL_FUNCTI
100 root 1.30 ONS>, or locally-installed as EV::libev manpage) for more info.
101 root 1.20
102     The loop will automatically be destroyed when it is no longer
103     referenced by any watcher and the loop object goes out of scope.
104    
105 root 1.30 If you are not embedding the loop, then Using "EV::FLAG_FORKCHECK"
106     is recommended, as only the default event loop is protected by this
107     module. If you *are* embedding this loop in the default loop, this
108     is not necessary, as "EV::embed" automatically does the right thing
109     on fork.
110 root 1.20
111     $loop->loop_fork
112     Must be called after a fork in the child, before entering or
113     continuing the event loop. An alternative is to use
114 root 1.27 "EV::FLAG_FORKCHECK" which calls this function automatically, at
115 root 1.20 some performance loss (refer to the libev documentation).
116    
117 root 1.27 $loop->loop_verify
118     Calls "ev_verify" to make internal consistency checks (for debugging
119 root 1.28 libev) and abort the program if any data structures were found to be
120 root 1.27 corrupted.
121    
122 root 1.21 $loop = EV::default_loop [$flags]
123 root 1.27 Return the default loop (which is a singleton object). Since this
124     module already creates the default loop with default flags,
125     specifying flags here will not have any effect unless you destroy
126 root 1.28 the default loop first, which isn't supported. So in short: don't do
127     it, and if you break it, you get to keep the pieces.
128 root 1.21
129 root 1.3 BASIC INTERFACE
130     $EV::DIED
131     Must contain a reference to a function that is called when a
132 root 1.18 callback throws an exception (with $@ containing the error). The
133 root 1.3 default prints an informative message and continues.
134    
135     If this callback throws an exception it will be silently ignored.
136    
137 root 1.21 $flags = EV::supported_backends
138     $flags = EV::recommended_backends
139     $flags = EV::embeddable_backends
140     Returns the set (see "EV::BACKEND_*" flags) of backends supported by
141     this instance of EV, the set of recommended backends (supposed to be
142     good) for this platform and the set of embeddable backends (see
143     EMBED WATCHERS).
144    
145     EV::sleep $seconds
146     Block the process for the given number of (fractional) seconds.
147    
148 root 1.6 $time = EV::time
149     Returns the current time in (fractional) seconds since the epoch.
150    
151 root 1.2 $time = EV::now
152 root 1.20 $time = $loop->now
153 root 1.6 Returns the time the last event loop iteration has been started.
154 root 1.31 This is the time that (relative) timers are based on, and referring
155 root 1.6 to it is usually faster then calling EV::time.
156    
157 root 1.32 EV::now_update
158     $loop->now_update
159     Establishes the current time by querying the kernel, updating the
160     time returned by "EV::now" in the progress. This is a costly
161     operation and is usually done automatically within "EV::loop".
162    
163     This function is rarely useful, but when some event callback runs
164     for a very long time without entering the event loop, updating
165     libev's idea of the current time is a good idea.
166    
167     EV::suspend
168     $loop->suspend
169     EV::resume
170     $loop->resume
171     These two functions suspend and resume a loop, for use when the loop
172     is not used for a while and timeouts should not be processed.
173    
174     A typical use case would be an interactive program such as a game:
175     When the user presses "^Z" to suspend the game and resumes it an
176     hour later it would be best to handle timeouts as if no time had
177     actually passed while the program was suspended. This can be
178     achieved by calling "suspend" in your "SIGTSTP" handler, sending
179     yourself a "SIGSTOP" and calling "resume" directly afterwards to
180     resume timer processing.
181    
182     Effectively, all "timer" watchers will be delayed by the time spend
183     between "suspend" and "resume", and all "periodic" watchers will be
184     rescheduled (that is, they will lose any events that would have
185     occured while suspended).
186    
187     After calling "suspend" you must not call *any* function on the
188     given loop other than "resume", and you must not call "resume"
189     without a previous call to "suspend".
190    
191     Calling "suspend"/"resume" has the side effect of updating the event
192     loop time (see "now_update").
193    
194 root 1.20 $backend = EV::backend
195     $backend = $loop->backend
196 root 1.6 Returns an integer describing the backend used by libev
197 root 1.31 (EV::BACKEND_SELECT or EV::BACKEND_EPOLL).
198 root 1.6
199     EV::loop [$flags]
200 root 1.20 $loop->loop ([$flags])
201 root 1.6 Begin checking for events and calling callbacks. It returns when a
202 root 1.10 callback calls EV::unloop.
203 root 1.6
204     The $flags argument can be one of the following:
205    
206     0 as above
207     EV::LOOP_ONESHOT block at most once (wait, but do not loop)
208     EV::LOOP_NONBLOCK do not block at all (fetch/handle events but do not wait)
209    
210 root 1.10 EV::unloop [$how]
211 root 1.20 $loop->unloop ([$how])
212 root 1.10 When called with no arguments or an argument of EV::UNLOOP_ONE,
213     makes the innermost call to EV::loop return.
214 root 1.6
215 root 1.10 When called with an argument of EV::UNLOOP_ALL, all calls to
216     EV::loop will return as fast as possible.
217 root 1.6
218 root 1.15 $count = EV::loop_count
219 root 1.20 $count = $loop->loop_count
220 root 1.15 Return the number of times the event loop has polled for new events.
221 root 1.31 Sometimes useful as a generation counter.
222 root 1.15
223 root 1.12 EV::once $fh_or_undef, $events, $timeout, $cb->($revents)
224 root 1.20 $loop->once ($fh_or_undef, $events, $timeout, $cb->($revents))
225 root 1.12 This function rolls together an I/O and a timer watcher for a single
226     one-shot event without the need for managing a watcher object.
227    
228     If $fh_or_undef is a filehandle or file descriptor, then $events
229     must be a bitset containing either "EV::READ", "EV::WRITE" or
230     "EV::READ | EV::WRITE", indicating the type of I/O event you want to
231     wait for. If you do not want to wait for some I/O event, specify
232     "undef" for $fh_or_undef and 0 for $events).
233    
234     If timeout is "undef" or negative, then there will be no timeout.
235     Otherwise a EV::timer with this value will be started.
236    
237     When an error occurs or either the timeout or I/O watcher triggers,
238     then the callback will be called with the received event set (in
239 root 1.20 general you can expect it to be a combination of "EV::ERROR",
240 root 1.12 "EV::READ", "EV::WRITE" and "EV::TIMEOUT").
241    
242     EV::once doesn't return anything: the watchers stay active till
243     either of them triggers, then they will be stopped and freed, and
244     the callback invoked.
245    
246 root 1.17 EV::feed_fd_event ($fd, $revents)
247 root 1.20 $loop->feed_fd_event ($fd, $revents)
248 root 1.17 Feed an event on a file descriptor into EV. EV will react to this
249     call as if the readyness notifications specified by $revents (a
250     combination of "EV::READ" and "EV::WRITE") happened on the file
251     descriptor $fd.
252    
253     EV::feed_signal_event ($signal)
254     Feed a signal event into EV. EV will react to this call as if the
255     signal specified by $signal had occured.
256    
257 root 1.21 EV::set_io_collect_interval $time
258     $loop->set_io_collect_interval ($time)
259     EV::set_timeout_collect_interval $time
260     $loop->set_timeout_collect_interval ($time)
261     These advanced functions set the minimum block interval when polling
262     for I/O events and the minimum wait interval for timer events. See
263     the libev documentation at
264     <http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#FUNCTIONS_CONT
265 root 1.30 ROLLING_THE_EVENT_LOOP> (locally installed as EV::libev) for a more
266     detailed discussion.
267 root 1.21
268 root 1.20 WATCHER OBJECTS
269 root 1.6 A watcher is an object that gets created to record your interest in some
270     event. For instance, if you want to wait for STDIN to become readable,
271     you would create an EV::io watcher for that:
272    
273 root 1.28 my $watcher = EV::io *STDIN, EV::READ, sub {
274     my ($watcher, $revents) = @_;
275     warn "yeah, STDIN should now be readable without blocking!\n"
276     };
277 root 1.2
278 root 1.6 All watchers can be active (waiting for events) or inactive (paused).
279     Only active watchers will have their callbacks invoked. All callbacks
280     will be called with at least two arguments: the watcher and a bitmask of
281     received events.
282    
283     Each watcher type has its associated bit in revents, so you can use the
284     same callback for multiple watchers. The event mask is named after the
285 root 1.31 type, i.e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE,
286 root 1.16 EV::periodic sets EV::PERIODIC and so on, with the exception of I/O
287 root 1.6 events (which can set both EV::READ and EV::WRITE bits), and EV::timer
288     (which uses EV::TIMEOUT).
289    
290     In the rare case where one wants to create a watcher but not start it at
291     the same time, each constructor has a variant with a trailing "_ns" in
292     its name, e.g. EV::io has a non-starting variant EV::io_ns and so on.
293    
294     Please note that a watcher will automatically be stopped when the
295 root 1.7 watcher object is destroyed, so you *need* to keep the watcher objects
296 root 1.6 returned by the constructors.
297    
298 root 1.7 Also, all methods changing some aspect of a watcher (->set, ->priority,
299     ->fh and so on) automatically stop and start it again if it is active,
300     which means pending events get lost.
301    
302 root 1.13 COMMON WATCHER METHODS
303     This section lists methods common to all watchers.
304 root 1.2
305 root 1.6 $w->start
306     Starts a watcher if it isn't active already. Does nothing to an
307     already active watcher. By default, all watchers start out in the
308     active state (see the description of the "_ns" variants if you need
309     stopped watchers).
310    
311     $w->stop
312     Stop a watcher if it is active. Also clear any pending events
313     (events that have been received but that didn't yet result in a
314 root 1.16 callback invocation), regardless of whether the watcher was active
315     or not.
316 root 1.6
317     $bool = $w->is_active
318     Returns true if the watcher is active, false otherwise.
319    
320 root 1.8 $current_data = $w->data
321     $old_data = $w->data ($new_data)
322     Queries a freely usable data scalar on the watcher and optionally
323     changes it. This is a way to associate custom data with a watcher:
324    
325     my $w = EV::timer 60, 0, sub {
326     warn $_[0]->data;
327     };
328     $w->data ("print me!");
329    
330 root 1.6 $current_cb = $w->cb
331     $old_cb = $w->cb ($new_cb)
332     Queries the callback on the watcher and optionally changes it. You
333 root 1.7 can do this at any time without the watcher restarting.
334    
335     $current_priority = $w->priority
336     $old_priority = $w->priority ($new_priority)
337     Queries the priority on the watcher and optionally changes it.
338     Pending watchers with higher priority will be invoked first. The
339     valid range of priorities lies between EV::MAXPRI (default 2) and
340     EV::MINPRI (default -2). If the priority is outside this range it
341     will automatically be normalised to the nearest valid priority.
342    
343 root 1.12 The default priority of any newly-created watcher is 0.
344    
345     Note that the priority semantics have not yet been fleshed out and
346     are subject to almost certain change.
347 root 1.2
348 root 1.17 $w->invoke ($revents)
349 root 1.6 Call the callback *now* with the given event mask.
350 root 1.2
351 root 1.17 $w->feed_event ($revents)
352     Feed some events on this watcher into EV. EV will react to this call
353     as if the watcher had received the given $revents mask.
354    
355     $revents = $w->clear_pending
356 root 1.20 If the watcher is pending, this function clears its pending status
357     and returns its $revents bitset (as if its callback was invoked). If
358     the watcher isn't pending it does nothing and returns 0.
359 root 1.17
360 root 1.12 $previous_state = $w->keepalive ($bool)
361     Normally, "EV::loop" will return when there are no active watchers
362     (which is a "deadlock" because no progress can be made anymore).
363     This is convinient because it allows you to start your watchers (and
364     your jobs), call "EV::loop" once and when it returns you know that
365     all your jobs are finished (or they forgot to register some watchers
366     for their task :).
367    
368 root 1.20 Sometimes, however, this gets in your way, for example when the
369 root 1.12 module that calls "EV::loop" (usually the main program) is not the
370     same module as a long-living watcher (for example a DNS client
371     module written by somebody else even). Then you might want any
372     outstanding requests to be handled, but you would not want to keep
373     "EV::loop" from returning just because you happen to have this
374     long-running UDP port watcher.
375    
376     In this case you can clear the keepalive status, which means that
377     even though your watcher is active, it won't keep "EV::loop" from
378     returning.
379    
380 root 1.31 The initial value for keepalive is true (enabled), and you can
381 root 1.12 change it any time.
382    
383 root 1.16 Example: Register an I/O watcher for some UDP socket but do not keep
384 root 1.12 the event loop from running just because of that watcher.
385    
386     my $udp_socket = ...
387     my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
388 root 1.28 $udp_watcher->keepalive (0);
389 root 1.20
390     $loop = $w->loop
391     Return the loop that this watcher is attached to.
392 root 1.12
393 root 1.20 WATCHER TYPES
394 root 1.13 Each of the following subsections describes a single watcher type.
395    
396 root 1.16 I/O WATCHERS - is this file descriptor readable or writable?
397 root 1.6 $w = EV::io $fileno_or_fh, $eventmask, $callback
398     $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
399 root 1.20 $w = $loop->io ($fileno_or_fh, $eventmask, $callback)
400     $w = $loop->io_ns ($fileno_or_fh, $eventmask, $callback)
401 root 1.6 As long as the returned watcher object is alive, call the $callback
402 root 1.13 when at least one of events specified in $eventmask occurs.
403 root 1.2
404 root 1.6 The $eventmask can be one or more of these constants ORed together:
405 root 1.1
406 root 1.2 EV::READ wait until read() wouldn't block anymore
407     EV::WRITE wait until write() wouldn't block anymore
408    
409 root 1.6 The "io_ns" variant doesn't start (activate) the newly created
410     watcher.
411    
412     $w->set ($fileno_or_fh, $eventmask)
413     Reconfigures the watcher, see the constructor above for details. Can
414     be called at any time.
415    
416     $current_fh = $w->fh
417     $old_fh = $w->fh ($new_fh)
418     Returns the previously set filehandle and optionally set a new one.
419    
420     $current_eventmask = $w->events
421     $old_eventmask = $w->events ($new_eventmask)
422     Returns the previously set event mask and optionally set a new one.
423    
424 root 1.13 TIMER WATCHERS - relative and optionally repeating timeouts
425 root 1.6 $w = EV::timer $after, $repeat, $callback
426     $w = EV::timer_ns $after, $repeat, $callback
427 root 1.20 $w = $loop->timer ($after, $repeat, $callback)
428     $w = $loop->timer_ns ($after, $repeat, $callback)
429 root 1.12 Calls the callback after $after seconds (which may be fractional).
430     If $repeat is non-zero, the timer will be restarted (with the
431     $repeat value as $after) after the callback returns.
432 root 1.6
433     This means that the callback would be called roughly after $after
434 root 1.10 seconds, and then every $repeat seconds. The timer does his best not
435     to drift, but it will not invoke the timer more often then once per
436     event loop iteration, and might drift in other cases. If that isn't
437     acceptable, look at EV::periodic, which can provide long-term stable
438     timers.
439 root 1.6
440 root 1.10 The timer is based on a monotonic clock, that is, if somebody is
441 root 1.6 sitting in front of the machine while the timer is running and
442     changes the system clock, the timer will nevertheless run (roughly)
443     the same time.
444    
445     The "timer_ns" variant doesn't start (activate) the newly created
446     watcher.
447    
448     $w->set ($after, $repeat)
449     Reconfigures the watcher, see the constructor above for details. Can
450 root 1.13 be called at any time.
451 root 1.6
452     $w->again
453     Similar to the "start" method, but has special semantics for
454     repeating timers:
455 root 1.2
456 root 1.10 If the timer is active and non-repeating, it will be stopped.
457    
458 root 1.6 If the timer is active and repeating, reset the timeout to occur
459     $repeat seconds after now.
460 root 1.2
461 root 1.10 If the timer is inactive and repeating, start it using the repeat
462     value.
463 root 1.6
464     Otherwise do nothing.
465    
466     This behaviour is useful when you have a timeout for some IO
467     operation. You create a timer object with the same value for $after
468     and $repeat, and then, in the read/write watcher, run the "again"
469     method on the timeout.
470    
471 root 1.13 PERIODIC WATCHERS - to cron or not to cron?
472 root 1.8 $w = EV::periodic $at, $interval, $reschedule_cb, $callback
473     $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
474 root 1.20 $w = $loop->periodic ($at, $interval, $reschedule_cb, $callback)
475     $w = $loop->periodic_ns ($at, $interval, $reschedule_cb, $callback)
476 root 1.8 Similar to EV::timer, but is not based on relative timeouts but on
477     absolute times. Apart from creating "simple" timers that trigger
478     "at" the specified time, it can also be used for non-drifting
479     absolute timers and more complex, cron-like, setups that are not
480     adversely affected by time jumps (i.e. when the system clock is
481     changed by explicit date -s or other means such as ntpd). It is also
482     the most complex watcher type in EV.
483    
484     It has three distinct "modes":
485    
486 root 1.22 * absolute timer ($interval = $reschedule_cb = 0)
487    
488 root 1.8 This time simply fires at the wallclock time $at and doesn't
489     repeat. It will not adjust when a time jump occurs, that is, if
490     it is to be run at January 1st 2011 then it will run when the
491     system time reaches or surpasses this time.
492    
493 root 1.23 * repeating interval timer ($interval > 0, $reschedule_cb = 0)
494 root 1.22
495 root 1.8 In this mode the watcher will always be scheduled to time out at
496     the next "$at + N * $interval" time (for some integer N) and
497     then repeat, regardless of any time jumps.
498    
499     This can be used to create timers that do not drift with respect
500     to system time:
501    
502     my $hourly = EV::periodic 0, 3600, 0, sub { print "once/hour\n" };
503    
504     That doesn't mean there will always be 3600 seconds in between
505     triggers, but only that the the clalback will be called when the
506     system time shows a full hour (UTC).
507    
508     Another way to think about it (for the mathematically inclined)
509     is that EV::periodic will try to run the callback in this mode
510     at the next possible time where "$time = $at (mod $interval)",
511     regardless of any time jumps.
512    
513 root 1.22 * manual reschedule mode ($reschedule_cb = coderef)
514    
515 root 1.8 In this mode $interval and $at are both being ignored. Instead,
516 root 1.10 each time the periodic watcher gets scheduled, the reschedule
517 root 1.8 callback ($reschedule_cb) will be called with the watcher as
518     first, and the current time as second argument.
519    
520     *This callback MUST NOT stop or destroy this or any other
521 root 1.26 periodic watcher, ever, and MUST NOT call any event loop
522     functions or methods*. If you need to stop it, return 1e30 and
523     stop it afterwards. You may create and start a "EV::prepare"
524     watcher for this task.
525 root 1.8
526     It must return the next time to trigger, based on the passed
527 root 1.26 time value (that is, the lowest time value larger than or equal
528     to to the second argument). It will usually be called just
529     before the callback will be triggered, but might be called at
530     other times, too.
531 root 1.8
532     This can be used to create very complex timers, such as a timer
533     that triggers on each midnight, local time (actually 24 hours
534     after the last midnight, to keep the example simple. If you know
535     a way to do it correctly in about the same space (without
536     requiring elaborate modules), drop me a note :):
537    
538     my $daily = EV::periodic 0, 0, sub {
539     my ($w, $now) = @_;
540    
541     use Time::Local ();
542     my (undef, undef, undef, $d, $m, $y) = localtime $now;
543     86400 + Time::Local::timelocal 0, 0, 0, $d, $m, $y
544     }, sub {
545     print "it's midnight or likely shortly after, now\n";
546     };
547 root 1.6
548     The "periodic_ns" variant doesn't start (activate) the newly created
549 root 1.2 watcher.
550    
551 root 1.8 $w->set ($at, $interval, $reschedule_cb)
552 root 1.6 Reconfigures the watcher, see the constructor above for details. Can
553 root 1.13 be called at any time.
554 root 1.6
555 root 1.8 $w->again
556     Simply stops and starts the watcher again.
557    
558 root 1.19 $time = $w->at
559     Return the time that the watcher is expected to trigger next.
560    
561 root 1.13 SIGNAL WATCHERS - signal me when a signal gets signalled!
562 root 1.6 $w = EV::signal $signal, $callback
563     $w = EV::signal_ns $signal, $callback
564 root 1.4 Call the callback when $signal is received (the signal can be
565 root 1.13 specified by number or by name, just as with "kill" or %SIG).
566 root 1.4
567     EV will grab the signal for the process (the kernel only allows one
568 root 1.6 component to receive a signal at a time) when you start a signal
569     watcher, and removes it again when you stop it. Perl does the same
570     when you add/remove callbacks to %SIG, so watch out.
571    
572     You can have as many signal watchers per signal as you want.
573 root 1.1
574 root 1.6 The "signal_ns" variant doesn't start (activate) the newly created
575     watcher.
576    
577     $w->set ($signal)
578     Reconfigures the watcher, see the constructor above for details. Can
579 root 1.13 be called at any time.
580 root 1.6
581 root 1.7 $current_signum = $w->signal
582     $old_signum = $w->signal ($new_signal)
583     Returns the previously set signal (always as a number not name) and
584     optionally set a new one.
585    
586 root 1.13 CHILD WATCHERS - watch out for process status changes
587 root 1.22 $w = EV::child $pid, $trace, $callback
588     $w = EV::child_ns $pid, $trace, $callback
589     $w = $loop->child ($pid, $trace, $callback)
590     $w = $loop->child_ns ($pid, $trace, $callback)
591 root 1.6 Call the callback when a status change for pid $pid (or any pid if
592 root 1.22 $pid is 0) has been received (a status change happens when the
593     process terminates or is killed, or, when trace is true,
594     additionally when it is stopped or continued). More precisely: when
595     the process receives a "SIGCHLD", EV will fetch the outstanding
596     exit/wait status for all changed/zombie children and call the
597     callback.
598 root 1.6
599 root 1.13 It is valid (and fully supported) to install a child watcher after a
600     child has exited but before the event loop has started its next
601     iteration (for example, first you "fork", then the new child process
602     might exit, and only then do you install a child watcher in the
603     parent for the new pid).
604 root 1.6
605 root 1.13 You can access both exit (or tracing) status and pid by using the
606     "rstatus" and "rpid" methods on the watcher object.
607    
608     You can have as many pid watchers per pid as you want, they will all
609     be called.
610 root 1.6
611     The "child_ns" variant doesn't start (activate) the newly created
612     watcher.
613 root 1.1
614 root 1.22 $w->set ($pid, $trace)
615 root 1.6 Reconfigures the watcher, see the constructor above for details. Can
616 root 1.13 be called at any time.
617 root 1.6
618 root 1.7 $current_pid = $w->pid
619     Returns the previously set process id and optionally set a new one.
620    
621     $exit_status = $w->rstatus
622     Return the exit/wait status (as returned by waitpid, see the waitpid
623     entry in perlfunc).
624    
625     $pid = $w->rpid
626     Return the pid of the awaited child (useful when you have installed
627     a watcher for all pids).
628    
629 root 1.13 STAT WATCHERS - did the file attributes just change?
630     $w = EV::stat $path, $interval, $callback
631     $w = EV::stat_ns $path, $interval, $callback
632 root 1.20 $w = $loop->stat ($path, $interval, $callback)
633     $w = $loop->stat_ns ($path, $interval, $callback)
634 root 1.13 Call the callback when a file status change has been detected on
635     $path. The $path does not need to exist, changing from "path exists"
636     to "path does not exist" is a status change like any other.
637    
638     The $interval is a recommended polling interval for systems where
639     OS-supported change notifications don't exist or are not supported.
640     If you use 0 then an unspecified default is used (which is highly
641     recommended!), which is to be expected to be around five seconds
642     usually.
643    
644     This watcher type is not meant for massive numbers of stat watchers,
645     as even with OS-supported change notifications, this can be
646     resource-intensive.
647    
648     The "stat_ns" variant doesn't start (activate) the newly created
649     watcher.
650    
651 root 1.14 ... = $w->stat
652     This call is very similar to the perl "stat" built-in: It stats
653     (using "lstat") the path specified in the watcher and sets perls
654     stat cache (as well as EV's idea of the current stat values) to the
655     values found.
656    
657     In scalar context, a boolean is return indicating success or failure
658     of the stat. In list context, the same 13-value list as with stat is
659     returned (except that the blksize and blocks fields are not
660     reliable).
661    
662     In the case of an error, errno is set to "ENOENT" (regardless of the
663     actual error value) and the "nlink" value is forced to zero (if the
664     stat was successful then nlink is guaranteed to be non-zero).
665    
666     See also the next two entries for more info.
667    
668     ... = $w->attr
669     Just like "$w->stat", but without the initial stat'ing: this returns
670     the values most recently detected by EV. See the next entry for more
671     info.
672    
673     ... = $w->prev
674     Just like "$w->stat", but without the initial stat'ing: this returns
675     the previous set of values, before the change.
676    
677     That is, when the watcher callback is invoked, "$w->prev" will be
678     set to the values found *before* a change was detected, while
679     "$w->attr" returns the values found leading to the change detection.
680     The difference (if any) between "prev" and "attr" is what triggered
681     the callback.
682    
683     If you did something to the filesystem object and do not want to
684     trigger yet another change, you can call "stat" to update EV's idea
685     of what the current attributes are.
686    
687 root 1.13 $w->set ($path, $interval)
688     Reconfigures the watcher, see the constructor above for details. Can
689     be called at any time.
690    
691     $current_path = $w->path
692     $old_path = $w->path ($new_path)
693     Returns the previously set path and optionally set a new one.
694    
695     $current_interval = $w->interval
696     $old_interval = $w->interval ($new_interval)
697     Returns the previously set interval and optionally set a new one.
698     Can be used to query the actual interval used.
699    
700     IDLE WATCHERS - when you've got nothing better to do...
701 root 1.6 $w = EV::idle $callback
702     $w = EV::idle_ns $callback
703 root 1.20 $w = $loop->idle ($callback)
704     $w = $loop->idle_ns ($callback)
705 root 1.16 Call the callback when there are no other pending watchers of the
706     same or higher priority (excluding check, prepare and other idle
707     watchers of the same or lower priority, of course). They are called
708     idle watchers because when the watcher is the highest priority
709     pending event in the process, the process is considered to be idle
710     at that priority.
711    
712     If you want a watcher that is only ever called when *no* other
713     events are outstanding you have to set the priority to "EV::MINPRI".
714 root 1.1
715 root 1.6 The process will not block as long as any idle watchers are active,
716     and they will be called repeatedly until stopped.
717 root 1.1
718 root 1.16 For example, if you have idle watchers at priority 0 and 1, and an
719     I/O watcher at priority 0, then the idle watcher at priority 1 and
720     the I/O watcher will always run when ready. Only when the idle
721     watcher at priority 1 is stopped and the I/O watcher at priority 0
722     is not pending with the 0-priority idle watcher be invoked.
723    
724 root 1.6 The "idle_ns" variant doesn't start (activate) the newly created
725     watcher.
726 root 1.4
727 root 1.13 PREPARE WATCHERS - customise your event loop!
728 root 1.6 $w = EV::prepare $callback
729     $w = EV::prepare_ns $callback
730 root 1.20 $w = $loop->prepare ($callback)
731     $w = $loop->prepare_ns ($callback)
732 root 1.6 Call the callback just before the process would block. You can still
733     create/modify any watchers at this point.
734 root 1.1
735 root 1.6 See the EV::check watcher, below, for explanations and an example.
736 root 1.1
737 root 1.6 The "prepare_ns" variant doesn't start (activate) the newly created
738     watcher.
739 root 1.1
740 root 1.13 CHECK WATCHERS - customise your event loop even more!
741 root 1.6 $w = EV::check $callback
742     $w = EV::check_ns $callback
743 root 1.20 $w = $loop->check ($callback)
744     $w = $loop->check_ns ($callback)
745 root 1.6 Call the callback just after the process wakes up again (after it
746     has gathered events), but before any other callbacks have been
747     invoked.
748    
749     This is used to integrate other event-based software into the EV
750     mainloop: You register a prepare callback and in there, you create
751     io and timer watchers as required by the other software. Here is a
752     real-world example of integrating Net::SNMP (with some details left
753     out):
754    
755     our @snmp_watcher;
756    
757     our $snmp_prepare = EV::prepare sub {
758     # do nothing unless active
759     $dispatcher->{_event_queue_h}
760     or return;
761    
762     # make the dispatcher handle any outstanding stuff
763 root 1.12 ... not shown
764 root 1.6
765 root 1.16 # create an I/O watcher for each and every socket
766 root 1.6 @snmp_watcher = (
767     (map { EV::io $_, EV::READ, sub { } }
768     keys %{ $dispatcher->{_descriptors} }),
769 root 1.12
770     EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
771     ? $event->[Net::SNMP::Dispatcher::_TIME] - EV::now : 0),
772     0, sub { },
773 root 1.6 );
774     };
775    
776 root 1.12 The callbacks are irrelevant (and are not even being called), the
777     only purpose of those watchers is to wake up the process as soon as
778     one of those events occurs (socket readable, or timer timed out).
779     The corresponding EV::check watcher will then clean up:
780 root 1.6
781     our $snmp_check = EV::check sub {
782     # destroy all watchers
783     @snmp_watcher = ();
784    
785     # make the dispatcher handle any new stuff
786 root 1.12 ... not shown
787 root 1.6 };
788    
789     The callbacks of the created watchers will not be called as the
790 root 1.31 watchers are destroyed before this can happen (remember EV::check
791 root 1.6 gets called first).
792 root 1.1
793 root 1.6 The "check_ns" variant doesn't start (activate) the newly created
794     watcher.
795 root 1.1
796 root 1.13 FORK WATCHERS - the audacity to resume the event loop after a fork
797     Fork watchers are called when a "fork ()" was detected. The invocation
798     is done before the event loop blocks next and before "check" watchers
799     are being called, and only in the child after the fork.
800    
801     $w = EV::fork $callback
802     $w = EV::fork_ns $callback
803 root 1.20 $w = $loop->fork ($callback)
804     $w = $loop->fork_ns ($callback)
805 root 1.13 Call the callback before the event loop is resumed in the child
806     process after a fork.
807    
808     The "fork_ns" variant doesn't start (activate) the newly created
809     watcher.
810    
811 root 1.21 EMBED WATCHERS - when one backend isn't enough...
812     This is a rather advanced watcher type that lets you embed one event
813     loop into another (currently only IO events are supported in the
814     embedded loop, other types of watchers might be handled in a delayed or
815     incorrect fashion and must not be used).
816    
817     See the libev documentation at
818     <http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code
819 root 1.30 _when_one_backend_> (locally installed as EV::libev) for more details.
820 root 1.21
821     In short, this watcher is most useful on BSD systems without working
822     kqueue to still be able to handle a large number of sockets:
823    
824 root 1.28 my $socket_loop;
825    
826     # check wether we use SELECT or POLL _and_ KQUEUE is supported
827     if (
828     (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
829     && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
830     ) {
831     # use kqueue for sockets
832     $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
833     }
834    
835     # use the default loop otherwise
836     $socket_loop ||= EV::default_loop;
837 root 1.21
838 root 1.29 $w = EV::embed $otherloop[, $callback]
839     $w = EV::embed_ns $otherloop[, $callback]
840     $w = $loop->embed ($otherloop[, $callback])
841     $w = $loop->embed_ns ($otherloop[, $callback])
842 root 1.21 Call the callback when the embedded event loop ($otherloop) has any
843 root 1.29 I/O activity. The $callback is optional: if it is missing, then the
844     embedded event loop will be managed automatically (which is
845     recommended), otherwise you have to invoke "sweep" yourself.
846 root 1.21
847     The "embed_ns" variant doesn't start (activate) the newly created
848     watcher.
849    
850 root 1.23 ASYNC WATCHERS - how to wake up another event loop
851     Async watchers are provided by EV, but have little use in perl directly,
852     as perl neither supports threads nor direct access to signal handlers or
853     other contexts where they could be of value.
854    
855     It is, however, possible to use them from the XS level.
856    
857     Please see the libev documentation for further details.
858    
859 root 1.24 $w = EV::async $callback
860     $w = EV::async_ns $callback
861     $w->send
862     $bool = $w->async_pending
863    
864 root 1.16 PERL SIGNALS
865     While Perl signal handling (%SIG) is not affected by EV, the behaviour
866     with EV is as the same as any other C library: Perl-signals will only be
867     handled when Perl runs, which means your signal handler might be invoked
868     only the next time an event callback is invoked.
869    
870     The solution is to use EV signal watchers (see "EV::signal"), which will
871     ensure proper operations with regards to other event watchers.
872    
873     If you cannot do this for whatever reason, you can also force a watcher
874     to be called on every event loop iteration by installing a "EV::check"
875     watcher:
876    
877     my $async_check = EV::check sub { };
878    
879 root 1.20 This ensures that perl gets into control for a short time to handle any
880     pending signals, and also ensures (slightly) slower overall operation.
881 root 1.16
882 root 1.5 THREADS
883 root 1.12 Threads are not supported by this module in any way. Perl pseudo-threads
884     is evil stuff and must die. As soon as Perl gains real threads I will
885     work on thread support for it.
886    
887     FORK
888     Most of the "improved" event delivering mechanisms of modern operating
889     systems have quite a few problems with fork(2) (to put it bluntly: it is
890     not supported and usually destructive). Libev makes it possible to work
891     around this by having a function that recreates the kernel state after
892     fork in the child.
893    
894     On non-win32 platforms, this module requires the pthread_atfork
895     functionality to do this automatically for you. This function is quite
896     buggy on most BSDs, though, so YMMV. The overhead for this is quite
897     negligible, because everything the function currently does is set a flag
898     that is checked only when the event loop gets used the next time, so
899     when you do fork but not use EV, the overhead is minimal.
900    
901     On win32, there is no notion of fork so all this doesn't apply, of
902     course.
903 root 1.2
904     SEE ALSO
905 root 1.20 EV::ADNS (asynchronous DNS), Glib::EV (makes Glib/Gtk2 use EV as event
906     loop), EV::Glib (embed Glib into EV), Coro::EV (efficient coroutines
907 root 1.25 with EV), Net::SNMP::EV (asynchronous SNMP), AnyEvent for event-loop
908     agnostic and portable event driven programming.
909 root 1.1
910     AUTHOR
911 root 1.28 Marc Lehmann <schmorp@schmorp.de>
912     http://home.schmorp.de/
913 root 1.1