import ceph quincy 17.2.4

[ceph.git] / ceph / src / pybind / mgr / volumes / fs / fs_util.py

diff --git a/ceph/src/pybind/mgr/volumes/fs/fs_util.py b/ceph/src/pybind/mgr/volumes/fs/fs_util.py
index 05a6e52caf54cd1f7378a664526f139d8bd5a453..be0a06acdd8997d2d7de06dffe653038e6d58c39 100644 (file)
--- a/ceph/src/pybind/mgr/volumes/fs/fs_util.py
+++ b/ceph/src/pybind/mgr/volumes/fs/fs_util.py
@@ -88,6 +88,28 @@ def listdir(fs, dirpath, filter_entries=None):
         raise VolumeException(-e.args[0], e.args[1])
     return dirs
 
+
+def has_subdir(fs, dirpath, filter_entries=None):
+    """
+    Check the presence of directory (only dirs) for a given path
+    """
+    res = False
+    if filter_entries is None:
+        filter_entries = [b".", b".."]
+    else:
+        filter_entries.extend([b".", b".."])
+    try:
+        with fs.opendir(dirpath) as dir_handle:
+            d = fs.readdir(dir_handle)
+            while d:
+                if (d.d_name not in filter_entries) and d.is_dir():
+                    res = True
+                    break
+                d = fs.readdir(dir_handle)
+    except cephfs.Error as e:
+        raise VolumeException(-e.args[0], e.args[1])
+    return res
+
 def is_inherited_snap(snapname):
     """
     Returns True if the snapname is inherited else False