From 57333d183176408c618da2d806f29856427f57f8 Mon Sep 17 00:00:00 2001 From: Fabian Reinartz Date: Fri, 1 Jul 2016 16:46:38 +0200 Subject: [PATCH] discovery/kubernetes: add missing locking --- retrieval/discovery/kubernetes/discovery.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/retrieval/discovery/kubernetes/discovery.go b/retrieval/discovery/kubernetes/discovery.go index 9e6574c07d..c2db40cb5d 100644 --- a/retrieval/discovery/kubernetes/discovery.go +++ b/retrieval/discovery/kubernetes/discovery.go @@ -408,7 +408,9 @@ func (kd *Discovery) watchNodes(events chan interface{}, done <-chan struct{}, r } // Reset the known nodes. + kd.nodesMu.Lock() kd.nodes = map[string]*Node{} + kd.nodesMu.Unlock() for _, node := range nodes { events <- &nodeEvent{Added, node} @@ -459,7 +461,9 @@ func (kd *Discovery) startServiceWatch(events chan<- interface{}, done <-chan st existingServices := kd.services // Reset the known services. + kd.servicesMu.Lock() kd.services = map[string]map[string]*Service{} + kd.servicesMu.Unlock() services, resourceVersion, err := kd.getServices() if err != nil {