Home
last modified time | relevance | path

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

/dpdk/examples/qos_sched/
H A Dmain.c65 flow->tx_thread.tx_port = flow->tx_port; in app_main_loop()
76 flow->wt_thread.tx_port = flow->tx_port; in app_main_loop()
116 i, lcore_id, wt_confs[i]->tx_port); in app_main_loop()
130 i, lcore_id, tx_confs[i]->tx_port); in app_main_loop()
167 rte_eth_stats_get(flow->tx_port, &stats); in app_stat()
169 flow->tx_port, in app_stat()
H A Dstats.c21 if (qos_conf[i].tx_port == port_id) in qavg_q()
67 if (qos_conf[i].tx_port == port_id) in qavg_tcpipe()
122 if (qos_conf[i].tx_port == port_id) in qavg_pipe()
169 if (qos_conf[i].tx_port == port_id) in qavg_tcsubport()
239 if (qos_conf[i].tx_port == port_id) in qavg_subport()
292 if (qos_conf[i].tx_port == port_id) in subport_stat()
330 if (qos_conf[i].tx_port == port_id) in pipe_stat()
H A Dargs.c222 pconf->tx_port = vals[1]; in app_parse_flow_conf()
240 if (pconf->tx_port >= RTE_MAX_ETHPORTS) { in app_parse_flow_conf()
242 nb_pfc, pconf->tx_port); in app_parse_flow_conf()
255 mask = 1lu << pconf->tx_port; in app_parse_flow_conf()
258 nb_pfc, pconf->tx_port); in app_parse_flow_conf()
H A Dmain.h83 uint16_t tx_port; member
102 uint16_t tx_port; member
H A Dinit.c420 app_init_port(qos_conf[i].tx_port, qos_conf[i].mbuf_pool); in app_init()
422 qos_conf[i].sched_port = app_init_sched_port(qos_conf[i].tx_port, socket); in app_init()
H A Dapp_thread.c124 ret = rte_eth_tx_burst(qconf->tx_port, qconf->tx_queue, mbufs, (uint16_t)n); in app_send_burst()
/dpdk/drivers/event/opdl/
H A Dopdl_test.c192 const uint8_t tx_port = 4; in ordered_basic() local
201 if (init(t, 2, tx_port+1) < 0 || in ordered_basic()
312 __LINE__, deq_pkts, tx_port); in ordered_basic()
330 const uint8_t tx_port = 4; in atomic_basic() local
338 if (init(t, 2, tx_port+1) < 0 || in atomic_basic()
463 __LINE__, deq_pkts, tx_port); in atomic_basic()
558 const uint8_t tx_port = 2; in single_link_w_stats() local
671 t->port[tx_port], in single_link_w_stats()
679 __LINE__, deq_pkts, tx_port); in single_link_w_stats()
698 const uint8_t tx_port = 2; in single_link() local
[all …]
/dpdk/app/test-pmd/
H A Dmacfwd.c72 txp = &ports[fs->tx_port]; in pkt_burst_mac_forward()
88 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in pkt_burst_mac_forward()
97 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_forward()
105 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_forward()
H A Dflowgen.c97 vlan_tci = ports[fs->tx_port].tx_vlan_id; in pkt_burst_flow_gen()
98 vlan_tci_outer = ports[fs->tx_port].tx_vlan_id_outer; in pkt_burst_flow_gen()
100 tx_offloads = ports[fs->tx_port].dev_conf.txmode.offloads; in pkt_burst_flow_gen()
170 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
178 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_flow_gen()
H A Dmacswap.c73 txp = &ports[fs->tx_port]; in pkt_burst_mac_swap()
77 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_swap()
85 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_swap()
H A Dtxonly.c270 ret = eth_dev_info_get_print_err(fs->tx_port, &dev_info); in pkt_burst_prepare()
275 fs->tx_port); in pkt_burst_prepare()
285 skew = timestamp_initial[fs->tx_port] + in pkt_burst_prepare()
346 txp = &ports[fs->tx_port]; in pkt_burst_transmit()
361 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, &eth_hdr.src_addr); in pkt_burst_transmit()
398 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_transmit()
407 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_transmit()
421 fs->tx_port, fs->tx_queue, in pkt_burst_transmit()
H A Dnoisy_vnf.c103 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in do_retry()
164 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
187 nb_tx = rte_eth_tx_burst(fs->tx_port, in pkt_burst_noisy_vnf()
213 sent = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
H A Diofwd.c66 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
75 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
H A D5tswap.c122 txp = &ports[fs->tx_port]; in pkt_burst_5tuple_swap()
165 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_5tuple_swap()
173 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_5tuple_swap()
H A Dicmpecho.c389 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in reply_to_icmp_echo_rqsts()
486 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
496 nb_tx += rte_eth_tx_burst(fs->tx_port, in reply_to_icmp_echo_rqsts()
H A Dcsumonly.c861 txp = &ports[fs->tx_port]; in pkt_burst_checksum_forward()
867 if (gso_ports[fs->tx_port].enable) in pkt_burst_checksum_forward()
899 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in pkt_burst_checksum_forward()
1109 if (gso_ports[fs->tx_port].enable != 0) { in pkt_burst_checksum_forward()
1142 nb_prep = rte_eth_tx_prepare(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
1149 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, tx_pkts_burst, in pkt_burst_checksum_forward()
1159 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
H A Dconfig.c4048 fwd_streams[i]->tx_port = in simple_fwd_config_setup()
4051 fwd_streams[i]->peer_addr = fwd_streams[i]->tx_port; in simple_fwd_config_setup()
4110 fs->tx_port = fwd_ports_ids[txp]; in rss_fwd_config_setup()
4112 fs->peer_addr = fs->tx_port; in rss_fwd_config_setup()
4225 fs->tx_port = fwd_ports_ids[txp]; in dcb_fwd_config_setup()
4227 fs->peer_addr = fs->tx_port; in dcb_fwd_config_setup()
4296 fs->tx_port = fs->rx_port; in icmp_echo_config_setup()
4298 fs->peer_addr = fs->tx_port; in icmp_echo_config_setup()
4400 fs->tx_port, fs->tx_queue, in pkt_fwd_config_display()
4401 ports[fs->tx_port].socket_id); in pkt_fwd_config_display()
H A Dtestpmd.c1937 fs->tx_port, fs->tx_queue, fwd_top_stats_border); in fwd_stream_stats_display()
1997 ports_stats[fs->tx_port].tx_stream = fs; in fwd_stats_display()
2001 ports_stats[fs->tx_port].tx_dropped += fs->fwd_dropped; in fwd_stats_display()
H A Dtestpmd.h134 portid_t tx_port; /**< forwarding port of received packets */ member
/dpdk/examples/ntb/
H A Dntb_fwd.c33 uint16_t tx_port; member
444 ret = rte_rawdev_enqueue_buffers(fs.tx_port, in start_iofwd_per_lcore()
471 nb_tx = rte_eth_tx_burst(fs.tx_port, in start_iofwd_per_lcore()
576 ret = rte_rawdev_enqueue_buffers(fs.tx_port, ntb_buf, in start_txonly_per_lcore()
618 fwd_streams[i * 2].tx_port = dev_id; in ntb_fwd_config_setup()
623 fwd_streams[i * 2 + 1].tx_port = eth_port_id; in ntb_fwd_config_setup()
640 fwd_streams[i].tx_port = RTE_MAX_ETHPORTS; in ntb_fwd_config_setup()
653 fwd_streams[i].tx_port = dev_id; in ntb_fwd_config_setup()
713 fs->tx_ntb ? "NTB" : "Eth", fs->tx_port, in assign_stream_to_lcores()
720 conf->stream_id, "NTB", fs->tx_port); in assign_stream_to_lcores()
/dpdk/app/test-flow-perf/
H A Dmain.c99 int tx_port; member
1702 do_tx(struct lcore_info *li, uint16_t cnt, uint16_t tx_port, in do_tx() argument
1708 nr_tx = rte_eth_tx_burst(tx_port, tx_queue, li->pkts, cnt); in do_tx()
1845 li->streams[stream_id].tx_port, in start_forwarding()
1877 lcore_infos[i].streams[j].tx_port = -1; in init_lcore_info()
1930 lcore_infos[lcore].streams[stream_id].tx_port = port; in init_lcore_info()
1940 if (lcore_infos[i].streams[j].tx_port == -1) in init_lcore_info()
1946 lcore_infos[i].streams[j].tx_port, in init_lcore_info()
/dpdk/doc/guides/prog_guide/
H A Devent_ethernet_tx_adapter.rst142 m->port = tx_port;
154 m->port = tx_port;
/dpdk/drivers/event/sw/
H A Dsw_evdev_selftest.c2633 const uint8_t tx_port = 4; in parallel_basic() local
2642 if (init(t, 2, tx_port + 1) < 0 || in parallel_basic()
2643 create_ports(t, tx_port + 1) < 0 || in parallel_basic()
2646 create_directed_qids(t, 1, &tx_port)) { in parallel_basic()
2735 deq_pkts = rte_event_dequeue_burst(evdev, t->port[tx_port], deq_ev, in parallel_basic()
2741 __LINE__, deq_pkts, tx_port); in parallel_basic()
2754 tx_port); in parallel_basic()
/dpdk/lib/ethdev/
H A Drte_ethdev.c2143 rte_eth_hairpin_bind(uint16_t tx_port, uint16_t rx_port) in rte_eth_hairpin_bind() argument
2148 RTE_ETH_VALID_PORTID_OR_ERR_RET(tx_port, -ENODEV); in rte_eth_hairpin_bind()
2149 dev = &rte_eth_devices[tx_port]; in rte_eth_hairpin_bind()
2152 RTE_ETHDEV_LOG(ERR, "Tx port %d is not started\n", tx_port); in rte_eth_hairpin_bind()
2161 tx_port, rx_port, RTE_MAX_ETHPORTS); in rte_eth_hairpin_bind()
2167 rte_eth_hairpin_unbind(uint16_t tx_port, uint16_t rx_port) in rte_eth_hairpin_unbind() argument
2172 RTE_ETH_VALID_PORTID_OR_ERR_RET(tx_port, -ENODEV); in rte_eth_hairpin_unbind()
2173 dev = &rte_eth_devices[tx_port]; in rte_eth_hairpin_unbind()
2176 RTE_ETHDEV_LOG(ERR, "Tx port %d is already stopped\n", tx_port); in rte_eth_hairpin_unbind()
2185 tx_port, rx_port, RTE_MAX_ETHPORTS); in rte_eth_hairpin_unbind()
H A Drte_ethdev.h2711 int rte_eth_hairpin_bind(uint16_t tx_port, uint16_t rx_port);
2738 int rte_eth_hairpin_unbind(uint16_t tx_port, uint16_t rx_port);