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

Comparing libev/ev.c (file contents):
Revision 1.318 by root, Tue Nov 17 00:22:28 2009 UTC vs.
Revision 1.333 by root, Tue Mar 9 08:58:22 2010 UTC

…		…
1	/*	1	/*
2	* libev event processing core, watcher management	2	* libev event processing core, watcher management
3	*	3	*
4	* Copyright (c) 2007,2008,2009 Marc Alexander Lehmann <libev@schmorp.de>	4	* Copyright (c) 2007,2008,2009,2010 Marc Alexander Lehmann <libev@schmorp.de>
5	* All rights reserved.	5	* All rights reserved.
6	*	6	*
7	* Redistribution and use in source and binary forms, with or without modifica-	7	* Redistribution and use in source and binary forms, with or without modifica-
8	* tion, are permitted provided that the following conditions are met:	8	* tion, are permitted provided that the following conditions are met:
9	*	9	*
110	# define EV_USE_EPOLL 0	110	# define EV_USE_EPOLL 0
111	# endif	111	# endif
112	# endif	112	# endif
113		113
114	# ifndef EV_USE_KQUEUE	114	# ifndef EV_USE_KQUEUE
115	# if HAVE_KQUEUE && HAVE_SYS_EVENT_H && HAVE_SYS_QUEUE_H	115	# if HAVE_KQUEUE && HAVE_SYS_EVENT_H
116	# define EV_USE_KQUEUE 1	116	# define EV_USE_KQUEUE 1
117	# else	117	# else
118	# define EV_USE_KQUEUE 0	118	# define EV_USE_KQUEUE 0
119	# endif	119	# endif
120	# endif	120	# endif
…		…
153		153
154	#endif	154	#endif
155		155
156	#include <math.h>	156	#include <math.h>
157	#include <stdlib.h>	157	#include <stdlib.h>
		158	#include <string.h>
158	#include <fcntl.h>	159	#include <fcntl.h>
159	#include <stddef.h>	160	#include <stddef.h>
160		161
161	#include <stdio.h>	162	#include <stdio.h>
162		163
163	#include <assert.h>	164	#include <assert.h>
164	#include <errno.h>	165	#include <errno.h>
165	#include <sys/types.h>	166	#include <sys/types.h>
166	#include <time.h>	167	#include <time.h>
		168	#include <limits.h>
167		169
168	#include <signal.h>	170	#include <signal.h>
169		171
170	#ifdef EV_H	172	#ifdef EV_H
171	# include EV_H	173	# include EV_H
…		…
182	# define WIN32_LEAN_AND_MEAN	184	# define WIN32_LEAN_AND_MEAN
183	# include <windows.h>	185	# include <windows.h>
184	# ifndef EV_SELECT_IS_WINSOCKET	186	# ifndef EV_SELECT_IS_WINSOCKET
185	# define EV_SELECT_IS_WINSOCKET 1	187	# define EV_SELECT_IS_WINSOCKET 1
186	# endif	188	# endif
		189	# undef EV_AVOID_STDIO
187	#endif	190	#endif
188		191
189	/* this block tries to deduce configuration from header-defined symbols and defaults */	192	/* this block tries to deduce configuration from header-defined symbols and defaults */
190		193
191	/* try to deduce the maximum number of signals on this platform */	194	/* try to deduce the maximum number of signals on this platform */
…		…
343	# endif	346	# endif
344	#endif	347	#endif
345		348
346	/* this block fixes any misconfiguration where we know we run into trouble otherwise */	349	/* this block fixes any misconfiguration where we know we run into trouble otherwise */
347		350
		351	#ifdef _AIX
		352	/* AIX has a completely broken poll.h header */
		353	# undef EV_USE_POLL
		354	# define EV_USE_POLL 0
		355	#endif
		356
