EmbeddedPkg: Extend NvVarStoreFormattedLib LIBRARY_CLASS

[mirror_edk2.git] / AppPkg / Applications / Python / Python-2.7.2 / Python / thread_os2.h

/* This code implemented by cvale@netcom.com */\r
\r
#define INCL_DOSPROCESS\r
#define INCL_DOSSEMAPHORES\r
#include "os2.h"\r
#include "limits.h"\r
\r
#include "process.h"\r
\r
#if defined(PYCC_GCC)\r
#include <sys/builtin.h>\r
#include <sys/fmutex.h>\r
#else\r
long PyThread_get_thread_ident(void);\r
#endif\r
\r
/* default thread stack size of 64kB */\r
#if !defined(THREAD_STACK_SIZE)\r
#define THREAD_STACK_SIZE       0x10000\r
#endif\r
\r
#define OS2_STACKSIZE(x)        (x ? x : THREAD_STACK_SIZE)\r
\r
/*\r
 * Initialization of the C package, should not be needed.\r
 */\r
static void\r
PyThread__init_thread(void)\r
{\r
}\r
\r
/*\r
 * Thread support.\r
 */\r
long\r
PyThread_start_new_thread(void (*func)(void *), void *arg)\r
{\r
    int thread_id;\r
\r
    thread_id = _beginthread(func,\r
                            NULL,\r
                            OS2_STACKSIZE(_pythread_stacksize),\r
                            arg);\r
\r
    if (thread_id == -1) {\r
        dprintf(("_beginthread failed. return %ld\n", errno));\r
    }\r
\r
    return thread_id;\r
}\r
\r
long\r
PyThread_get_thread_ident(void)\r
{\r
#if !defined(PYCC_GCC)\r
    PPIB pib;\r
    PTIB tib;\r
#endif\r
\r
    if (!initialized)\r
        PyThread_init_thread();\r
\r
#if defined(PYCC_GCC)\r
    return _gettid();\r
#else\r
    DosGetInfoBlocks(&tib, &pib);\r
    return tib->tib_ptib2->tib2_ultid;\r
#endif\r
}\r
\r
void\r
PyThread_exit_thread(void)\r
{\r
    dprintf(("%ld: PyThread_exit_thread called\n",\r
             PyThread_get_thread_ident()));\r
    if (!initialized)\r
        exit(0);\r
    _endthread();\r
}\r
\r
/*\r
 * Lock support.  This is implemented with an event semaphore and critical\r
 * sections to make it behave more like a posix mutex than its OS/2\r
 * counterparts.\r
 */\r
\r
typedef struct os2_lock_t {\r
    int is_set;\r
    HEV changed;\r
} *type_os2_lock;\r
\r
PyThread_type_lock\r
PyThread_allocate_lock(void)\r
{\r
#if defined(PYCC_GCC)\r
    _fmutex *sem = malloc(sizeof(_fmutex));\r
    if (!initialized)\r
        PyThread_init_thread();\r
    dprintf(("%ld: PyThread_allocate_lock() -> %lx\n",\r
             PyThread_get_thread_ident(),\r
             (long)sem));\r
    if (_fmutex_create(sem, 0)) {\r
        free(sem);\r
        sem = NULL;\r
    }\r
    return (PyThread_type_lock)sem;\r
#else\r
    APIRET rc;\r
    type_os2_lock lock = (type_os2_lock)malloc(sizeof(struct os2_lock_t));\r
\r
    dprintf(("PyThread_allocate_lock called\n"));\r
    if (!initialized)\r
        PyThread_init_thread();\r
\r
    lock->is_set = 0;\r
\r
    DosCreateEventSem(NULL, &lock->changed, 0, 0);\r
\r
    dprintf(("%ld: PyThread_allocate_lock() -> %p\n",\r
             PyThread_get_thread_ident(),\r
             lock->changed));\r
\r
    return (PyThread_type_lock)lock;\r
#endif\r
}\r
\r
void\r
PyThread_free_lock(PyThread_type_lock aLock)\r
{\r
#if !defined(PYCC_GCC)\r
    type_os2_lock lock = (type_os2_lock)aLock;\r
#endif\r
\r
    dprintf(("%ld: PyThread_free_lock(%p) called\n",\r
             PyThread_get_thread_ident(),aLock));\r
\r
#if defined(PYCC_GCC)\r
    if (aLock) {\r
        _fmutex_close((_fmutex *)aLock);\r
        free((_fmutex *)aLock);\r
    }\r
#else\r
    DosCloseEventSem(lock->changed);\r
    free(aLock);\r
#endif\r
}\r
\r
/*\r
 * Return 1 on success if the lock was acquired\r
 *\r
 * and 0 if the lock was not acquired.\r
 */\r
