Home
last modified time | relevance | path

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

12

/dpdk/examples/l2fwd-jobstats/
H A Dmain.c158 rte_spinlock_lock(&qconf->lock); in show_lcore_stats()
264 if (qconf->n_rx_port > 0) { in show_lcore_stats()
265 job = &qconf->flush_job; in show_lcore_stats()
451 rte_jobstats_start(&qconf->jobs_context, &qconf->flush_job); in l2fwd_flush_job()
473 rte_jobstats_finish(&qconf->flush_job, qconf->flush_job.target); in l2fwd_flush_job()
490 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
517 rte_jobstats_start(&qconf->jobs_context, &qconf->idle_job); in l2fwd_main_loop()
538 rte_jobstats_finish(&qconf->idle_job, qconf->idle_job.target); in l2fwd_main_loop()
821 qconf = NULL; in main()
842 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]
/dpdk/examples/l3fwd/
H A Dl3fwd_em.h27 qconf->ipv4_lookup_struct); in l3fwd_em_handle_ipv4()
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
180 struct lcore_conf *qconf) in l3fwd_em_no_opt_process_event_vector() argument
190 l3fwd_em_simple_process(mbufs[0], qconf); in l3fwd_em_no_opt_process_event_vector()
204 l3fwd_em_simple_process(mbufs[i], qconf); in l3fwd_em_no_opt_process_event_vector()
[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
233 dst_port[j + i] = em_get_dst_port(qconf, in l3fwd_em_send_packets()
251 struct lcore_conf *qconf) in l3fwd_em_process_events() argument
300 pkts_burst[j + i]->port = em_get_dst_port(qconf, in l3fwd_em_process_events()
324 struct lcore_conf *qconf) in l3fwd_em_process_event_vector() argument
358 em_get_dst_port_ipv4xN_events(qconf, &mbufs[j], in l3fwd_em_process_event_vector()
361 em_get_dst_port_ipv6xN_events(qconf, &mbufs[j], in l3fwd_em_process_event_vector()
366 em_get_dst_port(qconf, mbufs[j + i], in l3fwd_em_process_event_vector()
[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_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()
246 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
250 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
254 qconf->tx_mbufs[port].m_table[j] = m[n + j]; in send_packetsx4()
258 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_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()
127 struct lcore_conf *qconf) in l3fwd_em_process_event_vector() argument
135 vec->port = em_get_dst_port(qconf, mbufs[0], mbufs[0]->port); in l3fwd_em_process_event_vector()
[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_fib.c108 uint16_t portid, struct lcore_conf *qconf) in fib_send_packets() argument
178 struct lcore_conf *qconf; in fib_main_loop() local
183 qconf = &lcore_conf[lcore_id]; in fib_main_loop()
185 const uint16_t n_rx_q = qconf->n_rx_queue; in fib_main_loop()
186 const uint16_t n_tx_p = qconf->n_tx_port; in fib_main_loop()
196 portid = qconf->rx_queue_list[i].port_id; in fib_main_loop()
213 portid = qconf->tx_port_id[i]; in fib_main_loop()
214 if (qconf->tx_mbufs[portid].len == 0) in fib_main_loop()
216 send_burst(qconf, in fib_main_loop()
217 qconf->tx_mbufs[portid].len, in fib_main_loop()
[all …]
H A Dl3fwd_lpm.c88 qconf->ipv4_lookup_struct); in lpm_get_dst_port()
95 qconf->ipv6_lookup_struct); in lpm_get_dst_port()
153 struct lcore_conf *qconf; in lpm_main_loop() local
158 qconf = &lcore_conf[lcore_id]; in lpm_main_loop()
190 portid = qconf->tx_port_id[i]; in lpm_main_loop()
191 if (qconf->tx_mbufs[portid].len == 0) in lpm_main_loop()
193 send_burst(qconf, in lpm_main_loop()
194 qconf->tx_mbufs[portid].len, in lpm_main_loop()
196 qconf->tx_mbufs[portid].len = 0; in lpm_main_loop()
216 portid, qconf); in lpm_main_loop()
[all …]
H A Dl3fwd.h112 send_burst(struct lcore_conf *qconf, uint16_t n, uint16_t port) in send_burst() argument
118 queueid = qconf->tx_queue_id[port]; in send_burst()
119 m_table = (struct rte_mbuf **)qconf->tx_mbufs[port].m_table; in send_burst()
133 send_single_packet(struct lcore_conf *qconf, in send_single_packet() argument
138 len = qconf->tx_mbufs[port].len; in send_single_packet()
139 qconf->tx_mbufs[port].m_table[len] = m; in send_single_packet()
144 send_burst(qconf, MAX_PKT_BURST, port); in send_single_packet()
148 qconf->tx_mbufs[port].len = len; in send_single_packet()
/dpdk/examples/ipv4_multicast/
H A Dmain.c170 n = qconf->tx_mbufs[port].len; in send_burst()
178 qconf->tx_mbufs[port].len = 0; in send_burst()
296 send_burst(qconf, port); in mcast_send_pkt()
359 qconf, port); in mcast_forward()
390 send_burst(qconf, portid); in send_timeout_burst()
392 qconf->tx_tsc = cur_tsc; in send_timeout_burst()
403 struct lcore_queue_conf *qconf; in main_loop() local
409 if (qconf->n_rx_queue == 0) { in main_loop()
456 send_timeout_burst(qconf); in main_loop()
731 qconf->rx_queue_list[qconf->n_rx_queue] = portid; in main()
[all …]
/dpdk/examples/l3fwd-power/
H A Dmain.c484 struct lcore_conf *qconf; in send_single_packet() local
1069 qconf->n_rx_queue, in main_intr_loop()
1173 qconf); in main_telemetry_loop()
1179 qconf); in main_telemetry_loop()
1296 qconf); in main_empty_poll_loop()
1302 qconf); in main_empty_poll_loop()
1440 qconf); in main_legacy_loop()
1446 qconf); in main_legacy_loop()
1494 qconf->n_rx_queue, in main_legacy_loop()
2742 qconf->tx_port_id[qconf->n_tx_port] = portid; in main()
[all …]
/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()
72 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_poll_main_loop()
74 rsrc->dst_ports[qconf->rx_port_list[i]]; in l2fwd_poll_main_loop()
88 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_poll_main_loop()
90 port_id = qconf->rx_port_list[i]; in l2fwd_poll_main_loop()
110 struct lcore_queue_conf *qconf = NULL; in l2fwd_poll_lcore_config() local
135 qconf->rx_port_list[qconf->n_rx_port] = port_id; in l2fwd_poll_lcore_config()
[all …]
/dpdk/examples/ip_reassembly/
H A Dmain.c256 txmb = qconf->tx_mbufs[port]; in send_burst()
290 txmb = qconf->tx_mbufs[port]; in send_single_packet()
340 dr = &qconf->death_row; in reassemble()
385 dr = &qconf->death_row; in reassemble()
498 i, qconf, cur_tsc); in main_loop()
504 i, qconf, cur_tsc); in main_loop()
979 qconf->tx_stat.call, in queue_dump_stat()
980 qconf->tx_stat.queue, in queue_dump_stat()
981 qconf->tx_stat.drop, in queue_dump_stat()
982 qconf->tx_stat.send); in queue_dump_stat()
[all …]
/dpdk/examples/ip_fragmentation/
H A Dmain.c229 queueid = qconf->tx_queue_id[port]; in send_burst()
267 len = qconf->tx_mbufs[port_out].len; in l3fwd_simple_forward()
383 qconf->tx_mbufs[port_out].len = 0; in l3fwd_simple_forward()
395 struct lcore_queue_conf *qconf; in main_loop() local
401 qconf = &lcore_queue_conf[lcore_id]; in main_loop()
403 if (qconf->n_rx_queue == 0) { in main_loop()
435 qconf->tx_mbufs[portid].len, in main_loop()
437 qconf->tx_mbufs[portid].len = 0; in main_loop()
863 struct lcore_queue_conf *qconf; in main() local
939 rxq = &qconf->rx_queue_list[qconf->n_rx_queue]; in main()
[all …]
/dpdk/app/test/
H A Dtest_eventdev.c258 struct rte_event_queue_conf qconf; in test_eventdev_queue_default_conf_get() local
270 &qconf); in test_eventdev_queue_default_conf_get()
282 struct rte_event_queue_conf qconf; in test_eventdev_queue_setup() local
302 &qconf); in test_eventdev_queue_setup()
348 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_priority() local
361 &qconf); in test_eventdev_queue_attr_priority()
392 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_priority_runtime() local
484 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_weight_runtime() local
535 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_affinity_runtime() local
588 struct rte_event_queue_conf qconf; in test_eventdev_queue_attr_nb_atomic_flows() local
[all …]
/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 …]
/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()
/dpdk/examples/l3fwd-graph/
H A Dmain.c677 struct lcore_conf *qconf; in graph_main_loop() local
685 graph = qconf->graph; in graph_main_loop()
695 qconf->name, graph); in graph_main_loop()
758 struct lcore_conf *qconf; in main() local
980 if (qconf->n_rx_queue) in main()
1041 if (!qconf->n_rx_queue) in main()
1053 snprintf(qconf->name, sizeof(qconf->name), "worker_%u", in main()
1062 qconf->graph_id = graph_id; in main()
1063 qconf->graph = rte_graph_lookup(qconf->name); in main()
1065 if (!qconf->graph) in main()
[all …]
/dpdk/examples/l2fwd-keepalive/
H A Dmain.c201 struct lcore_queue_conf *qconf; in l2fwd_main_loop() local
209 qconf = &lcore_queue_conf[lcore_id]; in l2fwd_main_loop()
211 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
218 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
220 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
267 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
527 struct lcore_queue_conf *qconf; in main() local
600 qconf = NULL; in main()
621 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
622 qconf->n_rx_port++; in main()
[all …]
/dpdk/examples/link_status_interrupt/
H A Dmain.c207 struct lcore_queue_conf *qconf; in lsi_main_loop() local
216 qconf = &lcore_queue_conf[lcore_id]; in lsi_main_loop()
218 if (qconf->n_rx_port == 0) { in lsi_main_loop()
225 for (i = 0; i < qconf->n_rx_port; i++) { in lsi_main_loop()
227 portid = qconf->rx_port_list[i]; in lsi_main_loop()
277 for (i = 0; i < qconf->n_rx_port; i++) { in lsi_main_loop()
279 portid = qconf->rx_port_list[i]; in lsi_main_loop()
535 struct lcore_queue_conf *qconf; in main() local
588 qconf = &lcore_queue_conf[rx_lcore_id]; in main()
609 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]
/dpdk/examples/ipsec-secgw/
H A Dipsec-secgw.c627 tbl = qconf->tx_mbufs + port; in send_fragment_packet()
663 struct lcore_conf *qconf; in send_single_packet() local
1145 ctx = &qconf->inbound; in drain_crypto_buffers()
1152 ctx = &qconf->outbound; in drain_crypto_buffers()
1236 struct lcore_conf *qconf; in ipsec_poll_mode_worker() local
1245 rxql = qconf->rx_queue_list; in ipsec_poll_mode_worker()
1297 drain_tx_buffers(qconf); in ipsec_poll_mode_worker()
1318 &qconf->inbound); in ipsec_poll_mode_worker()
1321 &qconf->outbound); in ipsec_poll_mode_worker()
2086 struct lcore_conf *qconf; in add_cdev_mapping() local
[all …]
/dpdk/examples/l2fwd/
H A Dmain.c212 struct lcore_queue_conf *qconf; in l2fwd_main_loop() local
221 qconf = &lcore_queue_conf[lcore_id]; in l2fwd_main_loop()
223 if (qconf->n_rx_port == 0) { in l2fwd_main_loop()
230 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
232 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
283 for (i = 0; i < qconf->n_rx_port; i++) { in l2fwd_main_loop()
285 portid = qconf->rx_port_list[i]; in l2fwd_main_loop()
652 struct lcore_queue_conf *qconf; in main() local
738 qconf = NULL; in main()
761 qconf->rx_port_list[qconf->n_rx_port] = portid; in main()
[all …]

12