workqueue/rate-submit: update comments

[fio.git] / rate-submit.c

diff --git a/rate-submit.c b/rate-submit.c
index a68a3dd3a7b26bf1e4a03c03e3583c28ebfc6faa..3d35815212f5e1ca67b1b79990d78abf90579241 100644 (file)
--- a/rate-submit.c
+++ b/rate-submit.c
@@ -1,9 +1,15 @@
+/*
+ * Rated submission helpers
+ *
+ * Copyright (C) 2015 Jens Axboe <axboe@kernel.dk>
+ *
+ */

 #include "fio.h"
 #include "ioengine.h"
 #include "lib/getrusage.h"
 
 #include "fio.h"
 #include "ioengine.h"
 #include "lib/getrusage.h"
 

-static void io_workqueue_fn(struct submit_worker *sw,
-                           struct workqueue_work *work)
+static int io_workqueue_fn(struct submit_worker *sw,
+                          struct workqueue_work *work)

 {
        struct io_u *io_u = container_of(work, struct io_u, work);
        const enum fio_ddir ddir = io_u->ddir;
 {
        struct io_u *io_u = container_of(work, struct io_u, work);
        const enum fio_ddir ddir = io_u->ddir;


@@ -48,6 +54,8 @@ static void io_workqueue_fn(struct submit_worker *sw,
                if (ret > 0)
                        td->cur_depth -= ret;
        }
                if (ret > 0)
                        td->cur_depth -= ret;
        }

+
+       return 0;

 }
 
 static bool io_workqueue_pre_sleep_flush_fn(struct submit_worker *sw)
 }
 
 static bool io_workqueue_pre_sleep_flush_fn(struct submit_worker *sw)