SMKM_STORE_MGR::SmFeStoreEvictKeys
void __fastcall SMKM_STORE_MGR::SmFeStoreEvictKeys(_EX_PUSH_LOCK *a1, unsigned int *a2, int er8_0){
unsigned int v3;
int v6;
int v7;
_ETHREAD *CurrentThread;
unsigned __int64 v9;
__int64 v10;
__int64 v11;
unsigned __int64 v12;
__int64 v13;
__int64 v14;
_ETHREAD *v15;
unsigned int SessionId;
unsigned __int8 v17;
int v18;
_KLOCK_ENTRY *v19;
bool v20;
__int64 v21;
__int64 v22;
int a3;
__int128 a3_4;
__int64 v25[3];
int v26;
int v27;
__int64 v28;
char v29[136];
v3 = *a2;
memset(v29, 0i64, 0x80u);
v25[1] = 0i64;
v25[2] = 0i64;
v6 = 0;
v28 = 0i64;
v26 = 0;
v25[0] = (__int64)v29;
v27 = 8;
v7 = 1;
CurrentThread = (_ETHREAD *)KeGetCurrentThread();
a3_4 = 0i64;
--CurrentThread->Tcb.SpecialApcDisable;
v9 = (unsigned __int64)&a1[55];
ExAcquirePushLockExclusiveEx(a1 + 55, 0i64);
v10 = a3_4;
while( 1 )
{
if( v7 )
{
B_TREE<_SM_PAGE_KEY,SMKM_STORE_MGR::SMKM_FRONTEND_ENTRY,4096,B_TREE_DUMMY_NODE_POOL,B_TREE_KEY_COMPARATOR<_SM_PAGE_KEY>>::BTreeSearchKey(
(__int64)&a1[56],
v3,
(__int64)v25);
B_TREE<_SM_PAGE_KEY,SMKM_STORE_MGR::SMKM_FRONTEND_ENTRY,4096,B_TREE_DUMMY_NODE_POOL,B_TREE_KEY_COMPARATOR<_SM_PAGE_KEY>>::BTreeIteratorFromSearchResult(
v11,
(__int64)&a3_4,
(__int64)v25);
v10 = a3_4;
v7 = 0;
}
if( v10 )
{
v12 = *((_QWORD *)&a3_4 + 1) + 8i64;
v13 = (unsigned __int16)*(_DWORD *)v10 + 2i64;
*((_QWORD *)&a3_4 + 1) = v12;
if( v12 >= v10 + 8 * v13 )
{
v14 = *(_QWORD *)(v10 + 8);
if( v14 )
{
*(_QWORD *)&a3_4 = *(_QWORD *)(v10 + 8);
*((_QWORD *)&a3_4 + 1) = v14 + 16;
v10 = v14;
}
v12 = (v14 + 16) & -(__int64)(v14 != 0);
}
}
else
{
v12 = 0i64;
}
if( *(_BYTE *)(v12 + 6) == 3 )
{
*(_BYTE *)(v12 + 6) = 0;
SMKM_STORE_MGR::SmFeDeleteEntry((__int64)a1, (__int64)v25, (__int64 *)&a3_4);
v10 = a3_4;
v7 = 1;
}
if( ++v6 == er8_0 )
break;
++v3;
}
if( (_InterlockedExchangeAdd64((volatile signed __int64 *)v9, 0xFFFFFFFFFFFFFFFFui64) & 6) == 2 )
ExfTryToWakePushLock(a1 + 55);
a3 = 0;
v15 = (_ETHREAD *)KeGetCurrentThread();
if( MiGetSystemRegionType((UINT64)&a1[55]) == 1 )
SessionId = MmGetSessionIdEx(v15->Tcb.ApcState.Process);
else
SessionId = -1;
--v15->Tcb.SpecialApcDisable;
v17 = ++v15->Tcb.AbAllocationRegionCount;
v18 = ((char)v15->Tcb.AbEntrySummary | (char)v15->Tcb.AbOrphanedEntrySummary) ^ 0x3F;
while( 1 )
{
v20 = !_BitScanReverse((unsigned int *)&v21, v18);
if( v20 )
goto LABEL_26;
v19 = &v15->Tcb.LockEntries[v21];
v18 &= ~(1 << v21);
if( (v19->AcquiredByte & 1) != 0
&& (v19->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 & 1) == 0
&& (v19->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 & 0x7FFFFFFFFFFFFFFCi64) == (v9 & 0x7FFFFFFFFFFFFFFCi64)
&& v19->LockState.SessionId == SessionId )
{
v19->AcquiredByte &= ~1u;
if( v19->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 )
break;
}
}
if( !v19 )
{
LABEL_26:
if( (*(&v15->Tcb.MiscFlags + 1) & 0x10000) == 0 )
KeBugCheckEx(0x162u, v15, (PVOID)v9, (PVOID)SessionId, 0i64);
goto LABEL_33;
}
v19->CrossThreadReleasableAndBusyByte |= 2u;
if( v19->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 < 0 )
KiAbEntryRemoveFromTree(v19);
a3 = v19->BoostBitmap.AllFields & 0x1FFFF;
v19->BoostBitmap.AllFields &= 0xFFFE0000;
v19->ThreadLocalFlags &= ~1u;
v19->LockState.$E8276A2CF8B819ED32D1B6FEB35D730A::_bf_0 = 0i64;
v22 = v19 - v15->Tcb.LockEntries;
if( v17 == 1 )
v15->Tcb.AbEntrySummary |= 1 << v22;
else
_InterlockedOr8((volatile signed __int8 *)&v15->Tcb.AbOrphanedEntrySummary, 1 << v22);
LABEL_33:
--v15->Tcb.AbAllocationRegionCount;
KiAbThreadRemoveBoosts(&v15->Tcb, (VOID *)v9, (UINT64 *)&a3);
v20 = v15->Tcb.SpecialApcDisable++ == -1;
if( v20 && ($F25F8C4BA33AF922A5F1AF68CD89DDDF *)v15->Tcb.ApcState.ApcListHead[0].Flink != &v15->Tcb.152 )
KiCheckForKernelApcDelivery();
KiLeaveGuardedRegionUnsafe((__int64)KeGetCurrentThread());
}
Referenced by:
No references.