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

Comparing libev/ev.c (file contents):
Revision 1.448 by root, Tue Jul 24 16:28:08 2012 UTC vs.
Revision 1.470 by root, Sun Sep 7 13:44:21 2014 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,2010,2011,2012 Marc Alexander Lehmann <libev@schmorp.de>	4	* Copyright (c) 2007,2008,2009,2010,2011,2012,2013 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	*
43	# include EV_CONFIG_H	43	# include EV_CONFIG_H
44	# else	44	# else
45	# include "config.h"	45	# include "config.h"
46	# endif	46	# endif
47		47
48	#if HAVE_FLOOR	48	# if HAVE_FLOOR
49	# ifndef EV_USE_FLOOR	49	# ifndef EV_USE_FLOOR
50	# define EV_USE_FLOOR 1	50	# define EV_USE_FLOOR 1
		51	# endif
51	# endif	52	# endif
52	#endif
53		53
54	# if HAVE_CLOCK_SYSCALL	54	# if HAVE_CLOCK_SYSCALL
55	# ifndef EV_USE_CLOCK_SYSCALL	55	# ifndef EV_USE_CLOCK_SYSCALL
56	# define EV_USE_CLOCK_SYSCALL 1	56	# define EV_USE_CLOCK_SYSCALL 1
57	# ifndef EV_USE_REALTIME	57	# ifndef EV_USE_REALTIME
…		…
241	#elif defined SIGARRAYSIZE	241	#elif defined SIGARRAYSIZE
242	# define EV_NSIG (SIGARRAYSIZE) /* Assume ary[SIGARRAYSIZE] */	242	# define EV_NSIG (SIGARRAYSIZE) /* Assume ary[SIGARRAYSIZE] */
243	#elif defined _sys_nsig	243	#elif defined _sys_nsig
244	# define EV_NSIG (_sys_nsig) /* Solaris 2.5 */	244	# define EV_NSIG (_sys_nsig) /* Solaris 2.5 */
245	#else	245	#else
246	# error "unable to find value for NSIG, please report"	246	# define EV_NSIG (8 * sizeof (sigset_t) + 1)
247	/* to make it compile regardless, just remove the above line, */
248	/* but consider reporting it, too! :) */
249	# define EV_NSIG 65
250	#endif	247	#endif
251		248
252	#ifndef EV_USE_FLOOR	249	#ifndef EV_USE_FLOOR
253	# define EV_USE_FLOOR 0	250	# define EV_USE_FLOOR 0
254	#endif	251	#endif
255		252
256	#ifndef EV_USE_CLOCK_SYSCALL	253	#ifndef EV_USE_CLOCK_SYSCALL
257	# if __linux && __GLIBC__ >= 2	254	# if __linux && __GLIBC__ == 2 && __GLIBC_MINOR__ < 17
258	# define EV_USE_CLOCK_SYSCALL EV_FEATURE_OS	255	# define EV_USE_CLOCK_SYSCALL EV_FEATURE_OS
259	# else	256	# else
260	# define EV_USE_CLOCK_SYSCALL 0	257	# define EV_USE_CLOCK_SYSCALL 0
		258	# endif
		259	#endif
		260
		261	#if !(_POSIX_TIMERS > 0)
		262	# ifndef EV_USE_MONOTONIC
		263	# define EV_USE_MONOTONIC 0
		264	# endif
		265	# ifndef EV_USE_REALTIME
		266	# define EV_USE_REALTIME 0
261	# endif	267	# endif
262	#endif	268	#endif
263		269
264	#ifndef EV_USE_MONOTONIC	270	#ifndef EV_USE_MONOTONIC
265	# if defined _POSIX_MONOTONIC_CLOCK && _POSIX_MONOTONIC_CLOCK >= 0	271	# if defined _POSIX_MONOTONIC_CLOCK && _POSIX_MONOTONIC_CLOCK >= 0
…		…
355	# define EV_USE_4HEAP EV_FEATURE_DATA	361	# define EV_USE_4HEAP EV_FEATURE_DATA
356	#endif	362	#endif
357		363
358	#ifndef EV_HEAP_CACHE_AT	364	#ifndef EV_HEAP_CACHE_AT
359	# define EV_HEAP_CACHE_AT EV_FEATURE_DATA	365	# define EV_HEAP_CACHE_AT EV_FEATURE_DATA
		366	#endif
		367
		368	#ifdef ANDROID
		369	/* supposedly, android doesn't typedef fd_mask */
		370	# undef EV_USE_SELECT
		371	# define EV_USE_SELECT 0
		372	/* supposedly, we need to include syscall.h, not sys/syscall.h, so just disable */
		373	# undef EV_USE_CLOCK_SYSCALL
		374	# define EV_USE_CLOCK_SYSCALL 0
		375	#endif
		376
		377	/* aix's poll.h seems to cause lots of trouble */
		378	#ifdef _AIX
		379	/* AIX has a completely broken poll.h header */
		380	# undef EV_USE_POLL
		381	# define EV_USE_POLL 0
