mirror of https://github.com/containers/podman.git
Merge pull request #23099 from Luap99/remove-12624
test/e2e: remove podman system service tests
This commit is contained in:
commit
4ba26b15f1
|
@ -1,115 +0,0 @@
|
||||||
package integration
|
|
||||||
|
|
||||||
import (
|
|
||||||
"io"
|
|
||||||
"net"
|
|
||||||
"net/http"
|
|
||||||
"net/url"
|
|
||||||
"strconv"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/containers/podman/v5/utils"
|
|
||||||
. "github.com/onsi/ginkgo/v2"
|
|
||||||
. "github.com/onsi/gomega"
|
|
||||||
. "github.com/onsi/gomega/gexec"
|
|
||||||
)
|
|
||||||
|
|
||||||
var _ = Describe("podman system service", func() {
|
|
||||||
|
|
||||||
// The timeout used to for the service to respond. As shown in #12167,
|
|
||||||
// this may take some time on machines under high load.
|
|
||||||
var timeout = 30
|
|
||||||
|
|
||||||
Describe("verify timeout", func() {
|
|
||||||
It("of 2 seconds", func() {
|
|
||||||
SkipIfRemote("service subcommand not supported remotely")
|
|
||||||
|
|
||||||
address := url.URL{
|
|
||||||
Scheme: "tcp",
|
|
||||||
Host: net.JoinHostPort("localhost", randomPort()),
|
|
||||||
}
|
|
||||||
session := podmanTest.Podman([]string{
|
|
||||||
"system", "service", "--time=2", address.String(),
|
|
||||||
})
|
|
||||||
defer session.Kill()
|
|
||||||
|
|
||||||
WaitForService(address)
|
|
||||||
Eventually(session, timeout).Should(Exit(0))
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
Describe("verify pprof endpoints", func() {
|
|
||||||
// Depends on pkg/api/server/server.go:255
|
|
||||||
const magicComment = "pprof service listening on"
|
|
||||||
|
|
||||||
It("are available", func() {
|
|
||||||
Skip("FIXME: Test is too flaky (#12624)")
|
|
||||||
SkipIfRemote("service subcommand not supported remotely")
|
|
||||||
|
|
||||||
address := url.URL{
|
|
||||||
Scheme: "tcp",
|
|
||||||
Host: net.JoinHostPort("localhost", randomPort()),
|
|
||||||
}
|
|
||||||
|
|
||||||
pprofPort := randomPort()
|
|
||||||
session := podmanTest.Podman([]string{
|
|
||||||
"system", "service", "--log-level=debug", "--time=0",
|
|
||||||
"--pprof-address=localhost:" + pprofPort, address.String(),
|
|
||||||
})
|
|
||||||
defer session.Kill()
|
|
||||||
|
|
||||||
WaitForService(address)
|
|
||||||
|
|
||||||
// Combined with test below we have positive/negative test for pprof
|
|
||||||
Expect(session.Err.Contents()).Should(ContainSubstring(magicComment))
|
|
||||||
|
|
||||||
heap := url.URL{
|
|
||||||
Scheme: "http",
|
|
||||||
Host: net.JoinHostPort("localhost", pprofPort),
|
|
||||||
Path: "/debug/pprof/heap",
|
|
||||||
RawQuery: "seconds=2",
|
|
||||||
}
|
|
||||||
resp, err := http.Get(heap.String())
|
|
||||||
Expect(err).ShouldNot(HaveOccurred())
|
|
||||||
defer resp.Body.Close()
|
|
||||||
Expect(resp).To(HaveHTTPStatus(http.StatusOK))
|
|
||||||
|
|
||||||
body, err := io.ReadAll(resp.Body)
|
|
||||||
Expect(err).ShouldNot(HaveOccurred())
|
|
||||||
Expect(body).ShouldNot(BeEmpty())
|
|
||||||
|
|
||||||
session.Interrupt().Wait(time.Duration(timeout) * time.Second)
|
|
||||||
Eventually(session, timeout).Should(Exit(1))
|
|
||||||
})
|
|
||||||
|
|
||||||
It("are not available", func() {
|
|
||||||
Skip("FIXME: Test is too flaky (#12624)")
|
|
||||||
SkipIfRemote("service subcommand not supported remotely")
|
|
||||||
|
|
||||||
address := url.URL{
|
|
||||||
Scheme: "tcp",
|
|
||||||
Host: net.JoinHostPort("localhost", randomPort()),
|
|
||||||
}
|
|
||||||
|
|
||||||
session := podmanTest.Podman([]string{
|
|
||||||
"system", "service", "--log-level=debug", "--time=0", address.String(),
|
|
||||||
})
|
|
||||||
defer session.Kill()
|
|
||||||
|
|
||||||
WaitForService(address)
|
|
||||||
|
|
||||||
// Combined with test above we have positive/negative test for pprof
|
|
||||||
Expect(session.Err.Contents()).ShouldNot(ContainSubstring(magicComment))
|
|
||||||
|
|
||||||
session.Interrupt().Wait(time.Duration(timeout) * time.Second)
|
|
||||||
Eventually(session, timeout).Should(Exit(1))
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
// randomPort leans on the go net library to find an available port...
|
|
||||||
func randomPort() string {
|
|
||||||
port, err := utils.GetRandomPort()
|
|
||||||
Expect(err).ShouldNot(HaveOccurred())
|
|
||||||
return strconv.Itoa(port)
|
|
||||||
}
|
|
Loading…
Reference in New Issue