Home
last modified time | relevance | path

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

12

/dpdk/app/test-pmd/
H A Dieee1588fwd.c105 if (rte_eth_rx_burst(fs->rx_port, fs->rx_queue, &mb, 1) == 0) in ieee1588_packet_fwd()
121 fs->rx_port); in ieee1588_packet_fwd()
125 fs->rx_port, eth_type, in ieee1588_packet_fwd()
134 fs->rx_port); in ieee1588_packet_fwd()
148 fs->rx_port, ptp_hdr->version); in ieee1588_packet_fwd()
155 fs->rx_port, ptp_hdr->msg_id); in ieee1588_packet_fwd()
160 fs->rx_port); in ieee1588_packet_fwd()
169 fs->rx_port); in ieee1588_packet_fwd()
178 port_ieee1588_rx_timestamp_check(fs->rx_port, timesync_index); in ieee1588_packet_fwd()
189 printf("Port %u sent PTP packet dropped\n", fs->rx_port); in ieee1588_packet_fwd()
[all …]
H A Dshared_rxq_fwd.c34 if (fsm[sm_id]->rx_port == port && in forward_stream_get()
101 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in shared_rxq_fwd()
H A Drxonly.c58 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
H A Dnoisy_vnf.c143 struct noisy_config *ncf = noisy_cfg[fs->rx_port]; in pkt_burst_noisy_vnf()
155 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_noisy_vnf()
H A Diofwd.c59 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_io_forward()
H A Dmacswap.c66 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_swap()
H A Dicmpecho.c302 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
320 fs->rx_port, pkt->pkt_len, pkt->nb_segs); in reply_to_icmp_echo_rqsts()
H A Dmacfwd.c65 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_forward()
H A Dcsumonly.c846 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_checksum_forward()
858 gro_enable = gro_ports[fs->rx_port].enable; in pkt_burst_checksum_forward()
1038 fs->rx_port, m, m->pkt_len, m->nb_segs); in pkt_burst_checksum_forward()
1088 &(gro_ports[fs->rx_port].param)); in pkt_burst_checksum_forward()
H A Dflowgen.c88 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_flow_gen()
H A D5tswap.c115 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_5tuple_swap()
H A Dconfig.c3872 port = &ports[fs->rx_port]; in fwd_stream_on_other_lcores()
3890 lc_id, fs->rx_port, fs->rx_queue); in fwd_stream_on_other_lcores()
3932 port = &ports[fs->rx_port]; in pkt_fwd_shared_rxq_check()
3942 fs->rx_port, in pkt_fwd_shared_rxq_check()
4108 fs->rx_port = fwd_ports_ids[rxp]; in rss_fwd_config_setup()
4223 fs->rx_port = fwd_ports_ids[rxp]; in dcb_fwd_config_setup()
4294 fs->rx_port = fwd_ports_ids[rxp]; in icmp_echo_config_setup()
4296 fs->tx_port = fs->rx_port; in icmp_echo_config_setup()
4302 sm_id, fs->rx_port, fs->rx_queue, in icmp_echo_config_setup()
4398 fs->rx_port, fs->rx_queue, in pkt_fwd_config_display()
[all …]
H A Dtestpmd.c1936 fwd_top_stats_border, fs->rx_port, fs->rx_queue, in fwd_stream_stats_display()
1998 ports_stats[fs->rx_port].rx_stream = fs; in fwd_stats_display()
2003 ports_stats[fs->rx_port].rx_bad_ip_csum += fs->rx_bad_ip_csum; in fwd_stats_display()
2004 ports_stats[fs->rx_port].rx_bad_l4_csum += fs->rx_bad_l4_csum; in fwd_stats_display()
2005 ports_stats[fs->rx_port].rx_bad_outer_l4_csum += in fwd_stats_display()
2007 ports_stats[fs->rx_port].rx_bad_outer_ip_csum += in fwd_stats_display()
/dpdk/drivers/net/mlx5/
H A Dmlx5_trigger.c740 if (mlx5_eth_find_next(rx_port, dev->device) != rx_port) { in mlx5_hairpin_bind_single_port()
765 if (conf->peers[0].port == rx_port) { in mlx5_hairpin_bind_single_port()
798 if (txq_ctrl->hairpin_conf.peers[0].port != rx_port) { in mlx5_hairpin_bind_single_port()
878 if (mlx5_eth_find_next(rx_port, dev->device) != rx_port) { in mlx5_hairpin_unbind_single_port()
899 if (cur_port != rx_port) { in mlx5_hairpin_unbind_single_port()
902 " auto-bind mode", cur_port, rx_port); in mlx5_hairpin_unbind_single_port()
914 rx_port, rx_queue); in mlx5_hairpin_unbind_single_port()
943 if (rx_port == RTE_MAX_ETHPORTS) { in mlx5_hairpin_bind()
951 return mlx5_hairpin_bind_single_port(dev, rx_port); in mlx5_hairpin_bind()
970 if (rx_port == RTE_MAX_ETHPORTS) in mlx5_hairpin_unbind()
[all …]
/dpdk/examples/qos_sched/
H A Dmain.c55 flow->rx_thread.rx_port = flow->rx_port; in app_main_loop()
101 i, lcore_id, rx_confs[i]->rx_port); in app_main_loop()
158 rte_eth_stats_get(flow->rx_port, &stats); in app_stat()
161 flow->rx_port, in app_stat()
H A Dargs.c221 pconf->rx_port = vals[0]; in app_parse_flow_conf()
235 if (pconf->rx_port >= RTE_MAX_ETHPORTS) { in app_parse_flow_conf()
237 nb_pfc, pconf->rx_port); in app_parse_flow_conf()
246 mask = 1lu << pconf->rx_port; in app_parse_flow_conf()
249 nb_pfc, pconf->rx_port); in app_parse_flow_conf()
H A Dmain.h82 uint16_t rx_port; member
101 uint16_t rx_port; member
H A Dinit.c415 rte_eth_dev_socket_id(qos_conf[i].rx_port)); in app_init()
419 app_init_port(qos_conf[i].rx_port, qos_conf[i].mbuf_pool); in app_init()
H A Dapp_thread.c76 nb_rx = rte_eth_rx_burst(conf->rx_port, conf->rx_queue, rx_mbufs, in app_rx_thread()
/dpdk/drivers/event/opdl/
H A Dopdl_test.c189 const uint8_t rx_port = 0; in ordered_basic() local
262 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in ordered_basic()
327 const uint8_t rx_port = 0; in atomic_basic() local
402 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in atomic_basic()
556 const uint8_t rx_port = 0; in single_link_w_stats() local
631 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in single_link_w_stats()
635 t->port[rx_port], in single_link_w_stats()
/dpdk/examples/ntb/
H A Dntb_fwd.c34 uint16_t rx_port; member
437 nb_rx = rte_eth_rx_burst(fs.rx_port, in start_iofwd_per_lcore()
458 ret = rte_rawdev_dequeue_buffers(fs.rx_port, in start_iofwd_per_lcore()
507 ret = rte_rawdev_dequeue_buffers(fs.rx_port, in start_rxonly_per_lcore()
619 fwd_streams[i * 2].rx_port = eth_port_id; in ntb_fwd_config_setup()
624 fwd_streams[i * 2 + 1].rx_port = dev_id; in ntb_fwd_config_setup()
641 fwd_streams[i].rx_port = dev_id; in ntb_fwd_config_setup()
654 fwd_streams[i].rx_port = RTE_MAX_ETHPORTS; in ntb_fwd_config_setup()
712 fs->tx_ntb ? "Eth" : "NTB", fs->rx_port, in assign_stream_to_lcores()
717 conf->stream_id, "NTB", fs->rx_port); in assign_stream_to_lcores()
/dpdk/app/test-flow-perf/
H A Dmain.c101 int rx_port; member
1693 do_rx(struct lcore_info *li, uint16_t rx_port, uint16_t rx_queue) in do_rx() argument
1696 cnt = rte_eth_rx_burst(rx_port, rx_queue, li->pkts, MAX_PKT_BURST); in do_rx()
1837 if (li->streams[stream_id].rx_port == -1) in start_forwarding()
1841 li->streams[stream_id].rx_port, in start_forwarding()
1878 lcore_infos[i].streams[j].rx_port = -1; in init_lcore_info()
1929 lcore_infos[lcore].streams[stream_id].rx_port = port; in init_lcore_info()
1944 lcore_infos[i].streams[j].rx_port, in init_lcore_info()
/dpdk/drivers/event/sw/
H A Dsw_evdev_selftest.c701 const uint32_t rx_port = 0; in burst_packets() local
718 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in burst_packets()
2630 const uint8_t rx_port = 0; in parallel_basic() local
2697 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in parallel_basic()
2785 unsigned int rx_port = 0; /* port we get the first flow on */ in holb() local
2816 rx_port = 1; in holb()
2819 "port_%u_cq_ring_used", rx_port); in holb()
2821 "port_%u_cq_ring_free", rx_port); in holb()
2823 "port_%u_cq_ring_used", rx_port ^ 1); in holb()
/dpdk/lib/ethdev/
H A Dethdev_driver.h908 uint16_t rx_port);
932 uint16_t rx_port);
H A Drte_ethdev.c2143 rte_eth_hairpin_bind(uint16_t tx_port, uint16_t rx_port) in rte_eth_hairpin_bind() argument
2157 ret = (*dev->dev_ops->hairpin_bind)(dev, rx_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
2181 ret = (*dev->dev_ops->hairpin_unbind)(dev, rx_port); in rte_eth_hairpin_unbind()
2185 tx_port, rx_port, RTE_MAX_ETHPORTS); in rte_eth_hairpin_unbind()

12