Skip to content

K
k3s
Commit 800012df authored by Marek Grabowski's avatar Marek Grabowski
Browse files
Options

Merge pull request #17995 from ArtfulCoder/ktest

increased the number of tries in kube-proxy test
parents 80415f29 522f5def
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
test/e2e/kubeproxy.go
View file @ 800012df
...@@ -150,7 +150,7 @@ func createHTTPClient(transport *http.Transport) *http.Client { ...@@ -150,7 +150,7 @@ func createHTTPClient(transport *http.Transport) *http.Client {
func (config *KubeProxyTestConfig) hitClusterIP(epCount int) { func (config *KubeProxyTestConfig) hitClusterIP(epCount int) {
clusterIP := config.nodePortService.Spec.ClusterIP clusterIP := config.nodePortService.Spec.ClusterIP
tries := epCount*epCount + 5 // if epCount == 0 tries := epCount*epCount + 15 // if epCount == 0
By("dialing(udp) node1 --> clusterIP:clusterUdpPort") By("dialing(udp) node1 --> clusterIP:clusterUdpPort")
config.dialFromNode("udp", clusterIP, clusterUdpPort, tries, epCount) config.dialFromNode("udp", clusterIP, clusterUdpPort, tries, epCount)
By("dialing(http) node1 --> clusterIP:clusterHttpPort") By("dialing(http) node1 --> clusterIP:clusterHttpPort")
...@@ -169,7 +169,7 @@ func (config *KubeProxyTestConfig) hitClusterIP(epCount int) { ...@@ -169,7 +169,7 @@ func (config *KubeProxyTestConfig) hitClusterIP(epCount int) {
func (config *KubeProxyTestConfig) hitNodePort(epCount int) { func (config *KubeProxyTestConfig) hitNodePort(epCount int) {
node1_IP := config.externalAddrs[0] node1_IP := config.externalAddrs[0]
tries := epCount*epCount + 5 // + 10 if epCount == 0 tries := epCount*epCount + 15 // if epCount == 0
By("dialing(udp) node1 --> node1:nodeUdpPort") By("dialing(udp) node1 --> node1:nodeUdpPort")
config.dialFromNode("udp", node1_IP, nodeUdpPort, tries, epCount) config.dialFromNode("udp", node1_IP, nodeUdpPort, tries, epCount)
By("dialing(http) node1 --> node1:nodeHttpPort") By("dialing(http) node1 --> node1:nodeHttpPort")
...@@ -429,7 +429,7 @@ func (config *KubeProxyTestConfig) setup() { ...@@ -429,7 +429,7 @@ func (config *KubeProxyTestConfig) setup() {
selectorName: "true", selectorName: "true",
} }
By("Getting two nodes") By("Getting node addresses")
nodeList, err := config.f.Client.Nodes().List(labels.Everything(), fields.Everything(), unversioned.ListOptions{}) nodeList, err := config.f.Client.Nodes().List(labels.Everything(), fields.Everything(), unversioned.ListOptions{})
Expect(err).NotTo(HaveOccurred(), fmt.Sprintf("Failed to get node list: %v", err)) Expect(err).NotTo(HaveOccurred(), fmt.Sprintf("Failed to get node list: %v", err))
config.externalAddrs = NodeAddresses(nodeList, api.NodeExternalIP) config.externalAddrs = NodeAddresses(nodeList, api.NodeExternalIP)
......
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