replication: fixed typo in transfer stats (#1861)

minio · Jul 22, 2023 · c0ea248 · c0ea248
1 parent 8c81599
commit c0ea248
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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
 			}
 		}