Searched refs:seq_per_batch_ (Results 1 – 10 of 10) sorted by relevance
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 72 assert(!seq_per_batch_ || batch_cnt != 0); in WriteImpl()
89 if (seq_per_batch_ && immutable_db_options_.enable_pipelined_write) { in WriteImpl()
114 seq_per_batch_ ? kDoAssignOrder : kDontAssignOrder; in WriteImpl()
292 size_t seq_inc = seq_per_batch_ ? valid_batches : total_count; in WriteImpl()
368 if (seq_per_batch_) { in WriteImpl()
386 0 /*recovery_log_number*/, this, parallel, seq_per_batch_, in WriteImpl()
403 this, true /*concurrent_memtable_writes*/, seq_per_batch_, in WriteImpl()
623 seq_per_batch_, sub_batch_cnt, true /*batch_per_txn*/, in UnorderedWriteMemtable()
748 assert(writer->batch_cnt || !seq_per_batch_); in WriteImplWALOnly()
772 assert(writer->batch_cnt || !seq_per_batch_); in WriteImplWALOnly()
[all …]
|
| D | db_impl_secondary.cc | 260 next_sequence, &has_valid_writes, seq_per_batch_, batch_per_txn_); in RecoverLogFiles()
|
| D | db_impl_open.cc | 945 &has_valid_writes, seq_per_batch_, batch_per_txn_); in RecoverLogFiles()
|
| D | db_impl.h | 1017 const bool seq_per_batch_; variable
|
| D | db_impl.cc | 164 seq_per_batch_(seq_per_batch), in DBImpl()
231 assert(batch_per_txn_ || seq_per_batch_); in DBImpl()
|
| /rocksdb-6.9/db/ |
| D | wal_manager.h | 45 seq_per_batch_(seq_per_batch), in db_options_()
104 bool seq_per_batch_; variable
|
| D | transaction_log_impl.cc | 33 seq_per_batch_(seq_per_batch) { in TransactionLogIteratorImpl()
246 return SeekToStartSequence(current_file_index_, !seq_per_batch_); in UpdateCurrentWriteBatch()
286 if (seq_per_batch_) { in UpdateCurrentWriteBatch()
|
| D | write_batch.cc | 1216 bool seq_per_batch_; member in ROCKSDB_NAMESPACE::MemTableInserter
1290 seq_per_batch_(seq_per_batch), in MemTableInserter()
1338 if (batch_boundry == seq_per_batch_) { in MaybeAdvanceSeq()
1426 assert(!seq_per_batch_ || !moptions->inplace_update_support); in PutCFImpl()
1433 assert(seq_per_batch_); in PutCFImpl()
1517 assert(seq_per_batch_); in DeleteImpl()
1734 assert(seq_per_batch_); in MergeCF()
1748 assert(seq_per_batch_); in MergeCF()
|
| D | transaction_log_impl.h | 109 const bool seq_per_batch_; variable
|
| D | wal_manager.cc | 124 std::move(wal_files), version_set, seq_per_batch_)); in GetUpdatesSince()
|