13 const vclTemplate = `vcl {
14 app-socket-api %[1]s/var/run/app_ns_sockets/%[2]s
18 namespace-secret %[2]s
23 const networkTopologyDir string = "topo-network/"
24 const containerTopologyDir string = "topo-containers/"
31 type ActionResult struct {
38 type JsonResult struct {
45 func startServerApp(running chan error, done chan struct{}, env []string) {
46 cmd := exec.Command("iperf3", "-4", "-s")
52 msg := fmt.Errorf("failed to start iperf server: %v", err)
61 func startClientApp(ipAddress string, env []string, clnCh chan error, clnRes chan string) {
69 cmd := exec.Command("iperf3", "-c", ipAddress, "-u", "-l", "1460", "-b", "10g")
73 o, err := cmd.CombinedOutput()
76 clnCh <- fmt.Errorf("failed to start client app '%s'.\n%s", err, o)
79 time.Sleep(1 * time.Second)
83 clnRes <- fmt.Sprintf("Client output: %s", o)
89 func assertFileSize(f1, f2 string) error {
90 fi1, err := os.Stat(f1)
95 fi2, err1 := os.Stat(f2)
100 if fi1.Size() != fi2.Size() {
101 return fmt.Errorf("file sizes differ (%d vs %d)", fi1.Size(), fi2.Size())
106 func startHttpServer(running chan struct{}, done chan struct{}, addressPort, netNs string) {
107 cmd := newCommand([]string{"./http_server", addressPort}, netNs)
110 fmt.Println("Failed to start http server")
113 running <- struct{}{}
118 func startWget(finished chan error, server_ip, port, query, netNs string) {
120 finished <- errors.New("wget error")
123 cmd := newCommand([]string{"wget", "--timeout=10", "--no-proxy", "--tries=5", "-O", "/dev/null", server_ip + ":" + port + "/" + query},
125 o, err := cmd.CombinedOutput()
127 finished <- fmt.Errorf("wget error: '%v\n\n%s'", err, o)
129 } else if strings.Contains(string(o), "200 OK") == false {
130 finished <- fmt.Errorf("wget error: response not 200 OK")
136 func (c *Stanza) newStanza(name string) *Stanza {
137 c.append("\n" + name + " {")
142 func (c *Stanza) append(name string) *Stanza {
143 c.content += strings.Repeat(" ", c.pad)
144 c.content += name + "\n"
148 func (c *Stanza) close() *Stanza {
154 func (s *Stanza) toString() string {
158 func (s *Stanza) saveToFile(fileName string) error {
159 fo, err := os.Create(fileName)
165 _, err = io.Copy(fo, strings.NewReader(s.content))