ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev.pod
(Generate patch)

Comparing libev/ev.pod (file contents):
Revision 1.438 by root, Tue Jan 12 05:52:44 2016 UTC vs.
Revision 1.449 by root, Sun Jun 23 02:02:30 2019 UTC

105details of the event, and then hand it over to libev by I<starting> the 105details of the event, and then hand it over to libev by I<starting> the
106watcher. 106watcher.
107 107
108=head2 FEATURES 108=head2 FEATURES
109 109
110Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the 110Libev supports C<select>, C<poll>, the Linux-specific aio and C<epoll>
111BSD-specific C<kqueue> and the Solaris-specific event port mechanisms 111interfaces, the BSD-specific C<kqueue> and the Solaris-specific event port
112for file descriptor events (C<ev_io>), the Linux C<inotify> interface 112mechanisms for file descriptor events (C<ev_io>), the Linux C<inotify>
113(for C<ev_stat>), Linux eventfd/signalfd (for faster and cleaner 113interface (for C<ev_stat>), Linux eventfd/signalfd (for faster and cleaner
114inter-thread wakeup (C<ev_async>)/signal handling (C<ev_signal>)) relative 114inter-thread wakeup (C<ev_async>)/signal handling (C<ev_signal>)) relative
115timers (C<ev_timer>), absolute timers with customised rescheduling 115timers (C<ev_timer>), absolute timers with customised rescheduling
116(C<ev_periodic>), synchronous signals (C<ev_signal>), process status 116(C<ev_periodic>), synchronous signals (C<ev_signal>), process status
117change events (C<ev_child>), and event watchers dealing with the event 117change events (C<ev_child>), and event watchers dealing with the event
118loop mechanism itself (C<ev_idle>, C<ev_embed>, C<ev_prepare> and 118loop mechanism itself (C<ev_idle>, C<ev_embed>, C<ev_prepare> and
265 265
266You could override this function in high-availability programs to, say, 266You could override this function in high-availability programs to, say,
267free some memory if it cannot allocate memory, to use a special allocator, 267free some memory if it cannot allocate memory, to use a special allocator,
268or even to sleep a while and retry until some memory is available. 268or even to sleep a while and retry until some memory is available.
269 269
270Example: The following is the C<realloc> function that libev itself uses
271which should work with C<realloc> and C<free> functions of all kinds and
272is probably a good basis for your own implementation.
273
274 static void *
275 ev_realloc_emul (void *ptr, long size) EV_NOEXCEPT
276 {
277 if (size)
278 return realloc (ptr, size);
279
280 free (ptr);
281 return 0;
282 }
283
270Example: Replace the libev allocator with one that waits a bit and then 284Example: Replace the libev allocator with one that waits a bit and then
271retries (example requires a standards-compliant C<realloc>). 285retries.
272 286
273 static void * 287 static void *
274 persistent_realloc (void *ptr, size_t size) 288 persistent_realloc (void *ptr, size_t size)
275 { 289 {
290 if (!size)
291 {
292 free (ptr);
293 return 0;
294 }
295
276 for (;;) 296 for (;;)
277 { 297 {
278 void *newptr = realloc (ptr, size); 298 void *newptr = realloc (ptr, size);
279 299
280 if (newptr) 300 if (newptr)
411make libev check for a fork in each iteration by enabling this flag. 431make libev check for a fork in each iteration by enabling this flag.
412 432
413This works by calling C<getpid ()> on every iteration of the loop, 433This works by calling C<getpid ()> on every iteration of the loop,
414and thus this might slow down your event loop if you do a lot of loop 434and thus this might slow down your event loop if you do a lot of loop
415iterations and little real work, but is usually not noticeable (on my 435iterations and little real work, but is usually not noticeable (on my
416GNU/Linux system for example, C<getpid> is actually a simple 5-insn sequence 436GNU/Linux system for example, C<getpid> is actually a simple 5-insn
417without a system call and thus I<very> fast, but my GNU/Linux system also has 437sequence without a system call and thus I<very> fast, but my GNU/Linux
418C<pthread_atfork> which is even faster). 438system also has C<pthread_atfork> which is even faster). (Update: glibc
439versions 2.25 apparently removed the C<getpid> optimisation again).
419 440
420The big advantage of this flag is that you can forget about fork (and 441The big advantage of this flag is that you can forget about fork (and
421forget about forgetting to tell libev about forking, although you still 442forget about forgetting to tell libev about forking, although you still
422have to ignore C<SIGPIPE>) when you use this flag. 443have to ignore C<SIGPIPE>) when you use this flag.
423 444
546All this means that, in practice, C<EVBACKEND_SELECT> can be as fast or 567All this means that, in practice, C<EVBACKEND_SELECT> can be as fast or
547faster than epoll for maybe up to a hundred file descriptors, depending on 568faster than epoll for maybe up to a hundred file descriptors, depending on
548the usage. So sad. 569the usage. So sad.
549 570
550While nominally embeddable in other event loops, this feature is broken in 571While nominally embeddable in other event loops, this feature is broken in
551all kernel versions tested so far. 572a lot of kernel revisions, but probably(!) works in current versions.
573
574This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
575C<EVBACKEND_POLL>.
576
577=item C<EVBACKEND_LINUXAIO> (value 64, Linux)
578
579Use the linux-specific linux aio (I<not> C<< aio(7) >> but C<<
580io_submit(2) >>) event interface available in post-4.18 kernels.
581
582If this backend works for you (as of this writing, it was very
583experimental), it is the best event interface available on linux and might
584be well worth enabling it - if it isn't available in your kernel this will
585be detected and this backend will be skipped.
586
587This backend can batch oneshot requests and supports a user-space ring
588buffer to receive events. It also doesn't suffer from most of the design
589problems of epoll (such as not being able to remove event sources from
590the epoll set), and generally sounds too good to be true. Because, this
591being the linux kernel, of course it suffers from a whole new set of
592limitations.
593
594For one, it is not easily embeddable (but probably could be done using
595an event fd at some extra overhead). It also is subject to a system wide
596limit that can be configured in F</proc/sys/fs/aio-max-nr> - each loop
597currently requires C<61> of this number. If no aio requests are left, this
598backend will be skipped during initialisation.
599
600Most problematic in practise, however, is that not all file descriptors
601work with it. For example, in linux 5.1, tcp sockets, pipes, event fds,
602files, F</dev/null> and a few others are supported, but ttys do not work
603(probably because of a bug), so this is not (yet?) a generic event polling
604interface.
605
606To work around this latter problem, the current version of libev uses
607epoll as a fallback for file deescriptor types that do not work. Epoll
608is used in, kind of, slow mode that hopefully avoids most of its design
609problems and requires 1-3 extra syscalls per active fd every iteration.
552 610
553This backend maps C<EV_READ> and C<EV_WRITE> in the same way as 611This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
554C<EVBACKEND_POLL>. 612C<EVBACKEND_POLL>.
555 613
556=item C<EVBACKEND_KQUEUE> (value 8, most BSD clones) 614=item C<EVBACKEND_KQUEUE> (value 8, most BSD clones)
656 714
657Example: Use whatever libev has to offer, but make sure that kqueue is 715Example: Use whatever libev has to offer, but make sure that kqueue is
658used if available. 716used if available.
659 717
660 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_KQUEUE); 718 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_KQUEUE);
719
720Example: Similarly, on linux, you mgiht want to take advantage of the
721linux aio backend if possible, but fall back to something else if that
722isn't available.
723
724 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_LINUXAIO);
661 725
662=item ev_loop_destroy (loop) 726=item ev_loop_destroy (loop)
663 727
664Destroys an event loop object (frees all memory and kernel state 728Destroys an event loop object (frees all memory and kernel state
665etc.). None of the active event watchers will be stopped in the normal 729etc.). None of the active event watchers will be stopped in the normal
1609 1673
1610But really, best use non-blocking mode. 1674But really, best use non-blocking mode.
1611 1675
1612=head3 The special problem of disappearing file descriptors 1676=head3 The special problem of disappearing file descriptors
1613 1677
1614Some backends (e.g. kqueue, epoll) need to be told about closing a file 1678Some backends (e.g. kqueue, epoll, linuxaio) need to be told about closing
1615descriptor (either due to calling C<close> explicitly or any other means, 1679a file descriptor (either due to calling C<close> explicitly or any other
1616such as C<dup2>). The reason is that you register interest in some file 1680means, such as C<dup2>). The reason is that you register interest in some
1617descriptor, but when it goes away, the operating system will silently drop 1681file descriptor, but when it goes away, the operating system will silently
1618this interest. If another file descriptor with the same number then is 1682drop this interest. If another file descriptor with the same number then
1619registered with libev, there is no efficient way to see that this is, in 1683is registered with libev, there is no efficient way to see that this is,
1620fact, a different file descriptor. 1684in fact, a different file descriptor.
1621 1685
1622To avoid having to explicitly tell libev about such cases, libev follows 1686To avoid having to explicitly tell libev about such cases, libev follows
1623the following policy: Each time C<ev_io_set> is being called, libev 1687the following policy: Each time C<ev_io_set> is being called, libev
1624will assume that this is potentially a new file descriptor, otherwise 1688will assume that this is potentially a new file descriptor, otherwise
1625it is assumed that the file descriptor stays the same. That means that 1689it is assumed that the file descriptor stays the same. That means that
1674when you rarely read from a file instead of from a socket, and want to 1738when you rarely read from a file instead of from a socket, and want to
1675reuse the same code path. 1739reuse the same code path.
1676 1740
1677=head3 The special problem of fork 1741=head3 The special problem of fork
1678 1742
1679Some backends (epoll, kqueue) do not support C<fork ()> at all or exhibit 1743Some backends (epoll, kqueue, probably linuxaio) do not support C<fork ()>
1680useless behaviour. Libev fully supports fork, but needs to be told about 1744at all or exhibit useless behaviour. Libev fully supports fork, but needs
1681it in the child if you want to continue to use it in the child. 1745to be told about it in the child if you want to continue to use it in the
1746child.
1682 1747
1683To support fork in your child processes, you have to call C<ev_loop_fork 1748To support fork in your child processes, you have to call C<ev_loop_fork
1684()> after a fork in the child, enable C<EVFLAG_FORKCHECK>, or resort to 1749()> after a fork in the child, enable C<EVFLAG_FORKCHECK>, or resort to
1685C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>. 1750C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>.
1686 1751
2113 2178
2114=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 2179=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
2115 2180
2116=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat) 2181=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
2117 2182
2118Configure the timer to trigger after C<after> seconds. If C<repeat> 2183Configure the timer to trigger after C<after> seconds (fractional and
2119is C<0.>, then it will automatically be stopped once the timeout is 2184negative values are supported). If C<repeat> is C<0.>, then it will
2120reached. If it is positive, then the timer will automatically be 2185automatically be stopped once the timeout is reached. If it is positive,
2121configured to trigger again C<repeat> seconds later, again, and again, 2186then the timer will automatically be configured to trigger again C<repeat>
2122until stopped manually. 2187seconds later, again, and again, until stopped manually.
2123 2188
2124The timer itself will do a best-effort at avoiding drift, that is, if 2189The timer itself will do a best-effort at avoiding drift, that is, if
2125you configure a timer to trigger every 10 seconds, then it will normally 2190you configure a timer to trigger every 10 seconds, then it will normally
2126trigger at exactly 10 second intervals. If, however, your program cannot 2191trigger at exactly 10 second intervals. If, however, your program cannot
2127keep up with the timer (because it takes longer than those 10 seconds to 2192keep up with the timer (because it takes longer than those 10 seconds to
2224C<ev_timer>, which would still trigger roughly 10 seconds after starting 2289C<ev_timer>, which would still trigger roughly 10 seconds after starting
2225it, as it uses a relative timeout). 2290it, as it uses a relative timeout).
2226 2291
2227C<ev_periodic> watchers can also be used to implement vastly more complex 2292C<ev_periodic> watchers can also be used to implement vastly more complex
2228timers, such as triggering an event on each "midnight, local time", or 2293timers, such as triggering an event on each "midnight, local time", or
2229other complicated rules. This cannot be done with C<ev_timer> watchers, as 2294other complicated rules. This cannot easily be done with C<ev_timer>
2230those cannot react to time jumps. 2295watchers, as those cannot react to time jumps.
2231 2296
2232As with timers, the callback is guaranteed to be invoked only when the 2297As with timers, the callback is guaranteed to be invoked only when the
2233point in time where it is supposed to trigger has passed. If multiple 2298point in time where it is supposed to trigger has passed. If multiple
2234timers become ready during the same loop iteration then the ones with 2299timers become ready during the same loop iteration then the ones with
2235earlier time-out values are invoked before ones with later time-out values 2300earlier time-out values are invoked before ones with later time-out values
2321 2386
2322NOTE: I<< This callback must always return a time that is higher than or 2387NOTE: I<< This callback must always return a time that is higher than or
2323equal to the passed C<now> value >>. 2388equal to the passed C<now> value >>.
2324 2389
2325This can be used to create very complex timers, such as a timer that 2390This can be used to create very complex timers, such as a timer that
2326triggers on "next midnight, local time". To do this, you would calculate the 2391triggers on "next midnight, local time". To do this, you would calculate
2327next midnight after C<now> and return the timestamp value for this. How 2392the next midnight after C<now> and return the timestamp value for
2328you do this is, again, up to you (but it is not trivial, which is the main 2393this. Here is a (completely untested, no error checking) example on how to
2329reason I omitted it as an example). 2394do this:
2395
2396 #include <time.h>
2397
2398 static ev_tstamp
2399 my_rescheduler (ev_periodic *w, ev_tstamp now)
2400 {
2401 time_t tnow = (time_t)now;
2402 struct tm tm;
2403 localtime_r (&tnow, &tm);
2404
2405 tm.tm_sec = tm.tm_min = tm.tm_hour = 0; // midnight current day
2406 ++tm.tm_mday; // midnight next day
2407
2408 return mktime (&tm);
2409 }
2410
2411Note: this code might run into trouble on days that have more then two
2412midnights (beginning and end).
2330 2413
2331=back 2414=back
2332 2415
2333=item ev_periodic_again (loop, ev_periodic *) 2416=item ev_periodic_again (loop, ev_periodic *)
2334 2417
3517 3600
3518There are some other functions of possible interest. Described. Here. Now. 3601There are some other functions of possible interest. Described. Here. Now.
3519 3602
3520=over 4 3603=over 4
3521 3604
3522=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback) 3605=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback, arg)
3523 3606
3524This function combines a simple timer and an I/O watcher, calls your 3607This function combines a simple timer and an I/O watcher, calls your
3525callback on whichever event happens first and automatically stops both 3608callback on whichever event happens first and automatically stops both
3526watchers. This is useful if you want to wait for a single event on an fd 3609watchers. This is useful if you want to wait for a single event on an fd
3527or timeout without having to allocate/configure/start/stop/free one or 3610or timeout without having to allocate/configure/start/stop/free one or
3959The normal C API should work fine when used from C++: both ev.h and the 4042The normal C API should work fine when used from C++: both ev.h and the
3960libev sources can be compiled as C++. Therefore, code that uses the C API 4043libev sources can be compiled as C++. Therefore, code that uses the C API
3961will work fine. 4044will work fine.
3962 4045
3963Proper exception specifications might have to be added to callbacks passed 4046Proper exception specifications might have to be added to callbacks passed
3964to libev: exceptions may be thrown only from watcher callbacks, all 4047to libev: exceptions may be thrown only from watcher callbacks, all other
3965other callbacks (allocator, syserr, loop acquire/release and periodic 4048callbacks (allocator, syserr, loop acquire/release and periodic reschedule
3966reschedule callbacks) must not throw exceptions, and might need a C<throw 4049callbacks) must not throw exceptions, and might need a C<noexcept>
3967()> specification. If you have code that needs to be compiled as both C 4050specification. If you have code that needs to be compiled as both C and
3968and C++ you can use the C<EV_THROW> macro for this: 4051C++ you can use the C<EV_NOEXCEPT> macro for this:
3969 4052
3970 static void 4053 static void
3971 fatal_error (const char *msg) EV_THROW 4054 fatal_error (const char *msg) EV_NOEXCEPT
3972 { 4055 {
3973 perror (msg); 4056 perror (msg);
3974 abort (); 4057 abort ();
3975 } 4058 }
3976 4059
4386 ev_vars.h 4469 ev_vars.h
4387 ev_wrap.h 4470 ev_wrap.h
4388 4471
4389 ev_win32.c required on win32 platforms only 4472 ev_win32.c required on win32 platforms only
4390 4473
4391 ev_select.c only when select backend is enabled (which is enabled by default) 4474 ev_select.c only when select backend is enabled
4392 ev_poll.c only when poll backend is enabled (disabled by default) 4475 ev_poll.c only when poll backend is enabled
4393 ev_epoll.c only when the epoll backend is enabled (disabled by default) 4476 ev_epoll.c only when the epoll backend is enabled
4477 ev_linuxaio.c only when the linux aio backend is enabled
4394 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 4478 ev_kqueue.c only when the kqueue backend is enabled
4395 ev_port.c only when the solaris port backend is enabled (disabled by default) 4479 ev_port.c only when the solaris port backend is enabled
4396 4480
4397F<ev.c> includes the backend files directly when enabled, so you only need 4481F<ev.c> includes the backend files directly when enabled, so you only need
4398to compile this single file. 4482to compile this single file.
4399 4483
4400=head3 LIBEVENT COMPATIBILITY API 4484=head3 LIBEVENT COMPATIBILITY API
4588If defined to be C<1>, libev will compile in support for the Linux 4672If defined to be C<1>, libev will compile in support for the Linux
4589C<epoll>(7) backend. Its availability will be detected at runtime, 4673C<epoll>(7) backend. Its availability will be detected at runtime,
4590otherwise another method will be used as fallback. This is the preferred 4674otherwise another method will be used as fallback. This is the preferred
4591backend for GNU/Linux systems. If undefined, it will be enabled if the 4675backend for GNU/Linux systems. If undefined, it will be enabled if the
4592headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled. 4676headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled.
4677
4678=item EV_USE_LINUXAIO
4679
4680If defined to be C<1>, libev will compile in support for the Linux
4681aio backend. Due to it's currenbt limitations it has to be requested
4682explicitly. If undefined, it will be enabled on linux, otherwise
4683disabled.
4593 4684
4594=item EV_USE_KQUEUE 4685=item EV_USE_KQUEUE
4595 4686
4596If defined to be C<1>, libev will compile in support for the BSD style 4687If defined to be C<1>, libev will compile in support for the BSD style
4597C<kqueue>(2) backend. Its actual availability will be detected at runtime, 4688C<kqueue>(2) backend. Its actual availability will be detected at runtime,
5300structure (guaranteed by POSIX but not by ISO C for example), but it also 5391structure (guaranteed by POSIX but not by ISO C for example), but it also
5301assumes that the same (machine) code can be used to call any watcher 5392assumes that the same (machine) code can be used to call any watcher
5302callback: The watcher callbacks have different type signatures, but libev 5393callback: The watcher callbacks have different type signatures, but libev
5303calls them using an C<ev_watcher *> internally. 5394calls them using an C<ev_watcher *> internally.
5304 5395
5396=item null pointers and integer zero are represented by 0 bytes
5397
5398Libev uses C<memset> to initialise structs and arrays to C<0> bytes, and
5399relies on this setting pointers and integers to null.
5400
5305=item pointer accesses must be thread-atomic 5401=item pointer accesses must be thread-atomic
5306 5402
5307Accessing a pointer value must be atomic, it must both be readable and 5403Accessing a pointer value must be atomic, it must both be readable and
5308writable in one piece - this is the case on all current architectures. 5404writable in one piece - this is the case on all current architectures.
5309 5405

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines