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

Comparing libev/ev.pod (file contents):
Revision 1.435 by root, Tue Apr 21 10:10:57 2015 UTC vs.
Revision 1.447 by root, Sat Jun 22 16:25:53 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) when you use this 442forget about forgetting to tell libev about forking, although you still
422flag. 443have to ignore C<SIGPIPE>) when you use this flag.
423 444
424This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS> 445This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
425environment variable. 446environment variable.
426 447
427=item C<EVFLAG_NOINOTIFY> 448=item C<EVFLAG_NOINOTIFY>
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) >>) event interface
580available in post-4.18 kernels.
581
582If this backend works for you (as of this writing, it was very
583experimental and only supports a subset of file types), it is the best
584event interface available on linux and might be well worth it enabling it
585- if it isn't available in your kernel this will be detected and another
586backend will be chosen.
587
588This backend can batch oneshot requests and uses a user-space ring buffer
589to receive events. It also doesn't suffer from most of the design problems
590of epoll (such as not being able to remove event sources from the epoll
591set), and generally sounds too good to be true. Because, this being the
592linux kernel, of course it suffers from a whole new set of limitations.
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 various
596arbitrary limits that can be configured in F</proc/sys/fs/aio-max-nr>
597and F</proc/sys/fs/aio-nr>), which could lead to it being skipped during
598initialisation.
599
600Most problematic in practise, however, is that, like kqueue, it requires
601special support from drivers, and, not surprisingly, not all drivers
602implement it. For example, in linux 4.19, tcp sockets, pipes, event fds,
603files, F</dev/null> and a few others are supported, but ttys are not, so
604this is not (yet?) a generic event polling interface but is probably still
605be very useful in a web server or similar program.
552 606
553This backend maps C<EV_READ> and C<EV_WRITE> in the same way as 607This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
554C<EVBACKEND_POLL>. 608C<EVBACKEND_POLL>.
555 609
556=item C<EVBACKEND_KQUEUE> (value 8, most BSD clones) 610=item C<EVBACKEND_KQUEUE> (value 8, most BSD clones)
657Example: Use whatever libev has to offer, but make sure that kqueue is 711Example: Use whatever libev has to offer, but make sure that kqueue is
658used if available. 712used if available.
659 713
660 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_KQUEUE); 714 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_KQUEUE);
661 715
716Example: Similarly, on linux, you mgiht want to take advantage of the
717linux aio backend if possible, but fall back to something else if that
718isn't available.
719
720 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_LINUXAIO);
721
662=item ev_loop_destroy (loop) 722=item ev_loop_destroy (loop)
663 723
664Destroys an event loop object (frees all memory and kernel state 724Destroys an event loop object (frees all memory and kernel state
665etc.). None of the active event watchers will be stopped in the normal 725etc.). None of the active event watchers will be stopped in the normal
666sense, so e.g. C<ev_is_active> might still return true. It is your 726sense, so e.g. C<ev_is_active> might still return true. It is your
688to reinitialise the kernel state for backends that have one. Despite 748to reinitialise the kernel state for backends that have one. Despite
689the name, you can call it anytime you are allowed to start or stop 749the name, you can call it anytime you are allowed to start or stop
690watchers (except inside an C<ev_prepare> callback), but it makes most 750watchers (except inside an C<ev_prepare> callback), but it makes most
691sense after forking, in the child process. You I<must> call it (or use 751sense after forking, in the child process. You I<must> call it (or use
692C<EVFLAG_FORKCHECK>) in the child before resuming or calling C<ev_run>. 752C<EVFLAG_FORKCHECK>) in the child before resuming or calling C<ev_run>.
753
754In addition, if you want to reuse a loop (via this function or
755C<EVFLAG_FORKCHECK>), you I<also> have to ignore C<SIGPIPE>.
693 756
694Again, you I<have> to call it on I<any> loop that you want to re-use after 757Again, you I<have> to call it on I<any> loop that you want to re-use after
695a fork, I<even if you do not plan to use the loop in the parent>. This is 758a fork, I<even if you do not plan to use the loop in the parent>. This is
696because some kernel interfaces *cough* I<kqueue> *cough* do funny things 759because some kernel interfaces *cough* I<kqueue> *cough* do funny things
697during fork. 760during fork.
1606 1669
1607But really, best use non-blocking mode. 1670But really, best use non-blocking mode.
1608 1671
1609=head3 The special problem of disappearing file descriptors 1672=head3 The special problem of disappearing file descriptors
1610 1673
1611Some backends (e.g. kqueue, epoll) need to be told about closing a file 1674Some backends (e.g. kqueue, epoll, linuxaio) need to be told about closing
1612descriptor (either due to calling C<close> explicitly or any other means, 1675a file descriptor (either due to calling C<close> explicitly or any other
1613such as C<dup2>). The reason is that you register interest in some file 1676means, such as C<dup2>). The reason is that you register interest in some
1614descriptor, but when it goes away, the operating system will silently drop 1677file descriptor, but when it goes away, the operating system will silently
1615this interest. If another file descriptor with the same number then is 1678drop this interest. If another file descriptor with the same number then
1616registered with libev, there is no efficient way to see that this is, in 1679is registered with libev, there is no efficient way to see that this is,
1617fact, a different file descriptor. 1680in fact, a different file descriptor.
1618 1681
1619To avoid having to explicitly tell libev about such cases, libev follows 1682To avoid having to explicitly tell libev about such cases, libev follows
1620the following policy: Each time C<ev_io_set> is being called, libev 1683the following policy: Each time C<ev_io_set> is being called, libev
1621will assume that this is potentially a new file descriptor, otherwise 1684will assume that this is potentially a new file descriptor, otherwise
1622it is assumed that the file descriptor stays the same. That means that 1685it is assumed that the file descriptor stays the same. That means that
1671when you rarely read from a file instead of from a socket, and want to 1734when you rarely read from a file instead of from a socket, and want to
1672reuse the same code path. 1735reuse the same code path.
1673 1736
1674=head3 The special problem of fork 1737=head3 The special problem of fork
1675 1738
1676Some backends (epoll, kqueue) do not support C<fork ()> at all or exhibit 1739Some backends (epoll, kqueue, probably linuxaio) do not support C<fork ()>
1677useless behaviour. Libev fully supports fork, but needs to be told about 1740at all or exhibit useless behaviour. Libev fully supports fork, but needs
1678it in the child if you want to continue to use it in the child. 1741to be told about it in the child if you want to continue to use it in the
1742child.
1679 1743
1680To support fork in your child processes, you have to call C<ev_loop_fork 1744To support fork in your child processes, you have to call C<ev_loop_fork
1681()> after a fork in the child, enable C<EVFLAG_FORKCHECK>, or resort to 1745()> after a fork in the child, enable C<EVFLAG_FORKCHECK>, or resort to
1682C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>. 1746C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>.
1683 1747
2110 2174
2111=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 2175=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
2112 2176
2113=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat) 2177=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
2114 2178
2115Configure the timer to trigger after C<after> seconds. If C<repeat> 2179Configure the timer to trigger after C<after> seconds (fractional and
2116is C<0.>, then it will automatically be stopped once the timeout is 2180negative values are supported). If C<repeat> is C<0.>, then it will
2117reached. If it is positive, then the timer will automatically be 2181automatically be stopped once the timeout is reached. If it is positive,
2118configured to trigger again C<repeat> seconds later, again, and again, 2182then the timer will automatically be configured to trigger again C<repeat>
2119until stopped manually. 2183seconds later, again, and again, until stopped manually.
2120 2184
2121The timer itself will do a best-effort at avoiding drift, that is, if 2185The timer itself will do a best-effort at avoiding drift, that is, if
2122you configure a timer to trigger every 10 seconds, then it will normally 2186you configure a timer to trigger every 10 seconds, then it will normally
2123trigger at exactly 10 second intervals. If, however, your program cannot 2187trigger at exactly 10 second intervals. If, however, your program cannot
2124keep up with the timer (because it takes longer than those 10 seconds to 2188keep up with the timer (because it takes longer than those 10 seconds to
2206Periodic watchers are also timers of a kind, but they are very versatile 2270Periodic watchers are also timers of a kind, but they are very versatile
2207(and unfortunately a bit complex). 2271(and unfortunately a bit complex).
2208 2272
2209Unlike C<ev_timer>, periodic watchers are not based on real time (or 2273Unlike C<ev_timer>, periodic watchers are not based on real time (or
2210relative time, the physical time that passes) but on wall clock time 2274relative time, the physical time that passes) but on wall clock time
2211(absolute time, the thing you can read on your calender or clock). The 2275(absolute time, the thing you can read on your calendar or clock). The
2212difference is that wall clock time can run faster or slower than real 2276difference is that wall clock time can run faster or slower than real
2213time, and time jumps are not uncommon (e.g. when you adjust your 2277time, and time jumps are not uncommon (e.g. when you adjust your
2214wrist-watch). 2278wrist-watch).
2215 2279
2216You can tell a periodic watcher to trigger after some specific point 2280You can tell a periodic watcher to trigger after some specific point
2221C<ev_timer>, which would still trigger roughly 10 seconds after starting 2285C<ev_timer>, which would still trigger roughly 10 seconds after starting
2222it, as it uses a relative timeout). 2286it, as it uses a relative timeout).
2223 2287
2224C<ev_periodic> watchers can also be used to implement vastly more complex 2288C<ev_periodic> watchers can also be used to implement vastly more complex
2225timers, such as triggering an event on each "midnight, local time", or 2289timers, such as triggering an event on each "midnight, local time", or
2226other complicated rules. This cannot be done with C<ev_timer> watchers, as 2290other complicated rules. This cannot easily be done with C<ev_timer>
2227those cannot react to time jumps. 2291watchers, as those cannot react to time jumps.
2228 2292
2229As with timers, the callback is guaranteed to be invoked only when the 2293As with timers, the callback is guaranteed to be invoked only when the
2230point in time where it is supposed to trigger has passed. If multiple 2294point in time where it is supposed to trigger has passed. If multiple
2231timers become ready during the same loop iteration then the ones with 2295timers become ready during the same loop iteration then the ones with
2232earlier time-out values are invoked before ones with later time-out values 2296earlier time-out values are invoked before ones with later time-out values
2318 2382
2319NOTE: I<< This callback must always return a time that is higher than or 2383NOTE: I<< This callback must always return a time that is higher than or
2320equal to the passed C<now> value >>. 2384equal to the passed C<now> value >>.
2321 2385
2322This can be used to create very complex timers, such as a timer that 2386This can be used to create very complex timers, such as a timer that
2323triggers on "next midnight, local time". To do this, you would calculate the 2387triggers on "next midnight, local time". To do this, you would calculate
2324next midnight after C<now> and return the timestamp value for this. How 2388the next midnight after C<now> and return the timestamp value for
2325you do this is, again, up to you (but it is not trivial, which is the main 2389this. Here is a (completely untested, no error checking) example on how to
2326reason I omitted it as an example). 2390do this:
2391
2392 #include <time.h>
2393
2394 static ev_tstamp
2395 my_rescheduler (ev_periodic *w, ev_tstamp now)
2396 {
2397 time_t tnow = (time_t)now;
2398 struct tm tm;
2399 localtime_r (&tnow, &tm);
2400
2401 tm.tm_sec = tm.tm_min = tm.tm_hour = 0; // midnight current day
2402 ++tm.tm_mday; // midnight next day
2403
2404 return mktime (&tm);
2405 }
2406
2407Note: this code might run into trouble on days that have more then two
2408midnights (beginning and end).
2327 2409
2328=back 2410=back
2329 2411
2330=item ev_periodic_again (loop, ev_periodic *) 2412=item ev_periodic_again (loop, ev_periodic *)
2331 2413
3514 3596
3515There are some other functions of possible interest. Described. Here. Now. 3597There are some other functions of possible interest. Described. Here. Now.
3516 3598
3517=over 4 3599=over 4
3518 3600
3519=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback) 3601=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback, arg)
3520 3602
3521This function combines a simple timer and an I/O watcher, calls your 3603This function combines a simple timer and an I/O watcher, calls your
3522callback on whichever event happens first and automatically stops both 3604callback on whichever event happens first and automatically stops both
3523watchers. This is useful if you want to wait for a single event on an fd 3605watchers. This is useful if you want to wait for a single event on an fd
3524or timeout without having to allocate/configure/start/stop/free one or 3606or timeout without having to allocate/configure/start/stop/free one or
3956The normal C API should work fine when used from C++: both ev.h and the 4038The normal C API should work fine when used from C++: both ev.h and the
3957libev sources can be compiled as C++. Therefore, code that uses the C API 4039libev sources can be compiled as C++. Therefore, code that uses the C API
3958will work fine. 4040will work fine.
3959 4041
3960Proper exception specifications might have to be added to callbacks passed 4042Proper exception specifications might have to be added to callbacks passed
3961to libev: exceptions may be thrown only from watcher callbacks, all 4043to libev: exceptions may be thrown only from watcher callbacks, all other
3962other callbacks (allocator, syserr, loop acquire/release and periodic 4044callbacks (allocator, syserr, loop acquire/release and periodic reschedule
3963reschedule callbacks) must not throw exceptions, and might need a C<throw 4045callbacks) must not throw exceptions, and might need a C<noexcept>
3964()> specification. If you have code that needs to be compiled as both C 4046specification. If you have code that needs to be compiled as both C and
3965and C++ you can use the C<EV_THROW> macro for this: 4047C++ you can use the C<EV_NOEXCEPT> macro for this:
3966 4048
3967 static void 4049 static void
3968 fatal_error (const char *msg) EV_THROW 4050 fatal_error (const char *msg) EV_NOEXCEPT
3969 { 4051 {
3970 perror (msg); 4052 perror (msg);
3971 abort (); 4053 abort ();
3972 } 4054 }
3973 4055
4383 ev_vars.h 4465 ev_vars.h
4384 ev_wrap.h 4466 ev_wrap.h
4385 4467
4386 ev_win32.c required on win32 platforms only 4468 ev_win32.c required on win32 platforms only
4387 4469
4388 ev_select.c only when select backend is enabled (which is enabled by default) 4470 ev_select.c only when select backend is enabled
4389 ev_poll.c only when poll backend is enabled (disabled by default) 4471 ev_poll.c only when poll backend is enabled
4390 ev_epoll.c only when the epoll backend is enabled (disabled by default) 4472 ev_epoll.c only when the epoll backend is enabled
4473 ev_linuxaio.c only when the linux aio backend is enabled
4391 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 4474 ev_kqueue.c only when the kqueue backend is enabled
4392 ev_port.c only when the solaris port backend is enabled (disabled by default) 4475 ev_port.c only when the solaris port backend is enabled
4393 4476
4394F<ev.c> includes the backend files directly when enabled, so you only need 4477F<ev.c> includes the backend files directly when enabled, so you only need
4395to compile this single file. 4478to compile this single file.
4396 4479
4397=head3 LIBEVENT COMPATIBILITY API 4480=head3 LIBEVENT COMPATIBILITY API
4585If defined to be C<1>, libev will compile in support for the Linux 4668If defined to be C<1>, libev will compile in support for the Linux
4586C<epoll>(7) backend. Its availability will be detected at runtime, 4669C<epoll>(7) backend. Its availability will be detected at runtime,
4587otherwise another method will be used as fallback. This is the preferred 4670otherwise another method will be used as fallback. This is the preferred
4588backend for GNU/Linux systems. If undefined, it will be enabled if the 4671backend for GNU/Linux systems. If undefined, it will be enabled if the
4589headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled. 4672headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled.
4673
4674=item EV_USE_LINUXAIO
4675
4676If defined to be C<1>, libev will compile in support for the Linux
4677aio backend. Due to it's currenbt limitations it has to be requested
4678explicitly. If undefined, it will be enabled on linux, otherwise
4679disabled.
4590 4680
4591=item EV_USE_KQUEUE 4681=item EV_USE_KQUEUE
4592 4682
4593If defined to be C<1>, libev will compile in support for the BSD style 4683If defined to be C<1>, libev will compile in support for the BSD style
4594C<kqueue>(2) backend. Its actual availability will be detected at runtime, 4684C<kqueue>(2) backend. Its actual availability will be detected at runtime,
5297structure (guaranteed by POSIX but not by ISO C for example), but it also 5387structure (guaranteed by POSIX but not by ISO C for example), but it also
5298assumes that the same (machine) code can be used to call any watcher 5388assumes that the same (machine) code can be used to call any watcher
5299callback: The watcher callbacks have different type signatures, but libev 5389callback: The watcher callbacks have different type signatures, but libev
5300calls them using an C<ev_watcher *> internally. 5390calls them using an C<ev_watcher *> internally.
5301 5391
5392=item null pointers and integer zero are represented by 0 bytes
5393
5394Libev uses C<memset> to initialise structs and arrays to C<0> bytes, and
5395relies on this setting pointers and integers to null.
5396
5302=item pointer accesses must be thread-atomic 5397=item pointer accesses must be thread-atomic
5303 5398
5304Accessing a pointer value must be atomic, it must both be readable and 5399Accessing a pointer value must be atomic, it must both be readable and
5305writable in one piece - this is the case on all current architectures. 5400writable in one piece - this is the case on all current architectures.
5306 5401

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines