github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

handle recover from panic

Browse Source
This commit is contained in:
Sen Lu 2018-08-21 14:22:27 -07:00
parent 1a27e69a39
commit 333fe94bb9
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/e2e/instrumentation/logging/generic_soak.go
View File

@ -70,11 +70,12 @@ var _ = instrumentation.SIGDescribe("Logging soak [Performance] [Slow] [Disrupti
wg.Add(scale) wg.Add(scale)
for i := 0; i < scale; i++ { for i := 0; i < scale; i++ {
go func() { go func() {
defer wg.Done()
defer GinkgoRecover()
wave := fmt.Sprintf("wave%v", strconv.Itoa(i)) wave := fmt.Sprintf("wave%v", strconv.Itoa(i))
framework.Logf("Starting logging soak, wave = %v", wave) framework.Logf("Starting logging soak, wave = %v", wave)
RunLogPodsWithSleepOf(f, kbRateInSeconds, wave, totalLogTime) RunLogPodsWithSleepOf(f, kbRateInSeconds, wave, totalLogTime)
framework.Logf("Completed logging soak, wave %v", i) framework.Logf("Completed logging soak, wave %v", i)
wg.Done()
}() }()
// Niceness. // Niceness.
time.Sleep(millisecondsBetweenWaves) time.Sleep(millisecondsBetweenWaves)