Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-02-22 08:25:03 +00:00
Code Issues Projects Releases Packages Wiki Activity

[NTOSKRNL] Implement ExfAcquireRundownProtectionCacheAware(), ExfReleaseRundownProtectionCacheAware()

Browse source
This commit is contained in:
Pierre Schweitzer 2018-11-17 15:25:26 +01:00
parent 47d309b262
commit 7e36e76d5d
No known key found for this signature in database
GPG key ID: 7545556C3D585B0B
1 changed files with 46 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
ntoskrnl/ex/rundown.c
View file

@ -378,15 +378,35 @@ ExfWaitForRundownProtectionRelease(IN PEX_RUNDOWN_REF RunRef)
/* FIXME: STUBS **************************************************************/
/*
* @unimplemented NT5.2
* @implemented NT5.2
*/
BOOLEAN
FASTCALL
ExfAcquireRundownProtectionCacheAware(IN PEX_RUNDOWN_REF_CACHE_AWARE RunRefCacheAware)
{
DBG_UNREFERENCED_PARAMETER(RunRefCacheAware);
UNIMPLEMENTED;
return FALSE;
ULONG Value;
BOOLEAN Acquired;
PEX_RUNDOWN_REF RunRef;
RunRef = (PEX_RUNDOWN_REF)((ULONG_PTR)RunRefCacheAware->RunRefs +
RunRefCacheAware->RunRefSize *
(KeGetCurrentProcessorNumber() % RunRefCacheAware->Number));
/* Get current value */
Value = RunRef->Count & !EX_RUNDOWN_ACTIVE;
/* Try to acquire the quick way if already active */
if (ExpChangeRundown(RunRef,
((RunRef->Count & !EX_RUNDOWN_ACTIVE) + EX_RUNDOWN_COUNT_INC),
Value) == Value)
{
Acquired = 1;
}
else
{
Acquired = ExfAcquireRundownProtection(RunRef);
}
return Acquired;
}
/*
@ -404,14 +424,33 @@ ExfAcquireRundownProtectionCacheAwareEx(IN PEX_RUNDOWN_REF_CACHE_AWARE RunRefCac
}
/*
* @unimplemented NT5.2
* @implemented NT5.2
*/
VOID
FASTCALL
ExfReleaseRundownProtectionCacheAware(IN PEX_RUNDOWN_REF_CACHE_AWARE RunRefCacheAware)
{
DBG_UNREFERENCED_PARAMETER(RunRefCacheAware);
UNIMPLEMENTED;
ULONG Value;
PEX_RUNDOWN_REF RunRef;
RunRef = (PEX_RUNDOWN_REF)((ULONG_PTR)RunRefCacheAware->RunRefs +
RunRefCacheAware->RunRefSize *
(KeGetCurrentProcessorNumber() % RunRefCacheAware->Number));
/* Get current value */
Value = RunRef->Count & !EX_RUNDOWN_ACTIVE;
/* Try to release the quick way if multiple actived */
if (ExpChangeRundown(RunRef,
((RunRef->Count & !EX_RUNDOWN_ACTIVE) - EX_RUNDOWN_COUNT_INC),
Value) == Value)
{
/* Sanity check */
ASSERT((Value >= EX_RUNDOWN_COUNT_INC) || (KeNumberProcessors > 1));
}
else
{
ExfReleaseRundownProtection(RunRef);
}
}
/*