etcd: Lock around read to prevent race
This commit is contained in:
@@ -54,7 +54,9 @@ func (obj *EmbdEtcd) setEndpoints() {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
obj.stateMutex.Lock()
|
||||||
eps := etcdUtil.FromURLsMapToStringList(obj.endpoints) // get flat list
|
eps := etcdUtil.FromURLsMapToStringList(obj.endpoints) // get flat list
|
||||||
|
obj.stateMutex.Unlock()
|
||||||
sort.Strings(eps) // sort for determinism
|
sort.Strings(eps) // sort for determinism
|
||||||
|
|
||||||
curls, _ := obj.curls() // ignore error, was already validated
|
curls, _ := obj.curls() // ignore error, was already validated
|
||||||
|
|||||||
Reference in New Issue
Block a user