[FIX] Lock and lock the map

2024-11-30 02:38:17 +08:00 · 2018-09-27 12:19:27 +08:00 · 2018-09-27 12:19:27 +08:00 · b1e204f6d4
commit b1e204f6d4
parent 8d85d6d6fe
1 changed files with 2 additions and 0 deletions
--- a/node/nodem/healthy/health_manager.go
+++ b/node/nodem/healthy/health_manager.go
@ -256,7 +256,9 @@ func (p *probeManager) WatchServiceHealthy(serviceName string) Watcher {
 		serviceName: serviceName,
 	}
 	if s, ok := p.watches[serviceName]; ok {
+		p.lock.Lock()
 		s[w.id] = w
+		p.lock.Unlock()
 	} else {
 		p.lock.Lock()
 		p.watches[serviceName] = map[string]*watcher{