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

Comparing libev/ev.3 (file contents):
Revision 1.27 by root, Tue Nov 27 20:15:01 2007 UTC vs.
Revision 1.28 by root, Tue Nov 27 20:26:50 2007 UTC

132.TH "<STANDARD INPUT>" 1 "2007-11-27" "perl v5.8.8" "User Contributed Perl Documentation" 132.TH "<STANDARD INPUT>" 1 "2007-11-27" "perl v5.8.8" "User Contributed Perl Documentation"
133.SH "NAME" 133.SH "NAME"
134libev \- a high performance full\-featured event loop written in C 134libev \- a high performance full\-featured event loop written in C
135.SH "SYNOPSIS" 135.SH "SYNOPSIS"
136.IX Header "SYNOPSIS" 136.IX Header "SYNOPSIS"
137.Vb 1
138\& #include <ev.h>
139.Ve
140.SH "EXAMPLE PROGRAM"
141.IX Header "EXAMPLE PROGRAM"
142.Vb 1
143\& #include <ev.h>
144.Ve
145.PP
137.Vb 2 146.Vb 2
138\& /* this is the only header you need */
139\& #include <ev.h>
140.Ve
141.PP
142.Vb 3
143\& /* what follows is a fully working example program */
144\& ev_io stdin_watcher; 147\& ev_io stdin_watcher;
145\& ev_timer timeout_watcher; 148\& ev_timer timeout_watcher;
146.Ve 149.Ve
147.PP 150.PP
148.Vb 8 151.Vb 8
207watchers\fR, which are relatively small C structures you initialise with the 210watchers\fR, which are relatively small C structures you initialise with the
208details of the event, and then hand it over to libev by \fIstarting\fR the 211details of the event, and then hand it over to libev by \fIstarting\fR the
209watcher. 212watcher.
210.SH "FEATURES" 213.SH "FEATURES"
211.IX Header "FEATURES" 214.IX Header "FEATURES"
212Libev supports select, poll, the linux-specific epoll and the bsd-specific 215Libev supports \f(CW\*(C`select\*(C'\fR, \f(CW\*(C`poll\*(C'\fR, the linux-specific \f(CW\*(C`epoll\*(C'\fR, the
213kqueue mechanisms for file descriptor events, relative timers, absolute 216bsd-specific \f(CW\*(C`kqueue\*(C'\fR and the solaris-specific event port mechanisms
214timers with customised rescheduling, signal events, process status change 217for file descriptor events (\f(CW\*(C`ev_io\*(C'\fR), relative timers (\f(CW\*(C`ev_timer\*(C'\fR),
215events (related to \s-1SIGCHLD\s0), and event watchers dealing with the event 218absolute timers with customised rescheduling (\f(CW\*(C`ev_periodic\*(C'\fR), synchronous
216loop mechanism itself (idle, prepare and check watchers). It also is quite 219signals (\f(CW\*(C`ev_signal\*(C'\fR), process status change events (\f(CW\*(C`ev_child\*(C'\fR), and
217fast (see this benchmark comparing 220event watchers dealing with the event loop mechanism itself (\f(CW\*(C`ev_idle\*(C'\fR,
218it to libevent for example). 221\&\f(CW\*(C`ev_embed\*(C'\fR, \f(CW\*(C`ev_prepare\*(C'\fR and \f(CW\*(C`ev_check\*(C'\fR watchers) as well as
222file watchers (\f(CW\*(C`ev_stat\*(C'\fR) and even limited support for fork events
223(\f(CW\*(C`ev_fork\*(C'\fR).
224.PP
225It also is quite fast (see this
226benchmark comparing it to libevent
227for example).
219.SH "CONVENTIONS" 228.SH "CONVENTIONS"
220.IX Header "CONVENTIONS" 229.IX Header "CONVENTIONS"
221Libev is very configurable. In this manual the default configuration 230Libev is very configurable. In this manual the default configuration will
222will be described, which supports multiple event loops. For more info 231be described, which supports multiple event loops. For more info about
223about various configuration options please have a look at the file 232various configuration options please have a look at \fB\s-1EMBED\s0\fR section in
224\&\fI\s-1README\s0.embed\fR in the libev distribution. If libev was configured without 233this manual. If libev was configured without support for multiple event
225support for multiple event loops, then all functions taking an initial 234loops, then all functions taking an initial argument of name \f(CW\*(C`loop\*(C'\fR
226argument of name \f(CW\*(C`loop\*(C'\fR (which is always of type \f(CW\*(C`struct ev_loop *\*(C'\fR) 235(which is always of type \f(CW\*(C`struct ev_loop *\*(C'\fR) will not have this argument.
227will not have this argument.
228.SH "TIME REPRESENTATION" 236.SH "TIME REPRESENTATION"
229.IX Header "TIME REPRESENTATION" 237.IX Header "TIME REPRESENTATION"
230Libev represents time as a single floating point number, representing the 238Libev represents time as a single floating point number, representing the
231(fractional) number of seconds since the (\s-1POSIX\s0) epoch (somewhere near 239(fractional) number of seconds since the (\s-1POSIX\s0) epoch (somewhere near
232the beginning of 1970, details are complicated, don't ask). This type is 240the beginning of 1970, details are complicated, don't ask). This type is
257Usually, it's a good idea to terminate if the major versions mismatch, 265Usually, it's a good idea to terminate if the major versions mismatch,
258as this indicates an incompatible change. Minor versions are usually 266as this indicates an incompatible change. Minor versions are usually
259compatible to older versions, so a larger minor version alone is usually 267compatible to older versions, so a larger minor version alone is usually
260not a problem. 268not a problem.
261.Sp 269.Sp
262Example: make sure we haven't accidentally been linked against the wrong 270Example: Make sure we haven't accidentally been linked against the wrong
263version: 271version.
264.Sp 272.Sp
265.Vb 3 273.Vb 3
266\& assert (("libev version mismatch", 274\& assert (("libev version mismatch",
267\& ev_version_major () == EV_VERSION_MAJOR 275\& ev_version_major () == EV_VERSION_MAJOR
268\& && ev_version_minor () >= EV_VERSION_MINOR)); 276\& && ev_version_minor () >= EV_VERSION_MINOR));
308.Sp 316.Sp
309You could override this function in high-availability programs to, say, 317You could override this function in high-availability programs to, say,
310free some memory if it cannot allocate memory, to use a special allocator, 318free some memory if it cannot allocate memory, to use a special allocator,
311or even to sleep a while and retry until some memory is available. 319or even to sleep a while and retry until some memory is available.
312.Sp 320.Sp
313Example: replace the libev allocator with one that waits a bit and then 321Example: Replace the libev allocator with one that waits a bit and then
314retries: better than mine). 322retries).
315.Sp 323.Sp
316.Vb 6 324.Vb 6
317\& static void * 325\& static void *
318\& persistent_realloc (void *ptr, size_t size) 326\& persistent_realloc (void *ptr, size_t size)
319\& { 327\& {
345callback is set, then libev will expect it to remedy the sitution, no 353callback is set, then libev will expect it to remedy the sitution, no
346matter what, when it returns. That is, libev will generally retry the 354matter what, when it returns. That is, libev will generally retry the
347requested operation, or, if the condition doesn't go away, do bad stuff 355requested operation, or, if the condition doesn't go away, do bad stuff
348(such as abort). 356(such as abort).
349.Sp 357.Sp
350Example: do the same thing as libev does internally: 358Example: This is basically the same thing that libev does internally, too.
351.Sp 359.Sp
352.Vb 6 360.Vb 6
353\& static void 361\& static void
354\& fatal_error (const char *msg) 362\& fatal_error (const char *msg)
355\& { 363\& {
504Similar to \f(CW\*(C`ev_default_loop\*(C'\fR, but always creates a new event loop that is 512Similar to \f(CW\*(C`ev_default_loop\*(C'\fR, but always creates a new event loop that is
505always distinct from the default loop. Unlike the default loop, it cannot 513always distinct from the default loop. Unlike the default loop, it cannot
506handle signal and child watchers, and attempts to do so will be greeted by 514handle signal and child watchers, and attempts to do so will be greeted by
507undefined behaviour (or a failed assertion if assertions are enabled). 515undefined behaviour (or a failed assertion if assertions are enabled).
508.Sp 516.Sp
509Example: try to create a event loop that uses epoll and nothing else. 517Example: Try to create a event loop that uses epoll and nothing else.
510.Sp 518.Sp
511.Vb 3 519.Vb 3
512\& struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV); 520\& struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
513\& if (!epoller) 521\& if (!epoller)
514\& fatal ("no epoll found here, maybe it hides under your chair"); 522\& fatal ("no epoll found here, maybe it hides under your chair");
612\& be handled here by queueing them when their watcher gets executed. 620\& be handled here by queueing them when their watcher gets executed.
613\& - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK 621\& - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
614\& were used, return, otherwise continue with step *. 622\& were used, return, otherwise continue with step *.
615.Ve 623.Ve
616.Sp 624.Sp
617Example: queue some jobs and then loop until no events are outsanding 625Example: Queue some jobs and then loop until no events are outsanding
618anymore. 626anymore.
619.Sp 627.Sp
620.Vb 4 628.Vb 4
621\& ... queue jobs here, make sure they register event watchers as long 629\& ... queue jobs here, make sure they register event watchers as long
622\& ... as they still have work to do (even an idle watcher will do..) 630\& ... as they still have work to do (even an idle watcher will do..)
644visible to the libev user and should not keep \f(CW\*(C`ev_loop\*(C'\fR from exiting if 652visible to the libev user and should not keep \f(CW\*(C`ev_loop\*(C'\fR from exiting if
645no event watchers registered by it are active. It is also an excellent 653no event watchers registered by it are active. It is also an excellent
646way to do this for generic recurring timers or from within third-party 654way to do this for generic recurring timers or from within third-party
647libraries. Just remember to \fIunref after start\fR and \fIref before stop\fR. 655libraries. Just remember to \fIunref after start\fR and \fIref before stop\fR.
648.Sp 656.Sp
649Example: create a signal watcher, but keep it from keeping \f(CW\*(C`ev_loop\*(C'\fR 657Example: Create a signal watcher, but keep it from keeping \f(CW\*(C`ev_loop\*(C'\fR
650running when nothing else is active. 658running when nothing else is active.
651.Sp 659.Sp
652.Vb 4 660.Vb 4
653\& struct dv_signal exitsig; 661\& struct ev_signal exitsig;
654\& ev_signal_init (&exitsig, sig_cb, SIGINT); 662\& ev_signal_init (&exitsig, sig_cb, SIGINT);
655\& ev_signal_start (myloop, &exitsig); 663\& ev_signal_start (loop, &exitsig);
656\& evf_unref (myloop); 664\& evf_unref (loop);
657.Ve 665.Ve
658.Sp 666.Sp
659Example: for some weird reason, unregister the above signal handler again. 667Example: For some weird reason, unregister the above signal handler again.
660.Sp 668.Sp
661.Vb 2 669.Vb 2
662\& ev_ref (myloop); 670\& ev_ref (loop);
663\& ev_signal_stop (myloop, &exitsig); 671\& ev_signal_stop (loop, &exitsig);
664.Ve 672.Ve
665.SH "ANATOMY OF A WATCHER" 673.SH "ANATOMY OF A WATCHER"
666.IX Header "ANATOMY OF A WATCHER" 674.IX Header "ANATOMY OF A WATCHER"
667A watcher is a structure that you create and register to record your 675A watcher is a structure that you create and register to record your
668interest in some event. For instance, if you want to wait for \s-1STDIN\s0 to 676interest in some event. For instance, if you want to wait for \s-1STDIN\s0 to
957The file descriptor being watched. 965The file descriptor being watched.
958.IP "int events [read\-only]" 4 966.IP "int events [read\-only]" 4
959.IX Item "int events [read-only]" 967.IX Item "int events [read-only]"
960The events being watched. 968The events being watched.
961.PP 969.PP
962Example: call \f(CW\*(C`stdin_readable_cb\*(C'\fR when \s-1STDIN_FILENO\s0 has become, well 970Example: Call \f(CW\*(C`stdin_readable_cb\*(C'\fR when \s-1STDIN_FILENO\s0 has become, well
963readable, but only once. Since it is likely line\-buffered, you could 971readable, but only once. Since it is likely line\-buffered, you could
964attempt to read a whole line in the callback: 972attempt to read a whole line in the callback.
965.PP 973.PP
966.Vb 6 974.Vb 6
967\& static void 975\& static void
968\& stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents) 976\& stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents)
969\& { 977\& {
1061.IX Item "ev_tstamp repeat [read-write]" 1069.IX Item "ev_tstamp repeat [read-write]"
1062The current \f(CW\*(C`repeat\*(C'\fR value. Will be used each time the watcher times out 1070The current \f(CW\*(C`repeat\*(C'\fR value. Will be used each time the watcher times out
1063or \f(CW\*(C`ev_timer_again\*(C'\fR is called and determines the next timeout (if any), 1071or \f(CW\*(C`ev_timer_again\*(C'\fR is called and determines the next timeout (if any),
1064which is also when any modifications are taken into account. 1072which is also when any modifications are taken into account.
1065.PP 1073.PP
1066Example: create a timer that fires after 60 seconds. 1074Example: Create a timer that fires after 60 seconds.
1067.PP 1075.PP
1068.Vb 5 1076.Vb 5
1069\& static void 1077\& static void
1070\& one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 1078\& one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
1071\& { 1079\& {
1077\& struct ev_timer mytimer; 1085\& struct ev_timer mytimer;
1078\& ev_timer_init (&mytimer, one_minute_cb, 60., 0.); 1086\& ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
1079\& ev_timer_start (loop, &mytimer); 1087\& ev_timer_start (loop, &mytimer);
1080.Ve 1088.Ve
1081.PP 1089.PP
1082Example: create a timeout timer that times out after 10 seconds of 1090Example: Create a timeout timer that times out after 10 seconds of
1083inactivity. 1091inactivity.
1084.PP 1092.PP
1085.Vb 5 1093.Vb 5
1086\& static void 1094\& static void
1087\& timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 1095\& timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
1212.IX Item "ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) [read-write]" 1220.IX Item "ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) [read-write]"
1213The current reschedule callback, or \f(CW0\fR, if this functionality is 1221The current reschedule callback, or \f(CW0\fR, if this functionality is
1214switched off. Can be changed any time, but changes only take effect when 1222switched off. Can be changed any time, but changes only take effect when
1215the periodic timer fires or \f(CW\*(C`ev_periodic_again\*(C'\fR is being called. 1223the periodic timer fires or \f(CW\*(C`ev_periodic_again\*(C'\fR is being called.
1216.PP 1224.PP
1217Example: call a callback every hour, or, more precisely, whenever the 1225Example: Call a callback every hour, or, more precisely, whenever the
1218system clock is divisible by 3600. The callback invocation times have 1226system clock is divisible by 3600. The callback invocation times have
1219potentially a lot of jittering, but good long-term stability. 1227potentially a lot of jittering, but good long-term stability.
1220.PP 1228.PP
1221.Vb 5 1229.Vb 5
1222\& static void 1230\& static void
1230\& struct ev_periodic hourly_tick; 1238\& struct ev_periodic hourly_tick;
1231\& ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0); 1239\& ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
1232\& ev_periodic_start (loop, &hourly_tick); 1240\& ev_periodic_start (loop, &hourly_tick);
1233.Ve 1241.Ve
1234.PP 1242.PP
1235Example: the same as above, but use a reschedule callback to do it: 1243Example: The same as above, but use a reschedule callback to do it:
1236.PP 1244.PP
1237.Vb 1 1245.Vb 1
1238\& #include <math.h> 1246\& #include <math.h>
1239.Ve 1247.Ve
1240.PP 1248.PP
1248.PP 1256.PP
1249.Vb 1 1257.Vb 1
1250\& ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb); 1258\& ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
1251.Ve 1259.Ve
1252.PP 1260.PP
1253Example: call a callback every hour, starting now: 1261Example: Call a callback every hour, starting now:
1254.PP 1262.PP
1255.Vb 4 1263.Vb 4
1256\& struct ev_periodic hourly_tick; 1264\& struct ev_periodic hourly_tick;
1257\& ev_periodic_init (&hourly_tick, clock_cb, 1265\& ev_periodic_init (&hourly_tick, clock_cb,
1258\& fmod (ev_now (loop), 3600.), 3600., 0); 1266\& fmod (ev_now (loop), 3600.), 3600., 0);
1309.IP "int rstatus [read\-write]" 4 1317.IP "int rstatus [read\-write]" 4
1310.IX Item "int rstatus [read-write]" 1318.IX Item "int rstatus [read-write]"
1311The process exit/trace status caused by \f(CW\*(C`rpid\*(C'\fR (see your systems 1319The process exit/trace status caused by \f(CW\*(C`rpid\*(C'\fR (see your systems
1312\&\f(CW\*(C`waitpid\*(C'\fR and \f(CW\*(C`sys/wait.h\*(C'\fR documentation for details). 1320\&\f(CW\*(C`waitpid\*(C'\fR and \f(CW\*(C`sys/wait.h\*(C'\fR documentation for details).
1313.PP 1321.PP
1314Example: try to exit cleanly on \s-1SIGINT\s0 and \s-1SIGTERM\s0. 1322Example: Try to exit cleanly on \s-1SIGINT\s0 and \s-1SIGTERM\s0.
1315.PP 1323.PP
1316.Vb 5 1324.Vb 5
1317\& static void 1325\& static void
1318\& sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents) 1326\& sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1319\& { 1327\& {
1443.IX Item "ev_idle_init (ev_signal *, callback)" 1451.IX Item "ev_idle_init (ev_signal *, callback)"
1444Initialises and configures the idle watcher \- it has no parameters of any 1452Initialises and configures the idle watcher \- it has no parameters of any
1445kind. There is a \f(CW\*(C`ev_idle_set\*(C'\fR macro, but using it is utterly pointless, 1453kind. There is a \f(CW\*(C`ev_idle_set\*(C'\fR macro, but using it is utterly pointless,
1446believe me. 1454believe me.
1447.PP 1455.PP
1448Example: dynamically allocate an \f(CW\*(C`ev_idle\*(C'\fR, start it, and in the 1456Example: Dynamically allocate an \f(CW\*(C`ev_idle\*(C'\fR watcher, start it, and in the
1449callback, free it. Alos, use no error checking, as usual. 1457callback, free it. Also, use no error checking, as usual.
1450.PP 1458.PP
1451.Vb 7 1459.Vb 7
1452\& static void 1460\& static void
1453\& idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents) 1461\& idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1454\& { 1462\& {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines