Lines Matching refs:pqueue
21 static void tqueue_append(struct k_queue *pqueue) in tqueue_append() argument
25 k_queue_append(pqueue, (void *)&data[i]); in tqueue_append()
30 k_queue_prepend(pqueue, (void *)&data_p[i]); in tqueue_append()
35 k_queue_prepend(pqueue, (void *)&data_r[i]); in tqueue_append()
39 static void tqueue_get(struct k_queue *pqueue) in tqueue_get() argument
46 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
53 rx_data = k_queue_get(pqueue, K_NO_WAIT); in tqueue_get()
58 static void tqueue_find_and_remove(struct k_queue *pqueue) in tqueue_find_and_remove() argument
63 zassert_true(k_queue_remove(pqueue, &data_r[i])); in tqueue_find_and_remove()
85 static void tqueue_read_write(struct k_queue *pqueue) in tqueue_read_write() argument
90 tThread_entry, pqueue, NULL, NULL, in tqueue_read_write()
93 tqueue_append(pqueue); in tqueue_read_write()
94 irq_offload(tIsr_entry, (const void *)pqueue); in tqueue_read_write()
98 tqueue_find_and_remove(pqueue); in tqueue_read_write()
99 tqueue_get(pqueue); in tqueue_read_write()