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

Comparing libev/ev.pod (file contents):
Revision 1.237 by root, Thu Apr 16 07:58:03 2009 UTC vs.
Revision 1.247 by root, Wed Jul 8 02:46:05 2009 UTC

621 621
622This value can sometimes be useful as a generation counter of sorts (it 622This value can sometimes be useful as a generation counter of sorts (it
623"ticks" the number of loop iterations), as it roughly corresponds with 623"ticks" the number of loop iterations), as it roughly corresponds with
624C<ev_prepare> and C<ev_check> calls. 624C<ev_prepare> and C<ev_check> calls.
625 625
626=item unsigned int ev_loop_depth (loop)
627
628Returns the number of times C<ev_loop> was entered minus the number of
629times C<ev_loop> was exited, in other words, the recursion depth.
630
631Outside C<ev_loop>, this number is zero. In a callback, this number is
632C<1>, unless C<ev_loop> was invoked recursively (or from another thread),
633in which case it is higher.
634
635Leaving C<ev_loop> abnormally (setjmp/longjmp, cancelling the thread
636etc.), doesn't count as exit.
637
626=item unsigned int ev_backend (loop) 638=item unsigned int ev_backend (loop)
627 639
628Returns one of the C<EVBACKEND_*> flags indicating the event backend in 640Returns one of the C<EVBACKEND_*> flags indicating the event backend in
629use. 641use.
630 642
644 656
645This function is rarely useful, but when some event callback runs for a 657This function is rarely useful, but when some event callback runs for a
646very long time without entering the event loop, updating libev's idea of 658very long time without entering the event loop, updating libev's idea of
647the current time is a good idea. 659the current time is a good idea.
648 660
649See also "The special problem of time updates" in the C<ev_timer> section. 661See also L<The special problem of time updates> in the C<ev_timer> section.
650 662
651=item ev_suspend (loop) 663=item ev_suspend (loop)
652 664
653=item ev_resume (loop) 665=item ev_resume (loop)
654 666
811 823
812By setting a higher I<io collect interval> you allow libev to spend more 824By setting a higher I<io collect interval> you allow libev to spend more
813time collecting I/O events, so you can handle more events per iteration, 825time collecting I/O events, so you can handle more events per iteration,
814at the cost of increasing latency. Timeouts (both C<ev_periodic> and 826at the cost of increasing latency. Timeouts (both C<ev_periodic> and
815C<ev_timer>) will be not affected. Setting this to a non-null value will 827C<ev_timer>) will be not affected. Setting this to a non-null value will
816introduce an additional C<ev_sleep ()> call into most loop iterations. 828introduce an additional C<ev_sleep ()> call into most loop iterations. The
829sleep time ensures that libev will not poll for I/O events more often then
830once per this interval, on average.
817 831
818Likewise, by setting a higher I<timeout collect interval> you allow libev 832Likewise, by setting a higher I<timeout collect interval> you allow libev
819to spend more time collecting timeouts, at the expense of increased 833to spend more time collecting timeouts, at the expense of increased
820latency/jitter/inexactness (the watcher callback will be called 834latency/jitter/inexactness (the watcher callback will be called
821later). C<ev_io> watchers will not be affected. Setting this to a non-null 835later). C<ev_io> watchers will not be affected. Setting this to a non-null
823 837
824Many (busy) programs can usually benefit by setting the I/O collect 838Many (busy) programs can usually benefit by setting the I/O collect
825interval to a value near C<0.1> or so, which is often enough for 839interval to a value near C<0.1> or so, which is often enough for
826interactive servers (of course not for games), likewise for timeouts. It 840interactive servers (of course not for games), likewise for timeouts. It
827usually doesn't make much sense to set it to a lower value than C<0.01>, 841usually doesn't make much sense to set it to a lower value than C<0.01>,
828as this approaches the timing granularity of most systems. 842as this approaches the timing granularity of most systems. Note that if
843you do transactions with the outside world and you can't increase the
844parallelity, then this setting will limit your transaction rate (if you
845need to poll once per transaction and the I/O collect interval is 0.01,
846then you can't do more than 100 transations per second).
829 847
830Setting the I<timeout collect interval> can improve the opportunity for 848Setting the I<timeout collect interval> can improve the opportunity for
831saving power, as the program will "bundle" timer callback invocations that 849saving power, as the program will "bundle" timer callback invocations that
832are "near" in time together, by delaying some, thus reducing the number of 850are "near" in time together, by delaying some, thus reducing the number of
833times the process sleeps and wakes up again. Another useful technique to 851times the process sleeps and wakes up again. Another useful technique to
834reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure 852reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure
835they fire on, say, one-second boundaries only. 853they fire on, say, one-second boundaries only.
854
855Example: we only need 0.1s timeout granularity, and we wish not to poll
856more often than 100 times per second:
857
858 ev_set_timeout_collect_interval (EV_DEFAULT_UC_ 0.1);
859 ev_set_io_collect_interval (EV_DEFAULT_UC_ 0.01);
836 860
837=item ev_loop_verify (loop) 861=item ev_loop_verify (loop)
838 862
839This function only does something when C<EV_VERIFY> support has been 863This function only does something when C<EV_VERIFY> support has been
840compiled in, which is the default for non-minimal builds. It tries to go 864compiled in, which is the default for non-minimal builds. It tries to go
1184 #include <stddef.h> 1208 #include <stddef.h>
1185 1209
1186 static void 1210 static void
1187 t1_cb (EV_P_ ev_timer *w, int revents) 1211 t1_cb (EV_P_ ev_timer *w, int revents)
1188 { 1212 {
1189 struct my_biggy big = (struct my_biggy * 1213 struct my_biggy big = (struct my_biggy *)
1190 (((char *)w) - offsetof (struct my_biggy, t1)); 1214 (((char *)w) - offsetof (struct my_biggy, t1));
1191 } 1215 }
1192 1216
1193 static void 1217 static void
1194 t2_cb (EV_P_ ev_timer *w, int revents) 1218 t2_cb (EV_P_ ev_timer *w, int revents)
1195 { 1219 {
1196 struct my_biggy big = (struct my_biggy * 1220 struct my_biggy big = (struct my_biggy *)
1197 (((char *)w) - offsetof (struct my_biggy, t2)); 1221 (((char *)w) - offsetof (struct my_biggy, t2));
1198 } 1222 }
1199 1223
1200=head2 WATCHER PRIORITY MODELS 1224=head2 WATCHER PRIORITY MODELS
1201 1225
1277 // with the default priority are receiving events. 1301 // with the default priority are receiving events.
1278 ev_idle_start (EV_A_ &idle); 1302 ev_idle_start (EV_A_ &idle);
1279 } 1303 }
1280 1304
1281 static void 1305 static void
1282 idle-cb (EV_P_ ev_idle *w, int revents) 1306 idle_cb (EV_P_ ev_idle *w, int revents)
1283 { 1307 {
1284 // actual processing 1308 // actual processing
1285 read (STDIN_FILENO, ...); 1309 read (STDIN_FILENO, ...);
1286 1310
1287 // have to start the I/O watcher again, as 1311 // have to start the I/O watcher again, as
1332descriptors to non-blocking mode is also usually a good idea (but not 1356descriptors to non-blocking mode is also usually a good idea (but not
1333required if you know what you are doing). 1357required if you know what you are doing).
1334 1358
1335If you cannot use non-blocking mode, then force the use of a 1359If you cannot use non-blocking mode, then force the use of a
1336known-to-be-good backend (at the time of this writing, this includes only 1360known-to-be-good backend (at the time of this writing, this includes only
1337C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). 1361C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). The same applies to file
1362descriptors for which non-blocking operation makes no sense (such as
1363files) - libev doesn't guarentee any specific behaviour in that case.
1338 1364
1339Another thing you have to watch out for is that it is quite easy to 1365Another thing you have to watch out for is that it is quite easy to
1340receive "spurious" readiness notifications, that is your callback might 1366receive "spurious" readiness notifications, that is your callback might
1341be called with C<EV_READ> but a subsequent C<read>(2) will actually block 1367be called with C<EV_READ> but a subsequent C<read>(2) will actually block
1342because there is no data. Not only are some backends known to create a 1368because there is no data. Not only are some backends known to create a
1463year, it will still time out after (roughly) one hour. "Roughly" because 1489year, it will still time out after (roughly) one hour. "Roughly" because
1464detecting time jumps is hard, and some inaccuracies are unavoidable (the 1490detecting time jumps is hard, and some inaccuracies are unavoidable (the
1465monotonic clock option helps a lot here). 1491monotonic clock option helps a lot here).
1466 1492
1467The callback is guaranteed to be invoked only I<after> its timeout has 1493The callback is guaranteed to be invoked only I<after> its timeout has
1468passed. If multiple timers become ready during the same loop iteration 1494passed (not I<at>, so on systems with very low-resolution clocks this
1469then the ones with earlier time-out values are invoked before ones with 1495might introduce a small delay). If multiple timers become ready during the
1496same loop iteration then the ones with earlier time-out values are invoked
1470later time-out values (but this is no longer true when a callback calls 1497before ones with later time-out values (but this is no longer true when a
1471C<ev_loop> recursively). 1498callback calls C<ev_loop> recursively).
1472 1499
1473=head3 Be smart about timeouts 1500=head3 Be smart about timeouts
1474 1501
1475Many real-world problems involve some kind of timeout, usually for error 1502Many real-world problems involve some kind of timeout, usually for error
1476recovery. A typical example is an HTTP request - if the other side hangs, 1503recovery. A typical example is an HTTP request - if the other side hangs,
1520C<after> argument to C<ev_timer_set>, and only ever use the C<repeat> 1547C<after> argument to C<ev_timer_set>, and only ever use the C<repeat>
1521member and C<ev_timer_again>. 1548member and C<ev_timer_again>.
1522 1549
1523At start: 1550At start:
1524 1551
1525 ev_timer_init (timer, callback); 1552 ev_init (timer, callback);
1526 timer->repeat = 60.; 1553 timer->repeat = 60.;
1527 ev_timer_again (loop, timer); 1554 ev_timer_again (loop, timer);
1528 1555
1529Each time there is some activity: 1556Each time there is some activity:
1530 1557
1592 1619
1593To start the timer, simply initialise the watcher and set C<last_activity> 1620To start the timer, simply initialise the watcher and set C<last_activity>
1594to the current time (meaning we just have some activity :), then call the 1621to the current time (meaning we just have some activity :), then call the
1595callback, which will "do the right thing" and start the timer: 1622callback, which will "do the right thing" and start the timer:
1596 1623
1597 ev_timer_init (timer, callback); 1624 ev_init (timer, callback);
1598 last_activity = ev_now (loop); 1625 last_activity = ev_now (loop);
1599 callback (loop, timer, EV_TIMEOUT); 1626 callback (loop, timer, EV_TIMEOUT);
1600 1627
1601And when there is some activity, simply store the current time in 1628And when there is some activity, simply store the current time in
1602C<last_activity>, no libev calls at all: 1629C<last_activity>, no libev calls at all:
1999some child status changes (most typically when a child of yours dies or 2026some child status changes (most typically when a child of yours dies or
2000exits). It is permissible to install a child watcher I<after> the child 2027exits). It is permissible to install a child watcher I<after> the child
2001has been forked (which implies it might have already exited), as long 2028has been forked (which implies it might have already exited), as long
2002as the event loop isn't entered (or is continued from a watcher), i.e., 2029as the event loop isn't entered (or is continued from a watcher), i.e.,
2003forking and then immediately registering a watcher for the child is fine, 2030forking and then immediately registering a watcher for the child is fine,
2004but forking and registering a watcher a few event loop iterations later is 2031but forking and registering a watcher a few event loop iterations later or
2005not. 2032in the next callback invocation is not.
2006 2033
2007Only the default event loop is capable of handling signals, and therefore 2034Only the default event loop is capable of handling signals, and therefore
2008you can only register child watchers in the default event loop. 2035you can only register child watchers in the default event loop.
2009 2036
2010=head3 Process Interaction 2037=head3 Process Interaction
2365 // no longer anything immediate to do. 2392 // no longer anything immediate to do.
2366 } 2393 }
2367 2394
2368 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2395 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2369 ev_idle_init (idle_watcher, idle_cb); 2396 ev_idle_init (idle_watcher, idle_cb);
2370 ev_idle_start (loop, idle_cb); 2397 ev_idle_start (loop, idle_watcher);
2371 2398
2372 2399
2373=head2 C<ev_prepare> and C<ev_check> - customise your event loop! 2400=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
2374 2401
2375Prepare and check watchers are usually (but not always) used in pairs: 2402Prepare and check watchers are usually (but not always) used in pairs:
2468 struct pollfd fds [nfd]; 2495 struct pollfd fds [nfd];
2469 // actual code will need to loop here and realloc etc. 2496 // actual code will need to loop here and realloc etc.
2470 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 2497 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
2471 2498
2472 /* the callback is illegal, but won't be called as we stop during check */ 2499 /* the callback is illegal, but won't be called as we stop during check */
2473 ev_timer_init (&tw, 0, timeout * 1e-3); 2500 ev_timer_init (&tw, 0, timeout * 1e-3, 0.);
2474 ev_timer_start (loop, &tw); 2501 ev_timer_start (loop, &tw);
2475 2502
2476 // create one ev_io per pollfd 2503 // create one ev_io per pollfd
2477 for (int i = 0; i < nfd; ++i) 2504 for (int i = 0; i < nfd; ++i)
2478 { 2505 {
2708event loop blocks next and before C<ev_check> watchers are being called, 2735event loop blocks next and before C<ev_check> watchers are being called,
2709and only in the child after the fork. If whoever good citizen calling 2736and only in the child after the fork. If whoever good citizen calling
2710C<ev_default_fork> cheats and calls it in the wrong process, the fork 2737C<ev_default_fork> cheats and calls it in the wrong process, the fork
2711handlers will be invoked, too, of course. 2738handlers will be invoked, too, of course.
2712 2739
2740=head3 The special problem of life after fork - how is it possible?
2741
2742Most uses of C<fork()> consist of forking, then some simple calls to ste
2743up/change the process environment, followed by a call to C<exec()>. This
2744sequence should be handled by libev without any problems.
2745
2746This changes when the application actually wants to do event handling
2747in the child, or both parent in child, in effect "continuing" after the
2748fork.
2749
2750The default mode of operation (for libev, with application help to detect
2751forks) is to duplicate all the state in the child, as would be expected
2752when I<either> the parent I<or> the child process continues.
2753
2754When both processes want to continue using libev, then this is usually the
2755wrong result. In that case, usually one process (typically the parent) is
2756supposed to continue with all watchers in place as before, while the other
2757process typically wants to start fresh, i.e. without any active watchers.
2758
2759The cleanest and most efficient way to achieve that with libev is to
2760simply create a new event loop, which of course will be "empty", and
2761use that for new watchers. This has the advantage of not touching more
2762memory than necessary, and thus avoiding the copy-on-write, and the
2763disadvantage of having to use multiple event loops (which do not support
2764signal watchers).
2765
2766When this is not possible, or you want to use the default loop for
2767other reasons, then in the process that wants to start "fresh", call
2768C<ev_default_destroy ()> followed by C<ev_default_loop (...)>. Destroying
2769the default loop will "orphan" (not stop) all registered watchers, so you
2770have to be careful not to execute code that modifies those watchers. Note
2771also that in that case, you have to re-register any signal watchers.
2772
2713=head3 Watcher-Specific Functions and Data Members 2773=head3 Watcher-Specific Functions and Data Members
2714 2774
2715=over 4 2775=over 4
2716 2776
2717=item ev_fork_init (ev_signal *, callback) 2777=item ev_fork_init (ev_signal *, callback)
3899way (note also that glib is the slowest event library known to man). 3959way (note also that glib is the slowest event library known to man).
3900 3960
3901There is no supported compilation method available on windows except 3961There is no supported compilation method available on windows except
3902embedding it into other applications. 3962embedding it into other applications.
3903 3963
3964Sensible signal handling is officially unsupported by Microsoft - libev
3965tries its best, but under most conditions, signals will simply not work.
3966
3904Not a libev limitation but worth mentioning: windows apparently doesn't 3967Not a libev limitation but worth mentioning: windows apparently doesn't
3905accept large writes: instead of resulting in a partial write, windows will 3968accept large writes: instead of resulting in a partial write, windows will
3906either accept everything or return C<ENOBUFS> if the buffer is too large, 3969either accept everything or return C<ENOBUFS> if the buffer is too large,
3907so make sure you only write small amounts into your sockets (less than a 3970so make sure you only write small amounts into your sockets (less than a
3908megabyte seems safe, but this apparently depends on the amount of memory 3971megabyte seems safe, but this apparently depends on the amount of memory
3912the abysmal performance of winsockets, using a large number of sockets 3975the abysmal performance of winsockets, using a large number of sockets
3913is not recommended (and not reasonable). If your program needs to use 3976is not recommended (and not reasonable). If your program needs to use
3914more than a hundred or so sockets, then likely it needs to use a totally 3977more than a hundred or so sockets, then likely it needs to use a totally
3915different implementation for windows, as libev offers the POSIX readiness 3978different implementation for windows, as libev offers the POSIX readiness
3916notification model, which cannot be implemented efficiently on windows 3979notification model, which cannot be implemented efficiently on windows
3917(Microsoft monopoly games). 3980(due to Microsoft monopoly games).
3918 3981
3919A typical way to use libev under windows is to embed it (see the embedding 3982A typical way to use libev under windows is to embed it (see the embedding
3920section for details) and use the following F<evwrap.h> header file instead 3983section for details) and use the following F<evwrap.h> header file instead
3921of F<ev.h>: 3984of F<ev.h>:
3922 3985
3958 4021
3959Early versions of winsocket's select only supported waiting for a maximum 4022Early versions of winsocket's select only supported waiting for a maximum
3960of C<64> handles (probably owning to the fact that all windows kernels 4023of C<64> handles (probably owning to the fact that all windows kernels
3961can only wait for C<64> things at the same time internally; Microsoft 4024can only wait for C<64> things at the same time internally; Microsoft
3962recommends spawning a chain of threads and wait for 63 handles and the 4025recommends spawning a chain of threads and wait for 63 handles and the
3963previous thread in each. Great). 4026previous thread in each. Sounds great!).
3964 4027
3965Newer versions support more handles, but you need to define C<FD_SETSIZE> 4028Newer versions support more handles, but you need to define C<FD_SETSIZE>
3966to some high number (e.g. C<2048>) before compiling the winsocket select 4029to some high number (e.g. C<2048>) before compiling the winsocket select
3967call (which might be in libev or elsewhere, for example, perl does its own 4030call (which might be in libev or elsewhere, for example, perl and many
3968select emulation on windows). 4031other interpreters do their own select emulation on windows).
3969 4032
3970Another limit is the number of file descriptors in the Microsoft runtime 4033Another limit is the number of file descriptors in the Microsoft runtime
3971libraries, which by default is C<64> (there must be a hidden I<64> fetish 4034libraries, which by default is C<64> (there must be a hidden I<64>
3972or something like this inside Microsoft). You can increase this by calling 4035fetish or something like this inside Microsoft). You can increase this
3973C<_setmaxstdio>, which can increase this limit to C<2048> (another 4036by calling C<_setmaxstdio>, which can increase this limit to C<2048>
3974arbitrary limit), but is broken in many versions of the Microsoft runtime 4037(another arbitrary limit), but is broken in many versions of the Microsoft
3975libraries.
3976
3977This might get you to about C<512> or C<2048> sockets (depending on 4038runtime libraries. This might get you to about C<512> or C<2048> sockets
3978windows version and/or the phase of the moon). To get more, you need to 4039(depending on windows version and/or the phase of the moon). To get more,
3979wrap all I/O functions and provide your own fd management, but the cost of 4040you need to wrap all I/O functions and provide your own fd management, but
3980calling select (O(n²)) will likely make this unworkable. 4041the cost of calling select (O(n²)) will likely make this unworkable.
3981 4042
3982=back 4043=back
3983 4044
3984=head2 PORTABILITY REQUIREMENTS 4045=head2 PORTABILITY REQUIREMENTS
3985 4046
4028=item C<double> must hold a time value in seconds with enough accuracy 4089=item C<double> must hold a time value in seconds with enough accuracy
4029 4090
4030The type C<double> is used to represent timestamps. It is required to 4091The type C<double> is used to represent timestamps. It is required to
4031have at least 51 bits of mantissa (and 9 bits of exponent), which is good 4092have at least 51 bits of mantissa (and 9 bits of exponent), which is good
4032enough for at least into the year 4000. This requirement is fulfilled by 4093enough for at least into the year 4000. This requirement is fulfilled by
4033implementations implementing IEEE 754 (basically all existing ones). 4094implementations implementing IEEE 754, which is basically all existing
4095ones. With IEEE 754 doubles, you get microsecond accuracy until at least
40962200.
4034 4097
4035=back 4098=back
4036 4099
4037If you know of other additional requirements drop me a note. 4100If you know of other additional requirements drop me a note.
4038 4101

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines