flist: add flist_first_entry()

[fio.git] / lib / tp.c

diff --git a/lib/tp.c b/lib/tp.c
index 25f7eb6dfc034c778a6766ac8265f14a47eca37c..5111910ec518f9d318f7b444d13eea462b5a98fc 100644 (file)
--- a/lib/tp.c
+++ b/lib/tp.c
@@ -33,10 +33,8 @@ static void *tp_thread(void *data)
                if (!tdat->thread_exit && flist_empty(&tdat->work))
                        pthread_cond_wait(&tdat->cv, &tdat->lock);
 
-               if (!flist_empty(&tdat->work)) {
-                       flist_splice(&tdat->work, &work_list);
-                       INIT_FLIST_HEAD(&tdat->work);
-               }
+               if (!flist_empty(&tdat->work))
+                       flist_splice_tail_init(&tdat->work, &work_list);
 
                pthread_mutex_unlock(&tdat->lock);