From: Jos Collin <jcollin@redhat.com>
Date: Fri, 7 Jun 2019 11:55:54 +0000 (+0530)
Subject: qa/tasks: manage thrashers
X-Git-Tag: v15.1.0~1819^2~2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=3f13a355c7ea3b8ae64a866317739145236caf21;p=ceph.git

qa/tasks: manage thrashers

* Added daemons to thrashers
* Join the mds thrasher, as the other thrashers did

Fixes: http://tracker.ceph.com/issues/10369
Signed-off-by: Jos Collin <jcollin@redhat.com>
---

diff --git a/qa/tasks/mds_thrash.py b/qa/tasks/mds_thrash.py
index a4ef8d9850534..0547533897282 100644
--- a/qa/tasks/mds_thrash.py
+++ b/qa/tasks/mds_thrash.py
@@ -423,10 +423,9 @@ def task(ctx, config):
         log.debug('Yielding')
         yield
     finally:
-        log.info('joining mds_thrashers')
-        for thrasher in ctx.ceph[config['cluster']].thrashers:
-            thrasher.stop()
-            if thrasher.e:
-                raise RuntimeError('error during thrashing')
-            thrasher.join()
+        log.info('joining mds_thrasher')
+        thrasher.stop()
+        if thrasher.e:
+            raise RuntimeError('error during thrashing')
+        thrasher.join()
         log.info('done joining')
diff --git a/qa/tasks/mon_thrash.py b/qa/tasks/mon_thrash.py
index dc1866a2c6adb..b4023a978736f 100644
--- a/qa/tasks/mon_thrash.py
+++ b/qa/tasks/mon_thrash.py
@@ -356,6 +356,10 @@ def task(ctx, config):
         'mon_thrash task only accepts a dict for configuration'
     assert len(_get_mons(ctx)) > 2, \
         'mon_thrash task requires at least 3 monitors'
+
+    if 'cluster' not in config:
+        config['cluster'] = 'ceph'
+
     log.info('Beginning mon_thrash...')
     first_mon = teuthology.get_first_mon(ctx, config)
     (mon,) = ctx.cluster.only(first_mon).remotes.iterkeys()
@@ -367,6 +371,7 @@ def task(ctx, config):
     thrash_proc = MonitorThrasher(ctx,
         manager, config,
         logger=log.getChild('mon_thrasher'))
+    ctx.ceph[config['cluster']].thrashers.append(thrash_proc)
     try:
         log.debug('Yielding')
         yield
diff --git a/qa/tasks/rbd_mirror_thrash.py b/qa/tasks/rbd_mirror_thrash.py
index 081b353d92bdc..75e1cdab638e1 100644
--- a/qa/tasks/rbd_mirror_thrash.py
+++ b/qa/tasks/rbd_mirror_thrash.py
@@ -203,6 +203,7 @@ def task(ctx, config):
 
     thrasher = RBDMirrorThrasher(ctx, config, cluster, daemons)
     thrasher.start()
+    ctx.ceph[cluster].thrashers.append(thrasher)
 
     try:
         log.debug('Yielding')
diff --git a/qa/tasks/thrashosds.py b/qa/tasks/thrashosds.py
index 4f8ed5b608c7a..aa8d9c370249d 100644
--- a/qa/tasks/thrashosds.py
+++ b/qa/tasks/thrashosds.py
@@ -205,6 +205,7 @@ def task(ctx, config):
         config,
         logger=log.getChild('thrasher')
         )
+    ctx.ceph[cluster].thrashers.append(thrash_proc)
     try:
         yield
     finally: