Home
last modified time | relevance | path

Searched refs:imm (Results 1 – 15 of 15) sorted by relevance

/rocksdb-6.9/db/
Dmemtable_list.cc661 const auto* imm = in InstallMemtableAtomicFlushResults() local
662 (imm_lists == nullptr) ? cfds[k]->imm() : imm_lists->at(k); in InstallMemtableAtomicFlushResults()
702 auto* imm = (imm_lists == nullptr) ? cfds[k]->imm() : imm_lists->at(k); in InstallMemtableAtomicFlushResults() local
703 imm->InstallNewVersion(); in InstallMemtableAtomicFlushResults()
711 auto* imm = (imm_lists == nullptr) ? cfds[i]->imm() : imm_lists->at(i); in InstallMemtableAtomicFlushResults() local
720 imm->current_->Remove(m, to_delete); in InstallMemtableAtomicFlushResults()
721 imm->UpdateCachedValuesFromMemTableListVersion(); in InstallMemtableAtomicFlushResults()
722 imm->ResetTrimHistoryNeeded(); in InstallMemtableAtomicFlushResults()
727 auto* imm = (imm_lists == nullptr) ? cfds[i]->imm() : imm_lists->at(i); in InstallMemtableAtomicFlushResults() local
739 imm->num_flush_not_started_++; in InstallMemtableAtomicFlushResults()
[all …]
Dflush_job_test.cc212 cfd->imm()->Add(new_mem, &to_delete); in TEST_F()
276 cfd->imm()->Add(mem, &to_delete); in TEST_F()
346 cfd->imm()->Add(mem, &to_delete); in TEST_F()
414 all_cfds[k]->imm()->GetEarliestMemTableID()); in TEST_F()
415 ASSERT_EQ(0, all_cfds[k]->imm()->GetLatestMemTableID()); in TEST_F()
467 cfd->imm()->Add(new_mem, &to_delete); in TEST_F()
Dcolumn_family.cc430 imm->Unref(&to_delete); in Cleanup()
433 auto* memory_usage = current->cfd()->imm()->current_memory_usage(); in Cleanup()
448 imm = new_imm; in Init()
452 imm->Ref(); in Init()
695 imm()->PrecomputeMinLogContainingPrepSection(empty_list); in OldestLogToKeep()
858 imm()->NumNotFlushed(), vstorage->l0_delay_trigger_count(), in RecalculateWriteStallConditions()
874 name_.c_str(), imm()->NumNotFlushed(), in RecalculateWriteStallConditions()
909 name_.c_str(), imm()->NumNotFlushed(), in RecalculateWriteStallConditions()
1081 super_version->imm->AddIterators(read_opts, &merge_iter_builder); in RangesOverlapWithMemtables()
1090 super_version->imm->AddRangeTombstoneIterators(read_opts, nullptr /* arena */, in RangesOverlapWithMemtables()
Dflush_job.cc168 cfd_->imm()->PickMemtablesToFlush(max_memtable_id_, &mems_); in PickMemTable()
237 cfd_->imm()->RollbackMemtableFlush(mems_, meta_.fd.GetNumber()); in Run()
242 s = cfd_->imm()->TryInstallMemtableFlushResults( in Run()
269 stream << "immutable_memtables" << cfd_->imm()->NumNotFlushed(); in Run()
Ddb_flush_test.cc385 ASSERT_LT(seq, cfd->imm()->current()->GetEarliestSequenceNumber()); in TEST_F()
467 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
504 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
510 ASSERT_EQ(0, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
556 ASSERT_EQ(1, cfh->cfd()->imm()->NumNotFlushed()); in TEST_P()
Dinternal_stats.cc653 *value = cfd_->imm()->NumNotFlushed(); in HandleNumImmutableMemTable()
660 *value = cfd_->imm()->NumFlushed(); in HandleNumImmutableMemTableFlushed()
666 *value = (cfd_->imm()->IsFlushPending() ? 1 : 0); in HandleMemTableFlushPending()
709 cfd_->imm()->ApproximateUnflushedMemTablesMemoryUsage(); in HandleCurSizeAllMemTables()
716 cfd_->imm()->ApproximateMemoryUsage(); in HandleSizeAllMemTables()
732 *value = cfd_->imm()->current()->GetTotalNumEntries(); in HandleNumEntriesImmMemTables()
748 *value = cfd_->imm()->current()->GetTotalNumDeletes(); in HandleNumDeletesImmMemTables()
758 cfd_->imm()->current()->GetTotalNumEntries() + in HandleEstimateNumKeys()
761 cfd_->mem()->num_deletes() + cfd_->imm()->current()->GetTotalNumDeletes(); in HandleEstimateNumKeys()
901 cfd_->imm()->ApproximateOldestKeyTime(), *value}); in HandleEstimateOldestKeyTime()
Dforward_iterator.cc626 sv_->imm->AddIterators(read_options_, &imm_iters_, &arena_); in RebuildIterators()
632 sv_->imm->AddRangeTombstoneIterators(read_options_, &arena_, in RebuildIterators()
686 svnew->imm->AddIterators(read_options_, &imm_iters_, &arena_); in RenewIterators()
694 svnew->imm->AddRangeTombstoneIterators(read_options_, &arena_, in RenewIterators()
Dcolumn_family.h203 MemTableListVersion* imm; member
360 MemTableList* imm() { return &imm_; } in imm() function
Dwrite_batch.cc1795 MemTableList* const imm = cfd->imm(); in CheckMemtableFull() local
1796 assert(imm); in CheckMemtableFull()
1798 if (imm->HasHistory()) { in CheckMemtableFull()
1803 imm->ApproximateMemoryUsageExcludingLast() >= in CheckMemtableFull()
1805 imm->MarkTrimHistoryNeeded()) { in CheckMemtableFull()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc146 assert(cfd->imm()->NumNotFlushed() != 0); in FlushMemTableToOutputFile()
147 assert(cfd->imm()->IsFlushPending()); in FlushMemTableToOutputFile()
300 assert(cfd->imm()->NumNotFlushed() != 0); in AtomicFlushMemTablesToOutputFiles()
301 assert(cfd->imm()->IsFlushPending()); in AtomicFlushMemTablesToOutputFiles()
463 cfds[i]->imm()->RollbackMemtableFlush(mems, in AtomicFlushMemTablesToOutputFiles()
1649 loop_cfd->imm()->FlushRequested(); in FlushMemTable()
1753 cfd->imm()->FlushRequested(); in AtomicFlushMemTables()
1846 if (cfd->imm()->NumNotFlushed() < in WaitUntilFlushWouldNotStallWrites()
1858 cfd->imm()->NumNotFlushed() + 1, in WaitUntilFlushWouldNotStallWrites()
1901 } else if (cfds[i]->imm()->NumNotFlushed() == 0 || in WaitForFlushMemTables()
[all …]
Ddb_impl_write.cc1200 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in SelectColumnFamiliesForAtomicFlush()
1212 cfd->imm()->AssignAtomicFlushSeq(seq); in AssignAtomicFlushSeq()
1301 cfd->imm()->FlushRequested(); in SwitchWAL()
1380 cfd->imm()->FlushRequested(); in HandleWriteBufferFull()
1548 cfd->imm()->TrimHistory(&to_delete, cfd->mem()->ApproximateMemoryUsage()); in TrimMemtableHistory()
1678 int num_imm_unflushed = cfd->imm()->NumNotFlushed(); in SwitchMemtable()
1759 loop_cfd->imm()->NumNotFlushed() == 0) { in SwitchMemtable()
1768 cfd->imm()->Add(cfd->mem(), &context->memtables_to_free_); in SwitchMemtable()
Ddb_impl_secondary.cc250 cfd->imm()->Add(cfd->mem(), &job_context->memtables_to_free); in RecoverLogFiles()
350 super_version->imm->Get( in GetImpl()
542 cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(), in TryCatchUpWithPrimary()
Ddb_impl.cc1474 super_version->imm->AddIterators(read_options, &merge_iter_builder); in NewInternalIterator()
1622 sv->imm->Get(lkey, get_impl_options.value->GetSelf(), in GetImpl()
1640 sv->imm->GetMergeOperands(lkey, &s, &merge_context, in GetImpl()
1783 } else if (super_version->imm->Get( in MultiGet()
2204 super_version->imm->MultiGet(read_options, &range, callback, in MultiGetImpl()
3088 sv->imm->ApproximateStats(k1.Encode(), k2.Encode()); in GetApproximateMemTableStats()
3120 sizes[i] += sv->imm->ApproximateStats(k1.Encode(), k2.Encode()).size; in GetApproximateSizes()
3840 sv->imm->GetEarliestSequenceNumber(include_history); in GetEarliestMemTableSequenceNumber()
3896 sv->imm->Get(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
3915 SequenceNumber lower_bound_in_imm = sv->imm->GetEarliestSequenceNumber(); in GetLatestSequenceForKey()
[all …]
Ddb_impl_files.cc590 auto log = loop_cfd->imm()->PrecomputeMinLogContainingPrepSection( in FindMinPrepLogReferencedByMemTable()
/rocksdb-6.9/utilities/transactions/
Dtransaction_test.cc1941 ASSERT_TRUE(cfh_a->cfd()->imm()->HasFlushRequested()); in TEST_P()
1946 ASSERT_TRUE(!cfh_b->cfd()->imm()->HasFlushRequested()); in TEST_P()
1951 ASSERT_TRUE(cfh_b->cfd()->imm()->HasFlushRequested()); in TEST_P()
1965 ASSERT_TRUE(cfh_b->cfd()->imm()->HasFlushRequested()); in TEST_P()