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

Comparing libev/ev.pod (file contents):
Revision 1.183 by root, Tue Sep 23 08:37:38 2008 UTC vs.
Revision 1.194 by root, Mon Oct 20 16:08:36 2008 UTC

214C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for 214C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
215recommended ones. 215recommended ones.
216 216
217See the description of C<ev_embed> watchers for more info. 217See the description of C<ev_embed> watchers for more info.
218 218
219=item ev_set_allocator (void *(*cb)(void *ptr, long size)) 219=item ev_set_allocator (void *(*cb)(void *ptr, long size)) [NOT REENTRANT]
220 220
221Sets the allocation function to use (the prototype is similar - the 221Sets the allocation function to use (the prototype is similar - the
222semantics are identical to the C<realloc> C89/SuS/POSIX function). It is 222semantics are identical to the C<realloc> C89/SuS/POSIX function). It is
223used to allocate and free memory (no surprises here). If it returns zero 223used to allocate and free memory (no surprises here). If it returns zero
224when memory needs to be allocated (C<size != 0>), the library might abort 224when memory needs to be allocated (C<size != 0>), the library might abort
250 } 250 }
251 251
252 ... 252 ...
253 ev_set_allocator (persistent_realloc); 253 ev_set_allocator (persistent_realloc);
254 254
255=item ev_set_syserr_cb (void (*cb)(const char *msg)); 255=item ev_set_syserr_cb (void (*cb)(const char *msg)); [NOT REENTRANT]
256 256
257Set the callback function to call on a retryable system call error (such 257Set the callback function to call on a retryable system call error (such
258as failed select, poll, epoll_wait). The message is a printable string 258as failed select, poll, epoll_wait). The message is a printable string
259indicating the system call or subsystem causing the problem. If this 259indicating the system call or subsystem causing the problem. If this
260callback is set, then libev will expect it to remedy the situation, no 260callback is set, then libev will expect it to remedy the situation, no
685C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or 685C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or
686C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return. 686C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return.
687 687
688This "unloop state" will be cleared when entering C<ev_loop> again. 688This "unloop state" will be cleared when entering C<ev_loop> again.
689 689
690It is safe to call C<ev_unloop> from otuside any C<ev_loop> calls.
691
690=item ev_ref (loop) 692=item ev_ref (loop)
691 693
692=item ev_unref (loop) 694=item ev_unref (loop)
693 695
694Ref/unref can be used to add or remove a reference count on the event 696Ref/unref can be used to add or remove a reference count on the event
1625 1627
1626=back 1628=back
1627 1629
1628=head3 Examples 1630=head3 Examples
1629 1631
1630Example: Try to exit cleanly on SIGINT and SIGTERM. 1632Example: Try to exit cleanly on SIGINT.
1631 1633
1632 static void 1634 static void
1633 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents) 1635 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1634 { 1636 {
1635 ev_unloop (loop, EVUNLOOP_ALL); 1637 ev_unloop (loop, EVUNLOOP_ALL);
1636 } 1638 }
1637 1639
1638 struct ev_signal signal_watcher; 1640 struct ev_signal signal_watcher;
1639 ev_signal_init (&signal_watcher, sigint_cb, SIGINT); 1641 ev_signal_init (&signal_watcher, sigint_cb, SIGINT);
1640 ev_signal_start (loop, &sigint_cb); 1642 ev_signal_start (loop, &signal_watcher);
1641 1643
1642 1644
1643=head2 C<ev_child> - watch out for process status changes 1645=head2 C<ev_child> - watch out for process status changes
1644 1646
1645Child watchers trigger when your process receives a SIGCHLD in response to 1647Child watchers trigger when your process receives a SIGCHLD in response to
2233when you fork, you not only have to call C<ev_loop_fork> on both loops, 2235when you fork, you not only have to call C<ev_loop_fork> on both loops,
2234but you will also have to stop and restart any C<ev_embed> watchers 2236but you will also have to stop and restart any C<ev_embed> watchers
2235yourself - but you can use a fork watcher to handle this automatically, 2237yourself - but you can use a fork watcher to handle this automatically,
2236and future versions of libev might do just that. 2238and future versions of libev might do just that.
2237 2239
2238Unfortunately, not all backends are embeddable, only the ones returned by 2240Unfortunately, not all backends are embeddable: only the ones returned by
2239C<ev_embeddable_backends> are, which, unfortunately, does not include any 2241C<ev_embeddable_backends> are, which, unfortunately, does not include any
2240portable one. 2242portable one.
2241 2243
2242So when you want to use this feature you will always have to be prepared 2244So when you want to use this feature you will always have to be prepared
2243that you cannot get an embeddable loop. The recommended way to get around 2245that you cannot get an embeddable loop. The recommended way to get around
2244this is to have a separate variables for your embeddable loop, try to 2246this is to have a separate variables for your embeddable loop, try to
2245create it, and if that fails, use the normal loop for everything. 2247create it, and if that fails, use the normal loop for everything.
2248
2249=head3 C<ev_embed> and fork
2250
2251While the C<ev_embed> watcher is running, forks in the embedding loop will
2252automatically be applied to the embedded loop as well, so no special
2253fork handling is required in that case. When the watcher is not running,
2254however, it is still the task of the libev user to call C<ev_loop_fork ()>
2255as applicable.
2246 2256
2247=head3 Watcher-Specific Functions and Data Members 2257=head3 Watcher-Specific Functions and Data Members
2248 2258
2249=over 4 2259=over 4
2250 2260
2368is that the author does not know of a simple (or any) algorithm for a 2378is that the author does not know of a simple (or any) algorithm for a
2369multiple-writer-single-reader queue that works in all cases and doesn't 2379multiple-writer-single-reader queue that works in all cases and doesn't
2370need elaborate support such as pthreads. 2380need elaborate support such as pthreads.
2371 2381
2372That means that if you want to queue data, you have to provide your own 2382That means that if you want to queue data, you have to provide your own
2373queue. But at least I can tell you would implement locking around your 2383queue. But at least I can tell you how to implement locking around your
2374queue: 2384queue:
2375 2385
2376=over 4 2386=over 4
2377 2387
2378=item queueing from a signal handler context 2388=item queueing from a signal handler context
2379 2389
2380To implement race-free queueing, you simply add to the queue in the signal 2390To implement race-free queueing, you simply add to the queue in the signal
2381handler but you block the signal handler in the watcher callback. Here is an example that does that for 2391handler but you block the signal handler in the watcher callback. Here is
2382some fictitious SIGUSR1 handler: 2392an example that does that for some fictitious SIGUSR1 handler:
2383 2393
2384 static ev_async mysig; 2394 static ev_async mysig;
2385 2395
2386 static void 2396 static void
2387 sigusr1_handler (void) 2397 sigusr1_handler (void)
2454 2464
2455=item ev_async_init (ev_async *, callback) 2465=item ev_async_init (ev_async *, callback)
2456 2466
2457Initialises and configures the async watcher - it has no parameters of any 2467Initialises and configures the async watcher - it has no parameters of any
2458kind. There is a C<ev_asynd_set> macro, but using it is utterly pointless, 2468kind. There is a C<ev_asynd_set> macro, but using it is utterly pointless,
2459believe me. 2469trust me.
2460 2470
2461=item ev_async_send (loop, ev_async *) 2471=item ev_async_send (loop, ev_async *)
2462 2472
2463Sends/signals/activates the given C<ev_async> watcher, that is, feeds 2473Sends/signals/activates the given C<ev_async> watcher, that is, feeds
2464an C<EV_ASYNC> event on the watcher into the event loop. Unlike 2474an C<EV_ASYNC> event on the watcher into the event loop. Unlike
2465C<ev_feed_event>, this call is safe to do in other threads, signal or 2475C<ev_feed_event>, this call is safe to do from other threads, signal or
2466similar contexts (see the discussion of C<EV_ATOMIC_T> in the embedding 2476similar contexts (see the discussion of C<EV_ATOMIC_T> in the embedding
2467section below on what exactly this means). 2477section below on what exactly this means).
2468 2478
2469This call incurs the overhead of a system call only once per loop iteration, 2479This call incurs the overhead of a system call only once per loop iteration,
2470so while the overhead might be noticeable, it doesn't apply to repeated 2480so while the overhead might be noticeable, it doesn't apply to repeated
2494=over 4 2504=over 4
2495 2505
2496=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback) 2506=item ev_once (loop, int fd, int events, ev_tstamp timeout, callback)
2497 2507
2498This function combines a simple timer and an I/O watcher, calls your 2508This function combines a simple timer and an I/O watcher, calls your
2499callback on whichever event happens first and automatically stop both 2509callback on whichever event happens first and automatically stops both
2500watchers. This is useful if you want to wait for a single event on an fd 2510watchers. This is useful if you want to wait for a single event on an fd
2501or timeout without having to allocate/configure/start/stop/free one or 2511or timeout without having to allocate/configure/start/stop/free one or
2502more watchers yourself. 2512more watchers yourself.
2503 2513
2504If C<fd> is less than 0, then no I/O watcher will be started and events 2514If C<fd> is less than 0, then no I/O watcher will be started and the
2505is being ignored. Otherwise, an C<ev_io> watcher for the given C<fd> and 2515C<events> argument is being ignored. Otherwise, an C<ev_io> watcher for
2506C<events> set will be created and started. 2516the given C<fd> and C<events> set will be created and started.
2507 2517
2508If C<timeout> is less than 0, then no timeout watcher will be 2518If C<timeout> is less than 0, then no timeout watcher will be
2509started. Otherwise an C<ev_timer> watcher with after = C<timeout> (and 2519started. Otherwise an C<ev_timer> watcher with after = C<timeout> (and
2510repeat = 0) will be started. While C<0> is a valid timeout, it is of 2520repeat = 0) will be started. C<0> is a valid timeout.
2511dubious value.
2512 2521
2513The callback has the type C<void (*cb)(int revents, void *arg)> and gets 2522The callback has the type C<void (*cb)(int revents, void *arg)> and gets
2514passed an C<revents> set like normal event callbacks (a combination of 2523passed an C<revents> set like normal event callbacks (a combination of
2515C<EV_ERROR>, C<EV_READ>, C<EV_WRITE> or C<EV_TIMEOUT>) and the C<arg> 2524C<EV_ERROR>, C<EV_READ>, C<EV_WRITE> or C<EV_TIMEOUT>) and the C<arg>
2516value passed to C<ev_once>: 2525value passed to C<ev_once>. Note that it is possible to receive I<both>
2526a timeout and an io event at the same time - you probably should give io
2527events precedence.
2528
2529Example: wait up to ten seconds for data to appear on STDIN_FILENO.
2517 2530
2518 static void stdin_ready (int revents, void *arg) 2531 static void stdin_ready (int revents, void *arg)
2519 { 2532 {
2533 if (revents & EV_READ)
2534 /* stdin might have data for us, joy! */;
2520 if (revents & EV_TIMEOUT) 2535 else if (revents & EV_TIMEOUT)
2521 /* doh, nothing entered */; 2536 /* doh, nothing entered */;
2522 else if (revents & EV_READ)
2523 /* stdin might have data for us, joy! */;
2524 } 2537 }
2525 2538
2526 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0); 2539 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
2527 2540
2528=item ev_feed_event (ev_loop *, watcher *, int revents) 2541=item ev_feed_event (ev_loop *, watcher *, int revents)
2676 2689
2677The prototype of the C<function> must be C<void (*)(ev::TYPE &w, int)>. 2690The prototype of the C<function> must be C<void (*)(ev::TYPE &w, int)>.
2678 2691
2679See the method-C<set> above for more details. 2692See the method-C<set> above for more details.
2680 2693
2681Example: 2694Example: Use a plain function as callback.
2682 2695
2683 static void io_cb (ev::io &w, int revents) { } 2696 static void io_cb (ev::io &w, int revents) { }
2684 iow.set <io_cb> (); 2697 iow.set <io_cb> ();
2685 2698
2686=item w->set (struct ev_loop *) 2699=item w->set (struct ev_loop *)
2724Example: Define a class with an IO and idle watcher, start one of them in 2737Example: Define a class with an IO and idle watcher, start one of them in
2725the constructor. 2738the constructor.
2726 2739
2727 class myclass 2740 class myclass
2728 { 2741 {
2729 ev::io io; void io_cb (ev::io &w, int revents); 2742 ev::io io ; void io_cb (ev::io &w, int revents);
2730 ev:idle idle void idle_cb (ev::idle &w, int revents); 2743 ev::idle idle; void idle_cb (ev::idle &w, int revents);
2731 2744
2732 myclass (int fd) 2745 myclass (int fd)
2733 { 2746 {
2734 io .set <myclass, &myclass::io_cb > (this); 2747 io .set <myclass, &myclass::io_cb > (this);
2735 idle.set <myclass, &myclass::idle_cb> (this); 2748 idle.set <myclass, &myclass::idle_cb> (this);
2751=item Perl 2764=item Perl
2752 2765
2753The EV module implements the full libev API and is actually used to test 2766The EV module implements the full libev API and is actually used to test
2754libev. EV is developed together with libev. Apart from the EV core module, 2767libev. EV is developed together with libev. Apart from the EV core module,
2755there are additional modules that implement libev-compatible interfaces 2768there are additional modules that implement libev-compatible interfaces
2756to C<libadns> (C<EV::ADNS>), C<Net::SNMP> (C<Net::SNMP::EV>) and the 2769to C<libadns> (C<EV::ADNS>, but C<AnyEvent::DNS> is preferred nowadays),
2757C<libglib> event core (C<Glib::EV> and C<EV::Glib>). 2770C<Net::SNMP> (C<Net::SNMP::EV>) and the C<libglib> event core (C<Glib::EV>
2771and C<EV::Glib>).
2758 2772
2759It can be found and installed via CPAN, its homepage is at 2773It can be found and installed via CPAN, its homepage is at
2760L<http://software.schmorp.de/pkg/EV>. 2774L<http://software.schmorp.de/pkg/EV>.
2761 2775
2762=item Python 2776=item Python
2941 2955
2942=head2 PREPROCESSOR SYMBOLS/MACROS 2956=head2 PREPROCESSOR SYMBOLS/MACROS
2943 2957
2944Libev can be configured via a variety of preprocessor symbols you have to 2958Libev can be configured via a variety of preprocessor symbols you have to
2945define before including any of its files. The default in the absence of 2959define before including any of its files. The default in the absence of
2946autoconf is noted for every option. 2960autoconf is documented for every option.
2947 2961
2948=over 4 2962=over 4
2949 2963
2950=item EV_STANDALONE 2964=item EV_STANDALONE
2951 2965
3121When doing priority-based operations, libev usually has to linearly search 3135When doing priority-based operations, libev usually has to linearly search
3122all the priorities, so having many of them (hundreds) uses a lot of space 3136all the priorities, so having many of them (hundreds) uses a lot of space
3123and time, so using the defaults of five priorities (-2 .. +2) is usually 3137and time, so using the defaults of five priorities (-2 .. +2) is usually
3124fine. 3138fine.
3125 3139
3126If your embedding application does not need any priorities, defining these both to 3140If your embedding application does not need any priorities, defining these
3127C<0> will save some memory and CPU. 3141both to C<0> will save some memory and CPU.
3128 3142
3129=item EV_PERIODIC_ENABLE 3143=item EV_PERIODIC_ENABLE
3130 3144
3131If undefined or defined to be C<1>, then periodic timers are supported. If 3145If undefined or defined to be C<1>, then periodic timers are supported. If
3132defined to be C<0>, then they are not. Disabling them saves a few kB of 3146defined to be C<0>, then they are not. Disabling them saves a few kB of
3139code. 3153code.
3140 3154
3141=item EV_EMBED_ENABLE 3155=item EV_EMBED_ENABLE
3142 3156
3143If undefined or defined to be C<1>, then embed watchers are supported. If 3157If undefined or defined to be C<1>, then embed watchers are supported. If
3144defined to be C<0>, then they are not. 3158defined to be C<0>, then they are not. Embed watchers rely on most other
3159watcher types, which therefore must not be disabled.
3145 3160
3146=item EV_STAT_ENABLE 3161=item EV_STAT_ENABLE
3147 3162
3148If undefined or defined to be C<1>, then stat watchers are supported. If 3163If undefined or defined to be C<1>, then stat watchers are supported. If
3149defined to be C<0>, then they are not. 3164defined to be C<0>, then they are not.
3181two). 3196two).
3182 3197
3183=item EV_USE_4HEAP 3198=item EV_USE_4HEAP
3184 3199
3185Heaps are not very cache-efficient. To improve the cache-efficiency of the 3200Heaps are not very cache-efficient. To improve the cache-efficiency of the
3186timer and periodics heap, libev uses a 4-heap when this symbol is defined 3201timer and periodics heaps, libev uses a 4-heap when this symbol is defined
3187to C<1>. The 4-heap uses more complicated (longer) code but has 3202to C<1>. The 4-heap uses more complicated (longer) code but has noticeably
3188noticeably faster performance with many (thousands) of watchers. 3203faster performance with many (thousands) of watchers.
3189 3204
3190The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0> 3205The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0>
3191(disabled). 3206(disabled).
3192 3207
3193=item EV_HEAP_CACHE_AT 3208=item EV_HEAP_CACHE_AT
3194 3209
3195Heaps are not very cache-efficient. To improve the cache-efficiency of the 3210Heaps are not very cache-efficient. To improve the cache-efficiency of the
3196timer and periodics heap, libev can cache the timestamp (I<at>) within 3211timer and periodics heaps, libev can cache the timestamp (I<at>) within
3197the heap structure (selected by defining C<EV_HEAP_CACHE_AT> to C<1>), 3212the heap structure (selected by defining C<EV_HEAP_CACHE_AT> to C<1>),
3198which uses 8-12 bytes more per watcher and a few hundred bytes more code, 3213which uses 8-12 bytes more per watcher and a few hundred bytes more code,
3199but avoids random read accesses on heap changes. This improves performance 3214but avoids random read accesses on heap changes. This improves performance
3200noticeably with with many (hundreds) of watchers. 3215noticeably with many (hundreds) of watchers.
3201 3216
3202The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0> 3217The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0>
3203(disabled). 3218(disabled).
3204 3219
3205=item EV_VERIFY 3220=item EV_VERIFY
3211called once per loop, which can slow down libev. If set to C<3>, then the 3226called once per loop, which can slow down libev. If set to C<3>, then the
3212verification code will be called very frequently, which will slow down 3227verification code will be called very frequently, which will slow down
3213libev considerably. 3228libev considerably.
3214 3229
3215The default is C<1>, unless C<EV_MINIMAL> is set, in which case it will be 3230The default is C<1>, unless C<EV_MINIMAL> is set, in which case it will be
3216C<0.> 3231C<0>.
3217 3232
3218=item EV_COMMON 3233=item EV_COMMON
3219 3234
3220By default, all watchers have a C<void *data> member. By redefining 3235By default, all watchers have a C<void *data> member. By redefining
3221this macro to a something else you can include more and other types of 3236this macro to a something else you can include more and other types of
3238and the way callbacks are invoked and set. Must expand to a struct member 3253and the way callbacks are invoked and set. Must expand to a struct member
3239definition and a statement, respectively. See the F<ev.h> header file for 3254definition and a statement, respectively. See the F<ev.h> header file for
3240their default definitions. One possible use for overriding these is to 3255their default definitions. One possible use for overriding these is to
3241avoid the C<struct ev_loop *> as first argument in all cases, or to use 3256avoid the C<struct ev_loop *> as first argument in all cases, or to use
3242method calls instead of plain function calls in C++. 3257method calls instead of plain function calls in C++.
3258
3259=back
3243 3260
3244=head2 EXPORTED API SYMBOLS 3261=head2 EXPORTED API SYMBOLS
3245 3262
3246If you need to re-export the API (e.g. via a DLL) and you need a list of 3263If you need to re-export the API (e.g. via a DLL) and you need a list of
3247exported symbols, you can use the provided F<Symbol.*> files which list 3264exported symbols, you can use the provided F<Symbol.*> files which list
3294And a F<ev_cpp.C> implementation file that contains libev proper and is compiled: 3311And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
3295 3312
3296 #include "ev_cpp.h" 3313 #include "ev_cpp.h"
3297 #include "ev.c" 3314 #include "ev.c"
3298 3315
3316=head1 INTERACTION WITH OTHER PROGRAMS OR LIBRARIES
3299 3317
3300=head1 THREADS AND COROUTINES 3318=head2 THREADS AND COROUTINES
3301 3319
3302=head2 THREADS 3320=head3 THREADS
3303 3321
3304Libev itself is thread-safe (unless the opposite is specifically 3322All libev functions are reentrant and thread-safe unless explicitly
3305documented for a function), but it uses no locking itself. This means that 3323documented otherwise, but libev implements no locking itself. This means
3306you can use as many loops as you want in parallel, as long as only one 3324that you can use as many loops as you want in parallel, as long as there
3307thread ever calls into one libev function with the same loop parameter: 3325are no concurrent calls into any libev function with the same loop
3326parameter (C<ev_default_*> calls have an implicit default loop parameter,
3308libev guarentees that different event loops share no data structures that 3327of course): libev guarantees that different event loops share no data
3309need locking. 3328structures that need any locking.
3310 3329
3311Or to put it differently: calls with different loop parameters can be done 3330Or to put it differently: calls with different loop parameters can be done
3312concurrently from multiple threads, calls with the same loop parameter 3331concurrently from multiple threads, calls with the same loop parameter
3313must be done serially (but can be done from different threads, as long as 3332must be done serially (but can be done from different threads, as long as
3314only one thread ever is inside a call at any point in time, e.g. by using 3333only one thread ever is inside a call at any point in time, e.g. by using
3315a mutex per loop). 3334a mutex per loop).
3316 3335
3317Specifically to support threads (and signal handlers), libev implements 3336Specifically to support threads (and signal handlers), libev implements
3318so-called C<ev_async> watchers, which allow some limited form of 3337so-called C<ev_async> watchers, which allow some limited form of
3319concurrency on the same event loop. 3338concurrency on the same event loop, namely waking it up "from the
3339outside".
3320 3340
3321If you want to know which design (one loop, locking, or multiple loops 3341If you want to know which design (one loop, locking, or multiple loops
3322without or something else still) is best for your problem, then I cannot 3342without or something else still) is best for your problem, then I cannot
3323help you. I can give some generic advice however: 3343help you, but here is some generic advice:
3324 3344
3325=over 4 3345=over 4
3326 3346
3327=item * most applications have a main thread: use the default libev loop 3347=item * most applications have a main thread: use the default libev loop
3328in that thread, or create a separate thread running only the default loop. 3348in that thread, or create a separate thread running only the default loop.
3352default loop and triggering an C<ev_async> watcher from the default loop 3372default loop and triggering an C<ev_async> watcher from the default loop
3353watcher callback into the event loop interested in the signal. 3373watcher callback into the event loop interested in the signal.
3354 3374
3355=back 3375=back
3356 3376
3357=head2 COROUTINES 3377=head3 COROUTINES
3358 3378
3359Libev is much more accommodating to coroutines ("cooperative threads"): 3379Libev is very accommodating to coroutines ("cooperative threads"):
3360libev fully supports nesting calls to it's functions from different 3380libev fully supports nesting calls to its functions from different
3361coroutines (e.g. you can call C<ev_loop> on the same loop from two 3381coroutines (e.g. you can call C<ev_loop> on the same loop from two
3362different coroutines and switch freely between both coroutines running the 3382different coroutines, and switch freely between both coroutines running the
3363loop, as long as you don't confuse yourself). The only exception is that 3383loop, as long as you don't confuse yourself). The only exception is that
3364you must not do this from C<ev_periodic> reschedule callbacks. 3384you must not do this from C<ev_periodic> reschedule callbacks.
3365 3385
3366Care has been taken to ensure that libev does not keep local state inside 3386Care has been taken to ensure that libev does not keep local state inside
3367C<ev_loop>, and other calls do not usually allow coroutine switches. 3387C<ev_loop>, and other calls do not usually allow for coroutine switches as
3388they do not clal any callbacks.
3368 3389
3390=head2 COMPILER WARNINGS
3369 3391
3370=head1 COMPLEXITIES 3392Depending on your compiler and compiler settings, you might get no or a
3393lot of warnings when compiling libev code. Some people are apparently
3394scared by this.
3371 3395
3372In this section the complexities of (many of) the algorithms used inside 3396However, these are unavoidable for many reasons. For one, each compiler
3373libev will be explained. For complexity discussions about backends see the 3397has different warnings, and each user has different tastes regarding
3374documentation for C<ev_default_init>. 3398warning options. "Warn-free" code therefore cannot be a goal except when
3399targeting a specific compiler and compiler-version.
3375 3400
3376All of the following are about amortised time: If an array needs to be 3401Another reason is that some compiler warnings require elaborate
3377extended, libev needs to realloc and move the whole array, but this 3402workarounds, or other changes to the code that make it less clear and less
3378happens asymptotically never with higher number of elements, so O(1) might 3403maintainable.
3379mean it might do a lengthy realloc operation in rare cases, but on average
3380it is much faster and asymptotically approaches constant time.
3381 3404
3382=over 4 3405And of course, some compiler warnings are just plain stupid, or simply
3406wrong (because they don't actually warn about the condition their message
3407seems to warn about). For example, certain older gcc versions had some
3408warnings that resulted an extreme number of false positives. These have
3409been fixed, but some people still insist on making code warn-free with
3410such buggy versions.
3383 3411
3384=item Starting and stopping timer/periodic watchers: O(log skipped_other_timers) 3412While libev is written to generate as few warnings as possible,
3413"warn-free" code is not a goal, and it is recommended not to build libev
3414with any compiler warnings enabled unless you are prepared to cope with
3415them (e.g. by ignoring them). Remember that warnings are just that:
3416warnings, not errors, or proof of bugs.
3385 3417
3386This means that, when you have a watcher that triggers in one hour and
3387there are 100 watchers that would trigger before that then inserting will
3388have to skip roughly seven (C<ld 100>) of these watchers.
3389 3418
3390=item Changing timer/periodic watchers (by autorepeat or calling again): O(log skipped_other_timers) 3419=head2 VALGRIND
3391 3420
3392That means that changing a timer costs less than removing/adding them 3421Valgrind has a special section here because it is a popular tool that is
3393as only the relative motion in the event queue has to be paid for. 3422highly useful. Unfortunately, valgrind reports are very hard to interpret.
3394 3423
3395=item Starting io/check/prepare/idle/signal/child/fork/async watchers: O(1) 3424If you think you found a bug (memory leak, uninitialised data access etc.)
3425in libev, then check twice: If valgrind reports something like:
3396 3426
3397These just add the watcher into an array or at the head of a list. 3427 ==2274== definitely lost: 0 bytes in 0 blocks.
3428 ==2274== possibly lost: 0 bytes in 0 blocks.
3429 ==2274== still reachable: 256 bytes in 1 blocks.
3398 3430
3399=item Stopping check/prepare/idle/fork/async watchers: O(1) 3431Then there is no memory leak, just as memory accounted to global variables
3432is not a memleak - the memory is still being refernced, and didn't leak.
3400 3433
3401=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE)) 3434Similarly, under some circumstances, valgrind might report kernel bugs
3435as if it were a bug in libev (e.g. in realloc or in the poll backend,
3436although an acceptable workaround has been found here), or it might be
3437confused.
3402 3438
3403These watchers are stored in lists then need to be walked to find the 3439Keep in mind that valgrind is a very good tool, but only a tool. Don't
3404correct watcher to remove. The lists are usually short (you don't usually 3440make it into some kind of religion.
3405have many watchers waiting for the same fd or signal).
3406 3441
3407=item Finding the next timer in each loop iteration: O(1) 3442If you are unsure about something, feel free to contact the mailing list
3443with the full valgrind report and an explanation on why you think this
3444is a bug in libev (best check the archives, too :). However, don't be
3445annoyed when you get a brisk "this is no bug" answer and take the chance
3446of learning how to interpret valgrind properly.
3408 3447
3409By virtue of using a binary or 4-heap, the next timer is always found at a 3448If you need, for some reason, empty reports from valgrind for your project
3410fixed position in the storage array. 3449I suggest using suppression lists.
3411 3450
3412=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
3413 3451
3414A change means an I/O watcher gets started or stopped, which requires 3452=head1 PORTABILITY NOTES
3415libev to recalculate its status (and possibly tell the kernel, depending
3416on backend and whether C<ev_io_set> was used).
3417 3453
3418=item Activating one watcher (putting it into the pending state): O(1)
3419
3420=item Priority handling: O(number_of_priorities)
3421
3422Priorities are implemented by allocating some space for each
3423priority. When doing priority-based operations, libev usually has to
3424linearly search all the priorities, but starting/stopping and activating
3425watchers becomes O(1) w.r.t. priority handling.
3426
3427=item Sending an ev_async: O(1)
3428
3429=item Processing ev_async_send: O(number_of_async_watchers)
3430
3431=item Processing signals: O(max_signal_number)
3432
3433Sending involves a system call I<iff> there were no other C<ev_async_send>
3434calls in the current loop iteration. Checking for async and signal events
3435involves iterating over all running async watchers or all signal numbers.
3436
3437=back
3438
3439
3440=head1 WIN32 PLATFORM LIMITATIONS AND WORKAROUNDS 3454=head2 WIN32 PLATFORM LIMITATIONS AND WORKAROUNDS
3441 3455
3442Win32 doesn't support any of the standards (e.g. POSIX) that libev 3456Win32 doesn't support any of the standards (e.g. POSIX) that libev
3443requires, and its I/O model is fundamentally incompatible with the POSIX 3457requires, and its I/O model is fundamentally incompatible with the POSIX
3444model. Libev still offers limited functionality on this platform in 3458model. Libev still offers limited functionality on this platform in
3445the form of the C<EVBACKEND_SELECT> backend, and only supports socket 3459the form of the C<EVBACKEND_SELECT> backend, and only supports socket
3456 3470
3457Not a libev limitation but worth mentioning: windows apparently doesn't 3471Not a libev limitation but worth mentioning: windows apparently doesn't
3458accept large writes: instead of resulting in a partial write, windows will 3472accept large writes: instead of resulting in a partial write, windows will
3459either accept everything or return C<ENOBUFS> if the buffer is too large, 3473either accept everything or return C<ENOBUFS> if the buffer is too large,
3460so make sure you only write small amounts into your sockets (less than a 3474so make sure you only write small amounts into your sockets (less than a
3461megabyte seems safe, but thsi apparently depends on the amount of memory 3475megabyte seems safe, but this apparently depends on the amount of memory
3462available). 3476available).
3463 3477
3464Due to the many, low, and arbitrary limits on the win32 platform and 3478Due to the many, low, and arbitrary limits on the win32 platform and
3465the abysmal performance of winsockets, using a large number of sockets 3479the abysmal performance of winsockets, using a large number of sockets
3466is not recommended (and not reasonable). If your program needs to use 3480is not recommended (and not reasonable). If your program needs to use
3477 #define EV_SELECT_IS_WINSOCKET 1 /* configure libev for windows select */ 3491 #define EV_SELECT_IS_WINSOCKET 1 /* configure libev for windows select */
3478 3492
3479 #include "ev.h" 3493 #include "ev.h"
3480 3494
3481And compile the following F<evwrap.c> file into your project (make sure 3495And compile the following F<evwrap.c> file into your project (make sure
3482you do I<not> compile the F<ev.c> or any other embedded soruce files!): 3496you do I<not> compile the F<ev.c> or any other embedded source files!):
3483 3497
3484 #include "evwrap.h" 3498 #include "evwrap.h"
3485 #include "ev.c" 3499 #include "ev.c"
3486 3500
3487=over 4 3501=over 4
3532wrap all I/O functions and provide your own fd management, but the cost of 3546wrap all I/O functions and provide your own fd management, but the cost of
3533calling select (O(n²)) will likely make this unworkable. 3547calling select (O(n²)) will likely make this unworkable.
3534 3548
3535=back 3549=back
3536 3550
3537
3538=head1 PORTABILITY REQUIREMENTS 3551=head2 PORTABILITY REQUIREMENTS
3539 3552
3540In addition to a working ISO-C implementation, libev relies on a few 3553In addition to a working ISO-C implementation and of course the
3541additional extensions: 3554backend-specific APIs, libev relies on a few additional extensions:
3542 3555
3543=over 4 3556=over 4
3544 3557
3545=item C<void (*)(ev_watcher_type *, int revents)> must have compatible 3558=item C<void (*)(ev_watcher_type *, int revents)> must have compatible
3546calling conventions regardless of C<ev_watcher_type *>. 3559calling conventions regardless of C<ev_watcher_type *>.
3552calls them using an C<ev_watcher *> internally. 3565calls them using an C<ev_watcher *> internally.
3553 3566
3554=item C<sig_atomic_t volatile> must be thread-atomic as well 3567=item C<sig_atomic_t volatile> must be thread-atomic as well
3555 3568
3556The type C<sig_atomic_t volatile> (or whatever is defined as 3569The type C<sig_atomic_t volatile> (or whatever is defined as
3557C<EV_ATOMIC_T>) must be atomic w.r.t. accesses from different 3570C<EV_ATOMIC_T>) must be atomic with respect to accesses from different
3558threads. This is not part of the specification for C<sig_atomic_t>, but is 3571threads. This is not part of the specification for C<sig_atomic_t>, but is
3559believed to be sufficiently portable. 3572believed to be sufficiently portable.
3560 3573
3561=item C<sigprocmask> must work in a threaded environment 3574=item C<sigprocmask> must work in a threaded environment
3562 3575
3571except the initial one, and run the default loop in the initial thread as 3584except the initial one, and run the default loop in the initial thread as
3572well. 3585well.
3573 3586
3574=item C<long> must be large enough for common memory allocation sizes 3587=item C<long> must be large enough for common memory allocation sizes
3575 3588
3576To improve portability and simplify using libev, libev uses C<long> 3589To improve portability and simplify its API, libev uses C<long> internally
3577internally instead of C<size_t> when allocating its data structures. On 3590instead of C<size_t> when allocating its data structures. On non-POSIX
3578non-POSIX systems (Microsoft...) this might be unexpectedly low, but 3591systems (Microsoft...) this might be unexpectedly low, but is still at
3579is still at least 31 bits everywhere, which is enough for hundreds of 3592least 31 bits everywhere, which is enough for hundreds of millions of
3580millions of watchers. 3593watchers.
3581 3594
3582=item C<double> must hold a time value in seconds with enough accuracy 3595=item C<double> must hold a time value in seconds with enough accuracy
3583 3596
3584The type C<double> is used to represent timestamps. It is required to 3597The type C<double> is used to represent timestamps. It is required to
3585have at least 51 bits of mantissa (and 9 bits of exponent), which is good 3598have at least 51 bits of mantissa (and 9 bits of exponent), which is good
3589=back 3602=back
3590 3603
3591If you know of other additional requirements drop me a note. 3604If you know of other additional requirements drop me a note.
3592 3605
3593 3606
3594=head1 COMPILER WARNINGS 3607=head1 ALGORITHMIC COMPLEXITIES
3595 3608
3596Depending on your compiler and compiler settings, you might get no or a 3609In this section the complexities of (many of) the algorithms used inside
3597lot of warnings when compiling libev code. Some people are apparently 3610libev will be documented. For complexity discussions about backends see
3598scared by this. 3611the documentation for C<ev_default_init>.
3599 3612
3600However, these are unavoidable for many reasons. For one, each compiler 3613All of the following are about amortised time: If an array needs to be
3601has different warnings, and each user has different tastes regarding 3614extended, libev needs to realloc and move the whole array, but this
3602warning options. "Warn-free" code therefore cannot be a goal except when 3615happens asymptotically rarer with higher number of elements, so O(1) might
3603targeting a specific compiler and compiler-version. 3616mean that libev does a lengthy realloc operation in rare cases, but on
3617average it is much faster and asymptotically approaches constant time.
3604 3618
3605Another reason is that some compiler warnings require elaborate 3619=over 4
3606workarounds, or other changes to the code that make it less clear and less
3607maintainable.
3608 3620
3609And of course, some compiler warnings are just plain stupid, or simply 3621=item Starting and stopping timer/periodic watchers: O(log skipped_other_timers)
3610wrong (because they don't actually warn about the condition their message
3611seems to warn about).
3612 3622
3613While libev is written to generate as few warnings as possible, 3623This means that, when you have a watcher that triggers in one hour and
3614"warn-free" code is not a goal, and it is recommended not to build libev 3624there are 100 watchers that would trigger before that, then inserting will
3615with any compiler warnings enabled unless you are prepared to cope with 3625have to skip roughly seven (C<ld 100>) of these watchers.
3616them (e.g. by ignoring them). Remember that warnings are just that:
3617warnings, not errors, or proof of bugs.
3618 3626
3627=item Changing timer/periodic watchers (by autorepeat or calling again): O(log skipped_other_timers)
3619 3628
3620=head1 VALGRIND 3629That means that changing a timer costs less than removing/adding them,
3630as only the relative motion in the event queue has to be paid for.
3621 3631
3622Valgrind has a special section here because it is a popular tool that is 3632=item Starting io/check/prepare/idle/signal/child/fork/async watchers: O(1)
3623highly useful, but valgrind reports are very hard to interpret.
3624 3633
3625If you think you found a bug (memory leak, uninitialised data access etc.) 3634These just add the watcher into an array or at the head of a list.
3626in libev, then check twice: If valgrind reports something like:
3627 3635
3628 ==2274== definitely lost: 0 bytes in 0 blocks. 3636=item Stopping check/prepare/idle/fork/async watchers: O(1)
3629 ==2274== possibly lost: 0 bytes in 0 blocks.
3630 ==2274== still reachable: 256 bytes in 1 blocks.
3631 3637
3632Then there is no memory leak. Similarly, under some circumstances, 3638=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE))
3633valgrind might report kernel bugs as if it were a bug in libev, or it
3634might be confused (it is a very good tool, but only a tool).
3635 3639
3636If you are unsure about something, feel free to contact the mailing list 3640These watchers are stored in lists, so they need to be walked to find the
3637with the full valgrind report and an explanation on why you think this is 3641correct watcher to remove. The lists are usually short (you don't usually
3638a bug in libev. However, don't be annoyed when you get a brisk "this is 3642have many watchers waiting for the same fd or signal: one is typical, two
3639no bug" answer and take the chance of learning how to interpret valgrind 3643is rare).
3640properly.
3641 3644
3642If you need, for some reason, empty reports from valgrind for your project 3645=item Finding the next timer in each loop iteration: O(1)
3643I suggest using suppression lists. 3646
3647By virtue of using a binary or 4-heap, the next timer is always found at a
3648fixed position in the storage array.
3649
3650=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
3651
3652A change means an I/O watcher gets started or stopped, which requires
3653libev to recalculate its status (and possibly tell the kernel, depending
3654on backend and whether C<ev_io_set> was used).
3655
3656=item Activating one watcher (putting it into the pending state): O(1)
3657
3658=item Priority handling: O(number_of_priorities)
3659
3660Priorities are implemented by allocating some space for each
3661priority. When doing priority-based operations, libev usually has to
3662linearly search all the priorities, but starting/stopping and activating
3663watchers becomes O(1) with respect to priority handling.
3664
3665=item Sending an ev_async: O(1)
3666
3667=item Processing ev_async_send: O(number_of_async_watchers)
3668
3669=item Processing signals: O(max_signal_number)
3670
3671Sending involves a system call I<iff> there were no other C<ev_async_send>
3672calls in the current loop iteration. Checking for async and signal events
3673involves iterating over all running async watchers or all signal numbers.
3674
3675=back
3644 3676
3645 3677
3646=head1 AUTHOR 3678=head1 AUTHOR
3647 3679
3648Marc Lehmann <libev@schmorp.de>. 3680Marc Lehmann <libev@schmorp.de>.

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines