summaryrefslogtreecommitdiffstats
path: root/extras/hs-test/http_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'extras/hs-test/http_test.go')
-rw-r--r--extras/hs-test/http_test.go126
1 files changed, 1 insertions, 125 deletions
diff --git a/extras/hs-test/http_test.go b/extras/hs-test/http_test.go
index 68e2e656b35..a5694bfb54b 100644
--- a/extras/hs-test/http_test.go
+++ b/extras/hs-test/http_test.go
@@ -6,8 +6,6 @@ import (
"github.com/onsi/gomega/gmeasure"
"io"
"net/http"
- "os"
- "strings"
"time"
. "fd.io/hs-test/infra"
@@ -16,9 +14,7 @@ import (
func init() {
RegisterVethTests(HttpCliTest, HttpCliConnectErrorTest)
- RegisterNoTopoTests(NginxHttp3Test, NginxAsServerTest,
- NginxPerfCpsTest, NginxPerfRpsTest, NginxPerfWrkTest, NginxPerfCpsInterruptModeTest,
- NginxPerfRpsInterruptModeTest, NginxPerfWrkInterruptModeTest, HeaderServerTest,
+ RegisterNoTopoTests(HeaderServerTest,
HttpStaticMovedTest, HttpStaticNotFoundTest, HttpCliMethodNotAllowedTest,
HttpCliBadRequestTest, HttpStaticBuildInUrlGetIfStatsTest, HttpStaticBuildInUrlPostIfStatsTest,
HttpInvalidRequestLineTest, HttpMethodNotImplementedTest, HttpInvalidHeadersTest,
@@ -92,27 +88,6 @@ func HttpCliConnectErrorTest(s *VethsSuite) {
s.AssertContains(o, "failed to connect")
}
-func NginxHttp3Test(s *NoTopoSuite) {
- s.SkipUnlessExtendedTestsBuilt()
-
- query := "index.html"
- nginxCont := s.GetContainerByName("nginx-http3")
- s.AssertNil(nginxCont.Run())
-
- vpp := s.GetContainerByName("vpp").VppInstance
- vpp.WaitForApp("nginx-", 5)
- serverAddress := s.GetInterfaceByName(TapInterfaceName).Peer.Ip4AddressString()
-
- defer func() { os.Remove(query) }()
- curlCont := s.GetContainerByName("curl")
- args := fmt.Sprintf("curl --noproxy '*' --local-port 55444 --http3-only -k https://%s:8443/%s", serverAddress, query)
- curlCont.ExtraRunningArgs = args
- o, err := curlCont.CombinedOutput()
- s.Log(o)
- s.AssertNil(err, fmt.Sprint(err))
- s.AssertContains(o, "<http>", "<http> not found in the result!")
-}
-
func HttpStaticPromTest(s *NoTopoSuite) {
finished := make(chan error, 1)
query := "stats.prom"
@@ -566,102 +541,3 @@ func HeaderServerTest(s *NoTopoSuite) {
defer resp.Body.Close()
s.AssertEqual("http_cli_server", resp.Header.Get("Server"))
}
-
-func NginxAsServerTest(s *NoTopoSuite) {
- query := "return_ok"
- finished := make(chan error, 1)
-
- nginxCont := s.GetContainerByName("nginx")
- s.AssertNil(nginxCont.Run())
-
- vpp := s.GetContainerByName("vpp").VppInstance
- vpp.WaitForApp("nginx-", 5)
-
- serverAddress := s.GetInterfaceByName(TapInterfaceName).Peer.Ip4AddressString()
-
- defer func() { os.Remove(query) }()
- go func() {
- defer GinkgoRecover()
- s.StartWget(finished, serverAddress, "80", query, "")
- }()
- s.AssertNil(<-finished)
-}
-
-func parseString(s, pattern string) string {
- temp := strings.Split(s, "\n")
- for _, item := range temp {
- if strings.Contains(item, pattern) {
- return item
- }
- }
- return ""
-}
-
-func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
- nRequests := 1000000
- nClients := 1000
-
- serverAddress := s.GetInterfaceByName(TapInterfaceName).Peer.Ip4AddressString()
-
- vpp := s.GetContainerByName("vpp").VppInstance
-
- nginxCont := s.GetContainerByName(SingleTopoContainerNginx)
- s.AssertNil(nginxCont.Run())
- vpp.WaitForApp("nginx-", 5)
-
- if ab_or_wrk == "ab" {
- abCont := s.GetContainerByName("ab")
- args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
- if mode == "rps" {
- args += " -k"
- } else if mode != "cps" {
- return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
- }
- // don't exit on socket receive errors
- args += " -r"
- args += " http://" + serverAddress + ":80/64B.json"
- abCont.ExtraRunningArgs = args
- o, err := abCont.CombinedOutput()
- rps := parseString(o, "Requests per second:")
- s.Log(rps)
- s.Log(err)
- s.AssertNil(err, "err: '%s', output: '%s'", err, o)
- } else {
- wrkCont := s.GetContainerByName("wrk")
- args := fmt.Sprintf("-c %d -t 2 -d 30 http://%s:80/64B.json", nClients,
- serverAddress)
- wrkCont.ExtraRunningArgs = args
- o, err := wrkCont.CombinedOutput()
- rps := parseString(o, "requests")
- s.Log(rps)
- s.Log(err)
- s.AssertNil(err, "err: '%s', output: '%s'", err, o)
- }
- return nil
-}
-
-func NginxPerfCpsInterruptModeTest(s *NoTopoSuite) {
- NginxPerfCpsTest(s)
-}
-
-// unstable with multiple workers
-func NginxPerfCpsTest(s *NoTopoSuite) {
- s.SkipIfMultiWorker()
- s.AssertNil(runNginxPerf(s, "cps", "ab"))
-}
-
-func NginxPerfRpsInterruptModeTest(s *NoTopoSuite) {
- NginxPerfRpsTest(s)
-}
-
-func NginxPerfRpsTest(s *NoTopoSuite) {
- s.AssertNil(runNginxPerf(s, "rps", "ab"))
-}
-
-func NginxPerfWrkInterruptModeTest(s *NoTopoSuite) {
- NginxPerfWrkTest(s)
-}
-
-func NginxPerfWrkTest(s *NoTopoSuite) {
- s.AssertNil(runNginxPerf(s, "", "wrk"))
-}