[ViewVC] Diff of: cvs/libev/ev.pod

View File | Revision Log | Show Annotations | Download File

/cvs/libev/ev.pod

Comparing libev/ev.pod (file contents):
Revision 1.163 by root, Sat May 31 23:19:23 2008 UTC vs.
Revision 1.174 by root, Mon Aug 18 23:23:45 2008 UTC

…		…
2		2
3	libev - a high performance full-featured event loop written in C	3	libev - 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		8
9	=head2 EXAMPLE PROGRAM	9	=head2 EXAMPLE PROGRAM
10		10
11	// a single header file is required	11	// a single header file is required
12	#include <ev.h>	12	#include <ev.h>
13		13
14	// every watcher type has its own typedef'd struct	14	// every watcher type has its own typedef'd struct
15	// with the name ev_<type>	15	// with the name ev_<type>
16	ev_io stdin_watcher;	16	ev_io stdin_watcher;
17	ev_timer timeout_watcher;	17	ev_timer timeout_watcher;
18		18
19	// all watcher callbacks have a similar signature	19	// all watcher callbacks have a similar signature
20	// this callback is called when data is readable on stdin	20	// this callback is called when data is readable on stdin
21	static void	21	static void
22	stdin_cb (EV_P_ struct ev_io *w, int revents)	22	stdin_cb (EV_P_ struct ev_io *w, int revents)
23	{	23	{
24	puts ("stdin ready");	24	puts ("stdin ready");
25	// for one-shot events, one must manually stop the watcher	25	// for one-shot events, one must manually stop the watcher
26	// with its corresponding stop function.	26	// with its corresponding stop function.
27	ev_io_stop (EV_A_ w);	27	ev_io_stop (EV_A_ w);
28		28
29	// this causes all nested ev_loop's to stop iterating	29	// this causes all nested ev_loop's to stop iterating
30	ev_unloop (EV_A_ EVUNLOOP_ALL);	30	ev_unloop (EV_A_ EVUNLOOP_ALL);
31	}	31	}
32		32
33	// another callback, this time for a time-out	33	// another callback, this time for a time-out
34	static void	34	static void
35	timeout_cb (EV_P_ struct ev_timer *w, int revents)	35	timeout_cb (EV_P_ struct ev_timer *w, int revents)
36	{	36	{
37	puts ("timeout");	37	puts ("timeout");
38	// this causes the innermost ev_loop to stop iterating	38	// this causes the innermost ev_loop to stop iterating
39	ev_unloop (EV_A_ EVUNLOOP_ONE);	39	ev_unloop (EV_A_ EVUNLOOP_ONE);
40	}	40	}
41		41
42	int	42	int
43	main (void)	43	main (void)
44	{	44	{
45	// use the default event loop unless you have special needs	45	// use the default event loop unless you have special needs
46	struct ev_loop *loop = ev_default_loop (0);	46	struct ev_loop *loop = ev_default_loop (0);
47		47
48	// initialise an io watcher, then start it	48	// initialise an io watcher, then start it
49	// this one will watch for stdin to become readable	49	// this one will watch for stdin to become readable
50	ev_io_init (&stdin_watcher, stdin_cb, /STDIN_FILENO/ 0, EV_READ);	50	ev_io_init (&stdin_watcher, stdin_cb, /STDIN_FILENO/ 0, EV_READ);
51	ev_io_start (loop, &stdin_watcher);	51	ev_io_start (loop, &stdin_watcher);
52		52
53	// initialise a timer watcher, then start it	53	// initialise a timer watcher, then start it
54	// simple non-repeating 5.5 second timeout	54	// simple non-repeating 5.5 second timeout
55	ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);	55	ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);
56	ev_timer_start (loop, &timeout_watcher);	56	ev_timer_start (loop, &timeout_watcher);
57		57
58	// now wait for events to arrive	58	// now wait for events to arrive
59	ev_loop (loop, 0);	59	ev_loop (loop, 0);
60		60
61	// unloop was called, so exit	61	// unloop was called, so exit
62	return 0;	62	return 0;
63	}	63	}
64		64
65	=head1 DESCRIPTION	65	=head1 DESCRIPTION
66		66
67	The newest version of this document is also available as an html-formatted	67	The newest version of this document is also available as an html-formatted
68	web page you might find easier to navigate when reading it for the first	68	web page you might find easier to navigate when reading it for the first
…		…
178	not a problem.	178	not a problem.
179		179
180	Example: Make sure we haven't accidentally been linked against the wrong	180	Example: Make sure we haven't accidentally been linked against the wrong
181	version.	181	version.
182		182
183	assert (("libev version mismatch",	183	assert (("libev version mismatch",
184	ev_version_major () == EV_VERSION_MAJOR	184	ev_version_major () == EV_VERSION_MAJOR
185	&& ev_version_minor () >= EV_VERSION_MINOR));	185	&& ev_version_minor () >= EV_VERSION_MINOR));
186		186
187	=item unsigned int ev_supported_backends ()	187	=item unsigned int ev_supported_backends ()
188		188
189	Return the set of all backends (i.e. their corresponding C<EV_BACKEND_*>	189	Return the set of all backends (i.e. their corresponding C<EV_BACKEND_*>
190	value) compiled into this binary of libev (independent of their	190	value) compiled into this binary of libev (independent of their
…		…
192	a description of the set values.	192	a description of the set values.
193		193
194	Example: make sure we have the epoll method, because yeah this is cool and	194	Example: make sure we have the epoll method, because yeah this is cool and
195	a must have and can we have a torrent of it please!!!11	195	a must have and can we have a torrent of it please!!!11
196		196
197	assert (("sorry, no epoll, no sex",	197	assert (("sorry, no epoll, no sex",
198	ev_supported_backends () & EVBACKEND_EPOLL));	198	ev_supported_backends () & EVBACKEND_EPOLL));
199		199
200	=item unsigned int ev_recommended_backends ()	200	=item unsigned int ev_recommended_backends ()
201		201
202	Return the set of all backends compiled into this binary of libev and also	202	Return the set of all backends compiled into this binary of libev and also
203	recommended for this platform. This set is often smaller than the one	203	recommended for this platform. This set is often smaller than the one
…		…
466	backends will be tried (in the reverse order as listed here). If none are	466	backends will be tried (in the reverse order as listed here). If none are
467	specified, all backends in C<ev_recommended_backends ()> will be tried.	467	specified, all backends in C<ev_recommended_backends ()> will be tried.
468		468
469	The most typical usage is like this:	469	The most typical usage is like this:
470		470
471	if (!ev_default_loop (0))	471	if (!ev_default_loop (0))
472	fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");	472	fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
473		473
474	Restrict libev to the select and poll backends, and do not allow	474	Restrict libev to the select and poll backends, and do not allow
475	environment settings to be taken into account:	475	environment settings to be taken into account:
476		476
477	ev_default_loop (EVBACKEND_POLL \| EVBACKEND_SELECT \| EVFLAG_NOENV);	477	ev_default_loop (EVBACKEND_POLL \| EVBACKEND_SELECT \| EVFLAG_NOENV);
478		478
479	Use whatever libev has to offer, but make sure that kqueue is used if	479	Use whatever libev has to offer, but make sure that kqueue is used if
480	available (warning, breaks stuff, best use only with your own private	480	available (warning, breaks stuff, best use only with your own private
481	event loop and only if you know the OS supports your types of fds):	481	event loop and only if you know the OS supports your types of fds):
482		482
483	ev_default_loop (ev_recommended_backends () \| EVBACKEND_KQUEUE);	483	ev_default_loop (ev_recommended_backends () \| EVBACKEND_KQUEUE);
484		484
485	=item struct ev_loop *ev_loop_new (unsigned int flags)	485	=item struct ev_loop *ev_loop_new (unsigned int flags)
486		486
487	Similar to C<ev_default_loop>, but always creates a new event loop that is	487	Similar to C<ev_default_loop>, but always creates a new event loop that is
488	always distinct from the default loop. Unlike the default loop, it cannot	488	always distinct from the default loop. Unlike the default loop, it cannot
…		…
493	libev with threads is indeed to create one loop per thread, and using the	493	libev with threads is indeed to create one loop per thread, and using the
494	default loop in the "main" or "initial" thread.	494	default loop in the "main" or "initial" thread.
495		495
496	Example: Try to create a event loop that uses epoll and nothing else.	496	Example: Try to create a event loop that uses epoll and nothing else.
497		497
498	struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL \| EVFLAG_NOENV);	498	struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL \| EVFLAG_NOENV);
499	if (!epoller)	499	if (!epoller)
500	fatal ("no epoll found here, maybe it hides under your chair");	500	fatal ("no epoll found here, maybe it hides under your chair");
501		501
502	=item ev_default_destroy ()	502	=item ev_default_destroy ()
503		503
504	Destroys the default loop again (frees all memory and kernel state	504	Destroys the default loop again (frees all memory and kernel state
505	etc.). None of the active event watchers will be stopped in the normal	505	etc.). None of the active event watchers will be stopped in the normal
…		…
604		604
605	Here are the gory details of what C<ev_loop> does:	605	Here are the gory details of what C<ev_loop> does:
606		606
607	- Before the first iteration, call any pending watchers.	607	- Before the first iteration, call any pending watchers.
608	* If EVFLAG_FORKCHECK was used, check for a fork.	608	* If EVFLAG_FORKCHECK was used, check for a fork.
609	- If a fork was detected, queue and call all fork watchers.	609	- If a fork was detected (by any means), queue and call all fork watchers.
610	- Queue and call all prepare watchers.	610	- Queue and call all prepare watchers.
611	- If we have been forked, recreate the kernel state.	611	- If we have been forked, detach and recreate the kernel state
		612	as to not disturb the other process.
