rate-submit: clean up init/exit helpers

[fio.git] / backend.c

diff --git a/backend.c b/backend.c
index d39968519fe3680a8ab0fe87716087eb61ad1d6e..ae2612036124b700c7959251090389fd84d618ed 100644 (file)
--- a/backend.c
+++ b/backend.c
@@ -1555,8 +1555,7 @@ static void *thread_main(void *data)
 
        fio_verify_init(td);
 
-       if ((o->io_submit_mode == IO_MODE_OFFLOAD) &&
-           workqueue_init(td, &td->io_wq, &rated_wq_ops, td->o.iodepth))
+       if (rate_submit_init(td))
                goto err;
 
        fio_gettime(&td->epoch, NULL);
@@ -1654,10 +1653,8 @@ static void *thread_main(void *data)
 
        fio_writeout_logs(td);
 
-       if (o->io_submit_mode == IO_MODE_OFFLOAD)
-               workqueue_exit(&td->io_wq);
-
        iolog_compress_exit(td);
+       rate_submit_exit(td);
 
        if (o->exec_postrun)
                exec_string(o, o->exec_postrun, (const char *)"postrun");