extras/hs-test/ldp_test.go

   1 package main
   2
   3 import (
   4         "fmt"
   5         "os"
   6 )
   7
   8 func (s *VethsSuite) TestLDPreloadIperfVpp() {
   9         var clnVclConf, srvVclConf Stanza
  10
  11         serverContainer := s.getContainerByName("server-vpp")
  12         serverVclFileName := serverContainer.getHostWorkDir() + "/vcl_srv.conf"
  13
  14         clientContainer := s.getContainerByName("client-vpp")
  15         clientVclFileName := clientContainer.getHostWorkDir() + "/vcl_cln.conf"
  16
  17         ldpreload := os.Getenv("HST_LDPRELOAD")
  18         s.assertNotEqual("", ldpreload)
  19
  20         ldpreload = "LD_PRELOAD=" + ldpreload
  21
  22         stopServerCh := make(chan struct{}, 1)
  23         srvCh := make(chan error, 1)
  24         clnCh := make(chan error)
  25
  26         s.log("starting VPPs")
  27
  28         clientAppSocketApi := fmt.Sprintf("app-socket-api %s/var/run/app_ns_sockets/2",
  29                 clientContainer.getContainerWorkDir())
  30         err := clnVclConf.
  31                 newStanza("vcl").
  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)
  39         s.assertNil(err)
  40
  41         serverAppSocketApi := fmt.Sprintf("app-socket-api %s/var/run/app_ns_sockets/1",
  42                 serverContainer.getContainerWorkDir())
  43         err = srvVclConf.
  44                 newStanza("vcl").
  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)
  52         s.assertNil(err)
  53
  54         s.log("attaching server to vpp")
  55
  56         srvEnv := append(os.Environ(), ldpreload, "VCL_CONFIG="+serverVclFileName)
  57         go s.startServerApp(srvCh, stopServerCh, srvEnv)
  58
  59         err = <-srvCh
  60         s.assertNil(err)
  61
  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)
  67         s.log(<-clnRes)
  68
  69         // wait for client's result
  70         err = <-clnCh
  71         s.assertNil(err)
  72
  73         // stop server
  74         stopServerCh <- struct{}{}
  75 }