| /rocksdb-6.9/utilities/transactions/ |
| 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()
|
| 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()
715 WriteBatchInternal::MarkRollback(rollback_batch.GetWriteBatch(), name_); in RollbackInternal()
740 s = db_impl_->WriteImpl(write_options_, rollback_batch.GetWriteBatch(), in RollbackInternal()
|
| D | optimistic_transaction.cc | 82 write_options_, GetWriteBatch()->GetWriteBatch(), &callback); in CommitWithSerialValidate()
118 s = db_impl->Write(write_options_, GetWriteBatch()->GetWriteBatch()); in CommitWithParallelValidate()
|
| D | pessimistic_transaction.cc | 226 WriteBatchInternal::MarkEndPrepare(GetWriteBatch()->GetWriteBatch(), name_); in PrepareInternal()
257 write_options, GetWriteBatch()->GetWriteBatch(), kNoWriteCallback, in PrepareInternal()
350 db_impl_->WriteImpl(write_options_, GetWriteBatch()->GetWriteBatch(), in CommitWithoutPrepareInternal()
384 WriteBatchInternal::Append(working_batch, GetWriteBatch()->GetWriteBatch()); in CommitInternal()
|
| D | transaction_base.h | 197 WriteBatchWithIndex* GetWriteBatch() override;
283 WriteBatchInternal::InsertNoop(write_batch_.GetWriteBatch());
|
| D | write_unprepared_transaction_test.cc | 668 auto wb = txn->GetWriteBatch()->GetWriteBatch(); in TEST_P()
|
| D | transaction_base.cc | 591 WriteBatchWithIndex* TransactionBaseImpl::GetWriteBatch() { in GetWriteBatch() function in ROCKSDB_NAMESPACE::TransactionBaseImpl
718 return write_batch_.GetWriteBatch(); in GetBatchForWrite()
|
| D | pessimistic_transaction_db.cc | 158 real_trx->GetWriteBatch()->SubBatchCnt() == batch_info.batch_cnt_); in Initialize()
|
| D | write_prepared_transaction_test.cc | 255 ASSERT_OK(batch.GetWriteBatch()->Iterate(&counter)); in TEST()
285 ASSERT_OK(rndbatch.GetWriteBatch()->Iterate(&batch_counter)); in TEST()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | write_batch_with_index.h | 146 using WriteBatchBase::GetWriteBatch;
147 WriteBatch* GetWriteBatch() override;
|
| D | transaction.h | 432 virtual WriteBatchWithIndex* GetWriteBatch() = 0;
|
| /rocksdb-6.9/include/rocksdb/ |
| D | write_batch.h | 322 using WriteBatchBase::GetWriteBatch;
323 WriteBatch* GetWriteBatch() override { return this; } in GetWriteBatch() function
|
| D | write_batch_base.h | 105 virtual WriteBatch* GetWriteBatch() = 0;
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_with_index.cc | 80 return static_cast<jint>(wbwi->GetWriteBatch()->Count()); in Java_org_rocksdb_WriteBatchWithIndex_count0()
496 auto* wb = wbwi->GetWriteBatch(); in Java_org_rocksdb_WriteBatchWithIndex_getWriteBatch()
|
| D | transaction.cc | 1364 return reinterpret_cast<jlong>(txn->GetWriteBatch()); in Java_org_rocksdb_Transaction_getWriteBatch()
|
| D | rocksjni.cc | 1318 auto* wb = wbwi->GetWriteBatch(); in Java_org_rocksdb_RocksDB_write1()
|
| /rocksdb-6.9/db/ |
| D | write_batch_test.cc | 739 batch.GetWriteBatch()->Iterate(&handler); in TEST_F()
|
| D | c.cc | 1613 return b->rep->GetWriteBatch()->Count(); in rocksdb_writebatch_wi_count()
1818 b->rep->GetWriteBatch()->Iterate(&handler); in rocksdb_writebatch_wi_iterate()
1822 WriteBatch* wb = b->rep->GetWriteBatch(); in rocksdb_writebatch_wi_data()
1950 WriteBatch* wb = wbwi->rep->GetWriteBatch(); in rocksdb_write_writebatch_wi()
|
| D | db_test.cc | 2420 ASSERT_OK(db->Write(WriteOptions(), batch.GetWriteBatch())); in MTThreadBody()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 646 WriteBatch* WriteBatchWithIndex::GetWriteBatch() { return &rep->write_batch; } in GetWriteBatch() function in ROCKSDB_NAMESPACE::WriteBatchWithIndex
|
| D | write_batch_with_index_test.cc | 246 batch->GetWriteBatch()->Iterate(&handler); in TestValueAsSecondaryIndexHelper()
|