github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-31 16:46:54 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #92920 from gaurav1086/TestWatchBasedManager_fix_deadlock

Browse Source 
[test/kubelet]: Fix deadlock in watch manager test
This commit is contained in:
Kubernetes Prow Robot
2020-08-26 20:51:04 -07:00
committed by GitHub
parent 06eb495a0f 22dc4744a0
commit 343596b4d9
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/integration/kubelet/watch_manager_test.go
View File

@@ -40,6 +40,7 @@ func TestWatchBasedManager(t *testing.T) {
server := kubeapiservertesting.StartTestServerOrDie(t, nil, nil, framework.SharedEtcd())
defer server.TearDownFn()
const n = 10
server.ClientConfig.QPS = 10000
server.ClientConfig.Burst = 10000
client, err := kubernetes.NewForConfig(server.ClientConfig)
@@ -65,8 +66,8 @@ func TestWatchBasedManager(t *testing.T) {
// create 1000 secrets in parallel
t.Log(time.Now(), "creating 1000 secrets")
wg := sync.WaitGroup{}
errCh := make(chan error, 1)
for i := 0; i < 10; i++ {
errCh := make(chan error, n)
for i := 0; i < n; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
@@ -93,8 +94,8 @@ func TestWatchBasedManager(t *testing.T) {
// fetch all secrets
wg = sync.WaitGroup{}
errCh = make(chan error, 1)
for i := 0; i < 10; i++ {
errCh = make(chan error, n)
for i := 0; i < n; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()