Skip to content

Commit

Permalink
Merge pull request containers#9401 from rhatdan/stop
Browse files Browse the repository at this point in the history
podman kill should report rawInput not container id
  • Loading branch information
openshift-merge-robot authored Feb 16, 2021
2 parents 7fb347a + 958f901 commit fb6f143
Show file tree
Hide file tree
Showing 5 changed files with 35 additions and 9 deletions.
2 changes: 1 addition & 1 deletion cmd/podman/containers/kill.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ func kill(_ *cobra.Command, args []string) error {
}
for _, r := range responses {
if r.Err == nil {
fmt.Println(r.Id)
fmt.Println(r.RawInput)
} else {
errs = append(errs, r.Err)
}
Expand Down
5 changes: 3 additions & 2 deletions pkg/domain/entities/containers.go
Original file line number Diff line number Diff line change
Expand Up @@ -110,8 +110,9 @@ type KillOptions struct {
}

type KillReport struct {
Err error
Id string //nolint
Err error
Id string //nolint
RawInput string
}

type RestartOptions struct {
Expand Down
13 changes: 10 additions & 3 deletions pkg/domain/infra/abi/containers.go
Original file line number Diff line number Diff line change
Expand Up @@ -208,15 +208,22 @@ func (ic *ContainerEngine) ContainerKill(ctx context.Context, namesOrIds []strin
if err != nil {
return nil, err
}
ctrs, err := getContainersByContext(options.All, options.Latest, namesOrIds, ic.Libpod)
ctrs, rawInputs, err := getContainersAndInputByContext(options.All, options.Latest, namesOrIds, ic.Libpod)
if err != nil {
return nil, err
}
ctrMap := map[string]string{}
if len(rawInputs) == len(ctrs) {
for i := range ctrs {
ctrMap[ctrs[i].ID()] = rawInputs[i]
}
}
reports := make([]*entities.KillReport, 0, len(ctrs))
for _, con := range ctrs {
reports = append(reports, &entities.KillReport{
Id: con.ID(),
Err: con.Kill(uint(sig)),
Id: con.ID(),
Err: con.Kill(uint(sig)),
RawInput: ctrMap[con.ID()],
})
}
return reports, nil
Expand Down
11 changes: 8 additions & 3 deletions pkg/domain/infra/tunnel/containers.go
Original file line number Diff line number Diff line change
Expand Up @@ -124,16 +124,21 @@ func (ic *ContainerEngine) ContainerStop(ctx context.Context, namesOrIds []strin
}

func (ic *ContainerEngine) ContainerKill(ctx context.Context, namesOrIds []string, opts entities.KillOptions) ([]*entities.KillReport, error) {
ctrs, err := getContainersByContext(ic.ClientCtx, opts.All, false, namesOrIds)
ctrs, rawInputs, err := getContainersAndInputByContext(ic.ClientCtx, opts.All, false, namesOrIds)
if err != nil {
return nil, err
}
ctrMap := map[string]string{}
for i := range ctrs {
ctrMap[ctrs[i].ID] = rawInputs[i]
}
options := new(containers.KillOptions).WithSignal(opts.Signal)
reports := make([]*entities.KillReport, 0, len(ctrs))
for _, c := range ctrs {
reports = append(reports, &entities.KillReport{
Id: c.ID,
Err: containers.Kill(ic.ClientCtx, c.ID, options),
Id: c.ID,
Err: containers.Kill(ic.ClientCtx, c.ID, options),
RawInput: ctrMap[c.ID],
})
}
return reports, nil
Expand Down
13 changes: 13 additions & 0 deletions test/e2e/kill_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,19 @@ var _ = Describe("Podman kill", func() {
Expect(podmanTest.NumberOfContainersRunning()).To(Equal(0))
})

It("podman container kill a running container by short id", func() {
session := podmanTest.RunTopContainer("")
session.WaitWithDefaultTimeout()
Expect(session.ExitCode()).To(Equal(0))
cid := session.OutputToString()

result := podmanTest.Podman([]string{"container", "kill", cid[:5]})
result.WaitWithDefaultTimeout()
Expect(result.ExitCode()).To(Equal(0))
Expect(result.OutputToString()).To(Equal(cid[:5]))
Expect(podmanTest.NumberOfContainersRunning()).To(Equal(0))
})

It("podman kill a running container by id", func() {
session := podmanTest.RunTopContainer("")
session.WaitWithDefaultTimeout()
Expand Down

0 comments on commit fb6f143

Please sign in to comment.