Back to index

python3.2  3.2.2
Classes | Defines | Typedefs | Functions
thread_os2.h File Reference
#include "os2.h"
#include "limits.h"
#include "process.h"

Go to the source code of this file.

Classes

struct  os2_lock_t

Defines

#define INCL_DOSPROCESS
#define INCL_DOSSEMAPHORES
#define THREAD_STACK_SIZE   0x10000
#define OS2_STACKSIZE(x)   (x ? x : THREAD_STACK_SIZE)
#define THREAD_MIN_STACKSIZE   0x8000 /* 32kB */
#define THREAD_MAX_STACKSIZE   0x2000000 /* 32MB */
#define THREAD_SET_STACKSIZE(x)   _pythread_os2_set_stacksize(x)

Typedefs

typedef struct os2_lock_ttype_os2_lock

Functions

long PyThread_get_thread_ident (void)
static void PyThread__init_thread (void)
long PyThread_start_new_thread (void(*func)(void *), void *arg)
void PyThread_exit_thread (void)
PyThread_type_lock PyThread_allocate_lock (void)
void PyThread_free_lock (PyThread_type_lock aLock)
int PyThread_acquire_lock (PyThread_type_lock aLock, int waitflag)
void PyThread_release_lock (PyThread_type_lock aLock)
static int _pythread_os2_set_stacksize (size_t size)

Class Documentation

struct os2_lock_t

Definition at line 87 of file thread_os2.h.

Class Members
HEV changed
int is_set

Define Documentation

#define INCL_DOSPROCESS

Definition at line 3 of file thread_os2.h.

Definition at line 4 of file thread_os2.h.

#define OS2_STACKSIZE (   x)    (x ? x : THREAD_STACK_SIZE)

Definition at line 22 of file thread_os2.h.

#define THREAD_MAX_STACKSIZE   0x2000000 /* 32MB */

Definition at line 244 of file thread_os2.h.

#define THREAD_MIN_STACKSIZE   0x8000 /* 32kB */

Definition at line 243 of file thread_os2.h.

Definition at line 267 of file thread_os2.h.

#define THREAD_STACK_SIZE   0x10000

Definition at line 19 of file thread_os2.h.


Typedef Documentation

typedef struct os2_lock_t * type_os2_lock

Function Documentation

static int _pythread_os2_set_stacksize ( size_t  size) [static]

Definition at line 250 of file thread_os2.h.

{
    /* set to default */
    if (size == 0) {
        _pythread_stacksize = 0;
        return 0;
    }

    /* valid range? */
    if (size >= THREAD_MIN_STACKSIZE && size < THREAD_MAX_STACKSIZE) {
        _pythread_stacksize = size;
        return 0;
    }

    return -1;
}
static void PyThread__init_thread ( void  ) [static]

Definition at line 28 of file thread_os2.h.

{
}
int PyThread_acquire_lock ( PyThread_type_lock  aLock,
int  waitflag 
)

Definition at line 154 of file thread_os2.h.

{
#if !defined(PYCC_GCC)
    int   done = 0;
    ULONG count;
    PID   pid = 0;
    TID   tid = 0;
    type_os2_lock lock = (type_os2_lock)aLock;
#endif

    dprintf(("%ld: PyThread_acquire_lock(%p, %d) called\n",
             PyThread_get_thread_ident(),
             aLock,
             waitflag));

#if defined(PYCC_GCC)
    /* always successful if the lock doesn't exist */
    if (aLock &&
        _fmutex_request((_fmutex *)aLock, waitflag ? 0 : _FMR_NOWAIT))
        return 0;
#else
    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

    return 1;
}

Here is the call graph for this function:

Definition at line 93 of file thread_os2.h.

{
#if defined(PYCC_GCC)
    _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
    APIRET rc;
    type_os2_lock lock = (type_os2_lock)malloc(sizeof(struct os2_lock_t));

    dprintf(("PyThread_allocate_lock called\n"));
    if (!initialized)
        PyThread_init_thread();

    lock->is_set = 0;

    DosCreateEventSem(NULL, &lock->changed, 0, 0);

    dprintf(("%ld: PyThread_allocate_lock() -> %p\n",
             PyThread_get_thread_ident(),
             lock->changed));

    return (PyThread_type_lock)lock;
#endif
}

Here is the call graph for this function:

Definition at line 72 of file thread_os2.h.

{
    dprintf(("%ld: PyThread_exit_thread called\n",
             PyThread_get_thread_ident()));
    if (!initialized)
        exit(0);
    _endthread();
}

Here is the call graph for this function:

Definition at line 128 of file thread_os2.h.

{
#if !defined(PYCC_GCC)
    type_os2_lock lock = (type_os2_lock)aLock;
#endif

    dprintf(("%ld: PyThread_free_lock(%p) called\n",
             PyThread_get_thread_ident(),aLock));

#if defined(PYCC_GCC)
    if (aLock) {
        _fmutex_close((_fmutex *)aLock);
        free((_fmutex *)aLock);
    }
#else
    DosCloseEventSem(lock->changed);
    free(aLock);
#endif
}

Here is the call graph for this function:

Definition at line 205 of file thread_os2.h.

{
#if !defined(PYCC_GCC)
    type_os2_lock lock = (type_os2_lock)aLock;
#endif

    dprintf(("%ld: PyThread_release_lock(%p) called\n",
             PyThread_get_thread_ident(),
             aLock));

#if defined(PYCC_GCC)
    if (aLock)
        _fmutex_release((_fmutex *)aLock);
#else
    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
}

Here is the call graph for this function:

long PyThread_start_new_thread ( void(*)(void *)  func,
void arg 
)

Definition at line 36 of file thread_os2.h.

{
    int thread_id;

    thread_id = _beginthread(func,
                            NULL,
                            OS2_STACKSIZE(_pythread_stacksize),
                            arg);

    if (thread_id == -1) {
        dprintf(("_beginthread failed. return %ld\n", errno));
    }

    return thread_id;
}