360	#endif	382	#endif
361		383
362	/* on linux, we can use a (slow) syscall to avoid a dependency on pthread, */	384	/* on linux, we can use a (slow) syscall to avoid a dependency on pthread, */
363	/* which makes programs even slower. might work on other unices, too. */	385	/* which makes programs even slower. might work on other unices, too. */
364	#if EV_USE_CLOCK_SYSCALL	386	#if EV_USE_CLOCK_SYSCALL
…		…
372	# define EV_USE_CLOCK_SYSCALL 0	394	# define EV_USE_CLOCK_SYSCALL 0
373	# endif	395	# endif
374	#endif	396	#endif
375		397
376	/* this block fixes any misconfiguration where we know we run into trouble otherwise */	398	/* this block fixes any misconfiguration where we know we run into trouble otherwise */
377
378	#ifdef _AIX
379	/* AIX has a completely broken poll.h header */
380	# undef EV_USE_POLL
381	# define EV_USE_POLL 0
382	#endif
383		399
384	#ifndef CLOCK_MONOTONIC	400	#ifndef CLOCK_MONOTONIC
385	# undef EV_USE_MONOTONIC	401	# undef EV_USE_MONOTONIC
386	# define EV_USE_MONOTONIC 0	402	# define EV_USE_MONOTONIC 0
387	#endif	403	#endif
…		…
475	/* the following is ecb.h embedded into libev - use update_ev_c to update from an external copy */	491	/* the following is ecb.h embedded into libev - use update_ev_c to update from an external copy */
476	/* ECB.H BEGIN */	492	/* ECB.H BEGIN */
477	/*	493	/*
478	* libecb - http://software.schmorp.de/pkg/libecb	494	* libecb - http://software.schmorp.de/pkg/libecb
479	*	495	*
480	* Copyright (©) 2009-2012 Marc Alexander Lehmann <libecb@schmorp.de>	496	* Copyright (©) 2009-2014 Marc Alexander Lehmann <libecb@schmorp.de>
481	* Copyright (©) 2011 Emanuele Giaquinta	497	* Copyright (©) 2011 Emanuele Giaquinta
482	* All rights reserved.	498	* All rights reserved.
483	*	499	*
484	* Redistribution and use in source and binary forms, with or without modifica-	500	* Redistribution and use in source and binary forms, with or without modifica-
485	* tion, are permitted provided that the following conditions are met:	501	* tion, are permitted provided that the following conditions are met:
…		…
499	* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;	515	* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
500	* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,	516	* OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
501	* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-	517	* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-
502	* ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED	518	* ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
503	* OF THE POSSIBILITY OF SUCH DAMAGE.	519	* OF THE POSSIBILITY OF SUCH DAMAGE.
		520	*
		521	* Alternatively, the contents of this file may be used under the terms of
		522	* the GNU General Public License ("GPL") version 2 or any later version,
		523	* in which case the provisions of the GPL are applicable instead of
		524	* the above. If you wish to allow the use of your version of this file
		525	* only under the terms of the GPL and not to allow others to use your
		526	* version of this file under the BSD license, indicate your decision
		527	* by deleting the provisions above and replace them with the notice
		528	* and other provisions required by the GPL. If you do not delete the
		529	* provisions above, a recipient may use your version of this file under
		530	* either the BSD or the GPL.
504	*/	531	*/
505		532
506	#ifndef ECB_H	533	#ifndef ECB_H
507	#define ECB_H	534	#define ECB_H
508		535
509	/* 16 bits major, 16 bits minor */	536	/* 16 bits major, 16 bits minor */
510	#define ECB_VERSION 0x00010001	537	#define ECB_VERSION 0x00010003
511		538
512	#ifdef _WIN32	539	#ifdef _WIN32
513	typedef signed char int8_t;	540	typedef signed char int8_t;
514	typedef unsigned char uint8_t;	541	typedef unsigned char uint8_t;
515	typedef signed short int16_t;	542	typedef signed short int16_t;
…		…
530	#else	557	#else
531	#define ECB_PTRSIZE 4	558	#define ECB_PTRSIZE 4
532	typedef uint32_t uintptr_t;	559	typedef uint32_t uintptr_t;
533	typedef int32_t intptr_t;	560	typedef int32_t intptr_t;
534	#endif	561	#endif
535	typedef intptr_t ptrdiff_t;
536	#else	562	#else
537	#include <inttypes.h>	563	#include <inttypes.h>
538	#if UINTMAX_MAX > 0xffffffffU	564	#if UINTMAX_MAX > 0xffffffffU
539	#define ECB_PTRSIZE 8	565	#define ECB_PTRSIZE 8
540	#else	566	#else
541	#define ECB_PTRSIZE 4	567	#define ECB_PTRSIZE 4
		568	#endif
		569	#endif
		570
		571	/* work around x32 idiocy by defining proper macros */
		572	#if __amd64 \|\| __x86_64 \|\| _M_AMD64 \|\| _M_X64
		573	#if _ILP32
		574	#define ECB_AMD64_X32 1
		575	#else
		576	#define ECB_AMD64 1
