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

Comparing libev/ev.c (file contents):
Revision 1.185 by root, Fri Dec 14 18:22:30 2007 UTC vs.
Revision 1.197 by root, Sat Dec 22 15:20:13 2007 UTC

…		…
51	# ifndef EV_USE_MONOTONIC	51	# ifndef EV_USE_MONOTONIC
52	# define EV_USE_MONOTONIC 0	52	# define EV_USE_MONOTONIC 0
53	# endif	53	# endif
54	# ifndef EV_USE_REALTIME	54	# ifndef EV_USE_REALTIME
55	# define EV_USE_REALTIME 0	55	# define EV_USE_REALTIME 0
		56	# endif
		57	# endif
		58
		59	# ifndef EV_USE_NANOSLEEP
		60	# if HAVE_NANOSLEEP
		61	# define EV_USE_NANOSLEEP 1
		62	# else
		63	# define EV_USE_NANOSLEEP 0
56	# endif	64	# endif
57	# endif	65	# endif
58		66
59	# ifndef EV_USE_SELECT	67	# ifndef EV_USE_SELECT
60	# if HAVE_SELECT && HAVE_SYS_SELECT_H	68	# if HAVE_SELECT && HAVE_SYS_SELECT_H
…		…
146		154
147	#ifndef EV_USE_REALTIME	155	#ifndef EV_USE_REALTIME
148	# define EV_USE_REALTIME 0	156	# define EV_USE_REALTIME 0
149	#endif	157	#endif
150		158
		159	#ifndef EV_USE_NANOSLEEP
		160	# define EV_USE_NANOSLEEP 0
		161	#endif
		162
151	#ifndef EV_USE_SELECT	163	#ifndef EV_USE_SELECT
152	# define EV_USE_SELECT 1	164	# define EV_USE_SELECT 1
153	#endif	165	#endif
154		166
155	#ifndef EV_USE_POLL	167	#ifndef EV_USE_POLL
…		…
205	#endif	217	#endif
206		218
207	#if !EV_STAT_ENABLE	219	#if !EV_STAT_ENABLE
208	# undef EV_USE_INOTIFY	220	# undef EV_USE_INOTIFY
209	# define EV_USE_INOTIFY 0	221	# define EV_USE_INOTIFY 0
		222	#endif
		223
		224	#if !EV_USE_NANOSLEEP
		225	# ifndef _WIN32
		226	# include <sys/select.h>
		227	# endif
210	#endif	228	#endif
211		229
212	#if EV_USE_INOTIFY	230	#if EV_USE_INOTIFY
213	# include <sys/inotify.h>	231	# include <sys/inotify.h>
214	#endif	232	#endif
…		…
262		280
263	typedef ev_watcher *W;	281	typedef ev_watcher *W;
264	typedef ev_watcher_list *WL;	282	typedef ev_watcher_list *WL;
265	typedef ev_watcher_time *WT;	283	typedef ev_watcher_time *WT;
266		284
		285	/* sig_atomic_t is used to avoid per-thread variables or locking but still */
		286	/* giving it a reasonably high chance of working on typical architetcures */
267	static int have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */	287	static sig_atomic_t have_monotonic; /* did clock_gettime (CLOCK_MONOTONIC) work? */
268		288
269	#ifdef _WIN32	289	#ifdef _WIN32
270	# include "ev_win32.c"	290	# include "ev_win32.c"
271	#endif	291	#endif
272		292
…		…
408	{	428	{
409	return ev_rt_now;	429	return ev_rt_now;
410	}	430	}
411	#endif	431	#endif
412		432
		433	void
		434	ev_sleep (ev_tstamp delay)
		435	{
		436	if (delay > 0.)
		437	{
		438	#if EV_USE_NANOSLEEP
		439	struct timespec ts;
		440
		441	ts.tv_sec = (time_t)delay;
		442	ts.tv_nsec = (long)((delay - (ev_tstamp)(ts.tv_sec)) * 1e9);
		443
		444	nanosleep (&ts, 0);
		445	#elif defined(_WIN32)
		446	Sleep (delay * 1e3);
		447	#else
		448	struct timeval tv;
		449
		450	tv.tv_sec = (time_t)delay;
		451	tv.tv_usec = (long)((delay - (ev_tstamp)(tv.tv_sec)) * 1e6);
		452
		453	select (0, 0, 0, 0, &tv);
		454	#endif
		455	}
		456	}
		457
		458	/*****************************************************************************/
		459
