Home
last modified time | relevance | path

Searched refs:two_write_queues_ (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc233 if (!two_write_queues_) { in WriteImpl()
323 if (!two_write_queues_) { in WriteImpl()
429 if (two_write_queues_) { in WriteImpl()
1280 if (two_write_queues_) { in SwitchWAL()
1292 if (two_write_queues_) { in SwitchWAL()
1357 if (two_write_queues_) { in HandleWriteBufferFull()
1371 if (two_write_queues_) { in HandleWriteBufferFull()
1582 if (two_write_queues_) { in ScheduleFlushes()
1598 if (two_write_queues_) { in ScheduleFlushes()
1651 if (two_write_queues_) { in SwitchMemtable()
[all …]
Ddb_impl_files.cc204 if (two_write_queues_) { in FindObsoleteFiles()
208 if (two_write_queues_) { in FindObsoleteFiles()
Ddb_impl_open.cc1144 if (two_write_queues_) { in RestoreAliveLogFiles()
1186 if (two_write_queues_) { in RestoreAliveLogFiles()
1478 if (impl->two_write_queues_) { in Open()
1483 if (impl->two_write_queues_) { in Open()
Ddb_impl_debug.cc113 if (two_write_queues_) { in TEST_SwitchMemtable()
Ddb_impl_compaction_flush.cc1601 if (two_write_queues_) { in FlushMemTable()
1667 if (two_write_queues_) { in FlushMemTable()
1724 if (two_write_queues_) { in AtomicFlushMemTables()
1771 if (two_write_queues_) { in AtomicFlushMemTables()
Ddb_impl.cc206 two_write_queues_(options.two_write_queues), in DBImpl()
4096 if (two_write_queues_) { in IngestExternalFiles()
4239 if (two_write_queues_) { in IngestExternalFiles()
4349 if (two_write_queues_) { in CreateColumnFamilyWithImport()
4368 if (two_write_queues_) { in CreateColumnFamilyWithImport()
Ddb_impl.h2062 const bool two_write_queues_; variable
/rocksdb-6.9/utilities/transactions/
Dwrite_prepared_txn_db.h856 two_write_queues_(two_write_queues), in AddPreparedCallback()
858 (void)two_write_queues_; // to silence unused private field warning in AddPreparedCallback()
867 const bool do_lock = !two_write_queues_ || index == 0; in Callback()
868 const bool do_unlock = !two_write_queues_ || index + 1 == total; in Callback()
870 assert(!two_write_queues_ || !is_mem_disabled); // implies the 1st queue in Callback()
896 bool two_write_queues_; variable
Dpessimistic_transaction.cc230 : db_(db), two_write_queues_(two_write_queues) { in PrepareInternal()
231 (void)two_write_queues_; // to silence unused private field warning in PrepareInternal()
240 assert(!two_write_queues_ || is_mem_disabled); // implies the 2nd queue in PrepareInternal()
247 bool two_write_queues_; in PrepareInternal() member in ROCKSDB_NAMESPACE::WriteCommittedTxn::PrepareInternal::MarkLogCallback