612	- Update the kernel state with all outstanding changes.	613	- Update the kernel state with all outstanding changes.
613	- Update the "event loop time".	614	- Update the "event loop time" (ev_now ()).
614	- Calculate for how long to sleep or block, if at all	615	- Calculate for how long to sleep or block, if at all
615	(active idle watchers, EVLOOP_NONBLOCK or not having	616	(active idle watchers, EVLOOP_NONBLOCK or not having
616	any active watchers at all will result in not sleeping).	617	any active watchers at all will result in not sleeping).
617	- Sleep if the I/O and timer collect interval say so.	618	- Sleep if the I/O and timer collect interval say so.
618	- Block the process, waiting for any events.	619	- Block the process, waiting for any events.
619	- Queue all outstanding I/O (fd) events.	620	- Queue all outstanding I/O (fd) events.
620	- Update the "event loop time" and do time jump handling.	621	- Update the "event loop time" (ev_now ()), and do time jump adjustments.
621	- Queue all outstanding timers.	622	- Queue all outstanding timers.
622	- Queue all outstanding periodics.	623	- Queue all outstanding periodics.
623	- If no events are pending now, queue all idle watchers.	624	- Unless any events are pending now, queue all idle watchers.
624	- Queue all check watchers.	625	- Queue all check watchers.
625	- Call all queued watchers in reverse order (i.e. check watchers first).	626	- Call all queued watchers in reverse order (i.e. check watchers first).
626	Signals and child watchers are implemented as I/O watchers, and will	627	Signals and child watchers are implemented as I/O watchers, and will
627	be handled here by queueing them when their watcher gets executed.	628	be handled here by queueing them when their watcher gets executed.
628	- If ev_unloop has been called, or EVLOOP_ONESHOT or EVLOOP_NONBLOCK	629	- If ev_unloop has been called, or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
…		…
633	anymore.	634	anymore.
634		635
635	... queue jobs here, make sure they register event watchers as long	636	... queue jobs here, make sure they register event watchers as long
636	... as they still have work to do (even an idle watcher will do..)	637	... as they still have work to do (even an idle watcher will do..)
637	ev_loop (my_loop, 0);	638	ev_loop (my_loop, 0);
638	... jobs done. yeah!	639	... jobs done or somebody called unloop. yeah!
639		640
640	=item ev_unloop (loop, how)	641	=item ev_unloop (loop, how)
641		642
642	Can be used to make a call to C<ev_loop> return early (but only after it	643	Can be used to make a call to C<ev_loop> return early (but only after it
643	has processed all outstanding events). The C<how> argument must be either	644	has processed all outstanding events). The C<how> argument must be either
…		…
664	respectively).	665	respectively).
665		666
666	Example: Create a signal watcher, but keep it from keeping C<ev_loop>	667	Example: Create a signal watcher, but keep it from keeping C<ev_loop>
667	running when nothing else is active.	668	running when nothing else is active.
668		669
669	struct ev_signal exitsig;	670	struct ev_signal exitsig;
670	ev_signal_init (&exitsig, sig_cb, SIGINT);	671	ev_signal_init (&exitsig, sig_cb, SIGINT);
671	ev_signal_start (loop, &exitsig);	672	ev_signal_start (loop, &exitsig);
672	evf_unref (loop);	673	evf_unref (loop);
673		674
674	Example: For some weird reason, unregister the above signal handler again.	675	Example: For some weird reason, unregister the above signal handler again.
675		676
676	ev_ref (loop);	677	ev_ref (loop);
677	ev_signal_stop (loop, &exitsig);	678	ev_signal_stop (loop, &exitsig);
678		679
679	=item ev_set_io_collect_interval (loop, ev_tstamp interval)	680	=item ev_set_io_collect_interval (loop, ev_tstamp interval)
680		681
681	=item ev_set_timeout_collect_interval (loop, ev_tstamp interval)	682	=item ev_set_timeout_collect_interval (loop, ev_tstamp interval)
682		683
683	These advanced functions influence the time that libev will spend waiting	684	These advanced functions influence the time that libev will spend waiting
684	for events. Both are by default C<0>, meaning that libev will try to	685	for events. Both time intervals are by default C<0>, meaning that libev
685	invoke timer/periodic callbacks and I/O callbacks with minimum latency.	686	will try to invoke timer/periodic callbacks and I/O callbacks with minimum
		687	latency.
686		688
687	Setting these to a higher value (the C<interval> I<must> be >= C<0>)	689	Setting these to a higher value (the C<interval> I<must> be >= C<0>)
688	allows libev to delay invocation of I/O and timer/periodic callbacks to	690	allows libev to delay invocation of I/O and timer/periodic callbacks
689	increase efficiency of loop iterations.	691	to increase efficiency of loop iterations (or to increase power-saving
		692	opportunities).
690		693
691	The background is that sometimes your program runs just fast enough to	694	The background is that sometimes your program runs just fast enough to
692	handle one (or very few) event(s) per loop iteration. While this makes	695	handle one (or very few) event(s) per loop iteration. While this makes
693	the program responsive, it also wastes a lot of CPU time to poll for new	696	the program responsive, it also wastes a lot of CPU time to poll for new
694	events, especially with backends like C<select ()> which have a high	697	events, especially with backends like C<select ()> which have a high
…		…
710	interval to a value near C<0.1> or so, which is often enough for	713	interval to a value near C<0.1> or so, which is often enough for
711	interactive servers (of course not for games), likewise for timeouts. It	714	interactive servers (of course not for games), likewise for timeouts. It
712	usually doesn't make much sense to set it to a lower value than C<0.01>,	715	usually doesn't make much sense to set it to a lower value than C<0.01>,
713	as this approaches the timing granularity of most systems.	716	as this approaches the timing granularity of most systems.
714		717
		718	Setting the I<timeout collect interval> can improve the opportunity for
		719	saving power, as the program will "bundle" timer callback invocations that
		720	are "near" in time together, by delaying some, thus reducing the number of
		721	times the process sleeps and wakes up again. Another useful technique to
		722	reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure
		723	they fire on, say, one-second boundaries only.
		724