413	int inline_size	460	int inline_size
414	array_nextsize (int elem, int cur, int cnt)	461	array_nextsize (int elem, int cur, int cnt)
415	{	462	{
416	int ncur = cur + 1;	463	int ncur = cur + 1;
417		464
…		…
925	}	972	}
926		973
927	unsigned int	974	unsigned int
928	ev_embeddable_backends (void)	975	ev_embeddable_backends (void)
929	{	976	{
930	return EVBACKEND_EPOLL	977	int flags = EVBACKEND_EPOLL \| EVBACKEND_KQUEUE \| EVBACKEND_PORT;
931	\| EVBACKEND_KQUEUE	978
932	\| EVBACKEND_PORT;	979	/* epoll embeddability broken on all linux versions up to at least 2.6.23 */
		980	/* please fix it and tell me how to detect the fix */
		981	flags &= ~EVBACKEND_EPOLL;
		982
		983	return flags;
933	}	984	}
934		985
935	unsigned int	986	unsigned int
936	ev_backend (EV_P)	987	ev_backend (EV_P)
937	{	988	{
…		…
940		991
941	unsigned int	992	unsigned int
942	ev_loop_count (EV_P)	993	ev_loop_count (EV_P)
943	{	994	{
944	return loop_count;	995	return loop_count;
		996	}
		997
		998	void
		999	ev_set_io_collect_interval (EV_P_ ev_tstamp interval)
		1000	{
		1001	io_blocktime = interval;
		1002	}
		1003
		1004	void
		1005	ev_set_timeout_collect_interval (EV_P_ ev_tstamp interval)
		1006	{
		1007	timeout_blocktime = interval;
945	}	1008	}
946		1009
947	static void noinline	1010	static void noinline
948	loop_init (EV_P_ unsigned int flags)	1011	loop_init (EV_P_ unsigned int flags)
949	{	1012	{
…		…
960	ev_rt_now = ev_time ();	1023	ev_rt_now = ev_time ();
961	mn_now = get_clock ();	1024	mn_now = get_clock ();
962	now_floor = mn_now;	1025	now_floor = mn_now;
963	rtmn_diff = ev_rt_now - mn_now;	1026	rtmn_diff = ev_rt_now - mn_now;
964		1027
		1028	io_blocktime = 0.;
		1029	timeout_blocktime = 0.;
		1030
965	/* pid check not overridable via env */	1031	/* pid check not overridable via env */
966	#ifndef _WIN32	1032	#ifndef _WIN32
967	if (flags & EVFLAG_FORKCHECK)	1033	if (flags & EVFLAG_FORKCHECK)
968	curpid = getpid ();	1034	curpid = getpid ();
969	#endif	1035	#endif
…		…
1037	array_free (pending, [i]);	1103	array_free (pending, [i]);
1038	#if EV_IDLE_ENABLE	1104	#if EV_IDLE_ENABLE
1039	array_free (idle, [i]);	1105	array_free (idle, [i]);
1040	#endif	1106	#endif
1041	}	1107	}
		1108
		1109	ev_free (anfds); anfdmax = 0;
1042		1110
1043	/* have to use the microsoft-never-gets-it-right macro */	1111	/* have to use the microsoft-never-gets-it-right macro */
1044	array_free (fdchange, EMPTY);	1112	array_free (fdchange, EMPTY);
1045	array_free (timer, EMPTY);	1113	array_free (timer, EMPTY);
1046	#if EV_PERIODIC_ENABLE	1114	#if EV_PERIODIC_ENABLE
1047	array_free (periodic, EMPTY);	1115	array_free (periodic, EMPTY);
		1116	#endif
		1117	#if EV_FORK_ENABLE
		1118	array_free (fork, EMPTY);
1048	#endif	1119	#endif
1049	array_free (prepare, EMPTY);	1120	array_free (prepare, EMPTY);
1050	array_free (check, EMPTY);	1121	array_free (check, EMPTY);
1051		1122
1052	backend = 0;	1123	backend = 0;
…		…
1451	/* update fd-related kernel structures */	1522	/* update fd-related kernel structures */
1452	fd_reify (EV_A);	1523	fd_reify (EV_A);
1453		1524
1454	/* calculate blocking time */	1525	/* calculate blocking time */
1455	{	1526	{
1456	ev_tstamp block;	1527	ev_tstamp waittime = 0.;
		1528	ev_tstamp sleeptime = 0.;
1457		1529
1458	if (expect_false (flags & EVLOOP_NONBLOCK \|\| idleall \|\| !activecnt))	1530	if (expect_true (!(flags & EVLOOP_NONBLOCK \|\| idleall \|\| !activecnt)))
1459	block = 0.; /* do not block at all */
1460	else
1461	{	1531	{
1462	/* update time to cancel out callback processing overhead */	1532	/* update time to cancel out callback processing overhead */
1463	time_update (EV_A_ 1e100);	1533	time_update (EV_A_ 1e100);
1464		1534
1465	block = MAX_BLOCKTIME;	1535	waittime = MAX_BLOCKTIME;
1466		1536
1467	if (timercnt)	1537	if (timercnt)
1468	{	1538	{
1469	ev_tstamp to = ((WT)timers [0])->at - mn_now + backend_fudge;	1539	ev_tstamp to = ((WT)timers [0])->at - mn_now + backend_fudge;
1470	if (block > to) block = to;	1540	if (waittime > to) waittime = to;
1471	}	1541	}
1472		1542
1473	#if EV_PERIODIC_ENABLE	1543	#if EV_PERIODIC_ENABLE
1474	if (periodiccnt)	1544	if (periodiccnt)
1475	{	1545	{
1476	ev_tstamp to = ((WT)periodics [0])->at - ev_rt_now + backend_fudge;	1546	ev_tstamp to = ((WT)periodics [0])->at - ev_rt_now + backend_fudge;
1477	if (block > to) block = to;	1547	if (waittime > to) waittime = to;
1478	}	1548	}
1479	#endif	1549	#endif
1480		1550
1481	if (expect_false (block < 0.)) block = 0.;	1551	if (expect_false (waittime < timeout_blocktime))
		1552	waittime = timeout_blocktime;
		1553
		1554	sleeptime = waittime - backend_fudge;
		1555
		1556	if (expect_true (sleeptime > io_blocktime))
		1557	sleeptime = io_blocktime;
		1558
		1559	if (sleeptime)
		1560	{
		1561	ev_sleep (sleeptime);
		1562	waittime -= sleeptime;
		1563	}
1482	}	1564	}
1483		1565
1484	++loop_count;	1566	++loop_count;
1485	backend_poll (EV_A_ block);	1567	backend_poll (EV_A_ waittime);
1486		1568
1487	/* update ev_rt_now, do magic */	1569	/* update ev_rt_now, do magic */
1488	time_update (EV_A_ block);	1570	time_update (EV_A_ waittime + sleeptime);
1489	}	1571	}
1490		1572
1491	/* queue pending timers and reschedule them */	1573	/* queue pending timers and reschedule them */
1492	timers_reify (EV_A); /* relative timers called last */	1574	timers_reify (EV_A); /* relative timers called last */
1493	#if EV_PERIODIC_ENABLE	1575	#if EV_PERIODIC_ENABLE
…		…
2177		2259
2178	#if EV_EMBED_ENABLE	2260	#if EV_EMBED_ENABLE
2179	void noinline	2261	void noinline
2180	ev_embed_sweep (EV_P_ ev_embed *w)	2262	ev_embed_sweep (EV_P_ ev_embed *w)
2181	{	2263	{
2182	ev_loop (w->loop, EVLOOP_NONBLOCK);	2264	ev_loop (w->other, EVLOOP_NONBLOCK);
2183	}	2265	}
2184		2266
2185	static void	2267	static void
2186	embed_cb (EV_P_ ev_io *io, int revents)	2268	embed_io_cb (EV_P_ ev_io *io, int revents)
2187	{	2269	{
2188	ev_embed w = (ev_embed )(((char *)io) - offsetof (ev_embed, io));	2270	ev_embed w = (ev_embed )(((char *)io) - offsetof (ev_embed, io));
2189		2271
2190	if (ev_cb (w))	2272	if (ev_cb (w))
2191	ev_feed_event (EV_A_ (W)w, EV_EMBED);	2273	ev_feed_event (EV_A_ (W)w, EV_EMBED);
2192	else	2274	else
2193	ev_embed_sweep (loop, w);	2275	ev_loop (w->other, EVLOOP_NONBLOCK);
2194	}	2276	}
		2277
		2278	static void
		2279	embed_prepare_cb (EV_P_ ev_prepare *prepare, int revents)
		2280	{
		2281	ev_embed w = (ev_embed )(((char *)prepare) - offsetof (ev_embed, prepare));
		2282
		2283	{
		2284	struct ev_loop *loop = w->other;
		2285
		2286	while (fdchangecnt)
		2287	{
		2288	fd_reify (EV_A);
		2289	ev_loop (EV_A_ EVLOOP_NONBLOCK);
		2290	}
		2291	}
		2292	}
		2293
		2294	#if 0
		2295	static void
		2296	embed_idle_cb (EV_P_ ev_idle *idle, int revents)
		2297	{
		2298	ev_idle_stop (EV_A_ idle);
		2299	}
		2300	#endif
2195		2301
2196	void	2302	void
2197	ev_embed_start (EV_P_ ev_embed *w)	2303	ev_embed_start (EV_P_ ev_embed *w)
2198	{	2304	{
2199	if (expect_false (ev_is_active (w)))	2305	if (expect_false (ev_is_active (w)))
2200	return;	2306	return;
2201		2307
2202	{	2308	{
2203	struct ev_loop *loop = w->loop;	2309	struct ev_loop *loop = w->other;
2204	assert (("loop to be embedded is not embeddable", backend & ev_embeddable_backends ()));	2310	assert (("loop to be embedded is not embeddable", backend & ev_embeddable_backends ()));
2205	ev_io_init (&w->io, embed_cb, backend_fd, EV_READ);	2311	ev_io_init (&w->io, embed_io_cb, backend_fd, EV_READ);
2206	}	2312	}
2207		2313
2208	ev_set_priority (&w->io, ev_priority (w));	2314	ev_set_priority (&w->io, ev_priority (w));
2209	ev_io_start (EV_A_ &w->io);	2315	ev_io_start (EV_A_ &w->io);
2210		2316
		2317	ev_prepare_init (&w->prepare, embed_prepare_cb);
		2318	ev_set_priority (&w->prepare, EV_MINPRI);
		2319	ev_prepare_start (EV_A_ &w->prepare);
		2320
		2321	/ev_idle_init (&w->idle, e,bed_idle_cb);/
		2322
2211	ev_start (EV_A_ (W)w, 1);	2323	ev_start (EV_A_ (W)w, 1);
2212	}	2324	}
2213		2325
2214	void	2326	void
2215	ev_embed_stop (EV_P_ ev_embed *w)	2327	ev_embed_stop (EV_P_ ev_embed *w)
…		…
2217	clear_pending (EV_A_ (W)w);	2329	clear_pending (EV_A_ (W)w);
2218	if (expect_false (!ev_is_active (w)))	2330	if (expect_false (!ev_is_active (w)))
2219	return;	2331	return;
2220		2332
2221	ev_io_stop (EV_A_ &w->io);	2333	ev_io_stop (EV_A_ &w->io);
		2334	ev_prepare_stop (EV_A_ &w->prepare);
2222		2335
2223	ev_stop (EV_A_ (W)w);	2336	ev_stop (EV_A_ (W)w);
2224	}	2337	}
2225	#endif	2338	#endif
2226		2339
…		…
2315	ev_timer_set (&once->to, timeout, 0.);	2428	ev_timer_set (&once->to, timeout, 0.);
2316	ev_timer_start (EV_A_ &once->to);	2429	ev_timer_start (EV_A_ &once->to);
2317	}	2430	}
2318	}	2431	}
2319		2432
		2433	#if EV_MULTIPLICITY
		2434	#include "ev_wrap.h"
		2435	#endif
		2436
2320	#ifdef __cplusplus	2437	#ifdef __cplusplus
2321	}	2438	}
2322	#endif	2439	#endif
2323		2440

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.185 by root, Fri Dec 14 18:22:30 2007 UTC vs. Revision 1.197 by root, Sat Dec 22 15:20:13 2007 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.185 by root, Fri Dec 14 18:22:30 2007 UTC vs.
Revision 1.197 by root, Sat Dec 22 15:20:13 2007 UTC