Lines Matching refs:edit
36 VersionEdit edit; in Iterate() local
37 s = edit.DecodeFrom(record); in Iterate()
41 if (edit.has_db_id_) { in Iterate()
42 version_set_->db_id_ = edit.GetDbId(); in Iterate()
47 s = read_buffer_.AddEdit(&edit); in Iterate()
52 if (edit.is_in_atomic_group_) { in Iterate()
67 s = ApplyVersionEdit(edit, &cfd); in Iterate()
108 Status VersionEditHandler::ApplyVersionEdit(VersionEdit& edit, in ApplyVersionEdit() argument
111 if (edit.is_column_family_add_) { in ApplyVersionEdit()
112 s = OnColumnFamilyAdd(edit, cfd); in ApplyVersionEdit()
113 } else if (edit.is_column_family_drop_) { in ApplyVersionEdit()
114 s = OnColumnFamilyDrop(edit, cfd); in ApplyVersionEdit()
116 s = OnNonCfOperation(edit, cfd); in ApplyVersionEdit()
120 s = ExtractInfoFromVersionEdit(*cfd, edit); in ApplyVersionEdit()
125 Status VersionEditHandler::OnColumnFamilyAdd(VersionEdit& edit, in OnColumnFamilyAdd() argument
129 CheckColumnFamilyId(edit, &cf_in_not_found, &cf_in_builders); in OnColumnFamilyAdd()
136 edit.column_family_name_); in OnColumnFamilyAdd()
139 auto cf_options = name_to_options_.find(edit.column_family_name_); in OnColumnFamilyAdd()
144 edit.column_family_name_.compare(kPersistentStatsColumnFamilyName) == 0; in OnColumnFamilyAdd()
147 column_families_not_found_.emplace(edit.column_family_, in OnColumnFamilyAdd()
148 edit.column_family_name_); in OnColumnFamilyAdd()
153 tmp_cfd = CreateCfAndInit(cfo, edit); in OnColumnFamilyAdd()
155 tmp_cfd = CreateCfAndInit(cf_options->second, edit); in OnColumnFamilyAdd()
163 Status VersionEditHandler::OnColumnFamilyDrop(VersionEdit& edit, in OnColumnFamilyDrop() argument
167 CheckColumnFamilyId(edit, &cf_in_not_found, &cf_in_builders); in OnColumnFamilyDrop()
174 tmp_cfd = DestroyCfAndCleanup(edit); in OnColumnFamilyDrop()
176 column_families_not_found_.erase(edit.column_family_); in OnColumnFamilyDrop()
184 Status VersionEditHandler::OnNonCfOperation(VersionEdit& edit, in OnNonCfOperation() argument
188 CheckColumnFamilyId(edit, &cf_in_not_found, &cf_in_builders); in OnNonCfOperation()
200 auto builder_iter = builders_.find(edit.column_family_); in OnNonCfOperation()
203 edit.column_family_); in OnNonCfOperation()
205 s = MaybeCreateVersion(edit, tmp_cfd, /*force_create_version=*/false); in OnNonCfOperation()
207 s = builder_iter->second->version_builder()->Apply(&edit); in OnNonCfOperation()
228 void VersionEditHandler::CheckColumnFamilyId(const VersionEdit& edit, in CheckColumnFamilyId() argument
238 bool in_not_found = column_families_not_found_.find(edit.column_family_) != in CheckColumnFamilyId()
242 bool in_builders = builders_.find(edit.column_family_) != builders_.end(); in CheckColumnFamilyId()
319 VersionEdit edit; in CheckIterationResult() local
320 *s = MaybeCreateVersion(edit, cfd, /*force_create_version=*/true); in CheckIterationResult()
341 const ColumnFamilyOptions& cf_options, const VersionEdit& edit) { in CreateCfAndInit() argument
342 ColumnFamilyData* cfd = version_set_->CreateColumnFamily(cf_options, &edit); in CreateCfAndInit()
345 assert(builders_.find(edit.column_family_) == builders_.end()); in CreateCfAndInit()
346 builders_.emplace(edit.column_family_, in CreateCfAndInit()
349 cf_to_missing_files_.emplace(edit.column_family_, in CreateCfAndInit()
356 const VersionEdit& edit) { in DestroyCfAndCleanup() argument
357 auto builder_iter = builders_.find(edit.column_family_); in DestroyCfAndCleanup()
361 auto missing_files_iter = cf_to_missing_files_.find(edit.column_family_); in DestroyCfAndCleanup()
366 version_set_->GetColumnFamilySet()->GetColumnFamily(edit.column_family_); in DestroyCfAndCleanup()
422 const VersionEdit& edit) { in ExtractInfoFromVersionEdit() argument
425 if (edit.has_db_id_) { in ExtractInfoFromVersionEdit()
426 version_edit_params_.SetDBId(edit.db_id_); in ExtractInfoFromVersionEdit()
428 if (edit.has_log_number_) { in ExtractInfoFromVersionEdit()
429 if (cfd->GetLogNumber() > edit.log_number_) { in ExtractInfoFromVersionEdit()
435 cfd->SetLogNumber(edit.log_number_); in ExtractInfoFromVersionEdit()
436 version_edit_params_.SetLogNumber(edit.log_number_); in ExtractInfoFromVersionEdit()
439 if (edit.has_comparator_ && in ExtractInfoFromVersionEdit()
440 edit.comparator_ != cfd->user_comparator()->Name()) { in ExtractInfoFromVersionEdit()
443 "does not match existing comparator " + edit.comparator_); in ExtractInfoFromVersionEdit()
448 if (edit.has_prev_log_number_) { in ExtractInfoFromVersionEdit()
449 version_edit_params_.SetPrevLogNumber(edit.prev_log_number_); in ExtractInfoFromVersionEdit()
451 if (edit.has_next_file_number_) { in ExtractInfoFromVersionEdit()
452 version_edit_params_.SetNextFile(edit.next_file_number_); in ExtractInfoFromVersionEdit()
454 if (edit.has_max_column_family_) { in ExtractInfoFromVersionEdit()
455 version_edit_params_.SetMaxColumnFamily(edit.max_column_family_); in ExtractInfoFromVersionEdit()
457 if (edit.has_min_log_number_to_keep_) { in ExtractInfoFromVersionEdit()
460 edit.min_log_number_to_keep_); in ExtractInfoFromVersionEdit()
462 if (edit.has_last_sequence_) { in ExtractInfoFromVersionEdit()
463 version_edit_params_.SetLastSequence(edit.last_sequence_); in ExtractInfoFromVersionEdit()
508 const VersionEdit& edit) { in DestroyCfAndCleanup() argument
509 ColumnFamilyData* cfd = VersionEditHandler::DestroyCfAndCleanup(edit); in DestroyCfAndCleanup()
510 auto v_iter = versions_.find(edit.column_family_); in DestroyCfAndCleanup()
519 const VersionEdit& edit, ColumnFamilyData* cfd, bool force_create_version) { in MaybeCreateVersion() argument
522 assert(edit.column_family_ == cfd->GetID()); in MaybeCreateVersion()
528 for (const auto& file : edit.GetDeletedFiles()) { in MaybeCreateVersion()
536 for (const auto& elem : edit.GetNewFiles()) { in MaybeCreateVersion()