Lines Matching refs:write_thread_
131 status = WriteImplWALOnly(&write_thread_, write_options, my_batch, callback, in WriteImpl()
165 write_thread_.JoinBatchGroup(&w); in WriteImpl()
185 if (write_thread_.CompleteParallelMemTableWriter(&w)) { in WriteImpl()
191 write_thread_.ExitAsBatchGroupFollower(&w); in WriteImpl()
252 write_thread_.EnterAsBatchGroupLeader(&w, &write_group); in WriteImpl()
390 write_thread_.LaunchParallelMemTableWriters(&write_group); in WriteImpl()
442 should_exit_batch_group = write_thread_.CompleteParallelMemTableWriter(&w); in WriteImpl()
451 write_thread_.ExitAsBatchGroupLeader(write_group, status); in WriteImpl()
471 write_thread_.JoinBatchGroup(&w); in PipelinedWriteImpl()
475 write_thread_.WaitForMemTableWriters(); in PipelinedWriteImpl()
489 write_thread_.EnterAsBatchGroupLeader(&w, &wal_write_group); in PipelinedWriteImpl()
491 write_thread_.UpdateLastSequence(versions_->LastSequence()) + 1; in PipelinedWriteImpl()
512 write_thread_.UpdateLastSequence(current_sequence + total_count - 1); in PipelinedWriteImpl()
553 write_thread_.ExitAsBatchGroupLeader(wal_write_group, w.status); in PipelinedWriteImpl()
560 write_thread_.EnterAsMemTableWriter(&w, &memtable_write_group); in PipelinedWriteImpl()
563 write_thread_.LaunchParallelMemTableWriters(&memtable_write_group); in PipelinedWriteImpl()
571 write_thread_.ExitAsMemTableWriter(&w, memtable_write_group); in PipelinedWriteImpl()
585 if (write_thread_.CompleteParallelMemTableWriter(&w)) { in PipelinedWriteImpl()
588 write_thread_.ExitAsMemTableWriter(&w, *w.write_group); in PipelinedWriteImpl()
1414 write_thread_.BeginWriteStall(); in DelayWrite()
1432 write_thread_.EndWriteStall(); in DelayWrite()
1447 write_thread_.BeginWriteStall(); in DelayWrite()
1450 write_thread_.EndWriteStall(); in DelayWrite()