mirror of
https://github.com/reactos/reactos.git
synced 2024-06-30 09:50:07 +00:00
7e550edb26
Instead move to a threading model like the Windows one. We'll queue several work items to be executed in a system thread (Cc worker) when there are VACB that have been marked as dirty. Furthermore, some delay will be observed before action to avoid killing the system with IOs. This new threading model opens way for read ahead and write behind implementation. Also, moved the initialization of the lazy writer to CcInitializeCacheManager() it has nothing to do with views and shouldn't be initialized there. Also, moved the lazy writer implementation to its own file. Modified CcDeferWrite() and CcRosMarkDirtyVacb() to take into account the new threading model. Introduced new functions: - CcPostWorkQueue(): post an item to be handled by Cc worker and spawn a worker if required - CcScanDpc(): called after some time (not to have lazy writer always running) to queue a lazy scan - CcLazyWriteScan(): the lazy writer we used to have - CcScheduleLazyWriteScan(): function to call when you want to start a lazy writer run. It will make a DPC after some time and queue execution - CcWorkerThread(): the worker thread that will handle lazy write, read ahead, and so on
165 lines
3.8 KiB
C
165 lines
3.8 KiB
C
#pragma once
|
|
|
|
typedef struct _NOCC_BCB
|
|
{
|
|
/* Public part */
|
|
PUBLIC_BCB Bcb;
|
|
|
|
struct _NOCC_CACHE_MAP *Map;
|
|
PROS_SECTION_OBJECT SectionObject;
|
|
LARGE_INTEGER FileOffset;
|
|
ULONG Length;
|
|
PVOID BaseAddress;
|
|
BOOLEAN Dirty;
|
|
PVOID OwnerPointer;
|
|
|
|
/* Reference counts */
|
|
ULONG RefCount;
|
|
|
|
LIST_ENTRY ThisFileList;
|
|
|
|
KEVENT ExclusiveWait;
|
|
ULONG ExclusiveWaiter;
|
|
BOOLEAN Exclusive;
|
|
} NOCC_BCB, *PNOCC_BCB;
|
|
|
|
typedef struct _NOCC_CACHE_MAP
|
|
{
|
|
LIST_ENTRY Entry;
|
|
LIST_ENTRY AssociatedBcb;
|
|
LIST_ENTRY PrivateCacheMaps;
|
|
ULONG NumberOfMaps;
|
|
ULONG RefCount;
|
|
CC_FILE_SIZES FileSizes;
|
|
CACHE_MANAGER_CALLBACKS Callbacks;
|
|
PVOID LazyContext;
|
|
PVOID LogHandle;
|
|
PFLUSH_TO_LSN FlushToLsn;
|
|
ULONG ReadAheadGranularity;
|
|
} NOCC_CACHE_MAP, *PNOCC_CACHE_MAP;
|
|
|
|
VOID
|
|
NTAPI
|
|
CcPfInitializePrefetcher(VOID);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcMdlReadComplete2(IN PFILE_OBJECT FileObject,
|
|
IN PMDL MemoryDescriptorList);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcMdlWriteComplete2(IN PFILE_OBJECT FileObject,
|
|
IN PLARGE_INTEGER FileOffset,
|
|
IN PMDL MdlChain);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcInitView(VOID);
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcpUnpinData(PNOCC_BCB Bcb,
|
|
BOOLEAN ActuallyRelease);
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcInitializeCacheManager(VOID);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcShutdownSystem(VOID);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcInitCacheZeroPage(VOID);
|
|
|
|
/* Called by section.c */
|
|
BOOLEAN
|
|
NTAPI
|
|
CcFlushImageSection(PSECTION_OBJECT_POINTERS SectionObjectPointer,
|
|
MMFLUSH_TYPE FlushType);
|
|
|
|
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);
|
|
|
|
#define CcpFlushCache(M,F,L,I,D) _CcpFlushCache(M,F,L,I,D,__FILE__,__LINE__)
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcGetFileSizes(PFILE_OBJECT FileObject,
|
|
PCC_FILE_SIZES FileSizes);
|
|
|
|
ULONG
|
|
NTAPI
|
|
CcpCountCacheSections(PNOCC_CACHE_MAP Map);
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcpAcquireFileLock(PNOCC_CACHE_MAP Map);
|
|
|
|
VOID
|
|
NTAPI
|
|
CcpReleaseFileLock(PNOCC_CACHE_MAP Map);
|
|
|
|
/*
|
|
* Macro for generic cache manage bugchecking. Note that this macro assumes
|
|
* that the file name including extension is always longer than 4 characters.
|
|
*/
|
|
#define KEBUGCHECKCC \
|
|
KEBUGCHECKEX(CACHE_MANAGER, \
|
|
(*(ULONG*)(__FILE__ + sizeof(__FILE__) - 4) << 16) | \
|
|
(__LINE__ & 0xFFFF), 0, 0, 0)
|
|
|
|
/* Private data */
|
|
|
|
#define CACHE_SINGLE_FILE_MAX (16)
|
|
#define CACHE_OVERALL_SIZE (32 * 1024 * 1024)
|
|
#define CACHE_STRIPE VACB_MAPPING_GRANULARITY
|
|
#define CACHE_SHIFT 18
|
|
#define CACHE_NUM_SECTIONS (CACHE_OVERALL_SIZE / CACHE_STRIPE)
|
|
#define CACHE_ROUND_UP(x) (((x) + (CACHE_STRIPE-1)) & ~(CACHE_STRIPE-1))
|
|
#define CACHE_ROUND_DOWN(x) ((x) & ~(CACHE_STRIPE-1))
|
|
#define INVALID_CACHE ((ULONG)~0)
|
|
|
|
extern NOCC_BCB CcCacheSections[CACHE_NUM_SECTIONS];
|
|
extern PRTL_BITMAP CcCacheBitmap;
|
|
extern FAST_MUTEX CcMutex;
|
|
extern KEVENT CcDeleteEvent;
|
|
extern ULONG CcCacheClockHand;
|
|
extern LIST_ENTRY CcPendingUnmap;
|
|
extern KEVENT CcpLazyWriteEvent;
|
|
|
|
#define CcpLock() _CcpLock(__FILE__,__LINE__)
|
|
#define CcpUnlock() _CcpUnlock(__FILE__,__LINE__)
|
|
|
|
extern VOID _CcpLock(const char *file, int line);
|
|
extern VOID _CcpUnlock(const char *file, int line);
|
|
|
|
extern VOID CcpReferenceCache(ULONG Sector);
|
|
extern VOID CcpDereferenceCache(ULONG Sector, BOOLEAN Immediate);
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcpMapData(IN PFILE_OBJECT FileObject,
|
|
IN PLARGE_INTEGER FileOffset,
|
|
IN ULONG Length,
|
|
IN ULONG Flags,
|
|
OUT PVOID *BcbResult,
|
|
OUT PVOID *Buffer);
|
|
|
|
BOOLEAN
|
|
NTAPI
|
|
CcpPinMappedData(IN PNOCC_CACHE_MAP Map,
|
|
IN PLARGE_INTEGER FileOffset,
|
|
IN ULONG Length,
|
|
IN ULONG Flags,
|
|
IN OUT PVOID *Bcb);
|