Add locking to "wakeupChanForTesting" of GRPC clients.

strukturag · Jan 30, 2024 · 0cd4099 · 0cd4099
1 parent c4fce20
commit 0cd4099
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/grpc_client_test.go b/grpc_client_test.go
@@ -37,6 +37,9 @@ import (
 )
 
 func (c *GrpcClients) getWakeupChannelForTesting() <-chan struct{} {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+
 	if c.wakeupChanForTesting != nil {
 		return c.wakeupChanForTesting
 	}