Home
last modified time | relevance | path

Searched refs:SubBatchCnt (Results 1 – 6 of 6) sorted by relevance

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc110 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in PrepareInternal()
131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal()
467 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in RebuildFromWriteBatch()
Dwrite_prepared_transaction_test.cc199 TEST(WriteBatchWithIndex, SubBatchCnt) { in TEST() argument
216 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
221 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
226 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
233 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
240 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
247 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
262 ASSERT_EQ(batch_cnt_at[i - 1], batch.SubBatchCnt()); in TEST()
286 ASSERT_EQ(rndbatch.SubBatchCnt(), batch_counter.BatchCount()); in TEST()
Dwrite_unprepared_txn.cc358 prepare_batch_cnt_ = GetWriteBatch()->SubBatchCnt(); in FlushWriteBatchToDBInternal()
722 auto rollback_batch_cnt = rollback_batch.SubBatchCnt(); in RollbackInternal()
Dpessimistic_transaction_db.cc158 real_trx->GetWriteBatch()->SubBatchCnt() == batch_info.batch_cnt_); in Initialize()
/rocksdb-6.9/include/rocksdb/utilities/
Dwrite_batch_with_index.h262 size_t SubBatchCnt();
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index.cc648 size_t WriteBatchWithIndex::SubBatchCnt() { return rep->sub_batch_cnt; } in SubBatchCnt() function in ROCKSDB_NAMESPACE::WriteBatchWithIndex