From 8237c94671c06a08a8b35ddbaa5d4b1bf84b51c5 Mon Sep 17 00:00:00 2001 From: Gaius Date: Fri, 10 May 2024 14:12:17 +0800 Subject: [PATCH] fix: DownloadPeerDuration observe cost by milliseconds (#3255) Signed-off-by: Gaius --- client-rs | 2 +- scheduler/service/service_v2.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/client-rs b/client-rs index 0b365fafd..6d13d8808 160000 --- a/client-rs +++ b/client-rs @@ -1 +1 @@ -Subproject commit 0b365fafdecf9f8d009ab49c7e22ec95e627de8b +Subproject commit 6d13d8808b763662971cc7aa4b0525b2f4866276 diff --git a/scheduler/service/service_v2.go b/scheduler/service/service_v2.go index 27ce89789..86803ba0b 100644 --- a/scheduler/service/service_v2.go +++ b/scheduler/service/service_v2.go @@ -1014,7 +1014,7 @@ func (v *V2) handleDownloadPeerFinishedRequest(ctx context.Context, peerID strin metrics.DownloadPeerCount.WithLabelValues(priority.String(), peer.Task.Type.String(), peer.Task.Tag, peer.Task.Application, peer.Host.Type.Name()).Inc() // TODO to be determined which traffic type to use, temporarily use TrafficType_REMOTE_PEER instead - metrics.DownloadPeerDuration.WithLabelValues(metrics.CalculateSizeLevel(peer.Task.ContentLength.Load()).String()).Observe(float64(peer.Cost.Load())) + metrics.DownloadPeerDuration.WithLabelValues(metrics.CalculateSizeLevel(peer.Task.ContentLength.Load()).String()).Observe(float64(peer.Cost.Load().Milliseconds())) return nil } @@ -1047,7 +1047,7 @@ func (v *V2) handleDownloadPeerBackToSourceFinishedRequest(ctx context.Context, metrics.DownloadPeerCount.WithLabelValues(priority.String(), peer.Task.Type.String(), peer.Task.Tag, peer.Task.Application, peer.Host.Type.Name()).Inc() // TODO to be determined which traffic type to use, temporarily use TrafficType_REMOTE_PEER instead - metrics.DownloadPeerDuration.WithLabelValues(metrics.CalculateSizeLevel(peer.Task.ContentLength.Load()).String()).Observe(float64(peer.Cost.Load())) + metrics.DownloadPeerDuration.WithLabelValues(metrics.CalculateSizeLevel(peer.Task.ContentLength.Load()).String()).Observe(float64(peer.Cost.Load().Milliseconds())) return nil }