Home
last modified time | relevance | path

Searched refs:DeleteScheduler (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/file/
Ddelete_scheduler.cc22 DeleteScheduler::DeleteScheduler(Env* env, FileSystem* fs, in DeleteScheduler() function in ROCKSDB_NAMESPACE::DeleteScheduler
44 DeleteScheduler::~DeleteScheduler() { in ~DeleteScheduler()
55 Status DeleteScheduler::DeleteFile(const std::string& file_path, in DeleteFile()
108 const std::string DeleteScheduler::kTrashExtension = ".trash";
109 bool DeleteScheduler::IsTrashFile(const std::string& file_path) { in IsTrashFile()
125 if (!DeleteScheduler::IsTrashFile(current_file)) { in CleanupDirectory()
149 Status DeleteScheduler::MarkAsTrash(const std::string& file_path, in MarkAsTrash()
158 if (DeleteScheduler::IsTrashFile(file_path)) { in MarkAsTrash()
190 void DeleteScheduler::BackgroundEmptyTrash() { in BackgroundEmptyTrash()
348 void DeleteScheduler::WaitForEmptyTrash() { in WaitForEmptyTrash()
[all …]
Ddelete_scheduler_test.cc72 if (DeleteScheduler::IsTrashFile(f)) { in CountTrashFiles()
107 DeleteScheduler* delete_scheduler_;
662 ASSERT_TRUE(DeleteScheduler::IsTrashFile("x.trash")); in TEST_F()
663 ASSERT_TRUE(DeleteScheduler::IsTrashFile(".trash")); in TEST_F()
666 ASSERT_TRUE(DeleteScheduler::IsTrashFile("log.trash")); in TEST_F()
668 ASSERT_TRUE(DeleteScheduler::IsTrashFile("abc.t.trash")); in TEST_F()
671 ASSERT_FALSE(DeleteScheduler::IsTrashFile("abc.sst")); in TEST_F()
672 ASSERT_FALSE(DeleteScheduler::IsTrashFile("abc.txt")); in TEST_F()
676 ASSERT_FALSE(DeleteScheduler::IsTrashFile("abc.ttrash")); in TEST_F()
677 ASSERT_FALSE(DeleteScheduler::IsTrashFile(".ttrash")); in TEST_F()
[all …]
Ddelete_scheduler.h34 class DeleteScheduler {
36 DeleteScheduler(Env* env, FileSystem* fs, int64_t rate_bytes_per_sec,
40 ~DeleteScheduler();
Dsst_file_manager_impl.h132 DeleteScheduler* delete_scheduler() { return &delete_scheduler_; } in delete_scheduler()
172 DeleteScheduler delete_scheduler_;
/rocksdb-6.9/db/
Dcolumn_family.cc325 DeleteScheduler::CleanupDirectory(db_options.env, sfm, result.cf_paths[i].path); in SanitizeOptions()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc156 DeleteScheduler::CleanupDirectory(result.env, sfm, result.db_paths[i].path); in SanitizeOptions()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc239 DeleteScheduler::CleanupDirectory(env_, sfm, blob_dir_); in Open()
/rocksdb-6.9/
DHISTORY.md873 …wDeleteScheduler() in include/rocksdb/delete_scheduler.h to create a DeleteScheduler that can be s…