| /f-stack/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 …]
|
| /f-stack/dpdk/app/test-pmd/ |
| H A D | txonly.c | 329 uint16_t nb_pkt; in pkt_burst_transmit() local
359 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in pkt_burst_transmit()
364 nb_pkt, fs))) { in pkt_burst_transmit()
366 (void **)&pkts_burst[nb_pkt], in pkt_burst_transmit()
367 nb_pkt_per_burst - nb_pkt); in pkt_burst_transmit()
372 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in pkt_burst_transmit()
380 nb_pkt, fs))) { in pkt_burst_transmit()
384 pkts_burst[nb_pkt] = pkt; in pkt_burst_transmit()
388 if (nb_pkt == 0) in pkt_burst_transmit()
410 if (unlikely(nb_tx < nb_pkt)) { in pkt_burst_transmit()
[all …]
|
| H A D | flowgen.c | 96 uint16_t nb_pkt; in pkt_burst_flow_gen() local
125 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { 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()
192 if (unlikely(nb_tx < nb_pkt)) { in pkt_burst_flow_gen()
194 next_flow -= (nb_pkt - nb_tx); in pkt_burst_flow_gen()
200 } while (++nb_tx < nb_pkt); in pkt_burst_flow_gen()
|
| H A D | testpmd.c | 1716 uint16_t nb_pkt; in pkt_burst_stats_display() local
1733 for (nb_pkt = 1; nb_pkt < MAX_PKT_BURST; nb_pkt++) { in pkt_burst_stats_display()
1734 nb_burst = pbs->pkt_burst_spread[nb_pkt]; in pkt_burst_stats_display()
1745 pktnb_stats[1] = nb_pkt; in pkt_burst_stats_display()
1748 pktnb_stats[2] = nb_pkt; in pkt_burst_stats_display()
|
| /f-stack/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 …]
|
| /f-stack/dpdk/app/test/ |
| H A D | packet_burst_generator.c | 264 int i, nb_pkt = 0; in generate_packet_burst() local
270 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in generate_packet_burst()
274 if (nb_pkt == 0) in generate_packet_burst()
332 pkts_burst[nb_pkt] = pkt; in generate_packet_burst()
335 return nb_pkt; in generate_packet_burst()
345 int i, nb_pkt = 0; in generate_packet_burst_proto() local
351 for (nb_pkt = 0; nb_pkt < nb_pkt_per_burst; nb_pkt++) { in generate_packet_burst_proto()
355 if (nb_pkt == 0) in generate_packet_burst_proto()
453 pkts_burst[nb_pkt] = pkt; in generate_packet_burst_proto()
456 return nb_pkt; in generate_packet_burst_proto()
|
| /f-stack/dpdk/lib/librte_acl/ |
| H A D | acl_run_avx512_common.h | 427 const int32_t pri[], const uint32_t match[], uint32_t nb_pkt, in _F_()
433 msk = (1 << nb_pkt) - 1; in _F_()
444 uint32_t nb_pkt, uint32_t nb_trie) in _F_()
453 for (k = 0; k != (nb_pkt & ~_SIMD_FLOW_MSK_); k += _SIMD_FLOW_NUM_) { in _F_()
458 nb_trie, nb_pkt); in _F_()
460 nb_trie, nb_pkt); in _F_()
466 n = nb_pkt - k; in _F_()
470 _SIMD_MASK_BIT_, nb_trie, nb_pkt); in _F_()
475 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
262 for (k = 0; k != nb_pkt; k++, result += nb_cat) { in resolve_mcgt8_avx512x1()
269 for (i = 1, pm = match + nb_pkt; i != nb_trie; in resolve_mcgt8_avx512x1()
270 i++, pm += nb_pkt) { in resolve_mcgt8_avx512x1()
|
| /f-stack/dpdk/lib/librte_power/ |
| H A D | rte_power_empty_poll.h | 186 rte_power_poll_stat_update(unsigned int lcore_id, uint8_t nb_pkt);
|
| H A D | rte_power_empty_poll.c | 493 rte_power_poll_stat_update(unsigned int lcore_id, uint8_t nb_pkt) in rte_power_poll_stat_update() argument
506 poll_stats->num_dequeue_pkts += nb_pkt; in rte_power_poll_stat_update()
|
| /f-stack/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 | 113 It returns zero if using nb_pkt < 32 as the expected packet number in the receive handler.
|
| /f-stack/dpdk/doc/guides/howto/ |
| H A D | debug_troubleshoot.rst | 136 * Check the ``nb_pkt`` in ``rte_eth_tx_burst`` is done for multiple packets.
|