Vsan stretch tests to run on isolated setup

Author: Aishwarya-Hebbar

tests/e2e/vsan_stretched_cluster.go

@@ -128,8 +128,7 @@ var _ = ginkgo.Describe("[vsan-stretch-vanilla] vsan stretched cluster tests", f
 				ginkgo.Skip(envStoragePolicyNameWithThickProvision + " env variable not set")
 			}
 			sc, err := client.StorageV1().StorageClasses().Get(ctx, defaultNginxStorageClassName, metav1.GetOptions{})
-			framework.Logf("Storageclass is %v and err is %v", sc, err)
-			if (!strings.Contains(err.Error(), "not found")) && sc != nil {
+			if err != nil && (!strings.Contains(err.Error(), "not found")) && sc != nil {
 				framework.ExpectNoError(client.StorageV1().StorageClasses().Delete(ctx, defaultNginxStorageClassName,
 					*metav1.NewDeleteOptions(0)), "Unable to delete storage class "+defaultNginxStorageClassName)
 			}

tests/e2e/vsan_stretched_cluster_utils.go

@@ -220,19 +220,44 @@ func createFaultDomainMap(ctx context.Context, vs *vSphere) map[string]string {
 	return fdMap
 }
 
+func isSSHReachable(ip string, timeout time.Duration) error {
+	nimbusGeneratedK8sVmPwd := GetAndExpectStringEnvVar(nimbusK8sVmPwd)
+	sshClientConfig := &ssh.ClientConfig{
+		User: "root",
+		Auth: []ssh.AuthMethod{
+			ssh.Password(nimbusGeneratedK8sVmPwd),
+		},
+		HostKeyCallback: ssh.InsecureIgnoreHostKey(),
+	}
+	// Read hosts sshd port number
+	ip, portNum, err := getPortNumAndIP(ip)
+	gomega.Expect(err).NotTo(gomega.HaveOccurred())
+	addr := ip + ":" + portNum
+	_, err = ssh.Dial("tcp", addr, sshClientConfig)
+	if err != nil {
+		if strings.Contains(err.Error(), "connection reset by peer") ||
+			strings.Contains(err.Error(), "no route to host") ||
+			strings.Contains(err.Error(), "handshake failed") {
+			return err // unreachable
+		}
+	}
+	return nil
+}
+
 // waitForHostToBeDown wait for host to be down
 func waitForHostToBeDown(ctx context.Context, ip string) error {
 	framework.Logf("checking host status of %s", ip)
 	gomega.Expect(ip).NotTo(gomega.BeNil())
 	gomega.Expect(ip).NotTo(gomega.BeEmpty())
-	// Read hosts sshd port number
+	/* Read hosts sshd port number
 	ip, portNum, err := getPortNumAndIP(ip)
 	gomega.Expect(err).NotTo(gomega.HaveOccurred())
-	addr := ip + ":" + portNum
+	addr := ip + ":" + portNum*/
 
 	waitErr := wait.PollUntilContextTimeout(ctx, poll*2, pollTimeoutShort*2, true,
 		func(ctx context.Context) (bool, error) {
-			_, err := net.DialTimeout("tcp", addr, poll)
+			//_, err := net.DialTimeout("tcp", addr, poll)
+			err := isSSHReachable(ip, poll)
 			if err == nil {
 				framework.Logf("host is reachable")
 				return false, nil