| /rocksdb-6.9/util/ |
| D | random_test.cc | 41 int count = 0; in TEST() local
44 ++count; in TEST()
48 EXPECT_EQ(count, average); in TEST()
61 int count = 0; in TEST() local
64 ++count; in TEST()
68 EXPECT_EQ(count, 0); in TEST()
70 EXPECT_EQ(count, average); in TEST()
84 int count = 0; in TEST() local
87 ++count; in TEST()
91 EXPECT_EQ(count, 0); in TEST()
[all …]
|
| D | repeatable_thread_test.cc | 30 int count = 0; in TEST_F() local
35 count++; in TEST_F()
37 assert(count == 1 || prev_time + 1 * kSecond <= now); in TEST_F()
39 if (count >= kIteration) { in TEST_F()
47 while (count < kIteration) { in TEST_F()
60 std::atomic<int> count{0}; in TEST_F() local
91 [&] { count++; }, "rt_test", mock_env_.get(), 1 * kSecond, 1 * kSecond); in TEST_F()
97 ASSERT_EQ(kIteration, count.load()); in TEST_F()
|
| D | dynamic_bloom_test.cc | 204 uint32_t count = 0; in TEST_F() local
208 ++count; in TEST_F()
211 ASSERT_EQ(count, num_keys); in TEST_F()
213 assert(count > 0); in TEST_F()
215 static_cast<double>(elapsed) / count); in TEST_F()
|
| /rocksdb-6.9/third-party/folly/folly/detail/ |
| D | Futex.cpp | 56 count, /* val */ in nativeFutexWake()
74 if (epoch.count() < 0) { in timeSpecFromTimePoint()
87 struct timespec result = {secs.count(), nanos.count()}; in timeSpecFromTimePoint()
163 assert(count > 0); in emulatedFutexWake()
164 count--; in emulatedFutexWake()
166 return count > 0 ? UnparkControl::RemoveContinue in emulatedFutexWake()
221 int count, in futexWakeImpl() argument
224 return nativeFutexWake(futex, count, wakeMask); in futexWakeImpl()
226 return emulatedFutexWake(futex, count, wakeMask); in futexWakeImpl()
232 int count, in futexWakeImpl() argument
[all …]
|
| D | Futex-inl.h | 47 int count,
58 int count,
96 int futexWake(const Futex* futex, int count, uint32_t wakeMask) { in futexWake() argument
97 return futexWakeImpl(futex, count, wakeMask); in futexWake()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_test.cc | 59 unsigned int count = 0; in Java_org_rocksdb_WriteBatchTest_getContents() local
77 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
85 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
91 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
97 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
105 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
111 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
118 count++; in Java_org_rocksdb_WriteBatchTest_getContents()
126 } else if (ROCKSDB_NAMESPACE::WriteBatchInternal::Count(b) != count) { in Java_org_rocksdb_WriteBatchTest_getContents()
131 state.append(std::to_string(count)); in Java_org_rocksdb_WriteBatchTest_getContents()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl_filesnapshot.cc | 26 int count = 0; in DisableFileDeletions() local
31 count = ++disable_file_deletions_; in DisableFileDeletions()
35 "Disabled blob file deletions. count: %d", count); in DisableFileDeletions()
46 int count = 0; in EnableFileDeletions() local
52 count = --disable_file_deletions_; in EnableFileDeletions()
54 assert(count >= 0); in EnableFileDeletions()
58 count); in EnableFileDeletions()
|
| /rocksdb-6.9/monitoring/ |
| D | statistics.h | 53 virtual void setTickerCount(uint32_t ticker_type, uint64_t count) override;
55 virtual void recordTick(uint32_t ticker_type, uint64_t count) override;
106 void setTickerCountLocked(uint32_t ticker_type, uint64_t count);
125 uint64_t count = 1) {
127 statistics->recordTick(ticker_type, count);
132 uint64_t count) { in SetTickerCount() argument
134 statistics->setTickerCount(ticker_type, count); in SetTickerCount()
|
| D | statistics.cc | 277 void StatisticsImpl::setTickerCount(uint32_t tickerType, uint64_t count) { in setTickerCount() argument
280 setTickerCountLocked(tickerType, count); in setTickerCount()
283 stats_->setTickerCount(tickerType, count); in setTickerCount()
287 void StatisticsImpl::setTickerCountLocked(uint32_t tickerType, uint64_t count) { in setTickerCountLocked() argument
291 per_core_stats_.AccessAtCore(core_idx)->tickers_[tickerType] = count; in setTickerCountLocked()
315 void StatisticsImpl::recordTick(uint32_t tickerType, uint64_t count) { in recordTick() argument
318 count, std::memory_order_relaxed); in recordTick()
320 stats_->recordTick(tickerType, count); in recordTick()
378 hData.percentile99, hData.max, hData.count, hData.sum); in ToString()
|
| /rocksdb-6.9/db/ |
| D | db_compaction_filter_test.cc | 332 int count = 0; in TEST_F() local
348 count++; in TEST_F()
413 count = 0; in TEST_F()
415 count++; in TEST_F()
424 count = 0; in TEST_F()
437 count++; in TEST_F()
641 int count = 0; in TEST_F() local
656 count++; in TEST_F()
733 count++; in TEST_F()
740 count = 0; in TEST_F()
[all …]
|
| D | internal_stats.h | 171 int count; member
188 count(0) { in CompactionStats()
207 count(c) { in CompactionStats()
216 count = 0; in CompactionStats()
233 count(c.count) { in CompactionStats()
253 count = c.count;
274 this->count = 0; in Clear()
295 this->count += c.count; in Add()
316 this->count -= c.count; in Subtract()
645 int count; member
|
| D | merge_test.cc | 323 size_t min_merge, size_t count) { in testPartialMerge() argument
331 for (size_t i = 1; i <= count; i++) { in testPartialMerge()
338 if (count > max_merge) { in testPartialMerge()
343 ASSERT_EQ((count >= min_merge), (num_partial_merge_calls == 1)); in testPartialMerge()
350 for (size_t i = 1; i <= count; i++) { in testPartialMerge()
432 for (uint32_t count = min_merge - 1; count <= min_merge + 1; count++) { in runTest() local
435 testPartialMerge(&counters, db.get(), max_merge, min_merge, count); in runTest()
|
| D | db_log_iter_test.cc | 37 int& count) { in ReadRecords() argument
38 count = 0; in ReadRecords()
44 ++count; in ReadRecords()
204 int count; in TEST_F() local
205 SequenceNumber last_sequence_read = ReadRecords(iter, count); in TEST_F()
|
| D | db_wal_test.cc | 923 *count = 0; in FillData()
976 size_t count = 0; in FillData() local
978 return count; in FillData()
983 size_t count = 0; in GetData() local
986 ++count; in GetData()
989 return count; in GetData()
1311 auto validateData = [this, count]() { in TEST_F()
1312 for (size_t i = 0; i < count; i++) { in TEST_F()
1468 std::atomic<int> count{0}; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::TestFlushListener
1473 count++; in TEST_F()
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | WriteBatch.java | 347 private long count; field in WriteBatch.SavePoint
350 public SavePoint(final long size, final long count, in SavePoint() argument
353 this.count = count; in SavePoint()
359 this.count = 0; in clear()
378 return count; in getCount()
391 return (size | count | contentFlags) == 0; in isCleared()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_secondary_test.cc | 129 size_t count = 0; in TEST_F() local
131 if (0 == count) { in TEST_F()
138 ++count; in TEST_F()
141 ASSERT_EQ(2, count); in TEST_F()
180 size_t count = 0; in TEST_F() local
182 ++count; in TEST_F()
317 ++count; in TEST_F()
447 size_t count = 0; in TEST_F() local
449 ++count; in TEST_F()
519 size_t count = 0; in TEST_F() local
[all …]
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | BytewiseComparatorIntTest.java | 167 int count = 0; in testRoundtrip() local
175 count++; in testRoundtrip()
177 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtrip()
242 int count = 0; in testRoundtripCf() local
250 count++; in testRoundtripCf()
253 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtripCf()
|
| D | ReverseBytewiseComparatorIntTest.java | 170 int count = 0; in testRoundtrip() local
178 count++; in testRoundtrip()
180 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtrip()
245 int count = 0; in testRoundtripCf() local
253 count++; in testRoundtripCf()
256 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtripCf()
|
| D | IntComparatorTest.java | 166 int count = 0; in testRoundtrip() local
174 count++; in testRoundtrip()
176 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtrip()
241 int count = 0; in testRoundtripCf() local
249 count++; in testRoundtripCf()
252 assertThat(count).isEqualTo(TOTAL_KEYS); in testRoundtripCf()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | WriteBatchTest.java | 45 assertThat(batch.count()).isEqualTo(0); in emptyWriteBatch()
111 assertThat(batch.count()).isEqualTo(3); in multipleBatchOperationsDirect()
128 assertThat(b1.count()).isEqualTo(0); in testAppendOperation()
133 assertThat(b1.count()).isEqualTo(1); in testAppendOperation()
140 assertThat(b1.count()).isEqualTo(2); in testAppendOperation()
148 assertThat(b1.count()).isEqualTo(4); in testAppendOperation()
163 assertThat(batch.count()).isEqualTo(5); in blobOperation()
365 assertThat(batch2.count()).isEqualTo(batch1.count()); in data()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 44 int count; // count of elements in rep_ member
47 SavePoint() : size(0), count(0), content_flags(0) {} in SavePoint()
50 : size(_size), count(_count), content_flags(_flags) {} in SavePoint()
54 count = 0; in clear()
58 bool is_cleared() const { return (size | count | content_flags) == 0; } in is_cleared()
|
| /rocksdb-6.9/tools/ |
| D | blob_dump.cc | 58 if (display_types.count(arg_str) == 0) { in main()
67 if (display_types.count(arg_str) == 0) { in main()
78 if (display_types.count(arg_str) == 0) { in main()
|
| /rocksdb-6.9/memtable/ |
| D | hash_linklist_rep.cc | 34 explicit BucketHeader(void* n, uint32_t count) in BucketHeader()
35 : next(n), num_entries(count) {} in BucketHeader()
59 Allocator* allocator, uint32_t count) in SkipListBucketHeader()
61 count), in SkipListBucketHeader()
747 int count = 0; in GetIterator() local
756 count++; in GetIterator()
764 count++; in GetIterator()
770 keys_per_bucket_hist.Add(count); in GetIterator()
|
| /rocksdb-6.9/table/ |
| D | table_reader_bench.cc | 209 int count = 0; in TableReaderBenchmark() local
218 assert(Slice(MakeKey(r1, r2 + count, through_db)) == in TableReaderBenchmark()
221 if (++count >= r2_len) { in TableReaderBenchmark()
225 if (count != r2_len) { in TableReaderBenchmark()
228 "Expected %d but got %d\n", r2_len, count); in TableReaderBenchmark()
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | rules.ini | 162 …rocksdb.bloom.filter.useful.count:[]rocksdb.bloom.filter.full.positive.count:[]rocksdb.bloom.filte…
173 …rocksdb.bloom.filter.useful.count:[]rocksdb.bloom.filter.full.positive.count:[]rocksdb.bloom.filte…
|