소스 검색

Fix docker daemon exit immediately after starting without -H option closes #16927

Signed-off-by: Lei Jitang <leijitang@huawei.com>
Lei Jitang 9 년 전
부모
커밋
e38767e197
3개의 변경된 파일33개의 추가작업 그리고 4개의 파일을 삭제
  1. 3 0
      docker/daemon.go
  2. 8 0
      integration-cli/docker_cli_daemon_test.go
  3. 22 4
      integration-cli/docker_utils.go

+ 3 - 0
docker/daemon.go

@@ -224,6 +224,9 @@ func (cli *DaemonCli) CmdDaemon(args ...string) error {
 		defaultHost = opts.DefaultTLSHost
 		defaultHost = opts.DefaultTLSHost
 	}
 	}
 
 
+	if len(commonFlags.Hosts) == 0 {
+		commonFlags.Hosts = make([]string, 1)
+	}
 	for i := 0; i < len(commonFlags.Hosts); i++ {
 	for i := 0; i < len(commonFlags.Hosts); i++ {
 		var err error
 		var err error
 		if commonFlags.Hosts[i], err = opts.ParseHost(defaultHost, commonFlags.Hosts[i]); err != nil {
 		if commonFlags.Hosts[i], err = opts.ParseHost(defaultHost, 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)
 		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
 	execDriver     string
 	wait           chan error
 	wait           chan error
 	userlandProxy  bool
 	userlandProxy  bool
+	useDefaultHost bool
 }
 }
 
 
 // NewDaemon returns a Daemon instance to be used for testing.
 // 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,
 	args := append(d.GlobalFlags,
 		d.Command,
 		d.Command,
-		"--host", d.sock(),
 		"--graph", d.root,
 		"--graph", d.root,
 		"--pidfile", fmt.Sprintf("%s/docker.pid", d.folder),
 		"--pidfile", fmt.Sprintf("%s/docker.pid", d.folder),
 		fmt.Sprintf("--userland-proxy=%t", d.userlandProxy),
 		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 != "" {
 	if root := os.Getenv("DOCKER_REMAP_ROOT"); root != "" {
 		args = append(args, []string{"--userns-remap", 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):
 		case <-time.After(2 * time.Second):
 			return fmt.Errorf("[%s] timeout: daemon does not respond", d.id)
 			return fmt.Errorf("[%s] timeout: daemon does not respond", d.id)
 		case <-tick:
 		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 {
 			if err != nil {
 				continue
 				continue
 			}
 			}
@@ -291,7 +301,15 @@ func (d *Daemon) Restart(arg ...string) error {
 func (d *Daemon) queryRootDir() (string, error) {
 func (d *Daemon) queryRootDir() (string, error) {
 	// update daemon root by asking /info endpoint (to support user
 	// update daemon root by asking /info endpoint (to support user
 	// namespaced daemon with root remapped uid.gid directory)
 	// 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 {
 	if err != nil {
 		return "", err
 		return "", err
 	}
 	}