SimpleMutex.cpp

Go to the documentation of this file.

#include "SimpleMutex.h"
#include "RakAssert.h"

SimpleMutex::SimpleMutex() //: isInitialized(false)
{
        // Prior implementation of Initializing in Lock() was not threadsafe
        Init();
}

SimpleMutex::~SimpleMutex()
{
//      if (isInitialized==false)
//              return;
#ifdef _WIN32
        //      CloseHandle(hMutex);
        DeleteCriticalSection(&criticalSection);
#else
        pthread_mutex_destroy(&hMutex);
#endif
}

#ifdef _WIN32
#ifdef _DEBUG
#include <stdio.h>
#endif
#endif

void SimpleMutex::Lock(void)
{
//      if (isInitialized==false)
//              Init();

#ifdef _WIN32
        /*
        DWORD d = WaitForSingleObject(hMutex, INFINITE);
        #ifdef _DEBUG
        if (d==WAIT_FAILED)
        {
        LPVOID messageBuffer;
        FormatMessage(
        FORMAT_MESSAGE_ALLOCATE_BUFFER |
        FORMAT_MESSAGE_FROM_SYSTEM |
        FORMAT_MESSAGE_IGNORE_INSERTS,
        NULL,
        GetLastError(),
        MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), // Default language
        (LPTSTR) &messageBuffer,
        0,
        NULL
        );
        // Process any inserts in messageBuffer.
        // ...
        // Display the string.
        //MessageBox( NULL, (LPCTSTR)messageBuffer, "Error", MB_OK | MB_ICONINFORMATION );
        RAKNET_DEBUG_PRINTF("SimpleMutex error: %s", messageBuffer);
        // Free the buffer.
        LocalFree( messageBuffer );

        }

        RakAssert(d==WAIT_OBJECT_0);
        */
        EnterCriticalSection(&criticalSection);

#else
        int error = pthread_mutex_lock(&hMutex);
        (void) error;
        RakAssert(error==0);
#endif
}

void SimpleMutex::Unlock(void)
{
//      if (isInitialized==false)
//              return;
#ifdef _WIN32
        //      ReleaseMutex(hMutex);
        LeaveCriticalSection(&criticalSection);
#else
        int error = pthread_mutex_unlock(&hMutex);
        (void) error;
        RakAssert(error==0);
#endif
}

void SimpleMutex::Init(void)
{
#ifdef _WIN32
        //      hMutex = CreateMutex(NULL, FALSE, 0);
        //      RakAssert(hMutex);
        InitializeCriticalSection(&criticalSection);
#else
        int error = pthread_mutex_init(&hMutex, 0);
        (void) error;
        RakAssert(error==0);
#endif
//      isInitialized=true;
}