APIGOV-28913 - fix race condition

Axway · Sep 30, 2024 · ade6cf1 · ade6cf1
1 parent 10008e6
commit ade6cf1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/agent/poller/client.go b/pkg/agent/poller/client.go
@@ -86,7 +86,10 @@ func (p *PollClient) Start() error {
 	if p.onStreamConnection != nil {
 		p.onStreamConnection()
 	}
+
+	p.mutex.Lock()
 	p.initialized = true
+	p.mutex.Unlock()
 
 	select {
 	case err := <-listenCh: