27 Mar
2006
27 Mar
'06
6:17 p.m.
Author: mbosma
Date: Mon Mar 27 22:17:12 2006
New Revision: 21400
URL: http://svn.reactos.ru/svn/reactos?rev=21400&view=rev
Log:
Unify coding style using GNU Indent
Modified:
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/cacheman.c
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/copy.c
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/fs.c
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/mdl.c
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/pin.c
branches/cache_manager_rewrite/reactos/ntoskrnl/cc/view.c
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/cacheman.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/cacheman.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/cacheman.c Mon Mar 27 22:17:12
2006
@@ -16,41 +16,34 @@
/* FUNCTIONS *****************************************************************/
-VOID
-NTAPI
-CcInit(VOID)
+VOID NTAPI
+CcInit (VOID)
{
- CcInitView();
+ CcInitView ();
}
/*
* @unimplemented
*/
-LARGE_INTEGER
-STDCALL
-CcGetFlushedValidData (
- IN PSECTION_OBJECT_POINTERS SectionObjectPointer,
- IN BOOLEAN BcbListHeld
- )
+LARGE_INTEGER STDCALL
+CcGetFlushedValidData (IN PSECTION_OBJECT_POINTERS SectionObjectPointer,
+ IN BOOLEAN BcbListHeld)
{
- LARGE_INTEGER i;
+ LARGE_INTEGER i;
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
- i.QuadPart = 0;
- return i;
+ i.QuadPart = 0;
+ return i;
}
/*
* @unimplemented
*/
-PVOID
-STDCALL
-CcRemapBcb (
- IN PVOID Bcb
- )
+PVOID STDCALL
+CcRemapBcb (IN PVOID Bcb)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
return 0;
}
@@ -58,66 +51,51 @@
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcScheduleReadAhead (
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length
- )
+VOID STDCALL
+CcScheduleReadAhead (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcSetAdditionalCacheAttributes (
- IN PFILE_OBJECT FileObject,
- IN BOOLEAN DisableReadAhead,
- IN BOOLEAN DisableWriteBehind
- )
+VOID STDCALL
+CcSetAdditionalCacheAttributes (IN PFILE_OBJECT FileObject,
+ IN BOOLEAN DisableReadAhead,
+ IN BOOLEAN DisableWriteBehind)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcSetBcbOwnerPointer (
- IN PVOID Bcb,
- IN PVOID Owner
- )
+VOID STDCALL
+CcSetBcbOwnerPointer (IN PVOID Bcb,
+ IN PVOID Owner)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcSetDirtyPageThreshold (
- IN PFILE_OBJECT FileObject,
- IN ULONG DirtyPageThreshold
- )
+VOID STDCALL
+CcSetDirtyPageThreshold (IN PFILE_OBJECT FileObject,
+ IN ULONG DirtyPageThreshold)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcSetReadAheadGranularity (
- IN PFILE_OBJECT FileObject,
- IN ULONG Granularity
- )
+VOID STDCALL
+CcSetReadAheadGranularity (IN PFILE_OBJECT FileObject,
+ IN ULONG Granularity)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/copy.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/copy.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/copy.c Mon Mar 27 22:17:12 2006
@@ -18,13 +18,13 @@
static PFN_TYPE CcZeroPage = 0;
-#define MAX_ZERO_LENGTH (256 * 1024)
-#define MAX_RW_LENGTH (256 * 1024)
+#define MAX_ZERO_LENGTH (256 * 1024)
+#define MAX_RW_LENGTH (256 * 1024)
#if defined(__GNUC__)
/* void * alloca(size_t size); */
#elif defined(_MSC_VER)
-void* _alloca(size_t size);
+void *_alloca (size_t size);
#else
#error Unknown compiler for alloca intrinsic stack allocation "function"
#endif
@@ -41,600 +41,582 @@
/* FUNCTIONS *****************************************************************/
-NTSTATUS STDCALL
-MmMapViewInSystemCache(PCACHE_VIEW);
-
-
-VOID
-NTAPI
-CcInitCacheZeroPage(VOID)
-{
- NTSTATUS Status;
-
- Status = MmRequestPageMemoryConsumer(MC_NPPOOL, TRUE, &CcZeroPage);
- if (!NT_SUCCESS(Status))
- {
- DbgPrint("Can't allocate CcZeroPage.\n");
- KEBUGCHECKCC;
- }
- Status = MiZeroPage(CcZeroPage);
- if (!NT_SUCCESS(Status))
- {
- DbgPrint("Can't zero out CcZeroPage.\n");
- KEBUGCHECKCC;
- }
+NTSTATUS STDCALL MmMapViewInSystemCache (PCACHE_VIEW);
+
+
+VOID NTAPI
+CcInitCacheZeroPage (VOID)
+{
+ NTSTATUS Status;
+
+ Status = MmRequestPageMemoryConsumer (MC_NPPOOL, TRUE, &CcZeroPage);
+ if (!NT_SUCCESS (Status))
+ {
+ DbgPrint ("Can't allocate CcZeroPage.\n");
+ KEBUGCHECKCC;
+ }
+ Status = MiZeroPage (CcZeroPage);
+ if (!NT_SUCCESS (Status))
+ {
+ DbgPrint ("Can't zero out CcZeroPage.\n");
+ KEBUGCHECKCC;
+ }
}
/*
* @unimplemented
*/
BOOLEAN STDCALL
-CcCanIWrite (
- IN PFILE_OBJECT FileObject,
- IN ULONG BytesToWrite,
- IN BOOLEAN Wait,
- IN BOOLEAN Retrying)
-{
- UNIMPLEMENTED;
- return FALSE;
+CcCanIWrite (IN PFILE_OBJECT FileObject,
+ IN ULONG BytesToWrite,
+ IN BOOLEAN Wait,
+ IN BOOLEAN Retrying)
+{
+ UNIMPLEMENTED;
+ return FALSE;
}
BOOLEAN STDCALL
CcCopyRead (IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN BOOLEAN Wait,
- OUT PVOID Buffer,
- OUT PIO_STATUS_BLOCK IoStatus)
-{
-
- ULONG Index;
- PBCB Bcb;
- LARGE_INTEGER Offset;
- PLIST_ENTRY entry;
- PCACHE_VIEW current = NULL;
- ULONG CurrentLength;
- NTSTATUS Status;
-
- DPRINT("CcCopyRead(FileObject 0x%p, FileOffset %I64x, "
- "Length %d, Wait %d, Buffer 0x%p, IoStatus 0x%p)\n",
- FileObject, FileOffset->QuadPart, Length, Wait,
- Buffer, IoStatus);
-
-
- if (!Wait)
- {
- IoStatus->Information = 0;
- IoStatus->Status = STATUS_UNSUCCESSFUL;
- CHECKPOINT;
- return FALSE;
- }
-
- IoStatus->Information = Length;
- IoStatus->Status = STATUS_SUCCESS;
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
-
- if (FileOffset->QuadPart + Length > Bcb->FileSizes.FileSize.QuadPart)
- {
- KEBUGCHECK(0);
- }
-
- if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof(Bcb->CacheView) /
sizeof(Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- Offset = *FileOffset;
-
- ExAcquireFastMutex(&CcCacheViewLock);
- while (Length)
- {
- Index = Offset.QuadPart / CACHE_VIEW_SIZE;
- if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
- {
- CHECKPOINT;
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- Bcb->CacheView[Index]->RefCount++;
- }
- else
- {
- CHECKPOINT;
- if (IsListEmpty(&CcFreeCacheViewListHead))
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- entry = CcFreeCacheViewListHead.Flink;
- while (entry != &CcFreeCacheViewListHead)
- {
- current = CONTAINING_RECORD(entry, CACHE_VIEW, ListEntry);
- entry = entry->Flink;
- if (current->Bcb == NULL)
- {
- break;
- }
- }
- if (entry == &CcFreeCacheViewListHead)
- {
- KEBUGCHECK(0);
- }
-
- if (current->Bcb)
- {
- current->Bcb->CacheView[current->SectionData.ViewOffset / CACHE_VIEW_SIZE]
= NULL;
- }
- Bcb->CacheView[Index] = current;
-
-
- if(Bcb->CacheView[Index]->Bcb != NULL)
- {
- DPRINT1("%x\n", Bcb->CacheView[Index]->Bcb);
- /* not implemented */
- KEBUGCHECK(0);
- }
- Bcb->CacheView[Index]->RefCount = 1;
- Bcb->CacheView[Index]->Bcb = Bcb;
- Bcb->CacheView[Index]->SectionData.ViewOffset = Index * CACHE_VIEW_SIZE;
- Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
- Bcb->CacheView[Index]->SectionData.Segment = Bcb->Section->Segment;
-
- Status = MmMapViewInSystemCache(Bcb->CacheView[Index]);
-
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- if (Offset.QuadPart % CACHE_VIEW_SIZE)
- {
- if (Length > CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE)
- {
- CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE;
- }
- else
- {
- CurrentLength = Length;
- }
- memcpy(Buffer,
- (PVOID)((ULONG_PTR)Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE),
- CurrentLength);
- Buffer = (PVOID)((ULONG_PTR)Buffer + CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- else
- {
- CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
- memcpy(Buffer, Bcb->CacheView[Index]->BaseAddress, CurrentLength);
- Buffer = (PVOID)((ULONG_PTR)Buffer + CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- ExAcquireFastMutex(&CcCacheViewLock);
-
- Bcb->CacheView[Index]->RefCount--;
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- CHECKPOINT;
-
- return TRUE;
-}
-
-/*
- * @implemented
- */
-BOOLEAN STDCALL
-CcCopyWrite(IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN BOOLEAN Wait,
- IN PVOID Buffer)
-{
-
- ULONG Index;
- PBCB Bcb;
- LARGE_INTEGER Offset;
- PLIST_ENTRY entry;
- PCACHE_VIEW current = NULL;
- ULONG CurrentLength;
- NTSTATUS Status;
-
- DPRINT("CcCopyWrite(FileObject 0x%p, FileOffset %I64x, "
- "Length %d, Wait %d, Buffer 0x%p)\n",
- FileObject, FileOffset->QuadPart, Length, Wait, Buffer);
-
- if (!Wait)
- {
- CHECKPOINT;
- return FALSE;
- }
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
-
- if (FileOffset->QuadPart + Length > Bcb->FileSizes.FileSize.QuadPart)
- {
- KEBUGCHECK(0);
- }
-
- if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof(Bcb->CacheView) /
sizeof(Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- Offset = *FileOffset;
-
- ExAcquireFastMutex(&CcCacheViewLock);
- while (Length)
- {
- Index = Offset.QuadPart / CACHE_VIEW_SIZE;
- if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
- {
- CHECKPOINT;
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- Bcb->CacheView[Index]->RefCount++;
- }
- else
- {
- CHECKPOINT;
- if (IsListEmpty(&CcFreeCacheViewListHead))
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- entry = CcFreeCacheViewListHead.Flink;
- while (entry != &CcFreeCacheViewListHead)
- {
- current = CONTAINING_RECORD(entry, CACHE_VIEW, ListEntry);
- entry = entry->Flink;
- if (current->Bcb == NULL)
- {
- break;
- }
- }
- if (entry == &CcFreeCacheViewListHead)
- {
- KEBUGCHECK(0);
- }
-
- if (current->Bcb)
- {
- current->Bcb->CacheView[current->SectionData.ViewOffset / CACHE_VIEW_SIZE]
= NULL;
- }
-
- Bcb->CacheView[Index] = current;
-
- if(Bcb->CacheView[Index]->Bcb != NULL)
- {
- DPRINT1("%x\n", Bcb->CacheView[Index]->Bcb);
- /* not implemented */
- KEBUGCHECK(0);
- }
- Bcb->CacheView[Index]->RefCount = 1;
- Bcb->CacheView[Index]->Bcb = Bcb;
- Bcb->CacheView[Index]->SectionData.ViewOffset = Index * CACHE_VIEW_SIZE;
- Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
- Bcb->CacheView[Index]->SectionData.Segment = Bcb->Section->Segment;
-
- Status = MmMapViewInSystemCache(Bcb->CacheView[Index]);
-
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- if (Offset.QuadPart % CACHE_VIEW_SIZE)
- {
- if (Length > CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE)
- {
- CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE;
- }
- else
- {
- CurrentLength = Length;
- }
- memcpy((PVOID)((ULONG_PTR)Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE),
- Buffer, CurrentLength);
- Buffer = (PVOID)((ULONG_PTR)Buffer + CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- else
- {
- CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
- memcpy(Bcb->CacheView[Index]->BaseAddress, Buffer, CurrentLength);
- Buffer = (PVOID)((ULONG_PTR)Buffer + CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- ExAcquireFastMutex(&CcCacheViewLock);
-
- Bcb->CacheView[Index]->RefCount--;
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- CHECKPOINT;
-
- return TRUE;
-}
-
-/*
- * @unimplemented
- */
-VOID
-STDCALL
-CcDeferWrite (
- IN PFILE_OBJECT FileObject,
- IN PCC_POST_DEFERRED_WRITE PostRoutine,
- IN PVOID Context1,
- IN PVOID Context2,
- IN ULONG BytesToWrite,
- IN BOOLEAN Retrying
- )
-{
- UNIMPLEMENTED;
-}
-
-/*
- * @unimplemented
- */
-VOID
-STDCALL
-CcFastCopyRead (
- IN PFILE_OBJECT FileObject,
- IN ULONG FileOffset,
- IN ULONG Length,
- IN ULONG PageCount,
- OUT PVOID Buffer,
- OUT PIO_STATUS_BLOCK IoStatus
- )
-{
- UNIMPLEMENTED;
-}
-/*
- * @unimplemented
- */
-VOID
-STDCALL
-CcFastCopyWrite(
- IN PFILE_OBJECT FileObject,
- IN ULONG FileOffset,
- IN ULONG Length,
- IN PVOID Buffer)
-{
- UNIMPLEMENTED;
-}
-
-/*
- * @unimplemented
- */
-NTSTATUS
-STDCALL
-CcWaitForCurrentLazyWriterActivity (
- VOID
- )
-{
- UNIMPLEMENTED;
- return STATUS_NOT_IMPLEMENTED;
-}
-
-/*
- * @implemented
- */
-BOOLEAN STDCALL
-CcZeroData (IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER StartOffset,
- IN PLARGE_INTEGER EndOffset,
- IN BOOLEAN Wait)
-{
- NTSTATUS Status;
- LARGE_INTEGER WriteOffset;
- ULONG Length;
- ULONG CurrentLength;
- PMDL Mdl;
- ULONG i;
- IO_STATUS_BLOCK Iosb;
- KEVENT Event;
- LARGE_INTEGER Offset;
- ULONG Index;
-
- DPRINT("CcZeroData(FileObject 0x%p, StartOffset %I64x, EndOffset %I64x, "
- "Wait %d)\n", FileObject, StartOffset->QuadPart, EndOffset->QuadPart,
- Wait);
-
- Length = EndOffset->u.LowPart - StartOffset->u.LowPart;
- WriteOffset.QuadPart = StartOffset->QuadPart;
-
- if (FileObject->SectionObjectPointer->SharedCacheMap == NULL)
- {
- /* File is not cached */
-
- Mdl = alloca(MmSizeOfMdl(NULL, MAX_ZERO_LENGTH));
-
- while (Length > 0)
- {
- if (Length + WriteOffset.u.LowPart % PAGE_SIZE > MAX_ZERO_LENGTH)
- {
- CurrentLength = MAX_ZERO_LENGTH - WriteOffset.u.LowPart % PAGE_SIZE;
- }
- else
- {
- CurrentLength = Length;
- }
- MmInitializeMdl(Mdl, (PVOID)WriteOffset.u.LowPart, CurrentLength);
- Mdl->MdlFlags |= (MDL_PAGES_LOCKED | MDL_IO_PAGE_READ);
- for (i = 0; i < ((Mdl->Size - sizeof(MDL)) / sizeof(ULONG)); i++)
- {
- ((PPFN_TYPE)(Mdl + 1))[i] = CcZeroPage;
- }
- KeInitializeEvent(&Event, NotificationEvent, FALSE);
- Status = IoSynchronousPageWrite(FileObject, Mdl, &WriteOffset, &Event,
&Iosb);
- if (Status == STATUS_PENDING)
- {
- KeWaitForSingleObject(&Event, Executive, KernelMode, FALSE, NULL);
- Status = Iosb.Status;
- }
- MmUnmapLockedPages(Mdl->MappedSystemVa, Mdl);
- if (!NT_SUCCESS(Status))
- {
- return(FALSE);
- }
- WriteOffset.QuadPart += CurrentLength;
- Length -= CurrentLength;
- }
- }
- else
- {
- /* File is cached */
- PBCB Bcb;
- PCACHE_VIEW current = NULL;
- PLIST_ENTRY entry;
-
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
-
- if (!Wait)
- {
- CHECKPOINT;
- return FALSE;
- }
-
- if (EndOffset->QuadPart > Bcb->FileSizes.FileSize.QuadPart)
- {
- KEBUGCHECK(0);
- }
-
- if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof(Bcb->CacheView) /
sizeof(Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- Offset = *StartOffset;
- Length = EndOffset->QuadPart - StartOffset->QuadPart;
-
- ExAcquireFastMutex(&CcCacheViewLock);
- while (Length)
- {
- Index = Offset.QuadPart / CACHE_VIEW_SIZE;
- if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb ==
Bcb)
- {
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN BOOLEAN Wait,
+ OUT PVOID Buffer,
+ OUT PIO_STATUS_BLOCK IoStatus)
+{
+
+ ULONG Index;
+ PBCB Bcb;
+ LARGE_INTEGER Offset;
+ PLIST_ENTRY entry;
+ PCACHE_VIEW current = NULL;
+ ULONG CurrentLength;
+ NTSTATUS Status;
+
+ DPRINT ("CcCopyRead(FileObject 0x%p, FileOffset %I64x, "
+ "Length %d, Wait %d, Buffer 0x%p, IoStatus 0x%p)\n",
+ FileObject, FileOffset->QuadPart, Length, Wait, Buffer, IoStatus);
+
+
+ if (!Wait)
+ {
+ IoStatus->Information = 0;
+ IoStatus->Status = STATUS_UNSUCCESSFUL;
+ CHECKPOINT;
+ return FALSE;
+ }
+
+ IoStatus->Information = Length;
+ IoStatus->Status = STATUS_SUCCESS;
+
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+
+ if (FileOffset->QuadPart + Length > Bcb->FileSizes.FileSize.QuadPart)
+ {
+ KEBUGCHECK (0);
+ }
+
+ if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof (Bcb->CacheView) /
sizeof (Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ Offset = *FileOffset;
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+ while (Length)
+ {
+ Index = Offset.QuadPart / CACHE_VIEW_SIZE;
+ if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
+ {
CHECKPOINT;
if (Bcb->CacheView[Index]->RefCount == 0)
{
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
}
Bcb->CacheView[Index]->RefCount++;
- }
- else
- {
+ }
+ else
+ {
CHECKPOINT;
- if (IsListEmpty(&CcFreeCacheViewListHead))
- {
- /* not implemented */
- KEBUGCHECK(0);
+ if (IsListEmpty (&CcFreeCacheViewListHead))
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
}
entry = CcFreeCacheViewListHead.Flink;
while (entry != &CcFreeCacheViewListHead)
{
- current = CONTAINING_RECORD(entry, CACHE_VIEW, ListEntry);
- entry = entry->Flink;
- if (current->Bcb == NULL)
- {
- break;
- }
+ current = CONTAINING_RECORD (entry, CACHE_VIEW, ListEntry);
+ entry = entry->Flink;
+ if (current->Bcb == NULL)
+ {
+ break;
+ }
}
if (entry == &CcFreeCacheViewListHead)
{
- KEBUGCHECK(0);
- }
-
+ KEBUGCHECK (0);
+ }
+
+ if (current->Bcb)
+ {
+ current->Bcb->CacheView[current->SectionData.ViewOffset /
CACHE_VIEW_SIZE] = NULL;
+ }
Bcb->CacheView[Index] = current;
- if(Bcb->CacheView[Index]->Bcb != NULL)
- {
- DPRINT1("%x\n", Bcb->CacheView[Index]->Bcb);
- /* not implemented */
- KEBUGCHECK(0);
+
+ if (Bcb->CacheView[Index]->Bcb != NULL)
+ {
+ DPRINT1 ("%x\n", Bcb->CacheView[Index]->Bcb);
+ /* not implemented */
+ KEBUGCHECK (0);
}
Bcb->CacheView[Index]->RefCount = 1;
Bcb->CacheView[Index]->Bcb = Bcb;
Bcb->CacheView[Index]->SectionData.ViewOffset = Index *
CACHE_VIEW_SIZE;
- Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
- Bcb->CacheView[Index]->SectionData.Segment = Bcb->Section->Segment;
-
- Status = MmMapViewInSystemCache(Bcb->CacheView[Index]);
-
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- if (Offset.QuadPart % CACHE_VIEW_SIZE)
- {
+ Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
+ Bcb->CacheView[Index]->SectionData.Segment =
Bcb->Section->Segment;
+
+ Status = MmMapViewInSystemCache (Bcb->CacheView[Index]);
+
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ if (Offset.QuadPart % CACHE_VIEW_SIZE)
+ {
if (Length > CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE)
- {
- CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE;
- }
- else
- {
- CurrentLength = Length;
- }
- memset((PVOID)((ULONG_PTR)Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE), 0, CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- else
- {
- CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
- memset(Bcb->CacheView[Index]->BaseAddress, 0, CurrentLength);
- Length -= CurrentLength;
- Offset.QuadPart += CurrentLength;
- }
- ExAcquireFastMutex(&CcCacheViewLock);
-
- Bcb->CacheView[Index]->RefCount--;
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- CHECKPOINT;
-
- }
- return(TRUE);
-}
+ {
+ CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE;
+ }
+ else
+ {
+ CurrentLength = Length;
+ }
+ memcpy (Buffer,
+ (PVOID) ((ULONG_PTR) Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE), CurrentLength);
+ Buffer = (PVOID) ((ULONG_PTR) Buffer + CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ else
+ {
+ CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
+ memcpy (Buffer, Bcb->CacheView[Index]->BaseAddress, CurrentLength);
+ Buffer = (PVOID) ((ULONG_PTR) Buffer + CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ ExAcquireFastMutex (&CcCacheViewLock);
+
+ Bcb->CacheView[Index]->RefCount--;
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ CHECKPOINT;
+
+ return TRUE;
+}
+
+/*
+ * @implemented
+ */
+BOOLEAN STDCALL
+CcCopyWrite (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN BOOLEAN Wait,
+ IN PVOID Buffer)
+{
+
+ ULONG Index;
+ PBCB Bcb;
+ LARGE_INTEGER Offset;
+ PLIST_ENTRY entry;
+ PCACHE_VIEW current = NULL;
+ ULONG CurrentLength;
+ NTSTATUS Status;
+
+ DPRINT ("CcCopyWrite(FileObject 0x%p, FileOffset %I64x, "
+ "Length %d, Wait %d, Buffer 0x%p)\n", FileObject,
FileOffset->QuadPart, Length, Wait, Buffer);
+
+ if (!Wait)
+ {
+ CHECKPOINT;
+ return FALSE;
+ }
+
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+
+ if (FileOffset->QuadPart + Length > Bcb->FileSizes.FileSize.QuadPart)
+ {
+ KEBUGCHECK (0);
+ }
+
+ if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof (Bcb->CacheView) /
sizeof (Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ Offset = *FileOffset;
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+ while (Length)
+ {
+ Index = Offset.QuadPart / CACHE_VIEW_SIZE;
+ if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
+ {
+ CHECKPOINT;
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ Bcb->CacheView[Index]->RefCount++;
+ }
+ else
+ {
+ CHECKPOINT;
+ if (IsListEmpty (&CcFreeCacheViewListHead))
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ entry = CcFreeCacheViewListHead.Flink;
+ while (entry != &CcFreeCacheViewListHead)
+ {
+ current = CONTAINING_RECORD (entry, CACHE_VIEW, ListEntry);
+ entry = entry->Flink;
+ if (current->Bcb == NULL)
+ {
+ break;
+ }
+ }
+ if (entry == &CcFreeCacheViewListHead)
+ {
+ KEBUGCHECK (0);
+ }
+
+ if (current->Bcb)
+ {
+ current->Bcb->CacheView[current->SectionData.ViewOffset /
CACHE_VIEW_SIZE] = NULL;
+ }
+
+ Bcb->CacheView[Index] = current;
+
+ if (Bcb->CacheView[Index]->Bcb != NULL)
+ {
+ DPRINT1 ("%x\n", Bcb->CacheView[Index]->Bcb);
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+ Bcb->CacheView[Index]->RefCount = 1;
+ Bcb->CacheView[Index]->Bcb = Bcb;
+ Bcb->CacheView[Index]->SectionData.ViewOffset = Index *
CACHE_VIEW_SIZE;
+ Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
+ Bcb->CacheView[Index]->SectionData.Segment =
Bcb->Section->Segment;
+
+ Status = MmMapViewInSystemCache (Bcb->CacheView[Index]);
+
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ if (Offset.QuadPart % CACHE_VIEW_SIZE)
+ {
+ if (Length > CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE)
+ {
+ CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE;
+ }
+ else
+ {
+ CurrentLength = Length;
+ }
+ memcpy ((PVOID) ((ULONG_PTR) Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE),
+ Buffer, CurrentLength);
+ Buffer = (PVOID) ((ULONG_PTR) Buffer + CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ else
+ {
+ CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
+ memcpy (Bcb->CacheView[Index]->BaseAddress, Buffer, CurrentLength);
+ Buffer = (PVOID) ((ULONG_PTR) Buffer + CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ ExAcquireFastMutex (&CcCacheViewLock);
+
+ Bcb->CacheView[Index]->RefCount--;
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ CHECKPOINT;
+
+ return TRUE;
+}
+
+/*
+ * @unimplemented
+ */
+VOID STDCALL
+CcDeferWrite (IN PFILE_OBJECT FileObject,
+ IN PCC_POST_DEFERRED_WRITE PostRoutine,
+ IN PVOID Context1,
+ IN PVOID Context2,
+ IN ULONG BytesToWrite,
+ IN BOOLEAN Retrying)
+{
+ UNIMPLEMENTED;
+}
+
+/*
+ * @unimplemented
+ */
+VOID STDCALL
+CcFastCopyRead (IN PFILE_OBJECT FileObject,
+ IN ULONG FileOffset,
+ IN ULONG Length,
+ IN ULONG PageCount,
+ OUT PVOID Buffer,
+ OUT PIO_STATUS_BLOCK IoStatus)
+{
+ UNIMPLEMENTED;
+}
+
+/*
+ * @unimplemented
+ */
+VOID STDCALL
+CcFastCopyWrite (IN PFILE_OBJECT FileObject,
+ IN ULONG FileOffset,
+ IN ULONG Length,
+ IN PVOID Buffer)
+{
+ UNIMPLEMENTED;
+}
+
+/*
+ * @unimplemented
+ */
+NTSTATUS STDCALL
+CcWaitForCurrentLazyWriterActivity (VOID)
+{
+ UNIMPLEMENTED;
+ return STATUS_NOT_IMPLEMENTED;
+}
+
+/*
+ * @implemented
+ */
+BOOLEAN STDCALL
+CcZeroData (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER StartOffset,
+ IN PLARGE_INTEGER EndOffset,
+ IN BOOLEAN Wait)
+{
+ NTSTATUS Status;
+ LARGE_INTEGER WriteOffset;
+ ULONG Length;
+ ULONG CurrentLength;
+ PMDL Mdl;
+ ULONG i;
+ IO_STATUS_BLOCK Iosb;
+ KEVENT Event;
+ LARGE_INTEGER Offset;
+ ULONG Index;
+
+ DPRINT ("CcZeroData(FileObject 0x%p, StartOffset %I64x, EndOffset %I64x, "
+ "Wait %d)\n", FileObject, StartOffset->QuadPart,
EndOffset->QuadPart, Wait);
+
+ Length = EndOffset->u.LowPart - StartOffset->u.LowPart;
+ WriteOffset.QuadPart = StartOffset->QuadPart;
+
+ if (FileObject->SectionObjectPointer->SharedCacheMap == NULL)
+ {
+ /* File is not cached */
+
+ Mdl = alloca (MmSizeOfMdl (NULL, MAX_ZERO_LENGTH));
+
+ while (Length > 0)
+ {
+ if (Length + WriteOffset.u.LowPart % PAGE_SIZE > MAX_ZERO_LENGTH)
+ {
+ CurrentLength = MAX_ZERO_LENGTH - WriteOffset.u.LowPart % PAGE_SIZE;
+ }
+ else
+ {
+ CurrentLength = Length;
+ }
+ MmInitializeMdl (Mdl, (PVOID) WriteOffset.u.LowPart, CurrentLength);
+ Mdl->MdlFlags |= (MDL_PAGES_LOCKED | MDL_IO_PAGE_READ);
+ for (i = 0; i < ((Mdl->Size - sizeof (MDL)) / sizeof (ULONG)); i++)
+ {
+ ((PPFN_TYPE) (Mdl + 1))[i] = CcZeroPage;
+ }
+ KeInitializeEvent (&Event, NotificationEvent, FALSE);
+ Status = IoSynchronousPageWrite (FileObject, Mdl, &WriteOffset,
&Event, &Iosb);
+ if (Status == STATUS_PENDING)
+ {
+ KeWaitForSingleObject (&Event, Executive, KernelMode, FALSE, NULL);
+ Status = Iosb.Status;
+ }
+ MmUnmapLockedPages (Mdl->MappedSystemVa, Mdl);
+ if (!NT_SUCCESS (Status))
+ {
+ return (FALSE);
+ }
+ WriteOffset.QuadPart += CurrentLength;
+ Length -= CurrentLength;
+ }
+ }
+ else
+ {
+ /* File is cached */
+ PBCB Bcb;
+ PCACHE_VIEW current = NULL;
+ PLIST_ENTRY entry;
+
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+
+ if (!Wait)
+ {
+ CHECKPOINT;
+ return FALSE;
+ }
+
+ if (EndOffset->QuadPart > Bcb->FileSizes.FileSize.QuadPart)
+ {
+ KEBUGCHECK (0);
+ }
+
+ if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof (Bcb->CacheView) /
sizeof (Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ Offset = *StartOffset;
+ Length = EndOffset->QuadPart - StartOffset->QuadPart;
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+ while (Length)
+ {
+ Index = Offset.QuadPart / CACHE_VIEW_SIZE;
+ if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb ==
Bcb)
+ {
+ CHECKPOINT;
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ Bcb->CacheView[Index]->RefCount++;
+ }
+ else
+ {
+ CHECKPOINT;
+ if (IsListEmpty (&CcFreeCacheViewListHead))
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ entry = CcFreeCacheViewListHead.Flink;
+ while (entry != &CcFreeCacheViewListHead)
+ {
+ current = CONTAINING_RECORD (entry, CACHE_VIEW, ListEntry);
+ entry = entry->Flink;
+ if (current->Bcb == NULL)
+ {
+ break;
+ }
+ }
+ if (entry == &CcFreeCacheViewListHead)
+ {
+ KEBUGCHECK (0);
+ }
+
+ Bcb->CacheView[Index] = current;
+
+ if (Bcb->CacheView[Index]->Bcb != NULL)
+ {
+ DPRINT1 ("%x\n", Bcb->CacheView[Index]->Bcb);
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+ Bcb->CacheView[Index]->RefCount = 1;
+ Bcb->CacheView[Index]->Bcb = Bcb;
+ Bcb->CacheView[Index]->SectionData.ViewOffset = Index *
CACHE_VIEW_SIZE;
+ Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
+ Bcb->CacheView[Index]->SectionData.Segment =
Bcb->Section->Segment;
+
+ Status = MmMapViewInSystemCache (Bcb->CacheView[Index]);
+
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ if (Offset.QuadPart % CACHE_VIEW_SIZE)
+ {
+ if (Length > CACHE_VIEW_SIZE - Offset.u.LowPart % CACHE_VIEW_SIZE)
+ {
+ CurrentLength = CACHE_VIEW_SIZE - Offset.u.LowPart %
CACHE_VIEW_SIZE;
+ }
+ else
+ {
+ CurrentLength = Length;
+ }
+ memset ((PVOID) ((ULONG_PTR) Bcb->CacheView[Index]->BaseAddress +
Offset.u.LowPart % CACHE_VIEW_SIZE), 0,
+ CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ else
+ {
+ CurrentLength = Length > CACHE_VIEW_SIZE ? CACHE_VIEW_SIZE : Length;
+ memset (Bcb->CacheView[Index]->BaseAddress, 0, CurrentLength);
+ Length -= CurrentLength;
+ Offset.QuadPart += CurrentLength;
+ }
+ ExAcquireFastMutex (&CcCacheViewLock);
+
+ Bcb->CacheView[Index]->RefCount--;
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcFreeCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ CHECKPOINT;
+ }
+ return (TRUE);
+}
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/fs.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/fs.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/fs.c Mon Mar 27 22:17:12 2006
@@ -16,7 +16,7 @@
#ifndef ROUND_DOWN
-#define ROUND_DOWN(X,Y) ((X) & ~((Y) - 1))
+#define ROUND_DOWN(X,Y) ((X) & ~((Y) - 1))
#endif
/* GLOBALS *****************************************************************/
@@ -25,89 +25,71 @@
extern ULONG CcCacheViewArrayCount;
extern FAST_MUTEX CcCacheViewLock;
-NTSTATUS STDCALL
-MmUnmapViewInSystemCache(PCACHE_VIEW);
+NTSTATUS STDCALL MmUnmapViewInSystemCache (PCACHE_VIEW);
-NTSTATUS STDCALL
-MmChangeSectionSize(PSECTION_OBJECT Section,
- PLARGE_INTEGER NewMaxSize);
+NTSTATUS STDCALL MmChangeSectionSize (PSECTION_OBJECT Section, PLARGE_INTEGER
NewMaxSize);
/* FUNCTIONS *****************************************************************/
/*
* @unimplemented
*/
-LARGE_INTEGER
-STDCALL
-CcGetDirtyPages (
- IN PVOID LogHandle,
- IN PDIRTY_PAGE_ROUTINE DirtyPageRoutine,
- IN PVOID Context1,
- IN PVOID Context2
- )
+LARGE_INTEGER STDCALL
+CcGetDirtyPages (IN PVOID LogHandle,
+ IN PDIRTY_PAGE_ROUTINE DirtyPageRoutine,
+ IN PVOID Context1,
+ IN PVOID Context2)
{
- LARGE_INTEGER i;
- UNIMPLEMENTED;
- i.QuadPart = 0;
- return i;
+ LARGE_INTEGER i;
+ UNIMPLEMENTED;
+ i.QuadPart = 0;
+ return i;
}
/*
* @implemented
*/
-PFILE_OBJECT
-STDCALL
-CcGetFileObjectFromBcb (
- IN PVOID Bcb
- )
+PFILE_OBJECT STDCALL
+CcGetFileObjectFromBcb (IN PVOID Bcb)
{
- PINTERNAL_BCB iBcb = (PINTERNAL_BCB)Bcb;
- return iBcb->Bcb->FileObject;
+ PINTERNAL_BCB iBcb = (PINTERNAL_BCB) Bcb;
+ return iBcb->Bcb->FileObject;
}
/*
* @unimplemented
*/
-LARGE_INTEGER
-STDCALL
-CcGetLsnForFileObject (
- IN PFILE_OBJECT FileObject,
- OUT PLARGE_INTEGER OldestLsn OPTIONAL
- )
+LARGE_INTEGER STDCALL
+CcGetLsnForFileObject (IN PFILE_OBJECT FileObject,
+ OUT PLARGE_INTEGER OldestLsn OPTIONAL)
{
- LARGE_INTEGER i;
- UNIMPLEMENTED;
- i.QuadPart = 0;
- return i;
+ LARGE_INTEGER i;
+ UNIMPLEMENTED;
+ i.QuadPart = 0;
+ return i;
}
/*
* @unimplemented
*/
-BOOLEAN
-STDCALL
-CcIsThereDirtyData (
- IN PVPB Vpb
- )
+BOOLEAN STDCALL
+CcIsThereDirtyData (IN PVPB Vpb)
{
- UNIMPLEMENTED;
- return FALSE;
+ UNIMPLEMENTED;
+ return FALSE;
}
/*
* @unimplemented
*/
-BOOLEAN
-STDCALL
-CcPurgeCacheSection (
- IN PSECTION_OBJECT_POINTERS SectionObjectPointer,
- IN PLARGE_INTEGER FileOffset OPTIONAL,
- IN ULONG Length,
- IN BOOLEAN UninitializeCacheMaps
- )
+BOOLEAN STDCALL
+CcPurgeCacheSection (IN PSECTION_OBJECT_POINTERS SectionObjectPointer,
+ IN PLARGE_INTEGER FileOffset OPTIONAL,
+ IN ULONG Length,
+ IN BOOLEAN UninitializeCacheMaps)
{
- UNIMPLEMENTED;
- return FALSE;
+ UNIMPLEMENTED;
+ return FALSE;
}
@@ -115,101 +97,94 @@
* @implemented
*/
VOID STDCALL
-CcSetFileSizes (IN PFILE_OBJECT FileObject,
- IN PCC_FILE_SIZES FileSizes)
+CcSetFileSizes (IN PFILE_OBJECT FileObject,
+ IN PCC_FILE_SIZES FileSizes)
{
- PBCB Bcb;
- NTSTATUS Status;
- ULONG i;
+ PBCB Bcb;
+ NTSTATUS Status;
+ ULONG i;
- DPRINT("CcSetFileSizes(FileObject 0x%p, FileSizes 0x%p)\n",
- FileObject, FileSizes);
- DPRINT("AllocationSize %d, FileSize %d, ValidDataLength %d\n",
- (ULONG)FileSizes->AllocationSize.QuadPart,
- (ULONG)FileSizes->FileSize.QuadPart,
- (ULONG)FileSizes->ValidDataLength.QuadPart);
- DPRINT("%wZ\n", &FileObject->FileName);
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
- if (Bcb == NULL)
- {
- return;
- }
- DPRINT("AllocationSize %d, FileSize %d, ValidDataLength %d\n",
- (ULONG)Bcb->FileSizes.AllocationSize.QuadPart,
- (ULONG)Bcb->FileSizes.FileSize.QuadPart,
- (ULONG)Bcb->FileSizes.ValidDataLength.QuadPart);
- ExAcquireFastMutex(&CcCacheViewLock);
+ DPRINT ("CcSetFileSizes(FileObject 0x%p, FileSizes 0x%p)\n", FileObject,
FileSizes);
+ DPRINT ("AllocationSize %d, FileSize %d, ValidDataLength %d\n",
+ (ULONG) FileSizes->AllocationSize.QuadPart,
+ (ULONG) FileSizes->FileSize.QuadPart, (ULONG)
FileSizes->ValidDataLength.QuadPart);
+ DPRINT ("%wZ\n", &FileObject->FileName);
- DPRINT("%d\n", Bcb->FileSizes.FileSize.u.LowPart);
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+ if (Bcb == NULL)
+ {
+ return;
+ }
+ DPRINT ("AllocationSize %d, FileSize %d, ValidDataLength %d\n",
+ (ULONG) Bcb->FileSizes.AllocationSize.QuadPart,
+ (ULONG) Bcb->FileSizes.FileSize.QuadPart, (ULONG)
Bcb->FileSizes.ValidDataLength.QuadPart);
+ ExAcquireFastMutex (&CcCacheViewLock);
- for (i = ROUND_DOWN(FileSizes->AllocationSize.QuadPart, CACHE_VIEW_SIZE) /
CACHE_VIEW_SIZE;
- i < ROUND_UP(Bcb->FileSizes.AllocationSize.QuadPart, CACHE_VIEW_SIZE) /
CACHE_VIEW_SIZE;
- i++)
- {
- if (Bcb->CacheView[i] != NULL)
- {
- if (Bcb->CacheView[i]->Bcb != Bcb)
- {
- KEBUGCHECK(0);
- }
- if (Bcb->CacheView[i]->RefCount > 0)
- {
- KEBUGCHECK(0);
- }
- Status = MmUnmapViewInSystemCache(Bcb->CacheView[i]);
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- Bcb->CacheView[i]->RefCount = 0;
- Bcb->CacheView[i]->Bcb = NULL;
- Bcb->CacheView[i] = NULL;
- }
- }
-
+ DPRINT ("%d\n", Bcb->FileSizes.FileSize.u.LowPart);
+
+ for (i = ROUND_DOWN (FileSizes->AllocationSize.QuadPart, CACHE_VIEW_SIZE) /
CACHE_VIEW_SIZE;
+ i < ROUND_UP (Bcb->FileSizes.AllocationSize.QuadPart, CACHE_VIEW_SIZE) /
CACHE_VIEW_SIZE; i++)
+ {
+ if (Bcb->CacheView[i] != NULL)
+ {
+ if (Bcb->CacheView[i]->Bcb != Bcb)
+ {
+ KEBUGCHECK (0);
+ }
+ if (Bcb->CacheView[i]->RefCount > 0)
+ {
+ KEBUGCHECK (0);
+ }
+ Status = MmUnmapViewInSystemCache (Bcb->CacheView[i]);
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ Bcb->CacheView[i]->RefCount = 0;
+ Bcb->CacheView[i]->Bcb = NULL;
+ Bcb->CacheView[i] = NULL;
+ }
+ }
+
#if 0
- for (i = 0; i < CcCacheViewArrayCount; i++)
- {
- if (CcCacheViewArray[i].Bcb == Bcb)
- {
- if (PAGE_ROUND_UP(FileSizes->AllocationSize.QuadPart) <=
CcCacheViewArray[i].SectionData.ViewOffset ||
- (PAGE_ROUND_UP(FileSizes->AllocationSize.QuadPart) >
CcCacheViewArray[i].SectionData.ViewOffset &&
- PAGE_ROUND_UP(FileSizes->AllocationSize.QuadPart) <=
CcCacheViewArray[i].SectionData.ViewOffset + CACHE_VIEW_SIZE))
-
- {
- if (CcCacheViewArray[i].RefCount > 0)
- {
- KEBUGCHECK(0);
- }
- Status = MmUnmapViewInSystemCache(&CcCacheViewArray[i]);
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- CcCacheViewArray[i].RefCount = 0;
- CcCacheViewArray[i].Bcb = NULL;
- }
- }
- }
+ for (i = 0; i < CcCacheViewArrayCount; i++)
+ {
+ if (CcCacheViewArray[i].Bcb == Bcb)
+ {
+ if (PAGE_ROUND_UP (FileSizes->AllocationSize.QuadPart) <=
CcCacheViewArray[i].SectionData.ViewOffset ||
+ (PAGE_ROUND_UP (FileSizes->AllocationSize.QuadPart) >
CcCacheViewArray[i].SectionData.ViewOffset &&
+ PAGE_ROUND_UP (FileSizes->AllocationSize.QuadPart) <=
+ CcCacheViewArray[i].SectionData.ViewOffset + CACHE_VIEW_SIZE))
+
+ {
+ if (CcCacheViewArray[i].RefCount > 0)
+ {
+ KEBUGCHECK (0);
+ }
+ Status = MmUnmapViewInSystemCache (&CcCacheViewArray[i]);
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ CcCacheViewArray[i].RefCount = 0;
+ CcCacheViewArray[i].Bcb = NULL;
+ }
+ }
+ }
#endif
- Status = MmChangeSectionSize(Bcb->Section, &FileSizes->FileSize);
- Bcb->FileSizes = *FileSizes;
+ Status = MmChangeSectionSize (Bcb->Section, &FileSizes->FileSize);
+ Bcb->FileSizes = *FileSizes;
- ExReleaseFastMutex(&CcCacheViewLock);
+ ExReleaseFastMutex (&CcCacheViewLock);
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcSetLogHandleForFile (
- IN PFILE_OBJECT FileObject,
- IN PVOID LogHandle,
- IN PFLUSH_TO_LSN FlushToLsnRoutine
- )
+VOID STDCALL
+CcSetLogHandleForFile (IN PFILE_OBJECT FileObject,
+ IN PVOID LogHandle,
+ IN PFLUSH_TO_LSN FlushToLsnRoutine)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
-
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/mdl.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/mdl.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/mdl.c Mon Mar 27 22:17:12 2006
@@ -19,21 +19,18 @@
/*
* @implemented
*/
-VOID
-STDCALL
-CcMdlRead(
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- OUT PMDL * MdlChain,
- OUT PIO_STATUS_BLOCK IoStatus
- )
+VOID STDCALL
+CcMdlRead (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ OUT PMDL * MdlChain,
+ OUT PIO_STATUS_BLOCK IoStatus)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
- * NAME INTERNAL
+ * NAME INTERNAL
* CcMdlReadCompleteDev@8
*
* DESCRIPTION
@@ -46,13 +43,12 @@
* None.
*
* NOTE
- * Used by CcMdlReadComplete@8 and FsRtl
+ * Used by CcMdlReadComplete@8 and FsRtl
*
*/
-VOID
-STDCALL
-CcMdlReadCompleteDev(IN PMDL MdlChain,
- IN PFILE_OBJECT FileObject)
+VOID STDCALL
+CcMdlReadCompleteDev (IN PMDL MdlChain,
+ IN PFILE_OBJECT FileObject)
{
PMDL Mdl;
@@ -60,8 +56,8 @@
while ((Mdl = MdlChain))
{
MdlChain = Mdl->Next;
- MmUnlockPages(Mdl);
- IoFreeMdl(Mdl);
+ MmUnlockPages (Mdl);
+ IoFreeMdl (Mdl);
}
}
@@ -81,66 +77,58 @@
*
* @implemented
*/
-VOID
-STDCALL
-CcMdlReadComplete(IN PFILE_OBJECT FileObject,
- IN PMDL MdlChain)
-{
- PDEVICE_OBJECT DeviceObject = NULL;
- PFAST_IO_DISPATCH FastDispatch;
-
- /* Get Fast Dispatch Data */
- DeviceObject = IoGetRelatedDeviceObject(FileObject);
- FastDispatch = DeviceObject->DriverObject->FastIoDispatch;
-
- /* Check if we support Fast Calls, and check this one */
- if (FastDispatch && FastDispatch->MdlReadComplete)
- {
- /* Use the fast path */
- FastDispatch->MdlReadComplete(FileObject,
- MdlChain,
- DeviceObject);
- }
-
- /* Use slow path */
- CcMdlReadCompleteDev(MdlChain, FileObject);
-}
-
-/*
- * @implemented
- */
-VOID
-STDCALL
-CcMdlWriteComplete(IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
+VOID STDCALL
+CcMdlReadComplete (IN PFILE_OBJECT FileObject,
IN PMDL MdlChain)
{
PDEVICE_OBJECT DeviceObject = NULL;
PFAST_IO_DISPATCH FastDispatch;
/* Get Fast Dispatch Data */
- DeviceObject = IoGetRelatedDeviceObject(FileObject);
+ DeviceObject = IoGetRelatedDeviceObject (FileObject);
+ FastDispatch = DeviceObject->DriverObject->FastIoDispatch;
+
+ /* Check if we support Fast Calls, and check this one */
+ if (FastDispatch && FastDispatch->MdlReadComplete)
+ {
+ /* Use the fast path */
+ FastDispatch->MdlReadComplete (FileObject, MdlChain, DeviceObject);
+ }
+
+ /* Use slow path */
+ CcMdlReadCompleteDev (MdlChain, FileObject);
+}
+
+/*
+ * @implemented
+ */
+VOID STDCALL
+CcMdlWriteComplete (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN PMDL MdlChain)
+{
+ PDEVICE_OBJECT DeviceObject = NULL;
+ PFAST_IO_DISPATCH FastDispatch;
+
+ /* Get Fast Dispatch Data */
+ DeviceObject = IoGetRelatedDeviceObject (FileObject);
FastDispatch = DeviceObject->DriverObject->FastIoDispatch;
/* Check if we support Fast Calls, and check this one */
if (FastDispatch && FastDispatch->MdlWriteComplete)
{
- /* Use the fast path */
- FastDispatch->MdlWriteComplete(FileObject,
- FileOffset,
- MdlChain,
- DeviceObject);
+ /* Use the fast path */
+ FastDispatch->MdlWriteComplete (FileObject, FileOffset, MdlChain,
DeviceObject);
}
/* Use slow path */
- CcMdlWriteCompleteDev(FileOffset, MdlChain, FileObject);
+ CcMdlWriteCompleteDev (FileOffset, MdlChain, FileObject);
}
-VOID
-STDCALL
-CcMdlWriteCompleteDev(IN PLARGE_INTEGER FileOffset,
- IN PMDL MdlChain,
- IN PFILE_OBJECT FileObject)
+VOID STDCALL
+CcMdlWriteCompleteDev (IN PLARGE_INTEGER FileOffset,
+ IN PMDL MdlChain,
+ IN PFILE_OBJECT FileObject)
{
UNIMPLEMENTED;
}
@@ -148,28 +136,22 @@
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcMdlWriteAbort (
- IN PFILE_OBJECT FileObject,
- IN PMDL MdlChain
- )
+VOID STDCALL
+CcMdlWriteAbort (IN PFILE_OBJECT FileObject,
+ IN PMDL MdlChain)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcPrepareMdlWrite (
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- OUT PMDL * MdlChain,
- OUT PIO_STATUS_BLOCK IoStatus
- )
+VOID STDCALL
+CcPrepareMdlWrite (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ OUT PMDL * MdlChain,
+ OUT PIO_STATUS_BLOCK IoStatus)
{
- UNIMPLEMENTED;
+ UNIMPLEMENTED;
}
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/pin.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/pin.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/pin.c Mon Mar 27 22:17:12 2006
@@ -24,217 +24,208 @@
/* FUNCTIONS *****************************************************************/
-NTSTATUS STDCALL
-MmMapViewInSystemCache(PCACHE_VIEW);
-
-
-/*
- * @implemented
- */
-BOOLEAN STDCALL
-CcMapData(IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN BOOLEAN Wait,
- OUT PVOID* piBcb,
- OUT PVOID* pBuffer)
-{
- PINTERNAL_BCB iBcb;
- PBCB Bcb;
- ULONG Index;
- NTSTATUS Status;
- PLIST_ENTRY entry;
- PCACHE_VIEW current = NULL;
-
- DPRINT("CcMapData(FileObject 0x%p, FileOffset %I64x, Length %d, Wait %d,"
- " pBcb 0x%p, pBuffer 0x%p)\n", FileObject, FileOffset->QuadPart,
- Length, Wait, piBcb, pBuffer);
-
- ASSERT (FileObject);
- ASSERT (FileObject->SectionObjectPointer);
- ASSERT (FileObject->SectionObjectPointer->SharedCacheMap);
- ASSERT (FileOffset);
- ASSERT (piBcb);
- ASSERT (pBuffer);
-
- if (!Wait)
- {
- *piBcb = NULL;
- *pBuffer = NULL;
- return FALSE;
- }
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
-
- if (FileOffset->QuadPart + Length > Bcb->FileSizes.AllocationSize.QuadPart)
- {
- DPRINT("%d %I64d %I64d\n", Length, FileOffset->QuadPart + Length,
Bcb->FileSizes.AllocationSize.QuadPart);
+NTSTATUS STDCALL MmMapViewInSystemCache (PCACHE_VIEW);
+
+
+/*
+ * @implemented
+ */
+BOOLEAN STDCALL
+CcMapData (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN BOOLEAN Wait,
+ OUT PVOID * piBcb,
+ OUT PVOID * pBuffer)
+{
+ PINTERNAL_BCB iBcb;
+ PBCB Bcb;
+ ULONG Index;
+ NTSTATUS Status;
+ PLIST_ENTRY entry;
+ PCACHE_VIEW current = NULL;
+
+ DPRINT ("CcMapData(FileObject 0x%p, FileOffset %I64x, Length %d, Wait %d,"
+ " pBcb 0x%p, pBuffer 0x%p)\n", FileObject, FileOffset->QuadPart,
Length, Wait, piBcb, pBuffer);
+
+ ASSERT (FileObject);
+ ASSERT (FileObject->SectionObjectPointer);
+ ASSERT (FileObject->SectionObjectPointer->SharedCacheMap);
+ ASSERT (FileOffset);
+ ASSERT (piBcb);
+ ASSERT (pBuffer);
+
+ if (!Wait)
+ {
+ *piBcb = NULL;
+ *pBuffer = NULL;
+ return FALSE;
+ }
+
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+
+ if (FileOffset->QuadPart + Length > Bcb->FileSizes.AllocationSize.QuadPart)
+ {
+ DPRINT ("%d %I64d %I64d\n", Length, FileOffset->QuadPart + Length,
Bcb->FileSizes.AllocationSize.QuadPart);
// KEBUGCHECK(0);
- }
-
- if (FileOffset->QuadPart + Length - ROUND_DOWN(FileOffset->QuadPart,
CACHE_VIEW_SIZE) > CACHE_VIEW_SIZE)
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
-
-
- if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof(Bcb->CacheView) /
sizeof(Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- ExAcquireFastMutex(&CcCacheViewLock);
-
- Index = FileOffset->QuadPart / CACHE_VIEW_SIZE;
- if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
- {
- if (Bcb->CacheView[Index]->RefCount == 0)
- {
- RemoveEntryList(&Bcb->CacheView[Index]->ListEntry);
- InsertHeadList(&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
- }
- Bcb->CacheView[Index]->RefCount++;
- }
- else
- {
- if (IsListEmpty(&CcFreeCacheViewListHead))
- {
- /* not implemented */
- KEBUGCHECK(0);
- }
-
- entry = CcFreeCacheViewListHead.Flink;
- while (entry != &CcFreeCacheViewListHead)
- {
- current = CONTAINING_RECORD(entry, CACHE_VIEW, ListEntry);
- entry = entry->Flink;
- if (current->Bcb == NULL)
- {
- break;
- }
- }
- if (entry == &CcFreeCacheViewListHead)
- {
- KEBUGCHECK(0);
- }
-
- Bcb->CacheView[Index] = current;
-
- if(Bcb->CacheView[Index]->Bcb != NULL)
- {
- DPRINT1("%x\n", Bcb->CacheView[Index]->Bcb);
- /* not implemented */
- KEBUGCHECK(0);
- }
- Bcb->CacheView[Index]->RefCount = 1;
- Bcb->CacheView[Index]->Bcb = Bcb;
- Bcb->CacheView[Index]->SectionData.ViewOffset = Index * CACHE_VIEW_SIZE;
- Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
- Bcb->CacheView[Index]->SectionData.Segment = Bcb->Section->Segment;
-
- Status = MmMapViewInSystemCache(Bcb->CacheView[Index]);
-
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- }
- ExReleaseFastMutex(&CcCacheViewLock);
-
- iBcb = ExAllocateFromNPagedLookasideList(&iBcbLookasideList);
- if (iBcb == NULL)
- {
- KEBUGCHECK(0);
- }
- memset(iBcb, 0, sizeof(INTERNAL_BCB));
-
- iBcb->Bcb = Bcb;
- iBcb->Index = Index;
-
- *piBcb = iBcb;
- *pBuffer = (PVOID)((ULONG_PTR)Bcb->CacheView[Index]->BaseAddress +
(ULONG_PTR)(FileOffset->QuadPart -
Bcb->CacheView[Index]->SectionData.ViewOffset));
-
- DPRINT("CcMapData() done\n");
-
- return TRUE;
-}
-
-/*
- * @unimplemented
- */
-BOOLEAN
-STDCALL
-CcPinMappedData (
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN ULONG Flags,
- OUT PVOID * Bcb
- )
-{
- /* no-op for current implementation. */
- return TRUE;
-}
-
-/*
- * @unimplemented
- */
-BOOLEAN
-STDCALL
-CcPinRead (
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN ULONG Flags,
- OUT PVOID * Bcb,
- OUT PVOID * Buffer
- )
-{
- if (CcMapData(FileObject, FileOffset, Length, Flags, Bcb, Buffer))
- {
- if (CcPinMappedData(FileObject, FileOffset, Length, Flags, Bcb))
- return TRUE;
+ }
+
+ if (FileOffset->QuadPart + Length - ROUND_DOWN (FileOffset->QuadPart,
CACHE_VIEW_SIZE) > CACHE_VIEW_SIZE)
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+
+
+ if (Bcb->FileSizes.AllocationSize.QuadPart > sizeof (Bcb->CacheView) /
sizeof (Bcb->CacheView[0]) * CACHE_VIEW_SIZE)
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+
+ Index = FileOffset->QuadPart / CACHE_VIEW_SIZE;
+ if (Bcb->CacheView[Index] && Bcb->CacheView[Index]->Bcb == Bcb)
+ {
+ if (Bcb->CacheView[Index]->RefCount == 0)
+ {
+ RemoveEntryList (&Bcb->CacheView[Index]->ListEntry);
+ InsertHeadList (&CcInUseCacheViewListHead,
&Bcb->CacheView[Index]->ListEntry);
+ }
+ Bcb->CacheView[Index]->RefCount++;
+ }
else
- CcUnpinData(Bcb);
- }
- return FALSE;
-}
-
-/*
- * @unimplemented
- */
-BOOLEAN
-STDCALL
-CcPreparePinWrite (
- IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER FileOffset,
- IN ULONG Length,
- IN BOOLEAN Zero,
- IN ULONG Flags,
- OUT PVOID * Bcb,
- OUT PVOID * Buffer
- )
-{
- /*
- * FIXME: This is function is similar to CcPinRead, but doesn't
- * read the data if they're not present. Instead it should just
- * prepare the cache segments and zero them out if Zero == TRUE.
- *
- * For now calling CcPinRead is better than returning error or
- * just having UNIMPLEMENTED here.
- */
- return CcPinRead(FileObject, FileOffset, Length, Flags, Bcb, Buffer);
-}
-
-/*
- * @implemented
- */
-VOID STDCALL
-CcSetDirtyPinnedData (IN PVOID Bcb,
- IN PLARGE_INTEGER Lsn)
+ {
+ if (IsListEmpty (&CcFreeCacheViewListHead))
+ {
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+
+ entry = CcFreeCacheViewListHead.Flink;
+ while (entry != &CcFreeCacheViewListHead)
+ {
+ current = CONTAINING_RECORD (entry, CACHE_VIEW, ListEntry);
+ entry = entry->Flink;
+ if (current->Bcb == NULL)
+ {
+ break;
+ }
+ }
+ if (entry == &CcFreeCacheViewListHead)
+ {
+ KEBUGCHECK (0);
+ }
+
+ Bcb->CacheView[Index] = current;
+
+ if (Bcb->CacheView[Index]->Bcb != NULL)
+ {
+ DPRINT1 ("%x\n", Bcb->CacheView[Index]->Bcb);
+ /* not implemented */
+ KEBUGCHECK (0);
+ }
+ Bcb->CacheView[Index]->RefCount = 1;
+ Bcb->CacheView[Index]->Bcb = Bcb;
+ Bcb->CacheView[Index]->SectionData.ViewOffset = Index * CACHE_VIEW_SIZE;
+ Bcb->CacheView[Index]->SectionData.Section = Bcb->Section;
+ Bcb->CacheView[Index]->SectionData.Segment = Bcb->Section->Segment;
+
+ Status = MmMapViewInSystemCache (Bcb->CacheView[Index]);
+
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+
+ iBcb = ExAllocateFromNPagedLookasideList (&iBcbLookasideList);
+ if (iBcb == NULL)
+ {
+ KEBUGCHECK (0);
+ }
+ memset (iBcb, 0, sizeof (INTERNAL_BCB));
+
+ iBcb->Bcb = Bcb;
+ iBcb->Index = Index;
+
+ *piBcb = iBcb;
+ *pBuffer =
+ (PVOID) ((ULONG_PTR) Bcb->CacheView[Index]->BaseAddress +
+ (ULONG_PTR) (FileOffset->QuadPart -
Bcb->CacheView[Index]->SectionData.ViewOffset));
+
+ DPRINT ("CcMapData() done\n");
+
+ return TRUE;
+}
+
+/*
+ * @unimplemented
+ */
+BOOLEAN STDCALL
+CcPinMappedData (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN ULONG Flags,
+ OUT PVOID * Bcb)
+{
+ /* no-op for current implementation. */
+ return TRUE;
+}
+
+/*
+ * @unimplemented
+ */
+BOOLEAN STDCALL
+CcPinRead (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN ULONG Flags,
+ OUT PVOID * Bcb,
+ OUT PVOID * Buffer)
+{
+ if (CcMapData (FileObject, FileOffset, Length, Flags, Bcb, Buffer))
+ {
+ if (CcPinMappedData (FileObject, FileOffset, Length, Flags, Bcb))
+ return TRUE;
+ else
+ CcUnpinData (Bcb);
+ }
+ return FALSE;
+}
+
+/*
+ * @unimplemented
+ */
+BOOLEAN STDCALL
+CcPreparePinWrite (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER FileOffset,
+ IN ULONG Length,
+ IN BOOLEAN Zero,
+ IN ULONG Flags,
+ OUT PVOID * Bcb,
+ OUT PVOID * Buffer)
+{
+ /*
+ * FIXME: This is function is similar to CcPinRead, but doesn't
+ * read the data if they're not present. Instead it should just
+ * prepare the cache segments and zero them out if Zero == TRUE.
+ *
+ * For now calling CcPinRead is better than returning error or
+ * just having UNIMPLEMENTED here.
+ */
+ return CcPinRead (FileObject, FileOffset, Length, Flags, Bcb, Buffer);
+}
+
+/*
+ * @implemented
+ */
+VOID STDCALL
+CcSetDirtyPinnedData (IN PVOID Bcb,
+ IN PLARGE_INTEGER Lsn)
{
// PINTERNAL_BCB iBcb = Bcb;
// iBcb->Dirty = TRUE;
@@ -248,44 +239,38 @@
VOID STDCALL
CcUnpinData (IN PVOID _iBcb)
{
- PINTERNAL_BCB iBcb = _iBcb;
-
- DPRINT("CcUnpinData(%x)\n", _iBcb);
-
- ExAcquireFastMutex(&CcCacheViewLock);
- iBcb->Bcb->CacheView[iBcb->Index]->RefCount--;
- if (iBcb->Bcb->CacheView[iBcb->Index]->RefCount == 0)
- {
- RemoveEntryList(&iBcb->Bcb->CacheView[iBcb->Index]->ListEntry);
- InsertHeadList(&CcFreeCacheViewListHead,
&iBcb->Bcb->CacheView[iBcb->Index]->ListEntry);
- }
- ExReleaseFastMutex(&CcCacheViewLock);
- ExFreeToNPagedLookasideList(&iBcbLookasideList, iBcb);
-
- DPRINT("CcUnpinData done\n");
-}
-
-/*
- * @unimplemented
- */
-VOID
-STDCALL
-CcUnpinDataForThread (
- IN PVOID Bcb,
- IN ERESOURCE_THREAD ResourceThreadId
- )
-{
- UNIMPLEMENTED;
-}
-
-/*
- * @implemented
- */
-VOID
-STDCALL
-CcRepinBcb (
- IN PVOID Bcb
- )
+ PINTERNAL_BCB iBcb = _iBcb;
+
+ DPRINT ("CcUnpinData(%x)\n", _iBcb);
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+ iBcb->Bcb->CacheView[iBcb->Index]->RefCount--;
+ if (iBcb->Bcb->CacheView[iBcb->Index]->RefCount == 0)
+ {
+ RemoveEntryList (&iBcb->Bcb->CacheView[iBcb->Index]->ListEntry);
+ InsertHeadList (&CcFreeCacheViewListHead,
&iBcb->Bcb->CacheView[iBcb->Index]->ListEntry);
+ }
+ ExReleaseFastMutex (&CcCacheViewLock);
+ ExFreeToNPagedLookasideList (&iBcbLookasideList, iBcb);
+
+ DPRINT ("CcUnpinData done\n");
+}
+
+/*
+ * @unimplemented
+ */
+VOID STDCALL
+CcUnpinDataForThread (IN PVOID Bcb,
+ IN ERESOURCE_THREAD ResourceThreadId)
+{
+ UNIMPLEMENTED;
+}
+
+/*
+ * @implemented
+ */
+VOID STDCALL
+CcRepinBcb (IN PVOID Bcb)
{
// PINTERNAL_BCB iBcb = Bcb;
// iBcb->RefCount++;
@@ -295,13 +280,10 @@
/*
* @unimplemented
*/
-VOID
-STDCALL
-CcUnpinRepinnedBcb (
- IN PVOID Bcb,
- IN BOOLEAN WriteThrough,
- IN PIO_STATUS_BLOCK IoStatus)
-{
- KEBUGCHECK(0);
-}
-
+VOID STDCALL
+CcUnpinRepinnedBcb (IN PVOID Bcb,
+ IN BOOLEAN WriteThrough,
+ IN PIO_STATUS_BLOCK IoStatus)
+{
+ KEBUGCHECK (0);
+}
Modified: branches/cache_manager_rewrite/reactos/ntoskrnl/cc/view.c
URL:
http://svn.reactos.ru/svn/reactos/branches/cache_manager_rewrite/reactos/nt…
==============================================================================
--- branches/cache_manager_rewrite/reactos/ntoskrnl/cc/view.c (original)
+++ branches/cache_manager_rewrite/reactos/ntoskrnl/cc/view.c Mon Mar 27 22:17:12 2006
@@ -23,7 +23,7 @@
#undef ROUND_DOWN
#endif
-#define ROUND_UP(N, S) (((N) + (S) - 1) & ~((S) - 1))
+#define ROUND_UP(N, S) (((N) + (S) - 1) & ~((S) - 1))
#define ROUND_DOWN(N, S) ((N) & ~((S) - 1))
NPAGED_LOOKASIDE_LIST iBcbLookasideList;
@@ -37,21 +37,18 @@
LIST_ENTRY CcInUseCacheViewListHead;
PMEMORY_AREA CcCacheViewMemoryArea;
-NTSTATUS NTAPI
-MmCreateDataFileSection(PSECTION_OBJECT *SectionObject,
- ACCESS_MASK DesiredAccess,
- POBJECT_ATTRIBUTES ObjectAttributes,
- PLARGE_INTEGER UMaximumSize,
- ULONG SectionPageProtection,
- ULONG AllocationAttributes,
- PFILE_OBJECT FileObject,
- BOOLEAN CacheManager);
-
-NTSTATUS STDCALL
-MmUnmapViewInSystemCache(PCACHE_VIEW);
-
-NTSTATUS
-MmFlushDataFileSection(PSECTION_OBJECT Section, PLARGE_INTEGER StartOffset, ULONG
Length);
+NTSTATUS NTAPI MmCreateDataFileSection (PSECTION_OBJECT * SectionObject,
+ ACCESS_MASK DesiredAccess,
+ POBJECT_ATTRIBUTES ObjectAttributes,
+ PLARGE_INTEGER UMaximumSize,
+ ULONG SectionPageProtection,
+ ULONG AllocationAttributes,
+ PFILE_OBJECT FileObject,
+ BOOLEAN CacheManager);
+
+NTSTATUS STDCALL MmUnmapViewInSystemCache (PCACHE_VIEW);
+
+NTSTATUS MmFlushDataFileSection (PSECTION_OBJECT Section, PLARGE_INTEGER StartOffset,
ULONG Length);
/* FUNCTIONS *****************************************************************/
@@ -59,247 +56,220 @@
* @implemented
*/
VOID STDCALL
-CcFlushCache(IN PSECTION_OBJECT_POINTERS SectionObjectPointers,
- IN PLARGE_INTEGER FileOffset OPTIONAL,
- IN ULONG Length,
- OUT PIO_STATUS_BLOCK IoStatus)
-{
- PBCB Bcb;
- NTSTATUS Status = STATUS_SUCCESS;
-
- DPRINT("CcFlushCache(SectionObjectPointers 0x%p, FileOffset 0x%p, Length %d,
IoStatus 0x%p)\n",
- SectionObjectPointers, FileOffset, Length, IoStatus);
-
- if (SectionObjectPointers && SectionObjectPointers->SharedCacheMap)
- {
- Bcb = (PBCB)SectionObjectPointers->SharedCacheMap;
- ASSERT(Bcb);
-
- Status = MmFlushDataFileSection(Bcb->Section, FileOffset, Length);
- }
- if (IoStatus)
- {
- IoStatus->Status = Status;
- IoStatus->Status = STATUS_SUCCESS;
- }
+CcFlushCache (IN PSECTION_OBJECT_POINTERS SectionObjectPointers,
+ IN PLARGE_INTEGER FileOffset OPTIONAL,
+ IN ULONG Length,
+ OUT PIO_STATUS_BLOCK IoStatus)
+{
+ PBCB Bcb;
+ NTSTATUS Status = STATUS_SUCCESS;
+
+ DPRINT ("CcFlushCache(SectionObjectPointers 0x%p, FileOffset 0x%p, Length %d,
IoStatus 0x%p)\n",
+ SectionObjectPointers, FileOffset, Length, IoStatus);
+
+ if (SectionObjectPointers && SectionObjectPointers->SharedCacheMap)
+ {
+ Bcb = (PBCB) SectionObjectPointers->SharedCacheMap;
+ ASSERT (Bcb);
+
+ Status = MmFlushDataFileSection (Bcb->Section, FileOffset, Length);
+ }
+ if (IoStatus)
+ {
+ IoStatus->Status = Status;
+ IoStatus->Status = STATUS_SUCCESS;
+ }
}
/*
* @implemented
*/
PFILE_OBJECT STDCALL
-CcGetFileObjectFromSectionPtrs(IN PSECTION_OBJECT_POINTERS SectionObjectPointers)
-{
- PBCB Bcb;
- if (SectionObjectPointers && SectionObjectPointers->SharedCacheMap)
- {
- Bcb = (PBCB)SectionObjectPointers->SharedCacheMap;
- ASSERT(Bcb);
- return Bcb->FileObject;
- }
- return NULL;
-}
-
-
-VOID
-INIT_FUNCTION
-NTAPI
-CcInitView(VOID)
-
-{
- NTSTATUS Status;
- PHYSICAL_ADDRESS BoundaryAddressMultiple;
- ULONG i;
- ULONG Size;
- PVOID Base;
-
- DPRINT("CcInitView()\n");
-
- ExInitializeFastMutex(&CcCacheViewLock);
-
- ExInitializeNPagedLookasideList (&iBcbLookasideList,
- NULL,
- NULL,
- 0,
- sizeof(INTERNAL_BCB),
- TAG_IBCB,
- 20);
- ExInitializeNPagedLookasideList (&BcbLookasideList,
- NULL,
- NULL,
- 0,
- sizeof(BCB),
- TAG_BCB,
- 20);
-
- InitializeListHead(&CcFreeCacheViewListHead);
- InitializeListHead(&CcInUseCacheViewListHead);
-
- BoundaryAddressMultiple.QuadPart = 0LL;
-
- Size = MmSystemRangeStart >= (PVOID)0xC0000000 ? 0x18000000 : 0x20000000;
- CcCacheViewBase = (PVOID)(0xF0000000 - Size);
- MmLockAddressSpace(MmGetKernelAddressSpace());
-
- Status = MmCreateMemoryArea(
- MmGetKernelAddressSpace(),
- MEMORY_AREA_CACHE_SEGMENT,
- &CcCacheViewBase,
- Size,
- 0,
- &CcCacheViewMemoryArea,
- FALSE,
- FALSE,
- BoundaryAddressMultiple);
- MmUnlockAddressSpace(MmGetKernelAddressSpace());
- DPRINT1("CcCacheViewBase: %x\n", CcCacheViewBase);
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- CcCacheViewArray = ExAllocatePool(NonPagedPool, sizeof(CACHE_VIEW) * (Size /
CACHE_VIEW_SIZE));
- if (CcCacheViewArray == NULL)
- {
- KEBUGCHECK(0);
- }
-
- Base = CcCacheViewBase;
- CcCacheViewArrayCount = Size / CACHE_VIEW_SIZE;
- for (i = 0; i < CcCacheViewArrayCount; i++)
- {
- CcCacheViewArray[i].BaseAddress = Base;
- CcCacheViewArray[i].RefCount = 0;
- CcCacheViewArray[i].Bcb = NULL;
- CcCacheViewArray[i].SectionData.ViewOffset = 0;
- InsertTailList(&CcFreeCacheViewListHead, &CcCacheViewArray[i].ListEntry);
- Base = (PVOID)((ULONG_PTR)Base + CACHE_VIEW_SIZE);
- }
- CcInitCacheZeroPage();
-
+CcGetFileObjectFromSectionPtrs (IN PSECTION_OBJECT_POINTERS SectionObjectPointers)
+{
+ PBCB Bcb;
+ if (SectionObjectPointers && SectionObjectPointers->SharedCacheMap)
+ {
+ Bcb = (PBCB) SectionObjectPointers->SharedCacheMap;
+ ASSERT (Bcb);
+ return Bcb->FileObject;
+ }
+ return NULL;
+}
+
+
+VOID INIT_FUNCTION NTAPI
+CcInitView (VOID)
+{
+ NTSTATUS Status;
+ PHYSICAL_ADDRESS BoundaryAddressMultiple;
+ ULONG i;
+ ULONG Size;
+ PVOID Base;
+
+ DPRINT ("CcInitView()\n");
+
+ ExInitializeFastMutex (&CcCacheViewLock);
+
+ ExInitializeNPagedLookasideList (&iBcbLookasideList, NULL, NULL, 0, sizeof
(INTERNAL_BCB), TAG_IBCB, 20);
+ ExInitializeNPagedLookasideList (&BcbLookasideList, NULL, NULL, 0, sizeof (BCB),
TAG_BCB, 20);
+
+ InitializeListHead (&CcFreeCacheViewListHead);
+ InitializeListHead (&CcInUseCacheViewListHead);
+
+ BoundaryAddressMultiple.QuadPart = 0LL;
+
+ Size = MmSystemRangeStart >= (PVOID) 0xC0000000 ? 0x18000000 : 0x20000000;
+ CcCacheViewBase = (PVOID) (0xF0000000 - Size);
+ MmLockAddressSpace (MmGetKernelAddressSpace ());
+
+ Status = MmCreateMemoryArea (MmGetKernelAddressSpace (),
+ MEMORY_AREA_CACHE_SEGMENT,
+ &CcCacheViewBase, Size, 0,
&CcCacheViewMemoryArea, FALSE, FALSE, BoundaryAddressMultiple);
+ MmUnlockAddressSpace (MmGetKernelAddressSpace ());
+ DPRINT1 ("CcCacheViewBase: %x\n", CcCacheViewBase);
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ CcCacheViewArray = ExAllocatePool (NonPagedPool, sizeof (CACHE_VIEW) * (Size /
CACHE_VIEW_SIZE));
+ if (CcCacheViewArray == NULL)
+ {
+ KEBUGCHECK (0);
+ }
+
+ Base = CcCacheViewBase;
+ CcCacheViewArrayCount = Size / CACHE_VIEW_SIZE;
+ for (i = 0; i < CcCacheViewArrayCount; i++)
+ {
+ CcCacheViewArray[i].BaseAddress = Base;
+ CcCacheViewArray[i].RefCount = 0;
+ CcCacheViewArray[i].Bcb = NULL;
+ CcCacheViewArray[i].SectionData.ViewOffset = 0;
+ InsertTailList (&CcFreeCacheViewListHead,
&CcCacheViewArray[i].ListEntry);
+ Base = (PVOID) ((ULONG_PTR) Base + CACHE_VIEW_SIZE);
+ }
+ CcInitCacheZeroPage ();
+
}
VOID STDCALL
-CcInitializeCacheMap(IN PFILE_OBJECT FileObject,
- IN PCC_FILE_SIZES FileSizes,
- IN BOOLEAN PinAccess,
- IN PCACHE_MANAGER_CALLBACKS CallBacks,
- IN PVOID LazyWriterContext)
-{
- PBCB Bcb;
- NTSTATUS Status;
-
- DPRINT("CcInitializeCacheMap(), %wZ\n", &FileObject->FileName);
- DPRINT("%I64x (%I64d)\n", FileSizes->FileSize.QuadPart,
FileSizes->FileSize.QuadPart);
-
- ASSERT (FileObject);
- ASSERT (FileSizes);
-
- ExAcquireFastMutex(&CcCacheViewLock);
-
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
- if (Bcb == NULL)
- {
- Bcb = ExAllocateFromNPagedLookasideList(&BcbLookasideList);
- if (Bcb == NULL)
- {
- KEBUGCHECK(0);
- }
- memset(Bcb, 0, sizeof(BCB));
-
- Bcb->FileObject = FileObject;
- Bcb->FileSizes = *FileSizes;
- Bcb->PinAccess = PinAccess;
- Bcb->CallBacks = CallBacks;
- Bcb->LazyWriterContext = LazyWriterContext;
- Bcb->RefCount = 0;
-
- DPRINT("%x %x\n", FileObject, FileSizes->FileSize.QuadPart);
-
- Status = MmCreateDataFileSection(&Bcb->Section,
- STANDARD_RIGHTS_REQUIRED | SECTION_QUERY |
SECTION_MAP_READ | SECTION_MAP_WRITE,
- NULL,
- &Bcb->FileSizes.FileSize,
- PAGE_READWRITE,
- SEC_COMMIT,
- Bcb->FileObject,
- TRUE);
- if (!NT_SUCCESS(Status))
- {
- DPRINT1("%x\n", Status);
- KEBUGCHECK(0);
- }
-
- FileObject->SectionObjectPointer->SharedCacheMap = Bcb;
- }
-
- if (FileObject->PrivateCacheMap == NULL)
- {
- FileObject->PrivateCacheMap = Bcb;
- Bcb->RefCount++;
- }
-
- ExReleaseFastMutex(&CcCacheViewLock);
- DPRINT("CcInitializeCacheMap() done\n");
+CcInitializeCacheMap (IN PFILE_OBJECT FileObject,
+ IN PCC_FILE_SIZES FileSizes,
+ IN BOOLEAN PinAccess,
+ IN PCACHE_MANAGER_CALLBACKS CallBacks,
+ IN PVOID LazyWriterContext)
+{
+ PBCB Bcb;
+ NTSTATUS Status;
+
+ DPRINT ("CcInitializeCacheMap(), %wZ\n", &FileObject->FileName);
+ DPRINT ("%I64x (%I64d)\n", FileSizes->FileSize.QuadPart,
FileSizes->FileSize.QuadPart);
+
+ ASSERT (FileObject);
+ ASSERT (FileSizes);
+
+ ExAcquireFastMutex (&CcCacheViewLock);
+
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+ if (Bcb == NULL)
+ {
+ Bcb = ExAllocateFromNPagedLookasideList (&BcbLookasideList);
+ if (Bcb == NULL)
+ {
+ KEBUGCHECK (0);
+ }
+ memset (Bcb, 0, sizeof (BCB));
+
+ Bcb->FileObject = FileObject;
+ Bcb->FileSizes = *FileSizes;
+ Bcb->PinAccess = PinAccess;
+ Bcb->CallBacks = CallBacks;
+ Bcb->LazyWriterContext = LazyWriterContext;
+ Bcb->RefCount = 0;
+
+ DPRINT ("%x %x\n", FileObject, FileSizes->FileSize.QuadPart);
+
+ Status = MmCreateDataFileSection (&Bcb->Section,
+ STANDARD_RIGHTS_REQUIRED | SECTION_QUERY |
SECTION_MAP_READ | SECTION_MAP_WRITE,
+ NULL, &Bcb->FileSizes.FileSize,
PAGE_READWRITE, SEC_COMMIT, Bcb->FileObject, TRUE);
+ if (!NT_SUCCESS (Status))
+ {
+ DPRINT1 ("%x\n", Status);
+ KEBUGCHECK (0);
+ }
+
+ FileObject->SectionObjectPointer->SharedCacheMap = Bcb;
+ }
+
+ if (FileObject->PrivateCacheMap == NULL)
+ {
+ FileObject->PrivateCacheMap = Bcb;
+ Bcb->RefCount++;
+ }
+
+ ExReleaseFastMutex (&CcCacheViewLock);
+ DPRINT ("CcInitializeCacheMap() done\n");
}
BOOLEAN STDCALL
-CcUninitializeCacheMap (IN PFILE_OBJECT FileObject,
- IN PLARGE_INTEGER TruncateSize OPTIONAL,
- IN PCACHE_UNINITIALIZE_EVENT UninitializeCompleteEvent OPTIONAL)
-{
- PBCB Bcb;
- ULONG i;
- NTSTATUS Status;
-
- DPRINT("CcUninitializeCacheMap(), %wZ\n", &FileObject->FileName);
- ExAcquireFastMutex(&CcCacheViewLock);
- Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
- if (Bcb)
- {
- if (FileObject->PrivateCacheMap == Bcb)
- {
- Bcb->RefCount--;
- FileObject->PrivateCacheMap = NULL;
- }
- if (Bcb->RefCount == 0)
- {
- Bcb->RefCount++;
- ExReleaseFastMutex(&CcCacheViewLock);
- MmFlushDataFileSection(Bcb->Section, NULL, 0);
- ExAcquireFastMutex(&CcCacheViewLock);
- Bcb->RefCount--;
- if (Bcb->RefCount == 0)
- {
- for (i = 0; i < ROUND_UP(Bcb->FileSizes.AllocationSize.QuadPart,
CACHE_VIEW_SIZE) / CACHE_VIEW_SIZE; i++)
- {
- if (Bcb->CacheView[i] && Bcb->CacheView[i]->Bcb == Bcb)
- {
- CHECKPOINT;
- if (Bcb->CacheView[i]->RefCount > 0)
- {
- KEBUGCHECK(0);
- }
- Status = MmUnmapViewInSystemCache(Bcb->CacheView[i]);
- if (!NT_SUCCESS(Status))
- {
- KEBUGCHECK(0);
- }
- Bcb->CacheView[i]->RefCount = 0;
- Bcb->CacheView[i]->Bcb = NULL;
- Bcb->CacheView[i] = NULL;
- }
- }
-
- DPRINT("%x\n", Bcb->Section);
- ObDereferenceObject(Bcb->Section);
- FileObject->SectionObjectPointer->SharedCacheMap = NULL;
- ExFreeToNPagedLookasideList(&BcbLookasideList, Bcb);
- }
- }
- }
- DPRINT("CcUninitializeCacheMap() done, %wZ\n",
&FileObject->FileName);
- ExReleaseFastMutex(&CcCacheViewLock);
- return TRUE;
+CcUninitializeCacheMap (IN PFILE_OBJECT FileObject,
+ IN PLARGE_INTEGER TruncateSize OPTIONAL,
+ IN PCACHE_UNINITIALIZE_EVENT UninitializeCompleteEvent OPTIONAL)
+{
+ PBCB Bcb;
+ ULONG i;
+ NTSTATUS Status;
+
+ DPRINT ("CcUninitializeCacheMap(), %wZ\n", &FileObject->FileName);
+ ExAcquireFastMutex (&CcCacheViewLock);
+ Bcb = FileObject->SectionObjectPointer->SharedCacheMap;
+ if (Bcb)
+ {
+ if (FileObject->PrivateCacheMap == Bcb)
+ {
+ Bcb->RefCount--;
+ FileObject->PrivateCacheMap = NULL;
+ }
+ if (Bcb->RefCount == 0)
+ {
+ Bcb->RefCount++;
+ ExReleaseFastMutex (&CcCacheViewLock);
+ MmFlushDataFileSection (Bcb->Section, NULL, 0);
+ ExAcquireFastMutex (&CcCacheViewLock);
+ Bcb->RefCount--;
+ if (Bcb->RefCount == 0)
+ {
+ for (i = 0; i < ROUND_UP (Bcb->FileSizes.AllocationSize.QuadPart,
CACHE_VIEW_SIZE) / CACHE_VIEW_SIZE; i++)
+ {
+ if (Bcb->CacheView[i] && Bcb->CacheView[i]->Bcb ==
Bcb)
+ {
+ CHECKPOINT;
+ if (Bcb->CacheView[i]->RefCount > 0)
+ {
+ KEBUGCHECK (0);
+ }
+ Status = MmUnmapViewInSystemCache (Bcb->CacheView[i]);
+ if (!NT_SUCCESS (Status))
+ {
+ KEBUGCHECK (0);
+ }
+ Bcb->CacheView[i]->RefCount = 0;
+ Bcb->CacheView[i]->Bcb = NULL;
+ Bcb->CacheView[i] = NULL;
+ }
+ }
+
+ DPRINT ("%x\n", Bcb->Section);
+ ObDereferenceObject (Bcb->Section);
+ FileObject->SectionObjectPointer->SharedCacheMap = NULL;
+ ExFreeToNPagedLookasideList (&BcbLookasideList, Bcb);
+ }
+ }
+ }
+ DPRINT ("CcUninitializeCacheMap() done, %wZ\n",
&FileObject->FileName);
+ ExReleaseFastMutex (&CcCacheViewLock);
+ return TRUE;
}
6751
days inactive
6751
days old
0 comments
1 participants
participants (1)
-
aleksey＠studiocerebral.com