e2e: add test cases for pv.Spec.MountOptions

Signed-off-by: Rakshith R <rar@redhat.com>

e2e/cephfs.go

@@ -44,6 +44,7 @@ var (
 	cephFSExamplePath     = examplePath + "cephfs/"
 	subvolumegroup        = "e2e"
 	fileSystemName        = "myfs"
+	seLinuxMountOption    = []string{"context=\"system_u:object_r:container_file_t:s0:c0,c1\""}
 )
 
 func deployCephfsPlugin() {
@@ -318,6 +319,24 @@ var _ = Describe(cephfsType, func() {
 					}
 				})
 			}
+
+			By("verify seLinuxMountOptions support", func() {
+				err := createCephfsStorageClass(f.ClientSet, f, true, nil)
+				if err != nil {
+					framework.Failf("failed to create CephFS storageclass: %v", err)
+				}
+
+				err = checkMountOptions(pvcPath, appPath, f, seLinuxMountOption, seLinuxMountOption)
+				if err != nil {
+					framework.Failf("failed to verify mount options: %v", err)
+				}
+
+				err = deleteResource(cephFSExamplePath + "storageclass.yaml")
+				if err != nil {
+					framework.Failf("failed to delete CephFS storageclass: %v", err)
+				}
+			})
+
 			By("verify generic ephemeral volume support", func() {
 				err := createCephfsStorageClass(f.ClientSet, f, true, nil)
 				if err != nil {

e2e/nfs.go

@@ -363,6 +363,23 @@ var _ = Describe("nfs", func() {
 				}
 			})
 
+			By("verify mountOptions support", func() {
+				err := createNFSStorageClass(f.ClientSet, f, false, nil)
+				if err != nil {
+					framework.Failf("failed to create NFS storageclass: %v", err)
+				}
+
+				err = checkMountOptions(pvcPath, appPath, f, seLinuxMountOption, seLinuxMountOption)
+				if err != nil {
+					framework.Failf("failed to verify mount options: %v", err)
+				}
+
+				err = deleteResource(nfsExamplePath + "storageclass.yaml")
+				if err != nil {
+					framework.Failf("failed to delete NFS storageclass: %v", err)
+				}
+			})
+
 			By("verify RWOP volume support", func() {
 				err := createNFSStorageClass(f.ClientSet, f, false, nil)
 				if err != nil {

e2e/rbd.go

@@ -443,6 +443,13 @@ var _ = Describe("RBD", func() {
 				})
 			}
 
+			By("verify seLinuxMountOptions support", func() {
+				err := checkMountOptions(pvcPath, appPath, f, seLinuxMountOption, seLinuxMountOption)
+				if err != nil {
+					framework.Failf("failed to verify mount options: %v", err)
+				}
+			})
+
 			By("create a PVC and check PVC/PV metadata on RBD image", func() {
 				pvc, err := loadPVC(pvcPath)
 				if err != nil {
@@ -2955,7 +2962,7 @@ var _ = Describe("RBD", func() {
 
 			By("validate mount options in app pod", func() {
 				mountFlags := []string{"discard"}
-				err := checkMountOptions(pvcPath, appPath, f, mountFlags)
+				err := checkMountOptions(pvcPath, appPath, f, nil, mountFlags)
 				if err != nil {
 					framework.Failf("failed to check mount options: %v", err)
 				}

e2e/utils.go

@@ -769,13 +769,32 @@ func pvcDeleteWhenPoolNotFound(pvcPath string, cephFS bool, f *framework.Framewo
 	return err
 }
 
-func checkMountOptions(pvcPath, appPath string, f *framework.Framework, mountFlags []string) error {
+func checkMountOptions(pvcPath, appPath string, f *framework.Framework,
+	mountOptions, mountFlags []string) error {
 	pvc, err := loadPVC(pvcPath)
 	if err != nil {
 		return err
 	}
 
 	pvc.Namespace = f.UniqueName
+	err = createPVCAndvalidatePV(f.ClientSet, pvc, deployTimeout)
+	if err != nil {
+		framework.Failf("failed to create PVC: %v", err)
+	}
+	if len(mountOptions) > 0 {
+		// modify PV spec.MountOptions
+		pv, err := getBoundPV(f.ClientSet, pvc)
+		if err != nil {
+			framework.Failf("failed to get PV: %v", err)
+		}
+		pv.Spec.MountOptions = mountOptions
+
+		// update PV
+		_, err = f.ClientSet.CoreV1().PersistentVolumes().Update(context.TODO(), pv, metav1.UpdateOptions{})
+		if err != nil {
+			return fmt.Errorf("failed to update pv: %w", err)
+		}
+	}
 
 	app, err := loadApp(appPath)
 	if err != nil {
@@ -784,7 +803,7 @@ func checkMountOptions(pvcPath, appPath string, f *framework.Framework, mountFla
 	app.Labels = map[string]string{"app": "validate-mount-opt"}
 	app.Namespace = f.UniqueName
 
-	err = createPVCAndApp("", f, pvc, app, deployTimeout)
+	err = createApp(f.ClientSet, app, deployTimeout)
 	if err != nil {
 		return err
 	}

examples/cephfs/storageclass.yaml

@@ -65,5 +65,5 @@ parameters:
 
 reclaimPolicy: Delete
 allowVolumeExpansion: true
-mountOptions:
-  - debug
+# mountOptions:
+#   - context="system_u:object_r:container_file_t:s0:c0,c1"