Searched refs:rx_queue (Results 1 - 25 of 69) sorted by relevance

123

/deb_dpdk/drivers/net/mpipe/
H A Dmpipe_tilegx.c775 struct mpipe_rx_queue *rx_queue; local
791 rx_queue = mpipe_rx_queue(priv, queue);
792 ring_size = rx_queue->q.nb_desc * sizeof(gxio_mpipe_idesc_t);
805 rc = gxio_mpipe_iqueue_init(&rx_queue->iqueue, priv->context,
814 rx_queue->rx_ring_mem = ring_mem;
815 buffers += rx_queue->q.nb_desc;
917 struct mpipe_rx_queue *rx_queue; local
939 rx_queue = mpipe_rx_queue(priv, i);
941 stats->ipackets += rx_queue->q.stats.packets;
942 stats->ibytes += rx_queue
960 struct mpipe_rx_queue *rx_queue; local
1035 struct mpipe_rx_queue *rx_queue = dev->data->rx_queues[queue_idx]; local
1232 struct mpipe_rx_queue *rx_queue; local
1367 mpipe_do_recv(struct mpipe_rx_queue *rx_queue, struct rte_mbuf **rx_pkts, uint16_t nb_pkts) argument
1508 struct mpipe_rx_queue *rx_queue = _rxq; local
[all...]
/deb_dpdk/drivers/net/virtio/
H A Dvirtio_ethdev.h105 uint16_t virtio_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
108 uint16_t virtio_recv_mergeable_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
114 uint16_t virtio_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts,
H A Dvirtio_rxtx_simple.c143 virtio_recv_pkts_vec(void *rx_queue __rte_unused,
H A Dvirtio_rxtx_simple_neon.c70 virtio_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts, argument
73 struct virtnet_rx *rxvq = rx_queue;
H A Dvirtio_rxtx_simple_sse.c72 virtio_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts, argument
75 struct virtnet_rx *rxvq = rx_queue;
/deb_dpdk/drivers/net/af_packet/
H A Drte_eth_af_packet.c105 struct pkt_rx_queue rx_queue[RTE_PMD_AF_PACKET_MAX_RINGS]; member in struct:pmd_internals
261 sockfd = internals->rx_queue[i].sockfd;
272 internals->rx_queue[i].sockfd = -1;
311 igb_stats->q_ipackets[i] = internal->rx_queue[i].rx_pkts;
312 igb_stats->q_ibytes[i] = internal->rx_queue[i].rx_bytes;
342 internal->rx_queue[i].rx_pkts = 0;
343 internal->rx_queue[i].rx_bytes = 0;
379 struct pkt_rx_queue *pkt_q = &internals->rx_queue[rx_queue_id];
470 struct pkt_rx_queue *rx_queue; local
507 (*internals)->rx_queue[
[all...]
/deb_dpdk/drivers/net/bnxt/
H A Dbnxt_rxq.h66 void bnxt_rx_queue_release_op(void *rx_queue);
H A Dbnxt_rxr.h86 uint16_t bnxt_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
H A Dbnxt_rxq.c246 void bnxt_rx_queue_release_op(void *rx_queue) argument
248 struct bnxt_rx_queue *rxq = (struct bnxt_rx_queue *)rx_queue;
/deb_dpdk/examples/l3fwd-power/
H A Dmain.c780 struct lcore_rx_queue *rx_queue; local
784 rx_queue = &(qconf->rx_queue_list[i]);
785 port_id = rx_queue->port_id;
786 queue_id = rx_queue->queue_id;
796 struct lcore_rx_queue *rx_queue; local
803 rx_queue = &(qconf->rx_queue_list[i]);
804 portid = rx_queue->port_id;
805 queueid = rx_queue->queue_id;
830 struct lcore_rx_queue *rx_queue; local
898 rx_queue
[all...]
/deb_dpdk/drivers/net/ixgbe/
H A Dixgbe_ethdev.h360 int ixgbe_dev_rx_descriptor_done(void *rx_queue, uint16_t offset);
361 int ixgbevf_dev_rx_descriptor_done(void *rx_queue, uint16_t offset);
389 uint16_t ixgbe_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
392 uint16_t ixgbe_recv_pkts_bulk_alloc(void *rx_queue, struct rte_mbuf **rx_pkts,
395 uint16_t ixgbe_recv_pkts_lro_single_alloc(void *rx_queue,
397 uint16_t ixgbe_recv_pkts_lro_bulk_alloc(void *rx_queue,
H A Dixgbe_rxtx.h302 uint16_t ixgbe_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts,
304 uint16_t ixgbe_recv_scattered_pkts_vec(void *rx_queue,
H A Dixgbe_rxtx_vec_neon.c383 ixgbe_recv_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts, argument
386 return _recv_raw_pkts_vec(rx_queue, rx_pkts, nb_pkts, NULL);
400 ixgbe_recv_scattered_pkts_vec(void *rx_queue, struct rte_mbuf **rx_pkts, argument
403 struct ixgbe_rx_queue *rxq = rx_queue;
/deb_dpdk/examples/qos_sched/
H A Dmain.h111 uint16_t rx_queue; member in struct:thread_conf
130 uint16_t rx_queue; member in struct:flow_conf
H A Dmain.c86 flow->rx_thread.rx_queue = flow->rx_queue;
/deb_dpdk/app/test-pmd/
H A Drxonly.c112 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst,
128 (unsigned) fs->rx_queue,
149 printf(" - RSS queue=0x%x",(unsigned) fs->rx_queue);
230 printf(" - Receive queue=0x%x", (unsigned) fs->rx_queue);
H A Diofwd.c97 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue,
/deb_dpdk/drivers/net/e1000/
H A De1000_ethdev.h305 int eth_igb_rx_descriptor_done(void *rx_queue, uint16_t offset);
366 int eth_em_rx_descriptor_done(void *rx_queue, uint16_t offset);
379 uint16_t eth_em_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
382 uint16_t eth_em_recv_scattered_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
/deb_dpdk/drivers/net/thunderx/
H A Dnicvf_rxtx.h91 uint16_t nicvf_recv_pkts_multiseg(void *rx_queue, struct rte_mbuf **rx_pkts,
/deb_dpdk/drivers/net/fm10k/
H A Dfm10k.h347 uint16_t fm10k_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,
350 uint16_t fm10k_recv_scattered_pkts(void *rx_queue,
354 fm10k_dev_rx_descriptor_done(void *rx_queue, uint16_t offset);
H A Dfm10k_rxtx.c116 fm10k_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, argument
121 struct fm10k_rx_queue *q = rx_queue;
226 fm10k_recv_scattered_pkts(void *rx_queue, struct rte_mbuf **rx_pkts, argument
231 struct fm10k_rx_queue *q = rx_queue;
387 fm10k_dev_rx_descriptor_done(void *rx_queue, uint16_t offset) argument
390 struct fm10k_rx_queue *rxq = rx_queue;
/deb_dpdk/drivers/net/pcap/
H A Drte_eth_pcap.c93 struct pcap_rx_queue rx_queue[RTE_PMD_PCAP_MAX_QUEUES]; member in struct:pmd_internals
448 rx = &internals->rx_queue[0];
475 rx = &internals->rx_queue[i];
511 rx = &internals->rx_queue[0];
533 rx = &internals->rx_queue[i];
578 stats->q_ipackets[i] = internal->rx_queue[i].rx_stat.pkts;
579 stats->q_ibytes[i] = internal->rx_queue[i].rx_stat.bytes;
608 internal->rx_queue[i].rx_stat.pkts = 0;
609 internal->rx_queue[i].rx_stat.bytes = 0;
645 struct pcap_rx_queue *pcap_q = &internals->rx_queue[rx_queue_i
[all...]
/deb_dpdk/app/test/
H A Dtest_link_bonding_mode4.c103 struct rte_ring *rx_queue; member in struct:slave_conf
209 return rte_ring_enqueue_burst(slave->rx_queue, (void **)buf, size);
306 TEST_ASSERT_EQUAL(rte_ring_count(slave->rx_queue), 0,
310 TEST_ASSERT_EQUAL(rte_ring_count(slave->rx_queue), 0,
429 if (port->rx_queue == NULL) {
432 port->rx_queue = rte_ring_create(name, RX_RING_SIZE, socket_id, 0);
433 TEST_ASSERT(port->rx_queue != NULL,
450 retval = rte_eth_from_rings(name, &port->rx_queue, 1,
907 while (rte_ring_dequeue(slave->rx_queue, (void **)&pkt) == 0)
1266 while (rte_ring_count(slave->rx_queue) >
[all...]
H A Dvirtual_pmd.c51 struct rte_ring *rx_queue; member in struct:virtual_ethdev_private
84 while (rte_ring_dequeue(prv->rx_queue, &pkt) != -ENOENT)
350 rx_count = rte_ring_dequeue_burst(dev_private->rx_queue, (void **) bufs,
504 return rte_ring_enqueue_burst(dev_private->rx_queue, (void **)pkt_burst,
577 dev_private->rx_queue = rte_ring_create(name_buf, MAX_PKT_BURST, socket_id,
579 if (dev_private->rx_queue == NULL)
/deb_dpdk/drivers/net/vmxnet3/
H A Dvmxnet3_ethdev.h170 uint16_t vmxnet3_recv_pkts(void *rx_queue, struct rte_mbuf **rx_pkts,

Completed in 31 milliseconds

123