ExternalVendorCode/openwrt
1
0
Fork 0
mirror of https://github.com/openwrt/openwrt.git synced 2025-01-31 16:35:44 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

ath79: ag71xx: use netif_receive_skb_list on 4.19

Browse Source 
This new function make batch processing of network packets possible,
which slightly improves performance.

Signed-off-by: Chuanhong Guo <gch981213@gmail.com>
Tested-by: Rosen Penev <rosenp@gmail.com>
This commit is contained in:
Chuanhong Guo 2020-01-06 16:12:03 -08:00
parent 6f10aa737e
commit dd280444b3
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
target/linux/ath79/files/drivers/net/ethernet/atheros/ag71xx/ag71xx_main.c
View File

@ -1214,14 +1214,22 @@ static int ag71xx_rx_packets(struct ag71xx *ag, int limit)
unsigned int offset = ag->rx_buf_offset; unsigned int offset = ag->rx_buf_offset;
int ring_mask = BIT(ring->order) - 1; int ring_mask = BIT(ring->order) - 1;
int ring_size = BIT(ring->order); int ring_size = BIT(ring->order);
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(4,19,0))
struct list_head rx_list;
struct sk_buff *next;
#else
struct sk_buff_head queue; struct sk_buff_head queue;
#endif
struct sk_buff *skb; struct sk_buff *skb;
int done = 0; int done = 0;
DBG("%s: rx packets, limit=%d, curr=%u, dirty=%u\n", DBG("%s: rx packets, limit=%d, curr=%u, dirty=%u\n",
dev->name, limit, ring->curr, ring->dirty); dev->name, limit, ring->curr, ring->dirty);
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(4,19,0))
INIT_LIST_HEAD(&rx_list);
#else
skb_queue_head_init(&queue); skb_queue_head_init(&queue);
#endif
while (done < limit) { while (done < limit) {
unsigned int i = ring->curr & ring_mask; unsigned int i = ring->curr & ring_mask;
@ -1263,7 +1271,11 @@ static int ag71xx_rx_packets(struct ag71xx *ag, int limit)
} else { } else {
skb->dev = dev; skb->dev = dev;
skb->ip_summed = CHECKSUM_NONE; skb->ip_summed = CHECKSUM_NONE;
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(4,19,0))
list_add_tail(&skb->list, &rx_list);
#else
__skb_queue_tail(&queue, skb); __skb_queue_tail(&queue, skb);
#endif
} }
next: next:
@ -1275,10 +1287,16 @@ next:
ag71xx_ring_rx_refill(ag); ag71xx_ring_rx_refill(ag);
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(4,19,0))
list_for_each_entry_safe(skb, next, &rx_list, list)
skb->protocol = eth_type_trans(skb, dev);
netif_receive_skb_list(&rx_list);
#else
while ((skb = __skb_dequeue(&queue)) != NULL) { while ((skb = __skb_dequeue(&queue)) != NULL) {
skb->protocol = eth_type_trans(skb, dev); skb->protocol = eth_type_trans(skb, dev);
netif_receive_skb(skb); netif_receive_skb(skb);
} }
#endif
DBG("%s: rx finish, curr=%u, dirty=%u, done=%d\n", DBG("%s: rx finish, curr=%u, dirty=%u, done=%d\n",
dev->name, ring->curr, ring->dirty, done); dev->name, ring->curr, ring->dirty, done);