Home
last modified time | relevance | path

Searched refs:num_files (Results 1 – 22 of 22) sorted by relevance

/rocksdb-6.9/file/
Ddelete_scheduler_test.cc136 int num_files = 100; // 100 files in TEST_F() local
152 for (int i = 0; i < num_files; i++) { in TEST_F()
158 for (int i = 0; i < num_files; i++) { in TEST_F()
174 ASSERT_EQ(penalties.size(), num_files); in TEST_F()
175 for (int i = 0; i < num_files; i++) { in TEST_F()
182 ASSERT_EQ(num_files, dir_synced); in TEST_F()
269 int range_start = idx * num_files; in TEST_F()
566 int num_files = 10; // 10 files in TEST_F() local
583 for (int i = 0; i < num_files; i++) { in TEST_F()
636 int num_files = 100; // 100 files in TEST_F() local
[all …]
/rocksdb-6.9/db/
Ddb_table_properties_test.cc53 std::size_t* num_files = nullptr);
95 std::size_t* num_files) { in TestGetPropertiesOfTablesInRange() argument
129 if (num_files) { in TestGetPropertiesOfTablesInRange()
130 *num_files = vmd.size(); in TestGetPropertiesOfTablesInRange()
178 &num_properties, &num_files); in TEST_F()
179 ASSERT_EQ(num_properties, num_files); in TEST_F()
185 &num_properties, &num_files); in TEST_F()
186 ASSERT_GT(num_files, 0); in TEST_F()
193 &num_properties, &num_files); in TEST_F()
194 ASSERT_GT(num_files, 0); in TEST_F()
[all …]
Dcompacted_db_impl.cc28 size_t right = files_.num_files - 1; in FindFile()
111 if (l0.num_files > 1) { in Init()
114 if (l0.num_files == 1) { in Init()
123 if (vstorage->LevelFilesBrief(i).num_files > 0) { in Init()
129 if (vstorage->LevelFilesBrief(level).num_files > 0) { in Init()
Dversion_set.cc279 if (curr_file_level_->num_files == 0) { in PrepareNextLevel()
540 : curr_file_level_->num_files; in GetNextFile()
627 curr_file_level_->num_files) { in PrepareNextLevel()
775 file_level->num_files = num; in DoGenerateLevelFilesBrief()
844 if (index >= file_level.num_files) { in SomeFileOverlapsRange()
876 file_index_(flevel_->num_files), in LevelIterator()
991 file_index_ < flevel_->num_files) { in CheckMayBeOutOfLowerBound()
3011 const int num_files = static_cast<int>(level_files_brief_[level].num_files); in GetOverlappingInputsRangeBinarySearch() local
3016 int end_index = num_files; in GetOverlappingInputsRangeBinarySearch()
5320 if (files_brief.num_files == 0) { in ApproximateSize()
[all …]
Dimport_column_family_job.cc37 auto num_files = files_to_import_.size(); in Prepare() local
38 if (num_files == 0) { in Prepare()
40 } else if (num_files > 1) { in Prepare()
52 for (size_t i = 0; i < num_files; i++) { in Prepare()
Dexternal_sst_file_ingestion_job.cc54 auto num_files = files_to_ingest_.size(); in Prepare() local
55 if (num_files == 0) { in Prepare()
57 } else if (num_files > 1) { in Prepare()
60 for (size_t i = 0; i < num_files; i++) { in Prepare()
71 for (size_t i = 0; i < num_files - 1; i++) { in Prepare()
Dexternal_sst_file_test.cc989 int num_files = 10; in TEST_F() local
994 for (int i = 0; i < num_files; i++) { in TEST_F()
1021 for (int i = 0; i < num_files; ++i) { in TEST_F()
1029 fprintf(stderr, "Wrote %d files (%d keys)\n", num_files, in TEST_F()
1030 num_files * keys_per_file); in TEST_F()
1065 for (int i = 0; i < num_files; ++i) { in TEST_F()
1072 ASSERT_EQ(files_added.load(), num_files); in TEST_F()
1073 fprintf(stderr, "Loaded %d files (%d keys)\n", num_files, in TEST_F()
1074 num_files * keys_per_file); in TEST_F()
1077 for (int k = 0; k < num_files * keys_per_file; k += 100) { in TEST_F()
[all …]
Dversion_edit.h239 size_t num_files; member
242 num_files = 0; in LevelFilesBrief()
Ddb_io_failure_test.cc32 const size_t num_files = CountFiles(); in TEST_F() local
57 ASSERT_LT(CountFiles(), num_files + 3); in TEST_F()
Dversion_set_test.cc62 ASSERT_EQ(0u, file_level_.num_files); in TEST_F()
69 ASSERT_EQ(1u, file_level_.num_files); in TEST_F()
79 ASSERT_EQ(4u, file_level_.num_files); in TEST_F()
429 file_level_.num_files = 0; in LevelFileInit()
448 size_t num = file_level_.num_files; in Add()
454 file_level_.num_files++; in Add()
Ddb_sst_test.cc102 int const num_files = GetSstFileCount(dbname_); in TEST_F() local
103 ASSERT_GT(num_files, 0); in TEST_F()
126 ASSERT_EQ(num_files, GetSstFileCount(dbname_)); in TEST_F()
Dinternal_stats.cc87 int num_files, int being_compacted, in PrepareLevelStats() argument
95 (*level_stats)[LevelStatType::NUM_FILES] = num_files; in PrepareLevelStats()
172 int num_files, int being_compacted, double total_file_size, in PrintLevelStats() argument
176 PrepareLevelStats(&level_stats, num_files, being_compacted, total_file_size, in PrintLevelStats()
Ddb_test_util.cc1015 size_t num_files = 0; in TotalLiveFiles() local
1017 num_files += level.files.size(); in TotalLiveFiles()
1019 return num_files; in TotalLiveFiles()
Ddb_compaction_test.cc2655 const size_t num_files = CountLiveFiles(); in TEST_F() local
2660 ASSERT_EQ(CountLiveFiles(), num_files); in TEST_F()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc481 size_t num_files = 0; in ExportFilesInMetaData() local
496 ++num_files; in ExportFilesInMetaData()
500 if (num_files == 1 && s.IsNotSupported()) { in ExportFilesInMetaData()
515 num_files); in ExportFilesInMetaData()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc452 size_t num_files = flevel->num_files; in GenSubcompactionBoundaries() local
454 if (num_files == 0) { in GenSubcompactionBoundaries()
461 for (size_t i = 0; i < num_files; i++) { in GenSubcompactionBoundaries()
469 bounds.emplace_back(flevel->files[num_files - 1].largest_key); in GenSubcompactionBoundaries()
475 for (size_t i = 1; i < num_files; i++) { in GenSubcompactionBoundaries()
1634 void CompactionJob::UpdateCompactionInputStatsHelper(int* num_files, in UpdateCompactionInputStatsHelper() argument
1639 *num_files += static_cast<int>(num_input_files); in UpdateCompactionInputStatsHelper()
Dcompaction_picker_universal.cc442 unsigned int num_files = in PickCompaction() local
445 if ((c = PickCompactionToReduceSortedRuns(UINT_MAX, num_files)) != in PickCompaction()
449 cf_name_.c_str(), num_files); in PickCompaction()
Dcompaction_job.h141 int* num_files, uint64_t* bytes_read, int input_level);
/rocksdb-6.9/tools/
Dldb_cmd.cc2051 int num_files = 0; in DoCommand() local
2062 num_files = atoi(property.c_str()); in DoCommand()
2065 if (i == 0 && num_files != 1) { in DoCommand()
2069 ToString(num_files) + ", not 1.\n"); in DoCommand()
2073 if (i > 0 && num_files != 0) { in DoCommand()
2077 ToString(i) + " after compaction is " + ToString(num_files) + in DoCommand()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc1788 uint32_t num_files = 0; in LoadFromFile() local
1806 num_files = static_cast<uint32_t>(strtoul(data.data(), &next, 10)); in LoadFromFile()
1813 for (uint32_t i = 0; s.ok() && i < num_files; ++i) { in LoadFromFile()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1527 int num_files = vstorage->NumLevelFiles(i); in Open() local
1528 if (num_files > 0) { in Open()
Ddb_impl.cc4423 for (size_t j = 0; j < vstorage->LevelFilesBrief(i).num_files && s.ok(); in VerifyChecksum()