Home
last modified time | relevance | path

Searched refs:sfm (Results 1 – 13 of 13) sorted by relevance

/rocksdb-6.9/db/
Ddb_sst_test.cc312 ASSERT_EQ(sfm->GetTrackedFiles(), files_in_db); in TEST_F()
328 ASSERT_EQ(sfm->GetTrackedFiles(), files_in_db); in TEST_F()
338 ASSERT_EQ(sfm->GetTrackedFiles(), files_in_db); in TEST_F()
427 sfm->WaitForEmptyTrash(); in TEST_F()
490 sfm->WaitForEmptyTrash(); in TEST_F()
618 sfm->WaitForEmptyTrash(); in TEST_F()
690 sfm->WaitForEmptyTrash(); in TEST_F()
700 sfm->WaitForEmptyTrash(); in TEST_F()
752 sfm->WaitForEmptyTrash(); in TEST_F()
798 sfm->SetMaxAllowedSpaceUsage(0); in TEST_F()
[all …]
Derror_handler.cc130 SstFileManagerImpl* sfm = reinterpret_cast<SstFileManagerImpl*>( in CancelErrorRecovery() local
132 if (sfm) { in CancelErrorRecovery()
135 bool cancelled = sfm->CancelErrorRecovery(this); in CancelErrorRecovery()
320 SstFileManagerImpl* sfm = in RecoverFromNoSpace() local
324 if (sfm) { in RecoverFromNoSpace()
325 sfm->StartErrorRecovery(this, bg_error_); in RecoverFromNoSpace()
Derror_handler_fs_test.cc966 std::shared_ptr<SstFileManager> sfm(NewSstFileManager(def_env)); in TEST_F() local
981 options[i].sst_file_manager = sfm; in TEST_F()
1056 sfm.reset(); in TEST_F()
1067 std::shared_ptr<SstFileManager> sfm(NewSstFileManager(def_env)); in TEST_F() local
1082 options[i].sst_file_manager = sfm; in TEST_F()
Dcolumn_family.cc323 auto sfm = static_cast<SstFileManagerImpl*>(db_options.sst_file_manager.get()); in SanitizeOptions() local
325 DeleteScheduler::CleanupDirectory(db_options.env, sfm, result.cf_paths[i].path); in SanitizeOptions()
/rocksdb-6.9/file/
Dfile_util.cc96 SstFileManagerImpl* sfm = in DeleteDBFile() local
98 if (sfm && !force_fg) { in DeleteDBFile()
99 return sfm->ScheduleFileDeletion(fname, dir_to_sync, force_bg); in DeleteDBFile()
Ddelete_scheduler.cc115 Status DeleteScheduler::CleanupDirectory(Env* env, SstFileManagerImpl* sfm, in CleanupDirectory() argument
132 if (sfm) { in CleanupDirectory()
134 sfm->OnAddFile(trash_file); in CleanupDirectory()
135 file_delete = sfm->ScheduleFileDeletion(trash_file, path); in CleanupDirectory()
Ddelete_scheduler.h83 static Status CleanupDirectory(Env* env, SstFileManagerImpl* sfm,
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc33 auto sfm = static_cast<SstFileManagerImpl*>( in EnoughRoomForCompaction() local
35 if (sfm) { in EnoughRoomForCompaction()
226 if (sfm) { in FlushMemTableToOutputFile()
230 sfm->OnAddFile(file_path); in FlushMemTableToOutputFile()
231 if (sfm->IsMaxAllowedSpaceReached()) { in FlushMemTableToOutputFile()
557 if (sfm) { in AtomicFlushMemTablesToOutputFiles()
560 sfm->OnAddFile(file_path); in AtomicFlushMemTablesToOutputFiles()
561 if (sfm->IsMaxAllowedSpaceReached() && in AtomicFlushMemTablesToOutputFiles()
1064 if (sfm && sfm_reserved_compact_space) { in CompactFilesImpl()
1065 sfm->OnCompactionCompletion(c.get()); in CompactFilesImpl()
[all …]
Ddb_impl_open.cc154 auto sfm = static_cast<SstFileManagerImpl*>(result.sst_file_manager.get()); in SanitizeOptions() local
156 DeleteScheduler::CleanupDirectory(result.env, sfm, result.db_paths[i].path); in SanitizeOptions()
1566 auto sfm = static_cast<SstFileManagerImpl*>( in Open() local
1568 if (s.ok() && sfm) { in Open()
1614 sfm->OnAddFile(file_path, known_file_sizes.at(file_name), in Open()
1617 sfm->OnAddFile(file_path); in Open()
1628 sfm->ReserveDiskBuffer(max_write_buffer_size, in Open()
Ddb_impl.cc585 auto sfm = static_cast<SstFileManagerImpl*>( in CloseHelper() local
587 sfm->Close(); in CloseHelper()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc1389 auto sfm = in FinishCompactionOutputFile() local
1391 if (sfm && meta != nullptr && meta->fd.GetPathId() == 0) { in FinishCompactionOutputFile()
1392 sfm->OnAddFile(fname); in FinishCompactionOutputFile()
1393 if (sfm->IsMaxAllowedSpaceReached()) { in FinishCompactionOutputFile()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_test.cc588 SstFileManagerImpl *sfm = in TEST_F() local
627 sfm->WaitForEmptyTrash(); in TEST_F()
646 SstFileManagerImpl *sfm = in TEST_F() local
671 sfm->WaitForEmptyTrash(); in TEST_F()
Dblob_db_impl.cc237 SstFileManagerImpl* sfm = static_cast<SstFileManagerImpl*>( in Open() local
239 DeleteScheduler::CleanupDirectory(env_, sfm, blob_dir_); in Open()