Home
last modified time | relevance | path

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

12

/f-stack/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 Drxonly.c59 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
H A Diofwd.c60 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_io_forward()
H A Dmacswap.c67 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_swap()
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 Dicmpecho.c303 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
321 fs->rx_port, pkt->pkt_len, pkt->nb_segs); in reply_to_icmp_echo_rqsts()
H A Dmacfwd.c66 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_forward()
H A Dflowgen.c106 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_flow_gen()
H A Dcsumonly.c826 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_checksum_forward()
836 gro_enable = gro_ports[fs->rx_port].enable; in pkt_burst_checksum_forward()
1006 fs->rx_port, m, m->pkt_len, m->nb_segs); in pkt_burst_checksum_forward()
1055 &(gro_ports[fs->rx_port].param)); in pkt_burst_checksum_forward()
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 Dtestpmd.c1788 fwd_top_stats_border, fs->rx_port, fs->rx_queue, in fwd_stream_stats_display()
1846 ports_stats[fs->rx_port].rx_stream = fs; in fwd_stats_display()
1851 ports_stats[fs->rx_port].rx_bad_ip_csum += fs->rx_bad_ip_csum; in fwd_stats_display()
1852 ports_stats[fs->rx_port].rx_bad_l4_csum += fs->rx_bad_l4_csum; in fwd_stats_display()
1853 ports_stats[fs->rx_port].rx_bad_outer_l4_csum += in fwd_stats_display()
H A Dconfig.c3164 fwd_streams[i]->rx_port = fwd_ports_ids[i]; in simple_fwd_config_setup()
3210 fs->rx_port = fwd_ports_ids[rxp]; in rss_fwd_config_setup()
3277 fs->rx_port = fwd_ports_ids[rxp]; in dcb_fwd_config_setup()
3348 fs->rx_port = fwd_ports_ids[rxp]; in icmp_echo_config_setup()
3350 fs->tx_port = fs->rx_port; in icmp_echo_config_setup()
3356 sm_id, fs->rx_port, fs->rx_queue, in icmp_echo_config_setup()
3433 fs->rx_port, fs->rx_queue, in pkt_fwd_config_display()
3434 ports[fs->rx_port].socket_id, in pkt_fwd_config_display()
/f-stack/dpdk/drivers/net/mlx5/
H A Dmlx5_trigger.c698 if (mlx5_eth_find_next(rx_port, priv->pci_dev) != rx_port) { in mlx5_hairpin_bind_single_port()
723 if (conf->peers[0].port == rx_port) { in mlx5_hairpin_bind_single_port()
756 if (txq_ctrl->hairpin_conf.peers[0].port != rx_port) { in mlx5_hairpin_bind_single_port()
836 if (mlx5_eth_find_next(rx_port, priv->pci_dev) != rx_port) { in mlx5_hairpin_unbind_single_port()
857 if (cur_port != rx_port) { in mlx5_hairpin_unbind_single_port()
860 " auto-bind mode", cur_port, rx_port); in mlx5_hairpin_unbind_single_port()
872 rx_port, rx_queue); in mlx5_hairpin_unbind_single_port()
902 if (rx_port == RTE_MAX_ETHPORTS) { in mlx5_hairpin_bind()
910 return mlx5_hairpin_bind_single_port(dev, rx_port); in mlx5_hairpin_bind()
930 if (rx_port == RTE_MAX_ETHPORTS) in mlx5_hairpin_unbind()
[all …]
H A Dmlx5.h1184 int mlx5_hairpin_bind(struct rte_eth_dev *dev, uint16_t rx_port);
1185 int mlx5_hairpin_unbind(struct rte_eth_dev *dev, uint16_t rx_port);
/f-stack/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.c225 pconf->rx_port = vals[0]; in app_parse_flow_conf()
239 if (pconf->rx_port >= RTE_MAX_ETHPORTS) { in app_parse_flow_conf()
241 nb_pfc, pconf->rx_port); in app_parse_flow_conf()
250 mask = 1lu << pconf->rx_port; in app_parse_flow_conf()
253 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.c411 rte_eth_dev_socket_id(qos_conf[i].rx_port)); in app_init()
415 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()
/f-stack/freebsd/contrib/ncsw/Peripherals/FM/Port/
H A Dfman_port.c780 bool rx_port; in fman_port_enable() local
786 rx_port = TRUE; in fman_port_enable()
791 rx_port = FALSE; in fman_port_enable()
796 rx_port = FALSE; in fman_port_enable()
803 if (!rx_port) { in fman_port_enable()
826 rx_port = TRUE; in fman_port_disable()
832 rx_port = FALSE; in fman_port_disable()
845 if (!rx_port) { in fman_port_disable()
897 rx_port = TRUE; in fman_port_set_bpools()
913 if (rx_port) { in fman_port_set_bpools()
[all …]
/f-stack/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()
/f-stack/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()
/f-stack/dpdk/app/test-flow-perf/
H A Dmain.c80 int rx_port; member
1026 do_rx(struct lcore_info *li, uint16_t rx_port, uint16_t rx_queue) in do_rx() argument
1029 cnt = rte_eth_rx_burst(rx_port, rx_queue, li->pkts, MAX_PKT_BURST); in do_rx()
1170 if (li->streams[stream_id].rx_port == -1) in start_forwarding()
1174 li->streams[stream_id].rx_port, in start_forwarding()
1211 lcore_infos[i].streams[j].rx_port = -1; in init_lcore_info()
1262 lcore_infos[lcore].streams[stream_id].rx_port = port; in init_lcore_info()
1277 lcore_infos[i].streams[j].rx_port, in init_lcore_info()
/f-stack/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()
2628 const uint8_t rx_port = 0; in parallel_basic() local
2695 err = rte_event_enqueue_burst(evdev, t->port[rx_port], &ev, 1); in parallel_basic()
2783 unsigned int rx_port = 0; /* port we get the first flow on */ in holb() local
2814 rx_port = 1; in holb()
2817 "port_%u_cq_ring_used", rx_port); in holb()
2819 "port_%u_cq_ring_free", rx_port); in holb()
2821 "port_%u_cq_ring_used", rx_port ^ 1); in holb()
/f-stack/dpdk/lib/librte_ethdev/
H A Drte_ethdev_driver.h725 uint16_t rx_port);
749 uint16_t rx_port);

12