From: Rishabh Dave <ridave@redhat.com>
Date: Wed, 10 Aug 2022 16:53:10 +0000 (+0530)
Subject: qa/cephfs: add a method to check if CephFS mounts have hanged
X-Git-Tag: v18.0.0~119^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=b79853fbe9d69c72a3f64d3d899201149c8111e7;p=ceph.git

qa/cephfs: add a method to check if CephFS mounts have hanged

Signed-off-by: Rishabh Dave <ridave@redhat.com>
---

diff --git a/qa/tasks/cephfs/mount.py b/qa/tasks/cephfs/mount.py
index 065c0ff93789..89dbe5111208 100644
--- a/qa/tasks/cephfs/mount.py
+++ b/qa/tasks/cephfs/mount.py
@@ -168,6 +168,26 @@ class CephFSMount(object):
                      get_file(self.client_remote, self.client_keyring_path,
                               sudo=True).decode())
 
+    def is_stuck(self):
+        """
+        Check if mount is stuck/in a hanged state.
+        """
+        if not self.is_mounted():
+            return False
+
+        retval = self.client_remote.run(args=f'sudo stat {self.hostfs_mntpt}',
+                                        omit_sudo=False, wait=False).returncode
+        if retval == 0:
+            return False
+
+        time.sleep(10)
+        proc = self.client_remote.run(args='ps -ef', stdout=StringIO())
+        # if proc was running even after 10 seconds, it has to be stuck.
+        if f'stat {self.hostfs_mntpt}' in proc.stdout.getvalue():
+            log.critical('client mounted at self.hostfs_mntpt is stuck!')
+            return True
+        return False
+
     def is_mounted(self):
         return self.hostfs_mntpt in \
             self.client_remote.read_file('/proc/self/mounts',stdout=StringIO())