Method doLeaderRollback

kayak/processes.go:102–119

(ctx context.Context, tm *timer.Timer, prepareLog *kt.Log)

}

func (r *Runtime) doLeaderRollback(ctx context.Context, tm *timer.Timer, prepareLog *kt.Log) {
	defer trace.StartRegion(ctx, "doLeaderRollback").End()
	// rollback local
	var rollbackLog *kt.Log
	var logErr error
	if rollbackLog, logErr = r.leaderLogRollback(ctx, tm, prepareLog.Index); logErr != nil {
		// serve error, construct rollback log failed, internal error
		// TODO(): CHANGE LEADER
		return
	}

	defer trace.StartRegion(ctx, "followerRollback").End()

	// async send rollback to all nodes
	r.applyRPC(rollbackLog, 0)

	tm.Add("follower_rollback")
}

func (r *Runtime) leaderLogPrepare(ctx context.Context, tm *timer.Timer, data []byte) (*kt.Log, error) {
	defer trace.StartRegion(ctx, "leaderLogPrepare").End()