From 1a5523bc2ead29b4e2705e84247392fdc111bbe6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BE=90=E8=81=AA?= Date: Thu, 14 Jul 2022 15:24:43 +0800 Subject: [PATCH] fix: unittest --- hrp/internal/boomer/runner.go | 1 - hrp/internal/boomer/runner_test.go | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/hrp/internal/boomer/runner.go b/hrp/internal/boomer/runner.go index c75d6769..675f69b9 100644 --- a/hrp/internal/boomer/runner.go +++ b/hrp/internal/boomer/runner.go @@ -383,7 +383,6 @@ func (r *runner) spawnWorkers(spawnCount int64, spawnRate float64, quit chan boo // spawn workers with rate limit sleepTime := time.Duration(1000000/r.controller.getSpawnRate()) * time.Microsecond time.Sleep(sleepTime) - // loop count per worker var workerLoop *Loop if r.loop != nil { diff --git a/hrp/internal/boomer/runner_test.go b/hrp/internal/boomer/runner_test.go index 4293103b..5b71e451 100644 --- a/hrp/internal/boomer/runner_test.go +++ b/hrp/internal/boomer/runner_test.go @@ -193,7 +193,7 @@ func TestSpawnWorkersWithManyTasks(t *testing.T) { runner.setTasks(tasks) runner.client = newClient("localhost", 5557, runner.nodeID) - const numToSpawn int64 = 30 + const numToSpawn int64 = 20 go runner.spawnWorkers(numToSpawn, float64(numToSpawn), runner.stopChan, runner.spawnComplete) time.Sleep(3 * time.Second)