Lines Matching refs:version_set_
23 version_set_(version_set), in VersionEditHandler()
27 assert(version_set_ != nullptr); in VersionEditHandler()
42 version_set_->db_id_ = edit.GetDbId(); in Iterate()
44 *db_id = version_set_->db_id_; in Iterate()
202 tmp_cfd = version_set_->GetColumnFamilySet()->GetColumnFamily( in OnNonCfOperation()
281 version_set_->GetColumnFamilySet()->UpdateMaxColumnFamily( in CheckIterationResult()
283 version_set_->MarkMinLogNumberToKeep2PC( in CheckIterationResult()
285 version_set_->MarkFileNumberUsed(version_edit_params_.prev_log_number_); in CheckIterationResult()
286 version_set_->MarkFileNumberUsed(version_edit_params_.log_number_); in CheckIterationResult()
287 for (auto* cfd : *(version_set_->GetColumnFamilySet())) { in CheckIterationResult()
299 for (auto* cfd : *(version_set_->GetColumnFamilySet())) { in CheckIterationResult()
314 for (auto* cfd : *(version_set_->column_family_set_)) { in CheckIterationResult()
327 version_set_->manifest_file_size_ = reader.GetReadOffset(); in CheckIterationResult()
328 assert(version_set_->manifest_file_size_ > 0); in CheckIterationResult()
329 version_set_->next_file_number_.store( in CheckIterationResult()
331 version_set_->last_allocated_sequence_ = in CheckIterationResult()
333 version_set_->last_published_sequence_ = in CheckIterationResult()
335 version_set_->last_sequence_ = version_edit_params_.last_sequence_; in CheckIterationResult()
336 version_set_->prev_log_number_ = version_edit_params_.prev_log_number_; in CheckIterationResult()
342 ColumnFamilyData* cfd = version_set_->CreateColumnFamily(cf_options, &edit); in CreateCfAndInit()
366 version_set_->GetColumnFamilySet()->GetColumnFamily(edit.column_family_); in DestroyCfAndCleanup()
384 auto* v = new Version(cfd, version_set_, version_set_->file_options_, in MaybeCreateVersion()
386 version_set_->current_version_number_++); in MaybeCreateVersion()
390 !(version_set_->db_options_->skip_stats_update_on_db_open)); in MaybeCreateVersion()
391 version_set_->AppendVersion(cfd, v); in MaybeCreateVersion()
409 version_set_->db_options_->max_file_opening_threads, in LoadTables()
415 if (!s.ok() && !version_set_->db_options_->paranoid_checks) { in LoadTables()
431 version_set_->db_options()->info_log, in ExtractInfoFromVersionEdit()
491 for (auto* cfd : *(version_set_->column_family_set_)) { in CheckIterationResult()
500 version_set_->AppendVersion(cfd, v_iter->second); in CheckIterationResult()
542 s = version_set_->VerifyFileMetadata(fpath, meta); in MaybeCreateVersion()
558 auto* version = new Version(cfd, version_set_, version_set_->file_options_, in MaybeCreateVersion()
560 version_set_->current_version_number_++); in MaybeCreateVersion()
564 !version_set_->db_options_->skip_stats_update_on_db_open); in MaybeCreateVersion()