Commit 0331b27f authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub

Merge pull request #34053 from bprashanth/trim_string

Automatic merge from submit-queue Check for empty string post trimming We curl in a retry loop and timeout, trimming stdout to find endpoint names. When curl hits the timeout, stdout is empty, so we insert the empty string into the received set of endpoints. Fixes https://github.com/kubernetes/kubernetes/issues/32684
parents 33103e57 fd9b152f
...@@ -170,7 +170,10 @@ func (config *NetworkingTestConfig) dialFromContainer(protocol, containerIP, tar ...@@ -170,7 +170,10 @@ func (config *NetworkingTestConfig) dialFromContainer(protocol, containerIP, tar
continue continue
} }
for _, hostName := range output["responses"] { for _, hostName := range output["responses"] {
eps.Insert(hostName) trimmed := strings.TrimSpace(hostName)
if trimmed != "" {
eps.Insert(trimmed)
}
} }
} }
framework.Logf("Waiting for endpoints: %v", expectedEps.Difference(eps)) framework.Logf("Waiting for endpoints: %v", expectedEps.Difference(eps))
...@@ -217,7 +220,10 @@ func (config *NetworkingTestConfig) dialFromNode(protocol, targetIP string, targ ...@@ -217,7 +220,10 @@ func (config *NetworkingTestConfig) dialFromNode(protocol, targetIP string, targ
// we confirm unreachability. // we confirm unreachability.
framework.Logf("Failed to execute %v: %v", filterCmd, err) framework.Logf("Failed to execute %v: %v", filterCmd, err)
} else { } else {
eps.Insert(strings.TrimSpace(stdout)) trimmed := strings.TrimSpace(stdout)
if trimmed != "" {
eps.Insert(trimmed)
}
} }
framework.Logf("Waiting for %+v endpoints, got endpoints %+v", expectedEps.Difference(eps), eps) framework.Logf("Waiting for %+v endpoints, got endpoints %+v", expectedEps.Difference(eps), eps)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment