7 "github.com/edwarnicke/exechelper"
10 func (s *Veths2Suite) TestVclEchoQuic() {
11 s.T().Skip("quic test skipping..")
15 func (s *Veths2Suite) TestVclEchoUdp() {
16 s.T().Skip("udp echo currently broken in vpp, skipping..")
20 func (s *Veths2Suite) TestVclEchoTcp() {
24 func (s *Veths2Suite) 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 *Veths2Suite) TestVclRetryAttach() {
91 s.testRetryAttach("tcp")
94 func (s *Veths2Suite) 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)