hs-test: restrict concurrency on envoy 23/37923/3
authorFilip Tehlar <ftehlar@cisco.com>
Fri, 13 Jan 2023 20:33:43 +0000 (21:33 +0100)
committerFlorin Coras <florin.coras@gmail.com>
Mon, 16 Jan 2023 20:47:33 +0000 (20:47 +0000)
Type: test

Signed-off-by: Filip Tehlar <ftehlar@cisco.com>
Change-Id: I8b06f4554a6ee5b13de829e47eaa82431a76c332

extras/hs-test/container.go
extras/hs-test/proxy_test.go
extras/hs-test/topo-containers/ns.yaml

index 4ad4548..874ce3d 100644 (file)
@@ -14,12 +14,13 @@ type Volume struct {
 }
 
 type Container struct {
-       isOptional bool
-       name       string
-       image      string
-       workDir    string
-       volumes    map[string]Volume
-       envVars    map[string]string
+       isOptional       bool
+       name             string
+       image            string
+       workDir          string
+       extraRunningArgs string
+       volumes          map[string]Volume
+       envVars          map[string]string
 }
 
 func NewContainer(yamlInput ContainerConfig) (*Container, error) {
@@ -40,6 +41,12 @@ func NewContainer(yamlInput ContainerConfig) (*Container, error) {
                container.image = "hs-test/vpp"
        }
 
+       if args, ok := yamlInput["extra-args"]; ok {
+               container.extraRunningArgs = args.(string)
+       } else {
+               container.extraRunningArgs = ""
+       }
+
        if isOptional, ok := yamlInput["is-optional"]; ok {
                container.isOptional = isOptional.(bool)
        } else {
@@ -77,7 +84,7 @@ func (c *Container) getRunCommand() string {
        cmd += syncPath
        cmd += c.getVolumesAsCliOption()
        cmd += c.getEnvVarsAsCliOption()
-       cmd += " --name " + c.name + " " + c.image
+       cmd += " --name " + c.name + " " + c.image + " " + c.extraRunningArgs
        return cmd
 }
 
index 70fb526..f592426 100644 (file)
@@ -30,7 +30,7 @@ func testProxyHttpTcp(s *NsSuite) error {
 
        s.log("http server started...")
 
-       c := fmt.Sprintf("ip netns exec client wget --retry-connrefused --retry-on-http-error=503 --tries=10 -O %s 10.0.0.2:555/%s", outputFile, srcFile)
+       c := fmt.Sprintf("ip netns exec client wget --no-proxy --retry-connrefused --retry-on-http-error=503 --tries=10 -O %s 10.0.0.2:555/%s", outputFile, srcFile)
        _, err = exechelper.CombinedOutput(c)
        s.assertNil(err, "failed to run wget")
        stopServer <- struct{}{}
index bdba560..e472531 100644 (file)
@@ -25,4 +25,5 @@ containers:
       - name: "VCL_CONFIG"
         value: "/tmp/vcl.conf"
     image: "envoyproxy/envoy-contrib:v1.21-latest"
+    extra-args: "--concurrency 2 -c /etc/envoy/envoy.yaml"
     is-optional: true