Code Review / vpp.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
hs-test: add nginx+quic test
[vpp.git] / extras / hs-test / http_test.go
diff --git a/extras/hs-test/http_test.go b/extras/hs-test/http_test.go
index 5e88fe0..503f42a 100644 (file)
--- a/extras/hs-test/http_test.go
+++ b/extras/hs-test/http_test.go
@@ -3,12 +3,12 @@ package main
 import (
        "fmt"
        "os"
-       "os/exec"
+       "strings"
 )
 
 func (s *NsSuite) TestHttpTps() {
        iface := s.netInterfaces[clientInterface]
-       client_ip := iface.IP4AddressString()
+       client_ip := iface.ip4AddressString()
        port := "8080"
        finished := make(chan error, 1)
 
@@ -31,7 +31,7 @@ func (s *VethsSuite) TestHttpCli() {
 
        serverContainer.vppInstance.vppctl("http cli server")
 
-       uri := "http://" + serverVeth.IP4AddressString() + "/80"
+       uri := "http://" + serverVeth.ip4AddressString() + "/80"
 
        o := clientContainer.vppInstance.vppctl("http cli client" +
                " uri " + uri + " query /show/version")
@@ -40,7 +40,27 @@ func (s *VethsSuite) TestHttpCli() {
        s.assertContains(o, "<html>", "<html> not found in the result!")
 }
 
-func (s *NoTopoSuite) TestNginx() {
+func (s *NoTopoSuite) TestNginxHttp3() {
+       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.netInterfaces[tapInterfaceName].peer.ip4AddressString()
+
+       defer func() { os.Remove(query) }()
+       curlCont := s.getContainerByName("curl")
+       args := fmt.Sprintf("curl --noproxy '*' --http3-only -k https://%s:8443/%s", serverAddress, query)
+       curlCont.extraRunningArgs = args
+       o, err := curlCont.combinedOutput()
+       s.assertNil(err)
+       s.assertContains(o, "<http>", "<http> not found in the result!")
+}
+
+func (s *NoTopoSuite) TestNginxAsServer() {
        query := "return_ok"
        finished := make(chan error, 1)
 
@@ -48,51 +68,63 @@ func (s *NoTopoSuite) TestNginx() {
        s.assertNil(nginxCont.run())
 
        vpp := s.getContainerByName("vpp").vppInstance
-       err := vpp.waitForApp("-app", 5)
-       s.assertNil(err)
+       vpp.waitForApp("nginx-", 5)
 
-       serverAddress := s.netInterfaces[tapNameVpp].IP4AddressString()
+       serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
 
        defer func() { os.Remove(query) }()
        go 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 := 2000
-       var args []string
-       var exeName string
+       nClients := 1000
+
+       serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
 
-       serverAddress := s.netInterfaces[tapNameVpp].IP4AddressString()
+       vpp := s.getContainerByName("vpp").vppInstance
+
+       nginxCont := s.getContainerByName("nginx")
+       s.assertNil(nginxCont.run())
+       vpp.waitForApp("nginx-", 5)
 
        if ab_or_wrk == "ab" {
-               args = []string{"-n", fmt.Sprintf("%d", nRequests), "-c",
-                       fmt.Sprintf("%d", nClients)}
+               abCont := s.getContainerByName("ab")
+               args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
                if mode == "rps" {
-                       args = append(args, "-k")
+                       args += " -k"
                } else if mode != "cps" {
                        return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
                }
-               args = append(args, "http://"+serverAddress+":80/64B.json")
-               exeName = "ab"
+               // 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, err)
+               s.assertNil(err)
        } else {
-               args = []string{"-c", fmt.Sprintf("%d", nClients), "-t", "2", "-d", "30",
-                       "http://" + serverAddress + ":80"}
-               exeName = "wrk"
+               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, err)
+               s.assertNil(err)
        }
-
-       vpp := s.getContainerByName("vpp").vppInstance
-
-       nginxCont := s.getContainerByName("nginx")
-       s.assertNil(nginxCont.run())
-       err := vpp.waitForApp("-app", 5)
-       s.assertNil(err)
-
-       cmd := exec.Command(exeName, args...)
-       s.log(cmd)
-       o, _ := cmd.CombinedOutput()
-       s.log(string(o))
        return nil
 }
 
Vector Packet Processing