mds_thrash: requery mds status inside the wait loop

Signed-off-by: Sage Weil <sage@inktank.com>

diff --git a/teuthology/task/mds_thrash.py b/teuthology/task/mds_thrash.py
index d37651d4a2e2286bb92fe3b2344fdc5fc09559f8..c2fcd76e4f69628c21cc8dbc632a5d8d5b121092 100644 (file)
--- 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',