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, 4 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

# Content
1 /* 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 #include <time.h>
24 #include <winsock2.h>
25 #include <process.h>
26 #include <windows.h>
27 #include <pthread.h>
28 #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 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
41 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
52 static int
53 thread_create (thread_t *tid, void *(*proc)(void *), void *arg)
54 {
55 pthread_attr_t attr;
56
57 pthread_attr_init (&attr);
58 pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
59
60 return pthread_create (tid, &attr, proc, arg) == 0;
61 }
62
63 #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 #else
68 /////////////////////////////////////////////////////////////////////////////
69
70 /* 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 #include <unistd.h>
81 #include <fcntl.h>
82 #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 # define X_MUTEX_INIT PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
88 #else
89 # define X_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
90 #endif
91 #define X_LOCK(mutex) pthread_mutex_lock (&(mutex))
92 #define X_UNLOCK(mutex) pthread_mutex_unlock (&(mutex))
93
94 typedef pthread_cond_t cond_t;
95 #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
100 typedef pthread_t thread_t;
101 #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
104 static int
105 thread_create (thread_t *tid, void *(*proc)(void *), void *arg)
106 {
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 #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 #endif
131
132
133