Home
last modified time | relevance | path

Searched refs:two_write_queues (Results 1 – 25 of 26) sorted by relevance

12

/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn.cc116 db_impl_->immutable_db_options().two_write_queues, kFirstPrepareBatch); in PrepareInternal()
171 !db_impl_->immutable_db_options().two_write_queues || disable_memtable; in CommitInternal()
178 db_impl_->immutable_db_options().two_write_queues, !kFirstPrepareBatch); in CommitInternal()
197 if (UNLIKELY(!db_impl_->immutable_db_options().two_write_queues && in CommitInternal()
230 if (UNLIKELY(!db_impl_->immutable_db_options().two_write_queues)) { in CommitInternal()
356 bool do_one_write = !db_impl_->immutable_db_options().two_write_queues; in RollbackInternal()
371 db_impl_->immutable_db_options().two_write_queues, !kFirstPrepareBatch); in RollbackInternal()
392 assert(!db_impl_->immutable_db_options().two_write_queues); in RollbackInternal()
Dtransaction_test.h63 options.two_write_queues = two_write_queue; in TransactionTestBase()
230 if (options.two_write_queues) {
256 if (options.two_write_queues) {
283 if (options.two_write_queues) {
355 if (options.two_write_queues) {
364 if (options.two_write_queues) {
Dwrite_prepared_txn_db.h851 size_t sub_batch_cnt, bool two_write_queues, in AddPreparedCallback() argument
856 two_write_queues_(two_write_queues), in AddPreparedCallback()
929 assert(!db_impl_->immutable_db_options().two_write_queues || in Callback()
957 if (db_impl_->immutable_db_options().two_write_queues) { in Callback()
1020 assert(db_impl_->immutable_db_options().two_write_queues); in Callback()
Dpessimistic_transaction.cc229 MarkLogCallback(DBImpl* db, bool two_write_queues) in PrepareInternal() argument
230 : db_(db), two_write_queues_(two_write_queues) { in PrepareInternal()
249 db_impl_->immutable_db_options().two_write_queues); in PrepareInternal()
Dwrite_unprepared_txn.cc367 db_impl_->immutable_db_options().two_write_queues, first_prepare_batch); in FlushWriteBatchToDBInternal()
564 !db_impl_->immutable_db_options().two_write_queues || disable_memtable; in CommitInternal()
571 db_impl_->immutable_db_options().two_write_queues, !kFirstPrepareBatch); in CommitInternal()
716 bool do_one_write = !db_impl_->immutable_db_options().two_write_queues; in RollbackInternal()
Dwrite_unprepared_txn_db.h82 if (db_impl_->immutable_db_options().two_write_queues && publish_seq_) { in Callback()
Dwrite_prepared_transaction_test.cc1751 if (options.two_write_queues) { in TEST_P()
2340 if (options.two_write_queues) { in TEST_P()
2388 if (options.two_write_queues) { in TEST_P()
2499 if (options.two_write_queues) { in TEST_P()
2506 if (options.two_write_queues) { in TEST_P()
2886 if (options.two_write_queues) { in TEST_P()
3261 if (!options.two_write_queues) { in TEST_P()
Dwrite_prepared_txn_db.cc168 bool do_one_write = !db_impl_->immutable_db_options().two_write_queues; in WriteInternal()
182 db_impl_->immutable_db_options().two_write_queues, in WriteInternal()
Dwrite_unprepared_txn_db.cc184 if (db_impl_->immutable_db_options().two_write_queues) { in RollbackRecoveredTransaction()
Dpessimistic_transaction_db.cc232 db_options.unordered_write && !db_options.two_write_queues) { in Open()
/rocksdb-6.9/options/
Ddb_options.cc91 two_write_queues(options.two_write_queues), in ImmutableDBOptions()
236 two_write_queues); in Dump()
Ddb_options.h83 bool two_write_queues; member
Doptions_helper.cc140 options.two_write_queues = immutable_db_options.two_write_queues; in BuildDBOptions()
1661 {offsetof(struct DBOptions, two_write_queues), OptionType::kBoolean,
1663 offsetof(struct ImmutableDBOptions, two_write_queues)}},
/rocksdb-6.9/docs/_posts/
D2019-08-15-unordered-write.markdown19 … with TransactionDB configured with WritePrepared transactions and `two_write_queues`. You can rea…
27 db_options.two_write_queues = true;
/rocksdb-6.9/db/
Dwrite_callback_test.cc140 options.two_write_queues = two_queues; in TEST_F()
145 if (options.enable_pipelined_write && options.two_write_queues) { in TEST_F()
Dversion_set.h970 assert(!db_options_->two_write_queues || s <= last_allocated_sequence_); in SetLastSequence()
Ddb_test.cc3871 for (bool two_write_queues : {false, true}) { in TEST_F()
3873 options.two_write_queues = two_write_queues; in TEST_F()
3884 if (two_write_queues) { in TEST_F()
Ddb_test_util.cc554 options.two_write_queues = true; in GetOptions()
Dversion_set.cc4154 edit->SetLastSequence(db_options_->two_write_queues ? last_allocated_sequence_ in LogAndApplyCFHelper()
4186 edit->SetLastSequence(db_options_->two_write_queues ? last_allocated_sequence_ in LogAndApplyHelper()
Dexternal_sst_file_test.cc2786 options.two_write_queues = true; in TEST_P()
/rocksdb-6.9/include/rocksdb/
Doptions.h1082 bool two_write_queues = false; member
/rocksdb-6.9/java/rocksjni/
Doptions.cc2033 opt->two_write_queues = jtwo_write_queues == JNI_TRUE; in Java_org_rocksdb_Options_setTwoWriteQueues()
2044 return static_cast<jboolean>(opt->two_write_queues); in Java_org_rocksdb_Options_twoWriteQueues()
6413 opt->two_write_queues = jtwo_write_queues == JNI_TRUE; in Java_org_rocksdb_DBOptions_setTwoWriteQueues()
6424 return static_cast<jboolean>(opt->two_write_queues); in Java_org_rocksdb_DBOptions_twoWriteQueues()
/rocksdb-6.9/db/db_impl/
Ddb_impl.cc206 two_write_queues_(options.two_write_queues), in DBImpl()
218 !(seq_per_batch && options.two_write_queues)), in DBImpl()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc1996 options_.two_write_queues = true; in Open()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc4159 options.two_write_queues = true; in OpenDb()
4190 options.two_write_queues = true; in OpenDb()

12