diff options
author | Valerii Ponomarov <vponomar@redhat.com> | 2019-12-13 21:19:07 +0530 |
---|---|---|
committer | Bala Konda Reddy M <bmekala@redhat.com> | 2019-12-18 10:55:39 +0000 |
commit | 6a17654e9be3d5fbae9fa25249a7e2c8d892df3a (patch) | |
tree | 8812776ebfbb0ec17cbc481fd8a3b2c62aecc644 /tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py | |
parent | 902dc78766d0938f0e40c71c25a4ce2bb10b005d (diff) |
[py2to3] Add py3 support in 'tests/functional/glusterd'. Part 2
Change-Id: I1395e14d8d0aa0cc6097e51c64262fb481f36f05
Signed-off-by: Valerii Ponomarov <kiparis.kh@gmail.com>
Diffstat (limited to 'tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py')
-rw-r--r-- | tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py b/tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py index c65b92fa4..3f8248be4 100644 --- a/tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py +++ b/tests/functional/glusterd/test_self_heal_quota_daemon_after_reboot.py @@ -32,7 +32,7 @@ from glustolibs.gluster.gluster_init import is_glusterd_running @runs_on([['replicated', 'distributed-replicated'], ['glusterfs']]) class TestSelfHealDeamonQuotaDeamonAfterReboot(GlusterBaseClass): def setUp(self): - GlusterBaseClass.setUpClass.im_func(self) + self.get_super_method(self, 'setUp')() # checking for peer status from every node ret = self.validate_peers_are_connected() @@ -69,12 +69,10 @@ class TestSelfHealDeamonQuotaDeamonAfterReboot(GlusterBaseClass): # Getting self-heal daemon and quota daemon pids of every host from # gluster volume status for server in self.servers: - shd_pid = \ - (vol_status[self.volname][server]['Self-heal Daemon']['pid']) - quota_pid = \ - (vol_status[self.volname][server]['Quota Daemon']['pid']) - vol_status_quotad_pid_list.append(quota_pid) - vol_status_shd_pid_list.append(shd_pid) + vol_status_quotad_pid_list.append( + vol_status[self.volname][server]['Quota Daemon']['pid']) + vol_status_shd_pid_list.append( + vol_status[self.volname][server]['Self-heal Daemon']['pid']) g.log.info("shd list from get volume status: %s", vol_status_shd_pid_list) @@ -87,13 +85,20 @@ class TestSelfHealDeamonQuotaDeamonAfterReboot(GlusterBaseClass): # Finding and Storing all hosts self heal daemon # in to sh_daemon_list, all # host quota daemon into quotad_list list using ps command - for host in self.servers: - ret, out, _ = g.run(host, "ps -eaf | grep glustershd | " - "grep -v grep | awk '{ print $2 }'") - sh_daemon_list.append(out.strip()) - ret, out, _ = g.run(host, "ps -eaf | grep quotad | grep -v grep |" - " awk '{ print $2 }'") - quotad_list.append(out.strip()) + for daemon_name, daemon_list in (('glustershd', sh_daemon_list), + ('quotad', quotad_list)): + for host in self.servers: + cmd = "ps -eaf |grep %s |grep -v grep | awk '{ print $2 }'" % ( + daemon_name) + ret, out, err = g.run(host, cmd) + err_msg = ( + "Failed to find '%s' daemon on the '%s' host using " + "'ps -eaf' command.\nret: %s\nout: %s\nerr: %s" % ( + daemon_name, host, ret, out, err) + ) + self.assertEqual(ret, 0, err_msg) + daemon_list.append(out.strip()) + g.log.info("shd list :%s", sh_daemon_list) g.log.info("quotad list :%s", quotad_list) @@ -102,14 +107,9 @@ class TestSelfHealDeamonQuotaDeamonAfterReboot(GlusterBaseClass): # Here comparing the list of daemons got from ps command and # list of daemons got from vol status command, # all daemons should match from both the list - ret = cmp(sorted(sh_daemon_list + quotad_list), - sorted(vol_status_shd_pid_list + vol_status_quotad_pid_list)) - if ret == 0: - ps_daemon_len = len(sh_daemon_list + quotad_list) - vol_status_daemon_len = len((vol_status_shd_pid_list + - vol_status_quotad_pid_list)) - return bool(ps_daemon_len == len(self.servers) * 2 | - vol_status_daemon_len == len(self.servers) * 2) + if sorted(sh_daemon_list + quotad_list) == sorted( + vol_status_shd_pid_list + vol_status_quotad_pid_list): + return len(sh_daemon_list + quotad_list) == len(self.servers) * 2 return False |