260   Writer* leader = write_group.leader;  in LinkGroup()  local
268     if (w == leader) {  in LinkGroup()
275     leader->link_older = newest;  in LinkGroup()
307   Writer* leader = write_group.leader;  in CompleteLeader()  local
309     write_group.leader = nullptr;  in CompleteLeader()
312     assert(leader->link_newer != nullptr);  in CompleteLeader()
313     leader->link_newer->link_older = nullptr;  in CompleteLeader()
314     write_group.leader = leader->link_newer;  in CompleteLeader()
317   SetState(leader, STATE_COMPLETED);  in CompleteLeader()
322   assert(w != write_group.leader);  in CompleteFollower()
407 size_t WriteThread::EnterAsBatchGroupLeader(Writer* leader,  in EnterAsBatchGroupLeader()  argument
409   assert(leader->link_older == nullptr);  in EnterAsBatchGroupLeader()
410   assert(leader->batch != nullptr);  in EnterAsBatchGroupLeader()
413   size_t size = WriteBatchInternal::ByteSize(leader->batch);  in EnterAsBatchGroupLeader()
424   leader->write_group = write_group;  in EnterAsBatchGroupLeader()
425   write_group->leader = leader;  in EnterAsBatchGroupLeader()
426   write_group->last_writer = leader;  in EnterAsBatchGroupLeader()
439   Writer* w = leader;  in EnterAsBatchGroupLeader()
443     if (w->sync && !leader->sync) {  in EnterAsBatchGroupLeader()
448     if (w->no_slowdown != leader->no_slowdown) {  in EnterAsBatchGroupLeader()
454     if (w->disable_wal != leader->disable_wal) {  in EnterAsBatchGroupLeader()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader,  in EnterAsMemTableWriter()  argument
488   assert(leader != nullptr);  in EnterAsMemTableWriter()
489   assert(leader->link_older == nullptr);  in EnterAsMemTableWriter()
490   assert(leader->batch != nullptr);  in EnterAsMemTableWriter()
493   size_t size = WriteBatchInternal::ByteSize(leader->batch);  in EnterAsMemTableWriter()
504   leader->write_group = write_group;  in EnterAsMemTableWriter()
505   write_group->leader = leader;  in EnterAsMemTableWriter()
507   Writer* last_writer = leader;  in EnterAsMemTableWriter()
509   if (!allow_concurrent_memtable_write_ || !leader->batch->HasMerge()) {  in EnterAsMemTableWriter()
513     Writer* w = leader;  in EnterAsMemTableWriter()
547   Writer* leader = write_group.leader;  in ExitAsMemTableWriter()  local
559   Writer* w = leader;  in ExitAsMemTableWriter()
565     if (w != leader) {  in ExitAsMemTableWriter()
574   SetState(leader, STATE_COMPLETED);  in ExitAsMemTableWriter()
591     std::lock_guard<std::mutex> guard(write_group->leader->StateMutex());  in CompleteParallelMemTableWriter()
613   SetState(write_group->leader, STATE_COMPLETED);  in ExitAsBatchGroupFollower()
619   Writer* leader = write_group.leader;  in ExitAsBatchGroupLeader()  local
621   assert(leader->link_older == nullptr);  in ExitAsBatchGroupLeader()
630     for (Writer* w = last_writer; w != leader;) {  in ExitAsBatchGroupLeader()
638     if (!leader->ShouldWriteToMemtable()) {  in ExitAsBatchGroupLeader()
665         SetState(write_group.leader, STATE_MEMTABLE_WRITER_LEADER);  in ExitAsBatchGroupLeader()
687     AwaitState(leader, STATE_MEMTABLE_WRITER_LEADER |  in ExitAsBatchGroupLeader()
723     while (last_writer != leader) {  in ExitAsBatchGroupLeader()