Home
last modified time | relevance | path

Searched refs:tracked_at_seq (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc554 SequenceNumber tracked_at_seq = kMaxSequenceNumber; in TryLock() local
569 tracked_at_seq = iter->second.seq; in TryLock()
596 if (tracked_at_seq == kMaxSequenceNumber) { in TryLock()
604 tracked_at_seq = db_->GetLatestSequenceNumber(); in TryLock()
612 s = ValidateSnapshot(column_family, key, &tracked_at_seq); in TryLock()
644 TrackKey(cfh_id, key_str, tracked_at_seq, read_only, exclusive); in TryLock()
649 assert(info.seq <= tracked_at_seq); in TryLock()
664 SequenceNumber* tracked_at_seq) { in ValidateSnapshot() argument
668 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
680 *tracked_at_seq = snap_seq; in ValidateSnapshot()
Dwrite_prepared_txn.cc429 SequenceNumber* tracked_at_seq) { in ValidateSnapshot() argument
440 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
447 *tracked_at_seq = snap_seq; in ValidateSnapshot()
Dwrite_prepared_txn.h108 SequenceNumber* tracked_at_seq) override;
Dwrite_unprepared_txn.cc974 SequenceNumber* tracked_at_seq) { in ValidateSnapshot() argument
986 if (*tracked_at_seq <= snap_seq) { in ValidateSnapshot()
993 *tracked_at_seq = snap_seq; in ValidateSnapshot()
Dpessimistic_transaction.h195 SequenceNumber* tracked_at_seq);
Dwrite_unprepared_txn.h206 SequenceNumber* tracked_at_seq) override;