Home
last modified time | relevance | path

Searched refs:stats (Results 1 – 25 of 78) sorted by relevance

1234

/rocksdb-6.9/util/
Dcompaction_job_stats_impl.cc51 elapsed_micros += stats.elapsed_micros; in Add()
52 cpu_micros += stats.cpu_micros; in Add()
54 num_input_records += stats.num_input_records; in Add()
55 num_input_files += stats.num_input_files; in Add()
58 num_output_records += stats.num_output_records; in Add()
59 num_output_files += stats.num_output_files; in Add()
61 total_input_bytes += stats.total_input_bytes; in Add()
62 total_output_bytes += stats.total_output_bytes; in Add()
72 num_corrupt_keys += stats.num_corrupt_keys; in Add()
74 file_write_nanos += stats.file_write_nanos; in Add()
[all …]
Drate_limiter_test.cc187 auto stats = CreateDBStatistics(); in TEST_F() local
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc452 stats.num_input_records); in Verify()
454 stats.num_input_files); in Verify()
461 stats.num_output_files); in Verify()
485 stats.num_corrupt_keys); in Verify()
500 expected_stats_.push(stats); in AddExpectedStats()
534 stats.num_corrupt_keys); in Verify()
576 CompactionJobStats stats; in NewManualCompactionJobStats() local
577 stats.Reset(); in NewManualCompactionJobStats()
586 stats.total_input_bytes = in NewManualCompactionJobStats()
590 stats.total_output_bytes = in NewManualCompactionJobStats()
[all …]
Dcompaction_job.cc327 stats_(stats), in CompactionJob()
738 read_write_amp = (stats.bytes_written + stats.bytes_read_output_level + in Install()
741 write_amp = stats.bytes_written / in Install()
744 if (stats.micros > 0) { in Install()
746 (stats.bytes_read_non_output_levels + stats.bytes_read_output_level) / in Install()
749 stats.bytes_written / static_cast<double>(stats.micros); in Install()
762 stats.num_input_files_in_output_level, stats.num_output_files, in Install()
767 stats.num_dropped_records, in Install()
771 UpdateCompactionJobStats(stats); in Install()
1657 stats.bytes_read_non_output_levels + stats.bytes_read_output_level; in UpdateCompactionJobStats()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_test.cc347 stats->getTickerCount(READ_AMP_ESTIMATE_USEFUL_BYTES); in TEST_F()
380 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
386 nullptr, stats.get()); in TEST_F()
393 double read_amp = static_cast<double>(stats->getTickerCount( in TEST_F()
395 stats->getTickerCount(READ_AMP_TOTAL_READ_BYTES); in TEST_F()
413 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
418 nullptr, stats.get()); in TEST_F()
429 double read_amp = static_cast<double>(stats->getTickerCount( in TEST_F()
448 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F()
453 nullptr, stats.get()); in TEST_F()
[all …]
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc528 for (auto& stat : ta_[type].stats) { in MakeStatistics()
669 stats.a_succ_count = 0; in MakeStatisticKeyStatsOrPrefix()
672 if (!stats.a_key_f) { in MakeStatisticKeyStatsOrPrefix()
689 s = stats.a_key_f->Append(printout); in MakeStatisticKeyStatsOrPrefix()
741 stats.top_k_prefix_ave.push( in MakeStatisticKeyStatsOrPrefix()
746 stats.top_k_prefix_ave.push( in MakeStatisticKeyStatsOrPrefix()
768 if (stats.correlation_output.size() != in MakeStatisticCorrelation()
1013 ta_[type].stats.find(cf_id) == ta_[type].stats.end()) { in ReProcessing()
1141 ta_[type].stats.find(cf_id) == ta_[type].stats.end()) { in ReProcessing()
1222 ta_[type].stats[cf_id].a_count = 1; in KeyStatsInsertion()
[all …]
Ddb_bench_tool.cc2028 std::string stats; in FinishedOps() local
2241 Stats stats; member
3314 thread->stats.Stop(); in ThreadBody()
3421 thread->stats.AddBytes(bytes); in Crc32c()
3440 thread->stats.AddBytes(bytes); in xxHash()
4525 thread->stats.AddBytes(bytes); in DoWrite()
4864 thread->stats.AddBytes(bytes); in ReadSequential()
4921 thread->stats.AddBytes(bytes); in ReadToRowCache()
6830 thread->stats.Stop(); in TimeSeries()
6907 std::string stats; in PrintStats() local
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier.cc139 stats->insert({key, static_cast<double>(t)}); in Add()
143 std::map<std::string, double> stats; in Stats() local
144 Add(&stats, "persistentcache.blockcachetier.bytes_piplined", in Stats()
146 Add(&stats, "persistentcache.blockcachetier.bytes_written", in Stats()
148 Add(&stats, "persistentcache.blockcachetier.bytes_read", in Stats()
150 Add(&stats, "persistentcache.blockcachetier.insert_dropped", in Stats()
152 Add(&stats, "persistentcache.blockcachetier.cache_hits", in Stats()
154 Add(&stats, "persistentcache.blockcachetier.cache_misses", in Stats()
156 Add(&stats, "persistentcache.blockcachetier.cache_errors", in Stats()
166 Add(&stats, "persistentcache.blockcachetier.write_latency", in Stats()
[all …]
/rocksdb-6.9/db_stress_tool/
Dbatched_ops_stress.cc52 thread->stats.AddErrors(1); in TestPut()
81 thread->stats.AddErrors(1); in TestDelete()
83 thread->stats.AddDeletes(10); in TestDelete()
137 thread->stats.AddErrors(1); in TestGet()
142 thread->stats.AddGets(1, 0); in TestGet()
153 thread->stats.AddGets(1, 1); in TestGet()
203 thread->stats.AddErrors(1); in TestMultiGet()
208 thread->stats.AddGets(1, 0); in TestMultiGet()
222 thread->stats.AddGets(1, 1); in TestMultiGet()
326 thread->stats.AddPrefixes(1, count); in TestPrefixScan()
[all …]
Dcf_consistency_stress.cc43 thread->stats.AddErrors(1); in TestPut()
66 thread->stats.AddErrors(1); in TestDelete()
96 thread->stats.AddErrors(1); in TestDeleteRange()
188 thread->stats.AddErrors(1); in TestGet()
192 thread->stats.AddGets(1, 1); in TestGet()
194 thread->stats.AddGets(1, 0); in TestGet()
197 thread->stats.AddErrors(1); in TestGet()
224 thread->stats.AddGets(1, 1); in TestMultiGet()
227 thread->stats.AddGets(1, 0); in TestMultiGet()
231 thread->stats.AddErrors(1); in TestMultiGet()
[all …]
Dno_batched_ops_stress.cc150 thread->stats.AddGets(1, 1); in TestGet()
153 thread->stats.AddGets(1, 0); in TestGet()
157 thread->stats.AddErrors(1); in TestGet()
247 thread->stats.AddGets(1, 1); in TestMultiGet()
250 thread->stats.AddGets(1, 0); in TestMultiGet()
253 thread->stats.AddGets(1, 1); in TestMultiGet()
257 thread->stats.AddErrors(1); in TestMultiGet()
296 thread->stats.AddErrors(1); in TestPrefixScan()
426 thread->stats.AddDeletes(1); in TestDelete()
448 thread->stats.AddSingleDeletes(1); in TestDelete()
[all …]
Ddb_stress_driver.cc128 threads[0]->stats.Merge(threads[i]->stats); in RunStressTest()
130 threads[0]->stats.Report("Stress Test"); in RunStressTest()
/rocksdb-6.9/utilities/blob_db/
Dblob_compaction_filter.h37 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilterBase() argument
40 statistics_(stats) {} in BlobIndexCompactionFilterBase()
74 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilter() argument
75 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats) { in BlobIndexCompactionFilter()
85 uint64_t current_time, Statistics* stats) in BlobIndexCompactionFilterGC() argument
86 : BlobIndexCompactionFilterBase(std::move(context), current_time, stats), in BlobIndexCompactionFilterGC()
/rocksdb-6.9/java/rocksjni/
Dstatisticsjni.cc13 StatisticsJni::StatisticsJni(std::shared_ptr<Statistics> stats) in StatisticsJni() argument
14 : StatisticsImpl(stats), m_ignore_histograms() {} in StatisticsJni()
16 StatisticsJni::StatisticsJni(std::shared_ptr<Statistics> stats, in StatisticsJni() argument
18 : StatisticsImpl(stats), m_ignore_histograms(ignore_histograms) {} in StatisticsJni()
Dcompaction_job_info.cc228 auto* stats = new ROCKSDB_NAMESPACE::CompactionJobStats(); in Java_org_rocksdb_CompactionJobInfo_stats() local
229 stats->Add(compact_job_info->stats); in Java_org_rocksdb_CompactionJobInfo_stats()
230 return reinterpret_cast<jlong>(stats); in Java_org_rocksdb_CompactionJobInfo_stats()
Dstatisticsjni.h22 StatisticsJni(std::shared_ptr<Statistics> stats);
23 StatisticsJni(std::shared_ptr<Statistics> stats,
/rocksdb-6.9/monitoring/
Dinstrumented_mutex.cc13 Statistics* stats_for_report(Env* env, Statistics* stats) { in stats_for_report() argument
14 if (env != nullptr && stats != nullptr && in stats_for_report()
15 stats->get_stats_level() > kExceptTimeForMutex) { in stats_for_report()
16 return stats; in stats_for_report()
Dperf_context_imp.h30 #define PERF_CONDITIONAL_TIMER_FOR_MUTEX_GUARD(metric, condition, stats, \ argument
60 #define PERF_CONDITIONAL_TIMER_FOR_MUTEX_GUARD(metric, condition, stats, \ argument
63 false, PerfLevel::kEnableTime, stats, \
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc299 auto stats = default_cf_internal_stats_; in WriteImpl() local
306 stats->AddDBStats(InternalStats::kIntStatsWriteDoneBySelf, 1, in WriteImpl()
311 stats->AddDBStats(InternalStats::kIntStatsWriteDoneByOther, in WriteImpl()
515 auto stats = default_cf_internal_stats_; in PipelinedWriteImpl() local
530 stats->AddDBStats(InternalStats::kIntStatsWriteDoneByOther, in PipelinedWriteImpl()
613 InternalStats* stats = default_cf_internal_stats_; in UnorderedWriteMemtable() local
724 auto stats = default_cf_internal_stats_; in WriteImplWALOnly() local
728 stats->AddDBStats(InternalStats::kIntStatsWriteDoneBySelf, 1, in WriteImplWALOnly()
733 stats->AddDBStats(InternalStats::kIntStatsWriteDoneByOther, in WriteImplWALOnly()
1081 auto stats = default_cf_internal_stats_; in WriteToWAL() local
[all …]
/rocksdb-6.9/db/
Dflush_job.cc97 CompressionType output_compression, Statistics* stats, in FlushJob() argument
118 stats_(stats), in FlushJob()
436 InternalStats::CompactionStats stats(CompactionReason::kFlush, 1); in WriteLevel0Table() local
437 stats.micros = db_options_.env->NowMicros() - start_micros; in WriteLevel0Table()
438 stats.cpu_micros = db_options_.env->NowCPUNanos() / 1000 - start_cpu_micros; in WriteLevel0Table()
439 stats.bytes_written = meta_.fd.GetFileSize(); in WriteLevel0Table()
440 RecordTimeToHistogram(stats_, FLUSH_TIME, stats.micros); in WriteLevel0Table()
441 cfd_->internal_stats()->AddCompactionStats(0 /* level */, thread_pri_, stats); in WriteLevel0Table()
Dinternal_stats.cc91 stats.bytes_read_non_output_levels + stats.bytes_read_output_level; in PrepareLevelStats()
92 int64_t bytes_new = stats.bytes_written - stats.bytes_read_output_level; in PrepareLevelStats()
93 double elapsed = (stats.micros + 1) / kMicrosInSec; in PrepareLevelStats()
101 stats.bytes_read_non_output_levels / kGB; in PrepareLevelStats()
105 (*level_stats)[LevelStatType::MOVED_GB] = stats.bytes_moved / kGB; in PrepareLevelStats()
109 stats.bytes_written / kMB / elapsed; in PrepareLevelStats()
112 (*level_stats)[LevelStatType::COMP_COUNT] = stats.count; in PrepareLevelStats()
114 stats.count == 0 ? 0 : stats.micros / kMicrosInSec / stats.count; in PrepareLevelStats()
116 static_cast<double>(stats.num_input_records); in PrepareLevelStats()
118 static_cast<double>(stats.num_dropped_records); in PrepareLevelStats()
[all …]
Drange_del_aggregator_bench.cc174 Stats stats; in main() local
225 stats.time_add_tombstones += stop_watch_add_tombstones.ElapsedNanos(); in main()
245 stats.time_first_should_delete += call_time; in main()
247 stats.time_rest_should_delete += call_time; in main()
255 << stats; in main()
Dforward_iterator_bench.cc57 } stats; variable
157 ++::stats.cache_misses; in readOnceFromShard()
169 ++::stats.read; in readOnceFromShard()
253 ++::stats.written; in run()
287 uint64_t w = ::stats.written.load(); in run()
288 uint64_t r = ::stats.read.load(); in run()
296 ::stats.cache_misses.load()); in run()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DCompactionJobInfo.java133 public /* @Nullable */ CompactionJobStats stats() { in stats() method in CompactionJobInfo
134 final long statsHandle = stats(nativeHandle_); in stats()
158 private static native long stats(final long handle); in stats() method in CompactionJobInfo
/rocksdb-6.9/include/rocksdb/
Drate_limiter.h67 Statistics* stats, OpType op_type) { in Request() argument
69 Request(bytes, pri, stats); in Request()
78 Env::IOPriority io_priority, Statistics* stats,

1234