348	#ifndef CLOCK_MONOTONIC	357	#ifndef CLOCK_MONOTONIC
349	# undef EV_USE_MONOTONIC	358	# undef EV_USE_MONOTONIC
350	# define EV_USE_MONOTONIC 0	359	# define EV_USE_MONOTONIC 0
351	#endif	360	#endif
352		361
…		…
395	# endif	404	# endif
396	# endif	405	# endif
397	# ifdef __cplusplus	406	# ifdef __cplusplus
398	extern "C" {	407	extern "C" {
399	# endif	408	# endif
400	int eventfd (unsigned int initval, int flags);	409	int (eventfd) (unsigned int initval, int flags);
401	# ifdef __cplusplus	410	# ifdef __cplusplus
402	}	411	}
403	# endif	412	# endif
404	#endif	413	#endif
405		414
…		…
504		513
505	#ifndef EV_FD_TO_WIN32_HANDLE	514	#ifndef EV_FD_TO_WIN32_HANDLE
506	# define EV_FD_TO_WIN32_HANDLE(fd) _get_osfhandle (fd)	515	# define EV_FD_TO_WIN32_HANDLE(fd) _get_osfhandle (fd)
507	#endif	516	#endif
508	#ifndef EV_WIN32_HANDLE_TO_FD	517	#ifndef EV_WIN32_HANDLE_TO_FD
509	# define EV_WIN32_HANDLE_TO_FD(handle) _open_osfhandle (fd, 0)	518	# define EV_WIN32_HANDLE_TO_FD(handle) _open_osfhandle (handle, 0)
510	#endif	519	#endif
511	#ifndef EV_WIN32_CLOSE_FD	520	#ifndef EV_WIN32_CLOSE_FD
512	# define EV_WIN32_CLOSE_FD(fd) close (fd)	521	# define EV_WIN32_CLOSE_FD(fd) close (fd)
513	#endif	522	#endif
514		523
515	#ifdef _WIN32	524	#ifdef _WIN32
516	# include "ev_win32.c"	525	# include "ev_win32.c"
517	#endif	526	#endif
518		527
519	/*****************************************************************************/	528	/*****************************************************************************/
		529
		530	#if EV_AVOID_STDIO
		531	static void noinline
		532	ev_printerr (const char *msg)
		533	{
		534	write (STDERR_FILENO, msg, strlen (msg));
		535	}
		536	#endif