542	#endif	577	#endif
543	#endif	578	#endif
544		579
545	/* many compilers define _GNUC_ to some versions but then only implement	580	/* many compilers define _GNUC_ to some versions but then only implement
546	* what their idiot authors think are the "more important" extensions,	581	* what their idiot authors think are the "more important" extensions,
…		…
555	#else	590	#else
556	#define ECB_GCC_VERSION(major,minor) (__GNUC__ > (major) \|\| (__GNUC__ == (major) && __GNUC_MINOR__ >= (minor)))	591	#define ECB_GCC_VERSION(major,minor) (__GNUC__ > (major) \|\| (__GNUC__ == (major) && __GNUC_MINOR__ >= (minor)))
557	#endif	592	#endif
558	#endif	593	#endif
559		594
560	#define ECB_C (__STDC__+0) /* this assumes that __STDC__ is either empty or a number */
561	#define ECB_C99 (__STDC_VERSION__ >= 199901L)
562	#define ECB_C11 (__STDC_VERSION__ >= 201112L)
563	#define ECB_CPP (__cplusplus+0)	595	#define ECB_CPP (__cplusplus+0)
564	#define ECB_CPP11 (__cplusplus >= 201103L)	596	#define ECB_CPP11 (__cplusplus >= 201103L)
		597
		598	#if ECB_CPP
		599	#define ECB_C 0
		600	#define ECB_STDC_VERSION 0
		601	#else
		602	#define ECB_C 1
		603	#define ECB_STDC_VERSION __STDC_VERSION__
		604	#endif
		605
		606	#define ECB_C99 (ECB_STDC_VERSION >= 199901L)
		607	#define ECB_C11 (ECB_STDC_VERSION >= 201112L)
		608
		609	#if ECB_CPP
		610	#define ECB_EXTERN_C extern "C"
		611	#define ECB_EXTERN_C_BEG ECB_EXTERN_C {
		612	#define ECB_EXTERN_C_END }
		613	#else
		614	#define ECB_EXTERN_C extern
		615	#define ECB_EXTERN_C_BEG
		616	#define ECB_EXTERN_C_END
		617	#endif
565		618
566	/*****************************************************************************/	619	/*****************************************************************************/
567		620
568	/* ECB_NO_THREADS - ecb is not used by multiple threads, ever */	621	/* ECB_NO_THREADS - ecb is not used by multiple threads, ever */
569	/* ECB_NO_SMP - ecb might be used in multiple threads, but only on a single cpu */	622	/* ECB_NO_SMP - ecb might be used in multiple threads, but only on a single cpu */
…		…
592	\|\| defined __ARM_ARCH_6K__ \|\| defined __ARM_ARCH_6ZK__	645	\|\| defined __ARM_ARCH_6K__ \|\| defined __ARM_ARCH_6ZK__
593	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mcr p15,0,%0,c7,c10,5" : : "r" (0) : "memory")	646	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mcr p15,0,%0,c7,c10,5" : : "r" (0) : "memory")
594	#elif defined __ARM_ARCH_7__ \|\| defined __ARM_ARCH_7A__ \	647	#elif defined __ARM_ARCH_7__ \|\| defined __ARM_ARCH_7A__ \
595	\|\| defined __ARM_ARCH_7M__ \|\| defined __ARM_ARCH_7R__	648	\|\| defined __ARM_ARCH_7M__ \|\| defined __ARM_ARCH_7R__
596	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("dmb" : : : "memory")	649	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("dmb" : : : "memory")
		650	#elif __aarch64__
		651	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("dmb ish" : : : "memory")
597	#elif __sparc \|\| __sparc__	652	#elif (__sparc \|\| __sparc__) && !__sparcv8
598	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("membar #LoadStore \| #LoadLoad \| #StoreStore \| #StoreLoad" : : : "memory")	653	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("membar #LoadStore \| #LoadLoad \| #StoreStore \| #StoreLoad" : : : "memory")
599	#define ECB_MEMORY_FENCE_ACQUIRE __asm__ __volatile__ ("membar #LoadStore \| #LoadLoad" : : : "memory")	654	#define ECB_MEMORY_FENCE_ACQUIRE __asm__ __volatile__ ("membar #LoadStore \| #LoadLoad" : : : "memory")
600	#define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("membar #LoadStore \| #StoreStore")	655	#define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("membar #LoadStore \| #StoreStore")
601	#elif defined __s390__ \|\| defined __s390x__	656	#elif defined __s390__ \|\| defined __s390x__
602	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("bcr 15,0" : : : "memory")	657	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("bcr 15,0" : : : "memory")
603	#elif defined __mips__	658	#elif defined __mips__
		659	/* GNU/Linux emulates sync on mips1 architectures, so we force its use */
		660	/* anybody else who still uses mips1 is supposed to send in their version, with detection code. */
604	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("sync" : : : "memory")	661	#define ECB_MEMORY_FENCE __asm__ __volatile__ (".set mips2; sync; .set mips0" : : : "memory")
605	#elif defined __alpha__	662	#elif defined __alpha__
606	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mb" : : : "memory")	663	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mb" : : : "memory")
607	#elif defined __hppa__	664	#elif defined __hppa__
608	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("" : : : "memory")	665	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("" : : : "memory")
609	#define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("")	666	#define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("")
610	#elif defined __ia64__	667	#elif defined __ia64__
611	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mf" : : : "memory")	668	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("mf" : : : "memory")
		669	#elif defined __m68k__
		670	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("" : : : "memory")
		671	#elif defined __m88k__
		672	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("tb1 0,%%r0,128" : : : "memory")
		673	#elif defined __sh__
		674	#define ECB_MEMORY_FENCE __asm__ __volatile__ ("" : : : "memory")
