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/2veths")
40 defer func() { exechelper.Run("docker stop " + srvInstance) }()
42 err = dockerRun(clnInstance, "-v echo-cln-vol:/tmp/2veths")
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("2veths srv", srvInstance)
69 _, err = hstExec("2veths cln", clnInstance)
76 _, err = hstExec("echo-server "+proto, echoSrv)
78 t.Errorf("echo server: %v", err)
82 o, err := hstExec("echo-client "+proto, echoCln)
84 t.Errorf("echo client: %v", err)
89 func (s *Veths2Suite) TestVclRetryAttach() {
90 s.testRetryAttach("tcp")
93 func (s *Veths2Suite) testRetryAttach(proto string) {
96 exechelper.Run("docker volume create --name=echo-srv-vol")
97 exechelper.Run("docker volume create --name=echo-cln-vol")
99 srvInstance := "vpp-vcl-test-srv"
100 clnInstance := "vpp-vcl-test-cln"
101 echoSrv := "echo-srv"
102 echoCln := "echo-cln"
104 err := dockerRun(srvInstance, "-v echo-srv-vol:/tmp/2veths")
109 defer func() { exechelper.Run("docker stop " + srvInstance) }()
111 err = dockerRun(clnInstance, "-v echo-cln-vol:/tmp/2veths")
116 defer func() { exechelper.Run("docker stop " + clnInstance) }()
118 err = dockerRun(echoSrv, fmt.Sprintf("-v echo-srv-vol:/tmp/%s", echoSrv))
123 defer func() { exechelper.Run("docker stop " + echoSrv) }()
125 err = dockerRun(echoCln, fmt.Sprintf("-v echo-cln-vol:/tmp/%s", echoCln))
130 defer func() { exechelper.Run("docker stop " + echoCln) }()
132 _, err = hstExec("2veths srv-with-preset-hw-addr", srvInstance)
138 _, err = hstExec("2veths cln", clnInstance)
144 _, err = hstExec("vcl-test-server "+proto, echoSrv)
146 t.Errorf("vcl test server: %v", err)
150 fmt.Println("This whole test case can take around 3 minutes to run. Please be patient.")
151 fmt.Println("... Running first echo client test, before disconnect.")
152 _, err = hstExec("vcl-test-client "+proto, echoCln)
154 t.Errorf("vcl test client: %v", err)
157 fmt.Println("... First test ended. Stopping VPP server now.")
159 // Stop server-vpp-instance, start it again and then run vcl-test-client once more
160 stopVppCommand := "/bin/bash -c 'ps -C vpp_main -o pid= | xargs kill -9'"
161 _, err = dockerExec(stopVppCommand, srvInstance)
163 t.Errorf("error while stopping vpp: %v", err)
166 time.Sleep(5 * time.Second) // Give parent process time to reap the killed child process
167 stopVppCommand = "/bin/bash -c 'ps -C hs-test -o pid= | xargs kill -9'"
168 _, err = dockerExec(stopVppCommand, srvInstance)
170 t.Errorf("error while stopping hs-test: %v", err)
173 _, err = hstExec("2veths srv-with-preset-hw-addr", srvInstance)
179 fmt.Println("... VPP server is starting again, so waiting for a bit.")
180 time.Sleep(30 * time.Second) // Wait a moment for the re-attachment to happen
182 fmt.Println("... Running second echo client test, after disconnect and re-attachment.")
183 _, err = hstExec("vcl-test-client "+proto, echoCln)
185 t.Errorf("vcl test client: %v", err)