Home
last modified time | relevance | path

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

1234

/f-stack/dpdk/drivers/net/nfb/
H A Dnfb_tx.c51 uint16_t tx_queue_id, in nfb_eth_tx_queue_setup() argument
66 "%" PRIu16 "!\n", tx_queue_id); in nfb_eth_tx_queue_setup()
71 tx_queue_id, in nfb_eth_tx_queue_setup()
75 dev->data->tx_queues[tx_queue_id] = txq; in nfb_eth_tx_queue_setup()
84 uint16_t tx_queue_id, in nfb_eth_tx_queue_init() argument
90 txq->queue = ndp_open_tx_queue(nfb, tx_queue_id); in nfb_eth_tx_queue_init()
95 txq->tx_queue_id = tx_queue_id; in nfb_eth_tx_queue_init()
H A Dnfb_tx.h20 uint16_t tx_queue_id; /* index */ member
47 uint16_t tx_queue_id,
67 uint16_t tx_queue_id,
/f-stack/dpdk/drivers/net/ionic/
H A Dionic_rxtx.h32 int ionic_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
36 int ionic_dev_tx_queue_stop(struct rte_eth_dev *eth_dev, uint16_t tx_queue_id);
37 int ionic_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
H A Dionic_rxtx.c138 txq = eth_dev->data->tx_queues[tx_queue_id]; in ionic_dev_tx_queue_stop()
151 eth_dev->data->tx_queue_state[tx_queue_id] = in ionic_dev_tx_queue_stop()
170 tx_queue_id, nb_desc); in ionic_dev_tx_queue_setup()
172 if (tx_queue_id >= lif->ntxqcqs) { in ionic_dev_tx_queue_setup()
175 tx_queue_id, lif->ntxqcqs); in ionic_dev_tx_queue_setup()
186 if (eth_dev->data->tx_queues[tx_queue_id] != NULL) { in ionic_dev_tx_queue_setup()
187 void *tx_queue = eth_dev->data->tx_queues[tx_queue_id]; in ionic_dev_tx_queue_setup()
189 eth_dev->data->tx_queues[tx_queue_id] = NULL; in ionic_dev_tx_queue_setup()
203 eth_dev->data->tx_queues[tx_queue_id] = txq; in ionic_dev_tx_queue_setup()
219 txq = eth_dev->data->tx_queues[tx_queue_id]; in ionic_dev_tx_queue_start()
[all …]
/f-stack/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);
/f-stack/dpdk/drivers/event/octeontx2/
H A Dotx2_evdev_adptr.c443 uint16_t eth_port_id, uint16_t tx_queue_id, in sso_add_tx_queue_data() argument
472 )&dws->tx_adptr_data)[eth_port_id][tx_queue_id] = in sso_add_tx_queue_data()
496 )&ws->tx_adptr_data)[eth_port_id][tx_queue_id] = in sso_add_tx_queue_data()
508 int32_t tx_queue_id) in otx2_sso_tx_adapter_queue_add() argument
516 if (tx_queue_id < 0) { in otx2_sso_tx_adapter_queue_add()
528 txq = eth_dev->data->tx_queues[tx_queue_id]; in otx2_sso_tx_adapter_queue_add()
531 tx_queue_id, txq); in otx2_sso_tx_adapter_queue_add()
545 int32_t tx_queue_id) in otx2_sso_tx_adapter_queue_del() argument
553 if (tx_queue_id < 0) { in otx2_sso_tx_adapter_queue_del()
560 txq = eth_dev->data->tx_queues[tx_queue_id]; in otx2_sso_tx_adapter_queue_del()
/f-stack/dpdk/drivers/net/atlantic/
H A Datl_rxtx.c249 if (dev->data->tx_queues[tx_queue_id] != NULL) { in atl_tx_queue_setup()
250 atl_tx_queue_release(dev->data->tx_queues[tx_queue_id]); in atl_tx_queue_setup()
251 dev->data->tx_queues[tx_queue_id] = NULL; in atl_tx_queue_setup()
265 txq->queue_id = tx_queue_id; in atl_tx_queue_setup()
302 dev->data->tx_queues[tx_queue_id] = txq; in atl_tx_queue_setup()
538 if (tx_queue_id < dev->data->nb_tx_queues) { in atl_tx_queue_start()
539 hw_atl_b0_hw_ring_tx_start(hw, tx_queue_id); in atl_tx_queue_start()
542 hw_atl_b0_hw_tx_ring_tail_update(hw, 0, tx_queue_id); in atl_tx_queue_start()
543 dev->data->tx_queue_state[tx_queue_id] = in atl_tx_queue_start()
560 txq = dev->data->tx_queues[tx_queue_id]; in atl_tx_queue_stop()
[all …]
H A Datl_ethdev.h65 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);
/f-stack/dpdk/drivers/net/ice/
H A Dice_dcf_ethdev.c400 ice_dcf_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id) in ice_dcf_tx_queue_start() argument
407 if (tx_queue_id >= dev->data->nb_tx_queues) in ice_dcf_tx_queue_start()
410 txq = dev->data->tx_queues[tx_queue_id]; in ice_dcf_tx_queue_start()
413 txq->qtx_tail = hw->hw_addr + IAVF_QTX_TAIL1(tx_queue_id); in ice_dcf_tx_queue_start()
418 err = ice_dcf_switch_queue(&ad->real_hw, tx_queue_id, false, true); in ice_dcf_tx_queue_start()
422 tx_queue_id); in ice_dcf_tx_queue_start()
432 ice_dcf_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id) in ice_dcf_tx_queue_stop() argument
439 if (tx_queue_id >= dev->data->nb_tx_queues) in ice_dcf_tx_queue_stop()
442 err = ice_dcf_switch_queue(hw, tx_queue_id, false, false); in ice_dcf_tx_queue_stop()
445 tx_queue_id); in ice_dcf_tx_queue_stop()
[all …]
H A Dice_rxtx.h203 int ice_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
204 int ice_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
206 int ice_fdir_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
208 int ice_fdir_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
/f-stack/dpdk/drivers/net/axgbe/
H A Daxgbe_rxtx.h157 int axgbe_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
162 int axgbe_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
163 int axgbe_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
/f-stack/dpdk/lib/librte_eventdev/
H A Drte_event_eth_tx_adapter.c158 int32_t tx_queue_id);
244 uint16_t tx_queue_id) in txa_service_queue() argument
253 return likely(tqi != NULL) ? tqi + tx_queue_id : NULL; in txa_service_queue()
457 uint16_t tx_queue_id) in txa_service_is_queue_added() argument
713 int32_t tx_queue_id) in txa_service_queue_add() argument
724 if (tx_queue_id == -1) { in txa_service_queue_add()
764 if (txa_service_is_queue_added(txa, eth_dev, tx_queue_id)) { in txa_service_queue_add()
783 txa_retry->tx_queue = tx_queue_id; in txa_service_queue_add()
808 int32_t tx_queue_id) in txa_service_queue_del() argument
818 if (tx_queue_id == -1) { in txa_service_queue_del()
[all …]
/f-stack/dpdk/drivers/net/txgbe/
H A Dtxgbe_ethdev.h218 int txgbe_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
236 void txgbe_dev_save_tx_queue(struct txgbe_hw *hw, uint16_t tx_queue_id);
237 void txgbe_dev_store_tx_queue(struct txgbe_hw *hw, uint16_t tx_queue_id);
243 int txgbe_dev_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
245 int txgbe_dev_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
/f-stack/dpdk/drivers/net/bnxt/
H A Dbnxt_txr.h57 int bnxt_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id);
58 int bnxt_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id);
H A Dbnxt_txr.c527 int bnxt_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id) in bnxt_tx_queue_start() argument
530 struct bnxt_tx_queue *txq = bp->tx_queues[tx_queue_id]; in bnxt_tx_queue_start()
537 dev->data->tx_queue_state[tx_queue_id] = RTE_ETH_QUEUE_STATE_STARTED; in bnxt_tx_queue_start()
544 int bnxt_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id) in bnxt_tx_queue_stop() argument
547 struct bnxt_tx_queue *txq = bp->tx_queues[tx_queue_id]; in bnxt_tx_queue_stop()
557 dev->data->tx_queue_state[tx_queue_id] = RTE_ETH_QUEUE_STATE_STOPPED; in bnxt_tx_queue_stop()
/f-stack/dpdk/lib/librte_ethdev/
H A Drte_ethdev_trace.h59 RTE_TRACE_POINT_ARGS(uint16_t port_id, uint16_t tx_queue_id,
62 rte_trace_point_emit_u16(tx_queue_id);
H A Drte_ethdev.c930 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
938 tx_queue_id, port_id); in eth_dev_validate_tx_queue()
1045 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
1052 tx_queue_id, port_id); in rte_eth_dev_tx_queue_start()
1078 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
1085 tx_queue_id, port_id); in rte_eth_dev_tx_queue_stop()
2235 if (txq[tx_queue_id]) { in rte_eth_tx_queue_setup()
2239 txq[tx_queue_id] = NULL; in rte_eth_tx_queue_setup()
2338 if (txq[tx_queue_id] != NULL) { in rte_eth_tx_hairpin_queue_setup()
2342 txq[tx_queue_id] = NULL; in rte_eth_tx_hairpin_queue_setup()
[all …]
/f-stack/dpdk/drivers/net/virtio/
H A Dvirtio_ethdev.h73 int virtio_dev_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id,
78 uint16_t tx_queue_id);
/f-stack/dpdk/drivers/net/null/
H A Drte_eth_null.c243 eth_tx_queue_setup(struct rte_eth_dev *dev, uint16_t tx_queue_id, in eth_tx_queue_setup() argument
257 if (tx_queue_id >= dev->data->nb_tx_queues) in eth_tx_queue_setup()
262 dev->data->tx_queues[tx_queue_id] = in eth_tx_queue_setup()
263 &internals->tx_null_queues[tx_queue_id]; in eth_tx_queue_setup()
269 internals->tx_null_queues[tx_queue_id].internals = internals; in eth_tx_queue_setup()
270 internals->tx_null_queues[tx_queue_id].dummy_packet = dummy_packet; in eth_tx_queue_setup()
/f-stack/dpdk/drivers/net/sfc/
H A Dsfc_ethdev.c539 tx_queue_id, nb_tx_desc, socket_id); in sfc_tx_queue_setup()
547 dev->data->tx_queues[tx_queue_id] = sas->txq_info[tx_queue_id].dp; in sfc_tx_queue_setup()
1217 SFC_ASSERT(tx_queue_id < sas->txq_count); in sfc_tx_queue_info_get()
1219 txq_info = &sas->txq_info[tx_queue_id]; in sfc_tx_queue_info_get()
1355 sfc_log_init(sa, "TxQ = %u", tx_queue_id); in sfc_tx_queue_start()
1363 if (sas->txq_info[tx_queue_id].state != SFC_TXQ_INITIALIZED) in sfc_tx_queue_start()
1366 rc = sfc_tx_qstart(sa, tx_queue_id); in sfc_tx_queue_start()
1370 sas->txq_info[tx_queue_id].deferred_started = B_TRUE; in sfc_tx_queue_start()
1390 sfc_log_init(sa, "TxQ = %u", tx_queue_id); in sfc_tx_queue_stop()
1394 sfc_tx_qstop(sa, tx_queue_id); in sfc_tx_queue_stop()
[all …]
/f-stack/dpdk/examples/l3fwd/
H A Dl3fwd.h74 uint16_t tx_queue_id[RTE_MAX_ETHPORTS]; member
105 queueid = qconf->tx_queue_id[port]; in send_burst()
/f-stack/dpdk/drivers/net/failsafe/
H A Dfailsafe_ops.c308 fs_tx_queue_stop(struct rte_eth_dev *dev, uint16_t tx_queue_id) in fs_tx_queue_stop() argument
320 ret = rte_eth_dev_tx_queue_stop(port_id, tx_queue_id); in fs_tx_queue_stop()
336 fs_tx_queue_start(struct rte_eth_dev *dev, uint16_t tx_queue_id) in fs_tx_queue_start() argument
346 ret = rte_eth_dev_tx_queue_start(port_id, tx_queue_id); in fs_tx_queue_start()
350 fs_tx_queue_stop(dev, tx_queue_id); in fs_tx_queue_start()
571 uint16_t tx_queue_id, in fs_tx_queue_setup() argument
592 txq = dev->data->tx_queues[tx_queue_id]; in fs_tx_queue_setup()
595 dev->data->tx_queues[tx_queue_id] = NULL; in fs_tx_queue_setup()
607 txq->qid = tx_queue_id; in fs_tx_queue_setup()
612 dev->data->tx_queues[tx_queue_id] = txq; in fs_tx_queue_setup()
[all …]
/f-stack/dpdk/examples/bbdev_app/
H A Dmain.c139 unsigned int tx_queue_id; member
528 uint16_t tx_queue_id = 0; in lcore_conf_init() local
546 lconf->tx_queue_id = tx_queue_id++; in lcore_conf_init()
828 uint16_t port_id, tx_queue_id; in run_decoding() local
840 tx_queue_id = lcore_conf->tx_queue_id; in run_decoding()
914 nb_tx = rte_eth_tx_burst(port_id, tx_queue_id, recv_pkts_burst, nb_deq); in run_decoding()
/f-stack/dpdk/drivers/net/mvneta/
H A Dmvneta_rxtx.h18 void mvneta_txq_info_get(struct rte_eth_dev *dev, uint16_t tx_queue_id,
/f-stack/lib/
H A Dff_memory.h90 uint16_t tx_queue_id[RTE_MAX_ETHPORTS]; member

1234