From f17fb5472239d6ee0a16195fc96dbdba8bc08565 Mon Sep 17 00:00:00 2001
From: yati1998 <ypadia@redhat.com>
Date: Wed, 31 Jul 2024 15:05:36 +0530
Subject: [PATCH] csi: add check to include only cephfs subvolumes

this commit adds an extra check to check the drivername.

Signed-off-by: yati1998 <ypadia@redhat.com>
---
 pkg/filesystem/subvolume.go | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/pkg/filesystem/subvolume.go b/pkg/filesystem/subvolume.go
index 8928013..5524ae4 100644
--- a/pkg/filesystem/subvolume.go
+++ b/pkg/filesystem/subvolume.go
@@ -135,13 +135,16 @@ func getK8sRefSubvolume(ctx context.Context, clientsets *k8sutil.Clientsets) map
 	subvolumeNames := make(map[string]subVolumeInfo)
 	for _, pv := range pvList.Items {
 		if pv.Spec.CSI != nil {
-			subvolumePath := pv.Spec.CSI.VolumeAttributes["subvolumePath"]
-			name, err := getSubvolumeNameFromPath(subvolumePath)
-			if err != nil {
-				logging.Error(err, "failed to get subvolume name")
-				continue
+			driverName := pv.Spec.CSI.Driver
+			if strings.Contains(driverName, "cephfs.csi.ceph.com") {
+				subvolumePath := pv.Spec.CSI.VolumeAttributes["subvolumePath"]
+				name, err := getSubvolumeNameFromPath(subvolumePath)
+				if err != nil {
+					logging.Error(err, "failed to get subvolume name")
+					continue
+				}
+				subvolumeNames[name] = subVolumeInfo{}
 			}
-			subvolumeNames[name] = subVolumeInfo{}
 		}
 	}
 	return subvolumeNames