semevent-posix.cpp revision 2e42e0850e182e37277fe28ba5b5d1c37018e783
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/* $Id$ */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** @file
5b281ba489ca18f0380d7efc7a5108b606cce449vboxsync * IPRT - Event Semaphore, POSIX.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/*
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync * Copyright (C) 2006-2010 Sun Microsystems, Inc.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync *
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * available from http://www.virtualbox.org. This file is free software;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * you can redistribute it and/or modify it under the terms of the GNU
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * General Public License (GPL) as published by the Free Software
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync *
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * The contents of this file may alternatively be used under the terms
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * of the Common Development and Distribution License Version 1.0
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * VirtualBox OSE distribution, in which case the provisions of the
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * CDDL are applicable instead of those of the GPL.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync *
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * You may elect to license modified versions of this file under the
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * terms and conditions of either the GPL or the CDDL or both.
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync *
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * Clara, CA 95054 USA or visit http://www.sun.com if you need
1c94c0a63ba68be1a7b2c640e70d7a06464e4fcavboxsync * additional information or have any questions.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/*******************************************************************************
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync* Header Files *
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync*******************************************************************************/
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <iprt/semaphore.h>
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#include "internal/iprt.h"
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <iprt/asm.h>
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#include <iprt/assert.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <iprt/err.h>
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#include <iprt/mem.h>
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#include <iprt/lockvalidator.h>
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#include "internal/strict.h"
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <errno.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <pthread.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <unistd.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#include <sys/time.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#ifdef RT_OS_DARWIN
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync# define pthread_yield() pthread_yield_np()
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#ifdef RT_OS_SOLARIS
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync# include <sched.h>
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync# define pthread_yield() sched_yield()
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/*******************************************************************************
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync* Structures and Typedefs *
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync*******************************************************************************/
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** Internal representation of the POSIX implementation of an Event semaphore.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * The POSIX implementation uses a mutex and a condition variable to implement
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * the automatic reset event semaphore semantics.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsyncstruct RTSEMEVENTINTERNAL
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /** pthread condition. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_cond_t Cond;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /** pthread mutex which protects the condition and the event state. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_mutex_t Mutex;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /** The state of the semaphore.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * This is operated while owning mutex and using atomic updating. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync volatile uint32_t u32State;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /** Number of waiters. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync volatile uint32_t cWaiters;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync /** Signallers. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTLOCKVALRECSHRD Signallers;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync /** Indicates that lock validation should be performed. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync bool volatile fEverHadSignallers;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync};
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** The valus of the u32State variable in a RTSEMEVENTINTERNAL.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * @{ */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** The object isn't initialized. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#define EVENT_STATE_UNINITIALIZED 0
b3109af8dcc2a3da7f424aa05a4e84a64bf1c43fvboxsync/** The semaphore is signaled. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#define EVENT_STATE_SIGNALED 0xff00ff00
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** The semaphore is not signaled. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#define EVENT_STATE_NOT_SIGNALED 0x00ff00ff
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync/** @} */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsyncRTDECL(int) RTSemEventCreate(PRTSEMEVENT phEventSem)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync return RTSemEventCreateEx(phEventSem, 0 /*fFlags*/, NIL_RTLOCKVALCLASS, NULL);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync}
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsyncRTDECL(int) RTSemEventCreateEx(PRTSEMEVENT phEventSem, uint32_t fFlags, RTLOCKVALCLASS hClass, const char *pszNameFmt, ...)
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync{
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertReturn(!(fFlags & ~RTSEMEVENT_FLAGS_NO_LOCK_VAL), VERR_INVALID_PARAMETER);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Allocate semaphore handle.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync int rc;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync struct RTSEMEVENTINTERNAL *pThis = (struct RTSEMEVENTINTERNAL *)RTMemAlloc(sizeof(struct RTSEMEVENTINTERNAL));
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Create the condition variable.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_condattr_t CondAttr;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync rc = pthread_condattr_init(&CondAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (!rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_init(&pThis->Cond, &CondAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (!rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Create the semaphore.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_mutexattr_t MutexAttr;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync rc = pthread_mutexattr_init(&MutexAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (!rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_init(&pThis->Mutex, &MutexAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (!rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_mutexattr_destroy(&MutexAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_condattr_destroy(&CondAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->u32State, EVENT_STATE_NOT_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->cWaiters, 0);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync if (!pszNameFmt)
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync {
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync static uint32_t volatile s_iSemEventAnon = 0;
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync RTLockValidatorRecSharedInit(&pThis->Signallers, hClass, RTLOCKVAL_SUB_CLASS_ANY, pThis,
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync true /*fSignaller*/, !(fFlags & RTSEMEVENT_FLAGS_NO_LOCK_VAL),
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync "RTSemEvent-%u", ASMAtomicIncU32(&s_iSemEventAnon) - 1);
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync }
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync else
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync {
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync va_list va;
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync va_start(va, pszNameFmt);
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync RTLockValidatorRecSharedInitV(&pThis->Signallers, hClass, RTLOCKVAL_SUB_CLASS_ANY, pThis,
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync true /*fSignaller*/, !(fFlags & RTSEMEVENT_FLAGS_NO_LOCK_VAL),
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync pszNameFmt, va);
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync va_end(va);
2e42e0850e182e37277fe28ba5b5d1c37018e783vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync pThis->fEverHadSignallers = false;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync *phEventSem = pThis;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VINF_SUCCESS;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_mutexattr_destroy(&MutexAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync pthread_cond_destroy(&pThis->Cond);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_condattr_destroy(&CondAttr);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync rc = RTErrConvertFromErrno(rc);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTMemFree(pThis);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync else
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync rc = VERR_NO_MEMORY;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return rc;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsyncRTDECL(int) RTSemEventDestroy(RTSEMEVENT hEventSem)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Validate handle.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync if (pThis == NIL_RTSEMEVENT)
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync return VINF_SUCCESS;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturn(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED, VERR_INVALID_HANDLE);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Abort all waiters forcing them to return failure.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync int rc;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync for (int i = 30; i > 0; i--)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->u32State, EVENT_STATE_UNINITIALIZED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_destroy(&pThis->Cond);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc != EBUSY)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync break;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync pthread_cond_broadcast(&pThis->Cond);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync usleep(1000);
2c44f485771ff1ffffd3d9e614f8406e33a90701vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsgFailed(("Failed to destroy event sem %p, rc=%d.\n", pThis, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Destroy the semaphore
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * If it's busy we'll wait a bit to give the threads a chance to be scheduled.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync for (int i = 30; i > 0; i--)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_destroy(&pThis->Mutex);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc != EBUSY)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync break;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync usleep(1000);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsgFailed(("Failed to destroy event sem %p, rc=%d. (mutex)\n", pThis, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Free the semaphore memory and be gone.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTLockValidatorRecSharedDelete(&pThis->Signallers);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTMemFree(pThis);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VINF_SUCCESS;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsyncRTDECL(int) RTSemEventSignal(RTSEMEVENT hEventSem)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Validate input.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturn(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED, VERR_INVALID_HANDLE);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->fEverHadSignallers)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc9 = RTLockValidatorRecSharedCheckSignaller(&pThis->Signallers, NIL_RTTHREAD);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (RT_FAILURE(rc9))
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync return rc9;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Lock the mutex semaphore.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc = pthread_mutex_lock(&pThis->Mutex);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsgFailed(("Failed to lock event sem %p, rc=%d.\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Check the state.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->u32State == EVENT_STATE_NOT_SIGNALED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->u32State, EVENT_STATE_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_signal(&pThis->Cond);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to signal event sem %p, rc=%d.\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync else if (pThis->u32State == EVENT_STATE_SIGNALED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_signal(&pThis->Cond); /* give'm another kick... */
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to signal event sem %p, rc=%d. (2)\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync else
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync rc = VERR_SEM_DESTROYED;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Release the mutex and return.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc2 = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc2, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc2)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc2);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VINF_SUCCESS;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsyncDECL_FORCE_INLINE(int) rtSemEventWait(RTSEMEVENT hEventSem, RTMSINTERVAL cMillies, bool fAutoResume)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync PCRTLOCKVALSRCPOS pSrcPos = NULL;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Validate input.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturn(pThis, VERR_INVALID_HANDLE);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturn(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED, VERR_INVALID_HANDLE);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Timed or indefinite wait?
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (cMillies == RT_INDEFINITE_WAIT)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* for fairness, yield before going to sleep. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if ( ASMAtomicIncU32(&pThis->cWaiters) > 1
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync && pThis->u32State == EVENT_STATE_SIGNALED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_yield();
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* take mutex */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc = pthread_mutex_lock(&pThis->Mutex);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsgFailed(("Failed to lock event sem %p, rc=%d.\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync for (;;)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* check state. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->u32State == EVENT_STATE_SIGNALED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->u32State, EVENT_STATE_NOT_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc)); NOREF(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VINF_SUCCESS;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->u32State == EVENT_STATE_UNINITIALIZED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc)); NOREF(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VERR_SEM_DESTROYED;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* wait */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTTHREAD hThreadSelf = RTThreadSelfAutoAdopt();
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->fEverHadSignallers)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = RTLockValidatorRecSharedCheckBlocking(&pThis->Signallers, hThreadSelf, pSrcPos, false,
2805b95732a8d26015a397626b96049a6e6573e7vboxsync cMillies, RTTHREADSTATE_EVENT, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (RT_FAILURE(rc))
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync pthread_mutex_unlock(&pThis->Mutex);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync return rc;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#else
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTTHREAD hThreadSelf = RTThreadSelf();
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTThreadBlocking(hThreadSelf, RTTHREADSTATE_EVENT, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_wait(&pThis->Cond, &pThis->Mutex);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTThreadUnblocked(hThreadSelf, RTTHREADSTATE_EVENT);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsgFailed(("Failed to wait on event sem %p, rc=%d.\n", hEventSem, rc));
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc2 = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc2, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc2)); NOREF(rc2);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync else
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /*
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync * Get current time and calc end of wait time.
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync struct timespec ts = {0,0};
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#ifdef RT_OS_DARWIN
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync struct timeval tv = {0,0};
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync gettimeofday(&tv, NULL);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_sec = tv.tv_sec;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_nsec = tv.tv_usec * 1000;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#else
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync clock_gettime(CLOCK_REALTIME, &ts);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync#endif
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (cMillies != 0)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_nsec += (cMillies % 1000) * 1000000;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_sec += cMillies / 1000;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (ts.tv_nsec >= 1000000000)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_nsec -= 1000000000;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync ts.tv_sec++;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* for fairness, yield before going to sleep. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (ASMAtomicIncU32(&pThis->cWaiters) > 1 && cMillies)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync pthread_yield();
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* take mutex */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc = pthread_mutex_lock(&pThis->Mutex);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(rc == ETIMEDOUT, ("Failed to lock event sem %p, rc=%d.\n", hEventSem, rc));
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync for (;;)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* check state. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->u32State == EVENT_STATE_SIGNALED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicXchgU32(&pThis->u32State, EVENT_STATE_NOT_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc)); NOREF(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VINF_SUCCESS;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->u32State == EVENT_STATE_UNINITIALIZED)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc, ("Failed to unlock event sem %p, rc=%d.\n", hEventSem, rc)); NOREF(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return VERR_SEM_DESTROYED;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync /* we're done if the timeout is 0. */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (!cMillies)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_mutex_unlock(&pThis->Mutex);
75a0540cb8c3cca698de583260c62e496041a3a5vboxsync return VERR_TIMEOUT;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync /* wait */
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTTHREAD hThreadSelf = RTThreadSelfAutoAdopt();
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (pThis->fEverHadSignallers)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = RTLockValidatorRecSharedCheckBlocking(&pThis->Signallers, hThreadSelf, pSrcPos, false,
2805b95732a8d26015a397626b96049a6e6573e7vboxsync cMillies, RTTHREADSTATE_EVENT, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync if (RT_FAILURE(rc))
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync {
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync pthread_mutex_unlock(&pThis->Mutex);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync return rc;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync }
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#else
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTTHREAD hThreadSelf = RTThreadSelf();
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTThreadBlocking(hThreadSelf, RTTHREADSTATE_EVENT, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync rc = pthread_cond_timedwait(&pThis->Cond, &pThis->Mutex, &ts);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTThreadUnblocked(hThreadSelf, RTTHREADSTATE_EVENT);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync if (rc && (rc != EINTR || !fAutoResume)) /* according to SuS this function shall not return EINTR, but linux man page says differently. */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync {
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(rc == ETIMEDOUT, ("Failed to wait on event sem %p, rc=%d.\n", hEventSem, rc));
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicDecU32(&pThis->cWaiters);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync int rc2 = pthread_mutex_unlock(&pThis->Mutex);
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync AssertMsg(!rc2, ("Failed to unlock event sem %p, rc2=%d.\n", hEventSem, rc2)); NOREF(rc2);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return RTErrConvertFromErrno(rc);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync } /* for (;;) */
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync }
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsyncRTDECL(int) RTSemEventWait(RTSEMEVENT hEventSem, RTMSINTERVAL cMillies)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync int rc = rtSemEventWait(hEventSem, cMillies, true);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync Assert(rc != VERR_INTERRUPTED);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync return rc;
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
b79e4344bf4eb8033fd06d560cd864192728bd0bvboxsyncRTDECL(int) RTSemEventWaitNoResume(RTSEMEVENT hEventSem, RTMSINTERVAL cMillies)
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync{
a734bb626f889ee3334bfc381be194b4ec56aae6vboxsync return rtSemEventWait(hEventSem, cMillies, false);
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync}
9e5c26690d45216629b5f588aced8fcfb68c23b6vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsyncRTDECL(void) RTSemEventSetSignaller(RTSEMEVENT hEventSem, RTTHREAD hThread)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync{
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturnVoid(pThis);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturnVoid(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicWriteBool(&pThis->fEverHadSignallers, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTLockValidatorRecSharedResetOwner(&pThis->Signallers, hThread, NULL);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync}
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsyncRTDECL(void) RTSemEventAddSignaller(RTSEMEVENT hEventSem, RTTHREAD hThread)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync{
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturnVoid(pThis);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturnVoid(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync ASMAtomicWriteBool(&pThis->fEverHadSignallers, true);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTLockValidatorRecSharedAddOwner(&pThis->Signallers, hThread, NULL);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync}
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsyncRTDECL(void) RTSemEventRemoveSignaller(RTSEMEVENT hEventSem, RTTHREAD hThread)
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync{
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#ifdef RTSEMEVENT_STRICT
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync struct RTSEMEVENTINTERNAL *pThis = hEventSem;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertPtrReturnVoid(pThis);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync uint32_t u32 = pThis->u32State;
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync AssertReturnVoid(u32 == EVENT_STATE_NOT_SIGNALED || u32 == EVENT_STATE_SIGNALED);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync RTLockValidatorRecSharedRemoveOwner(&pThis->Signallers, hThread);
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync#endif
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync}
0fcf82b2591711fa8980e8f5d9cad1b8f222d6d7vboxsync