Home
last modified time | relevance | path

Searched refs:PessimisticTransaction (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc34 TransactionID PessimisticTransaction::GenTxnID() { in GenTxnID()
38 PessimisticTransaction::PessimisticTransaction( in PessimisticTransaction() function in ROCKSDB_NAMESPACE::PessimisticTransaction
93 PessimisticTransaction::~PessimisticTransaction() { in ~PessimisticTransaction()
103 void PessimisticTransaction::Clear() { in Clear()
108 void PessimisticTransaction::Reinitialize( in Reinitialize()
118 bool PessimisticTransaction::IsExpired() const { in IsExpired()
172 Status PessimisticTransaction::Prepare() { in Prepare()
263 Status PessimisticTransaction::Commit() { in Commit()
398 Status PessimisticTransaction::Rollback() { in Rollback()
662 Status PessimisticTransaction::ValidateSnapshot( in ValidateSnapshot()
[all …]
Dtransaction_lock_mgr.h76 Status TryLock(PessimisticTransaction* txn, uint32_t column_family_id,
81 void UnLock(const PessimisticTransaction* txn, const TransactionKeyMap* keys,
83 void UnLock(PessimisticTransaction* txn, uint32_t column_family_id,
134 Status AcquireWithTimeout(PessimisticTransaction* txn, LockMap* lock_map,
144 void UnLockKey(const PessimisticTransaction* txn, const std::string& key,
147 bool IncrementWaiters(const PessimisticTransaction* txn,
151 void DecrementWaiters(const PessimisticTransaction* txn,
153 void DecrementWaitersImpl(const PessimisticTransaction* txn,
Dpessimistic_transaction.h38 class PessimisticTransaction : public TransactionBaseImpl {
40 PessimisticTransaction(TransactionDB* db, const WriteOptions& write_options,
44 PessimisticTransaction(const PessimisticTransaction&) = delete;
45 void operator=(const PessimisticTransaction&) = delete;
47 virtual ~PessimisticTransaction();
201 class WriteCommittedTxn : public PessimisticTransaction {
Dpessimistic_transaction_db.h79 static_cast_with_check<PessimisticTransaction, Transaction>(txn); in WriteWithConcurrencyControl()
100 Status TryLock(PessimisticTransaction* txn, uint32_t cfh_id,
103 void UnLock(PessimisticTransaction* txn, const TransactionKeyMap* keys);
104 void UnLock(PessimisticTransaction* txn, uint32_t cfh_id,
117 PessimisticTransaction* tx);
180 std::unordered_map<TransactionID, PessimisticTransaction*>
Dtransaction_lock_mgr.cc286 Status TransactionLockMgr::TryLock(PessimisticTransaction* txn, in TryLock()
315 PessimisticTransaction* txn, LockMap* lock_map, LockMapStripe* stripe, in AcquireWithTimeout()
416 const PessimisticTransaction* txn, in DecrementWaiters()
423 const PessimisticTransaction* txn, in DecrementWaitersImpl()
438 const PessimisticTransaction* txn, in IncrementWaiters()
587 void TransactionLockMgr::UnLockKey(const PessimisticTransaction* txn, in UnLockKey()
626 void TransactionLockMgr::UnLock(PessimisticTransaction* txn, in UnLock()
649 void TransactionLockMgr::UnLock(const PessimisticTransaction* txn, in UnLock()
Dpessimistic_transaction_db.cc397 Status PessimisticTransactionDB::TryLock(PessimisticTransaction* txn, in TryLock()
404 void PessimisticTransactionDB::UnLock(PessimisticTransaction* txn, in UnLock()
409 void PessimisticTransactionDB::UnLock(PessimisticTransaction* txn, in UnLock()
546 TransactionID tx_id, PessimisticTransaction* tx) { in InsertExpirableTransaction()
565 PessimisticTransaction& tx = *(tx_it->second); in TryStealingExpiredTransactionLocks()
573 static_cast_with_check<PessimisticTransaction, Transaction>(txn); in ReinitializeTransaction()
Dwrite_unprepared_txn.cc83 PessimisticTransaction::Initialize(txn_options); in Initialize()
810 PessimisticTransaction::SetSavePoint(); in SetSavePoint()
822 Status s = PessimisticTransaction::RollbackToSavePoint(); in RollbackToSavePoint()
871 s = PessimisticTransaction::RollbackToSavePoint(); in RollbackToSavePointInternal()
886 Status s = PessimisticTransaction::PopSavePoint(); in PopSavePoint()
898 Status s = PessimisticTransaction::PopSavePoint(); in PopSavePoint()
Dwrite_prepared_txn.cc30 : PessimisticTransaction(txn_db, write_options, txn_options, false), in WritePreparedTxn()
39 PessimisticTransaction::Initialize(txn_options); in Initialize()
466 auto ret = PessimisticTransaction::RebuildFromWriteBatch(src_batch); in RebuildFromWriteBatch()
Dwrite_prepared_txn.h41 class WritePreparedTxn : public PessimisticTransaction {
Dtransaction_test.cc249 auto pes_txn2 = dynamic_cast<PessimisticTransaction*>(txn2); in TEST_P()
/rocksdb-6.9/db/db_impl/
Ddb_impl.h1158 friend class PessimisticTransaction; variable