612	#endif	675	#endif
613	#endif	676	#endif
614	#endif	677	#endif
615		678
616	#ifndef ECB_MEMORY_FENCE	679	#ifndef ECB_MEMORY_FENCE
617	#if ECB_GCC_VERSION(4,7)	680	#if ECB_GCC_VERSION(4,7)
618	/* see comment below (stdatomic.h) about the C11 memory model. */	681	/* see comment below (stdatomic.h) about the C11 memory model. */
619	#define ECB_MEMORY_FENCE __atomic_thread_fence (__ATOMIC_SEQ_CST)	682	#define ECB_MEMORY_FENCE __atomic_thread_fence (__ATOMIC_SEQ_CST)
		683	#define ECB_MEMORY_FENCE_ACQUIRE __atomic_thread_fence (__ATOMIC_ACQUIRE)
		684	#define ECB_MEMORY_FENCE_RELEASE __atomic_thread_fence (__ATOMIC_RELEASE)
		685
		686	/* The __has_feature syntax from clang is so misdesigned that we cannot use it
		687	* without risking compile time errors with other compilers. We could
		688	* define our own ecb_clang_has_feature, but I just can't be bothered to work
		689	* around this shit time and again.
620	#elif defined __clang && __has_feature (cxx_atomic)	690	* #elif defined __clang && __has_feature (cxx_atomic)
621	/* see comment below (stdatomic.h) about the C11 memory model. */	691	* // see comment below (stdatomic.h) about the C11 memory model.
622	#define ECB_MEMORY_FENCE __c11_atomic_thread_fence (__ATOMIC_SEQ_CST)	692	* #define ECB_MEMORY_FENCE __c11_atomic_thread_fence (__ATOMIC_SEQ_CST)
		693	* #define ECB_MEMORY_FENCE_ACQUIRE __c11_atomic_thread_fence (__ATOMIC_ACQUIRE)
		694	* #define ECB_MEMORY_FENCE_RELEASE __c11_atomic_thread_fence (__ATOMIC_RELEASE)
		695	*/
		696
623	#elif ECB_GCC_VERSION(4,4) \|\| defined __INTEL_COMPILER \|\| defined __clang__	697	#elif ECB_GCC_VERSION(4,4) \|\| defined __INTEL_COMPILER \|\| defined __clang__
624	#define ECB_MEMORY_FENCE __sync_synchronize ()	698	#define ECB_MEMORY_FENCE __sync_synchronize ()
		699	#elif _MSC_VER >= 1500 /* VC++ 2008 */
		700	/* apparently, microsoft broke all the memory barrier stuff in Visual Studio 2008... */
		701	#pragma intrinsic(_ReadBarrier,_WriteBarrier,_ReadWriteBarrier)
		702	#define ECB_MEMORY_FENCE _ReadWriteBarrier (); MemoryBarrier()
		703	#define ECB_MEMORY_FENCE_ACQUIRE _ReadWriteBarrier (); MemoryBarrier() /* according to msdn, _ReadBarrier is not a load fence */
		704	#define ECB_MEMORY_FENCE_RELEASE _WriteBarrier (); MemoryBarrier()
625	#elif _MSC_VER >= 1400 /* VC++ 2005 */	705	#elif _MSC_VER >= 1400 /* VC++ 2005 */
626	#pragma intrinsic(_ReadBarrier,_WriteBarrier,_ReadWriteBarrier)	706	#pragma intrinsic(_ReadBarrier,_WriteBarrier,_ReadWriteBarrier)
627	#define ECB_MEMORY_FENCE _ReadWriteBarrier ()	707	#define ECB_MEMORY_FENCE _ReadWriteBarrier ()
628	#define ECB_MEMORY_FENCE_ACQUIRE _ReadWriteBarrier () /* according to msdn, _ReadBarrier is not a load fence */	708	#define ECB_MEMORY_FENCE_ACQUIRE _ReadWriteBarrier () /* according to msdn, _ReadBarrier is not a load fence */
629	#define ECB_MEMORY_FENCE_RELEASE _WriteBarrier ()	709	#define ECB_MEMORY_FENCE_RELEASE _WriteBarrier ()
…		…
649	/* any fence other than seq_cst, which isn't very efficient for us. */	729	/* any fence other than seq_cst, which isn't very efficient for us. */
650	/* Why that is, we don't know - either the C11 memory model is quite useless */	730	/* Why that is, we don't know - either the C11 memory model is quite useless */
651	/* for most usages, or gcc and clang have a bug */	731	/* for most usages, or gcc and clang have a bug */
652	/* I currently lean towards the latter, and inefficiently implement */	732	/* I currently lean towards the latter, and inefficiently implement */
653	/* all three of ecb's fences as a seq_cst fence */	733	/* all three of ecb's fences as a seq_cst fence */
		734	/* Update, gcc-4.8 generates mfence for all c++ fences, but nothing */
		735	/* for all __atomic_thread_fence's except seq_cst */
