Skip to content

Commit e1e80e7

Browse files
Paolo Abenigregkh
authored andcommitted
inet: factor out locked section of inet_accept() in a new helper
[ Upstream commit 711bdd5 ] No functional changes intended. The new helper will be used by the MPTCP protocol in the next patch to avoid duplicating a few LoC. Signed-off-by: Paolo Abeni <pabeni@redhat.com> Reviewed-by: Matthieu Baerts <matthieu.baerts@tessares.net> Signed-off-by: Mat Martineau <martineau@kernel.org> Signed-off-by: Jakub Kicinski <kuba@kernel.org> Stable-dep-of: 26afda7 ("net: relax socket state check at accept time.") Signed-off-by: Sasha Levin <sashal@kernel.org>
1 parent 335c8f1 commit e1e80e7

File tree

2 files changed

+19
-15
lines changed

2 files changed

+19
-15
lines changed

include/net/inet_common.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,8 @@ int inet_dgram_connect(struct socket *sock, struct sockaddr *uaddr,
3131
int addr_len, int flags);
3232
int inet_accept(struct socket *sock, struct socket *newsock, int flags,
3333
bool kern);
34+
void __inet_accept(struct socket *sock, struct socket *newsock,
35+
struct sock *newsk);
3436
int inet_send_prepare(struct sock *sk);
3537
int inet_sendmsg(struct socket *sock, struct msghdr *msg, size_t size);
3638
void inet_splice_eof(struct socket *sock);

net/ipv4/af_inet.c

Lines changed: 17 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -744,6 +744,20 @@ int inet_stream_connect(struct socket *sock, struct sockaddr *uaddr,
744744
}
745745
EXPORT_SYMBOL(inet_stream_connect);
746746

747+
void __inet_accept(struct socket *sock, struct socket *newsock, struct sock *newsk)
748+
{
749+
sock_rps_record_flow(newsk);
750+
WARN_ON(!((1 << newsk->sk_state) &
751+
(TCPF_ESTABLISHED | TCPF_SYN_RECV |
752+
TCPF_CLOSE_WAIT | TCPF_CLOSE)));
753+
754+
if (test_bit(SOCK_SUPPORT_ZC, &sock->flags))
755+
set_bit(SOCK_SUPPORT_ZC, &newsock->flags);
756+
sock_graft(newsk, newsock);
757+
758+
newsock->state = SS_CONNECTED;
759+
}
760+
747761
/*
748762
* Accept a pending connection. The TCP layer now gives BSD semantics.
749763
*/
@@ -757,24 +771,12 @@ int inet_accept(struct socket *sock, struct socket *newsock, int flags,
757771
/* IPV6_ADDRFORM can change sk->sk_prot under us. */
758772
sk2 = READ_ONCE(sk1->sk_prot)->accept(sk1, flags, &err, kern);
759773
if (!sk2)
760-
goto do_err;
774+
return err;
761775

762776
lock_sock(sk2);
763-
764-
sock_rps_record_flow(sk2);
765-
WARN_ON(!((1 << sk2->sk_state) &
766-
(TCPF_ESTABLISHED | TCPF_SYN_RECV |
767-
TCPF_CLOSE_WAIT | TCPF_CLOSE)));
768-
769-
if (test_bit(SOCK_SUPPORT_ZC, &sock->flags))
770-
set_bit(SOCK_SUPPORT_ZC, &newsock->flags);
771-
sock_graft(sk2, newsock);
772-
773-
newsock->state = SS_CONNECTED;
774-
err = 0;
777+
__inet_accept(sock, newsock, sk2);
775778
release_sock(sk2);
776-
do_err:
777-
return err;
779+
return 0;
778780
}
779781
EXPORT_SYMBOL(inet_accept);
780782

0 commit comments

Comments
 (0)