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

Comparing libev/ev.pod (file contents):
Revision 1.371 by root, Sat Jun 4 05:25:03 2011 UTC vs.
Revision 1.400 by root, Mon Apr 2 23:46:11 2012 UTC

174=item ev_tstamp ev_time () 174=item ev_tstamp ev_time ()
175 175
176Returns the current time as libev would use it. Please note that the 176Returns the current time as libev would use it. Please note that the
177C<ev_now> function is usually faster and also often returns the timestamp 177C<ev_now> function is usually faster and also often returns the timestamp
178you actually want to know. Also interesting is the combination of 178you actually want to know. Also interesting is the combination of
179C<ev_update_now> and C<ev_now>. 179C<ev_now_update> and C<ev_now>.
180 180
181=item ev_sleep (ev_tstamp interval) 181=item ev_sleep (ev_tstamp interval)
182 182
183Sleep for the given interval: The current thread will be blocked 183Sleep for the given interval: The current thread will be blocked
184until either it is interrupted or the given time interval has 184until either it is interrupted or the given time interval has
441example) that can't properly initialise their signal masks. 441example) that can't properly initialise their signal masks.
442 442
443=item C<EVFLAG_NOSIGMASK> 443=item C<EVFLAG_NOSIGMASK>
444 444
445When this flag is specified, then libev will avoid to modify the signal 445When this flag is specified, then libev will avoid to modify the signal
446mask. Specifically, this means you ahve to make sure signals are unblocked 446mask. Specifically, this means you have to make sure signals are unblocked
447when you want to receive them. 447when you want to receive them.
448 448
449This behaviour is useful when you want to do your own signal handling, or 449This behaviour is useful when you want to do your own signal handling, or
450want to handle signals only in specific threads and want to avoid libev 450want to handle signals only in specific threads and want to avoid libev
451unblocking the signals. 451unblocking the signals.
512totally I<different> file descriptors (even already closed ones, so 512totally I<different> file descriptors (even already closed ones, so
513one cannot even remove them from the set) than registered in the set 513one cannot even remove them from the set) than registered in the set
514(especially on SMP systems). Libev tries to counter these spurious 514(especially on SMP systems). Libev tries to counter these spurious
515notifications by employing an additional generation counter and comparing 515notifications by employing an additional generation counter and comparing
516that against the events to filter out spurious ones, recreating the set 516that against the events to filter out spurious ones, recreating the set
517when required. Epoll also errornously rounds down timeouts, but gives you 517when required. Epoll also erroneously rounds down timeouts, but gives you
518no way to know when and by how much, so sometimes you have to busy-wait 518no way to know when and by how much, so sometimes you have to busy-wait
519because epoll returns immediately despite a nonzero timeout. And last 519because epoll returns immediately despite a nonzero timeout. And last
520not least, it also refuses to work with some file descriptors which work 520not least, it also refuses to work with some file descriptors which work
521perfectly fine with C<select> (files, many character devices...). 521perfectly fine with C<select> (files, many character devices...).
522 522
567 567
568It scales in the same way as the epoll backend, but the interface to the 568It scales in the same way as the epoll backend, but the interface to the
569kernel is more efficient (which says nothing about its actual speed, of 569kernel is more efficient (which says nothing about its actual speed, of
570course). While stopping, setting and starting an I/O watcher does never 570course). While stopping, setting and starting an I/O watcher does never
571cause an extra system call as with C<EVBACKEND_EPOLL>, it still adds up to 571cause an extra system call as with C<EVBACKEND_EPOLL>, it still adds up to
572two event changes per incident. Support for C<fork ()> is very bad (but 572two event changes per incident. Support for C<fork ()> is very bad (you
573sane, unlike epoll) and it drops fds silently in similarly hard-to-detect 573might have to leak fd's on fork, but it's more sane than epoll) and it
574cases 574drops fds silently in similarly hard-to-detect cases
575 575
576This backend usually performs well under most conditions. 576This backend usually performs well under most conditions.
577 577
578While nominally embeddable in other event loops, this doesn't work 578While nominally embeddable in other event loops, this doesn't work
579everywhere, so you might need to test for this. And since it is broken 579everywhere, so you might need to test for this. And since it is broken
608among the OS-specific backends (I vastly prefer correctness over speed 608among the OS-specific backends (I vastly prefer correctness over speed
609hacks). 609hacks).
610 610
611On the negative side, the interface is I<bizarre> - so bizarre that 611On the negative side, the interface is I<bizarre> - so bizarre that
612even sun itself gets it wrong in their code examples: The event polling 612even sun itself gets it wrong in their code examples: The event polling
613function sometimes returning events to the caller even though an error 613function sometimes returns events to the caller even though an error
614occurred, but with no indication whether it has done so or not (yes, it's 614occurred, but with no indication whether it has done so or not (yes, it's
615even documented that way) - deadly for edge-triggered interfaces where 615even documented that way) - deadly for edge-triggered interfaces where you
616you absolutely have to know whether an event occurred or not because you 616absolutely have to know whether an event occurred or not because you have
617have to re-arm the watcher. 617to re-arm the watcher.
618 618
619Fortunately libev seems to be able to work around these idiocies. 619Fortunately libev seems to be able to work around these idiocies.
620 620
621This backend maps C<EV_READ> and C<EV_WRITE> in the same way as 621This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
622C<EVBACKEND_POLL>. 622C<EVBACKEND_POLL>.
792without a previous call to C<ev_suspend>. 792without a previous call to C<ev_suspend>.
793 793
794Calling C<ev_suspend>/C<ev_resume> has the side effect of updating the 794Calling C<ev_suspend>/C<ev_resume> has the side effect of updating the
795event loop time (see C<ev_now_update>). 795event loop time (see C<ev_now_update>).
796 796
797=item ev_run (loop, int flags) 797=item bool ev_run (loop, int flags)
798 798
799Finally, this is it, the event handler. This function usually is called 799Finally, this is it, the event handler. This function usually is called
800after you have initialised all your watchers and you want to start 800after you have initialised all your watchers and you want to start
801handling events. It will ask the operating system for any new events, call 801handling events. It will ask the operating system for any new events, call
802the watcher callbacks, an then repeat the whole process indefinitely: This 802the watcher callbacks, and then repeat the whole process indefinitely: This
803is why event loops are called I<loops>. 803is why event loops are called I<loops>.
804 804
805If the flags argument is specified as C<0>, it will keep handling events 805If the flags argument is specified as C<0>, it will keep handling events
806until either no event watchers are active anymore or C<ev_break> was 806until either no event watchers are active anymore or C<ev_break> was
807called. 807called.
808
809The return value is false if there are no more active watchers (which
810usually means "all jobs done" or "deadlock"), and true in all other cases
811(which usually means " you should call C<ev_run> again").
808 812
809Please note that an explicit C<ev_break> is usually better than 813Please note that an explicit C<ev_break> is usually better than
810relying on all watchers to be stopped when deciding when a program has 814relying on all watchers to be stopped when deciding when a program has
811finished (especially in interactive programs), but having a program 815finished (especially in interactive programs), but having a program
812that automatically loops as long as it has to and no longer by virtue 816that automatically loops as long as it has to and no longer by virtue
813of relying on its watchers stopping correctly, that is truly a thing of 817of relying on its watchers stopping correctly, that is truly a thing of
814beauty. 818beauty.
815 819
816This function is also I<mostly> exception-safe - you can break out of 820This function is I<mostly> exception-safe - you can break out of a
817a C<ev_run> call by calling C<longjmp> in a callback, throwing a C++ 821C<ev_run> call by calling C<longjmp> in a callback, throwing a C++
818exception and so on. This does not decrement the C<ev_depth> value, nor 822exception and so on. This does not decrement the C<ev_depth> value, nor
819will it clear any outstanding C<EVBREAK_ONE> breaks. 823will it clear any outstanding C<EVBREAK_ONE> breaks.
820 824
821A flags value of C<EVRUN_NOWAIT> will look for new events, will handle 825A flags value of C<EVRUN_NOWAIT> will look for new events, will handle
822those events and any already outstanding ones, but will not wait and 826those events and any already outstanding ones, but will not wait and
952overhead for the actual polling but can deliver many events at once. 956overhead for the actual polling but can deliver many events at once.
953 957
954By setting a higher I<io collect interval> you allow libev to spend more 958By setting a higher I<io collect interval> you allow libev to spend more
955time collecting I/O events, so you can handle more events per iteration, 959time collecting I/O events, so you can handle more events per iteration,
956at the cost of increasing latency. Timeouts (both C<ev_periodic> and 960at the cost of increasing latency. Timeouts (both C<ev_periodic> and
957C<ev_timer>) will be not affected. Setting this to a non-null value will 961C<ev_timer>) will not be affected. Setting this to a non-null value will
958introduce an additional C<ev_sleep ()> call into most loop iterations. The 962introduce an additional C<ev_sleep ()> call into most loop iterations. The
959sleep time ensures that libev will not poll for I/O events more often then 963sleep time ensures that libev will not poll for I/O events more often then
960once per this interval, on average. 964once per this interval, on average (as long as the host time resolution is
965good enough).
961 966
962Likewise, by setting a higher I<timeout collect interval> you allow libev 967Likewise, by setting a higher I<timeout collect interval> you allow libev
963to spend more time collecting timeouts, at the expense of increased 968to spend more time collecting timeouts, at the expense of increased
964latency/jitter/inexactness (the watcher callback will be called 969latency/jitter/inexactness (the watcher callback will be called
965later). C<ev_io> watchers will not be affected. Setting this to a non-null 970later). C<ev_io> watchers will not be affected. Setting this to a non-null
1019can be done relatively simply by putting mutex_lock/unlock calls around 1024can be done relatively simply by putting mutex_lock/unlock calls around
1020each call to a libev function. 1025each call to a libev function.
1021 1026
1022However, C<ev_run> can run an indefinite time, so it is not feasible 1027However, C<ev_run> can run an indefinite time, so it is not feasible
1023to wait for it to return. One way around this is to wake up the event 1028to wait for it to return. One way around this is to wake up the event
1024loop via C<ev_break> and C<av_async_send>, another way is to set these 1029loop via C<ev_break> and C<ev_async_send>, another way is to set these
1025I<release> and I<acquire> callbacks on the loop. 1030I<release> and I<acquire> callbacks on the loop.
1026 1031
1027When set, then C<release> will be called just before the thread is 1032When set, then C<release> will be called just before the thread is
1028suspended waiting for new events, and C<acquire> is called just 1033suspended waiting for new events, and C<acquire> is called just
1029afterwards. 1034afterwards.
1385 1390
1386=over 4 1391=over 4
1387 1392
1388=item initialiased 1393=item initialiased
1389 1394
1390Before a watcher can be registered with the event looop it has to be 1395Before a watcher can be registered with the event loop it has to be
1391initialised. This can be done with a call to C<ev_TYPE_init>, or calls to 1396initialised. This can be done with a call to C<ev_TYPE_init>, or calls to
1392C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function. 1397C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1393 1398
1394In this state it is simply some block of memory that is suitable for 1399In this state it is simply some block of memory that is suitable for
1395use in an event loop. It can be moved around, freed, reused etc. at 1400use in an event loop. It can be moved around, freed, reused etc. at
1770detecting time jumps is hard, and some inaccuracies are unavoidable (the 1775detecting time jumps is hard, and some inaccuracies are unavoidable (the
1771monotonic clock option helps a lot here). 1776monotonic clock option helps a lot here).
1772 1777
1773The callback is guaranteed to be invoked only I<after> its timeout has 1778The callback is guaranteed to be invoked only I<after> its timeout has
1774passed (not I<at>, so on systems with very low-resolution clocks this 1779passed (not I<at>, so on systems with very low-resolution clocks this
1775might introduce a small delay). If multiple timers become ready during the 1780might introduce a small delay, see "the special problem of being too
1781early", below). If multiple timers become ready during the same loop
1776same loop iteration then the ones with earlier time-out values are invoked 1782iteration then the ones with earlier time-out values are invoked before
1777before ones of the same priority with later time-out values (but this is 1783ones of the same priority with later time-out values (but this is no
1778no longer true when a callback calls C<ev_run> recursively). 1784longer true when a callback calls C<ev_run> recursively).
1779 1785
1780=head3 Be smart about timeouts 1786=head3 Be smart about timeouts
1781 1787
1782Many real-world problems involve some kind of timeout, usually for error 1788Many real-world problems involve some kind of timeout, usually for error
1783recovery. A typical example is an HTTP request - if the other side hangs, 1789recovery. A typical example is an HTTP request - if the other side hangs,
1858 1864
1859In this case, it would be more efficient to leave the C<ev_timer> alone, 1865In this case, it would be more efficient to leave the C<ev_timer> alone,
1860but remember the time of last activity, and check for a real timeout only 1866but remember the time of last activity, and check for a real timeout only
1861within the callback: 1867within the callback:
1862 1868
1869 ev_tstamp timeout = 60.;
1863 ev_tstamp last_activity; // time of last activity 1870 ev_tstamp last_activity; // time of last activity
1871 ev_timer timer;
1864 1872
1865 static void 1873 static void
1866 callback (EV_P_ ev_timer *w, int revents) 1874 callback (EV_P_ ev_timer *w, int revents)
1867 { 1875 {
1868 ev_tstamp now = ev_now (EV_A); 1876 // calculate when the timeout would happen
1869 ev_tstamp timeout = last_activity + 60.; 1877 ev_tstamp after = last_activity - ev_now (EV_A) + timeout;
1870 1878
1871 // if last_activity + 60. is older than now, we did time out 1879 // if negative, it means we the timeout already occured
1872 if (timeout < now) 1880 if (after < 0.)
1873 { 1881 {
1874 // timeout occurred, take action 1882 // timeout occurred, take action
1875 } 1883 }
1876 else 1884 else
1877 { 1885 {
1878 // callback was invoked, but there was some activity, re-arm 1886 // callback was invoked, but there was some recent
1879 // the watcher to fire in last_activity + 60, which is 1887 // activity. simply restart the timer to time out
1880 // guaranteed to be in the future, so "again" is positive: 1888 // after "after" seconds, which is the earliest time
1881 w->repeat = timeout - now; 1889 // the timeout can occur.
1890 ev_timer_set (w, after, 0.);
1882 ev_timer_again (EV_A_ w); 1891 ev_timer_start (EV_A_ w);
1883 } 1892 }
1884 } 1893 }
1885 1894
1886To summarise the callback: first calculate the real timeout (defined 1895To summarise the callback: first calculate in how many seconds the
1887as "60 seconds after the last activity"), then check if that time has 1896timeout will occur (by calculating the absolute time when it would occur,
1888been reached, which means something I<did>, in fact, time out. Otherwise 1897C<last_activity + timeout>, and subtracting the current time, C<ev_now
1889the callback was invoked too early (C<timeout> is in the future), so 1898(EV_A)> from that).
1890re-schedule the timer to fire at that future time, to see if maybe we have
1891a timeout then.
1892 1899
1893Note how C<ev_timer_again> is used, taking advantage of the 1900If this value is negative, then we are already past the timeout, i.e. we
1894C<ev_timer_again> optimisation when the timer is already running. 1901timed out, and need to do whatever is needed in this case.
1902
1903Otherwise, we now the earliest time at which the timeout would trigger,
1904and simply start the timer with this timeout value.
1905
1906In other words, each time the callback is invoked it will check whether
1907the timeout cocured. If not, it will simply reschedule itself to check
1908again at the earliest time it could time out. Rinse. Repeat.
1895 1909
1896This scheme causes more callback invocations (about one every 60 seconds 1910This scheme causes more callback invocations (about one every 60 seconds
1897minus half the average time between activity), but virtually no calls to 1911minus half the average time between activity), but virtually no calls to
1898libev to change the timeout. 1912libev to change the timeout.
1899 1913
1900To start the timer, simply initialise the watcher and set C<last_activity> 1914To start the machinery, simply initialise the watcher and set
1901to the current time (meaning we just have some activity :), then call the 1915C<last_activity> to the current time (meaning there was some activity just
1902callback, which will "do the right thing" and start the timer: 1916now), then call the callback, which will "do the right thing" and start
1917the timer:
1903 1918
1919 last_activity = ev_now (EV_A);
1904 ev_init (timer, callback); 1920 ev_init (&timer, callback);
1905 last_activity = ev_now (loop); 1921 callback (EV_A_ &timer, 0);
1906 callback (loop, timer, EV_TIMER);
1907 1922
1908And when there is some activity, simply store the current time in 1923When there is some activity, simply store the current time in
1909C<last_activity>, no libev calls at all: 1924C<last_activity>, no libev calls at all:
1910 1925
1926 if (activity detected)
1911 last_activity = ev_now (loop); 1927 last_activity = ev_now (EV_A);
1928
1929When your timeout value changes, then the timeout can be changed by simply
1930providing a new value, stopping the timer and calling the callback, which
1931will agaion do the right thing (for example, time out immediately :).
1932
1933 timeout = new_value;
1934 ev_timer_stop (EV_A_ &timer);
1935 callback (EV_A_ &timer, 0);
1912 1936
1913This technique is slightly more complex, but in most cases where the 1937This technique is slightly more complex, but in most cases where the
1914time-out is unlikely to be triggered, much more efficient. 1938time-out is unlikely to be triggered, much more efficient.
1915
1916Changing the timeout is trivial as well (if it isn't hard-coded in the
1917callback :) - just change the timeout and invoke the callback, which will
1918fix things for you.
1919 1939
1920=item 4. Wee, just use a double-linked list for your timeouts. 1940=item 4. Wee, just use a double-linked list for your timeouts.
1921 1941
1922If there is not one request, but many thousands (millions...), all 1942If there is not one request, but many thousands (millions...), all
1923employing some kind of timeout with the same timeout value, then one can 1943employing some kind of timeout with the same timeout value, then one can
1950Method #1 is almost always a bad idea, and buys you nothing. Method #4 is 1970Method #1 is almost always a bad idea, and buys you nothing. Method #4 is
1951rather complicated, but extremely efficient, something that really pays 1971rather complicated, but extremely efficient, something that really pays
1952off after the first million or so of active timers, i.e. it's usually 1972off after the first million or so of active timers, i.e. it's usually
1953overkill :) 1973overkill :)
1954 1974
1975=head3 The special problem of being too early
1976
1977If you ask a timer to call your callback after three seconds, then
1978you expect it to be invoked after three seconds - but of course, this
1979cannot be guaranteed to infinite precision. Less obviously, it cannot be
1980guaranteed to any precision by libev - imagine somebody suspending the
1981process with a STOP signal for a few hours for example.
1982
1983So, libev tries to invoke your callback as soon as possible I<after> the
1984delay has occurred, but cannot guarantee this.
1985
1986A less obvious failure mode is calling your callback too early: many event
1987loops compare timestamps with a "elapsed delay >= requested delay", but
1988this can cause your callback to be invoked much earlier than you would
1989expect.
1990
1991To see why, imagine a system with a clock that only offers full second
1992resolution (think windows if you can't come up with a broken enough OS
1993yourself). If you schedule a one-second timer at the time 500.9, then the
1994event loop will schedule your timeout to elapse at a system time of 500
1995(500.9 truncated to the resolution) + 1, or 501.
1996
1997If an event library looks at the timeout 0.1s later, it will see "501 >=
1998501" and invoke the callback 0.1s after it was started, even though a
1999one-second delay was requested - this is being "too early", despite best
2000intentions.
2001
2002This is the reason why libev will never invoke the callback if the elapsed
2003delay equals the requested delay, but only when the elapsed delay is
2004larger than the requested delay. In the example above, libev would only invoke
2005the callback at system time 502, or 1.1s after the timer was started.
2006
2007So, while libev cannot guarantee that your callback will be invoked
2008exactly when requested, it I<can> and I<does> guarantee that the requested
2009delay has actually elapsed, or in other words, it always errs on the "too
2010late" side of things.
2011
1955=head3 The special problem of time updates 2012=head3 The special problem of time updates
1956 2013
1957Establishing the current time is a costly operation (it usually takes at 2014Establishing the current time is a costly operation (it usually takes
1958least two system calls): EV therefore updates its idea of the current 2015at least one system call): EV therefore updates its idea of the current
1959time only before and after C<ev_run> collects new events, which causes a 2016time only before and after C<ev_run> collects new events, which causes a
1960growing difference between C<ev_now ()> and C<ev_time ()> when handling 2017growing difference between C<ev_now ()> and C<ev_time ()> when handling
1961lots of events in one iteration. 2018lots of events in one iteration.
1962 2019
1963The relative timeouts are calculated relative to the C<ev_now ()> 2020The relative timeouts are calculated relative to the C<ev_now ()>
1969 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.); 2026 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.);
1970 2027
1971If the event loop is suspended for a long time, you can also force an 2028If the event loop is suspended for a long time, you can also force an
1972update of the time returned by C<ev_now ()> by calling C<ev_now_update 2029update of the time returned by C<ev_now ()> by calling C<ev_now_update
1973()>. 2030()>.
2031
2032=head3 The special problem of unsynchronised clocks
2033
2034Modern systems have a variety of clocks - libev itself uses the normal
2035"wall clock" clock and, if available, the monotonic clock (to avoid time
2036jumps).
2037
2038Neither of these clocks is synchronised with each other or any other clock
2039on the system, so C<ev_time ()> might return a considerably different time
2040than C<gettimeofday ()> or C<time ()>. On a GNU/Linux system, for example,
2041a call to C<gettimeofday> might return a second count that is one higher
2042than a directly following call to C<time>.
2043
2044The moral of this is to only compare libev-related timestamps with
2045C<ev_time ()> and C<ev_now ()>, at least if you want better precision than
2046a second or so.
2047
2048One more problem arises due to this lack of synchronisation: if libev uses
2049the system monotonic clock and you compare timestamps from C<ev_time>
2050or C<ev_now> from when you started your timer and when your callback is
2051invoked, you will find that sometimes the callback is a bit "early".
2052
2053This is because C<ev_timer>s work in real time, not wall clock time, so
2054libev makes sure your callback is not invoked before the delay happened,
2055I<measured according to the real time>, not the system clock.
2056
2057If your timeouts are based on a physical timescale (e.g. "time out this
2058connection after 100 seconds") then this shouldn't bother you as it is
2059exactly the right behaviour.
2060
2061If you want to compare wall clock/system timestamps to your timers, then
2062you need to use C<ev_periodic>s, as these are based on the wall clock
2063time, where your comparisons will always generate correct results.
1974 2064
1975=head3 The special problems of suspended animation 2065=head3 The special problems of suspended animation
1976 2066
1977When you leave the server world it is quite customary to hit machines that 2067When you leave the server world it is quite customary to hit machines that
1978can suspend/hibernate - what happens to the clocks during such a suspend? 2068can suspend/hibernate - what happens to the clocks during such a suspend?
2022keep up with the timer (because it takes longer than those 10 seconds to 2112keep up with the timer (because it takes longer than those 10 seconds to
2023do stuff) the timer will not fire more than once per event loop iteration. 2113do stuff) the timer will not fire more than once per event loop iteration.
2024 2114
2025=item ev_timer_again (loop, ev_timer *) 2115=item ev_timer_again (loop, ev_timer *)
2026 2116
2027This will act as if the timer timed out and restart it again if it is 2117This will act as if the timer timed out, and restarts it again if it is
2028repeating. The exact semantics are: 2118repeating. It basically works like calling C<ev_timer_stop>, updating the
2119timeout to the C<repeat> value and calling C<ev_timer_start>.
2029 2120
2121The exact semantics are as in the following rules, all of which will be
2122applied to the watcher:
2123
2124=over 4
2125
2030If the timer is pending, its pending status is cleared. 2126=item If the timer is pending, the pending status is always cleared.
2031 2127
2032If the timer is started but non-repeating, stop it (as if it timed out). 2128=item If the timer is started but non-repeating, stop it (as if it timed
2129out, without invoking it).
2033 2130
2034If the timer is repeating, either start it if necessary (with the 2131=item If the timer is repeating, make the C<repeat> value the new timeout
2035C<repeat> value), or reset the running timer to the C<repeat> value. 2132and start the timer, if necessary.
2133
2134=back
2036 2135
2037This sounds a bit complicated, see L<Be smart about timeouts>, above, for a 2136This sounds a bit complicated, see L<Be smart about timeouts>, above, for a
2038usage example. 2137usage example.
2039 2138
2040=item ev_tstamp ev_timer_remaining (loop, ev_timer *) 2139=item ev_tstamp ev_timer_remaining (loop, ev_timer *)
3219C<ev_async_sent> calls). In fact, you could use signal watchers as a kind 3318C<ev_async_sent> calls). In fact, you could use signal watchers as a kind
3220of "global async watchers" by using a watcher on an otherwise unused 3319of "global async watchers" by using a watcher on an otherwise unused
3221signal, and C<ev_feed_signal> to signal this watcher from another thread, 3320signal, and C<ev_feed_signal> to signal this watcher from another thread,
3222even without knowing which loop owns the signal. 3321even without knowing which loop owns the signal.
3223 3322
3224Unlike C<ev_signal> watchers, C<ev_async> works with any event loop, not
3225just the default loop.
3226
3227=head3 Queueing 3323=head3 Queueing
3228 3324
3229C<ev_async> does not support queueing of data in any way. The reason 3325C<ev_async> does not support queueing of data in any way. The reason
3230is that the author does not know of a simple (or any) algorithm for a 3326is that the author does not know of a simple (or any) algorithm for a
3231multiple-writer-single-reader queue that works in all cases and doesn't 3327multiple-writer-single-reader queue that works in all cases and doesn't
3330Unlike C<ev_feed_event>, this call is safe to do from other threads, 3426Unlike C<ev_feed_event>, this call is safe to do from other threads,
3331signal or similar contexts (see the discussion of C<EV_ATOMIC_T> in the 3427signal or similar contexts (see the discussion of C<EV_ATOMIC_T> in the
3332embedding section below on what exactly this means). 3428embedding section below on what exactly this means).
3333 3429
3334Note that, as with other watchers in libev, multiple events might get 3430Note that, as with other watchers in libev, multiple events might get
3335compressed into a single callback invocation (another way to look at this 3431compressed into a single callback invocation (another way to look at
3336is that C<ev_async> watchers are level-triggered, set on C<ev_async_send>, 3432this is that C<ev_async> watchers are level-triggered: they are set on
3337reset when the event loop detects that). 3433C<ev_async_send>, reset when the event loop detects that).
3338 3434
3339This call incurs the overhead of a system call only once per event loop 3435This call incurs the overhead of at most one extra system call per event
3340iteration, so while the overhead might be noticeable, it doesn't apply to 3436loop iteration, if the event loop is blocked, and no syscall at all if
3341repeated calls to C<ev_async_send> for the same event loop. 3437the event loop (or your program) is processing events. That means that
3438repeated calls are basically free (there is no need to avoid calls for
3439performance reasons) and that the overhead becomes smaller (typically
3440zero) under load.
3342 3441
3343=item bool = ev_async_pending (ev_async *) 3442=item bool = ev_async_pending (ev_async *)
3344 3443
3345Returns a non-zero value when C<ev_async_send> has been called on the 3444Returns a non-zero value when C<ev_async_send> has been called on the
3346watcher but the event has not yet been processed (or even noted) by the 3445watcher but the event has not yet been processed (or even noted) by the
3401 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0); 3500 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
3402 3501
3403=item ev_feed_fd_event (loop, int fd, int revents) 3502=item ev_feed_fd_event (loop, int fd, int revents)
3404 3503
3405Feed an event on the given fd, as if a file descriptor backend detected 3504Feed an event on the given fd, as if a file descriptor backend detected
3406the given events it. 3505the given events.
3407 3506
3408=item ev_feed_signal_event (loop, int signum) 3507=item ev_feed_signal_event (loop, int signum)
3409 3508
3410Feed an event as if the given signal occurred. See also C<ev_feed_signal>, 3509Feed an event as if the given signal occurred. See also C<ev_feed_signal>,
3411which is async-safe. 3510which is async-safe.
3485 { 3584 {
3486 struct my_biggy big = (struct my_biggy *) 3585 struct my_biggy big = (struct my_biggy *)
3487 (((char *)w) - offsetof (struct my_biggy, t2)); 3586 (((char *)w) - offsetof (struct my_biggy, t2));
3488 } 3587 }
3489 3588
3589=head2 AVOIDING FINISHING BEFORE RETURNING
3590
3591Often you have structures like this in event-based programs:
3592
3593 callback ()
3594 {
3595 free (request);
3596 }
3597
3598 request = start_new_request (..., callback);
3599
3600The intent is to start some "lengthy" operation. The C<request> could be
3601used to cancel the operation, or do other things with it.
3602
3603It's not uncommon to have code paths in C<start_new_request> that
3604immediately invoke the callback, for example, to report errors. Or you add
3605some caching layer that finds that it can skip the lengthy aspects of the
3606operation and simply invoke the callback with the result.
3607
3608The problem here is that this will happen I<before> C<start_new_request>
3609has returned, so C<request> is not set.
3610
3611Even if you pass the request by some safer means to the callback, you
3612might want to do something to the request after starting it, such as
3613canceling it, which probably isn't working so well when the callback has
3614already been invoked.
3615
3616A common way around all these issues is to make sure that
3617C<start_new_request> I<always> returns before the callback is invoked. If
3618C<start_new_request> immediately knows the result, it can artificially
3619delay invoking the callback by e.g. using a C<prepare> or C<idle> watcher
3620for example, or more sneakily, by reusing an existing (stopped) watcher
3621and pushing it into the pending queue:
3622
3623 ev_set_cb (watcher, callback);
3624 ev_feed_event (EV_A_ watcher, 0);
3625
3626This way, C<start_new_request> can safely return before the callback is
3627invoked, while not delaying callback invocation too much.
3628
3490=head2 MODEL/NESTED EVENT LOOP INVOCATIONS AND EXIT CONDITIONS 3629=head2 MODEL/NESTED EVENT LOOP INVOCATIONS AND EXIT CONDITIONS
3491 3630
3492Often (especially in GUI toolkits) there are places where you have 3631Often (especially in GUI toolkits) there are places where you have
3493I<modal> interaction, which is most easily implemented by recursively 3632I<modal> interaction, which is most easily implemented by recursively
3494invoking C<ev_run>. 3633invoking C<ev_run>.
3507 int exit_main_loop = 0; 3646 int exit_main_loop = 0;
3508 3647
3509 while (!exit_main_loop) 3648 while (!exit_main_loop)
3510 ev_run (EV_DEFAULT_ EVRUN_ONCE); 3649 ev_run (EV_DEFAULT_ EVRUN_ONCE);
3511 3650
3512 // in a model watcher 3651 // in a modal watcher
3513 int exit_nested_loop = 0; 3652 int exit_nested_loop = 0;
3514 3653
3515 while (!exit_nested_loop) 3654 while (!exit_nested_loop)
3516 ev_run (EV_A_ EVRUN_ONCE); 3655 ev_run (EV_A_ EVRUN_ONCE);
3517 3656
3697 switch_to (libev_coro); 3836 switch_to (libev_coro);
3698 } 3837 }
3699 3838
3700That basically suspends the coroutine inside C<wait_for_event> and 3839That basically suspends the coroutine inside C<wait_for_event> and
3701continues the libev coroutine, which, when appropriate, switches back to 3840continues the libev coroutine, which, when appropriate, switches back to
3702this or any other coroutine. I am sure if you sue this your own :) 3841this or any other coroutine.
3703 3842
3704You can do similar tricks if you have, say, threads with an event queue - 3843You can do similar tricks if you have, say, threads with an event queue -
3705instead of storing a coroutine, you store the queue object and instead of 3844instead of storing a coroutine, you store the queue object and instead of
3706switching to a coroutine, you push the watcher onto the queue and notify 3845switching to a coroutine, you push the watcher onto the queue and notify
3707any waiters. 3846any waiters.
3782with C<operator ()> can be used as callbacks. Other types should be easy 3921with C<operator ()> can be used as callbacks. Other types should be easy
3783to add as long as they only need one additional pointer for context. If 3922to add as long as they only need one additional pointer for context. If
3784you need support for other types of functors please contact the author 3923you need support for other types of functors please contact the author
3785(preferably after implementing it). 3924(preferably after implementing it).
3786 3925
3926For all this to work, your C++ compiler either has to use the same calling
3927conventions as your C compiler (for static member functions), or you have
3928to embed libev and compile libev itself as C++.
3929
3787Here is a list of things available in the C<ev> namespace: 3930Here is a list of things available in the C<ev> namespace:
3788 3931
3789=over 4 3932=over 4
3790 3933
3791=item C<ev::READ>, C<ev::WRITE> etc. 3934=item C<ev::READ>, C<ev::WRITE> etc.
3800=item C<ev::io>, C<ev::timer>, C<ev::periodic>, C<ev::idle>, C<ev::sig> etc. 3943=item C<ev::io>, C<ev::timer>, C<ev::periodic>, C<ev::idle>, C<ev::sig> etc.
3801 3944
3802For each C<ev_TYPE> watcher in F<ev.h> there is a corresponding class of 3945For each C<ev_TYPE> watcher in F<ev.h> there is a corresponding class of
3803the same name in the C<ev> namespace, with the exception of C<ev_signal> 3946the same name in the C<ev> namespace, with the exception of C<ev_signal>
3804which is called C<ev::sig> to avoid clashes with the C<signal> macro 3947which is called C<ev::sig> to avoid clashes with the C<signal> macro
3805defines by many implementations. 3948defined by many implementations.
3806 3949
3807All of those classes have these methods: 3950All of those classes have these methods:
3808 3951
3809=over 4 3952=over 4
3810 3953
3943watchers in the constructor. 4086watchers in the constructor.
3944 4087
3945 class myclass 4088 class myclass
3946 { 4089 {
3947 ev::io io ; void io_cb (ev::io &w, int revents); 4090 ev::io io ; void io_cb (ev::io &w, int revents);
3948 ev::io2 io2 ; void io2_cb (ev::io &w, int revents); 4091 ev::io io2 ; void io2_cb (ev::io &w, int revents);
3949 ev::idle idle; void idle_cb (ev::idle &w, int revents); 4092 ev::idle idle; void idle_cb (ev::idle &w, int revents);
3950 4093
3951 myclass (int fd) 4094 myclass (int fd)
3952 { 4095 {
3953 io .set <myclass, &myclass::io_cb > (this); 4096 io .set <myclass, &myclass::io_cb > (this);
4004L<http://hackage.haskell.org/cgi-bin/hackage-scripts/package/hlibev>. 4147L<http://hackage.haskell.org/cgi-bin/hackage-scripts/package/hlibev>.
4005 4148
4006=item D 4149=item D
4007 4150
4008Leandro Lucarella has written a D language binding (F<ev.d>) for libev, to 4151Leandro Lucarella has written a D language binding (F<ev.d>) for libev, to
4009be found at L<http://proj.llucax.com.ar/wiki/evd>. 4152be found at L<http://www.llucax.com.ar/proj/ev.d/index.html>.
4010 4153
4011=item Ocaml 4154=item Ocaml
4012 4155
4013Erkki Seppala has written Ocaml bindings for libev, to be found at 4156Erkki Seppala has written Ocaml bindings for libev, to be found at
4014L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>. 4157L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>.
4062suitable for use with C<EV_A>. 4205suitable for use with C<EV_A>.
4063 4206
4064=item C<EV_DEFAULT>, C<EV_DEFAULT_> 4207=item C<EV_DEFAULT>, C<EV_DEFAULT_>
4065 4208
4066Similar to the other two macros, this gives you the value of the default 4209Similar to the other two macros, this gives you the value of the default
4067loop, if multiple loops are supported ("ev loop default"). 4210loop, if multiple loops are supported ("ev loop default"). The default loop
4211will be initialised if it isn't already initialised.
4212
4213For non-multiplicity builds, these macros do nothing, so you always have
4214to initialise the loop somewhere.
4068 4215
4069=item C<EV_DEFAULT_UC>, C<EV_DEFAULT_UC_> 4216=item C<EV_DEFAULT_UC>, C<EV_DEFAULT_UC_>
4070 4217
4071Usage identical to C<EV_DEFAULT> and C<EV_DEFAULT_>, but requires that the 4218Usage identical to C<EV_DEFAULT> and C<EV_DEFAULT_>, but requires that the
4072default loop has been initialised (C<UC> == unchecked). Their behaviour 4219default loop has been initialised (C<UC> == unchecked). Their behaviour
4365If defined to be C<1>, libev will compile in support for the Linux inotify 4512If defined to be C<1>, libev will compile in support for the Linux inotify
4366interface to speed up C<ev_stat> watchers. Its actual availability will 4513interface to speed up C<ev_stat> watchers. Its actual availability will
4367be detected at runtime. If undefined, it will be enabled if the headers 4514be detected at runtime. If undefined, it will be enabled if the headers
4368indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled. 4515indicate GNU/Linux + Glibc 2.4 or newer, otherwise disabled.
4369 4516
4517=item EV_NO_SMP
4518
4519If defined to be C<1>, libev will assume that memory is always coherent
4520between threads, that is, threads can be used, but threads never run on
4521different cpus (or different cpu cores). This reduces dependencies
4522and makes libev faster.
4523
4524=item EV_NO_THREADS
4525
4526If defined to be C<1>, libev will assume that it will never be called
4527from different threads, which is a stronger assumption than C<EV_NO_SMP>,
4528above. This reduces dependencies and makes libev faster.
4529
4370=item EV_ATOMIC_T 4530=item EV_ATOMIC_T
4371 4531
4372Libev requires an integer type (suitable for storing C<0> or C<1>) whose 4532Libev requires an integer type (suitable for storing C<0> or C<1>) whose
4373access is atomic with respect to other threads or signal contexts. No such 4533access is atomic and serialised with respect to other threads or signal
4374type is easily found in the C language, so you can provide your own type 4534contexts. No such type is easily found in the C language, so you can
4375that you know is safe for your purposes. It is used both for signal handler "locking" 4535provide your own type that you know is safe for your purposes. It is used
4376as well as for signal and thread safety in C<ev_async> watchers. 4536both for signal handler "locking" as well as for signal and thread safety
4537in C<ev_async> watchers.
4377 4538
4378In the absence of this define, libev will use C<sig_atomic_t volatile> 4539In the absence of this define, libev will use C<sig_atomic_t volatile>
4379(from F<signal.h>), which is usually good enough on most platforms. 4540(from F<signal.h>), which is usually good enough on most platforms,
4541although strictly speaking using a type that also implies a memory fence
4542is required.
4380 4543
4381=item EV_H (h) 4544=item EV_H (h)
4382 4545
4383The name of the F<ev.h> header file used to include it. The default if 4546The name of the F<ev.h> header file used to include it. The default if
4384undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be 4547undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be
4408will have the C<struct ev_loop *> as first argument, and you can create 4571will have the C<struct ev_loop *> as first argument, and you can create
4409additional independent event loops. Otherwise there will be no support 4572additional independent event loops. Otherwise there will be no support
4410for multiple event loops and there is no first event loop pointer 4573for multiple event loops and there is no first event loop pointer
4411argument. Instead, all functions act on the single default loop. 4574argument. Instead, all functions act on the single default loop.
4412 4575
4576Note that C<EV_DEFAULT> and C<EV_DEFAULT_> will no longer provide a
4577default loop when multiplicity is switched off - you always have to
4578initialise the loop manually in this case.
4579
4413=item EV_MINPRI 4580=item EV_MINPRI
4414 4581
4415=item EV_MAXPRI 4582=item EV_MAXPRI
4416 4583
4417The range of allowed priorities. C<EV_MINPRI> must be smaller or equal to 4584The range of allowed priorities. C<EV_MINPRI> must be smaller or equal to
4453 #define EV_USE_POLL 1 4620 #define EV_USE_POLL 1
4454 #define EV_CHILD_ENABLE 1 4621 #define EV_CHILD_ENABLE 1
4455 #define EV_ASYNC_ENABLE 1 4622 #define EV_ASYNC_ENABLE 1
4456 4623
4457The actual value is a bitset, it can be a combination of the following 4624The actual value is a bitset, it can be a combination of the following
4458values: 4625values (by default, all of these are enabled):
4459 4626
4460=over 4 4627=over 4
4461 4628
4462=item C<1> - faster/larger code 4629=item C<1> - faster/larger code
4463 4630
4467code size by roughly 30% on amd64). 4634code size by roughly 30% on amd64).
4468 4635
4469When optimising for size, use of compiler flags such as C<-Os> with 4636When optimising for size, use of compiler flags such as C<-Os> with
4470gcc is recommended, as well as C<-DNDEBUG>, as libev contains a number of 4637gcc is recommended, as well as C<-DNDEBUG>, as libev contains a number of
4471assertions. 4638assertions.
4639
4640The default is off when C<__OPTIMIZE_SIZE__> is defined by your compiler
4641(e.g. gcc with C<-Os>).
4472 4642
4473=item C<2> - faster/larger data structures 4643=item C<2> - faster/larger data structures
4474 4644
4475Replaces the small 2-heap for timer management by a faster 4-heap, larger 4645Replaces the small 2-heap for timer management by a faster 4-heap, larger
4476hash table sizes and so on. This will usually further increase code size 4646hash table sizes and so on. This will usually further increase code size
4477and can additionally have an effect on the size of data structures at 4647and can additionally have an effect on the size of data structures at
4478runtime. 4648runtime.
4479 4649
4650The default is off when C<__OPTIMIZE_SIZE__> is defined by your compiler
4651(e.g. gcc with C<-Os>).
4652
4480=item C<4> - full API configuration 4653=item C<4> - full API configuration
4481 4654
4482This enables priorities (sets C<EV_MAXPRI>=2 and C<EV_MINPRI>=-2), and 4655This enables priorities (sets C<EV_MAXPRI>=2 and C<EV_MINPRI>=-2), and
4483enables multiplicity (C<EV_MULTIPLICITY>=1). 4656enables multiplicity (C<EV_MULTIPLICITY>=1).
4484 4657
4514 4687
4515With an intelligent-enough linker (gcc+binutils are intelligent enough 4688With an intelligent-enough linker (gcc+binutils are intelligent enough
4516when you use C<-Wl,--gc-sections -ffunction-sections>) functions unused by 4689when you use C<-Wl,--gc-sections -ffunction-sections>) functions unused by
4517your program might be left out as well - a binary starting a timer and an 4690your program might be left out as well - a binary starting a timer and an
4518I/O watcher then might come out at only 5Kb. 4691I/O watcher then might come out at only 5Kb.
4692
4693=item EV_API_STATIC
4694
4695If this symbol is defined (by default it is not), then all identifiers
4696will have static linkage. This means that libev will not export any
4697identifiers, and you cannot link against libev anymore. This can be useful
4698when you embed libev, only want to use libev functions in a single file,
4699and do not want its identifiers to be visible.
4700
4701To use this, define C<EV_API_STATIC> and include F<ev.c> in the file that
4702wants to use libev.
4703
4704This option only works when libev is compiled with a C compiler, as C++
4705doesn't support the required declaration syntax.
4519 4706
4520=item EV_AVOID_STDIO 4707=item EV_AVOID_STDIO
4521 4708
4522If this is set to C<1> at compiletime, then libev will avoid using stdio 4709If this is set to C<1> at compiletime, then libev will avoid using stdio
4523functions (printf, scanf, perror etc.). This will increase the code size 4710functions (printf, scanf, perror etc.). This will increase the code size
4903requires, and its I/O model is fundamentally incompatible with the POSIX 5090requires, and its I/O model is fundamentally incompatible with the POSIX
4904model. Libev still offers limited functionality on this platform in 5091model. Libev still offers limited functionality on this platform in
4905the form of the C<EVBACKEND_SELECT> backend, and only supports socket 5092the form of the C<EVBACKEND_SELECT> backend, and only supports socket
4906descriptors. This only applies when using Win32 natively, not when using 5093descriptors. This only applies when using Win32 natively, not when using
4907e.g. cygwin. Actually, it only applies to the microsofts own compilers, 5094e.g. cygwin. Actually, it only applies to the microsofts own compilers,
4908as every compielr comes with a slightly differently broken/incompatible 5095as every compiler comes with a slightly differently broken/incompatible
4909environment. 5096environment.
4910 5097
4911Lifting these limitations would basically require the full 5098Lifting these limitations would basically require the full
4912re-implementation of the I/O system. If you are into this kind of thing, 5099re-implementation of the I/O system. If you are into this kind of thing,
4913then note that glib does exactly that for you in a very portable way (note 5100then note that glib does exactly that for you in a very portable way (note
5046 5233
5047The type C<double> is used to represent timestamps. It is required to 5234The type C<double> is used to represent timestamps. It is required to
5048have at least 51 bits of mantissa (and 9 bits of exponent), which is 5235have at least 51 bits of mantissa (and 9 bits of exponent), which is
5049good enough for at least into the year 4000 with millisecond accuracy 5236good enough for at least into the year 4000 with millisecond accuracy
5050(the design goal for libev). This requirement is overfulfilled by 5237(the design goal for libev). This requirement is overfulfilled by
5051implementations using IEEE 754, which is basically all existing ones. With 5238implementations using IEEE 754, which is basically all existing ones.
5239
5052IEEE 754 doubles, you get microsecond accuracy until at least 2200. 5240With IEEE 754 doubles, you get microsecond accuracy until at least the
5241year 2255 (and millisecond accuracy till the year 287396 - by then, libev
5242is either obsolete or somebody patched it to use C<long double> or
5243something like that, just kidding).
5053 5244
5054=back 5245=back
5055 5246
5056If you know of other additional requirements drop me a note. 5247If you know of other additional requirements drop me a note.
5057 5248
5119=item Processing ev_async_send: O(number_of_async_watchers) 5310=item Processing ev_async_send: O(number_of_async_watchers)
5120 5311
5121=item Processing signals: O(max_signal_number) 5312=item Processing signals: O(max_signal_number)
5122 5313
5123Sending involves a system call I<iff> there were no other C<ev_async_send> 5314Sending involves a system call I<iff> there were no other C<ev_async_send>
5124calls in the current loop iteration. Checking for async and signal events 5315calls in the current loop iteration and the loop is currently
5316blocked. Checking for async and signal events involves iterating over all
5125involves iterating over all running async watchers or all signal numbers. 5317running async watchers or all signal numbers.
5126 5318
5127=back 5319=back
5128 5320
5129 5321
5130=head1 PORTING FROM LIBEV 3.X TO 4.X 5322=head1 PORTING FROM LIBEV 3.X TO 4.X

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines