| /dpdk/drivers/net/nfb/ |
| H A D | nfb_stats.c | 25 struct ndp_tx_queue *tx_queue = *((struct ndp_tx_queue **) in nfb_eth_stats_get() local
39 stats->q_opackets[i] = tx_queue[i].tx_pkts; in nfb_eth_stats_get()
40 stats->q_obytes[i] = tx_queue[i].tx_bytes; in nfb_eth_stats_get()
42 tx_total += tx_queue[i].tx_pkts; in nfb_eth_stats_get()
43 tx_total_bytes += tx_queue[i].tx_bytes; in nfb_eth_stats_get()
44 tx_err_total += tx_queue[i].err_pkts; in nfb_eth_stats_get()
64 struct ndp_tx_queue *tx_queue = *((struct ndp_tx_queue **) in nfb_eth_stats_reset() local
73 tx_queue[i].tx_pkts = 0; in nfb_eth_stats_reset()
74 tx_queue[i].tx_bytes = 0; in nfb_eth_stats_reset()
75 tx_queue[i].err_pkts = 0; in nfb_eth_stats_reset()
|
| /dpdk/drivers/net/cnxk/tx/cn9k/ |
| H A D | tx_all_offload.c | 11 cn9k_nix_xmit_pkts_all_offload(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t pkts) in cn9k_nix_xmit_pkts_all_offload() argument
13 struct cn9k_eth_txq *txq = (struct cn9k_eth_txq *)tx_queue; in cn9k_nix_xmit_pkts_all_offload()
16 return cn9k_nix_xmit_pkts_mseg(tx_queue, tx_pkts, pkts, cmd, txq->tx_offload_flags); in cn9k_nix_xmit_pkts_all_offload()
20 cn9k_nix_xmit_pkts_vec_all_offload(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t pkts) in cn9k_nix_xmit_pkts_vec_all_offload() argument
22 struct cn9k_eth_txq *txq = (struct cn9k_eth_txq *)tx_queue; in cn9k_nix_xmit_pkts_vec_all_offload()
25 return cn9k_nix_xmit_pkts_vector(tx_queue, tx_pkts, pkts, cmd, txq->tx_offload_flags); in cn9k_nix_xmit_pkts_vec_all_offload()
|
| /dpdk/drivers/net/cnxk/tx/cn10k/ |
| H A D | tx_all_offload.c | 14 cn10k_nix_xmit_pkts_all_offload(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t pkts) in cn10k_nix_xmit_pkts_all_offload() argument
16 struct cn10k_eth_txq *txq = (struct cn10k_eth_txq *)tx_queue; in cn10k_nix_xmit_pkts_all_offload()
19 return cn10k_nix_xmit_pkts_mseg(tx_queue, NULL, tx_pkts, pkts, cmd, txq->tx_offload_flags); in cn10k_nix_xmit_pkts_all_offload()
23 cn10k_nix_xmit_pkts_vec_all_offload(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t pkts) in cn10k_nix_xmit_pkts_vec_all_offload() argument
25 struct cn10k_eth_txq *txq = (struct cn10k_eth_txq *)tx_queue; in cn10k_nix_xmit_pkts_vec_all_offload()
28 return cn10k_nix_xmit_pkts_vector(tx_queue, NULL, tx_pkts, pkts, cmd, in cn10k_nix_xmit_pkts_vec_all_offload()
|
| /dpdk/drivers/crypto/qat/dev/ |
| H A D | qat_sym_pmd_gen1.c | 511 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_single_cipher_gen1() local
519 (uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_single_cipher_gen1()
520 cookie = qp->op_cookies[tail >> tx_queue->trailz]; in qat_sym_dp_enqueue_single_cipher_gen1()
521 tail = (tail + tx_queue->msg_size) & tx_queue->modulo_mask; in qat_sym_dp_enqueue_single_cipher_gen1()
523 rte_prefetch0((uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_single_cipher_gen1()
551 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_cipher_jobs_gen1() local
569 qp->op_cookies[tail >> tx_queue->trailz]; in qat_sym_dp_enqueue_cipher_jobs_gen1()
572 (uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_cipher_jobs_gen1()
595 tail = (tail + tx_queue->msg_size) & tx_queue->modulo_mask; in qat_sym_dp_enqueue_cipher_jobs_gen1()
622 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_single_auth_gen1() local
[all …]
|
| H A D | qat_crypto_pmd_gen3.c | 590 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_single_aead_gen3() local
599 (uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_single_aead_gen3()
600 cookie = qp->op_cookies[tail >> tx_queue->trailz]; in qat_sym_dp_enqueue_single_aead_gen3()
601 tail = (tail + tx_queue->msg_size) & tx_queue->modulo_mask; in qat_sym_dp_enqueue_single_aead_gen3()
603 rte_prefetch0((uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_single_aead_gen3()
628 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_aead_jobs_gen3() local
646 qp->op_cookies[tail >> tx_queue->trailz]; in qat_sym_dp_enqueue_aead_jobs_gen3()
649 (uint8_t *)tx_queue->base_addr + tail); in qat_sym_dp_enqueue_aead_jobs_gen3()
671 tail = (tail + tx_queue->msg_size) & tx_queue->modulo_mask; in qat_sym_dp_enqueue_aead_jobs_gen3()
698 struct qat_queue *tx_queue = &qp->tx_q; in qat_sym_dp_enqueue_single_auth_gen3() local
[all …]
|
| /dpdk/app/test-eventdev/ |
| H A D | test_pipeline_queue.c | 53 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_queue_worker_single_stage_fwd() local
64 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
112 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_queue_worker_single_stage_burst_fwd() local
125 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_queue_worker_single_stage_burst_fwd()
173 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_queue_worker_single_stage_fwd_vector() local
185 ev.queue_id = tx_queue[ev.vec->port]; in pipeline_queue_worker_single_stage_fwd_vector()
236 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_queue_worker_single_stage_burst_fwd_vector() local
250 ev[i].queue_id = tx_queue[ev[i].vec->port]; in pipeline_queue_worker_single_stage_burst_fwd_vector()
269 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_queue_worker_multi_stage_tx() local
282 if (ev.queue_id == tx_queue[ev.mbuf->port]) { in pipeline_queue_worker_multi_stage_tx()
[all …]
|
| H A D | test_pipeline_atq.c | 46 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_atq_worker_single_stage_fwd() local
57 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_atq_worker_single_stage_fwd()
98 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_atq_worker_single_stage_burst_fwd() local
112 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_atq_worker_single_stage_burst_fwd()
151 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_atq_worker_single_stage_fwd_vector() local
164 ev.queue_id = tx_queue[ev.vec->port]; in pipeline_atq_worker_single_stage_fwd_vector()
207 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_atq_worker_single_stage_burst_fwd_vector() local
221 ev[i].queue_id = tx_queue[ev[i].vec->port]; in pipeline_atq_worker_single_stage_burst_fwd_vector()
271 const uint8_t *tx_queue = t->tx_evqueue_id; in pipeline_atq_worker_multi_stage_fwd() local
285 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_atq_worker_multi_stage_fwd()
[all …]
|
| /dpdk/drivers/net/virtio/ |
| H A D | virtio_ethdev.h | 91 uint16_t virtio_xmit_pkts_prepare(void *tx_queue, struct rte_mbuf **tx_pkts,
94 uint16_t virtio_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
96 uint16_t virtio_xmit_pkts_packed(void *tx_queue, struct rte_mbuf **tx_pkts,
99 uint16_t virtio_xmit_pkts_inorder(void *tx_queue, struct rte_mbuf **tx_pkts,
108 uint16_t virtio_xmit_pkts_packed_vec(void *tx_queue, struct rte_mbuf **tx_pkts,
|
| H A D | virtio_rxtx_packed.c | 26 virtio_xmit_pkts_packed_vec(void *tx_queue, struct rte_mbuf **tx_pkts, in virtio_xmit_pkts_packed_vec() argument
29 struct virtnet_tx *txvq = tx_queue; in virtio_xmit_pkts_packed_vec()
|
| /dpdk/drivers/net/octeon_ep/ |
| H A D | otx_ep_rxtx.h | 36 otx_ep_xmit_pkts(void *tx_queue, struct rte_mbuf **pkts, uint16_t nb_pkts);
39 otx2_ep_xmit_pkts(void *tx_queue, struct rte_mbuf **pkts, uint16_t nb_pkts);
45 cnxk_ep_xmit_pkts(void *tx_queue, struct rte_mbuf **pkts, uint16_t nb_pkts);
48 cnxk_ep_xmit_pkts_mseg(void *tx_queue, struct rte_mbuf **pkts, uint16_t nb_pkts);
|
| /dpdk/drivers/net/bnxt/ |
| H A D | bnxt_txr.h | 49 uint16_t bnxt_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
51 uint16_t _bnxt_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
54 uint16_t bnxt_xmit_pkts_vec(void *tx_queue, struct rte_mbuf **tx_pkts,
58 uint16_t bnxt_xmit_pkts_vec_avx2(void *tx_queue, struct rte_mbuf **tx_pkts,
|
| /dpdk/drivers/net/cnxk/ |
| H A D | cn9k_tx_select.c | 25 cn9k_nix_tx_queue_count(void *tx_queue) in cn9k_nix_tx_queue_count() argument
27 struct cn9k_eth_txq *txq = (struct cn9k_eth_txq *)tx_queue; in cn9k_nix_tx_queue_count()
33 cn9k_nix_tx_queue_sec_count(void *tx_queue) in cn9k_nix_tx_queue_sec_count() argument
35 struct cn9k_eth_txq *txq = (struct cn9k_eth_txq *)tx_queue; in cn9k_nix_tx_queue_sec_count()
|
| H A D | cn10k_tx_select.c | 25 cn10k_nix_tx_queue_count(void *tx_queue) in cn10k_nix_tx_queue_count() argument
27 struct cn10k_eth_txq *txq = (struct cn10k_eth_txq *)tx_queue; in cn10k_nix_tx_queue_count()
33 cn10k_nix_tx_queue_sec_count(void *tx_queue) in cn10k_nix_tx_queue_sec_count() argument
35 struct cn10k_eth_txq *txq = (struct cn10k_eth_txq *)tx_queue; in cn10k_nix_tx_queue_sec_count()
|
| /dpdk/drivers/common/idpf/ |
| H A D | idpf_common_rxtx.h | 269 uint16_t idpf_dp_splitq_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
275 uint16_t idpf_dp_singleq_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
278 uint16_t idpf_dp_prep_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
293 uint16_t idpf_dp_splitq_recv_pkts_avx512(void *tx_queue, struct rte_mbuf **tx_pkts,
296 uint16_t idpf_dp_singleq_xmit_pkts_avx512(void *tx_queue,
300 uint16_t idpf_dp_splitq_xmit_pkts_avx512(void *tx_queue, struct rte_mbuf **tx_pkts,
|
| /dpdk/drivers/net/ionic/ |
| H A D | ionic_rxtx.h | 75 int ionic_dev_tx_descriptor_status(void *tx_queue, uint16_t offset);
82 uint16_t ionic_prep_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
88 uint16_t ionic_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
96 uint16_t ionic_xmit_pkts_sg(void *tx_queue, struct rte_mbuf **tx_pkts,
|
| /dpdk/drivers/crypto/virtio/ |
| H A D | virtio_cryptodev.h | 58 uint16_t virtio_crypto_pkt_tx_burst(void *tx_queue,
62 uint16_t virtio_crypto_pkt_rx_burst(void *tx_queue,
|
| /dpdk/drivers/net/atlantic/ |
| H A D | atl_ethdev.h | 72 int atl_dev_tx_descriptor_status(void *tx_queue, uint16_t offset);
101 uint16_t atl_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
104 uint16_t atl_prep_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
|
| /dpdk/drivers/net/tap/ |
| H A D | rte_eth_tap.h | 59 struct tx_queue { struct
93 struct tx_queue txq[RTE_PMD_TAP_MAX_QUEUES]; /* List of TX queues */
|
| /dpdk/drivers/net/octeontx/ |
| H A D | octeontx_rxtx.c | 46 octeontx_xmit_pkts_ ##name(void *tx_queue, \
51 return __octeontx_xmit_pkts(tx_queue, tx_pkts, pkts, cmd, \
|
| /dpdk/drivers/crypto/bcmfs/hw/ |
| H A D | bcmfs5_rm.c | 538 struct bcmfs_queue *tx_queue = &qp->tx_q; in bcmfs5_start_qp() local
545 for (off = 0; off < tx_queue->queue_size; off += FS_RING_DESC_SIZE) { in bcmfs5_start_qp()
547 if (next_addr == tx_queue->queue_size) in bcmfs5_start_qp()
549 next_addr += (uint64_t)tx_queue->base_phys_addr; in bcmfs5_start_qp()
554 rm_write_desc((uint8_t *)tx_queue->base_addr + off, d); in bcmfs5_start_qp()
603 bd_low = lower_32_bits(tx_queue->base_phys_addr); in bcmfs5_start_qp()
604 bd_high = upper_32_bits(tx_queue->base_phys_addr); in bcmfs5_start_qp()
610 tx_queue->tx_write_ptr = 0; in bcmfs5_start_qp()
|
| H A D | bcmfs4_rm.c | 606 struct bcmfs_queue *tx_queue = &qp->tx_q; in bcmfs4_start_qp() local
613 for (off = 0; off < tx_queue->queue_size; off += FS_RING_DESC_SIZE) { in bcmfs4_start_qp()
615 if (next_addr == tx_queue->queue_size) in bcmfs4_start_qp()
617 next_addr += (uint64_t)tx_queue->base_phys_addr; in bcmfs4_start_qp()
623 rm_write_desc((uint8_t *)tx_queue->base_addr + off, d); in bcmfs4_start_qp()
672 val = BD_START_ADDR_VALUE(tx_queue->base_phys_addr); in bcmfs4_start_qp()
676 tx_queue->tx_write_ptr = FS_MMIO_READ32((uint8_t *)qp->ioreg + in bcmfs4_start_qp()
678 tx_queue->tx_write_ptr *= FS_RING_DESC_SIZE; in bcmfs4_start_qp()
|
| /dpdk/app/test/ |
| H A D | virtual_pmd.c | 26 struct rte_ring *tx_queue; member
61 while (rte_ring_dequeue(prv->tx_queue, &pkt) != -ENOENT) in virtual_ethdev_stop()
200 while (rte_ring_dequeue(dev_private->tx_queue, &pkt) == -ENOBUFS) in virtual_ethdev_stats_reset()
364 nb_pkts = rte_ring_enqueue_burst(dev_private->tx_queue, (void **)bufs, in virtual_ethdev_tx_burst_success()
497 return rte_ring_dequeue_burst(dev_private->tx_queue, (void **)pkt_burst, in virtual_ethdev_get_mbufs_from_tx_queue()
542 dev_private->tx_queue = rte_ring_create(name_buf, MAX_PKT_BURST, socket_id, in virtual_ethdev_create()
544 if (dev_private->tx_queue == NULL) in virtual_ethdev_create()
|
| /dpdk/drivers/net/hns3/ |
| H A D | hns3_rxtx_vec.c | 38 hns3_xmit_pkts_vec(void *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts) in hns3_xmit_pkts_vec() argument
40 struct hns3_tx_queue *txq = (struct hns3_tx_queue *)tx_queue; in hns3_xmit_pkts_vec()
47 ret = hns3_xmit_fixed_burst_vec(tx_queue, &tx_pkts[nb_tx], in hns3_xmit_pkts_vec()
|
| H A D | hns3_rxtx_vec_sve.c | 286 hns3_xmit_fixed_burst_vec_sve(void *__restrict tx_queue, in hns3_xmit_fixed_burst_vec_sve() argument
290 struct hns3_tx_queue *txq = (struct hns3_tx_queue *)tx_queue; in hns3_xmit_fixed_burst_vec_sve()
320 hns3_xmit_pkts_vec_sve(void *tx_queue, in hns3_xmit_pkts_vec_sve() argument
324 struct hns3_tx_queue *txq = (struct hns3_tx_queue *)tx_queue; in hns3_xmit_pkts_vec_sve()
330 ret = hns3_xmit_fixed_burst_vec_sve(tx_queue, &tx_pkts[nb_tx], in hns3_xmit_pkts_vec_sve()
|
| /dpdk/drivers/net/axgbe/ |
| H A D | axgbe_rxtx_vec_sse.c | 59 axgbe_xmit_pkts_vec(void *tx_queue, struct rte_mbuf **tx_pkts, in axgbe_xmit_pkts_vec() argument
68 txq = (struct axgbe_tx_queue *)tx_queue; in axgbe_xmit_pkts_vec()
|