715	=item ev_loop_verify (loop)	725	=item ev_loop_verify (loop)
716		726
717	This function only does something when C<EV_VERIFY> support has been	727	This function only does something when C<EV_VERIFY> support has been
718	compiled in. It tries to go through all internal structures and checks	728	compiled in. It tries to go through all internal structures and checks
719	them for validity. If anything is found to be inconsistent, it will print	729	them for validity. If anything is found to be inconsistent, it will print
…		…
730		740
731	A watcher is a structure that you create and register to record your	741	A watcher is a structure that you create and register to record your
732	interest in some event. For instance, if you want to wait for STDIN to	742	interest in some event. For instance, if you want to wait for STDIN to
733	become readable, you would create an C<ev_io> watcher for that:	743	become readable, you would create an C<ev_io> watcher for that:
734		744
735	static void my_cb (struct ev_loop loop, struct ev_io w, int revents)	745	static void my_cb (struct ev_loop loop, struct ev_io w, int revents)
736	{	746	{
737	ev_io_stop (w);	747	ev_io_stop (w);
738	ev_unloop (loop, EVUNLOOP_ALL);	748	ev_unloop (loop, EVUNLOOP_ALL);
739	}	749	}
740		750
741	struct ev_loop *loop = ev_default_loop (0);	751	struct ev_loop *loop = ev_default_loop (0);
742	struct ev_io stdin_watcher;	752	struct ev_io stdin_watcher;
743	ev_init (&stdin_watcher, my_cb);	753	ev_init (&stdin_watcher, my_cb);
744	ev_io_set (&stdin_watcher, STDIN_FILENO, EV_READ);	754	ev_io_set (&stdin_watcher, STDIN_FILENO, EV_READ);
745	ev_io_start (loop, &stdin_watcher);	755	ev_io_start (loop, &stdin_watcher);
746	ev_loop (loop, 0);	756	ev_loop (loop, 0);
747		757
748	As you can see, you are responsible for allocating the memory for your	758	As you can see, you are responsible for allocating the memory for your
749	watcher structures (and it is usually a bad idea to do this on the stack,	759	watcher structures (and it is usually a bad idea to do this on the stack,
750	although this can sometimes be quite valid).	760	although this can sometimes be quite valid).
751		761
…		…
978	to associate arbitrary data with your watcher. If you need more data and	988	to associate arbitrary data with your watcher. If you need more data and
979	don't want to allocate memory and store a pointer to it in that data	989	don't want to allocate memory and store a pointer to it in that data
980	member, you can also "subclass" the watcher type and provide your own	990	member, you can also "subclass" the watcher type and provide your own
981	data:	991	data:
982		992
983	struct my_io	993	struct my_io
984	{	994	{
985	struct ev_io io;	995	struct ev_io io;
986	int otherfd;	996	int otherfd;
987	void *somedata;	997	void *somedata;
988	struct whatever *mostinteresting;	998	struct whatever *mostinteresting;
989	}	999	}
990		1000
991	And since your callback will be called with a pointer to the watcher, you	1001	And since your callback will be called with a pointer to the watcher, you
992	can cast it back to your own type:	1002	can cast it back to your own type:
993		1003
994	static void my_cb (struct ev_loop loop, struct ev_io w_, int revents)	1004	static void my_cb (struct ev_loop loop, struct ev_io w_, int revents)
995	{	1005	{
996	struct my_io w = (struct my_io )w_;	1006	struct my_io w = (struct my_io )w_;
997	...	1007	...
998	}	1008	}
999		1009
1000	More interesting and less C-conformant ways of casting your callback type	1010	More interesting and less C-conformant ways of casting your callback type
1001	instead have been omitted.	1011	instead have been omitted.
1002		1012
1003	Another common scenario is having some data structure with multiple	1013	Another common scenario is having some data structure with multiple
1004	watchers:	1014	watchers:
1005		1015
1006	struct my_biggy	1016	struct my_biggy
1007	{	1017	{
1008	int some_data;	1018	int some_data;
1009	ev_timer t1;	1019	ev_timer t1;
1010	ev_timer t2;	1020	ev_timer t2;
1011	}	1021	}
1012		1022
1013	In this case getting the pointer to C<my_biggy> is a bit more complicated,	1023	In this case getting the pointer to C<my_biggy> is a bit more complicated,
1014	you need to use C<offsetof>:	1024	you need to use C<offsetof>:
1015		1025
1016	#include <stddef.h>	1026	#include <stddef.h>
1017		1027
1018	static void	1028	static void
1019	t1_cb (EV_P_ struct ev_timer *w, int revents)	1029	t1_cb (EV_P_ struct ev_timer *w, int revents)
1020	{	1030	{
1021	struct my_biggy big = (struct my_biggy *	1031	struct my_biggy big = (struct my_biggy *
1022	(((char *)w) - offsetof (struct my_biggy, t1));	1032	(((char *)w) - offsetof (struct my_biggy, t1));
1023	}	1033	}
1024		1034
1025	static void	1035	static void
1026	t2_cb (EV_P_ struct ev_timer *w, int revents)	1036	t2_cb (EV_P_ struct ev_timer *w, int revents)
1027	{	1037	{
1028	struct my_biggy big = (struct my_biggy *	1038	struct my_biggy big = (struct my_biggy *
1029	(((char *)w) - offsetof (struct my_biggy, t2));	1039	(((char *)w) - offsetof (struct my_biggy, t2));
1030	}	1040	}
1031		1041
1032		1042
1033	=head1 WATCHER TYPES	1043	=head1 WATCHER TYPES
1034		1044
1035	This section describes each watcher in detail, but will not repeat	1045	This section describes each watcher in detail, but will not repeat
…		…
1124	C<EVBACKEND_POLL>.	1134	C<EVBACKEND_POLL>.
1125		1135
1126	=head3 The special problem of SIGPIPE	1136	=head3 The special problem of SIGPIPE
1127		1137
1128	While not really specific to libev, it is easy to forget about SIGPIPE:	1138	While not really specific to libev, it is easy to forget about SIGPIPE:
1129	when reading from a pipe whose other end has been closed, your program	1139	when writing to a pipe whose other end has been closed, your program gets
1130	gets send a SIGPIPE, which, by default, aborts your program. For most	1140	send a SIGPIPE, which, by default, aborts your program. For most programs
1131	programs this is sensible behaviour, for daemons, this is usually	1141	this is sensible behaviour, for daemons, this is usually undesirable.
1132	undesirable.
1133		1142
1134	So when you encounter spurious, unexplained daemon exits, make sure you	1143	So when you encounter spurious, unexplained daemon exits, make sure you
1135	ignore SIGPIPE (and maybe make sure you log the exit status of your daemon	1144	ignore SIGPIPE (and maybe make sure you log the exit status of your daemon
1136	somewhere, as that would have given you a big clue).	1145	somewhere, as that would have given you a big clue).
1137		1146
…		…
1162		1171
1163	Example: Call C<stdin_readable_cb> when STDIN_FILENO has become, well	1172	Example: Call C<stdin_readable_cb> when STDIN_FILENO has become, well
1164	readable, but only once. Since it is likely line-buffered, you could	1173	readable, but only once. Since it is likely line-buffered, you could
1165	attempt to read a whole line in the callback.	1174	attempt to read a whole line in the callback.
1166		1175
1167	static void	1176	static void
1168	stdin_readable_cb (struct ev_loop loop, struct ev_io w, int revents)	1177	stdin_readable_cb (struct ev_loop loop, struct ev_io w, int revents)
1169	{	1178	{
1170	ev_io_stop (loop, w);	1179	ev_io_stop (loop, w);
1171	.. read from stdin here (or from w->fd) and haqndle any I/O errors	1180	.. read from stdin here (or from w->fd) and haqndle any I/O errors
1172	}	1181	}
1173		1182
1174	...	1183	...
1175	struct ev_loop *loop = ev_default_init (0);	1184	struct ev_loop *loop = ev_default_init (0);
1176	struct ev_io stdin_readable;	1185	struct ev_io stdin_readable;
1177	ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ);	1186	ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ);
1178	ev_io_start (loop, &stdin_readable);	1187	ev_io_start (loop, &stdin_readable);
1179	ev_loop (loop, 0);	1188	ev_loop (loop, 0);
1180		1189
1181		1190
1182	=head2 C<ev_timer> - relative and optionally repeating timeouts	1191	=head2 C<ev_timer> - relative and optionally repeating timeouts
1183		1192
1184	Timer watchers are simple relative timers that generate an event after a	1193	Timer watchers are simple relative timers that generate an event after a
…		…
1269		1278
1270	=head3 Examples	1279	=head3 Examples
1271		1280
1272	Example: Create a timer that fires after 60 seconds.	1281	Example: Create a timer that fires after 60 seconds.
1273		1282
1274	static void	1283	static void
1275	one_minute_cb (struct ev_loop loop, struct ev_timer w, int revents)	1284	one_minute_cb (struct ev_loop loop, struct ev_timer w, int revents)
1276	{	1285	{
1277	.. one minute over, w is actually stopped right here	1286	.. one minute over, w is actually stopped right here
1278	}	1287	}
1279		1288
1280	struct ev_timer mytimer;	1289	struct ev_timer mytimer;
1281	ev_timer_init (&mytimer, one_minute_cb, 60., 0.);	1290	ev_timer_init (&mytimer, one_minute_cb, 60., 0.);
1282	ev_timer_start (loop, &mytimer);	1291	ev_timer_start (loop, &mytimer);
1283		1292
1284	Example: Create a timeout timer that times out after 10 seconds of	1293	Example: Create a timeout timer that times out after 10 seconds of
1285	inactivity.	1294	inactivity.
1286		1295
1287	static void	1296	static void
1288	timeout_cb (struct ev_loop loop, struct ev_timer w, int revents)	1297	timeout_cb (struct ev_loop loop, struct ev_timer w, int revents)
1289	{	1298	{
1290	.. ten seconds without any activity	1299	.. ten seconds without any activity
1291	}	1300	}
1292		1301
1293	struct ev_timer mytimer;	1302	struct ev_timer mytimer;
1294	ev_timer_init (&mytimer, timeout_cb, 0., 10.); /* note, only repeat used */	1303	ev_timer_init (&mytimer, timeout_cb, 0., 10.); /* note, only repeat used */
1295	ev_timer_again (&mytimer); /* start timer */	1304	ev_timer_again (&mytimer); /* start timer */
1296	ev_loop (loop, 0);	1305	ev_loop (loop, 0);
1297		1306
1298	// and in some piece of code that gets executed on any "activity":	1307	// and in some piece of code that gets executed on any "activity":
1299	// reset the timeout to start ticking again at 10 seconds	1308	// reset the timeout to start ticking again at 10 seconds
1300	ev_timer_again (&mytimer);	1309	ev_timer_again (&mytimer);
1301		1310
1302		1311
1303	=head2 C<ev_periodic> - to cron or not to cron?	1312	=head2 C<ev_periodic> - to cron or not to cron?
1304		1313
1305	Periodic watchers are also timers of a kind, but they are very versatile	1314	Periodic watchers are also timers of a kind, but they are very versatile
…		…
1448		1457
1449	Example: Call a callback every hour, or, more precisely, whenever the	1458	Example: Call a callback every hour, or, more precisely, whenever the
1450	system clock is divisible by 3600. The callback invocation times have	1459	system clock is divisible by 3600. The callback invocation times have
1451	potentially a lot of jitter, but good long-term stability.	1460	potentially a lot of jitter, but good long-term stability.
1452		1461
1453	static void	1462	static void
1454	clock_cb (struct ev_loop loop, struct ev_io w, int revents)	1463	clock_cb (struct ev_loop loop, struct ev_io w, int revents)
1455	{	1464	{
1456	... its now a full hour (UTC, or TAI or whatever your clock follows)	1465	... its now a full hour (UTC, or TAI or whatever your clock follows)
1457	}	1466	}
1458		1467
1459	struct ev_periodic hourly_tick;	1468	struct ev_periodic hourly_tick;
1460	ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);	1469	ev_periodic_init (&hourly_tick, clock_cb, 0., 3600., 0);
1461	ev_periodic_start (loop, &hourly_tick);	1470	ev_periodic_start (loop, &hourly_tick);
1462		1471
1463	Example: The same as above, but use a reschedule callback to do it:	1472	Example: The same as above, but use a reschedule callback to do it:
1464		1473
1465	#include <math.h>	1474	#include <math.h>
1466		1475
1467	static ev_tstamp	1476	static ev_tstamp
1468	my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)	1477	my_scheduler_cb (struct ev_periodic *w, ev_tstamp now)
1469	{	1478	{
1470	return fmod (now, 3600.) + 3600.;	1479	return fmod (now, 3600.) + 3600.;
1471	}	1480	}
1472		1481
1473	ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);	1482	ev_periodic_init (&hourly_tick, clock_cb, 0., 0., my_scheduler_cb);
1474		1483
1475	Example: Call a callback every hour, starting now:	1484	Example: Call a callback every hour, starting now:
1476		1485
1477	struct ev_periodic hourly_tick;	1486	struct ev_periodic hourly_tick;
1478	ev_periodic_init (&hourly_tick, clock_cb,	1487	ev_periodic_init (&hourly_tick, clock_cb,
1479	fmod (ev_now (loop), 3600.), 3600., 0);	1488	fmod (ev_now (loop), 3600.), 3600., 0);
1480	ev_periodic_start (loop, &hourly_tick);	1489	ev_periodic_start (loop, &hourly_tick);
1481		1490
1482		1491
1483	=head2 C<ev_signal> - signal me when a signal gets signalled!	1492	=head2 C<ev_signal> - signal me when a signal gets signalled!
1484		1493
1485	Signal watchers will trigger an event when the process receives a specific	1494	Signal watchers will trigger an event when the process receives a specific
…		…
1519		1528
1520	=head3 Examples	1529	=head3 Examples
1521		1530
1522	Example: Try to exit cleanly on SIGINT and SIGTERM.	1531	Example: Try to exit cleanly on SIGINT and SIGTERM.
1523		1532
1524	static void	1533	static void
1525	sigint_cb (struct ev_loop loop, struct ev_signal w, int revents)	1534	sigint_cb (struct ev_loop loop, struct ev_signal w, int revents)
1526	{	1535	{
1527	ev_unloop (loop, EVUNLOOP_ALL);	1536	ev_unloop (loop, EVUNLOOP_ALL);
1528	}	1537	}
1529		1538
1530	struct ev_signal signal_watcher;	1539	struct ev_signal signal_watcher;
1531	ev_signal_init (&signal_watcher, sigint_cb, SIGINT);	1540	ev_signal_init (&signal_watcher, sigint_cb, SIGINT);
1532	ev_signal_start (loop, &sigint_cb);	1541	ev_signal_start (loop, &sigint_cb);
1533		1542
1534		1543
1535	=head2 C<ev_child> - watch out for process status changes	1544	=head2 C<ev_child> - watch out for process status changes
1536		1545
1537	Child watchers trigger when your process receives a SIGCHLD in response to	1546	Child watchers trigger when your process receives a SIGCHLD in response to
…		…
1559	handler, you can override it easily by installing your own handler for	1568	handler, you can override it easily by installing your own handler for
1560	C<SIGCHLD> after initialising the default loop, and making sure the	1569	C<SIGCHLD> after initialising the default loop, and making sure the
1561	default loop never gets destroyed. You are encouraged, however, to use an	1570	default loop never gets destroyed. You are encouraged, however, to use an
1562	event-based approach to child reaping and thus use libev's support for	1571	event-based approach to child reaping and thus use libev's support for
1563	that, so other libev users can use C<ev_child> watchers freely.	1572	that, so other libev users can use C<ev_child> watchers freely.
		1573
		1574	=head3 Stopping the Child Watcher
		1575
		1576	Currently, the child watcher never gets stopped, even when the
		1577	child terminates, so normally one needs to stop the watcher in the
		1578	callback. Future versions of libev might stop the watcher automatically
		1579	when a child exit is detected.
