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}