alloc(const size_t numBytes) override | File_Namespace::FileMgr | |
allocateBuffer(const size_t page_size, const ChunkKey &key, const size_t num_bytes=0) override | File_Namespace::CachingFileMgr | virtual |
allocateBuffer(const ChunkKey &key, const std::vector< HeaderInfo >::const_iterator &headerStartIt, const std::vector< HeaderInfo >::const_iterator &headerEndIt) override | File_Namespace::CachingFileMgr | virtual |
CachingFileMgr(const DiskCacheConfig &config) | File_Namespace::CachingFileMgr | |
checkpoint(const int32_t db_id, const int32_t tb_id) override | File_Namespace::CachingFileMgr | |
File_Namespace::FileMgr::checkpoint() override | File_Namespace::FileMgr | |
chunk_evict_alg_ | File_Namespace::CachingFileMgr | mutableprivate |
chunkIndex_ | File_Namespace::FileMgr | |
chunkIndexMutex_ | File_Namespace::FileMgr | mutableprotected |
clearFileInfos() | File_Namespace::FileMgr | protected |
clearForTable(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | |
closePhysicalUnlocked() | File_Namespace::FileMgr | protected |
closeRemovePhysical() override | File_Namespace::CachingFileMgr | virtual |
compactFiles() | File_Namespace::FileMgr | |
COPY_PAGES_STATUS | File_Namespace::FileMgr | static |
copyPage(Page &srcPage, FileMgr *destFileMgr, Page &destPage, const size_t reservedHeaderSize, const size_t numBytes, const size_t offset) | File_Namespace::FileMgr | |
copyPageWithoutHeaderSize(const Page &source_page, const Page &destination_page) | File_Namespace::FileMgr | protected |
copySourcePageForCompaction(const Page &source_page, FileInfo *destination_file_info, std::vector< PageMapping > &page_mappings, std::set< Page > &touched_pages) | File_Namespace::FileMgr | protected |
createBuffer(const ChunkKey &key, size_t pageSize=0, const size_t numBytes=0) override | File_Namespace::FileMgr | |
createBufferFromHeaders(const ChunkKey &key, const std::vector< HeaderInfo >::const_iterator &startIt, const std::vector< HeaderInfo >::const_iterator &endIt) override | File_Namespace::CachingFileMgr | privatevirtual |
createBufferUnlocked(const ChunkKey &key, size_t pageSize=0, const size_t numBytes=0) override | File_Namespace::CachingFileMgr | privatevirtual |
createEpochFile(const std::string &epochFileName) | File_Namespace::FileMgr | protected |
createFile(const std::string &full_path, const size_t requested_file_size) const | File_Namespace::FileMgr | |
createFile(const std::string &base_path, const int file_id, const size_t page_size, const size_t num_pages) const | File_Namespace::FileMgr | |
createFileInfo(const size_t pageSize, const size_t numPages) | File_Namespace::FileMgr | protected |
createOrMigrateTopLevelMetadata() | File_Namespace::FileMgr | |
createTableFileMgrIfNoneExists(const int32_t db_id, const int32_t tb_id) | File_Namespace::CachingFileMgr | private |
DB_META_FILENAME | File_Namespace::FileMgr | static |
DBMetaFile_ | File_Namespace::FileMgr | protected |
DEFAULT_NUM_PAGES_PER_DATA_FILE | File_Namespace::FileMgr | static |
DEFAULT_NUM_PAGES_PER_METADATA_FILE | File_Namespace::FileMgr | static |
DELETE_EMPTY_FILES_STATUS | File_Namespace::FileMgr | static |
deleteBuffer(const ChunkKey &key, const bool purge=true) override | File_Namespace::FileMgr | |
deleteBufferIfExists(const ChunkKey &key) | File_Namespace::CachingFileMgr | |
deleteBuffersWithPrefix(const ChunkKey &keyPrefix, const bool purge=true) override | File_Namespace::FileMgr | |
deleteBufferUnlocked(const ChunkKeyToChunkMap::iterator chunk_it, const bool purge=true) override | File_Namespace::CachingFileMgr | privatevirtual |
deleteCacheIfTooLarge() | File_Namespace::CachingFileMgr | private |
deleteEmptyFiles() | File_Namespace::FileMgr | protected |
deleteWrapperFile(int32_t db, int32_t tb) | File_Namespace::CachingFileMgr | |
describeSelf() const override | File_Namespace::CachingFileMgr | virtual |
dump() const | File_Namespace::CachingFileMgr | |
dumpEvictionQueue() const | File_Namespace::CachingFileMgr | inline |
dumpKeysWithChunkData() const | File_Namespace::CachingFileMgr | |
dumpKeysWithMetadata() const | File_Namespace::CachingFileMgr | |
dumpTableQueue() const | File_Namespace::CachingFileMgr | inline |
epoch(int32_t db_id, int32_t tb_id) const override | File_Namespace::CachingFileMgr | virtual |
EPOCH_FILENAME | File_Namespace::FileMgr | static |
epochFloor() const | File_Namespace::FileMgr | inline |
evictMetadataPages() | File_Namespace::CachingFileMgr | private |
evictPages() | File_Namespace::CachingFileMgr | private |
failOnReadError() const override | File_Namespace::CachingFileMgr | inlinevirtual |
fetchBuffer(const ChunkKey &key, AbstractBuffer *destBuffer, const size_t numBytes) override | File_Namespace::FileMgr | |
FILE_MGR_VERSION_FILENAME | File_Namespace::FileMgr | static |
fileIndex_ | File_Namespace::FileMgr | protected |
FileMgr(const int32_t device_id, GlobalFileMgr *gfm, const TablePair file_mgr_key, const int32_t max_rollback_epochs=-1, const size_t num_reader_threads=0, const int32_t epoch=-1) | File_Namespace::FileMgr | |
FileMgr(const int32_t device_id, GlobalFileMgr *gfm, const TablePair file_mgr_key, const bool run_core_init) | File_Namespace::FileMgr | |
FileMgr(GlobalFileMgr *gfm, std::string basePath) | File_Namespace::FileMgr | |
FileMgr(const size_t defaultPageSize, const size_t defaultMetadataPageSize) | File_Namespace::FileMgr | protected |
FileMgr(const int epoch) | File_Namespace::FileMgr | protected |
fileMgrBasePath_ | File_Namespace::FileMgr | protected |
fileMgrVersion_ | File_Namespace::FileMgr | protected |
files_ | File_Namespace::FileMgr | protected |
files_rw_mutex_ | File_Namespace::FileMgr | mutableprotected |
free(AbstractBuffer *buffer) override | File_Namespace::FileMgr | |
free_page(std::pair< FileInfo *, int32_t > &&page) override | File_Namespace::CachingFileMgr | virtual |
free_pages_ | File_Namespace::FileMgr | protected |
freePages() | File_Namespace::FileMgr | protected |
get_fileMgrKey() const | File_Namespace::FileMgr | inline |
getAllocated() override | File_Namespace::CachingFileMgr | inline |
getAvailableSpace() | File_Namespace::CachingFileMgr | inline |
getAvailableWrapperSpace() | File_Namespace::CachingFileMgr | inline |
getBuffer(const ChunkKey &key, const size_t numBytes=0) override | File_Namespace::FileMgr | |
getBufferIfExists(const ChunkKey &key) | File_Namespace::CachingFileMgr | |
getBufferUnlocked(const ChunkKey &key, const size_t numBytes=0) const override | File_Namespace::CachingFileMgr | privatevirtual |
getChunkKeysForPrefix(const ChunkKey &prefix) const | File_Namespace::CachingFileMgr | |
getChunkMetadataVecForKeyPrefix(ChunkMetadataVector &chunkMetadataVec, const ChunkKey &keyPrefix) override | File_Namespace::CachingFileMgr | |
getChunkSpaceReservedByTable(int32_t db_id, int32_t tb_id) const | File_Namespace::CachingFileMgr | |
getDataFileSize() const | File_Namespace::CachingFileMgr | inline |
getDBConvert() const | File_Namespace::FileMgr | |
getFileForFileId(const int32_t fileId) | File_Namespace::FileMgr | |
getFileInfoForFileId(const int32_t fileId) const | File_Namespace::FileMgr | inline |
getFileMgrBasePath() const | File_Namespace::FileMgr | inline |
getFilePath(const std::string &file_name) const | File_Namespace::FileMgr | |
getFilesSize() const | File_Namespace::CachingFileMgr | |
getInUseSize() override | File_Namespace::FileMgr | inline |
getKeysForTable(int32_t db_id, int32_t tb_id) const | File_Namespace::CachingFileMgr | private |
getKeysWithMetadata() const | File_Namespace::CachingFileMgr | |
getMaxDataFiles() const | File_Namespace::CachingFileMgr | inline |
getMaxDataFilesSize() const | File_Namespace::CachingFileMgr | |
getMaxMetaFiles() const | File_Namespace::CachingFileMgr | inline |
getMaxSize() override | File_Namespace::CachingFileMgr | inline |
getMaxWrapperSize() const | File_Namespace::CachingFileMgr | inline |
getMetadataFileSize() const | File_Namespace::CachingFileMgr | inline |
getMetadataForFile(const boost::filesystem::directory_iterator &fileIterator) const | File_Namespace::FileMgr | |
getMetadataPageSize() const | File_Namespace::FileMgr | inline |
getMetadataSpaceReservedByTable(int32_t db_id, int32_t tb_id) const | File_Namespace::CachingFileMgr | |
getMgrType() override | File_Namespace::CachingFileMgr | inline |
getMinimumSize() | File_Namespace::CachingFileMgr | inlinestatic |
getNumChunks() override | File_Namespace::FileMgr | |
getNumChunksWithMetadata() const | File_Namespace::CachingFileMgr | |
getNumDataChunks() const | File_Namespace::CachingFileMgr | |
getNumDataFiles() const | File_Namespace::CachingFileMgr | |
getNumMetaFiles() const | File_Namespace::CachingFileMgr | |
getNumReaderThreads() | File_Namespace::FileMgr | inline |
getNumUsedMetadataPagesForChunkKey(const ChunkKey &chunkKey) const | File_Namespace::FileMgr | |
getPageMutex_ | File_Namespace::FileMgr | protected |
getPageSize() | File_Namespace::CachingFileMgr | inline |
File_Namespace::FileMgr::getPageSize() const | File_Namespace::FileMgr | inline |
getSpaceReservedByTable(int32_t db_id, int32_t tb_id) const | File_Namespace::CachingFileMgr | |
getStorageStats() const | File_Namespace::FileMgr | |
getStringMgrType() override | File_Namespace::CachingFileMgr | inline |
getTableFileMgrPath(int32_t db, int32_t tb) const | File_Namespace::CachingFileMgr | |
getTableFileMgrSpaceReserved(int32_t db_id, int32_t tb_id) const | File_Namespace::CachingFileMgr | |
getTableFileMgrsSize() const | File_Namespace::CachingFileMgr | |
hasChunkMetadataForKeyPrefix(const ChunkKey &keyPrefix) | File_Namespace::FileMgr | |
hasFileMgrKey() const override | File_Namespace::CachingFileMgr | inlinevirtual |
hasWrapperFile(int32_t db_id, int32_t table_id) const | File_Namespace::CachingFileMgr | |
incrementAllEpochs() | File_Namespace::CachingFileMgr | private |
incrementEpoch(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | private |
File_Namespace::FileMgr::incrementEpoch() | File_Namespace::FileMgr | inline |
init(const size_t num_reader_threads) | File_Namespace::CachingFileMgr | private |
initializeNumThreads(size_t num_reader_threads=0) | File_Namespace::FileMgr | protected |
INVALID_VERSION | File_Namespace::FileMgr | static |
isAllocationCapped() override | File_Namespace::FileMgr | inline |
isBufferOnDevice(const ChunkKey &key) override | File_Namespace::FileMgr | |
isFullyInitted_ | File_Namespace::FileMgr | protected |
lastCheckpointedEpoch() const | File_Namespace::FileMgr | inline |
LATEST_FILE_MGR_VERSION | File_Namespace::FileMgr | static |
LEGACY_EPOCH_FILENAME | File_Namespace::FileMgr | static |
limit_data_size_ | File_Namespace::CachingFileMgr | private |
max_num_data_files_ | File_Namespace::CachingFileMgr | private |
max_num_meta_files_ | File_Namespace::CachingFileMgr | private |
max_size_ | File_Namespace::CachingFileMgr | private |
max_wrapper_space_ | File_Namespace::CachingFileMgr | private |
maxRollbackEpochs() | File_Namespace::FileMgr | inline |
maxRollbackEpochs_ | File_Namespace::FileMgr | protected |
METADATA_FILE_SPACE_PERCENTAGE | File_Namespace::CachingFileMgr | static |
metadata_page_size_ | File_Namespace::FileMgr | protected |
METADATA_SPACE_PERCENTAGE | File_Namespace::CachingFileMgr | static |
migrateEpochFileV0() | File_Namespace::FileMgr | protected |
migrateLegacyFilesV1() | File_Namespace::FileMgr | protected |
migrateToLatestFileMgrVersion() | File_Namespace::FileMgr | protected |
mutex_free_page_ | File_Namespace::FileMgr | mutableprotected |
nextFileId_ | File_Namespace::FileMgr | protected |
num_pages_per_data_file_ | File_Namespace::FileMgr | protectedstatic |
num_pages_per_metadata_file_ | File_Namespace::FileMgr | protectedstatic |
num_reader_threads_ | File_Namespace::FileMgr | protected |
openAndReadEpochFile(const std::string &epochFileName) | File_Namespace::FileMgr | protected |
openAndReadLegacyEpochFile(const std::string &epochFileName) | File_Namespace::FileMgr | protected |
openExistingFile(const std::string &path, const int32_t fileId, const size_t pageSize, const size_t numPages, std::vector< HeaderInfo > &headerVec) | File_Namespace::FileMgr | protected |
openFiles() | File_Namespace::FileMgr | protected |
page_size_ | File_Namespace::FileMgr | protected |
printSlabs() override | File_Namespace::FileMgr | inline |
processFileFutures(std::vector< std::future< std::vector< HeaderInfo >>> &file_futures, std::vector< HeaderInfo > &headerVec) | File_Namespace::FileMgr | protected |
putBuffer(const ChunkKey &key, AbstractBuffer *srcBuffer, const size_t numBytes=0) override | File_Namespace::CachingFileMgr | |
readOnlyCheck(const std::string &action, const std::optional< std::string > &file_name={}) const override | File_Namespace::CachingFileMgr | inlineprivatevirtual |
readPageMappingsFromStatusFile() | File_Namespace::FileMgr | protected |
readTableFileMgrs() | File_Namespace::CachingFileMgr | private |
readVersionFromDisk(const std::string &versionFileName) const | File_Namespace::FileMgr | protected |
reconstruct() const | File_Namespace::CachingFileMgr | |
removeChunkKeepMetadata(const ChunkKey &key) | File_Namespace::CachingFileMgr | |
removeKey(const ChunkKey &key) const | File_Namespace::CachingFileMgr | private |
removeTableBuffers(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | private |
removeTableFileMgr(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | private |
removeTableRelatedDS(const int32_t db_id, const int32_t table_id) override | File_Namespace::FileMgr | |
renameAndSymlinkLegacyFiles(const std::string &table_data_dir) | File_Namespace::FileMgr | static |
renameCompactionStatusFile(const char *const from_status, const char *const to_status) | File_Namespace::FileMgr | |
requestFreePage(size_t pagesize, const bool isMetadata) override | File_Namespace::CachingFileMgr | virtual |
requestFreePages(size_t npages, size_t pagesize, std::vector< Page > &pages, const bool isMetadata) | File_Namespace::FileMgr | |
resetEpochFloor() | File_Namespace::FileMgr | inline |
resumeFileCompaction(const std::string &status_file_name) | File_Namespace::FileMgr | protected |
setDataSizeLimit(size_t max) | File_Namespace::CachingFileMgr | inline |
setEpoch(const int32_t newEpoch) | File_Namespace::FileMgr | protected |
setMaxNumDataFiles(size_t max) | File_Namespace::CachingFileMgr | inline |
setMaxNumMetadataFiles(size_t max) | File_Namespace::CachingFileMgr | inline |
setMaxSizes() | File_Namespace::CachingFileMgr | private |
setMaxWrapperSpace(size_t max) | File_Namespace::CachingFileMgr | inline |
setNumPagesPerDataFile(size_t num_pages) | File_Namespace::FileMgr | static |
setNumPagesPerMetadataFile(size_t num_pages) | File_Namespace::FileMgr | static |
sortAndCopyFilePagesForCompaction(size_t page_size, std::vector< PageMapping > &page_mappings, std::set< Page > &touched_pages) | File_Namespace::FileMgr | protected |
syncFilesToDisk() | File_Namespace::FileMgr | protected |
table_dirs_ | File_Namespace::CachingFileMgr | private |
table_dirs_mutex_ | File_Namespace::CachingFileMgr | mutableprivate |
table_evict_alg_ | File_Namespace::CachingFileMgr | mutableprivate |
touchKey(const ChunkKey &key) const | File_Namespace::CachingFileMgr | private |
UPDATE_PAGE_VISIBILITY_STATUS | File_Namespace::FileMgr | static |
updateMappedPagesVisibility(const std::vector< PageMapping > &page_mappings) | File_Namespace::FileMgr | protected |
updatePageIfDeleted(FileInfo *file_info, ChunkKey &chunk_key, int32_t contingent, int32_t page_epoch, int32_t page_num) override | File_Namespace::CachingFileMgr | virtual |
WRAPPER_FILE_NAME | File_Namespace::CachingFileMgr | static |
writeAndSyncEpochToDisk(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | private |
File_Namespace::FileMgr::writeAndSyncEpochToDisk() | File_Namespace::FileMgr | protected |
writeAndSyncVersionToDisk(const std::string &versionFileName, const int32_t version) | File_Namespace::FileMgr | protected |
writeDirtyBuffers(int32_t db_id, int32_t tb_id) | File_Namespace::CachingFileMgr | private |
writeFile(FILE *f, const size_t offset, const size_t size, const int8_t *buf) const | File_Namespace::FileMgr | |
writePageMappingsToStatusFile(const std::vector< PageMapping > &page_mappings) | File_Namespace::FileMgr | |
writeWrapperFile(const std::string &doc, int32_t db, int32_t tb) | File_Namespace::CachingFileMgr | |
~CachingFileMgr() override | File_Namespace::CachingFileMgr | |
~FileMgr() override | File_Namespace::FileMgr | |