(ctx context.Context, l *kt.Log)
| 373 | } |
| 374 | |
| 375 | func (r *Runtime) updateNextIndex(ctx context.Context, l *kt.Log) { |
| 376 | defer trace.StartRegion(ctx, "updateNextIndex").End() |
| 377 | |
| 378 | r.nextIndexLock.Lock() |
| 379 | defer r.nextIndexLock.Unlock() |
| 380 | |
| 381 | if r.nextIndex < l.Index+1 { |
| 382 | r.nextIndex = l.Index + 1 |
| 383 | } |
| 384 | } |
| 385 | |
| 386 | func (r *Runtime) checkIfPrepareFinished(ctx context.Context, index uint64) (finished bool) { |
| 387 | defer trace.StartRegion(ctx, "checkIfPrepareFinished").End() |
no test coverage detected