Home
last modified time | relevance | path

Searched refs:inputs (Results 1 – 18 of 18) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc171 assert(!inputs.empty()); in GetRange()
192 *largest = inputs[inputs.size() - 1]->largest; in GetRange()
247 assert(!inputs->empty()); in ExpandInputsToCleanCut()
264 old_size = inputs->size(); in ExpandInputsToCleanCut()
266 inputs->clear(); in ExpandInputsToCleanCut()
274 assert(!inputs->empty()); in ExpandInputsToCleanCut()
303 for (auto& in : inputs) { in FilesRangeOverlapWithCompaction()
446 assert(!inputs->empty()); in SetupOtherInputs()
644 CompactionInputFiles inputs; in CompactRange() local
645 inputs.level = input_level; in CompactRange()
[all …]
Dcompaction.cc81 for (size_t i = 0; i < inputs.size(); ++i) { in GetBoundaryKeys()
82 if (inputs[i].files.empty()) { in GetBoundaryKeys()
85 if (inputs[i].level == 0) { in GetBoundaryKeys()
87 for (const auto* f : inputs[i].files) { in GetBoundaryKeys()
119 for (size_t i = 0; i < inputs.size(); i++) { in PopulateWithAtomicBoundaries()
120 if (inputs[i].level == 0 || inputs[i].files.empty()) { in PopulateWithAtomicBoundaries()
123 inputs[i].atomic_compaction_unit_boundaries.reserve(inputs[i].files.size()); in PopulateWithAtomicBoundaries()
134 const auto* f = inputs[i].files[j]; in PopulateWithAtomicBoundaries()
153 assert(inputs[i].files.size() == in PopulateWithAtomicBoundaries()
156 return inputs; in PopulateWithAtomicBoundaries()
[all …]
Dcompaction_picker_fifo.cc66 std::vector<CompactionInputFiles> inputs; in PickTTLCompaction() local
67 inputs.emplace_back(); in PickTTLCompaction()
68 inputs[0].level = 0; in PickTTLCompaction()
80 inputs[0].files.push_back(f); in PickTTLCompaction()
88 if (inputs[0].files.empty() || in PickTTLCompaction()
94 for (const auto& f : inputs[0].files) { in PickTTLCompaction()
103 vstorage, ioptions_, mutable_cf_options, std::move(inputs), 0, 0, 0, 0, in PickTTLCompaction()
171 std::vector<CompactionInputFiles> inputs; in PickSizeCompaction() local
172 inputs.emplace_back(); in PickSizeCompaction()
173 inputs[0].level = 0; in PickSizeCompaction()
[all …]
Dcompaction_picker_universal.cc483 for (auto f : *c->inputs(0)) { in PickCompaction()
515 c->inputs(0)->size()); in PickCompaction()
720 for (size_t i = 0; i < inputs.size(); ++i) { in PickCompactionToReduceSortedRuns()
727 inputs[0].files.push_back(picking_file); in PickCompactionToReduceSortedRuns()
855 std::vector<CompactionInputFiles> inputs; in PickDeleteTriggeredCompaction() local
879 inputs.push_back(start_level_inputs); in PickDeleteTriggeredCompaction()
935 inputs.push_back(start_level_inputs); in PickDeleteTriggeredCompaction()
937 inputs.push_back(output_level_inputs); in PickDeleteTriggeredCompaction()
943 inputs.push_back(start_level_inputs); in PickDeleteTriggeredCompaction()
982 for (size_t i = 0; i < inputs.size(); ++i) { in PickCompactionToOldest()
[all …]
Dcompaction.h74 std::vector<CompactionInputFiles> inputs, int output_level,
143 const std::vector<FileMetaData*>* inputs( in inputs() function
149 const std::vector<CompactionInputFiles>* inputs() { return &inputs_; } in inputs() function
268 const std::vector<CompactionInputFiles>& inputs);
302 const std::vector<CompactionInputFiles>& inputs,
310 VersionStorageInfo* vstorage, std::vector<CompactionInputFiles> inputs);
316 const std::vector<CompactionInputFiles>& inputs);
319 const std::vector<CompactionInputFiles>& inputs);
Dcompaction_picker.h140 void GetRange(const CompactionInputFiles& inputs, InternalKey* smallest,
153 void GetRange(const std::vector<CompactionInputFiles>& inputs,
170 CompactionInputFiles* inputs,
181 const std::vector<CompactionInputFiles>& inputs, int level) const;
186 CompactionInputFiles* inputs,
191 const CompactionInputFiles& inputs,
Dcompaction_picker_test.cc997 ASSERT_EQ(5U, compaction->inputs(1)->back()->fd.GetNumber()); in TEST_F()
Dcompaction_job.cc1709 for (auto f : *compaction->inputs(i)) { in LogCompaction()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc160 ColumnFamilyData* cfd, const std::vector<CompactionInputFiles>& inputs, in EnoughRoomForCompaction() argument
165 for (size_t i = 0; i < inputs.size(); i++) { in EnoughRoomForCompaction()
166 for (size_t j = 0; j < inputs[i].size(); j++) { in EnoughRoomForCompaction()
167 FileMetaData* filemeta = inputs[i][j]; in EnoughRoomForCompaction()
188 TableFileName(cfd->ioptions()->cf_paths, inputs[0][0]->fd.GetNumber(), in EnoughRoomForCompaction()
189 inputs[0][0]->fd.GetPathId()); in EnoughRoomForCompaction()
Dsst_file_manager_impl.h79 const std::vector<CompactionInputFiles>& inputs,
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc38 std::vector<FileMetaData*> inputs; in SuggestCompactRange() local
41 end == nullptr ? nullptr : &end_key, &inputs); in SuggestCompactRange()
42 for (auto f : inputs) { in SuggestCompactRange()
Ddb_impl_compaction_flush.cc28 ColumnFamilyData* cfd, const std::vector<CompactionInputFiles>& inputs, in EnoughRoomForCompaction() argument
40 sfm->EnoughRoomForCompaction(cfd, inputs, error_handler_.GetBGError()); in EnoughRoomForCompaction()
47 (void)inputs; in EnoughRoomForCompaction()
979 for (const auto& inputs : input_files) { in CompactFilesImpl() local
980 if (cfd->compaction_picker()->AreFilesInCompaction(inputs.files)) { in CompactFilesImpl()
1178 for (const auto fmd : *c->inputs(i)) { in NotifyOnCompactionBegin()
2557 m->cfd, *(c->inputs()), &sfm_reserved_compact_space, log_buffer); in BackgroundCompaction()
2625 cfd, *(c->inputs()), &sfm_reserved_compact_space, log_buffer); in BackgroundCompaction()
2645 c->inputs(0)->size()); in BackgroundCompaction()
2688 for (const auto& f : *c->inputs(0)) { in BackgroundCompaction()
[all …]
Ddb_impl.h1587 const std::vector<CompactionInputFiles>& inputs,
/rocksdb-6.9/db/
Dversion_set.h215 std::vector<FileMetaData*>* inputs,
226 std::vector<FileMetaData*>* inputs,
235 std::vector<FileMetaData*>* inputs,
253 bool HasOverlappingUserKey(const std::vector<FileMetaData*>* inputs,
Dversion_set_test.cc161 std::vector<FileMetaData*> inputs; in GetOverlappingFiles() local
162 vstorage_.GetOverlappingInputs(level, &begin, &end, &inputs); in GetOverlappingFiles()
165 for (size_t i = 0; i < inputs.size(); ++i) { in GetOverlappingFiles()
169 AppendNumberTo(&result, inputs[i]->fd.GetNumber()); in GetOverlappingFiles()
Dversion_set.cc2889 std::vector<FileMetaData*>* inputs, int hint_index, int* file_index, in GetOverlappingInputs() argument
2896 inputs->clear(); in GetOverlappingInputs()
2902 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, hint_index, in GetOverlappingInputs()
2944 inputs->emplace_back(files_[level][*iter]); in GetOverlappingInputs()
2979 std::vector<FileMetaData*>* inputs, int hint_index, int* file_index) const { in GetCleanInputsWithinInterval() argument
2980 inputs->clear(); in GetCleanInputsWithinInterval()
2991 GetOverlappingInputsRangeBinarySearch(level, begin, end, inputs, in GetCleanInputsWithinInterval()
3005 std::vector<FileMetaData*>* inputs, int hint_index, int* file_index, in GetOverlappingInputsRangeBinarySearch() argument
3090 inputs->push_back(files_[level][i]); in GetOverlappingInputsRangeBinarySearch()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc486 auto inputs = info.input_file_infos; in ProcessCompactionJobInfo() local
487 auto iit = inputs.begin(); in ProcessCompactionJobInfo()
488 const auto iit_end = inputs.end(); in ProcessCompactionJobInfo()
/rocksdb-6.9/
DHISTORY.md122 …r compaction output files is now set to the minimum of the creation times of all compaction inputs.