Commit 721f80c4 authored by Raju Lakkaraju's avatar Raju Lakkaraju Committed by David S. Miller

net: lan743x: Fix to use multiqueue start/stop APIs

- Fix to use multiqueue start/stop APIs
 - Change to return NETDEV_TX_BUSY instead of holding the TX skb when busy
 - Increase Tx ring size to 128 to address performance issues in some platforms
 - Use NAPI_POLL_WEIGHT for Tx Napi handler instead of ring dependent value
 - Use multiqueue to register 4 Rx channels
Signed-off-by: default avatarRaju Lakkaraju <Raju.Lakkaraju@microchip.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent ceef59b5
...@@ -2066,11 +2066,13 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx, ...@@ -2066,11 +2066,13 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx,
{ {
int required_number_of_descriptors = 0; int required_number_of_descriptors = 0;
unsigned int start_frame_length = 0; unsigned int start_frame_length = 0;
netdev_tx_t retval = NETDEV_TX_OK;
unsigned int frame_length = 0; unsigned int frame_length = 0;
unsigned int head_length = 0; unsigned int head_length = 0;
unsigned long irq_flags = 0; unsigned long irq_flags = 0;
bool do_timestamp = false; bool do_timestamp = false;
bool ignore_sync = false; bool ignore_sync = false;
struct netdev_queue *txq;
int nr_frags = 0; int nr_frags = 0;
bool gso = false; bool gso = false;
int j; int j;
...@@ -2083,9 +2085,12 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx, ...@@ -2083,9 +2085,12 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx,
if (required_number_of_descriptors > (tx->ring_size - 1)) { if (required_number_of_descriptors > (tx->ring_size - 1)) {
dev_kfree_skb_irq(skb); dev_kfree_skb_irq(skb);
} else { } else {
/* save to overflow buffer */ /* save how many descriptors we needed to restart the queue */
tx->overflow_skb = skb; tx->rqd_descriptors = required_number_of_descriptors;
netif_stop_queue(tx->adapter->netdev); retval = NETDEV_TX_BUSY;
txq = netdev_get_tx_queue(tx->adapter->netdev,
tx->channel_number);
netif_tx_stop_queue(txq);
} }
goto unlock; goto unlock;
} }
...@@ -2144,15 +2149,15 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx, ...@@ -2144,15 +2149,15 @@ static netdev_tx_t lan743x_tx_xmit_frame(struct lan743x_tx *tx,
unlock: unlock:
spin_unlock_irqrestore(&tx->ring_lock, irq_flags); spin_unlock_irqrestore(&tx->ring_lock, irq_flags);
return NETDEV_TX_OK; return retval;
} }
static int lan743x_tx_napi_poll(struct napi_struct *napi, int weight) static int lan743x_tx_napi_poll(struct napi_struct *napi, int weight)
{ {
struct lan743x_tx *tx = container_of(napi, struct lan743x_tx, napi); struct lan743x_tx *tx = container_of(napi, struct lan743x_tx, napi);
struct lan743x_adapter *adapter = tx->adapter; struct lan743x_adapter *adapter = tx->adapter;
bool start_transmitter = false;
unsigned long irq_flags = 0; unsigned long irq_flags = 0;
struct netdev_queue *txq;
u32 ioc_bit = 0; u32 ioc_bit = 0;
ioc_bit = DMAC_INT_BIT_TX_IOC_(tx->channel_number); ioc_bit = DMAC_INT_BIT_TX_IOC_(tx->channel_number);
...@@ -2163,24 +2168,20 @@ static int lan743x_tx_napi_poll(struct napi_struct *napi, int weight) ...@@ -2163,24 +2168,20 @@ static int lan743x_tx_napi_poll(struct napi_struct *napi, int weight)
/* clean up tx ring */ /* clean up tx ring */
lan743x_tx_release_completed_descriptors(tx); lan743x_tx_release_completed_descriptors(tx);
if (netif_queue_stopped(adapter->netdev)) { txq = netdev_get_tx_queue(adapter->netdev, tx->channel_number);
if (tx->overflow_skb) { if (netif_tx_queue_stopped(txq)) {
if (lan743x_tx_get_desc_cnt(tx, tx->overflow_skb) <= if (tx->rqd_descriptors) {
lan743x_tx_get_avail_desc(tx)) if (tx->rqd_descriptors <=
start_transmitter = true; lan743x_tx_get_avail_desc(tx)) {
tx->rqd_descriptors = 0;
netif_tx_wake_queue(txq);
}
} else { } else {
netif_wake_queue(adapter->netdev); netif_tx_wake_queue(txq);
} }
} }
spin_unlock_irqrestore(&tx->ring_lock, irq_flags); spin_unlock_irqrestore(&tx->ring_lock, irq_flags);
if (start_transmitter) {
/* space is now available, transmit overflow skb */
lan743x_tx_xmit_frame(tx, tx->overflow_skb);
tx->overflow_skb = NULL;
netif_wake_queue(adapter->netdev);
}
if (!napi_complete(napi)) if (!napi_complete(napi))
goto done; goto done;
...@@ -2304,10 +2305,7 @@ static void lan743x_tx_close(struct lan743x_tx *tx) ...@@ -2304,10 +2305,7 @@ static void lan743x_tx_close(struct lan743x_tx *tx)
lan743x_tx_release_all_descriptors(tx); lan743x_tx_release_all_descriptors(tx);
if (tx->overflow_skb) { tx->rqd_descriptors = 0;
dev_kfree_skb(tx->overflow_skb);
tx->overflow_skb = NULL;
}
lan743x_tx_ring_cleanup(tx); lan743x_tx_ring_cleanup(tx);
} }
...@@ -2387,7 +2385,7 @@ static int lan743x_tx_open(struct lan743x_tx *tx) ...@@ -2387,7 +2385,7 @@ static int lan743x_tx_open(struct lan743x_tx *tx)
(tx->channel_number)); (tx->channel_number));
netif_napi_add_tx_weight(adapter->netdev, netif_napi_add_tx_weight(adapter->netdev,
&tx->napi, lan743x_tx_napi_poll, &tx->napi, lan743x_tx_napi_poll,
tx->ring_size - 1); NAPI_POLL_WEIGHT);
napi_enable(&tx->napi); napi_enable(&tx->napi);
data = 0; data = 0;
...@@ -3347,8 +3345,10 @@ static int lan743x_pcidev_probe(struct pci_dev *pdev, ...@@ -3347,8 +3345,10 @@ static int lan743x_pcidev_probe(struct pci_dev *pdev,
PCI11X1X_USED_TX_CHANNELS, PCI11X1X_USED_TX_CHANNELS,
LAN743X_USED_RX_CHANNELS); LAN743X_USED_RX_CHANNELS);
} else { } else {
netdev = devm_alloc_etherdev(&pdev->dev, netdev = devm_alloc_etherdev_mqs(&pdev->dev,
sizeof(struct lan743x_adapter)); sizeof(struct lan743x_adapter),
LAN743X_USED_TX_CHANNELS,
LAN743X_USED_RX_CHANNELS);
} }
if (!netdev) if (!netdev)
......
...@@ -954,8 +954,7 @@ struct lan743x_tx { ...@@ -954,8 +954,7 @@ struct lan743x_tx {
struct napi_struct napi; struct napi_struct napi;
u32 frame_count; u32 frame_count;
u32 rqd_descriptors;
struct sk_buff *overflow_skb;
}; };
void lan743x_tx_set_timestamping_mode(struct lan743x_tx *tx, void lan743x_tx_set_timestamping_mode(struct lan743x_tx *tx,
...@@ -1110,7 +1109,7 @@ struct lan743x_tx_buffer_info { ...@@ -1110,7 +1109,7 @@ struct lan743x_tx_buffer_info {
unsigned int buffer_length; unsigned int buffer_length;
}; };
#define LAN743X_TX_RING_SIZE (50) #define LAN743X_TX_RING_SIZE (128)
/* OWN bit is set. ie, Descs are owned by RX DMAC */ /* OWN bit is set. ie, Descs are owned by RX DMAC */
#define RX_DESC_DATA0_OWN_ (0x00008000) #define RX_DESC_DATA0_OWN_ (0x00008000)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment