Lines Matching refs:queue
34 QueueHandle_t queue; member
72 wq->queue = xQueueCreate(capacity, sizeof(struct work_item)); in osi_work_queue_create()
73 if (wq->queue != 0) { in osi_work_queue_create()
87 if (wq->queue != 0) { in osi_work_queue_delete()
88 vQueueDelete(wq->queue); in osi_work_queue_delete()
90 wq->queue = 0; in osi_work_queue_delete()
100 assert (wq->queue != 0); in osi_thead_work_queue_get()
103 if (pdTRUE == xQueueReceive(wq->queue, item, 0)) { in osi_thead_work_queue_get()
113 assert (wq->queue != 0); 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()
133 assert (wq->queue != 0); in osi_thead_work_queue_len()
136 size_t available_spaces = (size_t)uxQueueSpacesAvailable(wq->queue); in osi_thead_work_queue_len()