Lines Matching refs:leader
958 auto* leader = write_group.leader; in MergeBatch() local
959 assert(!leader->disable_wal); // Same holds for all in the batch group in MergeBatch()
960 if (write_group.size == 1 && !leader->CallbackFailed() && in MergeBatch()
961 leader->batch->GetWalTerminationPoint().is_cleared()) { in MergeBatch()
965 merged_batch = leader->batch; in MergeBatch()
1030 assert(!write_group.leader->disable_wal); in WriteToWAL()
1036 if (merged_batch == write_group.leader->batch) { in WriteToWAL()
1037 write_group.leader->log_used = logfile_number_; in WriteToWAL()
1099 assert(!write_group.leader->disable_wal); in ConcurrentWriteToWAL()
1110 if (merged_batch == write_group.leader->batch) { in ConcurrentWriteToWAL()
1111 write_group.leader->log_used = logfile_number_; in ConcurrentWriteToWAL()