From c0ea24830f7448112142d1d573272efe90532949 Mon Sep 17 00:00:00 2001 From: Poorna Date: Fri, 21 Jul 2023 23:33:55 -0400 Subject: [PATCH] replication: fixed typo in transfer stats (#1861) --- pkg/replication/replication.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/replication/replication.go b/pkg/replication/replication.go index 026ee7f2f..6776a0ba8 100644 --- a/pkg/replication/replication.go +++ b/pkg/replication/replication.go @@ -831,7 +831,7 @@ func (q ReplQueueStats) QStats() (r ReplQStats) { for _, node := range q.Nodes { r.Workers += int64(node.ActiveWorkers) for arn := range node.TgtXferStats { - xmap, ok := r.TgtXferStats[arn] + xmap, ok := node.TgtXferStats[arn] if !ok { xmap = make(map[MetricName]XferStats) } @@ -843,6 +843,9 @@ func (q ReplQueueStats) QStats() (r ReplQStats) { st.AvgRate += v.AvgRate st.CurrRate += v.CurrRate st.PeakRate = math.Max(st.PeakRate, v.PeakRate) + if _, ok := r.TgtXferStats[arn]; !ok { + r.TgtXferStats[arn] = make(map[MetricName]XferStats) + } r.TgtXferStats[arn][m] = st } }