Home
last modified time | relevance | path

Searched refs:qconf (Results 1 – 25 of 53) sorted by relevance

123

/f-stack/dpdk/examples/l2fwd-jobstats/
H A Dmain.c157 rte_spinlock_lock(&qconf->lock); in show_lcore_stats()
263 if (qconf->n_rx_port > 0) { in show_lcore_stats()
264 job = &qconf->flush_job; in show_lcore_stats()
442 rte_jobstats_start(&qconf->jobs_context, &qconf->flush_job); in l2fwd_flush_job()
464 rte_jobstats_finish(&qconf->flush_job, qconf->flush_job.target); in l2fwd_flush_job()
480 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
506 rte_jobstats_start(&qconf->jobs_context, &qconf->idle_job); in l2fwd_main_loop()
527 rte_jobstats_finish(&qconf->idle_job, qconf->idle_job.target); in l2fwd_main_loop()
807 qconf = NULL; in main()
828 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]
/f-stack/dpdk/examples/l3fwd/
H A Dl3fwd_em.h10 struct rte_ether_hdr *eth_hdr, struct lcore_conf *qconf) in l3fwd_em_handle_ipv4() argument
27 qconf->ipv4_lookup_struct); in l3fwd_em_handle_ipv4()
50 struct rte_ether_hdr *eth_hdr, struct lcore_conf *qconf) in l3fwd_em_handle_ipv6() argument
60 qconf->ipv6_lookup_struct); in l3fwd_em_handle_ipv6()
78 struct lcore_conf *qconf) in l3fwd_em_simple_forward() argument
91 send_single_packet(qconf, m, dst_port); in l3fwd_em_simple_forward()
94 send_single_packet(qconf, m, dst_port); in l3fwd_em_simple_forward()
126 uint16_t portid, struct lcore_conf *qconf) in l3fwd_em_no_opt_send_packets() argument
155 struct lcore_conf *qconf) in l3fwd_em_no_opt_process_events() argument
170 l3fwd_em_simple_process(events[j]->mbuf, qconf); in l3fwd_em_no_opt_process_events()
[all …]
H A Dl3fwd_lpm_neon.h53 processx4_step2(const struct lcore_conf *qconf, in processx4_step2() argument
72 dprt[0] = lpm_get_dst_port_with_ipv4(qconf, pkt[0], in processx4_step2()
74 dprt[1] = lpm_get_dst_port_with_ipv4(qconf, pkt[1], in processx4_step2()
76 dprt[2] = lpm_get_dst_port_with_ipv4(qconf, pkt[2], in processx4_step2()
78 dprt[3] = lpm_get_dst_port_with_ipv4(qconf, pkt[3], in processx4_step2()
89 uint16_t portid, struct lcore_conf *qconf) in l3fwd_lpm_send_packets() argument
112 processx4_step2(qconf, dip, ipv4_flag, portid, in l3fwd_lpm_send_packets()
146 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], in l3fwd_lpm_send_packets()
151 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], in l3fwd_lpm_send_packets()
156 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], in l3fwd_lpm_send_packets()
[all …]
H A Dl3fwd_lpm_sse.h50 processx4_step2(const struct lcore_conf *qconf, in processx4_step2() argument
66 rte_lpm_lookupx4(qconf->ipv4_lookup_struct, dip, dst.u32, in processx4_step2()
73 dprt[0] = lpm_get_dst_port_with_ipv4(qconf, pkt[0], dst.u32[0], portid); in processx4_step2()
74 dprt[1] = lpm_get_dst_port_with_ipv4(qconf, pkt[1], dst.u32[1], portid); in processx4_step2()
75 dprt[2] = lpm_get_dst_port_with_ipv4(qconf, pkt[2], dst.u32[2], portid); in processx4_step2()
86 uint16_t portid, struct lcore_conf *qconf) in l3fwd_lpm_send_packets() argument
99 processx4_step2(qconf, dip[j / FWDSTEP], in l3fwd_lpm_send_packets()
105 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
109 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
113 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
[all …]
H A Dl3fwd_em_hlm.h152 qconf->ipv4_lookup_struct); in em_get_dst_port()
167 qconf->ipv6_lookup_struct); in em_get_dst_port()
186 uint16_t portid, struct lcore_conf *qconf) in l3fwd_em_send_packets() argument
223 em_get_dst_port_ipv4xN(qconf, &pkts_burst[j], portid, in l3fwd_em_send_packets()
228 em_get_dst_port_ipv6xN(qconf, &pkts_burst[j], portid, in l3fwd_em_send_packets()
233 dst_port[j + i] = em_get_dst_port(qconf, in l3fwd_em_send_packets()
241 send_packets_multi(qconf, pkts_burst, dst_port, nb_rx); in l3fwd_em_send_packets()
251 struct lcore_conf *qconf) in l3fwd_em_process_events() argument
290 em_get_dst_port_ipv4xN_events(qconf, &pkts_burst[j], in l3fwd_em_process_events()
295 em_get_dst_port_ipv6xN_events(qconf, &pkts_burst[j], in l3fwd_em_process_events()
[all …]
H A Dl3fwd_common.h186 len = qconf->tx_mbufs[port].len; in send_packetsx4()
213 qconf->tx_mbufs[port].m_table[len + j] = m[j]; in send_packetsx4()
217 qconf->tx_mbufs[port].m_table[len + j] = m[j]; in send_packetsx4()
221 qconf->tx_mbufs[port].m_table[len + j] = m[j]; in send_packetsx4()
225 qconf->tx_mbufs[port].m_table[len + j] = m[j]; in send_packetsx4()
235 send_burst(qconf, MAX_PKT_BURST, port); in send_packetsx4()
243 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
247 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
251 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
255 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
[all …]
H A Dl3fwd_lpm_altivec.h56 processx4_step2(const struct lcore_conf *qconf, in processx4_step2() argument
76 rte_lpm_lookupx4(qconf->ipv4_lookup_struct, (xmm_t)dip, in processx4_step2()
83 dprt[0] = lpm_get_dst_port_with_ipv4(qconf, pkt[0], in processx4_step2()
85 dprt[1] = lpm_get_dst_port_with_ipv4(qconf, pkt[1], in processx4_step2()
87 dprt[2] = lpm_get_dst_port_with_ipv4(qconf, pkt[2], in processx4_step2()
89 dprt[3] = lpm_get_dst_port_with_ipv4(qconf, pkt[3], in processx4_step2()
100 uint8_t portid, struct lcore_conf *qconf) in l3fwd_lpm_send_packets() argument
113 processx4_step2(qconf, dip[j / FWDSTEP], in l3fwd_lpm_send_packets()
120 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
124 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
[all …]
H A Dl3fwd_lpm.h10 struct lcore_conf *qconf) in l3fwd_lpm_simple_forward() argument
31 qconf->ipv4_lookup_struct); in l3fwd_lpm_simple_forward()
49 send_single_packet(qconf, m, dst_port); in l3fwd_lpm_simple_forward()
58 qconf->ipv6_lookup_struct); in l3fwd_lpm_simple_forward()
71 send_single_packet(qconf, m, dst_port); in l3fwd_lpm_simple_forward()
80 uint16_t portid, struct lcore_conf *qconf) in l3fwd_lpm_no_opt_send_packets() argument
92 l3fwd_lpm_simple_forward(pkts_burst[j], portid, qconf); in l3fwd_lpm_no_opt_send_packets()
97 l3fwd_lpm_simple_forward(pkts_burst[j], portid, qconf); in l3fwd_lpm_no_opt_send_packets()
H A Dl3fwd_em_sequential.h24 em_get_dst_port(const struct lcore_conf *qconf, struct rte_mbuf *pkt, in em_get_dst_port() argument
43 qconf->ipv4_lookup_struct); in em_get_dst_port()
58 qconf->ipv6_lookup_struct); in em_get_dst_port()
77 uint16_t portid, struct lcore_conf *qconf) in l3fwd_em_send_packets() argument
93 dst_port[j] = em_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_em_send_packets()
96 send_packets_multi(qconf, pkts_burst, dst_port, nb_rx); in l3fwd_em_send_packets()
105 struct lcore_conf *qconf) in l3fwd_em_process_events() argument
120 mbuf->port = em_get_dst_port(qconf, mbuf, mbuf->port); in l3fwd_em_process_events()
H A Dl3fwd_lpm.c119 qconf->ipv4_lookup_struct); in lpm_get_dst_port()
126 qconf->ipv6_lookup_struct); in lpm_get_dst_port()
184 struct lcore_conf *qconf; in lpm_main_loop() local
191 qconf = &lcore_conf[lcore_id]; in lpm_main_loop()
193 if (qconf->n_rx_queue == 0) { in lpm_main_loop()
220 portid = qconf->tx_port_id[i]; in lpm_main_loop()
223 send_burst(qconf, in lpm_main_loop()
224 qconf->tx_mbufs[portid].len, in lpm_main_loop()
226 qconf->tx_mbufs[portid].len = 0; in lpm_main_loop()
246 portid, qconf); in lpm_main_loop()
[all …]
H A Dl3fwd.h99 send_burst(struct lcore_conf *qconf, uint16_t n, uint16_t port) in send_burst() argument
105 queueid = qconf->tx_queue_id[port]; in send_burst()
106 m_table = (struct rte_mbuf **)qconf->tx_mbufs[port].m_table; in send_burst()
120 send_single_packet(struct lcore_conf *qconf, in send_single_packet() argument
125 len = qconf->tx_mbufs[port].len; in send_single_packet()
126 qconf->tx_mbufs[port].m_table[len] = m; in send_single_packet()
131 send_burst(qconf, MAX_PKT_BURST, port); in send_single_packet()
135 qconf->tx_mbufs[port].len = len; in send_single_packet()
/f-stack/dpdk/examples/ipv4_multicast/
H A Dmain.c168 n = qconf->tx_mbufs[port].len; in send_burst()
176 qconf->tx_mbufs[port].len = 0; in send_burst()
288 send_burst(qconf, port); in mcast_send_pkt()
343 qconf, port); in mcast_forward()
373 send_burst(qconf, portid); in send_timeout_burst()
375 qconf->tx_tsc = cur_tsc; in send_timeout_burst()
386 struct lcore_queue_conf *qconf; in main_loop() local
392 if (qconf->n_rx_queue == 0) { in main_loop()
439 send_timeout_burst(qconf); in main_loop()
711 qconf->rx_queue_list[qconf->n_rx_queue] = portid; in main()
[all …]
/f-stack/dpdk/examples/l2fwd-event/
H A Dl2fwd_poll.c35 struct lcore_queue_conf *qconf; in l2fwd_poll_main_loop() local
48 if (qconf->n_rx_port == 0) { in l2fwd_poll_main_loop()
55 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_poll_main_loop()
57 port_id = qconf->rx_port_list[i]; in l2fwd_poll_main_loop()
71 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_poll_main_loop()
73 rsrc->dst_ports[qconf->rx_port_list[i]]; in l2fwd_poll_main_loop()
86 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_poll_main_loop()
88 port_id = qconf->rx_port_list[i]; in l2fwd_poll_main_loop()
107 struct lcore_queue_conf *qconf = NULL; in l2fwd_poll_lcore_config() local
132 qconf->rx_port_list[qconf->n_rx_port] = port_id; in l2fwd_poll_lcore_config()
[all …]
/f-stack/dpdk/examples/l3fwd-power/
H A Dmain.c479 struct lcore_conf *qconf; in send_single_packet() local
1056 qconf->n_rx_queue, in main_intr_loop()
1159 qconf); in main_telemetry_loop()
1165 qconf); in main_telemetry_loop()
1282 qconf); in main_empty_poll_loop()
1288 qconf); in main_empty_poll_loop()
1426 qconf); in main_legacy_loop()
1432 qconf); in main_legacy_loop()
1480 qconf->n_rx_queue, in main_legacy_loop()
2652 qconf->tx_port_id[qconf->n_tx_port] = portid; in main()
[all …]
/f-stack/dpdk/examples/ip_reassembly/
H A Dmain.c253 txmb = qconf->tx_mbufs[port]; in send_burst()
287 txmb = qconf->tx_mbufs[port]; in send_single_packet()
337 dr = &qconf->death_row; in reassemble()
382 dr = &qconf->death_row; in reassemble()
495 i, qconf, cur_tsc); in main_loop()
501 i, qconf, cur_tsc); in main_loop()
973 qconf->tx_stat.call, in queue_dump_stat()
974 qconf->tx_stat.queue, in queue_dump_stat()
975 qconf->tx_stat.drop, in queue_dump_stat()
976 qconf->tx_stat.send); in queue_dump_stat()
[all …]
/f-stack/dpdk/examples/ip_fragmentation/
H A Dmain.c226 queueid = qconf->tx_queue_id[port]; in send_burst()
264 len = qconf->tx_mbufs[port_out].len; in l3fwd_simple_forward()
380 qconf->tx_mbufs[port_out].len = 0; in l3fwd_simple_forward()
392 struct lcore_queue_conf *qconf; in main_loop() local
398 qconf = &lcore_queue_conf[lcore_id]; in main_loop()
400 if (qconf->n_rx_queue == 0) { in main_loop()
432 qconf->tx_mbufs[portid].len, in main_loop()
434 qconf->tx_mbufs[portid].len = 0; in main_loop()
860 struct lcore_queue_conf *qconf; in main() local
936 rxq = &qconf->rx_queue_list[qconf->n_rx_queue]; in main()
[all …]
/f-stack/dpdk/app/test/
H A Dtest_eventdev.c247 struct rte_event_queue_conf qconf; in test_eventdev_queue_default_conf_get() local
259 &qconf); in test_eventdev_queue_default_conf_get()
271 struct rte_event_queue_conf qconf; in test_eventdev_queue_setup() local
291 &qconf); in test_eventdev_queue_setup()
337 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_priority() local
350 &qconf); in test_eventdev_queue_attr_priority()
382 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_nb_atomic_flows() local
396 if (qconf.nb_atomic_flows == 0) in test_eventdev_queue_attr_nb_atomic_flows()
425 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_nb_atomic_order_sequences() local
457 qconf.nb_atomic_order_sequences, in test_eventdev_queue_attr_nb_atomic_order_sequences()
[all …]
/f-stack/dpdk/app/test-bbdev/
H A Dtest_bbdev.c282 &ts_params->qconf), in test_bbdev_configure_stop_queue()
291 &ts_params->qconf), in test_bbdev_configure_stop_queue()
308 &ts_params->qconf), in test_bbdev_configure_stop_queue()
341 &ts_params->qconf), in test_bbdev_configure_stop_queue()
410 &ts_params->qconf), in test_bbdev_configure_invalid_queue_configure()
419 &ts_params->qconf), in test_bbdev_configure_invalid_queue_configure()
430 &ts_params->qconf), in test_bbdev_configure_invalid_queue_configure()
436 &ts_params->qconf), in test_bbdev_configure_invalid_queue_configure()
442 &ts_params->qconf), in test_bbdev_configure_invalid_queue_configure()
669 &ts_params->qconf), in test_bbdev_stats()
[all …]
/f-stack/dpdk/examples/qos_sched/
H A Dapp_thread.c115 app_send_burst(struct thread_conf *qconf) in app_send_burst() argument
120 mbufs = (struct rte_mbuf **)qconf->m_table; in app_send_burst()
121 n = qconf->n_mbufs; in app_send_burst()
124 ret = rte_eth_tx_burst(qconf->tx_port, qconf->tx_queue, mbufs, (uint16_t)n); in app_send_burst()
135 app_send_packets(struct thread_conf *qconf, struct rte_mbuf **mbufs, uint32_t nb_pkt) in app_send_packets() argument
139 len = qconf->n_mbufs; in app_send_packets()
141 qconf->m_table[len] = mbufs[i]; in app_send_packets()
145 qconf->n_mbufs = len; in app_send_packets()
146 app_send_burst(qconf); in app_send_packets()
151 qconf->n_mbufs = len; in app_send_packets()
/f-stack/dpdk/examples/ipsec-secgw/
H A Dipsec-secgw.c582 qconf->frag.pool_indir); in send_fragment_packet()
586 qconf->frag.pool_indir); in send_fragment_packet()
606 struct lcore_conf *qconf; in send_single_packet() local
1073 ctx = &qconf->inbound; in drain_crypto_buffers()
1080 ctx = &qconf->outbound; in drain_crypto_buffers()
1161 struct lcore_conf *qconf; in ipsec_poll_mode_worker() local
1223 drain_tx_buffers(qconf); in ipsec_poll_mode_worker()
1244 &qconf->inbound); in ipsec_poll_mode_worker()
1247 &qconf->outbound); in ipsec_poll_mode_worker()
1956 struct lcore_conf *qconf; in add_cdev_mapping() local
[all …]
/f-stack/dpdk/examples/link_status_interrupt/
H A Dmain.c203 struct lcore_queue_conf *qconf; in lsi_main_loop() local
212 qconf = &lcore_queue_conf[lcore_id]; in lsi_main_loop()
214 if (qconf->n_rx_port == 0) { in lsi_main_loop()
221 for (i = 0; i < qconf->n_rx_port; i++) { in lsi_main_loop()
223 portid = qconf->rx_port_list[i]; in lsi_main_loop()
273 for (i = 0; i < qconf->n_rx_port; i++) { in lsi_main_loop()
275 portid = qconf->rx_port_list[i]; in lsi_main_loop()
527 struct lcore_queue_conf *qconf; in main() local
581 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
602 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]
/f-stack/dpdk/examples/l2fwd-keepalive/
H A Dmain.c202 struct lcore_queue_conf *qconf; in l2fwd_main_loop() local
210 qconf = &lcore_queue_conf[lcore_id]; in l2fwd_main_loop()
212 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
219 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
221 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
267 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
528 struct lcore_queue_conf *qconf; in main() local
601 qconf = NULL; in main()
622 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
623 qconf->n_rx_port++; in main()
[all …]
/f-stack/dpdk/examples/l3fwd-graph/
H A Dmain.c698 struct lcore_conf *qconf; in graph_main_loop() local
706 graph = qconf->graph; in graph_main_loop()
716 qconf->name, graph); in graph_main_loop()
742 struct lcore_conf *qconf; in main() local
957 if (qconf->n_rx_queue) in main()
1017 if (!qconf->n_rx_queue) in main()
1029 snprintf(qconf->name, sizeof(qconf->name), "worker_%u", in main()
1038 qconf->graph_id = graph_id; in main()
1039 qconf->graph = rte_graph_lookup(qconf->name); in main()
1040 if (!qconf->graph) in main()
[all …]
/f-stack/dpdk/examples/l2fwd/
H A Dmain.c207 struct lcore_queue_conf *qconf; in l2fwd_main_loop() local
216 qconf = &lcore_queue_conf[lcore_id]; in l2fwd_main_loop()
218 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
225 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
227 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
278 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
280 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
638 struct lcore_queue_conf *qconf; in main() local
720 qconf = NULL; in main()
743 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]
/f-stack/dpdk/doc/guides/sample_app_ug/
H A Dl2_forward_job_stats.rst302 rte_timer_init(&qconf->flush_timer);
318 rte_timer_init(&qconf->rx_timers[i]);
344 rte_spinlock_lock(&qconf->lock);
353 rte_jobstats_start(&qconf->jobs_context, &qconf->idle_job);
369 rte_jobstats_finish(&qconf->idle_job, qconf->idle_job.target);
375 rte_spinlock_unlock(&qconf->lock);
496 struct lcore_queue_conf *qconf;
500 len = qconf->tx_mbufs[port].len;
526 struct lcore_queue_conf *qconf;
533 rte_jobstats_start(&qconf->jobs_context, &qconf->flush_job);
[all …]

123