extras/hs-test/http_test.go

   1 package main
   2
   3 import (
   4         "fmt"
   5         "os"
   6         "os/exec"
   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) TestNginx() {
  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         err := vpp.waitForApp("-app", 5)
  52         s.assertNil(err)
  53
  54         serverAddress := s.netInterfaces[tapNameVpp].IP4AddressString()
  55
  56         defer func() { os.Remove(query) }()
  57         go startWget(finished, serverAddress, "80", query, "")
  58         s.assertNil(<-finished)
  59 }
  60
  61 func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
  62         nRequests := 1000000
  63         nClients := 2000
  64         var args []string
  65         var exeName string
  66
  67         serverAddress := s.netInterfaces[tapNameVpp].IP4AddressString()
  68
  69         if ab_or_wrk == "ab" {
  70                 args = []string{"-n", fmt.Sprintf("%d", nRequests), "-c",
  71                         fmt.Sprintf("%d", nClients)}
  72                 if mode == "rps" {
  73                         args = append(args, "-k")
  74                 } else if mode != "cps" {
  75                         return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
  76                 }
  77                 args = append(args, "http://"+serverAddress+":80/64B.json")
  78                 exeName = "ab"
  79         } else {
  80                 args = []string{"-c", fmt.Sprintf("%d", nClients), "-t", "2", "-d", "30",
  81                         "http://" + serverAddress + ":80"}
  82                 exeName = "wrk"
  83         }
  84
  85         vpp := s.getContainerByName("vpp").vppInstance
  86
  87         nginxCont := s.getContainerByName("nginx")
  88         s.assertNil(nginxCont.run())
  89         err := vpp.waitForApp("-app", 5)
  90         s.assertNil(err)
  91
  92         cmd := exec.Command(exeName, args...)
  93         s.log(cmd)
  94         o, _ := cmd.CombinedOutput()
  95         s.log(string(o))
  96         s.assertNotEmpty(o)
  97         return nil
  98 }
  99
 100 func (s *NoTopoSuite) TestNginxPerfCps() {
 101         s.assertNil(runNginxPerf(s, "cps", "ab"))
 102 }
 103
 104 func (s *NoTopoSuite) TestNginxPerfRps() {
 105         s.assertNil(runNginxPerf(s, "rps", "ab"))
 106 }
 107
 108 func (s *NoTopoSuite) TestNginxPerfWrk() {
 109         s.assertNil(runNginxPerf(s, "", "wrk"))
 110 }