Lines Matching refs:queue

140 	struct hif_client_rx_queue *queue;  in hif_lib_client_init_rx_buffers()  local
150 queue = &client->rx_q[qno]; in hif_lib_client_init_rx_buffers()
152 queue->base = client->rx_qbase + qno * q_size * sizeof(struct in hif_lib_client_init_rx_buffers()
154 queue->size = q_size; in hif_lib_client_init_rx_buffers()
155 queue->read_idx = 0; in hif_lib_client_init_rx_buffers()
156 queue->write_idx = 0; in hif_lib_client_init_rx_buffers()
157 queue->queue_id = 0; in hif_lib_client_init_rx_buffers()
158 queue->port_id = client->port_id; in hif_lib_client_init_rx_buffers()
159 queue->priv = client->priv; in hif_lib_client_init_rx_buffers()
161 queue->base, queue->size); in hif_lib_client_init_rx_buffers()
165 queue = &client->rx_q[qno]; in hif_lib_client_init_rx_buffers()
166 desc = queue->base; in hif_lib_client_init_rx_buffers()
168 for (ii = 0; ii < queue->size; ii++) { in hif_lib_client_init_rx_buffers()
182 hif_lib_client_cleanup_tx_queue(struct hif_client_tx_queue *queue) in hif_lib_client_cleanup_tx_queue() argument
191 if (queue->tx_pending) in hif_lib_client_cleanup_tx_queue()
210 struct hif_client_tx_queue *queue; in hif_lib_client_init_tx_buffers() local
219 queue = &client->tx_q[qno]; in hif_lib_client_init_tx_buffers()
221 queue->base = client->tx_qbase + qno * q_size * sizeof(struct in hif_lib_client_init_tx_buffers()
223 queue->size = q_size; in hif_lib_client_init_tx_buffers()
224 queue->read_idx = 0; in hif_lib_client_init_tx_buffers()
225 queue->write_idx = 0; in hif_lib_client_init_tx_buffers()
226 queue->tx_pending = 0; in hif_lib_client_init_tx_buffers()
227 queue->nocpy_flag = 0; in hif_lib_client_init_tx_buffers()
228 queue->prev_tmu_tx_pkts = 0; in hif_lib_client_init_tx_buffers()
229 queue->done_tmu_tx_pkts = 0; in hif_lib_client_init_tx_buffers()
230 queue->priv = client->priv; in hif_lib_client_init_tx_buffers()
231 queue->queue_id = 0; in hif_lib_client_init_tx_buffers()
232 queue->port_id = client->port_id; in hif_lib_client_init_tx_buffers()
235 queue->base, queue->size); in hif_lib_client_init_tx_buffers()
345 struct hif_client_rx_queue *queue = &client->rx_q[qno]; in hif_lib_event_handler_start() local
346 struct rx_queue_desc *desc = queue->base + queue->read_idx; in hif_lib_event_handler_start()
391 hif_lib_receive_pkt(struct hif_client_rx_queue *queue, in hif_lib_receive_pkt() argument
396 struct pfe_eth_priv_s *priv = queue->priv; in hif_lib_receive_pkt()
407 desc = queue->base + queue->read_idx; in hif_lib_receive_pkt()
428 mbuf->port = queue->port_id; in hif_lib_receive_pkt()
467 queue->read_idx = (queue->read_idx + 1) & in hif_lib_receive_pkt()
468 (queue->size - 1); in hif_lib_receive_pkt()
496 struct hif_client_tx_queue *queue = &client->tx_q[qno]; in hif_lib_xmit_pkt() local
497 struct tx_queue_desc *desc = queue->base + queue->write_idx; in hif_lib_xmit_pkt()
513 queue->write_idx = (queue->write_idx + 1) & (queue->size - 1); in hif_lib_xmit_pkt()
515 queue->tx_pending++; in hif_lib_xmit_pkt()
522 struct hif_client_tx_queue *queue = &client->tx_q[qno]; in hif_lib_tx_get_next_complete() local
523 struct tx_queue_desc *desc = queue->base + queue->read_idx; in hif_lib_tx_get_next_complete()
526 qno, queue->read_idx, queue->tx_pending); in hif_lib_tx_get_next_complete()
528 if (!queue->tx_pending) in hif_lib_tx_get_next_complete()
531 if (queue->nocpy_flag && !queue->done_tmu_tx_pkts) { in hif_lib_tx_get_next_complete()
534 if (queue->prev_tmu_tx_pkts > tmu_tx_pkts) in hif_lib_tx_get_next_complete()
535 queue->done_tmu_tx_pkts = UINT_MAX - in hif_lib_tx_get_next_complete()
536 queue->prev_tmu_tx_pkts + tmu_tx_pkts; in hif_lib_tx_get_next_complete()
538 queue->done_tmu_tx_pkts = tmu_tx_pkts - in hif_lib_tx_get_next_complete()
539 queue->prev_tmu_tx_pkts; in hif_lib_tx_get_next_complete()
541 queue->prev_tmu_tx_pkts = tmu_tx_pkts; in hif_lib_tx_get_next_complete()
543 if (!queue->done_tmu_tx_pkts) in hif_lib_tx_get_next_complete()
550 queue->read_idx = (queue->read_idx + 1) & (queue->size - 1); in hif_lib_tx_get_next_complete()
551 queue->tx_pending--; in hif_lib_tx_get_next_complete()
555 if (queue->done_tmu_tx_pkts && (*flags & HIF_LAST_BUFFER)) in hif_lib_tx_get_next_complete()
556 queue->done_tmu_tx_pkts--; in hif_lib_tx_get_next_complete()