ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/xthread.h
Revision: 1.5
Committed: Sun Jul 8 13:43:29 2007 UTC (17 years, 5 months ago) by root
Content type: text/plain
Branch: MAIN
CVS Tags: rel-2_6, rel-2_4, rel-2_5, rel-2_51, rel-2_41
Changes since 1.4: +22 -39 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.2 /* wether word reads are potentially non-atomic.
2     * this is conservatice, likely most arches this runs
3     * on have atomic word read/writes.
4     */
5     #ifndef WORDACCESS_UNSAFE
6     # if __i386 || __x86_64
7     # define WORDACCESS_UNSAFE 0
8     # else
9     # define WORDACCESS_UNSAFE 1
10     # endif
11     #endif
12    
13     /////////////////////////////////////////////////////////////////////////////
14    
15     #ifdef _WIN32
16     typedef int ssize_t;
17    
18     #define NTDDI_VERSION NTDDI_WIN2K // needed to get win2000 api calls
19     #define _WIN32_WINNT 0x400
20     #include <stdio.h>//D
21     #include <fcntl.h>
22     #include <io.h>
23 root 1.5 #include <time.h>
24 root 1.2 #include <winsock2.h>
25     #include <process.h>
26     #include <windows.h>
27 root 1.5 #include <pthread.h>
28 root 1.2 #define sigset_t int
29     #define sigfillset(a)
30     #define pthread_sigmask(a,b,c)
31     #define sigaddset(a,b)
32     #define sigemptyset(s)
33     #define sigfillset(s)
34    
35 root 1.5 typedef pthread_mutex_t mutex_t;
36     #define X_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
37     #define X_MUTEX_CHECK(mutex)
38     #define X_LOCK(mutex) pthread_mutex_lock (&(mutex))
39     #define X_UNLOCK(mutex) pthread_mutex_unlock (&(mutex))
40 root 1.2
41 root 1.5 typedef pthread_cond_t cond_t;
42     #define X_COND_INIT PTHREAD_COND_INITIALIZER
43     #define X_COND_CHECK(cond)
44     #define X_COND_SIGNAL(cond) pthread_cond_signal (&(cond))
45     #define X_COND_WAIT(cond,mutex) pthread_cond_wait (&(cond), &(mutex))
46     #define X_COND_TIMEDWAIT(cond,mutex,to) pthread_cond_timedwait (&(cond), &(mutex), &(to))
47    
48     typedef pthread_t thread_t;
49     #define X_THREAD_PROC(name) void *name (void *thr_arg)
50     #define X_THREAD_ATFORK(a,b,c)
51 root 1.2
52     static int
53 root 1.5 thread_create (thread_t *tid, void *(*proc)(void *), void *arg)
54 root 1.2 {
55 root 1.5 pthread_attr_t attr;
56 root 1.2
57 root 1.5 pthread_attr_init (&attr);
58     pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
59 root 1.2
60 root 1.5 return pthread_create (tid, &attr, proc, arg) == 0;
61 root 1.2 }
62    
63 root 1.4 #define respipe_read(a,b,c) PerlSock_recv ((a), (b), (c), 0)
64     #define respipe_write(a,b,c) send ((a), (b), (c), 0)
65     #define respipe_close(a) PerlSock_closesocket ((a))
66    
67 root 1.2 #else
68     /////////////////////////////////////////////////////////////////////////////
69    
70 root 1.1 /* solaris */
71     #define _POSIX_PTHREAD_SEMANTICS 1
72    
73     #if __linux && !defined(_GNU_SOURCE)
74     # define _GNU_SOURCE
75     #endif
76    
77     /* just in case */
78     #define _REENTRANT 1
79    
80 root 1.2 #include <unistd.h>
81     #include <fcntl.h>
82 root 1.1 #include <signal.h>
83     #include <pthread.h>
84    
85     typedef pthread_mutex_t mutex_t;
86     #if __linux && defined (PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP)
87 root 1.2 # define X_MUTEX_INIT PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
88 root 1.1 #else
89 root 1.2 # define X_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
90 root 1.1 #endif
91 root 1.2 #define X_LOCK(mutex) pthread_mutex_lock (&(mutex))
92     #define X_UNLOCK(mutex) pthread_mutex_unlock (&(mutex))
93 root 1.1
94     typedef pthread_cond_t cond_t;
95 root 1.2 #define X_COND_INIT PTHREAD_COND_INITIALIZER
96     #define X_COND_SIGNAL(cond) pthread_cond_signal (&(cond))
97     #define X_COND_WAIT(cond,mutex) pthread_cond_wait (&(cond), &(mutex))
98     #define X_COND_TIMEDWAIT(cond,mutex,to) pthread_cond_timedwait (&(cond), &(mutex), &(to))
99 root 1.1
100     typedef pthread_t thread_t;
101 root 1.2 #define X_THREAD_PROC(name) static void *name (void *thr_arg)
102     #define X_THREAD_ATFORK(prepare,parent,child) pthread_atfork (prepare, parent, child)
103 root 1.1
104 root 1.2 static int
105     thread_create (thread_t *tid, void *(*proc)(void *), void *arg)
106 root 1.1 {
107     int retval;
108     sigset_t fullsigset, oldsigset;
109     pthread_attr_t attr;
110    
111     pthread_attr_init (&attr);
112     pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
113     #ifdef PTHREAD_SCOPE_PROCESS
114     pthread_attr_setscope (&attr, PTHREAD_SCOPE_PROCESS);
115     #endif
116    
117     sigfillset (&fullsigset);
118    
119     pthread_sigmask (SIG_SETMASK, &fullsigset, &oldsigset);
120     retval = pthread_create (tid, &attr, proc, arg) == 0;
121     pthread_sigmask (SIG_SETMASK, &oldsigset, 0);
122    
123     return retval;
124     }
125    
126 root 1.4 #define respipe_read(a,b,c) read ((a), (b), (c))
127     #define respipe_write(a,b,c) write ((a), (b), (c))
128     #define respipe_close(a) close ((a))
129    
130 root 1.2 #endif
131    
132    
133 root 1.1