Home
last modified time | relevance | path

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

123

/f-stack/dpdk/examples/l3fwd/
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_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_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_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_altivec.h153 send_packets_multi(struct lcore_conf *qconf, struct rte_mbuf **pkts_burst, in send_packets_multi() argument
173 processx4_step3(pkts_burst, dst_port); in send_packets_multi()
179 processx4_step3(&pkts_burst[j], &dst_port[j]); in send_packets_multi()
220 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
225 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
230 process_packet(pkts_burst[j], dst_port + j); in send_packets_multi()
251 send_packetsx4(qconf, pn, pkts_burst + j, k); in send_packets_multi()
254 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_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_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_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()
/f-stack/dpdk/app/test-pmd/
H A Dmacswap.c55 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_mac_swap() local
67 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_swap()
76 do_macswap(pkts_burst, nb_rx, txp); in pkt_burst_mac_swap()
78 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_swap()
87 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_swap()
95 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_swap()
H A Dmacfwd.c49 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_mac_forward() local
66 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_forward()
83 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in pkt_burst_mac_forward()
85 mb = pkts_burst[i]; in pkt_burst_mac_forward()
98 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_forward()
107 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_mac_forward()
116 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_mac_forward()
H A Diofwd.c49 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_io_forward() local
61 pkts_burst, nb_pkt_per_burst); in pkt_burst_io_forward()
68 pkts_burst, nb_rx); in pkt_burst_io_forward()
77 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_io_forward()
85 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.c86 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_flow_gen() local
106 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_flow_gen()
111 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_flow_gen()
172 pkts_burst[nb_pkt] = pkt; in pkt_burst_flow_gen()
177 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
186 &pkts_burst[nb_tx], nb_rx - nb_tx); in pkt_burst_flow_gen()
199 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.c276 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in reply_to_icmp_echo_rqsts() local
303 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
313 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in reply_to_icmp_echo_rqsts()
315 pkt = pkts_burst[i]; in reply_to_icmp_echo_rqsts()
405 pkts_burst[nb_replies++] = pkt; in reply_to_icmp_echo_rqsts()
482 pkts_burst[nb_replies++] = pkt; in reply_to_icmp_echo_rqsts()
487 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
499 &pkts_burst[nb_tx], in reply_to_icmp_echo_rqsts()
508 rte_pktmbuf_free(pkts_burst[nb_tx]); in reply_to_icmp_echo_rqsts()
H A Drxonly.c49 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_receive() local
59 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
67 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_receive()
H A Dtxonly.c323 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_transmit() local
357 if (rte_mempool_get_bulk(mbp, (void **)pkts_burst, in pkt_burst_transmit()
360 if (unlikely(!pkt_burst_prepare(pkts_burst[nb_pkt], mbp, in pkt_burst_transmit()
366 (void **)&pkts_burst[nb_pkt], in pkt_burst_transmit()
384 pkts_burst[nb_pkt] = pkt; in pkt_burst_transmit()
391 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_transmit()
401 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_transmit()
419 rte_pktmbuf_free(pkts_burst[nb_tx]); in pkt_burst_transmit()
H A Dcsumonly.c796 struct rte_mbuf *pkts_burst[MAX_PKT_BURST]; in pkt_burst_checksum_forward() local
848 rte_prefetch0(rte_pktmbuf_mtod(pkts_burst[i + 1], in pkt_burst_checksum_forward()
851 m = pkts_burst[i]; in pkt_burst_checksum_forward()
996 pkts_burst[i] = m; in pkt_burst_checksum_forward()
1054 nb_rx = rte_gro_reassemble_burst(pkts_burst, nb_rx, in pkt_burst_checksum_forward()
1067 &pkts_burst[nb_rx], in pkt_burst_checksum_forward()
1075 tx_pkts_burst = pkts_burst; in pkt_burst_checksum_forward()
1080 ret = rte_gso_segment(pkts_burst[i], gso_ctx, in pkt_burst_checksum_forward()
1085 rte_pktmbuf_free(pkts_burst[i]); in pkt_burst_checksum_forward()
1091 gso_segments[nb_segments] = pkts_burst[i]; in pkt_burst_checksum_forward()
[all …]
/f-stack/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()
506 pkts_burst, MAX_PKT_BURST); in main_loop()
536 struct rte_mbuf **pkts_burst; in poll_burst() local
554 pkts_burst = (struct rte_mbuf **) in poll_burst()
558 if (!pkts_burst) in poll_burst()
575 &pkts_burst[next[portid]], in poll_burst()
596 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()
/f-stack/lib/
H A Dff_dpdk_kni.c201 struct rte_mbuf **pkts_burst, unsigned count) in kni_process_tx() argument
205 nb_tx = rte_ring_dequeue_burst(kni_rp[port_id], (void **)pkts_burst, count, NULL); in kni_process_tx()
212 nb_kni_tx = rte_kni_tx_burst(kni_stat[port_id]->kni, pkts_burst, nb_tx); in kni_process_tx()
217 rte_pktmbuf_free(pkts_burst[i]); in kni_process_tx()
228 struct rte_mbuf **pkts_burst, unsigned count) in kni_process_rx() argument
233 nb_kni_rx = rte_kni_rx_burst(kni_stat[port_id]->kni, pkts_burst, count); in kni_process_rx()
235 nb_rx = rte_eth_tx_burst(port_id, queue_id, pkts_burst, nb_kni_rx); in kni_process_rx()
239 rte_pktmbuf_free(pkts_burst[i]); in kni_process_rx()
555 struct rte_mbuf **pkts_burst, unsigned count) in ff_kni_process() argument
557 kni_process_tx(port_id, queue_id, pkts_burst, count); in ff_kni_process()
[all …]
/f-stack/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 …]
/f-stack/dpdk/examples/performance-thread/l3fwd-thread/
H A Dmain.c1725 pkts_burst[j]->packet_type & in process_burst()
1726 pkts_burst[j+1]->packet_type & in process_burst()
1727 pkts_burst[j+2]->packet_type & in process_burst()
1728 pkts_burst[j+3]->packet_type & in process_burst()
1729 pkts_burst[j+4]->packet_type & in process_burst()
1730 pkts_burst[j+5]->packet_type & in process_burst()
1731 pkts_burst[j+6]->packet_type & in process_burst()
1732 pkts_burst[j+7]->packet_type; in process_burst()
2052 portid = pkts_burst[0]->port; in lthread_tx_per_ring()
2186 (void **) pkts_burst, in lthread_rx()
[all …]

123