1564		1580
1565	=head3 Watcher-Specific Functions and Data Members	1581	=head3 Watcher-Specific Functions and Data Members
1566		1582
1567	=over 4	1583	=over 4
1568		1584
…		…
1597	=head3 Examples	1613	=head3 Examples
1598		1614
1599	Example: C<fork()> a new process and install a child handler to wait for	1615	Example: C<fork()> a new process and install a child handler to wait for
1600	its completion.	1616	its completion.
1601		1617
1602	ev_child cw;	1618	ev_child cw;
1603		1619
1604	static void	1620	static void
1605	child_cb (EV_P_ struct ev_child *w, int revents)	1621	child_cb (EV_P_ struct ev_child *w, int revents)
1606	{	1622	{
1607	ev_child_stop (EV_A_ w);	1623	ev_child_stop (EV_A_ w);
1608	printf ("process %d exited with status %x\n", w->rpid, w->rstatus);	1624	printf ("process %d exited with status %x\n", w->rpid, w->rstatus);
1609	}	1625	}
1610		1626
1611	pid_t pid = fork ();	1627	pid_t pid = fork ();
1612		1628
1613	if (pid < 0)	1629	if (pid < 0)
1614	// error	1630	// error
1615	else if (pid == 0)	1631	else if (pid == 0)
1616	{	1632	{
1617	// the forked child executes here	1633	// the forked child executes here
1618	exit (1);	1634	exit (1);
1619	}	1635	}
1620	else	1636	else
1621	{	1637	{
1622	ev_child_init (&cw, child_cb, pid, 0);	1638	ev_child_init (&cw, child_cb, pid, 0);
1623	ev_child_start (EV_DEFAULT_ &cw);	1639	ev_child_start (EV_DEFAULT_ &cw);
1624	}	1640	}
1625		1641
1626		1642
1627	=head2 C<ev_stat> - did the file attributes just change?	1643	=head2 C<ev_stat> - did the file attributes just change?
1628		1644
1629	This watches a file system path for attribute changes. That is, it calls	1645	This watches a file system path for attribute changes. That is, it calls
…		…
1662	will be no polling.	1678	will be no polling.
1663		1679
1664	=head3 ABI Issues (Largefile Support)	1680	=head3 ABI Issues (Largefile Support)
1665		1681
1666	Libev by default (unless the user overrides this) uses the default	1682	Libev by default (unless the user overrides this) uses the default
1667	compilation environment, which means that on systems with optionally	1683	compilation environment, which means that on systems with large file
1668	disabled large file support, you get the 32 bit version of the stat	1684	support disabled by default, you get the 32 bit version of the stat
1669	structure. When using the library from programs that change the ABI to	1685	structure. When using the library from programs that change the ABI to
1670	use 64 bit file offsets the programs will fail. In that case you have to	1686	use 64 bit file offsets the programs will fail. In that case you have to
1671	compile libev with the same flags to get binary compatibility. This is	1687	compile libev with the same flags to get binary compatibility. This is
1672	obviously the case with any flags that change the ABI, but the problem is	1688	obviously the case with any flags that change the ABI, but the problem is
1673	most noticeably with ev_stat and large file support.	1689	most noticeably disabled with ev_stat and large file support.
		1690
		1691	The solution for this is to lobby your distribution maker to make large
		1692	file interfaces available by default (as e.g. FreeBSD does) and not
		1693	optional. Libev cannot simply switch on large file support because it has
		1694	to exchange stat structures with application programs compiled using the
		1695	default compilation environment.
