Handle --rm when starting a container

podman start should follow the same behaviour as podman run when removing a
container.

Signed-off-by: Daniel J Walsh <dwalsh@redhat.com>
This commit is contained in:
Daniel J Walsh
2020-12-09 14:13:53 -05:00
parent dd954781e6
commit 098e0a7885
6 changed files with 77 additions and 26 deletions

View File

@ -803,10 +803,6 @@ To generate systemd unit files, please see *podman generate systemd*
Automatically remove the container when it exits. The default is *false*. Automatically remove the container when it exits. The default is *false*.
Note that the container will not be removed when it could not be created or
started successfully. This allows the user to inspect the container after
failure.
#### **--rootfs** #### **--rootfs**
If specified, the first argument refers to an exploded container on the file system. If specified, the first argument refers to an exploded container on the file system.

View File

@ -840,10 +840,6 @@ To generate systemd unit files, please see **podman generate systemd**.
Automatically remove the container when it exits. The default is **false**. Automatically remove the container when it exits. The default is **false**.
Note that the container will not be removed when it could not be created or
started successfully. This allows the user to inspect the container after
failure.
#### **--rmi**=*true|false* #### **--rmi**=*true|false*
After exit of the container, remove the image unless another After exit of the container, remove the image unless another

View File

@ -12,6 +12,8 @@ import (
// Listcontainer describes a container suitable for listing // Listcontainer describes a container suitable for listing
type ListContainer struct { type ListContainer struct {
// AutoRemove
AutoRemove bool
// Container command // Container command
Command []string Command []string
// Container creation time // Container creation time

View File

@ -515,6 +515,29 @@ func (ic *ContainerEngine) ContainerStart(ctx context.Context, namesOrIds []stri
reports = append(reports, &report) reports = append(reports, &report)
return reports, errors.Wrapf(report.Err, "unable to start container %s", name) return reports, errors.Wrapf(report.Err, "unable to start container %s", name)
} }
if ctr.AutoRemove {
// Defer the removal, so we can return early if needed and
// de-spaghetti the code.
defer func() {
shouldRestart, err := containers.ShouldRestart(ic.ClientCxt, ctr.ID)
if err != nil {
logrus.Errorf("Failed to check if %s should restart: %v", ctr.ID, err)
return
}
if !shouldRestart {
if err := containers.Remove(ic.ClientCxt, ctr.ID, bindings.PFalse, bindings.PTrue); err != nil {
if errorhandling.Contains(err, define.ErrNoSuchCtr) ||
errorhandling.Contains(err, define.ErrCtrRemoved) {
logrus.Warnf("Container %s does not exist: %v", ctr.ID, err)
} else {
logrus.Errorf("Error removing container %s: %v", ctr.ID, err)
}
}
}
}()
}
exitCode, err := containers.Wait(ic.ClientCxt, name, nil) exitCode, err := containers.Wait(ic.ClientCxt, name, nil)
if err == define.ErrNoSuchCtr { if err == define.ErrNoSuchCtr {
// Check events // Check events
@ -535,6 +558,16 @@ func (ic *ContainerEngine) ContainerStart(ctx context.Context, namesOrIds []stri
if !ctrRunning { if !ctrRunning {
err = containers.Start(ic.ClientCxt, name, &options.DetachKeys) err = containers.Start(ic.ClientCxt, name, &options.DetachKeys)
if err != nil { if err != nil {
if ctr.AutoRemove {
if err := containers.Remove(ic.ClientCxt, ctr.ID, bindings.PFalse, bindings.PTrue); err != nil {
if errorhandling.Contains(err, define.ErrNoSuchCtr) ||
errorhandling.Contains(err, define.ErrCtrRemoved) {
logrus.Warnf("Container %s does not exist: %v", ctr.ID, err)
} else {
logrus.Errorf("Error removing container %s: %v", ctr.ID, err)
}
}
}
report.Err = errors.Wrapf(err, "unable to start container %q", name) report.Err = errors.Wrapf(err, "unable to start container %q", name)
report.ExitCode = define.ExitCode(err) report.ExitCode = define.ExitCode(err)
reports = append(reports, &report) reports = append(reports, &report)

View File

@ -179,24 +179,25 @@ func ListContainerBatch(rt *libpod.Runtime, ctr *libpod.Container, opts entities
} }
ps := entities.ListContainer{ ps := entities.ListContainer{
Command: conConfig.Command, AutoRemove: ctr.AutoRemove(),
Created: conConfig.CreatedTime, Command: conConfig.Command,
Exited: exited, Created: conConfig.CreatedTime,
ExitCode: exitCode, Exited: exited,
ExitedAt: exitedTime.Unix(), ExitCode: exitCode,
ID: conConfig.ID, ExitedAt: exitedTime.Unix(),
Image: conConfig.RootfsImageName, ID: conConfig.ID,
ImageID: conConfig.RootfsImageID, Image: conConfig.RootfsImageName,
IsInfra: conConfig.IsInfra, ImageID: conConfig.RootfsImageID,
Labels: conConfig.Labels, IsInfra: conConfig.IsInfra,
Mounts: ctr.UserVolumes(), Labels: conConfig.Labels,
Names: []string{conConfig.Name}, Mounts: ctr.UserVolumes(),
Pid: pid, Names: []string{conConfig.Name},
Pod: conConfig.Pod, Pid: pid,
Ports: portMappings, Pod: conConfig.Pod,
Size: size, Ports: portMappings,
StartedAt: startedTime.Unix(), Size: size,
State: conState.String(), StartedAt: startedTime.Unix(),
State: conState.String(),
} }
if opts.Pod && len(conConfig.Pod) > 0 { if opts.Pod && len(conConfig.Pod) > 0 {
podName, err := rt.GetName(conConfig.Pod) podName, err := rt.GetName(conConfig.Pod)

View File

@ -49,6 +49,29 @@ var _ = Describe("Podman start", func() {
Expect(session.ExitCode()).To(Equal(0)) Expect(session.ExitCode()).To(Equal(0))
}) })
It("podman start --rm removed on failure", func() {
session := podmanTest.Podman([]string{"create", "--name=test", "--rm", ALPINE, "foo"})
session.WaitWithDefaultTimeout()
Expect(session.ExitCode()).To(Equal(0))
session = podmanTest.Podman([]string{"start", "test"})
session.WaitWithDefaultTimeout()
Expect(session.ExitCode()).To(Equal(125))
session = podmanTest.Podman([]string{"container", "exists", "test"})
Expect(session.ExitCode()).To(Not(Equal(0)))
})
It("podman start --rm --attach removed on failure", func() {
session := podmanTest.Podman([]string{"create", "--rm", ALPINE, "foo"})
session.WaitWithDefaultTimeout()
Expect(session.ExitCode()).To(Equal(0))
cid := session.OutputToString()
session = podmanTest.Podman([]string{"start", "--attach", cid})
session.WaitWithDefaultTimeout()
Expect(session.ExitCode()).To(Equal(125))
session = podmanTest.Podman([]string{"container", "exists", cid})
Expect(session.ExitCode()).To(Not(Equal(0)))
})
It("podman container start single container by id", func() { It("podman container start single container by id", func() {
session := podmanTest.Podman([]string{"container", "create", ALPINE, "ls"}) session := podmanTest.Podman([]string{"container", "create", ALPINE, "ls"})
session.WaitWithDefaultTimeout() session.WaitWithDefaultTimeout()