diff --git a/pkg/node/controller.go b/pkg/node/controller.go index 96dee5b..6647063 100644 --- a/pkg/node/controller.go +++ b/pkg/node/controller.go @@ -255,19 +255,19 @@ func (c *Controller) GetAllStats() map[string]*StatsPayload { for _, peer := range peers { waitGroup.Add(1) - go func(p *Peer) { + go func(connectedPeer *Peer) { defer waitGroup.Done() - stats, err := c.GetRemoteStats(p.ID) + stats, err := c.GetRemoteStats(connectedPeer.ID) if err != nil { logging.Debug("failed to get stats from peer", logging.Fields{ - "peer_id": p.ID, - "peer": p.Name, + "peer_id": connectedPeer.ID, + "peer": connectedPeer.Name, "error": err.Error(), }) return // Skip failed peers } resultsMutex.Lock() - results[p.ID] = stats + results[connectedPeer.ID] = stats resultsMutex.Unlock() }(peer) }