Gitiles
Code Review Sign In
gerrit.nordix.org / fdio / vpp / 40cba405c5c06a3dc086a55143cb3ffd1094597e / . / extras / hs-test / http_test.go
blob: 96985be1ca7c6a649032e939fb64b575b935c0da [file] [log] [blame]
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]1package main
2
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]3import (
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]4 "fmt"
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]5 "os"
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]6 "os/exec"
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]7)
8
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]9func (s *NsSuite) TestHttpTps() {
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]10 iface := s.netInterfaces[clientInterface]
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]11 client_ip := iface.IP4AddressString()
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]12 port := "8080"
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]13 finished := make(chan error, 1)
Maros Ondrejickadb823ed2022-12-14 16:30:04 +0100[diff] [blame]14
15 container := s.getContainerByName("vpp")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]16
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]17 // configure vpp in the container
18 container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]19
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]20 go startWget(finished, client_ip, port, "test_file_10M", "client")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]21 // wait for client
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]22 err := <-finished
Maros Ondrejicka98a91e82022-12-06 15:38:05 +0100[diff] [blame]23 s.assertNil(err)
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]24}
25
Maros Ondrejicka11a03e92022-12-01 09:56:37 +0100[diff] [blame]26func (s *VethsSuite) TestHttpCli() {
Maros Ondrejickadb823ed2022-12-14 16:30:04 +0100[diff] [blame]27 serverContainer := s.getContainerByName("server-vpp")
28 clientContainer := s.getContainerByName("client-vpp")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]29
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]30 serverVeth := s.netInterfaces[serverInterfaceName]
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]31
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]32 serverContainer.vppInstance.vppctl("http cli server")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]33
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]34 uri := "http://" + serverVeth.IP4AddressString() + "/80"
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]35
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]36 o := clientContainer.vppInstance.vppctl("http cli client" +
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]37 " uri " + uri + " query /show/version")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]38
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]39 s.log(o)
Maros Ondrejicka98a91e82022-12-06 15:38:05 +0100[diff] [blame]40 s.assertContains(o, "<html>", "<html> not found in the result!")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]41}
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]42
Maros Ondrejickaad406072023-02-24 14:16:25 +0100[diff] [blame]43func (s *NoTopoSuite) TestNginxAsServer() {
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]44 query := "return_ok"
45 finished := make(chan error, 1)
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]46
47 nginxCont := s.getContainerByName("nginx")
48 s.assertNil(nginxCont.run())
49
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]50 vpp := s.getContainerByName("vpp").vppInstance
51 err := vpp.waitForApp("-app", 5)
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]52 s.assertNil(err)
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]53
Maros Ondrejicka40cba402023-02-23 13:19:15 +0100[diff] [blame^]54 serverAddress := s.netInterfaces[tapInterfaceName].Peer().IP4AddressString()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]55
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]56 defer func() { os.Remove(query) }()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]57 go startWget(finished, serverAddress, "80", query, "")
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]58 s.assertNil(<-finished)
59}
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]60
61func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
62 nRequests := 1000000
63 nClients := 2000
64 var args []string
65 var exeName string
66
Maros Ondrejicka40cba402023-02-23 13:19:15 +0100[diff] [blame^]67 serverAddress := s.netInterfaces[tapInterfaceName].Peer().IP4AddressString()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]68
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]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 }
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]77 args = append(args, "http://"+serverAddress+":80/64B.json")
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]78 exeName = "ab"
79 } else {
80 args = []string{"-c", fmt.Sprintf("%d", nClients), "-t", "2", "-d", "30",
Maros Ondrejickaad406072023-02-24 14:16:25 +0100[diff] [blame]81 "http://" + serverAddress + ":80/64B.json"}
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]82 exeName = "wrk"
83 }
84
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]85 vpp := s.getContainerByName("vpp").vppInstance
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]86
87 nginxCont := s.getContainerByName("nginx")
88 s.assertNil(nginxCont.run())
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]89 err := vpp.waitForApp("-app", 5)
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]90 s.assertNil(err)
91
92 cmd := exec.Command(exeName, args...)
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]93 s.log(cmd)
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]94 o, _ := cmd.CombinedOutput()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]95 s.log(string(o))
Maros Ondrejicka2ddb2fd2023-02-15 17:44:46 +0100[diff] [blame]96 s.assertNotEmpty(o)
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]97 return nil
98}
99
100func (s *NoTopoSuite) TestNginxPerfCps() {
101 s.assertNil(runNginxPerf(s, "cps", "ab"))
102}
103
104func (s *NoTopoSuite) TestNginxPerfRps() {
105 s.assertNil(runNginxPerf(s, "rps", "ab"))
106}
107
108func (s *NoTopoSuite) TestNginxPerfWrk() {
109 s.assertNil(runNginxPerf(s, "", "wrk"))
110}