Lines Matching refs:inputs

167 void CompactionPicker::GetRange(const CompactionInputFiles& inputs,  in GetRange()  argument
170 const int level = inputs.level; in GetRange()
171 assert(!inputs.empty()); in GetRange()
176 for (size_t i = 0; i < inputs.size(); i++) { in GetRange()
177 FileMetaData* f = inputs[i]; in GetRange()
191 *smallest = inputs[0]->smallest; in GetRange()
192 *largest = inputs[inputs.size() - 1]->largest; in GetRange()
215 void CompactionPicker::GetRange(const std::vector<CompactionInputFiles>& inputs, in GetRange() argument
221 for (const auto& in : inputs) { in GetRange()
244 CompactionInputFiles* inputs, in ExpandInputsToCleanCut() argument
247 assert(!inputs->empty()); in ExpandInputsToCleanCut()
249 const int level = inputs->level; in ExpandInputsToCleanCut()
264 old_size = inputs->size(); in ExpandInputsToCleanCut()
265 GetRange(*inputs, &smallest, &largest); in ExpandInputsToCleanCut()
266 inputs->clear(); in ExpandInputsToCleanCut()
267 vstorage->GetOverlappingInputs(level, &smallest, &largest, &inputs->files, in ExpandInputsToCleanCut()
270 } while (inputs->size() > old_size); in ExpandInputsToCleanCut()
274 assert(!inputs->empty()); in ExpandInputsToCleanCut()
278 if (AreFilesInCompaction(inputs->files)) { in ExpandInputsToCleanCut()
301 const std::vector<CompactionInputFiles>& inputs, int level) const { in FilesRangeOverlapWithCompaction() argument
303 for (auto& in : inputs) { in FilesRangeOverlapWithCompaction()
315 GetRange(inputs, &smallest, &largest); in FilesRangeOverlapWithCompaction()
423 std::vector<FileMetaData*> inputs; in IsRangeInCompaction() local
426 vstorage->GetOverlappingInputs(level, smallest, largest, &inputs, in IsRangeInCompaction()
428 return AreFilesInCompaction(inputs); in IsRangeInCompaction()
443 VersionStorageInfo* vstorage, CompactionInputFiles* inputs, in SetupOtherInputs() argument
446 assert(!inputs->empty()); in SetupOtherInputs()
448 const int input_level = inputs->level; in SetupOtherInputs()
464 GetRange(*inputs, &smallest, &largest); in SetupOtherInputs()
489 const uint64_t inputs_size = TotalCompensatedFileSize(inputs->files); in SetupOtherInputs()
496 GetRange(*inputs, *output_level_inputs, &all_start, &all_limit); in SetupOtherInputs()
505 if (try_overlapping_inputs && expanded_inputs.size() > inputs->size() && in SetupOtherInputs()
528 if (expanded_inputs.size() > inputs->size() && in SetupOtherInputs()
539 cf_name.c_str(), input_level, inputs->size(), in SetupOtherInputs()
544 inputs->files = expanded_inputs.files; in SetupOtherInputs()
551 VersionStorageInfo* vstorage, const CompactionInputFiles& inputs, in GetGrandparents() argument
555 GetRange(inputs, output_level_inputs, &start, &limit); in GetGrandparents()
605 std::vector<CompactionInputFiles> inputs(vstorage->num_levels() - in CompactRange() local
608 inputs[level - start_level].level = level; in CompactRange()
609 auto& files = inputs[level - start_level].files; in CompactRange()
621 if (FilesRangeOverlapWithCompaction(inputs, output_level)) { in CompactRange()
629 vstorage, ioptions_, mutable_cf_options, std::move(inputs), in CompactRange()
644 CompactionInputFiles inputs; in CompactRange() local
645 inputs.level = input_level; in CompactRange()
655 vstorage->GetOverlappingInputs(input_level, begin, end, &inputs.files); in CompactRange()
656 if (inputs.empty()) { in CompactRange()
674 for (size_t i = 0; i + 1 < inputs.size(); ++i) { in CompactRange()
675 uint64_t s = inputs[i]->compensated_file_size; in CompactRange()
679 inputs.files.resize(i + 1); in CompactRange()
696 size_t skip_input_index = inputs.size(); in CompactRange()
697 for (size_t i = 0; i < inputs.size(); ++i) { in CompactRange()
698 if (inputs[i]->fd.GetNumber() < max_file_num_to_ignore) { in CompactRange()
699 inputs_shrunk.push_back(inputs[i]); in CompactRange()
710 if (inputs.size() != inputs_shrunk.size()) { in CompactRange()
711 inputs.files.swap(inputs_shrunk); in CompactRange()
715 for (size_t i = skip_input_index + 1; i < inputs.size(); ++i) { in CompactRange()
716 if (inputs[i]->fd.GetNumber() < max_file_num_to_ignore) { in CompactRange()
724 if (ExpandInputsToCleanCut(cf_name, vstorage, &inputs, &next_smallest) == in CompactRange()
748 if (!SetupOtherInputs(cf_name, mutable_cf_options, vstorage, &inputs, in CompactRange()
758 std::vector<CompactionInputFiles> compaction_inputs({inputs}); in CompactRange()
779 GetGrandparents(vstorage, inputs, output_level_inputs, &grandparents); in CompactRange()
1040 !FilesRangeOverlapWithCompaction(*c->inputs(), c->output_level())); in RegisterCompaction()