| package main |
| |
| func init() { |
| registerVethTests(VppEchoQuicTest, VppEchoTcpTest) |
| } |
| |
| func VppEchoQuicTest(s *VethsSuite) { |
| s.testVppEcho("quic") |
| } |
| |
| // TODO: udp echo currently broken in vpp |
| func VppEchoUdpTest(s *VethsSuite) { |
| s.testVppEcho("udp") |
| } |
| |
| func VppEchoTcpTest(s *VethsSuite) { |
| s.testVppEcho("tcp") |
| } |
| |
| func (s *VethsSuite) testVppEcho(proto string) { |
| serverVethAddress := s.getInterfaceByName(serverInterfaceName).ip4AddressString() |
| uri := proto + "://" + serverVethAddress + "/12344" |
| |
| echoSrvContainer := s.getContainerByName("server-app") |
| serverCommand := "vpp_echo server TX=RX" + |
| " socket-name " + echoSrvContainer.getContainerWorkDir() + "/var/run/app_ns_sockets/default" + |
| " use-app-socket-api" + |
| " uri " + uri |
| s.log(serverCommand) |
| echoSrvContainer.execServer(serverCommand) |
| |
| echoClnContainer := s.getContainerByName("client-app") |
| |
| clientCommand := "vpp_echo client" + |
| " socket-name " + echoClnContainer.getContainerWorkDir() + "/var/run/app_ns_sockets/default" + |
| " use-app-socket-api uri " + uri |
| s.log(clientCommand) |
| o := echoClnContainer.exec(clientCommand) |
| s.log(o) |
| } |