Home
last modified time | relevance | path

Searched refs:num_reads (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dtransaction_base.cc155 uint32_t num_reads = key_iter.second.num_reads; in RollbackToSavePoint() local
163 if (num_reads > 0) { in RollbackToSavePoint()
164 assert(tracked_keys_iter->second.num_reads >= num_reads); in RollbackToSavePoint()
165 tracked_keys_iter->second.num_reads -= num_reads; in RollbackToSavePoint()
662 iter->second.num_reads++; in TrackKey()
684 uint32_t num_reads = key_iter.second.num_reads; in GetTrackedKeysSinceSavePoint() local
689 assert(total_key_info->second.num_reads >= num_reads); in GetTrackedKeysSinceSavePoint()
692 if (total_key_info->second.num_reads == num_reads && in GetTrackedKeysSinceSavePoint()
746 savepoint_iter->second.num_reads--; in UndoGetForUpdate()
770 if (key_iter->second.num_reads > 0) { in UndoGetForUpdate()
[all …]
Dtransaction_util.h28 uint32_t num_reads; member
33 : seq(seq_no), num_writes(0), num_reads(0), exclusive(false) {} in TransactionKeyMapInfo()
38 num_reads += info.num_reads; in Merge()
/rocksdb-6.9/env/
Denv_test.cc1211 const int num_reads = rnd.Uniform(512) + 1; in TEST_F() local
1218 int odd = (attempt < 15) ? num_reads / 2 : 4; in TEST_F()
1233 for (int i = 0; i < num_reads; i++) { in TEST_F()
1249 ASSERT_EQ(num_reads, lens.size()); in TEST_F()
1253 scratches.reserve(num_reads); in TEST_F()
1254 std::vector<ReadRequest> reqs(num_reads); in TEST_F()
1268 for (int i = 0; i < num_reads; ++i) { in TEST_F()