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

Comparing libev/ev.pod (file contents):
Revision 1.53 by root, Tue Nov 27 20:15:02 2007 UTC vs.
Revision 1.58 by root, Wed Nov 28 11:31:34 2007 UTC

2 2
3libev - a high performance full-featured event loop written in C 3libev - a high performance full-featured event loop written in C
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 /* this is the only header you need */
8 #include <ev.h> 7 #include <ev.h>
9 8
10 /* what follows is a fully working example program */ 9=head1 EXAMPLE PROGRAM
10
11 #include <ev.h>
12
11 ev_io stdin_watcher; 13 ev_io stdin_watcher;
12 ev_timer timeout_watcher; 14 ev_timer timeout_watcher;
13 15
14 /* called when data readable on stdin */ 16 /* called when data readable on stdin */
15 static void 17 static void
61details 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
62watcher. 64watcher.
63 65
64=head1 FEATURES 66=head1 FEATURES
65 67
66Libev supports select, poll, the linux-specific epoll and the bsd-specific 68Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
67kqueue mechanisms for file descriptor events, relative timers, absolute 69BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
68timers with customised rescheduling, signal events, process status change 70for file descriptor events (C<ev_io>), the Linux C<inotify> interface
69events (related to SIGCHLD), and event watchers dealing with the event 71(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers
70loop mechanism itself (idle, prepare and check watchers). It also is quite 72with customised rescheduling (C<ev_periodic>), synchronous signals
73(C<ev_signal>), process status change events (C<ev_child>), and event
74watchers dealing with the event loop mechanism itself (C<ev_idle>,
75C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as
76file watchers (C<ev_stat>) and even limited support for fork events
77(C<ev_fork>).
78
79It also is quite fast (see this
71fast (see this L<benchmark|http://libev.schmorp.de/bench.html> comparing 80L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent
72it to libevent for example). 81for example).
73 82
74=head1 CONVENTIONS 83=head1 CONVENTIONS
75 84
76Libev is very configurable. In this manual the default configuration 85Libev is very configurable. In this manual the default configuration will
77will be described, which supports multiple event loops. For more info 86be described, which supports multiple event loops. For more info about
78about various configuration options please have a look at the file 87various configuration options please have a look at B<EMBED> section in
79F<README.embed> in the libev distribution. If libev was configured without 88this manual. If libev was configured without support for multiple event
80support for multiple event loops, then all functions taking an initial 89loops, then all functions taking an initial argument of name C<loop>
81argument of name C<loop> (which is always of type C<struct ev_loop *>) 90(which is always of type C<struct ev_loop *>) will not have this argument.
82will not have this argument.
83 91
84=head1 TIME REPRESENTATION 92=head1 TIME REPRESENTATION
85 93
86Libev represents time as a single floating point number, representing the 94Libev represents time as a single floating point number, representing the
87(fractional) number of seconds since the (POSIX) epoch (somewhere near 95(fractional) number of seconds since the (POSIX) epoch (somewhere near
116Usually, it's a good idea to terminate if the major versions mismatch, 124Usually, it's a good idea to terminate if the major versions mismatch,
117as this indicates an incompatible change. Minor versions are usually 125as this indicates an incompatible change. Minor versions are usually
118compatible to older versions, so a larger minor version alone is usually 126compatible to older versions, so a larger minor version alone is usually
119not a problem. 127not a problem.
120 128
121Example: make sure we haven't accidentally been linked against the wrong 129Example: Make sure we haven't accidentally been linked against the wrong
122version: 130version.
123 131
124 assert (("libev version mismatch", 132 assert (("libev version mismatch",
125 ev_version_major () == EV_VERSION_MAJOR 133 ev_version_major () == EV_VERSION_MAJOR
126 && ev_version_minor () >= EV_VERSION_MINOR)); 134 && ev_version_minor () >= EV_VERSION_MINOR));
127 135
167 175
168You could override this function in high-availability programs to, say, 176You could override this function in high-availability programs to, say,
169free some memory if it cannot allocate memory, to use a special allocator, 177free some memory if it cannot allocate memory, to use a special allocator,
170or even to sleep a while and retry until some memory is available. 178or even to sleep a while and retry until some memory is available.
171 179
172Example: replace the libev allocator with one that waits a bit and then 180Example: Replace the libev allocator with one that waits a bit and then
173retries: better than mine). 181retries).
174 182
175 static void * 183 static void *
176 persistent_realloc (void *ptr, size_t size) 184 persistent_realloc (void *ptr, size_t size)
177 { 185 {
178 for (;;) 186 for (;;)
197callback is set, then libev will expect it to remedy the sitution, no 205callback is set, then libev will expect it to remedy the sitution, no
198matter what, when it returns. That is, libev will generally retry the 206matter what, when it returns. That is, libev will generally retry the
199requested operation, or, if the condition doesn't go away, do bad stuff 207requested operation, or, if the condition doesn't go away, do bad stuff
200(such as abort). 208(such as abort).
201 209
202Example: do the same thing as libev does internally: 210Example: This is basically the same thing that libev does internally, too.
203 211
204 static void 212 static void
205 fatal_error (const char *msg) 213 fatal_error (const char *msg)
206 { 214 {
207 perror (msg); 215 perror (msg);
353Similar to C<ev_default_loop>, but always creates a new event loop that is 361Similar to C<ev_default_loop>, but always creates a new event loop that is
354always distinct from the default loop. Unlike the default loop, it cannot 362always distinct from the default loop. Unlike the default loop, it cannot
355handle signal and child watchers, and attempts to do so will be greeted by 363handle signal and child watchers, and attempts to do so will be greeted by
356undefined behaviour (or a failed assertion if assertions are enabled). 364undefined behaviour (or a failed assertion if assertions are enabled).
357 365
358Example: try to create a event loop that uses epoll and nothing else. 366Example: Try to create a event loop that uses epoll and nothing else.
359 367
360 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV); 368 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
361 if (!epoller) 369 if (!epoller)
362 fatal ("no epoll found here, maybe it hides under your chair"); 370 fatal ("no epoll found here, maybe it hides under your chair");
363 371
462 Signals and child watchers are implemented as I/O watchers, and will 470 Signals and child watchers are implemented as I/O watchers, and will
463 be handled here by queueing them when their watcher gets executed. 471 be handled here by queueing them when their watcher gets executed.
464 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK 472 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
465 were used, return, otherwise continue with step *. 473 were used, return, otherwise continue with step *.
466 474
467Example: queue some jobs and then loop until no events are outsanding 475Example: Queue some jobs and then loop until no events are outsanding
468anymore. 476anymore.
469 477
470 ... queue jobs here, make sure they register event watchers as long 478 ... queue jobs here, make sure they register event watchers as long
471 ... as they still have work to do (even an idle watcher will do..) 479 ... as they still have work to do (even an idle watcher will do..)
472 ev_loop (my_loop, 0); 480 ev_loop (my_loop, 0);
492visible to the libev user and should not keep C<ev_loop> from exiting if 500visible to the libev user and should not keep C<ev_loop> from exiting if
493no event watchers registered by it are active. It is also an excellent 501no event watchers registered by it are active. It is also an excellent
494way to do this for generic recurring timers or from within third-party 502way to do this for generic recurring timers or from within third-party
495libraries. Just remember to I<unref after start> and I<ref before stop>. 503libraries. Just remember to I<unref after start> and I<ref before stop>.
496 504
497Example: create a signal watcher, but keep it from keeping C<ev_loop> 505Example: Create a signal watcher, but keep it from keeping C<ev_loop>
498running when nothing else is active. 506running when nothing else is active.
499 507
500 struct dv_signal exitsig; 508 struct ev_signal exitsig;
501 ev_signal_init (&exitsig, sig_cb, SIGINT); 509 ev_signal_init (&exitsig, sig_cb, SIGINT);
502 ev_signal_start (myloop, &exitsig); 510 ev_signal_start (loop, &exitsig);
503 evf_unref (myloop); 511 evf_unref (loop);
504 512
505Example: for some weird reason, unregister the above signal handler again. 513Example: For some weird reason, unregister the above signal handler again.
506 514
507 ev_ref (myloop); 515 ev_ref (loop);
508 ev_signal_stop (myloop, &exitsig); 516 ev_signal_stop (loop, &exitsig);
509 517
510=back 518=back
511 519
512 520
513=head1 ANATOMY OF A WATCHER 521=head1 ANATOMY OF A WATCHER
696events but its callback has not yet been invoked). As long as a watcher 704events but its callback has not yet been invoked). As long as a watcher
697is pending (but not active) you must not call an init function on it (but 705is pending (but not active) you must not call an init function on it (but
698C<ev_TYPE_set> is safe) and you must make sure the watcher is available to 706C<ev_TYPE_set> is safe) and you must make sure the watcher is available to
699libev (e.g. you cnanot C<free ()> it). 707libev (e.g. you cnanot C<free ()> it).
700 708
701=item callback = ev_cb (ev_TYPE *watcher) 709=item callback ev_cb (ev_TYPE *watcher)
702 710
703Returns the callback currently set on the watcher. 711Returns the callback currently set on the watcher.
704 712
705=item ev_cb_set (ev_TYPE *watcher, callback) 713=item ev_cb_set (ev_TYPE *watcher, callback)
706 714
734 { 742 {
735 struct my_io *w = (struct my_io *)w_; 743 struct my_io *w = (struct my_io *)w_;
736 ... 744 ...
737 } 745 }
738 746
739More interesting and less C-conformant ways of catsing your callback type 747More interesting and less C-conformant ways of casting your callback type
740have been omitted.... 748instead have been omitted.
749
750Another common scenario is having some data structure with multiple
751watchers:
752
753 struct my_biggy
754 {
755 int some_data;
756 ev_timer t1;
757 ev_timer t2;
758 }
759
760In this case getting the pointer to C<my_biggy> is a bit more complicated,
761you need to use C<offsetof>:
762
763 #include <stddef.h>
764
765 static void
766 t1_cb (EV_P_ struct ev_timer *w, int revents)
767 {
768 struct my_biggy big = (struct my_biggy *
769 (((char *)w) - offsetof (struct my_biggy, t1));
770 }
771
772 static void
773 t2_cb (EV_P_ struct ev_timer *w, int revents)
774 {
775 struct my_biggy big = (struct my_biggy *
776 (((char *)w) - offsetof (struct my_biggy, t2));
777 }
741 778
742 779
743=head1 WATCHER TYPES 780=head1 WATCHER TYPES
744 781
745This section describes each watcher in detail, but will not repeat 782This section describes each watcher in detail, but will not repeat
814 851
815The events being watched. 852The events being watched.
816 853
817=back 854=back
818 855
819Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well 856Example: Call C<stdin_readable_cb> when STDIN_FILENO has become, well
820readable, but only once. Since it is likely line-buffered, you could 857readable, but only once. Since it is likely line-buffered, you could
821attempt to read a whole line in the callback: 858attempt to read a whole line in the callback.
822 859
823 static void 860 static void
824 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents) 861 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents)
825 { 862 {
826 ev_io_stop (loop, w); 863 ev_io_stop (loop, w);
916or C<ev_timer_again> is called and determines the next timeout (if any), 953or C<ev_timer_again> is called and determines the next timeout (if any),
917which is also when any modifications are taken into account. 954which is also when any modifications are taken into account.
918 955
919=back 956=back
920 957
921Example: create a timer that fires after 60 seconds. 958Example: Create a timer that fires after 60 seconds.
922 959
923 static void 960 static void
924 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 961 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
925 { 962 {
926 .. one minute over, w is actually stopped right here 963 .. one minute over, w is actually stopped right here
928 965
929 struct ev_timer mytimer; 966 struct ev_timer mytimer;
930 ev_timer_init (&mytimer, one_minute_cb, 60., 0.); 967 ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
931 ev_timer_start (loop, &mytimer); 968 ev_timer_start (loop, &mytimer);
932 969
933Example: create a timeout timer that times out after 10 seconds of 970Example: Create a timeout timer that times out after 10 seconds of
934inactivity. 971inactivity.
935 972
936 static void 973 static void
937 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 974 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
938 { 975 {
1063switched off. Can be changed any time, but changes only take effect when 1100switched off. Can be changed any time, but changes only take effect when
1064the periodic timer fires or C<ev_periodic_again> is being called. 1101the periodic timer fires or C<ev_periodic_again> is being called.
1065 1102
1066=back 1103=back
1067 1104
1068Example: call a callback every hour, or, more precisely, whenever the 1105Example: Call a callback every hour, or, more precisely, whenever the
1069system clock is divisible by 3600. The callback invocation times have 1106system clock is divisible by 3600. The callback invocation times have
1070potentially a lot of jittering, but good long-term stability. 1107potentially a lot of jittering, but good long-term stability.
1071 1108
1072 static void 1109 static void
1073 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents) 1110 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents)
1077 1114
1078 struct ev_periodic hourly_tick; 1115 struct ev_periodic hourly_tick;
1079 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0); 1116 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
1080 ev_periodic_start (loop, &hourly_tick); 1117 ev_periodic_start (loop, &hourly_tick);
1081 1118
1082Example: the same as above, but use a reschedule callback to do it: 1119Example: The same as above, but use a reschedule callback to do it:
1083 1120
1084 #include <math.h> 1121 #include <math.h>
1085 1122
1086 static ev_tstamp 1123 static ev_tstamp
1087 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now) 1124 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)
1089 return fmod (now, 3600.) + 3600.; 1126 return fmod (now, 3600.) + 3600.;
1090 } 1127 }
1091 1128
1092 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb); 1129 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
1093 1130
1094Example: call a callback every hour, starting now: 1131Example: Call a callback every hour, starting now:
1095 1132
1096 struct ev_periodic hourly_tick; 1133 struct ev_periodic hourly_tick;
1097 ev_periodic_init (&hourly_tick, clock_cb, 1134 ev_periodic_init (&hourly_tick, clock_cb,
1098 fmod (ev_now (loop), 3600.), 3600., 0); 1135 fmod (ev_now (loop), 3600.), 3600., 0);
1099 ev_periodic_start (loop, &hourly_tick); 1136 ev_periodic_start (loop, &hourly_tick);
1160The process exit/trace status caused by C<rpid> (see your systems 1197The process exit/trace status caused by C<rpid> (see your systems
1161C<waitpid> and C<sys/wait.h> documentation for details). 1198C<waitpid> and C<sys/wait.h> documentation for details).
1162 1199
1163=back 1200=back
1164 1201
1165Example: try to exit cleanly on SIGINT and SIGTERM. 1202Example: Try to exit cleanly on SIGINT and SIGTERM.
1166 1203
1167 static void 1204 static void
1168 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents) 1205 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1169 { 1206 {
1170 ev_unloop (loop, EVUNLOOP_ALL); 1207 ev_unloop (loop, EVUNLOOP_ALL);
1186not exist" is signified by the C<st_nlink> field being zero (which is 1223not exist" is signified by the C<st_nlink> field being zero (which is
1187otherwise always forced to be at least one) and all the other fields of 1224otherwise always forced to be at least one) and all the other fields of
1188the stat buffer having unspecified contents. 1225the stat buffer having unspecified contents.
1189 1226
1190Since there is no standard to do this, the portable implementation simply 1227Since there is no standard to do this, the portable implementation simply
1191calls C<stat (2)> regulalry on the path to see if it changed somehow. You 1228calls C<stat (2)> regularly on the path to see if it changed somehow. You
1192can specify a recommended polling interval for this case. If you specify 1229can specify a recommended polling interval for this case. If you specify
1193a polling interval of C<0> (highly recommended!) then a I<suitable, 1230a polling interval of C<0> (highly recommended!) then a I<suitable,
1194unspecified default> value will be used (which you can expect to be around 1231unspecified default> value will be used (which you can expect to be around
1195five seconds, although this might change dynamically). Libev will also 1232five seconds, although this might change dynamically). Libev will also
1196impose a minimum interval which is currently around C<0.1>, but thats 1233impose a minimum interval which is currently around C<0.1>, but thats
1198 1235
1199This watcher type is not meant for massive numbers of stat watchers, 1236This watcher type is not meant for massive numbers of stat watchers,
1200as even with OS-supported change notifications, this can be 1237as even with OS-supported change notifications, this can be
1201resource-intensive. 1238resource-intensive.
1202 1239
1203At the time of this writing, no specific OS backends are implemented, but 1240At the time of this writing, only the Linux inotify interface is
1204if demand increases, at least a kqueue and inotify backend will be added. 1241implemented (implementing kqueue support is left as an exercise for the
1242reader). Inotify will be used to give hints only and should not change the
1243semantics of C<ev_stat> watchers, which means that libev sometimes needs
1244to fall back to regular polling again even with inotify, but changes are
1245usually detected immediately, and if the file exists there will be no
1246polling.
1205 1247
1206=over 4 1248=over 4
1207 1249
1208=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval) 1250=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval)
1209 1251
1299kind. There is a C<ev_idle_set> macro, but using it is utterly pointless, 1341kind. There is a C<ev_idle_set> macro, but using it is utterly pointless,
1300believe me. 1342believe me.
1301 1343
1302=back 1344=back
1303 1345
1304Example: dynamically allocate an C<ev_idle>, start it, and in the 1346Example: Dynamically allocate an C<ev_idle> watcher, start it, and in the
1305callback, free it. Alos, use no error checking, as usual. 1347callback, free it. Also, use no error checking, as usual.
1306 1348
1307 static void 1349 static void
1308 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents) 1350 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1309 { 1351 {
1310 free (w); 1352 free (w);
1978 2020
1979=item EV_USE_DEVPOLL 2021=item EV_USE_DEVPOLL
1980 2022
1981reserved for future expansion, works like the USE symbols above. 2023reserved for future expansion, works like the USE symbols above.
1982 2024
2025=item EV_USE_INOTIFY
2026
2027If defined to be C<1>, libev will compile in support for the Linux inotify
2028interface to speed up C<ev_stat> watchers. Its actual availability will
2029be detected at runtime.
2030
1983=item EV_H 2031=item EV_H
1984 2032
1985The name of the F<ev.h> header file used to include it. The default if 2033The name of the F<ev.h> header file used to include it. The default if
1986undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This 2034undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This
1987can be used to virtually rename the F<ev.h> header file in case of conflicts. 2035can be used to virtually rename the F<ev.h> header file in case of conflicts.
2042=item EV_PID_HASHSIZE 2090=item EV_PID_HASHSIZE
2043 2091
2044C<ev_child> watchers use a small hash table to distribute workload by 2092C<ev_child> watchers use a small hash table to distribute workload by
2045pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 2093pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
2046than enough. If you need to manage thousands of children you might want to 2094than enough. If you need to manage thousands of children you might want to
2047increase this value. 2095increase this value (I<must> be a power of two).
2096
2097=item EV_INOTIFY_HASHSIZE
2098
2099C<ev_staz> watchers use a small hash table to distribute workload by
2100inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>),
2101usually more than enough. If you need to manage thousands of C<ev_stat>
2102watchers you might want to increase this value (I<must> be a power of
2103two).
2048 2104
2049=item EV_COMMON 2105=item EV_COMMON
2050 2106
2051By default, all watchers have a C<void *data> member. By redefining 2107By default, all watchers have a C<void *data> member. By redefining
2052this macro to a something else you can include more and other types of 2108this macro to a something else you can include more and other types of
2112 2168
2113=item Starting io/check/prepare/idle/signal/child watchers: O(1) 2169=item Starting io/check/prepare/idle/signal/child watchers: O(1)
2114 2170
2115=item Stopping check/prepare/idle watchers: O(1) 2171=item Stopping check/prepare/idle watchers: O(1)
2116 2172
2117=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % 16)) 2173=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE))
2118 2174
2119=item Finding the next timer per loop iteration: O(1) 2175=item Finding the next timer per loop iteration: O(1)
2120 2176
2121=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd) 2177=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
2122 2178

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines