Lines Matching refs:last_writer

263   Writer* last_writer = write_group.last_writer;  in LinkGroup()  local
264 Writer* w = last_writer; in LinkGroup()
278 if (newest_writer->compare_exchange_weak(newest, last_writer)) { in LinkGroup()
312 write_group.last_writer = nullptr; in CompleteLeader()
325 if (w == write_group.last_writer) { in CompleteFollower()
327 write_group.last_writer = w->link_older; in CompleteFollower()
434 write_group->last_writer = leader; in EnterAsBatchGroupLeader()
493 write_group->last_writer = w; in EnterAsBatchGroupLeader()
521 Writer* last_writer = leader; in EnterAsMemTableWriter() local
550 last_writer = w; in EnterAsMemTableWriter()
555 write_group->last_writer = last_writer; in EnterAsMemTableWriter()
557 last_writer->sequence + WriteBatchInternal::Count(last_writer->batch) - 1; in EnterAsMemTableWriter()
563 Writer* last_writer = write_group.last_writer; in ExitAsMemTableWriter() local
565 Writer* newest_writer = last_writer; in ExitAsMemTableWriter()
569 Writer* next_leader = last_writer->link_newer; in ExitAsMemTableWriter()
583 if (w == last_writer) { in ExitAsMemTableWriter()
638 Writer* last_writer = write_group.last_writer; in ExitAsBatchGroupLeader() local
654 for (Writer* w = last_writer; w != leader;) { in ExitAsBatchGroupLeader()
672 Writer* expected = last_writer; in ExitAsBatchGroupLeader()
677 next_leader = FindNextLeader(expected, last_writer); in ExitAsBatchGroupLeader()
678 assert(next_leader != nullptr && next_leader != last_writer); in ExitAsBatchGroupLeader()
716 if (head != last_writer || in ExitAsBatchGroupLeader()
725 assert(head != last_writer); in ExitAsBatchGroupLeader()
735 assert(last_writer->link_newer->link_older == last_writer); in ExitAsBatchGroupLeader()
736 last_writer->link_newer->link_older = nullptr; in ExitAsBatchGroupLeader()
742 SetState(last_writer->link_newer, STATE_GROUP_LEADER); in ExitAsBatchGroupLeader()
747 while (last_writer != leader) { in ExitAsBatchGroupLeader()
748 assert(last_writer); in ExitAsBatchGroupLeader()
749 last_writer->status = status; in ExitAsBatchGroupLeader()
753 auto next = last_writer->link_older; in ExitAsBatchGroupLeader()
754 SetState(last_writer, STATE_COMPLETED); in ExitAsBatchGroupLeader()
756 last_writer = next; in ExitAsBatchGroupLeader()