Changeset 5225 in vbox for trunk/src/VBox/Runtime/r0drv/linux/semevent-r0drv-linux.c

Timestamp:

Oct 10, 2007 3:06:48 PM (17 years ago)

Author:

vboxsync

Message:

semaphore-r0drv-lnx.c split.

File:

• trunk/src/VBox/Runtime/r0drv/linux/semevent-r0drv-linux.c (copied) (copied from trunk/src/VBox/Runtime/r0drv/linux/semaphore-r0drv-linux.c ) (3 diffs)

trunk/src/VBox/Runtime/r0drv/linux/semevent-r0drv-linux.c

@@ -1 +1 @@
 /* $Id$ */
 /** @file
- * innotek Portable Runtime - Semaphores, Ring-0 Driver, Linux.
+ * innotek Portable Runtime - Single Release Event Semaphores, Ring-0 Driver, Linux.
  */
 
@@ -48 +48 @@
 
 
-/**
- * Linux mutex semaphore.
- */
-typedef struct RTSEMMUTEXINTERNAL
-{
-    /** Magic value (RTSEMMUTEX_MAGIC). */
-    uint32_t volatile   u32Magic;
-    /** Number of recursive locks - 0 if not owned by anyone, > 0 if owned. */
-    uint32_t volatile   cRecursion;
-    /** The wait queue. */
-    wait_queue_head_t   Head;
-    /** The current owner. */
-    void * volatile     pOwner;
-} RTSEMMUTEXINTERNAL, *PRTSEMMUTEXINTERNAL;
-
-
-/**
- * Wrapper for the linux semaphore structure.
- */
-typedef struct RTSEMFASTMUTEXINTERNAL
-{
-    /** Magic value (RTSEMFASTMUTEX_MAGIC). */
-    uint32_t            u32Magic;
-    /** the linux semaphore. */
-    struct semaphore    Semaphore;
-} RTSEMFASTMUTEXINTERNAL, *PRTSEMFASTMUTEXINTERNAL;
-
-
-
 
 RTDECL(int)  RTSemEventCreate(PRTSEMEVENT pEventSem)
@@ -233 +204 @@
 }
 
