package main import ( "fmt" "os" "os/exec" ) func (s *NsSuite) TestHttpTps() { iface := s.netInterfaces[clientInterface] client_ip := iface.ip4AddressString() port := "8080" finished := make(chan error, 1) container := s.getContainerByName("vpp") // configure vpp in the container container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080") go startWget(finished, client_ip, port, "test_file_10M", "client") // wait for client err := <-finished s.assertNil(err) } func (s *VethsSuite) TestHttpCli() { serverContainer := s.getContainerByName("server-vpp") clientContainer := s.getContainerByName("client-vpp") serverVeth := s.netInterfaces[serverInterfaceName] serverContainer.vppInstance.vppctl("http cli server") uri := "http://" + serverVeth.ip4AddressString() + "/80" o := clientContainer.vppInstance.vppctl("http cli client" + " uri " + uri + " query /show/version") s.log(o) s.assertContains(o, "", " not found in the result!") } func (s *NoTopoSuite) TestNginxAsServer() { query := "return_ok" finished := make(chan error, 1) nginxCont := s.getContainerByName("nginx") s.assertNil(nginxCont.run()) vpp := s.getContainerByName("vpp").vppInstance vpp.waitForApp("nginx-", 5) serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString() defer func() { os.Remove(query) }() go startWget(finished, serverAddress, "80", query, "") s.assertNil(<-finished) } func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error { nRequests := 1000000 nClients := 2000 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)} if mode == "rps" { args = append(args, "-k") } else if mode != "cps" { return fmt.Errorf("invalid mode %s; expected cps/rps", mode) } args = append(args, "http://"+serverAddress+":80/64B.json") exeName = "ab" } else { args = []string{"-c", fmt.Sprintf("%d", nClients), "-t", "2", "-d", "30", "http://" + serverAddress + ":80/64B.json"} exeName = "wrk" } vpp := s.getContainerByName("vpp").vppInstance nginxCont := s.getContainerByName("nginx") s.assertNil(nginxCont.run()) vpp.waitForApp("nginx-", 5) cmd := exec.Command(exeName, args...) s.log(cmd) o, _ := cmd.CombinedOutput() s.log(string(o)) s.assertNotEmpty(o) return nil } func (s *NoTopoSuite) TestNginxPerfCps() { s.assertNil(runNginxPerf(s, "cps", "ab")) } func (s *NoTopoSuite) TestNginxPerfRps() { s.assertNil(runNginxPerf(s, "rps", "ab")) } func (s *NoTopoSuite) TestNginxPerfWrk() { s.assertNil(runNginxPerf(s, "", "wrk")) }