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

Comparing libev/ev.pod (file contents):
Revision 1.405 by root, Thu May 3 15:07:15 2012 UTC vs.
Revision 1.421 by root, Thu Aug 2 11:55:28 2012 UTC

82 82
83=head1 WHAT TO READ WHEN IN A HURRY 83=head1 WHAT TO READ WHEN IN A HURRY
84 84
85This manual tries to be very detailed, but unfortunately, this also makes 85This manual tries to be very detailed, but unfortunately, this also makes
86it very long. If you just want to know the basics of libev, I suggest 86it very long. If you just want to know the basics of libev, I suggest
87reading L<ANATOMY OF A WATCHER>, then the L<EXAMPLE PROGRAM> above and 87reading L</ANATOMY OF A WATCHER>, then the L</EXAMPLE PROGRAM> above and
88look up the missing functions in L<GLOBAL FUNCTIONS> and the C<ev_io> and 88look up the missing functions in L</GLOBAL FUNCTIONS> and the C<ev_io> and
89C<ev_timer> sections in L<WATCHER TYPES>. 89C<ev_timer> sections in L</WATCHER TYPES>.
90 90
91=head1 ABOUT LIBEV 91=head1 ABOUT LIBEV
92 92
93Libev is an event loop: you register interest in certain events (such as a 93Libev is an event loop: you register interest in certain events (such as a
94file descriptor being readable or a timeout occurring), and it will manage 94file descriptor being readable or a timeout occurring), and it will manage
764 764
765This function is rarely useful, but when some event callback runs for a 765This function is rarely useful, but when some event callback runs for a
766very long time without entering the event loop, updating libev's idea of 766very long time without entering the event loop, updating libev's idea of
767the current time is a good idea. 767the current time is a good idea.
768 768
769See also L<The special problem of time updates> in the C<ev_timer> section. 769See also L</The special problem of time updates> in the C<ev_timer> section.
770 770
771=item ev_suspend (loop) 771=item ev_suspend (loop)
772 772
773=item ev_resume (loop) 773=item ev_resume (loop)
774 774
1318 1318
1319=item callback ev_cb (ev_TYPE *watcher) 1319=item callback ev_cb (ev_TYPE *watcher)
1320 1320
1321Returns the callback currently set on the watcher. 1321Returns the callback currently set on the watcher.
1322 1322
1323=item ev_cb_set (ev_TYPE *watcher, callback) 1323=item ev_set_cb (ev_TYPE *watcher, callback)
1324 1324
1325Change the callback. You can change the callback at virtually any time 1325Change the callback. You can change the callback at virtually any time
1326(modulo threads). 1326(modulo threads).
1327 1327
1328=item ev_set_priority (ev_TYPE *watcher, int priority) 1328=item ev_set_priority (ev_TYPE *watcher, int priority)
1346or might not have been clamped to the valid range. 1346or might not have been clamped to the valid range.
1347 1347
1348The default priority used by watchers when no priority has been set is 1348The default priority used by watchers when no priority has been set is
1349always C<0>, which is supposed to not be too high and not be too low :). 1349always C<0>, which is supposed to not be too high and not be too low :).
1350 1350
1351See L<WATCHER PRIORITY MODELS>, below, for a more thorough treatment of 1351See L</WATCHER PRIORITY MODELS>, below, for a more thorough treatment of
1352priorities. 1352priorities.
1353 1353
1354=item ev_invoke (loop, ev_TYPE *watcher, int revents) 1354=item ev_invoke (loop, ev_TYPE *watcher, int revents)
1355 1355
1356Invoke the C<watcher> with the given C<loop> and C<revents>. Neither 1356Invoke the C<watcher> with the given C<loop> and C<revents>. Neither
1381See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related 1381See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1382functions that do not need a watcher. 1382functions that do not need a watcher.
1383 1383
1384=back 1384=back
1385 1385
1386See also the L<ASSOCIATING CUSTOM DATA WITH A WATCHER> and L<BUILDING YOUR 1386See also the L</ASSOCIATING CUSTOM DATA WITH A WATCHER> and L</BUILDING YOUR
1387OWN COMPOSITE WATCHERS> idioms. 1387OWN COMPOSITE WATCHERS> idioms.
1388 1388
1389=head2 WATCHER STATES 1389=head2 WATCHER STATES
1390 1390
1391There are various watcher states mentioned throughout this manual - 1391There are various watcher states mentioned throughout this manual -
2136=item If the timer is repeating, make the C<repeat> value the new timeout 2136=item If the timer is repeating, make the C<repeat> value the new timeout
2137and start the timer, if necessary. 2137and start the timer, if necessary.
2138 2138
2139=back 2139=back
2140 2140
2141This sounds a bit complicated, see L<Be smart about timeouts>, above, for a 2141This sounds a bit complicated, see L</Be smart about timeouts>, above, for a
2142usage example. 2142usage example.
2143 2143
2144=item ev_tstamp ev_timer_remaining (loop, ev_timer *) 2144=item ev_tstamp ev_timer_remaining (loop, ev_timer *)
2145 2145
2146Returns the remaining time until a timer fires. If the timer is active, 2146Returns the remaining time until a timer fires. If the timer is active,
2847Apart from keeping your process non-blocking (which is a useful 2847Apart from keeping your process non-blocking (which is a useful
2848effect on its own sometimes), idle watchers are a good place to do 2848effect on its own sometimes), idle watchers are a good place to do
2849"pseudo-background processing", or delay processing stuff to after the 2849"pseudo-background processing", or delay processing stuff to after the
2850event loop has handled all outstanding events. 2850event loop has handled all outstanding events.
2851 2851
2852=head3 Abusing an C<ev_idle> watcher for its side-effect
2853
2854As long as there is at least one active idle watcher, libev will never
2855sleep unnecessarily. Or in other words, it will loop as fast as possible.
2856For this to work, the idle watcher doesn't need to be invoked at all - the
2857lowest priority will do.
2858
2859This mode of operation can be useful together with an C<ev_check> watcher,
2860to do something on each event loop iteration - for example to balance load
2861between different connections.
2862
2863See L</Abusing an ev_check watcher for its side-effect> for a longer
2864example.
2865
2852=head3 Watcher-Specific Functions and Data Members 2866=head3 Watcher-Specific Functions and Data Members
2853 2867
2854=over 4 2868=over 4
2855 2869
2856=item ev_idle_init (ev_idle *, callback) 2870=item ev_idle_init (ev_idle *, callback)
2867callback, free it. Also, use no error checking, as usual. 2881callback, free it. Also, use no error checking, as usual.
2868 2882
2869 static void 2883 static void
2870 idle_cb (struct ev_loop *loop, ev_idle *w, int revents) 2884 idle_cb (struct ev_loop *loop, ev_idle *w, int revents)
2871 { 2885 {
2886 // stop the watcher
2887 ev_idle_stop (loop, w);
2888
2889 // now we can free it
2872 free (w); 2890 free (w);
2891
2873 // now do something you wanted to do when the program has 2892 // now do something you wanted to do when the program has
2874 // no longer anything immediate to do. 2893 // no longer anything immediate to do.
2875 } 2894 }
2876 2895
2877 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2896 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2879 ev_idle_start (loop, idle_watcher); 2898 ev_idle_start (loop, idle_watcher);
2880 2899
2881 2900
2882=head2 C<ev_prepare> and C<ev_check> - customise your event loop! 2901=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
2883 2902
2884Prepare and check watchers are usually (but not always) used in pairs: 2903Prepare and check watchers are often (but not always) used in pairs:
2885prepare watchers get invoked before the process blocks and check watchers 2904prepare watchers get invoked before the process blocks and check watchers
2886afterwards. 2905afterwards.
2887 2906
2888You I<must not> call C<ev_run> or similar functions that enter 2907You I<must not> call C<ev_run> or similar functions that enter
2889the current event loop from either C<ev_prepare> or C<ev_check> 2908the current event loop from either C<ev_prepare> or C<ev_check>
2917with priority higher than or equal to the event loop and one coroutine 2936with priority higher than or equal to the event loop and one coroutine
2918of lower priority, but only once, using idle watchers to keep the event 2937of lower priority, but only once, using idle watchers to keep the event
2919loop from blocking if lower-priority coroutines are active, thus mapping 2938loop from blocking if lower-priority coroutines are active, thus mapping
2920low-priority coroutines to idle/background tasks). 2939low-priority coroutines to idle/background tasks).
2921 2940
2922It is recommended to give C<ev_check> watchers highest (C<EV_MAXPRI>) 2941When used for this purpose, it is recommended to give C<ev_check> watchers
2923priority, to ensure that they are being run before any other watchers 2942highest (C<EV_MAXPRI>) priority, to ensure that they are being run before
2924after the poll (this doesn't matter for C<ev_prepare> watchers). 2943any other watchers after the poll (this doesn't matter for C<ev_prepare>
2944watchers).
2925 2945
2926Also, C<ev_check> watchers (and C<ev_prepare> watchers, too) should not 2946Also, C<ev_check> watchers (and C<ev_prepare> watchers, too) should not
2927activate ("feed") events into libev. While libev fully supports this, they 2947activate ("feed") events into libev. While libev fully supports this, they
2928might get executed before other C<ev_check> watchers did their job. As 2948might get executed before other C<ev_check> watchers did their job. As
2929C<ev_check> watchers are often used to embed other (non-libev) event 2949C<ev_check> watchers are often used to embed other (non-libev) event
2930loops those other event loops might be in an unusable state until their 2950loops those other event loops might be in an unusable state until their
2931C<ev_check> watcher ran (always remind yourself to coexist peacefully with 2951C<ev_check> watcher ran (always remind yourself to coexist peacefully with
2932others). 2952others).
2953
2954=head3 Abusing an C<ev_check> watcher for its side-effect
2955
2956C<ev_check> (and less often also C<ev_prepare>) watchers can also be
2957useful because they are called once per event loop iteration. For
2958example, if you want to handle a large number of connections fairly, you
2959normally only do a bit of work for each active connection, and if there
2960is more work to do, you wait for the next event loop iteration, so other
2961connections have a chance of making progress.
2962
2963Using an C<ev_check> watcher is almost enough: it will be called on the
2964next event loop iteration. However, that isn't as soon as possible -
2965without external events, your C<ev_check> watcher will not be invoked.
2966
2967This is where C<ev_idle> watchers come in handy - all you need is a
2968single global idle watcher that is active as long as you have one active
2969C<ev_check> watcher. The C<ev_idle> watcher makes sure the event loop
2970will not sleep, and the C<ev_check> watcher makes sure a callback gets
2971invoked. Neither watcher alone can do that.
2933 2972
2934=head3 Watcher-Specific Functions and Data Members 2973=head3 Watcher-Specific Functions and Data Members
2935 2974
2936=over 4 2975=over 4
2937 2976
3211 3250
3212=head2 C<ev_fork> - the audacity to resume the event loop after a fork 3251=head2 C<ev_fork> - the audacity to resume the event loop after a fork
3213 3252
3214Fork watchers are called when a C<fork ()> was detected (usually because 3253Fork watchers are called when a C<fork ()> was detected (usually because
3215whoever is a good citizen cared to tell libev about it by calling 3254whoever is a good citizen cared to tell libev about it by calling
3216C<ev_default_fork> or C<ev_loop_fork>). The invocation is done before the 3255C<ev_loop_fork>). The invocation is done before the event loop blocks next
3217event loop blocks next and before C<ev_check> watchers are being called, 3256and before C<ev_check> watchers are being called, and only in the child
3218and only in the child after the fork. If whoever good citizen calling 3257after the fork. If whoever good citizen calling C<ev_default_fork> cheats
3219C<ev_default_fork> cheats and calls it in the wrong process, the fork 3258and calls it in the wrong process, the fork handlers will be invoked, too,
3220handlers will be invoked, too, of course. 3259of course.
3221 3260
3222=head3 The special problem of life after fork - how is it possible? 3261=head3 The special problem of life after fork - how is it possible?
3223 3262
3224Most uses of C<fork()> consist of forking, then some simple calls to set 3263Most uses of C<fork()> consist of forking, then some simple calls to set
3225up/change the process environment, followed by a call to C<exec()>. This 3264up/change the process environment, followed by a call to C<exec()>. This
3835called): 3874called):
3836 3875
3837 void 3876 void
3838 wait_for_event (ev_watcher *w) 3877 wait_for_event (ev_watcher *w)
3839 { 3878 {
3840 ev_cb_set (w) = current_coro; 3879 ev_set_cb (w, current_coro);
3841 switch_to (libev_coro); 3880 switch_to (libev_coro);
3842 } 3881 }
3843 3882
3844That basically suspends the coroutine inside C<wait_for_event> and 3883That basically suspends the coroutine inside C<wait_for_event> and
3845continues the libev coroutine, which, when appropriate, switches back to 3884continues the libev coroutine, which, when appropriate, switches back to
3848You can do similar tricks if you have, say, threads with an event queue - 3887You can do similar tricks if you have, say, threads with an event queue -
3849instead of storing a coroutine, you store the queue object and instead of 3888instead of storing a coroutine, you store the queue object and instead of
3850switching to a coroutine, you push the watcher onto the queue and notify 3889switching to a coroutine, you push the watcher onto the queue and notify
3851any waiters. 3890any waiters.
3852 3891
3853To embed libev, see L<EMBEDDING>, but in short, it's easiest to create two 3892To embed libev, see L</EMBEDDING>, but in short, it's easiest to create two
3854files, F<my_ev.h> and F<my_ev.c> that include the respective libev files: 3893files, F<my_ev.h> and F<my_ev.c> that include the respective libev files:
3855 3894
3856 // my_ev.h 3895 // my_ev.h
3857 #define EV_CB_DECLARE(type) struct my_coro *cb; 3896 #define EV_CB_DECLARE(type) struct my_coro *cb;
3858 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb); 3897 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb);
3910libev sources can be compiled as C++. Therefore, code that uses the C API 3949libev sources can be compiled as C++. Therefore, code that uses the C API
3911will work fine. 3950will work fine.
3912 3951
3913Proper exception specifications might have to be added to callbacks passed 3952Proper exception specifications might have to be added to callbacks passed
3914to libev: exceptions may be thrown only from watcher callbacks, all 3953to libev: exceptions may be thrown only from watcher callbacks, all
3915other callbacks (allocator, syserr, loop acquire/release and periodioc 3954other callbacks (allocator, syserr, loop acquire/release and periodic
3916reschedule callbacks) must not throw exceptions, and might need a C<throw 3955reschedule callbacks) must not throw exceptions, and might need a C<throw
3917()> specification. If you have code that needs to be compiled as both C 3956()> specification. If you have code that needs to be compiled as both C
3918and C++ you can use the C<EV_THROW> macro for this: 3957and C++ you can use the C<EV_THROW> macro for this:
3919 3958
3920 static void 3959 static void
4081Associates a different C<struct ev_loop> with this watcher. You can only 4120Associates a different C<struct ev_loop> with this watcher. You can only
4082do this when the watcher is inactive (and not pending either). 4121do this when the watcher is inactive (and not pending either).
4083 4122
4084=item w->set ([arguments]) 4123=item w->set ([arguments])
4085 4124
4086Basically the same as C<ev_TYPE_set>, with the same arguments. Either this 4125Basically the same as C<ev_TYPE_set> (except for C<ev::embed> watchers>),
4087method or a suitable start method must be called at least once. Unlike the 4126with the same arguments. Either this method or a suitable start method
4088C counterpart, an active watcher gets automatically stopped and restarted 4127must be called at least once. Unlike the C counterpart, an active watcher
4089when reconfiguring it with this method. 4128gets automatically stopped and restarted when reconfiguring it with this
4129method.
4130
4131For C<ev::embed> watchers this method is called C<set_embed>, to avoid
4132clashing with the C<set (loop)> method.
4090 4133
4091=item w->start () 4134=item w->start ()
4092 4135
4093Starts the watcher. Note that there is no C<loop> argument, as the 4136Starts the watcher. Note that there is no C<loop> argument, as the
4094constructor already stores the event loop. 4137constructor already stores the event loop.
4197=item Lua 4240=item Lua
4198 4241
4199Brian Maher has written a partial interface to libev for lua (at the 4242Brian Maher has written a partial interface to libev for lua (at the
4200time of this writing, only C<ev_io> and C<ev_timer>), to be found at 4243time of this writing, only C<ev_io> and C<ev_timer>), to be found at
4201L<http://github.com/brimworks/lua-ev>. 4244L<http://github.com/brimworks/lua-ev>.
4245
4246=item Javascript
4247
4248Node.js (L<http://nodejs.org>) uses libev as the underlying event library.
4249
4250=item Others
4251
4252There are others, and I stopped counting.
4202 4253
4203=back 4254=back
4204 4255
4205 4256
4206=head1 MACRO MAGIC 4257=head1 MACRO MAGIC
4505 4556
4506If programs implement their own fd to handle mapping on win32, then this 4557If programs implement their own fd to handle mapping on win32, then this
4507macro can be used to override the C<close> function, useful to unregister 4558macro can be used to override the C<close> function, useful to unregister
4508file descriptors again. Note that the replacement function has to close 4559file descriptors again. Note that the replacement function has to close
4509the underlying OS handle. 4560the underlying OS handle.
4561
4562=item EV_USE_WSASOCKET
4563
4564If defined to be C<1>, libev will use C<WSASocket> to create its internal
4565communication socket, which works better in some environments. Otherwise,
4566the normal C<socket> function will be used, which works better in other
4567environments.
4510 4568
4511=item EV_USE_POLL 4569=item EV_USE_POLL
4512 4570
4513If defined to be C<1>, libev will compile in support for the C<poll>(2) 4571If defined to be C<1>, libev will compile in support for the C<poll>(2)
4514backend. Otherwise it will be enabled on non-win32 platforms. It 4572backend. Otherwise it will be enabled on non-win32 platforms. It
4566above. This reduces dependencies and makes libev faster. 4624above. This reduces dependencies and makes libev faster.
4567 4625
4568=item EV_ATOMIC_T 4626=item EV_ATOMIC_T
4569 4627
4570Libev requires an integer type (suitable for storing C<0> or C<1>) whose 4628Libev requires an integer type (suitable for storing C<0> or C<1>) whose
4571access is atomic and serialised with respect to other threads or signal 4629access is atomic with respect to other threads or signal contexts. No
4572contexts. No such type is easily found in the C language, so you can 4630such type is easily found in the C language, so you can provide your own
4573provide your own type that you know is safe for your purposes. It is used 4631type that you know is safe for your purposes. It is used both for signal
4574both for signal handler "locking" as well as for signal and thread safety 4632handler "locking" as well as for signal and thread safety in C<ev_async>
4575in C<ev_async> watchers. 4633watchers.
4576 4634
4577In the absence of this define, libev will use C<sig_atomic_t volatile> 4635In the absence of this define, libev will use C<sig_atomic_t volatile>
4578(from F<signal.h>), which is usually good enough on most platforms, 4636(from F<signal.h>), which is usually good enough on most platforms.
4579although strictly speaking using a type that also implies a memory fence
4580is required.
4581 4637
4582=item EV_H (h) 4638=item EV_H (h)
4583 4639
4584The name of the F<ev.h> header file used to include it. The default if 4640The name of the F<ev.h> header file used to include it. The default if
4585undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be 4641undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be
4953default loop and triggering an C<ev_async> watcher from the default loop 5009default loop and triggering an C<ev_async> watcher from the default loop
4954watcher callback into the event loop interested in the signal. 5010watcher callback into the event loop interested in the signal.
4955 5011
4956=back 5012=back
4957 5013
4958See also L<THREAD LOCKING EXAMPLE>. 5014See also L</THREAD LOCKING EXAMPLE>.
4959 5015
4960=head3 COROUTINES 5016=head3 COROUTINES
4961 5017
4962Libev is very accommodating to coroutines ("cooperative threads"): 5018Libev is very accommodating to coroutines ("cooperative threads"):
4963libev fully supports nesting calls to its functions from different 5019libev fully supports nesting calls to its functions from different
5254thread" or will block signals process-wide, both behaviours would 5310thread" or will block signals process-wide, both behaviours would
5255be compatible with libev. Interaction between C<sigprocmask> and 5311be compatible with libev. Interaction between C<sigprocmask> and
5256C<pthread_sigmask> could complicate things, however. 5312C<pthread_sigmask> could complicate things, however.
5257 5313
5258The most portable way to handle signals is to block signals in all threads 5314The most portable way to handle signals is to block signals in all threads
5259except the initial one, and run the default loop in the initial thread as 5315except the initial one, and run the signal handling loop in the initial
5260well. 5316thread as well.
5261 5317
5262=item C<long> must be large enough for common memory allocation sizes 5318=item C<long> must be large enough for common memory allocation sizes
5263 5319
5264To improve portability and simplify its API, libev uses C<long> internally 5320To improve portability and simplify its API, libev uses C<long> internally
5265instead of C<size_t> when allocating its data structures. On non-POSIX 5321instead of C<size_t> when allocating its data structures. On non-POSIX
5369=over 4 5425=over 4
5370 5426
5371=item C<EV_COMPAT3> backwards compatibility mechanism 5427=item C<EV_COMPAT3> backwards compatibility mechanism
5372 5428
5373The backward compatibility mechanism can be controlled by 5429The backward compatibility mechanism can be controlled by
5374C<EV_COMPAT3>. See L<PREPROCESSOR SYMBOLS/MACROS> in the L<EMBEDDING> 5430C<EV_COMPAT3>. See L</PREPROCESSOR SYMBOLS/MACROS> in the L</EMBEDDING>
5375section. 5431section.
5376 5432
5377=item C<ev_default_destroy> and C<ev_default_fork> have been removed 5433=item C<ev_default_destroy> and C<ev_default_fork> have been removed
5378 5434
5379These calls can be replaced easily by their C<ev_loop_xxx> counterparts: 5435These calls can be replaced easily by their C<ev_loop_xxx> counterparts:
5422=over 4 5478=over 4
5423 5479
5424=item active 5480=item active
5425 5481
5426A watcher is active as long as it has been started and not yet stopped. 5482A watcher is active as long as it has been started and not yet stopped.
5427See L<WATCHER STATES> for details. 5483See L</WATCHER STATES> for details.
5428 5484
5429=item application 5485=item application
5430 5486
5431In this document, an application is whatever is using libev. 5487In this document, an application is whatever is using libev.
5432 5488
5468watchers and events. 5524watchers and events.
5469 5525
5470=item pending 5526=item pending
5471 5527
5472A watcher is pending as soon as the corresponding event has been 5528A watcher is pending as soon as the corresponding event has been
5473detected. See L<WATCHER STATES> for details. 5529detected. See L</WATCHER STATES> for details.
5474 5530
5475=item real time 5531=item real time
5476 5532
5477The physical time that is observed. It is apparently strictly monotonic :) 5533The physical time that is observed. It is apparently strictly monotonic :)
5478 5534

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines