update_test.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package container // import "github.com/docker/docker/integration/container"
  2. import (
  3. "context"
  4. "testing"
  5. "time"
  6. containertypes "github.com/docker/docker/api/types/container"
  7. "github.com/docker/docker/integration/internal/container"
  8. "github.com/docker/docker/internal/test/request"
  9. "github.com/gotestyourself/gotestyourself/assert"
  10. is "github.com/gotestyourself/gotestyourself/assert/cmp"
  11. "github.com/gotestyourself/gotestyourself/poll"
  12. )
  13. func TestUpdateRestartPolicy(t *testing.T) {
  14. defer setupTest(t)()
  15. client := request.NewAPIClient(t)
  16. ctx := context.Background()
  17. cID := container.Run(t, ctx, client, container.WithCmd("sh", "-c", "sleep 1 && false"), func(c *container.TestContainerConfig) {
  18. c.HostConfig.RestartPolicy = containertypes.RestartPolicy{
  19. Name: "on-failure",
  20. MaximumRetryCount: 3,
  21. }
  22. })
  23. _, err := client.ContainerUpdate(ctx, cID, containertypes.UpdateConfig{
  24. RestartPolicy: containertypes.RestartPolicy{
  25. Name: "on-failure",
  26. MaximumRetryCount: 5,
  27. },
  28. })
  29. assert.NilError(t, err)
  30. timeout := 60 * time.Second
  31. if testEnv.OSType == "windows" {
  32. timeout = 180 * time.Second
  33. }
  34. poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond), poll.WithTimeout(timeout))
  35. inspect, err := client.ContainerInspect(ctx, cID)
  36. assert.NilError(t, err)
  37. assert.Check(t, is.Equal(inspect.RestartCount, 5))
  38. assert.Check(t, is.Equal(inspect.HostConfig.RestartPolicy.MaximumRetryCount, 5))
  39. }
  40. func TestUpdateRestartWithAutoRemove(t *testing.T) {
  41. defer setupTest(t)()
  42. client := request.NewAPIClient(t)
  43. ctx := context.Background()
  44. cID := container.Run(t, ctx, client, func(c *container.TestContainerConfig) {
  45. c.HostConfig.AutoRemove = true
  46. })
  47. _, err := client.ContainerUpdate(ctx, cID, containertypes.UpdateConfig{
  48. RestartPolicy: containertypes.RestartPolicy{
  49. Name: "always",
  50. },
  51. })
  52. assert.Check(t, is.ErrorContains(err, "Restart policy cannot be updated because AutoRemove is enabled for the container"))
  53. }