os/bluestore/KernelDevice: make the amount of reaped aio tunable

Signed-off-by: Haodong Tang <haodong.tang@intel.com>

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index 73ea6b30dcdc4bcd0d0b675d65781a09cb39436a..6aa697e3c6d3793394750f3bf3df79d225d46246 100644 (file)
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -1053,6 +1053,7 @@ OPTION(bdev_inject_crash_flush_delay, OPT_INT, 2) // wait N more seconds on flus
 OPTION(bdev_aio, OPT_BOOL, true)
 OPTION(bdev_aio_poll_ms, OPT_INT, 250)  // milliseconds
 OPTION(bdev_aio_max_queue_depth, OPT_INT, 1024)
+OPTION(bdev_aio_reap_max, OPT_INT, 16)
 OPTION(bdev_block_size, OPT_INT, 4096)
 OPTION(bdev_debug_aio, OPT_BOOL, false)
 OPTION(bdev_debug_aio_suicide_timeout, OPT_FLOAT, 60.0)

diff --git a/src/os/bluestore/KernelDevice.cc b/src/os/bluestore/KernelDevice.cc
index 032e2136253314414c4ec42f9a925ed92377d81c..2de595ea0728bdf4567f137b56e72ef8c42dfca0 100644 (file)
--- a/src/os/bluestore/KernelDevice.cc
+++ b/src/os/bluestore/KernelDevice.cc
@@ -340,7 +340,7 @@ void KernelDevice::_aio_thread()
   int inject_crash_count = 0;
   while (!aio_stop) {
     dout(40) << __func__ << " polling" << dendl;
-    int max = 16;
+    int max = cct->_conf->bdev_aio_reap_max;
     aio_t *aio[max];
     int r = aio_queue.get_next_completed(cct->_conf->bdev_aio_poll_ms,
                                         aio, max);