From d9a233c9bc58bead6fa54f26ef556d10dad1685f Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Sat, 9 Mar 2013 22:17:15 -0800 Subject: [PATCH] mds_thrash: requery mds status inside the wait loop Signed-off-by: Sage Weil --- teuthology/task/mds_thrash.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/teuthology/task/mds_thrash.py b/teuthology/task/mds_thrash.py index d37651d4a2e22..c2fcd76e4f696 100644 --- a/teuthology/task/mds_thrash.py +++ b/teuthology/task/mds_thrash.py @@ -246,12 +246,14 @@ def task(ctx, config): first, ctx=ctx, logger=log.getChild('ceph_manager'), ) - statuses = {m : manager.get_mds_status(m) for m in mdslist} - statuses_by_rank = {s['rank'] : s for (_,s) in statuses.iteritems()} - - log.info('Wait for all MDSs to reach steady state...') # make sure everyone is in active, standby, or standby-replay + log.info('Wait for all MDSs to reach steady state...') + statuses = None + statuses_by_rank = None while True: + statuses = {m : manager.get_mds_status(m) for m in mdslist} + statuses_by_rank = {s['rank'] : s for (_,s) in statuses.iteritems()} + ready = filter(lambda (_,s): s['state'] == 'up:active' or s['state'] == 'up:standby' or s['state'] == 'up:standby-replay', -- 2.39.5