Home
last modified time | relevance | path

Searched refs:to_delete (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/db/
Dmemtable_list_test.cc202 ASSERT_EQ(0, to_delete.size()); in TEST_F()
271 list.Add(mem, &to_delete); in TEST_F()
285 list.Add(mem2, &to_delete); in TEST_F()
317 for (MemTable* m : to_delete) { in TEST_F()
377 list.Add(mem, &to_delete); in TEST_F()
445 list.Add(mem2, &to_delete); in TEST_F()
465 list.Add(mem3, &to_delete); in TEST_F()
724 to_delete.clear(); in TEST_F()
752 to_delete.clear(); in TEST_F()
767 to_delete.clear(); in TEST_F()
[all …]
Dmemtable_list.cc39 to_delete->push_back(m); in UnrefMemTable()
82 assert(to_delete != nullptr); in Unref()
84 UnrefMemTable(to_delete, m); in Unref()
87 UnrefMemTable(to_delete, m); in Unref()
277 TrimHistory(to_delete, 0); in Remove()
279 UnrefMemTable(to_delete, m); in Remove()
320 UnrefMemTable(to_delete, x); in TrimHistory()
509 current_->Remove(m, to_delete); in TryInstallMemtableFlushResults()
545 current_->Add(m, to_delete); in Add()
750 assert(to_delete != nullptr); in RemoveOldMemTables()
[all …]
Dmemtable_list.h53 void Unref(autovector<MemTable*>* to_delete = nullptr);
143 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
147 void Add(MemTable* m, autovector<MemTable*>* to_delete);
149 void Remove(MemTable* m, autovector<MemTable*>* to_delete);
151 void TrimHistory(autovector<MemTable*>* to_delete, size_t usage);
163 void UnrefMemTable(autovector<MemTable*>* to_delete, MemTable* m);
267 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
274 void Add(MemTable* m, autovector<MemTable*>* to_delete);
373 autovector<MemTable*>* to_delete);
383 autovector<MemTable*>* to_delete, FSDirectory* db_directory,
[all …]
Dflush_job_test.cc211 autovector<MemTable*> to_delete; in TEST_F() local
213 for (auto& m : to_delete) { in TEST_F()
274 autovector<MemTable*> to_delete; in TEST_F() local
276 cfd->imm()->Add(mem, &to_delete); in TEST_F()
310 for (auto m : to_delete) { in TEST_F()
313 to_delete.clear(); in TEST_F()
329 autovector<MemTable*> to_delete; in TEST_F() local
419 for (auto m : to_delete) { in TEST_F()
422 to_delete.clear(); in TEST_F()
466 autovector<MemTable*> to_delete; in TEST_F() local
[all …]
Dcolumn_family.cc411 for (auto td : to_delete) { in ~SuperVersion()
430 imm->Unref(&to_delete); in Cleanup()
436 to_delete.push_back(m); in Cleanup()
626 autovector<MemTable*> to_delete; in ~ColumnFamilyData() local
627 imm_.current()->Unref(&to_delete); in ~ColumnFamilyData()
628 for (MemTable* m : to_delete) { in ~ColumnFamilyData()
1499 autovector<ColumnFamilyData*> to_delete; in FreeDeadColumnFamilies() local
1502 to_delete.push_back(cfd); in FreeDeadColumnFamilies()
1505 for (auto cfd : to_delete) { in FreeDeadColumnFamilies()
Dcolumn_family.h242 autovector<MemTable*> to_delete; member
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc392 const std::string& to_delete = candidate_file.file_name; in PurgeObsoleteFiles() local
396 if (!ParseFileName(to_delete, &number, info_log_prefix.prefix, &type)) { in PurgeObsoleteFiles()
433 (to_delete.find(kOptionsFileNamePrefix) != std::string::npos); in PurgeObsoleteFiles()
438 old_info_log_files.push_back(to_delete); in PurgeObsoleteFiles()
475 (!to_delete.empty() && to_delete.front() == '/') in PurgeObsoleteFiles()
478 to_delete; in PurgeObsoleteFiles()
526 std::string& to_delete = old_info_log_files.at(i); in PurgeObsoleteFiles() local
531 "/" + to_delete; in PurgeObsoleteFiles()
542 state.job_id, to_delete.c_str(), s.ToString().c_str()); in PurgeObsoleteFiles()
546 state.job_id, to_delete.c_str(), in PurgeObsoleteFiles()
Ddb_impl_write.cc1547 autovector<MemTable*> to_delete; in TrimMemtableHistory() local
1548 cfd->imm()->TrimHistory(&to_delete, cfd->mem()->ApproximateMemoryUsage()); in TrimMemtableHistory()
1549 if (!to_delete.empty()) { in TrimMemtableHistory()
1550 for (auto m : to_delete) { in TrimMemtableHistory()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc1013 std::vector<BackupID> to_delete; in PurgeOldBackups() local
1015 while ((backups_.size() - to_delete.size()) > num_backups_to_keep) { in PurgeOldBackups()
1016 to_delete.push_back(itr->first); in PurgeOldBackups()
1019 for (auto backup_id : to_delete) { in PurgeOldBackups()
1081 std::vector<std::string> to_delete; in DeleteBackupInternal() local
1087 to_delete.push_back(itr.first); in DeleteBackupInternal()
1094 for (auto& td : to_delete) { in DeleteBackupInternal()