Home
last modified time | relevance | path

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

12

/f-stack/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.c226 pconf->tx_port = vals[1]; in app_parse_flow_conf()
244 if (pconf->tx_port >= RTE_MAX_ETHPORTS) { in app_parse_flow_conf()
246 nb_pfc, pconf->tx_port); in app_parse_flow_conf()
259 mask = 1lu << pconf->tx_port; in app_parse_flow_conf()
262 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.c416 app_init_port(qos_conf[i].tx_port, qos_conf[i].mbuf_pool); in app_init()
418 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()
/f-stack/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 …]
/f-stack/dpdk/app/test-pmd/
H A Dmacfwd.c73 txp = &ports[fs->tx_port]; in pkt_burst_mac_forward()
89 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in pkt_burst_mac_forward()
98 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_forward()
106 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_forward()
H A Dflowgen.c114 vlan_tci = ports[fs->tx_port].tx_vlan_id; in pkt_burst_flow_gen()
115 vlan_tci_outer = ports[fs->tx_port].tx_vlan_id_outer; in pkt_burst_flow_gen()
117 tx_offloads = ports[fs->tx_port].dev_conf.txmode.offloads; in pkt_burst_flow_gen()
177 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
185 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_flow_gen()
H A Dmacswap.c74 txp = &ports[fs->tx_port]; in pkt_burst_mac_swap()
78 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_swap()
86 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_swap()
H A Dtxonly.c269 struct rte_eth_dev *dev = &rte_eth_devices[fs->tx_port]; in pkt_burst_prepare()
277 skew = timestamp_initial[fs->tx_port] + in pkt_burst_prepare()
339 txp = &ports[fs->tx_port]; in pkt_burst_transmit()
354 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, &eth_hdr.s_addr); in pkt_burst_transmit()
391 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_transmit()
400 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_transmit()
414 fs->tx_port, fs->tx_queue, in pkt_burst_transmit()
H A Diofwd.c67 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
76 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
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 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.c390 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in reply_to_icmp_echo_rqsts()
487 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
497 nb_tx += rte_eth_tx_burst(fs->tx_port, in reply_to_icmp_echo_rqsts()
H A Dcsumonly.c838 txp = &ports[fs->tx_port]; in pkt_burst_checksum_forward()
843 if (gso_ports[fs->tx_port].enable) in pkt_burst_checksum_forward()
872 rte_ether_addr_copy(&ports[fs->tx_port].eth_addr, in pkt_burst_checksum_forward()
1074 if (gso_ports[fs->tx_port].enable == 0) in pkt_burst_checksum_forward()
1103 nb_prep = rte_eth_tx_prepare(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
1109 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, tx_pkts_burst, in pkt_burst_checksum_forward()
1119 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
H A Dconfig.c3166 fwd_streams[i]->tx_port = in simple_fwd_config_setup()
3169 fwd_streams[i]->peer_addr = fwd_streams[i]->tx_port; in simple_fwd_config_setup()
3212 fs->tx_port = fwd_ports_ids[txp]; in rss_fwd_config_setup()
3214 fs->peer_addr = fs->tx_port; in rss_fwd_config_setup()
3279 fs->tx_port = fwd_ports_ids[txp]; in dcb_fwd_config_setup()
3281 fs->peer_addr = fs->tx_port; in dcb_fwd_config_setup()
3350 fs->tx_port = fs->rx_port; in icmp_echo_config_setup()
3352 fs->peer_addr = fs->tx_port; in icmp_echo_config_setup()
3435 fs->tx_port, fs->tx_queue, in pkt_fwd_config_display()
3436 ports[fs->tx_port].socket_id); in pkt_fwd_config_display()
H A Dtestpmd.c1789 fs->tx_port, fs->tx_queue, fwd_top_stats_border); in fwd_stream_stats_display()
1845 ports_stats[fs->tx_port].tx_stream = fs; in fwd_stats_display()
1849 ports_stats[fs->tx_port].tx_dropped += fs->fwd_dropped; in fwd_stats_display()
H A Dtestpmd.h126 portid_t tx_port; /**< forwarding port of received packets */ member
/f-stack/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()
/f-stack/dpdk/app/test-flow-perf/
H A Dmain.c78 int tx_port; member
1035 do_tx(struct lcore_info *li, uint16_t cnt, uint16_t tx_port, in do_tx() argument
1041 nr_tx = rte_eth_tx_burst(tx_port, tx_queue, li->pkts, cnt); in do_tx()
1178 li->streams[stream_id].tx_port, in start_forwarding()
1210 lcore_infos[i].streams[j].tx_port = -1; in init_lcore_info()
1263 lcore_infos[lcore].streams[stream_id].tx_port = port; in init_lcore_info()
1273 if (lcore_infos[i].streams[j].tx_port == -1) in init_lcore_info()
1279 lcore_infos[i].streams[j].tx_port, in init_lcore_info()
/f-stack/dpdk/doc/guides/prog_guide/
H A Devent_ethernet_tx_adapter.rst142 m->port = tx_port;
154 m->port = tx_port;
/f-stack/dpdk/drivers/event/sw/
H A Dsw_evdev_selftest.c2631 const uint8_t tx_port = 4; in parallel_basic() local
2640 if (init(t, 2, tx_port + 1) < 0 || in parallel_basic()
2641 create_ports(t, tx_port + 1) < 0 || in parallel_basic()
2644 create_directed_qids(t, 1, &tx_port)) { in parallel_basic()
2733 deq_pkts = rte_event_dequeue_burst(evdev, t->port[tx_port], deq_ev, in parallel_basic()
2739 __LINE__, deq_pkts, tx_port); in parallel_basic()
2752 tx_port); in parallel_basic()
/f-stack/dpdk/lib/librte_ethdev/
H A Drte_ethdev.c2353 rte_eth_hairpin_bind(uint16_t tx_port, uint16_t rx_port) in rte_eth_hairpin_bind() argument
2358 RTE_ETH_VALID_PORTID_OR_ERR_RET(tx_port, -ENODEV); in rte_eth_hairpin_bind()
2359 dev = &rte_eth_devices[tx_port]; in rte_eth_hairpin_bind()
2361 RTE_ETHDEV_LOG(ERR, "Tx port %d is not started\n", tx_port); in rte_eth_hairpin_bind()
2370 tx_port, rx_port, RTE_MAX_ETHPORTS); in rte_eth_hairpin_bind()
2376 rte_eth_hairpin_unbind(uint16_t tx_port, uint16_t rx_port) in rte_eth_hairpin_unbind() argument
2381 RTE_ETH_VALID_PORTID_OR_ERR_RET(tx_port, -ENODEV); in rte_eth_hairpin_unbind()
2382 dev = &rte_eth_devices[tx_port]; in rte_eth_hairpin_unbind()
2384 RTE_ETHDEV_LOG(ERR, "Tx port %d is already stopped\n", tx_port); in rte_eth_hairpin_unbind()
2393 tx_port, rx_port, RTE_MAX_ETHPORTS); in rte_eth_hairpin_unbind()
H A Drte_ethdev.h2353 int rte_eth_hairpin_bind(uint16_t tx_port, uint16_t rx_port);
2380 int rte_eth_hairpin_unbind(uint16_t tx_port, uint16_t rx_port);

12