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.60 by root, Wed Nov 28 18:29:30 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
155C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for 163C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
156recommended ones. 164recommended ones.
157 165
158See the description of C<ev_embed> watchers for more info. 166See the description of C<ev_embed> watchers for more info.
159 167
160=item ev_set_allocator (void *(*cb)(void *ptr, size_t size)) 168=item ev_set_allocator (void *(*cb)(void *ptr, long size))
161 169
162Sets the allocation function to use (the prototype and semantics are 170Sets the allocation function to use (the prototype is similar - the
163identical to the realloc C function). It is used to allocate and free 171semantics is identical - to the realloc C function). It is used to
164memory (no surprises here). If it returns zero when memory needs to be 172allocate and free memory (no surprises here). If it returns zero when
165allocated, the library might abort or take some potentially destructive 173memory needs to be allocated, the library might abort or take some
166action. The default is your system realloc function. 174potentially destructive action. The default is your system realloc
175function.
167 176
168You could override this function in high-availability programs to, say, 177You could override this function in high-availability programs to, say,
169free 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,
170or 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.
171 180
172Example: replace the libev allocator with one that waits a bit and then 181Example: Replace the libev allocator with one that waits a bit and then
173retries: better than mine). 182retries).
174 183
175 static void * 184 static void *
176 persistent_realloc (void *ptr, size_t size) 185 persistent_realloc (void *ptr, size_t size)
177 { 186 {
178 for (;;) 187 for (;;)
197callback is set, then libev will expect it to remedy the sitution, no 206callback is set, then libev will expect it to remedy the sitution, no
198matter what, when it returns. That is, libev will generally retry the 207matter what, when it returns. That is, libev will generally retry the
199requested operation, or, if the condition doesn't go away, do bad stuff 208requested operation, or, if the condition doesn't go away, do bad stuff
200(such as abort). 209(such as abort).
201 210
202Example: do the same thing as libev does internally: 211Example: This is basically the same thing that libev does internally, too.
203 212
204 static void 213 static void
205 fatal_error (const char *msg) 214 fatal_error (const char *msg)
206 { 215 {
207 perror (msg); 216 perror (msg);
353Similar to C<ev_default_loop>, but always creates a new event loop that is 362Similar 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 363always 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 364handle signal and child watchers, and attempts to do so will be greeted by
356undefined behaviour (or a failed assertion if assertions are enabled). 365undefined behaviour (or a failed assertion if assertions are enabled).
357 366
358Example: try to create a event loop that uses epoll and nothing else. 367Example: Try to create a event loop that uses epoll and nothing else.
359 368
360 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV); 369 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
361 if (!epoller) 370 if (!epoller)
362 fatal ("no epoll found here, maybe it hides under your chair"); 371 fatal ("no epoll found here, maybe it hides under your chair");
363 372
462 Signals and child watchers are implemented as I/O watchers, and will 471 Signals and child watchers are implemented as I/O watchers, and will
463 be handled here by queueing them when their watcher gets executed. 472 be handled here by queueing them when their watcher gets executed.
464 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK 473 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
465 were used, return, otherwise continue with step *. 474 were used, return, otherwise continue with step *.
466 475
467Example: queue some jobs and then loop until no events are outsanding 476Example: Queue some jobs and then loop until no events are outsanding
468anymore. 477anymore.
469 478
470 ... queue jobs here, make sure they register event watchers as long 479 ... 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..) 480 ... as they still have work to do (even an idle watcher will do..)
472 ev_loop (my_loop, 0); 481 ev_loop (my_loop, 0);
492visible to the libev user and should not keep C<ev_loop> from exiting if 501visible 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 502no 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 503way 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>. 504libraries. Just remember to I<unref after start> and I<ref before stop>.
496 505
497Example: create a signal watcher, but keep it from keeping C<ev_loop> 506Example: Create a signal watcher, but keep it from keeping C<ev_loop>
498running when nothing else is active. 507running when nothing else is active.
499 508
500 struct dv_signal exitsig; 509 struct ev_signal exitsig;
501 ev_signal_init (&exitsig, sig_cb, SIGINT); 510 ev_signal_init (&exitsig, sig_cb, SIGINT);
502 ev_signal_start (myloop, &exitsig); 511 ev_signal_start (loop, &exitsig);
503 evf_unref (myloop); 512 evf_unref (loop);
504 513
505Example: for some weird reason, unregister the above signal handler again. 514Example: For some weird reason, unregister the above signal handler again.
506 515
507 ev_ref (myloop); 516 ev_ref (loop);
508 ev_signal_stop (myloop, &exitsig); 517 ev_signal_stop (loop, &exitsig);
509 518
510=back 519=back
511 520
512 521
513=head1 ANATOMY OF A WATCHER 522=head1 ANATOMY OF A WATCHER
696events but its callback has not yet been invoked). As long as a watcher 705events 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 706is 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 707C<ev_TYPE_set> is safe) and you must make sure the watcher is available to
699libev (e.g. you cnanot C<free ()> it). 708libev (e.g. you cnanot C<free ()> it).
700 709
701=item callback = ev_cb (ev_TYPE *watcher) 710=item callback ev_cb (ev_TYPE *watcher)
702 711
703Returns the callback currently set on the watcher. 712Returns the callback currently set on the watcher.
704 713
705=item ev_cb_set (ev_TYPE *watcher, callback) 714=item ev_cb_set (ev_TYPE *watcher, callback)
706 715
734 { 743 {
735 struct my_io *w = (struct my_io *)w_; 744 struct my_io *w = (struct my_io *)w_;
736 ... 745 ...
737 } 746 }
738 747
739More interesting and less C-conformant ways of catsing your callback type 748More interesting and less C-conformant ways of casting your callback type
740have been omitted.... 749instead have been omitted.
750
751Another common scenario is having some data structure with multiple
752watchers:
753
754 struct my_biggy
755 {
756 int some_data;
757 ev_timer t1;
758 ev_timer t2;
759 }
760
761In this case getting the pointer to C<my_biggy> is a bit more complicated,
762you need to use C<offsetof>:
763
764 #include <stddef.h>
765
766 static void
767 t1_cb (EV_P_ struct ev_timer *w, int revents)
768 {
769 struct my_biggy big = (struct my_biggy *
770 (((char *)w) - offsetof (struct my_biggy, t1));
771 }
772
773 static void
774 t2_cb (EV_P_ struct ev_timer *w, int revents)
775 {
776 struct my_biggy big = (struct my_biggy *
777 (((char *)w) - offsetof (struct my_biggy, t2));
778 }
741 779
742 780
743=head1 WATCHER TYPES 781=head1 WATCHER TYPES
744 782
745This section describes each watcher in detail, but will not repeat 783This section describes each watcher in detail, but will not repeat
814 852
815The events being watched. 853The events being watched.
816 854
817=back 855=back
818 856
819Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well 857Example: Call C<stdin_readable_cb> when STDIN_FILENO has become, well
820readable, but only once. Since it is likely line-buffered, you could 858readable, but only once. Since it is likely line-buffered, you could
821attempt to read a whole line in the callback: 859attempt to read a whole line in the callback.
822 860
823 static void 861 static void
824 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents) 862 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents)
825 { 863 {
826 ev_io_stop (loop, w); 864 ev_io_stop (loop, w);
916or C<ev_timer_again> is called and determines the next timeout (if any), 954or C<ev_timer_again> is called and determines the next timeout (if any),
917which is also when any modifications are taken into account. 955which is also when any modifications are taken into account.
918 956
919=back 957=back
920 958
921Example: create a timer that fires after 60 seconds. 959Example: Create a timer that fires after 60 seconds.
922 960
923 static void 961 static void
924 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 962 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
925 { 963 {
926 .. one minute over, w is actually stopped right here 964 .. one minute over, w is actually stopped right here
928 966
929 struct ev_timer mytimer; 967 struct ev_timer mytimer;
930 ev_timer_init (&mytimer, one_minute_cb, 60., 0.); 968 ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
931 ev_timer_start (loop, &mytimer); 969 ev_timer_start (loop, &mytimer);
932 970
933Example: create a timeout timer that times out after 10 seconds of 971Example: Create a timeout timer that times out after 10 seconds of
934inactivity. 972inactivity.
935 973
936 static void 974 static void
937 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 975 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
938 { 976 {
1063switched off. Can be changed any time, but changes only take effect when 1101switched off. Can be changed any time, but changes only take effect when
1064the periodic timer fires or C<ev_periodic_again> is being called. 1102the periodic timer fires or C<ev_periodic_again> is being called.
1065 1103
1066=back 1104=back
1067 1105
1068Example: call a callback every hour, or, more precisely, whenever the 1106Example: Call a callback every hour, or, more precisely, whenever the
1069system clock is divisible by 3600. The callback invocation times have 1107system clock is divisible by 3600. The callback invocation times have
1070potentially a lot of jittering, but good long-term stability. 1108potentially a lot of jittering, but good long-term stability.
1071 1109
1072 static void 1110 static void
1073 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents) 1111 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents)
1077 1115
1078 struct ev_periodic hourly_tick; 1116 struct ev_periodic hourly_tick;
1079 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0); 1117 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
1080 ev_periodic_start (loop, &hourly_tick); 1118 ev_periodic_start (loop, &hourly_tick);
1081 1119
1082Example: the same as above, but use a reschedule callback to do it: 1120Example: The same as above, but use a reschedule callback to do it:
1083 1121
1084 #include <math.h> 1122 #include <math.h>
1085 1123
1086 static ev_tstamp 1124 static ev_tstamp
1087 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now) 1125 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)
1089 return fmod (now, 3600.) + 3600.; 1127 return fmod (now, 3600.) + 3600.;
1090 } 1128 }
1091 1129
1092 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb); 1130 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
1093 1131
1094Example: call a callback every hour, starting now: 1132Example: Call a callback every hour, starting now:
1095 1133
1096 struct ev_periodic hourly_tick; 1134 struct ev_periodic hourly_tick;
1097 ev_periodic_init (&hourly_tick, clock_cb, 1135 ev_periodic_init (&hourly_tick, clock_cb,
1098 fmod (ev_now (loop), 3600.), 3600., 0); 1136 fmod (ev_now (loop), 3600.), 3600., 0);
1099 ev_periodic_start (loop, &hourly_tick); 1137 ev_periodic_start (loop, &hourly_tick);
1160The process exit/trace status caused by C<rpid> (see your systems 1198The process exit/trace status caused by C<rpid> (see your systems
1161C<waitpid> and C<sys/wait.h> documentation for details). 1199C<waitpid> and C<sys/wait.h> documentation for details).
1162 1200
1163=back 1201=back
1164 1202
1165Example: try to exit cleanly on SIGINT and SIGTERM. 1203Example: Try to exit cleanly on SIGINT and SIGTERM.
1166 1204
1167 static void 1205 static void
1168 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents) 1206 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1169 { 1207 {
1170 ev_unloop (loop, EVUNLOOP_ALL); 1208 ev_unloop (loop, EVUNLOOP_ALL);
1185not exist" is a status change like any other. The condition "path does 1223not exist" is a status change like any other. The condition "path does
1186not exist" is signified by the C<st_nlink> field being zero (which is 1224not 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 1225otherwise always forced to be at least one) and all the other fields of
1188the stat buffer having unspecified contents. 1226the stat buffer having unspecified contents.
1189 1227
1228The path I<should> be absolute and I<must not> end in a slash. If it is
1229relative and your working directory changes, the behaviour is undefined.
1230
1190Since there is no standard to do this, the portable implementation simply 1231Since 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 1232calls 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 1233can specify a recommended polling interval for this case. If you specify
1193a polling interval of C<0> (highly recommended!) then a I<suitable, 1234a polling interval of C<0> (highly recommended!) then a I<suitable,
1194unspecified default> value will be used (which you can expect to be around 1235unspecified default> value will be used (which you can expect to be around
1195five seconds, although this might change dynamically). Libev will also 1236five seconds, although this might change dynamically). Libev will also
1196impose a minimum interval which is currently around C<0.1>, but thats 1237impose a minimum interval which is currently around C<0.1>, but thats
1198 1239
1199This watcher type is not meant for massive numbers of stat watchers, 1240This watcher type is not meant for massive numbers of stat watchers,
1200as even with OS-supported change notifications, this can be 1241as even with OS-supported change notifications, this can be
1201resource-intensive. 1242resource-intensive.
1202 1243
1203At the time of this writing, no specific OS backends are implemented, but 1244At the time of this writing, only the Linux inotify interface is
1204if demand increases, at least a kqueue and inotify backend will be added. 1245implemented (implementing kqueue support is left as an exercise for the
1246reader). Inotify will be used to give hints only and should not change the
1247semantics of C<ev_stat> watchers, which means that libev sometimes needs
1248to fall back to regular polling again even with inotify, but changes are
1249usually detected immediately, and if the file exists there will be no
1250polling.
1205 1251
1206=over 4 1252=over 4
1207 1253
1208=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval) 1254=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval)
1209 1255
1299kind. There is a C<ev_idle_set> macro, but using it is utterly pointless, 1345kind. There is a C<ev_idle_set> macro, but using it is utterly pointless,
1300believe me. 1346believe me.
1301 1347
1302=back 1348=back
1303 1349
1304Example: dynamically allocate an C<ev_idle>, start it, and in the 1350Example: Dynamically allocate an C<ev_idle> watcher, start it, and in the
1305callback, free it. Alos, use no error checking, as usual. 1351callback, free it. Also, use no error checking, as usual.
1306 1352
1307 static void 1353 static void
1308 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents) 1354 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1309 { 1355 {
1310 free (w); 1356 free (w);
1978 2024
1979=item EV_USE_DEVPOLL 2025=item EV_USE_DEVPOLL
1980 2026
1981reserved for future expansion, works like the USE symbols above. 2027reserved for future expansion, works like the USE symbols above.
1982 2028
2029=item EV_USE_INOTIFY
2030
2031If defined to be C<1>, libev will compile in support for the Linux inotify
2032interface to speed up C<ev_stat> watchers. Its actual availability will
2033be detected at runtime.
2034
1983=item EV_H 2035=item EV_H
1984 2036
1985The name of the F<ev.h> header file used to include it. The default if 2037The 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 2038undefined 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. 2039can be used to virtually rename the F<ev.h> header file in case of conflicts.
2042=item EV_PID_HASHSIZE 2094=item EV_PID_HASHSIZE
2043 2095
2044C<ev_child> watchers use a small hash table to distribute workload by 2096C<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 2097pid. 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 2098than enough. If you need to manage thousands of children you might want to
2047increase this value. 2099increase this value (I<must> be a power of two).
2100
2101=item EV_INOTIFY_HASHSIZE
2102
2103C<ev_staz> watchers use a small hash table to distribute workload by
2104inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>),
2105usually more than enough. If you need to manage thousands of C<ev_stat>
2106watchers you might want to increase this value (I<must> be a power of
2107two).
2048 2108
2049=item EV_COMMON 2109=item EV_COMMON
2050 2110
2051By default, all watchers have a C<void *data> member. By redefining 2111By 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 2112this macro to a something else you can include more and other types of
2112 2172
2113=item Starting io/check/prepare/idle/signal/child watchers: O(1) 2173=item Starting io/check/prepare/idle/signal/child watchers: O(1)
2114 2174
2115=item Stopping check/prepare/idle watchers: O(1) 2175=item Stopping check/prepare/idle watchers: O(1)
2116 2176
2117=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % 16)) 2177=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE))
2118 2178
2119=item Finding the next timer per loop iteration: O(1) 2179=item Finding the next timer per loop iteration: O(1)
2120 2180
2121=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd) 2181=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
2122 2182

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines