import 15.2.2 octopus source

[ceph.git] / ceph / qa / tasks / radosbench.py

diff --git a/ceph/qa/tasks/radosbench.py b/ceph/qa/tasks/radosbench.py
index f840e646dd65ccedfb7f26617abfbde1a443e898..90b21a5d88b26620c7d35b917d1d85be81288944 100644 (file)
--- a/ceph/qa/tasks/radosbench.py
+++ b/ceph/qa/tasks/radosbench.py
@@ -23,6 +23,7 @@ def task(ctx, config):
         time: <seconds to run>
         pool: <pool to use>
         size: write size to use
+        concurrency: max number of outstanding writes (16)
         objectsize: object size to use
         unique_pool: use a unique pool, defaults to False
         ec_pool: create an ec pool, defaults to False
@@ -83,6 +84,7 @@ def task(ctx, config):
                 pool = manager.create_pool_with_unique_name(erasure_code_profile_name=profile_name)
 
         size = config.get('size', 65536)
+        concurrency = config.get('concurrency', 16)
         osize = config.get('objectsize', 65536)
         sizeargs = ['-b', str(size)]
         if osize != 0 and osize != size:
@@ -102,6 +104,7 @@ def task(ctx, config):
                               '--no-log-to-stderr',
                               '--name', role]
                               + sizeargs +
+                              ['-t', str(concurrency)] +
                               ['-p' , pool,
                           'bench', str(60), "write", "--no-cleanup"
                           ]).format(tdir=testdir),