X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=rate-submit.c;h=92cb6222cd0512e00dea844b7762e7c0c7250390;hp=39b552d47927a40f4d910f249dabe5265bdd29fc;hb=2466096336bd0fbc1a94811aa338926af6baf42f;hpb=b38823202a5015e27cc4a683aa8d930764620443 diff --git a/rate-submit.c b/rate-submit.c index 39b552d4..92cb6222 100644 --- a/rate-submit.c +++ b/rate-submit.c @@ -7,6 +7,7 @@ #include "fio.h" #include "ioengine.h" #include "lib/getrusage.h" +#include "rate-submit.h" static int io_workqueue_fn(struct submit_worker *sw, struct workqueue_work *work) @@ -235,12 +236,12 @@ static struct workqueue_ops rated_wq_ops = { .exit_worker_fn = io_workqueue_exit_worker_fn, }; -int rate_submit_init(struct thread_data *td) +int rate_submit_init(struct thread_data *td, struct sk_out *sk_out) { if (td->o.io_submit_mode != IO_MODE_OFFLOAD) return 0; - return workqueue_init(td, &td->io_wq, &rated_wq_ops, td->o.iodepth); + return workqueue_init(td, &td->io_wq, &rated_wq_ops, td->o.iodepth, sk_out); } void rate_submit_exit(struct thread_data *td)