Lines Matching refs:pqueue
34 static void tqueue_append(struct k_queue *pqueue) in tqueue_append() argument
36 k_queue_insert(pqueue, k_queue_peek_tail(pqueue), in tqueue_append()
41 k_queue_append(pqueue, (void *)&data[i]); in tqueue_append()
46 k_queue_prepend(pqueue, (void *)&data_p[i]); in tqueue_append()
54 k_queue_append_list(pqueue, (uint32_t *)head, (uint32_t *)tail); in tqueue_append()
62 k_queue_merge_slist(pqueue, &slist); in tqueue_append()
65 static void tqueue_get(struct k_queue *pqueue) in tqueue_get() argument
72 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
78 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
83 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
88 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
110 static void tqueue_thread_thread(struct k_queue *pqueue) in tqueue_thread_thread() argument
115 tThread_entry, pqueue, NULL, NULL, in tqueue_thread_thread()
117 tqueue_append(pqueue); in tqueue_thread_thread()
122 static void tqueue_thread_isr(struct k_queue *pqueue) in tqueue_thread_isr() argument
126 irq_offload(tIsr_entry_append, (const void *)pqueue); in tqueue_thread_isr()
127 tqueue_get(pqueue); in tqueue_thread_isr()
130 static void tqueue_isr_thread(struct k_queue *pqueue) in tqueue_isr_thread() argument
134 tqueue_append(pqueue); in tqueue_isr_thread()
135 irq_offload(tIsr_entry_get, (const void *)pqueue); in tqueue_isr_thread()
217 static void tqueue_get_2threads(struct k_queue *pqueue) in tqueue_get_2threads() argument
221 tThread_get, pqueue, NULL, NULL, in tqueue_get_2threads()
225 tThread_get, pqueue, NULL, NULL, in tqueue_get_2threads()
231 k_queue_append(pqueue, (void *)&data[0]); in tqueue_get_2threads()
232 k_queue_append(pqueue, (void *)&data[1]); in tqueue_get_2threads()
255 static void tqueue_alloc(struct k_queue *pqueue) in tqueue_alloc() argument
260 k_queue_alloc_append(pqueue, (void *)&data_append); in tqueue_alloc()
263 zassert_false(k_queue_remove(pqueue, &data_append)); in tqueue_alloc()
271 k_queue_alloc_prepend(pqueue, (void *)&data_prepend); in tqueue_alloc()
273 zassert_false(k_queue_remove(pqueue, &data_prepend)); in tqueue_alloc()
278 zassert_true(k_queue_is_empty(pqueue)); in tqueue_alloc()
283 zassert_false(k_queue_alloc_prepend(pqueue, (void *)&data_prepend), in tqueue_alloc()
287 zassert_false(k_queue_is_empty(pqueue)); in tqueue_alloc()
289 zassert_true(k_queue_get(pqueue, K_FOREVER) != NULL, in tqueue_alloc()