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

Comparing libev/ev.pod (file contents):
Revision 1.253 by root, Tue Jul 14 18:33:48 2009 UTC vs.
Revision 1.283 by root, Wed Mar 10 09:18:25 2010 UTC

98=head2 FEATURES 98=head2 FEATURES
99 99
100Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the 100Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
101BSD-specific C<kqueue> and the Solaris-specific event port mechanisms 101BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
102for file descriptor events (C<ev_io>), the Linux C<inotify> interface 102for file descriptor events (C<ev_io>), the Linux C<inotify> interface
103(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers 103(for C<ev_stat>), Linux eventfd/signalfd (for faster and cleaner
104with customised rescheduling (C<ev_periodic>), synchronous signals 104inter-thread wakeup (C<ev_async>)/signal handling (C<ev_signal>)) relative
105(C<ev_signal>), process status change events (C<ev_child>), and event 105timers (C<ev_timer>), absolute timers with customised rescheduling
106watchers dealing with the event loop mechanism itself (C<ev_idle>, 106(C<ev_periodic>), synchronous signals (C<ev_signal>), process status
107C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as 107change events (C<ev_child>), and event watchers dealing with the event
108file watchers (C<ev_stat>) and even limited support for fork events 108loop mechanism itself (C<ev_idle>, C<ev_embed>, C<ev_prepare> and
109(C<ev_fork>). 109C<ev_check> watchers) as well as file watchers (C<ev_stat>) and even
110limited support for fork events (C<ev_fork>).
110 111
111It also is quite fast (see this 112It also is quite fast (see this
112L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent 113L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent
113for example). 114for example).
114 115
117Libev is very configurable. In this manual the default (and most common) 118Libev is very configurable. In this manual the default (and most common)
118configuration will be described, which supports multiple event loops. For 119configuration will be described, which supports multiple event loops. For
119more info about various configuration options please have a look at 120more info about various configuration options please have a look at
120B<EMBED> section in this manual. If libev was configured without support 121B<EMBED> section in this manual. If libev was configured without support
121for multiple event loops, then all functions taking an initial argument of 122for multiple event loops, then all functions taking an initial argument of
122name C<loop> (which is always of type C<ev_loop *>) will not have 123name C<loop> (which is always of type C<struct ev_loop *>) will not have
123this argument. 124this argument.
124 125
125=head2 TIME REPRESENTATION 126=head2 TIME REPRESENTATION
126 127
127Libev represents time as a single floating point number, representing 128Libev represents time as a single floating point number, representing
362flag. 363flag.
363 364
364This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS> 365This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
365environment variable. 366environment variable.
366 367
368=item C<EVFLAG_NOINOTIFY>
369
370When this flag is specified, then libev will not attempt to use the
371I<inotify> API for it's C<ev_stat> watchers. Apart from debugging and
372testing, this flag can be useful to conserve inotify file descriptors, as
373otherwise each loop using C<ev_stat> watchers consumes one inotify handle.
374
375=item C<EVFLAG_SIGNALFD>
376
377When this flag is specified, then libev will attempt to use the
378I<signalfd> API for it's C<ev_signal> (and C<ev_child>) watchers. This API
379delivers signals synchronously, which makes it both faster and might make
380it possible to get the queued signal data. It can also simplify signal
381handling with threads, as long as you properly block signals in your
382threads that are not interested in handling them.
383
384Signalfd will not be used by default as this changes your signal mask, and
385there are a lot of shoddy libraries and programs (glib's threadpool for
386example) that can't properly initialise their signal masks.
387
367=item C<EVBACKEND_SELECT> (value 1, portable select backend) 388=item C<EVBACKEND_SELECT> (value 1, portable select backend)
368 389
369This is your standard select(2) backend. Not I<completely> standard, as 390This is your standard select(2) backend. Not I<completely> standard, as
370libev tries to roll its own fd_set with no limits on the number of fds, 391libev tries to roll its own fd_set with no limits on the number of fds,
371but if that fails, expect a fairly low limit on the number of fds when 392but if that fails, expect a fairly low limit on the number of fds when
394 415
395This backend maps C<EV_READ> to C<POLLIN | POLLERR | POLLHUP>, and 416This backend maps C<EV_READ> to C<POLLIN | POLLERR | POLLHUP>, and
396C<EV_WRITE> to C<POLLOUT | POLLERR | POLLHUP>. 417C<EV_WRITE> to C<POLLOUT | POLLERR | POLLHUP>.
397 418
398=item C<EVBACKEND_EPOLL> (value 4, Linux) 419=item C<EVBACKEND_EPOLL> (value 4, Linux)
420
421Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9
422kernels).
399 423
400For few fds, this backend is a bit little slower than poll and select, 424For few fds, this backend is a bit little slower than poll and select,
401but it scales phenomenally better. While poll and select usually scale 425but it scales phenomenally better. While poll and select usually scale
402like O(total_fds) where n is the total number of fds (or the highest fd), 426like O(total_fds) where n is the total number of fds (or the highest fd),
403epoll scales either O(1) or O(active_fds). 427epoll scales either O(1) or O(active_fds).
518 542
519It is definitely not recommended to use this flag. 543It is definitely not recommended to use this flag.
520 544
521=back 545=back
522 546
523If one or more of these are or'ed into the flags value, then only these 547If one or more of the backend flags are or'ed into the flags value,
524backends will be tried (in the reverse order as listed here). If none are 548then only these backends will be tried (in the reverse order as listed
525specified, all backends in C<ev_recommended_backends ()> will be tried. 549here). If none are specified, all backends in C<ev_recommended_backends
550()> will be tried.
526 551
527Example: This is the most typical usage. 552Example: This is the most typical usage.
528 553
529 if (!ev_default_loop (0)) 554 if (!ev_default_loop (0))
530 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?"); 555 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
573as signal and child watchers) would need to be stopped manually. 598as signal and child watchers) would need to be stopped manually.
574 599
575In general it is not advisable to call this function except in the 600In general it is not advisable to call this function except in the
576rare occasion where you really need to free e.g. the signal handling 601rare occasion where you really need to free e.g. the signal handling
577pipe fds. If you need dynamically allocated loops it is better to use 602pipe fds. If you need dynamically allocated loops it is better to use
578C<ev_loop_new> and C<ev_loop_destroy>). 603C<ev_loop_new> and C<ev_loop_destroy>.
579 604
580=item ev_loop_destroy (loop) 605=item ev_loop_destroy (loop)
581 606
582Like C<ev_default_destroy>, but destroys an event loop created by an 607Like C<ev_default_destroy>, but destroys an event loop created by an
583earlier call to C<ev_loop_new>. 608earlier call to C<ev_loop_new>.
687event loop time (see C<ev_now_update>). 712event loop time (see C<ev_now_update>).
688 713
689=item ev_loop (loop, int flags) 714=item ev_loop (loop, int flags)
690 715
691Finally, this is it, the event handler. This function usually is called 716Finally, this is it, the event handler. This function usually is called
692after you initialised all your watchers and you want to start handling 717after you have initialised all your watchers and you want to start
693events. 718handling events.
694 719
695If the flags argument is specified as C<0>, it will not return until 720If the flags argument is specified as C<0>, it will not return until
696either no event watchers are active anymore or C<ev_unloop> was called. 721either no event watchers are active anymore or C<ev_unloop> was called.
697 722
698Please note that an explicit C<ev_unloop> is usually better than 723Please note that an explicit C<ev_unloop> is usually better than
772 797
773Ref/unref can be used to add or remove a reference count on the event 798Ref/unref can be used to add or remove a reference count on the event
774loop: Every watcher keeps one reference, and as long as the reference 799loop: Every watcher keeps one reference, and as long as the reference
775count is nonzero, C<ev_loop> will not return on its own. 800count is nonzero, C<ev_loop> will not return on its own.
776 801
777If you have a watcher you never unregister that should not keep C<ev_loop> 802This is useful when you have a watcher that you never intend to
778from returning, call ev_unref() after starting, and ev_ref() before 803unregister, but that nevertheless should not keep C<ev_loop> from
804returning. In such a case, call C<ev_unref> after starting, and C<ev_ref>
779stopping it. 805before stopping it.
780 806
781As an example, libev itself uses this for its internal signal pipe: It 807As an example, libev itself uses this for its internal signal pipe: It
782is not visible to the libev user and should not keep C<ev_loop> from 808is not visible to the libev user and should not keep C<ev_loop> from
783exiting if no event watchers registered by it are active. It is also an 809exiting if no event watchers registered by it are active. It is also an
784excellent way to do this for generic recurring timers or from within 810excellent way to do this for generic recurring timers or from within
862 888
863This call will simply invoke all pending watchers while resetting their 889This call will simply invoke all pending watchers while resetting their
864pending state. Normally, C<ev_loop> does this automatically when required, 890pending state. Normally, C<ev_loop> does this automatically when required,
865but when overriding the invoke callback this call comes handy. 891but when overriding the invoke callback this call comes handy.
866 892
893=item int ev_pending_count (loop)
894
895Returns the number of pending watchers - zero indicates that no watchers
896are pending.
897
867=item ev_set_invoke_pending_cb (loop, void (*invoke_pending_cb)(EV_P)) 898=item ev_set_invoke_pending_cb (loop, void (*invoke_pending_cb)(EV_P))
868 899
869This overrides the invoke pending functionality of the loop: Instead of 900This overrides the invoke pending functionality of the loop: Instead of
870invoking all pending watchers when there are any, C<ev_loop> will call 901invoking all pending watchers when there are any, C<ev_loop> will call
871this callback instead. This is useful, for example, when you want to 902this callback instead. This is useful, for example, when you want to
889suspended waiting for new events, and C<acquire> is called just 920suspended waiting for new events, and C<acquire> is called just
890afterwards. 921afterwards.
891 922
892Ideally, C<release> will just call your mutex_unlock function, and 923Ideally, C<release> will just call your mutex_unlock function, and
893C<acquire> will just call the mutex_lock function again. 924C<acquire> will just call the mutex_lock function again.
925
926While event loop modifications are allowed between invocations of
927C<release> and C<acquire> (that's their only purpose after all), no
928modifications done will affect the event loop, i.e. adding watchers will
929have no effect on the set of file descriptors being watched, or the time
930waited. Use an C<ev_async> watcher to wake up C<ev_loop> when you want it
931to take note of any changes you made.
932
933In theory, threads executing C<ev_loop> will be async-cancel safe between
934invocations of C<release> and C<acquire>.
935
936See also the locking example in the C<THREADS> section later in this
937document.
894 938
895=item ev_set_userdata (loop, void *data) 939=item ev_set_userdata (loop, void *data)
896 940
897=item ev_userdata (loop) 941=item ev_userdata (loop)
898 942
1088 1132
1089 ev_io w; 1133 ev_io w;
1090 ev_init (&w, my_cb); 1134 ev_init (&w, my_cb);
1091 ev_io_set (&w, STDIN_FILENO, EV_READ); 1135 ev_io_set (&w, STDIN_FILENO, EV_READ);
1092 1136
1093=item C<ev_TYPE_set> (ev_TYPE *, [args]) 1137=item C<ev_TYPE_set> (ev_TYPE *watcher, [args])
1094 1138
1095This macro initialises the type-specific parts of a watcher. You need to 1139This macro initialises the type-specific parts of a watcher. You need to
1096call C<ev_init> at least once before you call this macro, but you can 1140call C<ev_init> at least once before you call this macro, but you can
1097call C<ev_TYPE_set> any number of times. You must not, however, call this 1141call C<ev_TYPE_set> any number of times. You must not, however, call this
1098macro on a watcher that is active (it can be pending, however, which is a 1142macro on a watcher that is active (it can be pending, however, which is a
1111 1155
1112Example: Initialise and set an C<ev_io> watcher in one step. 1156Example: Initialise and set an C<ev_io> watcher in one step.
1113 1157
1114 ev_io_init (&w, my_cb, STDIN_FILENO, EV_READ); 1158 ev_io_init (&w, my_cb, STDIN_FILENO, EV_READ);
1115 1159
1116=item C<ev_TYPE_start> (loop *, ev_TYPE *watcher) 1160=item C<ev_TYPE_start> (loop, ev_TYPE *watcher)
1117 1161
1118Starts (activates) the given watcher. Only active watchers will receive 1162Starts (activates) the given watcher. Only active watchers will receive
1119events. If the watcher is already active nothing will happen. 1163events. If the watcher is already active nothing will happen.
1120 1164
1121Example: Start the C<ev_io> watcher that is being abused as example in this 1165Example: Start the C<ev_io> watcher that is being abused as example in this
1122whole section. 1166whole section.
1123 1167
1124 ev_io_start (EV_DEFAULT_UC, &w); 1168 ev_io_start (EV_DEFAULT_UC, &w);
1125 1169
1126=item C<ev_TYPE_stop> (loop *, ev_TYPE *watcher) 1170=item C<ev_TYPE_stop> (loop, ev_TYPE *watcher)
1127 1171
1128Stops the given watcher if active, and clears the pending status (whether 1172Stops the given watcher if active, and clears the pending status (whether
1129the watcher was active or not). 1173the watcher was active or not).
1130 1174
1131It is possible that stopped watchers are pending - for example, 1175It is possible that stopped watchers are pending - for example,
1156=item ev_cb_set (ev_TYPE *watcher, callback) 1200=item ev_cb_set (ev_TYPE *watcher, callback)
1157 1201
1158Change the callback. You can change the callback at virtually any time 1202Change the callback. You can change the callback at virtually any time
1159(modulo threads). 1203(modulo threads).
1160 1204
1161=item ev_set_priority (ev_TYPE *watcher, priority) 1205=item ev_set_priority (ev_TYPE *watcher, int priority)
1162 1206
1163=item int ev_priority (ev_TYPE *watcher) 1207=item int ev_priority (ev_TYPE *watcher)
1164 1208
1165Set and query the priority of the watcher. The priority is a small 1209Set and query the priority of the watcher. The priority is a small
1166integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI> 1210integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI>
1197returns its C<revents> bitset (as if its callback was invoked). If the 1241returns its C<revents> bitset (as if its callback was invoked). If the
1198watcher isn't pending it does nothing and returns C<0>. 1242watcher isn't pending it does nothing and returns C<0>.
1199 1243
1200Sometimes it can be useful to "poll" a watcher instead of waiting for its 1244Sometimes it can be useful to "poll" a watcher instead of waiting for its
1201callback to be invoked, which can be accomplished with this function. 1245callback to be invoked, which can be accomplished with this function.
1246
1247=item ev_feed_event (loop, ev_TYPE *watcher, int revents)
1248
1249Feeds the given event set into the event loop, as if the specified event
1250had happened for the specified watcher (which must be a pointer to an
1251initialised but not necessarily started event watcher). Obviously you must
1252not free the watcher as long as it has pending events.
1253
1254Stopping the watcher, letting libev invoke it, or calling
1255C<ev_clear_pending> will clear the pending event, even if the watcher was
1256not started in the first place.
1257
1258See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1259functions that do not need a watcher.
1202 1260
1203=back 1261=back
1204 1262
1205 1263
1206=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER 1264=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
1737 1795
1738If the event loop is suspended for a long time, you can also force an 1796If the event loop is suspended for a long time, you can also force an
1739update of the time returned by C<ev_now ()> by calling C<ev_now_update 1797update of the time returned by C<ev_now ()> by calling C<ev_now_update
1740()>. 1798()>.
1741 1799
1800=head3 The special problems of suspended animation
1801
1802When you leave the server world it is quite customary to hit machines that
1803can suspend/hibernate - what happens to the clocks during such a suspend?
1804
1805Some quick tests made with a Linux 2.6.28 indicate that a suspend freezes
1806all processes, while the clocks (C<times>, C<CLOCK_MONOTONIC>) continue
1807to run until the system is suspended, but they will not advance while the
1808system is suspended. That means, on resume, it will be as if the program
1809was frozen for a few seconds, but the suspend time will not be counted
1810towards C<ev_timer> when a monotonic clock source is used. The real time
1811clock advanced as expected, but if it is used as sole clocksource, then a
1812long suspend would be detected as a time jump by libev, and timers would
1813be adjusted accordingly.
1814
1815I would not be surprised to see different behaviour in different between
1816operating systems, OS versions or even different hardware.
1817
1818The other form of suspend (job control, or sending a SIGSTOP) will see a
1819time jump in the monotonic clocks and the realtime clock. If the program
1820is suspended for a very long time, and monotonic clock sources are in use,
1821then you can expect C<ev_timer>s to expire as the full suspension time
1822will be counted towards the timers. When no monotonic clock source is in
1823use, then libev will again assume a timejump and adjust accordingly.
1824
1825It might be beneficial for this latter case to call C<ev_suspend>
1826and C<ev_resume> in code that handles C<SIGTSTP>, to at least get
1827deterministic behaviour in this case (you can do nothing against
1828C<SIGSTOP>).
1829
1742=head3 Watcher-Specific Functions and Data Members 1830=head3 Watcher-Specific Functions and Data Members
1743 1831
1744=over 4 1832=over 4
1745 1833
1746=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 1834=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
1771If the timer is repeating, either start it if necessary (with the 1859If the timer is repeating, either start it if necessary (with the
1772C<repeat> value), or reset the running timer to the C<repeat> value. 1860C<repeat> value), or reset the running timer to the C<repeat> value.
1773 1861
1774This sounds a bit complicated, see L<Be smart about timeouts>, above, for a 1862This sounds a bit complicated, see L<Be smart about timeouts>, above, for a
1775usage example. 1863usage example.
1864
1865=item ev_tstamp ev_timer_remaining (loop, ev_timer *)
1866
1867Returns the remaining time until a timer fires. If the timer is active,
1868then this time is relative to the current event loop time, otherwise it's
1869the timeout value currently configured.
1870
1871That is, after an C<ev_timer_set (w, 5, 7)>, C<ev_timer_remaining> returns
1872C<5>. When the timer is started and one second passes, C<ev_timer_remaining>
1873will return C<4>. When the timer expires and is restarted, it will return
1874roughly C<7> (likely slightly less as callback invocation takes some time,
1875too), and so on.
1776 1876
1777=item ev_tstamp repeat [read-write] 1877=item ev_tstamp repeat [read-write]
1778 1878
1779The current C<repeat> value. Will be used each time the watcher times out 1879The current C<repeat> value. Will be used each time the watcher times out
1780or C<ev_timer_again> is called, and determines the next timeout (if any), 1880or C<ev_timer_again> is called, and determines the next timeout (if any),
2016Signal watchers will trigger an event when the process receives a specific 2116Signal watchers will trigger an event when the process receives a specific
2017signal one or more times. Even though signals are very asynchronous, libev 2117signal one or more times. Even though signals are very asynchronous, libev
2018will try it's best to deliver signals synchronously, i.e. as part of the 2118will try it's best to deliver signals synchronously, i.e. as part of the
2019normal event processing, like any other event. 2119normal event processing, like any other event.
2020 2120
2021If you want signals asynchronously, just use C<sigaction> as you would 2121If you want signals to be delivered truly asynchronously, just use
2022do without libev and forget about sharing the signal. You can even use 2122C<sigaction> as you would do without libev and forget about sharing
2023C<ev_async> from a signal handler to synchronously wake up an event loop. 2123the signal. You can even use C<ev_async> from a signal handler to
2124synchronously wake up an event loop.
2024 2125
2025You can configure as many watchers as you like per signal. Only when the 2126You can configure as many watchers as you like for the same signal, but
2127only within the same loop, i.e. you can watch for C<SIGINT> in your
2128default loop and for C<SIGIO> in another loop, but you cannot watch for
2129C<SIGINT> in both the default loop and another loop at the same time. At
2130the moment, C<SIGCHLD> is permanently tied to the default loop.
2131
2026first watcher gets started will libev actually register a signal handler 2132When the first watcher gets started will libev actually register something
2027with the kernel (thus it coexists with your own signal handlers as long as 2133with the kernel (thus it coexists with your own signal handlers as long as
2028you don't register any with libev for the same signal). Similarly, when 2134you don't register any with libev for the same signal).
2029the last signal watcher for a signal is stopped, libev will reset the
2030signal handler to SIG_DFL (regardless of what it was set to before).
2031 2135
2032If possible and supported, libev will install its handlers with 2136If possible and supported, libev will install its handlers with
2033C<SA_RESTART> behaviour enabled, so system calls should not be unduly 2137C<SA_RESTART> (or equivalent) behaviour enabled, so system calls should
2034interrupted. If you have a problem with system calls getting interrupted by 2138not be unduly interrupted. If you have a problem with system calls getting
2035signals you can block all signals in an C<ev_check> watcher and unblock 2139interrupted by signals you can block all signals in an C<ev_check> watcher
2036them in an C<ev_prepare> watcher. 2140and unblock them in an C<ev_prepare> watcher.
2141
2142=head3 The special problem of inheritance over fork/execve/pthread_create
2143
2144Both the signal mask (C<sigprocmask>) and the signal disposition
2145(C<sigaction>) are unspecified after starting a signal watcher (and after
2146stopping it again), that is, libev might or might not block the signal,
2147and might or might not set or restore the installed signal handler.
2148
2149While this does not matter for the signal disposition (libev never
2150sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on
2151C<execve>), this matters for the signal mask: many programs do not expect
2152certain signals to be blocked.
2153
2154This means that before calling C<exec> (from the child) you should reset
2155the signal mask to whatever "default" you expect (all clear is a good
2156choice usually).
2157
2158The simplest way to ensure that the signal mask is reset in the child is
2159to install a fork handler with C<pthread_atfork> that resets it. That will
2160catch fork calls done by libraries (such as the libc) as well.
2161
2162In current versions of libev, the signal will not be blocked indefinitely
2163unless you use the C<signalfd> API (C<EV_SIGNALFD>). While this reduces
2164the window of opportunity for problems, it will not go away, as libev
2165I<has> to modify the signal mask, at least temporarily.
2166
2167So I can't stress this enough: I<If you do not reset your signal mask when
2168you expect it to be empty, you have a race condition in your code>. This
2169is not a libev-specific thing, this is true for most event libraries.
2037 2170
2038=head3 Watcher-Specific Functions and Data Members 2171=head3 Watcher-Specific Functions and Data Members
2039 2172
2040=over 4 2173=over 4
2041 2174
2086libev) 2219libev)
2087 2220
2088=head3 Process Interaction 2221=head3 Process Interaction
2089 2222
2090Libev grabs C<SIGCHLD> as soon as the default event loop is 2223Libev grabs C<SIGCHLD> as soon as the default event loop is
2091initialised. This is necessary to guarantee proper behaviour even if 2224initialised. This is necessary to guarantee proper behaviour even if the
2092the first child watcher is started after the child exits. The occurrence 2225first child watcher is started after the child exits. The occurrence
2093of C<SIGCHLD> is recorded asynchronously, but child reaping is done 2226of C<SIGCHLD> is recorded asynchronously, but child reaping is done
2094synchronously as part of the event loop processing. Libev always reaps all 2227synchronously as part of the event loop processing. Libev always reaps all
2095children, even ones not watched. 2228children, even ones not watched.
2096 2229
2097=head3 Overriding the Built-In Processing 2230=head3 Overriding the Built-In Processing
2107=head3 Stopping the Child Watcher 2240=head3 Stopping the Child Watcher
2108 2241
2109Currently, the child watcher never gets stopped, even when the 2242Currently, the child watcher never gets stopped, even when the
2110child terminates, so normally one needs to stop the watcher in the 2243child terminates, so normally one needs to stop the watcher in the
2111callback. Future versions of libev might stop the watcher automatically 2244callback. Future versions of libev might stop the watcher automatically
2112when a child exit is detected. 2245when a child exit is detected (calling C<ev_child_stop> twice is not a
2246problem).
2113 2247
2114=head3 Watcher-Specific Functions and Data Members 2248=head3 Watcher-Specific Functions and Data Members
2115 2249
2116=over 4 2250=over 4
2117 2251
2857=head3 Queueing 2991=head3 Queueing
2858 2992
2859C<ev_async> does not support queueing of data in any way. The reason 2993C<ev_async> does not support queueing of data in any way. The reason
2860is that the author does not know of a simple (or any) algorithm for a 2994is that the author does not know of a simple (or any) algorithm for a
2861multiple-writer-single-reader queue that works in all cases and doesn't 2995multiple-writer-single-reader queue that works in all cases and doesn't
2862need elaborate support such as pthreads. 2996need elaborate support such as pthreads or unportable memory access
2997semantics.
2863 2998
2864That means that if you want to queue data, you have to provide your own 2999That means that if you want to queue data, you have to provide your own
2865queue. But at least I can tell you how to implement locking around your 3000queue. But at least I can tell you how to implement locking around your
2866queue: 3001queue:
2867 3002
3025 /* doh, nothing entered */; 3160 /* doh, nothing entered */;
3026 } 3161 }
3027 3162
3028 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0); 3163 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
3029 3164
3030=item ev_feed_event (struct ev_loop *, watcher *, int revents)
3031
3032Feeds the given event set into the event loop, as if the specified event
3033had happened for the specified watcher (which must be a pointer to an
3034initialised but not necessarily started event watcher).
3035
3036=item ev_feed_fd_event (struct ev_loop *, int fd, int revents) 3165=item ev_feed_fd_event (loop, int fd, int revents)
3037 3166
3038Feed an event on the given fd, as if a file descriptor backend detected 3167Feed an event on the given fd, as if a file descriptor backend detected
3039the given events it. 3168the given events it.
3040 3169
3041=item ev_feed_signal_event (struct ev_loop *loop, int signum) 3170=item ev_feed_signal_event (loop, int signum)
3042 3171
3043Feed an event as if the given signal occurred (C<loop> must be the default 3172Feed an event as if the given signal occurred (C<loop> must be the default
3044loop!). 3173loop!).
3045 3174
3046=back 3175=back
3126 3255
3127=over 4 3256=over 4
3128 3257
3129=item ev::TYPE::TYPE () 3258=item ev::TYPE::TYPE ()
3130 3259
3131=item ev::TYPE::TYPE (struct ev_loop *) 3260=item ev::TYPE::TYPE (loop)
3132 3261
3133=item ev::TYPE::~TYPE 3262=item ev::TYPE::~TYPE
3134 3263
3135The constructor (optionally) takes an event loop to associate the watcher 3264The constructor (optionally) takes an event loop to associate the watcher
3136with. If it is omitted, it will use C<EV_DEFAULT>. 3265with. If it is omitted, it will use C<EV_DEFAULT>.
3213Example: Use a plain function as callback. 3342Example: Use a plain function as callback.
3214 3343
3215 static void io_cb (ev::io &w, int revents) { } 3344 static void io_cb (ev::io &w, int revents) { }
3216 iow.set <io_cb> (); 3345 iow.set <io_cb> ();
3217 3346
3218=item w->set (struct ev_loop *) 3347=item w->set (loop)
3219 3348
3220Associates a different C<struct ev_loop> with this watcher. You can only 3349Associates a different C<struct ev_loop> with this watcher. You can only
3221do this when the watcher is inactive (and not pending either). 3350do this when the watcher is inactive (and not pending either).
3222 3351
3223=item w->set ([arguments]) 3352=item w->set ([arguments])
3320=item Ocaml 3449=item Ocaml
3321 3450
3322Erkki Seppala has written Ocaml bindings for libev, to be found at 3451Erkki Seppala has written Ocaml bindings for libev, to be found at
3323L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>. 3452L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>.
3324 3453
3454=item Lua
3455
3456Brian Maher has written a partial interface to libev for lua (at the
3457time of this writing, only C<ev_io> and C<ev_timer>), to be found at
3458L<http://github.com/brimworks/lua-ev>.
3459
3325=back 3460=back
3326 3461
3327 3462
3328=head1 MACRO MAGIC 3463=head1 MACRO MAGIC
3329 3464
3482 libev.m4 3617 libev.m4
3483 3618
3484=head2 PREPROCESSOR SYMBOLS/MACROS 3619=head2 PREPROCESSOR SYMBOLS/MACROS
3485 3620
3486Libev can be configured via a variety of preprocessor symbols you have to 3621Libev can be configured via a variety of preprocessor symbols you have to
3487define before including any of its files. The default in the absence of 3622define before including (or compiling) any of its files. The default in
3488autoconf is documented for every option. 3623the absence of autoconf is documented for every option.
3624
3625Symbols marked with "(h)" do not change the ABI, and can have different
3626values when compiling libev vs. including F<ev.h>, so it is permissible
3627to redefine them before including F<ev.h> without breakign compatibility
3628to a compiled library. All other symbols change the ABI, which means all
3629users of libev and the libev code itself must be compiled with compatible
3630settings.
3489 3631
3490=over 4 3632=over 4
3491 3633
3492=item EV_STANDALONE 3634=item EV_STANDALONE (h)
3493 3635
3494Must always be C<1> if you do not use autoconf configuration, which 3636Must always be C<1> if you do not use autoconf configuration, which
3495keeps libev from including F<config.h>, and it also defines dummy 3637keeps libev from including F<config.h>, and it also defines dummy
3496implementations for some libevent functions (such as logging, which is not 3638implementations for some libevent functions (such as logging, which is not
3497supported). It will also not define any of the structs usually found in 3639supported). It will also not define any of the structs usually found in
3498F<event.h> that are not directly supported by the libev core alone. 3640F<event.h> that are not directly supported by the libev core alone.
3499 3641
3500In stanbdalone mode, libev will still try to automatically deduce the 3642In standalone mode, libev will still try to automatically deduce the
3501configuration, but has to be more conservative. 3643configuration, but has to be more conservative.
3502 3644
3503=item EV_USE_MONOTONIC 3645=item EV_USE_MONOTONIC
3504 3646
3505If defined to be C<1>, libev will try to detect the availability of the 3647If defined to be C<1>, libev will try to detect the availability of the
3570be used is the winsock select). This means that it will call 3712be used is the winsock select). This means that it will call
3571C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise, 3713C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise,
3572it is assumed that all these functions actually work on fds, even 3714it is assumed that all these functions actually work on fds, even
3573on win32. Should not be defined on non-win32 platforms. 3715on win32. Should not be defined on non-win32 platforms.
3574 3716
3575=item EV_FD_TO_WIN32_HANDLE 3717=item EV_FD_TO_WIN32_HANDLE(fd)
3576 3718
3577If C<EV_SELECT_IS_WINSOCKET> is enabled, then libev needs a way to map 3719If C<EV_SELECT_IS_WINSOCKET> is enabled, then libev needs a way to map
3578file descriptors to socket handles. When not defining this symbol (the 3720file descriptors to socket handles. When not defining this symbol (the
3579default), then libev will call C<_get_osfhandle>, which is usually 3721default), then libev will call C<_get_osfhandle>, which is usually
3580correct. In some cases, programs use their own file descriptor management, 3722correct. In some cases, programs use their own file descriptor management,
3581in which case they can provide this function to map fds to socket handles. 3723in which case they can provide this function to map fds to socket handles.
3724
3725=item EV_WIN32_HANDLE_TO_FD(handle)
3726
3727If C<EV_SELECT_IS_WINSOCKET> then libev maps handles to file descriptors
3728using the standard C<_open_osfhandle> function. For programs implementing
3729their own fd to handle mapping, overwriting this function makes it easier
3730to do so. This can be done by defining this macro to an appropriate value.
3731
3732=item EV_WIN32_CLOSE_FD(fd)
3733
3734If programs implement their own fd to handle mapping on win32, then this
3735macro can be used to override the C<close> function, useful to unregister
3736file descriptors again. Note that the replacement function has to close
3737the underlying OS handle.
3582 3738
3583=item EV_USE_POLL 3739=item EV_USE_POLL
3584 3740
3585If defined to be C<1>, libev will compile in support for the C<poll>(2) 3741If defined to be C<1>, libev will compile in support for the C<poll>(2)
3586backend. Otherwise it will be enabled on non-win32 platforms. It 3742backend. Otherwise it will be enabled on non-win32 platforms. It
3633as well as for signal and thread safety in C<ev_async> watchers. 3789as well as for signal and thread safety in C<ev_async> watchers.
3634 3790
3635In the absence of this define, libev will use C<sig_atomic_t volatile> 3791In the absence of this define, libev will use C<sig_atomic_t volatile>
3636(from F<signal.h>), which is usually good enough on most platforms. 3792(from F<signal.h>), which is usually good enough on most platforms.
3637 3793
3638=item EV_H 3794=item EV_H (h)
3639 3795
3640The name of the F<ev.h> header file used to include it. The default if 3796The name of the F<ev.h> header file used to include it. The default if
3641undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be 3797undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be
3642used to virtually rename the F<ev.h> header file in case of conflicts. 3798used to virtually rename the F<ev.h> header file in case of conflicts.
3643 3799
3644=item EV_CONFIG_H 3800=item EV_CONFIG_H (h)
3645 3801
3646If C<EV_STANDALONE> isn't C<1>, this variable can be used to override 3802If C<EV_STANDALONE> isn't C<1>, this variable can be used to override
3647F<ev.c>'s idea of where to find the F<config.h> file, similarly to 3803F<ev.c>'s idea of where to find the F<config.h> file, similarly to
3648C<EV_H>, above. 3804C<EV_H>, above.
3649 3805
3650=item EV_EVENT_H 3806=item EV_EVENT_H (h)
3651 3807
3652Similarly to C<EV_H>, this macro can be used to override F<event.c>'s idea 3808Similarly to C<EV_H>, this macro can be used to override F<event.c>'s idea
3653of how the F<event.h> header can be found, the default is C<"event.h">. 3809of how the F<event.h> header can be found, the default is C<"event.h">.
3654 3810
3655=item EV_PROTOTYPES 3811=item EV_PROTOTYPES (h)
3656 3812
3657If defined to be C<0>, then F<ev.h> will not define any function 3813If defined to be C<0>, then F<ev.h> will not define any function
3658prototypes, but still define all the structs and other symbols. This is 3814prototypes, but still define all the structs and other symbols. This is
3659occasionally useful if you want to provide your own wrapper functions 3815occasionally useful if you want to provide your own wrapper functions
3660around libev functions. 3816around libev functions.
3682fine. 3838fine.
3683 3839
3684If your embedding application does not need any priorities, defining these 3840If your embedding application does not need any priorities, defining these
3685both to C<0> will save some memory and CPU. 3841both to C<0> will save some memory and CPU.
3686 3842
3687=item EV_PERIODIC_ENABLE 3843=item EV_PERIODIC_ENABLE, EV_IDLE_ENABLE, EV_EMBED_ENABLE, EV_STAT_ENABLE,
3844EV_PREPARE_ENABLE, EV_CHECK_ENABLE, EV_FORK_ENABLE, EV_SIGNAL_ENABLE,
3845EV_ASYNC_ENABLE, EV_CHILD_ENABLE.
3688 3846
3689If undefined or defined to be C<1>, then periodic timers are supported. If 3847If undefined or defined to be C<1> (and the platform supports it), then
3690defined to be C<0>, then they are not. Disabling them saves a few kB of 3848the respective watcher type is supported. If defined to be C<0>, then it
3691code. 3849is not. Disabling watcher types mainly saves codesize.
3692
3693=item EV_IDLE_ENABLE
3694
3695If undefined or defined to be C<1>, then idle watchers are supported. If
3696defined to be C<0>, then they are not. Disabling them saves a few kB of
3697code.
3698
3699=item EV_EMBED_ENABLE
3700
3701If undefined or defined to be C<1>, then embed watchers are supported. If
3702defined to be C<0>, then they are not. Embed watchers rely on most other
3703watcher types, which therefore must not be disabled.
3704
3705=item EV_STAT_ENABLE
3706
3707If undefined or defined to be C<1>, then stat watchers are supported. If
3708defined to be C<0>, then they are not.
3709
3710=item EV_FORK_ENABLE
3711
3712If undefined or defined to be C<1>, then fork watchers are supported. If
3713defined to be C<0>, then they are not.
3714
3715=item EV_ASYNC_ENABLE
3716
3717If undefined or defined to be C<1>, then async watchers are supported. If
3718defined to be C<0>, then they are not.
3719 3850
3720=item EV_MINIMAL 3851=item EV_MINIMAL
3721 3852
3722If you need to shave off some kilobytes of code at the expense of some 3853If you need to shave off some kilobytes of code at the expense of some
3723speed (but with the full API), define this symbol to C<1>. Currently this 3854speed (but with the full API), define this symbol to C<1>. Currently this
3725on amd64. It also selects a much smaller 2-heap for timer management over 3856on amd64. It also selects a much smaller 2-heap for timer management over
3726the default 4-heap. 3857the default 4-heap.
3727 3858
3728You can save even more by disabling watcher types you do not need 3859You can save even more by disabling watcher types you do not need
3729and setting C<EV_MAXPRI> == C<EV_MINPRI>. Also, disabling C<assert> 3860and setting C<EV_MAXPRI> == C<EV_MINPRI>. Also, disabling C<assert>
3730(C<-DNDEBUG>) will usually reduce code size a lot. 3861(C<-DNDEBUG>) will usually reduce code size a lot. Disabling inotify,
3862eventfd and signalfd will further help, and disabling backends one doesn't
3863need (e.g. poll, epoll, kqueue, ports) will help further.
3731 3864
3732Defining C<EV_MINIMAL> to C<2> will additionally reduce the core API to 3865Defining C<EV_MINIMAL> to C<2> will additionally reduce the core API to
3733provide a bare-bones event library. See C<ev.h> for details on what parts 3866provide a bare-bones event library. See C<ev.h> for details on what parts
3734of the API are still available, and do not complain if this subset changes 3867of the API are still available, and do not complain if this subset changes
3735over time. 3868over time.
3869
3870This example set of settings reduces the compiled size of libev from
387123.9Kb to 7.7Kb on my GNU/Linux amd64 system (and leaves little
3872in - there is also an effect on the amount of memory used). With
3873an intelligent-enough linker (gcc+binutils do this when you use
3874C<-Wl,--gc-sections -ffunction-sections>) further unused functions might
3875be left out as well automatically - a binary starting a timer and an I/O
3876watcher then might come out at only 5Kb.
3877
3878 // tuning and API changes
3879 #define EV_MINIMAL 2
3880 #define EV_MULTIPLICITY 0
3881 #define EV_MINPRI 0
3882 #define EV_MAXPRI 0
3883
3884 // OS-specific backends
3885 #define EV_USE_INOTIFY 0
3886 #define EV_USE_EVENTFD 0
3887 #define EV_USE_SIGNALFD 0
3888 #define EV_USE_REALTIME 0
3889 #define EV_USE_MONOTONIC 0
3890 #define EV_USE_CLOCK_SYSCALL 0
3891
3892 // disable all backends except select
3893 #define EV_USE_POLL 0
3894 #define EV_USE_PORT 0
3895 #define EV_USE_KQUEUE 0
3896 #define EV_USE_EPOLL 0
3897
3898 // disable all watcher types that cna be disabled
3899 #define EV_STAT_ENABLE 0
3900 #define EV_PERIODIC_ENABLE 0
3901 #define EV_IDLE_ENABLE 0
3902 #define EV_CHECK_ENABLE 0
3903 #define EV_PREPARE_ENABLE 0
3904 #define EV_FORK_ENABLE 0
3905 #define EV_SIGNAL_ENABLE 0
3906 #define EV_CHILD_ENABLE 0
3907 #define EV_ASYNC_ENABLE 0
3908 #define EV_EMBED_ENABLE 0
3909
3910=item EV_AVOID_STDIO
3911
3912If this is set to C<1> at compiletime, then libev will avoid using stdio
3913functions (printf, scanf, perror etc.). This will increase the codesize
3914somewhat, but if your program doesn't otherwise depend on stdio and your
3915libc allows it, this avoids linking in the stdio library which is quite
3916big.
3917
3918Note that error messages might become less precise when this option is
3919enabled.
3920
3921=item EV_NSIG
3922
3923The highest supported signal number, +1 (or, the number of
3924signals): Normally, libev tries to deduce the maximum number of signals
3925automatically, but sometimes this fails, in which case it can be
3926specified. Also, using a lower number than detected (C<32> should be
3927good for about any system in existance) can save some memory, as libev
3928statically allocates some 12-24 bytes per signal number.
3736 3929
3737=item EV_PID_HASHSIZE 3930=item EV_PID_HASHSIZE
3738 3931
3739C<ev_child> watchers use a small hash table to distribute workload by 3932C<ev_child> watchers use a small hash table to distribute workload by
3740pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 3933pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
3928 4121
3929=back 4122=back
3930 4123
3931=head4 THREAD LOCKING EXAMPLE 4124=head4 THREAD LOCKING EXAMPLE
3932 4125
4126Here is a fictitious example of how to run an event loop in a different
4127thread than where callbacks are being invoked and watchers are
4128created/added/removed.
4129
4130For a real-world example, see the C<EV::Loop::Async> perl module,
4131which uses exactly this technique (which is suited for many high-level
4132languages).
4133
4134The example uses a pthread mutex to protect the loop data, a condition
4135variable to wait for callback invocations, an async watcher to notify the
4136event loop thread and an unspecified mechanism to wake up the main thread.
4137
4138First, you need to associate some data with the event loop:
4139
4140 typedef struct {
4141 mutex_t lock; /* global loop lock */
4142 ev_async async_w;
4143 thread_t tid;
4144 cond_t invoke_cv;
4145 } userdata;
4146
4147 void prepare_loop (EV_P)
4148 {
4149 // for simplicity, we use a static userdata struct.
4150 static userdata u;
4151
4152 ev_async_init (&u->async_w, async_cb);
4153 ev_async_start (EV_A_ &u->async_w);
4154
4155 pthread_mutex_init (&u->lock, 0);
4156 pthread_cond_init (&u->invoke_cv, 0);
4157
4158 // now associate this with the loop
4159 ev_set_userdata (EV_A_ u);
4160 ev_set_invoke_pending_cb (EV_A_ l_invoke);
4161 ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
4162
4163 // then create the thread running ev_loop
4164 pthread_create (&u->tid, 0, l_run, EV_A);
4165 }
4166
4167The callback for the C<ev_async> watcher does nothing: the watcher is used
4168solely to wake up the event loop so it takes notice of any new watchers
4169that might have been added:
4170
4171 static void
4172 async_cb (EV_P_ ev_async *w, int revents)
4173 {
4174 // just used for the side effects
4175 }
4176
4177The C<l_release> and C<l_acquire> callbacks simply unlock/lock the mutex
4178protecting the loop data, respectively.
4179
4180 static void
4181 l_release (EV_P)
4182 {
4183 userdata *u = ev_userdata (EV_A);
4184 pthread_mutex_unlock (&u->lock);
4185 }
4186
4187 static void
4188 l_acquire (EV_P)
4189 {
4190 userdata *u = ev_userdata (EV_A);
4191 pthread_mutex_lock (&u->lock);
4192 }
4193
4194The event loop thread first acquires the mutex, and then jumps straight
4195into C<ev_loop>:
4196
4197 void *
4198 l_run (void *thr_arg)
4199 {
4200 struct ev_loop *loop = (struct ev_loop *)thr_arg;
4201
4202 l_acquire (EV_A);
4203 pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, 0);
4204 ev_loop (EV_A_ 0);
4205 l_release (EV_A);
4206
4207 return 0;
4208 }
4209
4210Instead of invoking all pending watchers, the C<l_invoke> callback will
4211signal the main thread via some unspecified mechanism (signals? pipe
4212writes? C<Async::Interrupt>?) and then waits until all pending watchers
4213have been called (in a while loop because a) spurious wakeups are possible
4214and b) skipping inter-thread-communication when there are no pending
4215watchers is very beneficial):
4216
4217 static void
4218 l_invoke (EV_P)
4219 {
4220 userdata *u = ev_userdata (EV_A);
4221
4222 while (ev_pending_count (EV_A))
4223 {
4224 wake_up_other_thread_in_some_magic_or_not_so_magic_way ();
4225 pthread_cond_wait (&u->invoke_cv, &u->lock);
4226 }
4227 }
4228
4229Now, whenever the main thread gets told to invoke pending watchers, it
4230will grab the lock, call C<ev_invoke_pending> and then signal the loop
4231thread to continue:
4232
4233 static void
4234 real_invoke_pending (EV_P)
4235 {
4236 userdata *u = ev_userdata (EV_A);
4237
4238 pthread_mutex_lock (&u->lock);
4239 ev_invoke_pending (EV_A);
4240 pthread_cond_signal (&u->invoke_cv);
4241 pthread_mutex_unlock (&u->lock);
4242 }
4243
4244Whenever you want to start/stop a watcher or do other modifications to an
4245event loop, you will now have to lock:
4246
4247 ev_timer timeout_watcher;
4248 userdata *u = ev_userdata (EV_A);
4249
4250 ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);
4251
4252 pthread_mutex_lock (&u->lock);
4253 ev_timer_start (EV_A_ &timeout_watcher);
4254 ev_async_send (EV_A_ &u->async_w);
4255 pthread_mutex_unlock (&u->lock);
4256
4257Note that sending the C<ev_async> watcher is required because otherwise
4258an event loop currently blocking in the kernel will have no knowledge
4259about the newly added timer. By waking up the loop it will pick up any new
4260watchers in the next event loop iteration.
4261
3933=head3 COROUTINES 4262=head3 COROUTINES
3934 4263
3935Libev is very accommodating to coroutines ("cooperative threads"): 4264Libev is very accommodating to coroutines ("cooperative threads"):
3936libev fully supports nesting calls to its functions from different 4265libev fully supports nesting calls to its functions from different
3937coroutines (e.g. you can call C<ev_loop> on the same loop from two 4266coroutines (e.g. you can call C<ev_loop> on the same loop from two
3938different coroutines, and switch freely between both coroutines running the 4267different coroutines, and switch freely between both coroutines running
3939loop, as long as you don't confuse yourself). The only exception is that 4268the loop, as long as you don't confuse yourself). The only exception is
3940you must not do this from C<ev_periodic> reschedule callbacks. 4269that you must not do this from C<ev_periodic> reschedule callbacks.
3941 4270
3942Care has been taken to ensure that libev does not keep local state inside 4271Care has been taken to ensure that libev does not keep local state inside
3943C<ev_loop>, and other calls do not usually allow for coroutine switches as 4272C<ev_loop>, and other calls do not usually allow for coroutine switches as
3944they do not call any callbacks. 4273they do not call any callbacks.
3945 4274

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines