Searched refs:NumNotFlushed (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/db/ |
| D | memtable_list_test.cc | 192 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
314 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
404 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
456 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
466 ASSERT_EQ(1, list.NumNotFlushed()); in TEST_F()
588 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
600 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
621 ASSERT_EQ(3, list.NumNotFlushed()); in TEST_F()
629 ASSERT_EQ(3, list.NumNotFlushed()); in TEST_F()
647 ASSERT_EQ(4, list.NumNotFlushed()); in TEST_F()
[all …]
|
| D | db_flush_test.cc | 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()
|
| D | column_family.cc | 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()
|
| D | memtable_list.h | 241 int NumNotFlushed() const;
|
| D | flush_job.cc | 269 stream << "immutable_memtables" << cfd_->imm()->NumNotFlushed(); in Run()
|
| D | memtable_list.cc | 93 int MemTableList::NumNotFlushed() const { in NumNotFlushed() function in ROCKSDB_NAMESPACE::MemTableList
|
| D | internal_stats.cc | 653 *value = cfd_->imm()->NumNotFlushed(); in HandleNumImmutableMemTable()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 146 assert(cfd->imm()->NumNotFlushed() != 0); in FlushMemTableToOutputFile()
300 assert(cfd->imm()->NumNotFlushed() != 0); in AtomicFlushMemTablesToOutputFiles()
1611 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in FlushMemTable()
1734 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || 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()
|
| D | db_impl_write.cc | 1200 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in SelectColumnFamiliesForAtomicFlush()
1678 int num_imm_unflushed = cfd->imm()->NumNotFlushed(); in SwitchMemtable()
1759 loop_cfd->imm()->NumNotFlushed() == 0) { in SwitchMemtable()
|