Procházet zdrojové kódy

Merge pull request #322 from mavenugo/master

Ignoring locally scoped endpoints/networks from distributed delete
Jana Radhakrishnan před 10 roky
rodič
revize
420c3479f3
1 změnil soubory, kde provedl 8 přidání a 2 odebrání
  1. 8 2
      libnetwork/store.go

+ 8 - 2
libnetwork/store.go

@@ -191,7 +191,10 @@ func (c *controller) watchNetworks() error {
 				lview := c.networks
 				lview := c.networks
 				c.Unlock()
 				c.Unlock()
 				for k, v := range lview {
 				for k, v := range lview {
-					tmpview[k] = v
+					global, _ := v.isGlobalScoped()
+					if global {
+						tmpview[k] = v
+					}
 				}
 				}
 				c.processNetworkUpdate(nws, &tmpview)
 				c.processNetworkUpdate(nws, &tmpview)
 				// Delete processing
 				// Delete processing
@@ -243,7 +246,10 @@ func (n *network) watchEndpoints() error {
 				lview := n.endpoints
 				lview := n.endpoints
 				n.Unlock()
 				n.Unlock()
 				for k, v := range lview {
 				for k, v := range lview {
-					tmpview[k] = v
+					global, _ := v.network.isGlobalScoped()
+					if global {
+						tmpview[k] = v
+					}
 				}
 				}
 				for _, epe := range eps {
 				for _, epe := range eps {
 					var ep endpoint
 					var ep endpoint