Skip to content

Commit

Permalink
netlink: allow large data transfers from user-space
Browse files Browse the repository at this point in the history
I can hit ENOBUFS in the sendmsg() path with a large batch that is
composed of many netlink messages. Here that limit is 8 MBytes of
skbuff data area as kmalloc does not manage to get more than that.

While discussing atomic rule-set for nftables with Patrick McHardy,
we decided to put all rule-set updates that need to be applied
atomically in one single batch to simplify the existing approach.
However, as explained above, the existing netlink code limits us
to a maximum of ~20000 rules that fit in one single batch without
hitting ENOBUFS. iptables does not have such limitation as it is
using vmalloc.

This patch adds netlink_alloc_large_skb() which is only used in
the netlink_sendmsg() path. It uses alloc_skb if the memory
requested is <= one memory page, that should be the common case
for most subsystems, else vmalloc for higher memory allocations.

Signed-off-by: Pablo Neira Ayuso <pablo@netfilter.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
Pablo Neira Ayuso authored and David S. Miller committed Jun 7, 2013
1 parent 1b5acd2 commit c05cdb1
Showing 1 changed file with 35 additions and 2 deletions.
37 changes: 35 additions & 2 deletions net/netlink/af_netlink.c
Original file line number Diff line number Diff line change
Expand Up @@ -750,6 +750,10 @@ static void netlink_skb_destructor(struct sk_buff *skb)
skb->head = NULL;
}
#endif
if (is_vmalloc_addr(skb->head)) {
vfree(skb->head);
skb->head = NULL;
}
if (skb->sk != NULL)
sock_rfree(skb);
}
Expand Down Expand Up @@ -1420,6 +1424,35 @@ struct sock *netlink_getsockbyfilp(struct file *filp)
return sock;
}

static struct sk_buff *netlink_alloc_large_skb(unsigned int size)
{
struct sk_buff *skb;
void *data;

if (size <= NLMSG_GOODSIZE)
return alloc_skb(size, GFP_KERNEL);

skb = alloc_skb_head(GFP_KERNEL);
if (skb == NULL)
return NULL;

data = vmalloc(size);
if (data == NULL)
goto err;

skb->head = data;
skb->data = data;
skb_reset_tail_pointer(skb);
skb->end = skb->tail + size;
skb->len = 0;
skb->destructor = netlink_skb_destructor;

return skb;
err:
kfree_skb(skb);
return NULL;
}

/*
* Attach a skb to a netlink socket.
* The caller must hold a reference to the destination socket. On error, the
Expand Down Expand Up @@ -1510,7 +1543,7 @@ static struct sk_buff *netlink_trim(struct sk_buff *skb, gfp_t allocation)
return skb;

delta = skb->end - skb->tail;
if (delta * 2 < skb->truesize)
if (is_vmalloc_addr(skb->head) || delta * 2 < skb->truesize)
return skb;

if (skb_shared(skb)) {
Expand Down Expand Up @@ -2096,7 +2129,7 @@ static int netlink_sendmsg(struct kiocb *kiocb, struct socket *sock,
if (len > sk->sk_sndbuf - 32)
goto out;
err = -ENOBUFS;
skb = alloc_skb(len, GFP_KERNEL);
skb = netlink_alloc_large_skb(len);
if (skb == NULL)
goto out;

Expand Down

0 comments on commit c05cdb1

Please sign in to comment.