Handle the case of reseting the Cluster Provider for leave caes

Signed-off-by: Madhu Venugopal <madhu@docker.com>
This commit is contained in:
Madhu Venugopal 2016-06-09 16:51:44 -07:00
parent 756acc23b9
commit 74fdcb1f4b

View file

@ -218,7 +218,9 @@ func New(cfgOptions ...config.Option) (NetworkController, error) {
func (c *controller) SetClusterProvider(provider cluster.Provider) {
c.cfg.Daemon.ClusterProvider = provider
go c.clusterAgentInit()
if provider != nil {
go c.clusterAgentInit()
}
}
func isValidClusteringIP(addr string) bool {
@ -261,6 +263,7 @@ func (c *controller) clusterAgentInit() {
} else {
c.agentInitDone = make(chan struct{})
c.agentClose()
return
}
}
}