Lines Matching refs:item
55 struct work_item item; member
97 static bool osi_thead_work_queue_get(struct work_queue *wq, struct work_item *item) in osi_thead_work_queue_get() argument
101 assert (item != NULL); in osi_thead_work_queue_get()
103 if (pdTRUE == xQueueReceive(wq->queue, item, 0)) { in osi_thead_work_queue_get()
110 static bool osi_thead_work_queue_put(struct work_queue *wq, const struct work_item *item, uint32_t … in osi_thead_work_queue_put() argument
114 assert (item != NULL); in osi_thead_work_queue_put()
118 if (xQueueSend(wq->queue, item, portMAX_DELAY) != pdTRUE) { in osi_thead_work_queue_put()
122 if (xQueueSend(wq->queue, item, timeout / portTICK_PERIOD_MS) != pdTRUE) { in osi_thead_work_queue_put()
162 struct work_item item; in osi_thread_run() local
164 if (osi_thead_work_queue_get(thread->work_queues[idx], &item) == true) { in osi_thread_run()
165 item.func(item.context); in osi_thread_run()
339 struct work_item item; in osi_thread_post() local
341 item.func = func; in osi_thread_post()
342 item.context = context; in osi_thread_post()
344 if (osi_thead_work_queue_put(thread->work_queues[queue_idx], &item, timeout) == false) { in osi_thread_post()
383 event->item.func = func; in osi_event_create()
384 event->item.context = context; in osi_event_create()
421 if (event != NULL && event->item.func != NULL) { in osi_thread_generic_event_handler()
425 event->item.func(event->item.context); in osi_thread_generic_event_handler()