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

Comparing libev/ev.pod (file contents):
Revision 1.228 by root, Sat Mar 28 08:22:30 2009 UTC vs.
Revision 1.253 by root, Tue Jul 14 18:33:48 2009 UTC

62 62
63 // unloop was called, so exit 63 // unloop was called, so exit
64 return 0; 64 return 0;
65 } 65 }
66 66
67=head1 DESCRIPTION 67=head1 ABOUT THIS DOCUMENT
68
69This document documents the libev software package.
68 70
69The newest version of this document is also available as an html-formatted 71The newest version of this document is also available as an html-formatted
70web page you might find easier to navigate when reading it for the first 72web page you might find easier to navigate when reading it for the first
71time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>. 73time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>.
74
75While this document tries to be as complete as possible in documenting
76libev, its usage and the rationale behind its design, it is not a tutorial
77on event-based programming, nor will it introduce event-based programming
78with libev.
79
80Familarity with event based programming techniques in general is assumed
81throughout this document.
82
83=head1 ABOUT LIBEV
72 84
73Libev is an event loop: you register interest in certain events (such as a 85Libev is an event loop: you register interest in certain events (such as a
74file descriptor being readable or a timeout occurring), and it will manage 86file descriptor being readable or a timeout occurring), and it will manage
75these event sources and provide your program with events. 87these event sources and provide your program with events.
76 88
110name C<loop> (which is always of type C<ev_loop *>) will not have 122name C<loop> (which is always of type C<ev_loop *>) will not have
111this argument. 123this argument.
112 124
113=head2 TIME REPRESENTATION 125=head2 TIME REPRESENTATION
114 126
115Libev represents time as a single floating point number, representing the 127Libev represents time as a single floating point number, representing
116(fractional) number of seconds since the (POSIX) epoch (somewhere near 128the (fractional) number of seconds since the (POSIX) epoch (somewhere
117the beginning of 1970, details are complicated, don't ask). This type is 129near the beginning of 1970, details are complicated, don't ask). This
118called C<ev_tstamp>, which is what you should use too. It usually aliases 130type is called C<ev_tstamp>, which is what you should use too. It usually
119to the C<double> type in C, and when you need to do any calculations on 131aliases to the C<double> type in C. When you need to do any calculations
120it, you should treat it as some floating point value. Unlike the name 132on it, you should treat it as some floating point value. Unlike the name
121component C<stamp> might indicate, it is also used for time differences 133component C<stamp> might indicate, it is also used for time differences
122throughout libev. 134throughout libev.
123 135
124=head1 ERROR HANDLING 136=head1 ERROR HANDLING
125 137
609 621
610This 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
611"ticks" the number of loop iterations), as it roughly corresponds with 623"ticks" the number of loop iterations), as it roughly corresponds with
612C<ev_prepare> and C<ev_check> calls. 624C<ev_prepare> and C<ev_check> calls.
613 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
614=item unsigned int ev_backend (loop) 638=item unsigned int ev_backend (loop)
615 639
616Returns one of the C<EVBACKEND_*> flags indicating the event backend in 640Returns one of the C<EVBACKEND_*> flags indicating the event backend in
617use. 641use.
618 642
632 656
633This 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
634very 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
635the current time is a good idea. 659the current time is a good idea.
636 660
637See 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.
662
663=item ev_suspend (loop)
664
665=item ev_resume (loop)
666
667These two functions suspend and resume a loop, for use when the loop is
668not used for a while and timeouts should not be processed.
669
670A typical use case would be an interactive program such as a game: When
671the user presses C<^Z> to suspend the game and resumes it an hour later it
672would be best to handle timeouts as if no time had actually passed while
673the program was suspended. This can be achieved by calling C<ev_suspend>
674in your C<SIGTSTP> handler, sending yourself a C<SIGSTOP> and calling
675C<ev_resume> directly afterwards to resume timer processing.
676
677Effectively, all C<ev_timer> watchers will be delayed by the time spend
678between C<ev_suspend> and C<ev_resume>, and all C<ev_periodic> watchers
679will be rescheduled (that is, they will lose any events that would have
680occured while suspended).
681
682After calling C<ev_suspend> you B<must not> call I<any> function on the
683given loop other than C<ev_resume>, and you B<must not> call C<ev_resume>
684without a previous call to C<ev_suspend>.
685
686Calling C<ev_suspend>/C<ev_resume> has the side effect of updating the
687event loop time (see C<ev_now_update>).
638 688
639=item ev_loop (loop, int flags) 689=item ev_loop (loop, int flags)
640 690
641Finally, this is it, the event handler. This function usually is called 691Finally, this is it, the event handler. This function usually is called
642after you initialised all your watchers and you want to start handling 692after you initialised all your watchers and you want to start handling
726 776
727If you have a watcher you never unregister that should not keep C<ev_loop> 777If you have a watcher you never unregister that should not keep C<ev_loop>
728from returning, call ev_unref() after starting, and ev_ref() before 778from returning, call ev_unref() after starting, and ev_ref() before
729stopping it. 779stopping it.
730 780
731As an example, libev itself uses this for its internal signal pipe: It is 781As an example, libev itself uses this for its internal signal pipe: It
732not visible to the libev user and should not keep C<ev_loop> from exiting 782is not visible to the libev user and should not keep C<ev_loop> from
733if no event watchers registered by it are active. It is also an excellent 783exiting if no event watchers registered by it are active. It is also an
734way to do this for generic recurring timers or from within third-party 784excellent way to do this for generic recurring timers or from within
735libraries. Just remember to I<unref after start> and I<ref before stop> 785third-party libraries. Just remember to I<unref after start> and I<ref
736(but only if the watcher wasn't active before, or was active before, 786before stop> (but only if the watcher wasn't active before, or was active
737respectively). 787before, respectively. Note also that libev might stop watchers itself
788(e.g. non-repeating timers) in which case you have to C<ev_ref>
789in the callback).
738 790
739Example: Create a signal watcher, but keep it from keeping C<ev_loop> 791Example: Create a signal watcher, but keep it from keeping C<ev_loop>
740running when nothing else is active. 792running when nothing else is active.
741 793
742 ev_signal exitsig; 794 ev_signal exitsig;
771 823
772By 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
773time 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,
774at the cost of increasing latency. Timeouts (both C<ev_periodic> and 826at the cost of increasing latency. Timeouts (both C<ev_periodic> and
775C<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
776introduce 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.
777 831
778Likewise, by setting a higher I<timeout collect interval> you allow libev 832Likewise, by setting a higher I<timeout collect interval> you allow libev
779to spend more time collecting timeouts, at the expense of increased 833to spend more time collecting timeouts, at the expense of increased
780latency/jitter/inexactness (the watcher callback will be called 834latency/jitter/inexactness (the watcher callback will be called
781later). 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
783 837
784Many (busy) programs can usually benefit by setting the I/O collect 838Many (busy) programs can usually benefit by setting the I/O collect
785interval 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
786interactive servers (of course not for games), likewise for timeouts. It 840interactive servers (of course not for games), likewise for timeouts. It
787usually 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>,
788as 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).
789 847
790Setting the I<timeout collect interval> can improve the opportunity for 848Setting the I<timeout collect interval> can improve the opportunity for
791saving power, as the program will "bundle" timer callback invocations that 849saving power, as the program will "bundle" timer callback invocations that
792are "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
793times the process sleeps and wakes up again. Another useful technique to 851times the process sleeps and wakes up again. Another useful technique to
794reduce 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
795they 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.
796 907
797=item ev_loop_verify (loop) 908=item ev_loop_verify (loop)
798 909
799This function only does something when C<EV_VERIFY> support has been 910This function only does something when C<EV_VERIFY> support has been
800compiled 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
926 1037
927=item C<EV_ASYNC> 1038=item C<EV_ASYNC>
928 1039
929The given async watcher has been asynchronously notified (see C<ev_async>). 1040The given async watcher has been asynchronously notified (see C<ev_async>).
930 1041
1042=item C<EV_CUSTOM>
1043
1044Not ever sent (or otherwise used) by libev itself, but can be freely used
1045by libev users to signal watchers (e.g. via C<ev_feed_event>).
1046
931=item C<EV_ERROR> 1047=item C<EV_ERROR>
932 1048
933An unspecified error has occurred, the watcher has been stopped. This might 1049An unspecified error has occurred, the watcher has been stopped. This might
934happen because the watcher could not be properly started because libev 1050happen because the watcher could not be properly started because libev
935ran out of memory, a file descriptor was found to be closed or any other 1051ran out of memory, a file descriptor was found to be closed or any other
1050integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI> 1166integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI>
1051(default: C<-2>). Pending watchers with higher priority will be invoked 1167(default: C<-2>). Pending watchers with higher priority will be invoked
1052before watchers with lower priority, but priority will not keep watchers 1168before watchers with lower priority, but priority will not keep watchers
1053from being executed (except for C<ev_idle> watchers). 1169from being executed (except for C<ev_idle> watchers).
1054 1170
1055This means that priorities are I<only> used for ordering callback
1056invocation after new events have been received. This is useful, for
1057example, to reduce latency after idling, or more often, to bind two
1058watchers on the same event and make sure one is called first.
1059
1060If you need to suppress invocation when higher priority events are pending 1171If you need to suppress invocation when higher priority events are pending
1061you need to look at C<ev_idle> watchers, which provide this functionality. 1172you need to look at C<ev_idle> watchers, which provide this functionality.
1062 1173
1063You I<must not> change the priority of a watcher as long as it is active or 1174You I<must not> change the priority of a watcher as long as it is active or
1064pending. 1175pending.
1065
1066The default priority used by watchers when no priority has been set is
1067always C<0>, which is supposed to not be too high and not be too low :).
1068 1176
1069Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is 1177Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is
1070fine, as long as you do not mind that the priority value you query might 1178fine, as long as you do not mind that the priority value you query might
1071or might not have been clamped to the valid range. 1179or might not have been clamped to the valid range.
1180
1181The default priority used by watchers when no priority has been set is
1182always C<0>, which is supposed to not be too high and not be too low :).
1183
1184See L<WATCHER PRIORITY MODELS>, below, for a more thorough treatment of
1185priorities.
1072 1186
1073=item ev_invoke (loop, ev_TYPE *watcher, int revents) 1187=item ev_invoke (loop, ev_TYPE *watcher, int revents)
1074 1188
1075Invoke the C<watcher> with the given C<loop> and C<revents>. Neither 1189Invoke the C<watcher> with the given C<loop> and C<revents>. Neither
1076C<loop> nor C<revents> need to be valid as long as the watcher callback 1190C<loop> nor C<revents> need to be valid as long as the watcher callback
1141 #include <stddef.h> 1255 #include <stddef.h>
1142 1256
1143 static void 1257 static void
1144 t1_cb (EV_P_ ev_timer *w, int revents) 1258 t1_cb (EV_P_ ev_timer *w, int revents)
1145 { 1259 {
1146 struct my_biggy big = (struct my_biggy * 1260 struct my_biggy big = (struct my_biggy *)
1147 (((char *)w) - offsetof (struct my_biggy, t1)); 1261 (((char *)w) - offsetof (struct my_biggy, t1));
1148 } 1262 }
1149 1263
1150 static void 1264 static void
1151 t2_cb (EV_P_ ev_timer *w, int revents) 1265 t2_cb (EV_P_ ev_timer *w, int revents)
1152 { 1266 {
1153 struct my_biggy big = (struct my_biggy * 1267 struct my_biggy big = (struct my_biggy *)
1154 (((char *)w) - offsetof (struct my_biggy, t2)); 1268 (((char *)w) - offsetof (struct my_biggy, t2));
1155 } 1269 }
1270
1271=head2 WATCHER PRIORITY MODELS
1272
1273Many event loops support I<watcher priorities>, which are usually small
1274integers that influence the ordering of event callback invocation
1275between watchers in some way, all else being equal.
1276
1277In libev, Watcher priorities can be set using C<ev_set_priority>. See its
1278description for the more technical details such as the actual priority
1279range.
1280
1281There are two common ways how these these priorities are being interpreted
1282by event loops:
1283
1284In the more common lock-out model, higher priorities "lock out" invocation
1285of lower priority watchers, which means as long as higher priority
1286watchers receive events, lower priority watchers are not being invoked.
1287
1288The less common only-for-ordering model uses priorities solely to order
1289callback invocation within a single event loop iteration: Higher priority
1290watchers are invoked before lower priority ones, but they all get invoked
1291before polling for new events.
1292
1293Libev uses the second (only-for-ordering) model for all its watchers
1294except for idle watchers (which use the lock-out model).
1295
1296The rationale behind this is that implementing the lock-out model for
1297watchers is not well supported by most kernel interfaces, and most event
1298libraries will just poll for the same events again and again as long as
1299their callbacks have not been executed, which is very inefficient in the
1300common case of one high-priority watcher locking out a mass of lower
1301priority ones.
1302
1303Static (ordering) priorities are most useful when you have two or more
1304watchers handling the same resource: a typical usage example is having an
1305C<ev_io> watcher to receive data, and an associated C<ev_timer> to handle
1306timeouts. Under load, data might be received while the program handles
1307other jobs, but since timers normally get invoked first, the timeout
1308handler will be executed before checking for data. In that case, giving
1309the timer a lower priority than the I/O watcher ensures that I/O will be
1310handled first even under adverse conditions (which is usually, but not
1311always, what you want).
1312
1313Since idle watchers use the "lock-out" model, meaning that idle watchers
1314will only be executed when no same or higher priority watchers have
1315received events, they can be used to implement the "lock-out" model when
1316required.
1317
1318For example, to emulate how many other event libraries handle priorities,
1319you can associate an C<ev_idle> watcher to each such watcher, and in
1320the normal watcher callback, you just start the idle watcher. The real
1321processing is done in the idle watcher callback. This causes libev to
1322continously poll and process kernel event data for the watcher, but when
1323the lock-out case is known to be rare (which in turn is rare :), this is
1324workable.
1325
1326Usually, however, the lock-out model implemented that way will perform
1327miserably under the type of load it was designed to handle. In that case,
1328it might be preferable to stop the real watcher before starting the
1329idle watcher, so the kernel will not have to process the event in case
1330the actual processing will be delayed for considerable time.
1331
1332Here is an example of an I/O watcher that should run at a strictly lower
1333priority than the default, and which should only process data when no
1334other events are pending:
1335
1336 ev_idle idle; // actual processing watcher
1337 ev_io io; // actual event watcher
1338
1339 static void
1340 io_cb (EV_P_ ev_io *w, int revents)
1341 {
1342 // stop the I/O watcher, we received the event, but
1343 // are not yet ready to handle it.
1344 ev_io_stop (EV_A_ w);
1345
1346 // start the idle watcher to ahndle the actual event.
1347 // it will not be executed as long as other watchers
1348 // with the default priority are receiving events.
1349 ev_idle_start (EV_A_ &idle);
1350 }
1351
1352 static void
1353 idle_cb (EV_P_ ev_idle *w, int revents)
1354 {
1355 // actual processing
1356 read (STDIN_FILENO, ...);
1357
1358 // have to start the I/O watcher again, as
1359 // we have handled the event
1360 ev_io_start (EV_P_ &io);
1361 }
1362
1363 // initialisation
1364 ev_idle_init (&idle, idle_cb);
1365 ev_io_init (&io, io_cb, STDIN_FILENO, EV_READ);
1366 ev_io_start (EV_DEFAULT_ &io);
1367
1368In the "real" world, it might also be beneficial to start a timer, so that
1369low-priority connections can not be locked out forever under load. This
1370enables your program to keep a lower latency for important connections
1371during short periods of high load, while not completely locking out less
1372important ones.
1156 1373
1157 1374
1158=head1 WATCHER TYPES 1375=head1 WATCHER TYPES
1159 1376
1160This section describes each watcher in detail, but will not repeat 1377This section describes each watcher in detail, but will not repeat
1186descriptors to non-blocking mode is also usually a good idea (but not 1403descriptors to non-blocking mode is also usually a good idea (but not
1187required if you know what you are doing). 1404required if you know what you are doing).
1188 1405
1189If you cannot use non-blocking mode, then force the use of a 1406If you cannot use non-blocking mode, then force the use of a
1190known-to-be-good backend (at the time of this writing, this includes only 1407known-to-be-good backend (at the time of this writing, this includes only
1191C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). 1408C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). The same applies to file
1409descriptors for which non-blocking operation makes no sense (such as
1410files) - libev doesn't guarentee any specific behaviour in that case.
1192 1411
1193Another thing you have to watch out for is that it is quite easy to 1412Another thing you have to watch out for is that it is quite easy to
1194receive "spurious" readiness notifications, that is your callback might 1413receive "spurious" readiness notifications, that is your callback might
1195be called with C<EV_READ> but a subsequent C<read>(2) will actually block 1414be called with C<EV_READ> but a subsequent C<read>(2) will actually block
1196because there is no data. Not only are some backends known to create a 1415because there is no data. Not only are some backends known to create a
1317year, it will still time out after (roughly) one hour. "Roughly" because 1536year, it will still time out after (roughly) one hour. "Roughly" because
1318detecting time jumps is hard, and some inaccuracies are unavoidable (the 1537detecting time jumps is hard, and some inaccuracies are unavoidable (the
1319monotonic clock option helps a lot here). 1538monotonic clock option helps a lot here).
1320 1539
1321The 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
1322passed, but if multiple timers become ready during the same loop iteration 1541passed (not I<at>, so on systems with very low-resolution clocks this
1323then order of execution is undefined. 1542might introduce a small delay). If multiple timers become ready during the
1543same loop iteration then the ones with earlier time-out values are invoked
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).
1324 1546
1325=head3 Be smart about timeouts 1547=head3 Be smart about timeouts
1326 1548
1327Many real-world problems involve some kind of timeout, usually for error 1549Many real-world problems involve some kind of timeout, usually for error
1328recovery. 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,
1372C<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>
1373member and C<ev_timer_again>. 1595member and C<ev_timer_again>.
1374 1596
1375At start: 1597At start:
1376 1598
1377 ev_timer_init (timer, callback); 1599 ev_init (timer, callback);
1378 timer->repeat = 60.; 1600 timer->repeat = 60.;
1379 ev_timer_again (loop, timer); 1601 ev_timer_again (loop, timer);
1380 1602
1381Each time there is some activity: 1603Each time there is some activity:
1382 1604
1444 1666
1445To 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>
1446to 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
1447callback, which will "do the right thing" and start the timer: 1669callback, which will "do the right thing" and start the timer:
1448 1670
1449 ev_timer_init (timer, callback); 1671 ev_init (timer, callback);
1450 last_activity = ev_now (loop); 1672 last_activity = ev_now (loop);
1451 callback (loop, timer, EV_TIMEOUT); 1673 callback (loop, timer, EV_TIMEOUT);
1452 1674
1453And when there is some activity, simply store the current time in 1675And when there is some activity, simply store the current time in
1454C<last_activity>, no libev calls at all: 1676C<last_activity>, no libev calls at all:
1547If the timer is started but non-repeating, stop it (as if it timed out). 1769If the timer is started but non-repeating, stop it (as if it timed out).
1548 1770
1549If the timer is repeating, either start it if necessary (with the 1771If the timer is repeating, either start it if necessary (with the
1550C<repeat> value), or reset the running timer to the C<repeat> value. 1772C<repeat> value), or reset the running timer to the C<repeat> value.
1551 1773
1552This sounds a bit complicated, see "Be smart about timeouts", above, for a 1774This sounds a bit complicated, see L<Be smart about timeouts>, above, for a
1553usage example. 1775usage example.
1554 1776
1555=item ev_tstamp repeat [read-write] 1777=item ev_tstamp repeat [read-write]
1556 1778
1557The current C<repeat> value. Will be used each time the watcher times out 1779The current C<repeat> value. Will be used each time the watcher times out
1617timers, such as triggering an event on each "midnight, local time", or 1839timers, such as triggering an event on each "midnight, local time", or
1618other complicated rules. This cannot be done with C<ev_timer> watchers, as 1840other complicated rules. This cannot be done with C<ev_timer> watchers, as
1619those cannot react to time jumps. 1841those cannot react to time jumps.
1620 1842
1621As with timers, the callback is guaranteed to be invoked only when the 1843As with timers, the callback is guaranteed to be invoked only when the
1622point in time where it is supposed to trigger has passed, but if multiple 1844point in time where it is supposed to trigger has passed. If multiple
1623periodic timers become ready during the same loop iteration, then order of 1845timers become ready during the same loop iteration then the ones with
1624execution is undefined. 1846earlier time-out values are invoked before ones with later time-out values
1847(but this is no longer true when a callback calls C<ev_loop> recursively).
1625 1848
1626=head3 Watcher-Specific Functions and Data Members 1849=head3 Watcher-Specific Functions and Data Members
1627 1850
1628=over 4 1851=over 4
1629 1852
1850some 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
1851exits). 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
1852has been forked (which implies it might have already exited), as long 2075has been forked (which implies it might have already exited), as long
1853as 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.,
1854forking and then immediately registering a watcher for the child is fine, 2077forking and then immediately registering a watcher for the child is fine,
1855but 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
1856not. 2079in the next callback invocation is not.
1857 2080
1858Only the default event loop is capable of handling signals, and therefore 2081Only the default event loop is capable of handling signals, and therefore
1859you 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)
1860 2087
1861=head3 Process Interaction 2088=head3 Process Interaction
1862 2089
1863Libev grabs C<SIGCHLD> as soon as the default event loop is 2090Libev grabs C<SIGCHLD> as soon as the default event loop is
1864initialised. This is necessary to guarantee proper behaviour even if 2091initialised. This is necessary to guarantee proper behaviour even if
2216 // no longer anything immediate to do. 2443 // no longer anything immediate to do.
2217 } 2444 }
2218 2445
2219 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2446 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2220 ev_idle_init (idle_watcher, idle_cb); 2447 ev_idle_init (idle_watcher, idle_cb);
2221 ev_idle_start (loop, idle_cb); 2448 ev_idle_start (loop, idle_watcher);
2222 2449
2223 2450
2224=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!
2225 2452
2226Prepare and check watchers are usually (but not always) used in pairs: 2453Prepare and check watchers are usually (but not always) used in pairs:
2319 struct pollfd fds [nfd]; 2546 struct pollfd fds [nfd];
2320 // actual code will need to loop here and realloc etc. 2547 // actual code will need to loop here and realloc etc.
2321 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 2548 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
2322 2549
2323 /* 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 */
2324 ev_timer_init (&tw, 0, timeout * 1e-3); 2551 ev_timer_init (&tw, 0, timeout * 1e-3, 0.);
2325 ev_timer_start (loop, &tw); 2552 ev_timer_start (loop, &tw);
2326 2553
2327 // create one ev_io per pollfd 2554 // create one ev_io per pollfd
2328 for (int i = 0; i < nfd; ++i) 2555 for (int i = 0; i < nfd; ++i)
2329 { 2556 {
2559event loop blocks next and before C<ev_check> watchers are being called, 2786event loop blocks next and before C<ev_check> watchers are being called,
2560and only in the child after the fork. If whoever good citizen calling 2787and only in the child after the fork. If whoever good citizen calling
2561C<ev_default_fork> cheats and calls it in the wrong process, the fork 2788C<ev_default_fork> cheats and calls it in the wrong process, the fork
2562handlers will be invoked, too, of course. 2789handlers will be invoked, too, of course.
2563 2790
2791=head3 The special problem of life after fork - how is it possible?
2792
2793Most uses of C<fork()> consist of forking, then some simple calls to ste
2794up/change the process environment, followed by a call to C<exec()>. This
2795sequence should be handled by libev without any problems.
2796
2797This changes when the application actually wants to do event handling
2798in the child, or both parent in child, in effect "continuing" after the
2799fork.
2800
2801The default mode of operation (for libev, with application help to detect
2802forks) is to duplicate all the state in the child, as would be expected
2803when I<either> the parent I<or> the child process continues.
2804
2805When both processes want to continue using libev, then this is usually the
2806wrong result. In that case, usually one process (typically the parent) is
2807supposed to continue with all watchers in place as before, while the other
2808process typically wants to start fresh, i.e. without any active watchers.
2809
2810The cleanest and most efficient way to achieve that with libev is to
2811simply create a new event loop, which of course will be "empty", and
2812use that for new watchers. This has the advantage of not touching more
2813memory than necessary, and thus avoiding the copy-on-write, and the
2814disadvantage of having to use multiple event loops (which do not support
2815signal watchers).
2816
2817When this is not possible, or you want to use the default loop for
2818other reasons, then in the process that wants to start "fresh", call
2819C<ev_default_destroy ()> followed by C<ev_default_loop (...)>. Destroying
2820the default loop will "orphan" (not stop) all registered watchers, so you
2821have to be careful not to execute code that modifies those watchers. Note
2822also that in that case, you have to re-register any signal watchers.
2823
2564=head3 Watcher-Specific Functions and Data Members 2824=head3 Watcher-Specific Functions and Data Members
2565 2825
2566=over 4 2826=over 4
2567 2827
2568=item ev_fork_init (ev_signal *, callback) 2828=item ev_fork_init (ev_signal *, callback)
3458defined to be C<0>, then they are not. 3718defined to be C<0>, then they are not.
3459 3719
3460=item EV_MINIMAL 3720=item EV_MINIMAL
3461 3721
3462If 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
3463speed, 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
3464inlining decisions, saves roughly 30% code size on amd64. It also selects a 3724is used to override some inlining decisions, saves roughly 30% code size
3465much 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.
3466 3736
3467=item EV_PID_HASHSIZE 3737=item EV_PID_HASHSIZE
3468 3738
3469C<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
3470pid. 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
3656default 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
3657watcher callback into the event loop interested in the signal. 3927watcher callback into the event loop interested in the signal.
3658 3928
3659=back 3929=back
3660 3930
3931=head4 THREAD LOCKING EXAMPLE
3932
3661=head3 COROUTINES 3933=head3 COROUTINES
3662 3934
3663Libev is very accommodating to coroutines ("cooperative threads"): 3935Libev is very accommodating to coroutines ("cooperative threads"):
3664libev fully supports nesting calls to its functions from different 3936libev fully supports nesting calls to its functions from different
3665coroutines (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
3750way (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).
3751 4023
3752There is no supported compilation method available on windows except 4024There is no supported compilation method available on windows except
3753embedding it into other applications. 4025embedding it into other applications.
3754 4026
4027Sensible signal handling is officially unsupported by Microsoft - libev
4028tries its best, but under most conditions, signals will simply not work.
4029
3755Not a libev limitation but worth mentioning: windows apparently doesn't 4030Not a libev limitation but worth mentioning: windows apparently doesn't
3756accept large writes: instead of resulting in a partial write, windows will 4031accept large writes: instead of resulting in a partial write, windows will
3757either 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,
3758so 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
3759megabyte seems safe, but this apparently depends on the amount of memory 4034megabyte seems safe, but this apparently depends on the amount of memory
3763the abysmal performance of winsockets, using a large number of sockets 4038the abysmal performance of winsockets, using a large number of sockets
3764is not recommended (and not reasonable). If your program needs to use 4039is not recommended (and not reasonable). If your program needs to use
3765more 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
3766different implementation for windows, as libev offers the POSIX readiness 4041different implementation for windows, as libev offers the POSIX readiness
3767notification model, which cannot be implemented efficiently on windows 4042notification model, which cannot be implemented efficiently on windows
3768(Microsoft monopoly games). 4043(due to Microsoft monopoly games).
3769 4044
3770A 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
3771section 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
3772of F<ev.h>: 4047of F<ev.h>:
3773 4048
3809 4084
3810Early versions of winsocket's select only supported waiting for a maximum 4085Early versions of winsocket's select only supported waiting for a maximum
3811of 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
3812can 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
3813recommends 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
3814previous thread in each. Great). 4089previous thread in each. Sounds great!).
3815 4090
3816Newer 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>
3817to 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
3818call (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
3819select emulation on windows). 4094other interpreters do their own select emulation on windows).
3820 4095
3821Another limit is the number of file descriptors in the Microsoft runtime 4096Another limit is the number of file descriptors in the Microsoft runtime
3822libraries, 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>
3823or something like this inside Microsoft). You can increase this by calling 4098fetish or something like this inside Microsoft). You can increase this
3824C<_setmaxstdio>, which can increase this limit to C<2048> (another 4099by calling C<_setmaxstdio>, which can increase this limit to C<2048>
3825arbitrary limit), but is broken in many versions of the Microsoft runtime 4100(another arbitrary limit), but is broken in many versions of the Microsoft
3826libraries.
3827
3828This 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
3829windows 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,
3830wrap 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
3831calling select (O(n²)) will likely make this unworkable. 4104the cost of calling select (O(n²)) will likely make this unworkable.
3832 4105
3833=back 4106=back
3834 4107
3835=head2 PORTABILITY REQUIREMENTS 4108=head2 PORTABILITY REQUIREMENTS
3836 4109
3879=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
3880 4153
3881The 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
3882have 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
3883enough 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
3884implementations 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.
3885 4160
3886=back 4161=back
3887 4162
3888If you know of other additional requirements drop me a note. 4163If you know of other additional requirements drop me a note.
3889 4164
3957involves iterating over all running async watchers or all signal numbers. 4232involves iterating over all running async watchers or all signal numbers.
3958 4233
3959=back 4234=back
3960 4235
3961 4236
4237=head1 GLOSSARY
4238
4239=over 4
4240
4241=item active
4242
4243A watcher is active as long as it has been started (has been attached to
4244an event loop) but not yet stopped (disassociated from the event loop).
4245
4246=item application
4247
4248In this document, an application is whatever is using libev.
4249
4250=item callback
4251
4252The address of a function that is called when some event has been
4253detected. Callbacks are being passed the event loop, the watcher that
4254received the event, and the actual event bitset.
4255
4256=item callback invocation
4257
4258The act of calling the callback associated with a watcher.
4259
4260=item event
4261
4262A change of state of some external event, such as data now being available
4263for reading on a file descriptor, time having passed or simply not having
4264any other events happening anymore.
4265
4266In libev, events are represented as single bits (such as C<EV_READ> or
4267C<EV_TIMEOUT>).
4268
4269=item event library
4270
4271A software package implementing an event model and loop.
4272
4273=item event loop
4274
4275An entity that handles and processes external events and converts them
4276into callback invocations.
4277
4278=item event model
4279
4280The model used to describe how an event loop handles and processes
4281watchers and events.
4282
4283=item pending
4284
4285A watcher is pending as soon as the corresponding event has been detected,
4286and stops being pending as soon as the watcher will be invoked or its
4287pending status is explicitly cleared by the application.
4288
4289A watcher can be pending, but not active. Stopping a watcher also clears
4290its pending status.
4291
4292=item real time
4293
4294The physical time that is observed. It is apparently strictly monotonic :)
4295
4296=item wall-clock time
4297
4298The time and date as shown on clocks. Unlike real time, it can actually
4299be wrong and jump forwards and backwards, e.g. when the you adjust your
4300clock.
4301
4302=item watcher
4303
4304A data structure that describes interest in certain events. Watchers need
4305to be started (attached to an event loop) before they can receive events.
4306
4307=item watcher invocation
4308
4309The act of calling the callback associated with a watcher.
4310
4311=back
4312
3962=head1 AUTHOR 4313=head1 AUTHOR
3963 4314
3964Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael Magnusson. 4315Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael Magnusson.
3965 4316

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines