Lines Matching refs:write_options
35 Status DBImpl::Delete(const WriteOptions& write_options, in Delete() argument
37 return DB::Delete(write_options, column_family, key); in Delete()
40 Status DBImpl::SingleDelete(const WriteOptions& write_options, in SingleDelete() argument
43 return DB::SingleDelete(write_options, column_family, key); in SingleDelete()
51 Status DBImpl::Write(const WriteOptions& write_options, WriteBatch* my_batch) { in Write() argument
52 return WriteImpl(write_options, my_batch, nullptr, nullptr); in Write()
56 Status DBImpl::WriteWithCallback(const WriteOptions& write_options, in WriteWithCallback() argument
59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback()
66 Status DBImpl::WriteImpl(const WriteOptions& write_options, in WriteImpl() argument
82 if (write_options.sync && write_options.disableWAL) { in WriteImpl()
105 if (write_options.low_pri) { in WriteImpl()
106 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl()
117 return WriteImplWALOnly(&nonmem_write_thread_, write_options, my_batch, in WriteImpl()
131 status = WriteImplWALOnly(&write_thread_, write_options, my_batch, callback, in WriteImpl()
144 status = UnorderedWriteMemtable(write_options, my_batch, callback, in WriteImpl()
151 return PipelinedWriteImpl(write_options, my_batch, callback, log_used, in WriteImpl()
156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl()
159 if (!write_options.disableWAL) { in WriteImpl()
178 write_options.ignore_missing_column_families, 0 /*log_number*/, this, in WriteImpl()
180 batch_per_txn_, write_options.memtable_insert_hint_per_batch); in WriteImpl()
222 bool need_log_sync = write_options.sync; in WriteImpl()
232 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImpl()
317 if (write_options.disableWAL) { in WriteImpl()
324 if (status.ok() && !write_options.disableWAL) { in WriteImpl()
330 if (status.ok() && !write_options.disableWAL) { in WriteImpl()
385 write_options.ignore_missing_column_families, in WriteImpl()
402 write_options.ignore_missing_column_families, 0 /*log_number*/, in WriteImpl()
405 write_options.memtable_insert_hint_per_batch); in WriteImpl()
460 Status DBImpl::PipelinedWriteImpl(const WriteOptions& write_options, in PipelinedWriteImpl() argument
469 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in PipelinedWriteImpl()
478 bool need_log_sync = !write_options.disableWAL && write_options.sync; in PipelinedWriteImpl()
482 w.status = PreprocessWrite(write_options, &need_log_sync, &write_context); in PipelinedWriteImpl()
525 if (w.status.ok() && !write_options.disableWAL) { in PipelinedWriteImpl()
568 write_options.ignore_missing_column_families, 0 /*log_number*/, this, in PipelinedWriteImpl()
581 &trim_history_scheduler_, write_options.ignore_missing_column_families, in PipelinedWriteImpl()
584 write_options.memtable_insert_hint_per_batch); in PipelinedWriteImpl()
599 Status DBImpl::UnorderedWriteMemtable(const WriteOptions& write_options, in UnorderedWriteMemtable() argument
607 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in UnorderedWriteMemtable()
621 &trim_history_scheduler_, write_options.ignore_missing_column_families, in UnorderedWriteMemtable()
624 write_options.memtable_insert_hint_per_batch); in UnorderedWriteMemtable()
627 if (write_options.disableWAL) { in UnorderedWriteMemtable()
652 WriteThread* write_thread, const WriteOptions& write_options, in WriteImplWALOnly() argument
659 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImplWALOnly()
690 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImplWALOnly()
756 if (!write_options.disableWAL) { in WriteImplWALOnly()
780 if (status.ok() && write_options.sync) { in WriteImplWALOnly()
781 assert(!write_options.disableWAL); in WriteImplWALOnly()
868 Status DBImpl::PreprocessWrite(const WriteOptions& write_options, in PreprocessWrite() argument
919 status = DelayWrite(last_batch_group_size_, write_options); in PreprocessWrite()
1400 const WriteOptions& write_options) { in DelayWrite() argument
1407 if (write_options.no_slowdown) { in DelayWrite()
1440 if (write_options.no_slowdown) { in DelayWrite()
1453 assert(!delayed || !write_options.no_slowdown); in DelayWrite()
1475 Status DBImpl::ThrottleLowPriWritesIfNeeded(const WriteOptions& write_options, in ThrottleLowPriWritesIfNeeded() argument
1477 assert(write_options.low_pri); in ThrottleLowPriWritesIfNeeded()
1488 if (write_options.no_slowdown) { in ThrottleLowPriWritesIfNeeded()