Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 1 | /* This code implemented by cvale@netcom.com */ |
| 2 | |
| 3 | #define INCL_DOSPROCESS |
| 4 | #define INCL_DOSSEMAPHORES |
| 5 | #include "os2.h" |
| 6 | #include "limits.h" |
| 7 | |
| 8 | #include "process.h" |
| 9 | |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 10 | #if defined(PYCC_GCC) |
| 11 | #include <sys/builtin.h> |
| 12 | #include <sys/fmutex.h> |
| 13 | #else |
Guido van Rossum | 65d5b57 | 1998-12-21 19:32:43 +0000 | [diff] [blame] | 14 | long PyThread_get_thread_ident(void); |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 15 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 16 | |
| 17 | /* |
| 18 | * Initialization of the C package, should not be needed. |
| 19 | */ |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 20 | static void |
| 21 | PyThread__init_thread(void) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 22 | { |
| 23 | } |
| 24 | |
| 25 | /* |
| 26 | * Thread support. |
| 27 | */ |
Guido van Rossum | 3c28863 | 2001-10-16 21:13:49 +0000 | [diff] [blame] | 28 | long |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 29 | PyThread_start_new_thread(void (*func)(void *), void *arg) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 30 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 31 | int aThread; |
| 32 | int success = 0; |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 33 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 34 | aThread = _beginthread(func,NULL,65536,arg); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 35 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 36 | if (aThread == -1) { |
| 37 | success = -1; |
| 38 | fprintf(stderr, "aThread failed == %d", aThread); |
| 39 | dprintf(("_beginthread failed. return %ld\n", errno)); |
| 40 | } |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 41 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 42 | return success; |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 43 | } |
| 44 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 45 | long |
| 46 | PyThread_get_thread_ident(void) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 47 | { |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 48 | #if !defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 49 | PPIB pib; |
| 50 | PTIB tib; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 51 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 52 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 53 | if (!initialized) |
| 54 | PyThread_init_thread(); |
| 55 | |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 56 | #if defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 57 | return _gettid(); |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 58 | #else |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 59 | DosGetInfoBlocks(&tib, &pib); |
| 60 | return tib->tib_ptib2->tib2_ultid; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 61 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 62 | } |
| 63 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 64 | static void |
| 65 | do_PyThread_exit_thread(int no_cleanup) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 66 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 67 | dprintf(("%ld: PyThread_exit_thread called\n", |
| 68 | PyThread_get_thread_ident())); |
| 69 | if (!initialized) |
| 70 | if (no_cleanup) |
| 71 | _exit(0); |
| 72 | else |
| 73 | exit(0); |
| 74 | _endthread(); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 75 | } |
| 76 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 77 | void |
| 78 | PyThread_exit_thread(void) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 79 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 80 | do_PyThread_exit_thread(0); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 81 | } |
| 82 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 83 | void |
| 84 | PyThread__exit_thread(void) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 85 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 86 | do_PyThread_exit_thread(1); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 87 | } |
| 88 | |
| 89 | #ifndef NO_EXIT_PROG |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 90 | static void |
| 91 | do_PyThread_exit_prog(int status, int no_cleanup) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 92 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 93 | dprintf(("PyThread_exit_prog(%d) called\n", status)); |
| 94 | if (!initialized) |
| 95 | if (no_cleanup) |
| 96 | _exit(status); |
| 97 | else |
| 98 | exit(status); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 99 | } |
| 100 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 101 | void |
| 102 | PyThread_exit_prog(int status) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 103 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 104 | do_PyThread_exit_prog(status, 0); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 105 | } |
| 106 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 107 | void |
| 108 | PyThread__exit_prog(int status) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 109 | { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 110 | do_PyThread_exit_prog(status, 1); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 111 | } |
| 112 | #endif /* NO_EXIT_PROG */ |
| 113 | |
| 114 | /* |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 115 | * Lock support. This is implemented with an event semaphore and critical |
| 116 | * sections to make it behave more like a posix mutex than its OS/2 |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 117 | * counterparts. |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 118 | */ |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 119 | |
| 120 | typedef struct os2_lock_t { |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 121 | int is_set; |
| 122 | HEV changed; |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 123 | } *type_os2_lock; |
| 124 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 125 | PyThread_type_lock |
| 126 | PyThread_allocate_lock(void) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 127 | { |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 128 | #if defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 129 | _fmutex *sem = malloc(sizeof(_fmutex)); |
| 130 | if (!initialized) |
| 131 | PyThread_init_thread(); |
| 132 | dprintf(("%ld: PyThread_allocate_lock() -> %lx\n", |
| 133 | PyThread_get_thread_ident(), |
| 134 | (long)sem)); |
| 135 | if (_fmutex_create(sem, 0)) { |
| 136 | free(sem); |
| 137 | sem = NULL; |
| 138 | } |
| 139 | return (PyThread_type_lock)sem; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 140 | #else |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 141 | APIRET rc; |
| 142 | type_os2_lock lock = (type_os2_lock)malloc(sizeof(struct os2_lock_t)); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 143 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 144 | dprintf(("PyThread_allocate_lock called\n")); |
| 145 | if (!initialized) |
| 146 | PyThread_init_thread(); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 147 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 148 | lock->is_set = 0; |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 149 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 150 | DosCreateEventSem(NULL, &lock->changed, 0, 0); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 151 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 152 | dprintf(("%ld: PyThread_allocate_lock() -> %p\n", |
| 153 | PyThread_get_thread_ident(), |
| 154 | lock->changed)); |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 155 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 156 | return (PyThread_type_lock)lock; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 157 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 158 | } |
| 159 | |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 160 | void |
| 161 | PyThread_free_lock(PyThread_type_lock aLock) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 162 | { |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 163 | #if !defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 164 | type_os2_lock lock = (type_os2_lock)aLock; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 165 | #endif |
| 166 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 167 | dprintf(("%ld: PyThread_free_lock(%p) called\n", |
| 168 | PyThread_get_thread_ident(),aLock)); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 169 | |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 170 | #if defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 171 | if (aLock) { |
| 172 | _fmutex_close((_fmutex *)aLock); |
| 173 | free((_fmutex *)aLock); |
| 174 | } |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 175 | #else |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 176 | DosCloseEventSem(lock->changed); |
| 177 | free(aLock); |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 178 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 179 | } |
| 180 | |
| 181 | /* |
| 182 | * Return 1 on success if the lock was acquired |
| 183 | * |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 184 | * and 0 if the lock was not acquired. |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 185 | */ |
Thomas Wouters | f70ef4f | 2000-07-22 18:47:25 +0000 | [diff] [blame] | 186 | int |
| 187 | PyThread_acquire_lock(PyThread_type_lock aLock, int waitflag) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 188 | { |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 189 | #if !defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 190 | int done = 0; |
| 191 | ULONG count; |
| 192 | PID pid = 0; |
| 193 | TID tid = 0; |
| 194 | type_os2_lock lock = (type_os2_lock)aLock; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 195 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 196 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 197 | dprintf(("%ld: PyThread_acquire_lock(%p, %d) called\n", |
| 198 | PyThread_get_thread_ident(), |
| 199 | aLock, |
| 200 | waitflag)); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 201 | |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 202 | #if defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 203 | /* always successful if the lock doesn't exist */ |
| 204 | if (aLock && |
| 205 | _fmutex_request((_fmutex *)aLock, waitflag ? 0 : _FMR_NOWAIT)) |
| 206 | return 0; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 207 | #else |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 208 | while (!done) { |
| 209 | /* if the lock is currently set, we have to wait for |
| 210 | * the state to change |
| 211 | */ |
| 212 | if (lock->is_set) { |
| 213 | if (!waitflag) |
| 214 | return 0; |
| 215 | DosWaitEventSem(lock->changed, SEM_INDEFINITE_WAIT); |
| 216 | } |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 217 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 218 | /* enter a critical section and try to get the semaphore. If |
| 219 | * it is still locked, we will try again. |
| 220 | */ |
| 221 | if (DosEnterCritSec()) |
| 222 | return 0; |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 223 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 224 | if (!lock->is_set) { |
| 225 | lock->is_set = 1; |
| 226 | DosResetEventSem(lock->changed, &count); |
| 227 | done = 1; |
| 228 | } |
| 229 | |
| 230 | DosExitCritSec(); |
| 231 | } |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 232 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 233 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 234 | return 1; |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 235 | } |
| 236 | |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 237 | void PyThread_release_lock(PyThread_type_lock aLock) |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 238 | { |
Andrew MacIntyre | 6904959 | 2002-12-04 12:27:06 +0000 | [diff] [blame] | 239 | #if !defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 240 | type_os2_lock lock = (type_os2_lock)aLock; |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 241 | #endif |
| 242 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 243 | dprintf(("%ld: PyThread_release_lock(%p) called\n", |
| 244 | PyThread_get_thread_ident(), |
| 245 | aLock)); |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 246 | |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 247 | #if defined(PYCC_GCC) |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 248 | if (aLock) |
| 249 | _fmutex_release((_fmutex *)aLock); |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 250 | #else |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 251 | if (!lock->is_set) { |
| 252 | dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n", |
| 253 | PyThread_get_thread_ident(), |
| 254 | aLock, |
| 255 | GetLastError())); |
| 256 | return; |
| 257 | } |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 258 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 259 | if (DosEnterCritSec()) { |
| 260 | dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n", |
| 261 | PyThread_get_thread_ident(), |
| 262 | aLock, |
| 263 | GetLastError())); |
| 264 | return; |
| 265 | } |
Tim Peters | a6ca4f4 | 2001-10-31 03:50:45 +0000 | [diff] [blame] | 266 | |
Andrew MacIntyre | c4c127b | 2002-12-04 12:29:37 +0000 | [diff] [blame^] | 267 | lock->is_set = 0; |
| 268 | DosPostEventSem(lock->changed); |
| 269 | |
| 270 | DosExitCritSec(); |
Andrew MacIntyre | d940054 | 2002-02-26 11:41:34 +0000 | [diff] [blame] | 271 | #endif |
Guido van Rossum | 6233293 | 1995-04-10 11:36:14 +0000 | [diff] [blame] | 272 | } |