mirror of
https://github.com/containers/podman.git
synced 2025-08-06 11:32:07 +08:00
5923656f32
This change was missed in pull/8689. Now that volume pruneing supports filters system pruneing can pass its filters down to the volume pruneing. Additionally this change adds tests for the following components * podman system prune subcommand with `--volumes` & `--filter` options * apiv2 api tests for `/system/` and `/libpod/system` endpoints Relates to #8453, #8672 Signed-off-by: Baron Lenardson <lenardson.baron@gmail.com>
219 lines
7.6 KiB
Go
219 lines
7.6 KiB
Go
package test_bindings
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/containers/podman/v2/pkg/bindings"
|
|
"github.com/containers/podman/v2/pkg/bindings/containers"
|
|
"github.com/containers/podman/v2/pkg/bindings/pods"
|
|
"github.com/containers/podman/v2/pkg/bindings/system"
|
|
"github.com/containers/podman/v2/pkg/bindings/volumes"
|
|
"github.com/containers/podman/v2/pkg/domain/entities"
|
|
. "github.com/onsi/ginkgo"
|
|
. "github.com/onsi/gomega"
|
|
"github.com/onsi/gomega/gexec"
|
|
)
|
|
|
|
var _ = Describe("Podman system", func() {
|
|
var (
|
|
bt *bindingTest
|
|
s *gexec.Session
|
|
newpod string
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
bt = newBindingTest()
|
|
bt.RestoreImagesFromCache()
|
|
newpod = "newpod"
|
|
bt.Podcreate(&newpod)
|
|
s = bt.startAPIService()
|
|
time.Sleep(1 * time.Second)
|
|
err := bt.NewConnection()
|
|
Expect(err).To(BeNil())
|
|
})
|
|
|
|
AfterEach(func() {
|
|
s.Kill()
|
|
bt.cleanup()
|
|
})
|
|
|
|
It("podman events", func() {
|
|
var name = "top"
|
|
_, err := bt.RunTopContainer(&name, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
filters := make(map[string][]string)
|
|
filters["container"] = []string{name}
|
|
|
|
binChan := make(chan entities.Event)
|
|
done := sync.Mutex{}
|
|
done.Lock()
|
|
eventCounter := 0
|
|
go func() {
|
|
defer done.Unlock()
|
|
for range binChan {
|
|
eventCounter++
|
|
}
|
|
}()
|
|
options := new(system.EventsOptions).WithFilters(filters).WithStream(false)
|
|
err = system.Events(bt.conn, binChan, nil, options)
|
|
Expect(err).To(BeNil())
|
|
done.Lock()
|
|
Expect(eventCounter).To(BeNumerically(">", 0))
|
|
})
|
|
|
|
It("podman system prune - pod,container stopped", func() {
|
|
// Start and stop a pod to enter in exited state.
|
|
_, err := pods.Start(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
_, err = pods.Stop(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
// Start and stop a container to enter in exited state.
|
|
var name = "top"
|
|
_, err = bt.RunTopContainer(&name, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
err = containers.Stop(bt.conn, name, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
options := new(system.PruneOptions).WithAll(true)
|
|
systemPruneResponse, err := system.Prune(bt.conn, options)
|
|
Expect(err).To(BeNil())
|
|
Expect(len(systemPruneResponse.PodPruneReport)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ContainerPruneReport.ID)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ImagePruneReport.Report.Id)).
|
|
To(BeNumerically(">", 0))
|
|
Expect(systemPruneResponse.ImagePruneReport.Report.Id).
|
|
To(ContainElement("docker.io/library/alpine:latest"))
|
|
Expect(len(systemPruneResponse.VolumePruneReport)).To(Equal(0))
|
|
})
|
|
|
|
It("podman system prune running alpine container", func() {
|
|
// Start and stop a pod to enter in exited state.
|
|
_, err := pods.Start(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
_, err = pods.Stop(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start and stop a container to enter in exited state.
|
|
var name = "top"
|
|
_, err = bt.RunTopContainer(&name, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
err = containers.Stop(bt.conn, name, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start container and leave in running
|
|
var name2 = "top2"
|
|
_, err = bt.RunTopContainer(&name2, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Adding an unused volume
|
|
_, err = volumes.Create(bt.conn, entities.VolumeCreateOptions{}, nil)
|
|
Expect(err).To(BeNil())
|
|
options := new(system.PruneOptions).WithAll(true)
|
|
systemPruneResponse, err := system.Prune(bt.conn, options)
|
|
Expect(err).To(BeNil())
|
|
Expect(len(systemPruneResponse.PodPruneReport)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ContainerPruneReport.ID)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ImagePruneReport.Report.Id)).
|
|
To(BeNumerically(">", 0))
|
|
// Alpine image should not be pruned as used by running container
|
|
Expect(systemPruneResponse.ImagePruneReport.Report.Id).
|
|
ToNot(ContainElement("docker.io/library/alpine:latest"))
|
|
// Though unused volume is available it should not be pruned as flag set to false.
|
|
Expect(len(systemPruneResponse.VolumePruneReport)).To(Equal(0))
|
|
})
|
|
|
|
It("podman system prune running alpine container volume prune", func() {
|
|
// Start a pod and leave it running
|
|
_, err := pods.Start(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start and stop a container to enter in exited state.
|
|
var name = "top"
|
|
_, err = bt.RunTopContainer(&name, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
err = containers.Stop(bt.conn, name, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start second container and leave in running
|
|
var name2 = "top2"
|
|
_, err = bt.RunTopContainer(&name2, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Adding an unused volume should work
|
|
_, err = volumes.Create(bt.conn, entities.VolumeCreateOptions{}, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
options := new(system.PruneOptions).WithAll(true).WithVolumes(true)
|
|
systemPruneResponse, err := system.Prune(bt.conn, options)
|
|
Expect(err).To(BeNil())
|
|
Expect(len(systemPruneResponse.PodPruneReport)).To(Equal(0))
|
|
Expect(len(systemPruneResponse.ContainerPruneReport.ID)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ImagePruneReport.Report.Id)).
|
|
To(BeNumerically(">", 0))
|
|
// Alpine image should not be pruned as used by running container
|
|
Expect(systemPruneResponse.ImagePruneReport.Report.Id).
|
|
ToNot(ContainElement("docker.io/library/alpine:latest"))
|
|
// Volume should be pruned now as flag set true
|
|
Expect(len(systemPruneResponse.VolumePruneReport)).To(Equal(1))
|
|
})
|
|
|
|
It("podman system prune running alpine container volume prune --filter", func() {
|
|
// Start a pod and leave it running
|
|
_, err := pods.Start(bt.conn, newpod, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start and stop a container to enter in exited state.
|
|
var name = "top"
|
|
_, err = bt.RunTopContainer(&name, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
err = containers.Stop(bt.conn, name, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Start second container and leave in running
|
|
var name2 = "top2"
|
|
_, err = bt.RunTopContainer(&name2, bindings.PFalse, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Adding an unused volume should work
|
|
_, err = volumes.Create(bt.conn, entities.VolumeCreateOptions{}, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Adding an unused volume with label should work
|
|
_, err = volumes.Create(bt.conn, entities.VolumeCreateOptions{Label: map[string]string{
|
|
"label1": "value1",
|
|
}}, nil)
|
|
Expect(err).To(BeNil())
|
|
|
|
f := make(map[string][]string)
|
|
f["label"] = []string{"label1=idontmatch"}
|
|
|
|
options := new(system.PruneOptions).WithAll(true).WithVolumes(true).WithFilters(f)
|
|
systemPruneResponse, err := system.Prune(bt.conn, options)
|
|
Expect(err).To(BeNil())
|
|
Expect(len(systemPruneResponse.PodPruneReport)).To(Equal(0))
|
|
// TODO fix system filter handling so all components can handle filters
|
|
// This check **should** be "Equal(0)" since we are passing label
|
|
// filters however the Prune function doesn't seem to pass filters
|
|
// to each component.
|
|
Expect(len(systemPruneResponse.ContainerPruneReport.ID)).To(Equal(1))
|
|
Expect(len(systemPruneResponse.ImagePruneReport.Report.Id)).
|
|
To(BeNumerically(">", 0))
|
|
// Alpine image should not be pruned as used by running container
|
|
Expect(systemPruneResponse.ImagePruneReport.Report.Id).
|
|
ToNot(ContainElement("docker.io/library/alpine:latest"))
|
|
// Volume shouldn't be pruned because the PruneOptions filters doesn't match
|
|
Expect(len(systemPruneResponse.VolumePruneReport)).To(Equal(0))
|
|
|
|
// Fix filter and re prune
|
|
f["label"] = []string{"label1=value1"}
|
|
options = new(system.PruneOptions).WithAll(true).WithVolumes(true).WithFilters(f)
|
|
systemPruneResponse, err = system.Prune(bt.conn, options)
|
|
Expect(err).To(BeNil())
|
|
|
|
// Volume should be pruned because the PruneOptions filters now match
|
|
Expect(len(systemPruneResponse.VolumePruneReport)).To(Equal(1))
|
|
})
|
|
})
|