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

[test/kubelet]: Fix deadlock in watch manager test

Browse Source 
Signed-off-by: Gaurav Singh <gaurav1086@gmail.com>
This commit is contained in:
Gaurav Singh 2020-07-08 17:57:03 -04:00
parent 21953d15ea
commit 22dc4744a0
1 changed files with 5 additions and 4 deletions
Show Stats 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()) server := kubeapiservertesting.StartTestServerOrDie(t, nil, nil, framework.SharedEtcd())
defer server.TearDownFn() defer server.TearDownFn()
const n = 10
server.ClientConfig.QPS = 10000 server.ClientConfig.QPS = 10000
server.ClientConfig.Burst = 10000 server.ClientConfig.Burst = 10000
client, err := kubernetes.NewForConfig(server.ClientConfig) client, err := kubernetes.NewForConfig(server.ClientConfig)
@ -65,8 +66,8 @@ func TestWatchBasedManager(t *testing.T) {
// create 1000 secrets in parallel // create 1000 secrets in parallel
t.Log(time.Now(), "creating 1000 secrets") t.Log(time.Now(), "creating 1000 secrets")
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
errCh := make(chan error, 1) errCh := make(chan error, n)
for i := 0; i < 10; i++ { for i := 0; i < n; i++ {
wg.Add(1) wg.Add(1)
go func(i int) { go func(i int) {
defer wg.Done() defer wg.Done()
@ -93,8 +94,8 @@ func TestWatchBasedManager(t *testing.T) {
// fetch all secrets // fetch all secrets
wg = sync.WaitGroup{} wg = sync.WaitGroup{}
errCh = make(chan error, 1) errCh = make(chan error, n)
for i := 0; i < 10; i++ { for i := 0; i < n; i++ {
wg.Add(1) wg.Add(1)
go func(i int) { go func(i int) {
defer wg.Done() defer wg.Done()