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

Comparing libev/ev.c (file contents):
Revision 1.271 by root, Mon Nov 3 12:13:15 2008 UTC vs.
Revision 1.273 by root, Mon Nov 3 14:27:06 2008 UTC

…		…
2415	# ifdef _WIN32	2415	# ifdef _WIN32
2416	# undef lstat	2416	# undef lstat
2417	# define lstat(a,b) _stati64 (a,b)	2417	# define lstat(a,b) _stati64 (a,b)
2418	# endif	2418	# endif
2419		2419
2420	#define DEF_STAT_INTERVAL 5.0074891	2420	#define DEF_STAT_INTERVAL 5.0074891
		2421	#define NFS_STAT_INTERVAL 30.1074891 /* for filesystems potentially failing inotify */
2421	#define MIN_STAT_INTERVAL 0.1074891	2422	#define MIN_STAT_INTERVAL 0.1074891
2422		2423
2423	static void noinline stat_timer_cb (EV_P_ ev_timer *w_, int revents);	2424	static void noinline stat_timer_cb (EV_P_ ev_timer *w_, int revents);
2424		2425
2425	#if EV_USE_INOTIFY	2426	#if EV_USE_INOTIFY
2426	# define EV_INOTIFY_BUFSIZE 8192	2427	# define EV_INOTIFY_BUFSIZE 8192
…		…
2430	{	2431	{
2431	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);	2432	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);
2432		2433
2433	if (w->wd < 0)	2434	if (w->wd < 0)
2434	{	2435	{
		2436	w->timer.repeat = w->interval ? w->interval : DEF_STAT_INTERVAL;
2435	ev_timer_start (EV_A_ &w->timer); /* this is not race-free, so we still need to recheck periodically */	2437	ev_timer_again (EV_A_ &w->timer); /* this is not race-free, so we still need to recheck periodically */
2436		2438
2437	/* monitor some parent directory for speedup hints */	2439	/* monitor some parent directory for speedup hints */
2438	/* note that exceeding the hardcoded path limit is not a correctness issue, */	2440	/* note that exceeding the hardcoded path limit is not a correctness issue, */
2439	/* but an efficiency issue only */	2441	/* but an efficiency issue only */
2440	if ((errno == ENOENT \|\| errno == EACCES) && strlen (w->path) < 4096)	2442	if ((errno == ENOENT \|\| errno == EACCES) && strlen (w->path) < 4096)
…		…
2457	}	2459	}
2458	while (w->wd < 0 && (errno == ENOENT \|\| errno == EACCES));	2460	while (w->wd < 0 && (errno == ENOENT \|\| errno == EACCES));
2459	}	2461	}
2460	}	2462	}
2461	else	2463	else
2462	todo, on nfs etc., we need to poll every 60s or so	2464	{
2463	ev_timer_stop (EV_A_ &w->timer); /* we can watch this in a race-free way */
2464
2465	if (w->wd >= 0)
2466	wlist_add (&fs_hash [w->wd & (EV_INOTIFY_HASHSIZE - 1)].head, (WL)w);	2465	wlist_add (&fs_hash [w->wd & (EV_INOTIFY_HASHSIZE - 1)].head, (WL)w);
		2466
		2467	/* now local changes will be tracked by inotify, but remote changes won't */
		2468	/* unless the filesystem it known to be local, we therefore still poll */
		2469	/* also do poll on <2.6.25, but with normal frequency */
		2470	struct statfs sfs;
		2471
		2472	if (fs_2625 && !statfs (w->path, &sfs))
		2473	if (sfs.f_type == 0x1373 /* devfs */
		2474	\|\| sfs.f_type == 0xEF53 /* ext2/3 */
		2475	\|\| sfs.f_type == 0x3153464a /* jfs */
		2476	\|\| sfs.f_type == 0x52654973 /* reiser3 */
		2477	\|\| sfs.f_type == 0x01021994 /* tempfs */
		2478	\|\| sfs.f_type == 0x58465342 /* xfs */)
		2479	return;
		2480
		2481	w->timer.repeat = w->interval ? w->interval : fs_2625 ? NFS_STAT_INTERVAL : DEF_STAT_INTERVAL;
		2482	ev_timer_again (EV_A_ &w->timer);
		2483	}
