r0drv/freebsd/semeventmulti-r0drv-freebsd.c

	semeventmulti-r0drv-freebsd.c revision ab93606043a9881487aa83be04191d2f4ea24071
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/* $Id$ */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/** @file
5b281ba489ca18f0380d7efc7a5108b606cce449vboxsync * IPRT - Multiple Release Event Semaphores, Ring-0 Driver, FreeBSD.
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/*
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * Copyright (c) 2007 knut st. osmundsen <bird-src-spam@anduin.net>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync *
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * Permission is hereby granted, free of charge, to any person
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * obtaining a copy of this software and associated documentation
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * files (the "Software"), to deal in the Software without
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * restriction, including without limitation the rights to use,
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * copy, modify, merge, publish, distribute, sublicense, and/or sell
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * copies of the Software, and to permit persons to whom the
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * Software is furnished to do so, subject to the following
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * conditions:
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync *
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * The above copyright notice and this permission notice shall be
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * included in all copies or substantial portions of the Software.
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync *
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * OTHER DEALINGS IN THE SOFTWARE.
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/*******************************************************************************
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync*   Header Files                                                               *
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync*******************************************************************************/
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include "the-freebsd-kernel.h"
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include <iprt/semaphore.h>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include <iprt/alloc.h>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include <iprt/asm.h>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include <iprt/assert.h>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include <iprt/err.h>
fea595114d685c0f865a710172df95896f08d47bvboxsync#include <iprt/spinlock.h>
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync#include "internal/magics.h"
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/*******************************************************************************
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync*   Structures and Typedefs                                                    *
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync*******************************************************************************/
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync/**
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync * FreeBSD multiple release event semaphore.
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsynctypedef struct RTSEMEVENTMULTIINTERNAL
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    /** Magic value (RTSEMEVENTMULTI_MAGIC). */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    uint32_t volatile   u32Magic;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    /** The number of waiting threads. */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    uint32_t volatile   cWaiters;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    /** Set if the event object is signaled. */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    uint8_t volatile    fSignaled;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    /** The number of threads in the process of waking up. */
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    uint32_t volatile   cWaking;
fea595114d685c0f865a710172df95896f08d47bvboxsync    /** Spinlock protecting this structure. */
fea595114d685c0f865a710172df95896f08d47bvboxsync    RTSPINLOCK          hSpinLock;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync} RTSEMEVENTMULTIINTERNAL, *PRTSEMEVENTMULTIINTERNAL;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiCreate(PRTSEMEVENTMULTI phEventMultiSem)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    return RTSemEventMultiCreateEx(phEventMultiSem, 0 /*fFlags*/, NIL_RTLOCKVALCLASS, NULL);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync}
ab93606043a9881487aa83be04191d2f4ea24071vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiCreateEx(PRTSEMEVENTMULTI phEventMultiSem, uint32_t fFlags, RTLOCKVALCLASS hClass,
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                                     const char *pszNameFmt, ...)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync{
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertCompile(sizeof(RTSEMEVENTMULTIINTERNAL) > sizeof(void *));
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertReturn(!(fFlags & ~RTSEMEVENTMULTI_FLAGS_NO_LOCK_VAL), VERR_INVALID_PARAMETER);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertPtrReturn(phEventMultiSem, VERR_INVALID_POINTER);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    PRTSEMEVENTMULTIINTERNAL pThis = (PRTSEMEVENTMULTIINTERNAL)RTMemAllocZ(sizeof(*pThis));
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    if (pThis)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        pThis->u32Magic = RTSEMEVENTMULTI_MAGIC;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        pThis->cWaiters = 0;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        pThis->cWaking = 0;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        pThis->fSignaled = 0;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        int rc = RTSpinlockCreate(&pThis->hSpinLock);
fea595114d685c0f865a710172df95896f08d47bvboxsync        if (RT_SUCCESS(rc))
fea595114d685c0f865a710172df95896f08d47bvboxsync        {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync            *phEventMultiSem = pThis;
fea595114d685c0f865a710172df95896f08d47bvboxsync            return VINF_SUCCESS;
fea595114d685c0f865a710172df95896f08d47bvboxsync        }
fea595114d685c0f865a710172df95896f08d47bvboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTMemFree(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync        return rc;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    return VERR_NO_MEMORY;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiDestroy(RTSEMEVENTMULTI hEventMultiSem)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    PRTSEMEVENTMULTIINTERNAL pThis = (PRTSEMEVENTMULTIINTERNAL)hEventMultiSem;
135d4fd34eb73c299eacfa22c1a864e2aba97fefvboxsync    RTSPINLOCKTMP            Tmp = RTSPINLOCKTMP_INITIALIZER;
fea595114d685c0f865a710172df95896f08d47bvboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    if (pThis == NIL_RTSEMEVENTMULTI)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        return VINF_SUCCESS;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertMsgReturn(pThis->u32Magic == RTSEMEVENTMULTI_MAGIC, ("pThis=%p u32Magic=%#x\n", pThis, pThis->u32Magic), VERR_INVALID_HANDLE);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockAcquire(pThis->hSpinLock, &Tmp);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    ASMAtomicIncU32(&pThis->u32Magic); /* make the handle invalid */
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    if (pThis->cWaiters > 0)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    {
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync        /* abort waiting thread, last man cleans up. */
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        ASMAtomicXchgU32(&pThis->cWaking, pThis->cWaking + pThis->cWaiters);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        sleepq_lock(pThis);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        sleepq_broadcast(pThis, SLEEPQ_CONDVAR, 0, 0);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        sleepq_release(pThis);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTSpinlockRelease(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    }
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    else if (pThis->cWaking)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync        /* the last waking thread is gonna do the cleanup */
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTSpinlockRelease(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    else
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTSpinlockRelease(pThis->hSpinLock, &Tmp);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTSpinlockDestroy(pThis->hSpinLock);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        RTMemFree(pThis);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    return VINF_SUCCESS;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiSignal(RTSEMEVENTMULTI hEventMultiSem)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
135d4fd34eb73c299eacfa22c1a864e2aba97fefvboxsync    RTSPINLOCKTMP            Tmp = RTSPINLOCKTMP_INITIALIZER;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    PRTSEMEVENTMULTIINTERNAL pThis = (PRTSEMEVENTMULTIINTERNAL)hEventMultiSem;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertMsgReturn(pThis->u32Magic == RTSEMEVENTMULTI_MAGIC,
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    ("pThis=%p u32Magic=%#x\n", pThis, pThis->u32Magic),
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                    VERR_INVALID_HANDLE);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockAcquire(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    ASMAtomicXchgU8(&pThis->fSignaled, true);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    if (pThis->cWaiters > 0)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        ASMAtomicXchgU32(&pThis->cWaking, pThis->cWaking + pThis->cWaiters);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        ASMAtomicXchgU32(&pThis->cWaiters, 0);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        sleepq_lock(pThis);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        int fWakeupSwapProc = sleepq_signal(pThis, SLEEPQ_CONDVAR, 0, 0);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync        sleepq_release(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync        if (fWakeupSwapProc)
fea595114d685c0f865a710172df95896f08d47bvboxsync            kick_proc0();
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockRelease(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    return VINF_SUCCESS;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiReset(RTSEMEVENTMULTI hEventMultiSem)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
135d4fd34eb73c299eacfa22c1a864e2aba97fefvboxsync    RTSPINLOCKTMP            Tmp = RTSPINLOCKTMP_INITIALIZER;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    PRTSEMEVENTMULTIINTERNAL pThis = (PRTSEMEVENTMULTIINTERNAL)hEventMultiSem;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertMsgReturn(pThis->u32Magic == RTSEMEVENTMULTI_MAGIC,
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    ("pThis=%p u32Magic=%#x\n", pThis, pThis->u32Magic),
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                    VERR_INVALID_HANDLE);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockAcquire(pThis->hSpinLock, &Tmp);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    ASMAtomicXchgU8(&pThis->fSignaled, false);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockRelease(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    return VINF_SUCCESS;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncstatic int rtSemEventMultiWait(RTSEMEVENTMULTI hEventMultiSem, unsigned cMillies, bool fInterruptible)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    int rc;
135d4fd34eb73c299eacfa22c1a864e2aba97fefvboxsync    RTSPINLOCKTMP            Tmp = RTSPINLOCKTMP_INITIALIZER;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    PRTSEMEVENTMULTIINTERNAL pThis = (PRTSEMEVENTMULTIINTERNAL)hEventMultiSem;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    AssertMsgReturn(pThis->u32Magic == RTSEMEVENTMULTI_MAGIC,
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    ("pThis=%p u32Magic=%#x\n", pThis, pThis->u32Magic),
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                    VERR_INVALID_HANDLE);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockAcquire(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    if (pThis->fSignaled)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync        rc = VINF_SUCCESS;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    else
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    {
fea595114d685c0f865a710172df95896f08d47bvboxsync        if (cMillies == 0)
fea595114d685c0f865a710172df95896f08d47bvboxsync            rc = VERR_TIMEOUT;
fea595114d685c0f865a710172df95896f08d47bvboxsync        else
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync        {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync            ASMAtomicIncU32(&pThis->cWaiters);
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync            int fFlags = SLEEPQ_CONDVAR;
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync            if (fInterruptible)
fea595114d685c0f865a710172df95896f08d47bvboxsync                fFlags |= SLEEPQ_INTERRUPTIBLE;
fea595114d685c0f865a710172df95896f08d47bvboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync            sleepq_lock(pThis);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync            sleepq_add(pThis, NULL, "IPRT Event Semaphore", fFlags, 0);
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync            if (cMillies != RT_INDEFINITE_WAIT)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync            {
fea595114d685c0f865a710172df95896f08d47bvboxsync                /*
fea595114d685c0f865a710172df95896f08d47bvboxsync                 * Translate milliseconds into ticks and go to sleep.
fea595114d685c0f865a710172df95896f08d47bvboxsync                 */
fea595114d685c0f865a710172df95896f08d47bvboxsync                struct timeval tv;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                tv.tv_sec = cMillies / 1000;
fea595114d685c0f865a710172df95896f08d47bvboxsync                tv.tv_usec = (cMillies % 1000) * 1000;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                sleepq_set_timeout(pThis, tvtohz(&tv));
fea595114d685c0f865a710172df95896f08d47bvboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                RTSpinlockRelease(pThis->hSpinLock, &Tmp);
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                if (fInterruptible)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    rc = SLEEPQ_TIMEDWAIT_SIG(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync                else
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    rc = SLEEPQ_TIMEDWAIT(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync            }
fea595114d685c0f865a710172df95896f08d47bvboxsync            else
fea595114d685c0f865a710172df95896f08d47bvboxsync            {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                RTSpinlockRelease(pThis->hSpinLock, &Tmp);
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                if (fInterruptible)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    rc = SLEEPQ_WAIT_SIG(pThis);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                else
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                {
fea595114d685c0f865a710172df95896f08d47bvboxsync                    rc = 0;
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    SLEEPQ_WAIT(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync                }
fea595114d685c0f865a710172df95896f08d47bvboxsync            }
fea595114d685c0f865a710172df95896f08d47bvboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync            RTSpinlockAcquire(pThis->hSpinLock, &Tmp);
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync            switch (rc)
fea595114d685c0f865a710172df95896f08d47bvboxsync            {
fea595114d685c0f865a710172df95896f08d47bvboxsync                case 0:
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    if (pThis->u32Magic == RTSEMEVENTMULTI_MAGIC)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                    {
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                        ASMAtomicDecU32(&pThis->cWaking);
fea595114d685c0f865a710172df95896f08d47bvboxsync                        rc = VINF_SUCCESS;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync                    }
fea595114d685c0f865a710172df95896f08d47bvboxsync                    else
fea595114d685c0f865a710172df95896f08d47bvboxsync                    {
fea595114d685c0f865a710172df95896f08d47bvboxsync                        rc = VERR_SEM_DESTROYED; /** @todo this isn't necessarily correct, we've
fea595114d685c0f865a710172df95896f08d47bvboxsync                                                  * could've woken up just before destruction... */
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                        if (!ASMAtomicDecU32(&pThis->cWaking))
fea595114d685c0f865a710172df95896f08d47bvboxsync                        {
fea595114d685c0f865a710172df95896f08d47bvboxsync                            /* The event was destroyed, as the last thread do the cleanup.
fea595114d685c0f865a710172df95896f08d47bvboxsync                               we don't actually know whether */
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                            RTSpinlockRelease(pThis->hSpinLock, &Tmp);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                            RTSpinlockDestroy(pThis->hSpinLock);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                            RTMemFree(pThis);
fea595114d685c0f865a710172df95896f08d47bvboxsync                            return rc;
fea595114d685c0f865a710172df95896f08d47bvboxsync                        }
fea595114d685c0f865a710172df95896f08d47bvboxsync                    }
fea595114d685c0f865a710172df95896f08d47bvboxsync                    break;
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                case EWOULDBLOCK:
fea595114d685c0f865a710172df95896f08d47bvboxsync                    Assert(cMillies != RT_INDEFINITE_WAIT);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    if (pThis->cWaiters > 0)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                        ASMAtomicDecU32(&pThis->cWaiters);
fea595114d685c0f865a710172df95896f08d47bvboxsync                    rc = VERR_TIMEOUT;
fea595114d685c0f865a710172df95896f08d47bvboxsync                    break;
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                case EINTR:
fea595114d685c0f865a710172df95896f08d47bvboxsync                case ERESTART:
fea595114d685c0f865a710172df95896f08d47bvboxsync                    Assert(fInterruptible);
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                    if (pThis->cWaiters > 0)
ab93606043a9881487aa83be04191d2f4ea24071vboxsync                        ASMAtomicDecU32(&pThis->cWaiters);
fea595114d685c0f865a710172df95896f08d47bvboxsync                    rc = VERR_INTERRUPTED;
fea595114d685c0f865a710172df95896f08d47bvboxsync                    break;
fea595114d685c0f865a710172df95896f08d47bvboxsync
fea595114d685c0f865a710172df95896f08d47bvboxsync                default:
fea595114d685c0f865a710172df95896f08d47bvboxsync                    AssertMsgFailed(("sleepq_* -> %d\n", rc));
fea595114d685c0f865a710172df95896f08d47bvboxsync                    rc = VERR_GENERAL_FAILURE;
fea595114d685c0f865a710172df95896f08d47bvboxsync                    break;
fea595114d685c0f865a710172df95896f08d47bvboxsync            }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync        }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    }
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    RTSpinlockRelease(pThis->hSpinLock, &Tmp);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync    return rc;
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiWait(RTSEMEVENTMULTI hEventMultiSem, unsigned cMillies)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    return rtSemEventMultiWait(hEventMultiSem, cMillies, false /* not interruptible */);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync
ab93606043a9881487aa83be04191d2f4ea24071vboxsyncRTDECL(int)  RTSemEventMultiWaitNoResume(RTSEMEVENTMULTI hEventMultiSem, unsigned cMillies)
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync{
ab93606043a9881487aa83be04191d2f4ea24071vboxsync    return rtSemEventMultiWait(hEventMultiSem, cMillies, true /* interruptible */);
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync}
1f1986470af9f0bb750dd859b142dc2e952deb20vboxsync