[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <1335457289.2775.52.camel@edumazet-glaptop>
Date: Thu, 26 Apr 2012 18:21:29 +0200
From: Eric Dumazet <eric.dumazet@...il.com>
To: Shawn Bohrer <sbohrer@...advisors.com>
Cc: netdev@...r.kernel.org
Subject: Re: Heavy spin_lock contention in __udp4_lib_mcast_deliver increase
On Thu, 2012-04-26 at 18:18 +0200, Eric Dumazet wrote:
> On Thu, 2012-04-26 at 17:53 +0200, Eric Dumazet wrote:
>
> > Let me understand
> >
> > You have 300 sockets bound to the same port, so a single message must be
> > copied 300 times and delivered to those sockets ?
> >
> >
>
> Please try the following patch. It should allow up to 512 sockets (on
> x86_64) to be stored in stack, and delivery performed out of the locked
> section.
>
> net/ipv4/udp.c | 16 ++++++++++++----
> net/ipv6/udp.c | 15 +++++++++++----
> 2 files changed, 23 insertions(+), 8 deletions(-)
>
> diff --git a/net/ipv4/udp.c b/net/ipv4/udp.c
> index 279fd08..beb9ea6 100644
> --- a/net/ipv4/udp.c
> +++ b/net/ipv4/udp.c
> @@ -1539,13 +1539,20 @@ static void flush_stack(struct sock **stack, unsigned int count,
> static int __udp4_lib_mcast_deliver(struct net *net, struct sk_buff *skb,
> struct udphdr *uh,
> __be32 saddr, __be32 daddr,
> - struct udp_table *udptable)
> + struct udp_table *udptable,
> + int proto)
> {
> - struct sock *sk, *stack[256 / sizeof(struct sock *)];
> + struct sock *sk, **stack;
> struct udp_hslot *hslot = udp_hashslot(udptable, net, ntohs(uh->dest));
> int dif;
> unsigned int i, count = 0;
>
> + stack = kmalloc(PAGE_SIZE, GFP_ATOMIC);
> + if (unlikely(!stack)) {
> + UDP_INC_STATS_BH(net, UDP_MIB_RCVBUFERRORS, proto == IPPROTO_UDPLITE);
> + kfree_skb(skb);
> + return 0;
> + }
> spin_lock(&hslot->lock);
> sk = sk_nulls_head(&hslot->head);
> dif = skb->dev->ifindex;
> @@ -1554,7 +1561,7 @@ static int __udp4_lib_mcast_deliver(struct net *net, struct sk_buff *skb,
> stack[count++] = sk;
> sk = udp_v4_mcast_next(net, sk_nulls_next(sk), uh->dest,
> daddr, uh->source, saddr, dif);
> - if (unlikely(count == ARRAY_SIZE(stack))) {
> + if (unlikely(count == PAGE_SIZE/sizeof(*sk))) {
Oops, should be PAGE_SIZE/sizeof(sk) of course
(same problem in ipv6/udp.c)
> if (!sk)
> break;
> flush_stack(stack, count, skb, ~0);
> @@ -1580,6 +1587,7 @@ static int __udp4_lib_mcast_deliver(struct net *net, struct sk_buff *skb,
> } else {
> kfree_skb(skb);
> }
> + kfree(stack);
> return 0;
> }
>
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
the body of a message to majordomo@...r.kernel.org
More majordomo info at http://vger.kernel.org/majordomo-info.html
Powered by blists - more mailing lists