diff --git a/e2e/cephfs.go b/e2e/cephfs.go index e8a8d34c8..119f930a4 100644 --- a/e2e/cephfs.go +++ b/e2e/cephfs.go @@ -232,8 +232,12 @@ var _ = Describe("cephfs", func() { } } - // TODO add cephfs backend validation - + subVol := listCephFSSubVolumes(f, "myfs", subvolumegroup) + if len(subVol) != totalCount { + msg := fmt.Sprintf("subvolumes %v. subvolume count %d not matching expected count %v", subVol, len(subVol), totalCount) + e2elog.Logf(msg) + Fail(msg) + } // delete pvc and app for i := 0; i < totalCount; i++ { name := fmt.Sprintf("%s%d", f.UniqueName, i) @@ -243,6 +247,12 @@ var _ = Describe("cephfs", func() { } } + subVol = listCephFSSubVolumes(f, "myfs", subvolumegroup) + if len(subVol) != 0 { + msg := fmt.Sprintf("subvolumes %v. subvolume count %d not matching expected count %v", subVol, len(subVol), 0) + e2elog.Logf(msg) + Fail(msg) + } }) By("check data persist after recreating pod with same pvc", func() {