Lines Matching refs:vstorage_
54 vstorage_(vstorage), in LevelCompactionBuilder()
101 VersionStorageInfo* vstorage_; member in ROCKSDB_NAMESPACE::__anon867945220111::LevelCompactionBuilder
128 if (vstorage_->ExpiredTtlFiles().empty()) { in PickExpiredTtlFiles()
139 (start_level_ == 0) ? vstorage_->base_level() : start_level_ + 1; in PickExpiredTtlFiles()
141 if ((start_level_ == vstorage_->num_non_empty_levels() - 1) || in PickExpiredTtlFiles()
149 return compaction_picker_->ExpandInputsToCleanCut(cf_name_, vstorage_, in PickExpiredTtlFiles()
153 for (auto& level_file : vstorage_->ExpiredTtlFiles()) { in PickExpiredTtlFiles()
164 if (vstorage_->FilesMarkedForPeriodicCompaction().empty()) { in PickFilesMarkedForPeriodicCompaction()
182 return compaction_picker_->ExpandInputsToCleanCut(cf_name_, vstorage_, in PickFilesMarkedForPeriodicCompaction()
186 for (auto& level_file : vstorage_->FilesMarkedForPeriodicCompaction()) { in PickFilesMarkedForPeriodicCompaction()
200 start_level_score_ = vstorage_->CompactionScore(i); in SetupInitialFiles()
201 start_level_ = vstorage_->CompactionScoreLevel(i); in SetupInitialFiles()
202 assert(i == 0 || start_level_score_ <= vstorage_->CompactionScore(i - 1)); in SetupInitialFiles()
204 if (skipped_l0_to_base && start_level_ == vstorage_->base_level()) { in SetupInitialFiles()
211 (start_level_ == 0) ? vstorage_->base_level() : start_level_ + 1; in SetupInitialFiles()
250 cf_name_, vstorage_, &start_level_, &output_level_, in SetupInitialFiles()
262 for (i = 0; i < vstorage_->BottommostFilesMarkedForCompaction().size(); in SetupInitialFiles()
264 auto& level_and_file = vstorage_->BottommostFilesMarkedForCompaction()[i]; in SetupInitialFiles()
269 if (compaction_picker_->ExpandInputsToCleanCut(cf_name_, vstorage_, in SetupInitialFiles()
274 if (i == vstorage_->BottommostFilesMarkedForCompaction().size()) { in SetupInitialFiles()
305 vstorage_, &start_level_inputs_, output_level_, &parent_index_); in SetupOtherL0FilesIfNeeded()
317 cf_name_, mutable_cf_options_, vstorage_, &start_level_inputs_, in SetupOtherInputsIfNeeded()
339 compaction_picker_->GetGrandparents(vstorage_, start_level_inputs_, in SetupOtherInputsIfNeeded()
378 vstorage_, ioptions_, mutable_cf_options_, std::move(compaction_inputs_), in GetCompaction()
381 ioptions_.compaction_style, vstorage_->base_level(), in GetCompaction()
385 GetCompressionType(ioptions_, vstorage_, mutable_cf_options_, in GetCompaction()
386 output_level_, vstorage_->base_level()), in GetCompaction()
387 GetCompressionOptions(ioptions_, vstorage_, output_level_), in GetCompaction()
399 vstorage_->ComputeCompactionScore(ioptions_, mutable_cf_options_); in GetCompaction()
475 vstorage_->FilesByCompactionPri(start_level_); in PickFileToCompact()
477 vstorage_->LevelFiles(start_level_); in PickFileToCompact()
480 for (cmp_idx = vstorage_->NextCompactionIndex(start_level_); in PickFileToCompact()
493 if (!compaction_picker_->ExpandInputsToCleanCut(cf_name_, vstorage_, in PickFileToCompact()
513 vstorage_->GetOverlappingInputs(output_level_, &smallest, &largest, in PickFileToCompact()
516 !compaction_picker_->ExpandInputsToCleanCut(cf_name_, vstorage_, in PickFileToCompact()
526 vstorage_->SetNextCompactionIndex(start_level_, cmp_idx); in PickFileToCompact()
534 vstorage_->LevelFiles(0 /* level */); in PickIntraL0Compaction()