Lines Matching refs:cfd

28   if (!cfh->cfd()->ioptions()->merge_operator) {  in Merge()
1196 for (ColumnFamilyData* cfd : *versions_->GetColumnFamilySet()) { in SelectColumnFamiliesForAtomicFlush()
1197 if (cfd->IsDropped()) { in SelectColumnFamiliesForAtomicFlush()
1200 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in SelectColumnFamiliesForAtomicFlush()
1202 cfds->push_back(cfd); in SelectColumnFamiliesForAtomicFlush()
1211 for (auto cfd : cfds) { in AssignAtomicFlushSeq() local
1212 cfd->imm()->AssignAtomicFlushSeq(seq); in AssignAtomicFlushSeq()
1269 for (auto cfd : *versions_->GetColumnFamilySet()) { in SwitchWAL()
1270 if (cfd->IsDropped()) { in SwitchWAL()
1273 if (cfd->OldestLogToKeep() <= oldest_alive_log) { in SwitchWAL()
1274 cfds.push_back(cfd); in SwitchWAL()
1284 for (const auto cfd : cfds) { in SwitchWAL() local
1285 cfd->Ref(); in SwitchWAL()
1286 status = SwitchMemtable(cfd, write_context); in SwitchWAL()
1287 cfd->UnrefAndTryDelete(); in SwitchWAL()
1300 for (auto cfd : cfds) { in SwitchWAL() local
1301 cfd->imm()->FlushRequested(); in SwitchWAL()
1336 for (auto cfd : *versions_->GetColumnFamilySet()) { in HandleWriteBufferFull()
1337 if (cfd->IsDropped()) { in HandleWriteBufferFull()
1340 if (!cfd->mem()->IsEmpty()) { in HandleWriteBufferFull()
1343 uint64_t seq = cfd->mem()->GetCreationSeq(); in HandleWriteBufferFull()
1345 cfd_picked = cfd; in HandleWriteBufferFull()
1360 for (const auto cfd : cfds) { in HandleWriteBufferFull() local
1361 if (cfd->mem()->IsEmpty()) { in HandleWriteBufferFull()
1364 cfd->Ref(); in HandleWriteBufferFull()
1365 status = SwitchMemtable(cfd, write_context); in HandleWriteBufferFull()
1366 cfd->UnrefAndTryDelete(); in HandleWriteBufferFull()
1379 for (const auto cfd : cfds) { in HandleWriteBufferFull() local
1380 cfd->imm()->FlushRequested(); in HandleWriteBufferFull()
1512 for (ColumnFamilyData* cfd : *cfds) { in MaybeFlushStatsCF()
1513 if (cfd == cfd_stats) { in MaybeFlushStatsCF()
1546 for (auto& cfd : cfds) { in TrimMemtableHistory() local
1548 cfd->imm()->TrimHistory(&to_delete, cfd->mem()->ApproximateMemoryUsage()); in TrimMemtableHistory()
1555 cfd->InstallSuperVersion(&context->superversion_context, &mutex_); in TrimMemtableHistory()
1558 if (cfd->UnrefAndTryDelete()) { in TrimMemtableHistory()
1559 cfd = nullptr; in TrimMemtableHistory()
1569 for (auto cfd : cfds) { in ScheduleFlushes() local
1570 cfd->Ref(); in ScheduleFlushes()
1586 for (auto& cfd : cfds) { in ScheduleFlushes() local
1587 if (!cfd->mem()->IsEmpty()) { in ScheduleFlushes()
1588 status = SwitchMemtable(cfd, context); in ScheduleFlushes()
1590 if (cfd->UnrefAndTryDelete()) { in ScheduleFlushes()
1591 cfd = nullptr; in ScheduleFlushes()
1634 Status DBImpl::SwitchMemtable(ColumnFamilyData* cfd, WriteContext* context) { in SwitchMemtable() argument
1665 const MutableCFOptions mutable_cf_options = *cfd->GetLatestMutableCFOptions(); in SwitchMemtable()
1670 memtable_info.cf_name = cfd->GetName(); in SwitchMemtable()
1671 memtable_info.first_seqno = cfd->mem()->GetFirstSequenceNumber(); in SwitchMemtable()
1672 memtable_info.earliest_seqno = cfd->mem()->GetEarliestSequenceNumber(); in SwitchMemtable()
1673 memtable_info.num_entries = cfd->mem()->num_entries(); in SwitchMemtable()
1674 memtable_info.num_deletes = cfd->mem()->num_deletes(); in SwitchMemtable()
1678 int num_imm_unflushed = cfd->imm()->NumNotFlushed(); in SwitchMemtable()
1690 new_mem = cfd->ConstructNewMemtable(mutable_cf_options, seq); in SwitchMemtable()
1696 cfd->GetName().c_str(), new_log_number, num_imm_unflushed); in SwitchMemtable()
1717 cfd->GetName().c_str(), cur_log_writer->get_log_number(), in SwitchMemtable()
1767 cfd->mem()->SetNextLogNumber(logfile_number_); in SwitchMemtable()
1768 cfd->imm()->Add(cfd->mem(), &context->memtables_to_free_); in SwitchMemtable()
1770 cfd->SetMemtable(new_mem); in SwitchMemtable()
1771 InstallSuperVersionAndScheduleWork(cfd, &context->superversion_context, in SwitchMemtable()
1777 NotifyOnMemTableSealed(cfd, memtable_info); in SwitchMemtable()