7 "github.com/edwarnicke/exechelper"
10 func (s *VethsSuite) TestVclEchoQuic() {
11 s.T().Skip("quic test skipping..")
15 func (s *VethsSuite) TestVclEchoUdp() {
16 s.T().Skip("udp echo currently broken in vpp, skipping..")
20 func (s *VethsSuite) TestVclEchoTcp() {
24 func (s *VethsSuite) testVclEcho(proto string) {
27 exechelper.Run("docker volume create --name=echo-srv-vol")
28 exechelper.Run("docker volume create --name=echo-cln-vol")
30 srvInstance := "vpp-echo-srv"
31 clnInstance := "vpp-echo-cln"
35 err := dockerRun(srvInstance, "-v echo-srv-vol:/tmp/Configure2Veths")
40 defer func() { exechelper.Run("docker stop " + srvInstance) }()
42 err = dockerRun(clnInstance, "-v echo-cln-vol:/tmp/Configure2Veths")
47 defer func() { exechelper.Run("docker stop " + clnInstance) }()
49 err = dockerRun(echoSrv, fmt.Sprintf("-v echo-srv-vol:/tmp/%s", echoSrv))
54 defer func() { exechelper.Run("docker stop " + echoSrv) }()
56 err = dockerRun(echoCln, fmt.Sprintf("-v echo-cln-vol:/tmp/%s", echoCln))
61 defer func() { exechelper.Run("docker stop " + echoCln) }()
63 _, err = hstExec("Configure2Veths srv", srvInstance)
69 _, err = hstExec("Configure2Veths cln", clnInstance)
76 _, err = hstExec("RunEchoServer "+proto, echoSrv)
78 t.Errorf("echo server: %v", err)
82 o, err := hstExec("RunEchoClient "+proto, echoCln)
84 t.Errorf("echo client: %v", err)
89 func (s *VethsSuite) TestVclRetryAttach() {
91 s.testRetryAttach("tcp")
94 func (s *VethsSuite) testRetryAttach(proto string) {
97 exechelper.Run("docker volume create --name=echo-srv-vol")
98 exechelper.Run("docker volume create --name=echo-cln-vol")
100 srvInstance := "vpp-vcl-test-srv"
101 clnInstance := "vpp-vcl-test-cln"
102 echoSrv := "echo-srv"
103 echoCln := "echo-cln"
105 err := dockerRun(srvInstance, "-v echo-srv-vol:/tmp/Configure2Veths")
110 defer func() { exechelper.Run("docker stop " + srvInstance) }()
112 err = dockerRun(clnInstance, "-v echo-cln-vol:/tmp/Configure2Veths")
117 defer func() { exechelper.Run("docker stop " + clnInstance) }()
119 err = dockerRun(echoSrv, fmt.Sprintf("-v echo-srv-vol:/tmp/%s", echoSrv))
124 defer func() { exechelper.Run("docker stop " + echoSrv) }()
126 err = dockerRun(echoCln, fmt.Sprintf("-v echo-cln-vol:/tmp/%s", echoCln))
131 defer func() { exechelper.Run("docker stop " + echoCln) }()
133 _, err = hstExec("Configure2Veths srv-with-preset-hw-addr", srvInstance)
139 _, err = hstExec("Configure2Veths cln", clnInstance)
145 _, err = hstExec("RunVclEchoServer "+proto, echoSrv)
147 t.Errorf("vcl test server: %v", err)
151 fmt.Println("This whole test case can take around 3 minutes to run. Please be patient.")
152 fmt.Println("... Running first echo client test, before disconnect.")
153 _, err = hstExec("RunVclEchoClient "+proto, echoCln)
155 t.Errorf("vcl test client: %v", err)
158 fmt.Println("... First test ended. Stopping VPP server now.")
160 // Stop server-vpp-instance, start it again and then run vcl-test-client once more
161 stopVppCommand := "/bin/bash -c 'ps -C vpp_main -o pid= | xargs kill -9'"
162 _, err = dockerExec(stopVppCommand, srvInstance)
164 t.Errorf("error while stopping vpp: %v", err)
167 time.Sleep(5 * time.Second) // Give parent process time to reap the killed child process
168 stopVppCommand = "/bin/bash -c 'ps -C hs-test -o pid= | xargs kill -9'"
169 _, err = dockerExec(stopVppCommand, srvInstance)
171 t.Errorf("error while stopping hs-test: %v", err)
174 _, err = hstExec("Configure2Veths srv-with-preset-hw-addr", srvInstance)
180 fmt.Println("... VPP server is starting again, so waiting for a bit.")
181 time.Sleep(30 * time.Second) // Wait a moment for the re-attachment to happen
183 fmt.Println("... Running second echo client test, after disconnect and re-attachment.")
184 _, err = hstExec("RunVclEchoClient "+proto, echoCln)
186 t.Errorf("vcl test client: %v", err)
191 func (s *VethsSuite) TestTcpWithLoss() {
192 serverContainer, err := s.NewContainer("server")
193 s.assertNil(err, "creating container failed")
194 err = serverContainer.run()
197 serverVpp := NewVppInstance(serverContainer)
198 s.assertNotNil(serverVpp)
199 serverVpp.setCliSocket("/var/run/vpp/cli.sock")
200 serverVpp.set2VethsServer()
201 err = serverVpp.start()
202 s.assertNil(err, "starting VPP failed")
204 _, err = serverVpp.vppctl("test echo server uri tcp://10.10.10.1/20022")
205 s.assertNil(err, "starting echo server failed")
207 clientContainer, err := s.NewContainer("client")
208 s.assertNil(err, "creating container failed")
209 err = clientContainer.run()
210 s.assertNil(err, "starting container failed")
212 clientVpp := NewVppInstance(clientContainer)
213 s.assertNotNil(clientVpp)
214 clientVpp.setCliSocket("/var/run/vpp/cli.sock")
215 clientVpp.set2VethsClient()
216 err = clientVpp.start()
217 s.assertNil(err, "starting VPP failed")
219 // Ensure that VPP doesn't abort itself with NSIM enabled
220 // Warning: Removing this ping will make the test fail!
221 _, err = serverVpp.vppctl("ping 10.10.10.2")
222 s.assertNil(err, "ping failed")
224 // Add loss of packets with Network Delay Simulator
225 _, err = clientVpp.vppctl("set nsim poll-main-thread delay 0.01 ms bandwidth 40 gbit packet-size 1400 packets-per-drop 1000")
226 s.assertNil(err, "configuring NSIM failed")
227 _, err = clientVpp.vppctl("nsim output-feature enable-disable host-vppcln")
228 s.assertNil(err, "enabling NSIM failed")
230 // Do echo test from client-vpp container
231 output, err := clientVpp.vppctl("test echo client uri tcp://10.10.10.1/20022 mbytes 50")
233 s.assertEqual(true, len(output) != 0)
234 s.assertNotContains(output, "failed: timeout")