net: airoha: Move airoha_queues in airoha_qdma
authorLorenzo Bianconi <lorenzo@kernel.org>
Thu, 1 Aug 2024 14:35:04 +0000 (16:35 +0200)
committerJakub Kicinski <kuba@kernel.org>
Fri, 2 Aug 2024 23:31:10 +0000 (16:31 -0700)
QDMA controllers available in EN7581 SoC have independent tx/rx hw queues
so move them in airoha_queues structure.

Signed-off-by: Lorenzo Bianconi <lorenzo@kernel.org>
Link: https://patch.msgid.link/795fc4797bffbf7f0a1351308aa9bf0e65b5126e.1722522582.git.lorenzo@kernel.org
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
drivers/net/ethernet/mediatek/airoha_eth.c

index 7add08b..fc67122 100644 (file)
@@ -785,6 +785,17 @@ struct airoha_hw_stats {
 
 struct airoha_qdma {
        void __iomem *regs;
+
+       struct airoha_tx_irq_queue q_tx_irq[AIROHA_NUM_TX_IRQ];
+
+       struct airoha_queue q_tx[AIROHA_NUM_TX_RING];
+       struct airoha_queue q_rx[AIROHA_NUM_RX_RING];
+
+       /* descriptor and packet buffers for qdma hw forward */
+       struct {
+               void *desc;
+               void *q;
+       } hfwd;
 };
 
 struct airoha_gdm_port {
@@ -809,20 +820,10 @@ struct airoha_eth {
        struct reset_control_bulk_data rsts[AIROHA_MAX_NUM_RSTS];
        struct reset_control_bulk_data xsi_rsts[AIROHA_MAX_NUM_XSI_RSTS];
 
-       struct airoha_qdma qdma[AIROHA_MAX_NUM_QDMA];
-       struct airoha_gdm_port *ports[AIROHA_MAX_NUM_GDM_PORTS];
-
        struct net_device *napi_dev;
-       struct airoha_queue q_tx[AIROHA_NUM_TX_RING];
-       struct airoha_queue q_rx[AIROHA_NUM_RX_RING];
-
-       struct airoha_tx_irq_queue q_tx_irq[AIROHA_NUM_TX_IRQ];
 
-       /* descriptor and packet buffers for qdma hw forward */
-       struct {
-               void *desc;
-               void *q;
-       } hfwd;
+       struct airoha_qdma qdma[AIROHA_MAX_NUM_QDMA];
+       struct airoha_gdm_port *ports[AIROHA_MAX_NUM_GDM_PORTS];
 };
 
 static u32 airoha_rr(void __iomem *base, u32 offset)
@@ -1390,7 +1391,7 @@ static int airoha_qdma_fill_rx_queue(struct airoha_queue *q)
        enum dma_data_direction dir = page_pool_get_dma_dir(q->page_pool);
        struct airoha_qdma *qdma = &q->eth->qdma[0];
        struct airoha_eth *eth = q->eth;
-       int qid = q - &eth->q_rx[0];
+       int qid = q - &qdma->q_rx[0];
        int nframes = 0;
 
        while (q->queued < q->ndesc - 1) {
@@ -1457,8 +1458,9 @@ static int airoha_qdma_get_gdm_port(struct airoha_eth *eth,
 static int airoha_qdma_rx_process(struct airoha_queue *q, int budget)
 {
        enum dma_data_direction dir = page_pool_get_dma_dir(q->page_pool);
+       struct airoha_qdma *qdma = &q->eth->qdma[0];
        struct airoha_eth *eth = q->eth;
-       int qid = q - &eth->q_rx[0];
+       int qid = q - &qdma->q_rx[0];
        int done = 0;
 
        while (done < budget) {
@@ -1549,7 +1551,7 @@ static int airoha_qdma_init_rx_queue(struct airoha_eth *eth,
                .dev = eth->dev,
                .napi = &q->napi,
        };
-       int qid = q - &eth->q_rx[0], thr;
+       int qid = q - &qdma->q_rx[0], thr;
        dma_addr_t dma_addr;
 
        q->buf_size = PAGE_SIZE / 2;
@@ -1613,7 +1615,7 @@ static int airoha_qdma_init_rx(struct airoha_eth *eth,
 {
        int i;
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_rx); i++) {
+       for (i = 0; i < ARRAY_SIZE(qdma->q_rx); i++) {
                int err;
 
                if (!(RX_DONE_INT_MASK & BIT(i))) {
@@ -1621,7 +1623,7 @@ static int airoha_qdma_init_rx(struct airoha_eth *eth,
                        continue;
                }
 
-               err = airoha_qdma_init_rx_queue(eth, &eth->q_rx[i],
+               err = airoha_qdma_init_rx_queue(eth, &qdma->q_rx[i],
                                                qdma, RX_DSCP_NUM(i));
                if (err)
                        return err;
@@ -1640,7 +1642,7 @@ static int airoha_qdma_tx_napi_poll(struct napi_struct *napi, int budget)
        irq_q = container_of(napi, struct airoha_tx_irq_queue, napi);
        eth = irq_q->eth;
        qdma = &eth->qdma[0];
-       id = irq_q - &eth->q_tx_irq[0];
+       id = irq_q - &qdma->q_tx_irq[0];
 
        while (irq_q->queued > 0 && done < budget) {
                u32 qid, last, val = irq_q->q[irq_q->head];
@@ -1657,10 +1659,10 @@ static int airoha_qdma_tx_napi_poll(struct napi_struct *napi, int budget)
                last = FIELD_GET(IRQ_DESC_IDX_MASK, val);
                qid = FIELD_GET(IRQ_RING_IDX_MASK, val);
 
-               if (qid >= ARRAY_SIZE(eth->q_tx))
+               if (qid >= ARRAY_SIZE(qdma->q_tx))
                        continue;
 
-               q = &eth->q_tx[qid];
+               q = &qdma->q_tx[qid];
                if (!q->ndesc)
                        continue;
 
@@ -1726,7 +1728,7 @@ static int airoha_qdma_init_tx_queue(struct airoha_eth *eth,
                                     struct airoha_queue *q,
                                     struct airoha_qdma *qdma, int size)
 {
-       int i, qid = q - &eth->q_tx[0];
+       int i, qid = q - &qdma->q_tx[0];
        dma_addr_t dma_addr;
 
        spin_lock_init(&q->lock);
@@ -1764,7 +1766,7 @@ static int airoha_qdma_tx_irq_init(struct airoha_eth *eth,
                                   struct airoha_tx_irq_queue *irq_q,
                                   struct airoha_qdma *qdma, int size)
 {
-       int id = irq_q - &eth->q_tx_irq[0];
+       int id = irq_q - &qdma->q_tx_irq[0];
        dma_addr_t dma_addr;
 
        netif_napi_add_tx(eth->napi_dev, &irq_q->napi,
@@ -1792,15 +1794,15 @@ static int airoha_qdma_init_tx(struct airoha_eth *eth,
 {
        int i, err;
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx_irq); i++) {
-               err = airoha_qdma_tx_irq_init(eth, &eth->q_tx_irq[i],
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx_irq); i++) {
+               err = airoha_qdma_tx_irq_init(eth, &qdma->q_tx_irq[i],
                                              qdma, IRQ_QUEUE_LEN(i));
                if (err)
                        return err;
        }
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx); i++) {
-               err = airoha_qdma_init_tx_queue(eth, &eth->q_tx[i],
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx); i++) {
+               err = airoha_qdma_init_tx_queue(eth, &qdma->q_tx[i],
                                                qdma, TX_DSCP_NUM);
                if (err)
                        return err;
@@ -1836,17 +1838,17 @@ static int airoha_qdma_init_hfwd_queues(struct airoha_eth *eth,
        int size;
 
        size = HW_DSCP_NUM * sizeof(struct airoha_qdma_fwd_desc);
-       eth->hfwd.desc = dmam_alloc_coherent(eth->dev, size, &dma_addr,
-                                            GFP_KERNEL);
-       if (!eth->hfwd.desc)
+       qdma->hfwd.desc = dmam_alloc_coherent(eth->dev, size, &dma_addr,
+                                             GFP_KERNEL);
+       if (!qdma->hfwd.desc)
                return -ENOMEM;
 
        airoha_qdma_wr(qdma, REG_FWD_DSCP_BASE, dma_addr);
 
        size = AIROHA_MAX_PACKET_SIZE * HW_DSCP_NUM;
-       eth->hfwd.q = dmam_alloc_coherent(eth->dev, size, &dma_addr,
-                                         GFP_KERNEL);
-       if (!eth->hfwd.q)
+       qdma->hfwd.q = dmam_alloc_coherent(eth->dev, size, &dma_addr,
+                                          GFP_KERNEL);
+       if (!qdma->hfwd.q)
                return -ENOMEM;
 
        airoha_qdma_wr(qdma, REG_FWD_BUF_BASE, dma_addr);
@@ -1934,8 +1936,8 @@ static int airoha_qdma_hw_init(struct airoha_eth *eth,
        airoha_qdma_irq_enable(eth, QDMA_INT_REG_IDX4, INT_IDX4_MASK);
 
        /* setup irq binding */
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx); i++) {
-               if (!eth->q_tx[i].ndesc)
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx); i++) {
+               if (!qdma->q_tx[i].ndesc)
                        continue;
 
                if (TX_RING_IRQ_BLOCKING_MAP_MASK & BIT(i))
@@ -1960,8 +1962,8 @@ static int airoha_qdma_hw_init(struct airoha_eth *eth,
        airoha_qdma_init_qos(eth, qdma);
 
        /* disable qdma rx delay interrupt */
-       for (i = 0; i < ARRAY_SIZE(eth->q_rx); i++) {
-               if (!eth->q_rx[i].ndesc)
+       for (i = 0; i < ARRAY_SIZE(qdma->q_rx); i++) {
+               if (!qdma->q_rx[i].ndesc)
                        continue;
 
                airoha_qdma_clear(qdma, REG_RX_DELAY_INT_IDX(i),
@@ -1995,18 +1997,18 @@ static irqreturn_t airoha_irq_handler(int irq, void *dev_instance)
                airoha_qdma_irq_disable(eth, QDMA_INT_REG_IDX1,
                                        RX_DONE_INT_MASK);
 
-               for (i = 0; i < ARRAY_SIZE(eth->q_rx); i++) {
-                       if (!eth->q_rx[i].ndesc)
+               for (i = 0; i < ARRAY_SIZE(qdma->q_rx); i++) {
+                       if (!qdma->q_rx[i].ndesc)
                                continue;
 
                        if (intr[1] & BIT(i))
-                               napi_schedule(&eth->q_rx[i].napi);
+                               napi_schedule(&qdma->q_rx[i].napi);
                }
        }
 
        if (intr[0] & INT_TX_MASK) {
-               for (i = 0; i < ARRAY_SIZE(eth->q_tx_irq); i++) {
-                       struct airoha_tx_irq_queue *irq_q = &eth->q_tx_irq[i];
+               for (i = 0; i < ARRAY_SIZE(qdma->q_tx_irq); i++) {
+                       struct airoha_tx_irq_queue *irq_q = &qdma->q_tx_irq[i];
                        u32 status, head;
 
                        if (!(intr[0] & TX_DONE_INT_MASK(i)))
@@ -2020,7 +2022,7 @@ static irqreturn_t airoha_irq_handler(int irq, void *dev_instance)
                        irq_q->head = head % irq_q->size;
                        irq_q->queued = FIELD_GET(IRQ_ENTRY_LEN_MASK, status);
 
-                       napi_schedule(&eth->q_tx_irq[i].napi);
+                       napi_schedule(&qdma->q_tx_irq[i].napi);
                }
        }
 
@@ -2079,44 +2081,46 @@ static int airoha_hw_init(struct airoha_eth *eth)
 
 static void airoha_hw_cleanup(struct airoha_eth *eth)
 {
+       struct airoha_qdma *qdma = &eth->qdma[0];
        int i;
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_rx); i++) {
-               if (!eth->q_rx[i].ndesc)
+       for (i = 0; i < ARRAY_SIZE(qdma->q_rx); i++) {
+               if (!qdma->q_rx[i].ndesc)
                        continue;
 
-               napi_disable(&eth->q_rx[i].napi);
-               netif_napi_del(&eth->q_rx[i].napi);
-               airoha_qdma_cleanup_rx_queue(&eth->q_rx[i]);
-               if (eth->q_rx[i].page_pool)
-                       page_pool_destroy(eth->q_rx[i].page_pool);
+               napi_disable(&qdma->q_rx[i].napi);
+               netif_napi_del(&qdma->q_rx[i].napi);
+               airoha_qdma_cleanup_rx_queue(&qdma->q_rx[i]);
+               if (qdma->q_rx[i].page_pool)
+                       page_pool_destroy(qdma->q_rx[i].page_pool);
        }
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx_irq); i++) {
-               napi_disable(&eth->q_tx_irq[i].napi);
-               netif_napi_del(&eth->q_tx_irq[i].napi);
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx_irq); i++) {
+               napi_disable(&qdma->q_tx_irq[i].napi);
+               netif_napi_del(&qdma->q_tx_irq[i].napi);
        }
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx); i++) {
-               if (!eth->q_tx[i].ndesc)
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx); i++) {
+               if (!qdma->q_tx[i].ndesc)
                        continue;
 
-               airoha_qdma_cleanup_tx_queue(&eth->q_tx[i]);
+               airoha_qdma_cleanup_tx_queue(&qdma->q_tx[i]);
        }
 }
 
 static void airoha_qdma_start_napi(struct airoha_eth *eth)
 {
+       struct airoha_qdma *qdma = &eth->qdma[0];
        int i;
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_tx_irq); i++)
-               napi_enable(&eth->q_tx_irq[i].napi);
+       for (i = 0; i < ARRAY_SIZE(qdma->q_tx_irq); i++)
+               napi_enable(&qdma->q_tx_irq[i].napi);
 
-       for (i = 0; i < ARRAY_SIZE(eth->q_rx); i++) {
-               if (!eth->q_rx[i].ndesc)
+       for (i = 0; i < ARRAY_SIZE(qdma->q_rx); i++) {
+               if (!qdma->q_rx[i].ndesc)
                        continue;
 
-               napi_enable(&eth->q_rx[i].napi);
+               napi_enable(&qdma->q_rx[i].napi);
        }
 }
 
@@ -2391,7 +2395,7 @@ static netdev_tx_t airoha_dev_xmit(struct sk_buff *skb,
               FIELD_PREP(QDMA_ETH_TXMSG_METER_MASK, 0x7f);
 
        qdma = &eth->qdma[0];
-       q = &eth->q_tx[qid];
+       q = &qdma->q_tx[qid];
        if (WARN_ON_ONCE(!q->ndesc))
                goto error;