Lines Matching refs:immutable_db_options_
85 if (two_write_queues_ && immutable_db_options_.enable_pipelined_write) { in WriteImpl()
89 if (seq_per_batch_ && immutable_db_options_.enable_pipelined_write) { in WriteImpl()
94 if (immutable_db_options_.unordered_write && in WriteImpl()
95 immutable_db_options_.enable_pipelined_write) { in WriteImpl()
123 if (immutable_db_options_.unordered_write) { in WriteImpl()
150 if (immutable_db_options_.enable_pipelined_write) { in WriteImpl()
163 StopWatch write_sw(env_, immutable_db_options_.statistics.get(), DB_WRITE); in WriteImpl()
266 bool parallel = immutable_db_options_.allow_concurrent_memtable_write && in WriteImpl()
465 StopWatch write_sw(env_, immutable_db_options_.statistics.get(), DB_WRITE); in PipelinedWriteImpl()
562 immutable_db_options_.allow_concurrent_memtable_write) { in PipelinedWriteImpl()
605 StopWatch write_sw(env_, immutable_db_options_.statistics.get(), DB_WRITE); in UnorderedWriteMemtable()
662 StopWatch write_sw(env_, immutable_db_options_.statistics.get(), DB_WRITE); in WriteImplWALOnly()
680 assert(immutable_db_options_.unordered_write); in WriteImplWALOnly()
817 assert(immutable_db_options_.unordered_write); in WriteImplWALOnly()
819 if (immutable_db_options_.unordered_write && status.ok()) { in WriteImplWALOnly()
835 if (immutable_db_options_.paranoid_checks && !status.ok() && in WriteStatusCheck()
846 if (immutable_db_options_.paranoid_checks && !io_status.ok() && in IOStatusCheck()
1063 io_s = log.writer->file()->Sync(immutable_db_options_.use_fsync); in WriteToWAL()
1209 assert(immutable_db_options_.atomic_flush); in AssignAtomicFlushSeq()
1242 immutable_db_options_.info_log, in SwitchWAL()
1259 immutable_db_options_.info_log, in SwitchWAL()
1266 if (immutable_db_options_.atomic_flush) { in SwitchWAL()
1297 if (immutable_db_options_.atomic_flush) { in SwitchWAL()
1322 immutable_db_options_.info_log, in HandleWriteBufferFull()
1330 if (immutable_db_options_.atomic_flush) { in HandleWriteBufferFull()
1376 if (immutable_db_options_.atomic_flush) { in HandleWriteBufferFull()
1507 if (!cfds->empty() && immutable_db_options_.persist_stats_to_disk) { in MaybeFlushStatsCF()
1531 ROCKS_LOG_INFO(immutable_db_options_.info_log, in MaybeFlushStatsCF()
1567 if (immutable_db_options_.atomic_flush) { in ScheduleFlushes()
1603 if (immutable_db_options_.atomic_flush) { in ScheduleFlushes()
1617 if (immutable_db_options_.listeners.size() == 0U) { in NotifyOnMemTableSealed()
1624 for (auto listener : immutable_db_options_.listeners) { in NotifyOnMemTableSealed()
1659 if (creating_new_log && immutable_db_options_.recycle_log_file_num && in SwitchMemtable()
1693 ROCKS_LOG_INFO(immutable_db_options_.info_log, in SwitchMemtable()
1714 ROCKS_LOG_WARN(immutable_db_options_.info_log, in SwitchMemtable()
1793 if (immutable_db_options_.db_write_buffer_size > 0) { in GetWalPreallocateBlockSize()
1794 bsize = std::min<size_t>(bsize, immutable_db_options_.db_write_buffer_size); in GetWalPreallocateBlockSize()
1796 if (immutable_db_options_.write_buffer_manager && in GetWalPreallocateBlockSize()
1797 immutable_db_options_.write_buffer_manager->enabled()) { in GetWalPreallocateBlockSize()
1799 bsize, immutable_db_options_.write_buffer_manager->buffer_size()); in GetWalPreallocateBlockSize()