From: Zhi Zhang <willzzhang@tencent.com>
Date: Thu, 15 Nov 2018 03:31:26 +0000 (+0800)
Subject: qa: add test for getfattr ceph.dir.pin
X-Git-Tag: v14.1.0~686^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=36f85fd3bb3684355682262e5e942ca5d70223ef;p=ceph.git

qa: add test for getfattr ceph.dir.pin

Signed-off-by: Zhi Zhang <zhangz.david@outlook.com>
---

diff --git a/qa/tasks/cephfs/test_exports.py b/qa/tasks/cephfs/test_exports.py
index 692403d3ac21..b0cb0461a315 100644
--- a/qa/tasks/cephfs/test_exports.py
+++ b/qa/tasks/cephfs/test_exports.py
@@ -103,9 +103,22 @@ class TestExports(CephFSTestCase):
         self.mount_a.run_shell(["mkdir", "-p", "a/b", "aa/bb"])
         self.mount_a.setfattr("a", "ceph.dir.pin", "1")
         self.mount_a.setfattr("aa/bb", "ceph.dir.pin", "0")
-        self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/1/2/3', 2), ('/a', 1), ('/aa/bb', 0)])
+        if (len(self.fs.get_active_names()) > 2):
+            self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/1/2/3', 2), ('/a', 1), ('/aa/bb', 0)])
+        else:
+            self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/a', 1), ('/aa/bb', 0)])
         self.mount_a.run_shell(["mv", "aa", "a/b/"])
-        self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/1/2/3', 2), ('/a', 1), ('/a/b/aa/bb', 0)])
+        if (len(self.fs.get_active_names()) > 2):
+            self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/1/2/3', 2), ('/a', 1), ('/a/b/aa/bb', 0)])
+        else:
+            self._wait_subtrees(status, 0, [('/1', 0), ('/1/4/5', 1), ('/a', 1), ('/a/b/aa/bb', 0)])
+
+        # Test getfattr
+        self.assertTrue(self.mount_a.getfattr("1", "ceph.dir.pin") == "0")
+        self.assertTrue(self.mount_a.getfattr("1/4", "ceph.dir.pin") == "-1")
+        self.assertTrue(self.mount_a.getfattr("1/4/5", "ceph.dir.pin") == "1")
+        if (len(self.fs.get_active_names()) > 2):
+            self.assertTrue(self.mount_a.getfattr("1/2/3", "ceph.dir.pin") == "2")
 
     def test_session_race(self):
         """