Merge pull request #1415 from mrjana/agent

Avoid double close of agentInitDone

libnetwork/agent.go

@@ -193,9 +193,12 @@ func (c *controller) agentSetup() error {
 		}
 	}
 
-	if c.agent != nil {
+	c.Lock()
+	if c.agent != nil && c.agentInitDone != nil {
 		close(c.agentInitDone)
+		c.agentInitDone = nil
 	}
+	c.Unlock()
 
 	return nil
 }

libnetwork/controller.go

@@ -347,7 +347,13 @@ func (c *controller) clusterAgentInit() {
 // AgentInitWait waits for agent initialization to be completed in the
 // controller.
 func (c *controller) AgentInitWait() {
-	<-c.agentInitDone
+	c.Lock()
+	agentInitDone := c.agentInitDone
+	c.Unlock()
+
+	if agentInitDone != nil {
+		<-agentInitDone
+	}
 }
 
 func (c *controller) makeDriverConfig(ntype string) map[string]interface{} {