Browse Source

Merge pull request #1410 from mrjana/agent

Avoid k/v store endpoint update in swarm mode
Santhosh Manohar 9 years ago
parent
commit
301e41aff7
1 changed files with 8 additions and 0 deletions
  1. 8 0
      libnetwork/store.go

+ 8 - 0
libnetwork/store.go

@@ -346,6 +346,10 @@ func (c *controller) networkWatchLoop(nw *netWatch, ep *endpoint, ecCh <-chan da
 }
 }
 
 
 func (c *controller) processEndpointCreate(nmap map[string]*netWatch, ep *endpoint) {
 func (c *controller) processEndpointCreate(nmap map[string]*netWatch, ep *endpoint) {
+	if !c.isDistributedControl() && ep.getNetwork().driverScope() == datastore.GlobalScope {
+		return
+	}
+
 	c.Lock()
 	c.Lock()
 	nw, ok := nmap[ep.getNetwork().ID()]
 	nw, ok := nmap[ep.getNetwork().ID()]
 	c.Unlock()
 	c.Unlock()
@@ -400,6 +404,10 @@ func (c *controller) processEndpointCreate(nmap map[string]*netWatch, ep *endpoi
 }
 }
 
 
 func (c *controller) processEndpointDelete(nmap map[string]*netWatch, ep *endpoint) {
 func (c *controller) processEndpointDelete(nmap map[string]*netWatch, ep *endpoint) {
+	if !c.isDistributedControl() && ep.getNetwork().driverScope() == datastore.GlobalScope {
+		return
+	}
+
 	c.Lock()
 	c.Lock()
 	nw, ok := nmap[ep.getNetwork().ID()]
 	nw, ok := nmap[ep.getNetwork().ID()]