alloc(const size_t numBytes) override | File_Namespace::FileMgr | |
allocateBuffer(const size_t page_size, const ChunkKey &key, const size_t num_bytes=0) | File_Namespace::FileMgr | protectedvirtual |
allocateBuffer(const ChunkKey &key, const std::vector< HeaderInfo >::const_iterator &headerStartIt, const std::vector< HeaderInfo >::const_iterator &headerEndIt) | File_Namespace::FileMgr | protectedvirtual |
checkpoint() override | File_Namespace::FileMgr | |
checkpoint(const int32_t db_id, const int32_t tb_id) override | File_Namespace::FileMgr | inline |
chunkIndex_ | File_Namespace::FileMgr | |
chunkIndexMutex_ | File_Namespace::FileMgr | mutableprotected |
clearFileInfos() | File_Namespace::FileMgr | protected |
closePhysicalUnlocked() | File_Namespace::FileMgr | protected |
closeRemovePhysical() | File_Namespace::FileMgr | 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 |
coreInit() | File_Namespace::FileMgr | private |
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 &headerStartIt, const std::vector< HeaderInfo >::const_iterator &headerEndIt) | File_Namespace::FileMgr | protectedvirtual |
createBufferUnlocked(const ChunkKey &key, size_t pageSize=0, const size_t numBytes=0) | File_Namespace::FileMgr | protectedvirtual |
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 | |
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 | |
deleteBuffersWithPrefix(const ChunkKey &keyPrefix, const bool purge=true) override | File_Namespace::FileMgr | |
deleteBufferUnlocked(const ChunkKeyToChunkMap::iterator chunk_it, const bool purge=true) | File_Namespace::FileMgr | protectedvirtual |
deleteEmptyFiles() | File_Namespace::FileMgr | protected |
describeSelf() const | File_Namespace::FileMgr | virtual |
epoch(int32_t db_id, int32_t tb_id) const | File_Namespace::FileMgr | inlinevirtual |
epoch() const | File_Namespace::FileMgr | inlineprivate |
epoch_ | File_Namespace::FileMgr | private |
EPOCH_FILENAME | File_Namespace::FileMgr | static |
epochFile_ | File_Namespace::FileMgr | private |
epochFloor() const | File_Namespace::FileMgr | inline |
epochIsCheckpointed_ | File_Namespace::FileMgr | private |
failOnReadError() const | File_Namespace::FileMgr | 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 |
fileMgrKey_ | File_Namespace::FileMgr | private |
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) | File_Namespace::FileMgr | virtual |
free_pages_ | File_Namespace::FileMgr | protected |
freePages() | File_Namespace::FileMgr | protected |
freePagesBeforeEpoch(const int32_t min_epoch) | File_Namespace::FileMgr | private |
freePagesBeforeEpochUnlocked(const int32_t min_epoch, const ChunkKeyToChunkMap::iterator lower_bound, const ChunkKeyToChunkMap::iterator upper_bound) | File_Namespace::FileMgr | private |
get_fileMgrKey() const | File_Namespace::FileMgr | inline |
getAllocated() override | File_Namespace::FileMgr | inline |
getBuffer(const ChunkKey &key, const size_t numBytes=0) override | File_Namespace::FileMgr | |
getBufferUnlocked(const ChunkKey &key, const size_t numBytes=0) const | File_Namespace::FileMgr | protectedvirtual |
getChunkMetadataVecForKeyPrefix(ChunkMetadataVector &chunkMetadataVec, const ChunkKey &keyPrefix) override | File_Namespace::FileMgr | |
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 | |
getFragmentCount() const | File_Namespace::FileMgr | private |
getInUseSize() override | File_Namespace::FileMgr | inline |
getMaxSize() override | File_Namespace::FileMgr | inline |
getMetadataForFile(const boost::filesystem::directory_iterator &fileIterator) const | File_Namespace::FileMgr | |
getMetadataPageSize() const | File_Namespace::FileMgr | inline |
getMgrType() override | File_Namespace::FileMgr | inline |
getNumChunks() override | File_Namespace::FileMgr | |
getNumReaderThreads() | File_Namespace::FileMgr | inline |
getNumUsedMetadataPagesForChunkKey(const ChunkKey &chunkKey) const | File_Namespace::FileMgr | |
getOrCreateBuffer(const ChunkKey &key) | File_Namespace::FileMgr | private |
getPageMutex_ | File_Namespace::FileMgr | protected |
getPageSize() const | File_Namespace::FileMgr | inline |
getStorageStats() const | File_Namespace::FileMgr | |
getStringMgrType() override | File_Namespace::FileMgr | inline |
gfm_ | File_Namespace::FileMgr | private |
GlobalFileMgr class | File_Namespace::FileMgr | friend |
hasChunkMetadataForKeyPrefix(const ChunkKey &keyPrefix) | File_Namespace::FileMgr | |
hasFileMgrKey() const | File_Namespace::FileMgr | inlinevirtual |
incrementEpoch() | File_Namespace::FileMgr | inline |
init(const size_t num_reader_threads, const int32_t epochOverride) | File_Namespace::FileMgr | private |
init(const std::string &dataPathToConvertFrom, const int32_t epochOverride) | File_Namespace::FileMgr | 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 |
maxRollbackEpochs() | File_Namespace::FileMgr | inline |
maxRollbackEpochs_ | File_Namespace::FileMgr | protected |
metadata_page_size_ | File_Namespace::FileMgr | protected |
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 *d, const size_t numBytes=0) override | File_Namespace::FileMgr | |
readOnlyCheck(const std::string &action, const std::optional< std::string > &file_name={}) const | File_Namespace::FileMgr | privatevirtual |
readPageMappingsFromStatusFile() | File_Namespace::FileMgr | protected |
readVersionFromDisk(const std::string &versionFileName) const | File_Namespace::FileMgr | protected |
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) | File_Namespace::FileMgr | 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 |
rollOffOldData(const int32_t epochCeiling, const bool shouldCheckpoint) | File_Namespace::FileMgr | private |
setDataAndMetadataFileStats(StorageStats &storage_stats) const | File_Namespace::FileMgr | private |
setEpoch(const int32_t newEpoch) | File_Namespace::FileMgr | protected |
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 |
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) | File_Namespace::FileMgr | virtual |
writeAndSyncEpochToDisk() | File_Namespace::FileMgr | protected |
writeAndSyncVersionToDisk(const std::string &versionFileName, const int32_t version) | File_Namespace::FileMgr | protected |
writeDirtyBuffers() | File_Namespace::FileMgr | 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 | |
~FileMgr() override | File_Namespace::FileMgr | |