From 6afb2156075b97ee51995b1108621107fd4f8cbb Mon Sep 17 00:00:00 2001 From: Mariano Ntrougkas <44480600+marios1861@users.noreply.github.com> Date: Mon, 20 Oct 2025 16:06:17 +0300 Subject: [PATCH] Refactor connection locking to use read lock Changed locking mechanism to use read lock for connection check. --- weed/worker/client.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/weed/worker/client.go b/weed/worker/client.go index a90eac643..c624b073f 100644 --- a/weed/worker/client.go +++ b/weed/worker/client.go @@ -73,13 +73,13 @@ func NewGrpcAdminClient(adminAddress string, workerID string, dialOption grpc.Di // Connect establishes gRPC connection to admin server with TLS detection func (c *GrpcAdminClient) Connect() error { - c.mutex.Lock() - defer c.mutex.Unlock() + c.mutex.RLock() if c.connected { + c.mutex.RUnlock() return fmt.Errorf("already connected") } - + c.mutex.RUnlock() // Always start the reconnection loop, even if initial connection fails go c.reconnectionLoop()