| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 1202 cfds->push_back(cfd); in SelectColumnFamiliesForAtomicFlush()
1211 for (auto cfd : cfds) { in AssignAtomicFlushSeq()
1274 cfds.push_back(cfd); in SwitchWAL()
1277 MaybeFlushStatsCF(&cfds); in SwitchWAL()
1300 for (auto cfd : cfds) { in SwitchWAL()
1353 MaybeFlushStatsCF(&cfds); in HandleWriteBufferFull()
1506 assert(cfds != nullptr); in MaybeFlushStatsCF()
1544 cfds.push_back(tmp_cfd); in TrimMemtableHistory()
1546 for (auto& cfd : cfds) { in TrimMemtableHistory()
1569 for (auto cfd : cfds) { in ScheduleFlushes()
[all …]
|
| D | db_impl_compaction_flush.cc | 295 cfds.emplace_back(arg.cfd_); in AtomicFlushMemTablesToOutputFiles()
299 for (const auto cfd : cfds) { in AtomicFlushMemTablesToOutputFiles()
318 auto cfd = cfds[i]; in AtomicFlushMemTablesToOutputFiles()
533 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()
1568 req->reserve(cfds.size()); in GenerateFlushRequest()
1569 for (const auto cfd : cfds) { in GenerateFlushRequest()
1736 cfds.emplace_back(cfd); in AtomicFlushMemTables()
1739 for (auto cfd : cfds) { in AtomicFlushMemTables()
1752 for (auto cfd : cfds) { in AtomicFlushMemTables()
1760 for (auto cfd : cfds) { in AtomicFlushMemTables()
[all …]
|
| D | db_impl_debug.cc | 146 const autovector<ColumnFamilyData*>& cfds, const FlushOptions& flush_opts) { in TEST_AtomicFlushMemTables() argument
147 return AtomicFlushMemTables(cfds, flush_opts, FlushReason::kTest); in TEST_AtomicFlushMemTables()
|
| D | db_impl.h | 893 Status TEST_AtomicFlushMemTables(const autovector<ColumnFamilyData*>& cfds,
1421 void MaybeFlushStatsCF(autovector<ColumnFamilyData*>* cfds);
1427 void SelectColumnFamiliesForAtomicFlush(autovector<ColumnFamilyData*>* cfds);
1456 const autovector<ColumnFamilyData*>& cfds,
1488 void AssignAtomicFlushSeq(const autovector<ColumnFamilyData*>& cfds);
1558 void GenerateFlushRequest(const autovector<ColumnFamilyData*>& cfds,
|
| D | db_impl_open.cc | 1110 autovector<ColumnFamilyData*> cfds; in RecoverLogFiles() local
1114 cfds.push_back(cfd); in RecoverLogFiles()
1121 status = versions_->LogAndApply(cfds, cf_opts, edit_lists, &mutex_, in RecoverLogFiles()
|
| D | db_impl.cc | 326 autovector<ColumnFamilyData*> cfds; in ResumeImpl() local
327 SelectColumnFamiliesForAtomicFlush(&cfds); in ResumeImpl()
329 s = AtomicFlushMemTables(cfds, flush_opts, FlushReason::kErrorRecovery); in ResumeImpl()
416 autovector<ColumnFamilyData*> cfds; in CancelAllBackgroundWork() local
417 SelectColumnFamiliesForAtomicFlush(&cfds); in CancelAllBackgroundWork()
419 AtomicFlushMemTables(cfds, FlushOptions(), FlushReason::kShutDown); in CancelAllBackgroundWork()
|
| /rocksdb-6.9/db/ |
| D | memtable_list.cc | 644 const autovector<ColumnFamilyData*>& cfds, in InstallMemtableAtomicFlushResults() argument
655 assert(cfds.size() == num); in InstallMemtableAtomicFlushResults()
662 (imm_lists == nullptr) ? cfds[k]->imm() : imm_lists->at(k); in InstallMemtableAtomicFlushResults()
689 if (cfds.size() > 1) { in InstallMemtableAtomicFlushResults()
698 s = vset->LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu, in InstallMemtableAtomicFlushResults()
701 for (size_t k = 0; k != cfds.size(); ++k) { in InstallMemtableAtomicFlushResults()
707 for (size_t i = 0; i != cfds.size(); ++i) { in InstallMemtableAtomicFlushResults()
708 if (cfds[i]->IsDropped()) { in InstallMemtableAtomicFlushResults()
718 cfds[i]->GetName().c_str(), m->GetFileNumber(), in InstallMemtableAtomicFlushResults()
726 for (size_t i = 0; i != cfds.size(); ++i) { in InstallMemtableAtomicFlushResults()
[all …]
|
| D | db_filesnapshot.cc | 88 autovector<ColumnFamilyData*> cfds; in GetLiveFiles() local
89 SelectColumnFamiliesForAtomicFlush(&cfds); in GetLiveFiles()
91 status = AtomicFlushMemTables(cfds, FlushOptions(), in GetLiveFiles()
|
| D | version_set.h | 837 autovector<ColumnFamilyData*> cfds; variable
838 cfds.emplace_back(column_family_data);
845 return LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu,
856 autovector<ColumnFamilyData*> cfds; variable
857 cfds.emplace_back(column_family_data);
862 return LogAndApply(cfds, mutable_cf_options_list, edit_lists, mu,
870 const autovector<ColumnFamilyData*>& cfds,
|
| D | memtable_list.h | 138 const autovector<ColumnFamilyData*>& cfds,
378 const autovector<ColumnFamilyData*>& cfds,
421 const autovector<ColumnFamilyData*>& cfds,
|
| D | memtable_list_test.cc | 163 autovector<ColumnFamilyData*> cfds; in Mock_InstallMemtableAtomicFlushResults() local
165 cfds.emplace_back(column_family_set->GetColumnFamily(cf_ids[i])); in Mock_InstallMemtableAtomicFlushResults()
166 EXPECT_NE(nullptr, cfds[i]); in Mock_InstallMemtableAtomicFlushResults()
183 &lists, cfds, mutable_cf_options_list, mems_list, &versions, &mutex, in Mock_InstallMemtableAtomicFlushResults()
|
| D | version_set_test.cc | 801 autovector<ColumnFamilyData*> cfds; in TEST_F() local
805 cfds.emplace_back(versions_->GetColumnFamilySet()->GetDefault()); in TEST_F()
824 versions_->LogAndApply(cfds, all_mutable_cf_options, edit_lists, &mutex_); in TEST_F()
1276 autovector<ColumnFamilyData*> cfds; in TEST_P() local
1284 cfds.push_back(cfd); in TEST_P()
1318 s = versions_->LogAndApply(cfds, mutable_cf_options_list, edit_lists, in TEST_P()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_test.cc | 5877 std::vector<ColumnFamilyDescriptor> cfds{ in TEST_P() local
5883 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
5899 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
5923 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
5961 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
5994 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
6021 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
6048 ASSERT_OK(ReOpenNoDelete(cfds, &handles)); in TEST_P()
|