cpython/Python/thread_os2.h

277 lines
5.0 KiB
C
Raw Normal View History

1995-04-10 08:36:14 -03:00
/* This code implemented by cvale@netcom.com */
#define INCL_DOSPROCESS
#define INCL_DOSSEMAPHORES
#include "os2.h"
#include "limits.h"
#include "process.h"
#if defined(PYCC_GCC)
#include <sys/builtin.h>
#include <sys/fmutex.h>
#else
long PyThread_get_thread_ident(void);
#endif
1995-04-10 08:36:14 -03:00
#if !defined(THREAD_STACK_SIZE)
#define THREAD_STACK_SIZE 0x10000
#endif
1995-04-10 08:36:14 -03:00
/*
* Initialization of the C package, should not be needed.
*/
static void
PyThread__init_thread(void)
1995-04-10 08:36:14 -03:00
{
}
/*
* Thread support.
*/
long
PyThread_start_new_thread(void (*func)(void *), void *arg)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
int aThread;
int success = 0;
1995-04-10 08:36:14 -03:00
aThread = _beginthread(func, NULL, THREAD_STACK_SIZE, arg);
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
if (aThread == -1) {
success = -1;
fprintf(stderr, "aThread failed == %d", aThread);
dprintf(("_beginthread failed. return %ld\n", errno));
}
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
return success;
1995-04-10 08:36:14 -03:00
}
long
PyThread_get_thread_ident(void)
1995-04-10 08:36:14 -03:00
{
#if !defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
PPIB pib;
PTIB tib;
#endif
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
if (!initialized)
PyThread_init_thread();
#if defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
return _gettid();
#else
2002-12-04 08:29:37 -04:00
DosGetInfoBlocks(&tib, &pib);
return tib->tib_ptib2->tib2_ultid;
#endif
1995-04-10 08:36:14 -03:00
}
static void
do_PyThread_exit_thread(int no_cleanup)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
dprintf(("%ld: PyThread_exit_thread called\n",
PyThread_get_thread_ident()));
if (!initialized)
if (no_cleanup)
_exit(0);
else
exit(0);
_endthread();
1995-04-10 08:36:14 -03:00
}
void
PyThread_exit_thread(void)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
do_PyThread_exit_thread(0);
1995-04-10 08:36:14 -03:00
}
void
PyThread__exit_thread(void)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
do_PyThread_exit_thread(1);
1995-04-10 08:36:14 -03:00
}
#ifndef NO_EXIT_PROG
static void
do_PyThread_exit_prog(int status, int no_cleanup)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
dprintf(("PyThread_exit_prog(%d) called\n", status));
if (!initialized)
if (no_cleanup)
_exit(status);
else
exit(status);
1995-04-10 08:36:14 -03:00
}
void
PyThread_exit_prog(int status)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
do_PyThread_exit_prog(status, 0);
1995-04-10 08:36:14 -03:00
}
void
PyThread__exit_prog(int status)
1995-04-10 08:36:14 -03:00
{
2002-12-04 08:29:37 -04:00
do_PyThread_exit_prog(status, 1);
1995-04-10 08:36:14 -03:00
}
#endif /* NO_EXIT_PROG */
/*
* Lock support. This is implemented with an event semaphore and critical
* sections to make it behave more like a posix mutex than its OS/2
* counterparts.
1995-04-10 08:36:14 -03:00
*/
typedef struct os2_lock_t {
2002-12-04 08:29:37 -04:00
int is_set;
HEV changed;
} *type_os2_lock;
PyThread_type_lock
PyThread_allocate_lock(void)
1995-04-10 08:36:14 -03:00
{
#if defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
_fmutex *sem = malloc(sizeof(_fmutex));
if (!initialized)
PyThread_init_thread();
dprintf(("%ld: PyThread_allocate_lock() -> %lx\n",
PyThread_get_thread_ident(),
(long)sem));
if (_fmutex_create(sem, 0)) {
free(sem);
sem = NULL;
}
return (PyThread_type_lock)sem;
#else
2002-12-04 08:29:37 -04:00
APIRET rc;
type_os2_lock lock = (type_os2_lock)malloc(sizeof(struct os2_lock_t));
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
dprintf(("PyThread_allocate_lock called\n"));
if (!initialized)
PyThread_init_thread();
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
lock->is_set = 0;
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
DosCreateEventSem(NULL, &lock->changed, 0, 0);
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
dprintf(("%ld: PyThread_allocate_lock() -> %p\n",
PyThread_get_thread_ident(),
lock->changed));
2002-12-04 08:29:37 -04:00
return (PyThread_type_lock)lock;
#endif
1995-04-10 08:36:14 -03:00
}
void
PyThread_free_lock(PyThread_type_lock aLock)
1995-04-10 08:36:14 -03:00
{
#if !defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
type_os2_lock lock = (type_os2_lock)aLock;
#endif
2002-12-04 08:29:37 -04:00
dprintf(("%ld: PyThread_free_lock(%p) called\n",
PyThread_get_thread_ident(),aLock));
1995-04-10 08:36:14 -03:00
#if defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
if (aLock) {
_fmutex_close((_fmutex *)aLock);
free((_fmutex *)aLock);
}
#else
2002-12-04 08:29:37 -04:00
DosCloseEventSem(lock->changed);
free(aLock);
#endif
1995-04-10 08:36:14 -03:00
}
/*
* Return 1 on success if the lock was acquired
*
* and 0 if the lock was not acquired.
1995-04-10 08:36:14 -03:00
*/
int
PyThread_acquire_lock(PyThread_type_lock aLock, int waitflag)
1995-04-10 08:36:14 -03:00
{
#if !defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
int done = 0;
ULONG count;
PID pid = 0;
TID tid = 0;
type_os2_lock lock = (type_os2_lock)aLock;
#endif
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
dprintf(("%ld: PyThread_acquire_lock(%p, %d) called\n",
PyThread_get_thread_ident(),
aLock,
waitflag));
1995-04-10 08:36:14 -03:00
#if defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
/* always successful if the lock doesn't exist */
if (aLock &&
_fmutex_request((_fmutex *)aLock, waitflag ? 0 : _FMR_NOWAIT))
return 0;
#else
2002-12-04 08:29:37 -04:00
while (!done) {
/* if the lock is currently set, we have to wait for
* the state to change
*/
if (lock->is_set) {
if (!waitflag)
return 0;
DosWaitEventSem(lock->changed, SEM_INDEFINITE_WAIT);
}
/* enter a critical section and try to get the semaphore. If
* it is still locked, we will try again.
*/
if (DosEnterCritSec())
return 0;
if (!lock->is_set) {
lock->is_set = 1;
DosResetEventSem(lock->changed, &count);
done = 1;
}
DosExitCritSec();
}
#endif
1995-04-10 08:36:14 -03:00
2002-12-04 08:29:37 -04:00
return 1;
1995-04-10 08:36:14 -03:00
}
void PyThread_release_lock(PyThread_type_lock aLock)
1995-04-10 08:36:14 -03:00
{
#if !defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
type_os2_lock lock = (type_os2_lock)aLock;
#endif
2002-12-04 08:29:37 -04:00
dprintf(("%ld: PyThread_release_lock(%p) called\n",
PyThread_get_thread_ident(),
aLock));
1995-04-10 08:36:14 -03:00
#if defined(PYCC_GCC)
2002-12-04 08:29:37 -04:00
if (aLock)
_fmutex_release((_fmutex *)aLock);
#else
2002-12-04 08:29:37 -04:00
if (!lock->is_set) {
dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n",
PyThread_get_thread_ident(),
aLock,
GetLastError()));
return;
}
if (DosEnterCritSec()) {
dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n",
PyThread_get_thread_ident(),
aLock,
GetLastError()));
return;
}
lock->is_set = 0;
DosPostEventSem(lock->changed);
DosExitCritSec();
#endif
1995-04-10 08:36:14 -03:00
}