#include "os/c-api/il2cpp-config-platforms.h"
|
|
#if IL2CPP_THREADS_WIN32
|
|
#include "SemaphoreImpl.h"
|
#include "WindowsHelpers.h"
|
|
namespace il2cpp
|
{
|
namespace os
|
{
|
SemaphoreImpl::SemaphoreImpl(int32_t initialValue, int32_t maximumValue)
|
{
|
#if IL2CPP_THREADS_ALL_ACCESS
|
m_Handle = ::CreateSemaphoreEx(NULL, initialValue, maximumValue, NULL, 0, SEMAPHORE_ALL_ACCESS);
|
#else
|
m_Handle = ::CreateSemaphore(NULL, initialValue, maximumValue, NULL);
|
#endif
|
|
IL2CPP_ASSERT(m_Handle);
|
}
|
|
SemaphoreImpl::~SemaphoreImpl()
|
{
|
IL2CPP_ASSERT(m_Handle);
|
|
::CloseHandle(m_Handle);
|
}
|
|
bool SemaphoreImpl::Post(int32_t releaseCount, int32_t* previousCount)
|
{
|
return ::ReleaseSemaphore(m_Handle, releaseCount, reinterpret_cast<LPLONG>(previousCount)) != 0;
|
}
|
|
WaitStatus SemaphoreImpl::Wait(bool interruptible)
|
{
|
return Wait(INFINITE, interruptible);
|
}
|
|
WaitStatus SemaphoreImpl::Wait(uint32_t ms, bool interruptible)
|
{
|
return il2cpp::os::win::WaitForSingleObjectAndAccountForAPCs(m_Handle, ms, interruptible);
|
}
|
|
void* SemaphoreImpl::GetOSHandle()
|
{
|
return (void*)m_Handle;
|
}
|
}
|
}
|
|
#endif
|
