X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=workqueue.c;h=b59595124913338bc59dc20fb6a036c895b4f1f1;hb=ad46c5715ffc5d4e70d2e941225b1f504f23e409;hp=faed2452e91a341be207d73108e075e44dd274b6;hpb=0943e13c80b404e0c8a11ad21d7d8ca84ba5fd3e;p=fio.git diff --git a/workqueue.c b/workqueue.c index faed2452..b5959512 100644 --- a/workqueue.c +++ b/workqueue.c @@ -190,8 +190,6 @@ static void *worker_thread(void *data) if (wq->wake_idle) pthread_cond_signal(&wq->flush_cond); } - if (wq->ops.update_acct_fn) - wq->ops.update_acct_fn(sw); pthread_cond_wait(&sw->cond, &sw->lock); } else { @@ -200,11 +198,10 @@ handle_work: } pthread_mutex_unlock(&sw->lock); handle_list(sw, &local_list); + if (wq->ops.update_acct_fn) + wq->ops.update_acct_fn(sw); } - if (wq->ops.update_acct_fn) - wq->ops.update_acct_fn(sw); - done: sk_out_drop(); return NULL;