RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-19 08:57:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

qa: timeout waiting for thrashed MDS to revive

Browse Source 
Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
This commit is contained in:
Patrick Donnelly 2017-01-27 12:53:56 -05:00
parent 8e9ea7b6ac
commit 884215d933
No known key found for this signature in database
GPG Key ID: 3A2A7E25BEA8AADB
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
qa/tasks/mds_thrash.py
View File

@ -4,6 +4,7 @@ Thrash mds by simulating failures
import logging
import contextlib
import ceph_manager
import itertools
import random
import time
@ -172,8 +173,7 @@ class MDSThrasher(Greenlet):
def wait_for_stable(self, rank = None, gid = None):
self.log('waiting for mds cluster to stabilize...')
itercount = 0
while True:
for itercount in itertools.count():
status = self.fs.status()
max_mds = status.get_fsmap(self.fs.id)['mdsmap']['max_mds']
ranks = list(status.get_ranks(self.fs.id))
@ -203,7 +203,6 @@ class MDSThrasher(Greenlet):
raise RuntimeError('timeout waiting for cluster to stabilize')
elif itercount % 5 == 0:
self.log('mds map: {status}'.format(status=self.fs.status()))
itercount = itercount + 1
time.sleep(2)
def do_thrash(self):
@ -318,7 +317,9 @@ class MDSThrasher(Greenlet):
self.log('reviving {label}'.format(label=label))
self.revive_mds(name)
while True:
for itercount in itertools.count():
if itercount > 300/2: # 5 minutes
raise RuntimeError('timeout waiting for MDS to revive')
status = self.fs.status()
info = status.get_mds(name)
if info and info['state'] in ('up:standby', 'up:standby-replay'):