70     struct work_queue *wq = (struct work_queue *)osi_malloc(sizeof(struct work_queue));  in osi_work_queue_create()  local
71     if (wq != NULL) {  in osi_work_queue_create()
72         wq->queue = xQueueCreate(capacity, sizeof(struct work_item));  in osi_work_queue_create()
73         if (wq->queue != 0) {  in osi_work_queue_create()
74             wq->capacity = capacity;  in osi_work_queue_create()
75             return wq;  in osi_work_queue_create()
77             osi_free(wq);  in osi_work_queue_create()
84 static void osi_work_queue_delete(struct work_queue *wq)  in osi_work_queue_delete()  argument
86     if (wq != NULL) {  in osi_work_queue_delete()
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()
91         wq->capacity = 0;  in osi_work_queue_delete()
92         osi_free(wq);  in osi_work_queue_delete()
97 static bool osi_thead_work_queue_get(struct work_queue *wq, struct work_item *item)  in osi_thead_work_queue_get()  argument
99     assert (wq != NULL);  in osi_thead_work_queue_get()
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()
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
112     assert (wq != NULL);  in osi_thead_work_queue_put()
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()
130 static size_t osi_thead_work_queue_len(struct work_queue *wq)  in osi_thead_work_queue_len()  argument
132     assert (wq != NULL);  in osi_thead_work_queue_len()
133     assert (wq->queue != 0);  in osi_thead_work_queue_len()
134     assert (wq->capacity != 0);  in osi_thead_work_queue_len()
136     size_t available_spaces = (size_t)uxQueueSpacesAvailable(wq->queue);  in osi_thead_work_queue_len()
138     if (available_spaces <= wq->capacity) {  in osi_thead_work_queue_len()
139         return wq->capacity - available_spaces;  in osi_thead_work_queue_len()