[*] Added missing this->s

This commit is contained in:
Reece Wilson 2023-09-09 19:46:08 +01:00
parent dfe44317a0
commit 1a4a4ad863
6 changed files with 22 additions and 22 deletions

View File

@ -35,11 +35,11 @@ namespace Aurora::Threading::Primitives
#else
if (ThrdCfg::gPreferNtCondMutexSpinTryLock)
{
return TryLockHeavy();
return this->TryLockHeavy();
}
else
{
return TryLockNoSpin();
return this->TryLockNoSpin();
}
#endif
}
@ -48,7 +48,7 @@ namespace Aurora::Threading::Primitives
{
return DoTryIf([=]()
{
return TryLockNoSpin();
return this->TryLockNoSpin();
});
}

View File

@ -58,13 +58,13 @@ namespace Aurora::Threading::Primitives
{
return DoTryIf([=]()
{
return TryLockNoSpin();
return this->TryLockNoSpin();
});
}
bool MutexImpl::LockMS(AuUInt64 uTimeout)
{
return LockNS(AuMSToNS<AuUInt64>(uTimeout));
return this->LockNS(AuMSToNS<AuUInt64>(uTimeout));
}
bool MutexImpl::LockNS(AuUInt64 uTimeout)

View File

@ -56,11 +56,11 @@ namespace Aurora::Threading::Primitives
{
if (ThrdCfg::gPreferNtMutexSpinTryLock)
{
return TryLockHeavy();
return this->TryLockHeavy();
}
else
{
return TryLockNoSpin();
return this->TryLockNoSpin();
}
}

View File

@ -282,7 +282,7 @@ namespace Aurora::Threading::Primitives
if constexpr (!bIsWriteRecursionAllowed)
{
if (TryLockWrite())
if (this->TryLockWrite())
{
return true;
}
@ -356,7 +356,7 @@ namespace Aurora::Threading::Primitives
{
if constexpr (!bIsWriteRecursionAllowed)
{
if (TryLockWrite())
if (this->TryLockWrite())
{
return true;
}
@ -564,12 +564,12 @@ namespace Aurora::Threading::Primitives
{
return DoTryIf([=]()
{
return TryLockReadNoSpin<true>();
return this->TryLockReadNoSpin<true>();
});
}
else
{
return TryLockReadNoSpin<true>();
return this->TryLockReadNoSpin<true>();
}
}

View File

@ -54,13 +54,13 @@ namespace Aurora::Threading::Primitives
{
return DoTryIf([=]()
{
return TryLockNoSpin();
return this->TryLockNoSpin();
});
}
bool SemaphoreImpl::LockMS(AuUInt64 uTimeout)
{
return LockNS(AuMSToNS<AuUInt64>(uTimeout));
return this->LockNS(AuMSToNS<AuUInt64>(uTimeout));
}
bool SemaphoreImpl::LockNS(AuUInt64 uTimeout)

View File

@ -53,7 +53,7 @@ namespace Aurora::Threading::Primitives
{
return DoTryIf([=]()
{
return TryLockNoSpin();
return this->TryLockNoSpin();
});
}
@ -61,11 +61,11 @@ namespace Aurora::Threading::Primitives
{
if (ThrdCfg::gPreferNtSemaphoreSpinTryLock)
{
return TryLockHeavy();
return this->TryLockHeavy();
}
else
{
return TryLockNoSpin();
return this->TryLockNoSpin();
}
}
@ -76,7 +76,7 @@ namespace Aurora::Threading::Primitives
bool SemaphoreImpl::LockMS(AuUInt64 uTimeout)
{
return LockNS(AuMSToNS<AuUInt64>(uTimeout));
return this->LockNS(AuMSToNS<AuUInt64>(uTimeout));
}
bool SemaphoreImpl::LockNS(AuUInt64 uTimeout)
@ -106,7 +106,7 @@ namespace Aurora::Threading::Primitives
{
static const AuUInt32 kExpect { 0 };
auto pCounter = GetSleepCounter();
auto pCounter = this->GetSleepCounter();
AuAtomicAdd(pCounter, 1u);
bool bStatus = InternalLTSWaitOnAddressHighRes(&this->dwState_, &kExpect, sizeof(kExpect), uEnd);
AuAtomicSub(pCounter, 1u);
@ -123,7 +123,7 @@ namespace Aurora::Threading::Primitives
{
this->mutex.Lock();
while (!TryLockNoSpin())
while (!this->TryLockNoSpin())
{
if (uTimeout != 0)
{
@ -163,7 +163,7 @@ namespace Aurora::Threading::Primitives
{
static const AuUInt32 kExpect { 0 };
auto pCounter = GetSleepCounter();
auto pCounter = this->GetSleepCounter();
AuAtomicAdd(pCounter, 1u);
bool bStatus = InternalLTSWaitOnAddressHighRes(&this->dwState_, &kExpect, sizeof(kExpect), qwTimeoutAbs);
AuAtomicSub(pCounter, 1u);
@ -180,7 +180,7 @@ namespace Aurora::Threading::Primitives
{
this->mutex.Lock();
while (!TryLockNoSpin())
while (!this->TryLockNoSpin())
{
if (qwTimeoutAbs != 0)
{
@ -217,7 +217,7 @@ namespace Aurora::Threading::Primitives
{
AuAtomicAdd<AuUInt32>(&this->dwState_, count);
if (AuAtomicLoad(GetSleepCounter()))
if (AuAtomicLoad(this->GetSleepCounter()))
{
if (count == 1)
{