| /dpdk/examples/multi_process/client_server_mp/mp_server/ |
| H A D | init.c | 54 struct port_info *ports; variable 64 RTE_MP_RX_DESC_DEFAULT * ports->num_ports; in init_mbuf_pools() 67 RTE_MP_TX_DESC_DEFAULT * ports->num_ports); in init_mbuf_pools() 194 if ((port_mask & (1 << ports->id[portid])) == 0) in check_all_ports_link_status() 210 ports->id[portid], in check_all_ports_link_status() 257 mz = rte_memzone_reserve(MZ_PORT_INFO, sizeof(*ports), in init() 261 memset(mz->addr, 0, sizeof(*ports)); in init() 262 ports = mz->addr; in init() 275 for (i = 0; i < ports->num_ports; i++) { in init() 276 retval = init_port(ports->id[i]); in init() [all …]
|
| H A D | main.c | 110 for (j = 0; j < ports->num_ports; j++){ in do_stats_display() 112 const uint64_t tx_val = tx->tx[ports->id[j]]; in do_stats_display() 113 const uint64_t drop_val = tx->tx_drop[ports->id[j]]; in do_stats_display() 126 for (i = 0; i < ports->num_ports; i++) in do_stats_display() 127 printf("Port %u: '%s'\t", (unsigned)ports->id[i], in do_stats_display() 128 get_printable_mac_addr(ports->id[i])); in do_stats_display() 130 for (i = 0; i < ports->num_ports; i++){ in do_stats_display() 133 (unsigned)ports->id[i], ports->rx_stats.rx[i], in do_stats_display() 263 rx_count = rte_eth_rx_burst(ports->id[port_num], 0, \ in do_packet_forwarding() 265 ports->rx_stats.rx[port_num] += rx_count; in do_packet_forwarding() [all …]
|
| H A D | args.c | 67 ports->id[ports->num_ports++] = id; in parse_portmask() 137 if (ports->num_ports == 0 || num_clients == 0){ in parse_app_args() 142 if (ports->num_ports % 2 != 0){ in parse_app_args()
|
| H A D | init.h | 34 extern struct port_info *ports; 39 extern struct port_info *ports;
|
| /dpdk/examples/multi_process/client_server_mp/mp_client/ |
| H A D | client.c | 161 configure_output_ports(const struct port_info *ports) in configure_output_ports() argument 164 if (ports->num_ports > RTE_MAX_ETHPORTS) in configure_output_ports() 167 for (i = 0; i < ports->num_ports - 1; i+=2){ in configure_output_ports() 168 uint16_t p1 = ports->id[i]; in configure_output_ports() 169 uint16_t p2 = ports->id[i+1]; in configure_output_ports() 208 struct port_info *ports; in main() local 236 ports = mz->addr; in main() 237 tx_stats = &(ports->tx_stats[client_id]); in main() 239 configure_output_ports(ports); in main() 253 for (i = 0; i < ports->num_ports; i++) { in main() [all …]
|
| /dpdk/examples/dma/ |
| H A D | dmafwd.c | 49 struct rxtx_port_config ports[RTE_MAX_ETHPORTS]; member 227 port_id = cfg.ports[i].rxtx_port; in print_stats() 242 dev_id = cfg.ports[i].dmadev_ids[j]; in print_stats() 507 dma_rx_port(&cfg.ports[i]); in rx_main_loop() 522 dma_tx_port(&cfg.ports[i]); in tx_main_loop() 537 dma_rx_port(&cfg.ports[i]); in rxtx_main_loop() 538 dma_tx_port(&cfg.ports[i]); in rxtx_main_loop() 817 cfg.ports[i].dmadev_ids[j] = dev_id; in assign_dmadevs() 847 if (cfg.ports[i].rx_to_tx_ring == NULL) in assign_rings() 973 cfg.ports[cfg.nb_ports].rxtx_port = portid; in port_init() [all …]
|
| /dpdk/examples/ethtool/ethtool-app/ |
| H A D | main.c | 45 struct app_port ports[MAX_PORTS]; member 56 struct app_port *ptr_port = &app_cfg.ports[idx_port]; in lock_port() 63 struct app_port *ptr_port = &app_cfg.ports[idx_port]; in unlock_port() 70 struct app_port *ptr_port = &app_cfg.ports[idx_port]; in mark_port_active() 77 struct app_port *ptr_port = &app_cfg.ports[idx_port]; in mark_port_inactive() 84 struct app_port *ptr_port = &app_cfg.ports[idx_port]; in mark_port_newmac() 104 struct app_port *ptr_port = &app_cfg->ports[idx_port]; in setup_ports() 195 ptr_port = &app_cfg.ports[idx_port]; in worker_main()
|
| /dpdk/app/test-pmd/ |
| H A D | util.c | 330 ports[port_id].tx_metadata; in tx_pkt_set_md() 351 if (!ports[portid].tx_set_md_cb[queue]) in add_tx_md_callback() 352 ports[portid].tx_set_md_cb[queue] = in add_tx_md_callback() 372 if (ports[portid].tx_set_md_cb[queue]) { in remove_tx_md_callback() 374 ports[portid].tx_set_md_cb[queue]); in remove_tx_md_callback() 375 ports[portid].tx_set_md_cb[queue] = NULL; in remove_tx_md_callback() 386 if (ports[port_id].mbuf_dynf) in tx_pkt_set_dynf() 407 if (!ports[portid].tx_set_dynf_cb[queue]) in add_tx_dynf_callback() 408 ports[portid].tx_set_dynf_cb[queue] = in add_tx_dynf_callback() 428 if (ports[portid].tx_set_dynf_cb[queue]) { in remove_tx_dynf_callback() [all …]
|
| H A D | testpmd.c | 1777 port = &ports[pid]; in init_fwd_streams() 2015 port = &ports[pt_id]; in fwd_stats_display() 2427 port = &ports[pi]; in all_ports_started() 2682 port = &ports[pi]; in fill_xstats_display_info_for_port() 2749 port = &ports[pi]; in start_port() 3052 port = &ports[pi]; in stop_port() 3145 port = &ports[pi]; in close_port() 3203 port = &ports[pi]; in reset_port() 3403 if (ports != NULL) { in pmd_test_exit() 3775 port = &ports[pid]; in init_port_config() [all …]
|
| H A D | config.c | 697 port = &ports[port_id]; in port_infos_display() 1608 port = &ports[port_id]; in action_get_by_id() 1636 port = &ports[port_id]; in action_alloc() 1806 port = &ports[port_id]; in port_flow_configure() 1874 port = &ports[port_id]; in port_action_handle_destroy() 2064 port = &ports[port_id]; in port_flow_tunnel_offload_cmd_prep() 2250 port = &ports[port_id]; in port_flow_pattern_template_create() 2280 port = &ports[port_id]; in port_flow_pattern_template_destroy() 2331 port = &ports[port_id]; in port_flow_actions_template_create() 2361 port = &ports[port_id]; in port_flow_actions_template_destroy() [all …]
|
| /dpdk/drivers/event/sw/ |
| H A D | sw_evdev_scheduler.c | 84 struct sw_port *p = &sw->ports[cq]; in sw_schedule_atomic_to_cq() 153 sw->ports[cq].cq_worker_ring) == 0); in sw_schedule_parallel_to_cq() 155 struct sw_port *p = &sw->ports[cq]; in sw_schedule_parallel_to_cq() 172 sw->ports[cq].cq_buf[sw->ports[cq].cq_buf_count++] = *qe; in sw_schedule_parallel_to_cq() 190 struct sw_port *port = &sw->ports[cq_id]; in sw_schedule_dir_to_cq() 355 struct sw_port *port = &sw->ports[port_id]; in __pull_port_lb() 473 struct sw_port *port = &sw->ports[port_id]; in sw_schedule_pull_port_dir() 530 if (sw->ports[i].unlinks_in_progress) in sw_event_schedule() 531 sw->ports[i].unlinks_in_progress = 0; in sw_event_schedule() 533 if (sw->ports[i].is_directed) in sw_event_schedule() [all …]
|
| /dpdk/drivers/event/dsw/ |
| H A D | dsw_xstats.c | 64 return dsw->ports[port_id]._variable; \ 75 return dsw->ports[port_id].queue_enqueued[queue_id]; in DSW_GEN_PORT_ACCESS_FN() 84 return dsw->ports[port_id].queue_dequeued[queue_id]; in DSW_GEN_PORT_ACCESS_FN() 94 uint64_t total_latency = dsw->ports[port_id].emigration_latency; in DSW_GEN_PORT_ACCESS_FN() 95 uint64_t num_emigrations = dsw->ports[port_id].emigrations; in DSW_GEN_PORT_ACCESS_FN() 105 dsw->ports[port_id].total_busy_cycles; in dsw_xstats_port_get_event_proc_latency() 107 dsw->ports[port_id].dequeued; in dsw_xstats_port_get_event_proc_latency() 116 return dsw->ports[port_id].total_busy_cycles; in dsw_xstats_port_get_busy_cycles() 129 load = __atomic_load_n(&dsw->ports[port_id].load, __ATOMIC_RELAXED); in DSW_GEN_PORT_ACCESS_FN()
|
| /dpdk/drivers/net/nfp/nfpcore/ |
| H A D | nfp_nsp_eth.c | 227 table->ports[i].index); in nfp_eth_calc_port_geometry() 230 if (table->ports[i].label_port != in nfp_eth_calc_port_geometry() 231 table->ports[j].label_port) in nfp_eth_calc_port_geometry() 233 table->ports[i].port_lanes += table->ports[j].lanes; in nfp_eth_calc_port_geometry() 237 if (table->ports[i].label_subport == in nfp_eth_calc_port_geometry() 238 table->ports[j].label_subport) in nfp_eth_calc_port_geometry() 240 table->ports[i].label_port, in nfp_eth_calc_port_geometry() 241 table->ports[i].label_subport); in nfp_eth_calc_port_geometry() 243 table->ports[i].is_split = 1; in nfp_eth_calc_port_geometry() 305 &table->ports[j++]); in __nfp_eth_read_ports() [all …]
|
| /dpdk/drivers/event/opdl/ |
| H A D | opdl_evdev_init.c | 287 return q->ports[i]->enq_stage_inst; in stage_for_port() 289 return q->ports[i]->deq_stage_inst; in stage_for_port() 338 queue->ports[i]->num_instance, in opdl_add_deps() 339 queue->ports[i]->instance_id, in opdl_add_deps() 359 struct opdl_port *port = &device->ports[i]; in opdl_add_event_handlers() 708 struct opdl_port *port = &device->ports[i]; in initialise_all_other_ports() 733 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports() 751 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports() 778 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports() 808 queue->ports[queue->nb_ports] = port; in initialise_all_other_ports() [all …]
|
| /dpdk/doc/guides/freebsd_gsg/ |
| H A D | install_from_ports.rst | 10 install it using the FreeBSD `pkg` utility or from the ports collection. 11 Details of installing applications from packages or the ports collection are documented in the 13 chapter `Installing Applications: Packages and Ports <https://www.freebsd.org/doc/handbook/ports.ht… 49 If so desired, the user can install DPDK using the ports collection rather than from 51 On a system with the ports collection installed in ``/usr/ports``, the DPDK 54 cd /usr/ports/net/dpdk 62 When the DPDK has been installed from the ports collection it installs 80 via the contigmem module, and 4 NIC ports bound to the nic_uio module::
|
| /dpdk/doc/guides/sample_app_ug/ |
| H A D | l2_forward_event.rst | 19 ports 1 and 2 forward into each other, and ports 3 and 4 forward into each other. 64 * p PORTMASK: A hexadecimal bitmask of the ports to configure 66 * q NQ: A number of queues (=ports) per lcore (default is 1) 211 ports with one lcore. If there are 16 ports on the target (and if the portmask 213 ports. 217 :start-after: Using lcore to poll one or several ports. 8< 252 * Ethernet ports 282 Ethernet ports. 364 During the initialization process, a static array of destination ports 373 destination ports. [all …]
|
| H A D | ipv4_multicast.rst | 30 four ports can be supported. 31 If using non-consecutive ports, use the destination IPv4 address accordingly. 35 with the mask of ports to multicast packets to. 57 * -p PORTMASK: Hexadecimal bitmask of ports to configure 78 * The -p option enables ports 0 and 1 132 if the routing table has any ports assigned to the destination address: 171 :start-after: Packets dispatched to destination ports. 8< 172 :end-before: >8 End of packets dispatched to destination ports. 205 For example, for N destination ports, we need to invoke mcast_out_pkt() (N-1) times. 210 The input packet's metadata must remain intact, so for N destination ports, [all …]
|
| H A D | l2_forward_real_virtual.rst | 24 if the first four ports are enabled (portmask 0xf), 25 ports 1 and 2 forward into each other, and ports 3 and 4 forward into each other. 75 with two physical ports in the PCI configuration space. 102 * p PORTMASK: A hexadecimal bitmask of the ports to configure 104 * P: Optional, set all ports to promiscuous mode 109 * q NQ: A number of queues (=ports) per lcore (default is 1) 113 * --portmap="(port,port)[,(port,port)]": Determines forwarding ports mapping. 122 To run the application in linux environment with 4 lcores, 4 ports, 8 RX queues 123 per lcore, to forward RX traffic of ports 0 & 1 on ports 2 & 3 respectively and 224 If there are 16 ports on the target (and if the portmask argument is -p ffff ), [all …]
|
| H A D | skeleton.rst | 73 The ``main()`` function also initializes all the ports using the user defined 78 :start-after: Initializing all ports. 8< 79 :end-before: >8 End of initializing all ports. 108 The Ethernet ports are configured with default settings using the 111 For this example the ports are set up with 1 RX and 1 TX queue using the 152 Packets are received in bursts on the RX ports and transmitted in bursts on 153 the TX ports. The ports are grouped in pairs with a simple mapping scheme
|
| H A D | test_pipeline.rst | 15 * Core A ("RX core") receives traffic from the NIC ports and feeds core B with traffic through SW… 23 …eceives traffic from core B through software queues and sends it to the NIC ports for transmission. 53 The PORTMASK parameter must contain 2 or 4 ports. 99 … | uniformly distributed for the range of output ports. | 122 … | uniformly distributed for the range of output ports. | 145 … | uniformly distributed for the range of output ports. | 161 …est Prefix Match (LPM) IPv4 table. | In the case of two ports, two routes … 168 … | In case of four ports, four entries are … 187 …ss Control List (ACL) table | In the case of two ports, two ACL rules are… 230 which results in uniform distribution of packets sent out on the set of output NIC ports.
|
| /dpdk/doc/guides/eventdevs/ |
| H A D | dlb2.rst | 27 supports atomic, ordered, and parallel scheduling events from queues to ports. 29 features are abstracted by the PMD such as directed ports. 41 directed queues, ports, credits, and other hardware resources. Some 97 available directed ports and queues. 102 of directed ports. Hence, the number of requested load-balanced ports is 106 directed ports and queues come in pairs. 115 ports can only be linked to directed queues. Furthermore, directed ports can 143 events are scheduled to ports. Refills come from credit pools. 181 the directed pool size divided by the total number of ports. 284 of its ports or queues are not, the PMD will apply their previous [all …]
|
| /dpdk/drivers/event/cnxk/ |
| H A D | cnxk_eventdev.c | 189 if (event_dev->data->ports[i] != NULL) in cnxk_setup_event_ports() 190 ws = event_dev->data->ports[i]; in cnxk_setup_event_ports() 198 event_dev->data->ports[i] = ws; in cnxk_setup_event_ports() 206 event_dev->data->ports[i] = NULL; in cnxk_setup_event_ports() 207 rte_free(cnxk_sso_hws_get_cookie(event_dev->data->ports[i])); in cnxk_setup_event_ports() 234 link_fn(dev, event_dev->data->ports[i], hwgrp, nb_hwgrp); in cnxk_sso_restore_links() 416 if (event_dev->data->ports[port_id] == NULL) { in cnxk_sso_port_setup() 474 ws = event_dev->data->ports[i]; in cnxk_sso_cleanup() 481 ws = event_dev->data->ports[0]; in cnxk_sso_cleanup() 557 ws = event_dev->data->ports[i]; in cnxk_sso_close() [all …]
|
| /dpdk/examples/multi_process/symmetric_mp/ |
| H A D | main.c | 73 static uint16_t ports[RTE_MAX_ETHPORTS]; variable 103 const uint8_t p_num = ports[i]; in print_stats() 160 ports[num_ports++] = (uint8_t)i; in smp_parse_args() 340 "%u ", (unsigned)ports[p]); in lcore_main() 353 const uint8_t src = ports[p]; in lcore_main() 354 const uint8_t dst = ports[p ^ 1]; /* 0 <-> 1, 2 <-> 3 etc */ in lcore_main() 476 if (smp_port_init(ports[i], mp, (uint16_t)num_procs) < 0) in main()
|
| /dpdk/lib/metrics/ |
| H A D | rte_metrics_telemetry.c | 154 rte_metrics_tel_format_port(uint32_t pid, json_t *ports, in rte_metrics_tel_format_port() argument 213 if (port == NULL || json_array_append_new(ports, port) < 0) { in rte_metrics_tel_format_port() 232 json_t *root, *ports; in rte_metrics_tel_encode_json_format() local 235 ports = json_array(); in rte_metrics_tel_encode_json_format() 236 if (ports == NULL) { in rte_metrics_tel_encode_json_format() 249 ports, &ep->pp.metric_ids[0], in rte_metrics_tel_encode_json_format() 259 ports, NULL, 0); in rte_metrics_tel_encode_json_format() 270 "data", ports); in rte_metrics_tel_encode_json_format()
|
| /dpdk/doc/guides/tools/ |
| H A D | proc_info.rst | 26 **-p PORTMASK**: Hexadecimal bitmask of ports to configure. 30 port mask is specified stats are printed for all DPDK ports. 34 port mask is specified xstats are printed for all DPDK ports. 38 no port mask is specified, the generic stats are reset for all DPDK ports. 42 If no port mask is specified xstats are reset for all DPDK ports.
|