Lines Matching refs:edit
3494 Status AtomicGroupReadBuffer::AddEdit(VersionEdit* edit) { in AddEdit() argument
3495 assert(edit); in AddEdit()
3496 if (edit->is_in_atomic_group_) { in AddEdit()
3499 replay_buffer_.resize(edit->remaining_entries_ + 1); in AddEdit()
3501 "AtomicGroupReadBuffer::AddEdit:FirstInAtomicGroup", edit); in AddEdit()
3504 if (read_edits_in_atomic_group_ + edit->remaining_entries_ != in AddEdit()
3507 "AtomicGroupReadBuffer::AddEdit:IncorrectAtomicGroupSize", edit); in AddEdit()
3510 replay_buffer_[read_edits_in_atomic_group_ - 1] = *edit; in AddEdit()
3513 "AtomicGroupReadBuffer::AddEdit:LastInAtomicGroup", edit); in AddEdit()
3522 "AtomicGroupReadBuffer::AddEdit:AtomicGroupMixedWithNormalEdits", edit); in AddEdit()
4084 for (const auto& edit : edit_list) { in LogAndApply() local
4085 assert(!edit->IsColumnFamilyManipulation()); in LogAndApply()
4146 void VersionSet::LogAndApplyCFHelper(VersionEdit* edit) { in LogAndApplyCFHelper() argument
4147 assert(edit->IsColumnFamilyManipulation()); in LogAndApplyCFHelper()
4148 edit->SetNextFile(next_file_number_.load()); in LogAndApplyCFHelper()
4154 edit->SetLastSequence(db_options_->two_write_queues ? last_allocated_sequence_ in LogAndApplyCFHelper()
4156 if (edit->is_column_family_drop_) { in LogAndApplyCFHelper()
4159 edit->SetMaxColumnFamily(column_family_set_->GetMaxColumnFamily()); in LogAndApplyCFHelper()
4164 VersionBuilder* builder, VersionEdit* edit, in LogAndApplyHelper() argument
4170 assert(!edit->IsColumnFamilyManipulation()); in LogAndApplyHelper()
4172 if (edit->has_log_number_) { in LogAndApplyHelper()
4173 assert(edit->log_number_ >= cfd->GetLogNumber()); in LogAndApplyHelper()
4174 assert(edit->log_number_ < next_file_number_.load()); in LogAndApplyHelper()
4177 if (!edit->has_prev_log_number_) { in LogAndApplyHelper()
4178 edit->SetPrevLogNumber(prev_log_number_); in LogAndApplyHelper()
4180 edit->SetNextFile(next_file_number_.load()); in LogAndApplyHelper()
4186 edit->SetLastSequence(db_options_->two_write_queues ? last_allocated_sequence_ in LogAndApplyHelper()
4189 Status s = builder->Apply(edit); in LogAndApplyHelper()
4195 VersionEdit& edit, in ApplyOneVersionEditToBuilder() argument
4206 bool cf_in_not_found = (column_families_not_found.find(edit.column_family_) != in ApplyOneVersionEditToBuilder()
4210 bool cf_in_builders = builders.find(edit.column_family_) != builders.end(); in ApplyOneVersionEditToBuilder()
4217 if (edit.is_column_family_add_) { in ApplyOneVersionEditToBuilder()
4221 edit.column_family_name_); in ApplyOneVersionEditToBuilder()
4223 auto cf_options = name_to_options.find(edit.column_family_name_); in ApplyOneVersionEditToBuilder()
4227 edit.column_family_name_.compare(kPersistentStatsColumnFamilyName) == 0; in ApplyOneVersionEditToBuilder()
4231 {edit.column_family_, edit.column_family_name_}); in ApplyOneVersionEditToBuilder()
4237 cfd = CreateColumnFamily(cfo, &edit); in ApplyOneVersionEditToBuilder()
4239 cfd = CreateColumnFamily(cf_options->second, &edit); in ApplyOneVersionEditToBuilder()
4243 edit.column_family_, std::unique_ptr<BaseReferencedVersionBuilder>( in ApplyOneVersionEditToBuilder()
4246 } else if (edit.is_column_family_drop_) { in ApplyOneVersionEditToBuilder()
4248 auto builder = builders.find(edit.column_family_); in ApplyOneVersionEditToBuilder()
4251 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in ApplyOneVersionEditToBuilder()
4260 column_families_not_found.erase(edit.column_family_); in ApplyOneVersionEditToBuilder()
4271 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in ApplyOneVersionEditToBuilder()
4278 auto builder = builders.find(edit.column_family_); in ApplyOneVersionEditToBuilder()
4280 Status s = builder->second->version_builder()->Apply(&edit); in ApplyOneVersionEditToBuilder()
4285 return ExtractInfoFromVersionEdit(cfd, edit, version_edit_params); in ApplyOneVersionEditToBuilder()
4383 VersionEdit edit; in ReadAndRecover() local
4384 s = edit.DecodeFrom(record); in ReadAndRecover()
4388 if (edit.has_db_id_) { in ReadAndRecover()
4389 db_id_ = edit.GetDbId(); in ReadAndRecover()
4391 db_id->assign(edit.GetDbId()); in ReadAndRecover()
4394 s = read_buffer->AddEdit(&edit); in ReadAndRecover()
4398 if (edit.is_in_atomic_group_) { in ReadAndRecover()
4418 s = ApplyOneVersionEditToBuilder(edit, name_to_options, in ReadAndRecover()
4813 VersionEdit edit; in ListColumnFamilies() local
4814 s = edit.DecodeFrom(record); in ListColumnFamilies()
4818 if (edit.is_column_family_add_) { in ListColumnFamilies()
4819 if (column_family_names.find(edit.column_family_) != in ListColumnFamilies()
4825 {edit.column_family_, edit.column_family_name_}); in ListColumnFamilies()
4826 } else if (edit.is_column_family_drop_) { in ListColumnFamilies()
4827 if (column_family_names.find(edit.column_family_) == in ListColumnFamilies()
4833 column_family_names.erase(edit.column_family_); in ListColumnFamilies()
5009 VersionEdit edit; in DumpManifest() local
5010 s = edit.DecodeFrom(record); in DumpManifest()
5017 printf("%s\n", edit.DebugString(hex).c_str()); in DumpManifest()
5019 printf("%s\n", edit.DebugJSON(count, hex).c_str()); in DumpManifest()
5024 builders.find(edit.column_family_) != builders.end(); in DumpManifest()
5026 if (edit.has_comparator_) { in DumpManifest()
5027 comparators.insert({edit.column_family_, edit.comparator_}); in DumpManifest()
5032 if (edit.is_column_family_add_) { in DumpManifest()
5038 cfd = CreateColumnFamily(ColumnFamilyOptions(options), &edit); in DumpManifest()
5041 edit.column_family_, std::unique_ptr<BaseReferencedVersionBuilder>( in DumpManifest()
5043 } else if (edit.is_column_family_drop_) { in DumpManifest()
5049 auto builder_iter = builders.find(edit.column_family_); in DumpManifest()
5051 comparators.erase(edit.column_family_); in DumpManifest()
5052 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in DumpManifest()
5063 cfd = column_family_set_->GetColumnFamily(edit.column_family_); in DumpManifest()
5070 auto builder = builders.find(edit.column_family_); in DumpManifest()
5072 s = builder->second->version_builder()->Apply(&edit); in DumpManifest()
5078 if (cfd != nullptr && edit.has_log_number_) { in DumpManifest()
5079 cfd->SetLogNumber(edit.log_number_); in DumpManifest()
5083 if (edit.has_prev_log_number_) { in DumpManifest()
5084 previous_log_number = edit.prev_log_number_; in DumpManifest()
5088 if (edit.has_next_file_number_) { in DumpManifest()
5089 next_file = edit.next_file_number_; in DumpManifest()
5093 if (edit.has_last_sequence_) { in DumpManifest()
5094 last_sequence = edit.last_sequence_; in DumpManifest()
5098 if (edit.has_max_column_family_) { in DumpManifest()
5099 column_family_set_->UpdateMaxColumnFamily(edit.max_column_family_); in DumpManifest()
5102 if (edit.has_min_log_number_to_keep_) { in DumpManifest()
5103 MarkMinLogNumberToKeep2PC(edit.min_log_number_to_keep_); in DumpManifest()
5220 VersionEdit edit; in WriteCurrentStateToManifest() local
5224 edit.AddColumnFamily(cfd->GetName()); in WriteCurrentStateToManifest()
5225 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5227 edit.SetComparatorName( in WriteCurrentStateToManifest()
5230 if (!edit.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5232 "Unable to Encode VersionEdit:" + edit.DebugString(true)); in WriteCurrentStateToManifest()
5243 VersionEdit edit; in WriteCurrentStateToManifest() local
5244 edit.SetColumnFamily(cfd->GetID()); in WriteCurrentStateToManifest()
5249 edit.AddFile(level, f->fd.GetNumber(), f->fd.GetPathId(), in WriteCurrentStateToManifest()
5260 edit.SetLogNumber(log_number); in WriteCurrentStateToManifest()
5262 if (!edit.EncodeTo(&record)) { in WriteCurrentStateToManifest()
5264 "Unable to Encode VersionEdit:" + edit.DebugString(true)); in WriteCurrentStateToManifest()
5707 const ColumnFamilyOptions& cf_options, const VersionEdit* edit) { in CreateColumnFamily() argument
5708 assert(edit->is_column_family_add_); in CreateColumnFamily()
5717 edit->column_family_name_, edit->column_family_, dummy_versions, in CreateColumnFamily()
5732 new_cfd->SetLogNumber(edit->log_number_); in CreateColumnFamily()
5954 VersionEdit edit; in ReadAndApply() local
5955 s = edit.DecodeFrom(record); in ReadAndApply()
5964 column_family_set_->GetColumnFamily(edit.column_family_); in ReadAndApply()
5971 s = read_buffer_.AddEdit(&edit); in ReadAndApply()
5976 if (edit.is_in_atomic_group_) { in ReadAndApply()
5994 s = ApplyOneVersionEditToBuilder(edit, cfds_changed, &temp_edit); in ReadAndApply()
6066 VersionEdit& edit, std::unordered_set<ColumnFamilyData*>* cfds_changed, in ApplyOneVersionEditToBuilder() argument
6069 column_family_set_->GetColumnFamily(edit.column_family_); in ApplyOneVersionEditToBuilder()
6078 if (active_version_builders_.find(edit.column_family_) == in ApplyOneVersionEditToBuilder()
6084 std::make_pair(edit.column_family_, std::move(builder_guard))); in ApplyOneVersionEditToBuilder()
6087 auto builder_iter = active_version_builders_.find(edit.column_family_); in ApplyOneVersionEditToBuilder()
6092 if (edit.is_column_family_add_) { in ApplyOneVersionEditToBuilder()
6097 } else if (edit.is_column_family_drop_) { in ApplyOneVersionEditToBuilder()
6109 Status s = builder->Apply(&edit); in ApplyOneVersionEditToBuilder()
6114 Status s = ExtractInfoFromVersionEdit(cfd, edit, version_edit); in ApplyOneVersionEditToBuilder()