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

Comparing libev/ev.pod (file contents):
Revision 1.238 by root, Sat Apr 18 12:10:41 2009 UTC vs.
Revision 1.246 by root, Thu Jul 2 12:08:55 2009 UTC

811 811
812By setting a higher I<io collect interval> you allow libev to spend more 812By 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, 813time collecting I/O events, so you can handle more events per iteration,
814at the cost of increasing latency. Timeouts (both C<ev_periodic> and 814at 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 815C<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. 816introduce an additional C<ev_sleep ()> call into most loop iterations. The
817sleep time ensures that libev will not poll for I/O events more often then
818once per this interval, on average.
817 819
818Likewise, by setting a higher I<timeout collect interval> you allow libev 820Likewise, by setting a higher I<timeout collect interval> you allow libev
819to spend more time collecting timeouts, at the expense of increased 821to spend more time collecting timeouts, at the expense of increased
820latency/jitter/inexactness (the watcher callback will be called 822latency/jitter/inexactness (the watcher callback will be called
821later). C<ev_io> watchers will not be affected. Setting this to a non-null 823later). C<ev_io> watchers will not be affected. Setting this to a non-null
823 825
824Many (busy) programs can usually benefit by setting the I/O collect 826Many (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 827interval 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 828interactive 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>, 829usually 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. 830as this approaches the timing granularity of most systems. Note that if
831you do transactions with the outside world and you can't increase the
832parallelity, then this setting will limit your transaction rate (if you
833need to poll once per transaction and the I/O collect interval is 0.01,
834then you can't do more than 100 transations per second).
829 835
830Setting the I<timeout collect interval> can improve the opportunity for 836Setting the I<timeout collect interval> can improve the opportunity for
831saving power, as the program will "bundle" timer callback invocations that 837saving power, as the program will "bundle" timer callback invocations that
832are "near" in time together, by delaying some, thus reducing the number of 838are "near" in time together, by delaying some, thus reducing the number of
833times the process sleeps and wakes up again. Another useful technique to 839times 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 840reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure
835they fire on, say, one-second boundaries only. 841they fire on, say, one-second boundaries only.
842
843Example: we only need 0.1s timeout granularity, and we wish not to poll
844more often than 100 times per second:
845
846 ev_set_timeout_collect_interval (EV_DEFAULT_UC_ 0.1);
847 ev_set_io_collect_interval (EV_DEFAULT_UC_ 0.01);
836 848
837=item ev_loop_verify (loop) 849=item ev_loop_verify (loop)
838 850
839This function only does something when C<EV_VERIFY> support has been 851This 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 852compiled in, which is the default for non-minimal builds. It tries to go
1184 #include <stddef.h> 1196 #include <stddef.h>
1185 1197
1186 static void 1198 static void
1187 t1_cb (EV_P_ ev_timer *w, int revents) 1199 t1_cb (EV_P_ ev_timer *w, int revents)
1188 { 1200 {
1189 struct my_biggy big = (struct my_biggy * 1201 struct my_biggy big = (struct my_biggy *)
1190 (((char *)w) - offsetof (struct my_biggy, t1)); 1202 (((char *)w) - offsetof (struct my_biggy, t1));
1191 } 1203 }
1192 1204
1193 static void 1205 static void
1194 t2_cb (EV_P_ ev_timer *w, int revents) 1206 t2_cb (EV_P_ ev_timer *w, int revents)
1195 { 1207 {
1196 struct my_biggy big = (struct my_biggy * 1208 struct my_biggy big = (struct my_biggy *)
1197 (((char *)w) - offsetof (struct my_biggy, t2)); 1209 (((char *)w) - offsetof (struct my_biggy, t2));
1198 } 1210 }
1199 1211
1200=head2 WATCHER PRIORITY MODELS 1212=head2 WATCHER PRIORITY MODELS
1201 1213
1277 // with the default priority are receiving events. 1289 // with the default priority are receiving events.
1278 ev_idle_start (EV_A_ &idle); 1290 ev_idle_start (EV_A_ &idle);
1279 } 1291 }
1280 1292
1281 static void 1293 static void
1282 idle-cb (EV_P_ ev_idle *w, int revents) 1294 idle_cb (EV_P_ ev_idle *w, int revents)
1283 { 1295 {
1284 // actual processing 1296 // actual processing
1285 read (STDIN_FILENO, ...); 1297 read (STDIN_FILENO, ...);
1286 1298
1287 // have to start the I/O watcher again, as 1299 // have to start the I/O watcher again, as
1332descriptors to non-blocking mode is also usually a good idea (but not 1344descriptors to non-blocking mode is also usually a good idea (but not
1333required if you know what you are doing). 1345required if you know what you are doing).
1334 1346
1335If you cannot use non-blocking mode, then force the use of a 1347If 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 1348known-to-be-good backend (at the time of this writing, this includes only
1337C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). 1349C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). The same applies to file
1350descriptors for which non-blocking operation makes no sense (such as
1351files) - libev doesn't guarentee any specific behaviour in that case.
1338 1352
1339Another thing you have to watch out for is that it is quite easy to 1353Another thing you have to watch out for is that it is quite easy to
1340receive "spurious" readiness notifications, that is your callback might 1354receive "spurious" readiness notifications, that is your callback might
1341be called with C<EV_READ> but a subsequent C<read>(2) will actually block 1355be 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 1356because 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 1477year, it will still time out after (roughly) one hour. "Roughly" because
1464detecting time jumps is hard, and some inaccuracies are unavoidable (the 1478detecting time jumps is hard, and some inaccuracies are unavoidable (the
1465monotonic clock option helps a lot here). 1479monotonic clock option helps a lot here).
1466 1480
1467The callback is guaranteed to be invoked only I<after> its timeout has 1481The callback is guaranteed to be invoked only I<after> its timeout has
1468passed. If multiple timers become ready during the same loop iteration 1482passed (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 1483might introduce a small delay). If multiple timers become ready during the
1484same 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 1485before ones with later time-out values (but this is no longer true when a
1471C<ev_loop> recursively). 1486callback calls C<ev_loop> recursively).
1472 1487
1473=head3 Be smart about timeouts 1488=head3 Be smart about timeouts
1474 1489
1475Many real-world problems involve some kind of timeout, usually for error 1490Many real-world problems involve some kind of timeout, usually for error
1476recovery. A typical example is an HTTP request - if the other side hangs, 1491recovery. 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> 1535C<after> argument to C<ev_timer_set>, and only ever use the C<repeat>
1521member and C<ev_timer_again>. 1536member and C<ev_timer_again>.
1522 1537
1523At start: 1538At start:
1524 1539
1525 ev_timer_init (timer, callback); 1540 ev_init (timer, callback);
1526 timer->repeat = 60.; 1541 timer->repeat = 60.;
1527 ev_timer_again (loop, timer); 1542 ev_timer_again (loop, timer);
1528 1543
1529Each time there is some activity: 1544Each time there is some activity:
1530 1545
1592 1607
1593To start the timer, simply initialise the watcher and set C<last_activity> 1608To 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 1609to the current time (meaning we just have some activity :), then call the
1595callback, which will "do the right thing" and start the timer: 1610callback, which will "do the right thing" and start the timer:
1596 1611
1597 ev_timer_init (timer, callback); 1612 ev_init (timer, callback);
1598 last_activity = ev_now (loop); 1613 last_activity = ev_now (loop);
1599 callback (loop, timer, EV_TIMEOUT); 1614 callback (loop, timer, EV_TIMEOUT);
1600 1615
1601And when there is some activity, simply store the current time in 1616And when there is some activity, simply store the current time in
1602C<last_activity>, no libev calls at all: 1617C<last_activity>, no libev calls at all:
1999some child status changes (most typically when a child of yours dies or 2014some 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 2015exits). It is permissible to install a child watcher I<after> the child
2001has been forked (which implies it might have already exited), as long 2016has 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., 2017as 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, 2018forking and then immediately registering a watcher for the child is fine,
2004but forking and registering a watcher a few event loop iterations later is 2019but forking and registering a watcher a few event loop iterations later or
2005not. 2020in the next callback invocation is not.
2006 2021
2007Only the default event loop is capable of handling signals, and therefore 2022Only the default event loop is capable of handling signals, and therefore
2008you can only register child watchers in the default event loop. 2023you can only register child watchers in the default event loop.
2009 2024
2010=head3 Process Interaction 2025=head3 Process Interaction
2365 // no longer anything immediate to do. 2380 // no longer anything immediate to do.
2366 } 2381 }
2367 2382
2368 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2383 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2369 ev_idle_init (idle_watcher, idle_cb); 2384 ev_idle_init (idle_watcher, idle_cb);
2370 ev_idle_start (loop, idle_cb); 2385 ev_idle_start (loop, idle_watcher);
2371 2386
2372 2387
2373=head2 C<ev_prepare> and C<ev_check> - customise your event loop! 2388=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
2374 2389
2375Prepare and check watchers are usually (but not always) used in pairs: 2390Prepare and check watchers are usually (but not always) used in pairs:
2468 struct pollfd fds [nfd]; 2483 struct pollfd fds [nfd];
2469 // actual code will need to loop here and realloc etc. 2484 // actual code will need to loop here and realloc etc.
2470 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 2485 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
2471 2486
2472 /* the callback is illegal, but won't be called as we stop during check */ 2487 /* the callback is illegal, but won't be called as we stop during check */
2473 ev_timer_init (&tw, 0, timeout * 1e-3); 2488 ev_timer_init (&tw, 0, timeout * 1e-3, 0.);
2474 ev_timer_start (loop, &tw); 2489 ev_timer_start (loop, &tw);
2475 2490
2476 // create one ev_io per pollfd 2491 // create one ev_io per pollfd
2477 for (int i = 0; i < nfd; ++i) 2492 for (int i = 0; i < nfd; ++i)
2478 { 2493 {
3932way (note also that glib is the slowest event library known to man). 3947way (note also that glib is the slowest event library known to man).
3933 3948
3934There is no supported compilation method available on windows except 3949There is no supported compilation method available on windows except
3935embedding it into other applications. 3950embedding it into other applications.
3936 3951
3952Sensible signal handling is officially unsupported by Microsoft - libev
3953tries its best, but under most conditions, signals will simply not work.
3954
3937Not a libev limitation but worth mentioning: windows apparently doesn't 3955Not a libev limitation but worth mentioning: windows apparently doesn't
3938accept large writes: instead of resulting in a partial write, windows will 3956accept large writes: instead of resulting in a partial write, windows will
3939either accept everything or return C<ENOBUFS> if the buffer is too large, 3957either accept everything or return C<ENOBUFS> if the buffer is too large,
3940so make sure you only write small amounts into your sockets (less than a 3958so make sure you only write small amounts into your sockets (less than a
3941megabyte seems safe, but this apparently depends on the amount of memory 3959megabyte seems safe, but this apparently depends on the amount of memory
3945the abysmal performance of winsockets, using a large number of sockets 3963the abysmal performance of winsockets, using a large number of sockets
3946is not recommended (and not reasonable). If your program needs to use 3964is not recommended (and not reasonable). If your program needs to use
3947more than a hundred or so sockets, then likely it needs to use a totally 3965more than a hundred or so sockets, then likely it needs to use a totally
3948different implementation for windows, as libev offers the POSIX readiness 3966different implementation for windows, as libev offers the POSIX readiness
3949notification model, which cannot be implemented efficiently on windows 3967notification model, which cannot be implemented efficiently on windows
3950(Microsoft monopoly games). 3968(due to Microsoft monopoly games).
3951 3969
3952A typical way to use libev under windows is to embed it (see the embedding 3970A typical way to use libev under windows is to embed it (see the embedding
3953section for details) and use the following F<evwrap.h> header file instead 3971section for details) and use the following F<evwrap.h> header file instead
3954of F<ev.h>: 3972of F<ev.h>:
3955 3973
3991 4009
3992Early versions of winsocket's select only supported waiting for a maximum 4010Early versions of winsocket's select only supported waiting for a maximum
3993of C<64> handles (probably owning to the fact that all windows kernels 4011of C<64> handles (probably owning to the fact that all windows kernels
3994can only wait for C<64> things at the same time internally; Microsoft 4012can only wait for C<64> things at the same time internally; Microsoft
3995recommends spawning a chain of threads and wait for 63 handles and the 4013recommends spawning a chain of threads and wait for 63 handles and the
3996previous thread in each. Great). 4014previous thread in each. Sounds great!).
3997 4015
3998Newer versions support more handles, but you need to define C<FD_SETSIZE> 4016Newer versions support more handles, but you need to define C<FD_SETSIZE>
3999to some high number (e.g. C<2048>) before compiling the winsocket select 4017to some high number (e.g. C<2048>) before compiling the winsocket select
4000call (which might be in libev or elsewhere, for example, perl does its own 4018call (which might be in libev or elsewhere, for example, perl and many
4001select emulation on windows). 4019other interpreters do their own select emulation on windows).
4002 4020
4003Another limit is the number of file descriptors in the Microsoft runtime 4021Another limit is the number of file descriptors in the Microsoft runtime
4004libraries, which by default is C<64> (there must be a hidden I<64> fetish 4022libraries, which by default is C<64> (there must be a hidden I<64>
4005or something like this inside Microsoft). You can increase this by calling 4023fetish or something like this inside Microsoft). You can increase this
4006C<_setmaxstdio>, which can increase this limit to C<2048> (another 4024by calling C<_setmaxstdio>, which can increase this limit to C<2048>
4007arbitrary limit), but is broken in many versions of the Microsoft runtime 4025(another arbitrary limit), but is broken in many versions of the Microsoft
4008libraries.
4009
4010This might get you to about C<512> or C<2048> sockets (depending on 4026runtime libraries. This might get you to about C<512> or C<2048> sockets
4011windows version and/or the phase of the moon). To get more, you need to 4027(depending on windows version and/or the phase of the moon). To get more,
4012wrap all I/O functions and provide your own fd management, but the cost of 4028you need to wrap all I/O functions and provide your own fd management, but
4013calling select (O(n²)) will likely make this unworkable. 4029the cost of calling select (O(n²)) will likely make this unworkable.
4014 4030
4015=back 4031=back
4016 4032
4017=head2 PORTABILITY REQUIREMENTS 4033=head2 PORTABILITY REQUIREMENTS
4018 4034
4061=item C<double> must hold a time value in seconds with enough accuracy 4077=item C<double> must hold a time value in seconds with enough accuracy
4062 4078
4063The type C<double> is used to represent timestamps. It is required to 4079The type C<double> is used to represent timestamps. It is required to
4064have at least 51 bits of mantissa (and 9 bits of exponent), which is good 4080have at least 51 bits of mantissa (and 9 bits of exponent), which is good
4065enough for at least into the year 4000. This requirement is fulfilled by 4081enough for at least into the year 4000. This requirement is fulfilled by
4066implementations implementing IEEE 754 (basically all existing ones). 4082implementations implementing IEEE 754, which is basically all existing
4083ones. With IEEE 754 doubles, you get microsecond accuracy until at least
40842200.
4067 4085
4068=back 4086=back
4069 4087
4070If you know of other additional requirements drop me a note. 4088If you know of other additional requirements drop me a note.
4071 4089

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines