Searched refs:txn_ (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 42 if (txn_ != nullptr) { in ~RandomTransactionInserter()
43 delete txn_; in ~RandomTransactionInserter()
52 txn_ = db->BeginTransaction(write_options_, txn_options, txn_); in TransactionDBInsert()
59 assert(txn_->SetName(name).ok()); in TransactionDBInsert()
62 bool take_snapshot = txn_->GetSnapshot() == nullptr || rand_->OneIn(2); in TransactionDBInsert()
64 txn_->SetSnapshot(); in TransactionDBInsert()
65 read_options_.snapshot = txn_->GetSnapshot(); in TransactionDBInsert()
67 auto res = DoInsert(db, txn_, false); in TransactionDBInsert()
207 s = txn_->GetCommitTimeWriteBatch()->Put("cat", "dog"); in DoInsert()
|
| D | transaction_test_util.h | 120 Transaction* txn_ = nullptr; variable
|
| /rocksdb-6.9/utilities/transactions/ |
| D | optimistic_transaction.h | 87 : txn_(txn) {} in OptimisticTransactionCallback()
90 return txn_->CheckTransactionForConflicts(db); in Callback()
96 OptimisticTransaction* txn_;
|
| D | write_unprepared_txn.cc | 193 WriteUnpreparedTxn* txn_; in RebuildFromWriteBatch() member
197 : txn_(txn), rollback_merge_operands_(rollback_merge_operands) {} in RebuildFromWriteBatch()
200 txn_->TrackKey(cf, key.ToString(), kMaxSequenceNumber, in RebuildFromWriteBatch()
206 txn_->TrackKey(cf, key.ToString(), kMaxSequenceNumber, in RebuildFromWriteBatch()
212 txn_->TrackKey(cf, key.ToString(), kMaxSequenceNumber, in RebuildFromWriteBatch()
219 txn_->TrackKey(cf, key.ToString(), kMaxSequenceNumber, in RebuildFromWriteBatch()
291 WriteUnpreparedTxn* txn_; in FlushWriteBatchToDBInternal() member
295 : txn_(txn), rollback_merge_operands_(rollback_merge_operands) {} in FlushWriteBatchToDBInternal()
299 if (txn_->tracked_keys_[cf].count(str) == 0) { in FlushWriteBatchToDBInternal()
300 txn_->untracked_keys_[cf].push_back(str); in FlushWriteBatchToDBInternal()
|
| D | transaction_base.cc | 787 Transaction* txn_; in RebuildFromWriteBatch() member
790 : txn_(txn), db_(db) { in RebuildFromWriteBatch()
791 assert(dynamic_cast<TransactionBaseImpl*>(txn_) != nullptr); in RebuildFromWriteBatch()
795 return txn_->Put(db_->GetColumnFamilyHandle(cf), key, val); in RebuildFromWriteBatch()
799 return txn_->Delete(db_->GetColumnFamilyHandle(cf), key); in RebuildFromWriteBatch()
803 return txn_->SingleDelete(db_->GetColumnFamilyHandle(cf), key); in RebuildFromWriteBatch()
807 return txn_->Merge(db_->GetColumnFamilyHandle(cf), key, val); in RebuildFromWriteBatch()
|