rpcs3/Utilities/SSemaphore.cpp

#include "stdafx.h"
#include "Utilities/SSemaphore.h"

void SSemaphore::wait()
{
	u32 order;
	{
		std::lock_guard<std::mutex> lock(m_mutex);
		order = m_in_order++;
	}

	std::unique_lock<std::mutex> cv_lock(m_cv_mutex);
	
	while (true)
	{
		if (Emu.IsStopped())
		{
			return;
		}
		
		m_cond.wait_for(cv_lock, std::chrono::milliseconds(1));

		std::lock_guard<std::mutex> lock(m_mutex);
		if (m_count)
		{
			if (m_out_order == order)
			{
				m_count--;
				m_out_order++;
				return;
			}
			else
			{
				m_cond.notify_one();
			}
		}
	}
}

bool SSemaphore::try_wait()
{
	std::lock_guard<std::mutex> lock(m_mutex);

	// TODO: ordering?
	if (m_count && m_in_order == m_out_order)
	{
		m_count--;
		return true;
	}
	else
	{
		return false;
	}
}

void SSemaphore::post()
{
	std::lock_guard<std::mutex> lock(m_mutex);

	if (m_count >= m_max)
	{
		return;
	}

	m_count++;
	m_cond.notify_one();
}

bool SSemaphore::post_and_wait()
{
	// TODO: ???
	if (try_wait()) return false;

	post();
	wait();

	return true;
}