Searched refs:mems (Results 1 – 8 of 8) sorted by relevance
369 assert(!mems.empty()); in RollbackMemtableFlush()373 for (MemTable* m : mems) { in RollbackMemtableFlush()389 const autovector<MemTable*>& mems, LogsWithPrepTracker* prep_tracker, in TryInstallMemtableFlushResults() argument402 for (size_t i = 0; i < mems.size(); ++i) { in TryInstallMemtableFlushResults()404 assert(i == 0 || mems[i]->GetEdits()->NumEntries() == 0); in TryInstallMemtableFlushResults()406 mems[i]->flush_completed_ = true; in TryInstallMemtableFlushResults()407 mems[i]->file_number_ = file_number; in TryInstallMemtableFlushResults()679 for (const auto mems : mems_list) { in InstallMemtableAtomicFlushResults() local680 assert(mems != nullptr); in InstallMemtableAtomicFlushResults()682 assert(!mems->empty()); in InstallMemtableAtomicFlushResults()[all …]
254 autovector<MemTable*>* mems);258 void RollbackMemtableFlush(const autovector<MemTable*>& mems,
146 void FlushJob::ReportFlushInputSize(const autovector<MemTable*>& mems) { in ReportFlushInputSize() argument148 for (auto* mem : mems) { in ReportFlushInputSize()
98 void ReportFlushInputSize(const autovector<MemTable*>& mems);
388 const auto& mems = flush_jobs[i]->GetMemTables(); in TEST_F() local389 mems_list.push_back(&mems); in TEST_F()
196 autovector<MemTable*> mems; in TEST_F() local197 list.PickMemtablesToFlush(nullptr /* memtable_id */, &mems); in TEST_F()198 ASSERT_EQ(0, mems.size()); in TEST_F()
404 auto* mems = reinterpret_cast<autovector<MemTable*>*>(arg); in TEST_F() local405 if (mems->front()->GetEarliestSequenceNumber() == listener->seq1 - 1) { in TEST_F()
462 auto& mems = jobs[i]->GetMemTables(); in AtomicFlushMemTablesToOutputFiles() local463 cfds[i]->imm()->RollbackMemtableFlush(mems, in AtomicFlushMemTablesToOutputFiles()473 const auto& mems = jobs[i]->GetMemTables(); in AtomicFlushMemTablesToOutputFiles() local477 } else if (!mems.empty() && in AtomicFlushMemTablesToOutputFiles()478 cfds[i]->imm()->GetEarliestMemTableID() < mems[0]->GetID()) { in AtomicFlushMemTablesToOutputFiles()485 } else if (mems.empty() && cfds[i]->imm()->GetEarliestMemTableID() <= in AtomicFlushMemTablesToOutputFiles()514 const auto& mems = jobs[i]->GetMemTables(); in AtomicFlushMemTablesToOutputFiles() local515 if (!cfds[i]->IsDropped() && !mems.empty()) { in AtomicFlushMemTablesToOutputFiles()517 mems_list.emplace_back(&mems); in AtomicFlushMemTablesToOutputFiles()