// Copyright 2011-2019 Molecular Matters GmbH, all rights reserved.

#include "LC_InterprocessMutex.h"
#include "LC_Logging.h"
#include "Windows/WindowsHWrapper.h"


InterprocessMutex::InterprocessMutex(const wchar_t* name)
	: m_mutex(::CreateMutexW(NULL, Windows::FALSE, name))
{
}


InterprocessMutex::~InterprocessMutex(void)
{
	::CloseHandle(m_mutex);
}


void InterprocessMutex::Lock(void)
{
	const DWORD result = ::WaitForSingleObject(m_mutex, INFINITE);
	switch (result)
	{
		case WAIT_OBJECT_0:
			// mutex was successfully signaled
			break;

		case WAIT_TIMEOUT:
			// the operation timed out, which should never happen with a timeout of INFINITE
			LC_ERROR_DEV("Mutex timed out.");
			break;

		case WAIT_ABANDONED:
			LC_ERROR_DEV("Wait() was called on a stale mutex which was not released by the owning thread.");
			break;

		case WAIT_FAILED:
			LC_ERROR_DEV("Failed to Wait() on a mutex.");
			break;

		default:
			break;
	}
}


void InterprocessMutex::Unlock(void)
{
	::ReleaseMutex(m_mutex);
}