188       auto last_sequence = w.write_group->last_sequence;  in WriteImpl()
216   WriteThread::WriteGroup write_group;  in WriteImpl()  local
252       write_thread_.EnterAsBatchGroupLeader(&w, &write_group);  in WriteImpl()
267                     write_group.size > 1;  in WriteImpl()
272     for (auto* writer : write_group) {  in WriteImpl()
309     auto write_done_by_other = write_group.size - 1;  in WriteImpl()
326         io_s = WriteToWAL(write_group, log_writer, log_used, need_log_sync,  in WriteImpl()
334         io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence,  in WriteImpl()
354       for (auto* writer : write_group) {  in WriteImpl()
383             write_group, current_sequence, column_family_memtables_.get(),  in WriteImpl()
389         write_group.last_sequence = last_sequence;  in WriteImpl()
390         write_thread_.LaunchParallelMemTableWriters(&write_group);  in WriteImpl()
451     write_thread_.ExitAsBatchGroupLeader(write_group, status);  in WriteImpl()
587       versions_->SetLastSequence(w.write_group->last_sequence);  in PipelinedWriteImpl()
588       write_thread_.ExitAsMemTableWriter(&w, *w.write_group);  in PipelinedWriteImpl()
694       WriteThread::WriteGroup write_group;  in WriteImplWALOnly()  local
695       write_thread->EnterAsBatchGroupLeader(&w, &write_group);  in WriteImplWALOnly()
696       write_thread->ExitAsBatchGroupLeader(write_group, status);  in WriteImplWALOnly()
701   WriteThread::WriteGroup write_group;  in WriteImplWALOnly()  local
703   write_thread->EnterAsBatchGroupLeader(&w, &write_group);  in WriteImplWALOnly()
709   for (auto* writer : write_group) {  in WriteImplWALOnly()
731   auto write_done_by_other = write_group.size - 1;  in WriteImplWALOnly()
747     for (auto* writer : write_group) {  in WriteImplWALOnly()
757     io_s = ConcurrentWriteToWAL(write_group, log_used, &last_sequence, seq_inc);  in WriteImplWALOnly()
766   for (auto* writer : write_group) {  in WriteImplWALOnly()
801     for (auto* writer : write_group) {  in WriteImplWALOnly()
822   write_thread->ExitAsBatchGroupLeader(write_group, status);  in WriteImplWALOnly()
950 WriteBatch* DBImpl::MergeBatch(const WriteThread::WriteGroup& write_group,  in MergeBatch()  argument
958   auto* leader = write_group.leader;  in MergeBatch()
960   if (write_group.size == 1 && !leader->CallbackFailed() &&  in MergeBatch()
975     for (auto writer : write_group) {  in MergeBatch()
1025 IOStatus DBImpl::WriteToWAL(const WriteThread::WriteGroup& write_group,  in WriteToWAL()  argument
1030   assert(!write_group.leader->disable_wal);  in WriteToWAL()
1034   WriteBatch* merged_batch = MergeBatch(write_group, &tmp_batch_,  in WriteToWAL()
1036   if (merged_batch == write_group.leader->batch) {  in WriteToWAL()
1037     write_group.leader->log_used = logfile_number_;  in WriteToWAL()
1039     for (auto writer : write_group) {  in WriteToWAL()
1095     const WriteThread::WriteGroup& write_group, uint64_t* log_used,  in ConcurrentWriteToWAL()  argument
1099   assert(!write_group.leader->disable_wal);  in ConcurrentWriteToWAL()
1105       MergeBatch(write_group, &tmp_batch, &write_with_wal, &to_be_cached_state);  in ConcurrentWriteToWAL()
1110   if (merged_batch == write_group.leader->batch) {  in ConcurrentWriteToWAL()
1111     write_group.leader->log_used = logfile_number_;  in ConcurrentWriteToWAL()
1113     for (auto writer : write_group) {  in ConcurrentWriteToWAL()