Lines Matching refs:files
29 uint64_t TotalCompensatedFileSize(const std::vector<FileMetaData*>& files) { in TotalCompensatedFileSize() argument
31 for (size_t i = 0; i < files.size() && files[i]; i++) { in TotalCompensatedFileSize()
32 sum += files[i]->compensated_file_size; in TotalCompensatedFileSize()
89 comp_inputs->files.push_back(level_files[i]); in FindIntraL0Compaction()
267 vstorage->GetOverlappingInputs(level, &smallest, &largest, &inputs->files, in ExpandInputsToCleanCut()
278 if (AreFilesInCompaction(inputs->files)) { in ExpandInputsToCleanCut()
322 const std::vector<FileMetaData*>& files) { in AreFilesInCompaction() argument
323 for (size_t i = 0; i < files.size(); i++) { in AreFilesInCompaction()
324 if (files[i]->being_compacted) { in AreFilesInCompaction()
389 matched_input_files[level].files.push_back(file); in GetCompactionInputsFromFileNumbers()
469 &output_level_inputs->files, *parent_index, in SetupOtherInputs()
471 if (AreFilesInCompaction(output_level_inputs->files)) { in SetupOtherInputs()
488 TotalCompensatedFileSize(output_level_inputs->files); in SetupOtherInputs()
489 const uint64_t inputs_size = TotalCompensatedFileSize(inputs->files); in SetupOtherInputs()
499 &expanded_inputs.files, base_index, nullptr); in SetupOtherInputs()
501 TotalCompensatedFileSize(expanded_inputs.files); in SetupOtherInputs()
507 !AreFilesInCompaction(expanded_inputs.files)) { in SetupOtherInputs()
513 &expanded_output_level_inputs.files, in SetupOtherInputs()
516 if (!AreFilesInCompaction(expanded_output_level_inputs.files) && in SetupOtherInputs()
525 &all_limit, &expanded_inputs.files, in SetupOtherInputs()
527 expanded_inputs_size = TotalCompensatedFileSize(expanded_inputs.files); in SetupOtherInputs()
530 !AreFilesInCompaction(expanded_inputs.files)) { in SetupOtherInputs()
544 inputs->files = expanded_inputs.files; in SetupOtherInputs()
609 auto& files = inputs[level - start_level].files; in CompactRange() local
611 files.push_back(f); in CompactRange()
613 if (AreFilesInCompaction(files)) { in CompactRange()
655 vstorage->GetOverlappingInputs(input_level, begin, end, &inputs.files); in CompactRange()
679 inputs.files.resize(i + 1); in CompactRange()
711 inputs.files.swap(inputs_shrunk); in CompactRange()
763 if (AreFilesInCompaction(compaction_inputs[i].files)) { in CompactRange()
857 auto& current_files = levels[l].files; in SanitizeCompactionInputFilesForAllLevels()
946 for (auto& next_lv_file : levels[m].files) { in SanitizeCompactionInputFilesForAllLevels()
1008 for (const auto& file_meta : level_meta.files) { in SanitizeCompactionInputFiles()
1079 start_level_inputs->files = {level_file.second}; in PickFilesMarkedForCompaction()
1100 start_level_inputs->files.clear(); in PickFilesMarkedForCompaction()
1114 start_level_inputs->files.clear(); in GetOverlappingL0Files()
1116 &(start_level_inputs->files)); in GetOverlappingL0Files()
1126 assert(!start_level_inputs->files.empty()); in GetOverlappingL0Files()