15 // TODO remove `configTemplate` once its usage has been replaced everywhere with VppConfig
16 const configTemplate = `unix {
18 log %[1]s/var/log/vpp/vpp.log
20 cli-listen %[1]s/var/run/vpp/cli.sock
21 runtime-dir %[1]s/var/run
34 socket-name %[1]s/var/run/vpp/api.sock
38 socket-name %[1]s/var/run/vpp/stats.sock
42 plugin unittest_plugin.so { enable }
43 plugin dpdk_plugin.so { disable }
44 plugin crypto_aesni_plugin.so { enable }
45 plugin quic_plugin.so { enable }
46 plugin crypto_ipsecmb_plugin.so { disable }
51 const vclTemplate = `vcl {
56 namespace-secret %[2]s
61 const NetworkTopologyDir string = "topo-network/"
62 const ContainerTopologyDir string = "topo-containers/"
69 type ActionResult struct {
76 type JsonResult struct {
83 func StartServerApp(running chan error, done chan struct{}, env []string) {
84 cmd := exec.Command("iperf3", "-4", "-s")
90 msg := fmt.Errorf("failed to start iperf server: %v", err)
99 func StartClientApp(env []string, clnCh chan error, clnRes chan string) {
107 cmd := exec.Command("iperf3", "-c", "10.10.10.1", "-u", "-l", "1460", "-b", "10g")
111 o, err := cmd.CombinedOutput()
114 clnCh <- fmt.Errorf("failed to start client app '%s'.\n%s", err, o)
117 time.Sleep(1 * time.Second)
121 clnRes <- fmt.Sprintf("Client output: %s", o)
127 func waitForSyncFile(fname string) (*JsonResult, error) {
130 for i := 0; i < 360; i++ {
131 f, err := os.Open(fname)
135 data, err := ioutil.ReadFile(fname)
137 return nil, fmt.Errorf("read error: %v", err)
139 err = json.Unmarshal(data, &res)
141 return nil, fmt.Errorf("json unmarshal error: %v", err)
145 time.Sleep(1 * time.Second)
147 return nil, fmt.Errorf("no sync file found")
150 func assertFileSize(f1, f2 string) error {
151 fi1, err := os.Stat(f1)
156 fi2, err1 := os.Stat(f2)
161 if fi1.Size() != fi2.Size() {
162 return fmt.Errorf("file sizes differ (%d vs %d)", fi1.Size(), fi2.Size())
167 func startHttpServer(running chan struct{}, done chan struct{}, addressPort, netNs string) {
168 cmd := NewCommand([]string{"./http_server", addressPort}, netNs)
171 fmt.Println("Failed to start http server")
174 running <- struct{}{}
179 func startWget(finished chan error, server_ip, port, query, netNs string) {
181 finished <- errors.New("wget error")
184 cmd := NewCommand([]string{"wget", "--tries=5", "-q", "-O", "/dev/null", server_ip + ":" + port + "/" + query},
186 o, err := cmd.CombinedOutput()
188 finished <- fmt.Errorf("wget error: '%v\n\n%s'", err, o)
194 func (c *Stanza) NewStanza(name string) *Stanza {
195 c.Append("\n" + name + " {")
200 func (c *Stanza) Append(name string) *Stanza {
201 c.content += strings.Repeat(" ", c.pad)
202 c.content += name + "\n"
206 func (c *Stanza) Close() *Stanza {
212 func (s *Stanza) ToString() string {
216 func (s *Stanza) SaveToFile(fileName string) error {
217 fo, err := os.Create(fileName)
223 _, err = io.Copy(fo, strings.NewReader(s.content))