Home
last modified time | relevance | path

Searched refs:pkts_burst (Results 1 – 25 of 47) sorted by relevance

12

/dpdk/app/test-pmd/
H A Dshared_rxq_fwd.c13 forward_rx_only(uint16_t nb_rx, struct rte_mbuf **pkts_burst) in forward_rx_only() argument
15 rte_pktmbuf_free_bulk(pkts_burst, nb_rx); in forward_rx_only()
68 struct rte_mbuf **pkts_burst) in forward_shared_rxq() argument
73 last_port = pkts_burst[0]->port; in forward_shared_rxq()
76 rte_prefetch0(pkts_burst[i + 1]); in forward_shared_rxq()
77 port = pkts_burst[i]->port; in forward_shared_rxq()
81 &pkts_burst[i - nb_sub_burst]); in forward_shared_rxq()
90 &pkts_burst[nb_rx - nb_sub_burst]); in forward_shared_rxq()
96 struct rte_mbuf *pkts_burst[nb_pkt_per_burst]; in shared_rxq_fwd() local
101 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in shared_rxq_fwd()
[all …]
H A Dmacswap.c54 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_mac_swap() local
66 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_swap()
75 do_macswap(pkts_burst, nb_rx, txp); in pkt_burst_mac_swap()
77 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_swap()
86 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_swap()
94 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_swap()
H A Dmacfwd.c48 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_mac_forward() local
65 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_forward()
82 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in pkt_burst_mac_forward()
84 mb = pkts_burst[i]; in pkt_burst_mac_forward()
97 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_forward()
106 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_forward()
115 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_forward()
H A Diofwd.c48 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_io_forward() local
60 pkts_burst, nb_pkt_per_burst); in pkt_burst_io_forward()
67 pkts_burst, nb_rx); in pkt_burst_io_forward()
76 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_io_forward()
84 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_io_forward()
H A D5tswap.c87 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_5tuple_swap() local
115 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_5tuple_swap()
124 vlan_qinq_set(pkts_burst, nb_rx, ol_flags, in pkt_burst_5tuple_swap()
128 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i+1], in pkt_burst_5tuple_swap()
130 mb = pkts_burst[i]; in pkt_burst_5tuple_swap()
165 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_5tuple_swap()
174 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_5tuple_swap()
182 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_5tuple_swap()
H A Dflowgen.c66 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_flow_gen() local
88 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_flow_gen()
94 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_flow_gen()
164 pkts_burst[nb_pkt] = pkt; in pkt_burst_flow_gen()
170 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
179 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_flow_gen()
194 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_flow_gen()
H A Dnoisy_vnf.c144 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_noisy_vnf() local
156 pkts_burst, nb_pkt_per_burst); in pkt_burst_noisy_vnf()
165 pkts_burst, nb_rx); in pkt_burst_noisy_vnf()
167 nb_tx += do_retry(nb_rx, nb_tx, pkts_burst, fs); in pkt_burst_noisy_vnf()
170 fs->fwd_dropped += drop_pkts(pkts_burst, nb_rx, nb_tx); in pkt_burst_noisy_vnf()
177 (void **) pkts_burst, nb_rx, NULL); in pkt_burst_noisy_vnf()
179 fs->fwd_dropped += drop_pkts(pkts_burst, in pkt_burst_noisy_vnf()
185 (void **) pkts_burst, nb_deqd, NULL); in pkt_burst_noisy_vnf()
H A Dicmpecho.c275 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in reply_to_icmp_echo_rqsts() local
302 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
312 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in reply_to_icmp_echo_rqsts()
314 pkt = pkts_burst[i]; in reply_to_icmp_echo_rqsts()
404 pkts_burst[nb_replies++] = pkt; in reply_to_icmp_echo_rqsts()
481 pkts_burst[nb_replies++] = pkt; in reply_to_icmp_echo_rqsts()
486 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
498 &pkts_burst[nb_tx], in reply_to_icmp_echo_rqsts()
507 rte_pktmbuf_free(pkts_burst[nb_tx]); in reply_to_icmp_echo_rqsts()
H A Drxonly.c48 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_receive() local
58 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
66 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_receive()
H A Dtxonly.c330 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_transmit() local
364 if (rte_mempool_get_bulk(mbp, (void **)pkts_burst, in pkt_burst_transmit()
367 if (unlikely(!pkt_burst_prepare(pkts_burst[nb_pkt], mbp, in pkt_burst_transmit()
373 (void **)&pkts_burst[nb_pkt], in pkt_burst_transmit()
391 pkts_burst[nb_pkt] = pkt; in pkt_burst_transmit()
398 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_transmit()
408 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_transmit()
426 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_transmit()
H A Dcsumonly.c813 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_checksum_forward() local
873 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in pkt_burst_checksum_forward()
876 m = pkts_burst[i]; in pkt_burst_checksum_forward()
1028 pkts_burst[i] = m; in pkt_burst_checksum_forward()
1087 nb_rx = rte_gro_reassemble_burst(pkts_burst, nb_rx, in pkt_burst_checksum_forward()
1100 &pkts_burst[nb_rx], in pkt_burst_checksum_forward()
1117 ret = rte_gso_segment(pkts_burst[i], gso_ctx, in pkt_burst_checksum_forward()
1122 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_checksum_forward()
1128 gso_segments[nb_segments] = pkts_burst[i]; in pkt_burst_checksum_forward()
1132 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_checksum_forward()
[all …]
/dpdk/examples/l3fwd/
H A Dl3fwd_lpm_neon.h100 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i], in l3fwd_lpm_send_packets()
107 pkts_burst[j + i + FWDSTEP], in l3fwd_lpm_send_packets()
111 processx4_step1(&pkts_burst[j], &dip, &ipv4_flag); in l3fwd_lpm_send_packets()
113 &pkts_burst[j], &dst_port[j]); in l3fwd_lpm_send_packets()
116 processx4_step1(&pkts_burst[j], &dip, &ipv4_flag); in l3fwd_lpm_send_packets()
127 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[j], in l3fwd_lpm_send_packets()
132 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[j], in l3fwd_lpm_send_packets()
137 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[j], 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()
[all …]
H A Dl3fwd_em_hlm.h217 pkts_burst[pos], in l3fwd_em_send_packets()
234 pkts_burst[j + i], portid); in l3fwd_em_send_packets()
264 pkts_burst[j] = ev[j]->mbuf; in l3fwd_em_process_events()
284 pkts_burst[pos], in l3fwd_em_process_events()
301 pkts_burst[j + i], in l3fwd_em_process_events()
302 pkts_burst[j + i]->port); in l3fwd_em_process_events()
303 process_packet(pkts_burst[j + i], in l3fwd_em_process_events()
304 &pkts_burst[j + i]->port); in l3fwd_em_process_events()
316 pkts_burst[j]->port = em_get_dst_port(qconf, pkts_burst[j], in l3fwd_em_process_events()
317 pkts_burst[j]->port); in l3fwd_em_process_events()
[all …]
H A Dl3fwd_lpm_sse.h85 l3fwd_lpm_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_lpm_send_packets() argument
95 processx4_step1(&pkts_burst[j], &dip[j / FWDSTEP], in l3fwd_lpm_send_packets()
100 ipv4_flag[j / FWDSTEP], portid, &pkts_burst[j], &dst_port[j]); 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()
117 send_packets_multi(qconf, pkts_burst, dst_port, nb_rx); in l3fwd_lpm_send_packets()
H A Dl3fwd_lpm_altivec.h99 l3fwd_lpm_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_lpm_send_packets() argument
109 processx4_step1(&pkts_burst[j], &dip[j / FWDSTEP], in l3fwd_lpm_send_packets()
115 portid, &pkts_burst[j], &dst_port[j]); 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()
128 dst_port[j] = lpm_get_dst_port(qconf, pkts_burst[j], portid); in l3fwd_lpm_send_packets()
133 send_packets_multi(qconf, pkts_burst, dst_port, nb_rx); in l3fwd_lpm_send_packets()
H A Dl3fwd_altivec.h154 send_packets_multi(struct lcore_conf *qconf, struct rte_mbuf **pkts_burst, in send_packets_multi() argument
174 processx4_step3(pkts_burst, dst_port); in send_packets_multi()
180 processx4_step3(&pkts_burst[j], &dst_port[j]); in send_packets_multi()
221 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
226 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
231 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
252 send_packetsx4(qconf, pn, pkts_burst + j, k); in send_packets_multi()
255 rte_pktmbuf_free(pkts_burst[m]); in send_packets_multi()
H A Dl3fwd_sse.h127 send_packets_multi(struct lcore_conf *qconf, struct rte_mbuf **pkts_burst, in send_packets_multi() argument
147 processx4_step3(pkts_burst, dst_port); in send_packets_multi()
153 processx4_step3(&pkts_burst[j], &dst_port[j]); in send_packets_multi()
192 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
197 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
202 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
223 send_packetsx4(qconf, pn, pkts_burst + j, k); in send_packets_multi()
226 rte_pktmbuf_free(pkts_burst[m]); in send_packets_multi()
H A Dl3fwd_lpm.h79 l3fwd_lpm_no_opt_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_lpm_no_opt_send_packets() argument
86 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[j], void *)); in l3fwd_lpm_no_opt_send_packets()
90 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[ in l3fwd_lpm_no_opt_send_packets()
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_neon.h131 send_packets_multi(struct lcore_conf *qconf, struct rte_mbuf **pkts_burst, in send_packets_multi() argument
151 processx4_step3(pkts_burst, dst_port); in send_packets_multi()
157 processx4_step3(&pkts_burst[j], &dst_port[j]); in send_packets_multi()
195 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
200 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
205 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
226 send_packetsx4(qconf, pn, pkts_burst + j, k); in send_packets_multi()
229 rte_pktmbuf_free(pkts_burst[m]); in send_packets_multi()
H A Dl3fwd_fib.c79 struct rte_mbuf **pkts_burst, uint16_t hops[nb_tx]) in fib_send_single() argument
88 pkts_burst[j], struct rte_ether_hdr *) + 1), in fib_send_single()
89 &hops[j], pkts_burst[j]->packet_type); in fib_send_single()
93 eth_hdr = rte_pktmbuf_mtod(pkts_burst[j], in fib_send_single()
100 send_single_packet(qconf, pkts_burst[j], hops[j]); in fib_send_single()
127 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[ in fib_send_packets()
129 fib_parse_packet(pkts_burst[i], in fib_send_packets()
137 fib_parse_packet(pkts_burst[i], in fib_send_packets()
162 send_packets_multi(qconf, pkts_burst, hops, nb_rx); in fib_send_packets()
164 fib_send_single(nb_rx, qconf, pkts_burst, hops); in fib_send_packets()
[all …]
H A Dl3fwd_em_sequential.h76 l3fwd_em_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_em_send_packets() argument
83 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[0], in l3fwd_em_send_packets()
90 pkts_burst[i], in l3fwd_em_send_packets()
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()
H A Dl3fwd_em.h125 l3fwd_em_no_opt_send_packets(int nb_rx, struct rte_mbuf **pkts_burst, in l3fwd_em_no_opt_send_packets() argument
132 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[j], void *)); in l3fwd_em_no_opt_send_packets()
139 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[ in l3fwd_em_no_opt_send_packets()
141 l3fwd_em_simple_forward(pkts_burst[j], portid, qconf); in l3fwd_em_no_opt_send_packets()
146 l3fwd_em_simple_forward(pkts_burst[j], portid, qconf); in l3fwd_em_no_opt_send_packets()
/dpdk/app/test/
H A Dtest_pmd_perf.c339 struct rte_mbuf *pkts_burst[], in measure_rxtx() argument
351 pkts_burst, MAX_PKT_BURST); in measure_rxtx()
390 pkts_burst, MAX_PKT_BURST); in measure_rxonly()
427 pkts_burst, MAX_PKT_BURST); in measure_txonly()
518 pkts_burst, MAX_PKT_BURST); in main_loop()
548 struct rte_mbuf **pkts_burst; in poll_burst() local
566 pkts_burst = (struct rte_mbuf **) in poll_burst()
570 if (!pkts_burst) in poll_burst()
586 &pkts_burst[next[portid]], in poll_burst()
607 rte_pktmbuf_free(pkts_burst[i]); in poll_burst()
[all …]
H A Dtest_kni.c218 struct rte_mbuf *pkts_burst[PKT_BURST_SZ]; in test_kni_loop() local
242 pkts_burst[nb_rx] = rte_pktmbuf_alloc(mp); in test_kni_loop()
243 if (!pkts_burst[nb_rx]) in test_kni_loop()
247 num = rte_kni_tx_burst(test_kni_ctx, pkts_burst, in test_kni_loop()
253 rte_pktmbuf_free(pkts_burst[i]); in test_kni_loop()
262 num = rte_kni_rx_burst(test_kni_ctx, pkts_burst, in test_kni_loop()
266 rte_pktmbuf_free(pkts_burst[nb_tx]); in test_kni_loop()
/dpdk/examples/ntb/
H A Dntb_fwd.c438 fs.qp_id, pkts_burst, in start_iofwd_per_lcore()
472 fs.qp_id, pkts_burst, nb_rx); in start_iofwd_per_lcore()
552 pkts_burst[nb_pkt]->data_len = in start_txonly_per_lcore()
553 pkts_burst[nb_pkt]->buf_len - in start_txonly_per_lcore()
555 pkts_burst[nb_pkt]->pkt_len = in start_txonly_per_lcore()
556 pkts_burst[nb_pkt]->data_len; in start_txonly_per_lcore()
558 pkts_burst[nb_pkt]; in start_txonly_per_lcore()
562 pkts_burst[nb_pkt] = in start_txonly_per_lcore()
567 pkts_burst[nb_pkt]->data_len = in start_txonly_per_lcore()
570 pkts_burst[nb_pkt]->pkt_len = in start_txonly_per_lcore()
[all …]

12