| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.cc | 24 SequenceNumber min_uncommitted) { in CheckKeyForConflicts() argument
41 snap_checker, min_uncommitted); in CheckKeyForConflicts()
54 SequenceNumber min_uncommitted) { in CheckKey() argument
59 assert(min_uncommitted == kMaxSequenceNumber || snap_checker != nullptr); in CheckKey()
82 } else if (snap_seq < earliest_seq || min_uncommitted <= earliest_seq) { in CheckKey()
118 (min_uncommitted == kMaxSequenceNumber) ? snap_seq : min_uncommitted; in CheckKey()
|
| D | write_prepared_txn_db.cc | 229 SequenceNumber min_uncommitted, snap_seq; in Get() local
231 AssignMinMaxSeqs(options.snapshot, &min_uncommitted, &snap_seq); in Get()
232 WritePreparedTxnReadCallback callback(this, snap_seq, min_uncommitted, in Get()
307 SequenceNumber min_uncommitted) in IteratorState()
327 SequenceNumber min_uncommitted = 0; in NewIterator() local
330 min_uncommitted = in NewIterator()
339 min_uncommitted = in NewIterator()
363 SequenceNumber min_uncommitted = 0; in NewIterators() local
375 min_uncommitted = in NewIterators()
677 auto min_uncommitted = WritePreparedTxnDB::SmallestUnCommittedSeq(); in GetSnapshotInternal() local
[all …]
|
| D | write_prepared_txn.cc | 48 SequenceNumber min_uncommitted, snap_seq; in MultiGet() local
50 wpt_db_->AssignMinMaxSeqs(options.snapshot, &min_uncommitted, &snap_seq); in MultiGet()
51 WritePreparedTxnReadCallback callback(wpt_db_, snap_seq, min_uncommitted, in MultiGet()
68 SequenceNumber min_uncommitted, snap_seq; in Get() local
70 wpt_db_->AssignMinMaxSeqs(options.snapshot, &min_uncommitted, &snap_seq); in Get()
71 WritePreparedTxnReadCallback callback(wpt_db_, snap_seq, min_uncommitted, in Get()
432 SequenceNumber min_uncommitted = in ValidateSnapshot() local
452 WritePreparedTxnReadCallback snap_checker(wpt_db_, snap_seq, min_uncommitted, in ValidateSnapshot()
456 &snap_checker, min_uncommitted); in ValidateSnapshot()
|
| D | write_unprepared_txn.cc | 849 SequenceNumber min_uncommitted = in RollbackToSavePointInternal() local
854 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in RollbackToSavePointInternal()
912 SequenceNumber min_uncommitted, snap_seq; in MultiGet() local
914 wupt_db_->AssignMinMaxSeqs(options.snapshot, &min_uncommitted, &snap_seq); in MultiGet()
915 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in MultiGet()
932 SequenceNumber min_uncommitted, snap_seq; in Get() local
934 wupt_db_->AssignMinMaxSeqs(options.snapshot, &min_uncommitted, &snap_seq); in Get()
935 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in Get()
978 SequenceNumber min_uncommitted = in ValidateSnapshot() local
999 wupt_db_, snap_seq, min_uncommitted, unprep_seqs_, kBackedByDBSnapshot); in ValidateSnapshot()
[all …]
|
| D | write_prepared_txn_db.h | 114 uint64_t min_uncommitted = kMinUnCommittedSeq,
119 prep_seq, snapshot_seq, min_uncommitted);
120 assert(min_uncommitted >= kMinUnCommittedSeq);
142 if (prep_seq < min_uncommitted) {
147 prep_seq, snapshot_seq, 1, min_uncommitted);
669 SequenceNumber min_uncommitted) { in EnhanceSnapshot() argument
671 assert(min_uncommitted <= snapshot->number_ + 1); in EnhanceSnapshot()
672 snapshot->min_uncommitted_ = min_uncommitted; in EnhanceSnapshot()
808 SequenceNumber min_uncommitted, in WritePreparedTxnReadCallback() argument
810 : ReadCallback(snapshot, min_uncommitted), in WritePreparedTxnReadCallback()
|
| D | write_unprepared_txn_db.cc | 368 SequenceNumber min_uncommitted, WriteUnpreparedTxn* txn) in IteratorState()
369 : callback(txn_db, sequence, min_uncommitted, txn->unprep_seqs_, in IteratorState()
392 SequenceNumber min_uncommitted = 0; in NewIterator() local
453 min_uncommitted = in NewIterator()
459 new IteratorState(this, snapshot_seq, own_snapshot, min_uncommitted, txn); in NewIterator()
|
| D | transaction_util.h | 70 SequenceNumber min_uncommitted = kMaxSequenceNumber);
98 SequenceNumber min_uncommitted = kMaxSequenceNumber);
|
| D | write_unprepared_txn.h | 58 SequenceNumber min_uncommitted, in WriteUnpreparedTxnReadCallback() argument
65 : ReadCallback(CalcMaxVisibleSeq(unprep_seqs, snapshot), min_uncommitted), in WriteUnpreparedTxnReadCallback()
|
| D | write_prepared_transaction_test.cc | 1635 auto min_uncommitted = wp_db->SmallestUnCommittedSeq(); in TEST_P() local
1636 ASSERT_LE(min_uncommitted, (*txns.begin())->GetId()); in TEST_P()
2007 uint64_t min_uncommitted = kMinUnCommittedSeq; in TEST_P() local
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()
|
| /rocksdb-6.9/db/ |
| D | read_callback.h | 16 ReadCallback(SequenceNumber last_visible_seq, SequenceNumber min_uncommitted) in ReadCallback() argument
17 : max_visible_seq_(last_visible_seq), min_uncommitted_(min_uncommitted) {} in ReadCallback()
|