| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 148 CompactionJobStats compaction_job_stats; member
188 compaction_job_stats = std::move(o.compaction_job_stats); in operator =()
291 compaction_job_stats_->Add(sc.compaction_job_stats); in AggregateStatistics()
311 compaction_job_stats_(compaction_job_stats), in CompactionJob()
999 sub_compact->compaction_job_stats.num_corrupt_keys = in ProcessKeyValueCompaction()
1053 sub_compact->compaction_job_stats.cpu_micros = in ProcessKeyValueCompaction()
1065 sub_compact->compaction_job_stats.cpu_micros -= in ProcessKeyValueCompaction()
1081 CompactionJobStats* compaction_job_stats) { in RecordDroppedKeys() argument
1089 if (compaction_job_stats) { in RecordDroppedKeys()
1090 compaction_job_stats->num_records_replaced += in RecordDroppedKeys()
[all …]
|
| D | compaction_job_test.cc | 37 const CompactionJobStats& compaction_job_stats) { in VerifyInitializationOfCompactionJobStats() argument
39 ASSERT_EQ(compaction_job_stats.elapsed_micros, 0U); in VerifyInitializationOfCompactionJobStats()
41 ASSERT_EQ(compaction_job_stats.num_input_records, 0U); in VerifyInitializationOfCompactionJobStats()
42 ASSERT_EQ(compaction_job_stats.num_input_files, 0U); in VerifyInitializationOfCompactionJobStats()
45 ASSERT_EQ(compaction_job_stats.num_output_records, 0U); in VerifyInitializationOfCompactionJobStats()
46 ASSERT_EQ(compaction_job_stats.num_output_files, 0U); in VerifyInitializationOfCompactionJobStats()
48 ASSERT_EQ(compaction_job_stats.is_manual_compaction, true); in VerifyInitializationOfCompactionJobStats()
50 ASSERT_EQ(compaction_job_stats.total_input_bytes, 0U); in VerifyInitializationOfCompactionJobStats()
51 ASSERT_EQ(compaction_job_stats.total_output_bytes, 0U); in VerifyInitializationOfCompactionJobStats()
59 ASSERT_EQ(compaction_job_stats.num_records_replaced, 0U); in VerifyInitializationOfCompactionJobStats()
[all …]
|
| D | compaction_job.h | 79 CompactionJobStats* compaction_job_stats,
137 CompactionJobStats* compaction_job_stats = nullptr);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 1024 CompactionJobStats compaction_job_stats; in CompactFilesImpl() local
1072 BuildCompactionJobInfo(cfd, c.get(), s, compaction_job_stats, in CompactFilesImpl()
1221 const CompactionJobStats& compaction_job_stats, const int job_id) { in NotifyOnCompactionCompleted() argument
1255 (void)compaction_job_stats; in NotifyOnCompactionCompleted()
2500 CompactionJobStats compaction_job_stats; in BackgroundCompaction() local
2683 compaction_job_stats.num_input_files = c->num_input_files(0); in BackgroundCompaction()
2686 compaction_job_stats, job_context->job_id); in BackgroundCompaction()
2716 compaction_job_stats.num_input_files = c->num_input_files(0); in BackgroundCompaction()
2825 &compaction_job_stats, thread_pri, in BackgroundCompaction()
3042 const CompactionJobStats& compaction_job_stats, const int job_id, in BuildCompactionJobInfo() argument
[all …]
|
| /rocksdb-6.9/util/ |
| D | compaction_job_stats_impl.cc.d | 3 include/rocksdb/compaction_job_stats.h \
|
| D | status.cc.d | 8 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | comparator.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | timer_queue_test.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | string_util.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | filelock_test.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | thread_local.cc.d | 10 include/rocksdb/compaction_job_stats.h \
|
| D | coding.cc.d | 10 include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/port/ |
| D | port_posix.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/table/block_based/ |
| D | data_block_footer.cc.d | 13 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | reader_common.cc.d | 12 include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/monitoring/ |
| D | histogram.cc.d | 10 include/rocksdb/compaction_job_stats.h \
|
| D | perf_level.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/test_util/ |
| D | sync_point.cc.d | 10 include/rocksdb/compaction_job_stats.h \
|
| D | sync_point_impl.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/env/ |
| D | mock_env_test.cc.d | 9 include/rocksdb/compaction_job_stats.h \
|
| D | env_basic_test.cc.d | 9 include/rocksdb/compaction_job_stats.h \
|
| D | file_system.cc.d | 10 include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/utilities/table_properties_collectors/ |
| D | compact_on_deletion_collector_test.cc.d | 13 include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/utilities/leveldb_options/ |
| D | leveldb_options.cc.d | 13 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/memtable/ |
| D | write_buffer_manager.cc.d | 13 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|