Searched refs:tx_queue (Results 1 - 25 of 57) sorted by relevance

123

/deb_dpdk/drivers/net/af_packet/
H A Drte_eth_af_packet.c106 struct pkt_tx_queue tx_queue[RTE_PMD_AF_PACKET_MAX_RINGS]; member in struct:pmd_internals
266 if (sockfd != internals->tx_queue[i].sockfd) {
267 sockfd = internals->tx_queue[i].sockfd;
273 internals->tx_queue[i].sockfd = -1;
320 igb_stats->q_opackets[i] = internal->tx_queue[i].tx_pkts;
321 igb_stats->q_errors[i] = internal->tx_queue[i].err_pkts;
322 igb_stats->q_obytes[i] = internal->tx_queue[i].tx_bytes;
347 internal->tx_queue[i].tx_pkts = 0;
348 internal->tx_queue[i].err_pkts = 0;
349 internal->tx_queue[
471 struct pkt_tx_queue *tx_queue; local
[all...]
/deb_dpdk/drivers/net/bnxt/
H A Dbnxt_txq.h69 void bnxt_tx_queue_release_op(void *tx_queue);
H A Dbnxt_txq.c83 void bnxt_tx_queue_release_op(void *tx_queue) argument
85 struct bnxt_tx_queue *txq = (struct bnxt_tx_queue *)tx_queue;
H A Dbnxt_txr.h69 uint16_t bnxt_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
/deb_dpdk/drivers/net/virtio/
H A Dvirtio_ethdev.h111 uint16_t virtio_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
117 uint16_t virtio_xmit_pkts_simple(void *tx_queue, struct rte_mbuf **tx_pkts,
H A Dvirtio_rxtx_simple.c61 virtio_xmit_pkts_simple(void *tx_queue, struct rte_mbuf **tx_pkts, argument
64 struct virtnet_tx *txvq = tx_queue;
/deb_dpdk/drivers/net/mpipe/
H A Dmpipe_tilegx.c916 struct mpipe_tx_queue *tx_queue; local
924 tx_queue = mpipe_tx_queue(priv, i);
926 stats->opackets += tx_queue->q.stats.packets;
927 stats->obytes += tx_queue->q.stats.bytes;
928 stats->oerrors += tx_queue->q.stats.errors;
930 idx = tx_queue->q.stat_idx;
932 stats->q_opackets[idx] += tx_queue->q.stats.packets;
933 stats->q_obytes[idx] += tx_queue->q.stats.bytes;
934 stats->q_errors[idx] += tx_queue->q.stats.errors;
959 struct mpipe_tx_queue *tx_queue; local
994 struct mpipe_tx_queue *tx_queue = dev->data->tx_queues[queue_idx]; local
1257 mpipe_do_xmit(struct mpipe_tx_queue *tx_queue, struct rte_mbuf **tx_pkts, uint16_t nb_pkts) argument
1524 struct mpipe_tx_queue *tx_queue = _txq; local
[all...]
/deb_dpdk/drivers/net/pcap/
H A Drte_eth_pcap.c94 struct pcap_tx_queue tx_queue[RTE_PMD_PCAP_MAX_QUEUES]; member in struct:pmd_internals
324 struct pcap_tx_queue *tx_queue = queue; local
328 if (unlikely(nb_pkts == 0 || tx_queue->pcap == NULL))
335 ret = pcap_sendpacket(tx_queue->pcap,
341 ret = pcap_sendpacket(tx_queue->pcap,
361 tx_queue->tx_stat.pkts += num_tx;
362 tx_queue->tx_stat.bytes += tx_bytes;
363 tx_queue->tx_stat.err_pkts += nb_pkts - num_tx;
447 tx = &internals->tx_queue[0];
460 tx = &internals->tx_queue[
[all...]
/deb_dpdk/examples/qos_sched/
H A Dmain.h112 uint16_t tx_queue; member in struct:thread_conf
131 uint16_t tx_queue; member in struct:flow_conf
H A Dmain.c95 flow->tx_thread.tx_queue = flow->tx_queue;
/deb_dpdk/app/test-pmd/
H A Diofwd.c106 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
115 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
H A Dmacfwd.c131 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx);
139 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
H A Dmacswap.c133 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx);
141 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
H A Dtxonly.c284 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt);
292 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
303 printf("port %d tx_queue %d - drop "
305 fs->tx_port, fs->tx_queue,
H A Dflowgen.c208 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt);
216 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue,
H A Dieee1588fwd.c217 if (rte_eth_tx_burst(fs->rx_port, fs->tx_queue, &mb, 1) == 0) {
H A Dicmpecho.c519 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst,
530 fs->tx_queue,
/deb_dpdk/app/test/
H A Dvirtual_pmd.c52 struct rte_ring *tx_queue; member in struct:virtual_ethdev_private
87 while (rte_ring_dequeue(prv->tx_queue, &pkt) != -ENOENT)
229 while (rte_ring_dequeue(dev_private->tx_queue, &pkt) == -ENOBUFS)
388 nb_pkts = rte_ring_enqueue_burst(dev_private->tx_queue, (void **)bufs,
516 return rte_ring_dequeue_burst(dev_private->tx_queue, (void **)pkt_burst,
583 dev_private->tx_queue = rte_ring_create(name_buf, MAX_PKT_BURST, socket_id,
585 if (dev_private->tx_queue == NULL)
H A Dtest_link_bonding_mode4.c104 struct rte_ring *tx_queue; member in struct:slave_conf
196 return rte_ring_dequeue_burst(slave->tx_queue, (void **)buf, size);
438 if (port->tx_queue == NULL) {
441 port->tx_queue = rte_ring_create(name, TX_RING_SIZE, socket_id, 0);
442 TEST_ASSERT_NOT_NULL(port->tx_queue,
451 &port->tx_queue, 1, socket_id);
1462 if (rte_ring_count(port->tx_queue) != 0)
1525 while (rte_ring_count(port->tx_queue) != 0) {
1526 if (rte_ring_dequeue(port->tx_queue, &pkt) == 0)
/deb_dpdk/drivers/net/vmxnet3/
H A Dvmxnet3_ethdev.h172 uint16_t vmxnet3_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
/deb_dpdk/drivers/net/fm10k/
H A Dfm10k.h356 uint16_t fm10k_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
365 uint16_t fm10k_xmit_pkts_vec(void *tx_queue, struct rte_mbuf **tx_pkts,
/deb_dpdk/drivers/net/bnx2x/
H A Dbnx2x_rxtx.c177 bnx2x_tx_queue_release(struct bnx2x_tx_queue *tx_queue) argument
182 if (NULL != tx_queue) {
184 sw_ring = tx_queue->sw_ring;
186 for (i = 0; i < tx_queue->nb_tx_desc; i++) {
192 rte_free(tx_queue);
/deb_dpdk/drivers/net/ixgbe/
H A Dixgbe_rxtx.h312 uint16_t ixgbe_xmit_pkts_vec(void *tx_queue, struct rte_mbuf **tx_pkts,
H A Dixgbe_ethdev.h400 uint16_t ixgbe_xmit_pkts(void *tx_queue, struct rte_mbuf **tx_pkts,
403 uint16_t ixgbe_xmit_pkts_simple(void *tx_queue, struct rte_mbuf **tx_pkts,
/deb_dpdk/drivers/net/qede/
H A Dqede_rxtx.h172 void qede_tx_queue_release(void *tx_queue);

Completed in 19 milliseconds

123