cachesub.c File Reference

#include <ntoskrnl.h>
#include "newcc.h"
#include "section/newmm.h"
#include <debug.h>

Include dependency graph for cachesub.c:

Go to the source code of this file.

Classes
struct	_WORK_QUEUE_WITH_READ_AHEAD

Macros
#define	NDEBUG

Typedefs
typedef struct _WORK_QUEUE_WITH_READ_AHEAD	WORK_QUEUE_WITH_READ_AHEAD
typedef struct _WORK_QUEUE_WITH_READ_AHEAD *	PWORK_QUEUE_WITH_READ_AHEAD

Functions
PDEVICE_OBJECT NTAPI	MmGetDeviceObjectForFile (IN PFILE_OBJECT FileObject)
VOID NTAPI	CcSetReadAheadGranularity (IN PFILE_OBJECT FileObject, IN ULONG Granularity)
VOID NTAPI	CcpReadAhead (PVOID Context)
VOID NTAPI	CcScheduleReadAhead (IN PFILE_OBJECT FileObject, IN PLARGE_INTEGER FileOffset, IN ULONG Length)
VOID NTAPI	CcSetDirtyPinnedData (IN PVOID BcbVoid, IN OPTIONAL PLARGE_INTEGER Lsn)
LARGE_INTEGER NTAPI	CcGetFlushedValidData (IN PSECTION_OBJECT_POINTERS SectionObjectPointer, IN BOOLEAN CcInternalCaller)
VOID NTAPI	_CcpFlushCache (IN PNOCC_CACHE_MAP Map, IN OPTIONAL PLARGE_INTEGER FileOffset, IN ULONG Length, OUT OPTIONAL PIO_STATUS_BLOCK IoStatus, BOOLEAN Delete, const char *File, int Line)
VOID NTAPI	CcFlushCache (IN PSECTION_OBJECT_POINTERS SectionObjectPointer, IN OPTIONAL PLARGE_INTEGER FileOffset, IN ULONG Length, OUT OPTIONAL PIO_STATUS_BLOCK IoStatus)
BOOLEAN NTAPI	CcFlushImageSection (PSECTION_OBJECT_POINTERS SectionObjectPointer, MMFLUSH_TYPE FlushType)
PVOID NTAPI	CcRemapBcb (IN PVOID Bcb)
VOID NTAPI	CcShutdownSystem (VOID)
VOID NTAPI	CcRepinBcb (IN PVOID Bcb)
VOID NTAPI	CcUnpinRepinnedBcb (IN PVOID Bcb, IN BOOLEAN WriteThrough, OUT PIO_STATUS_BLOCK IoStatus)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 15 of file cachesub.c.

Typedef Documentation

PWORK_QUEUE_WITH_READ_AHEAD

typedef struct _WORK_QUEUE_WITH_READ_AHEAD * PWORK_QUEUE_WITH_READ_AHEAD

WORK_QUEUE_WITH_READ_AHEAD

typedef struct _WORK_QUEUE_WITH_READ_AHEAD WORK_QUEUE_WITH_READ_AHEAD

Function Documentation

_CcpFlushCache()

VOID NTAPI _CcpFlushCache	(	IN PNOCC_CACHE_MAP	Map,
		IN OPTIONAL PLARGE_INTEGER	FileOffset,
		IN ULONG	Length,
		OUT OPTIONAL PIO_STATUS_BLOCK	IoStatus,
		BOOLEAN	Delete,
		const char *	File,
		int	Line
	)

Definition at line 142 of file cachesub.c.