520		537
521	static void (syserr_cb)(const char msg);	538	static void (syserr_cb)(const char msg);
522		539
523	void	540	void
524	ev_set_syserr_cb (void (cb)(const char msg))	541	ev_set_syserr_cb (void (cb)(const char msg))
…		…
534		551
535	if (syserr_cb)	552	if (syserr_cb)
536	syserr_cb (msg);	553	syserr_cb (msg);
537	else	554	else
538	{	555	{
		556	#if EV_AVOID_STDIO
		557	const char *err = strerror (errno);
		558
		559	ev_printerr (msg);
		560	ev_printerr (": ");
		561	ev_printerr (err);
		562	ev_printerr ("\n");
		563	#else
539	perror (msg);	564	perror (msg);
		565	#endif
540	abort ();	566	abort ();
541	}	567	}
542	}	568	}
543		569
544	static void *	570	static void *
…		…
569	{	595	{
570	ptr = alloc (ptr, size);	596	ptr = alloc (ptr, size);
571		597
572	if (!ptr && size)	598	if (!ptr && size)
573	{	599	{
		600	#if EV_AVOID_STDIO
		601	ev_printerr ("libev: memory allocation failed, aborting.\n");
		602	#else
574	fprintf (stderr, "libev: cannot allocate %ld bytes, aborting.", size);	603	fprintf (stderr, "libev: cannot allocate %ld bytes, aborting.", size);
		604	#endif
575	abort ();	605	abort ();
576	}	606	}
577		607
578	return ptr;	608	return ptr;
579	}	609	}
…		…
963	/* check whether the given fd is atcually valid, for error recovery */	993	/* check whether the given fd is atcually valid, for error recovery */
964	inline_size int	994	inline_size int
965	fd_valid (int fd)	995	fd_valid (int fd)
966	{	996	{
967	#ifdef _WIN32	997	#ifdef _WIN32
968	return _get_osfhandle (fd) != -1;	998	return EV_FD_TO_WIN32_HANDLE (fd) != -1;
969	#else	999	#else
970	return fcntl (fd, F_GETFD) != -1;	1000	return fcntl (fd, F_GETFD) != -1;
971	#endif	1001	#endif
972	}	1002	}
973		1003
…		…
1178	inline_speed void	1208	inline_speed void
1179	fd_intern (int fd)	1209	fd_intern (int fd)
1180	{	1210	{
1181	#ifdef _WIN32	1211	#ifdef _WIN32
1182	unsigned long arg = 1;	1212	unsigned long arg = 1;
1183	ioctlsocket (_get_osfhandle (fd), FIONBIO, &arg);	1213	ioctlsocket (EV_FD_TO_WIN32_HANDLE (fd), FIONBIO, &arg);
1184	#else	1214	#else
1185	fcntl (fd, F_SETFD, FD_CLOEXEC);	1215	fcntl (fd, F_SETFD, FD_CLOEXEC);
1186	fcntl (fd, F_SETFL, O_NONBLOCK);	1216	fcntl (fd, F_SETFL, O_NONBLOCK);
1187	#endif	1217	#endif
1188	}	1218	}
…		…
1293	{	1323	{
1294	#if EV_MULTIPLICITY	1324	#if EV_MULTIPLICITY
1295	EV_P = signals [signum - 1].loop;	1325	EV_P = signals [signum - 1].loop;
1296	#endif	1326	#endif
1297		1327
1298	#if _WIN32	1328	#ifdef _WIN32
1299	signal (signum, ev_sighandler);	1329	signal (signum, ev_sighandler);
1300	#endif	1330	#endif
1301		1331
1302	signals [signum - 1].pending = 1;	1332	signals [signum - 1].pending = 1;
1303	evpipe_write (EV_A_ &sig_pending);	1333	evpipe_write (EV_A_ &sig_pending);
…		…
1604	#endif	1634	#endif
1605	#if EV_USE_INOTIFY	1635	#if EV_USE_INOTIFY
1606	fs_fd = flags & EVFLAG_NOINOTIFY ? -1 : -2;	1636	fs_fd = flags & EVFLAG_NOINOTIFY ? -1 : -2;
1607	#endif	1637	#endif
1608	#if EV_USE_SIGNALFD	1638	#if EV_USE_SIGNALFD
1609	sigfd = flags & EVFLAG_NOSIGFD ? -1 : -2;	1639	sigfd = flags & EVFLAG_SIGNALFD ? -2 : -1;
1610	#endif	1640	#endif
1611		1641
1612	if (!(flags & 0x0000ffffU))	1642	if (!(flags & 0x0000ffffU))
1613	flags \|= ev_recommended_backends ();	1643	flags \|= ev_recommended_backends ();
1614		1644
…		…
2156	ANHE_at_cache (*he);	2186	ANHE_at_cache (*he);
2157	}	2187	}
2158	}	2188	}
2159		2189
2160	/* fetch new monotonic and realtime times from the kernel */	2190	/* fetch new monotonic and realtime times from the kernel */
2161	/* also detetc if there was a timejump, and act accordingly */	2191	/* also detect if there was a timejump, and act accordingly */
2162	inline_speed void	2192	inline_speed void
2163	time_update (EV_P_ ev_tstamp max_block)	2193	time_update (EV_P_ ev_tstamp max_block)
2164	{	2194	{
2165	#if EV_USE_MONOTONIC	2195	#if EV_USE_MONOTONIC
2166	if (expect_true (have_monotonic))	2196	if (expect_true (have_monotonic))
…		…
2500		2530
2501	if (expect_false (ev_is_active (w)))	2531	if (expect_false (ev_is_active (w)))
2502	return;	2532	return;
2503		2533
2504	assert (("libev: ev_io_start called with negative fd", fd >= 0));	2534	assert (("libev: ev_io_start called with negative fd", fd >= 0));
2505	assert (("libev: ev_io start called with illegal event mask", !(w->events & ~(EV__IOFDSET \| EV_READ \| EV_WRITE))));	2535	assert (("libev: ev_io_start called with illegal event mask", !(w->events & ~(EV__IOFDSET \| EV_READ \| EV_WRITE))));
2506		2536
2507	EV_FREQUENT_CHECK;	2537	EV_FREQUENT_CHECK;
2508		2538
2509	ev_start (EV_A_ (W)w, 1);	2539	ev_start (EV_A_ (W)w, 1);
2510	array_needsize (ANFD, anfds, anfdmax, fd + 1, array_init_zero);	2540	array_needsize (ANFD, anfds, anfdmax, fd + 1, array_init_zero);
…		…
2580	timers [active] = timers [timercnt + HEAP0];	2610	timers [active] = timers [timercnt + HEAP0];
2581	adjustheap (timers, timercnt, active);	2611	adjustheap (timers, timercnt, active);
2582	}	2612	}
2583	}	2613	}
2584		2614
2585	EV_FREQUENT_CHECK;
2586
2587	ev_at (w) -= mn_now;	2615	ev_at (w) -= mn_now;
2588		2616
2589	ev_stop (EV_A_ (W)w);	2617	ev_stop (EV_A_ (W)w);
		2618
		2619	EV_FREQUENT_CHECK;
