Home
last modified time | relevance | path

Searched refs:tx_queue_id (Results 1 – 25 of 40) sorted by relevance

12

/dpdk/drivers/net/ionic/
H A Dionic_rxtx.c97 ionic_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id) in ionic_dev_tx_queue_stop() argument
99 ionic_dev_tx_queue_stop_firsthalf(dev, tx_queue_id); in ionic_dev_tx_queue_stop()
100 ionic_dev_tx_queue_stop_secondhalf(dev, tx_queue_id); in ionic_dev_tx_queue_stop()
107 uint16_t tx_queue_id) in ionic_dev_tx_queue_stop_firsthalf() argument
109 struct ionic_tx_qcq *txq = dev->data->tx_queues[tx_queue_id]; in ionic_dev_tx_queue_stop_firsthalf()
111 IONIC_PRINT(DEBUG, "Stopping TX queue %u", tx_queue_id); in ionic_dev_tx_queue_stop_firsthalf()
113 dev->data->tx_queue_state[tx_queue_id] = RTE_ETH_QUEUE_STATE_STOPPED; in ionic_dev_tx_queue_stop_firsthalf()
120 uint16_t tx_queue_id) in ionic_dev_tx_queue_stop_secondhalf() argument
123 struct ionic_tx_qcq *txq = dev->data->tx_queues[tx_queue_id]; in ionic_dev_tx_queue_stop_secondhalf()
134 ionic_dev_tx_queue_setup(struct rte_eth_dev *eth_dev, uint16_t tx_queue_id, in ionic_dev_tx_queue_setup() argument
[all …]
H A Dionic_rxtx.h42 int ionic_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
46 int ionic_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
47 int ionic_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
55 uint16_t tx_queue_id);
57 uint16_t tx_queue_id);
65 uint16_t tx_queue_id);
67 uint16_t tx_queue_id);
/dpdk/lib/eventdev/
H A Drte_event_eth_tx_adapter.c174 int32_t tx_queue_id);
288 uint16_t tx_queue_id) in txa_service_queue() argument
297 return likely(tqi != NULL) ? tqi + tx_queue_id : NULL; in txa_service_queue()
502 uint16_t tx_queue_id) in txa_service_is_queue_added() argument
506 tqi = txa_service_queue(txa, dev->data->port_id, tx_queue_id); in txa_service_is_queue_added()
815 int32_t tx_queue_id) in txa_service_queue_add() argument
826 if (tx_queue_id == -1) { in txa_service_queue_add()
866 if (txa_service_is_queue_added(txa, eth_dev, tx_queue_id)) in txa_service_queue_add()
878 tqi = txa_service_queue(txa, eth_dev->data->port_id, tx_queue_id); in txa_service_queue_add()
885 txa_retry->tx_queue = tx_queue_id; in txa_service_queue_add()
[all …]
H A Drte_event_eth_tx_adapter.h484 * @param tx_queue_id
497 uint16_t tx_queue_id,
505 * <eth_dev_id, tx_queue_id> after calling
523 * @param tx_queue_id
530 rte_event_eth_tx_adapter_queue_start(uint16_t eth_dev_id, uint16_t tx_queue_id);
541 * @param tx_queue_id
548 rte_event_eth_tx_adapter_queue_stop(uint16_t eth_dev_id, uint16_t tx_queue_id);
H A Deventdev_pmd.h1205 * @param tx_queue_id
1216 int32_t tx_queue_id);
1233 * @param tx_queue_id
1244 int32_t tx_queue_id);
1323 * @param tx_queue_id
1335 (uint16_t eth_dev_id, uint16_t tx_queue_id, uint8_t *txa_inst_id);
1346 * @param tx_queue_id
1354 (uint8_t id, uint16_t eth_dev_id, uint16_t tx_queue_id);
1365 * @param tx_queue_id
1373 (uint8_t id, uint16_t eth_dev_id, uint16_t tx_queue_id);
[all...]
H A Deventdev_trace.h775 RTE_TRACE_POINT_ARGS(uint16_t eth_dev_id, uint16_t tx_queue_id,
778 rte_trace_point_emit_u16(tx_queue_id);
784 RTE_TRACE_POINT_ARGS(uint16_t eth_dev_id, uint16_t tx_queue_id),
786 rte_trace_point_emit_u16(tx_queue_id);
791 RTE_TRACE_POINT_ARGS(uint16_t eth_dev_id, uint16_t tx_queue_id),
793 rte_trace_point_emit_u16(tx_queue_id);
/dpdk/drivers/net/atlantic/
H A Datl_ethdev.h58 void atl_tx_queue_release(struct rte_eth_dev *dev, uint16_t tx_queue_id);
65 int atl_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
89 int atl_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
90 int atl_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
/dpdk/drivers/net/nfb/
H A Dnfb_tx.h20 uint16_t tx_queue_id; /* index */ member
47 uint16_t tx_queue_id,
67 uint16_t tx_queue_id,
/dpdk/drivers/net/cxgbe/
H A Dcxgbe_pfvf.h39 uint16_t tx_queue_id);
41 uint16_t tx_queue_id);
42 int cxgbe_dev_tx_queue_stop(struct rte_eth_dev *eth_dev, uint16_t tx_queue_id);
/dpdk/drivers/net/bnxt/
H A Dbnxt_txr.h62 int bnxt_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
63 int bnxt_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
/dpdk/drivers/net/virtio/
H A Dvirtio_ethdev.h70 int virtio_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
75 uint16_t tx_queue_id);
/dpdk/drivers/net/mvneta/
H A Dmvneta_rxtx.h18 void mvneta_txq_info_get(struct rte_eth_dev *dev, uint16_t tx_queue_id,
/dpdk/examples/bbdev_app/
H A Dmain.c137 unsigned int tx_queue_id; member
522 uint16_t tx_queue_id = 0; in lcore_conf_init() local
540 lconf->tx_queue_id = tx_queue_id++; in lcore_conf_init()
822 uint16_t port_id, tx_queue_id; in run_decoding() local
834 tx_queue_id = lcore_conf->tx_queue_id; in run_decoding()
908 nb_tx = rte_eth_tx_burst(port_id, tx_queue_id, recv_pkts_burst, nb_deq); in run_decoding()
/dpdk/lib/ethdev/
H A Drte_ethdev.c787 eth_dev_validate_tx_queue(const struct rte_eth_dev *dev, uint16_t tx_queue_id) in eth_dev_validate_tx_queue() argument
791 if (tx_queue_id >= dev->data->nb_tx_queues) { in eth_dev_validate_tx_queue()
795 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
799 if (dev->data->tx_queues[tx_queue_id] == NULL) { in eth_dev_validate_tx_queue()
803 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
914 rte_eth_dev_tx_queue_start(uint16_t port_id, uint16_t tx_queue_id) in rte_eth_dev_tx_queue_start() argument
929 ret = eth_dev_validate_tx_queue(dev, tx_queue_id); in rte_eth_dev_tx_queue_start()
936 if (rte_eth_dev_is_tx_hairpin_queue(dev, tx_queue_id)) { in rte_eth_dev_tx_queue_start()
939 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
943 if (dev->data->tx_queue_state[tx_queue_id] ! in rte_eth_dev_tx_queue_start()
958 rte_eth_dev_tx_queue_stop(uint16_t port_id,uint16_t tx_queue_id) rte_eth_dev_tx_queue_stop() argument
2462 rte_eth_tx_queue_setup(uint16_t port_id,uint16_t tx_queue_id,uint16_t nb_tx_desc,unsigned int socket_id,const struct rte_eth_txconf * tx_conf) rte_eth_tx_queue_setup() argument
2565 rte_eth_tx_hairpin_queue_setup(uint16_t port_id,uint16_t tx_queue_id,uint16_t nb_tx_desc,const struct rte_eth_hairpin_conf * conf) rte_eth_tx_hairpin_queue_setup() argument
3710 rte_eth_dev_set_tx_queue_stats_mapping(uint16_t port_id,uint16_t tx_queue_id,uint8_t stat_idx) rte_eth_dev_set_tx_queue_stats_mapping() argument
6956 rte_eth_dev_map_aggr_tx_affinity(uint16_t port_id,uint16_t tx_queue_id,uint8_t affinity) rte_eth_dev_map_aggr_tx_affinity() argument
[all...]
H A Drte_ethdev.h2524 * @param tx_queue_id
2567 int rte_eth_tx_queue_setup(uint16_t port_id, uint16_t tx_queue_id,
2579 * @param tx_queue_id
2598 (uint16_t port_id, uint16_t tx_queue_id, uint16_t nb_tx_desc,
2715 * @param tx_queue_id
2729 int rte_eth_dev_map_aggr_tx_affinity(uint16_t port_id, uint16_t tx_queue_id,
2838 * @param tx_queue_id
2849 int rte_eth_dev_tx_queue_start(uint16_t port_id, uint16_t tx_queue_id);
2856 * @param tx_queue_id
2867 int rte_eth_dev_tx_queue_stop(uint16_t port_id, uint16_t tx_queue_id);
6738 rte_eth_recycle_mbufs(uint16_t rx_port_id,uint16_t rx_queue_id,uint16_t tx_port_id,uint16_t tx_queue_id,struct rte_eth_recycle_rxq_info * recycle_rxq_info) rte_eth_recycle_mbufs() argument
[all...]
H A Dethdev_driver.h591 uint16_t tx_queue_id,
619 uint16_t tx_queue_id, struct rte_eth_txq_info *qinfo);
873 * @param tx_queue_id
893 (struct rte_eth_dev *dev, uint16_t tx_queue_id,
1317 * @param tx_queue_id
1325 typedef int (*eth_map_aggr_tx_affinity_t)(struct rte_eth_dev *dev, uint16_t tx_queue_id,
H A Dethdev_trace.h63 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id,
66 rte_trace_point_emit_u16(tx_queue_id);
170 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id, int ret),
172 rte_trace_point_emit_u16(tx_queue_id);
178 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id, int ret),
180 rte_trace_point_emit_u16(tx_queue_id);
248 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id,
252 rte_trace_point_emit_u16(tx_queue_id);
325 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id,
328 rte_trace_point_emit_u16(tx_queue_id);
[all...]
/dpdk/examples/l3fwd/
H A Dl3fwd.h86 uint16_t tx_queue_id[RTE_MAX_ETHPORTS];
130 queueid = qconf->tx_queue_id[port]; in send_burst()
85 uint16_t tx_queue_id[RTE_MAX_ETHPORTS]; global() member
H A Dl3fwd_common.h75 n = rte_eth_tx_burst(port, qconf->tx_queue_id[port], m, num); in send_packetsx4()
/dpdk/app/test/
H A Dvirtual_pmd.c137 uint16_t tx_queue_id, uint16_t nb_tx_desc __rte_unused, in virtual_ethdev_tx_queue_setup_success() argument
150 tx_q->queue_id = tx_queue_id; in virtual_ethdev_tx_queue_setup_success()
152 dev->data->tx_queues[tx_queue_id] = tx_q; in virtual_ethdev_tx_queue_setup_success()
159 uint16_t tx_queue_id __rte_unused, uint16_t nb_tx_desc __rte_unused, in virtual_ethdev_tx_queue_setup_fail()
/dpdk/drivers/net/bnx2x/
H A Dbnx2x_rxtx.h71 int bnx2x_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
/dpdk/examples/ipv4_multicast/
H A Dmain.c105 uint16_t tx_queue_id[MAX_PORTS]; member
167 queueid = qconf->tx_queue_id[port]; in send_burst()
796 qconf->tx_queue_id[portid] = queueid; in main()
/dpdk/examples/ipsec-secgw/
H A Devent_helper.h91 int tx_queue_id; member
/dpdk/drivers/net/cnxk/
H A Dcnxk_rep_ops.c403 cnxk_rep_tx_queue_setup(struct rte_eth_dev *ethdev, uint16_t tx_queue_id, uint16_t nb_tx_desc, in cnxk_rep_tx_queue_setup() argument
426 ethdev->data->tx_queues[tx_queue_id] = NULL; in cnxk_rep_tx_queue_setup()
446 ethdev->data->tx_queues[tx_queue_id] = txq; in cnxk_rep_tx_queue_setup()
447 ethdev->data->tx_queue_state[tx_queue_id] = RTE_ETH_QUEUE_STATE_STOPPED; in cnxk_rep_tx_queue_setup()
/dpdk/examples/eventdev_pipeline/
H A Dpipeline_common.h84 uint8_t tx_queue_id; member

12