@@ -450,12 +450,12 @@ func (h *handler) handleSyncMsg(ctx context.Context, msg Message) error {
450450 var (
451451 endTime = h .clock .Time ()
452452 messageHistograms = h .metrics .messages [op ]
453- msgHandlingTime = lockAcquiredTime .Sub (startTime )
454453 processingTime = endTime .Sub (startTime )
454+ msgHandlingTime = endTime .Sub (lockAcquiredTime )
455455 )
456456 h .resourceTracker .StopProcessing (nodeID , endTime )
457- messageHistograms .msgHandlingTime .Observe (float64 (msgHandlingTime ))
458457 messageHistograms .processingTime .Observe (float64 (processingTime ))
458+ messageHistograms .msgHandlingTime .Observe (float64 (msgHandlingTime ))
459459 msg .OnFinishedHandling ()
460460 h .ctx .Log .Debug ("finished handling sync message" ,
461461 zap .Stringer ("messageOp" , op ),
@@ -869,11 +869,11 @@ func (h *handler) handleChanMsg(msg message.InboundMessage) error {
869869 var (
870870 endTime = h .clock .Time ()
871871 messageHistograms = h .metrics .messages [op ]
872- msgHandlingTime = lockAcquiredTime .Sub (startTime )
873872 processingTime = endTime .Sub (startTime )
873+ msgHandlingTime = endTime .Sub (lockAcquiredTime )
874874 )
875- messageHistograms .msgHandlingTime .Observe (float64 (msgHandlingTime ))
876875 messageHistograms .processingTime .Observe (float64 (processingTime ))
876+ messageHistograms .msgHandlingTime .Observe (float64 (msgHandlingTime ))
877877 msg .OnFinishedHandling ()
878878 h .ctx .Log .Debug ("finished handling chan message" ,
879879 zap .Stringer ("messageOp" , op ),
0 commit comments