Home
last modified time | relevance | path

Searched refs:GetCommitTimeWriteBatch (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc295 if (WriteBatchInternal::Count(GetCommitTimeWriteBatch()) > 0) { in Commit()
375 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal()
Dtransaction_base.h253 WriteBatch* GetCommitTimeWriteBatch() override;
Dwrite_prepared_txn.cc145 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal()
Dtransaction_base.cc832 WriteBatch* TransactionBaseImpl::GetCommitTimeWriteBatch() { in GetCommitTimeWriteBatch() function in ROCKSDB_NAMESPACE::TransactionBaseImpl
Dwrite_unprepared_txn.cc540 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal()
Dtransaction_test.cc865 ASSERT_OK(txn1->GetCommitTimeWriteBatch()->Put("cat", "dog")); in TEST_P()
949 txn->GetCommitTimeWriteBatch()->Put(Slice("gtid"), Slice("dogs")); in TEST_P()
950 txn->GetCommitTimeWriteBatch()->Put(Slice("gtid2"), Slice("cats")); in TEST_P()
1148 txn2->GetCommitTimeWriteBatch()->Put(Slice("foo"), Slice("bar")); in TEST_P()
5753 auto cb = txn0->GetCommitTimeWriteBatch(); in TEST_P()
/rocksdb-6.9/include/rocksdb/utilities/
Dtransaction.h469 virtual WriteBatch* GetCommitTimeWriteBatch() = 0;
/rocksdb-6.9/test_util/
Dtransaction_test_util.cc207 s = txn_->GetCommitTimeWriteBatch()->Put("cat", "dog"); in DoInsert()
/rocksdb-6.9/java/rocksjni/
Dtransaction.cc1481 return reinterpret_cast<jlong>(txn->GetCommitTimeWriteBatch()); in Java_org_rocksdb_Transaction_getCommitTimeWriteBatch()