source/Standard Gaming Platform/Mutex Manager.cpp

#ifdef JA2_PRECOMPILED_HEADERS
	#include "JA2 SGP ALL.H"
#elif defined( WIZ8_PRECOMPILED_HEADERS )
	#include "WIZ8 SGP ALL.H"
#else
	#include "Mutex Manager.h"
	#include "debug.h"
#endif
//#define __MUTEX_TYPE

#ifdef __MUTEX_TYPE

//
// Use defines to allocate slots in the mutex manager. Put these defines in LOCAL.H
//

HANDLE MutexTable[MAX_MUTEX_HANDLES];

BOOLEAN InitializeMutexManager(void)
{
	UINT32 uiIndex;

	//
	// Register the Mutex Manager debug topic
	//

	RegisterDebugTopic(TOPIC_MUTEX, "Mutex Manager");
	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "Initializing the Mutex Manager");

	//
	// Initialize the table of mutex handles to NULL
	//

	for (uiIndex = 0; uiIndex < MAX_MUTEX_HANDLES; uiIndex++)
	{
	MutexTable[uiIndex] = NULL;
	}

	return TRUE;
}

void ShutdownMutexManager(void)
{
	UINT32 uiIndex;

	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "Shutting down the Mutex Manager");

	//
	// Make sure all mutex handles are closed
	//

	for (uiIndex = 0; uiIndex < MAX_MUTEX_HANDLES; uiIndex++)
	{
	if (MutexTable[uiIndex] != NULL)
	{
		CloseHandle(MutexTable[uiIndex]);
		MutexTable[uiIndex] = NULL;
	}
	}

	UnRegisterDebugTopic(TOPIC_MUTEX, "Mutex Manager");
}

BOOLEAN InitializeMutex(UINT32 uiMutexIndex, UINT8 *ubMutexName)
{
	MutexTable[uiMutexIndex] = CreateMutex(NULL, FALSE, ubMutexName);
	if (MutexTable[uiMutexIndex] == NULL)
	{
	//
	// Mutex creation has failed.
	//
	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Mutex initialization has failed.");
	return FALSE;
	}

	return TRUE;
}

BOOLEAN DeleteMutex(UINT32 uiMutexIndex)
{
	if (MutexTable[uiMutexIndex] == NULL)
	{
	//
	// Hum ?? We just tried to initialize a mutex entry which doesn't have a reserved slot
	//

	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Mutex cannot be deleted since it does not exit");
	return FALSE;
	}

	if (CloseHandle(MutexTable[uiMutexIndex]) == FALSE)
	{
	//
	// Hum, the mutex deletion has failed
	//

	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Mutex cannot be deleted since it does not exit");
	return FALSE;
	}

	MutexTable[uiMutexIndex] = NULL;

	return TRUE;
}

BOOLEAN EnterMutex(UINT32 uiMutexIndex, INT32 nLine, STR8 szFilename)
{
	switch (WaitForSingleObject(MutexTable[uiMutexIndex], INFINITE))
	{
	case WAIT_OBJECT_0
	: return TRUE;
	case WAIT_TIMEOUT
	: DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Possible infinite loop detected due to enter mutex timeout");
		return FALSE;
	case WAIT_ABANDONED
	: DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Abandoned mutex has been found");
		return FALSE;
	}
}

BOOLEAN EnterMutexWithTimeout(UINT32 uiMutexIndex, UINT32 uiTimeout, INT32 nLine, STR8 szFilename)
{
	switch (WaitForSingleObject(MutexTable[uiMutexIndex], uiTimeout))
	{
	case WAIT_OBJECT_0
	: return TRUE;
	case WAIT_TIMEOUT
	: return FALSE;
	case WAIT_ABANDONED
	: return FALSE;
	}
	return TRUE;
}

BOOLEAN LeaveMutex(UINT32 uiMutexIndex, INT32 nLine, STR8 szFilename)
{
	if (ReleaseMutex(MutexTable[uiMutexIndex]) == FALSE)
	{
	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "ERROR : Failed to leave mutex");
	return FALSE;
	}

	return TRUE;
}

#else

//
// Use defines to allocate slots in the mutex manager. Put these defines in LOCAL.H
//

CRITICAL_SECTION MutexTable[MAX_MUTEX_HANDLES];

BOOLEAN InitializeMutexManager(void)
{
	UINT32 uiIndex;

	//
	// Make sure all mutex handles are opened
	//

	for (uiIndex = 0; uiIndex < MAX_MUTEX_HANDLES; uiIndex++)
	{
	InitializeCriticalSection(&MutexTable[uiIndex]);
	}

	RegisterDebugTopic(TOPIC_MUTEX, "Mutex Manager");

	return TRUE;
}

void ShutdownMutexManager(void)
{
	UINT32 uiIndex;

	DbgMessage(TOPIC_MUTEX, DBG_LEVEL_0, "Shutting down the Mutex Manager");

	//
	// Make sure all mutex handles are closed
	//

	for (uiIndex = 0; uiIndex < MAX_MUTEX_HANDLES; uiIndex++)
	{
	DeleteCriticalSection(&MutexTable[uiIndex]);
	}

	UnRegisterDebugTopic(TOPIC_MUTEX, "Mutex Manager");
}

BOOLEAN InitializeMutex(UINT32 uiMutexIndex, UINT8 *ubMutexName)
{
	//InitializeCriticalSection(&MutexTable[uiMutexIndex]);

	return TRUE;
}

BOOLEAN DeleteMutex(UINT32 uiMutexIndex)
{
	//DeleteCriticalSection(&MutexTable[uiMutexIndex]);

	return TRUE;
}

BOOLEAN EnterMutex(UINT32 uiMutexIndex, INT32 nLine, STR8 szFilename)
{
	EnterCriticalSection(&MutexTable[uiMutexIndex]);
	return TRUE;
}

BOOLEAN EnterMutexWithTimeout(UINT32 uiMutexIndex, UINT32 uiTimeout, INT32 nLine, STR8 szFilename)
{
	EnterCriticalSection(&MutexTable[uiMutexIndex]);
	return TRUE;
}

BOOLEAN LeaveMutex(UINT32 uiMutexIndex, INT32 nLine, STR8 szFilename)
{
	LeaveCriticalSection(&MutexTable[uiMutexIndex]);

	return TRUE;
}

#endif