Home
last modified time | relevance | path

Searched refs:stats_ (Results 1 – 25 of 32) sorted by relevance

12

/rocksdb-6.9/monitoring/
Dhistogram_windowing.cc42 stats_.Clear(); in Clear()
60 stats_.Add(value); in Add()
76 stats_.Merge(other.stats_); in Merge()
78 if (stats_.num_buckets_ != other.stats_.num_buckets_ || in Merge()
101 return stats_.ToString(); in ToString()
114 if (stats_.num() >= start_num) { in Percentile()
122 return stats_.Average(); in Average()
126 return stats_.StandardDeviation(); in StandardDeviation()
130 stats_.Data(data); in Data()
161 stats_.buckets_[b].fetch_sub( in SwapHistoryBucket()
[all …]
Dhistogram.cc241 stats_.Clear(); in Clear()
245 return stats_.Empty(); in Empty()
249 stats_.Add(value); in Add()
261 stats_.Merge(other.stats_); in Merge()
265 return stats_.Median(); in Median()
269 return stats_.Percentile(p); in Percentile()
273 return stats_.Average(); in Average()
277 return stats_.StandardDeviation(); in StandardDeviation()
281 return stats_.ToString(); in ToString()
285 stats_.Data(data); in Data()
Dinstrumented_mutex.h23 : mutex_(adaptive), stats_(nullptr), env_(nullptr), in mutex_()
29 : mutex_(adaptive), stats_(stats), env_(env), in mutex_()
46 Statistics* stats_; variable
73 stats_(instrumented_mutex->stats_), in InstrumentedCondVar()
93 Statistics* stats_; variable
Dstatistics.cc237 : stats_(std::move(stats)) {} in StatisticsImpl()
282 if (stats_ && tickerType < TICKER_ENUM_MAX) { in setTickerCount()
283 stats_->setTickerCount(tickerType, count); in setTickerCount()
309 if (stats_ && tickerType < TICKER_ENUM_MAX) { in getAndResetTickerCount()
310 stats_->setTickerCount(tickerType, 0); in getAndResetTickerCount()
319 if (stats_ && tickerType < TICKER_ENUM_MAX) { in recordTick()
320 stats_->recordTick(tickerType, count); in recordTick()
330 if (stats_ && histogramType < HISTOGRAM_ENUM_MAX) { in recordInHistogram()
331 stats_->recordInHistogram(histogramType, value); in recordInHistogram()
Dhistogram_windowing.h38 virtual uint64_t min() const override { return stats_.min(); } in min()
39 virtual uint64_t max() const override { return stats_.max(); } in max()
40 virtual uint64_t num() const override { return stats_.num(); } in num()
62 HistogramStat stats_; variable
Dhistogram.h133 virtual uint64_t min() const override { return stats_.min(); } in min()
134 virtual uint64_t max() const override { return stats_.max(); } in max()
135 virtual uint64_t num() const override { return stats_.num(); } in num()
145 HistogramStat stats_;
Dinstrumented_mutex.cc26 stats_for_report(env_, stats_), stats_code_); in Lock()
40 stats_for_report(env_, stats_), stats_code_); in Wait()
54 stats_for_report(env_, stats_), stats_code_); in TimedWait()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier.cc151 stats_.insert_dropped_); in Stats()
153 stats_.cache_hits_); in Stats()
155 stats_.cache_misses_); in Stats()
157 stats_.cache_errors_); in Stats()
159 stats_.CacheHitPct()); in Stats()
161 stats_.CacheMissPct()); in Stats()
274 stats_.cache_misses_++; in Lookup()
283 stats_.cache_misses_++; in Lookup()
297 stats_.cache_misses_++; in Lookup()
298 stats_.cache_errors_++; in Lookup()
[all …]
Dvolatile_tier_impl.cc24 static_cast<double>(stats_.cache_hits_)}); in Stats()
26 static_cast<double>(stats_.cache_misses_)}); in Stats()
28 static_cast<double>(stats_.cache_inserts_)}); in Stats()
30 static_cast<double>(stats_.cache_evicts_)}); in Stats()
32 static_cast<double>(stats_.CacheHitPct())}); in Stats()
34 static_cast<double>(stats_.CacheMissPct())}); in Stats()
78 stats_.cache_inserts_++; in Insert()
96 stats_.cache_hits_++; in Lookup()
100 stats_.cache_misses_++; in Lookup()
121 stats_.cache_evicts_++; in Evict()
Dpersistent_cache_bench.cc121 stats_.Clear(); in CacheTierBenchmark()
154 << stats_.write_latency_.ToString() << std::endl in PrintStats()
156 << stats_.read_latency_.ToString() << std::endl in PrintStats()
158 << stats_.bytes_written_.ToString() << std::endl in PrintStats()
160 << stats_.bytes_read_.ToString() << std::endl in PrintStats()
211 stats_.write_latency_.Add(elapsed_micro); in InsertKey()
212 stats_.bytes_written_.Add(FLAGS_iosize); in InsertKey()
242 stats_.read_latency_.Add(elapsed_micro); in ReadKey()
243 stats_.bytes_read_.Add(FLAGS_iosize); in ReadKey()
301 mutable Stats stats_; // Stats member in ROCKSDB_NAMESPACE::CacheTierBenchmark
Dvolatile_tier_impl.h137 Statistics stats_; variable
/rocksdb-6.9/db/
Dmerge_helper.cc44 stats_(stats) { in MergeHelper()
216 stats_, env_); in MergeUntil()
324 stats_, env_); in MergeUntil()
347 StopWatchNano timer(env_, stats_ != nullptr); in MergeUntil()
354 RecordTick(stats_, MERGE_OPERATION_TOTAL_TIME, in MergeUntil()
355 stats_ ? timer.ElapsedNanosSafe() : 0); in MergeUntil()
394 if (stats_ != nullptr && ShouldReportDetailedTime(env_, stats_)) { in FilterMerge()
Dflush_job.cc118 stats_(stats), in FlushJob()
157 RecordTick(stats_, FLUSH_WRITE_BYTES, IOSTATS(bytes_written)); in RecordFlushIOStats()
440 RecordTimeToHistogram(stats_, FLUSH_TIME, stats.micros); in WriteLevel0Table()
Dflush_job.h127 Statistics* stats_; variable
/rocksdb-6.9/file/
Drandom_access_file_reader.cc31 StopWatch sw(env_, stats_, hist_type_, in Read()
32 (stats_ != nullptr) ? &elapsed : nullptr, true /*overwrite*/, in Read()
52 Env::IOPriority::IO_LOW, stats_, RateLimiter::OpType::kRead); in Read()
103 Env::IOPriority::IO_LOW, stats_, in Read()
150 if (stats_ != nullptr && file_read_hist_ != nullptr) { in Read()
197 StopWatch sw(env_, stats_, hist_type_, in MultiRead()
198 (stats_ != nullptr) ? &elapsed : nullptr, true /*overwrite*/, in MultiRead()
286 if (stats_ != nullptr && file_read_hist_ != nullptr) { in MultiRead()
Drandom_access_file_reader.h56 Statistics* stats_; variable
72 stats_(stats), in file_()
97 stats_ = std::move(o.stats_);
Dwritable_file_writer.h73 Statistics* stats_; variable
98 stats_(stats), in writable_file_()
Dwritable_file_writer.cc302 left, 0 /* alignment */, writable_file_->GetIOPriority(), stats_, in WriteBuffered()
390 stats_, RateLimiter::OpType::kWrite); in WriteDirect()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc160 RecordTick(stats_, WRITE_WITH_WAL); in WriteImpl()
308 RecordTick(stats_, WRITE_DONE_BY_SELF); in WriteImpl()
528 RecordTick(stats_, WRITE_DONE_BY_SELF, 1); in PipelinedWriteImpl()
661 RecordTick(stats_, WRITE_WITH_WAL); in WriteImplWALOnly()
727 RecordTick(stats_, BYTES_WRITTEN, total_byte_size); in WriteImplWALOnly()
730 RecordTick(stats_, WRITE_DONE_BY_SELF); in WriteImplWALOnly()
1054 StopWatch sw(env_, stats_, WAL_FILE_SYNC_MICROS); in WriteToWAL()
1084 RecordTick(stats_, WAL_FILE_SYNCED); in WriteToWAL()
1087 RecordTick(stats_, WAL_FILE_BYTES, log_size); in WriteToWAL()
1135 RecordTick(stats_, WAL_FILE_BYTES, log_size); in ConcurrentWriteToWAL()
[all …]
Ddb_impl_readonly.cc55 RecordTick(stats_, MEMTABLE_HIT); in Get()
61 RecordTick(stats_, MEMTABLE_MISS); in Get()
63 RecordTick(stats_, NUMBER_KEYS_READ); in Get()
65 RecordTick(stats_, BYTES_READ, size); in Get()
66 RecordInHistogram(stats_, BYTES_PER_READ, size); in Get()
Ddb_impl_secondary.cc322 StopWatch sw(env_, stats_, DB_GET); in GetImpl()
348 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
355 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
366 RecordTick(stats_, MEMTABLE_MISS); in GetImpl()
371 RecordTick(stats_, NUMBER_KEYS_READ); in GetImpl()
373 RecordTick(stats_, BYTES_READ, size); in GetImpl()
374 RecordTimeToHistogram(stats_, BYTES_PER_READ, size); in GetImpl()
Ddb_impl.cc1222 RecordTick(stats_, WAL_FILE_SYNCED); in SyncWAL()
1531 StopWatch sw(env_, stats_, DB_GET); in GetImpl()
1620 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
1629 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
1638 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
1644 RecordTick(stats_, MEMTABLE_HIT); in GetImpl()
1662 RecordTick(stats_, MEMTABLE_MISS); in GetImpl()
1670 RecordTick(stats_, NUMBER_KEYS_READ); in GetImpl()
1782 RecordTick(stats_, MEMTABLE_HIT); in MultiGet()
1787 RecordTick(stats_, MEMTABLE_HIT); in MultiGet()
[all …]
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java183 stats_ = new Stats(tid); in BenchmarkTask()
187 stats_.start_ = System.nanoTime(); in call()
189 stats_.finish_ = System.nanoTime(); in call()
190 return stats_; in call()
199 protected Stats stats_; field in DbBenchmark.BenchmarkTask
275 long interval = System.nanoTime() - stats_.start_; in writeRateControl()
400 stats_.found_++; in runTask()
401 stats_.finishedSingleOp(keySize_ + valueSize_); in runTask()
403 stats_.finishedSingleOp(keySize_); in runTask()
423 stats_.found_++; in runTask()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc327 stats_(stats), in CompactionJob()
413 StopWatch sw(env_, stats_, SUBCOMPACTION_SETUP_TIME); in Prepare()
423 RecordInHistogram(stats_, NUM_SUBCOMPACTIONS_SCHEDULED, in Prepare()
602 RecordTimeToHistogram(stats_, COMPACTION_CPU_TIME, in Run()
1010 RecordTick(stats_, FILTER_OPERATION_TOTAL_TIME, in ProcessKeyValueCompaction()
1083 RecordTick(stats_, COMPACTION_KEY_DROP_USER, in RecordDroppedKeys()
1087 RecordTick(stats_, COMPACTION_KEY_DROP_NEWER_ENTRY, in RecordDroppedKeys()
1095 RecordTick(stats_, COMPACTION_KEY_DROP_OBSOLETE, in RecordDroppedKeys()
1103 RecordTick(stats_, COMPACTION_KEY_DROP_RANGE_DEL, in RecordDroppedKeys()
1107 RecordTick(stats_, COMPACTION_RANGE_DEL_DROP_OBSOLETE, in RecordDroppedKeys()
[all …]
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc162 stats_(nullptr) {} in SimCacheImpl()
277 SetTickerCount(stats_, SIM_BLOCK_CACHE_HIT, 0); in reset_counter()
278 SetTickerCount(stats_, SIM_BLOCK_CACHE_MISS, 0); in reset_counter()
320 Statistics* stats_; member in ROCKSDB_NAMESPACE::__anona55187990111::SimCacheImpl

12