Code Review / vpp.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
hs-test: check exit value of ab/wrk
[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 52b7c39..310dc83 100644 (file)
--- a/extras/hs-test/http_test.go
+++ b/extras/hs-test/http_test.go
@@ -4,26 +4,22 @@ import (
        "fmt"
        "os"
        "os/exec"
-       "strings"
-       "time"
 )
 
 func (s *NsSuite) TestHttpTps() {
-       finished := make(chan error, 1)
-       server_ip := "10.0.0.2"
+       iface := s.netInterfaces[clientInterface]
+       client_ip := iface.ip4AddressString()
        port := "8080"
+       finished := make(chan error, 1)
 
        container := s.getContainerByName("vpp")
 
-       s.log("starting vpp..")
-
-       // start & configure vpp in the container
-       _, err := container.execAction("ConfigureHttpTps")
-       s.assertNil(err)
+       // configure vpp in the container
+       container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
 
-       go startWget(finished, server_ip, port, "test_file_10M", "client")
+       go startWget(finished, client_ip, port, "test_file_10M", "client")
        // wait for client
-       err = <-finished
+       err := <-finished
        s.assertNil(err)
 }
 
@@ -31,51 +27,33 @@ func (s *VethsSuite) TestHttpCli() {
        serverContainer := s.getContainerByName("server-vpp")
        clientContainer := s.getContainerByName("client-vpp")
 
-       serverVeth := s.veths["vppsrv"]
+       serverVeth := s.netInterfaces[serverInterfaceName]
 
-       _, err := serverContainer.vppInstance.vppctl("http cli server")
-       s.assertNil(err)
+       serverContainer.vppInstance.vppctl("http cli server")
 
-       uri := "http://" + serverVeth.Address() + "/80"
+       uri := "http://" + serverVeth.ip4AddressString() + "/80"
 
-       o, err := clientContainer.vppInstance.vppctl("http cli client" +
+       o := clientContainer.vppInstance.vppctl("http cli client" +
                " uri " + uri + " query /show/version")
-       s.assertNil(err)
 
        s.log(o)
        s.assertContains(o, "<html>", "<html> not found in the result!")
 }
 
-func waitForApp(vppInst *VppInstance, appName string, timeout int) error {
-       for i := 0; i < timeout; i++ {
-               o, err := vppInst.vppctl("show app")
-               if err != nil {
-                       return fmt.Errorf("Error ocurred during 'show app'")
-               }
-               if strings.Contains(o, appName) {
-                       return nil
-               }
-               time.Sleep(1 * time.Second)
-       }
-       return fmt.Errorf("Timeout while waiting for app '%s'", appName)
-}
-
-func (s *NoTopoSuite) TestNginx() {
+func (s *NoTopoSuite) TestNginxAsServer() {
        query := "return_ok"
        finished := make(chan error, 1)
-       vppCont := s.getContainerByName("vpp")
-       vppInst := NewVppInstance(vppCont)
-       vppInst.actionFuncName = "ConfigureTap"
-       s.assertNil(vppInst.start(), "failed to start vpp")
 
        nginxCont := s.getContainerByName("nginx")
        s.assertNil(nginxCont.run())
 
-       err := waitForApp(vppInst, "-app", 5)
-       s.assertNil(err)
+       vpp := s.getContainerByName("vpp").vppInstance
+       vpp.waitForApp("nginx-", 5)
+
+       serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
 
        defer func() { os.Remove(query) }()
-       go startWget(finished, "10.10.10.1", "80", query, "")
+       go startWget(finished, serverAddress, "80", query, "")
        s.assertNil(<-finished)
 }
 
@@ -85,6 +63,8 @@ func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
        var args []string
        var exeName string
 
+       serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
+
        if ab_or_wrk == "ab" {
                args = []string{"-n", fmt.Sprintf("%d", nRequests), "-c",
                        fmt.Sprintf("%d", nClients)}
@@ -93,28 +73,26 @@ func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
                } else if mode != "cps" {
                        return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
                }
-               args = append(args, "http://10.10.10.1:80/64B.json")
+               args = append(args, "http://"+serverAddress+":80/64B.json")
                exeName = "ab"
        } else {
                args = []string{"-c", fmt.Sprintf("%d", nClients), "-t", "2", "-d", "30",
-                       "http://10.10.10.1:80"}
+                       "http://" + serverAddress + ":80/64B.json"}
                exeName = "wrk"
        }
 
-       vppCont := s.getContainerByName("vpp")
-       vppInst := NewVppInstance(vppCont)
-       vppInst.actionFuncName = "ConfigureTap"
-       s.assertNil(vppInst.start(), "failed to start vpp")
+       vpp := s.getContainerByName("vpp").vppInstance
 
        nginxCont := s.getContainerByName("nginx")
        s.assertNil(nginxCont.run())
-       err := waitForApp(vppInst, "-app", 5)
-       s.assertNil(err)
+       vpp.waitForApp("nginx-", 5)
 
        cmd := exec.Command(exeName, args...)
-       fmt.Println(cmd)
-       o, _ := cmd.CombinedOutput()
-       fmt.Print(string(o))
+       s.log(cmd)
+       o, err := cmd.CombinedOutput()
+       s.log(string(o))
+       s.assertNil(err)
+       s.assertNotEmpty(o)
        return nil
 }
 
Vector Packet Processing