diff options
author | kshithijiyer <kshithij.ki@gmail.com> | 2019-03-25 18:43:24 +0530 |
---|---|---|
committer | Kshithij Iyer <kiyer@redhat.com> | 2019-03-29 09:54:15 +0000 |
commit | d9eccbb0c1faf713d8149a07502805ba1a37eecf (patch) | |
tree | b787affcd1058b43c8971bbe953ad2e9d9139feb /tests/functional/glusterd/test_rebalance_spurious.py | |
parent | 13227d34d0f9a9b996c7aaf07f486beffcbda391 (diff) |
Adding code to check if peers are connected in test_spurious_rebalance
Change-Id: I4a1097fbdebd49555fffcfa5fe609f4070e39182
Signed-off-by: kshithijiyer <kshithij.ki@gmail.com>
Diffstat (limited to 'tests/functional/glusterd/test_rebalance_spurious.py')
-rw-r--r-- | tests/functional/glusterd/test_rebalance_spurious.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/tests/functional/glusterd/test_rebalance_spurious.py b/tests/functional/glusterd/test_rebalance_spurious.py index ad16a0039..c9dbed035 100644 --- a/tests/functional/glusterd/test_rebalance_spurious.py +++ b/tests/functional/glusterd/test_rebalance_spurious.py @@ -14,6 +14,7 @@ # with this program; if not, write to the Free Software Foundation, Inc., # 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. +from time import sleep from glusto.core import Glusto as g from glustolibs.gluster.gluster_base_class import GlusterBaseClass, runs_on from glustolibs.gluster.volume_ops import (volume_create, volume_start, @@ -22,7 +23,8 @@ from glustolibs.gluster.brick_libs import get_all_bricks from glustolibs.gluster.volume_libs import (cleanup_volume) from glustolibs.gluster.peer_ops import (peer_probe, peer_detach, peer_probe_servers, - nodes_from_pool_list) + nodes_from_pool_list, + is_peer_connected) from glustolibs.gluster.lib_utils import form_bricks_list from glustolibs.gluster.brick_ops import remove_brick from glustolibs.gluster.exceptions import ExecutionError @@ -104,6 +106,16 @@ class TestSpuriousRebalance(GlusterBaseClass): self.servers[0], self.servers[index])) g.log.info("peer probe is success from %s to " "%s", self.servers[0], self.servers[index]) + # Checking if peer is connected + counter = 0 + while counter < 30: + ret = is_peer_connected(self.mnode, self.servers[:3]) + counter += 1 + if ret: + break + sleep(3) + self.assertTrue(ret, "Peer is not in connected state.") + g.log.info("Peers is in connected state.") self.volname = "testvol" bricks_list = form_bricks_list(self.mnode, self.volname, 3, |