Lines Matching refs:vstorage
102 const VersionStorageInfo* vstorage, in GetCompressionType() argument
114 level >= (vstorage->num_non_empty_levels() - 1)) { in GetCompressionType()
136 const VersionStorageInfo* vstorage, in GetCompressionOptions() argument
146 level >= (vstorage->num_non_empty_levels() - 1) && in GetCompressionOptions()
243 VersionStorageInfo* vstorage, in ExpandInputsToCleanCut() argument
267 vstorage->GetOverlappingInputs(level, &smallest, &largest, &inputs->files, in ExpandInputsToCleanCut()
334 VersionStorageInfo* vstorage, const MutableCFOptions& mutable_cf_options, in CompactFiles() argument
346 base_level = vstorage->base_level(); in CompactFiles()
351 GetCompressionType(ioptions_, vstorage, mutable_cf_options, in CompactFiles()
359 vstorage, ioptions_, mutable_cf_options, input_files, output_level, in CompactFiles()
362 GetCompressionOptions(ioptions_, vstorage, output_level), in CompactFiles()
371 std::unordered_set<uint64_t>* input_set, const VersionStorageInfo* vstorage, in GetCompactionInputsFromFileNumbers() argument
380 matched_input_files.resize(vstorage->num_levels()); in GetCompactionInputsFromFileNumbers()
385 for (int level = 0; level < vstorage->num_levels(); ++level) { in GetCompactionInputsFromFileNumbers()
386 for (auto file : vstorage->LevelFiles(level)) { in GetCompactionInputsFromFileNumbers()
419 bool CompactionPicker::IsRangeInCompaction(VersionStorageInfo* vstorage, in IsRangeInCompaction() argument
426 vstorage->GetOverlappingInputs(level, smallest, largest, &inputs, in IsRangeInCompaction()
443 VersionStorageInfo* vstorage, CompactionInputFiles* inputs, in SetupOtherInputs() argument
458 assert(vstorage->NumLevelFiles(l) == 0); in SetupOtherInputs()
468 vstorage->GetOverlappingInputs(output_level, &smallest, &largest, in SetupOtherInputs()
475 if (!ExpandInputsToCleanCut(cf_name, vstorage, output_level_inputs)) { in SetupOtherInputs()
498 vstorage->GetOverlappingInputs(input_level, &all_start, &all_limit, in SetupOtherInputs()
502 if (!ExpandInputsToCleanCut(cf_name, vstorage, &expanded_inputs)) { in SetupOtherInputs()
512 vstorage->GetOverlappingInputs(output_level, &new_start, &new_limit, in SetupOtherInputs()
517 ExpandInputsToCleanCut(cf_name, vstorage, in SetupOtherInputs()
524 vstorage->GetCleanInputsWithinInterval(input_level, &all_start, in SetupOtherInputs()
551 VersionStorageInfo* vstorage, const CompactionInputFiles& inputs, in GetGrandparents() argument
559 vstorage->GetOverlappingInputs(output_level_inputs.level + 1, &start, in GetGrandparents()
566 VersionStorageInfo* vstorage, int input_level, int output_level, in CompactRange() argument
578 assert(vstorage->num_levels() > 1); in CompactRange()
581 assert(output_level == vstorage->num_levels() - 2); in CompactRange()
583 assert(output_level == vstorage->num_levels() - 1); in CompactRange()
591 for (; start_level < vstorage->num_levels() && in CompactRange()
592 vstorage->NumLevelFiles(start_level) == 0; in CompactRange()
595 if (start_level == vstorage->num_levels()) { in CompactRange()
605 std::vector<CompactionInputFiles> inputs(vstorage->num_levels() - in CompactRange()
607 for (int level = start_level; level < vstorage->num_levels(); level++) { in CompactRange()
610 for (FileMetaData* f : vstorage->LevelFiles(level)) { in CompactRange()
629 vstorage, ioptions_, mutable_cf_options, std::move(inputs), in CompactRange()
635 GetCompressionType(ioptions_, vstorage, mutable_cf_options, in CompactRange()
637 GetCompressionOptions(ioptions_, vstorage, output_level), in CompactRange()
655 vstorage->GetOverlappingInputs(input_level, begin, end, &inputs.files); in CompactRange()
724 if (ExpandInputsToCleanCut(cf_name, vstorage, &inputs, &next_smallest) == in CompactRange()
742 output_level = vstorage->base_level(); in CompactRange()
748 if (!SetupOtherInputs(cf_name, mutable_cf_options, vstorage, &inputs, in CompactRange()
779 GetGrandparents(vstorage, inputs, output_level_inputs, &grandparents); in CompactRange()
781 vstorage, ioptions_, mutable_cf_options, std::move(compaction_inputs), in CompactRange()
784 ioptions_.compaction_style, vstorage->base_level(), in CompactRange()
788 GetCompressionType(ioptions_, vstorage, mutable_cf_options, output_level, in CompactRange()
789 vstorage->base_level()), in CompactRange()
790 GetCompressionOptions(ioptions_, vstorage, output_level), in CompactRange()
801 vstorage->ComputeCompactionScore(ioptions_, mutable_cf_options); in CompactRange()
1060 const std::string& cf_name, VersionStorageInfo* vstorage, int* start_level, in PickFilesMarkedForCompaction() argument
1062 if (vstorage->FilesMarkedForCompaction().empty()) { in PickFilesMarkedForCompaction()
1073 (*start_level == 0) ? vstorage->base_level() : *start_level + 1; in PickFilesMarkedForCompaction()
1081 return ExpandInputsToCleanCut(cf_name, vstorage, start_level_inputs); in PickFilesMarkedForCompaction()
1085 Random64 rnd(/* seed */ reinterpret_cast<uint64_t>(vstorage)); in PickFilesMarkedForCompaction()
1087 static_cast<uint64_t>(vstorage->FilesMarkedForCompaction().size()))); in PickFilesMarkedForCompaction()
1089 if (continuation(vstorage->FilesMarkedForCompaction()[random_file_index])) { in PickFilesMarkedForCompaction()
1094 for (auto& level_file : vstorage->FilesMarkedForCompaction()) { in PickFilesMarkedForCompaction()
1104 VersionStorageInfo* vstorage, CompactionInputFiles* start_level_inputs, in GetOverlappingL0Files() argument
1115 vstorage->GetOverlappingInputs(0, &smallest, &largest, in GetOverlappingL0Files()
1122 if (IsRangeInCompaction(vstorage, &smallest, &largest, output_level, in GetOverlappingL0Files()