Lines Matching refs:cfd
3480 ColumnFamilyData* cfd; member
3489 cfd(_cfd), in ManifestWriter()
3665 assert(last_writer->cfd != nullptr); in ProcessManifestWrites()
3666 if (last_writer->cfd->IsDropped()) { in ProcessManifestWrites()
3703 uint32_t cf_id = last_writer->cfd->GetID(); in ProcessManifestWrites()
3704 if (versions[i]->cfd()->GetID() == cf_id) { in ProcessManifestWrites()
3715 version = new Version(last_writer->cfd, this, file_options_, in ProcessManifestWrites()
3721 new BaseReferencedVersionBuilder(last_writer->cfd)); in ProcessManifestWrites()
3735 Status s = LogAndApplyHelper(last_writer->cfd, builder, e, mu); in ProcessManifestWrites()
3824 for (const auto* cfd : *column_family_set_) { in ProcessManifestWrites()
3825 assert(curr_state.find(cfd->GetID()) == curr_state.end()); in ProcessManifestWrites()
3826 curr_state[cfd->GetID()] = {cfd->GetLogNumber()}; in ProcessManifestWrites()
3841 ColumnFamilyData* cfd = versions[i]->cfd_; in ProcessManifestWrites() local
3843 cfd->internal_stats(), 1 /* max_threads */, in ProcessManifestWrites()
3971 first_writer.cfd->SetDropped(); in ProcessManifestWrites()
3972 first_writer.cfd->UnrefAndTryDelete(); in ProcessManifestWrites()
4006 ColumnFamilyData* cfd = versions[i]->cfd_; in ProcessManifestWrites() local
4007 AppendVersion(cfd, versions[i]); in ProcessManifestWrites()
4125 for (auto cfd : column_family_datas) { in LogAndApply() local
4127 if (cfd == nullptr || !cfd->IsDropped()) { in LogAndApply()
4163 Status VersionSet::LogAndApplyHelper(ColumnFamilyData* cfd, in LogAndApplyHelper() argument
4167 (void)cfd; in LogAndApplyHelper()
4173 assert(edit->log_number_ >= cfd->GetLogNumber()); in LogAndApplyHelper()
4215 ColumnFamilyData* cfd = nullptr; in ApplyOneVersionEditToBuilder() local
4237 cfd = CreateColumnFamily(cfo, &edit); in ApplyOneVersionEditToBuilder()
4239 cfd = CreateColumnFamily(cf_options->second, &edit); in ApplyOneVersionEditToBuilder()
4241 cfd->set_initialized(); in ApplyOneVersionEditToBuilder()
4244 new BaseReferencedVersionBuilder(cfd)))); in ApplyOneVersionEditToBuilder()
4251 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in ApplyOneVersionEditToBuilder()
4252 assert(cfd != nullptr); in ApplyOneVersionEditToBuilder()
4253 if (cfd->UnrefAndTryDelete()) { in ApplyOneVersionEditToBuilder()
4254 cfd = nullptr; in ApplyOneVersionEditToBuilder()
4271 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in ApplyOneVersionEditToBuilder()
4273 assert(cfd != nullptr); in ApplyOneVersionEditToBuilder()
4285 return ExtractInfoFromVersionEdit(cfd, edit, version_edit_params); in ApplyOneVersionEditToBuilder()
4289 ColumnFamilyData* cfd, const VersionEdit& from_edit, in ExtractInfoFromVersionEdit() argument
4291 if (cfd != nullptr) { in ExtractInfoFromVersionEdit()
4296 if (cfd->GetLogNumber() > from_edit.log_number_) { in ExtractInfoFromVersionEdit()
4302 cfd->SetLogNumber(from_edit.log_number_); in ExtractInfoFromVersionEdit()
4307 from_edit.comparator_ != cfd->user_comparator()->Name()) { in ExtractInfoFromVersionEdit()
4309 cfd->user_comparator()->Name(), in ExtractInfoFromVersionEdit()
4543 for (auto cfd : *column_family_set_) { in Recover()
4544 assert(builders.count(cfd->GetID()) > 0); in Recover()
4545 auto* builder = builders[cfd->GetID()]->version_builder(); in Recover()
4555 for (auto cfd : *column_family_set_) { in Recover()
4556 if (cfd->IsDropped()) { in Recover()
4560 cfd->table_cache()->SetTablesAreImmortal(); in Recover()
4562 assert(cfd->initialized()); in Recover()
4563 auto builders_iter = builders.find(cfd->GetID()); in Recover()
4570 cfd->internal_stats(), db_options_->max_file_opening_threads, in Recover()
4573 cfd->GetLatestMutableCFOptions()->prefix_extractor.get()); in Recover()
4581 Version* v = new Version(cfd, this, file_options_, in Recover()
4582 *cfd->GetLatestMutableCFOptions(), in Recover()
4587 v->PrepareApply(*cfd->GetLatestMutableCFOptions(), in Recover()
4589 AppendVersion(cfd, v); in Recover()
4611 for (auto cfd : *column_family_set_) { in Recover()
4612 if (cfd->IsDropped()) { in Recover()
4618 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
4945 for (auto cfd : *column_family_set_) { in GetLiveFilesChecksumInfo()
4946 if (cfd->IsDropped() || !cfd->initialized()) { in GetLiveFilesChecksumInfo()
4949 for (int level = 0; level < cfd->NumberLevels(); level++) { in GetLiveFilesChecksumInfo()
4951 cfd->current()->storage_info()->LevelFiles(level)) { in GetLiveFilesChecksumInfo()
5030 ColumnFamilyData* cfd = nullptr; in DumpManifest() local
5038 cfd = CreateColumnFamily(ColumnFamilyOptions(options), &edit); in DumpManifest()
5039 cfd->set_initialized(); in DumpManifest()
5042 new BaseReferencedVersionBuilder(cfd)))); in DumpManifest()
5052 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in DumpManifest()
5053 assert(cfd != nullptr); in DumpManifest()
5054 cfd->UnrefAndTryDelete(); in DumpManifest()
5055 cfd = nullptr; in DumpManifest()
5063 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in DumpManifest()
5065 assert(cfd != nullptr); in DumpManifest()
5078 if (cfd != nullptr && edit.has_log_number_) { in DumpManifest()
5079 cfd->SetLogNumber(edit.log_number_); in DumpManifest()
5124 for (auto cfd : *column_family_set_) { in DumpManifest()
5125 if (cfd->IsDropped()) { in DumpManifest()
5128 auto builders_iter = builders.find(cfd->GetID()); in DumpManifest()
5132 Version* v = new Version(cfd, this, file_options_, in DumpManifest()
5133 *cfd->GetLatestMutableCFOptions(), in DumpManifest()
5136 v->PrepareApply(*cfd->GetLatestMutableCFOptions(), false); in DumpManifest()
5140 cfd->GetName().c_str(), cfd->GetID()); in DumpManifest()
5141 printf("log number: %" PRIu64 "\n", cfd->GetLogNumber()); in DumpManifest()
5142 auto comparator = comparators.find(cfd->GetID()); in DumpManifest()
5213 for (auto cfd : *column_family_set_) { in WriteCurrentStateToManifest()
5214 if (cfd->IsDropped()) { in WriteCurrentStateToManifest()
5217 assert(cfd->initialized()); in WriteCurrentStateToManifest()
5221 if (cfd->GetID() != 0) { in WriteCurrentStateToManifest()
5224 edit.AddColumnFamily(cfd->GetName()); in WriteCurrentStateToManifest()
5225 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5228 cfd->internal_comparator().user_comparator()->Name()); in WriteCurrentStateToManifest()
5244 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5246 for (int level = 0; level < cfd->NumberLevels(); level++) { in WriteCurrentStateToManifest()
5248 cfd->current()->storage_info()->LevelFiles(level)) { in WriteCurrentStateToManifest()
5257 const auto iter = curr_state.find(cfd->GetID()); in WriteCurrentStateToManifest()
5477 for (auto cfd : *column_family_set_) { in AddLiveFiles()
5478 if (!cfd->initialized()) { in AddLiveFiles()
5481 Version* dummy_versions = cfd->dummy_versions(); in AddLiveFiles()
5494 for (auto cfd : *column_family_set_) { in AddLiveFiles()
5495 if (!cfd->initialized()) { in AddLiveFiles()
5498 auto* current = cfd->current(); in AddLiveFiles()
5500 Version* dummy_versions = cfd->dummy_versions(); in AddLiveFiles()
5519 auto cfd = c->column_family_data(); in MakeInputIterator() local
5542 list[num++] = cfd->table_cache()->NewIterator( in MakeInputIterator()
5544 cfd->internal_comparator(), in MakeInputIterator()
5557 cfd->table_cache(), read_options, file_options_compactions, in MakeInputIterator()
5558 cfd->internal_comparator(), c->input_levels(which), in MakeInputIterator()
5629 ColumnFamilyData** cfd) { in GetMetadataForFile() argument
5641 *cfd = cfd_iter; in GetMetadataForFile()
5651 for (auto cfd : *column_family_set_) { in GetLiveFilesMetaData()
5652 if (cfd->IsDropped() || !cfd->initialized()) { in GetLiveFilesMetaData()
5655 for (int level = 0; level < cfd->NumberLevels(); level++) { in GetLiveFilesMetaData()
5657 cfd->current()->storage_info()->LevelFiles(level)) { in GetLiveFilesMetaData()
5659 filemetadata.column_family_name = cfd->GetName(); in GetLiveFilesMetaData()
5661 if (path_id < cfd->ioptions()->cf_paths.size()) { in GetLiveFilesMetaData()
5662 filemetadata.db_path = cfd->ioptions()->cf_paths[path_id].path; in GetLiveFilesMetaData()
5664 assert(!cfd->ioptions()->cf_paths.empty()); in GetLiveFilesMetaData()
5665 filemetadata.db_path = cfd->ioptions()->cf_paths.back().path; in GetLiveFilesMetaData()
5842 auto cfd = column_family_set_->GetColumnFamily(cf.name); in Recover() local
5843 if (cfd == nullptr) { in Recover()
5851 auto cfd = column_family_set_->GetColumnFamily(cf.name); in Recover() local
5852 assert(cfd != nullptr); in Recover()
5853 if (!cfd->IsDropped()) { in Recover()
5854 auto builder_iter = builders.find(cfd->GetID()); in Recover()
5859 cfd->internal_stats(), db_options_->max_file_opening_threads, in Recover()
5862 cfd->GetLatestMutableCFOptions()->prefix_extractor.get()); in Recover()
5890 for (auto cfd : *column_family_set_) { in Recover()
5891 assert(builders.count(cfd->GetID()) > 0); in Recover()
5892 auto builder = builders[cfd->GetID()]->version_builder(); in Recover()
5902 for (auto cfd : *column_family_set_) { in Recover()
5903 if (cfd->IsDropped()) { in Recover()
5906 assert(cfd->initialized()); in Recover()
5907 auto builders_iter = builders.find(cfd->GetID()); in Recover()
5911 Version* v = new Version(cfd, this, file_options_, in Recover()
5912 *cfd->GetLatestMutableCFOptions(), in Recover()
5917 v->PrepareApply(*cfd->GetLatestMutableCFOptions(), in Recover()
5919 AppendVersion(cfd, v); in Recover()
5926 for (auto cfd : *column_family_set_) { in Recover()
5927 if (cfd->IsDropped()) { in Recover()
5932 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
5963 ColumnFamilyData* cfd = in ReadAndApply() local
5965 if (cfd != nullptr && !cfd->IsDropped()) { in ReadAndApply()
6028 for (auto* cfd : *column_family_set_) { in ReadAndApply()
6029 if (cfd->IsDropped()) { in ReadAndApply()
6047 for (auto cfd : *column_family_set_) { in ReadAndApply()
6048 auto builder_iter = active_version_builders_.find(cfd->GetID()); in ReadAndApply()
6068 ColumnFamilyData* cfd = in ApplyOneVersionEditToBuilder() local
6075 if (nullptr == cfd) { in ApplyOneVersionEditToBuilder()
6080 !cfd->IsDropped()) { in ApplyOneVersionEditToBuilder()
6082 new BaseReferencedVersionBuilder(cfd)); in ApplyOneVersionEditToBuilder()
6103 cfd->SetDropped(); in ApplyOneVersionEditToBuilder()
6104 if (cfd->UnrefAndTryDelete()) { in ApplyOneVersionEditToBuilder()
6105 cfd = nullptr; in ApplyOneVersionEditToBuilder()
6114 Status s = ExtractInfoFromVersionEdit(cfd, edit, version_edit); in ApplyOneVersionEditToBuilder()
6119 if (cfd != nullptr && !cfd->IsDropped()) { in ApplyOneVersionEditToBuilder()
6121 cfd->internal_stats(), db_options_->max_file_opening_threads, in ApplyOneVersionEditToBuilder()
6124 cfd->GetLatestMutableCFOptions()->prefix_extractor.get()); in ApplyOneVersionEditToBuilder()
6131 auto version = new Version(cfd, this, file_options_, in ApplyOneVersionEditToBuilder()
6132 *cfd->GetLatestMutableCFOptions(), in ApplyOneVersionEditToBuilder()
6135 version->PrepareApply(*cfd->GetLatestMutableCFOptions(), true); in ApplyOneVersionEditToBuilder()
6136 AppendVersion(cfd, version); in ApplyOneVersionEditToBuilder()
6138 if (cfds_changed->count(cfd) == 0) { in ApplyOneVersionEditToBuilder()
6139 cfds_changed->insert(cfd); in ApplyOneVersionEditToBuilder()