From e9425c04e8f242528a5ce0298994dc18d61bc905 Mon Sep 17 00:00:00 2001 From: Milind Yadav Date: Wed, 20 Aug 2025 17:10:12 +0530 Subject: [PATCH] UPSTREAM: 894: Adding SyncMutex to nodeipam unit tests --- pkg/controller/nodeipam/ipam/task_queue_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/controller/nodeipam/ipam/task_queue_test.go b/pkg/controller/nodeipam/ipam/task_queue_test.go index 744225c4ab..9a199cce70 100644 --- a/pkg/controller/nodeipam/ipam/task_queue_test.go +++ b/pkg/controller/nodeipam/ipam/task_queue_test.go @@ -32,10 +32,13 @@ func simpleKeyFun(obj interface{}) (string, error) { func TestTaskQueue(t *testing.T) { t.Parallel() synced := map[string]bool{} + var syncedMutex sync.Mutex doneCh := make(chan struct{}, 1) sync := func(key string) error { + syncedMutex.Lock() synced[key] = true + syncedMutex.Unlock() switch key { case "err": return errors.New("injected error")