Searched refs:seq_per_batch (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/db/ |
| D | write_callback_test.cc | 128 for (auto& seq_per_batch : {true, false}) { in TEST_F()
142 if (options.enable_pipelined_write && seq_per_batch) { in TEST_F()
170 &db, seq_per_batch, true /* batch_per_txn */); in TEST_F()
289 if (!write_op.callback_.should_fail_ && !seq_per_batch) { in TEST_F()
293 if (!write_op.callback_.should_fail_ && seq_per_batch) { in TEST_F()
301 if (seq_per_batch) { in TEST_F()
|
| D | write_batch_internal.h | 170 bool seq_per_batch = false, bool batch_per_txn = true);
181 bool seq_per_batch = false, bool batch_per_txn = true);
190 bool seq_per_batch = false, size_t batch_cnt = 0,
|
| D | wal_manager.h | 39 const FileOptions& file_options, const bool seq_per_batch = false)
45 seq_per_batch_(seq_per_batch), in db_options_()
|
| D | write_batch.cc | 1290 seq_per_batch_(seq_per_batch), in MemTableInserter()
1294 write_after_commit_(!seq_per_batch), in MemTableInserter()
1972 bool concurrent_memtable_writes, bool seq_per_batch, bool batch_per_txn) { in InsertInto() argument
1976 concurrent_memtable_writes, nullptr /*has_valid_writes*/, seq_per_batch, in InsertInto()
1994 assert(!seq_per_batch || w->batch_cnt != 0); in InsertInto()
2005 bool concurrent_memtable_writes, bool seq_per_batch, size_t batch_cnt, in InsertInto() argument
2014 concurrent_memtable_writes, nullptr /*has_valid_writes*/, seq_per_batch, in InsertInto()
2019 assert(!seq_per_batch || batch_cnt != 0); in InsertInto()
2020 assert(!seq_per_batch || inserter.sequence() - sequence == batch_cnt); in InsertInto()
2033 bool* has_valid_writes, bool seq_per_batch, bool batch_per_txn) { in InsertInto() argument
[all …]
|
| D | transaction_log_impl.cc | 20 const bool seq_per_batch) in TransactionLogIteratorImpl() argument
33 seq_per_batch_(seq_per_batch) { in TransactionLogIteratorImpl()
|
| D | transaction_log_impl.h | 66 const bool seq_per_batch);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 148 const bool seq_per_batch, const bool batch_per_txn) in DBImpl() argument
164 seq_per_batch_(seq_per_batch), in DBImpl()
199 wal_manager_(immutable_db_options_, file_options_, seq_per_batch), in DBImpl()
218 !(seq_per_batch && options.two_write_queues)), in DBImpl()
222 use_custom_gc_(seq_per_batch), in DBImpl()
|
| D | db_impl_open.cc | 1370 const bool seq_per_batch, const bool batch_per_txn) { in Open() argument
1390 DBImpl* impl = new DBImpl(db_options, dbname, seq_per_batch, batch_per_txn); in Open()
|
| D | db_impl.h | 130 const bool seq_per_batch = false, const bool batch_per_txn = true);
847 const bool seq_per_batch, const bool batch_per_txn);
|