Lines Matching refs:WriteThread

156   WriteThread::Writer w(write_options, my_batch, callback, log_ref,  in WriteImpl()
166 if (w.state == WriteThread::STATE_PARALLEL_MEMTABLE_WRITER) { in WriteImpl()
193 assert(w.state == WriteThread::STATE_COMPLETED); in WriteImpl()
198 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
209 assert(w.state == WriteThread::STATE_GROUP_LEADER); in WriteImpl()
216 WriteThread::WriteGroup write_group; in WriteImpl()
469 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in PipelinedWriteImpl()
472 if (w.state == WriteThread::STATE_GROUP_LEADER) { in PipelinedWriteImpl()
473 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
556 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
557 if (w.state == WriteThread::STATE_MEMTABLE_WRITER_LEADER) { in PipelinedWriteImpl()
575 if (w.state == WriteThread::STATE_PARALLEL_MEMTABLE_WRITER) { in PipelinedWriteImpl()
595 assert(w.state == WriteThread::STATE_COMPLETED); in PipelinedWriteImpl()
607 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in UnorderedWriteMemtable()
652 WriteThread* write_thread, const WriteOptions& write_options, in WriteImplWALOnly()
659 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImplWALOnly()
665 assert(w.state != WriteThread::STATE_PARALLEL_MEMTABLE_WRITER); in WriteImplWALOnly()
666 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
676 assert(w.state == WriteThread::STATE_GROUP_LEADER); in WriteImplWALOnly()
694 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
701 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
950 WriteBatch* DBImpl::MergeBatch(const WriteThread::WriteGroup& write_group, in MergeBatch()
1025 IOStatus DBImpl::WriteToWAL(const WriteThread::WriteGroup& write_group, in WriteToWAL()
1095 const WriteThread::WriteGroup& write_group, uint64_t* log_used, in ConcurrentWriteToWAL()
1279 WriteThread::Writer nonmem_w; in SwitchWAL()
1356 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1581 WriteThread::Writer nonmem_w; in ScheduleFlushes()
1636 WriteThread::Writer nonmem_w; in SwitchMemtable()