Lines Matching refs:imm
146 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()
478 cfds[i]->imm()->GetEarliestMemTableID() < mems[0]->GetID()) { in AtomicFlushMemTablesToOutputFiles()
485 } else if (mems.empty() && cfds[i]->imm()->GetEarliestMemTableID() <= in AtomicFlushMemTablesToOutputFiles()
1574 uint64_t max_memtable_id = cfd->imm()->GetLatestMemTableID(); in GenerateFlushRequest()
1611 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in FlushMemTable()
1613 flush_memtable_id = cfd->imm()->GetLatestMemTableID(); in FlushMemTable()
1639 flush_memtable_id = cfd_stats->imm()->GetLatestMemTableID(); in FlushMemTable()
1649 loop_cfd->imm()->FlushRequested(); in FlushMemTable()
1734 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in AtomicFlushMemTables()
1753 cfd->imm()->FlushRequested(); in AtomicFlushMemTables()
1831 std::min(cfd->mem()->GetID(), cfd->imm()->GetEarliestMemTableID()); in WaitUntilFlushWouldNotStallWrites()
1846 if (cfd->imm()->NumNotFlushed() < in WaitUntilFlushWouldNotStallWrites()
1858 cfd->imm()->NumNotFlushed() + 1, in WaitUntilFlushWouldNotStallWrites()
1901 } else if (cfds[i]->imm()->NumNotFlushed() == 0 || in WaitForFlushMemTables()
1903 cfds[i]->imm()->GetEarliestMemTableID() > in WaitForFlushMemTables()
2232 if (cfd->IsDropped() || !cfd->imm()->IsFlushPending()) { in BackgroundFlush()