Home
last modified time | relevance | path

Searched refs:mbufs (Results 1 – 25 of 135) sorted by relevance

123456

/dpdk/examples/qos_sched/
H A Dapp_thread.c117 struct rte_mbuf **mbufs; in app_send_burst() local
120 mbufs = (struct rte_mbuf **)qconf->m_table; in app_send_burst()
128 mbufs = (struct rte_mbuf **)&mbufs[ret]; in app_send_burst()
141 qconf->m_table[len] = mbufs[i]; in app_send_packets()
157 struct rte_mbuf *mbufs[burst_conf.qos_dequeue]; in app_tx_thread() local
167 app_send_packets(conf, mbufs, burst_conf.qos_dequeue); in app_tx_thread()
195 struct rte_mbuf *mbufs[burst_conf.ring_burst]; in app_worker_thread() local
213 nb_pkt = rte_sched_port_dequeue(conf->sched_port, mbufs, in app_worker_thread()
217 (void **)mbufs, nb_pkt, NULL) == 0) in app_worker_thread()
230 struct rte_mbuf *mbufs[burst_conf.ring_burst]; in app_mixed_thread() local
[all …]
/dpdk/doc/guides/prog_guide/
H A Dreorder_lib.rst9 The Reorder Library provides a mechanism for reordering mbufs based on their
15 The reorder library is essentially a buffer that reorders mbufs.
17 mbufs from it.
27 and late mbufs depending on the sequence number of the inserted mbuf:
35 mbufs.
45 late mbufs are returned to the user with an error.
49 To that end, mbufs in the Order buffer are moved into the Ready buffer.
51 late mbufs.
67 When draining mbufs, the reorder buffer would return mbufs in the Ready
85 mbufs into the reorder buffer and finally transmit drained mbufs.
[all …]
H A Dip_fragment_reassembly_lib.rst16 For each fragment two new mbufs are created:
26 Finally 'direct' and 'indirect' mbufs for each fragment are linked together via mbuf's next filed t…
28 …to explicitly specify which mempools should be used to allocate 'direct' and 'indirect' mbufs from.
30 For more information about direct and indirect mbufs, refer to :ref:`direct_indirect_buffer`.
66 At any given time up to (2 \* bucket_entries \* RTE_LIBRTE_IP_FRAG_MAX \* <maximum number of mbufs …
87 …b) Delete a timed-out entry, free mbufs associated with it mbufs and store a new entry with specif…
/dpdk/examples/l3fwd/
H A Dl3fwd_em_sequential.h129 struct rte_mbuf **mbufs = vec->mbufs; in l3fwd_em_process_event_vector() local
132 rte_prefetch0(rte_pktmbuf_mtod(mbufs[0], struct rte_ether_hdr *) + 1); in l3fwd_em_process_event_vector()
135 vec->port = em_get_dst_port(qconf, mbufs[0], mbufs[0]->port); in l3fwd_em_process_event_vector()
139 rte_prefetch0(rte_pktmbuf_mtod(mbufs[j], in l3fwd_em_process_event_vector()
142 mbufs[i]->port = in l3fwd_em_process_event_vector()
143 em_get_dst_port(qconf, mbufs[i], mbufs[i]->port); in l3fwd_em_process_event_vector()
144 process_packet(mbufs[i], &mbufs[i]->port); in l3fwd_em_process_event_vector()
145 event_vector_attr_validate(vec, mbufs[i]); in l3fwd_em_process_event_vector()
H A Dl3fwd_em_hlm.h326 struct rte_mbuf **mbufs = vec->mbufs; in l3fwd_em_process_event_vector() local
335 vec->port = em_get_dst_port(qconf, mbufs[0], mbufs[0]->port); in l3fwd_em_process_event_vector()
344 pkt_type &= mbufs[j + i]->packet_type; in l3fwd_em_process_event_vector()
365 mbufs[j + i]->port = in l3fwd_em_process_event_vector()
367 mbufs[j + i]->port); in l3fwd_em_process_event_vector()
368 process_packet(mbufs[j + i], in l3fwd_em_process_event_vector()
369 &mbufs[j + i]->port); in l3fwd_em_process_event_vector()
377 mbufs[j + i]->port = dst_port[j + i]; in l3fwd_em_process_event_vector()
383 mbufs[j]->port = in l3fwd_em_process_event_vector()
384 em_get_dst_port(qconf, mbufs[j], mbufs[j]->port); in l3fwd_em_process_event_vector()
[all …]
H A Dl3fwd_em.h182 struct rte_mbuf **mbufs = vec->mbufs; in l3fwd_em_no_opt_process_event_vector() local
187 rte_prefetch0(rte_pktmbuf_mtod(mbufs[i], void *)); in l3fwd_em_no_opt_process_event_vector()
190 l3fwd_em_simple_process(mbufs[0], qconf); in l3fwd_em_no_opt_process_event_vector()
192 if (mbufs[0]->port != BAD_PORT) in l3fwd_em_no_opt_process_event_vector()
193 vec->port = mbufs[0]->port; in l3fwd_em_no_opt_process_event_vector()
203 rte_pktmbuf_mtod(mbufs[i + PREFETCH_OFFSET], void *)); in l3fwd_em_no_opt_process_event_vector()
204 l3fwd_em_simple_process(mbufs[i], qconf); in l3fwd_em_no_opt_process_event_vector()
205 event_vector_attr_validate(vec, mbufs[i]); in l3fwd_em_no_opt_process_event_vector()
210 l3fwd_em_simple_process(mbufs[i], qconf); in l3fwd_em_no_opt_process_event_vector()
211 event_vector_attr_validate(vec, mbufs[i]); in l3fwd_em_no_opt_process_event_vector()
H A Dl3fwd_fib.c424 struct rte_mbuf **mbufs = vec->mbufs; in fib_process_event_vector() local
442 rte_prefetch0(rte_pktmbuf_mtod(mbufs[i], void *)); in fib_process_event_vector()
446 rte_prefetch0(rte_pktmbuf_mtod(mbufs[i + FIB_PREFETCH_OFFSET], in fib_process_event_vector()
448 fib_parse_packet(mbufs[i], &ipv4_arr[ipv4_cnt], &ipv4_cnt, in fib_process_event_vector()
454 fib_parse_packet(mbufs[i], &ipv4_arr[ipv4_cnt], &ipv4_cnt, in fib_process_event_vector()
482 mbufs[i]->port = nh; in fib_process_event_vector()
483 event_vector_attr_validate(vec, mbufs[i]); in fib_process_event_vector()
H A Dl3fwd_lpm.c430 struct rte_mbuf **mbufs = vec->mbufs; in lpm_process_event_vector() local
434 lpm_process_event_pkt(lconf, mbufs[0]); in lpm_process_event_vector()
436 if (mbufs[0]->port != BAD_PORT) in lpm_process_event_vector()
437 vec->port = mbufs[0]->port; in lpm_process_event_vector()
443 lpm_process_event_pkt(lconf, mbufs[i]); in lpm_process_event_vector()
444 event_vector_attr_validate(vec, mbufs[i]); in lpm_process_event_vector()
/dpdk/app/test/
H A Dtest_table_tables.c154 PREPARE_PACKET(mbufs[i], 0xadadadad); in test_table_stub()
156 PREPARE_PACKET(mbufs[i], 0xadadadab); in test_table_stub()
166 rte_pktmbuf_free(mbufs[i]); in test_table_stub()
264 PREPARE_PACKET(mbufs[i], 10); in test_table_array()
266 PREPARE_PACKET(mbufs[i], 20); in test_table_array()
280 rte_pktmbuf_free(mbufs[i]); in test_table_array()
446 rte_pktmbuf_free(mbufs[i]); in test_table_lpm()
624 rte_pktmbuf_free(mbufs[i]); in test_table_lpm_ipv6()
727 rte_pktmbuf_free(mbufs[i]); in test_table_hash_lru_generic()
837 rte_pktmbuf_free(mbufs[i]); in test_table_hash_ext_generic()
[all …]
H A Dtest_mbuf.c731 struct rte_mbuf *mbufs[NB_MBUF]; in test_pktmbuf_pool_bulk() local
808 rte_pktmbuf_free_bulk(mbufs, NB_MBUF); in test_pktmbuf_pool_bulk()
825 ret = rte_pktmbuf_chain(mbufs[0], mbufs[i]); in test_pktmbuf_pool_bulk()
830 mbufs[i] = NULL; in test_pktmbuf_pool_bulk()
833 rte_pktmbuf_free_bulk(mbufs, 1); in test_pktmbuf_pool_bulk()
852 mbufs[i / CHAIN_LEN] = m; in test_pktmbuf_pool_bulk()
862 rte_pktmbuf_free_bulk(mbufs, 1); in test_pktmbuf_pool_bulk()
1878 mbufs[loop] != NULL; loop++) in test_pktmbuf_alloc_bulk()
1879 rte_pktmbuf_free(mbufs[loop]); in test_pktmbuf_alloc_bulk()
1912 mbufs[loop] != NULL; loop++) in test_neg_pktmbuf_alloc_bulk()
[all …]
/dpdk/examples/l2fwd-event/
H A Dl2fwd_event.c358 struct rte_mbuf **mbufs = vec->mbufs; in l2fwd_event_vector_fwd() local
365 vec->port = rsrc->dst_ports[mbufs[0]->port]; in l2fwd_event_vector_fwd()
376 rte_pktmbuf_mtod(mbufs[j], void *)); in l2fwd_event_vector_fwd()
380 mbufs[i], vec->port, in l2fwd_event_vector_fwd()
391 &rsrc->port_stats[mbufs[i]->port].rx, 1, in l2fwd_event_vector_fwd()
396 rte_pktmbuf_mtod(mbufs[j], void *)); in l2fwd_event_vector_fwd()
398 mbufs[i]->port = rsrc->dst_ports[mbufs[i]->port]; in l2fwd_event_vector_fwd()
402 mbufs[i], mbufs[i]->port, in l2fwd_event_vector_fwd()
403 &rsrc->eth_addr[mbufs[i]->port]); in l2fwd_event_vector_fwd()
406 rte_event_eth_tx_adapter_txq_set(mbufs[i], 0); in l2fwd_event_vector_fwd()
[all …]
/dpdk/drivers/event/opdl/
H A Dopdl_test.c196 struct rte_mbuf *mbufs[3]; in ordered_basic() local
251 if (!mbufs[i]) { in ordered_basic()
258 ev.mbuf = mbufs[i]; in ordered_basic()
334 struct rte_mbuf *mbufs[3]; in atomic_basic() local
390 if (!mbufs[i]) { in atomic_basic()
398 ev.mbuf = mbufs[i]; in atomic_basic()
562 struct rte_mbuf *mbufs[3]; in single_link_w_stats() local
563 RTE_SET_USED(mbufs); in single_link_w_stats()
620 if (!mbufs[i]) { in single_link_w_stats()
627 ev.mbuf = mbufs[i]; in single_link_w_stats()
[all …]
/dpdk/examples/packet_ordering/
H A Dmain.c538 struct rte_mbuf *mbufs[MAX_PKTS_BURST]; in send_thread() local
550 (void *)mbufs, MAX_PKTS_BURST, NULL); in send_thread()
559 ret = rte_reorder_insert(args->buffer, mbufs[i]); in send_thread()
566 outp = mbufs[i]->port; in send_thread()
568 rte_pktmbuf_free(mbufs[i]); in send_thread()
572 rte_pktmbuf_free(mbufs[i]); in send_thread()
580 rte_pktmbuf_free(mbufs[i]); in send_thread()
622 struct rte_mbuf *mbufs[MAX_PKTS_BURST]; in tx_thread() local
635 (void *)mbufs, MAX_PKTS_BURST, NULL); in tx_thread()
643 outp = mbufs[i]->port; in tx_thread()
[all …]
/dpdk/lib/distributor/
H A Drte_distributor.h89 struct rte_mbuf **mbufs, unsigned int num_mbufs);
107 struct rte_mbuf **mbufs, unsigned int max_mbufs);
236 unsigned int worker_id, struct rte_mbuf **mbufs);
H A Drte_distributor_single.c110 d->returns.mbufs[(*ret_start + *ret_count) & RTE_DISTRIB_RETURNS_MASK] in store_return()
204 struct rte_mbuf **mbufs, unsigned num_mbufs) in rte_distributor_process_single() argument
224 next_mb = mbufs[next_idx++]; in rte_distributor_process_single()
319 struct rte_mbuf **mbufs, unsigned max_mbufs) in rte_distributor_returned_pkts_single() argument
328 mbufs[i] = returns->mbufs[idx]; in rte_distributor_returned_pkts_single()
371 memset(d->returns.mbufs, 0, sizeof(d->returns.mbufs)); in rte_distributor_clear_returns_single()
H A Drte_distributor.c225 d->returns.mbufs[(*ret_start + *ret_count) & RTE_DISTRIB_RETURNS_MASK] in store_return()
442 struct rte_mbuf **mbufs, unsigned int num_mbufs) in rte_distributor_process() argument
455 mbufs, num_mbufs); in rte_distributor_process()
488 if (mbufs[next_idx + i]) { in rte_distributor_process()
490 flows[i] = mbufs[next_idx + i]->hash.usr | 1; in rte_distributor_process()
521 next_mb = mbufs[next_idx++]; in rte_distributor_process()
612 struct rte_mbuf **mbufs, unsigned int max_mbufs) in rte_distributor_returned_pkts() argument
622 mbufs, max_mbufs); in rte_distributor_returned_pkts()
629 mbufs[i] = returns->mbufs[idx]; in rte_distributor_returned_pkts()
H A Drte_distributor_single.h78 struct rte_mbuf **mbufs, unsigned int num_mbufs);
96 struct rte_mbuf **mbufs, unsigned int max_mbufs);
/dpdk/drivers/event/cnxk/
H A Dcn10k_worker.h129 wqe = vec->mbufs; in cn10k_process_vwqe()
585 port[0] = mbufs[i]->port; in cn10k_sso_vwqe_split_tx()
586 port[1] = mbufs[i + 1]->port; in cn10k_sso_vwqe_split_tx()
587 port[2] = mbufs[i + 2]->port; in cn10k_sso_vwqe_split_tx()
588 port[3] = mbufs[i + 3]->port; in cn10k_sso_vwqe_split_tx()
598 cn10k_sso_tx_one(ws, mbufs[i + j], cmd, lmt_id, in cn10k_sso_vwqe_split_tx()
607 &mbufs[i], 4, cmd, in cn10k_sso_vwqe_split_tx()
612 mbufs += i; in cn10k_sso_vwqe_split_tx()
615 cn10k_sso_tx_one(ws, mbufs[i], cmd, lmt_id, lmt_addr, in cn10k_sso_vwqe_split_tx()
634 struct rte_mbuf **mbufs = ev->vec->mbufs; in cn10k_sso_hws_event_tx() local
[all …]
/dpdk/app/test-gpudev/
H A Dmain.c345 struct rte_mbuf *mbufs[10]; in create_update_comm_list() local
359 mbufs[i] = rte_zmalloc(NULL, sizeof(struct rte_mbuf), 0); in create_update_comm_list()
360 if (mbufs[i] == NULL) { in create_update_comm_list()
365 memset(mbufs[i], 0, sizeof(struct rte_mbuf)); in create_update_comm_list()
371 ret = rte_gpu_comm_populate_list_pkts(&(comm_list[0]), mbufs, 10); in create_update_comm_list()
410 rte_free(mbufs[i]); in create_update_comm_list()
419 rte_free(mbufs[i]); in create_update_comm_list()
/dpdk/drivers/net/nfb/
H A Dnfb_rx.h156 struct rte_mbuf *mbufs[nb_pkts]; in nfb_eth_ndp_rx() local
164 i = rte_pktmbuf_alloc_bulk(ndp->mb_pool, mbufs, nb_pkts); in nfb_eth_ndp_rx()
172 rte_pktmbuf_free(mbufs[i]); in nfb_eth_ndp_rx()
184 mbuf = mbufs[i]; in nfb_eth_ndp_rx()
/dpdk/lib/gpudev/
H A Dgpudev.c916 comm_list[idx_l].mbufs = rte_zmalloc(NULL, in rte_gpu_comm_create_list()
918 if (comm_list[idx_l].mbufs == NULL) { in rte_gpu_comm_create_list()
961 rte_free(comm_list[idx_l].mbufs); in rte_gpu_comm_destroy_list()
985 struct rte_mbuf **mbufs, uint32_t num_mbufs) in rte_gpu_comm_populate_list_pkts() argument
998 if (unlikely((mbufs[idx]->nb_segs > 1) || in rte_gpu_comm_populate_list_pkts()
999 (mbufs[idx]->next != NULL) || in rte_gpu_comm_populate_list_pkts()
1000 (mbufs[idx]->data_len != mbufs[idx]->pkt_len))) { in rte_gpu_comm_populate_list_pkts()
1005 rte_pktmbuf_mtod_offset(mbufs[idx], uintptr_t, 0); in rte_gpu_comm_populate_list_pkts()
1006 comm_list_item->pkt_list[idx].size = mbufs[idx]->pkt_len; in rte_gpu_comm_populate_list_pkts()
1007 comm_list_item->mbufs[idx] = mbufs[idx]; in rte_gpu_comm_populate_list_pkts()
[all …]
/dpdk/examples/bbdev_app/
H A Dmain.c296 rte_pktmbuf_free(mbufs[i]); in pktmbuf_free_bulk()
304 struct rte_mbuf *rx_pkt = *mbuf_input(mbufs[i]); in pktmbuf_input_free_bulk()
306 rte_pktmbuf_free(mbufs[i]); in pktmbuf_input_free_bulk()
366 add_awgn(struct rte_mbuf **mbufs, uint16_t num_pkts) in add_awgn() argument
368 RTE_SET_USED(mbufs); in add_awgn()
390 uint16_t pkt_data_len = rte_pktmbuf_data_len(mbufs[i]) - in transform_enc_out_dec_in()
395 char *data = rte_pktmbuf_append(mbufs[i], in transform_enc_out_dec_in()
408 mbufs[i], uint8_t *, in transform_enc_out_dec_in()
424 rte_memcpy(rte_pktmbuf_mtod_offset(mbufs[i], uint8_t *, in transform_enc_out_dec_in()
430 verify_data(struct rte_mbuf **mbufs, uint16_t num_pkts) in verify_data() argument
[all …]
/dpdk/lib/mbuf/
H A Drte_mbuf.h894 struct rte_mbuf **mbufs, unsigned count) in rte_pktmbuf_alloc_bulk() argument
899 rc = rte_mempool_get_bulk(pool, (void **)mbufs, count); in rte_pktmbuf_alloc_bulk()
911 __rte_mbuf_raw_sanity_check(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
912 rte_pktmbuf_reset(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
916 __rte_mbuf_raw_sanity_check(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
917 rte_pktmbuf_reset(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
921 __rte_mbuf_raw_sanity_check(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
922 rte_pktmbuf_reset(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
926 __rte_mbuf_raw_sanity_check(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
927 rte_pktmbuf_reset(mbufs[idx]); in rte_pktmbuf_alloc_bulk()
[all …]
/dpdk/lib/kni/
H A Drte_kni.h167 unsigned rte_kni_rx_burst(struct rte_kni *kni, struct rte_mbuf **mbufs,
186 unsigned rte_kni_tx_burst(struct rte_kni *kni, struct rte_mbuf **mbufs,
/dpdk/examples/flow_filtering/
H A Dmain.c58 struct rte_mbuf *mbufs[32]; in main_loop() local
70 i, mbufs, 32); in main_loop()
73 struct rte_mbuf *m = mbufs[j]; in main_loop()

123456