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

Comparing libev/ev.pod (file contents):
Revision 1.239 by root, Tue Apr 21 14:14:19 2009 UTC vs.
Revision 1.253 by root, Tue Jul 14 18:33:48 2009 UTC

620happily wraps around with enough iterations. 620happily wraps around with enough iterations.
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
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.
625 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.
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);
860
861=item ev_invoke_pending (loop)
862
863This call will simply invoke all pending watchers while resetting their
864pending state. Normally, C<ev_loop> does this automatically when required,
865but when overriding the invoke callback this call comes handy.
866
867=item ev_set_invoke_pending_cb (loop, void (*invoke_pending_cb)(EV_P))
868
869This overrides the invoke pending functionality of the loop: Instead of
870invoking all pending watchers when there are any, C<ev_loop> will call
871this callback instead. This is useful, for example, when you want to
872invoke the actual watchers inside another context (another thread etc.).
873
874If you want to reset the callback, use C<ev_invoke_pending> as new
875callback.
876
877=item ev_set_loop_release_cb (loop, void (*release)(EV_P), void (*acquire)(EV_P))
878
879Sometimes you want to share the same loop between multiple threads. This
880can be done relatively simply by putting mutex_lock/unlock calls around
881each call to a libev function.
882
883However, C<ev_loop> can run an indefinite time, so it is not feasible to
884wait for it to return. One way around this is to wake up the loop via
885C<ev_unloop> and C<av_async_send>, another way is to set these I<release>
886and I<acquire> callbacks on the loop.
887
888When set, then C<release> will be called just before the thread is
889suspended waiting for new events, and C<acquire> is called just
890afterwards.
891
892Ideally, C<release> will just call your mutex_unlock function, and
893C<acquire> will just call the mutex_lock function again.
894
895=item ev_set_userdata (loop, void *data)
896
897=item ev_userdata (loop)
898
899Set and retrieve a single C<void *> associated with a loop. When
900C<ev_set_userdata> has never been called, then C<ev_userdata> returns
901C<0.>
902
903These two functions can be used to associate arbitrary data with a loop,
904and are intended solely for the C<invoke_pending_cb>, C<release> and
905C<acquire> callbacks described above, but of course can be (ab-)used for
906any other purpose as well.
836 907
837=item ev_loop_verify (loop) 908=item ev_loop_verify (loop)
838 909
839This function only does something when C<EV_VERIFY> support has been 910This 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 911compiled in, which is the default for non-minimal builds. It tries to go
1184 #include <stddef.h> 1255 #include <stddef.h>
1185 1256
1186 static void 1257 static void
1187 t1_cb (EV_P_ ev_timer *w, int revents) 1258 t1_cb (EV_P_ ev_timer *w, int revents)
1188 { 1259 {
1189 struct my_biggy big = (struct my_biggy * 1260 struct my_biggy big = (struct my_biggy *)
1190 (((char *)w) - offsetof (struct my_biggy, t1)); 1261 (((char *)w) - offsetof (struct my_biggy, t1));
1191 } 1262 }
1192 1263
1193 static void 1264 static void
1194 t2_cb (EV_P_ ev_timer *w, int revents) 1265 t2_cb (EV_P_ ev_timer *w, int revents)
1195 { 1266 {
1196 struct my_biggy big = (struct my_biggy * 1267 struct my_biggy big = (struct my_biggy *)
1197 (((char *)w) - offsetof (struct my_biggy, t2)); 1268 (((char *)w) - offsetof (struct my_biggy, t2));
1198 } 1269 }
1199 1270
1200=head2 WATCHER PRIORITY MODELS 1271=head2 WATCHER PRIORITY MODELS
1201 1272
1277 // with the default priority are receiving events. 1348 // with the default priority are receiving events.
1278 ev_idle_start (EV_A_ &idle); 1349 ev_idle_start (EV_A_ &idle);
1279 } 1350 }
1280 1351
1281 static void 1352 static void
1282 idle-cb (EV_P_ ev_idle *w, int revents) 1353 idle_cb (EV_P_ ev_idle *w, int revents)
1283 { 1354 {
1284 // actual processing 1355 // actual processing
1285 read (STDIN_FILENO, ...); 1356 read (STDIN_FILENO, ...);
1286 1357
1287 // have to start the I/O watcher again, as 1358 // have to start the I/O watcher again, as
1465year, it will still time out after (roughly) one hour. "Roughly" because 1536year, it will still time out after (roughly) one hour. "Roughly" because
1466detecting time jumps is hard, and some inaccuracies are unavoidable (the 1537detecting time jumps is hard, and some inaccuracies are unavoidable (the
1467monotonic clock option helps a lot here). 1538monotonic clock option helps a lot here).
1468 1539
1469The callback is guaranteed to be invoked only I<after> its timeout has 1540The callback is guaranteed to be invoked only I<after> its timeout has
1470passed. If multiple timers become ready during the same loop iteration 1541passed (not I<at>, so on systems with very low-resolution clocks this
1471then the ones with earlier time-out values are invoked before ones with 1542might introduce a small delay). If multiple timers become ready during the
1472later time-out values (but this is no longer true when a callback calls 1543same loop iteration then the ones with earlier time-out values are invoked
1473C<ev_loop> recursively). 1544before ones of the same priority with later time-out values (but this is
1545no longer true when a callback calls C<ev_loop> recursively).
1474 1546
1475=head3 Be smart about timeouts 1547=head3 Be smart about timeouts
1476 1548
1477Many real-world problems involve some kind of timeout, usually for error 1549Many real-world problems involve some kind of timeout, usually for error
1478recovery. A typical example is an HTTP request - if the other side hangs, 1550recovery. A typical example is an HTTP request - if the other side hangs,
1522C<after> argument to C<ev_timer_set>, and only ever use the C<repeat> 1594C<after> argument to C<ev_timer_set>, and only ever use the C<repeat>
1523member and C<ev_timer_again>. 1595member and C<ev_timer_again>.
1524 1596
1525At start: 1597At start:
1526 1598
1527 ev_timer_init (timer, callback); 1599 ev_init (timer, callback);
1528 timer->repeat = 60.; 1600 timer->repeat = 60.;
1529 ev_timer_again (loop, timer); 1601 ev_timer_again (loop, timer);
1530 1602
1531Each time there is some activity: 1603Each time there is some activity:
1532 1604
1594 1666
1595To start the timer, simply initialise the watcher and set C<last_activity> 1667To start the timer, simply initialise the watcher and set C<last_activity>
1596to the current time (meaning we just have some activity :), then call the 1668to the current time (meaning we just have some activity :), then call the
1597callback, which will "do the right thing" and start the timer: 1669callback, which will "do the right thing" and start the timer:
1598 1670
1599 ev_timer_init (timer, callback); 1671 ev_init (timer, callback);
1600 last_activity = ev_now (loop); 1672 last_activity = ev_now (loop);
1601 callback (loop, timer, EV_TIMEOUT); 1673 callback (loop, timer, EV_TIMEOUT);
1602 1674
1603And when there is some activity, simply store the current time in 1675And when there is some activity, simply store the current time in
1604C<last_activity>, no libev calls at all: 1676C<last_activity>, no libev calls at all:
2001some child status changes (most typically when a child of yours dies or 2073some child status changes (most typically when a child of yours dies or
2002exits). It is permissible to install a child watcher I<after> the child 2074exits). It is permissible to install a child watcher I<after> the child
2003has been forked (which implies it might have already exited), as long 2075has been forked (which implies it might have already exited), as long
2004as the event loop isn't entered (or is continued from a watcher), i.e., 2076as the event loop isn't entered (or is continued from a watcher), i.e.,
2005forking and then immediately registering a watcher for the child is fine, 2077forking and then immediately registering a watcher for the child is fine,
2006but forking and registering a watcher a few event loop iterations later is 2078but forking and registering a watcher a few event loop iterations later or
2007not. 2079in the next callback invocation is not.
2008 2080
2009Only the default event loop is capable of handling signals, and therefore 2081Only the default event loop is capable of handling signals, and therefore
2010you can only register child watchers in the default event loop. 2082you can only register child watchers in the default event loop.
2083
2084Due to some design glitches inside libev, child watchers will always be
2085handled at maximum priority (their priority is set to C<EV_MAXPRI> by
2086libev)
2011 2087
2012=head3 Process Interaction 2088=head3 Process Interaction
2013 2089
2014Libev grabs C<SIGCHLD> as soon as the default event loop is 2090Libev grabs C<SIGCHLD> as soon as the default event loop is
2015initialised. This is necessary to guarantee proper behaviour even if 2091initialised. This is necessary to guarantee proper behaviour even if
2367 // no longer anything immediate to do. 2443 // no longer anything immediate to do.
2368 } 2444 }
2369 2445
2370 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2446 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2371 ev_idle_init (idle_watcher, idle_cb); 2447 ev_idle_init (idle_watcher, idle_cb);
2372 ev_idle_start (loop, idle_cb); 2448 ev_idle_start (loop, idle_watcher);
2373 2449
2374 2450
2375=head2 C<ev_prepare> and C<ev_check> - customise your event loop! 2451=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
2376 2452
2377Prepare and check watchers are usually (but not always) used in pairs: 2453Prepare and check watchers are usually (but not always) used in pairs:
2470 struct pollfd fds [nfd]; 2546 struct pollfd fds [nfd];
2471 // actual code will need to loop here and realloc etc. 2547 // actual code will need to loop here and realloc etc.
2472 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 2548 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
2473 2549
2474 /* the callback is illegal, but won't be called as we stop during check */ 2550 /* the callback is illegal, but won't be called as we stop during check */
2475 ev_timer_init (&tw, 0, timeout * 1e-3); 2551 ev_timer_init (&tw, 0, timeout * 1e-3, 0.);
2476 ev_timer_start (loop, &tw); 2552 ev_timer_start (loop, &tw);
2477 2553
2478 // create one ev_io per pollfd 2554 // create one ev_io per pollfd
2479 for (int i = 0; i < nfd; ++i) 2555 for (int i = 0; i < nfd; ++i)
2480 { 2556 {
3642defined to be C<0>, then they are not. 3718defined to be C<0>, then they are not.
3643 3719
3644=item EV_MINIMAL 3720=item EV_MINIMAL
3645 3721
3646If you need to shave off some kilobytes of code at the expense of some 3722If you need to shave off some kilobytes of code at the expense of some
3647speed, define this symbol to C<1>. Currently this is used to override some 3723speed (but with the full API), define this symbol to C<1>. Currently this
3648inlining decisions, saves roughly 30% code size on amd64. It also selects a 3724is used to override some inlining decisions, saves roughly 30% code size
3649much smaller 2-heap for timer management over the default 4-heap. 3725on amd64. It also selects a much smaller 2-heap for timer management over
3726the default 4-heap.
3727
3728You can save even more by disabling watcher types you do not need
3729and setting C<EV_MAXPRI> == C<EV_MINPRI>. Also, disabling C<assert>
3730(C<-DNDEBUG>) will usually reduce code size a lot.
3731
3732Defining C<EV_MINIMAL> to C<2> will additionally reduce the core API to
3733provide a bare-bones event library. See C<ev.h> for details on what parts
3734of the API are still available, and do not complain if this subset changes
3735over time.
3650 3736
3651=item EV_PID_HASHSIZE 3737=item EV_PID_HASHSIZE
3652 3738
3653C<ev_child> watchers use a small hash table to distribute workload by 3739C<ev_child> watchers use a small hash table to distribute workload by
3654pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 3740pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
3840default loop and triggering an C<ev_async> watcher from the default loop 3926default loop and triggering an C<ev_async> watcher from the default loop
3841watcher callback into the event loop interested in the signal. 3927watcher callback into the event loop interested in the signal.
3842 3928
3843=back 3929=back
3844 3930
3931=head4 THREAD LOCKING EXAMPLE
3932
3845=head3 COROUTINES 3933=head3 COROUTINES
3846 3934
3847Libev is very accommodating to coroutines ("cooperative threads"): 3935Libev is very accommodating to coroutines ("cooperative threads"):
3848libev fully supports nesting calls to its functions from different 3936libev fully supports nesting calls to its functions from different
3849coroutines (e.g. you can call C<ev_loop> on the same loop from two 3937coroutines (e.g. you can call C<ev_loop> on the same loop from two
3934way (note also that glib is the slowest event library known to man). 4022way (note also that glib is the slowest event library known to man).
3935 4023
3936There is no supported compilation method available on windows except 4024There is no supported compilation method available on windows except
3937embedding it into other applications. 4025embedding it into other applications.
3938 4026
4027Sensible signal handling is officially unsupported by Microsoft - libev
4028tries its best, but under most conditions, signals will simply not work.
4029
3939Not a libev limitation but worth mentioning: windows apparently doesn't 4030Not a libev limitation but worth mentioning: windows apparently doesn't
3940accept large writes: instead of resulting in a partial write, windows will 4031accept large writes: instead of resulting in a partial write, windows will
3941either accept everything or return C<ENOBUFS> if the buffer is too large, 4032either accept everything or return C<ENOBUFS> if the buffer is too large,
3942so make sure you only write small amounts into your sockets (less than a 4033so make sure you only write small amounts into your sockets (less than a
3943megabyte seems safe, but this apparently depends on the amount of memory 4034megabyte seems safe, but this apparently depends on the amount of memory
3947the abysmal performance of winsockets, using a large number of sockets 4038the abysmal performance of winsockets, using a large number of sockets
3948is not recommended (and not reasonable). If your program needs to use 4039is not recommended (and not reasonable). If your program needs to use
3949more than a hundred or so sockets, then likely it needs to use a totally 4040more than a hundred or so sockets, then likely it needs to use a totally
3950different implementation for windows, as libev offers the POSIX readiness 4041different implementation for windows, as libev offers the POSIX readiness
3951notification model, which cannot be implemented efficiently on windows 4042notification model, which cannot be implemented efficiently on windows
3952(Microsoft monopoly games). 4043(due to Microsoft monopoly games).
3953 4044
3954A typical way to use libev under windows is to embed it (see the embedding 4045A typical way to use libev under windows is to embed it (see the embedding
3955section for details) and use the following F<evwrap.h> header file instead 4046section for details) and use the following F<evwrap.h> header file instead
3956of F<ev.h>: 4047of F<ev.h>:
3957 4048
3993 4084
3994Early versions of winsocket's select only supported waiting for a maximum 4085Early versions of winsocket's select only supported waiting for a maximum
3995of C<64> handles (probably owning to the fact that all windows kernels 4086of C<64> handles (probably owning to the fact that all windows kernels
3996can only wait for C<64> things at the same time internally; Microsoft 4087can only wait for C<64> things at the same time internally; Microsoft
3997recommends spawning a chain of threads and wait for 63 handles and the 4088recommends spawning a chain of threads and wait for 63 handles and the
3998previous thread in each. Great). 4089previous thread in each. Sounds great!).
3999 4090
4000Newer versions support more handles, but you need to define C<FD_SETSIZE> 4091Newer versions support more handles, but you need to define C<FD_SETSIZE>
4001to some high number (e.g. C<2048>) before compiling the winsocket select 4092to some high number (e.g. C<2048>) before compiling the winsocket select
4002call (which might be in libev or elsewhere, for example, perl does its own 4093call (which might be in libev or elsewhere, for example, perl and many
4003select emulation on windows). 4094other interpreters do their own select emulation on windows).
4004 4095
4005Another limit is the number of file descriptors in the Microsoft runtime 4096Another limit is the number of file descriptors in the Microsoft runtime
4006libraries, which by default is C<64> (there must be a hidden I<64> fetish 4097libraries, which by default is C<64> (there must be a hidden I<64>
4007or something like this inside Microsoft). You can increase this by calling 4098fetish or something like this inside Microsoft). You can increase this
4008C<_setmaxstdio>, which can increase this limit to C<2048> (another 4099by calling C<_setmaxstdio>, which can increase this limit to C<2048>
4009arbitrary limit), but is broken in many versions of the Microsoft runtime 4100(another arbitrary limit), but is broken in many versions of the Microsoft
4010libraries.
4011
4012This might get you to about C<512> or C<2048> sockets (depending on 4101runtime libraries. This might get you to about C<512> or C<2048> sockets
4013windows version and/or the phase of the moon). To get more, you need to 4102(depending on windows version and/or the phase of the moon). To get more,
4014wrap all I/O functions and provide your own fd management, but the cost of 4103you need to wrap all I/O functions and provide your own fd management, but
4015calling select (O(n²)) will likely make this unworkable. 4104the cost of calling select (O(n²)) will likely make this unworkable.
4016 4105
4017=back 4106=back
4018 4107
4019=head2 PORTABILITY REQUIREMENTS 4108=head2 PORTABILITY REQUIREMENTS
4020 4109
4063=item C<double> must hold a time value in seconds with enough accuracy 4152=item C<double> must hold a time value in seconds with enough accuracy
4064 4153
4065The type C<double> is used to represent timestamps. It is required to 4154The type C<double> is used to represent timestamps. It is required to
4066have at least 51 bits of mantissa (and 9 bits of exponent), which is good 4155have at least 51 bits of mantissa (and 9 bits of exponent), which is good
4067enough for at least into the year 4000. This requirement is fulfilled by 4156enough for at least into the year 4000. This requirement is fulfilled by
4068implementations implementing IEEE 754 (basically all existing ones). 4157implementations implementing IEEE 754, which is basically all existing
4158ones. With IEEE 754 doubles, you get microsecond accuracy until at least
41592200.
4069 4160
4070=back 4161=back
4071 4162
4072If you know of other additional requirements drop me a note. 4163If you know of other additional requirements drop me a note.
4073 4164

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines