Home
last modified time | relevance | path

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

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.h127 if (prep_seq == 0) {
132 prep_seq, snapshot_seq, 1);
135 if (snapshot_seq < prep_seq) {
139 prep_seq, snapshot_seq, 0);
185 if (exist && prep_seq == cached.prep_seq) {
245 if (exist && prep_seq == cached.prep_seq) {
322 prep_seq, snapshot_seq, 0);
342 uint64_t prep_seq; member
347 return prep_seq == rhs.prep_seq && commit_seq == rhs.commit_seq;
912 prep_seq_(prep_seq), in db_()
[all …]
Dwrite_prepared_txn_db.cc486 assert(evicted.prep_seq != prepare_seq); in AddCommitted()
490 evicted.prep_seq, evicted.commit_seq, prev_max); in AddCommitted()
516 if (dp == evicted.prep_seq) { in AddCommitted()
523 evicted.prep_seq, evicted.commit_seq); in AddCommitted()
898 if (!MaybeUpdateOldCommitMap(evicted.prep_seq, evicted.commit_seq, in CheckAgainstSnapshots()
918 evicted.prep_seq, evicted.commit_seq, cnt); in CheckAgainstSnapshots()
926 if (!MaybeUpdateOldCommitMap(evicted.prep_seq, evicted.commit_seq, in CheckAgainstSnapshots()
941 const uint64_t& prep_seq, const uint64_t& commit_seq, in MaybeUpdateOldCommitMap() argument
951 if (prep_seq <= snapshot_seq) { // overlapping range in MaybeUpdateOldCommitMap()
956 snapshot_seq, prep_seq, commit_seq); in MaybeUpdateOldCommitMap()
[all …]
Dwrite_prepared_transaction_test.cc720 ASSERT_NE(c.prep_seq + size, e.prep_seq); in TEST_P()
1016 auto prep_seq = ++seq; in TEST_P() local
1017 wp_db->AddPrepared(prep_seq); in TEST_P()
1023 wp_db->AddCommitted(prep_seq, commit_seq); in TEST_P()
1024 wp_db->RemovePrepared(prep_seq); in TEST_P()
1029 prep_seq = ++seq; in TEST_P()
1030 wp_db->AddPrepared(prep_seq); in TEST_P()
1039 wp_db->RemovePrepared(prep_seq); in TEST_P()
1042 prep_seq = ++seq; in TEST_P()
1043 wp_db->AddPrepared(prep_seq); in TEST_P()
[all …]