docker
/
docs
mirror of https://github.com/docker/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[SwarmCluster] Add RLock to Cluster.hasEngine 

Signed-off-by: Anton Tiurin <noxiouz@yandex.ru>
This commit is contained in:
Anton Tiurin 2015-04-08 22:25:54 +03:00
parent 14108ccaa1
commit b221baf4ed
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cluster/swarm/cluster.go
View File

@ -148,6 +148,9 @@ func (c *Cluster) newEntries(entries []*discovery.Entry) {
}
func (c *Cluster) hasEngine(addr string) bool {
c.RLock()
defer c.RUnlock()
for _, engine := range c.engines {
if engine.Addr == addr {
return true
@ -255,7 +258,7 @@ func (c *Cluster) listNodes() []*node.Node {
c.RLock()
defer c.RUnlock()
out := []*node.Node{}
out := make([]*node.Node, 0, len(c.engines))
for _, n := range c.engines {
out = append(out, node.NewNode(n))
}
@ -268,7 +271,7 @@ func (c *Cluster) listEngines() []*cluster.Engine {
c.RLock()
defer c.RUnlock()
out := []*cluster.Engine{}
out := make([]*cluster.Engine, 0, len(c.engines))
for _, n := range c.engines {
out = append(out, n)
}