extras/hs-test/http_test.go

   1 package main
   2
   3 import (
   4         "fmt"
   5         "os"
   6 )
   7
   8 func (s *NsSuite) TestHttpTps() {
   9         iface := s.netInterfaces[clientInterface]
  10         client_ip := iface.ip4AddressString()
  11         port := "8080"
  12         finished := make(chan error, 1)
  13
  14         container := s.getContainerByName("vpp")
  15
  16         // configure vpp in the container
  17         container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
  18
  19         go startWget(finished, client_ip, port, "test_file_10M", "client")
  20         // wait for client
  21         err := <-finished
  22         s.assertNil(err)
  23 }
  24
  25 func (s *VethsSuite) TestHttpCli() {
  26         serverContainer := s.getContainerByName("server-vpp")
  27         clientContainer := s.getContainerByName("client-vpp")
  28
  29         serverVeth := s.netInterfaces[serverInterfaceName]
  30
  31         serverContainer.vppInstance.vppctl("http cli server")
  32
  33         uri := "http://" + serverVeth.ip4AddressString() + "/80"
  34
  35         o := clientContainer.vppInstance.vppctl("http cli client" +
  36                 " uri " + uri + " query /show/version")
  37
  38         s.log(o)
  39         s.assertContains(o, "<html>", "<html> not found in the result!")
  40 }
  41
  42 func (s *NoTopoSuite) TestNginxAsServer() {
  43         query := "return_ok"
  44         finished := make(chan error, 1)
  45
  46         nginxCont := s.getContainerByName("nginx")
  47         s.assertNil(nginxCont.run())
  48
  49         vpp := s.getContainerByName("vpp").vppInstance
  50         vpp.waitForApp("nginx-", 5)
  51
  52         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  53
  54         defer func() { os.Remove(query) }()
  55         go startWget(finished, serverAddress, "80", query, "")
  56         s.assertNil(<-finished)
  57 }
  58
  59 func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
  60         nRequests := 1000000
  61         nClients := 2000
  62
  63         serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
  64
  65         vpp := s.getContainerByName("vpp").vppInstance
  66
  67         nginxCont := s.getContainerByName("nginx")
  68         s.assertNil(nginxCont.run())
  69         vpp.waitForApp("nginx-", 5)
  70
  71         if ab_or_wrk == "ab" {
  72                 abCont := s.getContainerByName("ab")
  73                 args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
  74                 if mode == "rps" {
  75                         args += " -k"
  76                 } else if mode != "cps" {
  77                         return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
  78                 }
  79                 args += " http://" + serverAddress + ":80/64B.json"
  80                 abCont.extraRunningArgs = args
  81                 o, err := abCont.combinedOutput()
  82                 s.log(o, err)
  83                 s.assertNil(err)
  84         } else {
  85                 wrkCont := s.getContainerByName("wrk")
  86                 args := fmt.Sprintf("-c %d -t 2 -d 30 http://%s:80/64B.json", nClients,
  87                         serverAddress)
  88                 wrkCont.extraRunningArgs = args
  89                 o, err := wrkCont.combinedOutput()
  90                 s.log(o)
  91                 s.assertNil(err)
  92         }
  93         return nil
  94 }
  95
  96 func (s *NoTopoSuite) TestNginxPerfCps() {
  97         s.assertNil(runNginxPerf(s, "cps", "ab"))
  98 }
  99
 100 func (s *NoTopoSuite) TestNginxPerfRps() {
 101         s.assertNil(runNginxPerf(s, "rps", "ab"))
 102 }
 103
 104 func (s *NoTopoSuite) TestNginxPerfWrk() {
 105         s.assertNil(runNginxPerf(s, "", "wrk"))
 106 }