Method doCommitCycle

kayak/commit.go:259–269

(req *commitReq)

}

func (r *Runtime) doCommitCycle(req *commitReq) {
	r.peersLock.RLock()
	defer r.peersLock.RUnlock()

	if r.role == proto.Leader {
		defer trace.StartRegion(req.ctx, "commitCycle").End()
		r.leaderDoCommit(req)
	} else {
		r.followerDoCommit(req)
	}
}