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

Comparing libev/ev.pod (file contents):
Revision 1.431 by root, Fri Nov 22 16:42:10 2013 UTC vs.
Revision 1.443 by root, Thu Aug 30 21:51:15 2018 UTC

411make libev check for a fork in each iteration by enabling this flag. 411make libev check for a fork in each iteration by enabling this flag.
412 412
413This works by calling C<getpid ()> on every iteration of the loop, 413This works by calling C<getpid ()> on every iteration of the loop,
414and thus this might slow down your event loop if you do a lot of loop 414and thus this might slow down your event loop if you do a lot of loop
415iterations and little real work, but is usually not noticeable (on my 415iterations and little real work, but is usually not noticeable (on my
416GNU/Linux system for example, C<getpid> is actually a simple 5-insn sequence 416GNU/Linux system for example, C<getpid> is actually a simple 5-insn
417without a system call and thus I<very> fast, but my GNU/Linux system also has 417sequence without a system call and thus I<very> fast, but my GNU/Linux
418C<pthread_atfork> which is even faster). 418system also has C<pthread_atfork> which is even faster). (Update: glibc
419versions 2.25 apparently removed the C<getpid> optimisation again).
419 420
420The big advantage of this flag is that you can forget about fork (and 421The big advantage of this flag is that you can forget about fork (and
421forget about forgetting to tell libev about forking) when you use this 422forget about forgetting to tell libev about forking, although you still
422flag. 423have to ignore C<SIGPIPE>) when you use this flag.
423 424
424This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS> 425This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
425environment variable. 426environment variable.
426 427
427=item C<EVFLAG_NOINOTIFY> 428=item C<EVFLAG_NOINOTIFY>
682If you need dynamically allocated loops it is better to use C<ev_loop_new> 683If you need dynamically allocated loops it is better to use C<ev_loop_new>
683and C<ev_loop_destroy>. 684and C<ev_loop_destroy>.
684 685
685=item ev_loop_fork (loop) 686=item ev_loop_fork (loop)
686 687
687This function sets a flag that causes subsequent C<ev_run> iterations to 688This function sets a flag that causes subsequent C<ev_run> iterations
688reinitialise the kernel state for backends that have one. Despite the 689to reinitialise the kernel state for backends that have one. Despite
689name, you can call it anytime, but it makes most sense after forking, in 690the name, you can call it anytime you are allowed to start or stop
690the child process. You I<must> call it (or use C<EVFLAG_FORKCHECK>) in the 691watchers (except inside an C<ev_prepare> callback), but it makes most
692sense after forking, in the child process. You I<must> call it (or use
691child before resuming or calling C<ev_run>. 693C<EVFLAG_FORKCHECK>) in the child before resuming or calling C<ev_run>.
694
695In addition, if you want to reuse a loop (via this function or
696C<EVFLAG_FORKCHECK>), you I<also> have to ignore C<SIGPIPE>.
692 697
693Again, you I<have> to call it on I<any> loop that you want to re-use after 698Again, you I<have> to call it on I<any> loop that you want to re-use after
694a fork, I<even if you do not plan to use the loop in the parent>. This is 699a fork, I<even if you do not plan to use the loop in the parent>. This is
695because some kernel interfaces *cough* I<kqueue> *cough* do funny things 700because some kernel interfaces *cough* I<kqueue> *cough* do funny things
696during fork. 701during fork.
2028 2033
2029The relative timeouts are calculated relative to the C<ev_now ()> 2034The relative timeouts are calculated relative to the C<ev_now ()>
2030time. This is usually the right thing as this timestamp refers to the time 2035time. This is usually the right thing as this timestamp refers to the time
2031of the event triggering whatever timeout you are modifying/starting. If 2036of the event triggering whatever timeout you are modifying/starting. If
2032you suspect event processing to be delayed and you I<need> to base the 2037you suspect event processing to be delayed and you I<need> to base the
2033timeout on the current time, use something like this to adjust for this: 2038timeout on the current time, use something like the following to adjust
2039for it:
2034 2040
2035 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.); 2041 ev_timer_set (&timer, after + (ev_time () - ev_now ()), 0.);
2036 2042
2037If the event loop is suspended for a long time, you can also force an 2043If the event loop is suspended for a long time, you can also force an
2038update of the time returned by C<ev_now ()> by calling C<ev_now_update 2044update of the time returned by C<ev_now ()> by calling C<ev_now_update
2039()>. 2045()>, although that will push the event time of all outstanding events
2046further into the future.
2040 2047
2041=head3 The special problem of unsynchronised clocks 2048=head3 The special problem of unsynchronised clocks
2042 2049
2043Modern systems have a variety of clocks - libev itself uses the normal 2050Modern systems have a variety of clocks - libev itself uses the normal
2044"wall clock" clock and, if available, the monotonic clock (to avoid time 2051"wall clock" clock and, if available, the monotonic clock (to avoid time
2107 2114
2108=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 2115=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
2109 2116
2110=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat) 2117=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
2111 2118
2112Configure the timer to trigger after C<after> seconds. If C<repeat> 2119Configure the timer to trigger after C<after> seconds (fractional and
2113is C<0.>, then it will automatically be stopped once the timeout is 2120negative values are supported). If C<repeat> is C<0.>, then it will
2114reached. If it is positive, then the timer will automatically be 2121automatically be stopped once the timeout is reached. If it is positive,
2115configured to trigger again C<repeat> seconds later, again, and again, 2122then the timer will automatically be configured to trigger again C<repeat>
2116until stopped manually. 2123seconds later, again, and again, until stopped manually.
2117 2124
2118The timer itself will do a best-effort at avoiding drift, that is, if 2125The timer itself will do a best-effort at avoiding drift, that is, if
2119you configure a timer to trigger every 10 seconds, then it will normally 2126you configure a timer to trigger every 10 seconds, then it will normally
2120trigger at exactly 10 second intervals. If, however, your program cannot 2127trigger at exactly 10 second intervals. If, however, your program cannot
2121keep up with the timer (because it takes longer than those 10 seconds to 2128keep up with the timer (because it takes longer than those 10 seconds to
2203Periodic watchers are also timers of a kind, but they are very versatile 2210Periodic watchers are also timers of a kind, but they are very versatile
2204(and unfortunately a bit complex). 2211(and unfortunately a bit complex).
2205 2212
2206Unlike C<ev_timer>, periodic watchers are not based on real time (or 2213Unlike C<ev_timer>, periodic watchers are not based on real time (or
2207relative time, the physical time that passes) but on wall clock time 2214relative time, the physical time that passes) but on wall clock time
2208(absolute time, the thing you can read on your calender or clock). The 2215(absolute time, the thing you can read on your calendar or clock). The
2209difference is that wall clock time can run faster or slower than real 2216difference is that wall clock time can run faster or slower than real
2210time, and time jumps are not uncommon (e.g. when you adjust your 2217time, and time jumps are not uncommon (e.g. when you adjust your
2211wrist-watch). 2218wrist-watch).
2212 2219
2213You can tell a periodic watcher to trigger after some specific point 2220You can tell a periodic watcher to trigger after some specific point
2393 2400
2394 ev_periodic hourly_tick; 2401 ev_periodic hourly_tick;
2395 ev_periodic_init (&hourly_tick, clock_cb, 2402 ev_periodic_init (&hourly_tick, clock_cb,
2396 fmod (ev_now (loop), 3600.), 3600., 0); 2403 fmod (ev_now (loop), 3600.), 3600., 0);
2397 ev_periodic_start (loop, &hourly_tick); 2404 ev_periodic_start (loop, &hourly_tick);
2398 2405
2399 2406
2400=head2 C<ev_signal> - signal me when a signal gets signalled! 2407=head2 C<ev_signal> - signal me when a signal gets signalled!
2401 2408
2402Signal watchers will trigger an event when the process receives a specific 2409Signal watchers will trigger an event when the process receives a specific
2403signal one or more times. Even though signals are very asynchronous, libev 2410signal one or more times. Even though signals are very asynchronous, libev
2907 2914
2908Prepare and check watchers are often (but not always) used in pairs: 2915Prepare and check watchers are often (but not always) used in pairs:
2909prepare watchers get invoked before the process blocks and check watchers 2916prepare watchers get invoked before the process blocks and check watchers
2910afterwards. 2917afterwards.
2911 2918
2912You I<must not> call C<ev_run> or similar functions that enter 2919You I<must not> call C<ev_run> (or similar functions that enter the
2913the current event loop from either C<ev_prepare> or C<ev_check> 2920current event loop) or C<ev_loop_fork> from either C<ev_prepare> or
2914watchers. Other loops than the current one are fine, however. The 2921C<ev_check> watchers. Other loops than the current one are fine,
2915rationale behind this is that you do not need to check for recursion in 2922however. The rationale behind this is that you do not need to check
2916those watchers, i.e. the sequence will always be C<ev_prepare>, blocking, 2923for recursion in those watchers, i.e. the sequence will always be
2917C<ev_check> so if you have one watcher of each kind they will always be 2924C<ev_prepare>, blocking, C<ev_check> so if you have one watcher of each
2918called in pairs bracketing the blocking call. 2925kind they will always be called in pairs bracketing the blocking call.
2919 2926
2920Their main purpose is to integrate other event mechanisms into libev and 2927Their main purpose is to integrate other event mechanisms into libev and
2921their use is somewhat advanced. They could be used, for example, to track 2928their use is somewhat advanced. They could be used, for example, to track
2922variable changes, implement your own watchers, integrate net-snmp or a 2929variable changes, implement your own watchers, integrate net-snmp or a
2923coroutine library and lots more. They are also occasionally useful if 2930coroutine library and lots more. They are also occasionally useful if
3213used). 3220used).
3214 3221
3215 struct ev_loop *loop_hi = ev_default_init (0); 3222 struct ev_loop *loop_hi = ev_default_init (0);
3216 struct ev_loop *loop_lo = 0; 3223 struct ev_loop *loop_lo = 0;
3217 ev_embed embed; 3224 ev_embed embed;
3218 3225
3219 // see if there is a chance of getting one that works 3226 // see if there is a chance of getting one that works
3220 // (remember that a flags value of 0 means autodetection) 3227 // (remember that a flags value of 0 means autodetection)
3221 loop_lo = ev_embeddable_backends () & ev_recommended_backends () 3228 loop_lo = ev_embeddable_backends () & ev_recommended_backends ()
3222 ? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ()) 3229 ? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ())
3223 : 0; 3230 : 0;
3237C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too). 3244C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too).
3238 3245
3239 struct ev_loop *loop = ev_default_init (0); 3246 struct ev_loop *loop = ev_default_init (0);
3240 struct ev_loop *loop_socket = 0; 3247 struct ev_loop *loop_socket = 0;
3241 ev_embed embed; 3248 ev_embed embed;
3242 3249
3243 if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE) 3250 if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE)
3244 if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE)) 3251 if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE))
3245 { 3252 {
3246 ev_embed_init (&embed, 0, loop_socket); 3253 ev_embed_init (&embed, 0, loop_socket);
3247 ev_embed_start (loop, &embed); 3254 ev_embed_start (loop, &embed);
3263and calls it in the wrong process, the fork handlers will be invoked, too, 3270and calls it in the wrong process, the fork handlers will be invoked, too,
3264of course. 3271of course.
3265 3272
3266=head3 The special problem of life after fork - how is it possible? 3273=head3 The special problem of life after fork - how is it possible?
3267 3274
3268Most uses of C<fork()> consist of forking, then some simple calls to set 3275Most uses of C<fork ()> consist of forking, then some simple calls to set
3269up/change the process environment, followed by a call to C<exec()>. This 3276up/change the process environment, followed by a call to C<exec()>. This
3270sequence should be handled by libev without any problems. 3277sequence should be handled by libev without any problems.
3271 3278
3272This changes when the application actually wants to do event handling 3279This changes when the application actually wants to do event handling
3273in the child, or both parent in child, in effect "continuing" after the 3280in the child, or both parent in child, in effect "continuing" after the
3511 3518
3512There are some other functions of possible interest. Described. Here. Now. 3519There are some other functions of possible interest. Described. Here. Now.
3513 3520
3514=over 4 3521=over 4
3515 3522
3516=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback) 3523=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback, arg)
3517 3524
3518This function combines a simple timer and an I/O watcher, calls your 3525This function combines a simple timer and an I/O watcher, calls your
3519callback on whichever event happens first and automatically stops both 3526callback on whichever event happens first and automatically stops both
3520watchers. This is useful if you want to wait for a single event on an fd 3527watchers. This is useful if you want to wait for a single event on an fd
3521or timeout without having to allocate/configure/start/stop/free one or 3528or timeout without having to allocate/configure/start/stop/free one or
3897To embed libev, see L</EMBEDDING>, but in short, it's easiest to create two 3904To embed libev, see L</EMBEDDING>, but in short, it's easiest to create two
3898files, F<my_ev.h> and F<my_ev.c> that include the respective libev files: 3905files, F<my_ev.h> and F<my_ev.c> that include the respective libev files:
3899 3906
3900 // my_ev.h 3907 // my_ev.h
3901 #define EV_CB_DECLARE(type) struct my_coro *cb; 3908 #define EV_CB_DECLARE(type) struct my_coro *cb;
3902 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb); 3909 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb)
3903 #include "../libev/ev.h" 3910 #include "../libev/ev.h"
3904 3911
3905 // my_ev.c 3912 // my_ev.c
3906 #define EV_H "my_ev.h" 3913 #define EV_H "my_ev.h"
3907 #include "../libev/ev.c" 3914 #include "../libev/ev.c"
4097 void operator() (ev::io &w, int revents) 4104 void operator() (ev::io &w, int revents)
4098 { 4105 {
4099 ... 4106 ...
4100 } 4107 }
4101 } 4108 }
4102 4109
4103 myfunctor f; 4110 myfunctor f;
4104 4111
4105 ev::io w; 4112 ev::io w;
4106 w.set (&f); 4113 w.set (&f);
4107 4114
4380 ev_vars.h 4387 ev_vars.h
4381 ev_wrap.h 4388 ev_wrap.h
4382 4389
4383 ev_win32.c required on win32 platforms only 4390 ev_win32.c required on win32 platforms only
4384 4391
4385 ev_select.c only when select backend is enabled (which is enabled by default) 4392 ev_select.c only when select backend is enabled
4386 ev_poll.c only when poll backend is enabled (disabled by default) 4393 ev_poll.c only when poll backend is enabled
4387 ev_epoll.c only when the epoll backend is enabled (disabled by default) 4394 ev_epoll.c only when the epoll backend is enabled
4388 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 4395 ev_kqueue.c only when the kqueue backend is enabled
4389 ev_port.c only when the solaris port backend is enabled (disabled by default) 4396 ev_port.c only when the solaris port backend is enabled
4390 4397
4391F<ev.c> includes the backend files directly when enabled, so you only need 4398F<ev.c> includes the backend files directly when enabled, so you only need
4392to compile this single file. 4399to compile this single file.
4393 4400
4394=head3 LIBEVENT COMPATIBILITY API 4401=head3 LIBEVENT COMPATIBILITY API
5294structure (guaranteed by POSIX but not by ISO C for example), but it also 5301structure (guaranteed by POSIX but not by ISO C for example), but it also
5295assumes that the same (machine) code can be used to call any watcher 5302assumes that the same (machine) code can be used to call any watcher
5296callback: The watcher callbacks have different type signatures, but libev 5303callback: The watcher callbacks have different type signatures, but libev
5297calls them using an C<ev_watcher *> internally. 5304calls them using an C<ev_watcher *> internally.
5298 5305
5306=item null pointers and integer zero are represented by 0 bytes
5307
5308Libev uses C<memset> to initialise structs and arrays to C<0> bytes, and
5309relies on this setting pointers and integers to null.
5310
5299=item pointer accesses must be thread-atomic 5311=item pointer accesses must be thread-atomic
5300 5312
5301Accessing a pointer value must be atomic, it must both be readable and 5313Accessing a pointer value must be atomic, it must both be readable and
5302writable in one piece - this is the case on all current architectures. 5314writable in one piece - this is the case on all current architectures.
5303 5315

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines