1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2019 Cesnet
3 * Copyright(c) 2019 Netcope Technologies, a.s. <[email protected]>
4 * All rights reserved.
5 */
6
7 #include "nfb_tx.h"
8 #include "nfb.h"
9
10 int
nfb_eth_tx_queue_start(struct rte_eth_dev * dev,uint16_t txq_id)11 nfb_eth_tx_queue_start(struct rte_eth_dev *dev, uint16_t txq_id)
12 {
13 struct ndp_tx_queue *txq = dev->data->tx_queues[txq_id];
14 int ret;
15
16 if (txq->queue == NULL) {
17 RTE_LOG(ERR, PMD, "RX NDP queue is NULL!\n");
18 return -EINVAL;
19 }
20
21 ret = ndp_queue_start(txq->queue);
22 if (ret != 0)
23 goto err;
24 dev->data->tx_queue_state[txq_id] = RTE_ETH_QUEUE_STATE_STARTED;
25 return 0;
26
27 err:
28 return -EINVAL;
29 }
30
31 int
nfb_eth_tx_queue_stop(struct rte_eth_dev * dev,uint16_t txq_id)32 nfb_eth_tx_queue_stop(struct rte_eth_dev *dev, uint16_t txq_id)
33 {
34 struct ndp_tx_queue *txq = dev->data->tx_queues[txq_id];
35 int ret;
36
37 if (txq->queue == NULL) {
38 RTE_LOG(ERR, PMD, "TX NDP queue is NULL!\n");
39 return -EINVAL;
40 }
41
42 ret = ndp_queue_stop(txq->queue);
43 if (ret != 0)
44 return -EINVAL;
45 dev->data->tx_queue_state[txq_id] = RTE_ETH_QUEUE_STATE_STOPPED;
46 return 0;
47 }
48
49 int
nfb_eth_tx_queue_setup(struct rte_eth_dev * dev,uint16_t tx_queue_id,uint16_t nb_tx_desc __rte_unused,unsigned int socket_id,const struct rte_eth_txconf * tx_conf __rte_unused)50 nfb_eth_tx_queue_setup(struct rte_eth_dev *dev,
51 uint16_t tx_queue_id,
52 uint16_t nb_tx_desc __rte_unused,
53 unsigned int socket_id,
54 const struct rte_eth_txconf *tx_conf __rte_unused)
55 {
56 struct pmd_internals *internals = dev->data->dev_private;
57 int ret;
58 struct ndp_tx_queue *txq;
59
60 txq = rte_zmalloc_socket("ndp tx queue",
61 sizeof(struct ndp_tx_queue),
62 RTE_CACHE_LINE_SIZE, socket_id);
63
64 if (txq == NULL) {
65 RTE_LOG(ERR, PMD, "rte_zmalloc_socket() failed for tx queue id "
66 "%" PRIu16 "!\n", tx_queue_id);
67 return -ENOMEM;
68 }
69
70 ret = nfb_eth_tx_queue_init(internals->nfb,
71 tx_queue_id,
72 txq);
73
74 if (ret == 0)
75 dev->data->tx_queues[tx_queue_id] = txq;
76 else
77 rte_free(txq);
78
79 return ret;
80 }
81
82 int
nfb_eth_tx_queue_init(struct nfb_device * nfb,uint16_t tx_queue_id,struct ndp_tx_queue * txq)83 nfb_eth_tx_queue_init(struct nfb_device *nfb,
84 uint16_t tx_queue_id,
85 struct ndp_tx_queue *txq)
86 {
87 if (nfb == NULL)
88 return -EINVAL;
89
90 txq->queue = ndp_open_tx_queue(nfb, tx_queue_id);
91 if (txq->queue == NULL)
92 return -EINVAL;
93
94 txq->nfb = nfb;
95 txq->tx_queue_id = tx_queue_id;
96
97 txq->tx_pkts = 0;
98 txq->tx_bytes = 0;
99 txq->err_pkts = 0;
100
101 return 0;
102 }
103
104 void
nfb_eth_tx_queue_release(void * q)105 nfb_eth_tx_queue_release(void *q)
106 {
107 struct ndp_tx_queue *txq = (struct ndp_tx_queue *)q;
108 if (txq->queue != NULL) {
109 ndp_close_tx_queue(txq->queue);
110 rte_free(txq);
111 txq->queue = NULL;
112 }
113 }
114