| /rocksdb-6.9/monitoring/ |
| D | iostats_context.cc | 38 #define IOSTATS_CONTEXT_OUTPUT(counter) \ argument
39 if (!exclude_zero_counters || counter > 0) { \
40 ss << #counter << " = " << counter << ", "; \
|
| D | stats_history_test.cc | 43 int counter = 0; in TEST_F() local
56 "DBImpl::DumpStats:1", [&](void* /*arg*/) { counter++; }); in TEST_F()
61 ASSERT_GE(counter, 1); in TEST_F()
65 int old_val = counter; in TEST_F()
69 ASSERT_EQ(counter, old_val); in TEST_F()
93 int counter = 0; in TEST_F() local
95 "DBImpl::PersistStats:Entry", [&](void* /*arg*/) { counter++; }); in TEST_F()
100 ASSERT_GE(counter, 1); in TEST_F()
129 int counter = 0; in TEST_F() local
131 "DBImpl::PersistStats:Entry", [&](void* /*arg*/) { counter++; }); in TEST_F()
[all …]
|
| D | perf_context.cc | 418 #define PERF_CONTEXT_OUTPUT(counter) \ argument
419 if (!exclude_zero_counters || (counter > 0)) { \
420 ss << #counter << " = " << counter << ", "; \
423 #define PERF_CONTEXT_BY_LEVEL_OUTPUT_ONE_COUNTER(counter) \ argument
426 ss << #counter << " = "; \
428 if (!exclude_zero_counters || (kv.second.counter > 0)) { \
429 ss << kv.second.counter << "@level" << kv.first << ", "; \
|
| /rocksdb-6.9/db/ |
| D | db_options_test.cc | 132 int counter = 0; in TEST_F() local
148 low_bytes_per_sync = counter; in TEST_F()
152 counter = 0; in TEST_F()
163 ASSERT_GT(counter, 5); in TEST_F()
164 ASSERT_LT(counter, 15); in TEST_F()
168 ASSERT_GT(low_bytes_per_sync, counter); in TEST_F()
182 int counter = 0; in TEST_F() local
194 low_bytes_per_sync = counter; in TEST_F()
198 counter = 0; in TEST_F()
203 ASSERT_GT(counter, 0); in TEST_F()
[all …]
|
| D | repair.cc | 378 int counter = 0; in ConvertLogToTable() local
389 counter += WriteBatchInternal::Count(&batch); in ConvertLogToTable()
441 log, counter, meta.fd.GetNumber(), in ConvertLogToTable()
478 int counter = 0; in ScanTable() local
543 counter++; in ScanTable()
554 t->meta.fd.GetNumber(), counter, in ScanTable()
|
| D | transaction_log_impl.cc | 287 BatchCounter counter(current_batch_seq_); in UpdateCurrentWriteBatch() local
288 batch->Iterate(&counter); in UpdateCurrentWriteBatch()
289 current_last_seq_ = counter.sequence_; in UpdateCurrentWriteBatch()
|
| D | listener_test.cc | 850 int counter; member in ROCKSDB_NAMESPACE::ColumnFamilyHandleDeletionStartedListener
855 : cfs_(cfs), counter(0) { in ColumnFamilyHandleDeletionStartedListener()
861 counter++; in OnColumnFamilyHandleDeletionStarted()
863 int getCounter() { return counter; } in getCounter()
903 int counter() { return counter_; } in counter() function in ROCKSDB_NAMESPACE::BackgroundErrorListener
929 ASSERT_EQ(1, listener->counter()); in TEST_F()
961 ASSERT_EQ(1, listener->counter()); in TEST_F()
|
| D | db_test_util.h | 430 anon::AtomicCounter* counter, in NewRandomAccessFile()
433 counter_(counter), in NewRandomAccessFile()
473 anon::AtomicCounter* counter) in NewSequentialFile()
474 : target_(std::move(target)), counter_(counter) {} in NewSequentialFile()
|
| D | db_test.cc | 2372 std::atomic<int> counter[kNumThreads]; member
2386 int counter = 0; in MTThreadBody() local
2391 t->state->counter[id].store(counter, std::memory_order_release); in MTThreadBody()
2409 static_cast<int>(counter), cf, unique_id); in MTThreadBody()
2417 static_cast<int>(counter), cf, unique_id); in MTThreadBody()
2471 ASSERT_LE(c, t->state->counter[w].load(std::memory_order_acquire)); in MTThreadBody()
2483 counter++; in MTThreadBody()
2486 fprintf(stderr, "... stopping thread %d after %d ops\n", id, int(counter)); in MTThreadBody()
2526 mt.counter[id].store(0, std::memory_order_release); in TEST_P()
|
| /rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/ |
| D | PutBenchmarks.java | 108 public void put(final ComparatorBenchmarks.Counter counter) throws RocksDBException { in put() argument
109 final int i = counter.next(); in put()
|
| D | ComparatorBenchmarks.java | 135 public void put(final Counter counter) throws RocksDBException { in put() argument
136 final int i = counter.next(); in put()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_transaction_test.cc | 172 std::atomic<int64_t> counter(0); in TEST_P() local
206 int64_t snapshot_num = counter.fetch_add(1); in TEST_P()
210 buf[1] = counter.fetch_add(1); in TEST_P()
218 snapshot_num = counter.fetch_add(1); in TEST_P()
|
| D | write_prepared_txn.cc | 164 SubBatchCounter counter(*wpt_db_->GetCFComparatorMap()); in CommitInternal() local
165 auto s = working_batch->Iterate(&counter); in CommitInternal()
167 commit_batch_cnt = counter.BatchCount(); in CommitInternal()
|
| D | write_unprepared_txn.cc | 557 SubBatchCounter counter(*wpt_db_->GetCFComparatorMap()); in CommitInternal() local
558 auto s = working_batch->Iterate(&counter); in CommitInternal()
560 commit_batch_cnt = counter.BatchCount(); in CommitInternal()
|
| D | write_prepared_txn_db.cc | 158 SubBatchCounter counter(*GetCFComparatorMap()); in WriteInternal() local
159 auto s = batch->Iterate(&counter); in WriteInternal()
161 batch_cnt = counter.BatchCount(); in WriteInternal()
|
| D | write_prepared_transaction_test.cc | 254 SubBatchCounter counter(comparators); in TEST() local
255 ASSERT_OK(batch.GetWriteBatch()->Iterate(&counter)); in TEST()
256 ASSERT_EQ(batch_cnt, counter.BatchCount()); in TEST()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | file_system.h | 131 for (auto counter : counters) { in ToString() local
132 ss << counter.first << " = " << counter.second << ","; in ToString()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2016-07-26-rocksdb-4-8-released.markdown | 43 …* Add monotonically increasing counter (DB property "rocksdb.current-super-version-number") that i…
|
| D | 2014-05-14-lock.markdown | 29 …ock in order to find the latest super version and increase its reference counter. From the super v…
33 …super version and increase the reference count for that (dereference the counter is done in an ato…
|
| D | 2014-06-27-avoid-expensive-locks-in-get.markdown | 27 `Ref()` simply increases the reference counter and returns “this” pointer. However, this simple ope…
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_secondary_test.cc | 208 std::atomic<int>& counter) in NewRandomAccessFile() argument
209 : target_(std::move(target)), files_closed_(counter) {} in NewRandomAccessFile()
|
| /rocksdb-6.9/ |
| D | HISTORY.md | 113 … for GoodCompressionRatio), as seen in the `number.block.not_compressed` counter stat since versio…
337 * The counter stat `number.block.not_compressed` now also counts blocks not compressed due to poor …
792 * Add monotonically increasing counter (DB property "rocksdb.current-super-version-number") that in…
|