Lines Matching refs:wq

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()