lockimpl.cpp

Go to the documentation of this file.

/* SPDX-License-Identifier: MIT */
#include "ajabase/system/windows/lockimpl.h"
#include "ajabase/system/debug.h"


// class AJALockImpl

AJALockImpl::AJALockImpl(const char* pName)
{
    // initialize the windows lock
    mMutex = CreateMutex(NULL, FALSE, pName);
}


AJALockImpl::~AJALockImpl()
{
    // delete the windows lock
    if(mMutex != NULL)
    {
        CloseHandle(mMutex);
    }
}


AJAStatus
AJALockImpl::Lock(uint32_t timeout)
{
    if (mMutex == NULL)
    {
        return AJA_STATUS_INITIALIZE;
    }

    // check for infinite timeout
    if (timeout == 0xffffffff)
    {
        timeout = INFINITE;
    }

    // obtain the lock
    DWORD retCode = WaitForSingleObject(mMutex, (DWORD)timeout);

    // we got the lock
    if (retCode == WAIT_OBJECT_0)
    {
        return AJA_STATUS_SUCCESS;
    }
    // the wait timed out
    else if (retCode == WAIT_TIMEOUT)
    {
        return AJA_STATUS_TIMEOUT;
    }

    // some type of error occurred
    AJA_REPORT(0, AJA_DebugSeverity_Error, "AJALock::Lock WaitForSingleObject() returns error %08x", retCode);

    return AJA_STATUS_FAIL;
}


AJAStatus
AJALockImpl::Unlock()
{
    if (mMutex == NULL)
    {
        return AJA_STATUS_INITIALIZE;
    }

    // release the lock
    DWORD retCode = ReleaseMutex(mMutex);

    return AJA_STATUS_SUCCESS;
}