Searched refs:ci (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/db/ |
| D | listener_test.cc | 99 ASSERT_GT(ci.input_files.size(), 0U); in OnCompactionCompleted()
100 ASSERT_EQ(ci.input_files.size(), ci.input_file_infos.size()); in OnCompactionCompleted()
103 ASSERT_EQ(ci.input_file_infos[i].level, ci.base_input_level); in OnCompactionCompleted()
108 ASSERT_GT(ci.output_files.size(), 0U); in OnCompactionCompleted()
109 ASSERT_EQ(ci.output_files.size(), ci.output_file_infos.size()); in OnCompactionCompleted()
120 ASSERT_EQ(ci.output_file_infos[i].level, ci.output_level); in OnCompactionCompleted()
125 files_by_level[ci.output_level].begin(), in OnCompactionCompleted()
136 ASSERT_GT(ci.thread_id, 0U); in OnCompactionCompleted()
138 for (auto fl : {ci.input_files, ci.output_files}) { in OnCompactionCompleted()
140 auto it = ci.table_properties.find(fn); in OnCompactionCompleted()
[all …]
|
| D | db_test2.cc | 1256 ci.output_level == bottommost_level) { in OnCompactionCompleted()
1257 ASSERT_EQ(ci.compression, db_options_->bottommost_compression); in OnCompactionCompleted()
1259 ASSERT_EQ(ci.compression, in OnCompactionCompleted()
1260 db_options_->compression_per_level[ci.output_level]); in OnCompactionCompleted()
1262 ASSERT_EQ(ci.compression, db_options_->compression); in OnCompactionCompleted()
1336 ASSERT_EQ(ci.cf_name, "default"); in OnCompactionBegin()
1337 ASSERT_EQ(ci.base_input_level, 0); in OnCompactionBegin()
1339 compacting_files_cnt_ += ci.input_files.size(); in OnCompactionBegin()
1343 ASSERT_EQ(ci.cf_name, "default"); in OnCompactionCompleted()
1344 ASSERT_EQ(ci.base_input_level, 0); in OnCompactionCompleted()
[all …]
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_listener.h | 46 void OnCompactionCompleted(DB* /*db*/, const CompactionJobInfo& ci) override { in OnCompactionCompleted() argument
47 assert(IsValidColumnFamilyName(ci.cf_name)); in OnCompactionCompleted()
48 assert(ci.input_files.size() + ci.output_files.size() > 0U); in OnCompactionCompleted()
49 for (const auto& file_path : ci.input_files) { in OnCompactionCompleted()
52 for (const auto& file_path : ci.output_files) { in OnCompactionCompleted()
|
| /rocksdb-6.9/ |
| D | README.md | 3 [](https://travi…
4 … override { in OnCompactionCompleted() argument
427 ASSERT_GT(ci.stats.file_write_nanos, 0); in OnCompactionCompleted()
428 ASSERT_GT(ci.stats.file_range_sync_nanos, 0); in OnCompactionCompleted()
429 ASSERT_GT(ci.stats.file_fsync_nanos, 0); in OnCompactionCompleted()
430 ASSERT_GT(ci.stats.file_prepare_write_nanos, 0); in OnCompactionCompleted()
436 Verify(ci.stats, expected_stats_.front()); in OnCompactionCompleted()
|