Skip to content

Commit 6a515db

Browse files
author
sipriyaa
committed
new changes
1 parent 372e8f9 commit 6a515db

36 files changed

+244
-143
lines changed

tests/e2e/config_change_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ var _ bool = ginkgo.Describe("[csi-supervisor] config-change-test", func() {
101101
gomega.Expect(err).NotTo(gomega.HaveOccurred())
102102

103103
ginkgo.By(fmt.Sprintln("Changing password on the vCenter host"))
104-
vcAddress, err = readVcAddress()
104+
vcAddress, _, err = readVcAddress()
105105
gomega.Expect(err).NotTo(gomega.HaveOccurred())
106106
username := vsphereCfg.Global.User
107107
currentPassword := vsphereCfg.Global.Password

tests/e2e/crypto.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ var _ = ginkgo.Describe("[csi-supervisor] [encryption] Block volume encryption",
154154

155155
if isVsanHealthServiceStopped {
156156
ginkgo.By(fmt.Sprintln("Starting vsan-health on the vCenter host"))
157-
vcAddress, err = readVcAddress()
157+
vcAddress, _, err = readVcAddress()
158158
gomega.Expect(err).NotTo(gomega.HaveOccurred())
159159
err := invokeVCenterServiceControl(ctx, startOperation, vsanhealthServiceName, vcAddress)
160160
gomega.Expect(err).NotTo(gomega.HaveOccurred())

tests/e2e/csi_cns_telemetry_vc_reboot.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ var _ bool = ginkgo.Describe("[csi-block-vanilla] [csi-file-vanilla] "+
6262
// Reset the cluster distribution value to default value "CSI-Vanilla".
6363
setClusterDistribution(ctx, client, vanillaClusterDistribution)
6464
}
65-
vcAddress, err = readVcAddress()
65+
vcAddress, _, err = readVcAddress()
6666
gomega.Expect(err).NotTo(gomega.HaveOccurred())
6767
})
6868
ginkgo.AfterEach(func() {

tests/e2e/csi_snapshot_basic.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,8 @@ var _ = ginkgo.Describe("Volume Snapshot Basic Test", func() {
106106
}
107107

108108
// reading vc credentials
109-
vcAddress = readVcAddress()
109+
vcAddress, _, err = readVcAddress()
110+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
110111

111112
// reading operation scale value
112113
if os.Getenv("VOLUME_OPS_SCALE") != "" {

tests/e2e/csi_snapshot_negative.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ var _ = ginkgo.Describe("[block-snapshot-negative] Volume Snapshot Fault-Injecti
8080
}
8181

8282
//reading vc address
83-
vcAddress, err = readVcAddress()
83+
vcAddress, _, err = readVcAddress()
8484
gomega.Expect(err).NotTo(gomega.HaveOccurred())
8585

8686
// Get snapshot client using the rest config
@@ -324,7 +324,7 @@ func snapshotOperationWhileServiceDown(serviceName string, namespace string,
324324
scParameters := make(map[string]string)
325325

326326
storagePolicyName := GetAndExpectStringEnvVar(envStoragePolicyNameForSharedDatastores)
327-
vcAddress, err := readVcAddress()
327+
vcAddress, _, err := readVcAddress()
328328

329329
if vanillaCluster {
330330
ginkgo.By("Create storage class")

tests/e2e/csi_static_provisioning_basic.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ var _ = ginkgo.Describe("Basic Static Provisioning", func() {
111111
nonSharedDatastoreURL = GetAndExpectStringEnvVar(envNonSharedStorageClassDatastoreURL)
112112

113113
// reading vc address
114-
vcAddress, err = readVcAddress()
114+
vcAddress, _, err = readVcAddress()
115115
gomega.Expect(err).NotTo(gomega.HaveOccurred())
116116

117117
finder := find.NewFinder(e2eVSphere.Client.Client, false)

tests/e2e/ds_rename.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ var _ bool = ginkgo.Describe("ds-rename", func() {
5555
bootstrap()
5656
scParameters = make(map[string]string)
5757
storagePolicyName = GetAndExpectStringEnvVar(envStoragePolicyNameForSharedDatastores)
58-
vcAddress, err = readVcAddress()
58+
vcAddress, _, err = readVcAddress()
5959
gomega.Expect(err).NotTo(gomega.HaveOccurred())
6060

6161
govmomiClient := newClient(ctx, &e2eVSphere)

tests/e2e/fullsync_test_for_block_volume.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ var _ bool = ginkgo.Describe("full-sync-test", func() {
9595
defer cancel()
9696

9797
// reading vc address
98-
vcAddress, err = readVcAddress()
98+
vcAddress, _, err = readVcAddress()
9999
gomega.Expect(err).NotTo(gomega.HaveOccurred())
100100

101101
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/fullsync_test_for_file_volume.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ var _ bool = ginkgo.Describe("[csi-file-vanilla] Full sync test for file volume"
6666
defer cancel()
6767

6868
// reading vc address
69-
vcAddress, err = readVcAddress()
69+
vcAddress, _, err = readVcAddress()
7070
gomega.Expect(err).NotTo(gomega.HaveOccurred())
7171

7272
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/gc_block_volume_expansion.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ var _ = ginkgo.Describe("[csi-guest] Volume Expansion Test", func() {
7979
bootstrap()
8080

8181
// reading vc address
82-
vcAddress, err = readVcAddress()
82+
vcAddress, _, err = readVcAddress()
8383
gomega.Expect(err).NotTo(gomega.HaveOccurred())
8484

8585
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/gc_metadata_syncer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ var _ = ginkgo.Describe("[csi-guest] pvCSI metadata syncer tests", func() {
7474
defer cancel()
7575

7676
// reading vc address
77-
vcAddress, err = readVcAddress()
77+
vcAddress, _, err = readVcAddress()
7878
gomega.Expect(err).NotTo(gomega.HaveOccurred())
7979

8080
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/gc_rwx_service_down.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ var _ = ginkgo.Describe("File Volume Test on Service down", func() {
6565
defer cancel()
6666

6767
// reading vc address
68-
vcAddress, err = readVcAddress()
68+
vcAddress, _, err = readVcAddress()
6969
gomega.Expect(err).NotTo(gomega.HaveOccurred())
7070

7171
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/gc_rwx_syncer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ var _ = ginkgo.Describe("[rwm-csi-tkg] File Volume Test for label updates", func
6565
defer cancel()
6666

6767
// reading vc address
68-
vcAddress, err = readVcAddress()
68+
vcAddress, _, err = readVcAddress()
6969
gomega.Expect(err).NotTo(gomega.HaveOccurred())
7070

7171
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/gc_rwx_volume_health.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ var _ = ginkgo.Describe("File Volume Test volume health plumbing", func() {
6262
defer cancel()
6363

6464
// reading vc address
65-
vcAddress, err = readVcAddress()
65+
vcAddress, _, err = readVcAddress()
6666
gomega.Expect(err).NotTo(gomega.HaveOccurred())
6767

6868
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)

tests/e2e/hci_mesh_rwx_disruptive.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ var _ = ginkgo.Describe("[rwx-hci-singlevc-disruptive] RWX-Topology-HciMesh-Sing
7979
bootstrap()
8080

8181
// reading vc address
82-
vcAddress, err = readVcAddress()
82+
vcAddress, _, err = readVcAddress()
8383
gomega.Expect(err).NotTo(gomega.HaveOccurred())
8484

8585
// fetch list of k8s nodes

tests/e2e/improved_csi_idempotency.go

+6-2
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ var _ = ginkgo.Describe("Improved CSI Idempotency Tests", func() {
7373
defer cancel()
7474

7575
// reading vc address
76-
vcAddress, err = readVcAddress()
76+
vcAddress, _, err = readVcAddress()
7777
gomega.Expect(err).NotTo(gomega.HaveOccurred())
7878

7979
nodeList, err := fnodes.GetReadySchedulableNodes(ctx, f.ClientSet)
@@ -469,6 +469,10 @@ func createVolumeWithServiceDown(serviceName string, namespace string, client cl
469469
var fullSyncWaitTime int
470470
pvclaims = make([]*v1.PersistentVolumeClaim, volumeOpsScale)
471471

472+
// reading vc address
473+
vcAddress, _, err := readVcAddress()
474+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
475+
472476
// Decide which test setup is available to run
473477
if vanillaCluster {
474478
ginkgo.By("CNS_TEST: Running for vanilla k8s setup")
@@ -734,7 +738,7 @@ func extendVolumeWithServiceDown(serviceName string, namespace string, client cl
734738
pvclaims = make([]*v1.PersistentVolumeClaim, volumeOpsScale)
735739

736740
var vcAddress string
737-
vcAddress, err = readVcAddress()
741+
vcAddress, _, err = readVcAddress()
738742
gomega.Expect(err).NotTo(gomega.HaveOccurred())
739743

740744
// Decide which test setup is available to run

tests/e2e/multi_master_k8s.go

+9-1
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ import (
2121
"errors"
2222
"fmt"
2323
"net"
24+
"os"
2425
"strings"
2526
"time"
2627

@@ -292,7 +293,14 @@ var _ = ginkgo.Describe("[csi-multi-master-block-e2e]", func() {
292293
nodeNameOfvSphereCSIControllerPod, nodeNameIPMap[nodeNameOfvSphereCSIControllerPod]))
293294

294295
sshCmd := "systemctl stop kubelet.service"
295-
host := nodeNameIPMap[nodeNameOfvSphereCSIControllerPod] + ":22"
296+
// Get SSH port number from environment variable or use default
297+
vcPortNo := os.Getenv(envVcSshdPortNum)
298+
if vcPortNo == "" {
299+
vcPortNo = defaultShhdPortNum
300+
}
301+
302+
// Construct the host address dynamically
303+
host := nodeNameIPMap[nodeNameOfvSphereCSIControllerPod] + ":" + vcPortNo
296304
ginkgo.By(fmt.Sprintf("Invoking command %+v on host %+v", sshCmd, host))
297305
result, err := fssh.SSH(ctx, sshCmd, host, framework.TestContext.Provider)
298306
ginkgo.By(fmt.Sprintf("%s returned result %s", sshCmd, result.Stdout))

tests/e2e/multi_svc_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
118118
kubeconfig1 = GetAndExpectStringEnvVar("KUBECONFIG1")
119119

120120
// reading vc address
121-
vcAddress, err = readVcAddress()
121+
vcAddress, _, err = readVcAddress()
122122
gomega.Expect(err).NotTo(gomega.HaveOccurred())
123123

124124
ginkgo.By("Getting User and Supervisor-Id for both the supervisors")

tests/e2e/multi_vc.go

+13-14
Original file line numberDiff line numberDiff line change
@@ -159,15 +159,15 @@ var _ = ginkgo.Describe("[multivc-positive] MultiVc-Topology-Positive", func() {
159159
}
160160

161161
if isVsanHealthServiceStopped {
162-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
163-
vcAddress := vCenterHostname[0] + ":" + sshdPort
162+
vcAddress, _, err := readMultiVcAddress(0)
163+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
164164
framework.Logf("Bringing vsanhealth up before terminating the test")
165165
startVCServiceWait4VPs(ctx, vcAddress, vsanhealthServiceName, &isVsanHealthServiceStopped)
166166
}
167167

168168
if isSPSServiceStopped {
169-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
170-
vcAddress := vCenterHostname[0] + ":" + sshdPort
169+
vcAddress, _, err := readMultiVcAddress(0)
170+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
171171
framework.Logf("Bringing sps up before terminating the test")
172172
startVCServiceWait4VPs(ctx, vcAddress, spsServiceName, &isSPSServiceStopped)
173173
isSPSServiceStopped = false
@@ -1421,12 +1421,12 @@ var _ = ginkgo.Describe("[multivc-positive] MultiVc-Topology-Positive", func() {
14211421
}()
14221422

14231423
ginkgo.By("Rebooting VC1")
1424-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
1425-
vcAddress := vCenterHostname[0] + ":" + sshdPort
1424+
vcAddress, vCenterIP, err := readMultiVcAddress(0)
1425+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
14261426
framework.Logf("vcAddress - %s ", vcAddress)
14271427
err = invokeVCenterReboot(ctx, vcAddress)
14281428
gomega.Expect(err).NotTo(gomega.HaveOccurred())
1429-
err = waitForHostToBeUp(vCenterHostname[0])
1429+
err = waitForHostToBeUp(vCenterIP)
14301430
gomega.Expect(err).NotTo(gomega.HaveOccurred())
14311431
ginkgo.By("Done with reboot")
14321432

@@ -1518,12 +1518,12 @@ var _ = ginkgo.Describe("[multivc-positive] MultiVc-Topology-Positive", func() {
15181518
}()
15191519

15201520
ginkgo.By("Rebooting VC1")
1521-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
1522-
vcAddress := vCenterHostname[0] + ":" + sshdPort
1521+
vcAddress, vCenterIP, err := readMultiVcAddress(0)
1522+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
15231523
framework.Logf("vcAddress - %s ", vcAddress)
15241524
err = invokeVCenterReboot(ctx, vcAddress)
15251525
gomega.Expect(err).NotTo(gomega.HaveOccurred())
1526-
err = waitForHostToBeUp(vCenterHostname[0])
1526+
err = waitForHostToBeUp(vCenterIP)
15271527
gomega.Expect(err).NotTo(gomega.HaveOccurred())
15281528
ginkgo.By("Done with reboot")
15291529

@@ -1658,8 +1658,7 @@ var _ = ginkgo.Describe("[multivc-positive] MultiVc-Topology-Positive", func() {
16581658
}()
16591659

16601660
ginkgo.By("Bring down Vsan-health service on VC1")
1661-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
1662-
vcAddress := vCenterHostname[0] + ":" + sshdPort
1661+
vcAddress, _, err := readMultiVcAddress(0)
16631662
framework.Logf("vcAddress - %s ", vcAddress)
16641663
err = invokeVCenterServiceControl(ctx, stopOperation, vsanhealthServiceName, vcAddress)
16651664
gomega.Expect(err).NotTo(gomega.HaveOccurred())
@@ -1816,8 +1815,8 @@ var _ = ginkgo.Describe("[multivc-positive] MultiVc-Topology-Positive", func() {
18161815
gomega.Expect(err).NotTo(gomega.HaveOccurred())
18171816

18181817
ginkgo.By("Bring down SPS service")
1819-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
1820-
vcAddress := vCenterHostname[0] + ":" + sshdPort
1818+
vcAddress, _, err := readMultiVcAddress(0)
1819+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
18211820
framework.Logf("vcAddress - %s ", vcAddress)
18221821
err = invokeVCenterServiceControl(ctx, stopOperation, spsServiceName, vcAddress)
18231822
gomega.Expect(err).NotTo(gomega.HaveOccurred())

tests/e2e/multi_vc_config_secret.go

+13-8
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,6 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
6464
vCenterPassword string
6565
vCenterPort string
6666
dataCenter string
67-
err error
6867
revertToOriginalVsphereConf bool
6968
multiVCSetupType string
7069
allMasterIps []string
@@ -157,7 +156,7 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
157156

158157
if originalVC1PasswordChanged {
159158
clientIndex := 0
160-
vcAddress, err := readMultiVcAddress(0)
159+
vcAddress, _, err := readMultiVcAddress(0)
161160
gomega.Expect(err).NotTo(gomega.HaveOccurred())
162161
username := strings.Split(vCenterUser, ",")[0]
163162
originalPassword := strings.Split(vCenterPassword, ",")[0]
@@ -170,7 +169,9 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
170169

171170
if originalVC3PasswordChanged {
172171
clientIndex2 := 2
173-
vcAddress3 := strings.Split(vCenterIP, ",")[2] + ":" + sshdPort
172+
// reading 3rd vc
173+
vcAddress3, _, err := readMultiVcAddress(2)
174+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
174175
username3 := strings.Split(vCenterUser, ",")[2]
175176
originalPassword3 := strings.Split(vCenterPassword, ",")[2]
176177
newPassword3 := "Admin!23"
@@ -244,7 +245,8 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
244245
vsphereCfg, err := readVsphereConfSecret(client, ctx, csiNamespace)
245246
gomega.Expect(err).NotTo(gomega.HaveOccurred())
246247

247-
vcAddress := strings.Split(vsphereCfg.Global.VCenterHostname, ",")[0] + ":" + sshdPort
248+
vcAddress, _, err := readMultiVcAddress(0)
249+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
248250
framework.Logf("vcAddress - %s ", vcAddress)
249251
username := strings.Split(vsphereCfg.Global.User, ",")[0]
250252
originalPassword := strings.Split(vsphereCfg.Global.Password, ",")[0]
@@ -752,7 +754,8 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
752754
}()
753755

754756
// read VC1 credentials
755-
vcAddress1 := strings.Split(vsphereCfg.Global.VCenterHostname, ",")[0] + ":" + sshdPort
757+
vcAddress1, _, err := readMultiVcAddress(0)
758+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
756759
username1 := strings.Split(vsphereCfg.Global.User, ",")[0]
757760
originalPassword1 := strings.Split(vsphereCfg.Global.Password, ",")[0]
758761
newPassword1 := "E2E-test-password!23"
@@ -765,7 +768,8 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
765768

766769
if multiVCSetupType == "multi-3vc-setup" {
767770
// read VC3 credentials
768-
vcAddress3 = strings.Split(vsphereCfg.Global.VCenterHostname, ",")[2] + ":" + sshdPort
771+
vcAddress3, _, err = readMultiVcAddress(2)
772+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
769773
username3 = strings.Split(vsphereCfg.Global.User, ",")[2]
770774
originalPassword3 = strings.Split(vsphereCfg.Global.Password, ",")[2]
771775
newPassword3 = "Admin!23"
@@ -848,7 +852,7 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
848852

849853
ginkgo.By("Rebooting VC2")
850854
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
851-
vcAddress := vCenterHostname[1] + ":" + sshdPort
855+
vcAddress, _, err := readMultiVcAddress(1)
852856
framework.Logf("vcAddress - %s ", vcAddress)
853857
err = invokeVCenterReboot(ctx, vcAddress)
854858
gomega.Expect(err).NotTo(gomega.HaveOccurred())
@@ -919,7 +923,8 @@ var _ = ginkgo.Describe("[multivc-configsecret] MultiVc-ConfigSecret", func() {
919923
// read original vsphere config secret
920924
vsphereCfg, err := readVsphereConfSecret(client, ctx, csiNamespace)
921925
gomega.Expect(err).NotTo(gomega.HaveOccurred())
922-
vcAddress := strings.Split(vsphereCfg.Global.VCenterHostname, ",")[0] + ":" + sshdPort
926+
vcAddress, _, err := readMultiVcAddress(0)
927+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
923928
framework.Logf("vcAddress - %s ", vcAddress)
924929
username := strings.Split(vsphereCfg.Global.User, ",")[0]
925930
originalPassword := strings.Split(vsphereCfg.Global.Password, ",")[0]

tests/e2e/multi_vc_preferential_topology.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import (
2121
"fmt"
2222
"os"
2323
"strconv"
24-
"strings"
2524
"sync"
2625
"time"
2726

@@ -454,12 +453,12 @@ var _ = ginkgo.Describe("[multivc-preferential] MultiVc-Preferential", func() {
454453
gomega.Expect(err).NotTo(gomega.HaveOccurred())
455454

456455
ginkgo.By("Rebooting VC")
457-
vCenterHostname := strings.Split(multiVCe2eVSphere.multivcConfig.Global.VCenterHostname, ",")
458-
vcAddress := vCenterHostname[0] + ":" + sshdPort
456+
vcAddress, vCenterIP, err := readMultiVcAddress(0)
457+
gomega.Expect(err).NotTo(gomega.HaveOccurred())
459458
framework.Logf("vcAddress - %s ", vcAddress)
460459
err = invokeVCenterReboot(ctx, vcAddress)
461460
gomega.Expect(err).NotTo(gomega.HaveOccurred())
462-
err = waitForHostToBeUp(vCenterHostname[0])
461+
err = waitForHostToBeUp(vCenterIP)
463462
gomega.Expect(err).NotTo(gomega.HaveOccurred())
464463
ginkgo.By("Done with reboot")
465464

0 commit comments

Comments
 (0)