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

Comparing libev/ev.pod (file contents):
Revision 1.428 by root, Thu May 30 18:51:57 2013 UTC vs.
Revision 1.446 by root, Mon Mar 18 19:28:15 2019 UTC

1=encoding utf-8
2
1=head1 NAME 3=head1 NAME
2 4
3libev - a high performance full-featured event loop written in C 5libev - a high performance full-featured event loop written in C
4 6
5=head1 SYNOPSIS 7=head1 SYNOPSIS
263 265
264You could override this function in high-availability programs to, say, 266You could override this function in high-availability programs to, say,
265free some memory if it cannot allocate memory, to use a special allocator, 267free some memory if it cannot allocate memory, to use a special allocator,
266or even to sleep a while and retry until some memory is available. 268or even to sleep a while and retry until some memory is available.
267 269
270Example: The following is the C<realloc> function that libev itself uses
271which should work with C<realloc> and C<free> functions of all kinds and
272is probably a good basis for your own implementation.
273
274 static void *
275 ev_realloc_emul (void *ptr, long size) EV_NOEXCEPT
276 {
277 if (size)
278 return realloc (ptr, size);
279
280 free (ptr);
281 return 0;
282 }
283
268Example: Replace the libev allocator with one that waits a bit and then 284Example: Replace the libev allocator with one that waits a bit and then
269retries (example requires a standards-compliant C<realloc>). 285retries.
270 286
271 static void * 287 static void *
272 persistent_realloc (void *ptr, size_t size) 288 persistent_realloc (void *ptr, size_t size)
273 { 289 {
290 if (!size)
291 {
292 free (ptr);
293 return 0;
294 }
295
274 for (;;) 296 for (;;)
275 { 297 {
276 void *newptr = realloc (ptr, size); 298 void *newptr = realloc (ptr, size);
277 299
278 if (newptr) 300 if (newptr)
409make libev check for a fork in each iteration by enabling this flag. 431make libev check for a fork in each iteration by enabling this flag.
410 432
411This works by calling C<getpid ()> on every iteration of the loop, 433This works by calling C<getpid ()> on every iteration of the loop,
412and thus this might slow down your event loop if you do a lot of loop 434and thus this might slow down your event loop if you do a lot of loop
413iterations and little real work, but is usually not noticeable (on my 435iterations and little real work, but is usually not noticeable (on my
414GNU/Linux system for example, C<getpid> is actually a simple 5-insn sequence 436GNU/Linux system for example, C<getpid> is actually a simple 5-insn
415without a system call and thus I<very> fast, but my GNU/Linux system also has 437sequence without a system call and thus I<very> fast, but my GNU/Linux
416C<pthread_atfork> which is even faster). 438system also has C<pthread_atfork> which is even faster). (Update: glibc
439versions 2.25 apparently removed the C<getpid> optimisation again).
417 440
418The big advantage of this flag is that you can forget about fork (and 441The big advantage of this flag is that you can forget about fork (and
419forget about forgetting to tell libev about forking) when you use this 442forget about forgetting to tell libev about forking, although you still
420flag. 443have to ignore C<SIGPIPE>) when you use this flag.
421 444
422This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS> 445This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
423environment variable. 446environment variable.
424 447
425=item C<EVFLAG_NOINOTIFY> 448=item C<EVFLAG_NOINOTIFY>
680If you need dynamically allocated loops it is better to use C<ev_loop_new> 703If you need dynamically allocated loops it is better to use C<ev_loop_new>
681and C<ev_loop_destroy>. 704and C<ev_loop_destroy>.
682 705
683=item ev_loop_fork (loop) 706=item ev_loop_fork (loop)
684 707
685This function sets a flag that causes subsequent C<ev_run> iterations to 708This function sets a flag that causes subsequent C<ev_run> iterations
686reinitialise the kernel state for backends that have one. Despite the 709to reinitialise the kernel state for backends that have one. Despite
687name, you can call it anytime, but it makes most sense after forking, in 710the name, you can call it anytime you are allowed to start or stop
688the child process. You I<must> call it (or use C<EVFLAG_FORKCHECK>) in the 711watchers (except inside an C<ev_prepare> callback), but it makes most
712sense after forking, in the child process. You I<must> call it (or use
689child before resuming or calling C<ev_run>. 713C<EVFLAG_FORKCHECK>) in the child before resuming or calling C<ev_run>.
690 714
715In addition, if you want to reuse a loop (via this function or
716C<EVFLAG_FORKCHECK>), you I<also> have to ignore C<SIGPIPE>.
717
691Again, you I<have> to call it on I<any> loop that you want to re-use after 718Again, you I<have> to call it on I<any> loop that you want to re-use after
692a fork, I<even if you do not plan to use the loop in the parent>. This is 719a fork, I<even if you do not plan to use the loop in the parent>. This is
693because some kernel interfaces *cough* I<kqueue> *cough* do funny things 720because some kernel interfaces *cough* I<kqueue> *cough* do funny things
694during fork. 721during fork.
695 722
696On the other hand, you only need to call this function in the child 723On the other hand, you only need to call this function in the child
2026 2053
2027The relative timeouts are calculated relative to the C<ev_now ()> 2054The relative timeouts are calculated relative to the C<ev_now ()>
2028time. This is usually the right thing as this timestamp refers to the time 2055time. This is usually the right thing as this timestamp refers to the time
2029of the event triggering whatever timeout you are modifying/starting. If 2056of the event triggering whatever timeout you are modifying/starting. If
2030you suspect event processing to be delayed and you I<need> to base the 2057you suspect event processing to be delayed and you I<need> to base the
2031timeout on the current time, use something like this to adjust for this: 2058timeout on the current time, use something like the following to adjust
2059for it:
2032 2060
2033 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.); 2061 ev_timer_set (&timer, after + (ev_time () - ev_now ()), 0.);
2034 2062
2035If the event loop is suspended for a long time, you can also force an 2063If the event loop is suspended for a long time, you can also force an
2036update of the time returned by C<ev_now ()> by calling C<ev_now_update 2064update of the time returned by C<ev_now ()> by calling C<ev_now_update
2037()>. 2065()>, although that will push the event time of all outstanding events
2066further into the future.
2038 2067
2039=head3 The special problem of unsynchronised clocks 2068=head3 The special problem of unsynchronised clocks
2040 2069
2041Modern systems have a variety of clocks - libev itself uses the normal 2070Modern systems have a variety of clocks - libev itself uses the normal
2042"wall clock" clock and, if available, the monotonic clock (to avoid time 2071"wall clock" clock and, if available, the monotonic clock (to avoid time
2105 2134
2106=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 2135=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
2107 2136
2108=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat) 2137=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
2109 2138
2110Configure the timer to trigger after C<after> seconds. If C<repeat> 2139Configure the timer to trigger after C<after> seconds (fractional and
2111is C<0.>, then it will automatically be stopped once the timeout is 2140negative values are supported). If C<repeat> is C<0.>, then it will
2112reached. If it is positive, then the timer will automatically be 2141automatically be stopped once the timeout is reached. If it is positive,
2113configured to trigger again C<repeat> seconds later, again, and again, 2142then the timer will automatically be configured to trigger again C<repeat>
2114until stopped manually. 2143seconds later, again, and again, until stopped manually.
2115 2144
2116The timer itself will do a best-effort at avoiding drift, that is, if 2145The timer itself will do a best-effort at avoiding drift, that is, if
2117you configure a timer to trigger every 10 seconds, then it will normally 2146you configure a timer to trigger every 10 seconds, then it will normally
2118trigger at exactly 10 second intervals. If, however, your program cannot 2147trigger at exactly 10 second intervals. If, however, your program cannot
2119keep up with the timer (because it takes longer than those 10 seconds to 2148keep up with the timer (because it takes longer than those 10 seconds to
2201Periodic watchers are also timers of a kind, but they are very versatile 2230Periodic watchers are also timers of a kind, but they are very versatile
2202(and unfortunately a bit complex). 2231(and unfortunately a bit complex).
2203 2232
2204Unlike C<ev_timer>, periodic watchers are not based on real time (or 2233Unlike C<ev_timer>, periodic watchers are not based on real time (or
2205relative time, the physical time that passes) but on wall clock time 2234relative time, the physical time that passes) but on wall clock time
2206(absolute time, the thing you can read on your calender or clock). The 2235(absolute time, the thing you can read on your calendar or clock). The
2207difference is that wall clock time can run faster or slower than real 2236difference is that wall clock time can run faster or slower than real
2208time, and time jumps are not uncommon (e.g. when you adjust your 2237time, and time jumps are not uncommon (e.g. when you adjust your
2209wrist-watch). 2238wrist-watch).
2210 2239
2211You can tell a periodic watcher to trigger after some specific point 2240You can tell a periodic watcher to trigger after some specific point
2216C<ev_timer>, which would still trigger roughly 10 seconds after starting 2245C<ev_timer>, which would still trigger roughly 10 seconds after starting
2217it, as it uses a relative timeout). 2246it, as it uses a relative timeout).
2218 2247
2219C<ev_periodic> watchers can also be used to implement vastly more complex 2248C<ev_periodic> watchers can also be used to implement vastly more complex
2220timers, such as triggering an event on each "midnight, local time", or 2249timers, such as triggering an event on each "midnight, local time", or
2221other complicated rules. This cannot be done with C<ev_timer> watchers, as 2250other complicated rules. This cannot easily be done with C<ev_timer>
2222those cannot react to time jumps. 2251watchers, as those cannot react to time jumps.
2223 2252
2224As with timers, the callback is guaranteed to be invoked only when the 2253As with timers, the callback is guaranteed to be invoked only when the
2225point in time where it is supposed to trigger has passed. If multiple 2254point in time where it is supposed to trigger has passed. If multiple
2226timers become ready during the same loop iteration then the ones with 2255timers become ready during the same loop iteration then the ones with
2227earlier time-out values are invoked before ones with later time-out values 2256earlier time-out values are invoked before ones with later time-out values
2313 2342
2314NOTE: I<< This callback must always return a time that is higher than or 2343NOTE: I<< This callback must always return a time that is higher than or
2315equal to the passed C<now> value >>. 2344equal to the passed C<now> value >>.
2316 2345
2317This can be used to create very complex timers, such as a timer that 2346This can be used to create very complex timers, such as a timer that
2318triggers on "next midnight, local time". To do this, you would calculate the 2347triggers on "next midnight, local time". To do this, you would calculate
2319next midnight after C<now> and return the timestamp value for this. How 2348the next midnight after C<now> and return the timestamp value for
2320you do this is, again, up to you (but it is not trivial, which is the main 2349this. Here is a (completely untested, no error checking) example on how to
2321reason I omitted it as an example). 2350do this:
2351
2352 #include <time.h>
2353
2354 static ev_tstamp
2355 my_rescheduler (ev_periodic *w, ev_tstamp now)
2356 {
2357 time_t tnow = (time_t)now;
2358 struct tm tm;
2359 localtime_r (&tnow, &tm);
2360
2361 tm.tm_sec = tm.tm_min = tm.tm_hour = 0; // midnight current day
2362 ++tm.tm_mday; // midnight next day
2363
2364 return mktime (&tm);
2365 }
2366
2367Note: this code might run into trouble on days that have more then two
2368midnights (beginning and end).
2322 2369
2323=back 2370=back
2324 2371
2325=item ev_periodic_again (loop, ev_periodic *) 2372=item ev_periodic_again (loop, ev_periodic *)
2326 2373
2391 2438
2392 ev_periodic hourly_tick; 2439 ev_periodic hourly_tick;
2393 ev_periodic_init (&hourly_tick, clock_cb, 2440 ev_periodic_init (&hourly_tick, clock_cb,
2394 fmod (ev_now (loop), 3600.), 3600., 0); 2441 fmod (ev_now (loop), 3600.), 3600., 0);
2395 ev_periodic_start (loop, &hourly_tick); 2442 ev_periodic_start (loop, &hourly_tick);
2396 2443
2397 2444
2398=head2 C<ev_signal> - signal me when a signal gets signalled! 2445=head2 C<ev_signal> - signal me when a signal gets signalled!
2399 2446
2400Signal watchers will trigger an event when the process receives a specific 2447Signal watchers will trigger an event when the process receives a specific
2401signal one or more times. Even though signals are very asynchronous, libev 2448signal one or more times. Even though signals are very asynchronous, libev
2411only within the same loop, i.e. you can watch for C<SIGINT> in your 2458only within the same loop, i.e. you can watch for C<SIGINT> in your
2412default loop and for C<SIGIO> in another loop, but you cannot watch for 2459default loop and for C<SIGIO> in another loop, but you cannot watch for
2413C<SIGINT> in both the default loop and another loop at the same time. At 2460C<SIGINT> in both the default loop and another loop at the same time. At
2414the moment, C<SIGCHLD> is permanently tied to the default loop. 2461the moment, C<SIGCHLD> is permanently tied to the default loop.
2415 2462
2416When the first watcher gets started will libev actually register something 2463Only after the first watcher for a signal is started will libev actually
2417with the kernel (thus it coexists with your own signal handlers as long as 2464register something with the kernel. It thus coexists with your own signal
2418you don't register any with libev for the same signal). 2465handlers as long as you don't register any with libev for the same signal.
2419 2466
2420If possible and supported, libev will install its handlers with 2467If possible and supported, libev will install its handlers with
2421C<SA_RESTART> (or equivalent) behaviour enabled, so system calls should 2468C<SA_RESTART> (or equivalent) behaviour enabled, so system calls should
2422not be unduly interrupted. If you have a problem with system calls getting 2469not be unduly interrupted. If you have a problem with system calls getting
2423interrupted by signals you can block all signals in an C<ev_check> watcher 2470interrupted by signals you can block all signals in an C<ev_check> watcher
2905 2952
2906Prepare and check watchers are often (but not always) used in pairs: 2953Prepare and check watchers are often (but not always) used in pairs:
2907prepare watchers get invoked before the process blocks and check watchers 2954prepare watchers get invoked before the process blocks and check watchers
2908afterwards. 2955afterwards.
2909 2956
2910You I<must not> call C<ev_run> or similar functions that enter 2957You I<must not> call C<ev_run> (or similar functions that enter the
2911the current event loop from either C<ev_prepare> or C<ev_check> 2958current event loop) or C<ev_loop_fork> from either C<ev_prepare> or
2912watchers. Other loops than the current one are fine, however. The 2959C<ev_check> watchers. Other loops than the current one are fine,
2913rationale behind this is that you do not need to check for recursion in 2960however. The rationale behind this is that you do not need to check
2914those watchers, i.e. the sequence will always be C<ev_prepare>, blocking, 2961for recursion in those watchers, i.e. the sequence will always be
2915C<ev_check> so if you have one watcher of each kind they will always be 2962C<ev_prepare>, blocking, C<ev_check> so if you have one watcher of each
2916called in pairs bracketing the blocking call. 2963kind they will always be called in pairs bracketing the blocking call.
2917 2964
2918Their main purpose is to integrate other event mechanisms into libev and 2965Their main purpose is to integrate other event mechanisms into libev and
2919their use is somewhat advanced. They could be used, for example, to track 2966their use is somewhat advanced. They could be used, for example, to track
2920variable changes, implement your own watchers, integrate net-snmp or a 2967variable changes, implement your own watchers, integrate net-snmp or a
2921coroutine library and lots more. They are also occasionally useful if 2968coroutine library and lots more. They are also occasionally useful if
3211used). 3258used).
3212 3259
3213 struct ev_loop *loop_hi = ev_default_init (0); 3260 struct ev_loop *loop_hi = ev_default_init (0);
3214 struct ev_loop *loop_lo = 0; 3261 struct ev_loop *loop_lo = 0;
3215 ev_embed embed; 3262 ev_embed embed;
3216 3263
3217 // see if there is a chance of getting one that works 3264 // see if there is a chance of getting one that works
3218 // (remember that a flags value of 0 means autodetection) 3265 // (remember that a flags value of 0 means autodetection)
3219 loop_lo = ev_embeddable_backends () & ev_recommended_backends () 3266 loop_lo = ev_embeddable_backends () & ev_recommended_backends ()
3220 ? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ()) 3267 ? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ())
3221 : 0; 3268 : 0;
3235C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too). 3282C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too).
3236 3283
3237 struct ev_loop *loop = ev_default_init (0); 3284 struct ev_loop *loop = ev_default_init (0);
3238 struct ev_loop *loop_socket = 0; 3285 struct ev_loop *loop_socket = 0;
3239 ev_embed embed; 3286 ev_embed embed;
3240 3287
3241 if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE) 3288 if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE)
3242 if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE)) 3289 if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE))
3243 { 3290 {
3244 ev_embed_init (&embed, 0, loop_socket); 3291 ev_embed_init (&embed, 0, loop_socket);
3245 ev_embed_start (loop, &embed); 3292 ev_embed_start (loop, &embed);
3261and calls it in the wrong process, the fork handlers will be invoked, too, 3308and calls it in the wrong process, the fork handlers will be invoked, too,
3262of course. 3309of course.
3263 3310
3264=head3 The special problem of life after fork - how is it possible? 3311=head3 The special problem of life after fork - how is it possible?
3265 3312
3266Most uses of C<fork()> consist of forking, then some simple calls to set 3313Most uses of C<fork ()> consist of forking, then some simple calls to set
3267up/change the process environment, followed by a call to C<exec()>. This 3314up/change the process environment, followed by a call to C<exec()>. This
3268sequence should be handled by libev without any problems. 3315sequence should be handled by libev without any problems.
3269 3316
3270This changes when the application actually wants to do event handling 3317This changes when the application actually wants to do event handling
3271in the child, or both parent in child, in effect "continuing" after the 3318in the child, or both parent in child, in effect "continuing" after the
3509 3556
3510There are some other functions of possible interest. Described. Here. Now. 3557There are some other functions of possible interest. Described. Here. Now.
3511 3558
3512=over 4 3559=over 4
3513 3560
3514=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback) 3561=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback, arg)
3515 3562
3516This function combines a simple timer and an I/O watcher, calls your 3563This function combines a simple timer and an I/O watcher, calls your
3517callback on whichever event happens first and automatically stops both 3564callback on whichever event happens first and automatically stops both
3518watchers. This is useful if you want to wait for a single event on an fd 3565watchers. This is useful if you want to wait for a single event on an fd
3519or timeout without having to allocate/configure/start/stop/free one or 3566or timeout without having to allocate/configure/start/stop/free one or
3895To embed libev, see L</EMBEDDING>, but in short, it's easiest to create two 3942To embed libev, see L</EMBEDDING>, but in short, it's easiest to create two
3896files, F<my_ev.h> and F<my_ev.c> that include the respective libev files: 3943files, F<my_ev.h> and F<my_ev.c> that include the respective libev files:
3897 3944
3898 // my_ev.h 3945 // my_ev.h
3899 #define EV_CB_DECLARE(type) struct my_coro *cb; 3946 #define EV_CB_DECLARE(type) struct my_coro *cb;
3900 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb); 3947 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb)
3901 #include "../libev/ev.h" 3948 #include "../libev/ev.h"
3902 3949
3903 // my_ev.c 3950 // my_ev.c
3904 #define EV_H "my_ev.h" 3951 #define EV_H "my_ev.h"
3905 #include "../libev/ev.c" 3952 #include "../libev/ev.c"
3951The normal C API should work fine when used from C++: both ev.h and the 3998The normal C API should work fine when used from C++: both ev.h and the
3952libev sources can be compiled as C++. Therefore, code that uses the C API 3999libev sources can be compiled as C++. Therefore, code that uses the C API
3953will work fine. 4000will work fine.
3954 4001
3955Proper exception specifications might have to be added to callbacks passed 4002Proper exception specifications might have to be added to callbacks passed
3956to libev: exceptions may be thrown only from watcher callbacks, all 4003to libev: exceptions may be thrown only from watcher callbacks, all other
3957other callbacks (allocator, syserr, loop acquire/release and periodic 4004callbacks (allocator, syserr, loop acquire/release and periodic reschedule
3958reschedule callbacks) must not throw exceptions, and might need a C<throw 4005callbacks) must not throw exceptions, and might need a C<noexcept>
3959()> specification. If you have code that needs to be compiled as both C 4006specification. If you have code that needs to be compiled as both C and
3960and C++ you can use the C<EV_THROW> macro for this: 4007C++ you can use the C<EV_NOEXCEPT> macro for this:
3961 4008
3962 static void 4009 static void
3963 fatal_error (const char *msg) EV_THROW 4010 fatal_error (const char *msg) EV_NOEXCEPT
3964 { 4011 {
3965 perror (msg); 4012 perror (msg);
3966 abort (); 4013 abort ();
3967 } 4014 }
3968 4015
4095 void operator() (ev::io &w, int revents) 4142 void operator() (ev::io &w, int revents)
4096 { 4143 {
4097 ... 4144 ...
4098 } 4145 }
4099 } 4146 }
4100 4147
4101 myfunctor f; 4148 myfunctor f;
4102 4149
4103 ev::io w; 4150 ev::io w;
4104 w.set (&f); 4151 w.set (&f);
4105 4152
4378 ev_vars.h 4425 ev_vars.h
4379 ev_wrap.h 4426 ev_wrap.h
4380 4427
4381 ev_win32.c required on win32 platforms only 4428 ev_win32.c required on win32 platforms only
4382 4429
4383 ev_select.c only when select backend is enabled (which is enabled by default) 4430 ev_select.c only when select backend is enabled
4384 ev_poll.c only when poll backend is enabled (disabled by default) 4431 ev_poll.c only when poll backend is enabled
4385 ev_epoll.c only when the epoll backend is enabled (disabled by default) 4432 ev_epoll.c only when the epoll backend is enabled
4386 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 4433 ev_kqueue.c only when the kqueue backend is enabled
4387 ev_port.c only when the solaris port backend is enabled (disabled by default) 4434 ev_port.c only when the solaris port backend is enabled
4388 4435
4389F<ev.c> includes the backend files directly when enabled, so you only need 4436F<ev.c> includes the backend files directly when enabled, so you only need
4390to compile this single file. 4437to compile this single file.
4391 4438
4392=head3 LIBEVENT COMPATIBILITY API 4439=head3 LIBEVENT COMPATIBILITY API
5292structure (guaranteed by POSIX but not by ISO C for example), but it also 5339structure (guaranteed by POSIX but not by ISO C for example), but it also
5293assumes that the same (machine) code can be used to call any watcher 5340assumes that the same (machine) code can be used to call any watcher
5294callback: The watcher callbacks have different type signatures, but libev 5341callback: The watcher callbacks have different type signatures, but libev
5295calls them using an C<ev_watcher *> internally. 5342calls them using an C<ev_watcher *> internally.
5296 5343
5344=item null pointers and integer zero are represented by 0 bytes
5345
5346Libev uses C<memset> to initialise structs and arrays to C<0> bytes, and
5347relies on this setting pointers and integers to null.
5348
5297=item pointer accesses must be thread-atomic 5349=item pointer accesses must be thread-atomic
5298 5350
5299Accessing a pointer value must be atomic, it must both be readable and 5351Accessing a pointer value must be atomic, it must both be readable and
5300writable in one piece - this is the case on all current architectures. 5352writable in one piece - this is the case on all current architectures.
5301 5353

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines