Lines Matching refs:cfd
51 ColumnFamilyData* cfd = nullptr; in Iterate() local
55 s = ApplyVersionEdit(e, &cfd); in Iterate()
67 s = ApplyVersionEdit(edit, &cfd); in Iterate()
96 ColumnFamilyData* cfd = in Initialize() local
98 assert(cfd != nullptr); in Initialize()
100 (void)cfd; in Initialize()
109 ColumnFamilyData** cfd) { in ApplyVersionEdit() argument
112 s = OnColumnFamilyAdd(edit, cfd); in ApplyVersionEdit()
114 s = OnColumnFamilyDrop(edit, cfd); in ApplyVersionEdit()
116 s = OnNonCfOperation(edit, cfd); in ApplyVersionEdit()
119 assert(cfd != nullptr); in ApplyVersionEdit()
120 s = ExtractInfoFromVersionEdit(*cfd, edit); in ApplyVersionEdit()
126 ColumnFamilyData** cfd) { in OnColumnFamilyAdd() argument
131 assert(cfd != nullptr); in OnColumnFamilyAdd()
132 *cfd = nullptr; in OnColumnFamilyAdd()
157 *cfd = tmp_cfd; in OnColumnFamilyAdd()
164 ColumnFamilyData** cfd) { in OnColumnFamilyDrop() argument
169 assert(cfd != nullptr); in OnColumnFamilyDrop()
170 *cfd = nullptr; in OnColumnFamilyDrop()
180 *cfd = tmp_cfd; in OnColumnFamilyDrop()
185 ColumnFamilyData** cfd) { in OnNonCfOperation() argument
190 assert(cfd != nullptr); in OnNonCfOperation()
191 *cfd = nullptr; in OnNonCfOperation()
210 *cfd = tmp_cfd; in OnNonCfOperation()
287 for (auto* cfd : *(version_set_->GetColumnFamilySet())) { in CheckIterationResult()
288 auto builder_iter = builders_.find(cfd->GetID()); in CheckIterationResult()
299 for (auto* cfd : *(version_set_->GetColumnFamilySet())) { in CheckIterationResult()
300 if (cfd->IsDropped()) { in CheckIterationResult()
304 cfd->table_cache()->SetTablesAreImmortal(); in CheckIterationResult()
306 *s = LoadTables(cfd, /*prefetch_index_and_filter_in_cache=*/false, in CheckIterationResult()
314 for (auto* cfd : *(version_set_->column_family_set_)) { in CheckIterationResult()
315 if (cfd->IsDropped()) { in CheckIterationResult()
318 assert(cfd->initialized()); in CheckIterationResult()
320 *s = MaybeCreateVersion(edit, cfd, /*force_create_version=*/true); in CheckIterationResult()
342 ColumnFamilyData* cfd = version_set_->CreateColumnFamily(cf_options, &edit); in CreateCfAndInit() local
343 assert(cfd != nullptr); in CreateCfAndInit()
344 cfd->set_initialized(); in CreateCfAndInit()
347 VersionBuilderUPtr(new BaseReferencedVersionBuilder(cfd))); in CreateCfAndInit()
352 return cfd; in CreateCfAndInit()
377 ColumnFamilyData* cfd, in MaybeCreateVersion() argument
379 assert(cfd->initialized()); in MaybeCreateVersion()
381 auto builder_iter = builders_.find(cfd->GetID()); in MaybeCreateVersion()
384 auto* v = new Version(cfd, version_set_, version_set_->file_options_, in MaybeCreateVersion()
385 *cfd->GetLatestMutableCFOptions(), in MaybeCreateVersion()
389 v->PrepareApply(*cfd->GetLatestMutableCFOptions(), in MaybeCreateVersion()
391 version_set_->AppendVersion(cfd, v); in MaybeCreateVersion()
396 Status VersionEditHandler::LoadTables(ColumnFamilyData* cfd, in LoadTables() argument
399 assert(cfd != nullptr); in LoadTables()
400 assert(!cfd->IsDropped()); in LoadTables()
402 auto builder_iter = builders_.find(cfd->GetID()); in LoadTables()
408 cfd->internal_stats(), in LoadTables()
411 cfd->GetLatestMutableCFOptions()->prefix_extractor.get()); in LoadTables()
421 Status VersionEditHandler::ExtractInfoFromVersionEdit(ColumnFamilyData* cfd, in ExtractInfoFromVersionEdit() argument
424 if (cfd != nullptr) { in ExtractInfoFromVersionEdit()
429 if (cfd->GetLogNumber() > edit.log_number_) { in ExtractInfoFromVersionEdit()
435 cfd->SetLogNumber(edit.log_number_); in ExtractInfoFromVersionEdit()
440 edit.comparator_ != cfd->user_comparator()->Name()) { in ExtractInfoFromVersionEdit()
442 cfd->user_comparator()->Name(), in ExtractInfoFromVersionEdit()
491 for (auto* cfd : *(version_set_->column_family_set_)) { in CheckIterationResult()
492 if (cfd->IsDropped()) { in CheckIterationResult()
495 assert(cfd->initialized()); in CheckIterationResult()
496 auto v_iter = versions_.find(cfd->GetID()); in CheckIterationResult()
500 version_set_->AppendVersion(cfd, v_iter->second); in CheckIterationResult()
509 ColumnFamilyData* cfd = VersionEditHandler::DestroyCfAndCleanup(edit); in DestroyCfAndCleanup() local
515 return cfd; in DestroyCfAndCleanup()
519 const VersionEdit& edit, ColumnFamilyData* cfd, bool force_create_version) { in MaybeCreateVersion() argument
520 assert(cfd != nullptr); in MaybeCreateVersion()
522 assert(edit.column_family_ == cfd->GetID()); in MaybeCreateVersion()
524 auto missing_files_iter = cf_to_missing_files_.find(cfd->GetID()); in MaybeCreateVersion()
541 MakeTableFileName(cfd->ioptions()->cf_paths[0].path, file_num); in MaybeCreateVersion()
555 auto builder_iter = builders_.find(cfd->GetID()); in MaybeCreateVersion()
558 auto* version = new Version(cfd, version_set_, version_set_->file_options_, in MaybeCreateVersion()
559 *cfd->GetLatestMutableCFOptions(), in MaybeCreateVersion()
563 *cfd->GetLatestMutableCFOptions(), in MaybeCreateVersion()
565 auto v_iter = versions_.find(cfd->GetID()); in MaybeCreateVersion()
570 versions_.emplace(cfd->GetID(), version); in MaybeCreateVersion()