196   for (auto& cfd : column_families) {  in ValidateOptions()  local
197     s = ColumnFamilyData::ValidateOptions(db_options, cfd.options);  in ValidateOptions()
471     for (auto cfd : *versions_->GetColumnFamilySet()) {  in Recover()
472       s = cfd->AddDirectories(&created_dirs);  in Recover()
487     for (auto cfd : *versions_->GetColumnFamilySet()) {  in Recover()
488       auto* mutable_cf_options = cfd->GetLatestMutableCFOptions();  in Recover()
496     default_cf_internal_stats_ = default_cf_handle_->cfd()->internal_stats();  in Recover()
568         for (auto cfd : *versions_->GetColumnFamilySet()) {  in Recover()
569           cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(),  in Recover()
716   for (auto cfd : *versions_->GetColumnFamilySet()) {  in RecoverLogFiles()
718     edit.SetColumnFamily(cfd->GetID());  in RecoverLogFiles()
719     version_edits.insert({cfd->GetID(), edit});  in RecoverLogFiles()
738     for (auto cfd : *versions_->GetColumnFamilySet()) {  in RecoverLogFiles()
739       cf_name_id_map.insert(std::make_pair(cfd->GetName(), cfd->GetID()));  in RecoverLogFiles()
741           std::make_pair(cfd->GetID(), cfd->GetLogNumber()));  in RecoverLogFiles()
957         ColumnFamilyData* cfd;  in RecoverLogFiles()  local
959         while ((cfd = flush_scheduler_.TakeNextColumnFamily()) != nullptr) {  in RecoverLogFiles()
960           cfd->UnrefAndTryDelete();  in RecoverLogFiles()
963           assert(cfd->GetLogNumber() <= log_number);  in RecoverLogFiles()
964           auto iter = version_edits.find(cfd->GetID());  in RecoverLogFiles()
967           status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit);  in RecoverLogFiles()
975           cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(),  in RecoverLogFiles()
1037     for (auto cfd : *versions_->GetColumnFamilySet()) {  in RecoverLogFiles()
1038       if (cfd->GetLogNumber() > corrupted_log_number) {  in RecoverLogFiles()
1054     for (auto cfd : *versions_->GetColumnFamilySet()) {  in RecoverLogFiles()
1055       auto iter = version_edits.find(cfd->GetID());  in RecoverLogFiles()
1059       if (cfd->GetLogNumber() > max_log_number) {  in RecoverLogFiles()
1064         assert(cfd->mem()->GetFirstSequenceNumber() == 0);  in RecoverLogFiles()
1073       if (cfd->mem()->GetFirstSequenceNumber() != 0) {  in RecoverLogFiles()
1078           status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit);  in RecoverLogFiles()
1085           cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(),  in RecoverLogFiles()
1099       if (flushed || cfd->mem()->GetFirstSequenceNumber() == 0) {  in RecoverLogFiles()
1113       for (auto* cfd : *versions_->GetColumnFamilySet()) {  in RecoverLogFiles()
1114         cfds.push_back(cfd);  in RecoverLogFiles()
1115         cf_opts.push_back(cfd->GetLatestMutableCFOptions());  in RecoverLogFiles()
1116         auto iter = version_edits.find(cfd->GetID());  in RecoverLogFiles()
1192 Status DBImpl::WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd,  in WriteLevel0TableForRecovery()  argument
1211                     cfd->GetName().c_str(), meta.fd.GetNumber());  in WriteLevel0TableForRecovery()
1215         *cfd->GetLatestMutableCFOptions();  in WriteLevel0TableForRecovery()
1217         cfd->GetLatestMutableCFOptions()->paranoid_file_checks;  in WriteLevel0TableForRecovery()
1225       auto write_hint = cfd->CalculateSSTWriteHint(0);  in WriteLevel0TableForRecovery()
1244           dbname_, env_, fs_.get(), *cfd->ioptions(), mutable_cf_options,  in WriteLevel0TableForRecovery()
1245           file_options_for_compaction_, cfd->table_cache(), iter.get(),  in WriteLevel0TableForRecovery()
1246           std::move(range_del_iters), &meta, cfd->internal_comparator(),  in WriteLevel0TableForRecovery()
1247           cfd->int_tbl_prop_collector_factories(), cfd->GetID(), cfd->GetName(),  in WriteLevel0TableForRecovery()
1249           GetCompressionFlush(*cfd->ioptions(), mutable_cf_options),  in WriteLevel0TableForRecovery()
1251           cfd->ioptions()->compression_opts, paranoid_file_checks,  in WriteLevel0TableForRecovery()
1252           cfd->internal_stats(), TableFileCreationReason::kRecovery, &io_s,  in WriteLevel0TableForRecovery()
1259                       cfd->GetName().c_str(), meta.fd.GetNumber(),  in WriteLevel0TableForRecovery()
1282   cfd->internal_stats()->AddCompactionStats(level, Env::Priority::USER, stats);  in WriteLevel0TableForRecovery()
1283   cfd->internal_stats()->AddCFStats(InternalStats::BYTES_FLUSHED,  in WriteLevel0TableForRecovery()
1446         auto cfd =  in Open()  local
1448         if (cfd != nullptr) {  in Open()
1450               new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_));  in Open()
1451           impl->NewThreadStatusCfInfo(cfd);  in Open()
1473       for (auto cfd : *impl->versions_->GetColumnFamilySet()) {  in Open()
1475             cfd, &sv_context, *cfd->GetLatestMutableCFOptions());  in Open()
1523     for (auto cfd : *impl->versions_->GetColumnFamilySet()) {  in Open()
1524       if (cfd->ioptions()->compaction_style == kCompactionStyleFIFO) {  in Open()
1525         auto* vstorage = cfd->current()->storage_info();  in Open()
1536       if (!cfd->mem()->IsSnapshotSupported()) {  in Open()
1539       if (cfd->ioptions()->merge_operator != nullptr &&  in Open()
1540           !cfd->mem()->IsMergeOperatorSupported()) {  in Open()
1544             cfd->GetName().c_str());  in Open()