-
-
-RTDECL(int)  RTSemMutexCreate(PRTSEMMUTEX pMutexSem)
-{
-    PRTSEMMUTEXINTERNAL pMutexInt = (PRTSEMMUTEXINTERNAL)RTMemAlloc(sizeof(*pMutexInt));
-    if (pMutexInt)
-    {
-        pMutexInt->u32Magic = RTSEMMUTEX_MAGIC;
-        init_waitqueue_head(&pMutexInt->Head);
-        *pMutexSem = pMutexInt;
-AssertReleaseMsgFailed(("This mutex implementation is buggy, fix it!\n"));
-        return VINF_SUCCESS;
-    }
-    return VERR_NO_MEMORY;
-}
-
-
-RTDECL(int)  RTSemMutexDestroy(RTSEMMUTEX MutexSem)
-{
-    /*
-     * Validate input.
-     */
-    PRTSEMMUTEXINTERNAL pMutexInt = (PRTSEMMUTEXINTERNAL)MutexSem;
-    if (!pMutexInt)
-        return VERR_INVALID_PARAMETER;
-    if (pMutexInt->u32Magic != RTSEMMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pMutexInt->u32Magic=%RX32 pMutexInt=%p\n", pMutexInt->u32Magic, pMutexInt));
-        return VERR_INVALID_PARAMETER;
-    }
-
-    /*
-     * Invalidate it and signal the object just in case.
-     */
-    ASMAtomicIncU32(&pMutexInt->u32Magic);
-    ASMAtomicXchgU32(&pMutexInt->cRecursion, 0);
-    Assert(!waitqueue_active(&pMutexInt->Head));
-    wake_up_all(&pMutexInt->Head);
-    RTMemFree(pMutexInt);
-    return VINF_SUCCESS;
-}
-
-
-RTDECL(int)  RTSemMutexRequest(RTSEMMUTEX MutexSem, unsigned cMillies)
-{
-    /*
-     * Validate input.
-     */
-    PRTSEMMUTEXINTERNAL pMutexInt = (PRTSEMMUTEXINTERNAL)MutexSem;
-    if (!pMutexInt)
-        return VERR_INVALID_PARAMETER;
-    if (    !pMutexInt
-        ||  pMutexInt->u32Magic != RTSEMMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pMutexInt->u32Magic=%RX32 pMutexInt=%p\n", pMutexInt ? pMutexInt->u32Magic : 0, pMutexInt));
-        return VERR_INVALID_PARAMETER;
-    }
-
-    /*
-     * Check for recursive request.
-     */
-    if (pMutexInt->pOwner == current)
-    {
-        Assert(pMutexInt->cRecursion < 1000);
-        ASMAtomicIncU32(&pMutexInt->cRecursion);
-        return VINF_SUCCESS;
-    }
-
-    /*
-     * Try aquire it.
-     */
-    if (ASMAtomicCmpXchgU32(&pMutexInt->cRecursion, 1, 0))
-    {
-        ASMAtomicXchgPtr(&pMutexInt->pOwner, current);
-        return VINF_SUCCESS;
-    }
-    else
-    {
-        /*
-         * Ok wait for it.
-         */
-        DEFINE_WAIT(Wait);
-        int     rc       = VINF_SUCCESS;
-        long    lTimeout = cMillies == RT_INDEFINITE_WAIT ? MAX_SCHEDULE_TIMEOUT : msecs_to_jiffies(cMillies);
-        for (;;)
-        {
-            /* make everything thru schedule() atomic scheduling wise. */
-            prepare_to_wait(&pMutexInt->Head, &Wait, TASK_INTERRUPTIBLE);
-
-            /* check the condition. */
-            if (ASMAtomicCmpXchgU32(&pMutexInt->cRecursion, 1, 0))
-            {
-                ASMAtomicXchgPtr(&pMutexInt->pOwner, current);
-                break;
-            }
-
-            /* check for pending signals. */
-            if (signal_pending(current))
-            {
-                rc = VERR_INTERRUPTED; /** @todo VERR_INTERRUPTED isn't correct anylonger. please fix r0drv stuff! */
-                break;
-            }
-
-            /* wait */
-            lTimeout = schedule_timeout(lTimeout);
-
-            /* Check if someone destroyed the semaphore while we was waiting. */
-            if (pMutexInt->u32Magic != RTSEMMUTEX_MAGIC)
-            {
-                rc = VERR_SEM_DESTROYED;
-                break;
-            }
-
-            /* check for timeout. */
-            if (!lTimeout)
-            {
-                rc = VERR_TIMEOUT;
-                break;
-            }
-        }
-        finish_wait(&pMutexInt->Head, &Wait);
-        return rc;
-    }
-    return VINF_SUCCESS;
-}
-
-
-RTDECL(int)  RTSemMutexRelease(RTSEMMUTEX MutexSem)
-{
-    /*
-     * Validate input.
-     */
-    PRTSEMMUTEXINTERNAL pMutexInt = (PRTSEMMUTEXINTERNAL)MutexSem;
-    if (!pMutexInt)
-        return VERR_INVALID_PARAMETER;
-    if (    !pMutexInt
-        ||  pMutexInt->u32Magic != RTSEMMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pMutexInt->u32Magic=%RX32 pMutexInt=%p\n", pMutexInt ? pMutexInt->u32Magic : 0, pMutexInt));
-        return VERR_INVALID_PARAMETER;
-    }
-    if (pMutexInt->pOwner != current)
-    {
-        AssertMsgFailed(("Not owner, pOwner=%p current=%p\n", (void *)pMutexInt->pOwner, (void *)current));
-        return VERR_NOT_OWNER;
-    }
-
-    /*
-     * Release the mutex.
-     */
-    if (pMutexInt->cRecursion == 1)
-    {
-        ASMAtomicXchgPtr(&pMutexInt->pOwner, NULL);
-        ASMAtomicXchgU32(&pMutexInt->cRecursion, 0);
-    }
-    else
-        ASMAtomicDecU32(&pMutexInt->cRecursion);
-
-    return VINF_SUCCESS;
-}
-
-
-
-RTDECL(int)  RTSemFastMutexCreate(PRTSEMFASTMUTEX pMutexSem)
-{
-    /*
-     * Allocate.
-     */
-    PRTSEMFASTMUTEXINTERNAL pFastInt;
-    pFastInt = (PRTSEMFASTMUTEXINTERNAL)RTMemAlloc(sizeof(*pFastInt));
-    if (!pFastInt)
-        return VERR_NO_MEMORY;
-
-    /*
-     * Initialize.
-     */
-    pFastInt->u32Magic = RTSEMFASTMUTEX_MAGIC;
-    sema_init(&pFastInt->Semaphore, 1);
-    *pMutexSem = pFastInt;
-    return VINF_SUCCESS;
-}
-
-
-RTDECL(int)  RTSemFastMutexDestroy(RTSEMFASTMUTEX MutexSem)
-{
-    /*
-     * Validate.
-     */
-    PRTSEMFASTMUTEXINTERNAL pFastInt = (PRTSEMFASTMUTEXINTERNAL)MutexSem;
-    if (!pFastInt)
-        return VERR_INVALID_PARAMETER;
-    if (pFastInt->u32Magic != RTSEMFASTMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pFastInt->u32Magic=%RX32 pMutexInt=%p\n", pFastInt->u32Magic, pFastInt));
-        return VERR_INVALID_PARAMETER;
-    }
-
-    ASMAtomicIncU32(&pFastInt->u32Magic);
-    RTMemFree(pFastInt);
-    return VINF_SUCCESS;
-}
-
-
-RTDECL(int)  RTSemFastMutexRequest(RTSEMFASTMUTEX MutexSem)
-{
-    /*
-     * Validate.
-     */
-    PRTSEMFASTMUTEXINTERNAL pFastInt = (PRTSEMFASTMUTEXINTERNAL)MutexSem;
-    if (    !pFastInt
-        ||  pFastInt->u32Magic != RTSEMFASTMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pFastInt->u32Magic=%RX32 pMutexInt=%p\n", pFastInt ? pFastInt->u32Magic : 0, pFastInt));
-        return VERR_INVALID_PARAMETER;
-    }
-
-    down(&pFastInt->Semaphore);
-    return VINF_SUCCESS;
-}
-
-
-RTDECL(int)  RTSemFastMutexRelease(RTSEMFASTMUTEX MutexSem)
-{
-    /*
-     * Validate.
-     */
-    PRTSEMFASTMUTEXINTERNAL pFastInt = (PRTSEMFASTMUTEXINTERNAL)MutexSem;
-    if (    !pFastInt
-        ||  pFastInt->u32Magic != RTSEMFASTMUTEX_MAGIC)
-    {
-        AssertMsgFailed(("pFastInt->u32Magic=%RX32 pMutexInt=%p\n", pFastInt ? pFastInt->u32Magic : 0, pFastInt));
-        return VERR_INVALID_PARAMETER;
-    }
-
-    up(&pFastInt->Semaphore);
-    return VINF_SUCCESS;
-}
-