Lines Matching refs:seq
169 for (size_t seq = 1; seq <= t_cnt; seq++) { in TEST() local
175 heap.push(seq); in TEST()
176 last.store(seq); in TEST()
183 auto seq = i; in TEST() local
186 } while (last.load() < seq); in TEST()
188 heap.erase(seq); in TEST()
344 void TakeSnapshot(SequenceNumber seq) { snapshots_.push_back(seq); } in TakeSnapshot() argument
1014 SequenceNumber seq = 0; in TEST_P() local
1016 auto prep_seq = ++seq; in TEST_P()
1018 auto prep_seq2 = ++seq; in TEST_P()
1020 auto snap_seq1 = seq; in TEST_P()
1022 auto commit_seq = ++seq; in TEST_P()
1025 auto commit_seq2 = ++seq; in TEST_P()
1029 prep_seq = ++seq; in TEST_P()
1031 auto snap_seq2 = seq; in TEST_P()
1033 seq++; in TEST_P()
1034 auto snap_seq3 = seq; in TEST_P()
1036 seq++; in TEST_P()
1037 commit_seq = ++seq; in TEST_P()
1042 prep_seq = ++seq; in TEST_P()
1044 commit_seq = ++seq; in TEST_P()
1325 const SequenceNumber seq = txn0->GetId(); // is also prepare seq in TEST_P() local
1342 ASSERT_LT(seq, last_seq); in TEST_P()
1344 ASSERT_LT(last_seq - seq, wp_db->INC_STEP_FOR_MAX_EVICTED); in TEST_P()
1347 const SequenceNumber overwrite_seq = seq + wp_db->COMMIT_CACHE_SIZE; in TEST_P()
1680 auto seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P() local
1682 exp_seq = seq; in TEST_P()
1761 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
1762 ASSERT_EQ(exp_seq, seq); in TEST_P()
1772 seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P()
1773 ASSERT_LE(exp_seq, seq + with_empty_commits); in TEST_P()
1777 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
1778 ASSERT_LE(exp_seq, seq + with_empty_commits); in TEST_P()
1785 seq = db_impl->GetLatestSequenceNumber(); in TEST_P()
1786 ASSERT_LE(exp_seq, seq + with_empty_commits); in TEST_P()
1961 for (SequenceNumber seq = 0; in TEST_P() local
1962 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
1963 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq)); in TEST_P()
1977 for (SequenceNumber seq = 0; in TEST_P() local
1978 seq <= wp_db->max_evicted_seq_ && seq != prepare_seq; seq++) { in TEST_P()
1979 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq)); in TEST_P()
2002 const SequenceNumber seq = 1; in TEST_P() local
2004 size_t overwrite_seq = wp_db->COMMIT_CACHE_SIZE + seq; in TEST_P()
2012 ASSERT_LE(seq, snap_seq); in TEST_P()
2015 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq, min_uncommitted, &released)); in TEST_P()
2023 wp_db->IsInSnapshot(seq, snap_seq + 1, min_uncommitted, &released)); in TEST_P()
2030 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq, min_uncommitted, &released)); in TEST_P()
2037 wp_db->IsInSnapshot(seq, snap_seq + 1, min_uncommitted, &released)); in TEST_P()
2046 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq, min_uncommitted, &released)); in TEST_P()
2052 wp_db->IsInSnapshot(seq, snap_seq + 1, min_uncommitted, &released)); in TEST_P()
2059 ASSERT_TRUE(wp_db->IsInSnapshot(seq, snap_seq, min_uncommitted, &released)); in TEST_P()
2087 uint64_t seq = 0; in TEST_P() local
2114 seq++; in TEST_P()
2115 wp_db->AddPrepared(seq); in TEST_P()
2116 prepared.insert(seq); in TEST_P()
2120 seq++; in TEST_P()
2121 cur_txn = seq; in TEST_P()
2124 seq++; in TEST_P()
2125 wp_db->AddCommitted(cur_txn, seq); in TEST_P()
2127 commit_seqs.insert(seq); in TEST_P()
2136 wp_db->TakeSnapshot(seq); in TEST_P()
2143 snapshot = seq; in TEST_P()
2153 s <= seq && commit_seqs.find(s) == commit_seqs.end(); s++) { in TEST_P()
2161 max_snapshots, max_gap, seq, in TEST_P()
2175 wp_db->AddCommitted(cur_txn, seq); in TEST_P()
2179 wp_db->AddCommitted(p, seq); in TEST_P()
2333 uint64_t seq = 0; in TEST_P() local
2338 seq++; // one for the key/value in TEST_P()
2339 KeyVersion kv = {"foo", v, seq, kTypeValue}; in TEST_P()
2341 seq++; // one for the commit in TEST_P()
3075 auto seq = db_impl->TEST_GetLastVisibleSequence(); in TEST_P() local
3077 while (wp_db->max_evicted_seq_ < seq && tries < 50) { in TEST_P()