summaryrefslogtreecommitdiffstats
path: root/tests/functional/arbiter/test_metadata_self_heal.py
diff options
context:
space:
mode:
authorSri Vignesh <sselvan@redhat.com>2019-12-30 12:47:25 +0530
committerBala Konda Reddy M <bala12352@gmail.com>2020-02-18 07:25:58 +0000
commit47bfa358b326c56854e4868084a000d17d0e6780 (patch)
tree19d57fca2b6b1106a71d5640bf87950e7cb9e348 /tests/functional/arbiter/test_metadata_self_heal.py
parent30a22e8c81692dd6f49e984f64d7dae0358e61a2 (diff)
[testfix] Add steps to stabilize the existing content in Arbiter
Change-Id: I2ba0c81dad41bdac704007bd1780b8a98cb50358 Signed-off-by: Sri Vignesh <sselvan@redhat.com>
Diffstat (limited to 'tests/functional/arbiter/test_metadata_self_heal.py')
-rwxr-xr-xtests/functional/arbiter/test_metadata_self_heal.py11
1 files changed, 6 insertions, 5 deletions
diff --git a/tests/functional/arbiter/test_metadata_self_heal.py b/tests/functional/arbiter/test_metadata_self_heal.py
index ba359da7e..56afaf95e 100755
--- a/tests/functional/arbiter/test_metadata_self_heal.py
+++ b/tests/functional/arbiter/test_metadata_self_heal.py
@@ -1,4 +1,4 @@
-# Copyright (C) 2015-2018 Red Hat, Inc. <http://www.redhat.com>
+# Copyright (C) 2015-2020 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
@@ -32,7 +32,8 @@ from glustolibs.gluster.heal_libs import (monitor_heal_completion,
is_shd_daemonized)
from glustolibs.gluster.heal_ops import trigger_heal
from glustolibs.misc.misc_libs import upload_scripts
-from glustolibs.io.utils import (collect_mounts_arequal, validate_io_procs)
+from glustolibs.io.utils import (collect_mounts_arequal,
+ wait_for_io_to_complete)
@runs_on([['replicated', 'distributed-replicated'],
@@ -201,10 +202,10 @@ class TestMetadataSelfHeal(GlusterBaseClass):
user=self.mounts[0].user)
all_mounts_procs.append(proc)
- # Validate IO
+ # wait for io to complete
self.assertTrue(
- validate_io_procs(all_mounts_procs, self.mounts),
- "IO failed on some of the clients")
+ wait_for_io_to_complete(all_mounts_procs, self.mounts),
+ "Io failed to complete on some of the clients")
# Setting options
g.log.info('Setting options...')