9 func (s *NsSuite) TestHttpTps() {
10 iface := s.netInterfaces[clientInterface]
11 client_ip := iface.ip4AddressString()
13 finished := make(chan error, 1)
15 container := s.getContainerByName("vpp")
17 // configure vpp in the container
18 container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
20 go s.startWget(finished, client_ip, port, "test_file_10M", "client")
26 func (s *VethsSuite) TestHttpCli() {
27 serverContainer := s.getContainerByName("server-vpp")
28 clientContainer := s.getContainerByName("client-vpp")
30 serverVeth := s.netInterfaces[serverInterfaceName]
32 serverContainer.vppInstance.vppctl("http cli server")
34 uri := "http://" + serverVeth.ip4AddressString() + "/80"
36 o := clientContainer.vppInstance.vppctl("http cli client" +
37 " uri " + uri + " query /show/version")
40 s.assertContains(o, "<html>", "<html> not found in the result!")
43 func (s *NoTopoSuite) TestNginxHttp3() {
44 s.SkipUnlessExtendedTestsBuilt()
47 nginxCont := s.getContainerByName("nginx-http3")
48 s.assertNil(nginxCont.run())
50 vpp := s.getContainerByName("vpp").vppInstance
51 vpp.waitForApp("nginx-", 5)
52 serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
54 defer func() { os.Remove(query) }()
55 curlCont := s.getContainerByName("curl")
56 args := fmt.Sprintf("curl --noproxy '*' --http3-only -k https://%s:8443/%s", serverAddress, query)
57 curlCont.extraRunningArgs = args
58 o, err := curlCont.combinedOutput()
60 s.assertContains(o, "<http>", "<http> not found in the result!")
63 func (s *NoTopoSuite) TestNginxAsServer() {
65 finished := make(chan error, 1)
67 nginxCont := s.getContainerByName("nginx")
68 s.assertNil(nginxCont.run())
70 vpp := s.getContainerByName("vpp").vppInstance
71 vpp.waitForApp("nginx-", 5)
73 serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
75 defer func() { os.Remove(query) }()
76 go s.startWget(finished, serverAddress, "80", query, "")
77 s.assertNil(<-finished)
80 func parseString(s, pattern string) string {
81 temp := strings.Split(s, "\n")
82 for _, item := range temp {
83 if strings.Contains(item, pattern) {
90 func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
94 serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
96 vpp := s.getContainerByName("vpp").vppInstance
98 nginxCont := s.getContainerByName("nginx")
99 s.assertNil(nginxCont.run())
100 vpp.waitForApp("nginx-", 5)
102 if ab_or_wrk == "ab" {
103 abCont := s.getContainerByName("ab")
104 args := fmt.Sprintf("-n %d -c %d", nRequests, nClients)
107 } else if mode != "cps" {
108 return fmt.Errorf("invalid mode %s; expected cps/rps", mode)
110 // don't exit on socket receive errors
112 args += " http://" + serverAddress + ":80/64B.json"
113 abCont.extraRunningArgs = args
114 o, err := abCont.combinedOutput()
115 rps := parseString(o, "Requests per second:")
119 wrkCont := s.getContainerByName("wrk")
120 args := fmt.Sprintf("-c %d -t 2 -d 30 http://%s:80/64B.json", nClients,
122 wrkCont.extraRunningArgs = args
123 o, err := wrkCont.combinedOutput()
124 rps := parseString(o, "requests")
131 func (s *NoTopoSuite) TestNginxPerfCps() {
132 s.assertNil(runNginxPerf(s, "cps", "ab"))
135 func (s *NoTopoSuite) TestNginxPerfRps() {
136 s.assertNil(runNginxPerf(s, "rps", "ab"))
139 func (s *NoTopoSuite) TestNginxPerfWrk() {
140 s.assertNil(runNginxPerf(s, "", "wrk"))