mirror of
https://github.com/containers/podman.git
synced 2025-08-06 19:44:14 +08:00
6c0d94328f
Now that we have propert !remote tags set everywhere we can just rely on that and do not need to skip any dirs. Also on linux do not lint three times, one remote run is enough. We still have to skip the test dir for windows/macos though or we need to add linux build tags there everywhere as well. This seems simpler. Signed-off-by: Paul Holzinger <pholzing@redhat.com>
119 lines
2.7 KiB
Go
119 lines
2.7 KiB
Go
//go:build linux
|
|
|
|
package bindings_test
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io/fs"
|
|
"os"
|
|
"os/exec"
|
|
"path/filepath"
|
|
"reflect"
|
|
"strconv"
|
|
"syscall"
|
|
|
|
"github.com/containers/podman/v5/pkg/bindings"
|
|
"github.com/containers/podman/v5/pkg/bindings/containers"
|
|
"github.com/containers/podman/v5/pkg/bindings/images"
|
|
"github.com/containers/podman/v5/pkg/bindings/pods"
|
|
"github.com/containers/podman/v5/pkg/bindings/system"
|
|
. "github.com/onsi/ginkgo/v2"
|
|
. "github.com/onsi/gomega"
|
|
. "github.com/onsi/gomega/gexec"
|
|
)
|
|
|
|
var _ = Describe("Verify Podman resources", func() {
|
|
var (
|
|
bt *bindingTest
|
|
s *Session
|
|
)
|
|
|
|
BeforeEach(func() {
|
|
bt = newBindingTest()
|
|
s = bt.startAPIService()
|
|
err := bt.NewConnection()
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
})
|
|
|
|
AfterEach(func() {
|
|
s.Kill()
|
|
bt.cleanup()
|
|
})
|
|
|
|
It("no leaked connections", func() {
|
|
conn, err := bindings.NewConnection(context.Background(), bt.sock)
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
|
|
// Record details on open file descriptors before using API
|
|
buffer := lsof()
|
|
|
|
// Record open fd from /proc
|
|
start, err := readProc()
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
|
|
// Run some operations
|
|
_, err = system.Info(conn, nil)
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
_, err = images.List(conn, nil)
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
_, err = containers.List(conn, nil)
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
_, err = pods.List(conn, nil)
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
|
|
podman, _ := bindings.GetClient(conn)
|
|
podman.Client.CloseIdleConnections()
|
|
|
|
// Record open fd from /proc
|
|
finished, err := readProc()
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
if !reflect.DeepEqual(finished, start) {
|
|
fmt.Fprintf(GinkgoWriter, "Open FDs:\nlsof Before:\n%s\n", buffer)
|
|
|
|
// Record details on open file descriptors after using API
|
|
buffer := lsof()
|
|
fmt.Fprintf(GinkgoWriter, "lsof After:\n%s\n", buffer)
|
|
|
|
// We know test has failed. Easier to let ginkgo format output.
|
|
Expect(finished).Should(Equal(start))
|
|
}
|
|
})
|
|
})
|
|
|
|
func lsof() string {
|
|
lsof := exec.Command("lsof", "+E", "-p", strconv.Itoa(os.Getpid()))
|
|
buffer, err := lsof.Output()
|
|
Expect(err).ShouldNot(HaveOccurred())
|
|
return string(buffer)
|
|
}
|
|
|
|
func readProc() ([]string, error) {
|
|
syscall.Sync()
|
|
|
|
names := make([]string, 0)
|
|
err := filepath.WalkDir(fmt.Sprintf("/proc/%d/fd", os.Getpid()),
|
|
func(path string, d fs.DirEntry, err error) error {
|
|
name := path + " -> "
|
|
|
|
switch {
|
|
case d.IsDir():
|
|
return nil
|
|
case err != nil:
|
|
name += err.Error()
|
|
case d.Type()&fs.ModeSymlink != 0:
|
|
n, err := os.Readlink(path)
|
|
if err != nil && !os.IsNotExist(err) {
|
|
return err
|
|
}
|
|
if n == "" {
|
|
n = d.Type().String()
|
|
}
|
|
name += n
|
|
}
|
|
names = append(names, name)
|
|
return nil
|
|
})
|
|
return names, err
|
|
}
|