Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 31c70d59 authored by Eric Dumazet's avatar Eric Dumazet Committed by David S. Miller
Browse files

l2tp: keep original skb ownership



There is no reason to orphan skb in l2tp.

This breaks things like per socket memory limits, TCP Small queues...

Fix this before more people copy/paste it.

This is very similar to commit 8f646c92
("vxlan: keep original skb ownership")

Signed-off-by: default avatarEric Dumazet <edumazet@google.com>
Cc: James Chapman <jchapman@katalix.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 21962692
Loading
Loading
Loading
Loading
+2 −21
Original line number Original line Diff line number Diff line
@@ -1108,6 +1108,7 @@ static int l2tp_xmit_core(struct l2tp_session *session, struct sk_buff *skb,
			  struct flowi *fl, size_t data_len)
			  struct flowi *fl, size_t data_len)
{
{
	struct l2tp_tunnel *tunnel = session->tunnel;
	struct l2tp_tunnel *tunnel = session->tunnel;
	struct sock *sk = tunnel->sock;
	unsigned int len = skb->len;
	unsigned int len = skb->len;
	int error;
	int error;


@@ -1131,7 +1132,7 @@ static int l2tp_xmit_core(struct l2tp_session *session, struct sk_buff *skb,
	/* Queue the packet to IP for output */
	/* Queue the packet to IP for output */
	skb->local_df = 1;
	skb->local_df = 1;
#if IS_ENABLED(CONFIG_IPV6)
#if IS_ENABLED(CONFIG_IPV6)
	if (skb->sk->sk_family == PF_INET6 && !tunnel->v4mapped)
	if (sk->sk_family == PF_INET6 && !tunnel->v4mapped)
		error = inet6_csk_xmit(skb, NULL);
		error = inet6_csk_xmit(skb, NULL);
	else
	else
#endif
#endif
@@ -1151,23 +1152,6 @@ static int l2tp_xmit_core(struct l2tp_session *session, struct sk_buff *skb,
	return 0;
	return 0;
}
}


/* Automatically called when the skb is freed.
 */
static void l2tp_sock_wfree(struct sk_buff *skb)
{
	sock_put(skb->sk);
}

/* For data skbs that we transmit, we associate with the tunnel socket
 * but don't do accounting.
 */
static inline void l2tp_skb_set_owner_w(struct sk_buff *skb, struct sock *sk)
{
	sock_hold(sk);
	skb->sk = sk;
	skb->destructor = l2tp_sock_wfree;
}

#if IS_ENABLED(CONFIG_IPV6)
#if IS_ENABLED(CONFIG_IPV6)
static void l2tp_xmit_ipv6_csum(struct sock *sk, struct sk_buff *skb,
static void l2tp_xmit_ipv6_csum(struct sock *sk, struct sk_buff *skb,
				int udp_len)
				int udp_len)
@@ -1221,7 +1205,6 @@ int l2tp_xmit_skb(struct l2tp_session *session, struct sk_buff *skb, int hdr_len
		return NET_XMIT_DROP;
		return NET_XMIT_DROP;
	}
	}


	skb_orphan(skb);
	/* Setup L2TP header */
	/* Setup L2TP header */
	session->build_header(session, __skb_push(skb, hdr_len));
	session->build_header(session, __skb_push(skb, hdr_len));


@@ -1287,8 +1270,6 @@ int l2tp_xmit_skb(struct l2tp_session *session, struct sk_buff *skb, int hdr_len
		break;
		break;
	}
	}


	l2tp_skb_set_owner_w(skb, sk);

	l2tp_xmit_core(session, skb, fl, data_len);
	l2tp_xmit_core(session, skb, fl, data_len);
out_unlock:
out_unlock:
	bh_unlock_sock(sk);
	bh_unlock_sock(sk);