make a copy of services

2016-08-24 18:27:15 +01:00 · 2016-08-24 18:27:15 +01:00 · 0afaaeec8d
commit 0afaaeec8d
parent 321358ae1f
1 changed files with 5 additions and 1 deletions
--- a/registry/consul_watcher.go
+++ b/registry/consul_watcher.go
@ -100,7 +100,11 @@ func (cw *consulWatcher) serviceHandler(idx uint64, data interface{}) {
 	}

 	cw.RLock()
-	rservices := cw.services
+	// make a copy
+	rservices := make(map[string][]*Service)
+	for k, v := range cw.services {
+		rservices[k] = v
+	}
 	cw.RUnlock()

 	var newServices []*Service