docker_cli_exec_test.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601
  1. // +build !test_no_exec
  2. package main
  3. import (
  4. "bufio"
  5. "fmt"
  6. "net/http"
  7. "os"
  8. "os/exec"
  9. "reflect"
  10. "runtime"
  11. "sort"
  12. "strings"
  13. "sync"
  14. "time"
  15. "github.com/docker/docker/pkg/integration/checker"
  16. icmd "github.com/docker/docker/pkg/integration/cmd"
  17. "github.com/go-check/check"
  18. )
  19. func (s *DockerSuite) TestExec(c *check.C) {
  20. testRequires(c, DaemonIsLinux)
  21. out, _ := dockerCmd(c, "run", "-d", "--name", "testing", "busybox", "sh", "-c", "echo test > /tmp/file && top")
  22. c.Assert(waitRun(strings.TrimSpace(out)), check.IsNil)
  23. out, _ = dockerCmd(c, "exec", "testing", "cat", "/tmp/file")
  24. out = strings.Trim(out, "\r\n")
  25. c.Assert(out, checker.Equals, "test")
  26. }
  27. func (s *DockerSuite) TestExecInteractive(c *check.C) {
  28. testRequires(c, DaemonIsLinux)
  29. dockerCmd(c, "run", "-d", "--name", "testing", "busybox", "sh", "-c", "echo test > /tmp/file && top")
  30. execCmd := exec.Command(dockerBinary, "exec", "-i", "testing", "sh")
  31. stdin, err := execCmd.StdinPipe()
  32. c.Assert(err, checker.IsNil)
  33. stdout, err := execCmd.StdoutPipe()
  34. c.Assert(err, checker.IsNil)
  35. err = execCmd.Start()
  36. c.Assert(err, checker.IsNil)
  37. _, err = stdin.Write([]byte("cat /tmp/file\n"))
  38. c.Assert(err, checker.IsNil)
  39. r := bufio.NewReader(stdout)
  40. line, err := r.ReadString('\n')
  41. c.Assert(err, checker.IsNil)
  42. line = strings.TrimSpace(line)
  43. c.Assert(line, checker.Equals, "test")
  44. err = stdin.Close()
  45. c.Assert(err, checker.IsNil)
  46. errChan := make(chan error)
  47. go func() {
  48. errChan <- execCmd.Wait()
  49. close(errChan)
  50. }()
  51. select {
  52. case err := <-errChan:
  53. c.Assert(err, checker.IsNil)
  54. case <-time.After(1 * time.Second):
  55. c.Fatal("docker exec failed to exit on stdin close")
  56. }
  57. }
  58. func (s *DockerSuite) TestExecAfterContainerRestart(c *check.C) {
  59. out, _ := runSleepingContainer(c)
  60. cleanedContainerID := strings.TrimSpace(out)
  61. c.Assert(waitRun(cleanedContainerID), check.IsNil)
  62. dockerCmd(c, "restart", cleanedContainerID)
  63. c.Assert(waitRun(cleanedContainerID), check.IsNil)
  64. out, _ = dockerCmd(c, "exec", cleanedContainerID, "echo", "hello")
  65. outStr := strings.TrimSpace(out)
  66. c.Assert(outStr, checker.Equals, "hello")
  67. }
  68. func (s *DockerDaemonSuite) TestExecAfterDaemonRestart(c *check.C) {
  69. // TODO Windows CI: Requires a little work to get this ported.
  70. testRequires(c, DaemonIsLinux)
  71. testRequires(c, SameHostDaemon)
  72. err := s.d.StartWithBusybox()
  73. c.Assert(err, checker.IsNil)
  74. out, err := s.d.Cmd("run", "-d", "--name", "top", "-p", "80", "busybox:latest", "top")
  75. c.Assert(err, checker.IsNil, check.Commentf("Could not run top: %s", out))
  76. err = s.d.Restart()
  77. c.Assert(err, checker.IsNil, check.Commentf("Could not restart daemon"))
  78. out, err = s.d.Cmd("start", "top")
  79. c.Assert(err, checker.IsNil, check.Commentf("Could not start top after daemon restart: %s", out))
  80. out, err = s.d.Cmd("exec", "top", "echo", "hello")
  81. c.Assert(err, checker.IsNil, check.Commentf("Could not exec on container top: %s", out))
  82. outStr := strings.TrimSpace(string(out))
  83. c.Assert(outStr, checker.Equals, "hello")
  84. }
  85. // Regression test for #9155, #9044
  86. func (s *DockerSuite) TestExecEnv(c *check.C) {
  87. // TODO Windows CI: This one is interesting and may just end up being a feature
  88. // difference between Windows and Linux. On Windows, the environment is passed
  89. // into the process that is launched, not into the machine environment. Hence
  90. // a subsequent exec will not have LALA set/
  91. testRequires(c, DaemonIsLinux)
  92. runSleepingContainer(c, "-e", "LALA=value1", "-e", "LALA=value2", "-d", "--name", "testing")
  93. c.Assert(waitRun("testing"), check.IsNil)
  94. out, _ := dockerCmd(c, "exec", "testing", "env")
  95. c.Assert(out, checker.Not(checker.Contains), "LALA=value1")
  96. c.Assert(out, checker.Contains, "LALA=value2")
  97. c.Assert(out, checker.Contains, "HOME=/root")
  98. }
  99. func (s *DockerSuite) TestExecSetEnv(c *check.C) {
  100. testRequires(c, DaemonIsLinux)
  101. runSleepingContainer(c, "-e", "HOME=/root", "-d", "--name", "testing")
  102. c.Assert(waitRun("testing"), check.IsNil)
  103. out, _ := dockerCmd(c, "exec", "-e", "HOME=/another", "-e", "ABC=xyz", "testing", "env")
  104. c.Assert(out, checker.Not(checker.Contains), "HOME=/root")
  105. c.Assert(out, checker.Contains, "HOME=/another")
  106. c.Assert(out, checker.Contains, "ABC=xyz")
  107. }
  108. func (s *DockerSuite) TestExecExitStatus(c *check.C) {
  109. runSleepingContainer(c, "-d", "--name", "top")
  110. result := icmd.RunCommand(dockerBinary, "exec", "top", "sh", "-c", "exit 23")
  111. c.Assert(result, icmd.Matches, icmd.Expected{ExitCode: 23, Error: "exit status 23"})
  112. }
  113. func (s *DockerSuite) TestExecPausedContainer(c *check.C) {
  114. testRequires(c, IsPausable)
  115. defer unpauseAllContainers()
  116. out, _ := runSleepingContainer(c, "-d", "--name", "testing")
  117. ContainerID := strings.TrimSpace(out)
  118. dockerCmd(c, "pause", "testing")
  119. out, _, err := dockerCmdWithError("exec", "-i", "-t", ContainerID, "echo", "hello")
  120. c.Assert(err, checker.NotNil, check.Commentf("container should fail to exec new conmmand if it is paused"))
  121. expected := ContainerID + " is paused, unpause the container before exec"
  122. c.Assert(out, checker.Contains, expected, check.Commentf("container should not exec new command if it is paused"))
  123. }
  124. // regression test for #9476
  125. func (s *DockerSuite) TestExecTTYCloseStdin(c *check.C) {
  126. // TODO Windows CI: This requires some work to port to Windows.
  127. testRequires(c, DaemonIsLinux)
  128. dockerCmd(c, "run", "-d", "-it", "--name", "exec_tty_stdin", "busybox")
  129. cmd := exec.Command(dockerBinary, "exec", "-i", "exec_tty_stdin", "cat")
  130. stdinRw, err := cmd.StdinPipe()
  131. c.Assert(err, checker.IsNil)
  132. stdinRw.Write([]byte("test"))
  133. stdinRw.Close()
  134. out, _, err := runCommandWithOutput(cmd)
  135. c.Assert(err, checker.IsNil, check.Commentf(out))
  136. out, _ = dockerCmd(c, "top", "exec_tty_stdin")
  137. outArr := strings.Split(out, "\n")
  138. c.Assert(len(outArr), checker.LessOrEqualThan, 3, check.Commentf("exec process left running"))
  139. c.Assert(out, checker.Not(checker.Contains), "nsenter-exec")
  140. }
  141. func (s *DockerSuite) TestExecTTYWithoutStdin(c *check.C) {
  142. out, _ := dockerCmd(c, "run", "-d", "-ti", "busybox")
  143. id := strings.TrimSpace(out)
  144. c.Assert(waitRun(id), checker.IsNil)
  145. errChan := make(chan error)
  146. go func() {
  147. defer close(errChan)
  148. cmd := exec.Command(dockerBinary, "exec", "-ti", id, "true")
  149. if _, err := cmd.StdinPipe(); err != nil {
  150. errChan <- err
  151. return
  152. }
  153. expected := "the input device is not a TTY"
  154. if runtime.GOOS == "windows" {
  155. expected += ". If you are using mintty, try prefixing the command with 'winpty'"
  156. }
  157. if out, _, err := runCommandWithOutput(cmd); err == nil {
  158. errChan <- fmt.Errorf("exec should have failed")
  159. return
  160. } else if !strings.Contains(out, expected) {
  161. errChan <- fmt.Errorf("exec failed with error %q: expected %q", out, expected)
  162. return
  163. }
  164. }()
  165. select {
  166. case err := <-errChan:
  167. c.Assert(err, check.IsNil)
  168. case <-time.After(3 * time.Second):
  169. c.Fatal("exec is running but should have failed")
  170. }
  171. }
  172. func (s *DockerSuite) TestExecParseError(c *check.C) {
  173. // TODO Windows CI: Requires some extra work. Consider copying the
  174. // runSleepingContainer helper to have an exec version.
  175. testRequires(c, DaemonIsLinux)
  176. dockerCmd(c, "run", "-d", "--name", "top", "busybox", "top")
  177. // Test normal (non-detached) case first
  178. cmd := exec.Command(dockerBinary, "exec", "top")
  179. _, stderr, _, err := runCommandWithStdoutStderr(cmd)
  180. c.Assert(err, checker.NotNil)
  181. c.Assert(stderr, checker.Contains, "See 'docker exec --help'")
  182. }
  183. func (s *DockerSuite) TestExecStopNotHanging(c *check.C) {
  184. // TODO Windows CI: Requires some extra work. Consider copying the
  185. // runSleepingContainer helper to have an exec version.
  186. testRequires(c, DaemonIsLinux)
  187. dockerCmd(c, "run", "-d", "--name", "testing", "busybox", "top")
  188. err := exec.Command(dockerBinary, "exec", "testing", "top").Start()
  189. c.Assert(err, checker.IsNil)
  190. type dstop struct {
  191. out []byte
  192. err error
  193. }
  194. ch := make(chan dstop)
  195. go func() {
  196. out, err := exec.Command(dockerBinary, "stop", "testing").CombinedOutput()
  197. ch <- dstop{out, err}
  198. close(ch)
  199. }()
  200. select {
  201. case <-time.After(3 * time.Second):
  202. c.Fatal("Container stop timed out")
  203. case s := <-ch:
  204. c.Assert(s.err, check.IsNil)
  205. }
  206. }
  207. func (s *DockerSuite) TestExecCgroup(c *check.C) {
  208. // Not applicable on Windows - using Linux specific functionality
  209. testRequires(c, NotUserNamespace)
  210. testRequires(c, DaemonIsLinux)
  211. dockerCmd(c, "run", "-d", "--name", "testing", "busybox", "top")
  212. out, _ := dockerCmd(c, "exec", "testing", "cat", "/proc/1/cgroup")
  213. containerCgroups := sort.StringSlice(strings.Split(out, "\n"))
  214. var wg sync.WaitGroup
  215. var mu sync.Mutex
  216. execCgroups := []sort.StringSlice{}
  217. errChan := make(chan error)
  218. // exec a few times concurrently to get consistent failure
  219. for i := 0; i < 5; i++ {
  220. wg.Add(1)
  221. go func() {
  222. out, _, err := dockerCmdWithError("exec", "testing", "cat", "/proc/self/cgroup")
  223. if err != nil {
  224. errChan <- err
  225. return
  226. }
  227. cg := sort.StringSlice(strings.Split(out, "\n"))
  228. mu.Lock()
  229. execCgroups = append(execCgroups, cg)
  230. mu.Unlock()
  231. wg.Done()
  232. }()
  233. }
  234. wg.Wait()
  235. close(errChan)
  236. for err := range errChan {
  237. c.Assert(err, checker.IsNil)
  238. }
  239. for _, cg := range execCgroups {
  240. if !reflect.DeepEqual(cg, containerCgroups) {
  241. fmt.Println("exec cgroups:")
  242. for _, name := range cg {
  243. fmt.Printf(" %s\n", name)
  244. }
  245. fmt.Println("container cgroups:")
  246. for _, name := range containerCgroups {
  247. fmt.Printf(" %s\n", name)
  248. }
  249. c.Fatal("cgroups mismatched")
  250. }
  251. }
  252. }
  253. func (s *DockerSuite) TestExecInspectID(c *check.C) {
  254. out, _ := runSleepingContainer(c, "-d")
  255. id := strings.TrimSuffix(out, "\n")
  256. out = inspectField(c, id, "ExecIDs")
  257. c.Assert(out, checker.Equals, "[]", check.Commentf("ExecIDs should be empty, got: %s", out))
  258. // Start an exec, have it block waiting so we can do some checking
  259. cmd := exec.Command(dockerBinary, "exec", id, "sh", "-c",
  260. "while ! test -e /execid1; do sleep 1; done")
  261. err := cmd.Start()
  262. c.Assert(err, checker.IsNil, check.Commentf("failed to start the exec cmd"))
  263. // Give the exec 10 chances/seconds to start then give up and stop the test
  264. tries := 10
  265. for i := 0; i < tries; i++ {
  266. // Since its still running we should see exec as part of the container
  267. out = strings.TrimSpace(inspectField(c, id, "ExecIDs"))
  268. if out != "[]" && out != "<no value>" {
  269. break
  270. }
  271. c.Assert(i+1, checker.Not(checker.Equals), tries, check.Commentf("ExecIDs still empty after 10 second"))
  272. time.Sleep(1 * time.Second)
  273. }
  274. // Save execID for later
  275. execID, err := inspectFilter(id, "index .ExecIDs 0")
  276. c.Assert(err, checker.IsNil, check.Commentf("failed to get the exec id"))
  277. // End the exec by creating the missing file
  278. err = exec.Command(dockerBinary, "exec", id,
  279. "sh", "-c", "touch /execid1").Run()
  280. c.Assert(err, checker.IsNil, check.Commentf("failed to run the 2nd exec cmd"))
  281. // Wait for 1st exec to complete
  282. cmd.Wait()
  283. // Give the exec 10 chances/seconds to stop then give up and stop the test
  284. for i := 0; i < tries; i++ {
  285. // Since its still running we should see exec as part of the container
  286. out = strings.TrimSpace(inspectField(c, id, "ExecIDs"))
  287. if out == "[]" {
  288. break
  289. }
  290. c.Assert(i+1, checker.Not(checker.Equals), tries, check.Commentf("ExecIDs still not empty after 10 second"))
  291. time.Sleep(1 * time.Second)
  292. }
  293. // But we should still be able to query the execID
  294. sc, body, err := sockRequest("GET", "/exec/"+execID+"/json", nil)
  295. c.Assert(sc, checker.Equals, http.StatusOK, check.Commentf("received status != 200 OK: %d\n%s", sc, body))
  296. // Now delete the container and then an 'inspect' on the exec should
  297. // result in a 404 (not 'container not running')
  298. out, ec := dockerCmd(c, "rm", "-f", id)
  299. c.Assert(ec, checker.Equals, 0, check.Commentf("error removing container: %s", out))
  300. sc, body, err = sockRequest("GET", "/exec/"+execID+"/json", nil)
  301. c.Assert(sc, checker.Equals, http.StatusNotFound, check.Commentf("received status != 404: %d\n%s", sc, body))
  302. }
  303. func (s *DockerSuite) TestLinksPingLinkedContainersOnRename(c *check.C) {
  304. // Problematic on Windows as Windows does not support links
  305. testRequires(c, DaemonIsLinux)
  306. var out string
  307. out, _ = dockerCmd(c, "run", "-d", "--name", "container1", "busybox", "top")
  308. idA := strings.TrimSpace(out)
  309. c.Assert(idA, checker.Not(checker.Equals), "", check.Commentf("%s, id should not be nil", out))
  310. out, _ = dockerCmd(c, "run", "-d", "--link", "container1:alias1", "--name", "container2", "busybox", "top")
  311. idB := strings.TrimSpace(out)
  312. c.Assert(idB, checker.Not(checker.Equals), "", check.Commentf("%s, id should not be nil", out))
  313. dockerCmd(c, "exec", "container2", "ping", "-c", "1", "alias1", "-W", "1")
  314. dockerCmd(c, "rename", "container1", "container_new")
  315. dockerCmd(c, "exec", "container2", "ping", "-c", "1", "alias1", "-W", "1")
  316. }
  317. func (s *DockerSuite) TestRunMutableNetworkFiles(c *check.C) {
  318. // Not applicable on Windows to Windows CI.
  319. testRequires(c, SameHostDaemon, DaemonIsLinux)
  320. for _, fn := range []string{"resolv.conf", "hosts"} {
  321. deleteAllContainers()
  322. content, err := runCommandAndReadContainerFile(fn, exec.Command(dockerBinary, "run", "-d", "--name", "c1", "busybox", "sh", "-c", fmt.Sprintf("echo success >/etc/%s && top", fn)))
  323. c.Assert(err, checker.IsNil)
  324. c.Assert(strings.TrimSpace(string(content)), checker.Equals, "success", check.Commentf("Content was not what was modified in the container", string(content)))
  325. out, _ := dockerCmd(c, "run", "-d", "--name", "c2", "busybox", "top")
  326. contID := strings.TrimSpace(out)
  327. netFilePath := containerStorageFile(contID, fn)
  328. f, err := os.OpenFile(netFilePath, os.O_WRONLY|os.O_SYNC|os.O_APPEND, 0644)
  329. c.Assert(err, checker.IsNil)
  330. if _, err := f.Seek(0, 0); err != nil {
  331. f.Close()
  332. c.Fatal(err)
  333. }
  334. if err := f.Truncate(0); err != nil {
  335. f.Close()
  336. c.Fatal(err)
  337. }
  338. if _, err := f.Write([]byte("success2\n")); err != nil {
  339. f.Close()
  340. c.Fatal(err)
  341. }
  342. f.Close()
  343. res, _ := dockerCmd(c, "exec", contID, "cat", "/etc/"+fn)
  344. c.Assert(res, checker.Equals, "success2\n")
  345. }
  346. }
  347. func (s *DockerSuite) TestExecWithUser(c *check.C) {
  348. // TODO Windows CI: This may be fixable in the future once Windows
  349. // supports users
  350. testRequires(c, DaemonIsLinux)
  351. dockerCmd(c, "run", "-d", "--name", "parent", "busybox", "top")
  352. out, _ := dockerCmd(c, "exec", "-u", "1", "parent", "id")
  353. c.Assert(out, checker.Contains, "uid=1(daemon) gid=1(daemon)")
  354. out, _ = dockerCmd(c, "exec", "-u", "root", "parent", "id")
  355. c.Assert(out, checker.Contains, "uid=0(root) gid=0(root)", check.Commentf("exec with user by id expected daemon user got %s", out))
  356. }
  357. func (s *DockerSuite) TestExecWithPrivileged(c *check.C) {
  358. // Not applicable on Windows
  359. testRequires(c, DaemonIsLinux, NotUserNamespace)
  360. // Start main loop which attempts mknod repeatedly
  361. dockerCmd(c, "run", "-d", "--name", "parent", "--cap-drop=ALL", "busybox", "sh", "-c", `while (true); do if [ -e /exec_priv ]; then cat /exec_priv && mknod /tmp/sda b 8 0 && echo "Success"; else echo "Privileged exec has not run yet"; fi; usleep 10000; done`)
  362. // Check exec mknod doesn't work
  363. cmd := exec.Command(dockerBinary, "exec", "parent", "sh", "-c", "mknod /tmp/sdb b 8 16")
  364. out, _, err := runCommandWithOutput(cmd)
  365. c.Assert(err, checker.NotNil, check.Commentf("exec mknod in --cap-drop=ALL container without --privileged should fail"))
  366. c.Assert(out, checker.Contains, "Operation not permitted", check.Commentf("exec mknod in --cap-drop=ALL container without --privileged should fail"))
  367. // Check exec mknod does work with --privileged
  368. cmd = exec.Command(dockerBinary, "exec", "--privileged", "parent", "sh", "-c", `echo "Running exec --privileged" > /exec_priv && mknod /tmp/sdb b 8 16 && usleep 50000 && echo "Finished exec --privileged" > /exec_priv && echo ok`)
  369. out, _, err = runCommandWithOutput(cmd)
  370. c.Assert(err, checker.IsNil)
  371. actual := strings.TrimSpace(out)
  372. c.Assert(actual, checker.Equals, "ok", check.Commentf("exec mknod in --cap-drop=ALL container with --privileged failed, output: %q", out))
  373. // Check subsequent unprivileged exec cannot mknod
  374. cmd = exec.Command(dockerBinary, "exec", "parent", "sh", "-c", "mknod /tmp/sdc b 8 32")
  375. out, _, err = runCommandWithOutput(cmd)
  376. c.Assert(err, checker.NotNil, check.Commentf("repeating exec mknod in --cap-drop=ALL container after --privileged without --privileged should fail"))
  377. c.Assert(out, checker.Contains, "Operation not permitted", check.Commentf("repeating exec mknod in --cap-drop=ALL container after --privileged without --privileged should fail"))
  378. // Confirm at no point was mknod allowed
  379. logCmd := exec.Command(dockerBinary, "logs", "parent")
  380. out, _, err = runCommandWithOutput(logCmd)
  381. c.Assert(err, checker.IsNil)
  382. c.Assert(out, checker.Not(checker.Contains), "Success")
  383. }
  384. func (s *DockerSuite) TestExecWithImageUser(c *check.C) {
  385. // Not applicable on Windows
  386. testRequires(c, DaemonIsLinux)
  387. name := "testbuilduser"
  388. _, err := buildImage(name,
  389. `FROM busybox
  390. RUN echo 'dockerio:x:1001:1001::/bin:/bin/false' >> /etc/passwd
  391. USER dockerio`,
  392. true)
  393. c.Assert(err, checker.IsNil)
  394. dockerCmd(c, "run", "-d", "--name", "dockerioexec", name, "top")
  395. out, _ := dockerCmd(c, "exec", "dockerioexec", "whoami")
  396. c.Assert(out, checker.Contains, "dockerio", check.Commentf("exec with user by id expected dockerio user got %s", out))
  397. }
  398. func (s *DockerSuite) TestExecOnReadonlyContainer(c *check.C) {
  399. // Windows does not support read-only
  400. // --read-only + userns has remount issues
  401. testRequires(c, DaemonIsLinux, NotUserNamespace)
  402. dockerCmd(c, "run", "-d", "--read-only", "--name", "parent", "busybox", "top")
  403. dockerCmd(c, "exec", "parent", "true")
  404. }
  405. func (s *DockerSuite) TestExecUlimits(c *check.C) {
  406. testRequires(c, DaemonIsLinux)
  407. name := "testexeculimits"
  408. runSleepingContainer(c, "-d", "--ulimit", "nproc=21", "--name", name)
  409. c.Assert(waitRun(name), checker.IsNil)
  410. out, _, err := dockerCmdWithError("exec", name, "sh", "-c", "ulimit -p")
  411. c.Assert(err, checker.IsNil)
  412. c.Assert(strings.TrimSpace(out), checker.Equals, "21")
  413. }
  414. // #15750
  415. func (s *DockerSuite) TestExecStartFails(c *check.C) {
  416. // TODO Windows CI. This test should be portable. Figure out why it fails
  417. // currently.
  418. testRequires(c, DaemonIsLinux)
  419. name := "exec-15750"
  420. runSleepingContainer(c, "-d", "--name", name)
  421. c.Assert(waitRun(name), checker.IsNil)
  422. out, _, err := dockerCmdWithError("exec", name, "no-such-cmd")
  423. c.Assert(err, checker.NotNil, check.Commentf(out))
  424. c.Assert(out, checker.Contains, "executable file not found")
  425. }
  426. // Fix regression in https://github.com/docker/docker/pull/26461#issuecomment-250287297
  427. func (s *DockerSuite) TestExecWindowsPathNotWiped(c *check.C) {
  428. testRequires(c, DaemonIsWindows)
  429. out, _ := dockerCmd(c, "run", "-d", "--name", "testing", minimalBaseImage(), "powershell", "start-sleep", "60")
  430. c.Assert(waitRun(strings.TrimSpace(out)), check.IsNil)
  431. out, _ = dockerCmd(c, "exec", "testing", "powershell", "write-host", "$env:PATH")
  432. out = strings.ToLower(strings.Trim(out, "\r\n"))
  433. c.Assert(out, checker.Contains, `windowspowershell\v1.0`)
  434. }
  435. func (s *DockerSuite) TestExecEnvLinksHost(c *check.C) {
  436. testRequires(c, DaemonIsLinux)
  437. runSleepingContainer(c, "-d", "--name", "foo")
  438. runSleepingContainer(c, "-d", "--link", "foo:db", "--hostname", "myhost", "--name", "bar")
  439. out, _ := dockerCmd(c, "exec", "bar", "env")
  440. c.Assert(out, checker.Contains, "HOSTNAME=myhost")
  441. c.Assert(out, checker.Contains, "DB_NAME=/bar/db")
  442. }
  443. func (s *DockerSuite) TestExecWindowsOpenHandles(c *check.C) {
  444. testRequires(c, DaemonIsWindows)
  445. runSleepingContainer(c, "-d", "--name", "test")
  446. exec := make(chan bool)
  447. go func() {
  448. dockerCmd(c, "exec", "test", "cmd", "/c", "start sleep 10")
  449. exec <- true
  450. }()
  451. for {
  452. top := make(chan string)
  453. var out string
  454. go func() {
  455. out, _ := dockerCmd(c, "top", "test")
  456. top <- out
  457. }()
  458. select {
  459. case <-time.After(time.Second * 5):
  460. c.Error("timed out waiting for top while exec is exiting")
  461. case out = <-top:
  462. break
  463. }
  464. if strings.Count(out, "busybox.exe") == 2 && !strings.Contains(out, "cmd.exe") {
  465. // The initial exec process (cmd.exe) has exited, and both sleeps are currently running
  466. break
  467. }
  468. time.Sleep(1 * time.Second)
  469. }
  470. inspect := make(chan bool)
  471. go func() {
  472. dockerCmd(c, "inspect", "test")
  473. inspect <- true
  474. }()
  475. select {
  476. case <-time.After(time.Second * 5):
  477. c.Error("timed out waiting for inspect while exec is exiting")
  478. case <-inspect:
  479. break
  480. }
  481. // Ensure the background sleep is still running
  482. out, _ := dockerCmd(c, "top", "test")
  483. c.Assert(strings.Count(out, "busybox.exe"), checker.Equals, 2)
  484. // The exec should exit when the background sleep exits
  485. select {
  486. case <-time.After(time.Second * 15):
  487. c.Error("timed out waiting for async exec to exit")
  488. case <-exec:
  489. // Ensure the background sleep has actually exited
  490. out, _ := dockerCmd(c, "top", "test")
  491. c.Assert(strings.Count(out, "busybox.exe"), checker.Equals, 1)
  492. break
  493. }
  494. }