summaryrefslogtreecommitdiffstats
path: root/tests/functional/glusterd/test_volume_op.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/functional/glusterd/test_volume_op.py')
-rw-r--r--tests/functional/glusterd/test_volume_op.py148
1 files changed, 0 insertions, 148 deletions
diff --git a/tests/functional/glusterd/test_volume_op.py b/tests/functional/glusterd/test_volume_op.py
deleted file mode 100644
index 93851e011..000000000
--- a/tests/functional/glusterd/test_volume_op.py
+++ /dev/null
@@ -1,148 +0,0 @@
-# Copyright (C) 2016-2017 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.
-
-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.volume_ops import (volume_create, volume_start,
- volume_stop, volume_delete,
- get_volume_list, get_volume_info)
-from glustolibs.gluster.volume_libs import (setup_volume, cleanup_volume)
-from glustolibs.gluster.peer_ops import (peer_probe, peer_detach)
-from glustolibs.gluster.lib_utils import form_bricks_list
-
-
-@runs_on([['distributed', 'replicated', 'distributed-replicated', 'dispersed',
- 'distributed-dispersed'], ['glusterfs']])
-class TestVolumeOperations(GlusterBaseClass):
-
- @classmethod
- def setUpClass(cls):
-
- # Calling GlusterBaseClass setUpClass
- GlusterBaseClass.setUpClass.im_func(cls)
-
- # check whether peers are in connected state
- ret = cls.validate_peers_are_connected()
- if not ret:
- raise ExecutionError("Peers are not in connected state")
-
- def tearDown(self):
-
- vol_list = get_volume_list(self.mnode)
- if vol_list is None:
- raise ExecutionError("Failed to get the volume list")
-
- for volume in vol_list:
- ret = cleanup_volume(self.mnode, volume)
- if not ret:
- raise ExecutionError("Unable to delete volume % s" % volume)
- g.log.info("Volume deleted successfully : %s" % volume)
-
- GlusterBaseClass.tearDown.im_func(self)
-
- def test_volume_op(self):
-
- # Starting a non existing volume should fail
- ret, _, _ = volume_start(self.mnode, "no_vol", force=True)
- self.assertNotEqual(ret, 0, "Expected: It should fail to Start a non"
- " existing volume. Actual: Successfully started "
- "a non existing volume")
- g.log.info("Starting a non existing volume is failed")
-
- # Stopping a non existing volume should fail
- ret, _, _ = volume_stop(self.mnode, "no_vol", force=True)
- self.assertNotEqual(ret, 0, "Expected: It should fail to stop "
- "non-existing volume. Actual: Successfully "
- "stopped a non existing volume")
- g.log.info("Stopping a non existing volume is failed")
-
- # Deleting a non existing volume should fail
- ret = volume_delete(self.mnode, "no_vol")
- self.assertTrue(ret, "Expected: It should fail to delete a "
- "non existing volume. Actual:Successfully deleted "
- "a non existing volume")
- g.log.info("Deleting a non existing volume is failed")
-
- # Detach a server and try to create volume with node
- # which is not in cluster
- ret, _, _ = peer_detach(self.mnode, self.servers[1])
- self.assertEqual(ret, 0, ("Peer detach is failed"))
- g.log.info("Peer detach is successful")
-
- num_of_bricks = len(self.servers)
- bricks_list = form_bricks_list(self.mnode, self.volname, num_of_bricks,
- self.servers, self.all_servers_info)
-
- ret, _, _ = volume_create(self.mnode, self.volname, bricks_list)
- self.assertNotEqual(ret, 0, "Successfully created volume with brick "
- "from which is not a part of node")
- g.log.info("Creating a volume with brick from node which is not part "
- "of cluster is failed")
-
- # Peer probe the detached server
- ret, _, _ = peer_probe(self.mnode, self.servers[1])
- self.assertEqual(ret, 0, ("Peer probe is failed"))
- g.log.info("Peer probe is successful")
-
- # Create and start a volume
- ret = setup_volume(self.mnode, self.all_servers_info, self.volume,
- force=True)
- self.assertTrue(ret, "Failed to create the volume")
- g.log.info("Successfully created and started the volume")
-
- # Starting already started volume should fail
- ret, _, _ = volume_start(self.mnode, self.volname)
- self.assertNotEqual(ret, 0, "Expected: It should fail to start a "
- "already started volume. Actual:Successfully"
- " started a already started volume ")
- g.log.info("Starting a already started volume is Failed.")
-
- # Deleting a volume without stopping should fail
- ret = volume_delete(self.mnode, self.volname)
- self.assertFalse(ret, ("Expected: It should fail to delete a volume"
- " without stopping. Actual: Successfully "
- "deleted a volume without stopping it"))
- g.log.error("Failed to delete a volume without stopping it")
-
- # Stopping a volume should succeed
- ret, _, _ = volume_stop(self.mnode, self.volname)
- self.assertEqual(ret, 0, ("volume stop is failed"))
- g.log.info("Volume stop is success")
-
- # Stopping a already stopped volume should fail
- ret, _, _ = volume_stop(self.mnode, self.volname)
- self.assertNotEqual(ret, 0, "Expected: It should fail to stop a "
- "already stopped volume . Actual: Successfully"
- "stopped a already stopped volume")
- g.log.info("Volume stop is failed on already stopped volume")
-
- # Deleting a volume should succeed
- ret = volume_delete(self.mnode, self.volname)
- self.assertTrue(ret, ("Volume delete is failed"))
- g.log.info("Volume delete is success")
-
- # Deleting a non existing volume should fail
- ret = volume_delete(self.mnode, self.volname)
- self.assertTrue(ret, "Expected: It should fail to delete a non "
- "existing volume. Actual:Successfully deleted a "
- "non existing volume")
- g.log.info("Volume delete is failed for non existing volume")
-
- # Volume info command should succeed
- ret = get_volume_info(self.mnode)
- self.assertIsNotNone(ret, "volume info command failed")
- g.log.info("Volume info command is success")