(ctx context.Context, index uint64)
| 393 | } |
| 394 | |
| 395 | func (r *Runtime) markPendingPrepare(ctx context.Context, index uint64) { |
| 396 | defer trace.StartRegion(ctx, "markPendingPrepare").End() |
| 397 | |
| 398 | r.pendingPreparesLock.Lock() |
| 399 | defer r.pendingPreparesLock.Unlock() |
| 400 | |
| 401 | r.pendingPrepares[index] = true |
| 402 | } |
| 403 | |
| 404 | func (r *Runtime) markPrepareFinished(ctx context.Context, index uint64) { |
| 405 | defer trace.StartRegion(ctx, "markPrepareFinished").End() |
no test coverage detected