8 func (s *VethsSuite) TestLDPreloadIperfVpp() {
9 var clnVclConf, srvVclConf Stanza
11 serverContainer := s.getContainerByName("server-vpp")
12 serverVclFileName := serverContainer.getHostWorkDir() + "/vcl_srv.conf"
14 clientContainer := s.getContainerByName("client-vpp")
15 clientVclFileName := clientContainer.getHostWorkDir() + "/vcl_cln.conf"
17 ldpreload := os.Getenv("HST_LDPRELOAD")
18 s.assertNotEqual("", ldpreload)
20 ldpreload = "LD_PRELOAD=" + ldpreload
22 stopServerCh := make(chan struct{}, 1)
23 srvCh := make(chan error, 1)
24 clnCh := make(chan error)
26 s.log("starting VPPs")
28 clientAppSocketApi := fmt.Sprintf("app-socket-api %s/var/run/app_ns_sockets/default",
29 clientContainer.getHostWorkDir())
32 append("rx-fifo-size 4000000").
33 append("tx-fifo-size 4000000").
34 append("app-scope-local").
35 append("app-scope-global").
36 append("use-mq-eventfd").
37 append(clientAppSocketApi).close().
38 saveToFile(clientVclFileName)
41 serverAppSocketApi := fmt.Sprintf("app-socket-api %s/var/run/app_ns_sockets/default",
42 serverContainer.getHostWorkDir())
45 append("rx-fifo-size 4000000").
46 append("tx-fifo-size 4000000").
47 append("app-scope-local").
48 append("app-scope-global").
49 append("use-mq-eventfd").
50 append(serverAppSocketApi).close().
51 saveToFile(serverVclFileName)
54 s.log("attaching server to vpp")
56 srvEnv := append(os.Environ(), ldpreload, "VCL_CONFIG="+serverVclFileName)
57 go s.startServerApp(srvCh, stopServerCh, srvEnv)
62 s.log("attaching client to vpp")
63 var clnRes = make(chan string, 1)
64 clnEnv := append(os.Environ(), ldpreload, "VCL_CONFIG="+clientVclFileName)
65 serverVethAddress := s.netInterfaces[serverInterfaceName].ip4AddressString()
66 go s.startClientApp(serverVethAddress, clnEnv, clnCh, clnRes)
69 // wait for client's result
74 stopServerCh <- struct{}{}