Method followerPrepare

kayak/processes.go:135–165

(ctx context.Context, tm *timer.Timer, l *kt.Log, checkPrepare bool)

}

func (r *Runtime) followerPrepare(ctx context.Context, tm *timer.Timer, l *kt.Log, checkPrepare bool) (err error) {
	defer func() {
		log.WithField("r", l.Index).WithFields(tm.ToLogFields()).Debug("kayak follower prepare stat")
	}()

	// decode
	var req interface{}
	if req, err = r.doDecodePayload(ctx, l.Data); err != nil {
		return
	}
	tm.Add("decode")

	if checkPrepare {
		if err = r.doCheck(ctx, req); err != nil {
			return
		}
		tm.Add("check")
	}

	// write log
	if err = r.writeWAL(ctx, l); err != nil {
		return

	}
	tm.Add("write_wal")

	r.markPendingPrepare(ctx, l.Index)
	tm.Add("mark")

	return
}

func (r *Runtime) followerRollback(ctx context.Context, tm *timer.Timer, l *kt.Log) (err error) {
	var prepareLog *kt.Log