X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=workqueue.h;h=26b3aee1602171e9b090363c275003a53b13791a;hp=3a24f254d650fc66d7833bba79e883e2e33fedf7;hb=882718418309228b28146dc03d43c9253c7cfb35;hpb=b07f6ad1ff4a22c12f9de2592ee35607bf45105f diff --git a/workqueue.h b/workqueue.h index 3a24f254..26b3aee1 100644 --- a/workqueue.h +++ b/workqueue.h @@ -3,7 +3,11 @@ #include "flist.h" -typedef void (workqueue_fn)(struct thread_data *, struct io_u *); +struct workqueue_work { + struct flist_head list; +}; + +typedef void (workqueue_fn)(struct thread_data *, struct workqueue_work *); struct workqueue { unsigned int max_workers; @@ -24,7 +28,7 @@ struct workqueue { int workqueue_init(struct thread_data *td, struct workqueue *wq, workqueue_fn *fn, unsigned int max_workers); void workqueue_exit(struct workqueue *wq); -bool workqueue_enqueue(struct workqueue *wq, struct io_u *io_u); +bool workqueue_enqueue(struct workqueue *wq, struct workqueue_work *work); void workqueue_flush(struct workqueue *wq); #endif