FsRtlAcquireEofLock

void __fastcall FsRtlAcquireEofLock(__int64 a1, volatile signed __int32 *a2){
  _ETHREAD *CurrentThread; 
  __int64 v3; 
  __int64 v5; 
  __int64 v6; 
  char v7; 
  __int64 v8; 
  int SessionId; 
  bool v10; 
  unsigned __int8 CurrentIrql; 
  __int64 v12; 
  unsigned __int64 v13; 
  unsigned __int32 v14; 
  char v15; 
  unsigned int v17; 
  volatile signed __int32 *v18; 
  CurrentThread = (_ETHREAD *)KeGetCurrentThread();
  v17 = 0;
  v3 = *(_QWORD *)(a1 + 24);
  v18 = a2;
  v5 = *(_QWORD *)(v3 + 48);
  --*((_WORD *)CurrentThread + 243);
  if( ++*((_BYTE *)CurrentThread + 794) != 1 )
    KeBugCheckEx(0x192u, (ULONG_PTR)CurrentThread, v5, KeGetCurrentIrql(), 0i64);
  LOBYTE(v6) = *((_BYTE *)CurrentThread + 792);
  if( !(_BYTE)v6 )
  {
    if( !*((_BYTE *)CurrentThread + 870) )
    {
      v8 = 0i64;
      goto LABEL_29;
    }
    v15 = *((_BYTE *)CurrentThread + 870);
    *((_BYTE *)CurrentThread + 870) = 0;
    LOBYTE(v6) = v15 | *((_BYTE *)CurrentThread + 792);
  }
  v7 = v6;
  _BitScanForward((unsigned int *)&v6, (unsigned __int8)v6);
  *((_BYTE *)CurrentThread + 792) = v7 & ~(1 << v6);
  v8 = *((_QWORD *)CurrentThread + 100) + 96 * v6;
  if( !v8 )
  {
LABEL_29:
    _interlockedbittestandset((volatile signed __int32 *)CurrentThread + 30, 0x10u);
    goto LABEL_7;
  }
  if( (unsigned int)MiGetSystemRegionType(v5) == 1 )
    SessionId = MmGetSessionIdEx(*((_QWORD *)CurrentThread + 23));
  else
    SessionId = -1;
  *(_DWORD *)(v8 + 40) = SessionId;
  *(_QWORD *)(v8 + 32) = v5 & 0x7FFFFFFFFFFFFFFCi64;
LABEL_7:
  --*((_BYTE *)CurrentThread + 794);
  KiAbThreadRemoveBoosts((ULONG_PTR)CurrentThread, v5, &v17);
  v10 = (*((_WORD *)CurrentThread + 243))++ == 0xFFFF;
  if( v10 && *((_ETHREAD **)CurrentThread + 19) != (_ETHREAD *)((char *)CurrentThread + 152) )
    KiCheckForKernelApcDelivery();
  CurrentIrql = KeGetCurrentIrql();
  __writecr8(1ui64);
  if( !_interlockedbittestandreset((volatile signed __int32 *)v5, 0) )
    ExpAcquireFastMutexContended((FAST_MUTEX *)v5, (PVOID)v8);
  if( v8 )
    *(_BYTE *)(v8 + 26) |= 1u;
  *(_QWORD *)(v5 + 8) = KeGetCurrentThread();
  *(_DWORD *)(v5 + 48) = CurrentIrql;
  if( v18 )
    _InterlockedIncrement(v18);
  if( *(_ETHREAD **)a1 == CurrentThread )
  {
    ++*(_WORD *)(a1 + 38);
  }
  else if( *(_QWORD *)a1 )
  {
    FsRtlpWaitForIoAtEof(a1, a2, -1i64);
  }
  else
  {
    *(_QWORD *)a1 = CurrentThread;
    *(_WORD *)(a1 + 38) = 1;
  }
  if( a2 )
    _InterlockedIncrement(a2);
  v12 = *(_QWORD *)(*(_QWORD *)(a1 + 24) + 48i64);
  v13 = *(unsigned __int8 *)(v12 + 48);
  *(_QWORD *)(v12 + 8) = 0i64;
  v14 = _InterlockedCompareExchange((volatile signed __int32 *)v12, 1, 0);
  if( v14 )
    ExpReleaseFastMutexContended((FAST_MUTEX *)v12, v14);
  __writecr8(v13);
  KeAbPostRelease((PVOID)v12);
}

Referenced by: