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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines