123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214 |
- package container // import "github.com/docker/docker/integration/container"
- import (
- "context"
- "testing"
- "time"
- "github.com/docker/docker/api/types"
- containertypes "github.com/docker/docker/api/types/container"
- "github.com/docker/docker/api/types/network"
- "github.com/docker/docker/api/types/versions"
- "github.com/docker/docker/integration/internal/container"
- "github.com/docker/docker/pkg/stringid"
- "gotest.tools/v3/assert"
- is "gotest.tools/v3/assert/cmp"
- "gotest.tools/v3/poll"
- "gotest.tools/v3/skip"
- )
- // This test simulates the scenario mentioned in #31392:
- // Having two linked container, renaming the target and bringing a replacement
- // and then deleting and recreating the source container linked to the new target.
- // This checks that "rename" updates source container correctly and doesn't set it to null.
- func TestRenameLinkedContainer(t *testing.T) {
- skip.If(t, versions.LessThan(testEnv.DaemonAPIVersion(), "1.32"), "broken in earlier versions")
- skip.If(t, testEnv.OSType == "windows", "FIXME")
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- aName := "a0" + t.Name()
- bName := "b0" + t.Name()
- aID := container.Run(ctx, t, client, container.WithName(aName))
- bID := container.Run(ctx, t, client, container.WithName(bName), container.WithLinks(aName))
- err := client.ContainerRename(ctx, aID, "a1"+t.Name())
- assert.NilError(t, err)
- container.Run(ctx, t, client, container.WithName(aName))
- err = client.ContainerRemove(ctx, bID, types.ContainerRemoveOptions{Force: true})
- assert.NilError(t, err)
- bID = container.Run(ctx, t, client, container.WithName(bName), container.WithLinks(aName))
- inspect, err := client.ContainerInspect(ctx, bID)
- assert.NilError(t, err)
- assert.Check(t, is.DeepEqual([]string{"/" + aName + ":/" + bName + "/" + aName}, inspect.HostConfig.Links))
- }
- func TestRenameStoppedContainer(t *testing.T) {
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- oldName := "first_name" + t.Name()
- cID := container.Run(ctx, t, client, container.WithName(oldName), container.WithCmd("sh"))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))
- inspect, err := client.ContainerInspect(ctx, cID)
- assert.NilError(t, err)
- assert.Check(t, is.Equal("/"+oldName, inspect.Name))
- newName := "new_name" + stringid.GenerateRandomID()
- err = client.ContainerRename(ctx, oldName, newName)
- assert.NilError(t, err)
- inspect, err = client.ContainerInspect(ctx, cID)
- assert.NilError(t, err)
- assert.Check(t, is.Equal("/"+newName, inspect.Name))
- }
- func TestRenameRunningContainerAndReuse(t *testing.T) {
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- oldName := "first_name" + t.Name()
- cID := container.Run(ctx, t, client, container.WithName(oldName))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
- newName := "new_name" + stringid.GenerateRandomID()
- err := client.ContainerRename(ctx, oldName, newName)
- assert.NilError(t, err)
- inspect, err := client.ContainerInspect(ctx, cID)
- assert.NilError(t, err)
- assert.Check(t, is.Equal("/"+newName, inspect.Name))
- _, err = client.ContainerInspect(ctx, oldName)
- assert.Check(t, is.ErrorContains(err, "No such container: "+oldName))
- cID = container.Run(ctx, t, client, container.WithName(oldName))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
- inspect, err = client.ContainerInspect(ctx, cID)
- assert.NilError(t, err)
- assert.Check(t, is.Equal("/"+oldName, inspect.Name))
- }
- func TestRenameInvalidName(t *testing.T) {
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- oldName := "first_name" + t.Name()
- cID := container.Run(ctx, t, client, container.WithName(oldName))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
- err := client.ContainerRename(ctx, oldName, "new:invalid")
- assert.Check(t, is.ErrorContains(err, "Invalid container name"))
- inspect, err := client.ContainerInspect(ctx, oldName)
- assert.NilError(t, err)
- assert.Check(t, is.Equal(cID, inspect.ID))
- }
- // Test case for GitHub issue 22466
- // Docker's service discovery works for named containers so
- // ping to a named container should work, and an anonymous
- // container without a name does not work with service discovery.
- // However, an anonymous could be renamed to a named container.
- // This test is to make sure once the container has been renamed,
- // the service discovery for the (re)named container works.
- func TestRenameAnonymousContainer(t *testing.T) {
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- networkName := "network1" + t.Name()
- _, err := client.NetworkCreate(ctx, networkName, types.NetworkCreate{})
- assert.NilError(t, err)
- cID := container.Run(ctx, t, client, func(c *container.TestContainerConfig) {
- c.NetworkingConfig.EndpointsConfig = map[string]*network.EndpointSettings{
- networkName: {},
- }
- c.HostConfig.NetworkMode = containertypes.NetworkMode(networkName)
- })
- container1Name := "container1" + t.Name()
- err = client.ContainerRename(ctx, cID, container1Name)
- assert.NilError(t, err)
- // Stop/Start the container to get registered
- // FIXME(vdemeester) this is a really weird behavior as it fails otherwise
- err = client.ContainerStop(ctx, container1Name, nil)
- assert.NilError(t, err)
- err = client.ContainerStart(ctx, container1Name, types.ContainerStartOptions{})
- assert.NilError(t, err)
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
- count := "-c"
- if testEnv.OSType == "windows" {
- count = "-n"
- }
- cID = container.Run(ctx, t, client, func(c *container.TestContainerConfig) {
- c.NetworkingConfig.EndpointsConfig = map[string]*network.EndpointSettings{
- networkName: {},
- }
- c.HostConfig.NetworkMode = containertypes.NetworkMode(networkName)
- }, container.WithCmd("ping", count, "1", container1Name))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "exited"), poll.WithDelay(100*time.Millisecond))
- inspect, err := client.ContainerInspect(ctx, cID)
- assert.NilError(t, err)
- assert.Check(t, is.Equal(0, inspect.State.ExitCode), "container %s exited with the wrong exitcode: %s", cID, inspect.State.Error)
- }
- // TODO: should be a unit test
- func TestRenameContainerWithSameName(t *testing.T) {
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- oldName := "old" + t.Name()
- cID := container.Run(ctx, t, client, container.WithName(oldName))
- poll.WaitOn(t, container.IsInState(ctx, client, cID, "running"), poll.WithDelay(100*time.Millisecond))
- err := client.ContainerRename(ctx, oldName, oldName)
- assert.Check(t, is.ErrorContains(err, "Renaming a container with the same name"))
- err = client.ContainerRename(ctx, cID, oldName)
- assert.Check(t, is.ErrorContains(err, "Renaming a container with the same name"))
- }
- // Test case for GitHub issue 23973
- // When a container is being renamed, the container might
- // be linked to another container. In that case, the meta data
- // of the linked container should be updated so that the other
- // container could still reference to the container that is renamed.
- func TestRenameContainerWithLinkedContainer(t *testing.T) {
- skip.If(t, testEnv.IsRemoteDaemon)
- skip.If(t, testEnv.OSType == "windows", "FIXME")
- defer setupTest(t)()
- ctx := context.Background()
- client := testEnv.APIClient()
- db1Name := "db1" + t.Name()
- db1ID := container.Run(ctx, t, client, container.WithName(db1Name))
- poll.WaitOn(t, container.IsInState(ctx, client, db1ID, "running"), poll.WithDelay(100*time.Millisecond))
- app1Name := "app1" + t.Name()
- app2Name := "app2" + t.Name()
- app1ID := container.Run(ctx, t, client, container.WithName(app1Name), container.WithLinks(db1Name+":/mysql"))
- poll.WaitOn(t, container.IsInState(ctx, client, app1ID, "running"), poll.WithDelay(100*time.Millisecond))
- err := client.ContainerRename(ctx, app1Name, app2Name)
- assert.NilError(t, err)
- inspect, err := client.ContainerInspect(ctx, app2Name+"/mysql")
- assert.NilError(t, err)
- assert.Check(t, is.Equal(db1ID, inspect.ID))
- }
|