#include "os/c-api/il2cpp-config-platforms.h"
|
|
#if IL2CPP_THREADS_PTHREAD && !IL2CPP_TINY_WITHOUT_DEBUGGER
|
|
#include "MutexImpl.h"
|
#include "PosixHelpers.h"
|
#include "os/Thread.h"
|
|
namespace il2cpp
|
{
|
namespace os
|
{
|
MutexImpl::MutexImpl()
|
: posix::PosixWaitObject(kMutex)
|
, m_OwningThread(NULL)
|
, m_RecursionCount(0)
|
{
|
// For a mutex, 1 means unlocked.
|
m_Count = 1;
|
}
|
|
void MutexImpl::Lock(bool interruptible)
|
{
|
TryLock(posix::kNoTimeout, interruptible);
|
}
|
|
bool MutexImpl::TryLock(uint32_t milliseconds, bool interruptible)
|
{
|
Thread* currentThread = Thread::GetCurrentThread();
|
if (m_OwningThread == currentThread)
|
{
|
IL2CPP_ASSERT(m_Count == 0);
|
++m_RecursionCount;
|
return true;
|
}
|
|
if (Wait(milliseconds, interruptible) == kWaitStatusSuccess)
|
{
|
m_OwningThread = currentThread;
|
m_RecursionCount = 1;
|
return true;
|
}
|
|
return false;
|
}
|
|
void MutexImpl::Unlock()
|
{
|
IL2CPP_ASSERT(m_OwningThread == Thread::GetCurrentThread());
|
|
// Undo one locking level.
|
--m_RecursionCount;
|
if (m_RecursionCount > 0)
|
{
|
// Still locked.
|
return;
|
}
|
|
// Ok, we're releasing the mutex. Lock and signal. We don't absolutely
|
// need the lock as we are already owning the mutex here but play it safe.
|
posix::PosixAutoLock lock(&m_Mutex);
|
|
IL2CPP_ASSERT(m_Count == 0);
|
m_Count = 1; // Unintuitive but 1 means unlocked.
|
m_OwningThread = NULL;
|
|
// Signal condition so that either a thread that's already waiting or a thread that
|
// comes around later and waits can claim the mutex.
|
if (HaveWaitingThreads())
|
pthread_cond_signal(&m_Condition);
|
}
|
}
|
}
|
|
#endif
|
