| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_util.cc | 23 SequenceNumber snap_seq, bool cache_only, ReadCallback* snap_checker, in CheckKeyForConflicts() argument
40 result = CheckKey(db_impl, sv, earliest_seq, snap_seq, key, cache_only, in CheckKeyForConflicts()
51 SequenceNumber snap_seq, in CheckKey() argument
80 ToString(snap_seq)); in CheckKey()
82 } else if (snap_seq < earliest_seq || min_uncommitted <= earliest_seq) { in CheckKey()
100 snap_seq, earliest_seq); in CheckKey()
118 (min_uncommitted == kMaxSequenceNumber) ? snap_seq : min_uncommitted; in CheckKey()
127 ? snap_seq < seq in CheckKey()
|
| 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()
57 !wpt_db_->ValidateSnapshot(snap_seq, backed_by_snapshot))) { 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()
264 DBImpl* db, WritePreparedTxnDB* wpt_db, SequenceNumber snap_seq, in RollbackInternal()
436 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot() local
440 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
[all …]
|
| D | write_unprepared_txn.cc | 853 SequenceNumber snap_seq = roptions.snapshot->GetSequenceNumber(); in RollbackToSavePointInternal() local
854 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in RollbackToSavePointInternal()
912 SequenceNumber min_uncommitted, snap_seq; in MultiGet() local
915 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in MultiGet()
921 !wupt_db_->ValidateSnapshot(snap_seq, backed_by_snapshot))) { in MultiGet()
932 SequenceNumber min_uncommitted, snap_seq; in Get() local
935 WriteUnpreparedTxnReadCallback callback(wupt_db_, snap_seq, min_uncommitted, in Get()
940 wupt_db_->ValidateSnapshot(snap_seq, backed_by_snapshot))) { in Get()
982 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot() local
986 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
[all …]
|
| 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()
681 SequenceNumber snap_seq = snap_impl->GetSequenceNumber(); in GetSnapshotInternal() local
684 if (UNLIKELY(snap_seq != 0 && snap_seq <= future_max_evicted_seq_)) { in GetSnapshotInternal()
756 const SequenceNumber snap_seq) { in ReleaseSnapshotInternal() argument
759 if (snap_seq <= max_evicted_seq_.load(std::memory_order_acquire)) { in ReleaseSnapshotInternal()
768 snap_seq); in ReleaseSnapshotInternal()
770 auto prep_set_entry = old_commit_map_.find(snap_seq); in ReleaseSnapshotInternal()
776 snap_seq); in ReleaseSnapshotInternal()
[all …]
|
| D | transaction_util.h | 68 const std::string& key, SequenceNumber snap_seq, bool cache_only,
95 SequenceNumber earliest_seq, SequenceNumber snap_seq,
|
| D | write_prepared_transaction_test.cc | 1483 auto snap_seq = snap->GetSequenceNumber(); in TEST_P() local
1958 auto snap_seq = snap->GetSequenceNumber(); in TEST_P() local
1959 ASSERT_GT(snap_seq, 0); in TEST_P()
1969 ASSERT_FALSE(wp_db->IsInSnapshot(snap_seq + 1, snap_seq)); in TEST_P()
1976 snap_seq = snap->GetSequenceNumber(); in TEST_P()
1985 ASSERT_FALSE(wp_db->IsInSnapshot(snap_seq + 1, snap_seq)); in TEST_P()
2006 SequenceNumber snap_seq; in TEST_P() local
2011 snap_seq = snap1->GetSequenceNumber(); in TEST_P()
2012 ASSERT_LE(seq, snap_seq); in TEST_P()
2019 snap_seq = snap1->GetSequenceNumber(); in TEST_P()
[all …]
|
| D | pessimistic_transaction.cc | 667 SequenceNumber snap_seq = snapshot_->GetSequenceNumber(); in ValidateSnapshot() local
668 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
680 *tracked_at_seq = snap_seq; in ValidateSnapshot()
686 db_impl_, cfh, key.ToString(), snap_seq, false /* cache_only */); in ValidateSnapshot()
|
| D | write_prepared_txn_db.h | 463 const SequenceNumber snap_seq, const SnapshotBackup backed_by_snapshot,
680 void ReleaseSnapshotInternal(const SequenceNumber snap_seq);
1094 const SequenceNumber snap_seq, const SnapshotBackup backed_by_snapshot, in ValidateSnapshot() argument
1103 if (UNLIKELY(snap_seq <= max && snap_seq != 0)) { in ValidateSnapshot()
|
| D | write_unprepared_txn_db.cc | 75 DBImpl* db, SequenceNumber snap_seq, WriteBatch* dst_batch, in RollbackRecoveredTransaction()
80 callback(snap_seq), in RollbackRecoveredTransaction()
|