12 static void tp_flush_work(struct flist_head *list)
16 while (!flist_empty(list)) {
17 work = flist_entry(list->next, struct tp_work, list);
18 flist_del(&work->list);
23 static void *tp_thread(void *data)
25 struct tp_data *tdat = data;
26 struct flist_head work_list;
28 INIT_FLIST_HEAD(&work_list);
30 printf("tp_thread running\n");
33 pthread_mutex_lock(&tdat->lock);
35 if (!tdat->thread_exit && flist_empty(&tdat->work))
36 pthread_cond_wait(&tdat->cv, &tdat->lock);
38 if (!flist_empty(&tdat->work)) {
39 flist_splice(&tdat->work, &work_list);
40 INIT_FLIST_HEAD(&tdat->work);
43 pthread_mutex_unlock(&tdat->lock);
45 if (flist_empty(&work_list)) {
46 if (tdat->thread_exit)
51 tp_flush_work(&work_list);
54 printf("outta here\n");
58 void tp_queue_work(struct tp_data *tdat, struct tp_work *work)
62 pthread_mutex_lock(&tdat->lock);
63 flist_add_tail(&work->list, &tdat->work);
64 pthread_cond_signal(&tdat->cv);
65 pthread_mutex_unlock(&tdat->lock);
68 void tp_init(struct tp_data **tdatp)
76 *tdatp = tdat = smalloc(sizeof(*tdat));
77 pthread_mutex_init(&tdat->lock, NULL);
78 INIT_FLIST_HEAD(&tdat->work);
79 pthread_cond_init(&tdat->cv, NULL);
80 pthread_cond_init(&tdat->sleep_cv, NULL);
82 ret = pthread_create(&tdat->thread, NULL, tp_thread, tdat);
84 log_err("fio: failed to create tp thread\n");
87 void tp_exit(struct tp_data **tdatp)
89 struct tp_data *tdat = *tdatp;
95 tdat->thread_exit = 1;
96 pthread_mutex_lock(&tdat->lock);
97 pthread_cond_signal(&tdat->cv);
98 pthread_mutex_unlock(&tdat->lock);
100 pthread_join(tdat->thread, &ret);