Add mutex lock to updateServer

Signed-off-by: Alex Leong <[email protected]>
linkerd · Jul 25, 2023 · be35415 · be35415
1 parent 32831ba
commit be35415
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/controller/api/destination/watcher/endpoints_watcher.go b/controller/api/destination/watcher/endpoints_watcher.go
@@ -593,6 +593,9 @@ func (sp *servicePublisher) metricsLabels(port Port, hostname string) prometheus
 }
 
 func (sp *servicePublisher) updateServer(server *v1beta1.Server, isAdd bool) {
+	sp.Lock()
+	defer sp.Unlock()
+
 	selector, err := metav1.LabelSelectorAsSelector(server.Spec.PodSelector)
 	if err != nil {
 		sp.log.Errorf("failed to create Selector: %s", err)