Lines Matching refs:cfds

293   autovector<ColumnFamilyData*> cfds;  in AtomicFlushMemTablesToOutputFiles()  local
295 cfds.emplace_back(arg.cfd_); in AtomicFlushMemTablesToOutputFiles()
299 for (const auto cfd : cfds) { in AtomicFlushMemTablesToOutputFiles()
315 int num_cfs = static_cast<int>(cfds.size()); in AtomicFlushMemTablesToOutputFiles()
318 auto cfd = cfds[i]; in AtomicFlushMemTablesToOutputFiles()
361 NotifyOnFlushBegin(cfds[i], &file_meta[i], mutable_cf_options, in AtomicFlushMemTablesToOutputFiles()
463 cfds[i]->imm()->RollbackMemtableFlush(mems, in AtomicFlushMemTablesToOutputFiles()
472 for (size_t i = 0; i != cfds.size(); ++i) { in AtomicFlushMemTablesToOutputFiles()
474 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()
478 cfds[i]->imm()->GetEarliestMemTableID() < mems[0]->GetID()) { in AtomicFlushMemTablesToOutputFiles()
485 } else if (mems.empty() && cfds[i]->imm()->GetEarliestMemTableID() <= in AtomicFlushMemTablesToOutputFiles()
515 if (!cfds[i]->IsDropped() && !mems.empty()) { in AtomicFlushMemTablesToOutputFiles()
516 tmp_cfds.emplace_back(cfds[i]); in AtomicFlushMemTablesToOutputFiles()
533 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()
536 InstallSuperVersionAndScheduleWork(cfds[i], in AtomicFlushMemTablesToOutputFiles()
541 cfds[i]->GetName().c_str(), in AtomicFlushMemTablesToOutputFiles()
542 cfds[i]->current()->storage_info()->LevelSummary(&tmp)); in AtomicFlushMemTablesToOutputFiles()
552 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()
555 NotifyOnFlushCompleted(cfds[i], all_mutable_cf_options[i], in AtomicFlushMemTablesToOutputFiles()
559 cfds[i]->ioptions()->cf_paths[0].path, file_meta[i].fd.GetNumber()); in AtomicFlushMemTablesToOutputFiles()
704 autovector<ColumnFamilyData*> cfds; in CompactRange() local
706 SelectColumnFamiliesForAtomicFlush(&cfds); in CompactRange()
708 s = AtomicFlushMemTables(cfds, fo, FlushReason::kManualCompaction, in CompactRange()
1400 autovector<ColumnFamilyData*> cfds; in Flush() local
1402 [&cfds](ColumnFamilyHandle* elem) { in Flush()
1404 cfds.emplace_back(cfh->cfd()); in Flush()
1406 s = AtomicFlushMemTables(cfds, flush_options, FlushReason::kManualFlush); in Flush()
1565 void DBImpl::GenerateFlushRequest(const autovector<ColumnFamilyData*>& cfds, in GenerateFlushRequest() argument
1568 req->reserve(cfds.size()); in GenerateFlushRequest()
1569 for (const auto cfd : cfds) { in GenerateFlushRequest()
1675 autovector<ColumnFamilyData*> cfds; in FlushMemTable() local
1678 cfds.push_back(iter.first); in FlushMemTable()
1681 s = WaitForFlushMemTables(cfds, flush_memtable_ids, in FlushMemTable()
1684 for (auto* tmp_cfd : cfds) { in FlushMemTable()
1715 autovector<ColumnFamilyData*> cfds; in AtomicFlushMemTables() local
1736 cfds.emplace_back(cfd); in AtomicFlushMemTables()
1739 for (auto cfd : cfds) { in AtomicFlushMemTables()
1751 AssignAtomicFlushSeq(cfds); in AtomicFlushMemTables()
1752 for (auto cfd : cfds) { in AtomicFlushMemTables()
1760 for (auto cfd : cfds) { in AtomicFlushMemTables()
1764 GenerateFlushRequest(cfds, &flush_req); in AtomicFlushMemTables()
1783 s = WaitForFlushMemTables(cfds, flush_memtable_ids, in AtomicFlushMemTables()
1786 for (auto* cfd : cfds) { in AtomicFlushMemTables()
1878 const autovector<ColumnFamilyData*>& cfds, in WaitForFlushMemTables() argument
1881 int num = static_cast<int>(cfds.size()); in WaitForFlushMemTables()
1899 if (cfds[i]->IsDropped()) { in WaitForFlushMemTables()
1901 } else if (cfds[i]->imm()->NumNotFlushed() == 0 || in WaitForFlushMemTables()
1903 cfds[i]->imm()->GetEarliestMemTableID() > in WaitForFlushMemTables()