ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev.pod
Revision: 1.40
Committed: Sat Nov 24 10:15:16 2007 UTC (16 years, 5 months ago) by root
Branch: MAIN
Changes since 1.39: +7 -12 lines
Log Message:
include embedding doc in main doc

File Contents

# User Rev Content
1 root 1.1 =head1 NAME
2    
3     libev - a high performance full-featured event loop written in C
4    
5     =head1 SYNOPSIS
6    
7     #include <ev.h>
8    
9     =head1 DESCRIPTION
10    
11     Libev is an event loop: you register interest in certain events (such as a
12     file descriptor being readable or a timeout occuring), and it will manage
13 root 1.4 these event sources and provide your program with events.
14 root 1.1
15     To do this, it must take more or less complete control over your process
16     (or thread) by executing the I<event loop> handler, and will then
17     communicate events via a callback mechanism.
18    
19     You register interest in certain events by registering so-called I<event
20     watchers>, which are relatively small C structures you initialise with the
21     details of the event, and then hand it over to libev by I<starting> the
22     watcher.
23    
24     =head1 FEATURES
25    
26     Libev supports select, poll, the linux-specific epoll and the bsd-specific
27     kqueue mechanisms for file descriptor events, relative timers, absolute
28     timers with customised rescheduling, signal events, process status change
29     events (related to SIGCHLD), and event watchers dealing with the event
30 root 1.5 loop mechanism itself (idle, prepare and check watchers). It also is quite
31 root 1.7 fast (see this L<benchmark|http://libev.schmorp.de/bench.html> comparing
32     it to libevent for example).
33 root 1.1
34     =head1 CONVENTIONS
35    
36     Libev is very configurable. In this manual the default configuration
37     will be described, which supports multiple event loops. For more info
38 root 1.7 about various configuration options please have a look at the file
39 root 1.1 F<README.embed> in the libev distribution. If libev was configured without
40     support for multiple event loops, then all functions taking an initial
41     argument of name C<loop> (which is always of type C<struct ev_loop *>)
42     will not have this argument.
43    
44 root 1.17 =head1 TIME REPRESENTATION
45 root 1.1
46 root 1.2 Libev represents time as a single floating point number, representing the
47     (fractional) number of seconds since the (POSIX) epoch (somewhere near
48     the beginning of 1970, details are complicated, don't ask). This type is
49 root 1.1 called C<ev_tstamp>, which is what you should use too. It usually aliases
50 root 1.34 to the C<double> type in C, and when you need to do any calculations on
51     it, you should treat it as such.
52    
53 root 1.1
54 root 1.17 =head1 GLOBAL FUNCTIONS
55    
56 root 1.18 These functions can be called anytime, even before initialising the
57     library in any way.
58    
59 root 1.1 =over 4
60    
61     =item ev_tstamp ev_time ()
62    
63 root 1.26 Returns the current time as libev would use it. Please note that the
64     C<ev_now> function is usually faster and also often returns the timestamp
65     you actually want to know.
66 root 1.1
67     =item int ev_version_major ()
68    
69     =item int ev_version_minor ()
70    
71     You can find out the major and minor version numbers of the library
72     you linked against by calling the functions C<ev_version_major> and
73     C<ev_version_minor>. If you want, you can compare against the global
74     symbols C<EV_VERSION_MAJOR> and C<EV_VERSION_MINOR>, which specify the
75     version of the library your program was compiled against.
76    
77 root 1.9 Usually, it's a good idea to terminate if the major versions mismatch,
78 root 1.1 as this indicates an incompatible change. Minor versions are usually
79     compatible to older versions, so a larger minor version alone is usually
80     not a problem.
81    
82 root 1.34 Example: make sure we haven't accidentally been linked against the wrong
83     version:
84    
85     assert (("libev version mismatch",
86     ev_version_major () == EV_VERSION_MAJOR
87     && ev_version_minor () >= EV_VERSION_MINOR));
88    
89 root 1.31 =item unsigned int ev_supported_backends ()
90    
91     Return the set of all backends (i.e. their corresponding C<EV_BACKEND_*>
92     value) compiled into this binary of libev (independent of their
93     availability on the system you are running on). See C<ev_default_loop> for
94     a description of the set values.
95    
96 root 1.34 Example: make sure we have the epoll method, because yeah this is cool and
97     a must have and can we have a torrent of it please!!!11
98    
99     assert (("sorry, no epoll, no sex",
100     ev_supported_backends () & EVBACKEND_EPOLL));
101    
102 root 1.31 =item unsigned int ev_recommended_backends ()
103    
104     Return the set of all backends compiled into this binary of libev and also
105     recommended for this platform. This set is often smaller than the one
106     returned by C<ev_supported_backends>, as for example kqueue is broken on
107     most BSDs and will not be autodetected unless you explicitly request it
108     (assuming you know what you are doing). This is the set of backends that
109 root 1.33 libev will probe for if you specify no backends explicitly.
110 root 1.31
111 root 1.35 =item unsigned int ev_embeddable_backends ()
112    
113     Returns the set of backends that are embeddable in other event loops. This
114     is the theoretical, all-platform, value. To find which backends
115     might be supported on the current system, you would need to look at
116     C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
117     recommended ones.
118    
119     See the description of C<ev_embed> watchers for more info.
120    
121 root 1.1 =item ev_set_allocator (void *(*cb)(void *ptr, long size))
122    
123     Sets the allocation function to use (the prototype is similar to the
124 root 1.7 realloc C function, the semantics are identical). It is used to allocate
125     and free memory (no surprises here). If it returns zero when memory
126     needs to be allocated, the library might abort or take some potentially
127     destructive action. The default is your system realloc function.
128 root 1.1
129     You could override this function in high-availability programs to, say,
130     free some memory if it cannot allocate memory, to use a special allocator,
131     or even to sleep a while and retry until some memory is available.
132    
133 root 1.34 Example: replace the libev allocator with one that waits a bit and then
134     retries: better than mine).
135    
136     static void *
137     persistent_realloc (void *ptr, long size)
138     {
139     for (;;)
140     {
141     void *newptr = realloc (ptr, size);
142    
143     if (newptr)
144     return newptr;
145    
146     sleep (60);
147     }
148     }
149    
150     ...
151     ev_set_allocator (persistent_realloc);
152    
153 root 1.1 =item ev_set_syserr_cb (void (*cb)(const char *msg));
154    
155     Set the callback function to call on a retryable syscall error (such
156     as failed select, poll, epoll_wait). The message is a printable string
157     indicating the system call or subsystem causing the problem. If this
158     callback is set, then libev will expect it to remedy the sitution, no
159 root 1.7 matter what, when it returns. That is, libev will generally retry the
160 root 1.1 requested operation, or, if the condition doesn't go away, do bad stuff
161     (such as abort).
162    
163 root 1.34 Example: do the same thing as libev does internally:
164    
165     static void
166     fatal_error (const char *msg)
167     {
168     perror (msg);
169     abort ();
170     }
171    
172     ...
173     ev_set_syserr_cb (fatal_error);
174    
175 root 1.1 =back
176    
177     =head1 FUNCTIONS CONTROLLING THE EVENT LOOP
178    
179     An event loop is described by a C<struct ev_loop *>. The library knows two
180     types of such loops, the I<default> loop, which supports signals and child
181     events, and dynamically created loops which do not.
182    
183     If you use threads, a common model is to run the default event loop
184 root 1.17 in your main thread (or in a separate thread) and for each thread you
185 root 1.7 create, you also create another event loop. Libev itself does no locking
186     whatsoever, so if you mix calls to the same event loop in different
187     threads, make sure you lock (this is usually a bad idea, though, even if
188 root 1.9 done correctly, because it's hideous and inefficient).
189 root 1.1
190     =over 4
191    
192     =item struct ev_loop *ev_default_loop (unsigned int flags)
193    
194     This will initialise the default event loop if it hasn't been initialised
195     yet and return it. If the default loop could not be initialised, returns
196     false. If it already was initialised it simply returns it (and ignores the
197 root 1.31 flags. If that is troubling you, check C<ev_backend ()> afterwards).
198 root 1.1
199     If you don't know what event loop to use, use the one returned from this
200     function.
201    
202     The flags argument can be used to specify special behaviour or specific
203 root 1.33 backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>).
204 root 1.1
205 root 1.33 The following flags are supported:
206 root 1.1
207     =over 4
208    
209 root 1.10 =item C<EVFLAG_AUTO>
210 root 1.1
211 root 1.9 The default flags value. Use this if you have no clue (it's the right
212 root 1.1 thing, believe me).
213    
214 root 1.10 =item C<EVFLAG_NOENV>
215 root 1.1
216 root 1.8 If this flag bit is ored into the flag value (or the program runs setuid
217     or setgid) then libev will I<not> look at the environment variable
218     C<LIBEV_FLAGS>. Otherwise (the default), this environment variable will
219     override the flags completely if it is found in the environment. This is
220     useful to try out specific backends to test their performance, or to work
221     around bugs.
222 root 1.1
223 root 1.31 =item C<EVBACKEND_SELECT> (value 1, portable select backend)
224 root 1.1
225 root 1.29 This is your standard select(2) backend. Not I<completely> standard, as
226     libev tries to roll its own fd_set with no limits on the number of fds,
227     but if that fails, expect a fairly low limit on the number of fds when
228     using this backend. It doesn't scale too well (O(highest_fd)), but its usually
229     the fastest backend for a low number of fds.
230 root 1.1
231 root 1.31 =item C<EVBACKEND_POLL> (value 2, poll backend, available everywhere except on windows)
232 root 1.1
233 root 1.29 And this is your standard poll(2) backend. It's more complicated than
234     select, but handles sparse fds better and has no artificial limit on the
235     number of fds you can use (except it will slow down considerably with a
236     lot of inactive fds). It scales similarly to select, i.e. O(total_fds).
237 root 1.1
238 root 1.31 =item C<EVBACKEND_EPOLL> (value 4, Linux)
239 root 1.1
240 root 1.29 For few fds, this backend is a bit little slower than poll and select,
241     but it scales phenomenally better. While poll and select usually scale like
242     O(total_fds) where n is the total number of fds (or the highest fd), epoll scales
243     either O(1) or O(active_fds).
244 root 1.1
245 root 1.29 While stopping and starting an I/O watcher in the same iteration will
246     result in some caching, there is still a syscall per such incident
247     (because the fd could point to a different file description now), so its
248     best to avoid that. Also, dup()ed file descriptors might not work very
249     well if you register events for both fds.
250    
251 root 1.32 Please note that epoll sometimes generates spurious notifications, so you
252     need to use non-blocking I/O or other means to avoid blocking when no data
253     (or space) is available.
254    
255 root 1.31 =item C<EVBACKEND_KQUEUE> (value 8, most BSD clones)
256 root 1.29
257     Kqueue deserves special mention, as at the time of this writing, it
258     was broken on all BSDs except NetBSD (usually it doesn't work with
259     anything but sockets and pipes, except on Darwin, where of course its
260 root 1.33 completely useless). For this reason its not being "autodetected"
261     unless you explicitly specify it explicitly in the flags (i.e. using
262     C<EVBACKEND_KQUEUE>).
263 root 1.29
264     It scales in the same way as the epoll backend, but the interface to the
265     kernel is more efficient (which says nothing about its actual speed, of
266     course). While starting and stopping an I/O watcher does not cause an
267     extra syscall as with epoll, it still adds up to four event changes per
268     incident, so its best to avoid that.
269    
270 root 1.31 =item C<EVBACKEND_DEVPOLL> (value 16, Solaris 8)
271 root 1.29
272     This is not implemented yet (and might never be).
273    
274 root 1.31 =item C<EVBACKEND_PORT> (value 32, Solaris 10)
275 root 1.29
276     This uses the Solaris 10 port mechanism. As with everything on Solaris,
277     it's really slow, but it still scales very well (O(active_fds)).
278    
279 root 1.32 Please note that solaris ports can result in a lot of spurious
280     notifications, so you need to use non-blocking I/O or other means to avoid
281     blocking when no data (or space) is available.
282    
283 root 1.31 =item C<EVBACKEND_ALL>
284 root 1.29
285     Try all backends (even potentially broken ones that wouldn't be tried
286     with C<EVFLAG_AUTO>). Since this is a mask, you can do stuff such as
287 root 1.31 C<EVBACKEND_ALL & ~EVBACKEND_KQUEUE>.
288 root 1.1
289     =back
290    
291 root 1.29 If one or more of these are ored into the flags value, then only these
292     backends will be tried (in the reverse order as given here). If none are
293     specified, most compiled-in backend will be tried, usually in reverse
294     order of their flag values :)
295    
296 root 1.33 The most typical usage is like this:
297    
298     if (!ev_default_loop (0))
299     fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
300    
301     Restrict libev to the select and poll backends, and do not allow
302     environment settings to be taken into account:
303    
304     ev_default_loop (EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV);
305    
306     Use whatever libev has to offer, but make sure that kqueue is used if
307     available (warning, breaks stuff, best use only with your own private
308     event loop and only if you know the OS supports your types of fds):
309    
310     ev_default_loop (ev_recommended_backends () | EVBACKEND_KQUEUE);
311    
312 root 1.1 =item struct ev_loop *ev_loop_new (unsigned int flags)
313    
314     Similar to C<ev_default_loop>, but always creates a new event loop that is
315     always distinct from the default loop. Unlike the default loop, it cannot
316     handle signal and child watchers, and attempts to do so will be greeted by
317     undefined behaviour (or a failed assertion if assertions are enabled).
318    
319 root 1.34 Example: try to create a event loop that uses epoll and nothing else.
320    
321     struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
322     if (!epoller)
323     fatal ("no epoll found here, maybe it hides under your chair");
324    
325 root 1.1 =item ev_default_destroy ()
326    
327     Destroys the default loop again (frees all memory and kernel state
328 root 1.37 etc.). None of the active event watchers will be stopped in the normal
329     sense, so e.g. C<ev_is_active> might still return true. It is your
330     responsibility to either stop all watchers cleanly yoursef I<before>
331     calling this function, or cope with the fact afterwards (which is usually
332     the easiest thing, youc na just ignore the watchers and/or C<free ()> them
333     for example).
334 root 1.1
335     =item ev_loop_destroy (loop)
336    
337     Like C<ev_default_destroy>, but destroys an event loop created by an
338     earlier call to C<ev_loop_new>.
339    
340     =item ev_default_fork ()
341    
342     This function reinitialises the kernel state for backends that have
343     one. Despite the name, you can call it anytime, but it makes most sense
344     after forking, in either the parent or child process (or both, but that
345     again makes little sense).
346    
347 root 1.30 You I<must> call this function in the child process after forking if and
348     only if you want to use the event library in both processes. If you just
349     fork+exec, you don't have to call it.
350 root 1.1
351 root 1.9 The function itself is quite fast and it's usually not a problem to call
352 root 1.1 it just in case after a fork. To make this easy, the function will fit in
353     quite nicely into a call to C<pthread_atfork>:
354    
355     pthread_atfork (0, 0, ev_default_fork);
356    
357 root 1.31 At the moment, C<EVBACKEND_SELECT> and C<EVBACKEND_POLL> are safe to use
358     without calling this function, so if you force one of those backends you
359     do not need to care.
360    
361 root 1.1 =item ev_loop_fork (loop)
362    
363     Like C<ev_default_fork>, but acts on an event loop created by
364     C<ev_loop_new>. Yes, you have to call this on every allocated event loop
365     after fork, and how you do this is entirely your own problem.
366    
367 root 1.31 =item unsigned int ev_backend (loop)
368 root 1.1
369 root 1.31 Returns one of the C<EVBACKEND_*> flags indicating the event backend in
370 root 1.1 use.
371    
372 root 1.9 =item ev_tstamp ev_now (loop)
373 root 1.1
374     Returns the current "event loop time", which is the time the event loop
375 root 1.34 received events and started processing them. This timestamp does not
376     change as long as callbacks are being processed, and this is also the base
377     time used for relative timers. You can treat it as the timestamp of the
378     event occuring (or more correctly, libev finding out about it).
379 root 1.1
380     =item ev_loop (loop, int flags)
381    
382     Finally, this is it, the event handler. This function usually is called
383     after you initialised all your watchers and you want to start handling
384     events.
385    
386 root 1.33 If the flags argument is specified as C<0>, it will not return until
387     either no event watchers are active anymore or C<ev_unloop> was called.
388 root 1.1
389 root 1.34 Please note that an explicit C<ev_unloop> is usually better than
390     relying on all watchers to be stopped when deciding when a program has
391     finished (especially in interactive programs), but having a program that
392     automatically loops as long as it has to and no longer by virtue of
393     relying on its watchers stopping correctly is a thing of beauty.
394    
395 root 1.1 A flags value of C<EVLOOP_NONBLOCK> will look for new events, will handle
396     those events and any outstanding ones, but will not block your process in
397 root 1.9 case there are no events and will return after one iteration of the loop.
398 root 1.1
399     A flags value of C<EVLOOP_ONESHOT> will look for new events (waiting if
400     neccessary) and will handle those and any outstanding ones. It will block
401 root 1.9 your process until at least one new event arrives, and will return after
402 root 1.33 one iteration of the loop. This is useful if you are waiting for some
403     external event in conjunction with something not expressible using other
404     libev watchers. However, a pair of C<ev_prepare>/C<ev_check> watchers is
405     usually a better approach for this kind of thing.
406    
407     Here are the gory details of what C<ev_loop> does:
408    
409     * If there are no active watchers (reference count is zero), return.
410     - Queue prepare watchers and then call all outstanding watchers.
411     - If we have been forked, recreate the kernel state.
412     - Update the kernel state with all outstanding changes.
413     - Update the "event loop time".
414     - Calculate for how long to block.
415     - Block the process, waiting for any events.
416     - Queue all outstanding I/O (fd) events.
417     - Update the "event loop time" and do time jump handling.
418     - Queue all outstanding timers.
419     - Queue all outstanding periodics.
420     - If no events are pending now, queue all idle watchers.
421     - Queue all check watchers.
422     - Call all queued watchers in reverse order (i.e. check watchers first).
423     Signals and child watchers are implemented as I/O watchers, and will
424     be handled here by queueing them when their watcher gets executed.
425     - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
426     were used, return, otherwise continue with step *.
427 root 1.27
428 root 1.34 Example: queue some jobs and then loop until no events are outsanding
429     anymore.
430    
431     ... queue jobs here, make sure they register event watchers as long
432     ... as they still have work to do (even an idle watcher will do..)
433     ev_loop (my_loop, 0);
434     ... jobs done. yeah!
435    
436 root 1.1 =item ev_unloop (loop, how)
437    
438 root 1.9 Can be used to make a call to C<ev_loop> return early (but only after it
439     has processed all outstanding events). The C<how> argument must be either
440 root 1.25 C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or
441 root 1.9 C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return.
442 root 1.1
443     =item ev_ref (loop)
444    
445     =item ev_unref (loop)
446    
447 root 1.9 Ref/unref can be used to add or remove a reference count on the event
448     loop: Every watcher keeps one reference, and as long as the reference
449     count is nonzero, C<ev_loop> will not return on its own. If you have
450     a watcher you never unregister that should not keep C<ev_loop> from
451     returning, ev_unref() after starting, and ev_ref() before stopping it. For
452     example, libev itself uses this for its internal signal pipe: It is not
453     visible to the libev user and should not keep C<ev_loop> from exiting if
454     no event watchers registered by it are active. It is also an excellent
455     way to do this for generic recurring timers or from within third-party
456     libraries. Just remember to I<unref after start> and I<ref before stop>.
457 root 1.1
458 root 1.34 Example: create a signal watcher, but keep it from keeping C<ev_loop>
459     running when nothing else is active.
460    
461     struct dv_signal exitsig;
462     ev_signal_init (&exitsig, sig_cb, SIGINT);
463     ev_signal_start (myloop, &exitsig);
464     evf_unref (myloop);
465    
466     Example: for some weird reason, unregister the above signal handler again.
467    
468     ev_ref (myloop);
469     ev_signal_stop (myloop, &exitsig);
470    
471 root 1.1 =back
472    
473     =head1 ANATOMY OF A WATCHER
474    
475     A watcher is a structure that you create and register to record your
476     interest in some event. For instance, if you want to wait for STDIN to
477 root 1.10 become readable, you would create an C<ev_io> watcher for that:
478 root 1.1
479     static void my_cb (struct ev_loop *loop, struct ev_io *w, int revents)
480     {
481     ev_io_stop (w);
482     ev_unloop (loop, EVUNLOOP_ALL);
483     }
484    
485     struct ev_loop *loop = ev_default_loop (0);
486     struct ev_io stdin_watcher;
487     ev_init (&stdin_watcher, my_cb);
488     ev_io_set (&stdin_watcher, STDIN_FILENO, EV_READ);
489     ev_io_start (loop, &stdin_watcher);
490     ev_loop (loop, 0);
491    
492     As you can see, you are responsible for allocating the memory for your
493     watcher structures (and it is usually a bad idea to do this on the stack,
494     although this can sometimes be quite valid).
495    
496     Each watcher structure must be initialised by a call to C<ev_init
497     (watcher *, callback)>, which expects a callback to be provided. This
498     callback gets invoked each time the event occurs (or, in the case of io
499     watchers, each time the event loop detects that the file descriptor given
500     is readable and/or writable).
501    
502     Each watcher type has its own C<< ev_<type>_set (watcher *, ...) >> macro
503     with arguments specific to this watcher type. There is also a macro
504     to combine initialisation and setting in one call: C<< ev_<type>_init
505     (watcher *, callback, ...) >>.
506    
507     To make the watcher actually watch out for events, you have to start it
508     with a watcher-specific start function (C<< ev_<type>_start (loop, watcher
509     *) >>), and you can stop watching for events at any time by calling the
510     corresponding stop function (C<< ev_<type>_stop (loop, watcher *) >>.
511    
512     As long as your watcher is active (has been started but not stopped) you
513     must not touch the values stored in it. Most specifically you must never
514 root 1.36 reinitialise it or call its C<set> macro.
515 root 1.1
516     Each and every callback receives the event loop pointer as first, the
517     registered watcher structure as second, and a bitset of received events as
518     third argument.
519    
520 root 1.14 The received events usually include a single bit per event type received
521 root 1.1 (you can receive multiple events at the same time). The possible bit masks
522     are:
523    
524     =over 4
525    
526 root 1.10 =item C<EV_READ>
527 root 1.1
528 root 1.10 =item C<EV_WRITE>
529 root 1.1
530 root 1.10 The file descriptor in the C<ev_io> watcher has become readable and/or
531 root 1.1 writable.
532    
533 root 1.10 =item C<EV_TIMEOUT>
534 root 1.1
535 root 1.10 The C<ev_timer> watcher has timed out.
536 root 1.1
537 root 1.10 =item C<EV_PERIODIC>
538 root 1.1
539 root 1.10 The C<ev_periodic> watcher has timed out.
540 root 1.1
541 root 1.10 =item C<EV_SIGNAL>
542 root 1.1
543 root 1.10 The signal specified in the C<ev_signal> watcher has been received by a thread.
544 root 1.1
545 root 1.10 =item C<EV_CHILD>
546 root 1.1
547 root 1.10 The pid specified in the C<ev_child> watcher has received a status change.
548 root 1.1
549 root 1.10 =item C<EV_IDLE>
550 root 1.1
551 root 1.10 The C<ev_idle> watcher has determined that you have nothing better to do.
552 root 1.1
553 root 1.10 =item C<EV_PREPARE>
554 root 1.1
555 root 1.10 =item C<EV_CHECK>
556 root 1.1
557 root 1.10 All C<ev_prepare> watchers are invoked just I<before> C<ev_loop> starts
558     to gather new events, and all C<ev_check> watchers are invoked just after
559 root 1.1 C<ev_loop> has gathered them, but before it invokes any callbacks for any
560     received events. Callbacks of both watcher types can start and stop as
561     many watchers as they want, and all of them will be taken into account
562 root 1.10 (for example, a C<ev_prepare> watcher might start an idle watcher to keep
563 root 1.1 C<ev_loop> from blocking).
564    
565 root 1.10 =item C<EV_ERROR>
566 root 1.1
567     An unspecified error has occured, the watcher has been stopped. This might
568     happen because the watcher could not be properly started because libev
569     ran out of memory, a file descriptor was found to be closed or any other
570     problem. You best act on it by reporting the problem and somehow coping
571     with the watcher being stopped.
572    
573     Libev will usually signal a few "dummy" events together with an error,
574     for example it might indicate that a fd is readable or writable, and if
575     your callbacks is well-written it can just attempt the operation and cope
576     with the error from read() or write(). This will not work in multithreaded
577     programs, though, so beware.
578    
579     =back
580    
581 root 1.36 =head2 SUMMARY OF GENERIC WATCHER FUNCTIONS
582    
583     In the following description, C<TYPE> stands for the watcher type,
584     e.g. C<timer> for C<ev_timer> watchers and C<io> for C<ev_io> watchers.
585    
586     =over 4
587    
588     =item C<ev_init> (ev_TYPE *watcher, callback)
589    
590     This macro initialises the generic portion of a watcher. The contents
591     of the watcher object can be arbitrary (so C<malloc> will do). Only
592     the generic parts of the watcher are initialised, you I<need> to call
593     the type-specific C<ev_TYPE_set> macro afterwards to initialise the
594     type-specific parts. For each type there is also a C<ev_TYPE_init> macro
595     which rolls both calls into one.
596    
597     You can reinitialise a watcher at any time as long as it has been stopped
598     (or never started) and there are no pending events outstanding.
599    
600     The callbakc is always of type C<void (*)(ev_loop *loop, ev_TYPE *watcher,
601     int revents)>.
602    
603     =item C<ev_TYPE_set> (ev_TYPE *, [args])
604    
605     This macro initialises the type-specific parts of a watcher. You need to
606     call C<ev_init> at least once before you call this macro, but you can
607     call C<ev_TYPE_set> any number of times. You must not, however, call this
608     macro on a watcher that is active (it can be pending, however, which is a
609     difference to the C<ev_init> macro).
610    
611     Although some watcher types do not have type-specific arguments
612     (e.g. C<ev_prepare>) you still need to call its C<set> macro.
613    
614     =item C<ev_TYPE_init> (ev_TYPE *watcher, callback, [args])
615    
616     This convinience macro rolls both C<ev_init> and C<ev_TYPE_set> macro
617     calls into a single call. This is the most convinient method to initialise
618     a watcher. The same limitations apply, of course.
619    
620     =item C<ev_TYPE_start> (loop *, ev_TYPE *watcher)
621    
622     Starts (activates) the given watcher. Only active watchers will receive
623     events. If the watcher is already active nothing will happen.
624    
625     =item C<ev_TYPE_stop> (loop *, ev_TYPE *watcher)
626    
627     Stops the given watcher again (if active) and clears the pending
628     status. It is possible that stopped watchers are pending (for example,
629     non-repeating timers are being stopped when they become pending), but
630     C<ev_TYPE_stop> ensures that the watcher is neither active nor pending. If
631     you want to free or reuse the memory used by the watcher it is therefore a
632     good idea to always call its C<ev_TYPE_stop> function.
633    
634     =item bool ev_is_active (ev_TYPE *watcher)
635    
636     Returns a true value iff the watcher is active (i.e. it has been started
637     and not yet been stopped). As long as a watcher is active you must not modify
638     it.
639    
640     =item bool ev_is_pending (ev_TYPE *watcher)
641    
642     Returns a true value iff the watcher is pending, (i.e. it has outstanding
643     events but its callback has not yet been invoked). As long as a watcher
644     is pending (but not active) you must not call an init function on it (but
645     C<ev_TYPE_set> is safe) and you must make sure the watcher is available to
646     libev (e.g. you cnanot C<free ()> it).
647    
648     =item callback = ev_cb (ev_TYPE *watcher)
649    
650     Returns the callback currently set on the watcher.
651    
652     =item ev_cb_set (ev_TYPE *watcher, callback)
653    
654     Change the callback. You can change the callback at virtually any time
655     (modulo threads).
656    
657     =back
658    
659    
660 root 1.1 =head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
661    
662     Each watcher has, by default, a member C<void *data> that you can change
663 root 1.14 and read at any time, libev will completely ignore it. This can be used
664 root 1.1 to associate arbitrary data with your watcher. If you need more data and
665     don't want to allocate memory and store a pointer to it in that data
666     member, you can also "subclass" the watcher type and provide your own
667     data:
668    
669     struct my_io
670     {
671     struct ev_io io;
672     int otherfd;
673     void *somedata;
674     struct whatever *mostinteresting;
675     }
676    
677     And since your callback will be called with a pointer to the watcher, you
678     can cast it back to your own type:
679    
680     static void my_cb (struct ev_loop *loop, struct ev_io *w_, int revents)
681     {
682     struct my_io *w = (struct my_io *)w_;
683     ...
684     }
685    
686     More interesting and less C-conformant ways of catsing your callback type
687     have been omitted....
688    
689    
690     =head1 WATCHER TYPES
691    
692     This section describes each watcher in detail, but will not repeat
693     information given in the last section.
694    
695 root 1.34
696 root 1.11 =head2 C<ev_io> - is this file descriptor readable or writable
697 root 1.1
698 root 1.4 I/O watchers check whether a file descriptor is readable or writable
699 root 1.1 in each iteration of the event loop (This behaviour is called
700     level-triggering because you keep receiving events as long as the
701 root 1.14 condition persists. Remember you can stop the watcher if you don't want to
702 root 1.1 act on the event and neither want to receive future events).
703    
704 root 1.23 In general you can register as many read and/or write event watchers per
705 root 1.8 fd as you want (as long as you don't confuse yourself). Setting all file
706     descriptors to non-blocking mode is also usually a good idea (but not
707     required if you know what you are doing).
708    
709     You have to be careful with dup'ed file descriptors, though. Some backends
710     (the linux epoll backend is a notable example) cannot handle dup'ed file
711     descriptors correctly if you register interest in two or more fds pointing
712 root 1.24 to the same underlying file/socket etc. description (that is, they share
713     the same underlying "file open").
714 root 1.8
715     If you must do this, then force the use of a known-to-be-good backend
716 root 1.31 (at the time of this writing, this includes only C<EVBACKEND_SELECT> and
717     C<EVBACKEND_POLL>).
718 root 1.8
719 root 1.1 =over 4
720    
721     =item ev_io_init (ev_io *, callback, int fd, int events)
722    
723     =item ev_io_set (ev_io *, int fd, int events)
724    
725 root 1.10 Configures an C<ev_io> watcher. The fd is the file descriptor to rceeive
726 root 1.1 events for and events is either C<EV_READ>, C<EV_WRITE> or C<EV_READ |
727     EV_WRITE> to receive the given events.
728    
729 root 1.32 Please note that most of the more scalable backend mechanisms (for example
730     epoll and solaris ports) can result in spurious readyness notifications
731     for file descriptors, so you practically need to use non-blocking I/O (and
732     treat callback invocation as hint only), or retest separately with a safe
733     interface before doing I/O (XLib can do this), or force the use of either
734     C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>, which don't suffer from this
735     problem. Also note that it is quite easy to have your callback invoked
736     when the readyness condition is no longer valid even when employing
737     typical ways of handling events, so its a good idea to use non-blocking
738     I/O unconditionally.
739    
740 root 1.1 =back
741    
742 root 1.34 Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well
743     readable, but only once. Since it is likely line-buffered, you could
744     attempt to read a whole line in the callback:
745    
746     static void
747     stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents)
748     {
749     ev_io_stop (loop, w);
750     .. read from stdin here (or from w->fd) and haqndle any I/O errors
751     }
752    
753     ...
754     struct ev_loop *loop = ev_default_init (0);
755     struct ev_io stdin_readable;
756     ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ);
757     ev_io_start (loop, &stdin_readable);
758     ev_loop (loop, 0);
759    
760    
761 root 1.10 =head2 C<ev_timer> - relative and optionally recurring timeouts
762 root 1.1
763     Timer watchers are simple relative timers that generate an event after a
764     given time, and optionally repeating in regular intervals after that.
765    
766     The timers are based on real time, that is, if you register an event that
767 root 1.22 times out after an hour and you reset your system clock to last years
768 root 1.1 time, it will still time out after (roughly) and hour. "Roughly" because
769 root 1.28 detecting time jumps is hard, and some inaccuracies are unavoidable (the
770 root 1.1 monotonic clock option helps a lot here).
771    
772 root 1.9 The relative timeouts are calculated relative to the C<ev_now ()>
773     time. This is usually the right thing as this timestamp refers to the time
774 root 1.28 of the event triggering whatever timeout you are modifying/starting. If
775     you suspect event processing to be delayed and you I<need> to base the timeout
776 root 1.22 on the current time, use something like this to adjust for this:
777 root 1.9
778     ev_timer_set (&timer, after + ev_now () - ev_time (), 0.);
779    
780 root 1.28 The callback is guarenteed to be invoked only when its timeout has passed,
781     but if multiple timers become ready during the same loop iteration then
782     order of execution is undefined.
783    
784 root 1.1 =over 4
785    
786     =item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
787    
788     =item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
789    
790     Configure the timer to trigger after C<after> seconds. If C<repeat> is
791     C<0.>, then it will automatically be stopped. If it is positive, then the
792     timer will automatically be configured to trigger again C<repeat> seconds
793     later, again, and again, until stopped manually.
794    
795     The timer itself will do a best-effort at avoiding drift, that is, if you
796     configure a timer to trigger every 10 seconds, then it will trigger at
797     exactly 10 second intervals. If, however, your program cannot keep up with
798 root 1.22 the timer (because it takes longer than those 10 seconds to do stuff) the
799 root 1.1 timer will not fire more than once per event loop iteration.
800    
801     =item ev_timer_again (loop)
802    
803     This will act as if the timer timed out and restart it again if it is
804     repeating. The exact semantics are:
805    
806     If the timer is started but nonrepeating, stop it.
807    
808     If the timer is repeating, either start it if necessary (with the repeat
809     value), or reset the running timer to the repeat value.
810    
811     This sounds a bit complicated, but here is a useful and typical
812     example: Imagine you have a tcp connection and you want a so-called idle
813     timeout, that is, you want to be called when there have been, say, 60
814     seconds of inactivity on the socket. The easiest way to do this is to
815 root 1.10 configure an C<ev_timer> with after=repeat=60 and calling ev_timer_again each
816 root 1.1 time you successfully read or write some data. If you go into an idle
817     state where you do not expect data to travel on the socket, you can stop
818     the timer, and again will automatically restart it if need be.
819    
820     =back
821    
822 root 1.34 Example: create a timer that fires after 60 seconds.
823    
824     static void
825     one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
826     {
827     .. one minute over, w is actually stopped right here
828     }
829    
830     struct ev_timer mytimer;
831     ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
832     ev_timer_start (loop, &mytimer);
833    
834     Example: create a timeout timer that times out after 10 seconds of
835     inactivity.
836    
837     static void
838     timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
839     {
840     .. ten seconds without any activity
841     }
842    
843     struct ev_timer mytimer;
844     ev_timer_init (&mytimer, timeout_cb, 0., 10.); /* note, only repeat used */
845     ev_timer_again (&mytimer); /* start timer */
846     ev_loop (loop, 0);
847    
848     // and in some piece of code that gets executed on any "activity":
849     // reset the timeout to start ticking again at 10 seconds
850     ev_timer_again (&mytimer);
851    
852    
853 root 1.14 =head2 C<ev_periodic> - to cron or not to cron
854 root 1.1
855     Periodic watchers are also timers of a kind, but they are very versatile
856     (and unfortunately a bit complex).
857    
858 root 1.10 Unlike C<ev_timer>'s, they are not based on real time (or relative time)
859 root 1.1 but on wallclock time (absolute time). You can tell a periodic watcher
860     to trigger "at" some specific point in time. For example, if you tell a
861 root 1.38 periodic watcher to trigger in 10 seconds (by specifiying e.g. C<ev_now ()
862 root 1.1 + 10.>) and then reset your system clock to the last year, then it will
863 root 1.10 take a year to trigger the event (unlike an C<ev_timer>, which would trigger
864 root 1.1 roughly 10 seconds later and of course not if you reset your system time
865     again).
866    
867     They can also be used to implement vastly more complex timers, such as
868     triggering an event on eahc midnight, local time.
869    
870 root 1.28 As with timers, the callback is guarenteed to be invoked only when the
871     time (C<at>) has been passed, but if multiple periodic timers become ready
872     during the same loop iteration then order of execution is undefined.
873    
874 root 1.1 =over 4
875    
876     =item ev_periodic_init (ev_periodic *, callback, ev_tstamp at, ev_tstamp interval, reschedule_cb)
877    
878     =item ev_periodic_set (ev_periodic *, ev_tstamp after, ev_tstamp repeat, reschedule_cb)
879    
880     Lots of arguments, lets sort it out... There are basically three modes of
881     operation, and we will explain them from simplest to complex:
882    
883     =over 4
884    
885     =item * absolute timer (interval = reschedule_cb = 0)
886    
887     In this configuration the watcher triggers an event at the wallclock time
888     C<at> and doesn't repeat. It will not adjust when a time jump occurs,
889     that is, if it is to be run at January 1st 2011 then it will run when the
890     system time reaches or surpasses this time.
891    
892     =item * non-repeating interval timer (interval > 0, reschedule_cb = 0)
893    
894     In this mode the watcher will always be scheduled to time out at the next
895     C<at + N * interval> time (for some integer N) and then repeat, regardless
896     of any time jumps.
897    
898     This can be used to create timers that do not drift with respect to system
899     time:
900    
901     ev_periodic_set (&periodic, 0., 3600., 0);
902    
903     This doesn't mean there will always be 3600 seconds in between triggers,
904     but only that the the callback will be called when the system time shows a
905 root 1.12 full hour (UTC), or more correctly, when the system time is evenly divisible
906 root 1.1 by 3600.
907    
908     Another way to think about it (for the mathematically inclined) is that
909 root 1.10 C<ev_periodic> will try to run the callback in this mode at the next possible
910 root 1.1 time where C<time = at (mod interval)>, regardless of any time jumps.
911    
912     =item * manual reschedule mode (reschedule_cb = callback)
913    
914     In this mode the values for C<interval> and C<at> are both being
915     ignored. Instead, each time the periodic watcher gets scheduled, the
916     reschedule callback will be called with the watcher as first, and the
917     current time as second argument.
918    
919 root 1.18 NOTE: I<This callback MUST NOT stop or destroy any periodic watcher,
920     ever, or make any event loop modifications>. If you need to stop it,
921     return C<now + 1e30> (or so, fudge fudge) and stop it afterwards (e.g. by
922     starting a prepare watcher).
923 root 1.1
924 root 1.13 Its prototype is C<ev_tstamp (*reschedule_cb)(struct ev_periodic *w,
925 root 1.1 ev_tstamp now)>, e.g.:
926    
927     static ev_tstamp my_rescheduler (struct ev_periodic *w, ev_tstamp now)
928     {
929     return now + 60.;
930     }
931    
932     It must return the next time to trigger, based on the passed time value
933     (that is, the lowest time value larger than to the second argument). It
934     will usually be called just before the callback will be triggered, but
935     might be called at other times, too.
936    
937 root 1.18 NOTE: I<< This callback must always return a time that is later than the
938 root 1.19 passed C<now> value >>. Not even C<now> itself will do, it I<must> be larger.
939 root 1.18
940 root 1.1 This can be used to create very complex timers, such as a timer that
941     triggers on each midnight, local time. To do this, you would calculate the
942 root 1.19 next midnight after C<now> and return the timestamp value for this. How
943     you do this is, again, up to you (but it is not trivial, which is the main
944     reason I omitted it as an example).
945 root 1.1
946     =back
947    
948     =item ev_periodic_again (loop, ev_periodic *)
949    
950     Simply stops and restarts the periodic watcher again. This is only useful
951     when you changed some parameters or the reschedule callback would return
952     a different time than the last time it was called (e.g. in a crond like
953     program when the crontabs have changed).
954    
955     =back
956    
957 root 1.34 Example: call a callback every hour, or, more precisely, whenever the
958     system clock is divisible by 3600. The callback invocation times have
959     potentially a lot of jittering, but good long-term stability.
960    
961     static void
962     clock_cb (struct ev_loop *loop, struct ev_io *w, int revents)
963     {
964     ... its now a full hour (UTC, or TAI or whatever your clock follows)
965     }
966    
967     struct ev_periodic hourly_tick;
968     ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
969     ev_periodic_start (loop, &hourly_tick);
970    
971     Example: the same as above, but use a reschedule callback to do it:
972    
973     #include <math.h>
974    
975     static ev_tstamp
976     my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)
977     {
978     return fmod (now, 3600.) + 3600.;
979     }
980    
981     ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
982    
983     Example: call a callback every hour, starting now:
984    
985     struct ev_periodic hourly_tick;
986     ev_periodic_init (&hourly_tick, clock_cb,
987     fmod (ev_now (loop), 3600.), 3600., 0);
988     ev_periodic_start (loop, &hourly_tick);
989    
990    
991 root 1.10 =head2 C<ev_signal> - signal me when a signal gets signalled
992 root 1.1
993     Signal watchers will trigger an event when the process receives a specific
994     signal one or more times. Even though signals are very asynchronous, libev
995 root 1.9 will try it's best to deliver signals synchronously, i.e. as part of the
996 root 1.1 normal event processing, like any other event.
997    
998 root 1.14 You can configure as many watchers as you like per signal. Only when the
999 root 1.1 first watcher gets started will libev actually register a signal watcher
1000     with the kernel (thus it coexists with your own signal handlers as long
1001     as you don't register any with libev). Similarly, when the last signal
1002     watcher for a signal is stopped libev will reset the signal handler to
1003     SIG_DFL (regardless of what it was set to before).
1004    
1005     =over 4
1006    
1007     =item ev_signal_init (ev_signal *, callback, int signum)
1008    
1009     =item ev_signal_set (ev_signal *, int signum)
1010    
1011     Configures the watcher to trigger on the given signal number (usually one
1012     of the C<SIGxxx> constants).
1013    
1014     =back
1015    
1016 root 1.35
1017 root 1.10 =head2 C<ev_child> - wait for pid status changes
1018 root 1.1
1019     Child watchers trigger when your process receives a SIGCHLD in response to
1020     some child status changes (most typically when a child of yours dies).
1021    
1022     =over 4
1023    
1024     =item ev_child_init (ev_child *, callback, int pid)
1025    
1026     =item ev_child_set (ev_child *, int pid)
1027    
1028     Configures the watcher to wait for status changes of process C<pid> (or
1029     I<any> process if C<pid> is specified as C<0>). The callback can look
1030     at the C<rstatus> member of the C<ev_child> watcher structure to see
1031 root 1.14 the status word (use the macros from C<sys/wait.h> and see your systems
1032     C<waitpid> documentation). The C<rpid> member contains the pid of the
1033     process causing the status change.
1034 root 1.1
1035     =back
1036    
1037 root 1.34 Example: try to exit cleanly on SIGINT and SIGTERM.
1038    
1039     static void
1040     sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1041     {
1042     ev_unloop (loop, EVUNLOOP_ALL);
1043     }
1044    
1045     struct ev_signal signal_watcher;
1046     ev_signal_init (&signal_watcher, sigint_cb, SIGINT);
1047     ev_signal_start (loop, &sigint_cb);
1048    
1049    
1050 root 1.10 =head2 C<ev_idle> - when you've got nothing better to do
1051 root 1.1
1052 root 1.14 Idle watchers trigger events when there are no other events are pending
1053     (prepare, check and other idle watchers do not count). That is, as long
1054     as your process is busy handling sockets or timeouts (or even signals,
1055     imagine) it will not be triggered. But when your process is idle all idle
1056     watchers are being called again and again, once per event loop iteration -
1057     until stopped, that is, or your process receives more events and becomes
1058     busy.
1059 root 1.1
1060     The most noteworthy effect is that as long as any idle watchers are
1061     active, the process will not block when waiting for new events.
1062    
1063     Apart from keeping your process non-blocking (which is a useful
1064     effect on its own sometimes), idle watchers are a good place to do
1065     "pseudo-background processing", or delay processing stuff to after the
1066     event loop has handled all outstanding events.
1067    
1068     =over 4
1069    
1070     =item ev_idle_init (ev_signal *, callback)
1071    
1072     Initialises and configures the idle watcher - it has no parameters of any
1073     kind. There is a C<ev_idle_set> macro, but using it is utterly pointless,
1074     believe me.
1075    
1076     =back
1077    
1078 root 1.34 Example: dynamically allocate an C<ev_idle>, start it, and in the
1079     callback, free it. Alos, use no error checking, as usual.
1080    
1081     static void
1082     idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1083     {
1084     free (w);
1085     // now do something you wanted to do when the program has
1086     // no longer asnything immediate to do.
1087     }
1088    
1089     struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));
1090     ev_idle_init (idle_watcher, idle_cb);
1091     ev_idle_start (loop, idle_cb);
1092    
1093    
1094 root 1.16 =head2 C<ev_prepare> and C<ev_check> - customise your event loop
1095 root 1.1
1096 root 1.14 Prepare and check watchers are usually (but not always) used in tandem:
1097 root 1.20 prepare watchers get invoked before the process blocks and check watchers
1098 root 1.14 afterwards.
1099 root 1.1
1100 root 1.35 Their main purpose is to integrate other event mechanisms into libev and
1101     their use is somewhat advanced. This could be used, for example, to track
1102     variable changes, implement your own watchers, integrate net-snmp or a
1103     coroutine library and lots more.
1104 root 1.1
1105     This is done by examining in each prepare call which file descriptors need
1106 root 1.14 to be watched by the other library, registering C<ev_io> watchers for
1107     them and starting an C<ev_timer> watcher for any timeouts (many libraries
1108     provide just this functionality). Then, in the check watcher you check for
1109     any events that occured (by checking the pending status of all watchers
1110     and stopping them) and call back into the library. The I/O and timer
1111 root 1.20 callbacks will never actually be called (but must be valid nevertheless,
1112 root 1.14 because you never know, you know?).
1113 root 1.1
1114 root 1.14 As another example, the Perl Coro module uses these hooks to integrate
1115 root 1.1 coroutines into libev programs, by yielding to other active coroutines
1116     during each prepare and only letting the process block if no coroutines
1117 root 1.20 are ready to run (it's actually more complicated: it only runs coroutines
1118     with priority higher than or equal to the event loop and one coroutine
1119     of lower priority, but only once, using idle watchers to keep the event
1120     loop from blocking if lower-priority coroutines are active, thus mapping
1121     low-priority coroutines to idle/background tasks).
1122 root 1.1
1123     =over 4
1124    
1125     =item ev_prepare_init (ev_prepare *, callback)
1126    
1127     =item ev_check_init (ev_check *, callback)
1128    
1129     Initialises and configures the prepare or check watcher - they have no
1130     parameters of any kind. There are C<ev_prepare_set> and C<ev_check_set>
1131 root 1.14 macros, but using them is utterly, utterly and completely pointless.
1132 root 1.1
1133     =back
1134    
1135 root 1.34 Example: *TODO*.
1136    
1137    
1138 root 1.35 =head2 C<ev_embed> - when one backend isn't enough
1139    
1140     This is a rather advanced watcher type that lets you embed one event loop
1141 root 1.36 into another (currently only C<ev_io> events are supported in the embedded
1142     loop, other types of watchers might be handled in a delayed or incorrect
1143     fashion and must not be used).
1144 root 1.35
1145     There are primarily two reasons you would want that: work around bugs and
1146     prioritise I/O.
1147    
1148     As an example for a bug workaround, the kqueue backend might only support
1149     sockets on some platform, so it is unusable as generic backend, but you
1150     still want to make use of it because you have many sockets and it scales
1151     so nicely. In this case, you would create a kqueue-based loop and embed it
1152     into your default loop (which might use e.g. poll). Overall operation will
1153     be a bit slower because first libev has to poll and then call kevent, but
1154     at least you can use both at what they are best.
1155    
1156     As for prioritising I/O: rarely you have the case where some fds have
1157     to be watched and handled very quickly (with low latency), and even
1158     priorities and idle watchers might have too much overhead. In this case
1159     you would put all the high priority stuff in one loop and all the rest in
1160     a second one, and embed the second one in the first.
1161    
1162 root 1.36 As long as the watcher is active, the callback will be invoked every time
1163     there might be events pending in the embedded loop. The callback must then
1164     call C<ev_embed_sweep (mainloop, watcher)> to make a single sweep and invoke
1165     their callbacks (you could also start an idle watcher to give the embedded
1166     loop strictly lower priority for example). You can also set the callback
1167     to C<0>, in which case the embed watcher will automatically execute the
1168     embedded loop sweep.
1169    
1170 root 1.35 As long as the watcher is started it will automatically handle events. The
1171     callback will be invoked whenever some events have been handled. You can
1172     set the callback to C<0> to avoid having to specify one if you are not
1173     interested in that.
1174    
1175     Also, there have not currently been made special provisions for forking:
1176     when you fork, you not only have to call C<ev_loop_fork> on both loops,
1177     but you will also have to stop and restart any C<ev_embed> watchers
1178     yourself.
1179    
1180     Unfortunately, not all backends are embeddable, only the ones returned by
1181     C<ev_embeddable_backends> are, which, unfortunately, does not include any
1182     portable one.
1183    
1184     So when you want to use this feature you will always have to be prepared
1185     that you cannot get an embeddable loop. The recommended way to get around
1186     this is to have a separate variables for your embeddable loop, try to
1187     create it, and if that fails, use the normal loop for everything:
1188    
1189     struct ev_loop *loop_hi = ev_default_init (0);
1190     struct ev_loop *loop_lo = 0;
1191     struct ev_embed embed;
1192    
1193     // see if there is a chance of getting one that works
1194     // (remember that a flags value of 0 means autodetection)
1195     loop_lo = ev_embeddable_backends () & ev_recommended_backends ()
1196     ? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ())
1197     : 0;
1198    
1199     // if we got one, then embed it, otherwise default to loop_hi
1200     if (loop_lo)
1201     {
1202     ev_embed_init (&embed, 0, loop_lo);
1203     ev_embed_start (loop_hi, &embed);
1204     }
1205     else
1206     loop_lo = loop_hi;
1207    
1208     =over 4
1209    
1210 root 1.36 =item ev_embed_init (ev_embed *, callback, struct ev_loop *embedded_loop)
1211    
1212     =item ev_embed_set (ev_embed *, callback, struct ev_loop *embedded_loop)
1213    
1214     Configures the watcher to embed the given loop, which must be
1215     embeddable. If the callback is C<0>, then C<ev_embed_sweep> will be
1216     invoked automatically, otherwise it is the responsibility of the callback
1217     to invoke it (it will continue to be called until the sweep has been done,
1218     if you do not want thta, you need to temporarily stop the embed watcher).
1219 root 1.35
1220 root 1.36 =item ev_embed_sweep (loop, ev_embed *)
1221 root 1.35
1222 root 1.36 Make a single, non-blocking sweep over the embedded loop. This works
1223     similarly to C<ev_loop (embedded_loop, EVLOOP_NONBLOCK)>, but in the most
1224     apropriate way for embedded loops.
1225 root 1.35
1226     =back
1227    
1228    
1229 root 1.1 =head1 OTHER FUNCTIONS
1230    
1231 root 1.14 There are some other functions of possible interest. Described. Here. Now.
1232 root 1.1
1233     =over 4
1234    
1235     =item ev_once (loop, int fd, int events, ev_tstamp timeout, callback)
1236    
1237     This function combines a simple timer and an I/O watcher, calls your
1238     callback on whichever event happens first and automatically stop both
1239     watchers. This is useful if you want to wait for a single event on an fd
1240 root 1.22 or timeout without having to allocate/configure/start/stop/free one or
1241 root 1.1 more watchers yourself.
1242    
1243 root 1.14 If C<fd> is less than 0, then no I/O watcher will be started and events
1244     is being ignored. Otherwise, an C<ev_io> watcher for the given C<fd> and
1245     C<events> set will be craeted and started.
1246 root 1.1
1247     If C<timeout> is less than 0, then no timeout watcher will be
1248 root 1.14 started. Otherwise an C<ev_timer> watcher with after = C<timeout> (and
1249     repeat = 0) will be started. While C<0> is a valid timeout, it is of
1250     dubious value.
1251    
1252     The callback has the type C<void (*cb)(int revents, void *arg)> and gets
1253 root 1.21 passed an C<revents> set like normal event callbacks (a combination of
1254 root 1.14 C<EV_ERROR>, C<EV_READ>, C<EV_WRITE> or C<EV_TIMEOUT>) and the C<arg>
1255     value passed to C<ev_once>:
1256 root 1.1
1257     static void stdin_ready (int revents, void *arg)
1258     {
1259     if (revents & EV_TIMEOUT)
1260 root 1.14 /* doh, nothing entered */;
1261 root 1.1 else if (revents & EV_READ)
1262 root 1.14 /* stdin might have data for us, joy! */;
1263 root 1.1 }
1264    
1265 root 1.14 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
1266 root 1.1
1267 root 1.36 =item ev_feed_event (ev_loop *, watcher *, int revents)
1268 root 1.1
1269     Feeds the given event set into the event loop, as if the specified event
1270 root 1.14 had happened for the specified watcher (which must be a pointer to an
1271     initialised but not necessarily started event watcher).
1272 root 1.1
1273 root 1.36 =item ev_feed_fd_event (ev_loop *, int fd, int revents)
1274 root 1.1
1275 root 1.14 Feed an event on the given fd, as if a file descriptor backend detected
1276     the given events it.
1277 root 1.1
1278 root 1.36 =item ev_feed_signal_event (ev_loop *loop, int signum)
1279 root 1.1
1280 root 1.36 Feed an event as if the given signal occured (C<loop> must be the default
1281     loop!).
1282 root 1.1
1283     =back
1284    
1285 root 1.34
1286 root 1.20 =head1 LIBEVENT EMULATION
1287    
1288 root 1.24 Libev offers a compatibility emulation layer for libevent. It cannot
1289     emulate the internals of libevent, so here are some usage hints:
1290    
1291     =over 4
1292    
1293     =item * Use it by including <event.h>, as usual.
1294    
1295     =item * The following members are fully supported: ev_base, ev_callback,
1296     ev_arg, ev_fd, ev_res, ev_events.
1297    
1298     =item * Avoid using ev_flags and the EVLIST_*-macros, while it is
1299     maintained by libev, it does not work exactly the same way as in libevent (consider
1300     it a private API).
1301    
1302     =item * Priorities are not currently supported. Initialising priorities
1303     will fail and all watchers will have the same priority, even though there
1304     is an ev_pri field.
1305    
1306     =item * Other members are not supported.
1307    
1308     =item * The libev emulation is I<not> ABI compatible to libevent, you need
1309     to use the libev header file and library.
1310    
1311     =back
1312 root 1.20
1313     =head1 C++ SUPPORT
1314    
1315 root 1.38 Libev comes with some simplistic wrapper classes for C++ that mainly allow
1316     you to use some convinience methods to start/stop watchers and also change
1317     the callback model to a model using method callbacks on objects.
1318    
1319     To use it,
1320    
1321     #include <ev++.h>
1322    
1323     (it is not installed by default). This automatically includes F<ev.h>
1324     and puts all of its definitions (many of them macros) into the global
1325     namespace. All C++ specific things are put into the C<ev> namespace.
1326    
1327     It should support all the same embedding options as F<ev.h>, most notably
1328     C<EV_MULTIPLICITY>.
1329    
1330     Here is a list of things available in the C<ev> namespace:
1331    
1332     =over 4
1333    
1334     =item C<ev::READ>, C<ev::WRITE> etc.
1335    
1336     These are just enum values with the same values as the C<EV_READ> etc.
1337     macros from F<ev.h>.
1338    
1339     =item C<ev::tstamp>, C<ev::now>
1340    
1341     Aliases to the same types/functions as with the C<ev_> prefix.
1342    
1343     =item C<ev::io>, C<ev::timer>, C<ev::periodic>, C<ev::idle>, C<ev::sig> etc.
1344    
1345     For each C<ev_TYPE> watcher in F<ev.h> there is a corresponding class of
1346     the same name in the C<ev> namespace, with the exception of C<ev_signal>
1347     which is called C<ev::sig> to avoid clashes with the C<signal> macro
1348     defines by many implementations.
1349    
1350     All of those classes have these methods:
1351    
1352     =over 4
1353    
1354     =item ev::TYPE::TYPE (object *, object::method *)
1355    
1356     =item ev::TYPE::TYPE (object *, object::method *, struct ev_loop *)
1357    
1358     =item ev::TYPE::~TYPE
1359    
1360     The constructor takes a pointer to an object and a method pointer to
1361     the event handler callback to call in this class. The constructor calls
1362     C<ev_init> for you, which means you have to call the C<set> method
1363     before starting it. If you do not specify a loop then the constructor
1364     automatically associates the default loop with this watcher.
1365    
1366     The destructor automatically stops the watcher if it is active.
1367    
1368     =item w->set (struct ev_loop *)
1369    
1370     Associates a different C<struct ev_loop> with this watcher. You can only
1371     do this when the watcher is inactive (and not pending either).
1372    
1373     =item w->set ([args])
1374    
1375     Basically the same as C<ev_TYPE_set>, with the same args. Must be
1376     called at least once. Unlike the C counterpart, an active watcher gets
1377     automatically stopped and restarted.
1378    
1379     =item w->start ()
1380    
1381     Starts the watcher. Note that there is no C<loop> argument as the
1382     constructor already takes the loop.
1383    
1384     =item w->stop ()
1385    
1386     Stops the watcher if it is active. Again, no C<loop> argument.
1387    
1388     =item w->again () C<ev::timer>, C<ev::periodic> only
1389    
1390     For C<ev::timer> and C<ev::periodic>, this invokes the corresponding
1391     C<ev_TYPE_again> function.
1392    
1393     =item w->sweep () C<ev::embed> only
1394    
1395     Invokes C<ev_embed_sweep>.
1396    
1397     =back
1398    
1399     =back
1400    
1401     Example: Define a class with an IO and idle watcher, start one of them in
1402     the constructor.
1403    
1404     class myclass
1405     {
1406     ev_io io; void io_cb (ev::io &w, int revents);
1407     ev_idle idle void idle_cb (ev::idle &w, int revents);
1408    
1409     myclass ();
1410     }
1411    
1412     myclass::myclass (int fd)
1413     : io (this, &myclass::io_cb),
1414     idle (this, &myclass::idle_cb)
1415     {
1416     io.start (fd, ev::READ);
1417     }
1418 root 1.20
1419 root 1.39 =head1 EMBEDDING
1420    
1421     Libev can (and often is) directly embedded into host
1422     applications. Examples of applications that embed it include the Deliantra
1423     Game Server, the EV perl module, the GNU Virtual Private Ethernet (gvpe)
1424     and rxvt-unicode.
1425    
1426     The goal is to enable you to just copy the neecssary files into your
1427     source directory without having to change even a single line in them, so
1428     you can easily upgrade by simply copying (or having a checked-out copy of
1429     libev somewhere in your source tree).
1430    
1431     =head2 FILESETS
1432    
1433     Depending on what features you need you need to include one or more sets of files
1434     in your app.
1435    
1436     =head3 CORE EVENT LOOP
1437    
1438     To include only the libev core (all the C<ev_*> functions), with manual
1439     configuration (no autoconf):
1440    
1441     #define EV_STANDALONE 1
1442     #include "ev.c"
1443    
1444     This will automatically include F<ev.h>, too, and should be done in a
1445     single C source file only to provide the function implementations. To use
1446     it, do the same for F<ev.h> in all files wishing to use this API (best
1447     done by writing a wrapper around F<ev.h> that you can include instead and
1448     where you can put other configuration options):
1449    
1450     #define EV_STANDALONE 1
1451     #include "ev.h"
1452    
1453     Both header files and implementation files can be compiled with a C++
1454     compiler (at least, thats a stated goal, and breakage will be treated
1455     as a bug).
1456    
1457     You need the following files in your source tree, or in a directory
1458     in your include path (e.g. in libev/ when using -Ilibev):
1459    
1460     ev.h
1461     ev.c
1462     ev_vars.h
1463     ev_wrap.h
1464    
1465     ev_win32.c required on win32 platforms only
1466    
1467     ev_select.c only when select backend is enabled (which is is by default)
1468     ev_poll.c only when poll backend is enabled (disabled by default)
1469     ev_epoll.c only when the epoll backend is enabled (disabled by default)
1470     ev_kqueue.c only when the kqueue backend is enabled (disabled by default)
1471     ev_port.c only when the solaris port backend is enabled (disabled by default)
1472    
1473     F<ev.c> includes the backend files directly when enabled, so you only need
1474     to compile a single file.
1475    
1476     =head3 LIBEVENT COMPATIBILITY API
1477    
1478     To include the libevent compatibility API, also include:
1479    
1480     #include "event.c"
1481    
1482     in the file including F<ev.c>, and:
1483    
1484     #include "event.h"
1485    
1486     in the files that want to use the libevent API. This also includes F<ev.h>.
1487    
1488     You need the following additional files for this:
1489    
1490     event.h
1491     event.c
1492    
1493     =head3 AUTOCONF SUPPORT
1494    
1495     Instead of using C<EV_STANDALONE=1> and providing your config in
1496     whatever way you want, you can also C<m4_include([libev.m4])> in your
1497     F<configure.ac> and leave C<EV_STANDALONE> off. F<ev.c> will then include
1498     F<config.h> and configure itself accordingly.
1499    
1500     For this of course you need the m4 file:
1501    
1502     libev.m4
1503    
1504     =head2 PREPROCESSOR SYMBOLS/MACROS
1505    
1506     Libev can be configured via a variety of preprocessor symbols you have to define
1507     before including any of its files. The default is not to build for multiplicity
1508     and only include the select backend.
1509    
1510     =over 4
1511    
1512     =item EV_STANDALONE
1513    
1514     Must always be C<1> if you do not use autoconf configuration, which
1515     keeps libev from including F<config.h>, and it also defines dummy
1516     implementations for some libevent functions (such as logging, which is not
1517     supported). It will also not define any of the structs usually found in
1518     F<event.h> that are not directly supported by the libev core alone.
1519    
1520     =item EV_USE_MONOTONIC
1521    
1522     If defined to be C<1>, libev will try to detect the availability of the
1523     monotonic clock option at both compiletime and runtime. Otherwise no use
1524     of the monotonic clock option will be attempted. If you enable this, you
1525     usually have to link against librt or something similar. Enabling it when
1526     the functionality isn't available is safe, though, althoguh you have
1527     to make sure you link against any libraries where the C<clock_gettime>
1528     function is hiding in (often F<-lrt>).
1529    
1530     =item EV_USE_REALTIME
1531    
1532     If defined to be C<1>, libev will try to detect the availability of the
1533     realtime clock option at compiletime (and assume its availability at
1534     runtime if successful). Otherwise no use of the realtime clock option will
1535     be attempted. This effectively replaces C<gettimeofday> by C<clock_get
1536     (CLOCK_REALTIME, ...)> and will not normally affect correctness. See tzhe note about libraries
1537     in the description of C<EV_USE_MONOTONIC>, though.
1538    
1539     =item EV_USE_SELECT
1540    
1541     If undefined or defined to be C<1>, libev will compile in support for the
1542     C<select>(2) backend. No attempt at autodetection will be done: if no
1543     other method takes over, select will be it. Otherwise the select backend
1544     will not be compiled in.
1545    
1546     =item EV_SELECT_USE_FD_SET
1547    
1548     If defined to C<1>, then the select backend will use the system C<fd_set>
1549     structure. This is useful if libev doesn't compile due to a missing
1550     C<NFDBITS> or C<fd_mask> definition or it misguesses the bitset layout on
1551     exotic systems. This usually limits the range of file descriptors to some
1552     low limit such as 1024 or might have other limitations (winsocket only
1553     allows 64 sockets). The C<FD_SETSIZE> macro, set before compilation, might
1554     influence the size of the C<fd_set> used.
1555    
1556     =item EV_SELECT_IS_WINSOCKET
1557    
1558     When defined to C<1>, the select backend will assume that
1559     select/socket/connect etc. don't understand file descriptors but
1560     wants osf handles on win32 (this is the case when the select to
1561     be used is the winsock select). This means that it will call
1562     C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise,
1563     it is assumed that all these functions actually work on fds, even
1564     on win32. Should not be defined on non-win32 platforms.
1565    
1566     =item EV_USE_POLL
1567    
1568     If defined to be C<1>, libev will compile in support for the C<poll>(2)
1569     backend. Otherwise it will be enabled on non-win32 platforms. It
1570     takes precedence over select.
1571    
1572     =item EV_USE_EPOLL
1573    
1574     If defined to be C<1>, libev will compile in support for the Linux
1575     C<epoll>(7) backend. Its availability will be detected at runtime,
1576     otherwise another method will be used as fallback. This is the
1577     preferred backend for GNU/Linux systems.
1578    
1579     =item EV_USE_KQUEUE
1580    
1581     If defined to be C<1>, libev will compile in support for the BSD style
1582     C<kqueue>(2) backend. Its actual availability will be detected at runtime,
1583     otherwise another method will be used as fallback. This is the preferred
1584     backend for BSD and BSD-like systems, although on most BSDs kqueue only
1585     supports some types of fds correctly (the only platform we found that
1586     supports ptys for example was NetBSD), so kqueue might be compiled in, but
1587     not be used unless explicitly requested. The best way to use it is to find
1588     out wether kqueue supports your type of fd properly and use an embedded
1589     kqueue loop.
1590    
1591     =item EV_USE_PORT
1592    
1593     If defined to be C<1>, libev will compile in support for the Solaris
1594     10 port style backend. Its availability will be detected at runtime,
1595     otherwise another method will be used as fallback. This is the preferred
1596     backend for Solaris 10 systems.
1597    
1598     =item EV_USE_DEVPOLL
1599    
1600     reserved for future expansion, works like the USE symbols above.
1601    
1602     =item EV_H
1603    
1604     The name of the F<ev.h> header file used to include it. The default if
1605     undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This
1606     can be used to virtually rename the F<ev.h> header file in case of conflicts.
1607    
1608     =item EV_CONFIG_H
1609    
1610     If C<EV_STANDALONE> isn't C<1>, this variable can be used to override
1611     F<ev.c>'s idea of where to find the F<config.h> file, similarly to
1612     C<EV_H>, above.
1613    
1614     =item EV_EVENT_H
1615    
1616     Similarly to C<EV_H>, this macro can be used to override F<event.c>'s idea
1617     of how the F<event.h> header can be found.
1618    
1619     =item EV_PROTOTYPES
1620    
1621     If defined to be C<0>, then F<ev.h> will not define any function
1622     prototypes, but still define all the structs and other symbols. This is
1623     occasionally useful if you want to provide your own wrapper functions
1624     around libev functions.
1625    
1626     =item EV_MULTIPLICITY
1627    
1628     If undefined or defined to C<1>, then all event-loop-specific functions
1629     will have the C<struct ev_loop *> as first argument, and you can create
1630     additional independent event loops. Otherwise there will be no support
1631     for multiple event loops and there is no first event loop pointer
1632     argument. Instead, all functions act on the single default loop.
1633    
1634     =item EV_PERIODICS
1635    
1636     If undefined or defined to be C<1>, then periodic timers are supported,
1637     otherwise not. This saves a few kb of code.
1638    
1639     =item EV_COMMON
1640    
1641     By default, all watchers have a C<void *data> member. By redefining
1642     this macro to a something else you can include more and other types of
1643     members. You have to define it each time you include one of the files,
1644     though, and it must be identical each time.
1645    
1646     For example, the perl EV module uses something like this:
1647    
1648     #define EV_COMMON \
1649     SV *self; /* contains this struct */ \
1650     SV *cb_sv, *fh /* note no trailing ";" */
1651    
1652     =item EV_CB_DECLARE(type)
1653    
1654     =item EV_CB_INVOKE(watcher,revents)
1655    
1656     =item ev_set_cb(ev,cb)
1657    
1658     Can be used to change the callback member declaration in each watcher,
1659     and the way callbacks are invoked and set. Must expand to a struct member
1660     definition and a statement, respectively. See the F<ev.v> header file for
1661     their default definitions. One possible use for overriding these is to
1662     avoid the ev_loop pointer as first argument in all cases, or to use method
1663     calls instead of plain function calls in C++.
1664    
1665     =head2 EXAMPLES
1666    
1667     For a real-world example of a program the includes libev
1668     verbatim, you can have a look at the EV perl module
1669     (L<http://software.schmorp.de/pkg/EV.html>). It has the libev files in
1670     the F<libev/> subdirectory and includes them in the F<EV/EVAPI.h> (public
1671     interface) and F<EV.xs> (implementation) files. Only the F<EV.xs> file
1672     will be compiled. It is pretty complex because it provides its own header
1673     file.
1674    
1675     The usage in rxvt-unicode is simpler. It has a F<ev_cpp.h> header file
1676     that everybody includes and which overrides some autoconf choices:
1677    
1678 root 1.40 #define EV_USE_POLL 0
1679     #define EV_MULTIPLICITY 0
1680     #define EV_PERIODICS 0
1681     #define EV_CONFIG_H <config.h>
1682 root 1.39
1683 root 1.40 #include "ev++.h"
1684 root 1.39
1685     And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
1686    
1687 root 1.40 #include "ev_cpp.h"
1688     #include "ev.c"
1689 root 1.39
1690 root 1.1 =head1 AUTHOR
1691    
1692     Marc Lehmann <libev@schmorp.de>.
1693