github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-11 13:02:14 +00:00
Code Issues Projects Releases Wiki Activity

Add missing guards around SSH based e2e tests

Browse Source 
All other e2e tests which use SSH are skipped for providers other than gce,
gke and aws. This patch does the same for

- "should release NodePorts on delete" in service.go
- "should test privileged pod" in privileged.go.
This commit is contained in:
Dr. Stefan Schimanski 2015-09-28 12:21:00 +02:00
parent a68e0848dc
commit 657db0a2b5
2 changed files with 23 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
test/e2e/privileged.go
View File

@ -52,6 +52,7 @@ var _ = Describe("PrivilegedPod", func() {
f: f, f: f,
} }
It("should test privileged pod", func() { It("should test privileged pod", func() {
SkipUnlessProviderIs(providersWithSSH...)
By("Getting ssh-able hosts") By("Getting ssh-able hosts")
hosts, err := NodeSSHHosts(config.f.Client) hosts, err := NodeSSHHosts(config.f.Client)

38
test/e2e/service.go
View File

@ -532,14 +532,17 @@ var _ = Describe("Services", func() {
ip := pickNodeIP(c) ip := pickNodeIP(c)
testReachable(ip, nodePort) testReachable(ip, nodePort)
hosts, err := NodeSSHHosts(c) // this test uses NodeSSHHosts that does not work if a Node only reports LegacyHostIP
if err != nil { if providerIs(providersWithSSH...) {
Expect(err).NotTo(HaveOccurred()) hosts, err := NodeSSHHosts(c)
} if err != nil {
cmd := fmt.Sprintf(`test -n "$(ss -ant46 'sport = :%d' | tail -n +2 | grep LISTEN)"`, nodePort) Expect(err).NotTo(HaveOccurred())
_, _, code, err := SSH(cmd, hosts[0], testContext.Provider) }
if code != 0 { cmd := fmt.Sprintf(`test -n "$(ss -ant46 'sport = :%d' | tail -n +2 | grep LISTEN)"`, nodePort)
Failf("expected node port (%d) to be in use", nodePort) _, _, code, err := SSH(cmd, hosts[0], testContext.Provider)
if code != 0 {
Failf("expected node port (%d) to be in use", nodePort)
}
} }
}) })
@ -965,14 +968,17 @@ var _ = Describe("Services", func() {
err = t.DeleteService(serviceName) err = t.DeleteService(serviceName)
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
hosts, err := NodeSSHHosts(c) // this test uses NodeSSHHosts that does not work if a Node only reports LegacyHostIP
if err != nil { if providerIs(providersWithSSH...) {
Expect(err).NotTo(HaveOccurred()) hosts, err := NodeSSHHosts(c)
} if err != nil {
cmd := fmt.Sprintf(`test -n "$(ss -ant46 'sport = :%d' | tail -n +2 | grep LISTEN)"`, nodePort) Expect(err).NotTo(HaveOccurred())
_, _, code, err := SSH(cmd, hosts[0], testContext.Provider) }
if code == 0 { cmd := fmt.Sprintf(`test -n "$(ss -ant46 'sport = :%d' | tail -n +2 | grep LISTEN)"`, nodePort)
Failf("expected node port (%d) to not be in use", nodePort) _, _, code, err := SSH(cmd, hosts[0], testContext.Provider)
if code == 0 {
Failf("expected node port (%d) to not be in use", nodePort)
}
} }
By(fmt.Sprintf("creating service "+serviceName+" with same NodePort %d", nodePort)) By(fmt.Sprintf("creating service "+serviceName+" with same NodePort %d", nodePort))