X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=workqueue.c;h=841dbb9ffffa6de6252990592e7d750e876442b5;hp=1131400fd23a5acc8479c813fef0135c4987cf30;hb=b2ef2748a7c882fbac814f10d0f36630ac16ff89;hpb=c7334fa3f3be87854354044615b0c0e473c50713 diff --git a/workqueue.c b/workqueue.c index 1131400f..841dbb9f 100644 --- a/workqueue.c +++ b/workqueue.c @@ -10,6 +10,7 @@ #include "flist.h" #include "workqueue.h" #include "smalloc.h" +#include "pshared.h" enum { SW_F_IDLE = 1 << 0, @@ -109,9 +110,9 @@ void workqueue_enqueue(struct workqueue *wq, struct workqueue_work *work) flist_add_tail(&work->list, &sw->work_list); sw->seq = ++wq->work_seq; sw->flags &= ~SW_F_IDLE; - pthread_mutex_unlock(&sw->lock); pthread_cond_signal(&sw->cond); + pthread_mutex_unlock(&sw->lock); } static void handle_list(struct submit_worker *sw, struct flist_head *list)