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 }