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
  15         container := s.getContainerByName("vpp")
  16
  17         // configure vpp in the container
  18         container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
  19
  20         go startWget(finished, client_ip, port, "test_file_10M", "client")
  21         // wait for client
  22         err := <-finished
  23         s.assertNil(err)
  24 }
  25
  26 func (s *VethsSuite) TestHttpCli() {
  27         serverContainer := s.getContainerByName("server-vpp")
  28         clientContainer := s.getContainerByName("client-vpp")
  29
  30         serverVeth := s.netInterfaces[serverInterfaceName]
  31
  32         serverContainer.vppInstance.vppctl("http cli server")
  33
  34         uri := "http://" + serverVeth.ip4AddressString() + "/80"
  35
  36         o := clientContainer.vppInstance.vppctl("http cli client" +
  37                 " uri " + uri + " query /show/version")
  38
  39         s.log(o)
  40         s.assertContains(o, "<html>", "<html> not found in the result!")
  41 }
  42
  43 func (s *NoTopoSuite) TestNginxAsServer() {
  44         query := "return_ok"
  45         finished := make(chan error, 1)
  46
  47         nginxCont := s.getContainerByName("nginx")
  48         s.assertNil(nginxCont.run())
  49
  50         vpp := s.getContainerByName("vpp").vppInstance
  51         vpp.waitForApp("nginx-", 5)
  52
  53         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  54
  55         defer func() { os.Remove(query) }()
  56         go startWget(finished, serverAddress, "80", query, "")
  57         s.assertNil(<-finished)
  58 }
  59
  60 func parseString(s, pattern string) string {
  61         temp := strings.Split(s, "\n")
  62         for _, item := range temp {
  63                 if strings.Contains(item, pattern) {
  64                         return item
  65                 }
  66         }
  67         return ""
  68 }
  69
  70 func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
  71         nRequests := 1000000
  72         nClients := 1000
  73
  74         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  75
  76         vpp := s.getContainerByName("vpp").vppInstance
  77
  78         nginxCont := s.getContainerByName("nginx")
  79         s.assertNil(nginxCont.run())
  80         vpp.waitForApp("nginx-", 5)
  81
  82         if ab_or_wrk == "ab" {
  83                 abCont := s.getContainerByName("ab")
  84                 args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
  85                 if mode == "rps" {
  86                         args += " -k"
  87                 } else if mode != "cps" {
  88                         return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
  89                 }
  90                 // don't exit on socket receive errors
  91                 args += " -r"
  92                 args += " http://" + serverAddress + ":80/64B.json"
  93                 abCont.extraRunningArgs = args
  94                 o, err := abCont.combinedOutput()
  95                 rps := parseString(o, "Requests per second:")
  96                 s.log(rps, err)
  97                 s.assertNil(err)
  98         } else {
  99                 wrkCont := s.getContainerByName("wrk")
 100                 args := fmt.Sprintf("-c %d -t 2 -d 30 http://%s:80/64B.json", nClients,
 101                         serverAddress)
 102                 wrkCont.extraRunningArgs = args
 103                 o, err := wrkCont.combinedOutput()
 104                 rps := parseString(o, "requests")
 105                 s.log(rps, err)
 106                 s.assertNil(err)
 107         }
 108         return nil
 109 }
 110
 111 func (s *NoTopoSuite) TestNginxPerfCps() {
 112         s.assertNil(runNginxPerf(s, "cps", "ab"))
 113 }
 114
 115 func (s *NoTopoSuite) TestNginxPerfRps() {
 116         s.assertNil(runNginxPerf(s, "rps", "ab"))
 117 }
 118
 119 func (s *NoTopoSuite) TestNginxPerfWrk() {
 120         s.assertNil(runNginxPerf(s, "", "wrk"))
 121 }