(ctx context.Context, tm *timer.Timer, i uint64)
| 126 | } |
| 127 | |
| 128 | func (r *Runtime) leaderLogRollback(ctx context.Context, tm *timer.Timer, i uint64) (*kt.Log, error) { |
| 129 | defer trace.StartRegion(ctx, "leaderLogRollback").End() |
| 130 | defer tm.Add("leader_log_rollback") |
| 131 | // just write new log |
| 132 | return r.newLog(ctx, kt.LogRollback, r.uint64ToBytes(i)) |
| 133 | } |
| 134 | |
| 135 | func (r *Runtime) followerPrepare(ctx context.Context, tm *timer.Timer, l *kt.Log, checkPrepare bool) (err error) { |
| 136 | defer func() { |
no test coverage detected