extras/hs-test/http_test.go

   1 package main
   2
   3 import (
   4         "fmt"
   5         "os"
   6         "strings"
   7 )
   8
   9 func (s *NsSuite) TestHttpTps() {
  10         iface := s.netInterfaces[clientInterface]
  11         client_ip := iface.ip4AddressString()
  12         port := "8080"
  13         finished := make(chan error, 1)
  14         clientNetns := "cln"
  15
  16         container := s.getContainerByName("vpp")
  17
  18         // configure vpp in the container
  19         container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
  20
  21         go s.startWget(finished, client_ip, port, "test_file_10M", clientNetns)
  22         // wait for client
  23         err := <-finished
  24         s.assertNil(err, err)
  25 }
  26
  27 func (s *VethsSuite) TestHttpCli() {
  28         serverContainer := s.getContainerByName("server-vpp")
  29         clientContainer := s.getContainerByName("client-vpp")
  30
  31         serverVeth := s.netInterfaces[serverInterfaceName]
  32
  33         serverContainer.vppInstance.vppctl("http cli server")
  34
  35         uri := "http://" + serverVeth.ip4AddressString() + "/80"
  36
  37         o := clientContainer.vppInstance.vppctl("http cli client" +
  38                 " uri " + uri + " query /show/version")
  39
  40         s.log(o)
  41         s.assertContains(o, "<html>", "<html> not found in the result!")
  42 }
  43
  44 func (s *NoTopoSuite) TestNginxHttp3() {
  45         s.SkipUnlessExtendedTestsBuilt()
  46
  47         query := "index.html"
  48         nginxCont := s.getContainerByName("nginx-http3")
  49         s.assertNil(nginxCont.run())
  50
  51         vpp := s.getContainerByName("vpp").vppInstance
  52         vpp.waitForApp("nginx-", 5)
  53         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  54
  55         defer func() { os.Remove(query) }()
  56         curlCont := s.getContainerByName("curl")
  57         args := fmt.Sprintf("curl --noproxy '*' --local-port 55444 --http3-only -k https://%s:8443/%s", serverAddress, query)
  58         curlCont.extraRunningArgs = args
  59         o, err := curlCont.combinedOutput()
  60         s.assertNil(err, err)
  61         s.assertContains(o, "<http>", "<http> not found in the result!")
  62 }
  63
  64 func (s *NoTopoSuite) TestHttpStaticProm() {
  65         finished := make(chan error, 1)
  66         query := "stats.prom"
  67         vpp := s.getContainerByName("vpp").vppInstance
  68         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  69         s.log(vpp.vppctl("http static server uri tcp://" + serverAddress + "/80 url-handlers"))
  70         s.log(vpp.vppctl("prom enable"))
  71         go s.startWget(finished, serverAddress, "80", query, "")
  72         err := <-finished
  73         s.assertNil(err, err)
  74 }
  75
  76 func (s *NoTopoSuite) TestNginxAsServer() {
  77         query := "return_ok"
  78         finished := make(chan error, 1)
  79
  80         nginxCont := s.getContainerByName("nginx")
  81         s.assertNil(nginxCont.run())
  82
  83         vpp := s.getContainerByName("vpp").vppInstance
  84         vpp.waitForApp("nginx-", 5)
  85
  86         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  87
  88         defer func() { os.Remove(query) }()
  89         go s.startWget(finished, serverAddress, "80", query, "")
  90         s.assertNil(<-finished)
  91 }
  92
  93 func parseString(s, pattern string) string {
  94         temp := strings.Split(s, "\n")
  95         for _, item := range temp {
  96                 if strings.Contains(item, pattern) {
  97                         return item
  98                 }
  99         }
 100         return ""
 101 }
 102
 103 func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
 104         nRequests := 1000000
 105         nClients := 1000
 106
 107         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
 108
 109         vpp := s.getContainerByName("vpp").vppInstance
 110
 111         nginxCont := s.getContainerByName(singleTopoContainerNginx)
 112         s.assertNil(nginxCont.run())
 113         vpp.waitForApp("nginx-", 5)
 114
 115         if ab_or_wrk == "ab" {
 116                 abCont := s.getContainerByName("ab")
 117                 args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
 118                 if mode == "rps" {
 119                         args += " -k"
 120                 } else if mode != "cps" {
 121                         return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
 122                 }
 123                 // don't exit on socket receive errors
 124                 args += " -r"
 125                 args += " http://" + serverAddress + ":80/64B.json"
 126                 abCont.extraRunningArgs = args
 127                 o, err := abCont.combinedOutput()
 128                 rps := parseString(o, "Requests per second:")
 129                 s.log(rps, err)
 130                 s.assertNil(err, "err: '%s', output: '%s'", err, o)
 131         } else {
 132                 wrkCont := s.getContainerByName("wrk")
 133                 args := fmt.Sprintf("-c %d -t 2 -d 30 http://%s:80/64B.json", nClients,
 134                         serverAddress)
 135                 wrkCont.extraRunningArgs = args
 136                 o, err := wrkCont.combinedOutput()
 137                 rps := parseString(o, "requests")
 138                 s.log(rps, err)
 139                 s.assertNil(err, "err: '%s', output: '%s'", err, o)
 140         }
 141         return nil
 142 }
 143
 144 func (s *NoTopoSuite) TestNginxPerfCps() {
 145         s.assertNil(runNginxPerf(s, "cps", "ab"))
 146 }
 147
 148 func (s *NoTopoSuite) TestNginxPerfRps() {
 149         s.assertNil(runNginxPerf(s, "rps", "ab"))
 150 }
 151
 152 func (s *NoTopoSuite) TestNginxPerfWrk() {
 153         s.assertNil(runNginxPerf(s, "", "wrk"))
 154 }