Commit d1c76af9 authored by Herbert Xu's avatar Herbert Xu Committed by David S. Miller

GRO: Move netpoll checks to correct location

As my netpoll fix for net doesn't really work for net-next, we
need this update to move the checks into the right place.  As it
stands we may pass freed skbs to netpoll_receive_skb.

This patch also introduces a netpoll_rx_on function to avoid GRO
completely if we're invoked through netpoll.  This might seem
paranoid but as netpoll may have an external receive hook it's
better to be safe than sorry.  I don't think we need this for
2.6.29 though since there's nothing immediately broken by it.

This patch also moves the GRO_* return values to netdevice.h since
VLAN needs them too (I tried to avoid this originally but alas
this seems to be the easiest way out).  This fixes a bug in VLAN
where it continued to use the old return value 2 instead of the
correct GRO_DROP.
Signed-off-by: default avatarHerbert Xu <herbert@gondor.apana.org.au>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent afece1c6
...@@ -330,6 +330,14 @@ enum ...@@ -330,6 +330,14 @@ enum
NAPI_STATE_NPSVC, /* Netpoll - don't dequeue from poll_list */ NAPI_STATE_NPSVC, /* Netpoll - don't dequeue from poll_list */
}; };
enum {
GRO_MERGED,
GRO_MERGED_FREE,
GRO_HELD,
GRO_NORMAL,
GRO_DROP,
};
extern void __napi_schedule(struct napi_struct *n); extern void __napi_schedule(struct napi_struct *n);
static inline int napi_disable_pending(struct napi_struct *n) static inline int napi_disable_pending(struct napi_struct *n)
......
...@@ -63,6 +63,13 @@ static inline int netpoll_rx(struct sk_buff *skb) ...@@ -63,6 +63,13 @@ static inline int netpoll_rx(struct sk_buff *skb)
return ret; return ret;
} }
static inline int netpoll_rx_on(struct sk_buff *skb)
{
struct netpoll_info *npinfo = skb->dev->npinfo;
return npinfo && (npinfo->rx_np || npinfo->rx_flags);
}
static inline int netpoll_receive_skb(struct sk_buff *skb) static inline int netpoll_receive_skb(struct sk_buff *skb)
{ {
if (!list_empty(&skb->dev->napi_list)) if (!list_empty(&skb->dev->napi_list))
...@@ -99,6 +106,10 @@ static inline int netpoll_rx(struct sk_buff *skb) ...@@ -99,6 +106,10 @@ static inline int netpoll_rx(struct sk_buff *skb)
{ {
return 0; return 0;
} }
static inline int netpoll_rx_on(struct sk_buff *skb)
{
return 0;
}
static inline int netpoll_receive_skb(struct sk_buff *skb) static inline int netpoll_receive_skb(struct sk_buff *skb)
{ {
return 0; return 0;
......
...@@ -79,6 +79,9 @@ static int vlan_gro_common(struct napi_struct *napi, struct vlan_group *grp, ...@@ -79,6 +79,9 @@ static int vlan_gro_common(struct napi_struct *napi, struct vlan_group *grp,
{ {
struct sk_buff *p; struct sk_buff *p;
if (netpoll_rx_on(skb))
return GRO_NORMAL;
if (skb_bond_should_drop(skb)) if (skb_bond_should_drop(skb))
goto drop; goto drop;
...@@ -98,7 +101,7 @@ static int vlan_gro_common(struct napi_struct *napi, struct vlan_group *grp, ...@@ -98,7 +101,7 @@ static int vlan_gro_common(struct napi_struct *napi, struct vlan_group *grp,
return dev_gro_receive(napi, skb); return dev_gro_receive(napi, skb);
drop: drop:
return 2; return GRO_DROP;
} }
int vlan_gro_receive(struct napi_struct *napi, struct vlan_group *grp, int vlan_gro_receive(struct napi_struct *napi, struct vlan_group *grp,
...@@ -106,9 +109,6 @@ int vlan_gro_receive(struct napi_struct *napi, struct vlan_group *grp, ...@@ -106,9 +109,6 @@ int vlan_gro_receive(struct napi_struct *napi, struct vlan_group *grp,
{ {
skb_gro_reset_offset(skb); skb_gro_reset_offset(skb);
if (netpoll_receive_skb(skb))
return NET_RX_DROP;
return napi_skb_finish(vlan_gro_common(napi, grp, vlan_tci, skb), skb); return napi_skb_finish(vlan_gro_common(napi, grp, vlan_tci, skb), skb);
} }
EXPORT_SYMBOL(vlan_gro_receive); EXPORT_SYMBOL(vlan_gro_receive);
...@@ -121,9 +121,6 @@ int vlan_gro_frags(struct napi_struct *napi, struct vlan_group *grp, ...@@ -121,9 +121,6 @@ int vlan_gro_frags(struct napi_struct *napi, struct vlan_group *grp,
if (!skb) if (!skb)
return NET_RX_DROP; return NET_RX_DROP;
if (netpoll_receive_skb(skb))
return NET_RX_DROP;
return napi_frags_finish(napi, skb, return napi_frags_finish(napi, skb,
vlan_gro_common(napi, grp, vlan_tci, skb)); vlan_gro_common(napi, grp, vlan_tci, skb));
} }
......
...@@ -135,14 +135,6 @@ ...@@ -135,14 +135,6 @@
/* This should be increased if a protocol with a bigger head is added. */ /* This should be increased if a protocol with a bigger head is added. */
#define GRO_MAX_HEAD (MAX_HEADER + 128) #define GRO_MAX_HEAD (MAX_HEADER + 128)
enum {
GRO_MERGED,
GRO_MERGED_FREE,
GRO_HELD,
GRO_NORMAL,
GRO_DROP,
};
/* /*
* The list of packet types we will receive (as opposed to discard) * The list of packet types we will receive (as opposed to discard)
* and the routines to invoke. * and the routines to invoke.
...@@ -2474,6 +2466,9 @@ static int __napi_gro_receive(struct napi_struct *napi, struct sk_buff *skb) ...@@ -2474,6 +2466,9 @@ static int __napi_gro_receive(struct napi_struct *napi, struct sk_buff *skb)
{ {
struct sk_buff *p; struct sk_buff *p;
if (netpoll_rx_on(skb))
return GRO_NORMAL;
for (p = napi->gro_list; p; p = p->next) { for (p = napi->gro_list; p; p = p->next) {
NAPI_GRO_CB(p)->same_flow = !compare_ether_header( NAPI_GRO_CB(p)->same_flow = !compare_ether_header(
skb_mac_header(p), skb_gro_mac_header(skb)); skb_mac_header(p), skb_gro_mac_header(skb));
...@@ -2487,9 +2482,6 @@ int napi_skb_finish(int ret, struct sk_buff *skb) ...@@ -2487,9 +2482,6 @@ int napi_skb_finish(int ret, struct sk_buff *skb)
{ {
int err = NET_RX_SUCCESS; int err = NET_RX_SUCCESS;
if (netpoll_receive_skb(skb))
return NET_RX_DROP;
switch (ret) { switch (ret) {
case GRO_NORMAL: case GRO_NORMAL:
return netif_receive_skb(skb); return netif_receive_skb(skb);
...@@ -2587,9 +2579,6 @@ int napi_frags_finish(struct napi_struct *napi, struct sk_buff *skb, int ret) ...@@ -2587,9 +2579,6 @@ int napi_frags_finish(struct napi_struct *napi, struct sk_buff *skb, int ret)
{ {
int err = NET_RX_SUCCESS; int err = NET_RX_SUCCESS;
if (netpoll_receive_skb(skb))
return NET_RX_DROP;
switch (ret) { switch (ret) {
case GRO_NORMAL: case GRO_NORMAL:
case GRO_HELD: case GRO_HELD:
......
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