add rlock for liveProcesses

getanteon · Jun 10, 2024 · 898bf3a · 898bf3a
1 parent 5c0d8b5
commit 898bf3a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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 {