Gitiles
Code Review Sign In
gerrit.nordix.org / fdio / vpp / b41b0af609fce6fbe62b476f826a90bded9052ad / . / extras / hs-test / http_test.go
blob: 22f82c191a58fe23a6dc2a8b5b4e502c5abf13b5 [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 Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]6)
7
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]8func (s *NsSuite) TestHttpTps() {
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]9 iface := s.netInterfaces[clientInterface]
Maros Ondrejickae7625d02023-02-28 16:55:01 +0100[diff] [blame]10 client_ip := iface.ip4AddressString()
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]11 port := "8080"
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]12 finished := make(chan error, 1)
Maros Ondrejickadb823ed2022-12-14 16:30:04 +0100[diff] [blame]13
14 container := s.getContainerByName("vpp")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]15
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]16 // configure vpp in the container
17 container.vppInstance.vppctl("http tps uri tcp://0.0.0.0/8080")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]18
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]19 go startWget(finished, client_ip, port, "test_file_10M", "client")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]20 // wait for client
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]21 err := <-finished
Maros Ondrejicka98a91e82022-12-06 15:38:05 +0100[diff] [blame]22 s.assertNil(err)
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]23}
24
Maros Ondrejicka11a03e92022-12-01 09:56:37 +0100[diff] [blame]25func (s *VethsSuite) TestHttpCli() {
Maros Ondrejickadb823ed2022-12-14 16:30:04 +0100[diff] [blame]26 serverContainer := s.getContainerByName("server-vpp")
27 clientContainer := s.getContainerByName("client-vpp")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]28
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]29 serverVeth := s.netInterfaces[serverInterfaceName]
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]30
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]31 serverContainer.vppInstance.vppctl("http cli server")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]32
Maros Ondrejickae7625d02023-02-28 16:55:01 +0100[diff] [blame]33 uri := "http://" + serverVeth.ip4AddressString() + "/80"
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]34
Maros Ondrejicka2908f8c2023-02-02 08:58:04 +0100[diff] [blame]35 o := clientContainer.vppInstance.vppctl("http cli client" +
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]36 " uri " + uri + " query /show/version")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]37
Maros Ondrejickaffa3f602023-01-26 10:07:29 +0100[diff] [blame]38 s.log(o)
Maros Ondrejicka98a91e82022-12-06 15:38:05 +0100[diff] [blame]39 s.assertContains(o, "<html>", "<html> not found in the result!")
Filip Tehlarb15a0002022-11-10 12:34:17 +0100[diff] [blame]40}
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]41
Maros Ondrejickaad406072023-02-24 14:16:25 +0100[diff] [blame]42func (s *NoTopoSuite) TestNginxAsServer() {
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]43 query := "return_ok"
44 finished := make(chan error, 1)
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]45
46 nginxCont := s.getContainerByName("nginx")
47 s.assertNil(nginxCont.run())
48
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]49 vpp := s.getContainerByName("vpp").vppInstance
Florin Corase2415f72023-02-28 14:51:03 -0800[diff] [blame]50 vpp.waitForApp("nginx-", 5)
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]51
Maros Ondrejickae7625d02023-02-28 16:55:01 +0100[diff] [blame]52 serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]53
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]54 defer func() { os.Remove(query) }()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]55 go startWget(finished, serverAddress, "80", query, "")
Filip Tehlarc204c872022-12-21 08:59:16 +0100[diff] [blame]56 s.assertNil(<-finished)
57}
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]58
59func runNginxPerf(s *NoTopoSuite, mode, ab_or_wrk string) error {
60 nRequests := 1000000
61 nClients := 2000
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]62
Maros Ondrejickae7625d02023-02-28 16:55:01 +0100[diff] [blame]63 serverAddress := s.netInterfaces[tapInterfaceName].peer.ip4AddressString()
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]64
Maros Ondrejicka7550dd22023-02-07 20:40:27 +0100[diff] [blame]65 vpp := s.getContainerByName("vpp").vppInstance
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]66
67 nginxCont := s.getContainerByName("nginx")
68 s.assertNil(nginxCont.run())
Florin Corase2415f72023-02-28 14:51:03 -0800[diff] [blame]69 vpp.waitForApp("nginx-", 5)
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]70
Filip Tehlarb41b0af2023-03-20 12:39:20 +0100[diff] [blame^]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 }
Filip Tehlar8df3de42023-01-27 13:14:34 +0100[diff] [blame]93 return nil
94}
95
96func (s *NoTopoSuite) TestNginxPerfCps() {
97 s.assertNil(runNginxPerf(s, "cps", "ab"))
98}
99
100func (s *NoTopoSuite) TestNginxPerfRps() {
101 s.assertNil(runNginxPerf(s, "rps", "ab"))
102}
103
104func (s *NoTopoSuite) TestNginxPerfWrk() {
105 s.assertNil(runNginxPerf(s, "", "wrk"))
106}