Lines Matching refs:my_batch

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()
57 WriteBatch* my_batch, in WriteWithCallback() argument
59 return WriteImpl(write_options, my_batch, callback, nullptr); in WriteWithCallback()
67 WriteBatch* my_batch, WriteCallback* callback, in WriteImpl() argument
73 if (my_batch == nullptr) { in WriteImpl()
79 tracer_->Write(my_batch); in WriteImpl()
100 assert(!WriteBatchInternal::IsLatestPersistentState(my_batch) || in WriteImpl()
106 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl()
117 return WriteImplWALOnly(&nonmem_write_thread_, write_options, my_batch, in WriteImpl()
127 : WriteBatchInternal::Count(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()
461 WriteBatch* my_batch, WriteCallback* callback, in PipelinedWriteImpl() argument
469 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in PipelinedWriteImpl()
600 WriteBatch* my_batch, in UnorderedWriteMemtable() argument
607 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in UnorderedWriteMemtable()
612 size_t total_count = WriteBatchInternal::Count(my_batch); in UnorderedWriteMemtable()
653 WriteBatch* my_batch, WriteCallback* callback, uint64_t* log_used, in WriteImplWALOnly() argument
659 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImplWALOnly()
1476 WriteBatch* my_batch) { in ThrottleLowPriWritesIfNeeded() argument
1484 if (allow_2pc() && (my_batch->HasCommit() || my_batch->HasRollback())) { in ThrottleLowPriWritesIfNeeded()
1491 assert(my_batch != nullptr); in ThrottleLowPriWritesIfNeeded()
1498 my_batch->GetDataSize(), Env::IO_HIGH, nullptr /* stats */, in ThrottleLowPriWritesIfNeeded()