pause_test.go 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. package container // import "github.com/docker/docker/integration/container"
  2. import (
  3. "context"
  4. "io"
  5. "testing"
  6. "time"
  7. "github.com/docker/docker/api/types"
  8. "github.com/docker/docker/api/types/events"
  9. "github.com/docker/docker/api/types/filters"
  10. "github.com/docker/docker/integration/internal/container"
  11. "github.com/docker/docker/integration/internal/request"
  12. "github.com/docker/docker/internal/testutil"
  13. "github.com/gotestyourself/gotestyourself/poll"
  14. "github.com/gotestyourself/gotestyourself/skip"
  15. "github.com/stretchr/testify/assert"
  16. "github.com/stretchr/testify/require"
  17. )
  18. func TestPause(t *testing.T) {
  19. skip.If(t, testEnv.DaemonInfo.OSType == "windows" && testEnv.DaemonInfo.Isolation == "process")
  20. defer setupTest(t)()
  21. client := request.NewAPIClient(t)
  22. ctx := context.Background()
  23. cID := container.Run(t, ctx, client)
  24. poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
  25. since := request.DaemonUnixTime(ctx, t, client, testEnv)
  26. err := client.ContainerPause(ctx, cID)
  27. require.NoError(t, err)
  28. inspect, err := client.ContainerInspect(ctx, cID)
  29. require.NoError(t, err)
  30. assert.Equal(t, inspect.State.Paused, true)
  31. err = client.ContainerUnpause(ctx, cID)
  32. require.NoError(t, err)
  33. until := request.DaemonUnixTime(ctx, t, client, testEnv)
  34. messages, errs := client.Events(ctx, types.EventsOptions{
  35. Since: since,
  36. Until: until,
  37. Filters: filters.NewArgs(filters.Arg("container", cID)),
  38. })
  39. assert.Equal(t, getEventActions(t, messages, errs), []string{"pause", "unpause"})
  40. }
  41. func TestPauseFailsOnWindowsServerContainers(t *testing.T) {
  42. skip.If(t, (testEnv.DaemonInfo.OSType != "windows" || testEnv.DaemonInfo.Isolation != "process"))
  43. defer setupTest(t)()
  44. client := request.NewAPIClient(t)
  45. ctx := context.Background()
  46. cID := container.Run(t, ctx, client)
  47. poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
  48. err := client.ContainerPause(ctx, cID)
  49. testutil.ErrorContains(t, err, "cannot pause Windows Server Containers")
  50. }
  51. func TestPauseStopPausedContainer(t *testing.T) {
  52. skip.If(t, testEnv.DaemonInfo.OSType != "linux")
  53. defer setupTest(t)()
  54. client := request.NewAPIClient(t)
  55. ctx := context.Background()
  56. cID := container.Run(t, ctx, client)
  57. poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
  58. err := client.ContainerPause(ctx, cID)
  59. require.NoError(t, err)
  60. err = client.ContainerStop(ctx, cID, nil)
  61. require.NoError(t, err)
  62. poll.WaitOn(t, container.IsStopped(ctx, client, cID), poll.WithDelay(100*time.Millisecond))
  63. }
  64. func getEventActions(t *testing.T, messages <-chan events.Message, errs <-chan error) []string {
  65. actions := []string{}
  66. for {
  67. select {
  68. case err := <-errs:
  69. assert.Equal(t, err == nil || err == io.EOF, true)
  70. return actions
  71. case e := <-messages:
  72. actions = append(actions, e.Status)
  73. }
  74. }
  75. }