[OKE-36784] Adding e2e test for boot volume gating case

Author: YashasG98

test/e2e/cloud-provider-oci/boot_volume.go

@@ -54,3 +54,36 @@ var _ = Describe("Boot volume tests", func() {
 		})
 	})
 })
+
+var _ = Describe("Boot volume gating test", func() {
+	f := framework.NewBackupFramework("csi-basic")
+	Context("[cloudprovider][storage][csi][boot-volume]", func() {
+		It("Attach boot volume fails with volumeMode set to Filesystem", func() {
+			pvcJig := framework.NewPVCTestJig(f.ClientSet, "csi-boot-vol-e2e-tests")
+			compartmentId := ""
+			if setupF.Compartment1 != "" {
+				compartmentId = setupF.Compartment1
+			} else if f.CloudProviderConfig.CompartmentID != "" {
+				compartmentId = f.CloudProviderConfig.CompartmentID
+			} else if f.CloudProviderConfig.Auth.CompartmentID != "" {
+				compartmentId = f.CloudProviderConfig.Auth.CompartmentID
+			} else {
+				framework.Failf("Compartment Id undefined.")
+			}
+
+			scName := f.CreateStorageClassOrFail(f.Namespace.Name, "blockvolume.csi.oraclecloud.com",
+				map[string]string{framework.AttachmentType: framework.AttachmentTypeISCSI},
+				pvcJig.Labels, "WaitForFirstConsumer", false, "Retain", nil)
+			pvc, bootvolumeId := pvcJig.CreateAndAwaitStaticBootVolumePVCOrFailCSI(f.ComputeClient, f.Namespace.Name, compartmentId, setupF.AdLocation, setupF.MntTargetSubnetOcid, framework.MinVolumeBlock, scName, nil, v1.PersistentVolumeFilesystem, v1.ReadWriteOnce, v1.ClaimPending)
+			pvcJig.NewPodForCSIWithoutWait("app1", f.Namespace.Name, pvc.Name, setupF.AdLabel)
+			err := pvcJig.WaitTimeoutForPodRunningInNamespace("app1", f.Namespace.Name, 7*time.Minute)
+			if err == nil {
+				framework.Failf("Pod went to running state for gated condition")
+			}
+
+			pvcJig.DeletePod(f.Namespace.Name, "app1", 7*time.Minute)
+			pvcJig.DeleteBootVolume(f.BlockStorageClient, bootvolumeId, 5 * time.Minute)
+			_ = f.DeleteStorageClass(f.Namespace.Name)
+		})
+	})
+})

test/e2e/framework/pod_util.go

@@ -406,7 +406,7 @@ func (j *PVCTestJig) CreateAndAwaitNginxPodOrFail(ns string, pvc *v1.PersistentV
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, ns, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, ns, slowPodStartTimeout)
 	if err != nil {
 		Failf("Pod %q is not Running: %v", pod.Name, err)
 	}
@@ -423,7 +423,7 @@ func (j *PVCTestJig) waitTimeoutForPodNotFoundInNamespace(podName, namespace str
 
 // WaitTimeoutForPodRunningInNamespace waits default amount of time (PodStartTimeout) for the specified pod to become running.
 // Returns an error if timeout occurs first, or pod goes in to failed state.
-func (j *PVCTestJig) waitTimeoutForPodRunningInNamespace(podName, namespace string, timeout time.Duration) error {
+func (j *PVCTestJig) WaitTimeoutForPodRunningInNamespace(podName, namespace string, timeout time.Duration) error {
 	return wait.PollImmediate(Poll, timeout, j.podRunning(podName, namespace))
 }
 

test/e2e/framework/pvc_util.go

@@ -1045,7 +1045,7 @@ func (j *PVCTestJig) NewPodForCSI(name string, namespace string, claimName strin
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
 	if err != nil {
 		Logf("Pod failed to come up, logging debug info")
 		j.logPodDebugInfo(namespace, pod.Name)
@@ -1159,7 +1159,7 @@ func (j *PVCTestJig) NewPodForCSIwAntiAffinity(name string, namespace string, cl
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
 	if err != nil {
 		Failf("Pod %q is not Running: %v", pod.Name, err)
 	}
@@ -1214,7 +1214,7 @@ func (j *PVCTestJig) NewPodWithLabels(name string, namespace string, claimName s
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
 	if err != nil {
 		Logf("Pod failed to come up, logging debug info\n")
 		j.logPodDebugInfo(namespace, pod.Name)
@@ -1291,7 +1291,7 @@ func (j *PVCTestJig) NewPodForCSIClone(name string, namespace string, claimName
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
 	if err != nil {
 		Logf("Pod failed to come up, logging debug info\n")
 		j.logPodDebugInfo(namespace, pod.Name)
@@ -1408,7 +1408,7 @@ func (j *PVCTestJig) NewPodForCSIFSSWrite(name string, namespace string, claimNa
 	}
 
 	// Waiting for pod to be running
-	err = j.waitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
+	err = j.WaitTimeoutForPodRunningInNamespace(pod.Name, namespace, slowPodStartTimeout)
 	if err != nil {
 		Logf("Pod failed to come up, logging debug info\n")
 		j.logPodDebugInfo(namespace, pod.Name)