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

Comparing libev/ev.pod (file contents):
Revision 1.319 by root, Fri Oct 22 10:09:12 2010 UTC vs.
Revision 1.340 by root, Wed Nov 3 20:03:21 2010 UTC

43 43
44 int 44 int
45 main (void) 45 main (void)
46 { 46 {
47 // use the default event loop unless you have special needs 47 // use the default event loop unless you have special needs
48 struct ev_loop *loop = ev_default_loop (0); 48 struct ev_loop *loop = EV_DEFAULT;
49 49
50 // initialise an io watcher, then start it 50 // initialise an io watcher, then start it
51 // this one will watch for stdin to become readable 51 // this one will watch for stdin to become readable
52 ev_io_init (&stdin_watcher, stdin_cb, /*STDIN_FILENO*/ 0, EV_READ); 52 ev_io_init (&stdin_watcher, stdin_cb, /*STDIN_FILENO*/ 0, EV_READ);
53 ev_io_start (loop, &stdin_watcher); 53 ev_io_start (loop, &stdin_watcher);
77on event-based programming, nor will it introduce event-based programming 77on event-based programming, nor will it introduce event-based programming
78with libev. 78with libev.
79 79
80Familiarity with event based programming techniques in general is assumed 80Familiarity with event based programming techniques in general is assumed
81throughout this document. 81throughout this document.
82
83=head1 WHAT TO READ WHEN IN A HURRY
84
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
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
89C<ev_timer> sections in L<WATCHER TYPES>.
82 90
83=head1 ABOUT LIBEV 91=head1 ABOUT LIBEV
84 92
85Libev 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
86file descriptor being readable or a timeout occurring), and it will manage 94file descriptor being readable or a timeout occurring), and it will manage
165 173
166=item ev_tstamp ev_time () 174=item ev_tstamp ev_time ()
167 175
168Returns the current time as libev would use it. Please note that the 176Returns the current time as libev would use it. Please note that the
169C<ev_now> function is usually faster and also often returns the timestamp 177C<ev_now> function is usually faster and also often returns the timestamp
170you actually want to know. Also interetsing is the combination of 178you actually want to know. Also interesting is the combination of
171C<ev_update_now> and C<ev_now>. 179C<ev_update_now> and C<ev_now>.
172 180
173=item ev_sleep (ev_tstamp interval) 181=item ev_sleep (ev_tstamp interval)
174 182
175Sleep for the given interval: The current thread will be blocked until 183Sleep for the given interval: The current thread will be blocked until
193as this indicates an incompatible change. Minor versions are usually 201as this indicates an incompatible change. Minor versions are usually
194compatible to older versions, so a larger minor version alone is usually 202compatible to older versions, so a larger minor version alone is usually
195not a problem. 203not a problem.
196 204
197Example: Make sure we haven't accidentally been linked against the wrong 205Example: Make sure we haven't accidentally been linked against the wrong
198version (note, however, that this will not detect ABI mismatches :). 206version (note, however, that this will not detect other ABI mismatches,
207such as LFS or reentrancy).
199 208
200 assert (("libev version mismatch", 209 assert (("libev version mismatch",
201 ev_version_major () == EV_VERSION_MAJOR 210 ev_version_major () == EV_VERSION_MAJOR
202 && ev_version_minor () >= EV_VERSION_MINOR)); 211 && ev_version_minor () >= EV_VERSION_MINOR));
203 212
232the current system, you would need to look at C<ev_embeddable_backends () 241the current system, you would need to look at C<ev_embeddable_backends ()
233& ev_supported_backends ()>, likewise for recommended ones. 242& ev_supported_backends ()>, likewise for recommended ones.
234 243
235See the description of C<ev_embed> watchers for more info. 244See the description of C<ev_embed> watchers for more info.
236 245
237=item ev_set_allocator (void *(*cb)(void *ptr, long size)) [NOT REENTRANT] 246=item ev_set_allocator (void *(*cb)(void *ptr, long size))
238 247
239Sets the allocation function to use (the prototype is similar - the 248Sets the allocation function to use (the prototype is similar - the
240semantics are identical to the C<realloc> C89/SuS/POSIX function). It is 249semantics are identical to the C<realloc> C89/SuS/POSIX function). It is
241used to allocate and free memory (no surprises here). If it returns zero 250used to allocate and free memory (no surprises here). If it returns zero
242when memory needs to be allocated (C<size != 0>), the library might abort 251when memory needs to be allocated (C<size != 0>), the library might abort
268 } 277 }
269 278
270 ... 279 ...
271 ev_set_allocator (persistent_realloc); 280 ev_set_allocator (persistent_realloc);
272 281
273=item ev_set_syserr_cb (void (*cb)(const char *msg)); [NOT REENTRANT] 282=item ev_set_syserr_cb (void (*cb)(const char *msg))
274 283
275Set the callback function to call on a retryable system call error (such 284Set the callback function to call on a retryable system call error (such
276as failed select, poll, epoll_wait). The message is a printable string 285as failed select, poll, epoll_wait). The message is a printable string
277indicating the system call or subsystem causing the problem. If this 286indicating the system call or subsystem causing the problem. If this
278callback is set, then libev will expect it to remedy the situation, no 287callback is set, then libev will expect it to remedy the situation, no
292 ... 301 ...
293 ev_set_syserr_cb (fatal_error); 302 ev_set_syserr_cb (fatal_error);
294 303
295=back 304=back
296 305
297=head1 FUNCTIONS CONTROLLING THE EVENT LOOP 306=head1 FUNCTIONS CONTROLLING EVENT LOOPS
298 307
299An event loop is described by a C<struct ev_loop *> (the C<struct> is 308An event loop is described by a C<struct ev_loop *> (the C<struct> is
300I<not> optional in this case unless libev 3 compatibility is disabled, as 309I<not> optional in this case unless libev 3 compatibility is disabled, as
301libev 3 had an C<ev_loop> function colliding with the struct name). 310libev 3 had an C<ev_loop> function colliding with the struct name).
302 311
303The library knows two types of such loops, the I<default> loop, which 312The library knows two types of such loops, the I<default> loop, which
304supports signals and child events, and dynamically created event loops 313supports child process events, and dynamically created event loops which
305which do not. 314do not.
306 315
307=over 4 316=over 4
308 317
309=item struct ev_loop *ev_default_loop (unsigned int flags) 318=item struct ev_loop *ev_default_loop (unsigned int flags)
310 319
311This will initialise the default event loop if it hasn't been initialised 320This returns the "default" event loop object, which is what you should
312yet and return it. If the default loop could not be initialised, returns 321normally use when you just need "the event loop". Event loop objects and
313false. If it already was initialised it simply returns it (and ignores the 322the C<flags> parameter are described in more detail in the entry for
314flags. If that is troubling you, check C<ev_backend ()> afterwards). 323C<ev_loop_new>.
324
325If the default loop is already initialised then this function simply
326returns it (and ignores the flags. If that is troubling you, check
327C<ev_backend ()> afterwards). Otherwise it will create it with the given
328flags, which should almost always be C<0>, unless the caller is also the
329one calling C<ev_run> or otherwise qualifies as "the main program".
315 330
316If you don't know what event loop to use, use the one returned from this 331If you don't know what event loop to use, use the one returned from this
317function. 332function (or via the C<EV_DEFAULT> macro).
318 333
319Note that this function is I<not> thread-safe, so if you want to use it 334Note that this function is I<not> thread-safe, so if you want to use it
320from multiple threads, you have to lock (note also that this is unlikely, 335from multiple threads, you have to employ some kind of mutex (note also
321as loops cannot be shared easily between threads anyway). 336that this case is unlikely, as loops cannot be shared easily between
337threads anyway).
322 338
323The default loop is the only loop that can handle C<ev_signal> and 339The default loop is the only loop that can handle C<ev_child> watchers,
324C<ev_child> watchers, and to do this, it always registers a handler 340and to do this, it always registers a handler for C<SIGCHLD>. If this is
325for C<SIGCHLD>. If this is a problem for your application you can either 341a problem for your application you can either create a dynamic loop with
326create a dynamic loop with C<ev_loop_new> that doesn't do that, or you 342C<ev_loop_new> which doesn't do that, or you can simply overwrite the
327can simply overwrite the C<SIGCHLD> signal handler I<after> calling 343C<SIGCHLD> signal handler I<after> calling C<ev_default_init>.
328C<ev_default_init>. 344
345Example: This is the most typical usage.
346
347 if (!ev_default_loop (0))
348 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
349
350Example: Restrict libev to the select and poll backends, and do not allow
351environment settings to be taken into account:
352
353 ev_default_loop (EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV);
354
355=item struct ev_loop *ev_loop_new (unsigned int flags)
356
357This will create and initialise a new event loop object. If the loop
358could not be initialised, returns false.
359
360Note that this function I<is> thread-safe, and one common way to use
361libev with threads is indeed to create one loop per thread, and using the
362default loop in the "main" or "initial" thread.
329 363
330The flags argument can be used to specify special behaviour or specific 364The flags argument can be used to specify special behaviour or specific
331backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>). 365backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>).
332 366
333The following flags are supported: 367The following flags are supported:
368environment variable. 402environment variable.
369 403
370=item C<EVFLAG_NOINOTIFY> 404=item C<EVFLAG_NOINOTIFY>
371 405
372When this flag is specified, then libev will not attempt to use the 406When this flag is specified, then libev will not attempt to use the
373I<inotify> API for it's C<ev_stat> watchers. Apart from debugging and 407I<inotify> API for its C<ev_stat> watchers. Apart from debugging and
374testing, this flag can be useful to conserve inotify file descriptors, as 408testing, this flag can be useful to conserve inotify file descriptors, as
375otherwise each loop using C<ev_stat> watchers consumes one inotify handle. 409otherwise each loop using C<ev_stat> watchers consumes one inotify handle.
376 410
377=item C<EVFLAG_SIGNALFD> 411=item C<EVFLAG_SIGNALFD>
378 412
379When this flag is specified, then libev will attempt to use the 413When this flag is specified, then libev will attempt to use the
380I<signalfd> API for it's C<ev_signal> (and C<ev_child>) watchers. This API 414I<signalfd> API for its C<ev_signal> (and C<ev_child>) watchers. This API
381delivers signals synchronously, which makes it both faster and might make 415delivers signals synchronously, which makes it both faster and might make
382it possible to get the queued signal data. It can also simplify signal 416it possible to get the queued signal data. It can also simplify signal
383handling with threads, as long as you properly block signals in your 417handling with threads, as long as you properly block signals in your
384threads that are not interested in handling them. 418threads that are not interested in handling them.
385 419
429epoll scales either O(1) or O(active_fds). 463epoll scales either O(1) or O(active_fds).
430 464
431The epoll mechanism deserves honorable mention as the most misdesigned 465The epoll mechanism deserves honorable mention as the most misdesigned
432of the more advanced event mechanisms: mere annoyances include silently 466of the more advanced event mechanisms: mere annoyances include silently
433dropping file descriptors, requiring a system call per change per file 467dropping file descriptors, requiring a system call per change per file
434descriptor (and unnecessary guessing of parameters), problems with dup and 468descriptor (and unnecessary guessing of parameters), problems with dup,
469returning before the timeout value, resulting in additional iterations
470(and only giving 5ms accuracy while select on the same platform gives
435so on. The biggest issue is fork races, however - if a program forks then 4710.1ms) and so on. The biggest issue is fork races, however - if a program
436I<both> parent and child process have to recreate the epoll set, which can 472forks then I<both> parent and child process have to recreate the epoll
437take considerable time (one syscall per file descriptor) and is of course 473set, which can take considerable time (one syscall per file descriptor)
438hard to detect. 474and is of course hard to detect.
439 475
440Epoll is also notoriously buggy - embedding epoll fds I<should> work, but 476Epoll is also notoriously buggy - embedding epoll fds I<should> work, but
441of course I<doesn't>, and epoll just loves to report events for totally 477of course I<doesn't>, and epoll just loves to report events for totally
442I<different> file descriptors (even already closed ones, so one cannot 478I<different> file descriptors (even already closed ones, so one cannot
443even remove them from the set) than registered in the set (especially 479even remove them from the set) than registered in the set (especially
445employing an additional generation counter and comparing that against the 481employing an additional generation counter and comparing that against the
446events to filter out spurious ones, recreating the set when required. Last 482events to filter out spurious ones, recreating the set when required. Last
447not least, it also refuses to work with some file descriptors which work 483not least, it also refuses to work with some file descriptors which work
448perfectly fine with C<select> (files, many character devices...). 484perfectly fine with C<select> (files, many character devices...).
449 485
486Epoll is truly the train wreck analog among event poll mechanisms.
487
450While stopping, setting and starting an I/O watcher in the same iteration 488While stopping, setting and starting an I/O watcher in the same iteration
451will result in some caching, there is still a system call per such 489will result in some caching, there is still a system call per such
452incident (because the same I<file descriptor> could point to a different 490incident (because the same I<file descriptor> could point to a different
453I<file description> now), so its best to avoid that. Also, C<dup ()>'ed 491I<file description> now), so its best to avoid that. Also, C<dup ()>'ed
454file descriptors might not work very well if you register events for both 492file descriptors might not work very well if you register events for both
551If one or more of the backend flags are or'ed into the flags value, 589If one or more of the backend flags are or'ed into the flags value,
552then only these backends will be tried (in the reverse order as listed 590then only these backends will be tried (in the reverse order as listed
553here). If none are specified, all backends in C<ev_recommended_backends 591here). If none are specified, all backends in C<ev_recommended_backends
554()> will be tried. 592()> will be tried.
555 593
556Example: This is the most typical usage.
557
558 if (!ev_default_loop (0))
559 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
560
561Example: Restrict libev to the select and poll backends, and do not allow
562environment settings to be taken into account:
563
564 ev_default_loop (EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV);
565
566Example: Use whatever libev has to offer, but make sure that kqueue is
567used if available (warning, breaks stuff, best use only with your own
568private event loop and only if you know the OS supports your types of
569fds):
570
571 ev_default_loop (ev_recommended_backends () | EVBACKEND_KQUEUE);
572
573=item struct ev_loop *ev_loop_new (unsigned int flags)
574
575Similar to C<ev_default_loop>, but always creates a new event loop that is
576always distinct from the default loop.
577
578Note that this function I<is> thread-safe, and one common way to use
579libev with threads is indeed to create one loop per thread, and using the
580default loop in the "main" or "initial" thread.
581
582Example: Try to create a event loop that uses epoll and nothing else. 594Example: Try to create a event loop that uses epoll and nothing else.
583 595
584 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV); 596 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
585 if (!epoller) 597 if (!epoller)
586 fatal ("no epoll found here, maybe it hides under your chair"); 598 fatal ("no epoll found here, maybe it hides under your chair");
587 599
600Example: Use whatever libev has to offer, but make sure that kqueue is
601used if available.
602
603 struct ev_loop *loop = ev_loop_new (ev_recommended_backends () | EVBACKEND_KQUEUE);
604
588=item ev_default_destroy () 605=item ev_loop_destroy (loop)
589 606
590Destroys the default loop (frees all memory and kernel state etc.). None 607Destroys an event loop object (frees all memory and kernel state
591of the active event watchers will be stopped in the normal sense, so 608etc.). None of the active event watchers will be stopped in the normal
592e.g. C<ev_is_active> might still return true. It is your responsibility to 609sense, so e.g. C<ev_is_active> might still return true. It is your
593either stop all watchers cleanly yourself I<before> calling this function, 610responsibility to either stop all watchers cleanly yourself I<before>
594or cope with the fact afterwards (which is usually the easiest thing, you 611calling this function, or cope with the fact afterwards (which is usually
595can just ignore the watchers and/or C<free ()> them for example). 612the easiest thing, you can just ignore the watchers and/or C<free ()> them
613for example).
596 614
597Note that certain global state, such as signal state (and installed signal 615Note that certain global state, such as signal state (and installed signal
598handlers), will not be freed by this function, and related watchers (such 616handlers), will not be freed by this function, and related watchers (such
599as signal and child watchers) would need to be stopped manually. 617as signal and child watchers) would need to be stopped manually.
600 618
601In general it is not advisable to call this function except in the 619This function is normally used on loop objects allocated by
602rare occasion where you really need to free e.g. the signal handling 620C<ev_loop_new>, but it can also be used on the default loop returned by
621C<ev_default_loop>, in which case it is not thread-safe.
622
623Note that it is not advisable to call this function on the default loop
624except in the rare occasion where you really need to free its resources.
603pipe fds. If you need dynamically allocated loops it is better to use 625If you need dynamically allocated loops it is better to use C<ev_loop_new>
604C<ev_loop_new> and C<ev_loop_destroy>. 626and C<ev_loop_destroy>.
605 627
606=item ev_loop_destroy (loop) 628=item ev_loop_fork (loop)
607 629
608Like C<ev_default_destroy>, but destroys an event loop created by an
609earlier call to C<ev_loop_new>.
610
611=item ev_default_fork ()
612
613This function sets a flag that causes subsequent C<ev_run> iterations 630This function sets a flag that causes subsequent C<ev_run> iterations to
614to reinitialise the kernel state for backends that have one. Despite the 631reinitialise the kernel state for backends that have one. Despite the
615name, you can call it anytime, but it makes most sense after forking, in 632name, you can call it anytime, but it makes most sense after forking, in
616the child process (or both child and parent, but that again makes little 633the child process. You I<must> call it (or use C<EVFLAG_FORKCHECK>) in the
617sense). You I<must> call it in the child before using any of the libev 634child before resuming or calling C<ev_run>.
618functions, and it will only take effect at the next C<ev_run> iteration.
619 635
620Again, you I<have> to call it on I<any> loop that you want to re-use after 636Again, you I<have> to call it on I<any> loop that you want to re-use after
621a fork, I<even if you do not plan to use the loop in the parent>. This is 637a fork, I<even if you do not plan to use the loop in the parent>. This is
622because some kernel interfaces *cough* I<kqueue> *cough* do funny things 638because some kernel interfaces *cough* I<kqueue> *cough* do funny things
623during fork. 639during fork.
628call it at all (in fact, C<epoll> is so badly broken that it makes a 644call it at all (in fact, C<epoll> is so badly broken that it makes a
629difference, but libev will usually detect this case on its own and do a 645difference, but libev will usually detect this case on its own and do a
630costly reset of the backend). 646costly reset of the backend).
631 647
632The function itself is quite fast and it's usually not a problem to call 648The function itself is quite fast and it's usually not a problem to call
633it just in case after a fork. To make this easy, the function will fit in 649it just in case after a fork.
634quite nicely into a call to C<pthread_atfork>:
635 650
651Example: Automate calling C<ev_loop_fork> on the default loop when
652using pthreads.
653
654 static void
655 post_fork_child (void)
656 {
657 ev_loop_fork (EV_DEFAULT);
658 }
659
660 ...
636 pthread_atfork (0, 0, ev_default_fork); 661 pthread_atfork (0, 0, post_fork_child);
637
638=item ev_loop_fork (loop)
639
640Like C<ev_default_fork>, but acts on an event loop created by
641C<ev_loop_new>. Yes, you have to call this on every allocated event loop
642after fork that you want to re-use in the child, and how you keep track of
643them is entirely your own problem.
644 662
645=item int ev_is_default_loop (loop) 663=item int ev_is_default_loop (loop)
646 664
647Returns true when the given loop is, in fact, the default loop, and false 665Returns true when the given loop is, in fact, the default loop, and false
648otherwise. 666otherwise.
809Can be used to make a call to C<ev_run> return early (but only after it 827Can be used to make a call to C<ev_run> return early (but only after it
810has processed all outstanding events). The C<how> argument must be either 828has processed all outstanding events). The C<how> argument must be either
811C<EVBREAK_ONE>, which will make the innermost C<ev_run> call return, or 829C<EVBREAK_ONE>, which will make the innermost C<ev_run> call return, or
812C<EVBREAK_ALL>, which will make all nested C<ev_run> calls return. 830C<EVBREAK_ALL>, which will make all nested C<ev_run> calls return.
813 831
814This "unloop state" will be cleared when entering C<ev_run> again. 832This "break state" will be cleared when entering C<ev_run> again.
815 833
816It is safe to call C<ev_break> from outside any C<ev_run> calls. ##TODO## 834It is safe to call C<ev_break> from outside any C<ev_run> calls, too.
817 835
818=item ev_ref (loop) 836=item ev_ref (loop)
819 837
820=item ev_unref (loop) 838=item ev_unref (loop)
821 839
1106=item C<EV_FORK> 1124=item C<EV_FORK>
1107 1125
1108The event loop has been resumed in the child process after fork (see 1126The event loop has been resumed in the child process after fork (see
1109C<ev_fork>). 1127C<ev_fork>).
1110 1128
1129=item C<EV_CLEANUP>
1130
1131The event loop is about to be destroyed (see C<ev_cleanup>).
1132
1111=item C<EV_ASYNC> 1133=item C<EV_ASYNC>
1112 1134
1113The given async watcher has been asynchronously notified (see C<ev_async>). 1135The given async watcher has been asynchronously notified (see C<ev_async>).
1114 1136
1115=item C<EV_CUSTOM> 1137=item C<EV_CUSTOM>
1136programs, though, as the fd could already be closed and reused for another 1158programs, though, as the fd could already be closed and reused for another
1137thing, so beware. 1159thing, so beware.
1138 1160
1139=back 1161=back
1140 1162
1141=head2 WATCHER STATES
1142
1143There are various watcher states mentioned throughout this manual -
1144active, pending and so on. In this section these states and the rules to
1145transition between them will be described in more detail - and while these
1146rules might look complicated, they usually do "the right thing".
1147
1148=over 4
1149
1150=item initialiased
1151
1152Before a watcher can be registered with the event looop it has to be
1153initialised. This can be done with a call to C<ev_TYPE_init>, or calls to
1154C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1155
1156In this state it is simply some block of memory that is suitable for use
1157in an event loop. It can be moved around, freed, reused etc. at will.
1158
1159=item started/running/active
1160
1161Once a watcher has been started with a call to C<ev_TYPE_start> it becomes
1162property of the event loop, and is actively waiting for events. While in
1163this state it cannot be accessed (except in a few documented ways), moved,
1164freed or anything else - the only legal thing is to keep a pointer to it,
1165and call libev functions on it that are documented to work on active watchers.
1166
1167=item pending
1168
1169If a watcher is active and libev determines that an event it is interested
1170in has occurred (such as a timer expiring), it will become pending. It will
1171stay in this pending state until either it is stopped or its callback is
1172about to be invoked, so it is not normally pending inside the watcher
1173callback.
1174
1175The watcher might or might not be active while it is pending (for example,
1176an expired non-repeating timer can be pending but no longer active). If it
1177is stopped, it can be freely accessed (e.g. by calling C<ev_TYPE_set>),
1178but it is still property of the event loop at this time, so cannot be
1179moved, freed or reused. And if it is active the rules described in the
1180previous item still apply.
1181
1182It is also possible to feed an event on a watcher that is not active (e.g.
1183via C<ev_feed_event>), in which case it becomes pending without being
1184active.
1185
1186=item stopped
1187
1188A watcher can be stopped implicitly by libev (in which case it might still
1189be pending), or explicitly by calling its C<ev_TYPE_stop> function. The
1190latter will clear any pending state the watcher might be in, regardless
1191of whether it was active or not, so stopping a watcher explicitly before
1192freeing it is often a good idea.
1193
1194While stopped (and not pending) the watcher is essentially in the
1195initialised state, that is it can be reused, moved, modified in any way
1196you wish.
1197
1198=back
1199
1200=head2 GENERIC WATCHER FUNCTIONS 1163=head2 GENERIC WATCHER FUNCTIONS
1201 1164
1202=over 4 1165=over 4
1203 1166
1204=item C<ev_init> (ev_TYPE *watcher, callback) 1167=item C<ev_init> (ev_TYPE *watcher, callback)
1345 1308
1346See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related 1309See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1347functions that do not need a watcher. 1310functions that do not need a watcher.
1348 1311
1349=back 1312=back
1350
1351 1313
1352=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER 1314=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
1353 1315
1354Each watcher has, by default, a member C<void *data> that you can change 1316Each watcher has, by default, a member C<void *data> that you can change
1355and read at any time: libev will completely ignore it. This can be used 1317and read at any time: libev will completely ignore it. This can be used
1411 t2_cb (EV_P_ ev_timer *w, int revents) 1373 t2_cb (EV_P_ ev_timer *w, int revents)
1412 { 1374 {
1413 struct my_biggy big = (struct my_biggy *) 1375 struct my_biggy big = (struct my_biggy *)
1414 (((char *)w) - offsetof (struct my_biggy, t2)); 1376 (((char *)w) - offsetof (struct my_biggy, t2));
1415 } 1377 }
1378
1379=head2 WATCHER STATES
1380
1381There are various watcher states mentioned throughout this manual -
1382active, pending and so on. In this section these states and the rules to
1383transition between them will be described in more detail - and while these
1384rules might look complicated, they usually do "the right thing".
1385
1386=over 4
1387
1388=item initialiased
1389
1390Before a watcher can be registered with the event looop it has to be
1391initialised. This can be done with a call to C<ev_TYPE_init>, or calls to
1392C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1393
1394In this state it is simply some block of memory that is suitable for use
1395in an event loop. It can be moved around, freed, reused etc. at will.
1396
1397=item started/running/active
1398
1399Once a watcher has been started with a call to C<ev_TYPE_start> it becomes
1400property of the event loop, and is actively waiting for events. While in
1401this state it cannot be accessed (except in a few documented ways), moved,
1402freed or anything else - the only legal thing is to keep a pointer to it,
1403and call libev functions on it that are documented to work on active watchers.
1404
1405=item pending
1406
1407If a watcher is active and libev determines that an event it is interested
1408in has occurred (such as a timer expiring), it will become pending. It will
1409stay in this pending state until either it is stopped or its callback is
1410about to be invoked, so it is not normally pending inside the watcher
1411callback.
1412
1413The watcher might or might not be active while it is pending (for example,
1414an expired non-repeating timer can be pending but no longer active). If it
1415is stopped, it can be freely accessed (e.g. by calling C<ev_TYPE_set>),
1416but it is still property of the event loop at this time, so cannot be
1417moved, freed or reused. And if it is active the rules described in the
1418previous item still apply.
1419
1420It is also possible to feed an event on a watcher that is not active (e.g.
1421via C<ev_feed_event>), in which case it becomes pending without being
1422active.
1423
1424=item stopped
1425
1426A watcher can be stopped implicitly by libev (in which case it might still
1427be pending), or explicitly by calling its C<ev_TYPE_stop> function. The
1428latter will clear any pending state the watcher might be in, regardless
1429of whether it was active or not, so stopping a watcher explicitly before
1430freeing it is often a good idea.
1431
1432While stopped (and not pending) the watcher is essentially in the
1433initialised state, that is it can be reused, moved, modified in any way
1434you wish.
1435
1436=back
1416 1437
1417=head2 WATCHER PRIORITY MODELS 1438=head2 WATCHER PRIORITY MODELS
1418 1439
1419Many event loops support I<watcher priorities>, which are usually small 1440Many event loops support I<watcher priorities>, which are usually small
1420integers that influence the ordering of event callback invocation 1441integers that influence the ordering of event callback invocation
2239 2260
2240=head2 C<ev_signal> - signal me when a signal gets signalled! 2261=head2 C<ev_signal> - signal me when a signal gets signalled!
2241 2262
2242Signal watchers will trigger an event when the process receives a specific 2263Signal watchers will trigger an event when the process receives a specific
2243signal one or more times. Even though signals are very asynchronous, libev 2264signal one or more times. Even though signals are very asynchronous, libev
2244will try it's best to deliver signals synchronously, i.e. as part of the 2265will try its best to deliver signals synchronously, i.e. as part of the
2245normal event processing, like any other event. 2266normal event processing, like any other event.
2246 2267
2247If you want signals to be delivered truly asynchronously, just use 2268If you want signals to be delivered truly asynchronously, just use
2248C<sigaction> as you would do without libev and forget about sharing 2269C<sigaction> as you would do without libev and forget about sharing
2249the signal. You can even use C<ev_async> from a signal handler to 2270the signal. You can even use C<ev_async> from a signal handler to
3074disadvantage of having to use multiple event loops (which do not support 3095disadvantage of having to use multiple event loops (which do not support
3075signal watchers). 3096signal watchers).
3076 3097
3077When this is not possible, or you want to use the default loop for 3098When this is not possible, or you want to use the default loop for
3078other reasons, then in the process that wants to start "fresh", call 3099other reasons, then in the process that wants to start "fresh", call
3079C<ev_default_destroy ()> followed by C<ev_default_loop (...)>. Destroying 3100C<ev_loop_destroy (EV_DEFAULT)> followed by C<ev_default_loop (...)>.
3080the default loop will "orphan" (not stop) all registered watchers, so you 3101Destroying the default loop will "orphan" (not stop) all registered
3081have to be careful not to execute code that modifies those watchers. Note 3102watchers, so you have to be careful not to execute code that modifies
3082also that in that case, you have to re-register any signal watchers. 3103those watchers. Note also that in that case, you have to re-register any
3104signal watchers.
3083 3105
3084=head3 Watcher-Specific Functions and Data Members 3106=head3 Watcher-Specific Functions and Data Members
3085 3107
3086=over 4 3108=over 4
3087 3109
3088=item ev_fork_init (ev_signal *, callback) 3110=item ev_fork_init (ev_fork *, callback)
3089 3111
3090Initialises and configures the fork watcher - it has no parameters of any 3112Initialises and configures the fork watcher - it has no parameters of any
3091kind. There is a C<ev_fork_set> macro, but using it is utterly pointless, 3113kind. There is a C<ev_fork_set> macro, but using it is utterly pointless,
3092believe me. 3114really.
3093 3115
3094=back 3116=back
3117
3118
3119=head2 C<ev_cleanup> - even the best things end
3120
3121Cleanup watchers are called just before the event loop is being destroyed
3122by a call to C<ev_loop_destroy>.
3123
3124While there is no guarantee that the event loop gets destroyed, cleanup
3125watchers provide a convenient method to install cleanup hooks for your
3126program, worker threads and so on - you just to make sure to destroy the
3127loop when you want them to be invoked.
3128
3129Cleanup watchers are invoked in the same way as any other watcher. Unlike
3130all other watchers, they do not keep a reference to the event loop (which
3131makes a lot of sense if you think about it). Like all other watchers, you
3132can call libev functions in the callback, except C<ev_cleanup_start>.
3133
3134=head3 Watcher-Specific Functions and Data Members
3135
3136=over 4
3137
3138=item ev_cleanup_init (ev_cleanup *, callback)
3139
3140Initialises and configures the cleanup watcher - it has no parameters of
3141any kind. There is a C<ev_cleanup_set> macro, but using it is utterly
3142pointless, I assure you.
3143
3144=back
3145
3146Example: Register an atexit handler to destroy the default loop, so any
3147cleanup functions are called.
3148
3149 static void
3150 program_exits (void)
3151 {
3152 ev_loop_destroy (EV_DEFAULT_UC);
3153 }
3154
3155 ...
3156 atexit (program_exits);
3095 3157
3096 3158
3097=head2 C<ev_async> - how to wake up an event loop 3159=head2 C<ev_async> - how to wake up an event loop
3098 3160
3099In general, you cannot use an C<ev_run> from multiple threads or other 3161In general, you cannot use an C<ev_run> from multiple threads or other
4706structure (guaranteed by POSIX but not by ISO C for example), but it also 4768structure (guaranteed by POSIX but not by ISO C for example), but it also
4707assumes that the same (machine) code can be used to call any watcher 4769assumes that the same (machine) code can be used to call any watcher
4708callback: The watcher callbacks have different type signatures, but libev 4770callback: The watcher callbacks have different type signatures, but libev
4709calls them using an C<ev_watcher *> internally. 4771calls them using an C<ev_watcher *> internally.
4710 4772
4773=item pointer accesses must be thread-atomic
4774
4775Accessing a pointer value must be atomic, it must both be readable and
4776writable in one piece - this is the case on all current architectures.
4777
4711=item C<sig_atomic_t volatile> must be thread-atomic as well 4778=item C<sig_atomic_t volatile> must be thread-atomic as well
4712 4779
4713The type C<sig_atomic_t volatile> (or whatever is defined as 4780The type C<sig_atomic_t volatile> (or whatever is defined as
4714C<EV_ATOMIC_T>) must be atomic with respect to accesses from different 4781C<EV_ATOMIC_T>) must be atomic with respect to accesses from different
4715threads. This is not part of the specification for C<sig_atomic_t>, but is 4782threads. This is not part of the specification for C<sig_atomic_t>, but is
4821=back 4888=back
4822 4889
4823 4890
4824=head1 PORTING FROM LIBEV 3.X TO 4.X 4891=head1 PORTING FROM LIBEV 3.X TO 4.X
4825 4892
4826The major version 4 introduced some minor incompatible changes to the API. 4893The major version 4 introduced some incompatible changes to the API.
4827 4894
4828At the moment, the C<ev.h> header file tries to implement superficial 4895At the moment, the C<ev.h> header file provides compatibility definitions
4829compatibility, so most programs should still compile. Those might be 4896for all changes, so most programs should still compile. The compatibility
4830removed in later versions of libev, so better update early than late. 4897layer might be removed in later versions of libev, so better update to the
4898new API early than late.
4831 4899
4832=over 4 4900=over 4
4901
4902=item C<EV_COMPAT3> backwards compatibility mechanism
4903
4904The backward compatibility mechanism can be controlled by
4905C<EV_COMPAT3>. See L<PREPROCESSOR SYMBOLS/MACROS> in the L<EMBEDDING>
4906section.
4907
4908=item C<ev_default_destroy> and C<ev_default_fork> have been removed
4909
4910These calls can be replaced easily by their C<ev_loop_xxx> counterparts:
4911
4912 ev_loop_destroy (EV_DEFAULT_UC);
4913 ev_loop_fork (EV_DEFAULT);
4833 4914
4834=item function/symbol renames 4915=item function/symbol renames
4835 4916
4836A number of functions and symbols have been renamed: 4917A number of functions and symbols have been renamed:
4837 4918
4856ev_loop> anymore and C<EV_TIMER> now follows the same naming scheme 4937ev_loop> anymore and C<EV_TIMER> now follows the same naming scheme
4857as all other watcher types. Note that C<ev_loop_fork> is still called 4938as all other watcher types. Note that C<ev_loop_fork> is still called
4858C<ev_loop_fork> because it would otherwise clash with the C<ev_fork> 4939C<ev_loop_fork> because it would otherwise clash with the C<ev_fork>
4859typedef. 4940typedef.
4860 4941
4861=item C<EV_COMPAT3> backwards compatibility mechanism
4862
4863The backward compatibility mechanism can be controlled by
4864C<EV_COMPAT3>. See L<PREPROCESSOR SYMBOLS/MACROS> in the L<EMBEDDING>
4865section.
4866
4867=item C<EV_MINIMAL> mechanism replaced by C<EV_FEATURES> 4942=item C<EV_MINIMAL> mechanism replaced by C<EV_FEATURES>
4868 4943
4869The preprocessor symbol C<EV_MINIMAL> has been replaced by a different 4944The preprocessor symbol C<EV_MINIMAL> has been replaced by a different
4870mechanism, C<EV_FEATURES>. Programs using C<EV_MINIMAL> usually compile 4945mechanism, C<EV_FEATURES>. Programs using C<EV_MINIMAL> usually compile
4871and work, but the library code will of course be larger. 4946and work, but the library code will of course be larger.
4945 5020
4946=back 5021=back
4947 5022
4948=head1 AUTHOR 5023=head1 AUTHOR
4949 5024
4950Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael Magnusson. 5025Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael
5026Magnusson and Emanuele Giaquinta.
4951 5027

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines