Home
last modified time | relevance | path

Searched refs:working_batch (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc145 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
146 const bool empty = working_batch->Count() == 0; in CommitInternal()
147 WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
154 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
165 auto s = working_batch->Iterate(&counter); in CommitInternal()
191 auto s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
Dpessimistic_transaction.cc375 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
376 WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
379 working_batch->MarkWalTerminationPoint(); in CommitInternal()
384 WriteBatchInternal::Append(working_batch, GetWriteBatch()->GetWriteBatch()); in CommitInternal()
388 db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
Dwrite_unprepared_txn.cc540 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
541 const bool empty = working_batch->Count() == 0; in CommitInternal()
542 WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
549 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
558 auto s = working_batch->Iterate(&counter); in CommitInternal()
584 auto s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()