Lines Matching refs:pi
522 static void setup_attached_port(portid_t pi);
523 static void map_port_queue_stats_mapping_registers(portid_t pi,
1104 portid_t pi; in get_allowed_max_nb_rxq() local
1107 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_max_nb_rxq()
1108 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_max_nb_rxq()
1114 *pid = pi; in get_allowed_max_nb_rxq()
1154 portid_t pi; in get_allowed_max_nb_txq() local
1157 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_max_nb_txq()
1158 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_max_nb_txq()
1164 *pid = pi; in get_allowed_max_nb_txq()
1203 portid_t pi; in get_allowed_max_nb_rxd() local
1206 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_max_nb_rxd()
1207 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_max_nb_rxd()
1212 *pid = pi; in get_allowed_max_nb_rxd()
1227 portid_t pi; in get_allowed_min_nb_rxd() local
1230 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_min_nb_rxd()
1231 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_min_nb_rxd()
1236 *pid = pi; in get_allowed_min_nb_rxd()
1289 portid_t pi; in get_allowed_max_nb_txd() local
1292 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_max_nb_txd()
1293 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_max_nb_txd()
1298 *pid = pi; in get_allowed_max_nb_txd()
1313 portid_t pi; in get_allowed_min_nb_txd() local
1316 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_min_nb_txd()
1317 if (eth_dev_info_get_print_err(pi, &dev_info) != 0) in get_allowed_min_nb_txd()
1322 *pid = pi; in get_allowed_min_nb_txd()
1374 portid_t pi; in get_allowed_max_nb_hairpinq() local
1377 RTE_ETH_FOREACH_DEV(pi) { in get_allowed_max_nb_hairpinq()
1378 if (rte_eth_dev_hairpin_capability_get(pi, &cap) != 0) { in get_allowed_max_nb_hairpinq()
1379 *pid = pi; in get_allowed_max_nb_hairpinq()
1384 *pid = pi; in get_allowed_max_nb_hairpinq()
2312 portid_t pi; in all_ports_started() local
2315 RTE_ETH_FOREACH_DEV(pi) { in all_ports_started()
2316 port = &ports[pi]; in all_ports_started()
2341 portid_t pi; in all_ports_stopped() local
2343 RTE_ETH_FOREACH_DEV(pi) { in all_ports_stopped()
2344 if (!port_is_stopped(pi)) in all_ports_stopped()
2365 setup_hairpin_queues(portid_t pi, portid_t p_pi, uint16_t cnt_pi) in setup_hairpin_queues() argument
2373 struct rte_port *port = &ports[pi]; in setup_hairpin_queues()
2374 uint16_t peer_rx_port = pi; in setup_hairpin_queues()
2375 uint16_t peer_tx_port = pi; in setup_hairpin_queues()
2380 peer_rx_port = pi; in setup_hairpin_queues()
2381 peer_tx_port = pi; in setup_hairpin_queues()
2384 peer_tx_port = rte_eth_find_next_owned_by(pi + 1, in setup_hairpin_queues()
2403 peer_rx_port = rte_eth_find_next_owned_by(pi + 1, in setup_hairpin_queues()
2406 peer_rx_port = pi; in setup_hairpin_queues()
2418 (pi, qi, nb_txd, &hairpin_conf); in setup_hairpin_queues()
2428 "to stopped\n", pi); in setup_hairpin_queues()
2430 "queues\n", pi); in setup_hairpin_queues()
2441 (pi, qi, nb_rxd, &hairpin_conf); in setup_hairpin_queues()
2451 "to stopped\n", pi); in setup_hairpin_queues()
2453 "queues\n", pi); in setup_hairpin_queues()
2510 portid_t pi; in start_port() local
2527 RTE_ETH_FOREACH_DEV(pi) { in start_port()
2528 if (pid != pi && pid != (portid_t)RTE_PORT_ALL) in start_port()
2532 port = &ports[pi]; in start_port()
2535 printf("Port %d is now not stopped\n", pi); in start_port()
2543 int ret = port_flow_isolate(pi, 1); in start_port()
2546 " mode on port %d\n", pi); in start_port()
2551 printf("Configuring Port %d (socket %u)\n", pi, in start_port()
2554 rte_eth_dev_hairpin_capability_get(pi, &cap)) { in start_port()
2556 "queues\n", pi); in start_port()
2560 diag = rte_eth_dev_configure(pi, nb_rxq + nb_hairpinq, in start_port()
2567 "to stopped\n", pi); in start_port()
2568 printf("Fail to configure port %d\n", pi); in start_port()
2579 (txring_numa[pi] != NUMA_NO_CONFIG)) in start_port()
2580 diag = rte_eth_tx_queue_setup(pi, qi, in start_port()
2582 txring_numa[pi], in start_port()
2585 diag = rte_eth_tx_queue_setup(pi, qi, in start_port()
2598 "to stopped\n", pi); in start_port()
2600 pi); in start_port()
2608 (rxring_numa[pi] != NUMA_NO_CONFIG)) { in start_port()
2611 (rxring_numa[pi], 0); in start_port()
2616 rxring_numa[pi]); in start_port()
2620 diag = rx_queue_setup(pi, qi, in start_port()
2622 rxring_numa[pi], in start_port()
2636 diag = rx_queue_setup(pi, qi, in start_port()
2650 "to stopped\n", pi); in start_port()
2652 pi); in start_port()
2658 if (setup_hairpin_queues(pi, p_pi, cnt_pi) != 0) in start_port()
2663 diag = rte_eth_dev_set_ptypes(pi, RTE_PTYPE_UNKNOWN, in start_port()
2668 pi); in start_port()
2671 p_pi = pi; in start_port()
2675 if (rte_eth_dev_start(pi) < 0) { in start_port()
2676 printf("Fail to start port %d\n", pi); in start_port()
2682 "stopped\n", pi); in start_port()
2688 printf("Port %d can not be set into started\n", pi); in start_port()
2690 if (eth_macaddr_get_print_err(pi, &mac_addr) == 0) in start_port()
2691 printf("Port %d: %02X:%02X:%02X:%02X:%02X:%02X\n", pi, in start_port()
2699 pl[cfg_pi++] = pi; in start_port()
2713 pi = pl[i]; in start_port()
2715 peer_pi = rte_eth_hairpin_get_peer_ports(pi, peer_pl, in start_port()
2722 diag = rte_eth_hairpin_bind(pi, peer_pl[j]); in start_port()
2726 pi, peer_pl[j], in start_port()
2732 peer_pi = rte_eth_hairpin_get_peer_ports(pi, peer_pl, in start_port()
2739 diag = rte_eth_hairpin_bind(peer_pl[j], pi); in start_port()
2743 peer_pl[j], pi, in start_port()
2758 portid_t pi; in stop_port() local
2774 RTE_ETH_FOREACH_DEV(pi) { in stop_port()
2775 if (pid != pi && pid != (portid_t)RTE_PORT_ALL) in stop_port()
2778 if (port_is_forwarding(pi) != 0 && test_done == 0) { in stop_port()
2779 printf("Please remove port %d from forwarding configuration.\n", pi); in stop_port()
2783 if (port_is_bonding_slave(pi)) { in stop_port()
2784 printf("Please remove port %d from bonded device.\n", pi); in stop_port()
2788 port = &ports[pi]; in stop_port()
2796 rte_eth_hairpin_unbind(pi, RTE_MAX_ETHPORTS); in stop_port()
2798 peer_pi = rte_eth_hairpin_get_peer_ports(pi, peer_pl, in stop_port()
2805 rte_eth_hairpin_unbind(peer_pl[j], pi); in stop_port()
2809 if (rte_eth_dev_stop(pi) != 0) in stop_port()
2811 pi); in stop_port()
2815 printf("Port %d can not be set into stopped\n", pi); in stop_port()
2849 portid_t pi; in close_port() local
2857 RTE_ETH_FOREACH_DEV(pi) { in close_port()
2858 if (pid != pi && pid != (portid_t)RTE_PORT_ALL) in close_port()
2861 if (port_is_forwarding(pi) != 0 && test_done == 0) { in close_port()
2862 printf("Please remove port %d from forwarding configuration.\n", pi); in close_port()
2866 if (port_is_bonding_slave(pi)) { in close_port()
2867 printf("Please remove port %d from bonded device.\n", pi); in close_port()
2871 port = &ports[pi]; in close_port()
2874 printf("Port %d is already closed\n", pi); in close_port()
2878 port_flow_flush(pi); in close_port()
2879 rte_eth_dev_close(pi); in close_port()
2890 portid_t pi; in reset_port() local
2904 RTE_ETH_FOREACH_DEV(pi) { in reset_port()
2905 if (pid != pi && pid != (portid_t)RTE_PORT_ALL) in reset_port()
2908 if (port_is_forwarding(pi) != 0 && test_done == 0) { in reset_port()
2910 "configuration.\n", pi); in reset_port()
2914 if (port_is_bonding_slave(pi)) { in reset_port()
2916 pi); in reset_port()
2920 diag = rte_eth_dev_reset(pi); in reset_port()
2922 port = &ports[pi]; in reset_port()
2926 printf("Failed to reset port %d. diag=%d\n", pi, diag); in reset_port()
2936 portid_t pi; in attach_port() local
2954 for (pi = 0; pi < RTE_MAX_ETHPORTS; pi++) in attach_port()
2955 if (ports[pi].port_status == RTE_PORT_HANDLING && in attach_port()
2956 ports[pi].need_setup != 0) in attach_port()
2957 setup_attached_port(pi); in attach_port()
2962 RTE_ETH_FOREACH_MATCHING_DEV(pi, identifier, &iterator) { in attach_port()
2964 if (port_is_forwarding(pi)) in attach_port()
2966 setup_attached_port(pi); in attach_port()
2971 setup_attached_port(portid_t pi) in setup_attached_port() argument
2976 socket_id = (unsigned)rte_eth_dev_socket_id(pi); in setup_attached_port()
2980 reconfig(pi, socket_id); in setup_attached_port()
2981 ret = rte_eth_promiscuous_enable(pi); in setup_attached_port()
2984 pi, rte_strerror(-ret)); in setup_attached_port()
2986 ports_ids[nb_ports++] = pi; in setup_attached_port()
2987 fwd_ports_ids[nb_fwd_ports++] = pi; in setup_attached_port()
2989 ports[pi].need_setup = 0; in setup_attached_port()
2990 ports[pi].port_status = RTE_PORT_STOPPED; in setup_attached_port()
2992 printf("Port %d is attached. Now total ports is %d\n", pi, nb_ports); in setup_attached_port()
3402 map_port_queue_stats_mapping_registers(portid_t pi, struct rte_port *port) in map_port_queue_stats_mapping_registers() argument
3406 diag = set_tx_queue_stats_mapping_registers(pi, port); in map_port_queue_stats_mapping_registers()
3410 printf("TX queue stats mapping not supported port id=%d\n", pi); in map_port_queue_stats_mapping_registers()
3416 pi, diag); in map_port_queue_stats_mapping_registers()
3419 diag = set_rx_queue_stats_mapping_registers(pi, port); in map_port_queue_stats_mapping_registers()
3423 printf("RX queue stats mapping not supported port id=%d\n", pi); in map_port_queue_stats_mapping_registers()
3429 pi, diag); in map_port_queue_stats_mapping_registers()