/dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
H A D | write_prepared_txn.cc | 151 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 D | pessimistic_transaction.cc | 381 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_unprepared_txn.cc | 481 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 D | write_prepared_txn.cc | 151 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 D | pessimistic_transaction.cc | 381 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 D | write_prepared_txn.cc | 151 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 D | pessimistic_transaction.cc | 382 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 D | write_prepared_txn.cc | 151 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 D | pessimistic_transaction.cc | 382 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 D | write_prepared_txn.cc | 151 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 D | pessimistic_transaction.cc | 381 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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 D | write_prepared_txn.cc | 145 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 D | pessimistic_transaction.cc | 375 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()
|