docker_cli_events_unix_test.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  1. // +build !windows
  2. package main
  3. import (
  4. "bufio"
  5. "fmt"
  6. "io/ioutil"
  7. "os"
  8. "os/exec"
  9. "strings"
  10. "time"
  11. "unicode"
  12. "github.com/docker/docker/pkg/integration/checker"
  13. "github.com/go-check/check"
  14. "github.com/kr/pty"
  15. )
  16. // #5979
  17. func (s *DockerSuite) TestEventsRedirectStdout(c *check.C) {
  18. since := daemonTime(c).Unix()
  19. dockerCmd(c, "run", "busybox", "true")
  20. file, err := ioutil.TempFile("", "")
  21. c.Assert(err, checker.IsNil, check.Commentf("could not create temp file"))
  22. defer os.Remove(file.Name())
  23. command := fmt.Sprintf("%s events --since=%d --until=%d > %s", dockerBinary, since, daemonTime(c).Unix(), file.Name())
  24. _, tty, err := pty.Open()
  25. c.Assert(err, checker.IsNil, check.Commentf("Could not open pty"))
  26. cmd := exec.Command("sh", "-c", command)
  27. cmd.Stdin = tty
  28. cmd.Stdout = tty
  29. cmd.Stderr = tty
  30. c.Assert(cmd.Run(), checker.IsNil, check.Commentf("run err for command %q", command))
  31. scanner := bufio.NewScanner(file)
  32. for scanner.Scan() {
  33. for _, ch := range scanner.Text() {
  34. c.Assert(unicode.IsControl(ch), checker.False, check.Commentf("found control character %v", []byte(string(ch))))
  35. }
  36. }
  37. c.Assert(scanner.Err(), checker.IsNil, check.Commentf("Scan err for command %q", command))
  38. }
  39. func (s *DockerSuite) TestEventsOOMDisableFalse(c *check.C) {
  40. testRequires(c, DaemonIsLinux)
  41. testRequires(c, NativeExecDriver)
  42. testRequires(c, oomControl)
  43. testRequires(c, NotGCCGO)
  44. errChan := make(chan error)
  45. go func() {
  46. defer close(errChan)
  47. out, exitCode, _ := dockerCmdWithError("run", "--name", "oomFalse", "-m", "10MB", "busybox", "sh", "-c", "x=a; while true; do x=$x$x$x$x; done")
  48. if expected := 137; exitCode != expected {
  49. errChan <- fmt.Errorf("wrong exit code for OOM container: expected %d, got %d (output: %q)", expected, exitCode, out)
  50. }
  51. }()
  52. select {
  53. case err := <-errChan:
  54. c.Assert(err, checker.IsNil)
  55. case <-time.After(30 * time.Second):
  56. c.Fatal("Timeout waiting for container to die on OOM")
  57. }
  58. out, _ := dockerCmd(c, "events", "--since=0", "-f", "container=oomFalse", fmt.Sprintf("--until=%d", daemonTime(c).Unix()))
  59. events := strings.Split(strings.TrimSuffix(out, "\n"), "\n")
  60. c.Assert(len(events), checker.GreaterOrEqualThan, 5) //Missing expected event
  61. createEvent := strings.Fields(events[len(events)-5])
  62. attachEvent := strings.Fields(events[len(events)-4])
  63. startEvent := strings.Fields(events[len(events)-3])
  64. oomEvent := strings.Fields(events[len(events)-2])
  65. dieEvent := strings.Fields(events[len(events)-1])
  66. c.Assert(createEvent[len(createEvent)-1], checker.Equals, "create", check.Commentf("event should be create, not %#v", createEvent))
  67. c.Assert(attachEvent[len(attachEvent)-1], checker.Equals, "attach", check.Commentf("event should be attach, not %#v", attachEvent))
  68. c.Assert(startEvent[len(startEvent)-1], checker.Equals, "start", check.Commentf("event should be start, not %#v", startEvent))
  69. c.Assert(oomEvent[len(oomEvent)-1], checker.Equals, "oom", check.Commentf("event should be oom, not %#v", oomEvent))
  70. c.Assert(dieEvent[len(dieEvent)-1], checker.Equals, "die", check.Commentf("event should be die, not %#v", dieEvent))
  71. }
  72. func (s *DockerSuite) TestEventsOOMDisableTrue(c *check.C) {
  73. testRequires(c, DaemonIsLinux)
  74. testRequires(c, NativeExecDriver)
  75. testRequires(c, oomControl)
  76. testRequires(c, NotGCCGO)
  77. errChan := make(chan error)
  78. go func() {
  79. defer close(errChan)
  80. out, exitCode, _ := dockerCmdWithError("run", "--oom-kill-disable=true", "--name", "oomTrue", "-m", "10MB", "busybox", "sh", "-c", "x=a; while true; do x=$x$x$x$x; done")
  81. if expected := 137; exitCode != expected {
  82. errChan <- fmt.Errorf("wrong exit code for OOM container: expected %d, got %d (output: %q)", expected, exitCode, out)
  83. }
  84. }()
  85. select {
  86. case err := <-errChan:
  87. c.Assert(err, checker.IsNil)
  88. case <-time.After(20 * time.Second):
  89. defer dockerCmd(c, "kill", "oomTrue")
  90. out, _ := dockerCmd(c, "events", "--since=0", "-f", "container=oomTrue", fmt.Sprintf("--until=%d", daemonTime(c).Unix()))
  91. events := strings.Split(strings.TrimSuffix(out, "\n"), "\n")
  92. c.Assert(len(events), checker.GreaterOrEqualThan, 4) //Missing expected event
  93. createEvent := strings.Fields(events[len(events)-4])
  94. attachEvent := strings.Fields(events[len(events)-3])
  95. startEvent := strings.Fields(events[len(events)-2])
  96. oomEvent := strings.Fields(events[len(events)-1])
  97. c.Assert(createEvent[len(createEvent)-1], checker.Equals, "create", check.Commentf("event should be create, not %#v", createEvent))
  98. c.Assert(attachEvent[len(attachEvent)-1], checker.Equals, "attach", check.Commentf("event should be attach, not %#v", attachEvent))
  99. c.Assert(startEvent[len(startEvent)-1], checker.Equals, "start", check.Commentf("event should be start, not %#v", startEvent))
  100. c.Assert(oomEvent[len(oomEvent)-1], checker.Equals, "oom", check.Commentf("event should be oom, not %#v", oomEvent))
  101. out, _ = dockerCmd(c, "inspect", "-f", "{{.State.Status}}", "oomTrue")
  102. c.Assert(strings.TrimSpace(out), checker.Equals, "running", check.Commentf("container should be still running"))
  103. }
  104. }