Home
last modified time | relevance | path

Searched refs:mems_list (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/db/
Dmemtable_list.cc646 const autovector<const autovector<MemTable*>*>& mems_list, VersionSet* vset, in InstallMemtableAtomicFlushResults() argument
654 size_t num = mems_list.size(); in InstallMemtableAtomicFlushResults()
663 if (!mems_list[k]->empty()) { in InstallMemtableAtomicFlushResults()
664 assert((*mems_list[k])[0]->GetID() == imm->GetEarliestMemTableID()); in InstallMemtableAtomicFlushResults()
668 for (size_t i = 0; i != mems_list[k]->size(); ++i) { in InstallMemtableAtomicFlushResults()
669 assert(i == 0 || (*mems_list[k])[i]->GetEdits()->NumEntries() == 0); in InstallMemtableAtomicFlushResults()
670 (*mems_list[k])[i]->SetFlushCompleted(true); in InstallMemtableAtomicFlushResults()
671 (*mems_list[k])[i]->SetFileNumber(file_metas[k]->fd.GetNumber()); in InstallMemtableAtomicFlushResults()
679 for (const auto mems : mems_list) { in InstallMemtableAtomicFlushResults()
712 for (auto m : *mems_list[i]) { in InstallMemtableAtomicFlushResults()
[all …]
Dmemtable_list.h140 const autovector<const autovector<MemTable*>*>& mems_list,
380 const autovector<const autovector<MemTable*>*>& mems_list,
423 const autovector<const autovector<MemTable*>*>& mems_list, VersionSet* vset,
Dflush_job_test.cc386 autovector<const autovector<MemTable*>*> mems_list; in TEST_F() local
389 mems_list.push_back(&mems); in TEST_F()
397 nullptr /* imm_lists */, all_cfds, mutable_cf_options_list, mems_list, in TEST_F()
Dmemtable_list_test.cc133 const autovector<const autovector<MemTable*>*>& mems_list, in Mock_InstallMemtableAtomicFlushResults() argument
183 &lists, cfds, mutable_cf_options_list, mems_list, &versions, &mutex, in Mock_InstallMemtableAtomicFlushResults()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc510 autovector<const autovector<MemTable*>*> mems_list; in AtomicFlushMemTablesToOutputFiles() local
517 mems_list.emplace_back(&mems); in AtomicFlushMemTablesToOutputFiles()
524 nullptr /* imm_lists */, tmp_cfds, mutable_cf_options_list, mems_list, in AtomicFlushMemTablesToOutputFiles()