Searched refs:bufs (Results 1 - 23 of 23) sorted by relevance

/deb_dpdk/app/test/
H A Dtest_reorder.c168 struct rte_mbuf *bufs[num_bufs]; local
181 bufs[i] = rte_pktmbuf_alloc(p);
182 TEST_ASSERT_NOT_NULL(bufs[i], "Packet allocation failed\n");
183 bufs[i]->seqn = i;
192 ret = rte_reorder_insert(b, bufs[i]);
199 bufs[i] = NULL;
207 ret = rte_reorder_insert(b, bufs[4]);
214 bufs[4] = NULL;
217 bufs[5]->seqn = 2 * size;
218 ret = rte_reorder_insert(b, bufs[
255 struct rte_mbuf *bufs[num_bufs]; local
[all...]
H A Dtest_distributor.c112 struct rte_mbuf *bufs[BURST]; local
117 if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {
125 bufs[i]->hash.usr = 0;
127 rte_distributor_process(d, bufs, BURST);
147 bufs[i]->hash.usr = (i & 1) << 8;
149 rte_distributor_process(d, bufs, BURST);
172 bufs[i]->hash.usr = i;
174 rte_distributor_process(d, bufs, BURST);
188 rte_mempool_put_bulk(p, (void *)bufs, BURST);
276 struct rte_mbuf *bufs[BURS local
350 struct rte_mbuf *bufs[BURST]; local
407 struct rte_mbuf *bufs[BURST]; local
487 struct rte_mbuf *bufs[RTE_MAX_LCORE]; local
[all...]
H A Dtest_distributor_perf.c157 struct rte_mbuf *bufs[BURST]; local
160 if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {
166 bufs[i]->hash.usr = i;
170 rte_distributor_process(d, bufs, BURST);
182 rte_mempool_put_bulk(p, (void *)bufs, BURST);
200 struct rte_mbuf *bufs[RTE_MAX_LCORE]; local
201 rte_mempool_get_bulk(p, (void *)bufs, num_workers);
205 bufs[i]->hash.usr = i << 1;
206 rte_distributor_process(d, bufs, num_workers);
208 rte_mempool_put_bulk(p, (void *)bufs, num_worker
[all...]
H A Dvirtual_pmd.c337 struct rte_mbuf **bufs,
350 rx_count = rte_ring_dequeue_burst(dev_private->rx_queue, (void **) bufs,
358 dev_private->eth_stats.ibytes += rte_pktmbuf_pkt_len(bufs[i]);
365 struct rte_mbuf **bufs __rte_unused,
372 virtual_ethdev_tx_burst_success(void *queue, struct rte_mbuf **bufs, argument
388 nb_pkts = rte_ring_enqueue_burst(dev_private->tx_queue, (void **)bufs,
396 dev_private->eth_stats.obytes += rte_pktmbuf_pkt_len(bufs[i]);
402 virtual_ethdev_tx_burst_fail(void *queue, struct rte_mbuf **bufs, argument
424 if (bufs[i] != NULL)
425 rte_pktmbuf_free(bufs[
336 virtual_ethdev_rx_burst_success(void *queue __rte_unused, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
[all...]
H A Dtest_pmd_ring.c92 struct rte_mbuf bufs[RING_SIZE]; local
99 pbufs[i] = &bufs[i];
112 if (pbufs[i] != &bufs[i]) {
123 struct rte_mbuf bufs[RING_SIZE]; local
130 pbufs[i] = &bufs[i];
143 if (pbufs[i] != &bufs[i]) {
/deb_dpdk/examples/distributor/
H A Dmain.c173 struct rte_mbuf *bufs[num_workers]; local
175 if (rte_mempool_get_bulk(p, (void *)bufs, num_workers) != 0) {
181 bufs[i]->hash.rss = i << 1;
183 rte_distributor_process(d, bufs, num_workers);
184 rte_mempool_put_bulk(p, (void *)bufs, num_workers);
221 struct rte_mbuf *bufs[BURST_SIZE*2]; local
222 const uint16_t nb_rx = rte_eth_rx_burst(port, 0, bufs,
231 rte_distributor_process(d, bufs, nb_rx);
233 bufs, BURST_SIZE*2);
241 uint16_t sent = rte_ring_enqueue_burst(r, (void *)bufs, nb_re
330 struct rte_mbuf *bufs[BURST_SIZE]; local
[all...]
/deb_dpdk/drivers/net/null/
H A Drte_eth_null.c100 eth_null_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
106 if ((q == NULL) || (bufs == NULL))
111 bufs[i] = rte_pktmbuf_alloc(h->mb_pool);
112 if (!bufs[i])
114 bufs[i]->data_len = (uint16_t)packet_size;
115 bufs[i]->pkt_len = packet_size;
116 bufs[i]->nb_segs = 1;
117 bufs[i]->next = NULL;
118 bufs[i]->port = h->internals->port_id;
127 eth_null_copy_rx(void *q, struct rte_mbuf **bufs, uint16_ argument
156 eth_null_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
173 eth_null_copy_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
[all...]
/deb_dpdk/examples/l2fwd-cat/
H A Dl2fwd-cat.c148 struct rte_mbuf *bufs[BURST_SIZE]; local
150 bufs, BURST_SIZE);
157 bufs, nb_rx);
163 rte_pktmbuf_free(bufs[buf]);
/deb_dpdk/examples/skeleton/
H A Dbasicfwd.c146 struct rte_mbuf *bufs[BURST_SIZE]; local
148 bufs, BURST_SIZE);
155 bufs, nb_rx);
161 rte_pktmbuf_free(bufs[buf]);
/deb_dpdk/lib/librte_distributor/
H A Drte_distributor.c111 union rte_distributor_buffer bufs[RTE_DISTRIB_MAX_WORKERS]; member in struct:rte_distributor
129 union rte_distributor_buffer *buf = &d->bufs[worker_id];
141 union rte_distributor_buffer *buf = &d->bufs[worker_id];
165 union rte_distributor_buffer *buf = &d->bufs[worker_id];
211 d->bufs[wkr].bufptr64 = 0;
256 const int64_t data = d->bufs[wkr].bufptr64;
262 d->bufs[wkr].bufptr64 =
265 d->bufs[wkr].bufptr64 = RTE_DISTRIB_GET_BUF;
302 int64_t data = d->bufs[wkr].bufptr64;
349 d->bufs[wk
[all...]
/deb_dpdk/drivers/net/enic/base/
H A Dvnic_wq.c64 wq->bufs = (struct vnic_wq_buf *)rte_zmalloc_socket("wq->bufs",
69 if (wq->bufs == NULL)
82 rte_free(wq->bufs);
187 buf = &wq->bufs[to_clean];
194 buf = &wq->bufs[to_clean];
H A Dvnic_wq.h79 struct vnic_wq_buf *bufs; member in struct:vnic_wq
/deb_dpdk/examples/rxtx_callbacks/
H A Dmain.c170 struct rte_mbuf *bufs[BURST_SIZE]; local
172 bufs, BURST_SIZE);
176 bufs, nb_rx);
181 rte_pktmbuf_free(bufs[buf]);
/deb_dpdk/drivers/net/bonding/
H A Drte_eth_bond_pmd.c82 bond_ethdev_rx_burst(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
100 /* Offset of pointer to *bufs increases as packets are received
105 bufs + num_rx_total, nb_pkts);
118 bond_ethdev_rx_burst_active_backup(void *queue, struct rte_mbuf **bufs, argument
129 bd_rx_q->queue_id, bufs, nb_pkts);
142 bond_ethdev_rx_burst_8023ad(void *queue, struct rte_mbuf **bufs, argument
181 &bufs[num_rx_total], nb_pkts - num_rx_total);
184 rte_prefetch0(rte_pktmbuf_mtod(bufs[k], void *));
189 rte_prefetch0(rte_pktmbuf_mtod(bufs[j + 3], void *));
191 hdr = rte_pktmbuf_mtod(bufs[
387 bond_ethdev_rx_burst_alb(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
419 bond_ethdev_tx_burst_round_robin(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
482 bond_ethdev_tx_burst_active_backup(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
717 bond_ethdev_tx_burst_tlb(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
785 bond_ethdev_tx_burst_alb(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
928 bond_ethdev_tx_burst_balance(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
989 bond_ethdev_tx_burst_8023ad(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
1081 bond_ethdev_tx_burst_broadcast(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
[all...]
/deb_dpdk/drivers/net/ena/
H A Dena_ethdev.h63 struct ena_com_buf bufs[ENA_PKT_MAX_BUFS]; member in struct:ena_tx_buffer
H A Dena_ethdev.c617 /* Free all bufs */
646 /* Free all bufs */
1607 ebuf = tx_info->bufs;
/deb_dpdk/drivers/net/vhost/
H A Drte_eth_vhost.c362 struct rte_mbuf **bufs,
371 pkt_len = bufs[i]->pkt_len;
386 vhost_count_multicast_broadcast(vq, bufs[i]);
391 eth_vhost_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
406 r->virtqueue_id, r->mb_pool, bufs, nb_bufs);
411 bufs[i]->port = r->port;
412 r->stats.bytes += bufs[i]->pkt_len;
415 vhost_update_packet_xstats(r, bufs, nb_rx);
424 eth_vhost_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
439 r->virtqueue_id, bufs, nb_buf
361 vhost_update_packet_xstats(struct vhost_queue *vq, struct rte_mbuf **bufs, uint16_t count) argument
[all...]
/deb_dpdk/drivers/net/ring/
H A Drte_eth_ring.c87 eth_ring_rx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
89 void **ptrs = (void *)&bufs[0];
101 eth_ring_tx(void *q, struct rte_mbuf **bufs, uint16_t nb_bufs) argument
103 void **ptrs = (void *)&bufs[0];
/deb_dpdk/drivers/net/enic/
H A Denic_rxtx.c407 buf = &wq->bufs[tail_idx];
410 buf = &wq->bufs[tail_idx];
533 buf = &wq->bufs[head_idx];
554 buf = &wq->bufs[head_idx];
/deb_dpdk/drivers/net/pcap/
H A Drte_eth_pcap.c184 eth_pcap_rx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
233 bufs[num_rx] = mbuf;
258 eth_pcap_tx_dumper(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
273 mbuf = bufs[i];
319 eth_pcap_tx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
332 mbuf = bufs[i];
/deb_dpdk/drivers/net/szedata2/
H A Drte_eth_szedata2.c102 struct rte_mbuf **bufs,
311 bufs[num_rx] = mbuf;
335 struct rte_mbuf **bufs,
654 bufs[num_rx] = mbuf;
667 struct rte_mbuf **bufs,
702 mbuf = bufs[nb_pkts - pkt_left];
101 eth_szedata2_rx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
334 eth_szedata2_rx_scattered(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
666 eth_szedata2_tx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
/deb_dpdk/drivers/net/af_packet/
H A Drte_eth_af_packet.c128 eth_af_packet_rx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
171 bufs[i] = mbuf;
185 eth_af_packet_tx(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) argument
215 mbuf = bufs[num_tx];
/deb_dpdk/drivers/net/mlx4/
H A Dmlx4.c163 struct rte_mbuf *bufs[MLX4_PMD_SGE_WR_N]; /* SGEs buffers. */ member in struct:rxq_elt_sp
2156 assert(elemof(elt->sges) == elemof(elt->bufs));
2163 for (j = 0; (j != elemof(elt->bufs)); ++j) {
2179 elt->bufs[j] = buf;
2220 for (j = 0; (j != elemof(elt->bufs)); ++j) {
2221 struct rte_mbuf *buf = elt->bufs[j];
2256 for (j = 0; (j != elemof(elt->bufs)); ++j) {
2257 struct rte_mbuf *buf = elt->bufs[j];
3124 struct rte_mbuf *seg = elt->bufs[j];
3172 elt->bufs[
[all...]

Completed in 33 milliseconds