2467	}	2484	}
2468		2485
2469	static void noinline	2486	static void noinline
2470	infy_del (EV_P_ ev_stat *w)	2487	infy_del (EV_P_ ev_stat *w)
2471	{	2488	{
…		…
2524	for (ofs = 0; ofs < len; ofs += sizeof (struct inotify_event) + ev->len)	2541	for (ofs = 0; ofs < len; ofs += sizeof (struct inotify_event) + ev->len)
2525	infy_wd (EV_A_ ev->wd, ev->wd, ev);	2542	infy_wd (EV_A_ ev->wd, ev->wd, ev);
2526	}	2543	}
2527		2544
2528	void inline_size	2545	void inline_size
2529	infy_init (EV_P)	2546	check_2625 (EV_P)
2530	{	2547	{
2531	if (fs_fd != -2)
2532	return;
2533
2534	/* kernels < 2.6.25 are borked	2548	/* kernels < 2.6.25 are borked
2535	* http://www.ussg.indiana.edu/hypermail/linux/kernel/0711.3/1208.html	2549	* http://www.ussg.indiana.edu/hypermail/linux/kernel/0711.3/1208.html
2536	*/	2550	*/
2537	{
2538	struct utsname buf;	2551	struct utsname buf;
2539	int major, minor, micro;	2552	int major, minor, micro;
2540		2553
2541	fs_fd = -1;
2542
2543	if (uname (&buf))	2554	if (uname (&buf))
2544	return;	2555	return;
2545		2556
2546	if (sscanf (buf.release, "%d.%d.%d", &major, &minor, &micro) != 3)	2557	if (sscanf (buf.release, "%d.%d.%d", &major, &minor, &micro) != 3)
2547	return;	2558	return;
2548		2559
2549	if (major < 2	2560	if (major < 2
2550	\|\| (major == 2 && minor < 6)	2561	\|\| (major == 2 && minor < 6)
2551	\|\| (major == 2 && minor == 6 && micro < 25))	2562	\|\| (major == 2 && minor == 6 && micro < 25))
2552	return;	2563	return;
2553	}	2564
		2565	fs_2625 = 1;
		2566	}
		2567
		2568	void inline_size
		2569	infy_init (EV_P)
		2570	{
		2571	if (fs_fd != -2)
		2572	return;
		2573
		2574	fs_fd = -1;
		2575
		2576	check_2625 (EV_A);
2554		2577
2555	fs_fd = inotify_init ();	2578	fs_fd = inotify_init ();
2556		2579
2557	if (fs_fd >= 0)	2580	if (fs_fd >= 0)
2558	{	2581	{
…		…
2586	w->wd = -1;	2609	w->wd = -1;
2587		2610
2588	if (fs_fd >= 0)	2611	if (fs_fd >= 0)
2589	infy_add (EV_A_ w); /* re-add, no matter what */	2612	infy_add (EV_A_ w); /* re-add, no matter what */
2590	else	2613	else
2591	ev_timer_start (EV_A_ &w->timer);	2614	ev_timer_again (EV_A_ &w->timer);
2592	}	2615	}
2593	}	2616	}
2594	}	2617	}
2595		2618
2596	#endif	2619	#endif
…		…
2651	ev_stat_start (EV_P_ ev_stat *w)	2674	ev_stat_start (EV_P_ ev_stat *w)
2652	{	2675	{
2653	if (expect_false (ev_is_active (w)))	2676	if (expect_false (ev_is_active (w)))
2654	return;	2677	return;
2655		2678
2656	/* since we use memcmp, we need to clear any padding data etc. */
2657	memset (&w->prev, 0, sizeof (ev_statdata));
2658	memset (&w->attr, 0, sizeof (ev_statdata));
2659
2660	ev_stat_stat (EV_A_ w);	2679	ev_stat_stat (EV_A_ w);
2661		2680
		2681	if (w->interval < MIN_STAT_INTERVAL && w->interval)
2662	if (w->interval < MIN_STAT_INTERVAL)	2682	w->interval = MIN_STAT_INTERVAL;
2663	w->interval = w->interval ? MIN_STAT_INTERVAL : DEF_STAT_INTERVAL;
2664		2683
2665	ev_timer_init (&w->timer, stat_timer_cb, w->interval, w->interval);	2684	ev_timer_init (&w->timer, stat_timer_cb, 0., w->interval ? w->interval : DEF_STAT_INTERVAL);
2666	ev_set_priority (&w->timer, ev_priority (w));	2685	ev_set_priority (&w->timer, ev_priority (w));
2667		2686
2668	#if EV_USE_INOTIFY	2687	#if EV_USE_INOTIFY
2669	infy_init (EV_A);	2688	infy_init (EV_A);
2670		2689
2671	if (fs_fd >= 0)	2690	if (fs_fd >= 0)
2672	infy_add (EV_A_ w);	2691	infy_add (EV_A_ w);
2673	else	2692	else
2674	#endif	2693	#endif
2675	ev_timer_start (EV_A_ &w->timer);	2694	ev_timer_again (EV_A_ &w->timer);
2676		2695
2677	ev_start (EV_A_ (W)w, 1);	2696	ev_start (EV_A_ (W)w, 1);
2678		2697
2679	EV_FREQUENT_CHECK;	2698	EV_FREQUENT_CHECK;
2680	}	2699	}

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.271 by root, Mon Nov 3 12:13:15 2008 UTC vs. Revision 1.273 by root, Mon Nov 3 14:27:06 2008 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.271 by root, Mon Nov 3 12:13:15 2008 UTC vs.
Revision 1.273 by root, Mon Nov 3 14:27:06 2008 UTC