diff --git a/aggregator/data.go b/aggregator/data.go index 8a83c8c..2406a21 100644 --- a/aggregator/data.go +++ b/aggregator/data.go @@ -1253,6 +1253,8 @@ func (a *Aggregator) updateSocketMap(ctx context.Context) { ticker := time.NewTicker(3 * time.Minute) f := func() { + a.liveProcessesMu.RLock() + defer a.liveProcessesMu.RUnlock() for pid := range a.liveProcesses { sockMap := a.clusterInfo.SocketMaps[pid] if sockMap.mu == nil {