Lines Matching full:queue

11 void ull_tx_q_init(struct ull_tx_q *queue)  in ull_tx_q_init()  argument
13 queue->pause_data = 0U; in ull_tx_q_init()
14 sys_slist_init(&queue->tx_list); in ull_tx_q_init()
15 sys_slist_init(&queue->data_list); in ull_tx_q_init()
18 void ull_tx_q_pause_data(struct ull_tx_q *queue) in ull_tx_q_pause_data() argument
20 queue->pause_data++; in ull_tx_q_pause_data()
23 void ull_tx_q_resume_data(struct ull_tx_q *queue) in ull_tx_q_resume_data() argument
25 if (queue->pause_data > 0) { in ull_tx_q_resume_data()
26 queue->pause_data--; in ull_tx_q_resume_data()
30 if (!queue->pause_data && !sys_slist_is_empty(&queue->data_list)) { in ull_tx_q_resume_data()
31 sys_slist_merge_slist(&queue->tx_list, &queue->data_list); in ull_tx_q_resume_data()
35 void ull_tx_q_enqueue_data(struct ull_tx_q *queue, struct node_tx *tx) in ull_tx_q_enqueue_data() argument
39 if (queue->pause_data) { in ull_tx_q_enqueue_data()
41 list = &queue->data_list; in ull_tx_q_enqueue_data()
44 list = &queue->tx_list; in ull_tx_q_enqueue_data()
50 void ull_tx_q_enqueue_ctrl(struct ull_tx_q *queue, struct node_tx *tx) in ull_tx_q_enqueue_ctrl() argument
53 sys_slist_append(&queue->tx_list, (sys_snode_t *)tx); in ull_tx_q_enqueue_ctrl()
56 struct node_tx *ull_tx_q_peek(struct ull_tx_q *queue) in ull_tx_q_peek() argument
60 tx = (struct node_tx *)sys_slist_peek_head(&queue->tx_list); in ull_tx_q_peek()
65 struct node_tx *ull_tx_q_dequeue(struct ull_tx_q *queue) in ull_tx_q_dequeue() argument
69 tx = (struct node_tx *)sys_slist_get(&queue->tx_list); in ull_tx_q_dequeue()