Lines Matching refs:work_queues
43 …struct work_queue **work_queues; /*!< Point to queue array, and the priority inverse array in… member
164 if (osi_thead_work_queue_get(thread->work_queues[idx], &item) == true) { in osi_thread_run()
223 …thread->work_queues = (struct work_queue **)osi_calloc(sizeof(struct work_queue *) * work_queue_nu… in osi_thread_create()
224 if (thread->work_queues == NULL) { in osi_thread_create()
231 thread->work_queues[i] = osi_work_queue_create(queue_len); in osi_thread_create()
232 if (thread->work_queues[i] == NULL) { in osi_thread_create()
274 if (thread->work_queues && thread->work_queues[i]) { in osi_thread_create()
275 osi_work_queue_delete(thread->work_queues[i]); in osi_thread_create()
276 thread->work_queues[i] = NULL; in osi_thread_create()
280 if (thread->work_queues) { in osi_thread_create()
281 osi_free(thread->work_queues); in osi_thread_create()
282 thread->work_queues = NULL; in osi_thread_create()
307 if (thread->work_queues[i]) { in osi_thread_free()
308 osi_work_queue_delete(thread->work_queues[i]); in osi_thread_free()
309 thread->work_queues[i] = NULL; in osi_thread_free()
313 if (thread->work_queues) { in osi_thread_free()
314 osi_free(thread->work_queues); in osi_thread_free()
315 thread->work_queues = NULL; in osi_thread_free()
344 if (osi_thead_work_queue_put(thread->work_queues[queue_idx], &item, timeout) == false) { in osi_thread_post()
374 return (int)(osi_thead_work_queue_len(thread->work_queues[wq_idx])); in osi_thread_queue_wait_size()