Home
last modified time | relevance | path

Searched refs:n_pkts (Results 1 – 25 of 46) sorted by relevance

12

/dpdk/lib/port/
H A Drte_swx_port_ring.c34 int n_pkts; member
89 int n_pkts; in reader_pkt_rx() local
95 if (!n_pkts) { in reader_pkt_rx()
102 n_pkts); in reader_pkt_rx()
104 p->n_pkts = n_pkts; in reader_pkt_rx()
174 int n_pkts; member
224 int n_pkts; in __writer_flush() local
229 p->n_pkts - n_pkts, in __writer_flush()
234 if (n_pkts == p->n_pkts) in __writer_flush()
238 p->n_pkts = 0; in __writer_flush()
[all …]
H A Drte_swx_port_ethdev.c42 int n_pkts; member
92 int n_pkts; in reader_pkt_rx() local
98 if (!n_pkts) { in reader_pkt_rx()
106 n_pkts); in reader_pkt_rx()
108 p->n_pkts = n_pkts; in reader_pkt_rx()
175 int n_pkts; member
220 int n_pkts; in __writer_flush() local
226 p->n_pkts - n_pkts); in __writer_flush()
233 if (n_pkts == p->n_pkts) in __writer_flush()
237 p->n_pkts = 0; in __writer_flush()
[all …]
H A Drte_port_frag.c48 uint32_t n_pkts; member
102 port->n_pkts = 0; in rte_port_ring_reader_frag_create()
128 uint32_t n_pkts) in rte_port_ring_reader_frag_rx() argument
139 p->pos_frags += n_pkts; in rte_port_ring_reader_frag_rx()
140 p->n_frags -= n_pkts; in rte_port_ring_reader_frag_rx()
142 return n_pkts; in rte_port_ring_reader_frag_rx()
156 if (p->n_pkts == 0) { in rte_port_ring_reader_frag_rx()
161 if (p->n_pkts == 0) in rte_port_ring_reader_frag_rx()
168 p->n_pkts--; in rte_port_ring_reader_frag_rx()
176 return n_pkts; in rte_port_ring_reader_frag_rx()
[all …]
H A Drte_swx_port_fd.c36 uint32_t n_pkts; member
95 if (p->n_pkts == p->pos) { in reader_pkt_rx()
110 p->stats.n_pkts++; in reader_pkt_rx()
117 p->n_pkts = i; in reader_pkt_rx()
120 if (!p->n_pkts) in reader_pkt_rx()
164 uint32_t n_pkts; member
217 p->n_pkts); in __writer_flush()
222 p->n_pkts = 0; in __writer_flush()
233 p->n_pkts - 1, in writer_pkt_tx()
244 p->stats.n_pkts++; in writer_pkt_tx()
[all …]
H A Drte_port_source_sink.c44 uint32_t n_pkts; member
56 uint32_t n_pkts = 0; in pcap_source_load() local
84 n_pkts++; in pcap_source_load()
117 for (i = 0; i < n_pkts; i++) { in pcap_source_load()
145 for (i = 0; i < n_pkts; i++) { in pcap_source_load()
154 port->n_pkts = n_pkts; in pcap_source_load()
160 file_name, port->n_pkts); in pcap_source_load()
259 for (i = 0; i < n_pkts; i++) { in rte_port_source_rx()
269 if (p->pkt_index >= p->n_pkts) in rte_port_source_rx()
276 return n_pkts; in rte_port_source_rx()
[all …]
H A Drte_port_kni.c69 rx_pkt_cnt = rte_kni_rx_burst(p->kni, pkts, n_pkts); in rte_port_kni_reader_rx()
203 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_kni_writer_tx_bulk() local
209 RTE_PORT_KNI_WRITER_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_kni_writer_tx_bulk()
210 n_pkts_ok = rte_kni_tx_burst(p->kni, pkts, n_pkts); in rte_port_kni_writer_tx_bulk()
212 RTE_PORT_KNI_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - n_pkts_ok); in rte_port_kni_writer_tx_bulk()
213 for (; n_pkts_ok < n_pkts; n_pkts_ok++) { in rte_port_kni_writer_tx_bulk()
407 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_kni_writer_nodrop_tx_bulk() local
413 RTE_PORT_KNI_WRITER_NODROP_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_kni_writer_nodrop_tx_bulk()
414 n_pkts_ok = rte_kni_tx_burst(p->kni, pkts, n_pkts); in rte_port_kni_writer_nodrop_tx_bulk()
416 if (n_pkts_ok >= n_pkts) in rte_port_kni_writer_nodrop_tx_bulk()
[all …]
H A Drte_port_eventdev.c74 p->ev, n_pkts, 0); in rte_port_eventdev_reader_rx()
234 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_eventdev_writer_tx_bulk() local
243 for (i = 0; i < n_pkts; i++) { in rte_port_eventdev_writer_tx_bulk()
251 events, n_pkts); in rte_port_eventdev_writer_tx_bulk()
254 n_pkts - n_enq_ok); in rte_port_eventdev_writer_tx_bulk()
255 for (; n_enq_ok < n_pkts; n_enq_ok++) in rte_port_eventdev_writer_tx_bulk()
466 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_eventdev_writer_nodrop_tx_bulk() local
476 for (i = 0; i < n_pkts; i++) { in rte_port_eventdev_writer_nodrop_tx_bulk()
484 events, n_pkts); in rte_port_eventdev_writer_nodrop_tx_bulk()
486 if (n_enq_ok >= n_pkts) in rte_port_eventdev_writer_nodrop_tx_bulk()
[all …]
H A Drte_port_ring.c86 n_pkts, NULL); in rte_port_ring_reader_rx()
94 uint32_t n_pkts) in rte_port_ring_multi_reader_rx() argument
100 n_pkts, NULL); in rte_port_ring_multi_reader_rx()
282 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_ring_writer_tx_bulk_internal() local
295 (void **)pkts, n_pkts, NULL); in rte_port_ring_writer_tx_bulk_internal()
298 (void **)pkts, n_pkts, NULL); in rte_port_ring_writer_tx_bulk_internal()
301 for ( ; n_pkts_ok < n_pkts; n_pkts_ok++) { in rte_port_ring_writer_tx_bulk_internal()
612 (void **)pkts, n_pkts, NULL); in rte_port_ring_writer_nodrop_tx_bulk_internal()
616 (void **)pkts, n_pkts, NULL); in rte_port_ring_writer_nodrop_tx_bulk_internal()
618 if (n_pkts_ok >= n_pkts) in rte_port_ring_writer_nodrop_tx_bulk_internal()
[all …]
H A Drte_port_ethdev.c72 rx_pkt_cnt = rte_eth_rx_burst(p->port_id, p->queue_id, pkts, n_pkts); in rte_port_ethdev_reader_rx()
209 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_ethdev_writer_tx_bulk() local
215 RTE_PORT_ETHDEV_WRITER_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_ethdev_writer_tx_bulk()
217 n_pkts); in rte_port_ethdev_writer_tx_bulk()
219 RTE_PORT_ETHDEV_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - n_pkts_ok); in rte_port_ethdev_writer_tx_bulk()
220 for ( ; n_pkts_ok < n_pkts; n_pkts_ok++) { in rte_port_ethdev_writer_tx_bulk()
416 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_ethdev_writer_nodrop_tx_bulk() local
422 RTE_PORT_ETHDEV_WRITER_NODROP_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_ethdev_writer_nodrop_tx_bulk()
424 n_pkts); in rte_port_ethdev_writer_nodrop_tx_bulk()
426 if (n_pkts_ok >= n_pkts) in rte_port_ethdev_writer_nodrop_tx_bulk()
[all …]
H A Drte_swx_port_source_sink.c46 uint32_t n_pkts; member
59 for (i = 0; i < p->n_pkts; i++) in source_free()
124 p->pkts[p->n_pkts] = m; in source_create()
125 p->n_pkts++; in source_create()
128 if (!p->n_pkts) in source_create()
180 p->stats.n_pkts++; in source_pkt_rx()
185 if (p->pos == p->n_pkts) { in source_pkt_rx()
302 p->stats.n_pkts++; in sink_pkt_tx()
H A Drte_port_fd.c79 rte_port_fd_reader_rx(void *port, struct rte_mbuf **pkts, uint32_t n_pkts) in rte_port_fd_reader_rx() argument
84 if (rte_pktmbuf_alloc_bulk(p->mempool, pkts, n_pkts) != 0) in rte_port_fd_reader_rx()
87 for (i = 0; i < n_pkts; i++) { in rte_port_fd_reader_rx()
100 for (j = i; j < n_pkts; j++) in rte_port_fd_reader_rx()
242 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_fd_writer_tx_bulk() local
245 for (i = 0; i < n_pkts; i++) in rte_port_fd_writer_tx_bulk()
247 RTE_PORT_FD_WRITER_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_fd_writer_tx_bulk()
427 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_fd_writer_nodrop_tx_bulk() local
430 for (i = 0; i < n_pkts; i++) in rte_port_fd_writer_nodrop_tx_bulk()
432 RTE_PORT_FD_WRITER_NODROP_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_fd_writer_nodrop_tx_bulk()
H A Drte_port_sym_crypto.c69 rte_port_sym_crypto_reader_rx(void *port, struct rte_mbuf **pkts, uint32_t n_pkts) in rte_port_sym_crypto_reader_rx() argument
76 p->ops, n_pkts); in rte_port_sym_crypto_reader_rx()
238 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_sym_crypto_writer_tx_bulk() local
241 RTE_PORT_SYM_CRYPTO_WRITER_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_sym_crypto_writer_tx_bulk()
243 for (i = 0; i < n_pkts; i++) in rte_port_sym_crypto_writer_tx_bulk()
450 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_sym_crypto_writer_nodrop_tx_bulk() local
453 RTE_PORT_SYM_CRYPTO_WRITER_NODROP_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_sym_crypto_writer_nodrop_tx_bulk()
455 for (i = 0; i < n_pkts; i++) in rte_port_sym_crypto_writer_nodrop_tx_bulk()
H A Drte_port_sched.c62 rte_port_sched_reader_rx(void *port, struct rte_mbuf **pkts, uint32_t n_pkts) in rte_port_sched_reader_rx() argument
67 nb_rx = rte_sched_port_dequeue(p->sched, pkts, n_pkts); in rte_port_sched_reader_rx()
194 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_sched_writer_tx_bulk() local
203 nb_tx = rte_sched_port_enqueue(p->sched, pkts, n_pkts); in rte_port_sched_writer_tx_bulk()
204 RTE_PORT_SCHED_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - nb_tx); in rte_port_sched_writer_tx_bulk()
H A Drte_swx_port.h78 uint64_t n_pkts; member
162 uint64_t n_pkts; member
H A Drte_port_sym_crypto.h29 uint16_t n_pkts, void *arg);
H A Drte_port_ras.c237 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_ring_writer_ras_tx_bulk() local
240 for (i = 0; i < n_pkts; i++) { in rte_port_ring_writer_ras_tx_bulk()
/dpdk/lib/pipeline/
H A Drte_swx_pipeline_internal.h3569 n_pkts = m->n_pkts[color_out]; in __instr_meter_hhm_exec()
3602 n_pkts = m->n_pkts[color_out]; in __instr_meter_hhi_exec()
3635 n_pkts = m->n_pkts[color_out]; in __instr_meter_hmm_exec()
3668 n_pkts = m->n_pkts[color_out]; in __instr_meter_hmi_exec()
3701 n_pkts = m->n_pkts[color_out]; in __instr_meter_mhm_exec()
3734 n_pkts = m->n_pkts[color_out]; in __instr_meter_mhi_exec()
3767 n_pkts = m->n_pkts[color_out]; in __instr_meter_mmm_exec()
3800 n_pkts = m->n_pkts[color_out]; in __instr_meter_mmi_exec()
3833 n_pkts = m->n_pkts[color_out]; in __instr_meter_ihm_exec()
3866 n_pkts = m->n_pkts[color_out]; in __instr_meter_ihi_exec()
[all …]
H A Drte_port_in_action.c387 uint32_t n_pkts, in ah_filter_on_match() argument
399 for (i = 0; i < n_pkts; i++) { in ah_filter_on_match()
421 uint32_t n_pkts, in ah_filter_on_mismatch() argument
433 for (i = 0; i < n_pkts; i++) { in ah_filter_on_mismatch()
455 uint32_t n_pkts, in ah_lb() argument
461 uint64_t pkt_mask = RTE_LEN2MASK(n_pkts, uint64_t); in ah_lb()
466 for (i = 0; i < n_pkts; i++) { in ah_lb()
H A Drte_pipeline.c1089 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_compute_masks() local
1092 for (i = 0; i < n_pkts; i++) { in rte_pipeline_compute_masks()
1143 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_action_handler_port() local
1146 for (i = 0; i < n_pkts; i++) { in rte_pipeline_action_handler_port()
1216 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_action_handler_port_meta() local
1219 for (i = 0; i < n_pkts; i++) { in rte_pipeline_action_handler_port_meta()
1292 for (i = 0; i < n_pkts; i++) in rte_pipeline_action_handler_drop()
1312 uint32_t n_pkts, table_id; in rte_pipeline_run() local
1320 if (n_pkts == 0) { in rte_pipeline_run()
1325 p->pkts_mask = RTE_LEN2MASK(n_pkts, uint64_t); in rte_pipeline_run()
[all …]
/dpdk/app/test-pipeline/
H A Druntime.c114 uint16_t n_mbufs, n_pkts; in app_main_loop_tx() local
135 n_pkts = rte_eth_tx_burst( in app_main_loop_tx()
141 if (n_pkts < n_mbufs) { in app_main_loop_tx()
144 for (k = n_pkts; k < n_mbufs; k++) { in app_main_loop_tx()
/dpdk/lib/sched/
H A Drte_sched.h255 uint64_t n_pkts; member
560 rte_sched_port_enqueue(struct rte_sched_port *port, struct rte_mbuf **pkts, uint32_t n_pkts);
580 rte_sched_port_dequeue(struct rte_sched_port *port, struct rte_mbuf **pkts, uint32_t n_pkts);
/dpdk/lib/node/
H A Dethdev_rx.c45 uint16_t n_pkts = 0; in ethdev_rx_node_process() local
50 n_pkts = ethdev_rx_node_process_inline(graph, node, ctx); in ethdev_rx_node_process()
51 return n_pkts; in ethdev_rx_node_process()
/dpdk/lib/table/
H A Drte_table_array.c154 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_table_array_lookup() local
157 for (i = 0; i < n_pkts; i++) { in rte_table_array_lookup()
H A Drte_table_acl.c725 uint32_t n_pkts, i, j; in rte_table_acl_lookup() local
740 n_pkts = j; in rte_table_acl_lookup()
744 rte_acl_classify(acl->ctx, pkts_data, results, n_pkts, 1); in rte_table_acl_lookup()
746 n_pkts = 0; in rte_table_acl_lookup()
750 for (i = 0; i < n_pkts; i++) { in rte_table_acl_lookup()
/dpdk/drivers/net/memif/
H A Drte_eth_memif.c432 mq->n_pkts += n_rx_pkts; in eth_memif_rx()
558 mq->n_pkts += n_rx_pkts; in eth_memif_rx_zc()
693 mq->n_pkts += n_tx_pkts; in eth_memif_tx()
850 mq->n_pkts += n_tx_pkts; in eth_memif_tx_zc()
1336 mq->n_pkts = 0; in memif_tx_queue_setup()
1376 mq->n_pkts = 0; in memif_rx_queue_setup()
1455 stats->q_ipackets[i] = mq->n_pkts; in memif_stats_get()
1457 stats->ipackets += mq->n_pkts; in memif_stats_get()
1471 stats->opackets += mq->n_pkts; in memif_stats_get()
1487 mq->n_pkts = 0; in memif_stats_reset()
[all …]

12