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

[NTOS:MM]

Browse source 
- Keep track of physical pages allocated for special pool, and respect the initially calculated MiSpecialPagesNonPagedMaximum

svn path=/trunk/; revision=71304
This commit is contained in:
Thomas Faber 2016-05-10 11:47:05 +00:00
parent bbc880b695
commit 1ebef466b4
1 changed files with 40 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

44
reactos/ntoskrnl/mm/ARM3/special.c
View file

@ -44,8 +44,12 @@ PMMPTE MiSpecialPoolFirstPte;
PMMPTE MiSpecialPoolLastPte; PMMPTE MiSpecialPoolLastPte;
PFN_COUNT MmSpecialPagesInUse; PFN_COUNT MmSpecialPagesInUse;
PFN_COUNT MmSpecialPagesInUsePeak;
PFN_COUNT MiSpecialPagesPagable;
PFN_COUNT MiSpecialPagesPagablePeak;
PFN_COUNT MiSpecialPagesNonPaged; PFN_COUNT MiSpecialPagesNonPaged;
PFN_NUMBER MiSpecialPagesNonPagedMaximum; PFN_COUNT MiSpecialPagesNonPagedPeak;
PFN_COUNT MiSpecialPagesNonPagedMaximum;
BOOLEAN MmSpecialPoolCatchOverruns = TRUE; BOOLEAN MmSpecialPoolCatchOverruns = TRUE;
@ -135,7 +139,9 @@ MiInitializeSpecialPool(VOID)
/* Reserve those PTEs */ /* Reserve those PTEs */
do do
{ {
PointerPte = MiReserveAlignedSystemPtes(SpecialPoolPtes, 0, /*0x400000*/0); // FIXME: PointerPte = MiReserveAlignedSystemPtes(SpecialPoolPtes,
SystemPteSpace,
/*0x400000*/0); // FIXME:
if (PointerPte) break; if (PointerPte) break;
/* Reserving didn't work, so try to reduce the requested size */ /* Reserving didn't work, so try to reduce the requested size */
@ -238,6 +244,7 @@ MmAllocateSpecialPool(SIZE_T NumberOfBytes, ULONG Tag, POOL_TYPE PoolType, ULONG
LARGE_INTEGER TickCount; LARGE_INTEGER TickCount;
PVOID Entry; PVOID Entry;
PPOOL_HEADER Header; PPOOL_HEADER Header;
PFN_COUNT PagesInUse;
DPRINT("MmAllocateSpecialPool(%x %x %x %x)\n", NumberOfBytes, Tag, PoolType, SpecialType); DPRINT("MmAllocateSpecialPool(%x %x %x %x)\n", NumberOfBytes, Tag, PoolType, SpecialType);
@ -262,8 +269,13 @@ MmAllocateSpecialPool(SIZE_T NumberOfBytes, ULONG Tag, POOL_TYPE PoolType, ULONG
} }
/* TODO: Take into account various limitations */ /* TODO: Take into account various limitations */
/*if ((PoolType != NonPagedPool) &&
MiSpecialPagesNonPaged > MiSpecialPagesNonPagedMaximum)*/ /* Heed the maximum limit of nonpaged pages */
if ((PoolType == NonPagedPool) &&
(MiSpecialPagesNonPaged > MiSpecialPagesNonPagedMaximum))
{
return NULL;
}
/* Lock PFN database */ /* Lock PFN database */
Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock); Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock);
@ -311,6 +323,11 @@ MmAllocateSpecialPool(SIZE_T NumberOfBytes, ULONG Tag, POOL_TYPE PoolType, ULONG
/* Release the PFN database lock */ /* Release the PFN database lock */
KeReleaseQueuedSpinLock(LockQueuePfnLock, Irql); KeReleaseQueuedSpinLock(LockQueuePfnLock, Irql);
/* Increase page counter */
PagesInUse = InterlockedIncrementUL(&MmSpecialPagesInUse);
if (PagesInUse > MmSpecialPagesInUsePeak)
MmSpecialPagesInUsePeak = PagesInUse;
/* Put some content into the page. Low value of tick count would do */ /* Put some content into the page. Low value of tick count would do */
Entry = MiPteToAddress(PointerPte); Entry = MiPteToAddress(PointerPte);
RtlFillMemory(Entry, PAGE_SIZE, TickCount.LowPart); RtlFillMemory(Entry, PAGE_SIZE, TickCount.LowPart);
@ -347,11 +364,21 @@ MmAllocateSpecialPool(SIZE_T NumberOfBytes, ULONG Tag, POOL_TYPE PoolType, ULONG
/* Also mark the next PTE as special-pool-paged */ /* Also mark the next PTE as special-pool-paged */
PointerPte[1].u.Soft.PageFileHigh |= SPECIAL_POOL_PAGED_PTE; PointerPte[1].u.Soft.PageFileHigh |= SPECIAL_POOL_PAGED_PTE;
/* Increase pagable counter */
PagesInUse = InterlockedIncrementUL(&MiSpecialPagesPagable);
if (PagesInUse > MiSpecialPagesPagablePeak)
MiSpecialPagesPagablePeak = PagesInUse;
} }
else else
{ {
/* Mark the next PTE as special-pool-nonpaged */ /* Mark the next PTE as special-pool-nonpaged */
PointerPte[1].u.Soft.PageFileHigh |= SPECIAL_POOL_NONPAGED_PTE; PointerPte[1].u.Soft.PageFileHigh |= SPECIAL_POOL_NONPAGED_PTE;
/* Increase nonpaged counter */
PagesInUse = InterlockedIncrementUL(&MiSpecialPagesNonPaged);
if (PagesInUse > MiSpecialPagesNonPagedPeak)
MiSpecialPagesNonPagedPeak = PagesInUse;
} }
/* Finally save tag and put allocation time into the header's blocksize. /* Finally save tag and put allocation time into the header's blocksize.
@ -547,6 +574,9 @@ MmFreeSpecialPool(PVOID P)
/* Non pagable. Get PFN element corresponding to the PTE */ /* Non pagable. Get PFN element corresponding to the PTE */
Pfn = MI_PFN_ELEMENT(PointerPte->u.Hard.PageFrameNumber); Pfn = MI_PFN_ELEMENT(PointerPte->u.Hard.PageFrameNumber);
/* Count the page as free */
InterlockedDecrementUL(&MiSpecialPagesNonPaged);
/* Lock PFN database */ /* Lock PFN database */
Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock); Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock);
@ -567,6 +597,9 @@ MmFreeSpecialPool(PVOID P)
/* Pagable. Delete that virtual address */ /* Pagable. Delete that virtual address */
MiDeleteSystemPageableVm(PointerPte, 1, 0, NULL); MiDeleteSystemPageableVm(PointerPte, 1, 0, NULL);
/* Count the page as free */
InterlockedDecrementUL(&MiSpecialPagesPagable);
/* Lock PFN database */ /* Lock PFN database */
Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock); Irql = KeAcquireQueuedSpinLock(LockQueuePfnLock);
} }
@ -586,6 +619,9 @@ MmFreeSpecialPool(PVOID P)
/* Release the PFN database lock */ /* Release the PFN database lock */
KeReleaseQueuedSpinLock(LockQueuePfnLock, Irql); KeReleaseQueuedSpinLock(LockQueuePfnLock, Irql);
/* Update page counter */
InterlockedDecrementUL(&MmSpecialPagesInUse);
} }
VOID VOID