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

Comparing libev/ev.pod (file contents):
Revision 1.358 by sf-exg, Tue Jan 11 08:43:48 2011 UTC vs.
Revision 1.374 by sf-exg, Sat Jun 4 16:54:59 2011 UTC

58 ev_timer_start (loop, &timeout_watcher); 58 ev_timer_start (loop, &timeout_watcher);
59 59
60 // now wait for events to arrive 60 // now wait for events to arrive
61 ev_run (loop, 0); 61 ev_run (loop, 0);
62 62
63 // unloop was called, so exit 63 // break was called, so exit
64 return 0; 64 return 0;
65 } 65 }
66 66
67=head1 ABOUT THIS DOCUMENT 67=head1 ABOUT THIS DOCUMENT
68 68
178you actually want to know. Also interesting is the combination of 178you actually want to know. Also interesting is the combination of
179C<ev_update_now> and C<ev_now>. 179C<ev_update_now> and C<ev_now>.
180 180
181=item ev_sleep (ev_tstamp interval) 181=item ev_sleep (ev_tstamp interval)
182 182
183Sleep for the given interval: The current thread will be blocked until 183Sleep for the given interval: The current thread will be blocked
184either it is interrupted or the given time interval has passed. Basically 184until either it is interrupted or the given time interval has
185passed (approximately - it might return a bit earlier even if not
186interrupted). Returns immediately if C<< interval <= 0 >>.
187
185this is a sub-second-resolution C<sleep ()>. 188Basically this is a sub-second-resolution C<sleep ()>.
189
190The range of the C<interval> is limited - libev only guarantees to work
191with sleep times of up to one day (C<< interval <= 86400 >>).
186 192
187=item int ev_version_major () 193=item int ev_version_major ()
188 194
189=item int ev_version_minor () 195=item int ev_version_minor ()
190 196
435example) that can't properly initialise their signal masks. 441example) that can't properly initialise their signal masks.
436 442
437=item C<EVFLAG_NOSIGMASK> 443=item C<EVFLAG_NOSIGMASK>
438 444
439When this flag is specified, then libev will avoid to modify the signal 445When this flag is specified, then libev will avoid to modify the signal
440mask. Specifically, this means you ahve to make sure signals are unblocked 446mask. Specifically, this means you have to make sure signals are unblocked
441when you want to receive them. 447when you want to receive them.
442 448
443This behaviour is useful when you want to do your own signal handling, or 449This behaviour is useful when you want to do your own signal handling, or
444want to handle signals only in specific threads and want to avoid libev 450want to handle signals only in specific threads and want to avoid libev
445unblocking the signals. 451unblocking the signals.
452
453It's also required by POSIX in a threaded program, as libev calls
454C<sigprocmask>, whose behaviour is officially unspecified.
446 455
447This flag's behaviour will become the default in future versions of libev. 456This flag's behaviour will become the default in future versions of libev.
448 457
449=item C<EVBACKEND_SELECT> (value 1, portable select backend) 458=item C<EVBACKEND_SELECT> (value 1, portable select backend)
450 459
480=item C<EVBACKEND_EPOLL> (value 4, Linux) 489=item C<EVBACKEND_EPOLL> (value 4, Linux)
481 490
482Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9 491Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9
483kernels). 492kernels).
484 493
485For few fds, this backend is a bit little slower than poll and select, 494For few fds, this backend is a bit little slower than poll and select, but
486but it scales phenomenally better. While poll and select usually scale 495it scales phenomenally better. While poll and select usually scale like
487like O(total_fds) where n is the total number of fds (or the highest fd), 496O(total_fds) where total_fds is the total number of fds (or the highest
488epoll scales either O(1) or O(active_fds). 497fd), epoll scales either O(1) or O(active_fds).
489 498
490The epoll mechanism deserves honorable mention as the most misdesigned 499The epoll mechanism deserves honorable mention as the most misdesigned
491of the more advanced event mechanisms: mere annoyances include silently 500of the more advanced event mechanisms: mere annoyances include silently
492dropping file descriptors, requiring a system call per change per file 501dropping file descriptors, requiring a system call per change per file
493descriptor (and unnecessary guessing of parameters), problems with dup, 502descriptor (and unnecessary guessing of parameters), problems with dup,
4960.1ms) and so on. The biggest issue is fork races, however - if a program 5050.1ms) and so on. The biggest issue is fork races, however - if a program
497forks then I<both> parent and child process have to recreate the epoll 506forks then I<both> parent and child process have to recreate the epoll
498set, which can take considerable time (one syscall per file descriptor) 507set, which can take considerable time (one syscall per file descriptor)
499and is of course hard to detect. 508and is of course hard to detect.
500 509
501Epoll is also notoriously buggy - embedding epoll fds I<should> work, but 510Epoll is also notoriously buggy - embedding epoll fds I<should> work,
502of course I<doesn't>, and epoll just loves to report events for totally 511but of course I<doesn't>, and epoll just loves to report events for
503I<different> file descriptors (even already closed ones, so one cannot 512totally I<different> file descriptors (even already closed ones, so
504even remove them from the set) than registered in the set (especially 513one cannot even remove them from the set) than registered in the set
505on SMP systems). Libev tries to counter these spurious notifications by 514(especially on SMP systems). Libev tries to counter these spurious
506employing an additional generation counter and comparing that against the 515notifications by employing an additional generation counter and comparing
507events to filter out spurious ones, recreating the set when required. Last 516that against the events to filter out spurious ones, recreating the set
517when required. Epoll also erroneously rounds down timeouts, but gives you
518no way to know when and by how much, so sometimes you have to busy-wait
519because epoll returns immediately despite a nonzero timeout. And last
508not least, it also refuses to work with some file descriptors which work 520not least, it also refuses to work with some file descriptors which work
509perfectly fine with C<select> (files, many character devices...). 521perfectly fine with C<select> (files, many character devices...).
510 522
511Epoll is truly the train wreck analog among event poll mechanisms, 523Epoll is truly the train wreck among event poll mechanisms, a frankenpoll,
512a frankenpoll, cobbled together in a hurry, no thought to design or 524cobbled together in a hurry, no thought to design or interaction with
513interaction with others. 525others. Oh, the pain, will it ever stop...
514 526
515While stopping, setting and starting an I/O watcher in the same iteration 527While stopping, setting and starting an I/O watcher in the same iteration
516will result in some caching, there is still a system call per such 528will result in some caching, there is still a system call per such
517incident (because the same I<file descriptor> could point to a different 529incident (because the same I<file descriptor> could point to a different
518I<file description> now), so its best to avoid that. Also, C<dup ()>'ed 530I<file description> now), so its best to avoid that. Also, C<dup ()>'ed
822This is useful if you are waiting for some external event in conjunction 834This is useful if you are waiting for some external event in conjunction
823with something not expressible using other libev watchers (i.e. "roll your 835with something not expressible using other libev watchers (i.e. "roll your
824own C<ev_run>"). However, a pair of C<ev_prepare>/C<ev_check> watchers is 836own C<ev_run>"). However, a pair of C<ev_prepare>/C<ev_check> watchers is
825usually a better approach for this kind of thing. 837usually a better approach for this kind of thing.
826 838
827Here are the gory details of what C<ev_run> does: 839Here are the gory details of what C<ev_run> does (this is for your
840understanding, not a guarantee that things will work exactly like this in
841future versions):
828 842
829 - Increment loop depth. 843 - Increment loop depth.
830 - Reset the ev_break status. 844 - Reset the ev_break status.
831 - Before the first iteration, call any pending watchers. 845 - Before the first iteration, call any pending watchers.
832 LOOP: 846 LOOP:
865anymore. 879anymore.
866 880
867 ... queue jobs here, make sure they register event watchers as long 881 ... queue jobs here, make sure they register event watchers as long
868 ... as they still have work to do (even an idle watcher will do..) 882 ... as they still have work to do (even an idle watcher will do..)
869 ev_run (my_loop, 0); 883 ev_run (my_loop, 0);
870 ... jobs done or somebody called unloop. yeah! 884 ... jobs done or somebody called break. yeah!
871 885
872=item ev_break (loop, how) 886=item ev_break (loop, how)
873 887
874Can be used to make a call to C<ev_run> return early (but only after it 888Can be used to make a call to C<ev_run> return early (but only after it
875has processed all outstanding events). The C<how> argument must be either 889has processed all outstanding events). The C<how> argument must be either
938overhead for the actual polling but can deliver many events at once. 952overhead for the actual polling but can deliver many events at once.
939 953
940By setting a higher I<io collect interval> you allow libev to spend more 954By setting a higher I<io collect interval> you allow libev to spend more
941time collecting I/O events, so you can handle more events per iteration, 955time collecting I/O events, so you can handle more events per iteration,
942at the cost of increasing latency. Timeouts (both C<ev_periodic> and 956at the cost of increasing latency. Timeouts (both C<ev_periodic> and
943C<ev_timer>) will be not affected. Setting this to a non-null value will 957C<ev_timer>) will not be affected. Setting this to a non-null value will
944introduce an additional C<ev_sleep ()> call into most loop iterations. The 958introduce an additional C<ev_sleep ()> call into most loop iterations. The
945sleep time ensures that libev will not poll for I/O events more often then 959sleep time ensures that libev will not poll for I/O events more often then
946once per this interval, on average. 960once per this interval, on average (as long as the host time resolution is
961good enough).
947 962
948Likewise, by setting a higher I<timeout collect interval> you allow libev 963Likewise, by setting a higher I<timeout collect interval> you allow libev
949to spend more time collecting timeouts, at the expense of increased 964to spend more time collecting timeouts, at the expense of increased
950latency/jitter/inexactness (the watcher callback will be called 965latency/jitter/inexactness (the watcher callback will be called
951later). C<ev_io> watchers will not be affected. Setting this to a non-null 966later). C<ev_io> watchers will not be affected. Setting this to a non-null
1371 1386
1372=over 4 1387=over 4
1373 1388
1374=item initialiased 1389=item initialiased
1375 1390
1376Before a watcher can be registered with the event looop it has to be 1391Before a watcher can be registered with the event loop it has to be
1377initialised. This can be done with a call to C<ev_TYPE_init>, or calls to 1392initialised. This can be done with a call to C<ev_TYPE_init>, or calls to
1378C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function. 1393C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1379 1394
1380In this state it is simply some block of memory that is suitable for use 1395In this state it is simply some block of memory that is suitable for
1381in an event loop. It can be moved around, freed, reused etc. at will. 1396use in an event loop. It can be moved around, freed, reused etc. at
1397will - as long as you either keep the memory contents intact, or call
1398C<ev_TYPE_init> again.
1382 1399
1383=item started/running/active 1400=item started/running/active
1384 1401
1385Once a watcher has been started with a call to C<ev_TYPE_start> it becomes 1402Once a watcher has been started with a call to C<ev_TYPE_start> it becomes
1386property of the event loop, and is actively waiting for events. While in 1403property of the event loop, and is actively waiting for events. While in
1414latter will clear any pending state the watcher might be in, regardless 1431latter will clear any pending state the watcher might be in, regardless
1415of whether it was active or not, so stopping a watcher explicitly before 1432of whether it was active or not, so stopping a watcher explicitly before
1416freeing it is often a good idea. 1433freeing it is often a good idea.
1417 1434
1418While stopped (and not pending) the watcher is essentially in the 1435While stopped (and not pending) the watcher is essentially in the
1419initialised state, that is it can be reused, moved, modified in any way 1436initialised state, that is, it can be reused, moved, modified in any way
1420you wish. 1437you wish (but when you trash the memory block, you need to C<ev_TYPE_init>
1438it again).
1421 1439
1422=back 1440=back
1423 1441
1424=head2 WATCHER PRIORITY MODELS 1442=head2 WATCHER PRIORITY MODELS
1425 1443
2145 2163
2146Another way to think about it (for the mathematically inclined) is that 2164Another way to think about it (for the mathematically inclined) is that
2147C<ev_periodic> will try to run the callback in this mode at the next possible 2165C<ev_periodic> will try to run the callback in this mode at the next possible
2148time where C<time = offset (mod interval)>, regardless of any time jumps. 2166time where C<time = offset (mod interval)>, regardless of any time jumps.
2149 2167
2150For numerical stability it is preferable that the C<offset> value is near 2168The C<interval> I<MUST> be positive, and for numerical stability, the
2151C<ev_now ()> (the current time), but there is no range requirement for 2169interval value should be higher than C<1/8192> (which is around 100
2152this value, and in fact is often specified as zero. 2170microseconds) and C<offset> should be higher than C<0> and should have
2171at most a similar magnitude as the current time (say, within a factor of
2172ten). Typical values for offset are, in fact, C<0> or something between
2173C<0> and C<interval>, which is also the recommended range.
2153 2174
2154Note also that there is an upper limit to how often a timer can fire (CPU 2175Note also that there is an upper limit to how often a timer can fire (CPU
2155speed for example), so if C<interval> is very small then timing stability 2176speed for example), so if C<interval> is very small then timing stability
2156will of course deteriorate. Libev itself tries to be exact to be about one 2177will of course deteriorate. Libev itself tries to be exact to be about one
2157millisecond (if the OS supports it and the machine is fast enough). 2178millisecond (if the OS supports it and the machine is fast enough).
2300=head3 The special problem of inheritance over fork/execve/pthread_create 2321=head3 The special problem of inheritance over fork/execve/pthread_create
2301 2322
2302Both the signal mask (C<sigprocmask>) and the signal disposition 2323Both the signal mask (C<sigprocmask>) and the signal disposition
2303(C<sigaction>) are unspecified after starting a signal watcher (and after 2324(C<sigaction>) are unspecified after starting a signal watcher (and after
2304stopping it again), that is, libev might or might not block the signal, 2325stopping it again), that is, libev might or might not block the signal,
2305and might or might not set or restore the installed signal handler. 2326and might or might not set or restore the installed signal handler (but
2327see C<EVFLAG_NOSIGMASK>).
2306 2328
2307While this does not matter for the signal disposition (libev never 2329While this does not matter for the signal disposition (libev never
2308sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on 2330sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on
2309C<execve>), this matters for the signal mask: many programs do not expect 2331C<execve>), this matters for the signal mask: many programs do not expect
2310certain signals to be blocked. 2332certain signals to be blocked.
3181 atexit (program_exits); 3203 atexit (program_exits);
3182 3204
3183 3205
3184=head2 C<ev_async> - how to wake up an event loop 3206=head2 C<ev_async> - how to wake up an event loop
3185 3207
3186In general, you cannot use an C<ev_run> from multiple threads or other 3208In general, you cannot use an C<ev_loop> from multiple threads or other
3187asynchronous sources such as signal handlers (as opposed to multiple event 3209asynchronous sources such as signal handlers (as opposed to multiple event
3188loops - those are of course safe to use in different threads). 3210loops - those are of course safe to use in different threads).
3189 3211
3190Sometimes, however, you need to wake up an event loop you do not control, 3212Sometimes, however, you need to wake up an event loop you do not control,
3191for example because it belongs to another thread. This is what C<ev_async> 3213for example because it belongs to another thread. This is what C<ev_async>
3301trust me. 3323trust me.
3302 3324
3303=item ev_async_send (loop, ev_async *) 3325=item ev_async_send (loop, ev_async *)
3304 3326
3305Sends/signals/activates the given C<ev_async> watcher, that is, feeds 3327Sends/signals/activates the given C<ev_async> watcher, that is, feeds
3306an C<EV_ASYNC> event on the watcher into the event loop. Unlike 3328an C<EV_ASYNC> event on the watcher into the event loop, and instantly
3329returns.
3330
3307C<ev_feed_event>, this call is safe to do from other threads, signal or 3331Unlike C<ev_feed_event>, this call is safe to do from other threads,
3308similar contexts (see the discussion of C<EV_ATOMIC_T> in the embedding 3332signal or similar contexts (see the discussion of C<EV_ATOMIC_T> in the
3309section below on what exactly this means). 3333embedding section below on what exactly this means).
3310 3334
3311Note that, as with other watchers in libev, multiple events might get 3335Note that, as with other watchers in libev, multiple events might get
3312compressed into a single callback invocation (another way to look at this 3336compressed into a single callback invocation (another way to look at this
3313is that C<ev_async> watchers are level-triggered, set on C<ev_async_send>, 3337is that C<ev_async> watchers are level-triggered, set on C<ev_async_send>,
3314reset when the event loop detects that). 3338reset when the event loop detects that).
3504 exit_main_loop = exit_nested_loop = 1; 3528 exit_main_loop = exit_nested_loop = 1;
3505 3529
3506=head2 THREAD LOCKING EXAMPLE 3530=head2 THREAD LOCKING EXAMPLE
3507 3531
3508Here is a fictitious example of how to run an event loop in a different 3532Here is a fictitious example of how to run an event loop in a different
3509thread than where callbacks are being invoked and watchers are 3533thread from where callbacks are being invoked and watchers are
3510created/added/removed. 3534created/added/removed.
3511 3535
3512For a real-world example, see the C<EV::Loop::Async> perl module, 3536For a real-world example, see the C<EV::Loop::Async> perl module,
3513which uses exactly this technique (which is suited for many high-level 3537which uses exactly this technique (which is suited for many high-level
3514languages). 3538languages).
3540 // now associate this with the loop 3564 // now associate this with the loop
3541 ev_set_userdata (EV_A_ u); 3565 ev_set_userdata (EV_A_ u);
3542 ev_set_invoke_pending_cb (EV_A_ l_invoke); 3566 ev_set_invoke_pending_cb (EV_A_ l_invoke);
3543 ev_set_loop_release_cb (EV_A_ l_release, l_acquire); 3567 ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
3544 3568
3545 // then create the thread running ev_loop 3569 // then create the thread running ev_run
3546 pthread_create (&u->tid, 0, l_run, EV_A); 3570 pthread_create (&u->tid, 0, l_run, EV_A);
3547 } 3571 }
3548 3572
3549The callback for the C<ev_async> watcher does nothing: the watcher is used 3573The callback for the C<ev_async> watcher does nothing: the watcher is used
3550solely to wake up the event loop so it takes notice of any new watchers 3574solely to wake up the event loop so it takes notice of any new watchers
4195F<event.h> that are not directly supported by the libev core alone. 4219F<event.h> that are not directly supported by the libev core alone.
4196 4220
4197In standalone mode, libev will still try to automatically deduce the 4221In standalone mode, libev will still try to automatically deduce the
4198configuration, but has to be more conservative. 4222configuration, but has to be more conservative.
4199 4223
4224=item EV_USE_FLOOR
4225
4226If defined to be C<1>, libev will use the C<floor ()> function for its
4227periodic reschedule calculations, otherwise libev will fall back on a
4228portable (slower) implementation. If you enable this, you usually have to
4229link against libm or something equivalent. Enabling this when the C<floor>
4230function is not available will fail, so the safe default is to not enable
4231this.
4232
4200=item EV_USE_MONOTONIC 4233=item EV_USE_MONOTONIC
4201 4234
4202If defined to be C<1>, libev will try to detect the availability of the 4235If defined to be C<1>, libev will try to detect the availability of the
4203monotonic clock option at both compile time and runtime. Otherwise no 4236monotonic clock option at both compile time and runtime. Otherwise no
4204use of the monotonic clock option will be attempted. If you enable this, 4237use of the monotonic clock option will be attempted. If you enable this,
4871requires, and its I/O model is fundamentally incompatible with the POSIX 4904requires, and its I/O model is fundamentally incompatible with the POSIX
4872model. Libev still offers limited functionality on this platform in 4905model. Libev still offers limited functionality on this platform in
4873the form of the C<EVBACKEND_SELECT> backend, and only supports socket 4906the form of the C<EVBACKEND_SELECT> backend, and only supports socket
4874descriptors. This only applies when using Win32 natively, not when using 4907descriptors. This only applies when using Win32 natively, not when using
4875e.g. cygwin. Actually, it only applies to the microsofts own compilers, 4908e.g. cygwin. Actually, it only applies to the microsofts own compilers,
4876as every compielr comes with a slightly differently broken/incompatible 4909as every compiler comes with a slightly differently broken/incompatible
4877environment. 4910environment.
4878 4911
4879Lifting these limitations would basically require the full 4912Lifting these limitations would basically require the full
4880re-implementation of the I/O system. If you are into this kind of thing, 4913re-implementation of the I/O system. If you are into this kind of thing,
4881then note that glib does exactly that for you in a very portable way (note 4914then note that glib does exactly that for you in a very portable way (note
5215The physical time that is observed. It is apparently strictly monotonic :) 5248The physical time that is observed. It is apparently strictly monotonic :)
5216 5249
5217=item wall-clock time 5250=item wall-clock time
5218 5251
5219The time and date as shown on clocks. Unlike real time, it can actually 5252The time and date as shown on clocks. Unlike real time, it can actually
5220be wrong and jump forwards and backwards, e.g. when the you adjust your 5253be wrong and jump forwards and backwards, e.g. when you adjust your
5221clock. 5254clock.
5222 5255
5223=item watcher 5256=item watcher
5224 5257
5225A data structure that describes interest in certain events. Watchers need 5258A data structure that describes interest in certain events. Watchers need
5228=back 5261=back
5229 5262
5230=head1 AUTHOR 5263=head1 AUTHOR
5231 5264
5232Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael 5265Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael
5233Magnusson and Emanuele Giaquinta. 5266Magnusson and Emanuele Giaquinta, and minor corrections by many others.
5234 5267

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines