Fix minor data race in Snowflake broker metrics

This commit is contained in:
Cecylia Bocovich 2025-02-19 17:53:38 -05:00
parent 1180d11a66
commit 63613cc50a
No known key found for this signature in database
GPG key ID: 009DE379FD9B7B90

View file

@ -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}