(ctx context.Context, index uint64)
| 384 | } |
| 385 | |
| 386 | func (r *Runtime) checkIfPrepareFinished(ctx context.Context, index uint64) (finished bool) { |
| 387 | defer trace.StartRegion(ctx, "checkIfPrepareFinished").End() |
| 388 | |
| 389 | r.pendingPreparesLock.RLock() |
| 390 | defer r.pendingPreparesLock.RUnlock() |
| 391 | |
| 392 | return !r.pendingPrepares[index] |
| 393 | } |
| 394 | |
| 395 | func (r *Runtime) markPendingPrepare(ctx context.Context, index uint64) { |
| 396 | defer trace.StartRegion(ctx, "markPendingPrepare").End() |
no test coverage detected