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

Comparing libev/ev.pod (file contents):
Revision 1.41 by root, Sat Nov 24 10:19:14 2007 UTC vs.
Revision 1.58 by root, Wed Nov 28 11:31:34 2007 UTC

3libev - a high performance full-featured event loop written in C 3libev - a high performance full-featured event loop written in C
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 #include <ev.h> 7 #include <ev.h>
8
9=head1 EXAMPLE PROGRAM
10
11 #include <ev.h>
12
13 ev_io stdin_watcher;
14 ev_timer timeout_watcher;
15
16 /* called when data readable on stdin */
17 static void
18 stdin_cb (EV_P_ struct ev_io *w, int revents)
19 {
20 /* puts ("stdin ready"); */
21 ev_io_stop (EV_A_ w); /* just a syntax example */
22 ev_unloop (EV_A_ EVUNLOOP_ALL); /* leave all loop calls */
23 }
24
25 static void
26 timeout_cb (EV_P_ struct ev_timer *w, int revents)
27 {
28 /* puts ("timeout"); */
29 ev_unloop (EV_A_ EVUNLOOP_ONE); /* leave one loop call */
30 }
31
32 int
33 main (void)
34 {
35 struct ev_loop *loop = ev_default_loop (0);
36
37 /* initialise an io watcher, then start it */
38 ev_io_init (&stdin_watcher, stdin_cb, /*STDIN_FILENO*/ 0, EV_READ);
39 ev_io_start (loop, &stdin_watcher);
40
41 /* simple non-repeating 5.5 second timeout */
42 ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);
43 ev_timer_start (loop, &timeout_watcher);
44
45 /* loop till timeout or data ready */
46 ev_loop (loop, 0);
47
48 return 0;
49 }
8 50
9=head1 DESCRIPTION 51=head1 DESCRIPTION
10 52
11Libev is an event loop: you register interest in certain events (such as a 53Libev is an event loop: you register interest in certain events (such as a
12file descriptor being readable or a timeout occuring), and it will manage 54file descriptor being readable or a timeout occuring), and it will manage
21details of the event, and then hand it over to libev by I<starting> the 63details of the event, and then hand it over to libev by I<starting> the
22watcher. 64watcher.
23 65
24=head1 FEATURES 66=head1 FEATURES
25 67
26Libev supports select, poll, the linux-specific epoll and the bsd-specific 68Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
27kqueue mechanisms for file descriptor events, relative timers, absolute 69BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
28timers with customised rescheduling, signal events, process status change 70for file descriptor events (C<ev_io>), the Linux C<inotify> interface
29events (related to SIGCHLD), and event watchers dealing with the event 71(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers
30loop mechanism itself (idle, prepare and check watchers). It also is quite 72with customised rescheduling (C<ev_periodic>), synchronous signals
73(C<ev_signal>), process status change events (C<ev_child>), and event
74watchers dealing with the event loop mechanism itself (C<ev_idle>,
75C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as
76file watchers (C<ev_stat>) and even limited support for fork events
77(C<ev_fork>).
78
79It also is quite fast (see this
31fast (see this L<benchmark|http://libev.schmorp.de/bench.html> comparing 80L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent
32it to libevent for example). 81for example).
33 82
34=head1 CONVENTIONS 83=head1 CONVENTIONS
35 84
36Libev is very configurable. In this manual the default configuration 85Libev is very configurable. In this manual the default configuration will
37will be described, which supports multiple event loops. For more info 86be described, which supports multiple event loops. For more info about
38about various configuration options please have a look at the file 87various configuration options please have a look at B<EMBED> section in
39F<README.embed> in the libev distribution. If libev was configured without 88this manual. If libev was configured without support for multiple event
40support for multiple event loops, then all functions taking an initial 89loops, then all functions taking an initial argument of name C<loop>
41argument of name C<loop> (which is always of type C<struct ev_loop *>) 90(which is always of type C<struct ev_loop *>) will not have this argument.
42will not have this argument.
43 91
44=head1 TIME REPRESENTATION 92=head1 TIME REPRESENTATION
45 93
46Libev represents time as a single floating point number, representing the 94Libev represents time as a single floating point number, representing the
47(fractional) number of seconds since the (POSIX) epoch (somewhere near 95(fractional) number of seconds since the (POSIX) epoch (somewhere near
48the beginning of 1970, details are complicated, don't ask). This type is 96the beginning of 1970, details are complicated, don't ask). This type is
49called C<ev_tstamp>, which is what you should use too. It usually aliases 97called C<ev_tstamp>, which is what you should use too. It usually aliases
50to the C<double> type in C, and when you need to do any calculations on 98to the C<double> type in C, and when you need to do any calculations on
51it, you should treat it as such. 99it, you should treat it as such.
52 100
53
54=head1 GLOBAL FUNCTIONS 101=head1 GLOBAL FUNCTIONS
55 102
56These functions can be called anytime, even before initialising the 103These functions can be called anytime, even before initialising the
57library in any way. 104library in any way.
58 105
77Usually, it's a good idea to terminate if the major versions mismatch, 124Usually, it's a good idea to terminate if the major versions mismatch,
78as this indicates an incompatible change. Minor versions are usually 125as this indicates an incompatible change. Minor versions are usually
79compatible to older versions, so a larger minor version alone is usually 126compatible to older versions, so a larger minor version alone is usually
80not a problem. 127not a problem.
81 128
82Example: make sure we haven't accidentally been linked against the wrong 129Example: Make sure we haven't accidentally been linked against the wrong
83version: 130version.
84 131
85 assert (("libev version mismatch", 132 assert (("libev version mismatch",
86 ev_version_major () == EV_VERSION_MAJOR 133 ev_version_major () == EV_VERSION_MAJOR
87 && ev_version_minor () >= EV_VERSION_MINOR)); 134 && ev_version_minor () >= EV_VERSION_MINOR));
88 135
116C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for 163C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
117recommended ones. 164recommended ones.
118 165
119See the description of C<ev_embed> watchers for more info. 166See the description of C<ev_embed> watchers for more info.
120 167
121=item ev_set_allocator (void *(*cb)(void *ptr, long size)) 168=item ev_set_allocator (void *(*cb)(void *ptr, size_t size))
122 169
123Sets the allocation function to use (the prototype is similar to the 170Sets the allocation function to use (the prototype and semantics are
124realloc C function, the semantics are identical). It is used to allocate 171identical to the realloc C function). It is used to allocate and free
125and free memory (no surprises here). If it returns zero when memory 172memory (no surprises here). If it returns zero when memory needs to be
126needs to be allocated, the library might abort or take some potentially 173allocated, the library might abort or take some potentially destructive
127destructive action. The default is your system realloc function. 174action. The default is your system realloc function.
128 175
129You could override this function in high-availability programs to, say, 176You could override this function in high-availability programs to, say,
130free some memory if it cannot allocate memory, to use a special allocator, 177free some memory if it cannot allocate memory, to use a special allocator,
131or even to sleep a while and retry until some memory is available. 178or even to sleep a while and retry until some memory is available.
132 179
133Example: replace the libev allocator with one that waits a bit and then 180Example: Replace the libev allocator with one that waits a bit and then
134retries: better than mine). 181retries).
135 182
136 static void * 183 static void *
137 persistent_realloc (void *ptr, long size) 184 persistent_realloc (void *ptr, size_t size)
138 { 185 {
139 for (;;) 186 for (;;)
140 { 187 {
141 void *newptr = realloc (ptr, size); 188 void *newptr = realloc (ptr, size);
142 189
158callback is set, then libev will expect it to remedy the sitution, no 205callback is set, then libev will expect it to remedy the sitution, no
159matter what, when it returns. That is, libev will generally retry the 206matter what, when it returns. That is, libev will generally retry the
160requested operation, or, if the condition doesn't go away, do bad stuff 207requested operation, or, if the condition doesn't go away, do bad stuff
161(such as abort). 208(such as abort).
162 209
163Example: do the same thing as libev does internally: 210Example: This is basically the same thing that libev does internally, too.
164 211
165 static void 212 static void
166 fatal_error (const char *msg) 213 fatal_error (const char *msg)
167 { 214 {
168 perror (msg); 215 perror (msg);
314Similar to C<ev_default_loop>, but always creates a new event loop that is 361Similar to C<ev_default_loop>, but always creates a new event loop that is
315always distinct from the default loop. Unlike the default loop, it cannot 362always distinct from the default loop. Unlike the default loop, it cannot
316handle signal and child watchers, and attempts to do so will be greeted by 363handle signal and child watchers, and attempts to do so will be greeted by
317undefined behaviour (or a failed assertion if assertions are enabled). 364undefined behaviour (or a failed assertion if assertions are enabled).
318 365
319Example: try to create a event loop that uses epoll and nothing else. 366Example: Try to create a event loop that uses epoll and nothing else.
320 367
321 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV); 368 struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
322 if (!epoller) 369 if (!epoller)
323 fatal ("no epoll found here, maybe it hides under your chair"); 370 fatal ("no epoll found here, maybe it hides under your chair");
324 371
423 Signals and child watchers are implemented as I/O watchers, and will 470 Signals and child watchers are implemented as I/O watchers, and will
424 be handled here by queueing them when their watcher gets executed. 471 be handled here by queueing them when their watcher gets executed.
425 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK 472 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
426 were used, return, otherwise continue with step *. 473 were used, return, otherwise continue with step *.
427 474
428Example: queue some jobs and then loop until no events are outsanding 475Example: Queue some jobs and then loop until no events are outsanding
429anymore. 476anymore.
430 477
431 ... queue jobs here, make sure they register event watchers as long 478 ... queue jobs here, make sure they register event watchers as long
432 ... as they still have work to do (even an idle watcher will do..) 479 ... as they still have work to do (even an idle watcher will do..)
433 ev_loop (my_loop, 0); 480 ev_loop (my_loop, 0);
453visible to the libev user and should not keep C<ev_loop> from exiting if 500visible to the libev user and should not keep C<ev_loop> from exiting if
454no event watchers registered by it are active. It is also an excellent 501no event watchers registered by it are active. It is also an excellent
455way to do this for generic recurring timers or from within third-party 502way to do this for generic recurring timers or from within third-party
456libraries. Just remember to I<unref after start> and I<ref before stop>. 503libraries. Just remember to I<unref after start> and I<ref before stop>.
457 504
458Example: create a signal watcher, but keep it from keeping C<ev_loop> 505Example: Create a signal watcher, but keep it from keeping C<ev_loop>
459running when nothing else is active. 506running when nothing else is active.
460 507
461 struct dv_signal exitsig; 508 struct ev_signal exitsig;
462 ev_signal_init (&exitsig, sig_cb, SIGINT); 509 ev_signal_init (&exitsig, sig_cb, SIGINT);
463 ev_signal_start (myloop, &exitsig); 510 ev_signal_start (loop, &exitsig);
464 evf_unref (myloop); 511 evf_unref (loop);
465 512
466Example: for some weird reason, unregister the above signal handler again. 513Example: For some weird reason, unregister the above signal handler again.
467 514
468 ev_ref (myloop); 515 ev_ref (loop);
469 ev_signal_stop (myloop, &exitsig); 516 ev_signal_stop (loop, &exitsig);
470 517
471=back 518=back
519
472 520
473=head1 ANATOMY OF A WATCHER 521=head1 ANATOMY OF A WATCHER
474 522
475A watcher is a structure that you create and register to record your 523A watcher is a structure that you create and register to record your
476interest in some event. For instance, if you want to wait for STDIN to 524interest in some event. For instance, if you want to wait for STDIN to
543The signal specified in the C<ev_signal> watcher has been received by a thread. 591The signal specified in the C<ev_signal> watcher has been received by a thread.
544 592
545=item C<EV_CHILD> 593=item C<EV_CHILD>
546 594
547The pid specified in the C<ev_child> watcher has received a status change. 595The pid specified in the C<ev_child> watcher has received a status change.
596
597=item C<EV_STAT>
598
599The path specified in the C<ev_stat> watcher changed its attributes somehow.
548 600
549=item C<EV_IDLE> 601=item C<EV_IDLE>
550 602
551The C<ev_idle> watcher has determined that you have nothing better to do. 603The C<ev_idle> watcher has determined that you have nothing better to do.
552 604
560received events. Callbacks of both watcher types can start and stop as 612received events. Callbacks of both watcher types can start and stop as
561many watchers as they want, and all of them will be taken into account 613many watchers as they want, and all of them will be taken into account
562(for example, a C<ev_prepare> watcher might start an idle watcher to keep 614(for example, a C<ev_prepare> watcher might start an idle watcher to keep
563C<ev_loop> from blocking). 615C<ev_loop> from blocking).
564 616
617=item C<EV_EMBED>
618
619The embedded event loop specified in the C<ev_embed> watcher needs attention.
620
621=item C<EV_FORK>
622
623The event loop has been resumed in the child process after fork (see
624C<ev_fork>).
625
565=item C<EV_ERROR> 626=item C<EV_ERROR>
566 627
567An unspecified error has occured, the watcher has been stopped. This might 628An unspecified error has occured, the watcher has been stopped. This might
568happen because the watcher could not be properly started because libev 629happen because the watcher could not be properly started because libev
569ran out of memory, a file descriptor was found to be closed or any other 630ran out of memory, a file descriptor was found to be closed or any other
576with the error from read() or write(). This will not work in multithreaded 637with the error from read() or write(). This will not work in multithreaded
577programs, though, so beware. 638programs, though, so beware.
578 639
579=back 640=back
580 641
581=head2 SUMMARY OF GENERIC WATCHER FUNCTIONS 642=head2 GENERIC WATCHER FUNCTIONS
582 643
583In the following description, C<TYPE> stands for the watcher type, 644In the following description, C<TYPE> stands for the watcher type,
584e.g. C<timer> for C<ev_timer> watchers and C<io> for C<ev_io> watchers. 645e.g. C<timer> for C<ev_timer> watchers and C<io> for C<ev_io> watchers.
585 646
586=over 4 647=over 4
595which rolls both calls into one. 656which rolls both calls into one.
596 657
597You can reinitialise a watcher at any time as long as it has been stopped 658You can reinitialise a watcher at any time as long as it has been stopped
598(or never started) and there are no pending events outstanding. 659(or never started) and there are no pending events outstanding.
599 660
600The callbakc is always of type C<void (*)(ev_loop *loop, ev_TYPE *watcher, 661The callback is always of type C<void (*)(ev_loop *loop, ev_TYPE *watcher,
601int revents)>. 662int revents)>.
602 663
603=item C<ev_TYPE_set> (ev_TYPE *, [args]) 664=item C<ev_TYPE_set> (ev_TYPE *, [args])
604 665
605This macro initialises the type-specific parts of a watcher. You need to 666This macro initialises the type-specific parts of a watcher. You need to
643events but its callback has not yet been invoked). As long as a watcher 704events but its callback has not yet been invoked). As long as a watcher
644is pending (but not active) you must not call an init function on it (but 705is pending (but not active) you must not call an init function on it (but
645C<ev_TYPE_set> is safe) and you must make sure the watcher is available to 706C<ev_TYPE_set> is safe) and you must make sure the watcher is available to
646libev (e.g. you cnanot C<free ()> it). 707libev (e.g. you cnanot C<free ()> it).
647 708
648=item callback = ev_cb (ev_TYPE *watcher) 709=item callback ev_cb (ev_TYPE *watcher)
649 710
650Returns the callback currently set on the watcher. 711Returns the callback currently set on the watcher.
651 712
652=item ev_cb_set (ev_TYPE *watcher, callback) 713=item ev_cb_set (ev_TYPE *watcher, callback)
653 714
681 { 742 {
682 struct my_io *w = (struct my_io *)w_; 743 struct my_io *w = (struct my_io *)w_;
683 ... 744 ...
684 } 745 }
685 746
686More interesting and less C-conformant ways of catsing your callback type 747More interesting and less C-conformant ways of casting your callback type
687have been omitted.... 748instead have been omitted.
749
750Another common scenario is having some data structure with multiple
751watchers:
752
753 struct my_biggy
754 {
755 int some_data;
756 ev_timer t1;
757 ev_timer t2;
758 }
759
760In this case getting the pointer to C<my_biggy> is a bit more complicated,
761you need to use C<offsetof>:
762
763 #include <stddef.h>
764
765 static void
766 t1_cb (EV_P_ struct ev_timer *w, int revents)
767 {
768 struct my_biggy big = (struct my_biggy *
769 (((char *)w) - offsetof (struct my_biggy, t1));
770 }
771
772 static void
773 t2_cb (EV_P_ struct ev_timer *w, int revents)
774 {
775 struct my_biggy big = (struct my_biggy *
776 (((char *)w) - offsetof (struct my_biggy, t2));
777 }
688 778
689 779
690=head1 WATCHER TYPES 780=head1 WATCHER TYPES
691 781
692This section describes each watcher in detail, but will not repeat 782This section describes each watcher in detail, but will not repeat
693information given in the last section. 783information given in the last section. Any initialisation/set macros,
784functions and members specific to the watcher type are explained.
694 785
786Members are additionally marked with either I<[read-only]>, meaning that,
787while the watcher is active, you can look at the member and expect some
788sensible content, but you must not modify it (you can modify it while the
789watcher is stopped to your hearts content), or I<[read-write]>, which
790means you can expect it to have some sensible content while the watcher
791is active, but you can also modify it. Modifying it may not do something
792sensible or take immediate effect (or do anything at all), but libev will
793not crash or malfunction in any way.
695 794
795
696=head2 C<ev_io> - is this file descriptor readable or writable 796=head2 C<ev_io> - is this file descriptor readable or writable?
697 797
698I/O watchers check whether a file descriptor is readable or writable 798I/O watchers check whether a file descriptor is readable or writable
699in each iteration of the event loop (This behaviour is called 799in each iteration of the event loop, or, more precisely, when reading
700level-triggering because you keep receiving events as long as the 800would not block the process and writing would at least be able to write
701condition persists. Remember you can stop the watcher if you don't want to 801some data. This behaviour is called level-triggering because you keep
702act on the event and neither want to receive future events). 802receiving events as long as the condition persists. Remember you can stop
803the watcher if you don't want to act on the event and neither want to
804receive future events.
703 805
704In general you can register as many read and/or write event watchers per 806In general you can register as many read and/or write event watchers per
705fd as you want (as long as you don't confuse yourself). Setting all file 807fd as you want (as long as you don't confuse yourself). Setting all file
706descriptors to non-blocking mode is also usually a good idea (but not 808descriptors to non-blocking mode is also usually a good idea (but not
707required if you know what you are doing). 809required if you know what you are doing).
708 810
709You have to be careful with dup'ed file descriptors, though. Some backends 811You have to be careful with dup'ed file descriptors, though. Some backends
710(the linux epoll backend is a notable example) cannot handle dup'ed file 812(the linux epoll backend is a notable example) cannot handle dup'ed file
711descriptors correctly if you register interest in two or more fds pointing 813descriptors correctly if you register interest in two or more fds pointing
712to the same underlying file/socket etc. description (that is, they share 814to the same underlying file/socket/etc. description (that is, they share
713the same underlying "file open"). 815the same underlying "file open").
714 816
715If you must do this, then force the use of a known-to-be-good backend 817If you must do this, then force the use of a known-to-be-good backend
716(at the time of this writing, this includes only C<EVBACKEND_SELECT> and 818(at the time of this writing, this includes only C<EVBACKEND_SELECT> and
717C<EVBACKEND_POLL>). 819C<EVBACKEND_POLL>).
718 820
821Another thing you have to watch out for is that it is quite easy to
822receive "spurious" readyness notifications, that is your callback might
823be called with C<EV_READ> but a subsequent C<read>(2) will actually block
824because there is no data. Not only are some backends known to create a
825lot of those (for example solaris ports), it is very easy to get into
826this situation even with a relatively standard program structure. Thus
827it is best to always use non-blocking I/O: An extra C<read>(2) returning
828C<EAGAIN> is far preferable to a program hanging until some data arrives.
829
830If you cannot run the fd in non-blocking mode (for example you should not
831play around with an Xlib connection), then you have to seperately re-test
832wether a file descriptor is really ready with a known-to-be good interface
833such as poll (fortunately in our Xlib example, Xlib already does this on
834its own, so its quite safe to use).
835
719=over 4 836=over 4
720 837
721=item ev_io_init (ev_io *, callback, int fd, int events) 838=item ev_io_init (ev_io *, callback, int fd, int events)
722 839
723=item ev_io_set (ev_io *, int fd, int events) 840=item ev_io_set (ev_io *, int fd, int events)
724 841
725Configures an C<ev_io> watcher. The fd is the file descriptor to rceeive 842Configures an C<ev_io> watcher. The C<fd> is the file descriptor to
726events for and events is either C<EV_READ>, C<EV_WRITE> or C<EV_READ | 843rceeive events for and events is either C<EV_READ>, C<EV_WRITE> or
727EV_WRITE> to receive the given events. 844C<EV_READ | EV_WRITE> to receive the given events.
728 845
729Please note that most of the more scalable backend mechanisms (for example 846=item int fd [read-only]
730epoll and solaris ports) can result in spurious readyness notifications 847
731for file descriptors, so you practically need to use non-blocking I/O (and 848The file descriptor being watched.
732treat callback invocation as hint only), or retest separately with a safe 849
733interface before doing I/O (XLib can do this), or force the use of either 850=item int events [read-only]
734C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>, which don't suffer from this 851
735problem. Also note that it is quite easy to have your callback invoked 852The events being watched.
736when the readyness condition is no longer valid even when employing
737typical ways of handling events, so its a good idea to use non-blocking
738I/O unconditionally.
739 853
740=back 854=back
741 855
742Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well 856Example: Call C<stdin_readable_cb> when STDIN_FILENO has become, well
743readable, but only once. Since it is likely line-buffered, you could 857readable, but only once. Since it is likely line-buffered, you could
744attempt to read a whole line in the callback: 858attempt to read a whole line in the callback.
745 859
746 static void 860 static void
747 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents) 861 stdin_readable_cb (struct ev_loop *loop, struct ev_io *w, int revents)
748 { 862 {
749 ev_io_stop (loop, w); 863 ev_io_stop (loop, w);
756 ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ); 870 ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ);
757 ev_io_start (loop, &stdin_readable); 871 ev_io_start (loop, &stdin_readable);
758 ev_loop (loop, 0); 872 ev_loop (loop, 0);
759 873
760 874
761=head2 C<ev_timer> - relative and optionally recurring timeouts 875=head2 C<ev_timer> - relative and optionally repeating timeouts
762 876
763Timer watchers are simple relative timers that generate an event after a 877Timer watchers are simple relative timers that generate an event after a
764given time, and optionally repeating in regular intervals after that. 878given time, and optionally repeating in regular intervals after that.
765 879
766The timers are based on real time, that is, if you register an event that 880The timers are based on real time, that is, if you register an event that
807 921
808If the timer is repeating, either start it if necessary (with the repeat 922If the timer is repeating, either start it if necessary (with the repeat
809value), or reset the running timer to the repeat value. 923value), or reset the running timer to the repeat value.
810 924
811This sounds a bit complicated, but here is a useful and typical 925This sounds a bit complicated, but here is a useful and typical
812example: Imagine you have a tcp connection and you want a so-called idle 926example: Imagine you have a tcp connection and you want a so-called
813timeout, that is, you want to be called when there have been, say, 60 927idle timeout, that is, you want to be called when there have been,
814seconds of inactivity on the socket. The easiest way to do this is to 928say, 60 seconds of inactivity on the socket. The easiest way to do
815configure an C<ev_timer> with after=repeat=60 and calling ev_timer_again each 929this is to configure an C<ev_timer> with C<after>=C<repeat>=C<60> and calling
816time you successfully read or write some data. If you go into an idle 930C<ev_timer_again> each time you successfully read or write some data. If
817state where you do not expect data to travel on the socket, you can stop 931you go into an idle state where you do not expect data to travel on the
818the timer, and again will automatically restart it if need be. 932socket, you can stop the timer, and again will automatically restart it if
933need be.
934
935You can also ignore the C<after> value and C<ev_timer_start> altogether
936and only ever use the C<repeat> value:
937
938 ev_timer_init (timer, callback, 0., 5.);
939 ev_timer_again (loop, timer);
940 ...
941 timer->again = 17.;
942 ev_timer_again (loop, timer);
943 ...
944 timer->again = 10.;
945 ev_timer_again (loop, timer);
946
947This is more efficient then stopping/starting the timer eahc time you want
948to modify its timeout value.
949
950=item ev_tstamp repeat [read-write]
951
952The current C<repeat> value. Will be used each time the watcher times out
953or C<ev_timer_again> is called and determines the next timeout (if any),
954which is also when any modifications are taken into account.
819 955
820=back 956=back
821 957
822Example: create a timer that fires after 60 seconds. 958Example: Create a timer that fires after 60 seconds.
823 959
824 static void 960 static void
825 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 961 one_minute_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
826 { 962 {
827 .. one minute over, w is actually stopped right here 963 .. one minute over, w is actually stopped right here
829 965
830 struct ev_timer mytimer; 966 struct ev_timer mytimer;
831 ev_timer_init (&mytimer, one_minute_cb, 60., 0.); 967 ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
832 ev_timer_start (loop, &mytimer); 968 ev_timer_start (loop, &mytimer);
833 969
834Example: create a timeout timer that times out after 10 seconds of 970Example: Create a timeout timer that times out after 10 seconds of
835inactivity. 971inactivity.
836 972
837 static void 973 static void
838 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents) 974 timeout_cb (struct ev_loop *loop, struct ev_timer *w, int revents)
839 { 975 {
848 // and in some piece of code that gets executed on any "activity": 984 // and in some piece of code that gets executed on any "activity":
849 // reset the timeout to start ticking again at 10 seconds 985 // reset the timeout to start ticking again at 10 seconds
850 ev_timer_again (&mytimer); 986 ev_timer_again (&mytimer);
851 987
852 988
853=head2 C<ev_periodic> - to cron or not to cron 989=head2 C<ev_periodic> - to cron or not to cron?
854 990
855Periodic watchers are also timers of a kind, but they are very versatile 991Periodic watchers are also timers of a kind, but they are very versatile
856(and unfortunately a bit complex). 992(and unfortunately a bit complex).
857 993
858Unlike C<ev_timer>'s, they are not based on real time (or relative time) 994Unlike C<ev_timer>'s, they are not based on real time (or relative time)
950Simply stops and restarts the periodic watcher again. This is only useful 1086Simply stops and restarts the periodic watcher again. This is only useful
951when you changed some parameters or the reschedule callback would return 1087when you changed some parameters or the reschedule callback would return
952a different time than the last time it was called (e.g. in a crond like 1088a different time than the last time it was called (e.g. in a crond like
953program when the crontabs have changed). 1089program when the crontabs have changed).
954 1090
1091=item ev_tstamp interval [read-write]
1092
1093The current interval value. Can be modified any time, but changes only
1094take effect when the periodic timer fires or C<ev_periodic_again> is being
1095called.
1096
1097=item ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) [read-write]
1098
1099The current reschedule callback, or C<0>, if this functionality is
1100switched off. Can be changed any time, but changes only take effect when
1101the periodic timer fires or C<ev_periodic_again> is being called.
1102
955=back 1103=back
956 1104
957Example: call a callback every hour, or, more precisely, whenever the 1105Example: Call a callback every hour, or, more precisely, whenever the
958system clock is divisible by 3600. The callback invocation times have 1106system clock is divisible by 3600. The callback invocation times have
959potentially a lot of jittering, but good long-term stability. 1107potentially a lot of jittering, but good long-term stability.
960 1108
961 static void 1109 static void
962 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents) 1110 clock_cb (struct ev_loop *loop, struct ev_io *w, int revents)
966 1114
967 struct ev_periodic hourly_tick; 1115 struct ev_periodic hourly_tick;
968 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0); 1116 ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
969 ev_periodic_start (loop, &hourly_tick); 1117 ev_periodic_start (loop, &hourly_tick);
970 1118
971Example: the same as above, but use a reschedule callback to do it: 1119Example: The same as above, but use a reschedule callback to do it:
972 1120
973 #include <math.h> 1121 #include <math.h>
974 1122
975 static ev_tstamp 1123 static ev_tstamp
976 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now) 1124 my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)
978 return fmod (now, 3600.) + 3600.; 1126 return fmod (now, 3600.) + 3600.;
979 } 1127 }
980 1128
981 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb); 1129 ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
982 1130
983Example: call a callback every hour, starting now: 1131Example: Call a callback every hour, starting now:
984 1132
985 struct ev_periodic hourly_tick; 1133 struct ev_periodic hourly_tick;
986 ev_periodic_init (&hourly_tick, clock_cb, 1134 ev_periodic_init (&hourly_tick, clock_cb,
987 fmod (ev_now (loop), 3600.), 3600., 0); 1135 fmod (ev_now (loop), 3600.), 3600., 0);
988 ev_periodic_start (loop, &hourly_tick); 1136 ev_periodic_start (loop, &hourly_tick);
989 1137
990 1138
991=head2 C<ev_signal> - signal me when a signal gets signalled 1139=head2 C<ev_signal> - signal me when a signal gets signalled!
992 1140
993Signal watchers will trigger an event when the process receives a specific 1141Signal watchers will trigger an event when the process receives a specific
994signal one or more times. Even though signals are very asynchronous, libev 1142signal one or more times. Even though signals are very asynchronous, libev
995will try it's best to deliver signals synchronously, i.e. as part of the 1143will try it's best to deliver signals synchronously, i.e. as part of the
996normal event processing, like any other event. 1144normal event processing, like any other event.
1009=item ev_signal_set (ev_signal *, int signum) 1157=item ev_signal_set (ev_signal *, int signum)
1010 1158
1011Configures the watcher to trigger on the given signal number (usually one 1159Configures the watcher to trigger on the given signal number (usually one
1012of the C<SIGxxx> constants). 1160of the C<SIGxxx> constants).
1013 1161
1162=item int signum [read-only]
1163
1164The signal the watcher watches out for.
1165
1014=back 1166=back
1015 1167
1016 1168
1017=head2 C<ev_child> - wait for pid status changes 1169=head2 C<ev_child> - watch out for process status changes
1018 1170
1019Child watchers trigger when your process receives a SIGCHLD in response to 1171Child watchers trigger when your process receives a SIGCHLD in response to
1020some child status changes (most typically when a child of yours dies). 1172some child status changes (most typically when a child of yours dies).
1021 1173
1022=over 4 1174=over 4
1030at the C<rstatus> member of the C<ev_child> watcher structure to see 1182at the C<rstatus> member of the C<ev_child> watcher structure to see
1031the status word (use the macros from C<sys/wait.h> and see your systems 1183the status word (use the macros from C<sys/wait.h> and see your systems
1032C<waitpid> documentation). The C<rpid> member contains the pid of the 1184C<waitpid> documentation). The C<rpid> member contains the pid of the
1033process causing the status change. 1185process causing the status change.
1034 1186
1187=item int pid [read-only]
1188
1189The process id this watcher watches out for, or C<0>, meaning any process id.
1190
1191=item int rpid [read-write]
1192
1193The process id that detected a status change.
1194
1195=item int rstatus [read-write]
1196
1197The process exit/trace status caused by C<rpid> (see your systems
1198C<waitpid> and C<sys/wait.h> documentation for details).
1199
1035=back 1200=back
1036 1201
1037Example: try to exit cleanly on SIGINT and SIGTERM. 1202Example: Try to exit cleanly on SIGINT and SIGTERM.
1038 1203
1039 static void 1204 static void
1040 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents) 1205 sigint_cb (struct ev_loop *loop, struct ev_signal *w, int revents)
1041 { 1206 {
1042 ev_unloop (loop, EVUNLOOP_ALL); 1207 ev_unloop (loop, EVUNLOOP_ALL);
1045 struct ev_signal signal_watcher; 1210 struct ev_signal signal_watcher;
1046 ev_signal_init (&signal_watcher, sigint_cb, SIGINT); 1211 ev_signal_init (&signal_watcher, sigint_cb, SIGINT);
1047 ev_signal_start (loop, &sigint_cb); 1212 ev_signal_start (loop, &sigint_cb);
1048 1213
1049 1214
1215=head2 C<ev_stat> - did the file attributes just change?
1216
1217This watches a filesystem path for attribute changes. That is, it calls
1218C<stat> regularly (or when the OS says it changed) and sees if it changed
1219compared to the last time, invoking the callback if it did.
1220
1221The path does not need to exist: changing from "path exists" to "path does
1222not exist" is a status change like any other. The condition "path does
1223not exist" is signified by the C<st_nlink> field being zero (which is
1224otherwise always forced to be at least one) and all the other fields of
1225the stat buffer having unspecified contents.
1226
1227Since there is no standard to do this, the portable implementation simply
1228calls C<stat (2)> regularly on the path to see if it changed somehow. You
1229can specify a recommended polling interval for this case. If you specify
1230a polling interval of C<0> (highly recommended!) then a I<suitable,
1231unspecified default> value will be used (which you can expect to be around
1232five seconds, although this might change dynamically). Libev will also
1233impose a minimum interval which is currently around C<0.1>, but thats
1234usually overkill.
1235
1236This watcher type is not meant for massive numbers of stat watchers,
1237as even with OS-supported change notifications, this can be
1238resource-intensive.
1239
1240At the time of this writing, only the Linux inotify interface is
1241implemented (implementing kqueue support is left as an exercise for the
1242reader). Inotify will be used to give hints only and should not change the
1243semantics of C<ev_stat> watchers, which means that libev sometimes needs
1244to fall back to regular polling again even with inotify, but changes are
1245usually detected immediately, and if the file exists there will be no
1246polling.
1247
1248=over 4
1249
1250=item ev_stat_init (ev_stat *, callback, const char *path, ev_tstamp interval)
1251
1252=item ev_stat_set (ev_stat *, const char *path, ev_tstamp interval)
1253
1254Configures the watcher to wait for status changes of the given
1255C<path>. The C<interval> is a hint on how quickly a change is expected to
1256be detected and should normally be specified as C<0> to let libev choose
1257a suitable value. The memory pointed to by C<path> must point to the same
1258path for as long as the watcher is active.
1259
1260The callback will be receive C<EV_STAT> when a change was detected,
1261relative to the attributes at the time the watcher was started (or the
1262last change was detected).
1263
1264=item ev_stat_stat (ev_stat *)
1265
1266Updates the stat buffer immediately with new values. If you change the
1267watched path in your callback, you could call this fucntion to avoid
1268detecting this change (while introducing a race condition). Can also be
1269useful simply to find out the new values.
1270
1271=item ev_statdata attr [read-only]
1272
1273The most-recently detected attributes of the file. Although the type is of
1274C<ev_statdata>, this is usually the (or one of the) C<struct stat> types
1275suitable for your system. If the C<st_nlink> member is C<0>, then there
1276was some error while C<stat>ing the file.
1277
1278=item ev_statdata prev [read-only]
1279
1280The previous attributes of the file. The callback gets invoked whenever
1281C<prev> != C<attr>.
1282
1283=item ev_tstamp interval [read-only]
1284
1285The specified interval.
1286
1287=item const char *path [read-only]
1288
1289The filesystem path that is being watched.
1290
1291=back
1292
1293Example: Watch C</etc/passwd> for attribute changes.
1294
1295 static void
1296 passwd_cb (struct ev_loop *loop, ev_stat *w, int revents)
1297 {
1298 /* /etc/passwd changed in some way */
1299 if (w->attr.st_nlink)
1300 {
1301 printf ("passwd current size %ld\n", (long)w->attr.st_size);
1302 printf ("passwd current atime %ld\n", (long)w->attr.st_mtime);
1303 printf ("passwd current mtime %ld\n", (long)w->attr.st_mtime);
1304 }
1305 else
1306 /* you shalt not abuse printf for puts */
1307 puts ("wow, /etc/passwd is not there, expect problems. "
1308 "if this is windows, they already arrived\n");
1309 }
1310
1311 ...
1312 ev_stat passwd;
1313
1314 ev_stat_init (&passwd, passwd_cb, "/etc/passwd");
1315 ev_stat_start (loop, &passwd);
1316
1317
1050=head2 C<ev_idle> - when you've got nothing better to do 1318=head2 C<ev_idle> - when you've got nothing better to do...
1051 1319
1052Idle watchers trigger events when there are no other events are pending 1320Idle watchers trigger events when there are no other events are pending
1053(prepare, check and other idle watchers do not count). That is, as long 1321(prepare, check and other idle watchers do not count). That is, as long
1054as your process is busy handling sockets or timeouts (or even signals, 1322as your process is busy handling sockets or timeouts (or even signals,
1055imagine) it will not be triggered. But when your process is idle all idle 1323imagine) it will not be triggered. But when your process is idle all idle
1073kind. There is a C<ev_idle_set> macro, but using it is utterly pointless, 1341kind. There is a C<ev_idle_set> macro, but using it is utterly pointless,
1074believe me. 1342believe me.
1075 1343
1076=back 1344=back
1077 1345
1078Example: dynamically allocate an C<ev_idle>, start it, and in the 1346Example: Dynamically allocate an C<ev_idle> watcher, start it, and in the
1079callback, free it. Alos, use no error checking, as usual. 1347callback, free it. Also, use no error checking, as usual.
1080 1348
1081 static void 1349 static void
1082 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents) 1350 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1083 { 1351 {
1084 free (w); 1352 free (w);
1089 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle)); 1357 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));
1090 ev_idle_init (idle_watcher, idle_cb); 1358 ev_idle_init (idle_watcher, idle_cb);
1091 ev_idle_start (loop, idle_cb); 1359 ev_idle_start (loop, idle_cb);
1092 1360
1093 1361
1094=head2 C<ev_prepare> and C<ev_check> - customise your event loop 1362=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
1095 1363
1096Prepare and check watchers are usually (but not always) used in tandem: 1364Prepare and check watchers are usually (but not always) used in tandem:
1097prepare watchers get invoked before the process blocks and check watchers 1365prepare watchers get invoked before the process blocks and check watchers
1098afterwards. 1366afterwards.
1099 1367
1368You I<must not> call C<ev_loop> or similar functions that enter
1369the current event loop from either C<ev_prepare> or C<ev_check>
1370watchers. Other loops than the current one are fine, however. The
1371rationale behind this is that you do not need to check for recursion in
1372those watchers, i.e. the sequence will always be C<ev_prepare>, blocking,
1373C<ev_check> so if you have one watcher of each kind they will always be
1374called in pairs bracketing the blocking call.
1375
1100Their main purpose is to integrate other event mechanisms into libev and 1376Their main purpose is to integrate other event mechanisms into libev and
1101their use is somewhat advanced. This could be used, for example, to track 1377their use is somewhat advanced. This could be used, for example, to track
1102variable changes, implement your own watchers, integrate net-snmp or a 1378variable changes, implement your own watchers, integrate net-snmp or a
1103coroutine library and lots more. 1379coroutine library and lots more. They are also occasionally useful if
1380you cache some data and want to flush it before blocking (for example,
1381in X programs you might want to do an C<XFlush ()> in an C<ev_prepare>
1382watcher).
1104 1383
1105This is done by examining in each prepare call which file descriptors need 1384This is done by examining in each prepare call which file descriptors need
1106to be watched by the other library, registering C<ev_io> watchers for 1385to be watched by the other library, registering C<ev_io> watchers for
1107them and starting an C<ev_timer> watcher for any timeouts (many libraries 1386them and starting an C<ev_timer> watcher for any timeouts (many libraries
1108provide just this functionality). Then, in the check watcher you check for 1387provide just this functionality). Then, in the check watcher you check for
1130parameters of any kind. There are C<ev_prepare_set> and C<ev_check_set> 1409parameters of any kind. There are C<ev_prepare_set> and C<ev_check_set>
1131macros, but using them is utterly, utterly and completely pointless. 1410macros, but using them is utterly, utterly and completely pointless.
1132 1411
1133=back 1412=back
1134 1413
1135Example: *TODO*. 1414Example: To include a library such as adns, you would add IO watchers
1415and a timeout watcher in a prepare handler, as required by libadns, and
1416in a check watcher, destroy them and call into libadns. What follows is
1417pseudo-code only of course:
1136 1418
1419 static ev_io iow [nfd];
1420 static ev_timer tw;
1137 1421
1422 static void
1423 io_cb (ev_loop *loop, ev_io *w, int revents)
1424 {
1425 // set the relevant poll flags
1426 // could also call adns_processreadable etc. here
1427 struct pollfd *fd = (struct pollfd *)w->data;
1428 if (revents & EV_READ ) fd->revents |= fd->events & POLLIN;
1429 if (revents & EV_WRITE) fd->revents |= fd->events & POLLOUT;
1430 }
1431
1432 // create io watchers for each fd and a timer before blocking
1433 static void
1434 adns_prepare_cb (ev_loop *loop, ev_prepare *w, int revents)
1435 {
1436 int timeout = 3600000;truct pollfd fds [nfd];
1437 // actual code will need to loop here and realloc etc.
1438 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
1439
1440 /* the callback is illegal, but won't be called as we stop during check */
1441 ev_timer_init (&tw, 0, timeout * 1e-3);
1442 ev_timer_start (loop, &tw);
1443
1444 // create on ev_io per pollfd
1445 for (int i = 0; i < nfd; ++i)
1446 {
1447 ev_io_init (iow + i, io_cb, fds [i].fd,
1448 ((fds [i].events & POLLIN ? EV_READ : 0)
1449 | (fds [i].events & POLLOUT ? EV_WRITE : 0)));
1450
1451 fds [i].revents = 0;
1452 iow [i].data = fds + i;
1453 ev_io_start (loop, iow + i);
1454 }
1455 }
1456
1457 // stop all watchers after blocking
1458 static void
1459 adns_check_cb (ev_loop *loop, ev_check *w, int revents)
1460 {
1461 ev_timer_stop (loop, &tw);
1462
1463 for (int i = 0; i < nfd; ++i)
1464 ev_io_stop (loop, iow + i);
1465
1466 adns_afterpoll (adns, fds, nfd, timeval_from (ev_now (loop));
1467 }
1468
1469
1138=head2 C<ev_embed> - when one backend isn't enough 1470=head2 C<ev_embed> - when one backend isn't enough...
1139 1471
1140This is a rather advanced watcher type that lets you embed one event loop 1472This is a rather advanced watcher type that lets you embed one event loop
1141into another (currently only C<ev_io> events are supported in the embedded 1473into another (currently only C<ev_io> events are supported in the embedded
1142loop, other types of watchers might be handled in a delayed or incorrect 1474loop, other types of watchers might be handled in a delayed or incorrect
1143fashion and must not be used). 1475fashion and must not be used).
1221 1553
1222Make a single, non-blocking sweep over the embedded loop. This works 1554Make a single, non-blocking sweep over the embedded loop. This works
1223similarly to C<ev_loop (embedded_loop, EVLOOP_NONBLOCK)>, but in the most 1555similarly to C<ev_loop (embedded_loop, EVLOOP_NONBLOCK)>, but in the most
1224apropriate way for embedded loops. 1556apropriate way for embedded loops.
1225 1557
1558=item struct ev_loop *loop [read-only]
1559
1560The embedded event loop.
1561
1562=back
1563
1564
1565=head2 C<ev_fork> - the audacity to resume the event loop after a fork
1566
1567Fork watchers are called when a C<fork ()> was detected (usually because
1568whoever is a good citizen cared to tell libev about it by calling
1569C<ev_default_fork> or C<ev_loop_fork>). The invocation is done before the
1570event loop blocks next and before C<ev_check> watchers are being called,
1571and only in the child after the fork. If whoever good citizen calling
1572C<ev_default_fork> cheats and calls it in the wrong process, the fork
1573handlers will be invoked, too, of course.
1574
1575=over 4
1576
1577=item ev_fork_init (ev_signal *, callback)
1578
1579Initialises and configures the fork watcher - it has no parameters of any
1580kind. There is a C<ev_fork_set> macro, but using it is utterly pointless,
1581believe me.
1582
1226=back 1583=back
1227 1584
1228 1585
1229=head1 OTHER FUNCTIONS 1586=head1 OTHER FUNCTIONS
1230 1587
1392 1749
1393=item w->sweep () C<ev::embed> only 1750=item w->sweep () C<ev::embed> only
1394 1751
1395Invokes C<ev_embed_sweep>. 1752Invokes C<ev_embed_sweep>.
1396 1753
1754=item w->update () C<ev::stat> only
1755
1756Invokes C<ev_stat_stat>.
1757
1397=back 1758=back
1398 1759
1399=back 1760=back
1400 1761
1401Example: Define a class with an IO and idle watcher, start one of them in 1762Example: Define a class with an IO and idle watcher, start one of them in
1413 : io (this, &myclass::io_cb), 1774 : io (this, &myclass::io_cb),
1414 idle (this, &myclass::idle_cb) 1775 idle (this, &myclass::idle_cb)
1415 { 1776 {
1416 io.start (fd, ev::READ); 1777 io.start (fd, ev::READ);
1417 } 1778 }
1779
1780
1781=head1 MACRO MAGIC
1782
1783Libev can be compiled with a variety of options, the most fundemantal is
1784C<EV_MULTIPLICITY>. This option determines wether (most) functions and
1785callbacks have an initial C<struct ev_loop *> argument.
1786
1787To make it easier to write programs that cope with either variant, the
1788following macros are defined:
1789
1790=over 4
1791
1792=item C<EV_A>, C<EV_A_>
1793
1794This provides the loop I<argument> for functions, if one is required ("ev
1795loop argument"). The C<EV_A> form is used when this is the sole argument,
1796C<EV_A_> is used when other arguments are following. Example:
1797
1798 ev_unref (EV_A);
1799 ev_timer_add (EV_A_ watcher);
1800 ev_loop (EV_A_ 0);
1801
1802It assumes the variable C<loop> of type C<struct ev_loop *> is in scope,
1803which is often provided by the following macro.
1804
1805=item C<EV_P>, C<EV_P_>
1806
1807This provides the loop I<parameter> for functions, if one is required ("ev
1808loop parameter"). The C<EV_P> form is used when this is the sole parameter,
1809C<EV_P_> is used when other parameters are following. Example:
1810
1811 // this is how ev_unref is being declared
1812 static void ev_unref (EV_P);
1813
1814 // this is how you can declare your typical callback
1815 static void cb (EV_P_ ev_timer *w, int revents)
1816
1817It declares a parameter C<loop> of type C<struct ev_loop *>, quite
1818suitable for use with C<EV_A>.
1819
1820=item C<EV_DEFAULT>, C<EV_DEFAULT_>
1821
1822Similar to the other two macros, this gives you the value of the default
1823loop, if multiple loops are supported ("ev loop default").
1824
1825=back
1826
1827Example: Declare and initialise a check watcher, working regardless of
1828wether multiple loops are supported or not.
1829
1830 static void
1831 check_cb (EV_P_ ev_timer *w, int revents)
1832 {
1833 ev_check_stop (EV_A_ w);
1834 }
1835
1836 ev_check check;
1837 ev_check_init (&check, check_cb);
1838 ev_check_start (EV_DEFAULT_ &check);
1839 ev_loop (EV_DEFAULT_ 0);
1840
1418 1841
1419=head1 EMBEDDING 1842=head1 EMBEDDING
1420 1843
1421Libev can (and often is) directly embedded into host 1844Libev can (and often is) directly embedded into host
1422applications. Examples of applications that embed it include the Deliantra 1845applications. Examples of applications that embed it include the Deliantra
1462 ev_vars.h 1885 ev_vars.h
1463 ev_wrap.h 1886 ev_wrap.h
1464 1887
1465 ev_win32.c required on win32 platforms only 1888 ev_win32.c required on win32 platforms only
1466 1889
1467 ev_select.c only when select backend is enabled (which is is by default) 1890 ev_select.c only when select backend is enabled (which is by default)
1468 ev_poll.c only when poll backend is enabled (disabled by default) 1891 ev_poll.c only when poll backend is enabled (disabled by default)
1469 ev_epoll.c only when the epoll backend is enabled (disabled by default) 1892 ev_epoll.c only when the epoll backend is enabled (disabled by default)
1470 ev_kqueue.c only when the kqueue backend is enabled (disabled by default) 1893 ev_kqueue.c only when the kqueue backend is enabled (disabled by default)
1471 ev_port.c only when the solaris port backend is enabled (disabled by default) 1894 ev_port.c only when the solaris port backend is enabled (disabled by default)
1472 1895
1473F<ev.c> includes the backend files directly when enabled, so you only need 1896F<ev.c> includes the backend files directly when enabled, so you only need
1474to compile a single file. 1897to compile this single file.
1475 1898
1476=head3 LIBEVENT COMPATIBILITY API 1899=head3 LIBEVENT COMPATIBILITY API
1477 1900
1478To include the libevent compatibility API, also include: 1901To include the libevent compatibility API, also include:
1479 1902
1492 1915
1493=head3 AUTOCONF SUPPORT 1916=head3 AUTOCONF SUPPORT
1494 1917
1495Instead of using C<EV_STANDALONE=1> and providing your config in 1918Instead of using C<EV_STANDALONE=1> and providing your config in
1496whatever way you want, you can also C<m4_include([libev.m4])> in your 1919whatever way you want, you can also C<m4_include([libev.m4])> in your
1497F<configure.ac> and leave C<EV_STANDALONE> off. F<ev.c> will then include 1920F<configure.ac> and leave C<EV_STANDALONE> undefined. F<ev.c> will then
1498F<config.h> and configure itself accordingly. 1921include F<config.h> and configure itself accordingly.
1499 1922
1500For this of course you need the m4 file: 1923For this of course you need the m4 file:
1501 1924
1502 libev.m4 1925 libev.m4
1503 1926
1597 2020
1598=item EV_USE_DEVPOLL 2021=item EV_USE_DEVPOLL
1599 2022
1600reserved for future expansion, works like the USE symbols above. 2023reserved for future expansion, works like the USE symbols above.
1601 2024
2025=item EV_USE_INOTIFY
2026
2027If defined to be C<1>, libev will compile in support for the Linux inotify
2028interface to speed up C<ev_stat> watchers. Its actual availability will
2029be detected at runtime.
2030
1602=item EV_H 2031=item EV_H
1603 2032
1604The name of the F<ev.h> header file used to include it. The default if 2033The name of the F<ev.h> header file used to include it. The default if
1605undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This 2034undefined is C<< <ev.h> >> in F<event.h> and C<"ev.h"> in F<ev.c>. This
1606can be used to virtually rename the F<ev.h> header file in case of conflicts. 2035can be used to virtually rename the F<ev.h> header file in case of conflicts.
1629will have the C<struct ev_loop *> as first argument, and you can create 2058will have the C<struct ev_loop *> as first argument, and you can create
1630additional independent event loops. Otherwise there will be no support 2059additional independent event loops. Otherwise there will be no support
1631for multiple event loops and there is no first event loop pointer 2060for multiple event loops and there is no first event loop pointer
1632argument. Instead, all functions act on the single default loop. 2061argument. Instead, all functions act on the single default loop.
1633 2062
1634=item EV_PERIODICS 2063=item EV_PERIODIC_ENABLE
1635 2064
1636If undefined or defined to be C<1>, then periodic timers are supported, 2065If undefined or defined to be C<1>, then periodic timers are supported. If
1637otherwise not. This saves a few kb of code. 2066defined to be C<0>, then they are not. Disabling them saves a few kB of
2067code.
2068
2069=item EV_EMBED_ENABLE
2070
2071If undefined or defined to be C<1>, then embed watchers are supported. If
2072defined to be C<0>, then they are not.
2073
2074=item EV_STAT_ENABLE
2075
2076If undefined or defined to be C<1>, then stat watchers are supported. If
2077defined to be C<0>, then they are not.
2078
2079=item EV_FORK_ENABLE
2080
2081If undefined or defined to be C<1>, then fork watchers are supported. If
2082defined to be C<0>, then they are not.
2083
2084=item EV_MINIMAL
2085
2086If you need to shave off some kilobytes of code at the expense of some
2087speed, define this symbol to C<1>. Currently only used for gcc to override
2088some inlining decisions, saves roughly 30% codesize of amd64.
2089
2090=item EV_PID_HASHSIZE
2091
2092C<ev_child> watchers use a small hash table to distribute workload by
2093pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
2094than enough. If you need to manage thousands of children you might want to
2095increase this value (I<must> be a power of two).
2096
2097=item EV_INOTIFY_HASHSIZE
2098
2099C<ev_staz> watchers use a small hash table to distribute workload by
2100inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>),
2101usually more than enough. If you need to manage thousands of C<ev_stat>
2102watchers you might want to increase this value (I<must> be a power of
2103two).
1638 2104
1639=item EV_COMMON 2105=item EV_COMMON
1640 2106
1641By default, all watchers have a C<void *data> member. By redefining 2107By default, all watchers have a C<void *data> member. By redefining
1642this macro to a something else you can include more and other types of 2108this macro to a something else you can include more and other types of
1647 2113
1648 #define EV_COMMON \ 2114 #define EV_COMMON \
1649 SV *self; /* contains this struct */ \ 2115 SV *self; /* contains this struct */ \
1650 SV *cb_sv, *fh /* note no trailing ";" */ 2116 SV *cb_sv, *fh /* note no trailing ";" */
1651 2117
1652=item EV_CB_DECLARE(type) 2118=item EV_CB_DECLARE (type)
1653 2119
1654=item EV_CB_INVOKE(watcher,revents) 2120=item EV_CB_INVOKE (watcher, revents)
1655 2121
1656=item ev_set_cb(ev,cb) 2122=item ev_set_cb (ev, cb)
1657 2123
1658Can be used to change the callback member declaration in each watcher, 2124Can be used to change the callback member declaration in each watcher,
1659and the way callbacks are invoked and set. Must expand to a struct member 2125and the way callbacks are invoked and set. Must expand to a struct member
1660definition and a statement, respectively. See the F<ev.v> header file for 2126definition and a statement, respectively. See the F<ev.v> header file for
1661their default definitions. One possible use for overriding these is to 2127their default definitions. One possible use for overriding these is to
1662avoid the ev_loop pointer as first argument in all cases, or to use method 2128avoid the C<struct ev_loop *> as first argument in all cases, or to use
1663calls instead of plain function calls in C++. 2129method calls instead of plain function calls in C++.
1664 2130
1665=head2 EXAMPLES 2131=head2 EXAMPLES
1666 2132
1667For a real-world example of a program the includes libev 2133For a real-world example of a program the includes libev
1668verbatim, you can have a look at the EV perl module 2134verbatim, you can have a look at the EV perl module
1685And a F<ev_cpp.C> implementation file that contains libev proper and is compiled: 2151And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
1686 2152
1687 #include "ev_cpp.h" 2153 #include "ev_cpp.h"
1688 #include "ev.c" 2154 #include "ev.c"
1689 2155
2156
2157=head1 COMPLEXITIES
2158
2159In this section the complexities of (many of) the algorithms used inside
2160libev will be explained. For complexity discussions about backends see the
2161documentation for C<ev_default_init>.
2162
2163=over 4
2164
2165=item Starting and stopping timer/periodic watchers: O(log skipped_other_timers)
2166
2167=item Changing timer/periodic watchers (by autorepeat, again): O(log skipped_other_timers)
2168
2169=item Starting io/check/prepare/idle/signal/child watchers: O(1)
2170
2171=item Stopping check/prepare/idle watchers: O(1)
2172
2173=item Stopping an io/signal/child watcher: O(number_of_watchers_for_this_(fd/signal/pid % EV_PID_HASHSIZE))
2174
2175=item Finding the next timer per loop iteration: O(1)
2176
2177=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
2178
2179=item Activating one watcher: O(1)
2180
2181=back
2182
2183
1690=head1 AUTHOR 2184=head1 AUTHOR
1691 2185
1692Marc Lehmann <libev@schmorp.de>. 2186Marc Lehmann <libev@schmorp.de>.
1693 2187

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines