Home
last modified time | relevance | path

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

12

/f-stack/dpdk/lib/librte_port/
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.c50 uint32_t n_pkts; member
104 port->n_pkts = 0; in rte_port_ring_reader_frag_create()
130 uint32_t n_pkts) in rte_port_ring_reader_frag_rx() argument
141 p->pos_frags += n_pkts; in rte_port_ring_reader_frag_rx()
142 p->n_frags -= n_pkts; in rte_port_ring_reader_frag_rx()
144 return n_pkts; in rte_port_ring_reader_frag_rx()
158 if (p->n_pkts == 0) { in rte_port_ring_reader_frag_rx()
163 if (p->n_pkts == 0) in rte_port_ring_reader_frag_rx()
170 p->n_pkts--; in rte_port_ring_reader_frag_rx()
178 return n_pkts; in rte_port_ring_reader_frag_rx()
[all …]
H A Drte_port_source_sink.c45 uint32_t n_pkts; member
57 uint32_t n_pkts = 0; in pcap_source_load() local
85 n_pkts++; in pcap_source_load()
118 for (i = 0; i < n_pkts; i++) { in pcap_source_load()
146 for (i = 0; i < n_pkts; i++) { in pcap_source_load()
155 port->n_pkts = n_pkts; in pcap_source_load()
161 file_name, port->n_pkts); in pcap_source_load()
267 for (i = 0; i < n_pkts; i++) { in rte_port_source_rx()
277 if (p->pkt_index >= p->n_pkts) in rte_port_source_rx()
284 return n_pkts; in rte_port_source_rx()
[all …]
H A Drte_port_kni.c70 rx_pkt_cnt = rte_kni_rx_burst(p->kni, pkts, n_pkts); in rte_port_kni_reader_rx()
204 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_kni_writer_tx_bulk() local
210 RTE_PORT_KNI_WRITER_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_kni_writer_tx_bulk()
211 n_pkts_ok = rte_kni_tx_burst(p->kni, pkts, n_pkts); in rte_port_kni_writer_tx_bulk()
213 RTE_PORT_KNI_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - n_pkts_ok); in rte_port_kni_writer_tx_bulk()
214 for (; n_pkts_ok < n_pkts; n_pkts_ok++) { in rte_port_kni_writer_tx_bulk()
408 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_kni_writer_nodrop_tx_bulk() local
414 RTE_PORT_KNI_WRITER_NODROP_STATS_PKTS_IN_ADD(p, n_pkts); in rte_port_kni_writer_nodrop_tx_bulk()
415 n_pkts_ok = rte_kni_tx_burst(p->kni, pkts, n_pkts); in rte_port_kni_writer_nodrop_tx_bulk()
417 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_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_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_swx_port_source_sink.c45 uint32_t n_pkts; member
58 for (i = 0; i < p->n_pkts; i++) in source_free()
121 p->pkts[p->n_pkts] = m; in source_create()
122 p->n_pkts++; in source_create()
125 if (!p->n_pkts) in source_create()
175 p->stats.n_pkts++; in source_pkt_rx()
180 if (p->pos == p->n_pkts) in source_pkt_rx()
295 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_sched.c63 rte_port_sched_reader_rx(void *port, struct rte_mbuf **pkts, uint32_t n_pkts) in rte_port_sched_reader_rx() argument
68 nb_rx = rte_sched_port_dequeue(p->sched, pkts, n_pkts); in rte_port_sched_reader_rx()
195 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_sched_writer_tx_bulk() local
204 nb_tx = rte_sched_port_enqueue(p->sched, pkts, n_pkts); in rte_port_sched_writer_tx_bulk()
205 RTE_PORT_SCHED_WRITER_STATS_PKTS_DROP_ADD(p, n_pkts - nb_tx); in rte_port_sched_writer_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_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.h98 uint32_t n_pkts);
H A Drte_port_ras.c238 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_port_ring_writer_ras_tx_bulk() local
241 for (i = 0; i < n_pkts; i++) { in rte_port_ring_writer_ras_tx_bulk()
/f-stack/dpdk/app/test-pipeline/
H A Druntime.c115 uint16_t n_mbufs, n_pkts; in app_main_loop_tx() local
136 n_pkts = rte_eth_tx_burst( in app_main_loop_tx()
142 if (n_pkts < n_mbufs) { in app_main_loop_tx()
145 for (k = n_pkts; k < n_mbufs; k++) { in app_main_loop_tx()
/f-stack/dpdk/lib/librte_pipeline/
H A Drte_port_in_action.c389 uint32_t n_pkts, in ah_filter_on_match() argument
401 for (i = 0; i < n_pkts; i++) { in ah_filter_on_match()
423 uint32_t n_pkts, in ah_filter_on_mismatch() argument
435 for (i = 0; i < n_pkts; i++) { in ah_filter_on_mismatch()
457 uint32_t n_pkts, in ah_lb() argument
463 uint64_t pkt_mask = RTE_LEN2MASK(n_pkts, uint64_t); in ah_lb()
468 for (i = 0; i < n_pkts; i++) { in ah_lb()
H A Drte_pipeline.c1093 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_compute_masks() local
1096 for (i = 0; i < n_pkts; i++) { in rte_pipeline_compute_masks()
1147 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_action_handler_port() local
1150 for (i = 0; i < n_pkts; i++) { in rte_pipeline_action_handler_port()
1220 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_pipeline_action_handler_port_meta() local
1223 for (i = 0; i < n_pkts; i++) { in rte_pipeline_action_handler_port_meta()
1296 for (i = 0; i < n_pkts; i++) in rte_pipeline_action_handler_drop()
1316 uint32_t n_pkts, table_id; in rte_pipeline_run() local
1324 if (n_pkts == 0) { in rte_pipeline_run()
1329 p->pkts_mask = RTE_LEN2MASK(n_pkts, uint64_t); in rte_pipeline_run()
[all …]
/f-stack/dpdk/lib/librte_sched/
H A Drte_sched.h220 uint64_t n_pkts; member
531 rte_sched_port_enqueue(struct rte_sched_port *port, struct rte_mbuf **pkts, uint32_t n_pkts);
551 rte_sched_port_dequeue(struct rte_sched_port *port, struct rte_mbuf **pkts, uint32_t n_pkts);
/f-stack/dpdk/lib/librte_node/
H A Dethdev_rx.c46 uint16_t n_pkts = 0; in ethdev_rx_node_process() local
51 n_pkts = ethdev_rx_node_process_inline(graph, node, ctx); in ethdev_rx_node_process()
52 return n_pkts; in ethdev_rx_node_process()
/f-stack/dpdk/lib/librte_table/
H A Drte_table_array.c156 uint64_t n_pkts = __builtin_popcountll(pkts_mask); in rte_table_array_lookup() local
159 for (i = 0; i < n_pkts; i++) { in rte_table_array_lookup()
H A Drte_table_acl.c728 uint32_t n_pkts, i, j; in rte_table_acl_lookup() local
743 n_pkts = j; in rte_table_acl_lookup()
747 rte_acl_classify(acl->ctx, pkts_data, results, n_pkts, 1); in rte_table_acl_lookup()
749 n_pkts = 0; in rte_table_acl_lookup()
753 for (i = 0; i < n_pkts; i++) { in rte_table_acl_lookup()
/f-stack/dpdk/drivers/net/memif/
H A Drte_eth_memif.c431 mq->n_pkts += n_rx_pkts; in eth_memif_rx()
555 mq->n_pkts += n_rx_pkts; in eth_memif_rx_zc()
686 mq->n_pkts += n_tx_pkts; in eth_memif_tx()
837 mq->n_pkts += n_tx_pkts; in eth_memif_tx_zc()
1309 mq->n_pkts = 0; in memif_tx_queue_setup()
1337 mq->n_pkts = 0; in memif_rx_queue_setup()
1399 stats->q_ipackets[i] = mq->n_pkts; in memif_stats_get()
1401 stats->ipackets += mq->n_pkts; in memif_stats_get()
1415 stats->opackets += mq->n_pkts; in memif_stats_get()
1431 mq->n_pkts = 0; in memif_stats_reset()
[all …]
H A Drte_eth_memif.h72 uint64_t n_pkts; /**< number of rx/tx packets */ member
/f-stack/dpdk/examples/qos_sched/
H A Dstats.c355 i, 0, stats.n_pkts, stats.n_pkts_dropped, stats.n_bytes, in pipe_stat()
363 i, j, stats.n_pkts, stats.n_pkts_dropped, stats.n_bytes, in pipe_stat()

12