github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-28 05:57:25 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #90498 from gaurav1086/fix_logging_race_condition

Browse Source 
Fix race condition in logging
This commit is contained in:
Kubernetes Prow Robot 2020-06-07 10:33:45 -07:00 committed by GitHub
commit 14559bc406
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -58,14 +58,14 @@ var _ = instrumentation.SIGDescribe("Logging soak [Performance] [Slow] [Disrupti
var wg sync.WaitGroup var wg sync.WaitGroup
wg.Add(loggingSoak.Scale) wg.Add(loggingSoak.Scale)
for i := 0; i < loggingSoak.Scale; i++ { for i := 0; i < loggingSoak.Scale; i++ {
go func() { go func(i int) {
defer wg.Done() defer wg.Done()
defer ginkgo.GinkgoRecover() defer ginkgo.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)
}() }(i)
// Niceness. // Niceness.
time.Sleep(loggingSoak.TimeBetweenWaves) time.Sleep(loggingSoak.TimeBetweenWaves)
} }