Fix panic caused by concurrent writes to handshakes map

synadia-io · Aug 1, 2024 · 1fddd16 · 1fddd16
1 parent c4bd7be
commit 1fddd16
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/node/workload_mgr.go b/internal/node/workload_mgr.go
@@ -517,6 +517,9 @@ func (w *WorkloadManager) agentHandshakeTimedOut(id string) {
 }
 
 func (w *WorkloadManager) agentHandshakeSucceeded(workloadID string) {
+	w.poolMutex.Lock()
+	defer w.poolMutex.Unlock()
+
 	now := time.Now().UTC()
 	w.handshakes[workloadID] = now.Format(time.RFC3339)
 }