Home
last modified time | relevance | path

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

12

/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn.cc151 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
152 const bool empty = working_batch->Count() == 0; in CommitInternal()
153 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
161 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
172 s = working_batch->Iterate(&counter); in CommitInternal()
198 s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
H A Dpessimistic_transaction.cc381 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
382 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
386 working_batch->MarkWalTerminationPoint(); in CommitInternal()
391 s = WriteBatchInternal::Append(working_batch, in CommitInternal()
396 s = db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
/dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/utilities/transactions/
H A 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()
H A 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()
H A Dwrite_unprepared_txn.cc481 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
482 const bool empty = working_batch->Count() == 0; in CommitInternal()
483 WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
490 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
499 auto s = working_batch->Iterate(&counter); in CommitInternal()
525 auto s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn.cc151 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
152 const bool empty = working_batch->Count() == 0; in CommitInternal()
153 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
161 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
172 s = working_batch->Iterate(&counter); in CommitInternal()
198 s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
H A Dpessimistic_transaction.cc381 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
382 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
386 working_batch->MarkWalTerminationPoint(); in CommitInternal()
391 s = WriteBatchInternal::Append(working_batch, in CommitInternal()
396 s = db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
/dports/databases/rocksdb/rocksdb-6.26.1/utilities/transactions/
H A Dwrite_prepared_txn.cc151 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
152 const bool empty = working_batch->Count() == 0; in CommitInternal()
153 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
161 WriteBatchInternal::SetAsLatestPersistentState(working_batch); in CommitInternal()
172 s = working_batch->Iterate(&counter); in CommitInternal()
198 s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
H A Dpessimistic_transaction.cc382 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
383 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
387 working_batch->MarkWalTerminationPoint(); in CommitInternal()
392 s = WriteBatchInternal::Append(working_batch, in CommitInternal()
397 s = db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
/dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/
H A Dwrite_prepared_txn.cc151 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
152 const bool empty = working_batch->Count() == 0; in CommitInternal()
153 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
161 WriteBatchInternal::SetAsLatestPersistentState(working_batch); in CommitInternal()
172 s = working_batch->Iterate(&counter); in CommitInternal()
198 s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
H A Dpessimistic_transaction.cc382 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
383 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
387 working_batch->MarkWalTerminationPoint(); in CommitInternal()
392 s = WriteBatchInternal::Append(working_batch, in CommitInternal()
397 s = db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/
H A Dwrite_prepared_txn.cc151 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
152 const bool empty = working_batch->Count() == 0; in CommitInternal()
153 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
161 WriteBatchInternal::SetAsLastestPersistentState(working_batch); in CommitInternal()
172 s = working_batch->Iterate(&counter); in CommitInternal()
198 s = db_impl_->WriteImpl(write_options_, working_batch, nullptr, nullptr, in CommitInternal()
H A Dpessimistic_transaction.cc381 WriteBatch* working_batch = GetCommitTimeWriteBatch(); in CommitInternal() local
382 auto s = WriteBatchInternal::MarkCommit(working_batch, name_); in CommitInternal()
386 working_batch->MarkWalTerminationPoint(); in CommitInternal()
391 s = WriteBatchInternal::Append(working_batch, in CommitInternal()
396 s = db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr, in CommitInternal()
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A 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()
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A 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()
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A Dpessimistic_transaction.cc375 WriteBatch* working_batch = GetCommitTimeWriteBatch();
376 WriteBatchInternal::MarkCommit(working_batch, name_);
379 working_batch->MarkWalTerminationPoint();
384 WriteBatchInternal::Append(working_batch, GetWriteBatch()->GetWriteBatch());
388 db_impl_->WriteImpl(write_options_, working_batch, /*callback*/ nullptr,
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A 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()
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A 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()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/
H A 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()
H A 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()

12