Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-04-04 12:39:35 +00:00
Code Issues Projects Releases Packages Wiki Activity

- Implement delay-close worker function.

Browse source 
See issue #3418 for more details.

svn path=/trunk/; revision=36051
This commit is contained in:
Aleksey Bragin 2008-09-08 12:41:30 +00:00
parent 4a66766bc1
commit 3be0b4bebf
1 changed files with 123 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

125
reactos/ntoskrnl/config/cmdelay.c
View file

@ -54,13 +54,134 @@ VOID
NTAPI
CmpDelayCloseWorker(IN PVOID Context)
{
PCM_DELAYED_CLOSE_ENTRY ListEntry;
ULONG i, ConvKey;
PAGED_CODE();
/* Sanity check */
ASSERT(CmpDelayCloseWorkItemActive);
/* FIXME: TODO */
ASSERT(FALSE);
/* Lock the registry */
CmpLockRegistry();
/* Acquire the delayed close table lock */
KeAcquireGuardedMutex(&CmpDelayedCloseTableLock);
/* Iterate */
for (i = 0; i < (CmpDelayedCloseSize >> 2); i++)
{
/* Break out of the loop if there is nothing to process */
if (CmpDelayedCloseElements <= CmpDelayedCloseSize) break;
/* Sanity check */
ASSERT(!IsListEmpty(&CmpDelayedLRUListHead));
/* Get the entry */
ListEntry = CONTAINING_RECORD(CmpDelayedLRUListHead.Blink,
CM_DELAYED_CLOSE_ENTRY,
DelayedLRUList);
/* Save the ConvKey value of the KCB */
ConvKey = ListEntry->KeyControlBlock->ConvKey;
/* Release the delayed close table lock */
KeReleaseGuardedMutex(&CmpDelayedCloseTableLock);
/* Acquire the KCB lock */
CmpAcquireKcbLockExclusiveByKey(ConvKey);
/* Reacquire the delayed close table lock */
KeAcquireGuardedMutex(&CmpDelayedCloseTableLock);
/* Get the entry */
ListEntry = CONTAINING_RECORD(CmpDelayedLRUListHead.Blink,
CM_DELAYED_CLOSE_ENTRY,
DelayedLRUList);
/* Is the entry we have still the first one? */
if (CmpDelayedCloseElements <= CmpDelayedCloseSize)
{
/* No, someone already inserted an entry there */
CmpReleaseKcbLockByKey(ConvKey);
break;
}
/* Is it a different entry? */
if (ConvKey != ListEntry->KeyControlBlock->ConvKey)
{
/* Release the delayed close table lock */
KeReleaseGuardedMutex(&CmpDelayedCloseTableLock);
/* Release the KCB lock */
CmpReleaseKcbLockByKey(ConvKey);
/* Reacquire the delayed close table lock */
KeAcquireGuardedMutex(&CmpDelayedCloseTableLock);
/* Iterate again */
continue;
}
/* Remove it from the end of the list */
ListEntry =
(PCM_DELAYED_CLOSE_ENTRY)RemoveTailList(&CmpDelayedLRUListHead);
/* Get the containing entry */
ListEntry = CONTAINING_RECORD(ListEntry,
CM_DELAYED_CLOSE_ENTRY,
DelayedLRUList);
/* Process the entry */
if ((ListEntry->KeyControlBlock->RefCount) ||
(ListEntry->KeyControlBlock->DelayedCloseIndex))
{
/* Add it to the beginning of the list */
InsertHeadList(&CmpDelayedLRUListHead, &ListEntry->DelayedLRUList);
/* Release the delayed close table lock */
KeReleaseGuardedMutex(&CmpDelayedCloseTableLock);
}
else
{
/* Release the delayed close table lock */
KeReleaseGuardedMutex(&CmpDelayedCloseTableLock);
/* Zero out the DelayCloseEntry pointer */
ListEntry->KeyControlBlock->DelayCloseEntry = NULL;
/* Cleanup the KCB cache */
CmpCleanUpKcbCacheWithLock(ListEntry->KeyControlBlock, FALSE);
/* Free the delay item */
CmpFreeDelayItem(ListEntry);
/* Decrement delayed close elements count */
InterlockedDecrement((PLONG)&CmpDelayedCloseElements);
}
/* Release the KCB lock */
CmpReleaseKcbLockByKey(ConvKey);
/* Reacquire the delayed close table lock */
KeAcquireGuardedMutex(&CmpDelayedCloseTableLock);
}
if (CmpDelayedCloseElements <= CmpDelayedCloseSize)
{
/* We're not active anymore */
CmpDelayCloseWorkItemActive = FALSE;
}
else
{
/* We didn't process all things, so reschedule for the next time */
CmpArmDelayedCloseTimer();
}
/* Release the delayed close table lock */
KeReleaseGuardedMutex(&CmpDelayedCloseTableLock);
/* Unlock the registry */
CmpUnlockRegistry();
}
VOID