{
    PNOCC_BCB Bcb = NULL;
    LARGE_INTEGER LowerBound, UpperBound;
    PLIST_ENTRY ListEntry;
    IO_STATUS_BLOCK IOSB;
 
    RtlZeroMemory(&IOSB, sizeof(IO_STATUS_BLOCK));
 
    DPRINT("CcFlushCache (while file) (%s:%d)\n", File, Line);
 
    if (FileOffset && Length)
    {
        LowerBound.QuadPart = FileOffset->QuadPart;
        UpperBound.QuadPart = LowerBound.QuadPart + Length;
    }
    else
    {
        LowerBound.QuadPart = 0;
        UpperBound.QuadPart = 0x7fffffffffffffffull;
    }
 
    CcpLock();
    ListEntry = Map->AssociatedBcb.Flink;
 
    while (ListEntry != &Map->AssociatedBcb)
    {
        Bcb = CONTAINING_RECORD(ListEntry, NOCC_BCB, ThisFileList);
        CcpReferenceCache((ULONG)(Bcb - CcCacheSections));
 
        if (Bcb->FileOffset.QuadPart + Bcb->Length >= LowerBound.QuadPart &&
            Bcb->FileOffset.QuadPart < UpperBound.QuadPart)
        {
            DPRINT("Bcb #%x (@%08x%08x)\n",
                   Bcb - CcCacheSections,
                   Bcb->FileOffset.u.HighPart, Bcb->FileOffset.u.LowPart);
 
            Bcb->RefCount++;
            CcpUnlock();
            MiFlushMappedSection(Bcb->BaseAddress,
                                 &Bcb->FileOffset,
                                 &Map->FileSizes.FileSize,
                                 Bcb->Dirty);
            CcpLock();
            Bcb->RefCount--;
 
            Bcb->Dirty = FALSE;
 
            ListEntry = ListEntry->Flink;
            if (Delete && Bcb->RefCount < 2)
            {
                Bcb->RefCount = 1;
                CcpDereferenceCache((ULONG)(Bcb - CcCacheSections), FALSE);
            }
            else
            {
                CcpUnpinData(Bcb, TRUE);
            }
        }
        else
        {
            ListEntry = ListEntry->Flink;
            CcpUnpinData(Bcb, TRUE);
        }
 
        DPRINT("End loop\n");
    }
    CcpUnlock();
 
    if (IoStatus) *IoStatus = IOSB;
}

CcFlushCache()

VOID NTAPI CcFlushCache	(	IN PSECTION_OBJECT_POINTERS	SectionObjectPointer,
		IN OPTIONAL PLARGE_INTEGER FileOffset	,
		IN ULONG	Length,
		OUT OPTIONAL PIO_STATUS_BLOCK	IoStatus
	)

Definition at line 222 of file cachesub.c.

{
    PNOCC_CACHE_MAP Map = (PNOCC_CACHE_MAP)SectionObjectPointer->SharedCacheMap;
 
    /* Not cached */
    if (!Map)
    {
        if (IoStatus)
        {
            IoStatus->Status = STATUS_SUCCESS;
            IoStatus->Information = 0;
        }
        return;
    }
 
    CcpFlushCache(Map, FileOffset, Length, IoStatus, TRUE);
}

Referenced by __attribute__(), _Dispatch_type_(), _Requires_lock_held_(), CcCopyWrite(), CcFlushImageSection(), CcUnpinRepinnedBcb(), CcZeroData(), Ext2Cleanup(), Ext2CreateFile(), Ext2FloppyFlush(), Ext2FlushFile(), Ext2FlushRange(), Ext2FlushVcb(), Ext2PurgeFile(), Ext2PurgeVolume(), Ext2ReadFile(), Ext2TearDownStream(), Ext2WriteFile(), Ext2WriteVolume(), FatCloseEaFile(), FatCommonSetEa(), FatDeferredFlush(), FatFlushDirentForFile(), FatFlushFatEntries(), flush_fcb_caches(), flush_subvol_fcbs(), MmCreateImageSection(), PerformTest(), RxCommonRead(), RxCommonWrite(), RxFlushFcbInSystemCache(), set_rename_information(), set_zero_data(), TestIrpHandler(), UDFCloseAllXXXDelayedInDir(), UDFCommonCleanup(), UDFCommonCreate(), UDFCommonRead(), UDFCommonWrite(), UDFFlushAFile(), UDFPurgeCacheEx_(), VfatFlushFile(), VfatMoveEntry(), vfatRenameEntry(), and vfatUpdateFCB().

CcFlushImageSection()

BOOLEAN NTAPI CcFlushImageSection	(	PSECTION_OBJECT_POINTERS	SectionObjectPointer,
		MMFLUSH_TYPE	FlushType
	)

Definition at line 245 of file cachesub.c.

{
    PNOCC_CACHE_MAP Map = (PNOCC_CACHE_MAP)SectionObjectPointer->SharedCacheMap;
    PNOCC_BCB Bcb;
    PLIST_ENTRY Entry;
    IO_STATUS_BLOCK IOSB;
    BOOLEAN Result = TRUE;
 
    if (!Map) return TRUE;
 
    for (Entry = Map->AssociatedBcb.Flink;
         Entry != &Map->AssociatedBcb;
         Entry = Entry->Flink)
    {
        Bcb = CONTAINING_RECORD(Entry, NOCC_BCB, ThisFileList);
 
        if (!Bcb->Dirty) continue;
 
        switch (FlushType)
        {
            case MmFlushForDelete:
                CcPurgeCacheSection(SectionObjectPointer,
                                    &Bcb->FileOffset,
                                    Bcb->Length,
                                    FALSE);
                break;
            case MmFlushForWrite:
                CcFlushCache(SectionObjectPointer,
                             &Bcb->FileOffset,
                             Bcb->Length,
                             &IOSB);
                break;
        }
    }
 
    return Result;
}

