| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn_db.cc | 134 const size_t batch_cnt = optimizations.skip_duplicate_key_check in Write() local
138 return WriteInternal(opts, updates, batch_cnt, NO_TXN); in Write()
156 if (batch_cnt == 0) { // not provided, then compute it in WriteInternal()
161 batch_cnt = counter.BatchCount(); in WriteInternal()
164 static_cast<uint64_t>(batch_cnt)); in WriteInternal()
166 assert(batch_cnt); in WriteInternal()
181 this, db_impl_, batch_cnt, in WriteInternal()
194 batch_cnt, pre_release_callback); in WriteInternal()
213 this, db_impl_, prepare_seq, batch_cnt, ZERO_COMMITS); in WriteInternal()
557 prepare_seq, batch_cnt); in RemovePrepared()
[all …]
|
| D | write_prepared_txn.cc | 131 const size_t batch_cnt = GetWriteBatch()->SubBatchCnt(); in CommitWithoutPrepareInternal() local
132 return CommitBatchInternal(GetWriteBatch()->GetWriteBatch(), batch_cnt); in CommitWithoutPrepareInternal()
136 size_t batch_cnt) { in CommitBatchInternal() argument
137 return wpt_db_->WriteInternal(write_options_, batch, batch_cnt, this); in CommitBatchInternal()
190 size_t batch_cnt = UNLIKELY(commit_batch_cnt) ? commit_batch_cnt : 1; in CommitInternal() local
193 batch_cnt, pre_release_callback); in CommitInternal()
|
| D | pessimistic_transaction.h | 131 size_t batch_cnt = 0) = 0;
216 Status CommitBatchInternal(WriteBatch* batch, size_t batch_cnt) override;
|
| D | write_prepared_transaction_test.cc | 211 size_t batch_cnt = 1; in TEST() local
216 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
217 batch_cnt_at.push_back(batch_cnt); in TEST()
221 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
222 batch_cnt_at.push_back(batch_cnt); in TEST()
226 ASSERT_EQ(batch_cnt, batch.SubBatchCnt()); in TEST()
228 batch_cnt_at.push_back(batch_cnt); in TEST()
232 batch_cnt++; in TEST()
236 batch_cnt_at.push_back(batch_cnt); in TEST()
243 batch_cnt_at.push_back(batch_cnt); in TEST()
[all …]
|
| D | write_prepared_txn.h | 94 Status CommitBatchInternal(WriteBatch* batch, size_t batch_cnt) override;
|
| D | write_unprepared_txn.cc | 583 size_t batch_cnt = UNLIKELY(commit_batch_cnt) ? commit_batch_cnt : 1; in CommitInternal() local
586 batch_cnt, pre_release_callback); in CommitInternal()
|
| D | write_prepared_txn_db.h | 84 size_t batch_cnt, WritePreparedTxn* txn);
334 void RemovePrepared(const uint64_t seq, const size_t batch_cnt = 1);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 70 size_t batch_cnt, in WriteImpl() argument
72 assert(!seq_per_batch_ || batch_cnt != 0); in WriteImpl()
124 const size_t sub_batch_cnt = batch_cnt != 0 in WriteImpl()
125 ? batch_cnt in WriteImpl()
274 valid_batches += writer->batch_cnt; in WriteImpl()
369 assert(writer->batch_cnt); in WriteImpl()
370 next_sequence += writer->batch_cnt; in WriteImpl()
404 w.batch_cnt, batch_per_txn_, in WriteImpl()
748 assert(writer->batch_cnt || !seq_per_batch_); in WriteImplWALOnly()
750 total_batch_cnt += writer->batch_cnt; in WriteImplWALOnly()
[all …]
|
| D | db_impl.h | 742 size_t batch_cnt, bool unprepared) in RecoveredTransaction()
744 batches_[seq] = {log, batch, batch_cnt}; in RecoveredTransaction()
754 size_t batch_cnt, bool unprepared) { in AddBatch()
756 batches_[seq] = {log_number, batch, batch_cnt}; in AddBatch()
782 size_t batch_cnt, bool unprepared_batch) { in InsertRecoveredTransaction() argument
791 log, name, batch, seq, batch_cnt, unprepared_batch); in InsertRecoveredTransaction()
793 rtxn->second->AddBatch(seq, log, batch, batch_cnt, unprepared_batch); in InsertRecoveredTransaction()
1087 size_t batch_cnt = 0,
|
| /rocksdb-6.9/db/ |
| D | write_thread.h | 121 size_t batch_cnt; // if non-zero, number of sub-batches in the write batch member
144 batch_cnt(0), in Writer()
165 batch_cnt(_batch_cnt), in batch()
|
| D | write_batch.cc | 1851 size_t batch_cnt = in MarkEndPrepare() local
1857 batch_cnt, unprepared_batch_); in MarkEndPrepare()
1994 assert(!seq_per_batch || w->batch_cnt != 0); in InsertInto()
1995 assert(!seq_per_batch || inserter.sequence() - w->sequence == w->batch_cnt); in InsertInto()
2005 bool concurrent_memtable_writes, bool seq_per_batch, size_t batch_cnt, in InsertInto() argument
2008 (void)batch_cnt; in InsertInto()
2019 assert(!seq_per_batch || batch_cnt != 0); in InsertInto()
2020 assert(!seq_per_batch || inserter.sequence() - sequence == batch_cnt); in InsertInto()
|
| D | write_batch_internal.h | 190 bool seq_per_batch = false, size_t batch_cnt = 0,
|