Lines Matching refs:work_queue
48 fixed_queue_t* work_queue;
76 ret->work_queue = fixed_queue_new(work_queue_capacity);
77 if (!ret->work_queue) goto error;
97 fixed_queue_free(ret->work_queue, osi_free);
114 fixed_queue_free(thread->work_queue, osi_free);
139 fixed_queue_enqueue(thread->work_queue, item);
216 int fd = fixed_queue_get_dequeue_fd(thread->work_queue);
217 void* context = thread->work_queue;
229 static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue));
230 while (item && count <= fixed_queue_capacity(thread->work_queue)) {
234 static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue));
238 if (count > fixed_queue_capacity(thread->work_queue))