ソースを参照

Merge pull request #16928 from coolljt0725/fix_16927

Fix docker daemon exit immediately after starting without -H option closes #16927
Antonio Murdaca 9 年 前
コミット
08c5f52d70

+ 3 - 0
docker/daemon.go

@@ -222,6 +222,9 @@ func (cli *DaemonCli) CmdDaemon(args ...string) error {
 		serverConfig.TLSConfig = tlsConfig
 	}
 
+	if len(commonFlags.Hosts) == 0 {
+		commonFlags.Hosts = make([]string, 1)
+	}
 	for i := 0; i < len(commonFlags.Hosts); i++ {
 		var err error
 		if commonFlags.Hosts[i], err = opts.ParseHost(commonFlags.Hosts[i]); err != nil {

+ 8 - 0
integration-cli/docker_cli_daemon_test.go

@@ -1715,3 +1715,11 @@ func (s *DockerDaemonSuite) TestDaemonCorruptedFluentdAddress(c *check.C) {
 		c.Fatalf("Expected %q message; but doesn't exist in log: %q, err: %v", expected, out, err)
 	}
 }
+
+func (s *DockerDaemonSuite) TestDaemonStartWithoutHost(c *check.C) {
+	s.d.useDefaultHost = true
+	defer func() {
+		s.d.useDefaultHost = false
+	}()
+	c.Assert(s.d.Start(), check.IsNil)
+}

+ 22 - 4
integration-cli/docker_utils.go

@@ -49,6 +49,7 @@ type Daemon struct {
 	execDriver     string
 	wait           chan error
 	userlandProxy  bool
+	useDefaultHost bool
 }
 
 // NewDaemon returns a Daemon instance to be used for testing.
@@ -101,12 +102,13 @@ func (d *Daemon) Start(arg ...string) error {
 
 	args := append(d.GlobalFlags,
 		d.Command,
-		"--host", d.sock(),
 		"--graph", d.root,
 		"--pidfile", fmt.Sprintf("%s/docker.pid", d.folder),
 		fmt.Sprintf("--userland-proxy=%t", d.userlandProxy),
 	)
-
+	if !d.useDefaultHost {
+		args = append(args, []string{"--host", d.sock()}...)
+	}
 	if root := os.Getenv("DOCKER_REMAP_ROOT"); root != "" {
 		args = append(args, []string{"--userns-remap", root}...)
 	}
@@ -168,7 +170,15 @@ func (d *Daemon) Start(arg ...string) error {
 		case <-time.After(2 * time.Second):
 			return fmt.Errorf("[%s] timeout: daemon does not respond", d.id)
 		case <-tick:
-			c, err := net.Dial("unix", filepath.Join(d.folder, "docker.sock"))
+			var (
+				c   net.Conn
+				err error
+			)
+			if d.useDefaultHost {
+				c, err = net.Dial("unix", "/var/run/docker.sock")
+			} else {
+				c, err = net.Dial("unix", filepath.Join(d.folder, "docker.sock"))
+			}
 			if err != nil {
 				continue
 			}
@@ -291,7 +301,15 @@ func (d *Daemon) Restart(arg ...string) error {
 func (d *Daemon) queryRootDir() (string, error) {
 	// update daemon root by asking /info endpoint (to support user
 	// namespaced daemon with root remapped uid.gid directory)
-	conn, err := net.Dial("unix", filepath.Join(d.folder, "docker.sock"))
+	var (
+		conn net.Conn
+		err  error
+	)
+	if d.useDefaultHost {
+		conn, err = net.Dial("unix", "/var/run/docker.sock")
+	} else {
+		conn, err = net.Dial("unix", filepath.Join(d.folder, "docker.sock"))
+	}
 	if err != nil {
 		return "", err
 	}