Home
last modified time | relevance | path

Searched refs:input_files (Results 1 – 13 of 13) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker.cc336 assert(input_files.size()); in CompactFiles()
340 assert(!FilesRangeOverlapWithCompaction(input_files, output_level)); in CompactFiles()
359 vstorage, ioptions_, mutable_cf_options, input_files, output_level, in CompactFiles()
370 std::vector<CompactionInputFiles>* input_files, in GetCompactionInputsFromFileNumbers() argument
377 assert(input_files); in GetCompactionInputsFromFileNumbers()
412 input_files->emplace_back(std::move(matched_input_files[level])); in GetCompactionInputsFromFileNumbers()
834 std::unordered_set<uint64_t>* input_files, in SanitizeCompactionInputFilesForAllLevels() argument
865 input_files->end()) { in SanitizeCompactionInputFilesForAllLevels()
969 std::unordered_set<uint64_t>* input_files, in SanitizeCompactionInputFiles() argument
991 if (input_files->size() == 0) { in SanitizeCompactionInputFiles()
[all …]
Dcompaction_picker.h93 Status SanitizeCompactionInputFiles(std::unordered_set<uint64_t>* input_files,
113 const std::vector<CompactionInputFiles>& input_files,
121 std::vector<CompactionInputFiles>* input_files,
224 std::unordered_set<uint64_t>* input_files,
Dcompaction_job_test.cc297 const std::vector<std::vector<FileMetaData*>>& input_files, in RunCompaction() argument
307 for (size_t level = 0; level < input_files.size(); level++) {
308 auto level_files = input_files[level];
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h48 assert(ci.input_files.size() + ci.output_files.size() > 0U); in OnCompactionCompleted()
49 for (const auto& file_path : ci.input_files) { in OnCompactionCompleted()
Ddb_stress_test_base.cc1409 std::vector<std::string> input_files; in TestCompactFiles() local
1410 input_files.push_back(files[random_file_index].name); in TestCompactFiles()
1413 input_files.push_back(files[random_file_index - 1].name); in TestCompactFiles()
1417 input_files.push_back(files[random_file_index + 1].name); in TestCompactFiles()
1423 input_files, static_cast<int>(output_level)); in TestCompactFiles()
/rocksdb-6.9/docs/_posts/
D2018-08-01-rocksdb-tuning-advisor.markdown42 …c=advisor/rules.ini --rocksdb_options=test/input_files/OPTIONS-000005 --log_files_path_prefix=test…
/rocksdb-6.9/tools/advisor/
DREADME.md44 …c=advisor/rules.ini --rocksdb_options=test/input_files/OPTIONS-000005 --log_files_path_prefix=test…
/rocksdb-6.9/db/
Dlistener_test.cc99 ASSERT_GT(ci.input_files.size(), 0U); in OnCompactionCompleted()
100 ASSERT_EQ(ci.input_files.size(), ci.input_file_infos.size()); in OnCompactionCompleted()
105 TableFileNameToNumber(ci.input_files[i])); in OnCompactionCompleted()
138 for (auto fl : {ci.input_files, ci.output_files}) { in OnCompactionCompleted()
Ddb_test.cc5781 std::vector<std::string> input_files; in TEST_F() local
5782 input_files.push_back(cf_meta_data.levels[0].files[0].name); in TEST_F()
5795 db_->DefaultColumnFamily(), input_files, 0); in TEST_F()
Ddb_test2.cc1339 compacting_files_cnt_ += ci.input_files.size(); in OnCompactionBegin()
1346 compacted_files_cnt_ += ci.input_files.size(); in OnCompactionCompleted()
/rocksdb-6.9/java/rocksjni/
Dcompaction_job_info.cc120 env, &compact_job_info->input_files); in Java_org_rocksdb_CompactionJobInfo_inputFiles()
/rocksdb-6.9/include/rocksdb/
Dlistener.h235 std::vector<std::string> input_files; member
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc972 std::vector<CompactionInputFiles> input_files; in CompactFilesImpl() local
974 &input_files, &input_set, version->storage_info(), compact_options); in CompactFilesImpl()
979 for (const auto& inputs : input_files) { in CompactFilesImpl()
989 cfd, input_files, &sfm_reserved_compact_space, log_buffer); in CompactFilesImpl()
1003 compact_options, input_files, output_level, version->storage_info(), in CompactFilesImpl()
1183 info.input_files.push_back(fn); in NotifyOnCompactionBegin()
3062 compaction_job_info->input_files.push_back(fn); in BuildCompactionJobInfo()