654	#define ECB_MEMORY_FENCE atomic_thread_fence (memory_order_seq_cst)	736	#define ECB_MEMORY_FENCE atomic_thread_fence (memory_order_seq_cst)
655	#endif	737	#endif
656	#endif	738	#endif
657		739
658	#ifndef ECB_MEMORY_FENCE	740	#ifndef ECB_MEMORY_FENCE
…		…
715	#define ecb_is_constant(expr) __builtin_constant_p (expr)	797	#define ecb_is_constant(expr) __builtin_constant_p (expr)
716	#define ecb_expect(expr,value) __builtin_expect ((expr),(value))	798	#define ecb_expect(expr,value) __builtin_expect ((expr),(value))
717	#define ecb_prefetch(addr,rw,locality) __builtin_prefetch (addr, rw, locality)	799	#define ecb_prefetch(addr,rw,locality) __builtin_prefetch (addr, rw, locality)
718	#else	800	#else
719	#define ecb_attribute(attrlist)	801	#define ecb_attribute(attrlist)
		802
		803	/* possible C11 impl for integral types
		804	typedef struct ecb_is_constant_struct ecb_is_constant_struct;
		805	#define ecb_is_constant(expr) _Generic ((1 ? (struct ecb_is_constant_struct )0 : (void )((expr) - (expr)), ecb_is_constant_struct : 0, default: 1)) /
		806
720	#define ecb_is_constant(expr) 0	807	#define ecb_is_constant(expr) 0
721	#define ecb_expect(expr,value) (expr)	808	#define ecb_expect(expr,value) (expr)
722	#define ecb_prefetch(addr,rw,locality)	809	#define ecb_prefetch(addr,rw,locality)
723	#endif	810	#endif
724		811
…		…
727	#define ecb_decltype(x) __decltype(x)	814	#define ecb_decltype(x) __decltype(x)
728	#elif ECB_GCC_VERSION(3,0)	815	#elif ECB_GCC_VERSION(3,0)
729	#define ecb_decltype(x) __typeof(x)	816	#define ecb_decltype(x) __typeof(x)
730	#endif	817	#endif
731		818
		819	#if _MSC_VER >= 1300
		820	#define ecb_deprecated __declspec(deprecated)
		821	#else
		822	#define ecb_deprecated ecb_attribute ((__deprecated__))
		823	#endif
		824
732	#define ecb_noinline ecb_attribute ((__noinline__))	825	#define ecb_noinline ecb_attribute ((__noinline__))
733	#define ecb_unused ecb_attribute ((__unused__))	826	#define ecb_unused ecb_attribute ((__unused__))
734	#define ecb_const ecb_attribute ((__const__))	827	#define ecb_const ecb_attribute ((__const__))
735	#define ecb_pure ecb_attribute ((__pure__))	828	#define ecb_pure ecb_attribute ((__pure__))
736		829
		830	/* http://msdn.microsoft.com/en-us/library/k6ktzx3s.aspx __declspec(noreturn) */
