RtlpHpLfhSubsegmentIncBlockCounts
__int64 __fastcall RtlpHpLfhSubsegmentIncBlockCounts(
__int64 a1,
__int64 a2,
unsigned int er8_0,
int a4,
_DWORD *a5,
int a6,
UINT8 *a7){
int v7;
UINT8 v10;
char v11;
__int64 v12;
signed __int16 *v13;
unsigned int v14;
__int64 v15;
int v16;
signed __int16 v17;
__int64 v18;
volatile signed __int64 *v19;
_ETHREAD *CurrentThread;
unsigned int SessionId;
unsigned __int8 v23;
int v24;
bool v25;
__int64 v26;
_KLOCK_ENTRY *v27;
__int64 v28;
signed __int16 v29;
signed __int16 *v30;
__int64 v31;
UINT64 a3;
v7 = a6;
if( a6 )
v10 = *a7;
else
v10 = -1;
v11 = *(_BYTE *)(a2 + 44);
v12 = er8_0 >> v11;
v13 = (signed __int16 *)(2 * v12 + a2 + *(unsigned __int16 *)(a2 + 46));
v31 = 2 * v12;
_m_prefetchw(v13);
v14 = -1;
v30 = &v13[((er8_0 + a4 - 1) >> v11) - (unsigned int)v12 + 1];
LODWORD(v15) = 0;
v16 = 0;
if( v13 < v30 )
{
do
{
while( 2 )
{
v17 = *v13;
while( v17 > 0 )
{
v29 = v17;
v17 = _InterlockedCompareExchange16(v13, v17 + 1, v17);
if( v29 == v17 )
{
v18 = v31;
goto LABEL_10;
}
}
if( !v7 )
{
v7 = 1;
v10 = RtlpHpAcquireLockExclusive((_EX_PUSH_LOCK *)(a2 + 24), *(unsigned __int8 *)(a1 + 57));
continue;
}
break;
}
v18 = v31;
if( v17 )
{
++v16;
v15 = v31 >> 1;
if( v14 == -1 )
v14 = v31 >> 1;
}
else
{
--v16;
}
*v13 = v17 + 1;
LABEL_10:
++v13;
v31 = v18 + 2;
}
while( v13 < v30 );
if( v16 && (RtlpHpLfhPerfFlags & 0x20) != 0 )
_InterlockedExchangeAdd64(
(volatile signed __int64 *)(*(__int16 *)(a1 + 58) + a1 + 24),
(v16 << *(_BYTE *)(a2 + 44)) / 4096);
if( v14 != -1 )
{
v7 = 0;
*a5 = v15 - v14 + 1;
*a7 = v10;
}
}
if( v7 )
{
v19 = (volatile signed __int64 *)(a2 + 24);
if( *(_BYTE *)(a1 + 57) )
{
ExReleaseSpinLockExclusiveFromDpcLevel((INT64 *)(a2 + 24));
__writecr8(v10);
}
else
{
if( (_InterlockedExchangeAdd64(v19, 0xFFFFFFFFFFFFFFFFui64) & 6) == 2 )
ExfTryToWakePushLock((_EX_PUSH_LOCK *)(a2 + 24));
LODWORD(a3) = 0;
CurrentThread = (_ETHREAD *)KeGetCurrentThread();
if( MiGetSystemRegionType(a2 + 24) == 1 )
SessionId = MmGetSessionIdEx(CurrentThread->Tcb.ApcState.Process);
else
SessionId = -1;
--CurrentThread->Tcb.SpecialApcDisable;
v23 = ++CurrentThread->Tcb.AbAllocationRegionCount;
v24 = ((char)CurrentThread->Tcb.AbEntrySummary | (char)CurrentThread->Tcb.AbOrphanedEntrySummary) ^ 0x3F;
while( 1 )
{
v25 = !_BitScanReverse((unsigned int *)&v26, v24);
a6 = v26;
if( v25 )
break;
v27 = &CurrentThread->Tcb.LockEntries[v26];
v24 &= ~(1 << v26);
if( (v27->AcquiredByte & 1) != 0
&& (v27->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 & 1) == 0
&& (v27->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 & 0x7FFFFFFFFFFFFFFCi64) == ((unsigned __int64)v19 & 0x7FFFFFFFFFFFFFFCi64)
&& v27->LockState.SessionId == SessionId )
{
v27->AcquiredByte &= ~1u;
if( v27->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 )
{
if( v27 )
{
v27->CrossThreadReleasableAndBusyByte |= 2u;
if( v27->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 < 0 )
KiAbEntryRemoveFromTree(v27);
LODWORD(a3) = v27->BoostBitmap.AllFields & 0x1FFFF;
v27->BoostBitmap.AllFields &= 0xFFFE0000;
v27->ThreadLocalFlags &= ~1u;
v27->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 = 0i64;
v28 = v27 - CurrentThread->Tcb.LockEntries;
if( v23 == 1 )
CurrentThread->Tcb.AbEntrySummary |= 1 << v28;
else
_InterlockedOr8((volatile signed __int8 *)&CurrentThread->Tcb.AbOrphanedEntrySummary, 1 << v28);
goto LABEL_37;
}
break;
}
}
}
if( (*(&CurrentThread->Tcb.MiscFlags + 1) & 0x10000) == 0 )
KeBugCheckEx(0x162u, CurrentThread, (PVOID)(a2 + 24), (PVOID)SessionId, 0i64);
LABEL_37:
--CurrentThread->Tcb.AbAllocationRegionCount;
KiAbThreadRemoveBoosts(&CurrentThread->Tcb, (VOID *)(a2 + 24), &a3);
v25 = CurrentThread->Tcb.SpecialApcDisable++ == -1;
if( v25
&& ($F25F8C4BA33AF922A5F1AF68CD89DDDF *)CurrentThread->Tcb.ApcState.ApcListHead[0].Flink != &CurrentThread->Tcb.152 )
{
KiCheckForKernelApcDelivery();
}
KiLeaveGuardedRegionUnsafe((__int64)KeGetCurrentThread());
}
}
return v14;
}Referenced by:
RtlpHpLfhSlotAllocate