From 63613cc50a1c32de4ca3c620cec90d9bc3bc561c Mon Sep 17 00:00:00 2001 From: Cecylia Bocovich Date: Wed, 19 Feb 2025 17:53:38 -0500 Subject: [PATCH] Fix minor data race in Snowflake broker metrics --- broker/ipc.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/broker/ipc.go b/broker/ipc.go index d0b4d47..f4f7f6b 100644 --- a/broker/ipc.go +++ b/broker/ipc.go @@ -214,7 +214,9 @@ func (i *IPC) ClientOffers(arg messages.Arg, response *[]byte) error { resp := &messages.ClientPollResponse{Answer: answer} err = sendClientResponse(resp, response) // Initial tracking of elapsed time. + i.ctx.metrics.lock.Lock() i.ctx.metrics.clientRoundtripEstimate = time.Since(startTime) / time.Millisecond + i.ctx.metrics.lock.Unlock() case <-time.After(time.Second * ClientTimeout): log.Println("Client: Timed out.") resp := &messages.ClientPollResponse{Error: messages.StrTimedOut}