| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 112 auto s = WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
116 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
125 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
137 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
138 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
358 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
477 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 85 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
129 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 112 auto s = WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
116 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
125 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
137 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
138 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
358 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
477 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 85 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
129 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/rocksdb/rocksdb-6.26.1/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 112 auto s = WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
116 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
125 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
137 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
138 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
350 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
469 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 85 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
129 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 112 auto s = WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
116 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
125 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
137 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
138 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
350 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
469 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 85 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
129 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 112 auto s = WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
116 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
125 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
137 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
138 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
358 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
477 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 85 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
129 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| H A D | write_unprepared_txn.cc | 252 write_batch_.GetWriteBatch()->Count() > 0 && in MaybeFlushWriteBatchToDB()
346 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&handler); in FlushWriteBatchToDBInternal()
355 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in FlushWriteBatchToDBInternal()
358 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in FlushWriteBatchToDBInternal()
374 s = db_impl_->WriteImpl(write_options, GetWriteBatch()->GetWriteBatch(), in FlushWriteBatchToDBInternal()
473 size_t curr_boundary = trailing_batch ? wb.GetWriteBatch()->GetDataSize() in FlushWriteBatchWithSavePointToDB()
482 Status s = WriteBatchInternal::Iterate(wb.GetWriteBatch(), &sp_handler, in FlushWriteBatchWithSavePointToDB()
488 if (write_batch_.GetWriteBatch()->Count() > 0) { in FlushWriteBatchWithSavePointToDB()
710 WriteBatchInternal::MarkRollback(rollback_batch.GetWriteBatch(), name_); in RollbackInternal()
732 s = db_impl_->WriteImpl(write_options_, rollback_batch.GetWriteBatch(), in RollbackInternal()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/utilities/transactions/ |
| H A D | write_prepared_txn.cc | 107 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_, in PrepareInternal()
110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
120 write_options, GetWriteBatch()->GetWriteBatch(), in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
349 auto s = GetWriteBatch()->GetWriteBatch()->Iterate(&rollback_handler); in RollbackInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
|
| H A D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|