jeanlemotan
98 lines
1.8 KiB
C++
98 lines
1.8 KiB
C++
///////////////////////////////////////////////////////////////////////////////
|
|
// Copyright (c) Lewis Baker
|
|
// Licenced under MIT license. See LICENSE.txt for details.
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
|
|
#include "auto_reset_event.hpp"
|
|
|
|
#if CPPCORO_OS_WINNT
|
|
# define WIN32_LEAN_AND_MEAN
|
|
# include <Windows.h>
|
|
# include <system_error>
|
|
#endif
|
|
|
|
namespace cppcoro
|
|
{
|
|
#if CPPCORO_OS_WINNT
|
|
|
|
auto_reset_event::auto_reset_event(bool initiallySet)
|
|
: m_event(::CreateEventW(NULL, FALSE, initiallySet ? TRUE : FALSE, NULL))
|
|
{
|
|
if (m_event.handle() == NULL)
|
|
{
|
|
DWORD errorCode = ::GetLastError();
|
|
throw std::system_error
|
|
{
|
|
static_cast<int>(errorCode),
|
|
std::system_category(),
|
|
"auto_reset_event: CreateEvent failed"
|
|
};
|
|
}
|
|
}
|
|
|
|
auto_reset_event::~auto_reset_event()
|
|
{
|
|
}
|
|
|
|
void auto_reset_event::set()
|
|
{
|
|
BOOL ok =::SetEvent(m_event.handle());
|
|
if (!ok)
|
|
{
|
|
DWORD errorCode = ::GetLastError();
|
|
throw std::system_error
|
|
{
|
|
static_cast<int>(errorCode),
|
|
std::system_category(),
|
|
"auto_reset_event: SetEvent failed"
|
|
};
|
|
}
|
|
}
|
|
|
|
void auto_reset_event::wait()
|
|
{
|
|
DWORD result = ::WaitForSingleObjectEx(m_event.handle(), INFINITE, FALSE);
|
|
if (result != WAIT_OBJECT_0)
|
|
{
|
|
DWORD errorCode = ::GetLastError();
|
|
throw std::system_error
|
|
{
|
|
static_cast<int>(errorCode),
|
|
std::system_category(),
|
|
"auto_reset_event: WaitForSingleObjectEx failed"
|
|
};
|
|
}
|
|
}
|
|
|
|
#else
|
|
|
|
auto_reset_event::auto_reset_event(bool initiallySet)
|
|
: m_isSet(initiallySet)
|
|
{}
|
|
|
|
auto_reset_event::~auto_reset_event()
|
|
{}
|
|
|
|
void auto_reset_event::set()
|
|
{
|
|
std::unique_lock lock{ m_mutex };
|
|
if (!m_isSet)
|
|
{
|
|
m_isSet = true;
|
|
m_cv.notify_one();
|
|
}
|
|
}
|
|
|
|
void auto_reset_event::wait()
|
|
{
|
|
std::unique_lock lock{ m_mutex };
|
|
while (!m_isSet)
|
|
{
|
|
m_cv.wait(lock);
|
|
}
|
|
m_isSet = false;
|
|
}
|
|
|
|
#endif
|
|
}
|