CcGetFlushedValidData()

LARGE_INTEGER NTAPI CcGetFlushedValidData	(	IN PSECTION_OBJECT_POINTERS	SectionObjectPointer,
		IN BOOLEAN	CcInternalCaller
	)

Definition at line 130 of file cachesub.c.

{
    LARGE_INTEGER Result = {{0}};
    UNIMPLEMENTED_DBGBREAK();
    return Result;
}

Referenced by PerformTest().

CcpReadAhead()

VOID NTAPI CcpReadAhead

(

PVOID

Context

)

Definition at line 48 of file cachesub.c.

{
    LARGE_INTEGER Offset;
    PWORK_QUEUE_WITH_READ_AHEAD WorkItem = (PWORK_QUEUE_WITH_READ_AHEAD)Context;
    PNOCC_CACHE_MAP Map = (PNOCC_CACHE_MAP)WorkItem->FileObject->SectionObjectPointer->SharedCacheMap;
 
    DPRINT1("Reading ahead %08x%08x:%x %wZ\n",
            WorkItem->FileOffset.HighPart,
            WorkItem->FileOffset.LowPart,
            WorkItem->Length,
            &WorkItem->FileObject->FileName);
 
    Offset.HighPart = WorkItem->FileOffset.HighPart;
    Offset.LowPart = PAGE_ROUND_DOWN(WorkItem->FileOffset.LowPart);
    if (Map)
    {
        PLIST_ENTRY ListEntry;
        volatile char *chptr;
        PNOCC_BCB Bcb;
        for (ListEntry = Map->AssociatedBcb.Flink;
             ListEntry != &Map->AssociatedBcb;
             ListEntry = ListEntry->Flink)
        {
            Bcb = CONTAINING_RECORD(ListEntry, NOCC_BCB, ThisFileList);
            if ((Offset.QuadPart + WorkItem->Length < Bcb->FileOffset.QuadPart) ||
                (Bcb->FileOffset.QuadPart + Bcb->Length < Offset.QuadPart))
                continue;
            for (chptr = Bcb->BaseAddress, Offset = Bcb->FileOffset;
                 chptr < ((PCHAR)Bcb->BaseAddress) + Bcb->Length &&
                     Offset.QuadPart <
                     WorkItem->FileOffset.QuadPart + WorkItem->Length;
                 chptr += PAGE_SIZE, Offset.QuadPart += PAGE_SIZE)
            {
                *chptr ^= 0;
            }
        }
    }
    ObDereferenceObject(WorkItem->FileObject);
    ExFreePool(WorkItem);
    DPRINT("Done\n");
}

Referenced by CcScheduleReadAhead().

CcRemapBcb()

PVOID NTAPI CcRemapBcb

(

IN PVOID

Bcb

)

Definition at line 287 of file cachesub.c.

{
    ULONG Number = (ULONG)(((PNOCC_BCB)Bcb) - CcCacheSections);
    CcpLock();
    ASSERT(RtlTestBit(CcCacheBitmap, Number));
    CcpReferenceCache(Number);
    CcpUnlock();
    return Bcb;
}

CcRepinBcb()

VOID NTAPI CcRepinBcb

(

IN PVOID

Bcb

)

Definition at line 331 of file cachesub.c.

{
    ULONG Number = (ULONG)(((PNOCC_BCB)Bcb) - CcCacheSections);
    CcpLock();
    ASSERT(RtlTestBit(CcCacheBitmap, Number));
    DPRINT("CcRepinBcb(#%x)\n", Number);
    CcpReferenceCache(Number);
    CcpUnlock();
}

Referenced by FatFlushFat(), and FatRepinBcb().

CcScheduleReadAhead()

VOID NTAPI CcScheduleReadAhead	(	IN PFILE_OBJECT	FileObject,
		IN PLARGE_INTEGER	FileOffset,
		IN ULONG	Length
	)

Definition at line 92 of file cachesub.c.

{
    PWORK_QUEUE_WITH_READ_AHEAD WorkItem;
 
    DPRINT("Schedule read ahead %08x%08x:%x %wZ\n",
           FileOffset->HighPart,
           FileOffset->LowPart,
           Length,
           &FileObject->FileName);
 
    WorkItem = ExAllocatePool(NonPagedPool, sizeof(*WorkItem));
    if (!WorkItem) KeBugCheck(0);
    ObReferenceObject(FileObject);
    WorkItem->FileObject = FileObject;
    WorkItem->FileOffset = *FileOffset;
    WorkItem->Length = Length;
 
    ExInitializeWorkItem(&WorkItem->WorkItem,
                         (PWORKER_THREAD_ROUTINE)CcpReadAhead,
                         WorkItem);
 
    ExQueueWorkItem(&WorkItem->WorkItem, DelayedWorkQueue);
    DPRINT("Done\n");
}

