Home
last modified time | relevance | path

Searched refs:cnt (Results 1 – 12 of 12) sorted by relevance

/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader_test.cc158 int cnt = 0; in CheckIterator() local
161 ASSERT_TRUE(Slice(keys[cnt]) == it->key()); in CheckIterator()
163 ++cnt; in CheckIterator()
169 cnt = static_cast<int>(num_items) - 1; in CheckIterator()
173 ASSERT_TRUE(Slice(keys[cnt]) == it->key()); in CheckIterator()
175 --cnt; in CheckIterator()
178 ASSERT_EQ(cnt, -1); in CheckIterator()
180 cnt = static_cast<int>(num_items) / 2; in CheckIterator()
181 it->Seek(keys[cnt]); in CheckIterator()
184 ASSERT_TRUE(Slice(keys[cnt]) == it->key()); in CheckIterator()
[all …]
/rocksdb-6.9/db/
Dlogs_with_prep_tracker.cc32 rit->cnt++; in MarkLogAsContainingPrepSection()
53 completed_it->second < it->cnt) { in FindMinLogContainingOutstandingPrep()
57 completed_it->second == it->cnt); in FindMinLogContainingOutstandingPrep()
Dlogs_with_prep_tracker.h42 uint64_t cnt; // number of prepared sections in the log member
Ddb_test.cc3867 const size_t cnt = 100; in TEST_F() local
3879 for (size_t i = 0; i < cnt; i++) { in TEST_F()
3886 for (size_t i = cnt; i < 2 * cnt; i++) { in TEST_F()
3895 for (size_t i = 0; i < cnt * 100; i++) { // FlushWAL is faster than Put in TEST_F()
3905 for (size_t i = 0; i < cnt; i++) { in TEST_F()
6444 int cnt = ++flushes_done; in TEST_F() local
6445 fprintf(stderr, "Flushed %d times\n", cnt); in TEST_F()
/rocksdb-6.9/utilities/transactions/
Dwrite_unprepared_txn_db.cc286 auto cnt = batch_info.batch_cnt_ ? batch_info.batch_cnt_ : 1; in Initialize() local
289 ordered_seq_cnt[seq] = cnt; in Initialize()
291 wupt->unprep_seqs_[seq] = cnt; in Initialize()
311 auto cnt = seq_cnt.second; in Initialize() local
312 for (size_t i = 0; i < cnt; i++) { in Initialize()
Dwrite_prepared_txn_db.cc42 auto cnt = batch_info.batch_cnt_ ? batch_info.batch_cnt_ : 1; in Initialize() local
43 ordered_seq_cnt[seq] = cnt; in Initialize()
48 auto cnt = seq_cnt.second; in Initialize() local
49 for (size_t i = 0; i < cnt; i++) { in Initialize()
877 auto cnt = snapshots_total_.load(std::memory_order_acquire); in CheckAgainstSnapshots() local
886 size_t ip1 = std::min(cnt, SNAPSHOT_CACHE_SIZE); in CheckAgainstSnapshots()
912 if (UNLIKELY(SNAPSHOT_CACHE_SIZE < cnt && search_larger_list)) { in CheckAgainstSnapshots()
918 evicted.prep_seq, evicted.commit_seq, cnt); in CheckAgainstSnapshots()
Dwrite_prepared_transaction_test.cc1600 const int cnt = 100; in TEST_P() local
1601 for (int i = 0; i < cnt; i++) { in TEST_P()
1614 for (int i = 0; i < cnt; i++) { in TEST_P()
1615 uint32_t index = rnd.Uniform(cnt - i); in TEST_P()
Dtransaction_test.cc6098 size_t cnt = 0; in TEST_P() local
6103 cnt++; in TEST_P()
6105 ASSERT_EQ(cnt, 2); in TEST_P()
6106 cnt = 0; in TEST_P()
6111 cnt++; in TEST_P()
6113 ASSERT_EQ(cnt, 2); in TEST_P()
/rocksdb-6.9/file/
Ddelete_scheduler.cc167 int cnt = 0; in MarkAsTrash() local
177 *trash_file = file_path + std::to_string(cnt) + kTrashExtension; in MarkAsTrash()
182 cnt++; in MarkAsTrash()
/rocksdb-6.9/tools/
Dtrace_analyzer_test.cc121 void CheckFileContent(const std::vector<std::string>& cnt, in CheckFileContent() argument
144 ASSERT_EQ(cnt.size(), result.size()); in CheckFileContent()
147 ASSERT_EQ(result[i], cnt[i]); in CheckFileContent()
149 ASSERT_EQ(result[i][0], cnt[i][0]); in CheckFileContent()
/rocksdb-6.9/table/block_based/
Dpartitioned_filter_block_test.cc284 int cnt = 0; in CountNumOfIndexPartitions() local
287 cnt++; in CountNumOfIndexPartitions()
289 return cnt - 1; // 1 is 2nd level index in CountNumOfIndexPartitions()
/rocksdb-6.9/db/db_impl/
Ddb_secondary_test.cc587 int cnt = 0; in TEST_F() local
588 for (iter->SeekToFirst(); iter->Valid(); iter->Next(), ++cnt) { in TEST_F()
589 ASSERT_EQ("key" + std::to_string(cnt), iter->key().ToString()); in TEST_F()