From ce7fa1839f4b3e3db675b2d68a2bb57849f58c1e Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Fri, 2 May 2014 16:32:53 -0700 Subject: [PATCH] ceph_manager: randomly reweight in osds Signed-off-by: Sage Weil --- teuthology/task/ceph_manager.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/teuthology/task/ceph_manager.py b/teuthology/task/ceph_manager.py index 2778358e5f..7ed01d070d 100644 --- a/teuthology/task/ceph_manager.py +++ b/teuthology/task/ceph_manager.py @@ -123,6 +123,17 @@ class Thrasher: self.ceph_manager.mark_in_osd(osd) self.log("Added osd %s"%(str(osd),)) + def reweight_osd(self, osd=None): + """ + Reweight an osd that is in + :param osd: Osd to be marked. + """ + if osd is None: + osd = random.choice(self.in_osds) + val = random.uniform(.1, 1.0) + self.log("Reweighting osd %s to %f" % (str(osd), val)) + self.raw_cluster_cmd('osd', 'reweight', str(osd), val) + def primary_affinity(self, osd=None): if osd is None: osd = random.choice(self.in_osds) @@ -320,6 +331,7 @@ class Thrasher: actions.append((self.revive_osd, 1.0,)) if self.config.get('thrash_primary_affinity', True): actions.append((self.primary_affinity, 1.0,)) + actions.append((self.reweight_osd, self.config.get('reweight_osd',.5),)) actions.append((self.grow_pool, self.config.get('chance_pgnum_grow', 0),)) actions.append((self.fix_pgp_num, self.config.get('chance_pgpnum_fix', 0),)) actions.append((self.test_pool_min_size, chance_test_min_size,)) -- 2.39.5