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 default { disable }
44 plugin unittest_plugin.so { enable }
45 plugin quic_plugin.so { enable }
46 plugin af_packet_plugin.so { enable }
47 plugin hs_apps_plugin.so { enable }
48 plugin http_plugin.so { enable }
53 const vclTemplate = `vcl {
54 app-socket-api %[1]s/var/run/app_ns_sockets/%[2]s
58 namespace-secret %[2]s
63 const NetworkTopologyDir string = "topo-network/"
64 const ContainerTopologyDir string = "topo-containers/"
71 type ActionResult struct {
78 type JsonResult struct {
85 func StartServerApp(running chan error, done chan struct{}, env []string) {
86 cmd := exec.Command("iperf3", "-4", "-s")
92 msg := fmt.Errorf("failed to start iperf server: %v", err)
101 func StartClientApp(ipAddress string, env []string, clnCh chan error, clnRes chan string) {
109 cmd := exec.Command("iperf3", "-c", ipAddress, "-u", "-l", "1460", "-b", "10g")
113 o, err := cmd.CombinedOutput()
116 clnCh <- fmt.Errorf("failed to start client app '%s'.\n%s", err, o)
119 time.Sleep(1 * time.Second)
123 clnRes <- fmt.Sprintf("Client output: %s", o)
129 func waitForSyncFile(fname string) (*JsonResult, error) {
132 for i := 0; i < 360; i++ {
133 f, err := os.Open(fname)
137 data, err := ioutil.ReadFile(fname)
139 return nil, fmt.Errorf("read error: %v", err)
141 err = json.Unmarshal(data, &res)
143 return nil, fmt.Errorf("json unmarshal error: %v", err)
147 time.Sleep(1 * time.Second)
149 return nil, fmt.Errorf("no sync file found")
152 func assertFileSize(f1, f2 string) error {
153 fi1, err := os.Stat(f1)
158 fi2, err1 := os.Stat(f2)
163 if fi1.Size() != fi2.Size() {
164 return fmt.Errorf("file sizes differ (%d vs %d)", fi1.Size(), fi2.Size())
169 func startHttpServer(running chan struct{}, done chan struct{}, addressPort, netNs string) {
170 cmd := NewCommand([]string{"./http_server", addressPort}, netNs)
173 fmt.Println("Failed to start http server")
176 running <- struct{}{}
181 func startWget(finished chan error, server_ip, port, query, netNs string) {
183 finished <- errors.New("wget error")
186 cmd := NewCommand([]string{"wget", "--timeout=10", "--no-proxy", "--tries=5", "-O", "/dev/null", server_ip + ":" + port + "/" + query},
188 o, err := cmd.CombinedOutput()
190 finished <- fmt.Errorf("wget error: '%v\n\n%s'", err, o)
192 } else if strings.Contains(string(o), "200 OK") == false {
193 finished <- fmt.Errorf("wget error: response not 200 OK")
199 func (c *Stanza) NewStanza(name string) *Stanza {
200 c.Append("\n" + name + " {")
205 func (c *Stanza) Append(name string) *Stanza {
206 c.content += strings.Repeat(" ", c.pad)
207 c.content += name + "\n"
211 func (c *Stanza) Close() *Stanza {
217 func (s *Stanza) ToString() string {
221 func (s *Stanza) SaveToFile(fileName string) error {
222 fo, err := os.Create(fileName)
228 _, err = io.Copy(fo, strings.NewReader(s.content))