Home
last modified time | relevance | path

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

/rocksdb-6.9/utilities/transactions/
Dtransaction_lock_mgr.h46 autovector<TransactionID> m_neighbors;
121 HashMap<TransactionID, int> rev_wait_txn_map_;
123 HashMap<TransactionID, TrackedTrxInfo> wait_txn_map_;
129 bool IsLockExpired(TransactionID txn_id, const LockInfo& lock_info, Env* env,
142 autovector<TransactionID>* txn_ids);
148 const autovector<TransactionID>& wait_ids,
152 const autovector<TransactionID>& wait_ids);
154 const autovector<TransactionID>& wait_ids);
Dpessimistic_transaction.h68 static TransactionID GenTxnID();
70 TransactionID GetID() const override { return txn_id_; } in GetID()
72 std::vector<TransactionID> GetWaitingTxns(uint32_t* column_family_id, in GetWaitingTxns()
75 std::vector<TransactionID> ids(waiting_txn_ids_.size()); in GetWaitingTxns()
82 void SetWaitingTxn(autovector<TransactionID> ids, uint32_t column_family_id, in SetWaitingTxn()
157 static std::atomic<TransactionID> txn_id_counter_;
160 TransactionID txn_id_;
165 autovector<TransactionID> waiting_txn_ids_;
Dtransaction_lock_mgr.cc32 autovector<TransactionID> txn_ids;
37 LockInfo(TransactionID id, uint64_t time, bool ex) in LockInfo()
255 bool TransactionLockMgr::IsLockExpired(TransactionID txn_id, in IsLockExpired()
340 autovector<TransactionID> wait_ids; in AcquireWithTimeout()
417 const autovector<TransactionID>& wait_ids) { in DecrementWaiters()
424 const autovector<TransactionID>& wait_ids) { in DecrementWaitersImpl()
439 const autovector<TransactionID>& wait_ids, const std::string& key, in IncrementWaiters()
443 std::vector<TransactionID> queue_values(static_cast<size_t>(txn->GetDeadlockDetectDepth())); in IncrementWaiters()
525 autovector<TransactionID>* txn_ids) { in AcquireLocked()
594 TransactionID txn_id = txn->GetID(); in UnLockKey()
Dpessimistic_transaction_db.h116 void InsertExpirableTransaction(TransactionID tx_id,
118 void RemoveExpirableTransaction(TransactionID tx_id);
124 bool TryStealingExpiredTransactionLocks(TransactionID tx_id);
180 std::unordered_map<TransactionID, PessimisticTransaction*>
Dpessimistic_transaction_db.cc546 TransactionID tx_id, PessimisticTransaction* tx) { in InsertExpirableTransaction()
552 void PessimisticTransactionDB::RemoveExpirableTransaction(TransactionID tx_id) { in RemoveExpirableTransaction()
558 TransactionID tx_id) { in TryStealingExpiredTransactionLocks()
Dpessimistic_transaction.cc32 std::atomic<TransactionID> PessimisticTransaction::txn_id_counter_(1);
34 TransactionID PessimisticTransaction::GenTxnID() { in GenTxnID()
Dtransaction_test.cc281 TransactionID id1 = txn1->GetID(); in TEST_P()
289 std::vector<TransactionID> wait = txn2->GetWaitingTxns(&cf_id, &key); in TEST_P()
390 std::vector<TransactionID> expected_txns = {txn1->GetID(), txn2->GetID(), in TEST_P()
392 std::vector<TransactionID> lock_txns = cf_iterator->second.ids; in TEST_P()
565 TransactionID leaf_id = in TEST_P()
749 TransactionID curr_txn_id = txns[0]->GetID(); in TEST_P()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h25 using TransactionID = uint64_t; variable
479 virtual TransactionID GetID() const { return 0; } in GetID()
483 virtual std::vector<TransactionID> GetWaitingTxns( in GetWaitingTxns()
486 return std::vector<TransactionID>(); in GetWaitingTxns()
Dtransaction_db.h197 std::vector<TransactionID> ids;
202 TransactionID m_txn_id;
/rocksdb-6.9/java/rocksjni/
Dtransaction.cc1551 ROCKSDB_NAMESPACE::TransactionID id = txn->GetID(); in Java_org_rocksdb_Transaction_getID()
1578 std::vector<ROCKSDB_NAMESPACE::TransactionID> waiting_txns = in Java_org_rocksdb_Transaction_getWaitingTxns()
Dportal.h5625 const std::vector<TransactionID> &transaction_ids) { in newWaitingTransactions()
5710 const ROCKSDB_NAMESPACE::TransactionID transaction_id, in newDeadlockInfo()