diff mbox series

[1/2] protocol: pm callback must be done after msk state is set up

Message ID 20200109143114.7716-1-fw@strlen.de
State Accepted, archived
Delegated to: Matthieu Baerts
Headers show
Series [1/2] protocol: pm callback must be done after msk state is set up | expand

Commit Message

Florian Westphal Jan. 9, 2020, 2:31 p.m. UTC
Squashto: mptcp: Add path manager interface

current location calls this when msk->token is still 0, so pm worker
will never find the mptcp socket it should be using.

Signed-off-by: Florian Westphal <fw@strlen.de>
---
 net/mptcp/protocol.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

Comments

Paolo Abeni Jan. 9, 2020, 3:29 p.m. UTC | #1
On Thu, 2020-01-09 at 15:31 +0100, Florian Westphal wrote:
> Squashto: mptcp: Add path manager interface
> 
> current location calls this when msk->token is still 0, so pm worker
> will never find the mptcp socket it should be using.
> 
> Signed-off-by: Florian Westphal <fw@strlen.de>
> ---
>  net/mptcp/protocol.c | 4 ++--
>  1 file changed, 2 insertions(+), 2 deletions(-)
> 
> diff --git a/net/mptcp/protocol.c b/net/mptcp/protocol.c
> index 475ef4c90460..a33c4c58de78 100644
> --- a/net/mptcp/protocol.c
> +++ b/net/mptcp/protocol.c
> @@ -1371,8 +1371,6 @@ void mptcp_finish_connect(struct sock *ssk)
>  
>  	pr_debug("msk=%p, token=%u", sk, subflow->token);
>  
> -	mptcp_pm_new_connection(msk, 0);
> -
>  	mptcp_crypto_key_sha(subflow->remote_key, NULL, &ack_seq);
>  	ack_seq++;
>  	subflow->map_seq = ack_seq;
> @@ -1389,6 +1387,8 @@ void mptcp_finish_connect(struct sock *ssk)
>  	WRITE_ONCE(msk->ack_seq, ack_seq);
>  	WRITE_ONCE(msk->can_ack, 1);
>  	atomic64_set(&msk->snd_una, msk->write_seq);
> +
> +	mptcp_pm_new_connection(msk, 0);
>  }
>  
>  static void mptcp_sock_graft(struct sock *sk, struct socket *parent)

LGTM, thanks Florian! (This was fast!)

Does this fix the MP_JOIN handshake or is there any other pending known
issue ? (beyond the list corruption fixed by the next patch...)

Paolo
Florian Westphal Jan. 9, 2020, 4:53 p.m. UTC | #2
Paolo Abeni <pabeni@redhat.com> wrote:
> On Thu, 2020-01-09 at 15:31 +0100, Florian Westphal wrote:
> > Squashto: mptcp: Add path manager interface
> > 
> > current location calls this when msk->token is still 0, so pm worker
> > will never find the mptcp socket it should be using.
> > 
> > Signed-off-by: Florian Westphal <fw@strlen.de>
> > ---
> >  net/mptcp/protocol.c | 4 ++--
> >  1 file changed, 2 insertions(+), 2 deletions(-)
> > 
> > diff --git a/net/mptcp/protocol.c b/net/mptcp/protocol.c
> > index 475ef4c90460..a33c4c58de78 100644
> > --- a/net/mptcp/protocol.c
> > +++ b/net/mptcp/protocol.c
> > @@ -1371,8 +1371,6 @@ void mptcp_finish_connect(struct sock *ssk)
> >  
> >  	pr_debug("msk=%p, token=%u", sk, subflow->token);
> >  
> > -	mptcp_pm_new_connection(msk, 0);
> > -
> >  	mptcp_crypto_key_sha(subflow->remote_key, NULL, &ack_seq);
> >  	ack_seq++;
> >  	subflow->map_seq = ack_seq;
> > @@ -1389,6 +1387,8 @@ void mptcp_finish_connect(struct sock *ssk)
> >  	WRITE_ONCE(msk->ack_seq, ack_seq);
> >  	WRITE_ONCE(msk->can_ack, 1);
> >  	atomic64_set(&msk->snd_una, msk->write_seq);
> > +
> > +	mptcp_pm_new_connection(msk, 0);
> >  }
> >  
> >  static void mptcp_sock_graft(struct sock *sk, struct socket *parent)
> 
> LGTM, thanks Florian! (This was fast!)
> 
> Does this fix the MP_JOIN handshake or is there any other pending known
> issue ? (beyond the list corruption fixed by the next patch...)

Yes and yes.  Things only work when slowing down the test prog to give
the join time to complete.

Else, this hits the 'is parent not established anymore' check
in mptcp_finish_join.  This also gives a memory leak of the socket.
diff mbox series

Patch

diff --git a/net/mptcp/protocol.c b/net/mptcp/protocol.c
index 475ef4c90460..a33c4c58de78 100644
--- a/net/mptcp/protocol.c
+++ b/net/mptcp/protocol.c
@@ -1371,8 +1371,6 @@  void mptcp_finish_connect(struct sock *ssk)
 
 	pr_debug("msk=%p, token=%u", sk, subflow->token);
 
-	mptcp_pm_new_connection(msk, 0);
-
 	mptcp_crypto_key_sha(subflow->remote_key, NULL, &ack_seq);
 	ack_seq++;
 	subflow->map_seq = ack_seq;
@@ -1389,6 +1387,8 @@  void mptcp_finish_connect(struct sock *ssk)
 	WRITE_ONCE(msk->ack_seq, ack_seq);
 	WRITE_ONCE(msk->can_ack, 1);
 	atomic64_set(&msk->snd_una, msk->write_seq);
+
+	mptcp_pm_new_connection(msk, 0);
 }
 
 static void mptcp_sock_graft(struct sock *sk, struct socket *parent)