ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/xthread.h
Revision: 1.4
Committed: Sun Jul 8 11:12:15 2007 UTC (17 years, 5 months ago) by root
Content type: text/plain
Branch: MAIN
Changes since 1.3: +8 -0 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     #include <winsock2.h>
24     #include <process.h>
25     #include <windows.h>
26     #define sigset_t int
27     #define sigfillset(a)
28     #define pthread_sigmask(a,b,c)
29     #define sigaddset(a,b)
30     #define sigemptyset(s)
31     #define sigfillset(s)
32    
33     #define pthread_kill(a,b)
34     #define pthread_self() 0
35    
36     typedef HANDLE mutex_t;
37     #define X_MUTEX_INIT 0
38     #define X_MUTEX_CHECK(mutex) if (!(mutex)) (mutex) = CreateMutex (NULL, FALSE, NULL)
39     #define X_LOCK(mutex) WaitForSingleObject ((mutex), INFINITE)
40     #define X_UNLOCK(mutex) ReleaseMutex (mutex)
41    
42     typedef HANDLE cond_t;
43     #define X_COND_INIT 0
44     #define X_COND_CHECK(cond) if (!(cond)) (cond) = CreateEvent (NULL, FALSE, FALSE, NULL)
45     #define X_COND_SIGNAL(cond) SetEvent (cond)
46     #define X_COND_WAIT(cond,mutex) do { SignalObjectAndWait ((mutex), (cond),INFINITE, FALSE); WaitForSingleObject ((mutex), INFINITE); } while (0)
47    
48     #define ETIMEDOUT 1
49    
50     struct timespec {
51     unsigned long tv_sec, tv_nsec;
52     };
53    
54     static int
55     X_COND_TIMEDWAIT (mutex_t mutex, cond_t cond, struct timespec to)
56     {
57     unsigned long ms = to.tv_nsec / 1000 + to.tv_sec * 1000;
58    
59     if (SignalObjectAndWait (mutex, cond, ms, FALSE) == WAIT_TIMEOUT)
60     return ETIMEDOUT;
61    
62     if (WaitForSingleObject (mutex, ms) == WAIT_TIMEOUT)
63     return ETIMEDOUT;
64    
65     return 0;
66     }
67    
68     typedef DWORD thread_t;
69     #define X_THREAD_PROC(name) DWORD WINAPI name (LPVOID thr_arg)
70     #define X_THREAD_ATFORK(a,b,c)
71    
72     static int
73     thread_create (thread_t *tid, LPTHREAD_START_ROUTINE proc, void *arg)
74     {
75     *tid = 0;
76     CreateThread (0, 4096, proc, arg, 0, tid);
77     return !!*tid;
78     }
79    
80 root 1.4 #define respipe_read(a,b,c) PerlSock_recv ((a), (b), (c), 0)
81     #define respipe_write(a,b,c) send ((a), (b), (c), 0)
82     #define respipe_close(a) PerlSock_closesocket ((a))
83    
84 root 1.2 #else
85     /////////////////////////////////////////////////////////////////////////////
86    
87 root 1.1 /* solaris */
88     #define _POSIX_PTHREAD_SEMANTICS 1
89    
90     #if __linux && !defined(_GNU_SOURCE)
91     # define _GNU_SOURCE
92     #endif
93    
94     /* just in case */
95     #define _REENTRANT 1
96    
97 root 1.2 #include <unistd.h>
98     #include <fcntl.h>
99 root 1.1 #include <signal.h>
100     #include <pthread.h>
101    
102     typedef pthread_mutex_t mutex_t;
103     #if __linux && defined (PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP)
104 root 1.2 # define X_MUTEX_INIT PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
105 root 1.1 #else
106 root 1.2 # define X_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
107 root 1.1 #endif
108 root 1.2 #define X_LOCK(mutex) pthread_mutex_lock (&(mutex))
109     #define X_UNLOCK(mutex) pthread_mutex_unlock (&(mutex))
110 root 1.1
111     typedef pthread_cond_t cond_t;
112 root 1.2 #define X_COND_INIT PTHREAD_COND_INITIALIZER
113     #define X_COND_SIGNAL(cond) pthread_cond_signal (&(cond))
114     #define X_COND_WAIT(cond,mutex) pthread_cond_wait (&(cond), &(mutex))
115     #define X_COND_TIMEDWAIT(cond,mutex,to) pthread_cond_timedwait (&(cond), &(mutex), &(to))
116 root 1.1
117     typedef pthread_t thread_t;
118 root 1.2 #define X_THREAD_PROC(name) static void *name (void *thr_arg)
119     #define X_THREAD_ATFORK(prepare,parent,child) pthread_atfork (prepare, parent, child)
120 root 1.1
121 root 1.2 static int
122     thread_create (thread_t *tid, void *(*proc)(void *), void *arg)
123 root 1.1 {
124     int retval;
125     sigset_t fullsigset, oldsigset;
126     pthread_attr_t attr;
127    
128     pthread_attr_init (&attr);
129     pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED);
130     #ifdef PTHREAD_SCOPE_PROCESS
131     pthread_attr_setscope (&attr, PTHREAD_SCOPE_PROCESS);
132     #endif
133    
134     sigfillset (&fullsigset);
135    
136     pthread_sigmask (SIG_SETMASK, &fullsigset, &oldsigset);
137     retval = pthread_create (tid, &attr, proc, arg) == 0;
138     pthread_sigmask (SIG_SETMASK, &oldsigset, 0);
139    
140     return retval;
141     }
142    
143 root 1.4 #define respipe_read(a,b,c) read ((a), (b), (c))
144     #define respipe_write(a,b,c) write ((a), (b), (c))
145     #define respipe_close(a) close ((a))
146    
147 root 1.2 #endif
148    
149    
150 root 1.1