mgmt: support "server aio_threads = <digit>"

This allows tunable thread counts at runtime like regular
mogstored (using Perlbal).

1 files changed, 22 insertions, 0 deletions

diff --git a/mgmt_fn.c b/mgmt_fn.c
index db0c4f7..b2e2939 100644
--- a/mgmt_fn.c
+++ b/mgmt_fn.c
@@ -178,3 +178,25 @@ void mog_mgmt_fn_watch_err(struct mog_mgmt *mgmt)
         IOV_STR(&iov, "ERR iostat unavailable\r\n");
         mog_mgmt_writev(mgmt, &iov, 1);
 }
+
+void mog_mgmt_fn_aio_threads(struct mog_mgmt *mgmt, char *buf)
+{
+        char *end;
+        unsigned long long nr;
+        struct mog_queue *q = mgmt->svc->queue;
+        char *nptr = buf + mgmt->mark[0];
+        char *eor = nptr + mgmt->mark[1] - mgmt->mark[0];
+        struct iovec iov;
+
+        assert((*eor == '\n' || *eor == '\r') && "missing end-of-record");
+        *eor = 0;
+
+        nr = strtoull(nptr, &end, 10);
+        assert(*end == 0 && "ragel misfed mog_mgmt_fn_set_aio_threads");
+
+        if (nr > 0 && nr <= 100)
+                mog_thrpool_set_n_threads(q, nr);
+
+        IOV_STR(&iov, "\r\n");
+        mog_mgmt_writev(mgmt, &iov, 1);
+}