ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/README
Revision: 1.34
Committed: Sun Aug 9 13:30:41 2009 UTC (14 years, 9 months ago) by root
Branch: MAIN
CVS Tags: rel-3_8
Changes since 1.33: +6 -0 lines
Log Message:
3.8

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 root 1.33
8     # TIMERS
9    
10     my $w = EV::timer 2, 0, sub {
11 root 1.28 warn "is called after 2s";
12     };
13 root 1.33
14     my $w = EV::timer 2, 2, sub {
15 root 1.28 warn "is called roughly every 2s (repeat = 2)";
16     };
17 root 1.33
18     undef $w; # destroy event watcher again
19    
20     my $w = EV::periodic 0, 60, 0, sub {
21 root 1.28 warn "is called every minute, on the minute, exactly";
22     };
23 root 1.33
24     # IO
25    
26     my $w = EV::io *STDIN, EV::READ, sub {
27 root 1.28 my ($w, $revents) = @_; # all callbacks receive the watcher and event mask
28     warn "stdin is readable, you entered: ", <STDIN>;
29     };
30 root 1.33
31     # SIGNALS
32    
33     my $w = EV::signal 'QUIT', sub {
34 root 1.28 warn "sigquit received\n";
35     };
36 root 1.33
37     # CHILD/PID STATUS CHANGES
38    
39     my $w = EV::child 666, 0, sub {
40 root 1.28 my ($w, $revents) = @_;
41     my $status = $w->rstatus;
42     };
43 root 1.33
44     # STAT CHANGES
45 root 1.28 my $w = EV::stat "/etc/passwd", 10, sub {
46     my ($w, $revents) = @_;
47     warn $w->path, " has changed somehow.\n";
48     };
49 root 1.33
50     # MAINLOOP
51 root 1.28 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.33 $count = EV::pending_count
269     $count = $loop->pending_count
270     Returns the number of currently pending watchers.
271    
272     EV::invoke_pending
273     $loop->invoke_pending
274     Invoke all currently pending watchers.
275    
276 root 1.20 WATCHER OBJECTS
277 root 1.6 A watcher is an object that gets created to record your interest in some
278     event. For instance, if you want to wait for STDIN to become readable,
279     you would create an EV::io watcher for that:
280    
281 root 1.28 my $watcher = EV::io *STDIN, EV::READ, sub {
282     my ($watcher, $revents) = @_;
283     warn "yeah, STDIN should now be readable without blocking!\n"
284     };
285 root 1.2
286 root 1.6 All watchers can be active (waiting for events) or inactive (paused).
287     Only active watchers will have their callbacks invoked. All callbacks
288     will be called with at least two arguments: the watcher and a bitmask of
289     received events.
290    
291     Each watcher type has its associated bit in revents, so you can use the
292     same callback for multiple watchers. The event mask is named after the
293 root 1.31 type, i.e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE,
294 root 1.16 EV::periodic sets EV::PERIODIC and so on, with the exception of I/O
295 root 1.6 events (which can set both EV::READ and EV::WRITE bits), and EV::timer
296     (which uses EV::TIMEOUT).
297    
298     In the rare case where one wants to create a watcher but not start it at
299     the same time, each constructor has a variant with a trailing "_ns" in
300     its name, e.g. EV::io has a non-starting variant EV::io_ns and so on.
301    
302     Please note that a watcher will automatically be stopped when the
303 root 1.7 watcher object is destroyed, so you *need* to keep the watcher objects
304 root 1.6 returned by the constructors.
305    
306 root 1.7 Also, all methods changing some aspect of a watcher (->set, ->priority,
307     ->fh and so on) automatically stop and start it again if it is active,
308     which means pending events get lost.
309    
310 root 1.13 COMMON WATCHER METHODS
311     This section lists methods common to all watchers.
312 root 1.2
313 root 1.6 $w->start
314     Starts a watcher if it isn't active already. Does nothing to an
315     already active watcher. By default, all watchers start out in the
316     active state (see the description of the "_ns" variants if you need
317     stopped watchers).
318    
319     $w->stop
320     Stop a watcher if it is active. Also clear any pending events
321     (events that have been received but that didn't yet result in a
322 root 1.16 callback invocation), regardless of whether the watcher was active
323     or not.
324 root 1.6
325     $bool = $w->is_active
326     Returns true if the watcher is active, false otherwise.
327    
328 root 1.8 $current_data = $w->data
329     $old_data = $w->data ($new_data)
330     Queries a freely usable data scalar on the watcher and optionally
331     changes it. This is a way to associate custom data with a watcher:
332    
333     my $w = EV::timer 60, 0, sub {
334     warn $_[0]->data;
335     };
336     $w->data ("print me!");
337    
338 root 1.6 $current_cb = $w->cb
339     $old_cb = $w->cb ($new_cb)
340     Queries the callback on the watcher and optionally changes it. You
341 root 1.7 can do this at any time without the watcher restarting.
342    
343     $current_priority = $w->priority
344     $old_priority = $w->priority ($new_priority)
345     Queries the priority on the watcher and optionally changes it.
346     Pending watchers with higher priority will be invoked first. The
347     valid range of priorities lies between EV::MAXPRI (default 2) and
348     EV::MINPRI (default -2). If the priority is outside this range it
349     will automatically be normalised to the nearest valid priority.
350    
351 root 1.12 The default priority of any newly-created watcher is 0.
352    
353     Note that the priority semantics have not yet been fleshed out and
354     are subject to almost certain change.
355 root 1.2
356 root 1.17 $w->invoke ($revents)
357 root 1.6 Call the callback *now* with the given event mask.
358 root 1.2
359 root 1.17 $w->feed_event ($revents)
360     Feed some events on this watcher into EV. EV will react to this call
361     as if the watcher had received the given $revents mask.
362    
363     $revents = $w->clear_pending
364 root 1.20 If the watcher is pending, this function clears its pending status
365     and returns its $revents bitset (as if its callback was invoked). If
366     the watcher isn't pending it does nothing and returns 0.
367 root 1.17
368 root 1.12 $previous_state = $w->keepalive ($bool)
369     Normally, "EV::loop" will return when there are no active watchers
370     (which is a "deadlock" because no progress can be made anymore).
371     This is convinient because it allows you to start your watchers (and
372     your jobs), call "EV::loop" once and when it returns you know that
373     all your jobs are finished (or they forgot to register some watchers
374     for their task :).
375    
376 root 1.20 Sometimes, however, this gets in your way, for example when the
377 root 1.12 module that calls "EV::loop" (usually the main program) is not the
378     same module as a long-living watcher (for example a DNS client
379     module written by somebody else even). Then you might want any
380     outstanding requests to be handled, but you would not want to keep
381     "EV::loop" from returning just because you happen to have this
382     long-running UDP port watcher.
383    
384     In this case you can clear the keepalive status, which means that
385     even though your watcher is active, it won't keep "EV::loop" from
386     returning.
387    
388 root 1.31 The initial value for keepalive is true (enabled), and you can
389 root 1.12 change it any time.
390    
391 root 1.16 Example: Register an I/O watcher for some UDP socket but do not keep
392 root 1.12 the event loop from running just because of that watcher.
393    
394     my $udp_socket = ...
395     my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
396 root 1.28 $udp_watcher->keepalive (0);
397 root 1.20
398     $loop = $w->loop
399     Return the loop that this watcher is attached to.
400 root 1.12
401 root 1.20 WATCHER TYPES
402 root 1.13 Each of the following subsections describes a single watcher type.
403    
404 root 1.16 I/O WATCHERS - is this file descriptor readable or writable?
405 root 1.6 $w = EV::io $fileno_or_fh, $eventmask, $callback
406     $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
407 root 1.20 $w = $loop->io ($fileno_or_fh, $eventmask, $callback)
408     $w = $loop->io_ns ($fileno_or_fh, $eventmask, $callback)
409 root 1.6 As long as the returned watcher object is alive, call the $callback
410 root 1.13 when at least one of events specified in $eventmask occurs.
411 root 1.2
412 root 1.6 The $eventmask can be one or more of these constants ORed together:
413 root 1.1
414 root 1.2 EV::READ wait until read() wouldn't block anymore
415     EV::WRITE wait until write() wouldn't block anymore
416    
417 root 1.6 The "io_ns" variant doesn't start (activate) the newly created
418     watcher.
419    
420     $w->set ($fileno_or_fh, $eventmask)
421     Reconfigures the watcher, see the constructor above for details. Can
422     be called at any time.
423    
424     $current_fh = $w->fh
425     $old_fh = $w->fh ($new_fh)
426     Returns the previously set filehandle and optionally set a new one.
427    
428     $current_eventmask = $w->events
429     $old_eventmask = $w->events ($new_eventmask)
430     Returns the previously set event mask and optionally set a new one.
431    
432 root 1.13 TIMER WATCHERS - relative and optionally repeating timeouts
433 root 1.6 $w = EV::timer $after, $repeat, $callback
434     $w = EV::timer_ns $after, $repeat, $callback
435 root 1.20 $w = $loop->timer ($after, $repeat, $callback)
436     $w = $loop->timer_ns ($after, $repeat, $callback)
437 root 1.12 Calls the callback after $after seconds (which may be fractional).
438     If $repeat is non-zero, the timer will be restarted (with the
439     $repeat value as $after) after the callback returns.
440 root 1.6
441     This means that the callback would be called roughly after $after
442 root 1.10 seconds, and then every $repeat seconds. The timer does his best not
443     to drift, but it will not invoke the timer more often then once per
444     event loop iteration, and might drift in other cases. If that isn't
445     acceptable, look at EV::periodic, which can provide long-term stable
446     timers.
447 root 1.6
448 root 1.10 The timer is based on a monotonic clock, that is, if somebody is
449 root 1.6 sitting in front of the machine while the timer is running and
450     changes the system clock, the timer will nevertheless run (roughly)
451     the same time.
452    
453     The "timer_ns" variant doesn't start (activate) the newly created
454     watcher.
455    
456     $w->set ($after, $repeat)
457     Reconfigures the watcher, see the constructor above for details. Can
458 root 1.13 be called at any time.
459 root 1.6
460     $w->again
461     Similar to the "start" method, but has special semantics for
462     repeating timers:
463 root 1.2
464 root 1.10 If the timer is active and non-repeating, it will be stopped.
465    
466 root 1.6 If the timer is active and repeating, reset the timeout to occur
467     $repeat seconds after now.
468 root 1.2
469 root 1.10 If the timer is inactive and repeating, start it using the repeat
470     value.
471 root 1.6
472     Otherwise do nothing.
473    
474     This behaviour is useful when you have a timeout for some IO
475     operation. You create a timer object with the same value for $after
476     and $repeat, and then, in the read/write watcher, run the "again"
477     method on the timeout.
478    
479 root 1.13 PERIODIC WATCHERS - to cron or not to cron?
480 root 1.8 $w = EV::periodic $at, $interval, $reschedule_cb, $callback
481     $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
482 root 1.20 $w = $loop->periodic ($at, $interval, $reschedule_cb, $callback)
483     $w = $loop->periodic_ns ($at, $interval, $reschedule_cb, $callback)
484 root 1.8 Similar to EV::timer, but is not based on relative timeouts but on
485     absolute times. Apart from creating "simple" timers that trigger
486     "at" the specified time, it can also be used for non-drifting
487     absolute timers and more complex, cron-like, setups that are not
488     adversely affected by time jumps (i.e. when the system clock is
489     changed by explicit date -s or other means such as ntpd). It is also
490     the most complex watcher type in EV.
491    
492     It has three distinct "modes":
493    
494 root 1.22 * absolute timer ($interval = $reschedule_cb = 0)
495    
496 root 1.8 This time simply fires at the wallclock time $at and doesn't
497     repeat. It will not adjust when a time jump occurs, that is, if
498     it is to be run at January 1st 2011 then it will run when the
499     system time reaches or surpasses this time.
500    
501 root 1.23 * repeating interval timer ($interval > 0, $reschedule_cb = 0)
502 root 1.22
503 root 1.8 In this mode the watcher will always be scheduled to time out at
504     the next "$at + N * $interval" time (for some integer N) and
505     then repeat, regardless of any time jumps.
506    
507     This can be used to create timers that do not drift with respect
508     to system time:
509    
510     my $hourly = EV::periodic 0, 3600, 0, sub { print "once/hour\n" };
511    
512     That doesn't mean there will always be 3600 seconds in between
513     triggers, but only that the the clalback will be called when the
514     system time shows a full hour (UTC).
515    
516     Another way to think about it (for the mathematically inclined)
517     is that EV::periodic will try to run the callback in this mode
518     at the next possible time where "$time = $at (mod $interval)",
519     regardless of any time jumps.
520    
521 root 1.22 * manual reschedule mode ($reschedule_cb = coderef)
522    
523 root 1.8 In this mode $interval and $at are both being ignored. Instead,
524 root 1.10 each time the periodic watcher gets scheduled, the reschedule
525 root 1.8 callback ($reschedule_cb) will be called with the watcher as
526     first, and the current time as second argument.
527    
528     *This callback MUST NOT stop or destroy this or any other
529 root 1.26 periodic watcher, ever, and MUST NOT call any event loop
530     functions or methods*. If you need to stop it, return 1e30 and
531     stop it afterwards. You may create and start a "EV::prepare"
532     watcher for this task.
533 root 1.8
534     It must return the next time to trigger, based on the passed
535 root 1.26 time value (that is, the lowest time value larger than or equal
536     to to the second argument). It will usually be called just
537     before the callback will be triggered, but might be called at
538     other times, too.
539 root 1.8
540     This can be used to create very complex timers, such as a timer
541     that triggers on each midnight, local time (actually 24 hours
542     after the last midnight, to keep the example simple. If you know
543     a way to do it correctly in about the same space (without
544     requiring elaborate modules), drop me a note :):
545    
546     my $daily = EV::periodic 0, 0, sub {
547     my ($w, $now) = @_;
548    
549     use Time::Local ();
550     my (undef, undef, undef, $d, $m, $y) = localtime $now;
551     86400 + Time::Local::timelocal 0, 0, 0, $d, $m, $y
552     }, sub {
553     print "it's midnight or likely shortly after, now\n";
554     };
555 root 1.6
556     The "periodic_ns" variant doesn't start (activate) the newly created
557 root 1.2 watcher.
558    
559 root 1.8 $w->set ($at, $interval, $reschedule_cb)
560 root 1.6 Reconfigures the watcher, see the constructor above for details. Can
561 root 1.13 be called at any time.
562 root 1.6
563 root 1.8 $w->again
564     Simply stops and starts the watcher again.
565    
566 root 1.19 $time = $w->at
567     Return the time that the watcher is expected to trigger next.
568    
569 root 1.13 SIGNAL WATCHERS - signal me when a signal gets signalled!
570 root 1.6 $w = EV::signal $signal, $callback
571     $w = EV::signal_ns $signal, $callback
572 root 1.34 $w = $loop->signal ($signal, $callback)
573     $w = $loop->signal_ns ($signal, $callback)
574 root 1.4 Call the callback when $signal is received (the signal can be
575 root 1.13 specified by number or by name, just as with "kill" or %SIG).
576 root 1.4
577 root 1.34 Only one event loop can grab a given signal - attempting to grab the
578     same signal from two EV loops will crash the program immediately or
579     cause data corruption.
580    
581 root 1.4 EV will grab the signal for the process (the kernel only allows one
582 root 1.6 component to receive a signal at a time) when you start a signal
583     watcher, and removes it again when you stop it. Perl does the same
584     when you add/remove callbacks to %SIG, so watch out.
585    
586     You can have as many signal watchers per signal as you want.
587 root 1.1
588 root 1.6 The "signal_ns" variant doesn't start (activate) the newly created
589     watcher.
590    
591     $w->set ($signal)
592     Reconfigures the watcher, see the constructor above for details. Can
593 root 1.13 be called at any time.
594 root 1.6
595 root 1.7 $current_signum = $w->signal
596     $old_signum = $w->signal ($new_signal)
597     Returns the previously set signal (always as a number not name) and
598     optionally set a new one.
599    
600 root 1.13 CHILD WATCHERS - watch out for process status changes
601 root 1.22 $w = EV::child $pid, $trace, $callback
602     $w = EV::child_ns $pid, $trace, $callback
603     $w = $loop->child ($pid, $trace, $callback)
604     $w = $loop->child_ns ($pid, $trace, $callback)
605 root 1.6 Call the callback when a status change for pid $pid (or any pid if
606 root 1.22 $pid is 0) has been received (a status change happens when the
607     process terminates or is killed, or, when trace is true,
608     additionally when it is stopped or continued). More precisely: when
609     the process receives a "SIGCHLD", EV will fetch the outstanding
610     exit/wait status for all changed/zombie children and call the
611     callback.
612 root 1.6
613 root 1.13 It is valid (and fully supported) to install a child watcher after a
614     child has exited but before the event loop has started its next
615     iteration (for example, first you "fork", then the new child process
616     might exit, and only then do you install a child watcher in the
617     parent for the new pid).
618 root 1.6
619 root 1.13 You can access both exit (or tracing) status and pid by using the
620     "rstatus" and "rpid" methods on the watcher object.
621    
622     You can have as many pid watchers per pid as you want, they will all
623     be called.
624 root 1.6
625     The "child_ns" variant doesn't start (activate) the newly created
626     watcher.
627 root 1.1
628 root 1.22 $w->set ($pid, $trace)
629 root 1.6 Reconfigures the watcher, see the constructor above for details. Can
630 root 1.13 be called at any time.
631 root 1.6
632 root 1.7 $current_pid = $w->pid
633     Returns the previously set process id and optionally set a new one.
634    
635     $exit_status = $w->rstatus
636     Return the exit/wait status (as returned by waitpid, see the waitpid
637     entry in perlfunc).
638    
639     $pid = $w->rpid
640     Return the pid of the awaited child (useful when you have installed
641     a watcher for all pids).
642    
643 root 1.13 STAT WATCHERS - did the file attributes just change?
644     $w = EV::stat $path, $interval, $callback
645     $w = EV::stat_ns $path, $interval, $callback
646 root 1.20 $w = $loop->stat ($path, $interval, $callback)
647     $w = $loop->stat_ns ($path, $interval, $callback)
648 root 1.13 Call the callback when a file status change has been detected on
649     $path. The $path does not need to exist, changing from "path exists"
650     to "path does not exist" is a status change like any other.
651    
652     The $interval is a recommended polling interval for systems where
653     OS-supported change notifications don't exist or are not supported.
654     If you use 0 then an unspecified default is used (which is highly
655     recommended!), which is to be expected to be around five seconds
656     usually.
657    
658     This watcher type is not meant for massive numbers of stat watchers,
659     as even with OS-supported change notifications, this can be
660     resource-intensive.
661    
662     The "stat_ns" variant doesn't start (activate) the newly created
663     watcher.
664    
665 root 1.14 ... = $w->stat
666     This call is very similar to the perl "stat" built-in: It stats
667     (using "lstat") the path specified in the watcher and sets perls
668     stat cache (as well as EV's idea of the current stat values) to the
669     values found.
670    
671     In scalar context, a boolean is return indicating success or failure
672     of the stat. In list context, the same 13-value list as with stat is
673     returned (except that the blksize and blocks fields are not
674     reliable).
675    
676     In the case of an error, errno is set to "ENOENT" (regardless of the
677     actual error value) and the "nlink" value is forced to zero (if the
678     stat was successful then nlink is guaranteed to be non-zero).
679    
680     See also the next two entries for more info.
681    
682     ... = $w->attr
683     Just like "$w->stat", but without the initial stat'ing: this returns
684     the values most recently detected by EV. See the next entry for more
685     info.
686    
687     ... = $w->prev
688     Just like "$w->stat", but without the initial stat'ing: this returns
689     the previous set of values, before the change.
690    
691     That is, when the watcher callback is invoked, "$w->prev" will be
692     set to the values found *before* a change was detected, while
693     "$w->attr" returns the values found leading to the change detection.
694     The difference (if any) between "prev" and "attr" is what triggered
695     the callback.
696    
697     If you did something to the filesystem object and do not want to
698     trigger yet another change, you can call "stat" to update EV's idea
699     of what the current attributes are.
700    
701 root 1.13 $w->set ($path, $interval)
702     Reconfigures the watcher, see the constructor above for details. Can
703     be called at any time.
704    
705     $current_path = $w->path
706     $old_path = $w->path ($new_path)
707     Returns the previously set path and optionally set a new one.
708    
709     $current_interval = $w->interval
710     $old_interval = $w->interval ($new_interval)
711     Returns the previously set interval and optionally set a new one.
712     Can be used to query the actual interval used.
713    
714     IDLE WATCHERS - when you've got nothing better to do...
715 root 1.6 $w = EV::idle $callback
716     $w = EV::idle_ns $callback
717 root 1.20 $w = $loop->idle ($callback)
718     $w = $loop->idle_ns ($callback)
719 root 1.16 Call the callback when there are no other pending watchers of the
720     same or higher priority (excluding check, prepare and other idle
721     watchers of the same or lower priority, of course). They are called
722     idle watchers because when the watcher is the highest priority
723     pending event in the process, the process is considered to be idle
724     at that priority.
725    
726     If you want a watcher that is only ever called when *no* other
727     events are outstanding you have to set the priority to "EV::MINPRI".
728 root 1.1
729 root 1.6 The process will not block as long as any idle watchers are active,
730     and they will be called repeatedly until stopped.
731 root 1.1
732 root 1.16 For example, if you have idle watchers at priority 0 and 1, and an
733     I/O watcher at priority 0, then the idle watcher at priority 1 and
734     the I/O watcher will always run when ready. Only when the idle
735     watcher at priority 1 is stopped and the I/O watcher at priority 0
736     is not pending with the 0-priority idle watcher be invoked.
737    
738 root 1.6 The "idle_ns" variant doesn't start (activate) the newly created
739     watcher.
740 root 1.4
741 root 1.13 PREPARE WATCHERS - customise your event loop!
742 root 1.6 $w = EV::prepare $callback
743     $w = EV::prepare_ns $callback
744 root 1.20 $w = $loop->prepare ($callback)
745     $w = $loop->prepare_ns ($callback)
746 root 1.6 Call the callback just before the process would block. You can still
747     create/modify any watchers at this point.
748 root 1.1
749 root 1.6 See the EV::check watcher, below, for explanations and an example.
750 root 1.1
751 root 1.6 The "prepare_ns" variant doesn't start (activate) the newly created
752     watcher.
753 root 1.1
754 root 1.13 CHECK WATCHERS - customise your event loop even more!
755 root 1.6 $w = EV::check $callback
756     $w = EV::check_ns $callback
757 root 1.20 $w = $loop->check ($callback)
758     $w = $loop->check_ns ($callback)
759 root 1.6 Call the callback just after the process wakes up again (after it
760     has gathered events), but before any other callbacks have been
761     invoked.
762    
763     This is used to integrate other event-based software into the EV
764     mainloop: You register a prepare callback and in there, you create
765     io and timer watchers as required by the other software. Here is a
766     real-world example of integrating Net::SNMP (with some details left
767     out):
768    
769     our @snmp_watcher;
770    
771     our $snmp_prepare = EV::prepare sub {
772     # do nothing unless active
773     $dispatcher->{_event_queue_h}
774     or return;
775    
776     # make the dispatcher handle any outstanding stuff
777 root 1.12 ... not shown
778 root 1.6
779 root 1.16 # create an I/O watcher for each and every socket
780 root 1.6 @snmp_watcher = (
781     (map { EV::io $_, EV::READ, sub { } }
782     keys %{ $dispatcher->{_descriptors} }),
783 root 1.12
784     EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
785     ? $event->[Net::SNMP::Dispatcher::_TIME] - EV::now : 0),
786     0, sub { },
787 root 1.6 );
788     };
789    
790 root 1.12 The callbacks are irrelevant (and are not even being called), the
791     only purpose of those watchers is to wake up the process as soon as
792     one of those events occurs (socket readable, or timer timed out).
793     The corresponding EV::check watcher will then clean up:
794 root 1.6
795     our $snmp_check = EV::check sub {
796     # destroy all watchers
797     @snmp_watcher = ();
798    
799     # make the dispatcher handle any new stuff
800 root 1.12 ... not shown
801 root 1.6 };
802    
803     The callbacks of the created watchers will not be called as the
804 root 1.31 watchers are destroyed before this can happen (remember EV::check
805 root 1.6 gets called first).
806 root 1.1
807 root 1.6 The "check_ns" variant doesn't start (activate) the newly created
808     watcher.
809 root 1.1
810 root 1.13 FORK WATCHERS - the audacity to resume the event loop after a fork
811     Fork watchers are called when a "fork ()" was detected. The invocation
812     is done before the event loop blocks next and before "check" watchers
813     are being called, and only in the child after the fork.
814    
815     $w = EV::fork $callback
816     $w = EV::fork_ns $callback
817 root 1.20 $w = $loop->fork ($callback)
818     $w = $loop->fork_ns ($callback)
819 root 1.13 Call the callback before the event loop is resumed in the child
820     process after a fork.
821    
822     The "fork_ns" variant doesn't start (activate) the newly created
823     watcher.
824    
825 root 1.21 EMBED WATCHERS - when one backend isn't enough...
826     This is a rather advanced watcher type that lets you embed one event
827     loop into another (currently only IO events are supported in the
828     embedded loop, other types of watchers might be handled in a delayed or
829     incorrect fashion and must not be used).
830    
831     See the libev documentation at
832     <http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#code_ev_embed_code
833 root 1.30 _when_one_backend_> (locally installed as EV::libev) for more details.
834 root 1.21
835     In short, this watcher is most useful on BSD systems without working
836     kqueue to still be able to handle a large number of sockets:
837    
838 root 1.28 my $socket_loop;
839 root 1.33
840     # check wether we use SELECT or POLL _and_ KQUEUE is supported
841 root 1.28 if (
842     (EV::backend & (EV::BACKEND_POLL | EV::BACKEND_SELECT))
843     && (EV::supported_backends & EV::embeddable_backends & EV::BACKEND_KQUEUE)
844     ) {
845     # use kqueue for sockets
846     $socket_loop = new EV::Loop EV::BACKEND_KQUEUE | EV::FLAG_NOENV;
847     }
848 root 1.33
849     # use the default loop otherwise
850 root 1.28 $socket_loop ||= EV::default_loop;
851 root 1.21
852 root 1.29 $w = EV::embed $otherloop[, $callback]
853     $w = EV::embed_ns $otherloop[, $callback]
854     $w = $loop->embed ($otherloop[, $callback])
855     $w = $loop->embed_ns ($otherloop[, $callback])
856 root 1.21 Call the callback when the embedded event loop ($otherloop) has any
857 root 1.29 I/O activity. The $callback is optional: if it is missing, then the
858     embedded event loop will be managed automatically (which is
859     recommended), otherwise you have to invoke "sweep" yourself.
860 root 1.21
861     The "embed_ns" variant doesn't start (activate) the newly created
862     watcher.
863    
864 root 1.23 ASYNC WATCHERS - how to wake up another event loop
865     Async watchers are provided by EV, but have little use in perl directly,
866 root 1.33 as perl neither supports threads running in parallel nor direct access
867     to signal handlers or other contexts where they could be of value.
868 root 1.23
869     It is, however, possible to use them from the XS level.
870    
871     Please see the libev documentation for further details.
872    
873 root 1.24 $w = EV::async $callback
874     $w = EV::async_ns $callback
875     $w->send
876     $bool = $w->async_pending
877    
878 root 1.16 PERL SIGNALS
879     While Perl signal handling (%SIG) is not affected by EV, the behaviour
880     with EV is as the same as any other C library: Perl-signals will only be
881     handled when Perl runs, which means your signal handler might be invoked
882     only the next time an event callback is invoked.
883    
884     The solution is to use EV signal watchers (see "EV::signal"), which will
885     ensure proper operations with regards to other event watchers.
886    
887     If you cannot do this for whatever reason, you can also force a watcher
888     to be called on every event loop iteration by installing a "EV::check"
889     watcher:
890    
891     my $async_check = EV::check sub { };
892    
893 root 1.20 This ensures that perl gets into control for a short time to handle any
894     pending signals, and also ensures (slightly) slower overall operation.
895 root 1.16
896 root 1.33 ITHREADS
897     Ithreads are not supported by this module in any way. Perl
898     pseudo-threads is evil stuff and must die. Real threads as provided by
899     Coro are fully supported (and enhanced support is available via
900     Coro::EV).
901 root 1.12
902     FORK
903     Most of the "improved" event delivering mechanisms of modern operating
904     systems have quite a few problems with fork(2) (to put it bluntly: it is
905     not supported and usually destructive). Libev makes it possible to work
906     around this by having a function that recreates the kernel state after
907     fork in the child.
908    
909     On non-win32 platforms, this module requires the pthread_atfork
910     functionality to do this automatically for you. This function is quite
911     buggy on most BSDs, though, so YMMV. The overhead for this is quite
912     negligible, because everything the function currently does is set a flag
913     that is checked only when the event loop gets used the next time, so
914     when you do fork but not use EV, the overhead is minimal.
915    
916     On win32, there is no notion of fork so all this doesn't apply, of
917     course.
918 root 1.2
919     SEE ALSO
920 root 1.20 EV::ADNS (asynchronous DNS), Glib::EV (makes Glib/Gtk2 use EV as event
921     loop), EV::Glib (embed Glib into EV), Coro::EV (efficient coroutines
922 root 1.25 with EV), Net::SNMP::EV (asynchronous SNMP), AnyEvent for event-loop
923     agnostic and portable event driven programming.
924 root 1.1
925     AUTHOR
926 root 1.28 Marc Lehmann <schmorp@schmorp.de>
927     http://home.schmorp.de/
928 root 1.1