Referenced by CcCopyRead().

CcSetDirtyPinnedData()

VOID NTAPI CcSetDirtyPinnedData	(	IN PVOID	BcbVoid,
		IN OPTIONAL PLARGE_INTEGER	Lsn
	)

Definition at line 121 of file cachesub.c.

{
    PNOCC_BCB Bcb = (PNOCC_BCB)BcbVoid;
    Bcb->Dirty = TRUE;
}

Referenced by Ext2ExpandBlock(), Ext2FreeBlock(), Ext2GetBlock(), Ext2TruncateBlock(), FAT12FindAndMarkAvailableCluster(), FAT12WriteCluster(), FAT16FindAndMarkAvailableCluster(), FAT16SetDirtyStatus(), FAT16WriteCluster(), FAT32FindAndMarkAvailableCluster(), FAT32SetDirtyStatus(), FAT32UpdateFreeClustersCount(), FAT32WriteCluster(), FATAddEntry(), FATDelEntry(), FatFlushFat(), FatMarkEaRangeDirty(), FATXAddEntry(), FATXDelEntry(), FsdSetFsLabelInformation(), PerformTest(), submit_bh_mdl(), submit_bh_pin(), vfatFindDirSpace(), vfatRenameEntry(), and VfatUpdateEntry().

CcSetReadAheadGranularity()

VOID NTAPI CcSetReadAheadGranularity	(	IN PFILE_OBJECT	FileObject,
		IN ULONG	Granularity
	)

Definition at line 36 of file cachesub.c.

{
    PNOCC_CACHE_MAP Map = (PNOCC_CACHE_MAP)FileObject->SectionObjectPointer->SharedCacheMap;
    if (Map)
    {
        Map->ReadAheadGranularity = Granularity;
    }
}

Referenced by _Requires_lock_held_(), Ext2ReadFile(), Ext2WriteFile(), init_file_cache(), RxCommonRead(), RxCommonWrite(), UDFCommonRead(), and UDFCommonWrite().

CcShutdownSystem()

VOID NTAPI CcShutdownSystem

(

VOID

)

Definition at line 299 of file cachesub.c.

{
    ULONG i, Result;
    NTSTATUS Status;
 
    DPRINT1("CC: Shutdown\n");
 
    for (i = 0; i < CACHE_NUM_SECTIONS; i++)
    {
        PNOCC_BCB Bcb = &CcCacheSections[i];
        if (Bcb->SectionObject)
        {
            DPRINT1("Evicting #%02x %08x%08x %wZ\n",
                    i,
                    Bcb->FileOffset.u.HighPart,
                    Bcb->FileOffset.u.LowPart,
                    &MmGetFileObjectForSection((PROS_SECTION_OBJECT)Bcb->SectionObject)->FileName);
 
            CcpFlushCache(Bcb->Map, NULL, 0, NULL, TRUE);
            Bcb->Dirty = FALSE;
        }
    }
 
    /* Evict all section pages */
    Status = MiRosTrimCache(~0, 0, &Result);
 
    DPRINT1("Done (Evicted %d, Status %x)\n", Result, Status);
}

Referenced by PopGracefulShutdown().

CcUnpinRepinnedBcb()

VOID NTAPI CcUnpinRepinnedBcb	(	IN PVOID	Bcb,
		IN BOOLEAN	WriteThrough,
		OUT PIO_STATUS_BLOCK	IoStatus
	)

Definition at line 343 of file cachesub.c.

{
    PNOCC_BCB RealBcb = (PNOCC_BCB)Bcb;
 
    if (WriteThrough)
    {
        DPRINT("BCB #%x\n", RealBcb - CcCacheSections);
 
        CcpFlushCache(RealBcb->Map,
                      &RealBcb->FileOffset,
                      RealBcb->Length,
                      IoStatus,
                      RealBcb->Dirty);
    }
 
    CcUnpinData(Bcb);
}

Referenced by FatFlushFat(), and FatUnpinRepinnedBcbs().

MmGetDeviceObjectForFile()

PDEVICE_OBJECT NTAPI MmGetDeviceObjectForFile

(

IN PFILE_OBJECT

FileObject

)

Definition at line 57 of file io.c.

{
    return IoGetRelatedDeviceObject(FileObject);
}