From bee19638f198131e8041e8792040a419f3c544fb Mon Sep 17 00:00:00 2001 From: YamasouA Date: Fri, 28 Feb 2025 22:45:01 +0900 Subject: [PATCH] tweak --- test/integration/scheduler_perf/scheduler_perf.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/test/integration/scheduler_perf/scheduler_perf.go b/test/integration/scheduler_perf/scheduler_perf.go index 0cda120ff2f..192c6974b91 100644 --- a/test/integration/scheduler_perf/scheduler_perf.go +++ b/test/integration/scheduler_perf/scheduler_perf.go @@ -1628,7 +1628,7 @@ func (e *WorkloadExecutor) runBarrierOp(opIndex int, op *barrierOp) error { func (e *WorkloadExecutor) runSleepOp(op *sleepOp) { select { - case <-(e.tCtx).Done(): + case <-e.tCtx.Done(): case <-time.After(op.Duration.Duration): } } @@ -1825,7 +1825,7 @@ func (e *WorkloadExecutor) runChurnOp(opIndex int, op *churnOp) error { churnFns[i]("") } count++ - case <-(e.tCtx).Done(): + case <-e.tCtx.Done(): return } } @@ -1849,7 +1849,7 @@ func (e *WorkloadExecutor) runChurnOp(opIndex int, op *churnOp) error { retVals[i][count%op.Number] = churnFns[i](retVals[i][count%op.Number]) } count++ - case <-(e.tCtx).Done(): + case <-e.tCtx.Done(): return } }