Lines Matching refs:m
31 void MemTableListVersion::AddMemTable(MemTable* m) { in AddMemTable() argument
32 memlist_.push_front(m); in AddMemTable()
33 *parent_memtable_list_memory_usage_ += m->ApproximateMemoryUsage(); in AddMemTable()
37 MemTable* m) { in UnrefMemTable() argument
38 if (m->Unref()) { in UnrefMemTable()
39 to_delete->push_back(m); in UnrefMemTable()
40 assert(*parent_memtable_list_memory_usage_ >= m->ApproximateMemoryUsage()); in UnrefMemTable()
41 *parent_memtable_list_memory_usage_ -= m->ApproximateMemoryUsage(); in UnrefMemTable()
54 for (auto& m : memlist_) { in MemTableListVersion() local
55 m->Ref(); in MemTableListVersion()
59 for (auto& m : memlist_history_) { in MemTableListVersion() local
60 m->Ref(); in MemTableListVersion()
83 for (const auto& m : memlist_) { in Unref() local
84 UnrefMemTable(to_delete, m); in Unref()
86 for (const auto& m : memlist_history_) { in Unref() local
87 UnrefMemTable(to_delete, m); in Unref()
195 for (auto& m : memlist_) { in AddRangeTombstoneIterators() local
197 m->NewRangeTombstoneIterator(read_opts, read_seq)); in AddRangeTombstoneIterators()
206 for (auto& m : memlist_) { in AddIterators() local
207 iterator_list->push_back(m->NewIterator(options, arena)); in AddIterators()
213 for (auto& m : memlist_) { in AddIterators() local
215 m->NewIterator(options, merge_iter_builder->GetArena())); in AddIterators()
221 for (auto& m : memlist_) { in GetTotalNumEntries() local
222 total_num += m->num_entries(); in GetTotalNumEntries()
230 for (auto& m : memlist_) { in ApproximateStats() local
231 auto mStats = m->ApproximateStats(start_ikey, end_ikey); in ApproximateStats()
240 for (auto& m : memlist_) { in GetTotalNumDeletes() local
241 total_num += m->num_deletes(); in GetTotalNumDeletes()
258 void MemTableListVersion::Add(MemTable* m, autovector<MemTable*>* to_delete) { in Add() argument
260 AddMemTable(m); in Add()
262 TrimHistory(to_delete, m->ApproximateMemoryUsage()); in Add()
266 void MemTableListVersion::Remove(MemTable* m, in Remove() argument
269 memlist_.remove(m); in Remove()
271 m->MarkFlushed(); in Remove()
274 memlist_history_.push_front(m); in Remove()
279 UnrefMemTable(to_delete, m); in Remove()
343 MemTable* m = *it; in PickMemtablesToFlush() local
344 if (!atomic_flush && m->atomic_flush_seqno_ != kMaxSequenceNumber) { in PickMemtablesToFlush()
347 if (max_memtable_id != nullptr && m->GetID() > *max_memtable_id) { in PickMemtablesToFlush()
350 if (!m->flush_in_progress_) { in PickMemtablesToFlush()
351 assert(!m->flush_completed_); in PickMemtablesToFlush()
356 m->flush_in_progress_ = true; // flushing will start very soon in PickMemtablesToFlush()
357 ret->push_back(m); in PickMemtablesToFlush()
373 for (MemTable* m : mems) { in RollbackMemtableFlush()
374 assert(m->flush_in_progress_); in RollbackMemtableFlush()
375 assert(m->file_number_ == 0); in RollbackMemtableFlush()
377 m->flush_in_progress_ = false; in RollbackMemtableFlush()
378 m->flush_completed_ = false; in RollbackMemtableFlush()
379 m->edit_.Clear(); in RollbackMemtableFlush()
441 MemTable* m = *it; in TryInstallMemtableFlushResults() local
442 if (!m->flush_completed_) { in TryInstallMemtableFlushResults()
445 if (it == memlist.rbegin() || batch_file_number != m->file_number_) { in TryInstallMemtableFlushResults()
446 batch_file_number = m->file_number_; in TryInstallMemtableFlushResults()
449 cfd->GetName().c_str(), m->file_number_); in TryInstallMemtableFlushResults()
450 edit_list.push_back(&m->edit_); in TryInstallMemtableFlushResults()
451 memtables_to_flush.push_back(m); in TryInstallMemtableFlushResults()
453 std::unique_ptr<FlushJobInfo> info = m->ReleaseFlushJobInfo(); in TryInstallMemtableFlushResults()
504 MemTable* m = current_->memlist_.back(); in TryInstallMemtableFlushResults() local
507 cfd->GetName().c_str(), m->file_number_, mem_id); in TryInstallMemtableFlushResults()
508 assert(m->file_number_ > 0); in TryInstallMemtableFlushResults()
509 current_->Remove(m, to_delete); in TryInstallMemtableFlushResults()
516 MemTable* m = *it; in TryInstallMemtableFlushResults() local
520 m->file_number_, mem_id); in TryInstallMemtableFlushResults()
521 m->flush_completed_ = false; in TryInstallMemtableFlushResults()
522 m->flush_in_progress_ = false; in TryInstallMemtableFlushResults()
523 m->edit_.Clear(); in TryInstallMemtableFlushResults()
525 m->file_number_ = 0; in TryInstallMemtableFlushResults()
537 void MemTableList::Add(MemTable* m, autovector<MemTable*>* to_delete) { in Add() argument
545 current_->Add(m, to_delete); in Add()
546 m->MarkImmutable(); in Add()
617 for (auto& m : current_->memlist_) { in PrecomputeMinLogContainingPrepSection() local
622 if (m == m_to_flush) { in PrecomputeMinLogContainingPrepSection()
631 auto log = m->GetMinLogContainingPrepSection(); in PrecomputeMinLogContainingPrepSection()
712 for (auto m : *mems_list[i]) { in InstallMemtableAtomicFlushResults()
713 assert(m->GetFileNumber() > 0); in InstallMemtableAtomicFlushResults()
714 uint64_t mem_id = m->GetID(); in InstallMemtableAtomicFlushResults()
718 cfds[i]->GetName().c_str(), m->GetFileNumber(), in InstallMemtableAtomicFlushResults()
720 imm->current_->Remove(m, to_delete); in InstallMemtableAtomicFlushResults()
728 for (auto m : *mems_list[i]) { in InstallMemtableAtomicFlushResults()
729 uint64_t mem_id = m->GetID(); in InstallMemtableAtomicFlushResults()
733 cfds[i]->GetName().c_str(), m->GetFileNumber(), in InstallMemtableAtomicFlushResults()
735 m->SetFlushCompleted(false); in InstallMemtableAtomicFlushResults()
736 m->SetFlushInProgress(false); in InstallMemtableAtomicFlushResults()
737 m->GetEdits()->Clear(); in InstallMemtableAtomicFlushResults()
738 m->SetFileNumber(0); in InstallMemtableAtomicFlushResults()