| /dpdk/examples/qos_sched/ |
| H A D | app_thread.c | 140 for(i = 0; i < nb_pkt; i++) { in app_send_packets()
200 uint32_t nb_pkt; in app_worker_thread() local
205 if (likely(nb_pkt)) { in app_worker_thread()
207 nb_pkt); in app_worker_thread()
215 if (likely(nb_pkt > 0)) in app_worker_thread()
217 (void **)mbufs, nb_pkt, NULL) == 0) in app_worker_thread()
236 uint32_t nb_pkt; in app_mixed_thread() local
241 if (likely(nb_pkt)) { in app_mixed_thread()
243 nb_pkt); in app_mixed_thread()
252 if (likely(nb_pkt > 0)) { in app_mixed_thread()
[all …]
|
| /dpdk/examples/ntb/ |
| H A D | ntb_fwd.c | 220 unsigned int nb_pkt; in cmd_sendfile_parsed() local
269 for (nb_pkt = 0; nb_pkt < val; nb_pkt++) { in cmd_sendfile_parsed()
276 pkts_send[nb_pkt]->buf_addr = mbuf_send[nb_pkt]; in cmd_sendfile_parsed()
279 for (nb_pkt = 0; nb_pkt < val; nb_pkt++) { in cmd_sendfile_parsed()
280 mbuf_send[nb_pkt] = in cmd_sendfile_parsed()
290 pkts_send[nb_pkt]->buf_addr = mbuf_send[nb_pkt]; in cmd_sendfile_parsed()
316 count -= nb_pkt; in cmd_sendfile_parsed()
538 uint16_t nb_pkt, nb_tx; in start_txonly_per_lcore() local
550 for (nb_pkt = 0; nb_pkt < pkt_burst; nb_pkt++) { in start_txonly_per_lcore()
558 pkts_burst[nb_pkt]; in start_txonly_per_lcore()
[all …]
|
| /dpdk/app/test-pmd/ |
| H A D | txonly.c | 336 uint16_t nb_pkt; in pkt_burst_transmit() local
366 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in pkt_burst_transmit()
371 nb_pkt, fs))) { in pkt_burst_transmit()
373 (void **)&pkts_burst[nb_pkt], in pkt_burst_transmit()
374 nb_pkt_per_burst - nb_pkt); in pkt_burst_transmit()
379 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in pkt_burst_transmit()
387 nb_pkt, fs))) { in pkt_burst_transmit()
391 pkts_burst[nb_pkt] = pkt; in pkt_burst_transmit()
395 if (nb_pkt == 0) in pkt_burst_transmit()
417 if (unlikely(nb_tx < nb_pkt)) { in pkt_burst_transmit()
[all …]
|
| H A D | flowgen.c | 77 uint16_t nb_pkt; in pkt_burst_flow_gen() local
108 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in pkt_burst_flow_gen()
109 if (!nb_pkt || !nb_clones) { 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()
174 if (unlikely(nb_tx < nb_pkt) && fs->retry_enabled) { in pkt_burst_flow_gen()
176 while (nb_tx < nb_pkt && retry++ < burst_tx_retry_num) { in pkt_burst_flow_gen()
179 &pkts_burst[nb_tx], nb_pkt - nb_tx); in pkt_burst_flow_gen()
185 nb_dropped = nb_pkt - nb_tx; in pkt_burst_flow_gen()
195 } while (++nb_tx < nb_pkt); in pkt_burst_flow_gen()
|
| H A D | testpmd.c | 1864 uint16_t nb_pkt; in pkt_burst_stats_display() local
1881 for (nb_pkt = 1; nb_pkt < MAX_PKT_BURST + 1; nb_pkt++) { in pkt_burst_stats_display()
1882 nb_burst = pbs->pkt_burst_spread[nb_pkt]; in pkt_burst_stats_display()
1893 pktnb_stats[1] = nb_pkt; in pkt_burst_stats_display()
1896 pktnb_stats[2] = nb_pkt; in pkt_burst_stats_display()
|
| /dpdk/app/test/ |
| H A D | packet_burst_generator.c | 266 int i, nb_pkt = 0; in generate_packet_burst() local
272 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in generate_packet_burst()
276 if (nb_pkt == 0) in generate_packet_burst()
334 pkts_burst[nb_pkt] = pkt; in generate_packet_burst()
337 return nb_pkt; in generate_packet_burst()
347 int i, nb_pkt = 0; in generate_packet_burst_proto() local
353 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in generate_packet_burst_proto()
357 if (nb_pkt == 0) in generate_packet_burst_proto()
455 pkts_burst[nb_pkt] = pkt; in generate_packet_burst_proto()
458 return nb_pkt; in generate_packet_burst_proto()
|
| /dpdk/lib/acl/ |
| H A D | acl_run_avx512_common.h | 451 const int32_t pri[], const uint32_t match[], uint32_t nb_pkt, in _F_()
457 msk = (1 << nb_pkt) - 1; in _F_()
468 uint32_t nb_pkt, uint32_t nb_trie) in _F_()
477 for (k = 0; k != (nb_pkt & ~_SIMD_FLOW_MSK_); k += _SIMD_FLOW_NUM_) { in _F_()
482 nb_trie, nb_pkt); in _F_()
484 nb_trie, nb_pkt); in _F_()
490 n = nb_pkt - k; in _F_()
494 _SIMD_MASK_BIT_, nb_trie, nb_pkt); in _F_()
499 nb_trie, nb_pkt); in _F_()
|
| H A D | acl_run_avx512.c | 72 uint32_t nb_pkt, uint32_t nb_cat, uint32_t nb_trie) in resolve_mcle8_avx512x1() argument
83 for (k = 0; k != nb_pkt; k++, result += nb_cat) { in resolve_mcle8_avx512x1()
92 for (i = 1, pm = match + nb_pkt; i != nb_trie; in resolve_mcle8_avx512x1()
93 i++, pm += nb_pkt) { in resolve_mcle8_avx512x1()
|
| H A D | acl_run_avx512x16.h | 247 uint32_t nb_pkt, uint32_t nb_cat, uint32_t nb_trie) in resolve_mcgt8_avx512x1() argument
260 for (k = 0; k != nb_pkt; k++, result += nb_cat) { in resolve_mcgt8_avx512x1()
267 for (i = 1, pm = match + nb_pkt; i != nb_trie; in resolve_mcgt8_avx512x1()
268 i++, pm += nb_pkt) { in resolve_mcgt8_avx512x1()
|
| /dpdk/lib/power/ |
| H A D | rte_power_empty_poll.h | 181 rte_power_poll_stat_update(unsigned int lcore_id, uint8_t nb_pkt);
|
| H A D | rte_power_empty_poll.c | 480 rte_power_poll_stat_update(unsigned int lcore_id, uint8_t nb_pkt) in rte_power_poll_stat_update() argument
493 poll_stats->num_dequeue_pkts += nb_pkt; in rte_power_poll_stat_update()
|
| /dpdk/doc/guides/nics/ |
| H A D | fm10k.rst | 95 ``nb_pkt`` < 4 in the receive handler. If ``nb_pkt`` is not a multiple of 4, a
|
| H A D | ixgbe.rst | 133 It returns zero if using nb_pkt < 32 as the expected packet number in the receive handler.
|
| /dpdk/doc/guides/howto/ |
| H A D | debug_troubleshoot.rst | 134 * Check the ``nb_pkt`` in ``rte_eth_tx_burst`` is done for multiple packets.
|