SMKM_STORE_MGR::SmFeStoreEvictKeys
INT64 __fastcall SMKM_STORE_MGR::SmFeStoreEvictKeys(__int64 a1, unsigned int *a2, int a3){
unsigned int v3;
int v6;
int v7;
_ETHREAD *CurrentThread;
__int64 v9;
__int64 v10;
__int64 v11;
unsigned __int64 v12;
__int64 v13;
__int64 v14;
_ETHREAD *v15;
unsigned int SessionId;
char v17;
int v18;
unsigned __int64 v19;
bool v20;
__int64 v21;
__int64 v22;
int v24;
__int128 v25;
__int64 v26[3];
int v27;
int v28;
__int64 v29;
INT64 result[17];
v3 = *a2;
memset((INT64)result, 0i64);
v26[1] = 0i64;
v26[2] = 0i64;
v6 = 0;
v29 = 0i64;
v27 = 0;
v26[0] = (__int64)result;
v28 = 8;
v7 = 1;
CurrentThread = (_ETHREAD *)KeGetCurrentThread();
v25 = 0i64;
--*((_WORD *)CurrentThread + 243);
v9 = a1 + 440;
ExAcquirePushLockExclusiveEx(a1 + 440, 0i64);
v10 = v25;
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(
a1 + 448,
v3,
(__int64)v26);
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)&v25,
(__int64)v26);
v10 = v25;
v7 = 0;
}
if( v10 )
{
v12 = *((_QWORD *)&v25 + 1) + 8i64;
v13 = (unsigned __int16)*(_DWORD *)v10 + 2i64;
*((_QWORD *)&v25 + 1) = v12;
if( v12 >= v10 + 8 * v13 )
{
v14 = *(_QWORD *)(v10 + 8);
if( v14 )
{
*(_QWORD *)&v25 = *(_QWORD *)(v10 + 8);
*((_QWORD *)&v25 + 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(a1, (__int64)v26, (__int64 *)&v25);
v10 = v25;
v7 = 1;
}
if( ++v6 == a3 )
break;
++v3;
}
if( (_InterlockedExchangeAdd64((volatile signed __int64 *)v9, 0xFFFFFFFFFFFFFFFFui64) & 6) == 2 )
ExfTryToWakePushLock((volatile INT64 *)(a1 + 440));
v24 = 0;
v15 = (_ETHREAD *)KeGetCurrentThread();
if( (unsigned int)MiGetSystemRegionType(a1 + 440) == 1 )
SessionId = MmGetSessionIdEx(*((_QWORD *)v15 + 23));
else
SessionId = -1;
--*((_WORD *)v15 + 243);
v17 = ++*((_BYTE *)v15 + 794);
v18 = (*((char *)v15 + 792) | *((char *)v15 + 870)) ^ 0x3F;
while( 1 )
{
v20 = !_BitScanReverse((unsigned int *)&v21, v18);
if( v20 )
goto LABEL_26;
v19 = *((_QWORD *)v15 + 100) + 96 * v21;
v18 &= ~(1 << v21);
if( (*(_BYTE *)(v19 + 26) & 1) != 0
&& (*(_DWORD *)(v19 + 32) & 1) == 0
&& (*(_QWORD *)(v19 + 32) & 0x7FFFFFFFFFFFFFFCi64) == (v9 & 0x7FFFFFFFFFFFFFFCi64)
&& *(_DWORD *)(v19 + 40) == SessionId )
{
*(_BYTE *)(v19 + 26) &= ~1u;
if( *(_QWORD *)(v19 + 32) )
break;
}
}
if( !v19 )
{
LABEL_26:
if( (*((_DWORD *)v15 + 30) & 0x10000) == 0 )
KeBugCheckEx(0x162u, (ULONG_PTR)v15, v9, SessionId, 0i64);
goto LABEL_33;
}
*(_BYTE *)(v19 + 32) |= 2u;
if( *(__int64 *)(v19 + 32) < 0 )
KiAbEntryRemoveFromTree(v19);
v24 = *(_DWORD *)(v19 + 88) & 0x1FFFF;
*(_DWORD *)(v19 + 88) &= 0xFFFE0000;
*(_BYTE *)(v19 + 25) &= ~1u;
*(_QWORD *)(v19 + 32) = 0i64;
v22 = (__int64)(v19 - *((_QWORD *)v15 + 100)) / 96;
if( v17 == 1 )
*((_BYTE *)v15 + 792) |= 1 << v22;
else
_InterlockedOr8((volatile signed __int8 *)v15 + 870, 1 << v22);
LABEL_33:
--*((_BYTE *)v15 + 794);
KiAbThreadRemoveBoosts((ULONG_PTR)v15, v9, (unsigned int *)&v24);
v20 = (*((_WORD *)v15 + 243))++ == 0xFFFF;
if( v20 && *((_ETHREAD **)v15 + 19) != (_ETHREAD *)((char *)v15 + 152) )
KiCheckForKernelApcDelivery();
return KiLeaveGuardedRegionUnsafe((__int64)KeGetCurrentThread());
}
Referenced by:
No references.