| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | StatisticsTest.java | 28 final Statistics statistics = new Statistics(); in statsLevel() local
29 statistics.setStatsLevel(StatsLevel.ALL); in statsLevel()
35 try (final Statistics statistics = new Statistics(); in getTickerCount() argument
37 .setStatistics(statistics) in getTickerCount()
58 .setStatistics(statistics) in getAndResetTickerCount()
83 .setStatistics(statistics) in getHistogramData()
114 .setStatistics(statistics) in getHistogramString()
134 .setStatistics(statistics) in reset()
150 statistics.reset(); in reset()
161 .setStatistics(statistics) in ToString()
[all …]
|
| D | StatisticsCollectorTest.java | 29 try (final Statistics statistics = new Statistics(); in statisticsCollector() argument
31 .setStatistics(statistics) in statisticsCollector()
36 try(final Statistics stats = opt.statistics()) { in statisticsCollector()
|
| D | BlockBasedTableConfigTest.java | 115 final Statistics statistics = new Statistics()) { in blockCacheIntegration()
120 .setStatistics(statistics) in blockCacheIntegration()
131 assertThat(statistics.getTickerCount(TickerType.BLOCK_CACHE_ADD)).isEqualTo(shard + 1); in blockCacheIntegration()
176 final Statistics statistics = new Statistics()) { in blockCacheCompressedIntegration()
186 .setStatistics(statistics) in blockCacheCompressedIntegration()
207 … assertThat(statistics.getTickerCount(TickerType.BLOCK_CACHE_COMPRESSED_ADD)).isEqualTo(shard + 1); in blockCacheCompressedIntegration()
|
| /rocksdb-6.9/db/ |
| D | db_statistics_test.cc | 48 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
49 options.statistics->set_stats_level(StatsLevel::kExceptTimeForMutex); in TEST_F()
71 options.statistics->getTickerCount(NUMBER_BLOCK_COMPRESSED); in TEST_F()
81 ASSERT_EQ(options.statistics->getTickerCount(NUMBER_BLOCK_COMPRESSED) in TEST_F()
94 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
107 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
108 options.statistics->set_stats_level(StatsLevel::kAll); in TEST_F()
121 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
128 options.statistics->histogramData(DB_WRITE, &histogram_data); in TEST_F()
136 options.statistics->histogramData(DB_WRITE, &histogram_data); in TEST_F()
[all …]
|
| D | merge_helper.cc | 55 Statistics* statistics, Env* env, in TimedFullMerge() argument
67 RecordInHistogram(statistics, READ_NUM_MERGE_OPERANDS, in TimedFullMerge()
78 StopWatchNano timer(env, statistics != nullptr); in TimedFullMerge()
95 RecordTick(statistics, MERGE_OPERATION_TOTAL_TIME, in TimedFullMerge()
96 statistics ? timer.ElapsedNanos() : 0); in TimedFullMerge()
100 RecordTick(statistics, NUMBER_MERGE_FAILURES); in TimedFullMerge()
|
| D | flush_job_test.cc | 45 db_options_.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics();
224 kNoCompression, db_options_.statistics.get(), in TEST_F()
234 db_options_.statistics->histogramData(FLUSH_TIME, &hist); in TEST_F()
291 db_options_.statistics.get(), &event_logger, true, in TEST_F()
300 db_options_.statistics->histogramData(FLUSH_TIME, &hist); in TEST_F()
363 db_options_.statistics.get(), &event_logger, true, in TEST_F()
403 db_options_.statistics->histogramData(FLUSH_TIME, &hist); in TEST_F()
479 kNoCompression, db_options_.statistics.get(), in TEST_F()
488 db_options_.statistics->histogramData(FLUSH_TIME, &hist); in TEST_F()
|
| D | db_block_cache_test.cc | 49 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in GetOptions()
295 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
381 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
466 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
522 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
578 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
615 no_block_cache_opts.statistics = options.statistics; in TEST_F()
707 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
|
| D | memtable.cc | 59 statistics(ioptions.statistics), in ImmutableMemTableOptions()
610 Statistics* statistics; member
696 s->statistics, s->env_, nullptr /* result_operand */, true); in SaveValue()
734 s->statistics, s->env_, nullptr /* result_operand */, true); in SaveValue()
761 merge_context->GetOperands(), s->value, s->logger, s->statistics, in SaveValue()
861 saver.statistics = moptions_.statistics; in GetFromTable()
933 RecordTick(moptions_.statistics, MEMTABLE_HIT); in MultiGet()
984 RecordTick(moptions_.statistics, NUMBER_KEYS_UPDATED); in Update()
1052 RecordTick(moptions_.statistics, NUMBER_KEYS_UPDATED); in UpdateCallback()
1057 RecordTick(moptions_.statistics, NUMBER_KEYS_WRITTEN); in UpdateCallback()
|
| D | db_bloom_filter_test.cc | 91 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_P()
153 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
1399 options.statistics = CreateDBStatistics(); in TEST_F()
1416 options.statistics = CreateDBStatistics(); in TEST_F()
1430 options.statistics = CreateDBStatistics(); in TEST_F()
1448 options.statistics = CreateDBStatistics(); in TEST_F()
1487 options.statistics = CreateDBStatistics(); in TEST_F()
1521 options.statistics = CreateDBStatistics(); in TEST_F()
1652 options.statistics = CreateDBStatistics(); in TEST_F()
1786 options.statistics = CreateDBStatistics(); in TEST_F()
[all …]
|
| /rocksdb-6.9/build_tools/ |
| D | regression_build_test.sh | 57 --statistics=1 \
74 --statistics=1 \
92 --statistics=1 \
110 --statistics=1 \
129 --statistics=1 \
147 --statistics=1 \
167 --statistics=1 \
186 --statistics=1 \
204 --statistics=1 \
223 --statistics=1 \
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | statistics.h | 112 if (statistics) { in RecordInHistogram()
113 statistics->recordInHistogram(histogram_type, value); in RecordInHistogram()
117 inline void RecordTimeToHistogram(Statistics* statistics, in RecordTimeToHistogram() argument
119 if (statistics) { in RecordTimeToHistogram()
120 statistics->reportTimeToHistogram(histogram_type, value); in RecordTimeToHistogram()
124 inline void RecordTick(Statistics* statistics, uint32_t ticker_type,
126 if (statistics) {
127 statistics->recordTick(ticker_type, count);
131 inline void SetTickerCount(Statistics* statistics, uint32_t ticker_type, in SetTickerCount() argument
133 if (statistics) { in SetTickerCount()
[all …]
|
| D | statistics.cc.d | 1 monitoring/statistics.cc.d monitoring/statistics.o: \
2 monitoring/statistics.cc monitoring/statistics.h \
3 include/rocksdb/statistics.h include/rocksdb/status.h \
|
| D | perf_step_timer.h | 18 Statistics* statistics = nullptr, uint32_t ticker_type = 0)
21 env_((perf_counter_enabled_ || statistics != nullptr)
26 statistics_(statistics),
|
| D | stats_history_test.cc | 146 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
201 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
315 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
396 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
401 ASSERT_TRUE(options.statistics->getTickerMap(&stats_map_before)); in TEST_F()
431 ASSERT_TRUE(options.statistics->getTickerMap(&stats_map_after)); in TEST_F()
475 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
576 options.statistics = ROCKSDB_NAMESPACE::CreateDBStatistics(); in TEST_F()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2017-05-14-core-local-stats.markdown | 10 …statistics were implemented with std::atomic values shared across the entire program. A ticker con…
16 …99%+) are served by uncompressed block cache. Such a scenario stresses the statistics code heavily.
18 Benchmark command: `TEST_TMPDIR=/dev/shm/ perf record -g ./db_bench -statistics -use_existing_db=tr…
40 …statistics use thread-local storage. Each thread has a local set of atomic values that no other th…
42 …ss unnoticed if statistics are queried infrequently. Second, exited threads' local values are stil…
64 To measure statistics query latency, we ran sysbench with 4K OLTP clients concurrently with one cli…
75 …statistics infrequently. Eventually, though, we found use cases where those assumptions do not hol…
77 …statistics will be local to each CPU core. Similarly to thread-local, each core updates only its l…
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_reader.cc | 225 Statistics* const statistics = rep_->ioptions.statistics; in UpdateCacheHitMetrics() local
235 RecordTick(statistics, BLOCK_CACHE_HIT); in UpdateCacheHitMetrics()
275 RecordTick(statistics, BLOCK_CACHE_DATA_HIT); in UpdateCacheHitMetrics()
283 Statistics* const statistics = rep_->ioptions.statistics; in UpdateCacheMissMetrics() local
292 RecordTick(statistics, BLOCK_CACHE_MISS); in UpdateCacheMissMetrics()
336 Statistics* const statistics = rep_->ioptions.statistics; in UpdateCacheInsertionMetrics() local
343 RecordTick(statistics, BLOCK_CACHE_ADD); in UpdateCacheInsertionMetrics()
1131 Statistics* statistics = rep_->ioptions.statistics; in GetDataBlockFromCache() local
1216 Statistics* statistics = ioptions.statistics; in PutDataBlockToCache() local
1420 Statistics* statistics = rep_->ioptions.statistics; in MaybeReadBlockAndLoadToCache() local
[all …]
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_timeseries_parser.py | 92 def fetch_aggregated_values(self, entity, statistics, aggregation_op): argument
98 for stat in statistics:
164 def handle_evaluate_expression(self, condition, statistics, entities): argument
175 entity, statistics, condition.aggregation_op
177 keys = [result[key] for key in statistics]
192 for epoch in self.keys_ts[entity][statistics[0]].keys():
195 for key in statistics
|
| D | db_stats_fetcher.py | 166 def fetch_timeseries(self, statistics): argument
257 def fetch_timeseries(self, statistics): argument
260 print('OdsStatsFetcher: fetching ' + str(statistics))
265 self._get_string_in_quotes(','.join(statistics)),
278 self._get_string_in_quotes(','.join(statistics))
|
| /rocksdb-6.9/util/ |
| D | stop_watch.h | 17 StopWatch(Env* const env, Statistics* statistics, const uint32_t hist_type,
21 statistics_(statistics), in env_()
25 stats_enabled_(statistics && in env_()
26 statistics->get_stats_level() >= in env_()
28 statistics->HistEnabledForType(hist_type)), in env_()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_test.cc | 984 auto statistics = CreateDBStatistics(); in TEST_F() local
985 options.statistics = statistics; in TEST_F()
1037 auto statistics = CreateDBStatistics(); in TEST_F() local
1038 options.statistics = statistics; in TEST_F()
1273 auto statistics = CreateDBStatistics(); in TEST_F() local
1274 options.statistics = statistics; in TEST_F()
1374 options.statistics = CreateDBStatistics(); in TEST_F()
1508 const Statistics *const statistics = options.statistics.get(); in TEST_F() local
1509 assert(statistics); in TEST_F()
1568 const Statistics *const statistics = db_options.statistics.get(); in TEST_F() local
[all …]
|
| D | blob_compaction_filter.cc | 75 RecordTick(statistics(), BLOB_DB_GC_NUM_KEYS_RELOCATED, in ~BlobIndexCompactionFilterGC()
77 RecordTick(statistics(), BLOB_DB_GC_BYTES_RELOCATED, in ~BlobIndexCompactionFilterGC()
79 RecordTick(statistics(), BLOB_DB_GC_NUM_NEW_FILES, gc_stats_.NewFiles()); in ~BlobIndexCompactionFilterGC()
80 RecordTick(statistics(), BLOB_DB_GC_FAILURES, gc_stats_.HasError()); in ~BlobIndexCompactionFilterGC()
302 std::move(context), current_time, statistics())); in CreateCompactionFilter()
324 std::move(context), std::move(context_gc), current_time, statistics())); in CreateCompactionFilter()
|
| /rocksdb-6.9/table/ |
| D | persistent_cache_helper.cc | 65 RecordTick(cache_options.statistics, PERSISTENT_CACHE_MISS); in LookupRawPage()
72 RecordTick(cache_options.statistics, PERSISTENT_CACHE_HIT); in LookupRawPage()
98 RecordTick(cache_options.statistics, PERSISTENT_CACHE_MISS); in LookupUncompressedPage()
107 RecordTick(cache_options.statistics, PERSISTENT_CACHE_HIT); in LookupUncompressedPage()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | StatisticsCollector.java | 76 Statistics statistics = statsCollectorInput.getStatistics(); in collectStatistics()
83 final long tickerValue = statistics.getTickerCount(ticker); in collectStatistics()
92 statistics.getHistogramData(histogramType); in collectStatistics()
|
| D | StatsCollectorInput.java | 22 public StatsCollectorInput(final Statistics statistics, in StatsCollectorInput() argument
24 _statistics = statistics; in StatsCollectorInput()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer.cc | 1690 statistics += ":"; in PrintAccessCountStats()
1691 statistics += in PrintAccessCountStats()
1693 statistics += ","; in PrintAccessCountStats()
1699 statistics.c_str()); in PrintAccessCountStats()
1721 statistics += ","; in PrintAccessCountStats()
1723 statistics += ":"; in PrintAccessCountStats()
1724 statistics += in PrintAccessCountStats()
1745 statistics += ",nkeys="; in PrintAccessCountStats()
1747 statistics += ",block_size="; in PrintAccessCountStats()
1749 statistics += ",num_ref_keys="; in PrintAccessCountStats()
[all …]
|