737	#if ECB_C11	831	#if ECB_C11
738	#define ecb_noreturn _Noreturn	832	#define ecb_noreturn _Noreturn
739	#else	833	#else
740	#define ecb_noreturn ecb_attribute ((__noreturn__))	834	#define ecb_noreturn ecb_attribute ((__noreturn__))
741	#endif	835	#endif
…		…
935	ecb_inline void ecb_unreachable (void) ecb_noreturn;	1029	ecb_inline void ecb_unreachable (void) ecb_noreturn;
936	ecb_inline void ecb_unreachable (void) { }	1030	ecb_inline void ecb_unreachable (void) { }
937	#endif	1031	#endif
938		1032
939	/* try to tell the compiler that some condition is definitely true */	1033	/* try to tell the compiler that some condition is definitely true */
940	#define ecb_assume(cond) do { if (!(cond)) ecb_unreachable (); } while (0)	1034	#define ecb_assume(cond) if (!(cond)) ecb_unreachable (); else 0
941		1035
942	ecb_inline unsigned char ecb_byteorder_helper (void) ecb_const;	1036	ecb_inline unsigned char ecb_byteorder_helper (void) ecb_const;
943	ecb_inline unsigned char	1037	ecb_inline unsigned char
944	ecb_byteorder_helper (void)	1038	ecb_byteorder_helper (void)
945	{	1039	{
946	const uint32_t u = 0x11223344;	1040	/* the union code still generates code under pressure in gcc, */
947	return (unsigned char )&u;	1041	/* but less than using pointers, and always seems to */
		1042	/* successfully return a constant. */
		1043	/* the reason why we have this horrible preprocessor mess */
		1044	/* is to avoid it in all cases, at least on common architectures */
		1045	/* or when using a recent enough gcc version (>= 4.6) */
		1046	#if __i386 \|\| __i386__ \|\| _M_X86 \|\| __amd64 \|\| __amd64__ \|\| _M_X64
		1047	return 0x44;
		1048	#elif __BYTE_ORDER__ && __BYTE_ORDER__ == __ORDER_LITTLE_ENDIAN__
		1049	return 0x44;
		1050	#elif __BYTE_ORDER__ && __BYTE_ORDER__ == __ORDER_BIG_ENDIAN__
		1051	return 0x11;
		1052	#else
		1053	union
		1054	{
		1055	uint32_t i;
		1056	uint8_t c;
		1057	} u = { 0x11223344 };
		1058	return u.c;
		1059	#endif
948	}	1060	}
949		1061
950	ecb_inline ecb_bool ecb_big_endian (void) ecb_const;	1062	ecb_inline ecb_bool ecb_big_endian (void) ecb_const;
951	ecb_inline ecb_bool ecb_big_endian (void) { return ecb_byteorder_helper () == 0x11; }	1063	ecb_inline ecb_bool ecb_big_endian (void) { return ecb_byteorder_helper () == 0x11; }
952	ecb_inline ecb_bool ecb_little_endian (void) ecb_const;	1064	ecb_inline ecb_bool ecb_little_endian (void) ecb_const;
…		…
981	{	1093	{
982	return N;	1094	return N;
983	}	1095	}
984	#else	1096	#else
985	#define ecb_array_length(name) (sizeof (name) / sizeof (name [0]))	1097	#define ecb_array_length(name) (sizeof (name) / sizeof (name [0]))
		1098	#endif
		1099
		1100	/*******************************************************************************/
		1101	/* floating point stuff, can be disabled by defining ECB_NO_LIBM */
		1102
		1103	/* basically, everything uses "ieee pure-endian" floating point numbers */
		1104	/* the only noteworthy exception is ancient armle, which uses order 43218765 */
		1105	#if 0 \
		1106	\|\| __i386 \|\| __i386__ \
		1107	\|\| __amd64 \|\| __amd64__ \|\| __x86_64 \|\| __x86_64__ \
		1108	\|\| __powerpc__ \|\| __ppc__ \|\| __powerpc64__ \|\| __ppc64__ \
		1109	\|\| defined __s390__ \|\| defined __s390x__ \
		1110	\|\| defined __mips__ \
		1111	\|\| defined __alpha__ \
		1112	\|\| defined __hppa__ \
		1113	\|\| defined __ia64__ \
		1114	\|\| defined __m68k__ \
		1115	\|\| defined __m88k__ \
		1116	\|\| defined __sh__ \
		1117	\|\| defined _M_IX86 \|\| defined _M_AMD64 \|\| defined _M_IA64 \
		1118	\|\| (defined __arm__ && (defined __ARM_EABI__ \|\| defined __EABI__ \|\| defined __VFP_FP__ \|\| defined _WIN32_WCE \|\| defined __ANDROID__)) \
		1119	\|\| defined __aarch64__
		1120	#define ECB_STDFP 1
		1121	#include <string.h> /* for memcpy */
		1122	#else
		1123	#define ECB_STDFP 0
		1124	#endif
		1125
		1126	#ifndef ECB_NO_LIBM
		1127
		1128	#include <math.h> /* for frexp, ldexp, INFINITY, NAN */
		1129
		1130	/* only the oldest of old doesn't have this one. solaris. */
		1131	#ifdef INFINITY
		1132	#define ECB_INFINITY INFINITY
		1133	#else
		1134	#define ECB_INFINITY HUGE_VAL
		1135	#endif
		1136
		1137	#ifdef NAN
		1138	#define ECB_NAN NAN
		1139	#else
		1140	#define ECB_NAN ECB_INFINITY
		1141	#endif
		1142
		1143	/* converts an ieee half/binary16 to a float */
		1144	ecb_function_ float ecb_binary16_to_float (uint16_t x) ecb_const;
		1145	ecb_function_ float
		1146	ecb_binary16_to_float (uint16_t x)
		1147	{
		1148	int e = (x >> 10) & 0x1f;
		1149	int m = x & 0x3ff;
		1150	float r;
		1151
		1152	if (!e ) r = ldexpf (m , -24);
		1153	else if (e != 31) r = ldexpf (m + 0x400, e - 25);
		1154	else if (m ) r = ECB_NAN;
		1155	else r = ECB_INFINITY;
		1156
		1157	return x & 0x8000 ? -r : r;
		1158	}
		1159
		1160	/* convert a float to ieee single/binary32 */
		1161	ecb_function_ uint32_t ecb_float_to_binary32 (float x) ecb_const;
		1162	ecb_function_ uint32_t
		1163	ecb_float_to_binary32 (float x)
		1164	{
		1165	uint32_t r;
		1166
		1167	#if ECB_STDFP
		1168	memcpy (&r, &x, 4);
		1169	#else
		1170	/* slow emulation, works for anything but -0 */
		1171	uint32_t m;
		1172	int e;
		1173
		1174	if (x == 0e0f ) return 0x00000000U;
		1175	if (x > +3.40282346638528860e+38f) return 0x7f800000U;
		1176	if (x < -3.40282346638528860e+38f) return 0xff800000U;
		1177	if (x != x ) return 0x7fbfffffU;
		1178
		1179	m = frexpf (x, &e) * 0x1000000U;
		1180
		1181	r = m & 0x80000000U;
		1182
		1183	if (r)
		1184	m = -m;
		1185
		1186	if (e <= -126)
		1187	{
		1188	m &= 0xffffffU;
		1189	m >>= (-125 - e);
		1190	e = -126;
		1191	}
		1192
		1193	r \|= (e + 126) << 23;
		1194	r \|= m & 0x7fffffU;
		1195	#endif
		1196
		1197	return r;
		1198	}
		1199
		1200	/* converts an ieee single/binary32 to a float */
		1201	ecb_function_ float ecb_binary32_to_float (uint32_t x) ecb_const;
		1202	ecb_function_ float
		1203	ecb_binary32_to_float (uint32_t x)
		1204	{
		1205	float r;
		1206
		1207	#if ECB_STDFP
		1208	memcpy (&r, &x, 4);
		1209	#else
		1210	/* emulation, only works for normals and subnormals and +0 */
		1211	int neg = x >> 31;
		1212	int e = (x >> 23) & 0xffU;
		1213
		1214	x &= 0x7fffffU;
		1215
		1216	if (e)
		1217	x \|= 0x800000U;
		1218	else
		1219	e = 1;
		1220
		1221	/* we distrust ldexpf a bit and do the 2*-24 scaling by an extra multiply /
		1222	r = ldexpf (x * (0.5f / 0x800000U), e - 126);
		1223
		1224	r = neg ? -r : r;
		1225	#endif
		1226
		1227	return r;
		1228	}
		1229
		1230	/* convert a double to ieee double/binary64 */
		1231	ecb_function_ uint64_t ecb_double_to_binary64 (double x) ecb_const;
		1232	ecb_function_ uint64_t
		1233	ecb_double_to_binary64 (double x)
		1234	{
		1235	uint64_t r;
		1236
		1237	#if ECB_STDFP
		1238	memcpy (&r, &x, 8);
		1239	#else
		1240	/* slow emulation, works for anything but -0 */
		1241	uint64_t m;
		1242	int e;
		1243
		1244	if (x == 0e0 ) return 0x0000000000000000U;
		1245	if (x > +1.79769313486231470e+308) return 0x7ff0000000000000U;
		1246	if (x < -1.79769313486231470e+308) return 0xfff0000000000000U;
		1247	if (x != x ) return 0X7ff7ffffffffffffU;
		1248
		1249	m = frexp (x, &e) * 0x20000000000000U;
		1250
		1251	r = m & 0x8000000000000000;;
		1252
		1253	if (r)
		1254	m = -m;
		1255
		1256	if (e <= -1022)
		1257	{
		1258	m &= 0x1fffffffffffffU;
		1259	m >>= (-1021 - e);
		1260	e = -1022;
		1261	}
		1262
		1263	r \|= ((uint64_t)(e + 1022)) << 52;
		1264	r \|= m & 0xfffffffffffffU;
		1265	#endif
		1266
		1267	return r;
		1268	}
		1269
		1270	/* converts an ieee double/binary64 to a double */
		1271	ecb_function_ double ecb_binary64_to_double (uint64_t x) ecb_const;
		1272	ecb_function_ double
		1273	ecb_binary64_to_double (uint64_t x)
		1274	{
		1275	double r;
		1276
		1277	#if ECB_STDFP
		1278	memcpy (&r, &x, 8);
		1279	#else
		1280	/* emulation, only works for normals and subnormals and +0 */
		1281	int neg = x >> 63;
		1282	int e = (x >> 52) & 0x7ffU;
		1283
		1284	x &= 0xfffffffffffffU;
		1285
		1286	if (e)
		1287	x \|= 0x10000000000000U;
		1288	else
		1289	e = 1;
		1290
		1291	/* we distrust ldexp a bit and do the 2*-53 scaling by an extra multiply /
		1292	r = ldexp (x * (0.5 / 0x10000000000000U), e - 1022);
		1293
		1294	r = neg ? -r : r;
		1295	#endif
		1296
		1297	return r;
		1298	}
		1299
986	#endif	1300	#endif
987		1301
988	#endif	1302	#endif
989		1303
990	/* ECB.H END */	1304	/* ECB.H END */
…		…
1884	ev_syserr ("(libev) error creating signal/async pipe");	2198	ev_syserr ("(libev) error creating signal/async pipe");
1885		2199
1886	fd_intern (fds [0]);	2200	fd_intern (fds [0]);
1887	}	2201	}
1888		2202
1889	fd_intern (fds [1]);
1890
1891	evpipe [0] = fds [0];	2203	evpipe [0] = fds [0];
1892		2204
1893	if (evpipe [1] < 0)	2205	if (evpipe [1] < 0)
1894	evpipe [1] = fds [1]; /* first call, set write fd */	2206	evpipe [1] = fds [1]; /* first call, set write fd */
1895	else	2207	else
…		…
1900	/* so must not be executed on windows */	2212	/* so must not be executed on windows */
1901		2213
1902	dup2 (fds [1], evpipe [1]);	2214	dup2 (fds [1], evpipe [1]);
1903	close (fds [1]);	2215	close (fds [1]);
1904	}	2216	}
		2217
		2218	fd_intern (evpipe [1]);