int\r
PyThread_acquire_lock(PyThread_type_lock aLock, int waitflag)\r
{\r
#if !defined(PYCC_GCC)\r
    int   done = 0;\r
    ULONG count;\r
    PID   pid = 0;\r
    TID   tid = 0;\r
    type_os2_lock lock = (type_os2_lock)aLock;\r
#endif\r
\r
    dprintf(("%ld: PyThread_acquire_lock(%p, %d) called\n",\r
             PyThread_get_thread_ident(),\r
             aLock,\r
             waitflag));\r
\r
#if defined(PYCC_GCC)\r
    /* always successful if the lock doesn't exist */\r
    if (aLock &&\r
        _fmutex_request((_fmutex *)aLock, waitflag ? 0 : _FMR_NOWAIT))\r
        return 0;\r
#else\r
    while (!done) {\r
        /* if the lock is currently set, we have to wait for\r
         * the state to change\r
         */\r
        if (lock->is_set) {\r
            if (!waitflag)\r
                return 0;\r
            DosWaitEventSem(lock->changed, SEM_INDEFINITE_WAIT);\r
        }\r
\r
        /* enter a critical section and try to get the semaphore.  If\r
         * it is still locked, we will try again.\r
         */\r
        if (DosEnterCritSec())\r
            return 0;\r
\r
        if (!lock->is_set) {\r
            lock->is_set = 1;\r
            DosResetEventSem(lock->changed, &count);\r
            done = 1;\r
        }\r
\r
        DosExitCritSec();\r
    }\r
#endif\r
\r
    return 1;\r
}\r
\r
void\r
PyThread_release_lock(PyThread_type_lock aLock)\r
{\r
#if !defined(PYCC_GCC)\r
    type_os2_lock lock = (type_os2_lock)aLock;\r
#endif\r
\r
    dprintf(("%ld: PyThread_release_lock(%p) called\n",\r
             PyThread_get_thread_ident(),\r
             aLock));\r
\r
#if defined(PYCC_GCC)\r
    if (aLock)\r
        _fmutex_release((_fmutex *)aLock);\r
#else\r
    if (!lock->is_set) {\r
        dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n",\r
                 PyThread_get_thread_ident(),\r
                 aLock,\r
                 GetLastError()));\r
        return;\r
    }\r
\r
    if (DosEnterCritSec()) {\r
        dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n",\r
                 PyThread_get_thread_ident(),\r
                 aLock,\r
                 GetLastError()));\r
        return;\r
    }\r
\r
    lock->is_set = 0;\r
    DosPostEventSem(lock->changed);\r
\r
    DosExitCritSec();\r
#endif\r
}\r
\r
/* minimum/maximum thread stack sizes supported */\r
#define THREAD_MIN_STACKSIZE    0x8000          /* 32kB */\r
#define THREAD_MAX_STACKSIZE    0x2000000       /* 32MB */\r
\r
/* set the thread stack size.\r
 * Return 0 if size is valid, -1 otherwise.\r
 */\r
static int\r
_pythread_os2_set_stacksize(size_t size)\r
{\r
    /* set to default */\r
    if (size == 0) {\r
        _pythread_stacksize = 0;\r
        return 0;\r
    }\r
\r
    /* valid range? */\r
    if (size >= THREAD_MIN_STACKSIZE && size < THREAD_MAX_STACKSIZE) {\r
        _pythread_stacksize = size;\r
        return 0;\r
    }\r
\r
    return -1;\r
}\r
\r
#define THREAD_SET_STACKSIZE(x) _pythread_os2_set_stacksize(x)\r