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

Comparing libev/ev.pod (file contents):
Revision 1.54 by root, Tue Nov 27 20:26:51 2007 UTC vs.
Revision 1.66 by root, Mon Dec 3 13:41:25 2007 UTC

63details of the event, and then hand it over to libev by I<starting> the 63details of the event, and then hand it over to libev by I<starting> the
64watcher. 64watcher.
65 65
66=head1 FEATURES 66=head1 FEATURES
67 67
68Libev supports C<select>, C<poll>, the linux-specific C<epoll>, the 68Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
69bsd-specific C<kqueue> and the solaris-specific event port mechanisms 69BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
70for file descriptor events (C<ev_io>), relative timers (C<ev_timer>), 70for file descriptor events (C<ev_io>), the Linux C<inotify> interface
71(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers
71absolute timers with customised rescheduling (C<ev_periodic>), synchronous 72with customised rescheduling (C<ev_periodic>), synchronous signals
72signals (C<ev_signal>), process status change events (C<ev_child>), and 73(C<ev_signal>), process status change events (C<ev_child>), and event
73event watchers dealing with the event loop mechanism itself (C<ev_idle>, 74watchers dealing with the event loop mechanism itself (C<ev_idle>,
74C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as 75C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as
75file watchers (C<ev_stat>) and even limited support for fork events 76file watchers (C<ev_stat>) and even limited support for fork events
76(C<ev_fork>). 77(C<ev_fork>).
77 78
78It also is quite fast (see this 79It also is quite fast (see this
162C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for 163C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
163recommended ones. 164recommended ones.
164 165
165See the description of C<ev_embed> watchers for more info. 166See the description of C<ev_embed> watchers for more info.
166 167
167=item ev_set_allocator (void *(*cb)(void *ptr, size_t size)) 168=item ev_set_allocator (void *(*cb)(void *ptr, long size))
168 169
169Sets the allocation function to use (the prototype and semantics are 170Sets the allocation function to use (the prototype is similar - the
170identical to the realloc C function). It is used to allocate and free 171semantics is identical - to the realloc C function). It is used to
171memory (no surprises here). If it returns zero when memory needs to be 172allocate and free memory (no surprises here). If it returns zero when
172allocated, the library might abort or take some potentially destructive 173memory needs to be allocated, the library might abort or take some
173action. The default is your system realloc function. 174potentially destructive action. The default is your system realloc
175function.
174 176
175You could override this function in high-availability programs to, say, 177You could override this function in high-availability programs to, say,
176free some memory if it cannot allocate memory, to use a special allocator, 178free some memory if it cannot allocate memory, to use a special allocator,
177or even to sleep a while and retry until some memory is available. 179or even to sleep a while and retry until some memory is available.
178 180
264C<LIBEV_FLAGS>. Otherwise (the default), this environment variable will 266C<LIBEV_FLAGS>. Otherwise (the default), this environment variable will
265override the flags completely if it is found in the environment. This is 267override the flags completely if it is found in the environment. This is
266useful to try out specific backends to test their performance, or to work 268useful to try out specific backends to test their performance, or to work
267around bugs. 269around bugs.
268 270
271=item C<EVFLAG_FORKCHECK>
272
273Instead of calling C<ev_default_fork> or C<ev_loop_fork> manually after
274a fork, you can also make libev check for a fork in each iteration by
275enabling this flag.
276
277This works by calling C<getpid ()> on every iteration of the loop,
278and thus this might slow down your event loop if you do a lot of loop
279iterations and little real work, but is usually not noticeable (on my
280Linux system for example, C<getpid> is actually a simple 5-insn sequence
281without a syscall and thus I<very> fast, but my Linux system also has
282C<pthread_atfork> which is even faster).
283
284The big advantage of this flag is that you can forget about fork (and
285forget about forgetting to tell libev about forking) when you use this
286flag.
287
288This flag setting cannot be overriden or specified in the C<LIBEV_FLAGS>
289environment variable.
290
269=item C<EVBACKEND_SELECT> (value 1, portable select backend) 291=item C<EVBACKEND_SELECT> (value 1, portable select backend)
270 292
271This is your standard select(2) backend. Not I<completely> standard, as 293This is your standard select(2) backend. Not I<completely> standard, as
272libev tries to roll its own fd_set with no limits on the number of fds, 294libev tries to roll its own fd_set with no limits on the number of fds,
273but if that fails, expect a fairly low limit on the number of fds when 295but if that fails, expect a fairly low limit on the number of fds when
407=item ev_loop_fork (loop) 429=item ev_loop_fork (loop)
408 430
409Like C<ev_default_fork>, but acts on an event loop created by 431Like C<ev_default_fork>, but acts on an event loop created by
410C<ev_loop_new>. Yes, you have to call this on every allocated event loop 432C<ev_loop_new>. Yes, you have to call this on every allocated event loop
411after fork, and how you do this is entirely your own problem. 433after fork, and how you do this is entirely your own problem.
434
435=item unsigned int ev_loop_count (loop)
436
437Returns the count of loop iterations for the loop, which is identical to
438the number of times libev did poll for new events. It starts at C<0> and
439happily wraps around with enough iterations.
440
441This value can sometimes be useful as a generation counter of sorts (it
442"ticks" the number of loop iterations), as it roughly corresponds with
443C<ev_prepare> and C<ev_check> calls.
412 444
413=item unsigned int ev_backend (loop) 445=item unsigned int ev_backend (loop)
414 446
415Returns one of the C<EVBACKEND_*> flags indicating the event backend in 447Returns one of the C<EVBACKEND_*> flags indicating the event backend in
416use. 448use.
703events but its callback has not yet been invoked). As long as a watcher 735events but its callback has not yet been invoked). As long as a watcher
704is pending (but not active) you must not call an init function on it (but 736is pending (but not active) you must not call an init function on it (but
705C<ev_TYPE_set> is safe) and you must make sure the watcher is available to 737C<ev_TYPE_set> is safe) and you must make sure the watcher is available to
706libev (e.g. you cnanot C<free ()> it). 738libev (e.g. you cnanot C<free ()> it).
707 739
708=item callback = ev_cb (ev_TYPE *watcher) 740=item callback ev_cb (ev_TYPE *watcher)
709 741
710Returns the callback currently set on the watcher. 742Returns the callback currently set on the watcher.
711 743
712=item ev_cb_set (ev_TYPE *watcher, callback) 744=item ev_cb_set (ev_TYPE *watcher, callback)
713 745
741 { 773 {
742 struct my_io *w = (struct my_io *)w_; 774 struct my_io *w = (struct my_io *)w_;
743 ... 775 ...
744 } 776 }
745 777
746More interesting and less C-conformant ways of catsing your callback type 778More interesting and less C-conformant ways of casting your callback type
747have been omitted.... 779instead have been omitted.
780
781Another common scenario is having some data structure with multiple
782watchers:
783
784 struct my_biggy
785 {
786 int some_data;
787 ev_timer t1;
788 ev_timer t2;
789 }
790
791In this case getting the pointer to C<my_biggy> is a bit more complicated,
792you need to use C<offsetof>:
793
794 #include <stddef.h>
795
796 static void
797 t1_cb (EV_P_ struct ev_timer *w, int revents)
798 {
799 struct my_biggy big = (struct my_biggy *
800 (((char *)w) - offsetof (struct my_biggy, t1));
801 }
802
803 static void
804 t2_cb (EV_P_ struct ev_timer *w, int revents)
805 {
806 struct my_biggy big = (struct my_biggy *
807 (((char *)w) - offsetof (struct my_biggy, t2));
808 }
748 809
749 810
750=head1 WATCHER TYPES 811=head1 WATCHER TYPES
751 812
752This section describes each watcher in detail, but will not repeat 813This section describes each watcher in detail, but will not repeat
885=item ev_timer_again (loop) 946=item ev_timer_again (loop)
886 947
887This will act as if the timer timed out and restart it again if it is 948This will act as if the timer timed out and restart it again if it is
888repeating. The exact semantics are: 949repeating. The exact semantics are:
889 950
951If the timer is pending, its pending status is cleared.
952
890If the timer is started but nonrepeating, stop it. 953If the timer is started but nonrepeating, stop it (as if it timed out).
891 954
892If the timer is repeating, either start it if necessary (with the repeat 955If the timer is repeating, either start it if necessary (with the
893value), or reset the running timer to the repeat value. 956C<repeat> value), or reset the running timer to the C<repeat> value.
894 957
895This sounds a bit complicated, but here is a useful and typical 958This sounds a bit complicated, but here is a useful and typical
896example: Imagine you have a tcp connection and you want a so-called 959example: Imagine you have a tcp connection and you want a so-called idle
897idle timeout, that is, you want to be called when there have been, 960timeout, that is, you want to be called when there have been, say, 60
898say, 60 seconds of inactivity on the socket. The easiest way to do 961seconds of inactivity on the socket. The easiest way to do this is to
899this is to configure an C<ev_timer> with C<after>=C<repeat>=C<60> and calling 962configure an C<ev_timer> with a C<repeat> value of C<60> and then call
900C<ev_timer_again> each time you successfully read or write some data. If 963C<ev_timer_again> each time you successfully read or write some data. If
901you go into an idle state where you do not expect data to travel on the 964you go into an idle state where you do not expect data to travel on the
902socket, you can stop the timer, and again will automatically restart it if 965socket, you can C<ev_timer_stop> the timer, and C<ev_timer_again> will
903need be. 966automatically restart it if need be.
904 967
905You can also ignore the C<after> value and C<ev_timer_start> altogether 968That means you can ignore the C<after> value and C<ev_timer_start>
906and only ever use the C<repeat> value: 969altogether and only ever use the C<repeat> value and C<ev_timer_again>:
907 970
908 ev_timer_init (timer, callback, 0., 5.); 971 ev_timer_init (timer, callback, 0., 5.);
909 ev_timer_again (loop, timer); 972 ev_timer_again (loop, timer);
910 ... 973 ...
911 timer->again = 17.; 974 timer->again = 17.;
912 ev_timer_again (loop, timer); 975 ev_timer_again (loop, timer);
913 ... 976 ...
914 timer->again = 10.; 977 timer->again = 10.;
915 ev_timer_again (loop, timer); 978 ev_timer_again (loop, timer);
916 979
917This is more efficient then stopping/starting the timer eahc time you want 980This is more slightly efficient then stopping/starting the timer each time
918to modify its timeout value. 981you want to modify its timeout value.
919 982
920=item ev_tstamp repeat [read-write] 983=item ev_tstamp repeat [read-write]
921 984
922The current C<repeat> value. Will be used each time the watcher times out 985The current C<repeat> value. Will be used each time the watcher times out
923or C<ev_timer_again> is called and determines the next timeout (if any), 986or C<ev_timer_again> is called and determines the next timeout (if any),
1192not exist" is a status change like any other. The condition "path does 1255not exist" is a status change like any other. The condition "path does
1193not exist" is signified by the C<st_nlink> field being zero (which is 1256not exist" is signified by the C<st_nlink> field being zero (which is
1194otherwise always forced to be at least one) and all the other fields of 1257otherwise always forced to be at least one) and all the other fields of
1195the stat buffer having unspecified contents. 1258the stat buffer having unspecified contents.
1196 1259
1260The path I<should> be absolute and I<must not> end in a slash. If it is
1261relative and your working directory changes, the behaviour is undefined.
1262
1197Since there is no standard to do this, the portable implementation simply 1263Since there is no standard to do this, the portable implementation simply
1198calls C<stat (2)> regulalry on the path to see if it changed somehow. You 1264calls C<stat (2)> regularly on the path to see if it changed somehow. You
1199can specify a recommended polling interval for this case. If you specify 1265can specify a recommended polling interval for this case. If you specify
1200a polling interval of C<0> (highly recommended!) then a I<suitable, 1266a polling interval of C<0> (highly recommended!) then a I<suitable,
1201unspecified default> value will be used (which you can expect to be around 1267unspecified default> value will be used (which you can expect to be around
1202five seconds, although this might change dynamically). Libev will also 1268five seconds, although this might change dynamically). Libev will also
1203impose a minimum interval which is currently around C<0.1>, but thats 1269impose a minimum interval which is currently around C<0.1>, but thats
1205 1271
1206This watcher type is not meant for massive numbers of stat watchers, 1272This watcher type is not meant for massive numbers of stat watchers,
1207as even with OS-supported change notifications, this can be 1273as even with OS-supported change notifications, this can be
1208resource-intensive. 1274resource-intensive.
1209 1275
1210At the time of this writing, no specific OS backends are implemented, but 1276At the time of this writing, only the Linux inotify interface is
1211if demand increases, at least a kqueue and inotify backend will be added. 1277implemented (implementing kqueue support is left as an exercise for the
1278reader). Inotify will be used to give hints only and should not change the
1279semantics of C<ev_stat> watchers, which means that libev sometimes needs
1280to fall back to regular polling again even with inotify, but changes are
1281usually detected immediately, and if the file exists there will be no
1282polling.
1212 1283
1213=over 4 1284=over 4
1214 1285
1215=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval) 1286=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval)
1216 1287
1396 1467
1397 // create io watchers for each fd and a timer before blocking 1468 // create io watchers for each fd and a timer before blocking
1398 static void 1469 static void
1399 adns_prepare_cb (ev_loop *loop, ev_prepare *w, int revents) 1470 adns_prepare_cb (ev_loop *loop, ev_prepare *w, int revents)
1400 { 1471 {
1401 int timeout = 3600000;truct pollfd fds [nfd]; 1472 int timeout = 3600000;
1473 struct pollfd fds [nfd];
1402 // actual code will need to loop here and realloc etc. 1474 // actual code will need to loop here and realloc etc.
1403 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 1475 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
1404 1476
1405 /* the callback is illegal, but won't be called as we stop during check */ 1477 /* the callback is illegal, but won't be called as we stop during check */
1406 ev_timer_init (&tw, 0, timeout * 1e-3); 1478 ev_timer_init (&tw, 0, timeout * 1e-3);
1787Similar to the other two macros, this gives you the value of the default 1859Similar to the other two macros, this gives you the value of the default
1788loop, if multiple loops are supported ("ev loop default"). 1860loop, if multiple loops are supported ("ev loop default").
1789 1861
1790=back 1862=back
1791 1863
1792Example: Declare and initialise a check watcher, working regardless of 1864Example: Declare and initialise a check watcher, utilising the above
1793wether multiple loops are supported or not. 1865macros so it will work regardless of wether multiple loops are supported
1866or not.
1794 1867
1795 static void 1868 static void
1796 check_cb (EV_P_ ev_timer *w, int revents) 1869 check_cb (EV_P_ ev_timer *w, int revents)
1797 { 1870 {
1798 ev_check_stop (EV_A_ w); 1871 ev_check_stop (EV_A_ w);
1800 1873
1801 ev_check check; 1874 ev_check check;
1802 ev_check_init (&check, check_cb); 1875 ev_check_init (&check, check_cb);
1803 ev_check_start (EV_DEFAULT_ &check); 1876 ev_check_start (EV_DEFAULT_ &check);
1804 ev_loop (EV_DEFAULT_ 0); 1877 ev_loop (EV_DEFAULT_ 0);
1805
1806 1878
1807=head1 EMBEDDING 1879=head1 EMBEDDING
1808 1880
1809Libev can (and often is) directly embedded into host 1881Libev can (and often is) directly embedded into host
1810applications. Examples of applications that embed it include the Deliantra 1882applications. Examples of applications that embed it include the Deliantra
1850 ev_vars.h 1922 ev_vars.h
1851 ev_wrap.h 1923 ev_wrap.h
1852 1924
1853 ev_win32.c required on win32 platforms only 1925 ev_win32.c required on win32 platforms only
1854 1926
1855 ev_select.c only when select backend is enabled (which is by default) 1927 ev_select.c only when select backend is enabled (which is enabled by default)
1856 ev_poll.c only when poll backend is enabled (disabled by default) 1928 ev_poll.c only when poll backend is enabled (disabled by default)
1857 ev_epoll.c only when the epoll backend is enabled (disabled by default) 1929 ev_epoll.c only when the epoll backend is enabled (disabled by default)
1858 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 1930 ev_kqueue.c only when the kqueue backend is enabled (disabled by default)
1859 ev_port.c only when the solaris port backend is enabled (disabled by default) 1931 ev_port.c only when the solaris port backend is enabled (disabled by default)
1860 1932
1985 2057
1986=item EV_USE_DEVPOLL 2058=item EV_USE_DEVPOLL
1987 2059
1988reserved for future expansion, works like the USE symbols above. 2060reserved for future expansion, works like the USE symbols above.
1989 2061
2062=item EV_USE_INOTIFY
2063
2064If defined to be C<1>, libev will compile in support for the Linux inotify
2065interface to speed up C<ev_stat> watchers. Its actual availability will
2066be detected at runtime.
2067
1990=item EV_H 2068=item EV_H
1991 2069
1992The name of the F<ev.h> header file used to include it. The default if 2070The name of the F<ev.h> header file used to include it. The default if
1993undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This 2071undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This
1994can be used to virtually rename the F<ev.h> header file in case of conflicts. 2072can be used to virtually rename the F<ev.h> header file in case of conflicts.
2049=item EV_PID_HASHSIZE 2127=item EV_PID_HASHSIZE
2050 2128
2051C<ev_child> watchers use a small hash table to distribute workload by 2129C<ev_child> watchers use a small hash table to distribute workload by
2052pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 2130pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
2053than enough. If you need to manage thousands of children you might want to 2131than enough. If you need to manage thousands of children you might want to
2054increase this value. 2132increase this value (I<must> be a power of two).
2133
2134=item EV_INOTIFY_HASHSIZE
2135
2136C<ev_staz> watchers use a small hash table to distribute workload by
2137inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>),
2138usually more than enough. If you need to manage thousands of C<ev_stat>
2139watchers you might want to increase this value (I<must> be a power of
2140two).
2055 2141
2056=item EV_COMMON 2142=item EV_COMMON
2057 2143
2058By default, all watchers have a C<void *data> member. By redefining 2144By default, all watchers have a C<void *data> member. By redefining
2059this macro to a something else you can include more and other types of 2145this macro to a something else you can include more and other types of
2088interface) and F<EV.xs> (implementation) files. Only the F<EV.xs> file 2174interface) and F<EV.xs> (implementation) files. Only the F<EV.xs> file
2089will be compiled. It is pretty complex because it provides its own header 2175will be compiled. It is pretty complex because it provides its own header
2090file. 2176file.
2091 2177
2092The usage in rxvt-unicode is simpler. It has a F<ev_cpp.h> header file 2178The usage in rxvt-unicode is simpler. It has a F<ev_cpp.h> header file
2093that everybody includes and which overrides some autoconf choices: 2179that everybody includes and which overrides some configure choices:
2094 2180
2181 #define EV_MINIMAL 1
2095 #define EV_USE_POLL 0 2182 #define EV_USE_POLL 0
2096 #define EV_MULTIPLICITY 0 2183 #define EV_MULTIPLICITY 0
2097 #define EV_PERIODICS 0 2184 #define EV_PERIODIC_ENABLE 0
2185 #define EV_STAT_ENABLE 0
2186 #define EV_FORK_ENABLE 0
2098 #define EV_CONFIG_H <config.h> 2187 #define EV_CONFIG_H <config.h>
2188 #define EV_MINPRI 0
2189 #define EV_MAXPRI 0
2099 2190
2100 #include "ev++.h" 2191 #include "ev++.h"
2101 2192
2102And a F<ev_cpp.C> implementation file that contains libev proper and is compiled: 2193And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
2103 2194
2119 2210
2120=item Starting io/check/prepare/idle/signal/child watchers: O(1) 2211=item Starting io/check/prepare/idle/signal/child watchers: O(1)
2121 2212
2122=item Stopping check/prepare/idle watchers: O(1) 2213=item Stopping check/prepare/idle watchers: O(1)
2123 2214
2124=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % 16)) 2215=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE))
2125 2216
2126=item Finding the next timer per loop iteration: O(1) 2217=item Finding the next timer per loop iteration: O(1)
2127 2218
2128=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd) 2219=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
2129 2220

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines