From 0cd4099f7b500183fe528e8949278887d89afef6 Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Tue, 30 Jan 2024 16:31:07 +0100 Subject: [PATCH] Add locking to "wakeupChanForTesting" of GRPC clients. --- grpc_client_test.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/grpc_client_test.go b/grpc_client_test.go index a2db4b3..30e719e 100644 --- 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 }