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

Comparing libev/ev.3 (file contents):
Revision 1.113 by root, Mon Jun 24 19:53:47 2019 UTC vs.
Revision 1.125 by sf-exg, Sun May 14 19:02:31 2023 UTC

131.\} 131.\}
132.rm #[ #] #H #V #F C 132.rm #[ #] #H #V #F C
133.\" ======================================================================== 133.\" ========================================================================
134.\" 134.\"
135.IX Title "LIBEV 3" 135.IX Title "LIBEV 3"
136.TH LIBEV 3 "2019-06-24" "libev-4.25" "libev - high performance full featured event loop" 136.TH LIBEV 3 "2021-01-11" "libev-4.33" "libev - high performance full featured event loop"
137.\" For nroff, turn off justification. Always turn off hyphenation; it makes 137.\" For nroff, turn off justification. Always turn off hyphenation; it makes
138.\" way too many mistakes in technical documents. 138.\" way too many mistakes in technical documents.
139.if n .ad l 139.if n .ad l
140.nh 140.nh
141.SH "NAME" 141.SH "NAME"
291When libev detects a usage error such as a negative timer interval, then 291When libev detects a usage error such as a negative timer interval, then
292it will print a diagnostic message and abort (via the \f(CW\*(C`assert\*(C'\fR mechanism, 292it will print a diagnostic message and abort (via the \f(CW\*(C`assert\*(C'\fR mechanism,
293so \f(CW\*(C`NDEBUG\*(C'\fR will disable this checking): these are programming errors in 293so \f(CW\*(C`NDEBUG\*(C'\fR will disable this checking): these are programming errors in
294the libev caller and need to be fixed there. 294the libev caller and need to be fixed there.
295.PP 295.PP
296Via the \f(CW\*(C`EV_FREQUENT\*(C'\fR macro you can compile in and/or enable extensive
297consistency checking code inside libev that can be used to check for
298internal inconsistencies, suually caused by application bugs.
299.PP
296Libev also has a few internal error-checking \f(CW\*(C`assert\*(C'\fRions, and also has 300Libev also has a few internal error-checking \f(CW\*(C`assert\*(C'\fRions. These do not
297extensive consistency checking code. These do not trigger under normal
298circumstances, as they indicate either a bug in libev or worse. 301trigger under normal circumstances, as they indicate either a bug in libev
302or worse.
299.SH "GLOBAL FUNCTIONS" 303.SH "GLOBAL FUNCTIONS"
300.IX Header "GLOBAL FUNCTIONS" 304.IX Header "GLOBAL FUNCTIONS"
301These functions can be called anytime, even before initialising the 305These functions can be called anytime, even before initialising the
302library in any way. 306library in any way.
303.IP "ev_tstamp ev_time ()" 4 307.IP "ev_tstamp ev_time ()" 4
602want to handle signals only in specific threads and want to avoid libev 606want to handle signals only in specific threads and want to avoid libev
603unblocking the signals. 607unblocking the signals.
604.Sp 608.Sp
605It's also required by \s-1POSIX\s0 in a threaded program, as libev calls 609It's also required by \s-1POSIX\s0 in a threaded program, as libev calls
606\&\f(CW\*(C`sigprocmask\*(C'\fR, whose behaviour is officially unspecified. 610\&\f(CW\*(C`sigprocmask\*(C'\fR, whose behaviour is officially unspecified.
611.ie n .IP """EVFLAG_NOTIMERFD""" 4
612.el .IP "\f(CWEVFLAG_NOTIMERFD\fR" 4
613.IX Item "EVFLAG_NOTIMERFD"
614When this flag is specified, the libev will avoid using a \f(CW\*(C`timerfd\*(C'\fR to
615detect time jumps. It will still be able to detect time jumps, but takes
616longer and has a lower accuracy in doing so, but saves a file descriptor
617per loop.
607.Sp 618.Sp
608This flag's behaviour will become the default in future versions of libev. 619The current implementation only tries to use a \f(CW\*(C`timerfd\*(C'\fR when the first
620\&\f(CW\*(C`ev_periodic\*(C'\fR watcher is started and falls back on other methods if it
621cannot be created, but this behaviour might change in the future.
609.ie n .IP """EVBACKEND_SELECT"" (value 1, portable select backend)" 4 622.ie n .IP """EVBACKEND_SELECT"" (value 1, portable select backend)" 4
610.el .IP "\f(CWEVBACKEND_SELECT\fR (value 1, portable select backend)" 4 623.el .IP "\f(CWEVBACKEND_SELECT\fR (value 1, portable select backend)" 4
611.IX Item "EVBACKEND_SELECT (value 1, portable select backend)" 624.IX Item "EVBACKEND_SELECT (value 1, portable select backend)"
612This is your standard \fBselect\fR\|(2) backend. Not \fIcompletely\fR standard, as 625This is your standard \fBselect\fR\|(2) backend. Not \fIcompletely\fR standard, as
613libev tries to roll its own fd_set with no limits on the number of fds, 626libev tries to roll its own fd_set with no limits on the number of fds,
638This backend maps \f(CW\*(C`EV_READ\*(C'\fR to \f(CW\*(C`POLLIN | POLLERR | POLLHUP\*(C'\fR, and 651This backend maps \f(CW\*(C`EV_READ\*(C'\fR to \f(CW\*(C`POLLIN | POLLERR | POLLHUP\*(C'\fR, and
639\&\f(CW\*(C`EV_WRITE\*(C'\fR to \f(CW\*(C`POLLOUT | POLLERR | POLLHUP\*(C'\fR. 652\&\f(CW\*(C`EV_WRITE\*(C'\fR to \f(CW\*(C`POLLOUT | POLLERR | POLLHUP\*(C'\fR.
640.ie n .IP """EVBACKEND_EPOLL"" (value 4, Linux)" 4 653.ie n .IP """EVBACKEND_EPOLL"" (value 4, Linux)" 4
641.el .IP "\f(CWEVBACKEND_EPOLL\fR (value 4, Linux)" 4 654.el .IP "\f(CWEVBACKEND_EPOLL\fR (value 4, Linux)" 4
642.IX Item "EVBACKEND_EPOLL (value 4, Linux)" 655.IX Item "EVBACKEND_EPOLL (value 4, Linux)"
643Use the linux-specific \fBepoll\fR\|(7) interface (for both pre\- and post\-2.6.9 656Use the Linux-specific \fBepoll\fR\|(7) interface (for both pre\- and post\-2.6.9
644kernels). 657kernels).
645.Sp 658.Sp
646For few fds, this backend is a bit little slower than poll and select, but 659For few fds, this backend is a bit little slower than poll and select, but
647it scales phenomenally better. While poll and select usually scale like 660it scales phenomenally better. While poll and select usually scale like
648O(total_fds) where total_fds is the total number of fds (or the highest 661O(total_fds) where total_fds is the total number of fds (or the highest
701This backend maps \f(CW\*(C`EV_READ\*(C'\fR and \f(CW\*(C`EV_WRITE\*(C'\fR in the same way as 714This backend maps \f(CW\*(C`EV_READ\*(C'\fR and \f(CW\*(C`EV_WRITE\*(C'\fR in the same way as
702\&\f(CW\*(C`EVBACKEND_POLL\*(C'\fR. 715\&\f(CW\*(C`EVBACKEND_POLL\*(C'\fR.
703.ie n .IP """EVBACKEND_LINUXAIO"" (value 64, Linux)" 4 716.ie n .IP """EVBACKEND_LINUXAIO"" (value 64, Linux)" 4
704.el .IP "\f(CWEVBACKEND_LINUXAIO\fR (value 64, Linux)" 4 717.el .IP "\f(CWEVBACKEND_LINUXAIO\fR (value 64, Linux)" 4
705.IX Item "EVBACKEND_LINUXAIO (value 64, Linux)" 718.IX Item "EVBACKEND_LINUXAIO (value 64, Linux)"
706Use the linux-specific linux aio (\fInot\fR \f(CWaio(7)\fR but \f(CWio_submit(2)\fR) event interface available in post\-4.18 kernels. 719Use the Linux-specific Linux \s-1AIO\s0 (\fInot\fR \f(CWaio(7)\fR but \f(CWio_submit(2)\fR) event interface available in post\-4.18 kernels (but libev
720only tries to use it in 4.19+).
721.Sp
722This is another Linux train wreck of an event interface.
707.Sp 723.Sp
708If this backend works for you (as of this writing, it was very 724If this backend works for you (as of this writing, it was very
709experimental), it is the best event interface available on linux and might 725experimental), it is the best event interface available on Linux and might
710be well worth enabling it \- if it isn't available in your kernel this will 726be well worth enabling it \- if it isn't available in your kernel this will
711be detected and this backend will be skipped. 727be detected and this backend will be skipped.
712.Sp 728.Sp
713This backend can batch oneshot requests and supports a user-space ring 729This backend can batch oneshot requests and supports a user-space ring
714buffer to receive events. It also doesn't suffer from most of the design 730buffer to receive events. It also doesn't suffer from most of the design
715problems of epoll (such as not being able to remove event sources from the 731problems of epoll (such as not being able to remove event sources from
716epoll set), and generally sounds too good to be true. Because, this being 732the epoll set), and generally sounds too good to be true. Because, this
717the linux kernel, of course it suffers from a whole new set of limitations. 733being the Linux kernel, of course it suffers from a whole new set of
734limitations, forcing you to fall back to epoll, inheriting all its design
735issues.
718.Sp 736.Sp
719For one, it is not easily embeddable (but probably could be done using 737For one, it is not easily embeddable (but probably could be done using
720an event fd at some extra overhead). It also is subject to a system wide 738an event fd at some extra overhead). It also is subject to a system wide
721limit that can be configured in \fI/proc/sys/fs/aio\-max\-nr\fR \- each loop 739limit that can be configured in \fI/proc/sys/fs/aio\-max\-nr\fR. If no \s-1AIO\s0
722currently requires \f(CW61\fR of this number. If no aio requests are left, this
723backend will be skipped during initialisation. 740requests are left, this backend will be skipped during initialisation, and
741will switch to epoll when the loop is active.
724.Sp 742.Sp
725Most problematic in practise, however, is that not all file descriptors 743Most problematic in practice, however, is that not all file descriptors
726work with it. For example, in linux 5.1, tcp sockets, pipes, event fds, 744work with it. For example, in Linux 5.1, \s-1TCP\s0 sockets, pipes, event fds,
727files, \fI/dev/null\fR and a few others are supported, but ttys do not work 745files, \fI/dev/null\fR and many others are supported, but ttys do not work
728properly (a known bug that the kernel developers don't care about, see 746properly (a known bug that the kernel developers don't care about, see
729<https://lore.kernel.org/patchwork/patch/1047453/>), so this is not 747<https://lore.kernel.org/patchwork/patch/1047453/>), so this is not
730(yet?) a generic event polling interface. 748(yet?) a generic event polling interface.
731.Sp 749.Sp
732Overall, it seems the linux developers just don't want it to have a 750Overall, it seems the Linux developers just don't want it to have a
733generic event handling mechanism other than \f(CW\*(C`select\*(C'\fR or \f(CW\*(C`poll\*(C'\fR. 751generic event handling mechanism other than \f(CW\*(C`select\*(C'\fR or \f(CW\*(C`poll\*(C'\fR.
734.Sp 752.Sp
735To work around the fd type problem, the current version of libev uses 753To work around all these problem, the current version of libev uses its
736epoll as a fallback for file deescriptor types that do not work. Epoll 754epoll backend as a fallback for file descriptor types that do not work. Or
737is used in, kind of, slow mode that hopefully avoids most of its design 755falls back completely to epoll if the kernel acts up.
738problems and requires 1\-3 extra syscalls per active fd every iteration.
739.Sp 756.Sp
740This backend maps \f(CW\*(C`EV_READ\*(C'\fR and \f(CW\*(C`EV_WRITE\*(C'\fR in the same way as 757This backend maps \f(CW\*(C`EV_READ\*(C'\fR and \f(CW\*(C`EV_WRITE\*(C'\fR in the same way as
741\&\f(CW\*(C`EVBACKEND_POLL\*(C'\fR. 758\&\f(CW\*(C`EVBACKEND_POLL\*(C'\fR.
742.ie n .IP """EVBACKEND_KQUEUE"" (value 8, most \s-1BSD\s0 clones)" 4 759.ie n .IP """EVBACKEND_KQUEUE"" (value 8, most \s-1BSD\s0 clones)" 4
743.el .IP "\f(CWEVBACKEND_KQUEUE\fR (value 8, most \s-1BSD\s0 clones)" 4 760.el .IP "\f(CWEVBACKEND_KQUEUE\fR (value 8, most \s-1BSD\s0 clones)" 4
744.IX Item "EVBACKEND_KQUEUE (value 8, most BSD clones)" 761.IX Item "EVBACKEND_KQUEUE (value 8, most BSD clones)"
745Kqueue deserves special mention, as at the time of this writing, it 762Kqueue deserves special mention, as at the time this backend was
746was broken on all BSDs except NetBSD (usually it doesn't work reliably 763implemented, it was broken on all BSDs except NetBSD (usually it doesn't
747with anything but sockets and pipes, except on Darwin, where of course 764work reliably with anything but sockets and pipes, except on Darwin,
748it's completely useless). Unlike epoll, however, whose brokenness 765where of course it's completely useless). Unlike epoll, however, whose
749is by design, these kqueue bugs can (and eventually will) be fixed 766brokenness is by design, these kqueue bugs can be (and mostly have been)
750without \s-1API\s0 changes to existing programs. For this reason it's not being 767fixed without \s-1API\s0 changes to existing programs. For this reason it's not
751\&\*(L"auto-detected\*(R" unless you explicitly specify it in the flags (i.e. using 768being \*(L"auto-detected\*(R" on all platforms unless you explicitly specify it
752\&\f(CW\*(C`EVBACKEND_KQUEUE\*(C'\fR) or libev was compiled on a known-to-be-good (\-enough) 769in the flags (i.e. using \f(CW\*(C`EVBACKEND_KQUEUE\*(C'\fR) or libev was compiled on a
753system like NetBSD. 770known-to-be-good (\-enough) system like NetBSD.
754.Sp 771.Sp
755You still can embed kqueue into a normal poll or select backend and use it 772You still can embed kqueue into a normal poll or select backend and use it
756only for sockets (after having made sure that sockets work with kqueue on 773only for sockets (after having made sure that sockets work with kqueue on
757the target platform). See \f(CW\*(C`ev_embed\*(C'\fR watchers for more info. 774the target platform). See \f(CW\*(C`ev_embed\*(C'\fR watchers for more info.
758.Sp 775.Sp
759It scales in the same way as the epoll backend, but the interface to the 776It scales in the same way as the epoll backend, but the interface to the
760kernel is more efficient (which says nothing about its actual speed, of 777kernel is more efficient (which says nothing about its actual speed, of
761course). While stopping, setting and starting an I/O watcher does never 778course). While stopping, setting and starting an I/O watcher does never
762cause an extra system call as with \f(CW\*(C`EVBACKEND_EPOLL\*(C'\fR, it still adds up to 779cause an extra system call as with \f(CW\*(C`EVBACKEND_EPOLL\*(C'\fR, it still adds up to
763two event changes per incident. Support for \f(CW\*(C`fork ()\*(C'\fR is very bad (you 780two event changes per incident. Support for \f(CW\*(C`fork ()\*(C'\fR is very bad (you
764might have to leak fd's on fork, but it's more sane than epoll) and it 781might have to leak fds on fork, but it's more sane than epoll) and it
765drops fds silently in similarly hard-to-detect cases. 782drops fds silently in similarly hard-to-detect cases.
766.Sp 783.Sp
767This backend usually performs well under most conditions. 784This backend usually performs well under most conditions.
768.Sp 785.Sp
769While nominally embeddable in other event loops, this doesn't work 786While nominally embeddable in other event loops, this doesn't work
1070\& \- Queue all expired timers. 1087\& \- Queue all expired timers.
1071\& \- Queue all expired periodics. 1088\& \- Queue all expired periodics.
1072\& \- Queue all idle watchers with priority higher than that of pending events. 1089\& \- Queue all idle watchers with priority higher than that of pending events.
1073\& \- Queue all check watchers. 1090\& \- Queue all check watchers.
1074\& \- Call all queued watchers in reverse order (i.e. check watchers first). 1091\& \- Call all queued watchers in reverse order (i.e. check watchers first).
1075\& Signals and child watchers are implemented as I/O watchers, and will 1092\& Signals, async and child watchers are implemented as I/O watchers, and
1076\& be handled here by queueing them when their watcher gets executed. 1093\& will be handled here by queueing them when their watcher gets executed.
1077\& \- If ev_break has been called, or EVRUN_ONCE or EVRUN_NOWAIT 1094\& \- If ev_break has been called, or EVRUN_ONCE or EVRUN_NOWAIT
1078\& were used, or there are no active watchers, goto FINISH, otherwise 1095\& were used, or there are no active watchers, goto FINISH, otherwise
1079\& continue with step LOOP. 1096\& continue with step LOOP.
1080\& FINISH: 1097\& FINISH:
1081\& \- Reset the ev_break status iff it was EVBREAK_ONE. 1098\& \- Reset the ev_break status iff it was EVBREAK_ONE.
1332with a watcher-specific start function (\f(CW\*(C`ev_TYPE_start (loop, watcher 1349with a watcher-specific start function (\f(CW\*(C`ev_TYPE_start (loop, watcher
1333*)\*(C'\fR), and you can stop watching for events at any time by calling the 1350*)\*(C'\fR), and you can stop watching for events at any time by calling the
1334corresponding stop function (\f(CW\*(C`ev_TYPE_stop (loop, watcher *)\*(C'\fR. 1351corresponding stop function (\f(CW\*(C`ev_TYPE_stop (loop, watcher *)\*(C'\fR.
1335.PP 1352.PP
1336As long as your watcher is active (has been started but not stopped) you 1353As long as your watcher is active (has been started but not stopped) you
1337must not touch the values stored in it. Most specifically you must never 1354must not touch the values stored in it except when explicitly documented
1338reinitialise it or call its \f(CW\*(C`ev_TYPE_set\*(C'\fR macro. 1355otherwise. Most specifically you must never reinitialise it or call its
1356\&\f(CW\*(C`ev_TYPE_set\*(C'\fR macro.
1339.PP 1357.PP
1340Each and every callback receives the event loop pointer as first, the 1358Each and every callback receives the event loop pointer as first, the
1341registered watcher structure as second, and a bitset of received events as 1359registered watcher structure as second, and a bitset of received events as
1342third argument. 1360third argument.
1343.PP 1361.PP
1514therefore a good idea to always call its \f(CW\*(C`ev_TYPE_stop\*(C'\fR function. 1532therefore a good idea to always call its \f(CW\*(C`ev_TYPE_stop\*(C'\fR function.
1515.IP "bool ev_is_active (ev_TYPE *watcher)" 4 1533.IP "bool ev_is_active (ev_TYPE *watcher)" 4
1516.IX Item "bool ev_is_active (ev_TYPE *watcher)" 1534.IX Item "bool ev_is_active (ev_TYPE *watcher)"
1517Returns a true value iff the watcher is active (i.e. it has been started 1535Returns a true value iff the watcher is active (i.e. it has been started
1518and not yet been stopped). As long as a watcher is active you must not modify 1536and not yet been stopped). As long as a watcher is active you must not modify
1519it. 1537it unless documented otherwise.
1520.IP "bool ev_is_pending (ev_TYPE *watcher)" 4 1538.IP "bool ev_is_pending (ev_TYPE *watcher)" 4
1521.IX Item "bool ev_is_pending (ev_TYPE *watcher)" 1539.IX Item "bool ev_is_pending (ev_TYPE *watcher)"
1522Returns a true value iff the watcher is pending, (i.e. it has outstanding 1540Returns a true value iff the watcher is pending, (i.e. it has outstanding
1523events but its callback has not yet been invoked). As long as a watcher 1541events but its callback has not yet been invoked). As long as a watcher
1524is pending (but not active) you must not call an init function on it (but 1542is pending (but not active) you must not call an init function on it (but
1646.IX Subsection "WATCHER PRIORITY MODELS" 1664.IX Subsection "WATCHER PRIORITY MODELS"
1647Many event loops support \fIwatcher priorities\fR, which are usually small 1665Many event loops support \fIwatcher priorities\fR, which are usually small
1648integers that influence the ordering of event callback invocation 1666integers that influence the ordering of event callback invocation
1649between watchers in some way, all else being equal. 1667between watchers in some way, all else being equal.
1650.PP 1668.PP
1651In libev, Watcher priorities can be set using \f(CW\*(C`ev_set_priority\*(C'\fR. See its 1669In libev, watcher priorities can be set using \f(CW\*(C`ev_set_priority\*(C'\fR. See its
1652description for the more technical details such as the actual priority 1670description for the more technical details such as the actual priority
1653range. 1671range.
1654.PP 1672.PP
1655There are two common ways how these these priorities are being interpreted 1673There are two common ways how these these priorities are being interpreted
1656by event loops: 1674by event loops:
1750.IX Header "WATCHER TYPES" 1768.IX Header "WATCHER TYPES"
1751This section describes each watcher in detail, but will not repeat 1769This section describes each watcher in detail, but will not repeat
1752information given in the last section. Any initialisation/set macros, 1770information given in the last section. Any initialisation/set macros,
1753functions and members specific to the watcher type are explained. 1771functions and members specific to the watcher type are explained.
1754.PP 1772.PP
1755Members are additionally marked with either \fI[read\-only]\fR, meaning that, 1773Most members are additionally marked with either \fI[read\-only]\fR, meaning
1756while the watcher is active, you can look at the member and expect some 1774that, while the watcher is active, you can look at the member and expect
1757sensible content, but you must not modify it (you can modify it while the 1775some sensible content, but you must not modify it (you can modify it while
1758watcher is stopped to your hearts content), or \fI[read\-write]\fR, which 1776the watcher is stopped to your hearts content), or \fI[read\-write]\fR, which
1759means you can expect it to have some sensible content while the watcher 1777means you can expect it to have some sensible content while the watcher is
1760is active, but you can also modify it. Modifying it may not do something 1778active, but you can also modify it (within the same thread as the event
1779loop, i.e. without creating data races). Modifying it may not do something
1761sensible or take immediate effect (or do anything at all), but libev will 1780sensible or take immediate effect (or do anything at all), but libev will
1762not crash or malfunction in any way. 1781not crash or malfunction in any way.
1782.PP
1783In any case, the documentation for each member will explain what the
1784effects are, and if there are any additional access restrictions.
1763.ie n .SS """ev_io"" \- is this file descriptor readable or writable?" 1785.ie n .SS """ev_io"" \- is this file descriptor readable or writable?"
1764.el .SS "\f(CWev_io\fP \- is this file descriptor readable or writable?" 1786.el .SS "\f(CWev_io\fP \- is this file descriptor readable or writable?"
1765.IX Subsection "ev_io - is this file descriptor readable or writable?" 1787.IX Subsection "ev_io - is this file descriptor readable or writable?"
1766I/O watchers check whether a file descriptor is readable or writable 1788I/O watchers check whether a file descriptor is readable or writable
1767in each iteration of the event loop, or, more precisely, when reading 1789in each iteration of the event loop, or, more precisely, when reading
1863reuse the same code path. 1885reuse the same code path.
1864.PP 1886.PP
1865\fIThe special problem of fork\fR 1887\fIThe special problem of fork\fR
1866.IX Subsection "The special problem of fork" 1888.IX Subsection "The special problem of fork"
1867.PP 1889.PP
1868Some backends (epoll, kqueue, probably linuxaio) do not support \f(CW\*(C`fork ()\*(C'\fR 1890Some backends (epoll, kqueue, linuxaio, iouring) do not support \f(CW\*(C`fork ()\*(C'\fR
1869at all or exhibit useless behaviour. Libev fully supports fork, but needs 1891at all or exhibit useless behaviour. Libev fully supports fork, but needs
1870to be told about it in the child if you want to continue to use it in the 1892to be told about it in the child if you want to continue to use it in the
1871child. 1893child.
1872.PP 1894.PP
1873To support fork in your child processes, you have to call \f(CW\*(C`ev_loop_fork 1895To support fork in your child processes, you have to call \f(CW\*(C`ev_loop_fork
1933.PD 0 1955.PD 0
1934.IP "ev_io_set (ev_io *, int fd, int events)" 4 1956.IP "ev_io_set (ev_io *, int fd, int events)" 4
1935.IX Item "ev_io_set (ev_io *, int fd, int events)" 1957.IX Item "ev_io_set (ev_io *, int fd, int events)"
1936.PD 1958.PD
1937Configures an \f(CW\*(C`ev_io\*(C'\fR watcher. The \f(CW\*(C`fd\*(C'\fR is the file descriptor to 1959Configures an \f(CW\*(C`ev_io\*(C'\fR watcher. The \f(CW\*(C`fd\*(C'\fR is the file descriptor to
1938receive events for and \f(CW\*(C`events\*(C'\fR is either \f(CW\*(C`EV_READ\*(C'\fR, \f(CW\*(C`EV_WRITE\*(C'\fR or 1960receive events for and \f(CW\*(C`events\*(C'\fR is either \f(CW\*(C`EV_READ\*(C'\fR, \f(CW\*(C`EV_WRITE\*(C'\fR, both
1939\&\f(CW\*(C`EV_READ | EV_WRITE\*(C'\fR, to express the desire to receive the given events. 1961\&\f(CW\*(C`EV_READ | EV_WRITE\*(C'\fR or \f(CW0\fR, to express the desire to receive the given
1962events.
1963.Sp
1964Note that setting the \f(CW\*(C`events\*(C'\fR to \f(CW0\fR and starting the watcher is
1965supported, but not specially optimized \- if your program sometimes happens
1966to generate this combination this is fine, but if it is easy to avoid
1967starting an io watcher watching for no events you should do so.
1968.IP "ev_io_modify (ev_io *, int events)" 4
1969.IX Item "ev_io_modify (ev_io *, int events)"
1970Similar to \f(CW\*(C`ev_io_set\*(C'\fR, but only changes the requested events. Using this
1971might be faster with some backends, as libev can assume that the \f(CW\*(C`fd\*(C'\fR
1972still refers to the same underlying file description, something it cannot
1973do when using \f(CW\*(C`ev_io_set\*(C'\fR.
1940.IP "int fd [read\-only]" 4 1974.IP "int fd [no\-modify]" 4
1941.IX Item "int fd [read-only]" 1975.IX Item "int fd [no-modify]"
1942The file descriptor being watched. 1976The file descriptor being watched. While it can be read at any time, you
1977must not modify this member even when the watcher is stopped \- always use
1978\&\f(CW\*(C`ev_io_set\*(C'\fR for that.
1943.IP "int events [read\-only]" 4 1979.IP "int events [no\-modify]" 4
1944.IX Item "int events [read-only]" 1980.IX Item "int events [no-modify]"
1945The events being watched. 1981The set of events the fd is being watched for, among other flags. Remember
1982that this is a bit set \- to test for \f(CW\*(C`EV_READ\*(C'\fR, use \f(CW\*(C`w\->events &
1983EV_READ\*(C'\fR, and similarly for \f(CW\*(C`EV_WRITE\*(C'\fR.
1984.Sp
1985As with \f(CW\*(C`fd\*(C'\fR, you must not modify this member even when the watcher is
1986stopped, always use \f(CW\*(C`ev_io_set\*(C'\fR or \f(CW\*(C`ev_io_modify\*(C'\fR for that.
1946.PP 1987.PP
1947\fIExamples\fR 1988\fIExamples\fR
1948.IX Subsection "Examples" 1989.IX Subsection "Examples"
1949.PP 1990.PP
1950Example: Call \f(CW\*(C`stdin_readable_cb\*(C'\fR when \s-1STDIN_FILENO\s0 has become, well 1991Example: Call \f(CW\*(C`stdin_readable_cb\*(C'\fR when \s-1STDIN_FILENO\s0 has become, well
3961.PP 4002.PP
3962First, you need to associate some data with the event loop: 4003First, you need to associate some data with the event loop:
3963.PP 4004.PP
3964.Vb 6 4005.Vb 6
3965\& typedef struct { 4006\& typedef struct {
3966\& mutex_t lock; /* global loop lock */ 4007\& pthread_mutex_t lock; /* global loop lock */
4008\& pthread_t tid;
4009\& pthread_cond_t invoke_cv;
3967\& ev_async async_w; 4010\& ev_async async_w;
3968\& thread_t tid;
3969\& cond_t invoke_cv;
3970\& } userdata; 4011\& } userdata;
3971\& 4012\&
3972\& void prepare_loop (EV_P) 4013\& void prepare_loop (EV_P)
3973\& { 4014\& {
3974\& // for simplicity, we use a static userdata struct. 4015\& // for simplicity, we use a static userdata struct.
3975\& static userdata u; 4016\& static userdata u;
3976\& 4017\&
3977\& ev_async_init (&u\->async_w, async_cb); 4018\& ev_async_init (&u.async_w, async_cb);
3978\& ev_async_start (EV_A_ &u\->async_w); 4019\& ev_async_start (EV_A_ &u.async_w);
3979\& 4020\&
3980\& pthread_mutex_init (&u\->lock, 0); 4021\& pthread_mutex_init (&u.lock, 0);
3981\& pthread_cond_init (&u\->invoke_cv, 0); 4022\& pthread_cond_init (&u.invoke_cv, 0);
3982\& 4023\&
3983\& // now associate this with the loop 4024\& // now associate this with the loop
3984\& ev_set_userdata (EV_A_ u); 4025\& ev_set_userdata (EV_A_ &u);
3985\& ev_set_invoke_pending_cb (EV_A_ l_invoke); 4026\& ev_set_invoke_pending_cb (EV_A_ l_invoke);
3986\& ev_set_loop_release_cb (EV_A_ l_release, l_acquire); 4027\& ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
3987\& 4028\&
3988\& // then create the thread running ev_run 4029\& // then create the thread running ev_run
3989\& pthread_create (&u\->tid, 0, l_run, EV_A); 4030\& pthread_create (&u.tid, 0, l_run, EV_A);
3990\& } 4031\& }
3991.Ve 4032.Ve
3992.PP 4033.PP
3993The callback for the \f(CW\*(C`ev_async\*(C'\fR watcher does nothing: the watcher is used 4034The callback for the \f(CW\*(C`ev_async\*(C'\fR watcher does nothing: the watcher is used
3994solely to wake up the event loop so it takes notice of any new watchers 4035solely to wake up the event loop so it takes notice of any new watchers
4378gets automatically stopped and restarted when reconfiguring it with this 4419gets automatically stopped and restarted when reconfiguring it with this
4379method. 4420method.
4380.Sp 4421.Sp
4381For \f(CW\*(C`ev::embed\*(C'\fR watchers this method is called \f(CW\*(C`set_embed\*(C'\fR, to avoid 4422For \f(CW\*(C`ev::embed\*(C'\fR watchers this method is called \f(CW\*(C`set_embed\*(C'\fR, to avoid
4382clashing with the \f(CW\*(C`set (loop)\*(C'\fR method. 4423clashing with the \f(CW\*(C`set (loop)\*(C'\fR method.
4424.Sp
4425For \f(CW\*(C`ev::io\*(C'\fR watchers there is an additional \f(CW\*(C`set\*(C'\fR method that acepts a
4426new event mask only, and internally calls \f(CW\*(C`ev_io_modify\*(C'\fR.
4383.IP "w\->start ()" 4 4427.IP "w\->start ()" 4
4384.IX Item "w->start ()" 4428.IX Item "w->start ()"
4385Starts the watcher. Note that there is no \f(CW\*(C`loop\*(C'\fR argument, as the 4429Starts the watcher. Note that there is no \f(CW\*(C`loop\*(C'\fR argument, as the
4386constructor already stores the event loop. 4430constructor already stores the event loop.
4387.IP "w\->start ([arguments])" 4 4431.IP "w\->start ([arguments])" 4
4616\& 4660\&
4617\& ev_select.c only when select backend is enabled 4661\& ev_select.c only when select backend is enabled
4618\& ev_poll.c only when poll backend is enabled 4662\& ev_poll.c only when poll backend is enabled
4619\& ev_epoll.c only when the epoll backend is enabled 4663\& ev_epoll.c only when the epoll backend is enabled
4620\& ev_linuxaio.c only when the linux aio backend is enabled 4664\& ev_linuxaio.c only when the linux aio backend is enabled
4665\& ev_iouring.c only when the linux io_uring backend is enabled
4621\& ev_kqueue.c only when the kqueue backend is enabled 4666\& ev_kqueue.c only when the kqueue backend is enabled
4622\& ev_port.c only when the solaris port backend is enabled 4667\& ev_port.c only when the solaris port backend is enabled
4623.Ve 4668.Ve
4624.PP 4669.PP
4625\&\fIev.c\fR includes the backend files directly when enabled, so you only need 4670\&\fIev.c\fR includes the backend files directly when enabled, so you only need
4738higher, as it simplifies linking (no need for \f(CW\*(C`\-lrt\*(C'\fR). 4783higher, as it simplifies linking (no need for \f(CW\*(C`\-lrt\*(C'\fR).
4739.IP "\s-1EV_USE_NANOSLEEP\s0" 4 4784.IP "\s-1EV_USE_NANOSLEEP\s0" 4
4740.IX Item "EV_USE_NANOSLEEP" 4785.IX Item "EV_USE_NANOSLEEP"
4741If defined to be \f(CW1\fR, libev will assume that \f(CW\*(C`nanosleep ()\*(C'\fR is available 4786If defined to be \f(CW1\fR, libev will assume that \f(CW\*(C`nanosleep ()\*(C'\fR is available
4742and will use it for delays. Otherwise it will use \f(CW\*(C`select ()\*(C'\fR. 4787and will use it for delays. Otherwise it will use \f(CW\*(C`select ()\*(C'\fR.
4788.IP "\s-1EV_USE_EVENTFD\s0" 4
4789.IX Item "EV_USE_EVENTFD"
4790If defined to be \f(CW1\fR, then libev will assume that \f(CW\*(C`eventfd ()\*(C'\fR is
4791available and will probe for kernel support at runtime. This will improve
4792\&\f(CW\*(C`ev_signal\*(C'\fR and \f(CW\*(C`ev_async\*(C'\fR performance and reduce resource consumption.
4793If undefined, it will be enabled if the headers indicate GNU/Linux + Glibc
47942.7 or newer, otherwise disabled.
4795.IP "\s-1EV_USE_SIGNALFD\s0" 4
4796.IX Item "EV_USE_SIGNALFD"
4797If defined to be \f(CW1\fR, then libev will assume that \f(CW\*(C`signalfd ()\*(C'\fR is
4798available and will probe for kernel support at runtime. This enables
4799the use of \s-1EVFLAG_SIGNALFD\s0 for faster and simpler signal handling. If
4800undefined, it will be enabled if the headers indicate GNU/Linux + Glibc
48012.7 or newer, otherwise disabled.
4802.IP "\s-1EV_USE_TIMERFD\s0" 4
4803.IX Item "EV_USE_TIMERFD"
4804If defined to be \f(CW1\fR, then libev will assume that \f(CW\*(C`timerfd ()\*(C'\fR is
4805available and will probe for kernel support at runtime. This allows
4806libev to detect time jumps accurately. If undefined, it will be enabled
4807if the headers indicate GNU/Linux + Glibc 2.8 or newer and define
4808\&\f(CW\*(C`TFD_TIMER_CANCEL_ON_SET\*(C'\fR, otherwise disabled.
4743.IP "\s-1EV_USE_EVENTFD\s0" 4 4809.IP "\s-1EV_USE_EVENTFD\s0" 4
4744.IX Item "EV_USE_EVENTFD" 4810.IX Item "EV_USE_EVENTFD"
4745If defined to be \f(CW1\fR, then libev will assume that \f(CW\*(C`eventfd ()\*(C'\fR is 4811If defined to be \f(CW1\fR, then libev will assume that \f(CW\*(C`eventfd ()\*(C'\fR is
4746available and will probe for kernel support at runtime. This will improve 4812available and will probe for kernel support at runtime. This will improve
4747\&\f(CW\*(C`ev_signal\*(C'\fR and \f(CW\*(C`ev_async\*(C'\fR performance and reduce resource consumption. 4813\&\f(CW\*(C`ev_signal\*(C'\fR and \f(CW\*(C`ev_async\*(C'\fR performance and reduce resource consumption.
4808otherwise another method will be used as fallback. This is the preferred 4874otherwise another method will be used as fallback. This is the preferred
4809backend for GNU/Linux systems. If undefined, it will be enabled if the 4875backend for GNU/Linux systems. If undefined, it will be enabled if the
4810headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled. 4876headers indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled.
4811.IP "\s-1EV_USE_LINUXAIO\s0" 4 4877.IP "\s-1EV_USE_LINUXAIO\s0" 4
4812.IX Item "EV_USE_LINUXAIO" 4878.IX Item "EV_USE_LINUXAIO"
4879If defined to be \f(CW1\fR, libev will compile in support for the Linux aio
4880backend (\f(CW\*(C`EV_USE_EPOLL\*(C'\fR must also be enabled). If undefined, it will be
4881enabled on linux, otherwise disabled.
4882.IP "\s-1EV_USE_IOURING\s0" 4
4883.IX Item "EV_USE_IOURING"
4813If defined to be \f(CW1\fR, libev will compile in support for the Linux 4884If defined to be \f(CW1\fR, libev will compile in support for the Linux
4814aio backend. Due to it's currenbt limitations it has to be requested 4885io_uring backend (\f(CW\*(C`EV_USE_EPOLL\*(C'\fR must also be enabled). Due to it's
4815explicitly. If undefined, it will be enabled on linux, otherwise 4886current limitations it has to be requested explicitly. If undefined, it
4816disabled. 4887will be enabled on linux, otherwise disabled.
4817.IP "\s-1EV_USE_KQUEUE\s0" 4 4888.IP "\s-1EV_USE_KQUEUE\s0" 4
4818.IX Item "EV_USE_KQUEUE" 4889.IX Item "EV_USE_KQUEUE"
4819If defined to be \f(CW1\fR, libev will compile in support for the \s-1BSD\s0 style 4890If defined to be \f(CW1\fR, libev will compile in support for the \s-1BSD\s0 style
4820\&\f(CW\*(C`kqueue\*(C'\fR(2) backend. Its actual availability will be detected at runtime, 4891\&\f(CW\*(C`kqueue\*(C'\fR(2) backend. Its actual availability will be detected at runtime,
4821otherwise another method will be used as fallback. This is the preferred 4892otherwise another method will be used as fallback. This is the preferred
5077in. If set to \f(CW1\fR, then verification code will be compiled in, but not 5148in. If set to \f(CW1\fR, then verification code will be compiled in, but not
5078called. If set to \f(CW2\fR, then the internal verification code will be 5149called. If set to \f(CW2\fR, then the internal verification code will be
5079called once per loop, which can slow down libev. If set to \f(CW3\fR, then the 5150called once per loop, which can slow down libev. If set to \f(CW3\fR, then the
5080verification code will be called very frequently, which will slow down 5151verification code will be called very frequently, which will slow down
5081libev considerably. 5152libev considerably.
5153.Sp
5154Verification errors are reported via C's \f(CW\*(C`assert\*(C'\fR mechanism, so if you
5155disable that (e.g. by defining \f(CW\*(C`NDEBUG\*(C'\fR) then no errors will be reported.
5082.Sp 5156.Sp
5083The default is \f(CW1\fR, unless \f(CW\*(C`EV_FEATURES\*(C'\fR overrides it, in which case it 5157The default is \f(CW1\fR, unless \f(CW\*(C`EV_FEATURES\*(C'\fR overrides it, in which case it
5084will be \f(CW0\fR. 5158will be \f(CW0\fR.
5085.IP "\s-1EV_COMMON\s0" 4 5159.IP "\s-1EV_COMMON\s0" 4
5086.IX Item "EV_COMMON" 5160.IX Item "EV_COMMON"

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines