From 333fe94bb9ae1aef09684bcda4f1f8115216f7b0 Mon Sep 17 00:00:00 2001 From: Sen Lu Date: Tue, 21 Aug 2018 14:22:27 -0700 Subject: [PATCH] handle recover from panic --- test/e2e/instrumentation/logging/generic_soak.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/test/e2e/instrumentation/logging/generic_soak.go b/test/e2e/instrumentation/logging/generic_soak.go index acf58bfd029..d142e12b597 100644 --- a/test/e2e/instrumentation/logging/generic_soak.go +++ b/test/e2e/instrumentation/logging/generic_soak.go @@ -70,11 +70,12 @@ var _ = instrumentation.SIGDescribe("Logging soak [Performance] [Slow] [Disrupti wg.Add(scale) for i := 0; i < scale; i++ { go func() { + defer wg.Done() + defer GinkgoRecover() wave := fmt.Sprintf("wave%v", strconv.Itoa(i)) framework.Logf("Starting logging soak, wave = %v", wave) RunLogPodsWithSleepOf(f, kbRateInSeconds, wave, totalLogTime) framework.Logf("Completed logging soak, wave %v", i) - wg.Done() }() // Niceness. time.Sleep(millisecondsBetweenWaves)