summaryrefslogtreecommitdiffstats
path: root/tests/functional/dht
diff options
context:
space:
mode:
authorSusant Palai <spalai@redhat.com>2018-06-18 21:50:13 +0530
committerAkarsha Rai <akrai@redhat.com>2018-06-29 13:34:11 +0000
commitd9b83821cf3b3126b7174846c48f10eca769cb68 (patch)
tree9484e31260c2a1851064c53d630df08f5e6ce173 /tests/functional/dht
parent0ccf077aea4f5527d6e3d0101d145642611f94c0 (diff)
glusto/dht: test lookup of directories
test: case -1: - bring down a subvol - create a directory so that it does not hash to down subvol - make sure stat is successful on the dir case -2: - create directory - bring down hashed subvol - make sure stat is successful on the dir case -3: - create dir - bringdown unhashed subvol - make sure stat is successful on the dir Change-Id: I9cbd2e7f04c885eaa09414d6b49632cf77dd72ec Signed-off-by: Susant Palai <spalai@redhat.com>
Diffstat (limited to 'tests/functional/dht')
-rw-r--r--tests/functional/dht/test_lookup_dir.py280
1 files changed, 280 insertions, 0 deletions
diff --git a/tests/functional/dht/test_lookup_dir.py b/tests/functional/dht/test_lookup_dir.py
new file mode 100644
index 0000000..861b91a
--- /dev/null
+++ b/tests/functional/dht/test_lookup_dir.py
@@ -0,0 +1,280 @@
+# Copyright (C) 2018-2019 Red Hat, Inc. <http://www.redhat.com>
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License along
+# with this program; if not, write to the Free Software Foundation, Inc.,
+# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+"""
+Description:
+ Test lookup directory with subvol down
+"""
+
+from glusto.core import Glusto as g
+
+from glustolibs.gluster.exceptions import ExecutionError
+from glustolibs.gluster.gluster_base_class import GlusterBaseClass, runs_on
+from glustolibs.gluster.brick_libs import (
+ bring_bricks_offline,
+ bring_bricks_online)
+from glustolibs.gluster.brickdir import BrickDir
+from glustolibs.gluster.volume_libs import get_subvols
+from glustolibs.gluster.constants import FILETYPE_DIRS
+from glustolibs.gluster.constants import \
+ TEST_LAYOUT_IS_COMPLETE as LAYOUT_IS_COMPLETE
+from glustolibs.gluster.dht_test_utils import validate_files_in_dir,\
+ find_hashed_subvol, find_nonhashed_subvol
+
+
+@runs_on([['distributed-replicated', 'distributed', 'distributed-dispersed'],
+ ['glusterfs', 'nfs', 'samba']])
+class TestLookupDir(GlusterBaseClass):
+ '''
+ test case: (directory lookup)
+ case -1:
+ - bring down a subvol
+ - create a directory so that it does not hash to down subvol
+ - make sure stat is successful on the dir
+
+ case -2:
+ - create directory
+ - bring down hashed subvol
+ - make sure stat is successful on the dir
+
+ case -3:
+ - create dir
+ - bringdown unhashed subvol
+ - make sure stat is successful on the dir
+ '''
+ # Create Volume and mount according to config file
+ def setUp(self):
+ """
+ Setup and mount volume or raise ExecutionError
+ """
+ GlusterBaseClass.setUp.im_func(self)
+
+ # Setup Volume
+ ret = self.setup_volume_and_mount_volume(self.mounts)
+ if not ret:
+ g.log.error("Failed to Setup and Mount Volume")
+ raise ExecutionError("Failed to Setup and Mount Volume")
+
+ def mkdir_post_hashdown(self, subvols, parent_dir):
+ '''
+ case -1:
+ - bring down a subvol
+ - create a directory so that it does not hash to down subvol
+ - make sure stat is successful on the dir
+ '''
+ # pylint: disable=protected-access
+ # pylint: disable=pointless-string-statement
+ # Find a non hashed subvolume(or brick)
+ nonhashed_subvol, count = find_nonhashed_subvol(subvols, "/", "parent")
+ if nonhashed_subvol is None:
+ g.log.error('Error in finding nonhashed subvol for parent')
+ return False
+
+ # bring nonhashed_subbvol offline
+ ret = bring_bricks_offline(self.volname, subvols[count])
+ if ret == 0:
+ g.log.error('Error in bringing down subvolume %s',
+ subvols[count])
+ return False
+
+ g.log.info('target subvol %s is offline', subvols[count])
+
+ # create parent dir
+ ret, _, err = g.run(self.clients[0], ("mkdir %s" % parent_dir))
+ if ret != 0:
+ g.log.error('mkdir failed for %s err: %s', parent_dir, err)
+ return False
+ g.log.info("mkdir of parent directory %s successful", parent_dir)
+
+ # this confirms both layout and stat of the directory
+ ret = validate_files_in_dir(self.clients[0],
+ self.mounts[0].mountpoint + '/parent_dir',
+ test_type=LAYOUT_IS_COMPLETE,
+ file_type=FILETYPE_DIRS)
+ self.assertTrue(ret, "Layout is not complete")
+ g.log.info('Layout is complete')
+
+ # bring up the subvol
+ ret = bring_bricks_online(self.mnode, self.volname, subvols[count],
+ bring_bricks_online_methods=None)
+ if ret == 0:
+ g.log.error("Error in bringing back subvol online")
+ return False
+
+ g.log.info('Subvol is back online')
+
+ # delete parent_dir
+ ret, _, err = g.run(self.clients[0], ("rmdir %s" % parent_dir))
+ if ret != 0:
+ g.log.error('rmdir failed for %s err: %s', parent_dir, err)
+ g.log.info("rmdir of directory %s successful", parent_dir)
+
+ return True
+
+ def mkdir_before_hashdown(self, subvols, parent_dir):
+ '''
+ case -2:
+ - create directory
+ - bring down hashed subvol
+ - make sure stat is successful on the dir
+ '''
+ # pylint: disable=protected-access
+ # pylint: disable=pointless-string-statement
+ # create parent dir
+ ret, _, err = g.run(self.clients[0], ("mkdir %s" % parent_dir))
+ if ret != 0:
+ g.log.error('mkdir failed for %s err: %s', parent_dir, err)
+ return False
+ g.log.info("mkdir of parent directory %s successful", parent_dir)
+
+ # find hashed subvol
+ hashed_subvol, count = find_hashed_subvol(subvols, "/", "parent")
+ if hashed_subvol is None:
+ g.log.error('Error in finding hash value')
+ return False
+
+ g.log.info("hashed subvol %s", hashed_subvol._host)
+
+ # bring hashed_subvol offline
+ ret = bring_bricks_offline(self.volname, subvols[count])
+ if ret == 0:
+ g.log.error('Error in bringing down subvolume %s', subvols[count])
+ return False
+ g.log.info('target subvol %s is offline', subvols[count])
+
+ # this confirms both layout and stat of the directory
+ ret = validate_files_in_dir(self.clients[0],
+ self.mounts[0].mountpoint + '/parent_dir',
+ test_type=LAYOUT_IS_COMPLETE,
+ file_type=FILETYPE_DIRS)
+ self.assertTrue(ret, "Layout is not complete")
+ g.log.info('Layout is complete')
+
+ # bring up the subvol
+ ret = bring_bricks_online(self.mnode, self.volname, subvols[count],
+ bring_bricks_online_methods=None)
+ if ret == 0:
+ g.log.error("Error in bringing back subvol online")
+ return False
+ g.log.info('Subvol is back online')
+
+ # delete parent_dir
+ ret, _, err = g.run(self.clients[0], ("rmdir %s" % parent_dir))
+ if ret == 0:
+ g.log.error('rmdir failed for %s err: %s', parent_dir, err)
+ g.log.info("rmdir of directory %s successful", parent_dir)
+ return True
+
+ def mkdir_nonhashed_down(self, subvols, parent_dir):
+ '''
+ case -3:
+ - create dir
+ - bringdown a non-hashed subvol
+ - make sure stat is successful on the dir
+ '''
+ # pylint: disable=protected-access
+ # pylint: disable=pointless-string-statement
+ # create parent dir
+ ret, _, err = g.run(self.clients[0], ("mkdir %s" % parent_dir))
+ if ret != 0:
+ g.log.error('mkdir failed for %s err: %s', parent_dir, err)
+ return False
+
+ g.log.info("mkdir of parent directory %s successful", parent_dir)
+
+ # Find a non hashed subvolume(or brick)
+ nonhashed_subvol, count = find_nonhashed_subvol(subvols, "/", "parent")
+ if nonhashed_subvol is None:
+ g.log.error('Error in finding hash value')
+ return False
+
+ # bring nonhashed_subbvol offline
+ ret = bring_bricks_offline(self.volname, subvols[count])
+ if ret == 0:
+ g.log.error('Error in bringing down subvolume %s', subvols[count])
+ return False
+ g.log.info('target subvol %s is offline', subvols[count])
+
+ # this confirms both layout and stat of the directory
+ ret = validate_files_in_dir(self.clients[0],
+ self.mounts[0].mountpoint + '/parent_dir',
+ test_type=LAYOUT_IS_COMPLETE,
+ file_type=FILETYPE_DIRS)
+ self.assertTrue(ret, "Expected - Layout is complete")
+ g.log.info('Layout is complete')
+
+ # bring up the subvol
+ ret = bring_bricks_online(self.mnode, self.volname, subvols[count],
+ bring_bricks_online_methods=None)
+ if ret == 0:
+ g.log.error("Error in bringing back subvol online")
+ return False
+ g.log.info('Subvol is back online')
+
+ # delete parent_dir
+ ret, _, err = g.run(self.clients[0], ("rmdir %s" % parent_dir))
+ if ret != 0:
+ g.log.error('rmdir failed for %s err: %s', parent_dir, err)
+ return False
+ g.log.info("rmdir of directory %s successful", parent_dir)
+ return True
+
+ def test_lookup_dir(self):
+ '''
+ Test directory lookup.
+ '''
+ # pylint: disable=too-many-locals
+ mount_obj = self.mounts[0]
+ mountpoint = mount_obj.mountpoint
+
+ # directory that needs to be created
+ parent_dir = mountpoint + '/parent'
+
+ # calculate hash for name "parent"
+ subvols = (get_subvols(self.mnode, self.volname))['volume_subvols']
+
+ # This populates one brick from one subvolume
+ secondary_bricks = []
+ for subvol in subvols:
+ secondary_bricks.append(subvol[0])
+
+ for subvol in secondary_bricks:
+ g.log.debug("secondary bricks %s", subvol)
+
+ brickobject = []
+ for item in secondary_bricks:
+ temp = BrickDir(item)
+ brickobject.append(temp)
+
+ ret = self.mkdir_post_hashdown(subvols, parent_dir)
+ self.assertTrue(ret, 'mkdir_post_hashdown failed')
+
+ ret = self.mkdir_before_hashdown(subvols, parent_dir)
+ self.assertTrue(ret, 'mkdir_before_hashdown failed')
+
+ ret = self.mkdir_nonhashed_down(subvols, parent_dir)
+ self.assertTrue(ret, 'mkdir_nonhashed_down failed')
+
+ @classmethod
+ def tearDownClass(cls):
+ # Unmount Volume and Cleanup Volume
+ g.log.info("Starting to Unmount Volume and Cleanup Volume")
+ ret = cls.unmount_volume_and_cleanup_volume(mounts=cls.mounts)
+ if not ret:
+ raise ExecutionError("Failed to Unmount Volume and Cleanup Volume")
+ g.log.info("Successful in Unmount Volume and Cleanup Volume")
+
+ # Calling GlusterBaseClass tearDown
+ GlusterBaseClass.tearDownClass.im_func(cls)