1905		2219
1906	ev_io_set (&pipe_w, evpipe [0] < 0 ? evpipe [1] : evpipe [0], EV_READ);	2220	ev_io_set (&pipe_w, evpipe [0] < 0 ? evpipe [1] : evpipe [0], EV_READ);
1907	ev_io_start (EV_A_ &pipe_w);	2221	ev_io_start (EV_A_ &pipe_w);
1908	ev_unref (EV_A); /* watcher should not keep loop alive */	2222	ev_unref (EV_A); /* watcher should not keep loop alive */
1909	}	2223	}
…		…
2028		2342
2029	void	2343	void
2030	ev_feed_signal (int signum) EV_THROW	2344	ev_feed_signal (int signum) EV_THROW
2031	{	2345	{
2032	#if EV_MULTIPLICITY	2346	#if EV_MULTIPLICITY
		2347	EV_P;
		2348	ECB_MEMORY_FENCE_ACQUIRE;
2033	EV_P = signals [signum - 1].loop;	2349	EV_A = signals [signum - 1].loop;
2034		2350
2035	if (!EV_A)	2351	if (!EV_A)
2036	return;	2352	return;
2037	#endif	2353	#endif
2038		2354
…		…
2291	{	2607	{
2292	return userdata;	2608	return userdata;
2293	}	2609	}
2294		2610
2295	void	2611	void
2296	ev_set_invoke_pending_cb (EV_P_ void (*invoke_pending_cb)(EV_P)) EV_THROW	2612	ev_set_invoke_pending_cb (EV_P_ ev_loop_callback invoke_pending_cb) EV_THROW
2297	{	2613	{
2298	invoke_cb = invoke_pending_cb;	2614	invoke_cb = invoke_pending_cb;
2299	}	2615	}
2300		2616
2301	void	2617	void
2302	ev_set_loop_release_cb (EV_P_ void (release)(EV_P) EV_THROW, void (acquire)(EV_P) EV_THROW) EV_THROW	2618	ev_set_loop_release_cb (EV_P_ ev_loop_callback_nothrow release, ev_loop_callback_nothrow acquire) EV_THROW
2303	{	2619	{
2304	release_cb = release;	2620	release_cb = release;
2305	acquire_cb = acquire;	2621	acquire_cb = acquire;
2306	}	2622	}
2307	#endif	2623	#endif
…		…
3526	#if EV_MULTIPLICITY	3842	#if EV_MULTIPLICITY
3527	assert (("libev: a signal must not be attached to two different loops",	3843	assert (("libev: a signal must not be attached to two different loops",
3528	!signals [w->signum - 1].loop \|\| signals [w->signum - 1].loop == loop));	3844	!signals [w->signum - 1].loop \|\| signals [w->signum - 1].loop == loop));
3529		3845
3530	signals [w->signum - 1].loop = EV_A;	3846	signals [w->signum - 1].loop = EV_A;
		3847	ECB_MEMORY_FENCE_RELEASE;
3531	#endif	3848	#endif
3532		3849
3533	EV_FREQUENT_CHECK;	3850	EV_FREQUENT_CHECK;
3534		3851
3535	#if EV_USE_SIGNALFD	3852	#if EV_USE_SIGNALFD
…		…
3690	# define EV_INOTIFY_BUFSIZE (sizeof (struct inotify_event) * 2 + NAME_MAX)	4007	# define EV_INOTIFY_BUFSIZE (sizeof (struct inotify_event) * 2 + NAME_MAX)
3691		4008
3692	static void noinline	4009	static void noinline
3693	infy_add (EV_P_ ev_stat *w)	4010	infy_add (EV_P_ ev_stat *w)
3694	{	4011	{
3695	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);	4012	w->wd = inotify_add_watch (fs_fd, w->path,
		4013	IN_ATTRIB \| IN_DELETE_SELF \| IN_MOVE_SELF \| IN_MODIFY
		4014	\| IN_CREATE \| IN_DELETE \| IN_MOVED_FROM \| IN_MOVED_TO
		4015	\| IN_DONT_FOLLOW \| IN_MASK_ADD);
3696		4016
3697	if (w->wd >= 0)	4017	if (w->wd >= 0)
3698	{	4018	{
3699	struct statfs sfs;	4019	struct statfs sfs;
3700		4020
…		…
3704		4024
3705	if (!fs_2625)	4025	if (!fs_2625)
3706	w->timer.repeat = w->interval ? w->interval : DEF_STAT_INTERVAL;	4026	w->timer.repeat = w->interval ? w->interval : DEF_STAT_INTERVAL;
3707	else if (!statfs (w->path, &sfs)	4027	else if (!statfs (w->path, &sfs)
3708	&& (sfs.f_type == 0x1373 /* devfs */	4028	&& (sfs.f_type == 0x1373 /* devfs */
		4029	\|\| sfs.f_type == 0x4006 /* fat */
		4030	\|\| sfs.f_type == 0x4d44 /* msdos */
3709	\|\| sfs.f_type == 0xEF53 /* ext2/3 */	4031	\|\| sfs.f_type == 0xEF53 /* ext2/3 */
		4032	\|\| sfs.f_type == 0x72b6 /* jffs2 */
		4033	\|\| sfs.f_type == 0x858458f6 /* ramfs */
		4034	\|\| sfs.f_type == 0x5346544e /* ntfs */
3710	\|\| sfs.f_type == 0x3153464a /* jfs */	4035	\|\| sfs.f_type == 0x3153464a /* jfs */
		4036	\|\| sfs.f_type == 0x9123683e /* btrfs */
3711	\|\| sfs.f_type == 0x52654973 /* reiser3 */	4037	\|\| sfs.f_type == 0x52654973 /* reiser3 */
3712	\|\| sfs.f_type == 0x01021994 /* tempfs */	4038	\|\| sfs.f_type == 0x01021994 /* tmpfs */
3713	\|\| sfs.f_type == 0x58465342 /* xfs */))	4039	\|\| sfs.f_type == 0x58465342 /* xfs */))
3714	w->timer.repeat = 0.; /* filesystem is local, kernel new enough */	4040	w->timer.repeat = 0.; /* filesystem is local, kernel new enough */
3715	else	4041	else
3716	w->timer.repeat = w->interval ? w->interval : NFS_STAT_INTERVAL; /* remote, use reduced frequency */	4042	w->timer.repeat = w->interval ? w->interval : NFS_STAT_INTERVAL; /* remote, use reduced frequency */
3717	}	4043	}

Diff Legend

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

Comparing libev/ev.c (file contents): Revision 1.448 by root, Tue Jul 24 16:28:08 2012 UTC vs. Revision 1.470 by root, Sun Sep 7 13:44:21 2014 UTC

Diff Legend

Comparing libev/ev.c (file contents):
Revision 1.448 by root, Tue Jul 24 16:28:08 2012 UTC vs.
Revision 1.470 by root, Sun Sep 7 13:44:21 2014 UTC