Searched refs:work_queue (Results 1 – 1 of 1) sorted by relevance
44 fixed_queue_t *work_queue; member75 ret->work_queue = fixed_queue_new(work_queue_capacity); in thread_new_sized()76 if (!ret->work_queue) in thread_new_sized()99 fixed_queue_free(ret->work_queue, osi_free); in thread_new_sized()117 fixed_queue_free(thread->work_queue, osi_free); in thread_free()149 fixed_queue_enqueue(thread->work_queue, item); in thread_post()205 int fd = fixed_queue_get_dequeue_fd(thread->work_queue); in run_thread()206 void *context = thread->work_queue; in run_thread()216 work_item_t *item = fixed_queue_try_dequeue(thread->work_queue); in run_thread()217 while (item && count <= fixed_queue_capacity(thread->work_queue)) { in run_thread()[all …]