1674		1696
1675	=head3 Inotify	1697	=head3 Inotify
1676		1698
1677	When C<inotify (7)> support has been compiled into libev (generally only	1699	When C<inotify (7)> support has been compiled into libev (generally only
1678	available on Linux) and present at runtime, it will be used to speed up	1700	available on Linux) and present at runtime, it will be used to speed up
…		…
1767		1789
1768	=head3 Examples	1790	=head3 Examples
1769		1791
1770	Example: Watch C</etc/passwd> for attribute changes.	1792	Example: Watch C</etc/passwd> for attribute changes.
1771		1793
1772	static void	1794	static void
1773	passwd_cb (struct ev_loop loop, ev_stat w, int revents)	1795	passwd_cb (struct ev_loop loop, ev_stat w, int revents)
1774	{	1796	{
1775	/* /etc/passwd changed in some way */	1797	/* /etc/passwd changed in some way */
1776	if (w->attr.st_nlink)	1798	if (w->attr.st_nlink)
1777	{	1799	{
1778	printf ("passwd current size %ld\n", (long)w->attr.st_size);	1800	printf ("passwd current size %ld\n", (long)w->attr.st_size);
1779	printf ("passwd current atime %ld\n", (long)w->attr.st_mtime);	1801	printf ("passwd current atime %ld\n", (long)w->attr.st_mtime);
1780	printf ("passwd current mtime %ld\n", (long)w->attr.st_mtime);	1802	printf ("passwd current mtime %ld\n", (long)w->attr.st_mtime);
1781	}	1803	}
1782	else	1804	else
1783	/* you shalt not abuse printf for puts */	1805	/* you shalt not abuse printf for puts */
1784	puts ("wow, /etc/passwd is not there, expect problems. "	1806	puts ("wow, /etc/passwd is not there, expect problems. "
1785	"if this is windows, they already arrived\n");	1807	"if this is windows, they already arrived\n");
1786	}	1808	}
1787		1809
1788	...	1810	...
1789	ev_stat passwd;	1811	ev_stat passwd;
1790		1812
1791	ev_stat_init (&passwd, passwd_cb, "/etc/passwd", 0.);	1813	ev_stat_init (&passwd, passwd_cb, "/etc/passwd", 0.);
1792	ev_stat_start (loop, &passwd);	1814	ev_stat_start (loop, &passwd);
1793		1815
1794	Example: Like above, but additionally use a one-second delay so we do not	1816	Example: Like above, but additionally use a one-second delay so we do not
1795	miss updates (however, frequent updates will delay processing, too, so	1817	miss updates (however, frequent updates will delay processing, too, so
1796	one might do the work both on C<ev_stat> callback invocation I<and> on	1818	one might do the work both on C<ev_stat> callback invocation I<and> on
1797	C<ev_timer> callback invocation).	1819	C<ev_timer> callback invocation).
1798		1820
1799	static ev_stat passwd;	1821	static ev_stat passwd;
1800	static ev_timer timer;	1822	static ev_timer timer;
1801		1823
1802	static void	1824	static void
1803	timer_cb (EV_P_ ev_timer *w, int revents)	1825	timer_cb (EV_P_ ev_timer *w, int revents)
1804	{	1826	{
1805	ev_timer_stop (EV_A_ w);	1827	ev_timer_stop (EV_A_ w);
1806		1828
1807	/* now it's one second after the most recent passwd change */	1829	/* now it's one second after the most recent passwd change */
1808	}	1830	}
1809		1831
1810	static void	1832	static void
1811	stat_cb (EV_P_ ev_stat *w, int revents)	1833	stat_cb (EV_P_ ev_stat *w, int revents)
1812	{	1834	{
1813	/* reset the one-second timer */	1835	/* reset the one-second timer */
1814	ev_timer_again (EV_A_ &timer);	1836	ev_timer_again (EV_A_ &timer);
1815	}	1837	}
1816		1838
1817	...	1839	...
1818	ev_stat_init (&passwd, stat_cb, "/etc/passwd", 0.);	1840	ev_stat_init (&passwd, stat_cb, "/etc/passwd", 0.);
1819	ev_stat_start (loop, &passwd);	1841	ev_stat_start (loop, &passwd);
1820	ev_timer_init (&timer, timer_cb, 0., 1.02);	1842	ev_timer_init (&timer, timer_cb, 0., 1.02);
1821		1843
1822		1844
1823	=head2 C<ev_idle> - when you've got nothing better to do...	1845	=head2 C<ev_idle> - when you've got nothing better to do...
1824		1846
1825	Idle watchers trigger events when no other events of the same or higher	1847	Idle watchers trigger events when no other events of the same or higher
…		…
1856	=head3 Examples	1878	=head3 Examples
1857		1879
1858	Example: Dynamically allocate an C<ev_idle> watcher, start it, and in the	1880	Example: Dynamically allocate an C<ev_idle> watcher, start it, and in the
1859	callback, free it. Also, use no error checking, as usual.	1881	callback, free it. Also, use no error checking, as usual.
1860		1882
1861	static void	1883	static void
1862	idle_cb (struct ev_loop loop, struct ev_idle w, int revents)	1884	idle_cb (struct ev_loop loop, struct ev_idle w, int revents)
1863	{	1885	{
1864	free (w);	1886	free (w);
1865	// now do something you wanted to do when the program has	1887	// now do something you wanted to do when the program has
1866	// no longer anything immediate to do.	1888	// no longer anything immediate to do.
1867	}	1889	}
1868		1890
1869	struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));	1891	struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));
1870	ev_idle_init (idle_watcher, idle_cb);	1892	ev_idle_init (idle_watcher, idle_cb);
1871	ev_idle_start (loop, idle_cb);	1893	ev_idle_start (loop, idle_cb);
1872		1894
1873		1895
1874	=head2 C<ev_prepare> and C<ev_check> - customise your event loop!	1896	=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
1875		1897
1876	Prepare and check watchers are usually (but not always) used in tandem:	1898	Prepare and check watchers are usually (but not always) used in tandem:
…		…
1948	and in a check watcher, destroy them and call into libadns. What follows	1970	and in a check watcher, destroy them and call into libadns. What follows
1949	is pseudo-code only of course. This requires you to either use a low	1971	is pseudo-code only of course. This requires you to either use a low
1950	priority for the check watcher or use C<ev_clear_pending> explicitly, as	1972	priority for the check watcher or use C<ev_clear_pending> explicitly, as
1951	the callbacks for the IO/timeout watchers might not have been called yet.	1973	the callbacks for the IO/timeout watchers might not have been called yet.
1952		1974
1953	static ev_io iow [nfd];	1975	static ev_io iow [nfd];
1954	static ev_timer tw;	1976	static ev_timer tw;
1955		1977
1956	static void	1978	static void
1957	io_cb (ev_loop loop, ev_io w, int revents)	1979	io_cb (ev_loop loop, ev_io w, int revents)
1958	{	1980	{
1959	}	1981	}
1960		1982
1961	// create io watchers for each fd and a timer before blocking	1983	// create io watchers for each fd and a timer before blocking
1962	static void	1984	static void
1963	adns_prepare_cb (ev_loop loop, ev_prepare w, int revents)	1985	adns_prepare_cb (ev_loop loop, ev_prepare w, int revents)
1964	{	1986	{
1965	int timeout = 3600000;	1987	int timeout = 3600000;
1966	struct pollfd fds [nfd];	1988	struct pollfd fds [nfd];
1967	// actual code will need to loop here and realloc etc.	1989	// actual code will need to loop here and realloc etc.
1968	adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));	1990	adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
1969		1991
1970	/* the callback is illegal, but won't be called as we stop during check */	1992	/* the callback is illegal, but won't be called as we stop during check */
1971	ev_timer_init (&tw, 0, timeout * 1e-3);	1993	ev_timer_init (&tw, 0, timeout * 1e-3);
1972	ev_timer_start (loop, &tw);	1994	ev_timer_start (loop, &tw);
1973		1995
1974	// create one ev_io per pollfd	1996	// create one ev_io per pollfd
1975	for (int i = 0; i < nfd; ++i)	1997	for (int i = 0; i < nfd; ++i)
1976	{	1998	{
1977	ev_io_init (iow + i, io_cb, fds [i].fd,	1999	ev_io_init (iow + i, io_cb, fds [i].fd,
1978	((fds [i].events & POLLIN ? EV_READ : 0)	2000	((fds [i].events & POLLIN ? EV_READ : 0)
1979	\| (fds [i].events & POLLOUT ? EV_WRITE : 0)));	2001	\| (fds [i].events & POLLOUT ? EV_WRITE : 0)));
1980		2002
1981	fds [i].revents = 0;	2003	fds [i].revents = 0;
1982	ev_io_start (loop, iow + i);	2004	ev_io_start (loop, iow + i);
1983	}	2005	}
1984	}	2006	}
1985		2007
1986	// stop all watchers after blocking	2008	// stop all watchers after blocking
1987	static void	2009	static void
1988	adns_check_cb (ev_loop loop, ev_check w, int revents)	2010	adns_check_cb (ev_loop loop, ev_check w, int revents)
1989	{	2011	{
1990	ev_timer_stop (loop, &tw);	2012	ev_timer_stop (loop, &tw);
1991		2013
1992	for (int i = 0; i < nfd; ++i)	2014	for (int i = 0; i < nfd; ++i)
1993	{	2015	{
1994	// set the relevant poll flags	2016	// set the relevant poll flags
1995	// could also call adns_processreadable etc. here	2017	// could also call adns_processreadable etc. here
1996	struct pollfd *fd = fds + i;	2018	struct pollfd *fd = fds + i;
1997	int revents = ev_clear_pending (iow + i);	2019	int revents = ev_clear_pending (iow + i);
1998	if (revents & EV_READ ) fd->revents \|= fd->events & POLLIN;	2020	if (revents & EV_READ ) fd->revents \|= fd->events & POLLIN;
1999	if (revents & EV_WRITE) fd->revents \|= fd->events & POLLOUT;	2021	if (revents & EV_WRITE) fd->revents \|= fd->events & POLLOUT;
2000		2022
2001	// now stop the watcher	2023	// now stop the watcher
2002	ev_io_stop (loop, iow + i);	2024	ev_io_stop (loop, iow + i);
2003	}	2025	}
2004		2026
2005	adns_afterpoll (adns, fds, nfd, timeval_from (ev_now (loop));	2027	adns_afterpoll (adns, fds, nfd, timeval_from (ev_now (loop));
2006	}	2028	}
2007		2029
2008	Method 2: This would be just like method 1, but you run C<adns_afterpoll>	2030	Method 2: This would be just like method 1, but you run C<adns_afterpoll>
2009	in the prepare watcher and would dispose of the check watcher.	2031	in the prepare watcher and would dispose of the check watcher.
2010		2032
2011	Method 3: If the module to be embedded supports explicit event	2033	Method 3: If the module to be embedded supports explicit event
2012	notification (libadns does), you can also make use of the actual watcher	2034	notification (libadns does), you can also make use of the actual watcher
2013	callbacks, and only destroy/create the watchers in the prepare watcher.	2035	callbacks, and only destroy/create the watchers in the prepare watcher.
2014		2036
2015	static void	2037	static void
2016	timer_cb (EV_P_ ev_timer *w, int revents)	2038	timer_cb (EV_P_ ev_timer *w, int revents)
2017	{	2039	{
2018	adns_state ads = (adns_state)w->data;	2040	adns_state ads = (adns_state)w->data;
2019	update_now (EV_A);	2041	update_now (EV_A);
2020		2042
2021	adns_processtimeouts (ads, &tv_now);	2043	adns_processtimeouts (ads, &tv_now);
2022	}	2044	}
2023		2045
2024	static void	2046	static void
2025	io_cb (EV_P_ ev_io *w, int revents)	2047	io_cb (EV_P_ ev_io *w, int revents)
2026	{	2048	{
2027	adns_state ads = (adns_state)w->data;	2049	adns_state ads = (adns_state)w->data;
2028	update_now (EV_A);	2050	update_now (EV_A);
2029		2051
2030	if (revents & EV_READ ) adns_processreadable (ads, w->fd, &tv_now);	2052	if (revents & EV_READ ) adns_processreadable (ads, w->fd, &tv_now);
2031	if (revents & EV_WRITE) adns_processwriteable (ads, w->fd, &tv_now);	2053	if (revents & EV_WRITE) adns_processwriteable (ads, w->fd, &tv_now);
2032	}	2054	}
2033		2055
2034	// do not ever call adns_afterpoll	2056	// do not ever call adns_afterpoll
2035		2057
2036	Method 4: Do not use a prepare or check watcher because the module you	2058	Method 4: Do not use a prepare or check watcher because the module you
2037	want to embed is too inflexible to support it. Instead, you can override	2059	want to embed is too inflexible to support it. Instead, you can override
2038	their poll function. The drawback with this solution is that the main	2060	their poll function. The drawback with this solution is that the main
2039	loop is now no longer controllable by EV. The C<Glib::EV> module does	2061	loop is now no longer controllable by EV. The C<Glib::EV> module does
2040	this.	2062	this.
2041		2063
2042	static gint	2064	static gint
2043	event_poll_func (GPollFD *fds, guint nfds, gint timeout)	2065	event_poll_func (GPollFD *fds, guint nfds, gint timeout)
2044	{	2066	{
2045	int got_events = 0;	2067	int got_events = 0;
2046		2068
2047	for (n = 0; n < nfds; ++n)	2069	for (n = 0; n < nfds; ++n)
2048	// create/start io watcher that sets the relevant bits in fds[n] and increment got_events	2070	// create/start io watcher that sets the relevant bits in fds[n] and increment got_events
2049		2071
2050	if (timeout >= 0)	2072	if (timeout >= 0)
2051	// create/start timer	2073	// create/start timer
2052		2074
2053	// poll	2075	// poll
2054	ev_loop (EV_A_ 0);	2076	ev_loop (EV_A_ 0);
2055		2077
2056	// stop timer again	2078	// stop timer again
2057	if (timeout >= 0)	2079	if (timeout >= 0)
2058	ev_timer_stop (EV_A_ &to);	2080	ev_timer_stop (EV_A_ &to);
2059		2081
2060	// stop io watchers again - their callbacks should have set	2082	// stop io watchers again - their callbacks should have set
2061	for (n = 0; n < nfds; ++n)	2083	for (n = 0; n < nfds; ++n)
2062	ev_io_stop (EV_A_ iow [n]);	2084	ev_io_stop (EV_A_ iow [n]);
2063		2085
2064	return got_events;	2086	return got_events;
2065	}	2087	}
2066		2088
2067		2089
2068	=head2 C<ev_embed> - when one backend isn't enough...	2090	=head2 C<ev_embed> - when one backend isn't enough...
2069		2091
2070	This is a rather advanced watcher type that lets you embed one event loop	2092	This is a rather advanced watcher type that lets you embed one event loop
…		…
2148	event loop. If that is not possible, use the default loop. The default	2170	event loop. If that is not possible, use the default loop. The default
2149	loop is stored in C<loop_hi>, while the embeddable loop is stored in	2171	loop is stored in C<loop_hi>, while the embeddable loop is stored in
2150	C<loop_lo> (which is C<loop_hi> in the case no embeddable loop can be	2172	C<loop_lo> (which is C<loop_hi> in the case no embeddable loop can be
2151	used).	2173	used).
2152		2174
2153	struct ev_loop *loop_hi = ev_default_init (0);	2175	struct ev_loop *loop_hi = ev_default_init (0);
2154	struct ev_loop *loop_lo = 0;	2176	struct ev_loop *loop_lo = 0;
2155	struct ev_embed embed;	2177	struct ev_embed embed;
2156		2178
2157	// see if there is a chance of getting one that works	2179	// see if there is a chance of getting one that works
2158	// (remember that a flags value of 0 means autodetection)	2180	// (remember that a flags value of 0 means autodetection)
2159	loop_lo = ev_embeddable_backends () & ev_recommended_backends ()	2181	loop_lo = ev_embeddable_backends () & ev_recommended_backends ()
2160	? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ())	2182	? ev_loop_new (ev_embeddable_backends () & ev_recommended_backends ())
2161	: 0;	2183	: 0;
2162		2184
2163	// if we got one, then embed it, otherwise default to loop_hi	2185	// if we got one, then embed it, otherwise default to loop_hi
2164	if (loop_lo)	2186	if (loop_lo)
2165	{	2187	{
2166	ev_embed_init (&embed, 0, loop_lo);	2188	ev_embed_init (&embed, 0, loop_lo);
2167	ev_embed_start (loop_hi, &embed);	2189	ev_embed_start (loop_hi, &embed);
2168	}	2190	}
2169	else	2191	else
2170	loop_lo = loop_hi;	2192	loop_lo = loop_hi;
2171		2193
2172	Example: Check if kqueue is available but not recommended and create	2194	Example: Check if kqueue is available but not recommended and create
2173	a kqueue backend for use with sockets (which usually work with any	2195	a kqueue backend for use with sockets (which usually work with any
2174	kqueue implementation). Store the kqueue/socket-only event loop in	2196	kqueue implementation). Store the kqueue/socket-only event loop in
2175	C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too).	2197	C<loop_socket>. (One might optionally use C<EVFLAG_NOENV>, too).
2176		2198
2177	struct ev_loop *loop = ev_default_init (0);	2199	struct ev_loop *loop = ev_default_init (0);
2178	struct ev_loop *loop_socket = 0;	2200	struct ev_loop *loop_socket = 0;
2179	struct ev_embed embed;	2201	struct ev_embed embed;
2180		2202
2181	if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE)	2203	if (ev_supported_backends () & ~ev_recommended_backends () & EVBACKEND_KQUEUE)
2182	if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE))	2204	if ((loop_socket = ev_loop_new (EVBACKEND_KQUEUE))
2183	{	2205	{
2184	ev_embed_init (&embed, 0, loop_socket);	2206	ev_embed_init (&embed, 0, loop_socket);
2185	ev_embed_start (loop, &embed);	2207	ev_embed_start (loop, &embed);
2186	}	2208	}
2187		2209
2188	if (!loop_socket)	2210	if (!loop_socket)
2189	loop_socket = loop;	2211	loop_socket = loop;
2190		2212
2191	// now use loop_socket for all sockets, and loop for everything else	2213	// now use loop_socket for all sockets, and loop for everything else
2192		2214
2193		2215
2194	=head2 C<ev_fork> - the audacity to resume the event loop after a fork	2216	=head2 C<ev_fork> - the audacity to resume the event loop after a fork
2195		2217
2196	Fork watchers are called when a C<fork ()> was detected (usually because	2218	Fork watchers are called when a C<fork ()> was detected (usually because
…		…
2385	The callback has the type C<void (cb)(int revents, void arg)> and gets	2407	The callback has the type C<void (cb)(int revents, void arg)> and gets
2386	passed an C<revents> set like normal event callbacks (a combination of	2408	passed an C<revents> set like normal event callbacks (a combination of
2387	C<EV_ERROR>, C<EV_READ>, C<EV_WRITE> or C<EV_TIMEOUT>) and the C<arg>	2409	C<EV_ERROR>, C<EV_READ>, C<EV_WRITE> or C<EV_TIMEOUT>) and the C<arg>
2388	value passed to C<ev_once>:	2410	value passed to C<ev_once>:
2389		2411
2390	static void stdin_ready (int revents, void *arg)	2412	static void stdin_ready (int revents, void *arg)
2391	{	2413	{
2392	if (revents & EV_TIMEOUT)	2414	if (revents & EV_TIMEOUT)
2393	/* doh, nothing entered */;	2415	/* doh, nothing entered */;
2394	else if (revents & EV_READ)	2416	else if (revents & EV_READ)
2395	/* stdin might have data for us, joy! */;	2417	/* stdin might have data for us, joy! */;
2396	}	2418	}
2397		2419
2398	ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);	2420	ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
2399		2421
2400	=item ev_feed_event (ev_loop , watcher , int revents)	2422	=item ev_feed_event (ev_loop , watcher , int revents)
2401		2423
2402	Feeds the given event set into the event loop, as if the specified event	2424	Feeds the given event set into the event loop, as if the specified event
2403	had happened for the specified watcher (which must be a pointer to an	2425	had happened for the specified watcher (which must be a pointer to an
…		…
2452	you to use some convenience methods to start/stop watchers and also change	2474	you to use some convenience methods to start/stop watchers and also change
2453	the callback model to a model using method callbacks on objects.	2475	the callback model to a model using method callbacks on objects.
2454		2476
2455	To use it,	2477	To use it,
2456		2478
2457	#include <ev++.h>	2479	#include <ev++.h>
2458		2480
2459	This automatically includes F<ev.h> and puts all of its definitions (many	2481	This automatically includes F<ev.h> and puts all of its definitions (many
2460	of them macros) into the global namespace. All C++ specific things are	2482	of them macros) into the global namespace. All C++ specific things are
2461	put into the C<ev> namespace. It should support all the same embedding	2483	put into the C<ev> namespace. It should support all the same embedding
2462	options as F<ev.h>, most notably C<EV_MULTIPLICITY>.	2484	options as F<ev.h>, most notably C<EV_MULTIPLICITY>.
…		…
2529	your compiler is good :), then the method will be fully inlined into the	2551	your compiler is good :), then the method will be fully inlined into the
2530	thunking function, making it as fast as a direct C callback.	2552	thunking function, making it as fast as a direct C callback.
2531		2553
2532	Example: simple class declaration and watcher initialisation	2554	Example: simple class declaration and watcher initialisation
2533		2555
2534	struct myclass	2556	struct myclass
2535	{	2557	{
2536	void io_cb (ev::io &w, int revents) { }	2558	void io_cb (ev::io &w, int revents) { }
2537	}	2559	}
2538		2560
2539	myclass obj;	2561	myclass obj;
2540	ev::io iow;	2562	ev::io iow;
2541	iow.set <myclass, &myclass::io_cb> (&obj);	2563	iow.set <myclass, &myclass::io_cb> (&obj);
2542		2564
2543	=item w->set<function> (void *data = 0)	2565	=item w->set<function> (void *data = 0)
2544		2566
2545	Also sets a callback, but uses a static method or plain function as	2567	Also sets a callback, but uses a static method or plain function as
2546	callback. The optional C<data> argument will be stored in the watcher's	2568	callback. The optional C<data> argument will be stored in the watcher's
…		…
2550		2572
2551	See the method-C<set> above for more details.	2573	See the method-C<set> above for more details.
2552		2574
2553	Example:	2575	Example:
2554		2576
2555	static void io_cb (ev::io &w, int revents) { }	2577	static void io_cb (ev::io &w, int revents) { }
2556	iow.set <io_cb> ();	2578	iow.set <io_cb> ();
2557		2579
2558	=item w->set (struct ev_loop *)	2580	=item w->set (struct ev_loop *)
2559		2581
2560	Associates a different C<struct ev_loop> with this watcher. You can only	2582	Associates a different C<struct ev_loop> with this watcher. You can only
2561	do this when the watcher is inactive (and not pending either).	2583	do this when the watcher is inactive (and not pending either).
…		…
2594	=back	2616	=back
2595		2617
2596	Example: Define a class with an IO and idle watcher, start one of them in	2618	Example: Define a class with an IO and idle watcher, start one of them in
2597	the constructor.	2619	the constructor.
2598		2620
2599	class myclass	2621	class myclass
2600	{	2622	{
2601	ev::io io; void io_cb (ev::io &w, int revents);	2623	ev::io io; void io_cb (ev::io &w, int revents);
2602	ev:idle idle void idle_cb (ev::idle &w, int revents);	2624	ev:idle idle void idle_cb (ev::idle &w, int revents);
2603		2625
2604	myclass (int fd)	2626	myclass (int fd)
2605	{	2627	{
2606	io .set <myclass, &myclass::io_cb > (this);	2628	io .set <myclass, &myclass::io_cb > (this);
2607	idle.set <myclass, &myclass::idle_cb> (this);	2629	idle.set <myclass, &myclass::idle_cb> (this);
2608		2630
2609	io.start (fd, ev::READ);	2631	io.start (fd, ev::READ);
2610	}	2632	}
2611	};	2633	};
2612		2634
2613		2635
2614	=head1 OTHER LANGUAGE BINDINGS	2636	=head1 OTHER LANGUAGE BINDINGS
2615		2637
2616	Libev does not offer other language bindings itself, but bindings for a	2638	Libev does not offer other language bindings itself, but bindings for a
…		…
2626	libev. EV is developed together with libev. Apart from the EV core module,	2648	libev. EV is developed together with libev. Apart from the EV core module,
2627	there are additional modules that implement libev-compatible interfaces	2649	there are additional modules that implement libev-compatible interfaces
2628	to C<libadns> (C<EV::ADNS>), C<Net::SNMP> (C<Net::SNMP::EV>) and the	2650	to C<libadns> (C<EV::ADNS>), C<Net::SNMP> (C<Net::SNMP::EV>) and the
2629	C<libglib> event core (C<Glib::EV> and C<EV::Glib>).	2651	C<libglib> event core (C<Glib::EV> and C<EV::Glib>).
2630		2652
2631	It can be found and installed via CPAN, its homepage is found at	2653	It can be found and installed via CPAN, its homepage is at
2632	L<http://software.schmorp.de/pkg/EV>.	2654	L<http://software.schmorp.de/pkg/EV>.
		2655
		2656	=item Python
		2657
		2658	Python bindings can be found at L<http://code.google.com/p/pyev/>. It
		2659	seems to be quite complete and well-documented. Note, however, that the
		2660	patch they require for libev is outright dangerous as it breaks the ABI
		2661	for everybody else, and therefore, should never be applied in an installed
		2662	libev (if python requires an incompatible ABI then it needs to embed
		2663	libev).
2633		2664
2634	=item Ruby	2665	=item Ruby
2635		2666
2636	Tony Arcieri has written a ruby extension that offers access to a subset	2667	Tony Arcieri has written a ruby extension that offers access to a subset
2637	of the libev API and adds file handle abstractions, asynchronous DNS and	2668	of the libev API and adds file handle abstractions, asynchronous DNS and
…		…
2639	L<http://rev.rubyforge.org/>.	2670	L<http://rev.rubyforge.org/>.
2640		2671
2641	=item D	2672	=item D
2642		2673
2643	Leandro Lucarella has written a D language binding (F<ev.d>) for libev, to	2674	Leandro Lucarella has written a D language binding (F<ev.d>) for libev, to
2644	be found at L<http://git.llucax.com.ar/?p=software/ev.d.git;a=summary>.	2675	be found at L<http://proj.llucax.com.ar/wiki/evd>.
2645		2676
2646	=back	2677	=back
2647		2678
2648		2679
2649	=head1 MACRO MAGIC	2680	=head1 MACRO MAGIC
…		…
2661		2692
2662	This provides the loop I<argument> for functions, if one is required ("ev	2693	This provides the loop I<argument> for functions, if one is required ("ev
2663	loop argument"). The C<EV_A> form is used when this is the sole argument,	2694	loop argument"). The C<EV_A> form is used when this is the sole argument,
2664	C<EV_A_> is used when other arguments are following. Example:	2695	C<EV_A_> is used when other arguments are following. Example:
2665		2696
2666	ev_unref (EV_A);	2697	ev_unref (EV_A);
2667	ev_timer_add (EV_A_ watcher);	2698	ev_timer_add (EV_A_ watcher);
2668	ev_loop (EV_A_ 0);	2699	ev_loop (EV_A_ 0);
2669		2700
2670	It assumes the variable C<loop> of type C<struct ev_loop *> is in scope,	2701	It assumes the variable C<loop> of type C<struct ev_loop *> is in scope,
2671	which is often provided by the following macro.	2702	which is often provided by the following macro.
2672		2703
2673	=item C<EV_P>, C<EV_P_>	2704	=item C<EV_P>, C<EV_P_>
2674		2705
2675	This provides the loop I<parameter> for functions, if one is required ("ev	2706	This provides the loop I<parameter> for functions, if one is required ("ev
2676	loop parameter"). The C<EV_P> form is used when this is the sole parameter,	2707	loop parameter"). The C<EV_P> form is used when this is the sole parameter,
2677	C<EV_P_> is used when other parameters are following. Example:	2708	C<EV_P_> is used when other parameters are following. Example:
2678		2709
2679	// this is how ev_unref is being declared	2710	// this is how ev_unref is being declared
2680	static void ev_unref (EV_P);	2711	static void ev_unref (EV_P);
2681		2712
2682	// this is how you can declare your typical callback	2713	// this is how you can declare your typical callback
2683	static void cb (EV_P_ ev_timer *w, int revents)	2714	static void cb (EV_P_ ev_timer *w, int revents)
2684		2715
2685	It declares a parameter C<loop> of type C<struct ev_loop *>, quite	2716	It declares a parameter C<loop> of type C<struct ev_loop *>, quite
2686	suitable for use with C<EV_A>.	2717	suitable for use with C<EV_A>.
2687		2718
2688	=item C<EV_DEFAULT>, C<EV_DEFAULT_>	2719	=item C<EV_DEFAULT>, C<EV_DEFAULT_>
…		…
2704		2735
2705	Example: Declare and initialise a check watcher, utilising the above	2736	Example: Declare and initialise a check watcher, utilising the above
2706	macros so it will work regardless of whether multiple loops are supported	2737	macros so it will work regardless of whether multiple loops are supported
2707	or not.	2738	or not.
2708		2739
2709	static void	2740	static void
2710	check_cb (EV_P_ ev_timer *w, int revents)	2741	check_cb (EV_P_ ev_timer *w, int revents)
2711	{	2742	{
2712	ev_check_stop (EV_A_ w);	2743	ev_check_stop (EV_A_ w);
2713	}	2744	}
2714		2745
2715	ev_check check;	2746	ev_check check;
2716	ev_check_init (&check, check_cb);	2747	ev_check_init (&check, check_cb);
2717	ev_check_start (EV_DEFAULT_ &check);	2748	ev_check_start (EV_DEFAULT_ &check);
2718	ev_loop (EV_DEFAULT_ 0);	2749	ev_loop (EV_DEFAULT_ 0);
2719		2750
2720	=head1 EMBEDDING	2751	=head1 EMBEDDING
2721		2752
2722	Libev can (and often is) directly embedded into host	2753	Libev can (and often is) directly embedded into host
2723	applications. Examples of applications that embed it include the Deliantra	2754	applications. Examples of applications that embed it include the Deliantra
…		…
2737	=head3 CORE EVENT LOOP	2768	=head3 CORE EVENT LOOP
2738		2769
2739	To include only the libev core (all the C<ev_*> functions), with manual	2770	To include only the libev core (all the C<ev_*> functions), with manual
2740	configuration (no autoconf):	2771	configuration (no autoconf):
2741		2772
2742	#define EV_STANDALONE 1	2773	#define EV_STANDALONE 1
2743	#include "ev.c"	2774	#include "ev.c"
2744		2775
2745	This will automatically include F<ev.h>, too, and should be done in a	2776	This will automatically include F<ev.h>, too, and should be done in a
2746	single C source file only to provide the function implementations. To use	2777	single C source file only to provide the function implementations. To use
2747	it, do the same for F<ev.h> in all files wishing to use this API (best	2778	it, do the same for F<ev.h> in all files wishing to use this API (best
2748	done by writing a wrapper around F<ev.h> that you can include instead and	2779	done by writing a wrapper around F<ev.h> that you can include instead and
2749	where you can put other configuration options):	2780	where you can put other configuration options):
2750		2781
2751	#define EV_STANDALONE 1	2782	#define EV_STANDALONE 1
2752	#include "ev.h"	2783	#include "ev.h"
2753		2784
2754	Both header files and implementation files can be compiled with a C++	2785	Both header files and implementation files can be compiled with a C++
2755	compiler (at least, thats a stated goal, and breakage will be treated	2786	compiler (at least, thats a stated goal, and breakage will be treated
2756	as a bug).	2787	as a bug).
2757		2788
2758	You need the following files in your source tree, or in a directory	2789	You need the following files in your source tree, or in a directory
2759	in your include path (e.g. in libev/ when using -Ilibev):	2790	in your include path (e.g. in libev/ when using -Ilibev):
2760		2791
2761	ev.h	2792	ev.h
2762	ev.c	2793	ev.c
2763	ev_vars.h	2794	ev_vars.h
2764	ev_wrap.h	2795	ev_wrap.h
2765		2796
2766	ev_win32.c required on win32 platforms only	2797	ev_win32.c required on win32 platforms only
2767		2798
2768	ev_select.c only when select backend is enabled (which is enabled by default)	2799	ev_select.c only when select backend is enabled (which is enabled by default)
2769	ev_poll.c only when poll backend is enabled (disabled by default)	2800	ev_poll.c only when poll backend is enabled (disabled by default)
2770	ev_epoll.c only when the epoll backend is enabled (disabled by default)	2801	ev_epoll.c only when the epoll backend is enabled (disabled by default)
2771	ev_kqueue.c only when the kqueue backend is enabled (disabled by default)	2802	ev_kqueue.c only when the kqueue backend is enabled (disabled by default)
2772	ev_port.c only when the solaris port backend is enabled (disabled by default)	2803	ev_port.c only when the solaris port backend is enabled (disabled by default)
2773		2804
2774	F<ev.c> includes the backend files directly when enabled, so you only need	2805	F<ev.c> includes the backend files directly when enabled, so you only need
2775	to compile this single file.	2806	to compile this single file.
2776		2807
2777	=head3 LIBEVENT COMPATIBILITY API	2808	=head3 LIBEVENT COMPATIBILITY API
2778		2809
2779	To include the libevent compatibility API, also include:	2810	To include the libevent compatibility API, also include:
2780		2811
2781	#include "event.c"	2812	#include "event.c"
2782		2813
2783	in the file including F<ev.c>, and:	2814	in the file including F<ev.c>, and:
2784		2815
2785	#include "event.h"	2816	#include "event.h"
2786		2817
2787	in the files that want to use the libevent API. This also includes F<ev.h>.	2818	in the files that want to use the libevent API. This also includes F<ev.h>.
2788		2819
2789	You need the following additional files for this:	2820	You need the following additional files for this:
2790		2821
2791	event.h	2822	event.h
2792	event.c	2823	event.c
2793		2824
2794	=head3 AUTOCONF SUPPORT	2825	=head3 AUTOCONF SUPPORT
2795		2826
2796	Instead of using C<EV_STANDALONE=1> and providing your configuration in	2827	Instead of using C<EV_STANDALONE=1> and providing your configuration in
2797	whatever way you want, you can also C<m4_include([libev.m4])> in your	2828	whatever way you want, you can also C<m4_include([libev.m4])> in your
2798	F<configure.ac> and leave C<EV_STANDALONE> undefined. F<ev.c> will then	2829	F<configure.ac> and leave C<EV_STANDALONE> undefined. F<ev.c> will then
2799	include F<config.h> and configure itself accordingly.	2830	include F<config.h> and configure itself accordingly.
2800		2831
2801	For this of course you need the m4 file:	2832	For this of course you need the m4 file:
2802		2833
2803	libev.m4	2834	libev.m4
2804		2835
2805	=head2 PREPROCESSOR SYMBOLS/MACROS	2836	=head2 PREPROCESSOR SYMBOLS/MACROS
2806		2837
2807	Libev can be configured via a variety of preprocessor symbols you have to	2838	Libev can be configured via a variety of preprocessor symbols you have to
2808	define before including any of its files. The default in the absence of	2839	define before including any of its files. The default in the absence of
…		…
3085	members. You have to define it each time you include one of the files,	3116	members. You have to define it each time you include one of the files,
3086	though, and it must be identical each time.	3117	though, and it must be identical each time.
3087		3118
3088	For example, the perl EV module uses something like this:	3119	For example, the perl EV module uses something like this:
3089		3120
3090	#define EV_COMMON \	3121	#define EV_COMMON \
3091	SV self; / contains this struct */ \	3122	SV self; / contains this struct */ \
3092	SV cb_sv, fh /* note no trailing ";" */	3123	SV cb_sv, fh /* note no trailing ";" */
3093		3124
3094	=item EV_CB_DECLARE (type)	3125	=item EV_CB_DECLARE (type)
3095		3126
3096	=item EV_CB_INVOKE (watcher, revents)	3127	=item EV_CB_INVOKE (watcher, revents)
3097		3128
…		…
3108		3139
3109	If you need to re-export the API (e.g. via a DLL) and you need a list of	3140	If you need to re-export the API (e.g. via a DLL) and you need a list of
3110	exported symbols, you can use the provided F<Symbol.*> files which list	3141	exported symbols, you can use the provided F<Symbol.*> files which list
3111	all public symbols, one per line:	3142	all public symbols, one per line:
3112		3143
3113	Symbols.ev for libev proper	3144	Symbols.ev for libev proper
3114	Symbols.event for the libevent emulation	3145	Symbols.event for the libevent emulation
3115		3146
3116	This can also be used to rename all public symbols to avoid clashes with	3147	This can also be used to rename all public symbols to avoid clashes with
3117	multiple versions of libev linked together (which is obviously bad in	3148	multiple versions of libev linked together (which is obviously bad in
3118	itself, but sometimes it is inconvenient to avoid this).	3149	itself, but sometimes it is inconvenient to avoid this).
3119		3150
…		…
3140	file.	3171	file.
3141		3172
3142	The usage in rxvt-unicode is simpler. It has a F<ev_cpp.h> header file	3173	The usage in rxvt-unicode is simpler. It has a F<ev_cpp.h> header file
3143	that everybody includes and which overrides some configure choices:	3174	that everybody includes and which overrides some configure choices:
3144		3175
3145	#define EV_MINIMAL 1	3176	#define EV_MINIMAL 1
3146	#define EV_USE_POLL 0	3177	#define EV_USE_POLL 0
3147	#define EV_MULTIPLICITY 0	3178	#define EV_MULTIPLICITY 0
3148	#define EV_PERIODIC_ENABLE 0	3179	#define EV_PERIODIC_ENABLE 0
3149	#define EV_STAT_ENABLE 0	3180	#define EV_STAT_ENABLE 0
3150	#define EV_FORK_ENABLE 0	3181	#define EV_FORK_ENABLE 0
3151	#define EV_CONFIG_H <config.h>	3182	#define EV_CONFIG_H <config.h>
3152	#define EV_MINPRI 0	3183	#define EV_MINPRI 0
3153	#define EV_MAXPRI 0	3184	#define EV_MAXPRI 0
3154		3185
3155	#include "ev++.h"	3186	#include "ev++.h"
3156		3187
3157	And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:	3188	And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
3158		3189
3159	#include "ev_cpp.h"	3190	#include "ev_cpp.h"
3160	#include "ev.c"	3191	#include "ev.c"
3161		3192
3162		3193
3163	=head1 THREADS AND COROUTINES	3194	=head1 THREADS AND COROUTINES
3164		3195
3165	=head2 THREADS	3196	=head2 THREADS
…		…
3173	parallel from multiple threads, calls with the same loop parameter must be	3204	parallel from multiple threads, calls with the same loop parameter must be
3174	done serially (but can be done from different threads, as long as only one	3205	done serially (but can be done from different threads, as long as only one
3175	thread ever is inside a call at any point in time, e.g. by using a mutex	3206	thread ever is inside a call at any point in time, e.g. by using a mutex
3176	per loop).	3207	per loop).
3177		3208
3178	If you want to know which design is best for your problem, then I cannot	3209	If you want to know which design (one loop, locking, or multiple loops
3179	help you but by giving some generic advice:	3210	without or something else still) is best for your problem, then I cannot
		3211	help you. I can give some generic advice however:
3180		3212
3181	=over 4	3213	=over 4
3182		3214
3183	=item * most applications have a main thread: use the default libev loop	3215	=item * most applications have a main thread: use the default libev loop
3184	in that thread, or create a separate thread running only the default loop.	3216	in that thread, or create a separate thread running only the default loop.
…		…
3317	more than a hundred or so sockets, then likely it needs to use a totally	3349	more than a hundred or so sockets, then likely it needs to use a totally
3318	different implementation for windows, as libev offers the POSIX readiness	3350	different implementation for windows, as libev offers the POSIX readiness
3319	notification model, which cannot be implemented efficiently on windows	3351	notification model, which cannot be implemented efficiently on windows
3320	(Microsoft monopoly games).	3352	(Microsoft monopoly games).
3321		3353
		3354	A typical way to use libev under windows is to embed it (see the embedding
		3355	section for details) and use the following F<evwrap.h> header file instead
		3356	of F<ev.h>:
		3357
		3358	#define EV_STANDALONE /* keeps ev from requiring config.h */
		3359	#define EV_SELECT_IS_WINSOCKET 1 /* configure libev for windows select */
		3360
		3361	#include "ev.h"
		3362
		3363	And compile the following F<evwrap.c> file into your project (make sure
		3364	you do I<not> compile the F<ev.c> or any other embedded soruce files!):
		3365
		3366	#include "evwrap.h"
		3367	#include "ev.c"
		3368
3322	=over 4	3369	=over 4
3323		3370
3324	=item The winsocket select function	3371	=item The winsocket select function
3325		3372
3326	The winsocket C<select> function doesn't follow POSIX in that it	3373	The winsocket C<select> function doesn't follow POSIX in that it
3327	requires socket I<handles> and not socket I<file descriptors> (it is	3374	requires socket I<handles> and not socket I<file descriptors> (it is
3328	also extremely buggy). This makes select very inefficient, and also	3375	also extremely buggy). This makes select very inefficient, and also
3329	requires a mapping from file descriptors to socket handles. See the	3376	requires a mapping from file descriptors to socket handles (the Microsoft
		3377	C runtime provides the function C<_open_osfhandle> for this). See the
3330	discussion of the C<EV_SELECT_USE_FD_SET>, C<EV_SELECT_IS_WINSOCKET> and	3378	discussion of the C<EV_SELECT_USE_FD_SET>, C<EV_SELECT_IS_WINSOCKET> and
3331	C<EV_FD_TO_WIN32_HANDLE> preprocessor symbols for more info.	3379	C<EV_FD_TO_WIN32_HANDLE> preprocessor symbols for more info.
3332		3380
3333	The configuration for a "naked" win32 using the Microsoft runtime	3381	The configuration for a "naked" win32 using the Microsoft runtime
3334	libraries and raw winsocket select is:	3382	libraries and raw winsocket select is:
3335		3383
3336	#define EV_USE_SELECT 1	3384	#define EV_USE_SELECT 1
3337	#define EV_SELECT_IS_WINSOCKET 1 /* forces EV_SELECT_USE_FD_SET, too */	3385	#define EV_SELECT_IS_WINSOCKET 1 /* forces EV_SELECT_USE_FD_SET, too */
3338		3386
3339	Note that winsockets handling of fd sets is O(n), so you can easily get a	3387	Note that winsockets handling of fd sets is O(n), so you can easily get a
3340	complexity in the O(n²) range when using win32.	3388	complexity in the O(n²) range when using win32.
3341		3389
3342	=item Limited number of file descriptors	3390	=item Limited number of file descriptors
…		…
3374	In addition to a working ISO-C implementation, libev relies on a few	3422	In addition to a working ISO-C implementation, libev relies on a few
3375	additional extensions:	3423	additional extensions:
3376		3424
3377	=over 4	3425	=over 4
3378		3426
		3427	=item C<void ()(ev_watcher_type , int revents)> must have compatible
		3428	calling conventions regardless of C<ev_watcher_type *>.
		3429
		3430	Libev assumes not only that all watcher pointers have the same internal
		3431	structure (guaranteed by POSIX but not by ISO C for example), but it also
		3432	assumes that the same (machine) code can be used to call any watcher
		3433	callback: The watcher callbacks have different type signatures, but libev
		3434	calls them using an C<ev_watcher *> internally.
		3435
3379	=item C<sig_atomic_t volatile> must be thread-atomic as well	3436	=item C<sig_atomic_t volatile> must be thread-atomic as well
3380		3437
3381	The type C<sig_atomic_t volatile> (or whatever is defined as	3438	The type C<sig_atomic_t volatile> (or whatever is defined as
3382	C<EV_ATOMIC_T>) must be atomic w.r.t. accesses from different	3439	C<EV_ATOMIC_T>) must be atomic w.r.t. accesses from different
3383	threads. This is not part of the specification for C<sig_atomic_t>, but is	3440	threads. This is not part of the specification for C<sig_atomic_t>, but is

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Administered by

schmorpforge-cvs@schmorp.de

Powered by ViewVC 1.2.3