2590	}	2620	}
2591		2621
2592	void noinline	2622	void noinline
2593	ev_timer_again (EV_P_ ev_timer *w)	2623	ev_timer_again (EV_P_ ev_timer *w)
2594	{	2624	{
…		…
2673	periodics [active] = periodics [periodiccnt + HEAP0];	2703	periodics [active] = periodics [periodiccnt + HEAP0];
2674	adjustheap (periodics, periodiccnt, active);	2704	adjustheap (periodics, periodiccnt, active);
2675	}	2705	}
2676	}	2706	}
2677		2707
2678	EV_FREQUENT_CHECK;
2679
2680	ev_stop (EV_A_ (W)w);	2708	ev_stop (EV_A_ (W)w);
		2709
		2710	EV_FREQUENT_CHECK;
2681	}	2711	}
2682		2712
2683	void noinline	2713	void noinline
2684	ev_periodic_again (EV_P_ ev_periodic *w)	2714	ev_periodic_again (EV_P_ ev_periodic *w)
2685	{	2715	{
…		…
2746	if (!((WL)w)->next)	2776	if (!((WL)w)->next)
2747	# if EV_USE_SIGNALFD	2777	# if EV_USE_SIGNALFD
2748	if (sigfd < 0) /TODO/	2778	if (sigfd < 0) /TODO/
2749	# endif	2779	# endif
2750	{	2780	{
2751	# if _WIN32	2781	# ifdef _WIN32
2752	evpipe_init (EV_A);	2782	evpipe_init (EV_A);
2753		2783
2754	signal (w->signum, ev_sighandler);	2784	signal (w->signum, ev_sighandler);
2755	# else	2785	# else
2756	struct sigaction sa;	2786	struct sigaction sa;
…		…
2789	signals [w->signum - 1].loop = 0; /* unattach from signal */	2819	signals [w->signum - 1].loop = 0; /* unattach from signal */
2790	#endif	2820	#endif
2791	#if EV_USE_SIGNALFD	2821	#if EV_USE_SIGNALFD
2792	if (sigfd >= 0)	2822	if (sigfd >= 0)
2793	{	2823	{
2794	sigprocmask (SIG_UNBLOCK, &sigfd_set, 0);//D	2824	sigset_t ss;
		2825
		2826	sigemptyset (&ss);
		2827	sigaddset (&ss, w->signum);
2795	sigdelset (&sigfd_set, w->signum);	2828	sigdelset (&sigfd_set, w->signum);
		2829
2796	signalfd (sigfd, &sigfd_set, 0);	2830	signalfd (sigfd, &sigfd_set, 0);
2797	sigprocmask (SIG_BLOCK, &sigfd_set, 0);//D	2831	sigprocmask (SIG_UNBLOCK, &ss, 0);
2798	/TODO: maybe unblock signal? /
2799	}	2832	}
2800	else	2833	else
2801	#endif	2834	#endif
2802	signal (w->signum, SIG_DFL);	2835	signal (w->signum, SIG_DFL);
2803	}	2836	}
…		…
2849	#define MIN_STAT_INTERVAL 0.1074891	2882	#define MIN_STAT_INTERVAL 0.1074891
2850		2883
2851	static void noinline stat_timer_cb (EV_P_ ev_timer *w_, int revents);	2884	static void noinline stat_timer_cb (EV_P_ ev_timer *w_, int revents);
2852		2885
2853	#if EV_USE_INOTIFY	2886	#if EV_USE_INOTIFY
2854	# define EV_INOTIFY_BUFSIZE 8192	2887
		2888	/* the * 2 is to allow for alignment padding, which for some reason is >> 8 */
		2889	# define EV_INOTIFY_BUFSIZE (sizeof (struct inotify_event) * 2 + NAME_MAX)
2855		2890
2856	static void noinline	2891	static void noinline
2857	infy_add (EV_P_ ev_stat *w)	2892	infy_add (EV_P_ ev_stat *w)
2858	{	2893	{
2859	w->wd = inotify_add_watch (fs_fd, w->path, IN_ATTRIB \| IN_DELETE_SELF \| IN_MOVE_SELF \| IN_MODIFY \| IN_DONT_FOLLOW \| IN_MASK_ADD);	2894	w->wd = inotify_add_watch (fs_fd, w->path, IN_ATTRIB \| IN_DELETE_SELF \| IN_MOVE_SELF \| IN_MODIFY \| IN_DONT_FOLLOW \| IN_MASK_ADD);
…		…
2968		3003
2969	static void	3004	static void
2970	infy_cb (EV_P_ ev_io *w, int revents)	3005	infy_cb (EV_P_ ev_io *w, int revents)
2971	{	3006	{
2972	char buf [EV_INOTIFY_BUFSIZE];	3007	char buf [EV_INOTIFY_BUFSIZE];
2973	struct inotify_event ev = (struct inotify_event )buf;
2974	int ofs;	3008	int ofs;
2975	int len = read (fs_fd, buf, sizeof (buf));	3009	int len = read (fs_fd, buf, sizeof (buf));
2976		3010
2977	for (ofs = 0; ofs < len; ofs += sizeof (struct inotify_event) + ev->len)	3011	for (ofs = 0; ofs < len; )
		3012	{
		3013	struct inotify_event ev = (struct inotify_event )(buf + ofs);
2978	infy_wd (EV_A_ ev->wd, ev->wd, ev);	3014	infy_wd (EV_A_ ev->wd, ev->wd, ev);
		3015	ofs += sizeof (struct inotify_event) + ev->len;
		3016	}
		3017	}
		3018
		3019	inline_size unsigned int
		3020	ev_linux_version (void)
		3021	{
		3022	struct utsname buf;
		3023	unsigned int v;
		3024	int i;
		3025	char *p = buf.release;
		3026
		3027	if (uname (&buf))
		3028	return 0;
		3029
		3030	for (i = 3+1; --i; )
		3031	{
		3032	unsigned int c = 0;
		3033
		3034	for (;;)
		3035	{
		3036	if (p >= '0' && p <= '9')
		3037	c = c * 10 + *p++ - '0';
		3038	else
		3039	{
		3040	p += *p == '.';
		3041	break;
		3042	}
		3043	}
		3044
		3045	v = (v << 8) \| c;
		3046	}
		3047
		3048	return v;
2979	}	3049	}
2980		3050
2981	inline_size void	3051	inline_size void
2982	check_2625 (EV_P)	3052	ev_check_2625 (EV_P)
2983	{	3053	{
2984	/* kernels < 2.6.25 are borked	3054	/* kernels < 2.6.25 are borked
2985	* http://www.ussg.indiana.edu/hypermail/linux/kernel/0711.3/1208.html	3055	* http://www.ussg.indiana.edu/hypermail/linux/kernel/0711.3/1208.html
2986	*/	3056	*/
2987	struct utsname buf;	3057	if (ev_linux_version () < 0x020619)
2988	int major, minor, micro;
2989
2990	if (uname (&buf))
2991	return;
2992
2993	if (sscanf (buf.release, "%d.%d.%d", &major, &minor, &micro) != 3)
2994	return;
2995
2996	if (major < 2
2997	\|\| (major == 2 && minor < 6)
2998	\|\| (major == 2 && minor == 6 && micro < 25))
2999	return;	3058	return;
3000		3059
3001	fs_2625 = 1;	3060	fs_2625 = 1;
3002	}	3061	}
3003		3062
…		…
3018	if (fs_fd != -2)	3077	if (fs_fd != -2)
3019	return;	3078	return;
3020		3079
3021	fs_fd = -1;	3080	fs_fd = -1;
3022		3081
3023	check_2625 (EV_A);	3082	ev_check_2625 (EV_A);
3024		3083
3025	fs_fd = infy_newfd ();	3084	fs_fd = infy_newfd ();
3026		3085
3027	if (fs_fd >= 0)	3086	if (fs_fd >= 0)
3028	{	3087	{
…		…
3100	static void noinline	3159	static void noinline
3101	stat_timer_cb (EV_P_ ev_timer *w_, int revents)	3160	stat_timer_cb (EV_P_ ev_timer *w_, int revents)
3102	{	3161	{
3103	ev_stat w = (ev_stat )(((char *)w_) - offsetof (ev_stat, timer));	3162	ev_stat w = (ev_stat )(((char *)w_) - offsetof (ev_stat, timer));
3104		3163
3105	/* we copy this here each the time so that */	3164	ev_statdata prev = w->attr;
3106	/* prev has the old value when the callback gets invoked */
3107	w->prev = w->attr;
3108	ev_stat_stat (EV_A_ w);	3165	ev_stat_stat (EV_A_ w);
3109		3166
3110	/* memcmp doesn't work on netbsd, they.... do stuff to their struct stat */	3167	/* memcmp doesn't work on netbsd, they.... do stuff to their struct stat */
3111	if (	3168	if (
3112	w->prev.st_dev != w->attr.st_dev	3169	prev.st_dev != w->attr.st_dev
3113	\|\| w->prev.st_ino != w->attr.st_ino	3170	\|\| prev.st_ino != w->attr.st_ino
3114	\|\| w->prev.st_mode != w->attr.st_mode	3171	\|\| prev.st_mode != w->attr.st_mode
3115	\|\| w->prev.st_nlink != w->attr.st_nlink	3172	\|\| prev.st_nlink != w->attr.st_nlink
3116	\|\| w->prev.st_uid != w->attr.st_uid	3173	\|\| prev.st_uid != w->attr.st_uid
3117	\|\| w->prev.st_gid != w->attr.st_gid	3174	\|\| prev.st_gid != w->attr.st_gid
3118	\|\| w->prev.st_rdev != w->attr.st_rdev	3175	\|\| prev.st_rdev != w->attr.st_rdev
3119	\|\| w->prev.st_size != w->attr.st_size	3176	\|\| prev.st_size != w->attr.st_size
3120	\|\| w->prev.st_atime != w->attr.st_atime	3177	\|\| prev.st_atime != w->attr.st_atime
3121	\|\| w->prev.st_mtime != w->attr.st_mtime	3178	\|\| prev.st_mtime != w->attr.st_mtime
3122	\|\| w->prev.st_ctime != w->attr.st_ctime	3179	\|\| prev.st_ctime != w->attr.st_ctime
3123	) {	3180	) {
		3181	/* we only update w->prev on actual differences */
		3182	/* in case we test more often than invoke the callback, */
		3183	/* to ensure that prev is always different to attr */
		3184	w->prev = prev;
		3185
3124	#if EV_USE_INOTIFY	3186	#if EV_USE_INOTIFY
3125	if (fs_fd >= 0)	3187	if (fs_fd >= 0)
3126	{	3188	{
3127	infy_del (EV_A_ w);	3189	infy_del (EV_A_ w);
3128	infy_add (EV_A_ w);	3190	infy_add (EV_A_ w);
…		…
3409	EV_FREQUENT_CHECK;	3471	EV_FREQUENT_CHECK;
3410		3472
3411	ev_io_stop (EV_A_ &w->io);	3473	ev_io_stop (EV_A_ &w->io);
3412	ev_prepare_stop (EV_A_ &w->prepare);	3474	ev_prepare_stop (EV_A_ &w->prepare);
3413	ev_fork_stop (EV_A_ &w->fork);	3475	ev_fork_stop (EV_A_ &w->fork);
		3476
		3477	ev_stop (EV_A_ (W)w);
3414		3478
3415	EV_FREQUENT_CHECK;	3479	EV_FREQUENT_CHECK;
3416	}	3480	}
3417	#endif	3481	#endif
3418		3482

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.318 by root, Tue Nov 17 00:22:28 2009 UTC vs. Revision 1.333 by root, Tue Mar 9 08:58:22 2010 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.318 by root, Tue Nov 17 00:22:28 2009 UTC vs.
Revision 1.333 by root, Tue Mar 9 08:58:22 2010 UTC