ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev.c
(Generate patch)

Comparing libev/ev.c (file contents):
Revision 1.381 by root, Mon Jun 27 21:29:35 2011 UTC vs.
Revision 1.410 by root, Sat Feb 4 17:57:55 2012 UTC

… …
183# include EV_H 183# include EV_H
184#else 184#else
185# include "ev.h" 185# include "ev.h"
186#endif 186#endif
187 187
188EV_CPP(extern "C" {) 188#if EV_NO_THREADS
189# undef EV_NO_SMP
190# define EV_NO_SMP 1
191# undef ECB_NO_THREADS
192# define ECB_NO_THREADS 1
193#endif
194#if EV_NO_SMP
195# undef EV_NO_SMP
196# define ECB_NO_SMP 1
197#endif
189 198
190#ifndef _WIN32 199#ifndef _WIN32
191# include <sys/time.h> 200# include <sys/time.h>
192# include <sys/wait.h> 201# include <sys/wait.h>
193# include <unistd.h> 202# include <unistd.h>
… …
464#define MAX_BLOCKTIME 59.743 /* never wait longer than this time (to detect time jumps) */ 473#define MAX_BLOCKTIME 59.743 /* never wait longer than this time (to detect time jumps) */
465 474
466#define EV_TV_SET(tv,t) do { tv.tv_sec = (long)t; tv.tv_usec = (long)((t - tv.tv_sec) * 1e6); } while (0) 475#define EV_TV_SET(tv,t) do { tv.tv_sec = (long)t; tv.tv_usec = (long)((t - tv.tv_sec) * 1e6); } while (0)
467#define EV_TS_SET(ts,t) do { ts.tv_sec = (long)t; ts.tv_nsec = (long)((t - ts.tv_sec) * 1e9); } while (0) 476#define EV_TS_SET(ts,t) do { ts.tv_sec = (long)t; ts.tv_nsec = (long)((t - ts.tv_sec) * 1e9); } while (0)
468 477
469/* the following are taken from libecb */ 478/* the following is ecb.h embedded into libev - use update_ev_c to update from an external copy */
470/* ecb.h start */ 479/* ECB.H BEGIN */
480/*
481 * libecb - http://software.schmorp.de/pkg/libecb
482 *
483 * Copyright (©) 2009-2012 Marc Alexander Lehmann <libecb@schmorp.de>
484 * Copyright (©) 2011 Emanuele Giaquinta
485 * All rights reserved.
486 *
487 * Redistribution and use in source and binary forms, with or without modifica-
488 * tion, are permitted provided that the following conditions are met:
489 *
490 * 1. Redistributions of source code must retain the above copyright notice,
491 * this list of conditions and the following disclaimer.
492 *
493 * 2. Redistributions in binary form must reproduce the above copyright
494 * notice, this list of conditions and the following disclaimer in the
495 * documentation and/or other materials provided with the distribution.
496 *
497 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
498 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-
499 * CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
500 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPE-
501 * CIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
502 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
503 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
504 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-
505 * ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
506 * OF THE POSSIBILITY OF SUCH DAMAGE.
507 */
508
509#ifndef ECB_H
510#define ECB_H
511
512#ifdef _WIN32
513 typedef signed char int8_t;
514 typedef unsigned char uint8_t;
515 typedef signed short int16_t;
516 typedef unsigned short uint16_t;
517 typedef signed int int32_t;
518 typedef unsigned int uint32_t;
519 #if __GNUC__
520 typedef signed long long int64_t;
521 typedef unsigned long long uint64_t;
522 #else /* _MSC_VER || __BORLANDC__ */
523 typedef signed __int64 int64_t;
524 typedef unsigned __int64 uint64_t;
525 #endif
526#else
527 #include <inttypes.h>
528#endif
471 529
472/* many compilers define _GNUC_ to some versions but then only implement 530/* many compilers define _GNUC_ to some versions but then only implement
473 * what their idiot authors think are the "more important" extensions, 531 * what their idiot authors think are the "more important" extensions,
474 * causing enourmous grief in return for some better fake benchmark numbers. 532 * causing enormous grief in return for some better fake benchmark numbers.
475 * or so. 533 * or so.
476 * we try to detect these and simply assume they are not gcc - if they have 534 * we try to detect these and simply assume they are not gcc - if they have
477 * an issue with that they should have done it right in the first place. 535 * an issue with that they should have done it right in the first place.
478 */ 536 */
479#ifndef ECB_GCC_VERSION 537#ifndef ECB_GCC_VERSION
… …
482 #else 540 #else
483 #define ECB_GCC_VERSION(major,minor) (__GNUC__ > (major) || (__GNUC__ == (major) && __GNUC_MINOR__ >= (minor))) 541 #define ECB_GCC_VERSION(major,minor) (__GNUC__ > (major) || (__GNUC__ == (major) && __GNUC_MINOR__ >= (minor)))
484 #endif 542 #endif
485#endif 543#endif
486 544
545/*****************************************************************************/
546
547/* ECB_NO_THREADS - ecb is not used by multiple threads, ever */
548/* ECB_NO_SMP - ecb might be used in multiple threads, but only on a single cpu */
549
550#if ECB_NO_THREADS
551# define ECB_NO_SMP 1
552#endif
553
554#if ECB_NO_THREADS || ECB_NO_SMP
555 #define ECB_MEMORY_FENCE do { } while (0)
556#endif
557
558#ifndef ECB_MEMORY_FENCE
559 #if ECB_GCC_VERSION(2,5) || defined(__INTEL_COMPILER) || (__llvm__ && __GNUC__) || __SUNPRO_C >= 0x5110 || __SUNPRO_CC >= 0x5110
560 #if __i386 || __i386__
561 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("lock; orb $0, -1(%%esp)" : : : "memory")
562 #define ECB_MEMORY_FENCE_ACQUIRE ECB_MEMORY_FENCE /* non-lock xchg might be enough */
563 #define ECB_MEMORY_FENCE_RELEASE do { } while (0) /* unlikely to change in future cpus */
564 #elif __amd64 || __amd64__ || __x86_64 || __x86_64__
565 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("mfence" : : : "memory")
566 #define ECB_MEMORY_FENCE_ACQUIRE __asm__ __volatile__ ("lfence" : : : "memory")
567 #define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("sfence") /* play safe - not needed in any current cpu */
568 #elif __powerpc__ || __ppc__ || __powerpc64__ || __ppc64__
569 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("sync" : : : "memory")
570 #elif defined(__ARM_ARCH_6__ ) || defined(__ARM_ARCH_6J__ ) \
571 || defined(__ARM_ARCH_6K__) || defined(__ARM_ARCH_6ZK__)
572 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("mcr p15,0,%0,c7,c10,5" : : "r" (0) : "memory")
573 #elif defined(__ARM_ARCH_7__ ) || defined(__ARM_ARCH_7A__ ) \
574 || defined(__ARM_ARCH_7M__) || defined(__ARM_ARCH_7R__ )
575 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("dmb" : : : "memory")
576 #elif __sparc || __sparc__
577 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("membar #LoadStore | #LoadLoad | #StoreStore | #StoreLoad | " : : : "memory")
578 #define ECB_MEMORY_FENCE_ACQUIRE __asm__ __volatile__ ("membar #LoadStore | #LoadLoad" : : : "memory")
579 #define ECB_MEMORY_FENCE_RELEASE __asm__ __volatile__ ("membar #LoadStore | #StoreStore")
580 #elif defined(__s390__) || defined(__s390x__)
581 #define ECB_MEMORY_FENCE __asm__ __volatile__ ("bcr 15,0" : : : "memory")
582 #endif
583 #endif
584#endif
585
586#ifndef ECB_MEMORY_FENCE
587 #if ECB_GCC_VERSION(4,4) || defined(__INTEL_COMPILER) || defined(__clang__)
588 #define ECB_MEMORY_FENCE __sync_synchronize ()
589 /*#define ECB_MEMORY_FENCE_ACQUIRE ({ char dummy = 0; __sync_lock_test_and_set (&dummy, 1); }) */
590 /*#define ECB_MEMORY_FENCE_RELEASE ({ char dummy = 1; __sync_lock_release (&dummy ); }) */
591 #elif _MSC_VER >= 1400 /* VC++ 2005 */
592 #pragma intrinsic(_ReadBarrier,_WriteBarrier,_ReadWriteBarrier)
593 #define ECB_MEMORY_FENCE _ReadWriteBarrier ()
594 #define ECB_MEMORY_FENCE_ACQUIRE _ReadWriteBarrier () /* according to msdn, _ReadBarrier is not a load fence */
595 #define ECB_MEMORY_FENCE_RELEASE _WriteBarrier ()
596 #elif defined(_WIN32)
597 #include <WinNT.h>
598 #define ECB_MEMORY_FENCE MemoryBarrier () /* actually just xchg on x86... scary */
599 #elif __SUNPRO_C >= 0x5110 || __SUNPRO_CC >= 0x5110
600 #include <mbarrier.h>
601 #define ECB_MEMORY_FENCE __machine_rw_barrier ()
602 #define ECB_MEMORY_FENCE_ACQUIRE __machine_r_barrier ()
603 #define ECB_MEMORY_FENCE_RELEASE __machine_w_barrier ()
604 #endif
605#endif
606
607#ifndef ECB_MEMORY_FENCE
608 #if !ECB_AVOID_PTHREADS
609 /*
610 * if you get undefined symbol references to pthread_mutex_lock,
611 * or failure to find pthread.h, then you should implement
612 * the ECB_MEMORY_FENCE operations for your cpu/compiler
613 * OR provide pthread.h and link against the posix thread library
614 * of your system.
615 */
616 #include <pthread.h>
617 #define ECB_NEEDS_PTHREADS 1
618 #define ECB_MEMORY_FENCE_NEEDS_PTHREADS 1
619
620 static pthread_mutex_t ecb_mf_lock = PTHREAD_MUTEX_INITIALIZER;
621 #define ECB_MEMORY_FENCE do { pthread_mutex_lock (&ecb_mf_lock); pthread_mutex_unlock (&ecb_mf_lock); } while (0)
622 #endif
623#endif
624
625#if !defined(ECB_MEMORY_FENCE_ACQUIRE) && defined(ECB_MEMORY_FENCE)
626 #define ECB_MEMORY_FENCE_ACQUIRE ECB_MEMORY_FENCE
627#endif
628
629#if !defined(ECB_MEMORY_FENCE_RELEASE) && defined(ECB_MEMORY_FENCE)
630 #define ECB_MEMORY_FENCE_RELEASE ECB_MEMORY_FENCE
631#endif
632
633/*****************************************************************************/
634
635#define ECB_C99 (__STDC_VERSION__ >= 199901L)
636
487#if __cplusplus 637#if __cplusplus
488 #define ecb_inline static inline 638 #define ecb_inline static inline
489#elif ECB_GCC_VERSION(2,5) 639#elif ECB_GCC_VERSION(2,5)
490 #define ecb_inline static __inline__ 640 #define ecb_inline static __inline__
491#elif ECB_C99 641#elif ECB_C99
492 #define ecb_inline static inline 642 #define ecb_inline static inline
493#else 643#else
494 #define ecb_inline static 644 #define ecb_inline static
495#endif 645#endif
646
647#if ECB_GCC_VERSION(3,3)
648 #define ecb_restrict __restrict__
649#elif ECB_C99
650 #define ecb_restrict restrict
651#else
652 #define ecb_restrict
653#endif
654
655typedef int ecb_bool;
656
657#define ECB_CONCAT_(a, b) a ## b
658#define ECB_CONCAT(a, b) ECB_CONCAT_(a, b)
659#define ECB_STRINGIFY_(a) # a
660#define ECB_STRINGIFY(a) ECB_STRINGIFY_(a)
661
662#define ecb_function_ ecb_inline
496 663
497#if ECB_GCC_VERSION(3,1) 664#if ECB_GCC_VERSION(3,1)
498 #define ecb_attribute(attrlist) __attribute__(attrlist) 665 #define ecb_attribute(attrlist) __attribute__(attrlist)
499 #define ecb_is_constant(expr) __builtin_constant_p (expr) 666 #define ecb_is_constant(expr) __builtin_constant_p (expr)
500 #define ecb_expect(expr,value) __builtin_expect ((expr),(value)) 667 #define ecb_expect(expr,value) __builtin_expect ((expr),(value))
… …
504 #define ecb_is_constant(expr) 0 671 #define ecb_is_constant(expr) 0
505 #define ecb_expect(expr,value) (expr) 672 #define ecb_expect(expr,value) (expr)
506 #define ecb_prefetch(addr,rw,locality) 673 #define ecb_prefetch(addr,rw,locality)
507#endif 674#endif
508 675
676/* no emulation for ecb_decltype */
677#if ECB_GCC_VERSION(4,5)
678 #define ecb_decltype(x) __decltype(x)
679#elif ECB_GCC_VERSION(3,0)
680 #define ecb_decltype(x) __typeof(x)
681#endif
682
509#define ecb_noinline ecb_attribute ((__noinline__)) 683#define ecb_noinline ecb_attribute ((__noinline__))
510#define ecb_noreturn ecb_attribute ((__noreturn__)) 684#define ecb_noreturn ecb_attribute ((__noreturn__))
511#define ecb_unused ecb_attribute ((__unused__)) 685#define ecb_unused ecb_attribute ((__unused__))
512#define ecb_const ecb_attribute ((__const__)) 686#define ecb_const ecb_attribute ((__const__))
513#define ecb_pure ecb_attribute ((__pure__)) 687#define ecb_pure ecb_attribute ((__pure__))
… …
525/* put around conditional expressions if you are very sure that the */ 699/* put around conditional expressions if you are very sure that the */
526/* expression is mostly true or mostly false. note that these return */ 700/* expression is mostly true or mostly false. note that these return */
527/* booleans, not the expression. */ 701/* booleans, not the expression. */
528#define ecb_expect_false(expr) ecb_expect (!!(expr), 0) 702#define ecb_expect_false(expr) ecb_expect (!!(expr), 0)
529#define ecb_expect_true(expr) ecb_expect (!!(expr), 1) 703#define ecb_expect_true(expr) ecb_expect (!!(expr), 1)
530/* ecb.h end */ 704/* for compatibility to the rest of the world */
705#define ecb_likely(expr) ecb_expect_true (expr)
706#define ecb_unlikely(expr) ecb_expect_false (expr)
707
708/* count trailing zero bits and count # of one bits */
709#if ECB_GCC_VERSION(3,4)
710 /* we assume int == 32 bit, long == 32 or 64 bit and long long == 64 bit */
711 #define ecb_ld32(x) (__builtin_clz (x) ^ 31)
712 #define ecb_ld64(x) (__builtin_clzll (x) ^ 63)
713 #define ecb_ctz32(x) __builtin_ctz (x)
714 #define ecb_ctz64(x) __builtin_ctzll (x)
715 #define ecb_popcount32(x) __builtin_popcount (x)
716 /* no popcountll */
717#else
718 ecb_function_ int ecb_ctz32 (uint32_t x) ecb_const;
719 ecb_function_ int
720 ecb_ctz32 (uint32_t x)
721 {
722 int r = 0;
723
724 x &= ~x + 1; /* this isolates the lowest bit */
725
726#if ECB_branchless_on_i386
727 r += !!(x & 0xaaaaaaaa) << 0;
728 r += !!(x & 0xcccccccc) << 1;
729 r += !!(x & 0xf0f0f0f0) << 2;
730 r += !!(x & 0xff00ff00) << 3;
731 r += !!(x & 0xffff0000) << 4;
732#else
733 if (x & 0xaaaaaaaa) r += 1;
734 if (x & 0xcccccccc) r += 2;
735 if (x & 0xf0f0f0f0) r += 4;
736 if (x & 0xff00ff00) r += 8;
737 if (x & 0xffff0000) r += 16;
738#endif
739
740 return r;
741 }
742
743 ecb_function_ int ecb_ctz64 (uint64_t x) ecb_const;
744 ecb_function_ int
745 ecb_ctz64 (uint64_t x)
746 {
747 int shift = x & 0xffffffffU ? 0 : 32;
748 return ecb_ctz32 (x >> shift) + shift;
749 }
750
751 ecb_function_ int ecb_popcount32 (uint32_t x) ecb_const;
752 ecb_function_ int
753 ecb_popcount32 (uint32_t x)
754 {
755 x -= (x >> 1) & 0x55555555;
756 x = ((x >> 2) & 0x33333333) + (x & 0x33333333);
757 x = ((x >> 4) + x) & 0x0f0f0f0f;
758 x *= 0x01010101;
759
760 return x >> 24;
761 }
762
763 ecb_function_ int ecb_ld32 (uint32_t x) ecb_const;
764 ecb_function_ int ecb_ld32 (uint32_t x)
765 {
766 int r = 0;
767
768 if (x >> 16) { x >>= 16; r += 16; }
769 if (x >> 8) { x >>= 8; r += 8; }
770 if (x >> 4) { x >>= 4; r += 4; }
771 if (x >> 2) { x >>= 2; r += 2; }
772 if (x >> 1) { r += 1; }
773
774 return r;
775 }
776
777 ecb_function_ int ecb_ld64 (uint64_t x) ecb_const;
778 ecb_function_ int ecb_ld64 (uint64_t x)
779 {
780 int r = 0;
781
782 if (x >> 32) { x >>= 32; r += 32; }
783
784 return r + ecb_ld32 (x);
785 }
786#endif
787
788ecb_function_ uint8_t ecb_bitrev8 (uint8_t x) ecb_const;
789ecb_function_ uint8_t ecb_bitrev8 (uint8_t x)
790{
791 return ( (x * 0x0802U & 0x22110U)
792 | (x * 0x8020U & 0x88440U)) * 0x10101U >> 16;
793}
794
795ecb_function_ uint16_t ecb_bitrev16 (uint16_t x) ecb_const;
796ecb_function_ uint16_t ecb_bitrev16 (uint16_t x)
797{
798 x = ((x >> 1) & 0x5555) | ((x & 0x5555) << 1);
799 x = ((x >> 2) & 0x3333) | ((x & 0x3333) << 2);
800 x = ((x >> 4) & 0x0f0f) | ((x & 0x0f0f) << 4);
801 x = ( x >> 8 ) | ( x << 8);
802
803 return x;
804}
805
806ecb_function_ uint32_t ecb_bitrev32 (uint32_t x) ecb_const;
807ecb_function_ uint32_t ecb_bitrev32 (uint32_t x)
808{
809 x = ((x >> 1) & 0x55555555) | ((x & 0x55555555) << 1);
810 x = ((x >> 2) & 0x33333333) | ((x & 0x33333333) << 2);
811 x = ((x >> 4) & 0x0f0f0f0f) | ((x & 0x0f0f0f0f) << 4);
812 x = ((x >> 8) & 0x00ff00ff) | ((x & 0x00ff00ff) << 8);
813 x = ( x >> 16 ) | ( x << 16);
814
815 return x;
816}
817
818/* popcount64 is only available on 64 bit cpus as gcc builtin */
819/* so for this version we are lazy */
820ecb_function_ int ecb_popcount64 (uint64_t x) ecb_const;
821ecb_function_ int
822ecb_popcount64 (uint64_t x)
823{
824 return ecb_popcount32 (x) + ecb_popcount32 (x >> 32);
825}
826
827ecb_inline uint8_t ecb_rotl8 (uint8_t x, unsigned int count) ecb_const;
828ecb_inline uint8_t ecb_rotr8 (uint8_t x, unsigned int count) ecb_const;
829ecb_inline uint16_t ecb_rotl16 (uint16_t x, unsigned int count) ecb_const;
830ecb_inline uint16_t ecb_rotr16 (uint16_t x, unsigned int count) ecb_const;
831ecb_inline uint32_t ecb_rotl32 (uint32_t x, unsigned int count) ecb_const;
832ecb_inline uint32_t ecb_rotr32 (uint32_t x, unsigned int count) ecb_const;
833ecb_inline uint64_t ecb_rotl64 (uint64_t x, unsigned int count) ecb_const;
834ecb_inline uint64_t ecb_rotr64 (uint64_t x, unsigned int count) ecb_const;
835
836ecb_inline uint8_t ecb_rotl8 (uint8_t x, unsigned int count) { return (x >> ( 8 - count)) | (x << count); }
837ecb_inline uint8_t ecb_rotr8 (uint8_t x, unsigned int count) { return (x << ( 8 - count)) | (x >> count); }
838ecb_inline uint16_t ecb_rotl16 (uint16_t x, unsigned int count) { return (x >> (16 - count)) | (x << count); }
839ecb_inline uint16_t ecb_rotr16 (uint16_t x, unsigned int count) { return (x << (16 - count)) | (x >> count); }
840ecb_inline uint32_t ecb_rotl32 (uint32_t x, unsigned int count) { return (x >> (32 - count)) | (x << count); }
841ecb_inline uint32_t ecb_rotr32 (uint32_t x, unsigned int count) { return (x << (32 - count)) | (x >> count); }
842ecb_inline uint64_t ecb_rotl64 (uint64_t x, unsigned int count) { return (x >> (64 - count)) | (x << count); }
843ecb_inline uint64_t ecb_rotr64 (uint64_t x, unsigned int count) { return (x << (64 - count)) | (x >> count); }
844
845#if ECB_GCC_VERSION(4,3)
846 #define ecb_bswap16(x) (__builtin_bswap32 (x) >> 16)
847 #define ecb_bswap32(x) __builtin_bswap32 (x)
848 #define ecb_bswap64(x) __builtin_bswap64 (x)
849#else
850 ecb_function_ uint16_t ecb_bswap16 (uint16_t x) ecb_const;
851 ecb_function_ uint16_t
852 ecb_bswap16 (uint16_t x)
853 {
854 return ecb_rotl16 (x, 8);
855 }
856
857 ecb_function_ uint32_t ecb_bswap32 (uint32_t x) ecb_const;
858 ecb_function_ uint32_t
859 ecb_bswap32 (uint32_t x)
860 {
861 return (((uint32_t)ecb_bswap16 (x)) << 16) | ecb_bswap16 (x >> 16);
862 }
863
864 ecb_function_ uint64_t ecb_bswap64 (uint64_t x) ecb_const;
865 ecb_function_ uint64_t
866 ecb_bswap64 (uint64_t x)
867 {
868 return (((uint64_t)ecb_bswap32 (x)) << 32) | ecb_bswap32 (x >> 32);
869 }
870#endif
871
872#if ECB_GCC_VERSION(4,5)
873 #define ecb_unreachable() __builtin_unreachable ()
874#else
875 /* this seems to work fine, but gcc always emits a warning for it :/ */
876 ecb_inline void ecb_unreachable (void) ecb_noreturn;
877 ecb_inline void ecb_unreachable (void) { }
878#endif
879
880/* try to tell the compiler that some condition is definitely true */
881#define ecb_assume(cond) do { if (!(cond)) ecb_unreachable (); } while (0)
882
883ecb_inline unsigned char ecb_byteorder_helper (void) ecb_const;
884ecb_inline unsigned char
885ecb_byteorder_helper (void)
886{
887 const uint32_t u = 0x11223344;
888 return *(unsigned char *)&u;
889}
890
891ecb_inline ecb_bool ecb_big_endian (void) ecb_const;
892ecb_inline ecb_bool ecb_big_endian (void) { return ecb_byteorder_helper () == 0x11; }
893ecb_inline ecb_bool ecb_little_endian (void) ecb_const;
894ecb_inline ecb_bool ecb_little_endian (void) { return ecb_byteorder_helper () == 0x44; }
895
896#if ECB_GCC_VERSION(3,0) || ECB_C99
897 #define ecb_mod(m,n) ((m) % (n) + ((m) % (n) < 0 ? (n) : 0))
898#else
899 #define ecb_mod(m,n) ((m) < 0 ? ((n) - 1 - ((-1 - (m)) % (n))) : ((m) % (n)))
900#endif
901
902#if __cplusplus
903 template<typename T>
904 static inline T ecb_div_rd (T val, T div)
905 {
906 return val < 0 ? - ((-val + div - 1) / div) : (val ) / div;
907 }
908 template<typename T>
909 static inline T ecb_div_ru (T val, T div)
910 {
911 return val < 0 ? - ((-val ) / div) : (val + div - 1) / div;
912 }
913#else
914 #define ecb_div_rd(val,div) ((val) < 0 ? - ((-(val) + (div) - 1) / (div)) : ((val) ) / (div))
915 #define ecb_div_ru(val,div) ((val) < 0 ? - ((-(val) ) / (div)) : ((val) + (div) - 1) / (div))
916#endif
917
918#if ecb_cplusplus_does_not_suck
919 /* does not work for local types (http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2008/n2657.htm) */
920 template<typename T, int N>
921 static inline int ecb_array_length (const T (&arr)[N])
922 {
923 return N;
924 }
925#else
926 #define ecb_array_length(name) (sizeof (name) / sizeof (name [0]))
927#endif
928
929#endif
930
931/* ECB.H END */
932
933#if ECB_MEMORY_FENCE_NEEDS_PTHREADS
934/* if your architecture doesn't need memory fences, e.g. because it is
935 * single-cpu/core, or if you use libev in a project that doesn't use libev
936 * from multiple threads, then you can define ECB_AVOID_PTHREADS when compiling
937 * libev, in which cases the memory fences become nops.
938 * alternatively, you can remove this #error and link against libpthread,
939 * which will then provide the memory fences.
940 */
941# error "memory fences not defined for your architecture, please report"
942#endif
943
944#ifndef ECB_MEMORY_FENCE
945# define ECB_MEMORY_FENCE do { } while (0)
946# define ECB_MEMORY_FENCE_ACQUIRE ECB_MEMORY_FENCE
947# define ECB_MEMORY_FENCE_RELEASE ECB_MEMORY_FENCE
948#endif
531 949
532#define expect_false(cond) ecb_expect_false (cond) 950#define expect_false(cond) ecb_expect_false (cond)
533#define expect_true(cond) ecb_expect_true (cond) 951#define expect_true(cond) ecb_expect_true (cond)
534#define noinline ecb_noinline 952#define noinline ecb_noinline
535 953
… …
831 #undef VAR 1249 #undef VAR
832 }; 1250 };
833 #include "ev_wrap.h" 1251 #include "ev_wrap.h"
834 1252
835 static struct ev_loop default_loop_struct; 1253 static struct ev_loop default_loop_struct;
836 struct ev_loop *ev_default_loop_ptr; 1254 EV_API_DECL struct ev_loop *ev_default_loop_ptr = 0; /* needs to be initialised to make it a definition despite extern */
837 1255
838#else 1256#else
839 1257
840 ev_tstamp ev_rt_now; 1258 EV_API_DECL ev_tstamp ev_rt_now = 0; /* needs to be initialised to make it a definition despite extern */
841 #define VAR(name,decl) static decl; 1259 #define VAR(name,decl) static decl;
842 #include "ev_vars.h" 1260 #include "ev_vars.h"
843 #undef VAR 1261 #undef VAR
844 1262
845 static int ev_default_loop_ptr; 1263 static int ev_default_loop_ptr;
… …
939 1357
940 do 1358 do
941 ncur <<= 1; 1359 ncur <<= 1;
942 while (cnt > ncur); 1360 while (cnt > ncur);
943 1361
944 /* if size is large, round to MALLOC_ROUND - 4 * longs to accomodate malloc overhead */ 1362 /* if size is large, round to MALLOC_ROUND - 4 * longs to accommodate malloc overhead */
945 if (elem * ncur > MALLOC_ROUND - sizeof (void *) * 4) 1363 if (elem * ncur > MALLOC_ROUND - sizeof (void *) * 4)
946 { 1364 {
947 ncur *= elem; 1365 ncur *= elem;
948 ncur = (ncur + elem + (MALLOC_ROUND - 1) + sizeof (void *) * 4) & ~(MALLOC_ROUND - 1); 1366 ncur = (ncur + elem + (MALLOC_ROUND - 1) + sizeof (void *) * 4) & ~(MALLOC_ROUND - 1);
949 ncur = ncur - sizeof (void *) * 4; 1367 ncur = ncur - sizeof (void *) * 4;
… …
964 memset ((void *)(base), 0, sizeof (*(base)) * (count)) 1382 memset ((void *)(base), 0, sizeof (*(base)) * (count))
965 1383
966#define array_needsize(type,base,cur,cnt,init) \ 1384#define array_needsize(type,base,cur,cnt,init) \
967 if (expect_false ((cnt) > (cur))) \ 1385 if (expect_false ((cnt) > (cur))) \
968 { \ 1386 { \
969 int ocur_ = (cur); \ 1387 int ecb_unused ocur_ = (cur); \
970 (base) = (type *)array_realloc \ 1388 (base) = (type *)array_realloc \
971 (sizeof (type), (base), &(cur), (cnt)); \ 1389 (sizeof (type), (base), &(cur), (cnt)); \
972 init ((base) + (ocur_), (cur) - ocur_); \ 1390 init ((base) + (ocur_), (cur) - ocur_); \
973 } 1391 }
974 1392
… …
1420} 1838}
1421 1839
1422inline_speed void 1840inline_speed void
1423evpipe_write (EV_P_ EV_ATOMIC_T *flag) 1841evpipe_write (EV_P_ EV_ATOMIC_T *flag)
1424{ 1842{
1425 if (!*flag) 1843 if (expect_true (*flag))
1426 { 1844 return;
1845
1427 *flag = 1; 1846 *flag = 1;
1428 1847
1848 ECB_MEMORY_FENCE_RELEASE; /* make sure flag is visible before the wakeup */
1849
1429 pipe_write_skipped = 1; 1850 pipe_write_skipped = 1;
1430 1851
1852 ECB_MEMORY_FENCE; /* make sure pipe_write_skipped is visible before we check pipe_write_wanted */
1853
1431 if (pipe_write_wanted) 1854 if (pipe_write_wanted)
1855 {
1856 int old_errno;
1857
1858 pipe_write_skipped = 0; /* just an optimisation, no fence needed */
1859
1860 old_errno = errno; /* save errno because write will clobber it */
1861
1862#if EV_USE_EVENTFD
1863 if (evfd >= 0)
1432 { 1864 {
1433 int old_errno;
1434
1435 pipe_write_skipped = 0;
1436
1437 old_errno = errno; /* save errno because write will clobber it */
1438
1439#if EV_USE_EVENTFD
1440 if (evfd >= 0)
1441 {
1442 uint64_t counter = 1; 1865 uint64_t counter = 1;
1443 write (evfd, &counter, sizeof (uint64_t)); 1866 write (evfd, &counter, sizeof (uint64_t));
1444 }
1445 else
1446#endif
1447 {
1448 /* win32 people keep sending patches that change this write() to send() */
1449 /* and then run away. but send() is wrong, it wants a socket handle on win32 */
1450 /* so when you think this write should be a send instead, please find out */
1451 /* where your send() is from - it's definitely not the microsoft send, and */
1452 /* tell me. thank you. */
1453 write (evpipe [1], &(evpipe [1]), 1);
1454 }
1455
1456 errno = old_errno;
1457 } 1867 }
1868 else
1869#endif
1870 {
1871 /* win32 people keep sending patches that change this write() to send() */
1872 /* and then run away. but send() is wrong, it wants a socket handle on win32 */
1873 /* so when you think this write should be a send instead, please find out */
1874 /* where your send() is from - it's definitely not the microsoft send, and */
1875 /* tell me. thank you. */
1876 write (evpipe [1], &(evpipe [1]), 1);
1877 }
1878
1879 errno = old_errno;
1458 } 1880 }
1459} 1881}
1460 1882
1461/* called whenever the libev signal pipe */ 1883/* called whenever the libev signal pipe */
1462/* got some events (signal, async) */ 1884/* got some events (signal, async) */
… …
2573 time_update (EV_A_ 1e100); 2995 time_update (EV_A_ 1e100);
2574 2996
2575 /* from now on, we want a pipe-wake-up */ 2997 /* from now on, we want a pipe-wake-up */
2576 pipe_write_wanted = 1; 2998 pipe_write_wanted = 1;
2577 2999
3000 ECB_MEMORY_FENCE; /* make sure pipe_write_wanted is visible before we check for potential skips */
3001
2578 if (expect_true (!(flags & EVRUN_NOWAIT || idleall || !activecnt || pipe_write_skipped))) 3002 if (expect_true (!(flags & EVRUN_NOWAIT || idleall || !activecnt || pipe_write_skipped)))
2579 { 3003 {
2580 waittime = MAX_BLOCKTIME; 3004 waittime = MAX_BLOCKTIME;
2581 3005
2582 if (timercnt) 3006 if (timercnt)
… …
2623#endif 3047#endif
2624 assert ((loop_done = EVBREAK_RECURSE, 1)); /* assert for side effect */ 3048 assert ((loop_done = EVBREAK_RECURSE, 1)); /* assert for side effect */
2625 backend_poll (EV_A_ waittime); 3049 backend_poll (EV_A_ waittime);
2626 assert ((loop_done = EVBREAK_CANCEL, 1)); /* assert for side effect */ 3050 assert ((loop_done = EVBREAK_CANCEL, 1)); /* assert for side effect */
2627 3051
2628 pipe_write_wanted = 0; 3052 pipe_write_wanted = 0; /* just an optimisation, no fence needed */
2629 3053
2630 if (pipe_write_skipped) 3054 if (pipe_write_skipped)
2631 { 3055 {
2632 assert (("libev: pipe_w not active, but pipe not written", ev_is_active (&pipe_w))); 3056 assert (("libev: pipe_w not active, but pipe not written", ev_is_active (&pipe_w)));
2633 ev_feed_event (EV_A_ &pipe_w, EV_CUSTOM); 3057 ev_feed_event (EV_A_ &pipe_w, EV_CUSTOM);
… …
2891 3315
2892void noinline 3316void noinline
2893ev_timer_again (EV_P_ ev_timer *w) 3317ev_timer_again (EV_P_ ev_timer *w)
2894{ 3318{
2895 EV_FREQUENT_CHECK; 3319 EV_FREQUENT_CHECK;
3320
3321 clear_pending (EV_A_ (W)w);
2896 3322
2897 if (ev_is_active (w)) 3323 if (ev_is_active (w))
2898 { 3324 {
2899 if (w->repeat) 3325 if (w->repeat)
2900 { 3326 {
… …
3983 cb (EV_A_ EV_PERIODIC, ANHE_w (periodics [i])); 4409 cb (EV_A_ EV_PERIODIC, ANHE_w (periodics [i]));
3984#endif 4410#endif
3985 4411
3986#if EV_IDLE_ENABLE 4412#if EV_IDLE_ENABLE
3987 if (types & EV_IDLE) 4413 if (types & EV_IDLE)
3988 for (j = NUMPRI; i--; ) 4414 for (j = NUMPRI; j--; )
3989 for (i = idlecnt [j]; i--; ) 4415 for (i = idlecnt [j]; i--; )
3990 cb (EV_A_ EV_IDLE, idles [j][i]); 4416 cb (EV_A_ EV_IDLE, idles [j][i]);
3991#endif 4417#endif
3992 4418
3993#if EV_FORK_ENABLE 4419#if EV_FORK_ENABLE
… …
4046 4472
4047#if EV_MULTIPLICITY 4473#if EV_MULTIPLICITY
4048 #include "ev_wrap.h" 4474 #include "ev_wrap.h"
4049#endif 4475#endif
4050 4476
4051EV_CPP(})
4052

Diff Legend

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