Make inspect-rewrite wait if the start operation is still in progress

proxy/inspect_container_interceptor.go

@@ -22,19 +22,20 @@ func (i *inspectContainerInterceptor) InterceptResponse(r *http.Response) error
 		return err
 	}
 
-	if err := updateContainerNetworkSettings(container); err != nil {
+	if err := updateContainerNetworkSettings(container, i.proxy); err != nil {
 		Log.Warningf("Inspecting container %s failed: %s", container["Id"], err)
 	}
 
 	return marshalResponseBody(r, container)
 }
 
-func updateContainerNetworkSettings(container jsonObject) error {
+func updateContainerNetworkSettings(container jsonObject, proxy *Proxy) error {
 	containerID, err := container.String("Id")
 	if err != nil {
 		return err
 	}
 
+	proxy.waitForStartByIdent(containerID)
 	mac, ips, nets, err := weaveContainerIPs(containerID)
 	if err != nil || len(ips) == 0 {
 		return err

proxy/inspect_exec_interceptor.go

@@ -27,7 +27,7 @@ func (i *inspectExecInterceptor) InterceptResponse(r *http.Response) error {
 		return err
 	}
 
-	if err := updateContainerNetworkSettings(container); err != nil {
+	if err := updateContainerNetworkSettings(container, i.proxy); err != nil {
 		Log.Warningf("Inspecting exec %s failed: %s", exec["Id"], err)
 	}
 

proxy/proxy.go

@@ -358,6 +358,23 @@ func (proxy *Proxy) waitForStart(r *http.Request) error {
 	return nil
 }
 
+// If some other operation is waiting for a container to start, join in the wait
+func (proxy *Proxy) waitForStartByIdent(ident string) {
+	var ch chan struct{}
+	proxy.Lock()
+	for _, wait := range proxy.waiters {
+		if ident == wait.ident {
+			ch = wait.ch
+			break
+		}
+	}
+	proxy.Unlock()
+	if ch != nil {
+		Log.Debugf("Wait for start of container %s", ident)
+		<-ch
+	}
+}
+
 func (proxy *Proxy) ContainerDied(ident string) {
 }