[PATCH 1/2] mptcp: fix compilation error without IPV6
by Matthieu Baerts
net/mptcp/options.c: In function ‘add_addr_hmac_valid’:
net/mptcp/options.c:796:39: error: ‘struct mptcp_options_received’ has no member named ‘addr6’; did you mean ‘addr’?
796 | mp_opt->addr_id, &mp_opt->addr6);
| ^~~~~
| addr
Fixes: 8536089ea875 (mptcp: v1 ADD_ADDR changes: add_addr_hmac_valid)
Signed-off-by: Matthieu Baerts <matthieu.baerts(a)tessares.net>
---
Notes:
to be squashed in "mptcp: Add path manager interface"
net/mptcp/options.c | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/net/mptcp/options.c b/net/mptcp/options.c
index 1f64619be5c0..919f727cc7de 100644
--- a/net/mptcp/options.c
+++ b/net/mptcp/options.c
@@ -781,7 +781,7 @@ static void update_una(struct mptcp_sock *msk,
static bool add_addr_hmac_valid(struct mptcp_subflow_context *subflow,
struct mptcp_options_received *mp_opt)
{
- u64 hmac;
+ u64 hmac = 0;
if (mp_opt->echo)
return true;
@@ -790,10 +790,12 @@ static bool add_addr_hmac_valid(struct mptcp_subflow_context *subflow,
hmac = add_addr_generate_hmac(subflow->remote_key,
subflow->local_key,
mp_opt->addr_id, &mp_opt->addr);
+#if IS_ENABLED(CONFIG_MPTCP_IPV6)
else
hmac = add_addr6_generate_hmac(subflow->remote_key,
subflow->local_key,
mp_opt->addr_id, &mp_opt->addr6);
+#endif
pr_debug("subflow=%p, ahmac=%llu, mp_opt->ahmac=%llu\n",
subflow, (unsigned long long)hmac,
--
2.25.1
6 months
[RFC mptcp-next] tcp: mptcp: use mptcp receive buffer space to select rcv window
by Florian Westphal
In MPTCP, the receive windo is shared across all subflows, because it
refers to the mptcp-level sequence space.
This commit doesn't change choice of initial window for passive or active
connections.
While it would be possible to change those as well, this adds complexity
(especially when handling MP_JOIN requests).
However, the MPTCP RFC specifically says that a MPTCP sender
'MUST NOT use the RCV.WND field of a TCP segment at the connection level if
it does not also carry a DSS option with a Data ACK field.'
SYN/SYNACK packets do not carry a DSS option with a Data ACK field.
CC: Eric Dumazet <edumazet(a)google.com>
Signed-off-by: Florian Westphal <fw(a)strlen.de>
---
This patch would add additional direct call in __tcp_select_window().
I looked at mptcp option writing to check if it could be done there but
that seemed worse.
include/net/mptcp.h | 3 +++
net/ipv4/tcp_output.c | 5 +++++
net/mptcp/subflow.c | 17 +++++++++++++++++
3 files changed, 25 insertions(+)
diff --git a/include/net/mptcp.h b/include/net/mptcp.h
index 7489f9267640..1ef4520f45c3 100644
--- a/include/net/mptcp.h
+++ b/include/net/mptcp.h
@@ -66,6 +66,8 @@ static inline bool rsk_is_mptcp(const struct request_sock *req)
return tcp_rsk(req)->is_mptcp;
}
+void mptcp_space(const struct sock *ssk, int *space, int *full_space);
+
void mptcp_parse_option(const struct sk_buff *skb, const unsigned char *ptr,
int opsize, struct tcp_options_received *opt_rx);
bool mptcp_syn_options(struct sock *sk, const struct sk_buff *skb,
@@ -195,6 +197,7 @@ static inline bool mptcp_sk_is_subflow(const struct sock *sk)
return false;
}
+static inline void mptcp_space(const struct sock *ssk, int *s, int *fs) { }
static inline void mptcp_seq_show(struct seq_file *seq) { }
#endif /* CONFIG_MPTCP */
diff --git a/net/ipv4/tcp_output.c b/net/ipv4/tcp_output.c
index 306e25d743e8..1a829536a115 100644
--- a/net/ipv4/tcp_output.c
+++ b/net/ipv4/tcp_output.c
@@ -2771,6 +2771,11 @@ u32 __tcp_select_window(struct sock *sk)
int full_space = min_t(int, tp->window_clamp, allowed_space);
int window;
+ if (sk_is_mptcp(sk)) {
+ mptcp_space(sk, &free_space, &allowed_space);
+ full_space = min_t(int, tp->window_clamp, allowed_space);
+ }
+
if (unlikely(mss > full_space)) {
mss = full_space;
if (mss <= 0)
diff --git a/net/mptcp/subflow.c b/net/mptcp/subflow.c
index 40ad7995b13b..aefcbb8bb737 100644
--- a/net/mptcp/subflow.c
+++ b/net/mptcp/subflow.c
@@ -745,6 +745,23 @@ bool mptcp_subflow_data_available(struct sock *sk)
return subflow->data_avail;
}
+/* If ssk has an mptcp parent socket, use the mptcp rcvbuf occupancy,
+ * not the ssk one.
+ *
+ * In mptcp, rwin is about the mptcp-level connection data.
+ *
+ * Data that is still on the ssk rx queue can thus be ignored,
+ * as far as mptcp peer is concerened that data is still inflight.
+ */
+void mptcp_space(const struct sock *ssk, int *space, int *full_space)
+{
+ const struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(ssk);
+ const struct sock *sk = READ_ONCE(subflow->conn);
+
+ *space = tcp_space(sk);
+ *full_space = tcp_full_space(sk);
+}
+
static void subflow_data_ready(struct sock *sk)
{
struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(sk);
--
2.24.1
6 months
[PATCH v5 0/5] Add support for v1 of ADD_ADDR option
by Peter Krystad
Support parsing and writing the new option format, with hmac generation
and validation.
Support for echoing ADD_ADDR still to come.
v2: check msg len in mptcp_crypto_hmac_sha().
remove obsolete casts
v3: Rebase and split for squashing, patches ready to be applied.
v4: Get the first two patches of the set right
v5: plug hole in mptcp_options_received
Peter Krystad (5):
mptcp: Re-factor mptcp_crypto_hmac_sha()
mptcp: v1 ADD_ADDR changes: options and parsing
mptcp: v1 ADD_ADDR changes: add_addr_hmac_valid
mptcp: v1 ADD_ADDR changes: add subflow_generate_hmac()
mptcp: v1 ADD_ADDR changes: use subflow_generate_hmac()
include/linux/tcp.h | 19 ++++---
include/net/mptcp.h | 2 +
net/mptcp/crypto.c | 17 ++++--
net/mptcp/options.c | 132 +++++++++++++++++++++++++++++++++----------
net/mptcp/protocol.h | 19 +++++--
5 files changed, 140 insertions(+), 49 deletions(-)
--
2.17.2
6 months
rare MPTCP self-test failure
by Paolo Abeni
Hi all,
sharing here some results alreay presented on IRC.
I see a poll() timeout on the client side while running MP_JOIN self-
tests in loop. That happens quite rarely (once every ~500 self-tests
runs), like this:
---
copyfd_io_poll: poll timed out (events: POLLIN 1, POLLOUT 0)
client exit code 2, server 0
\nnetns ns1-0-pjF9LD socket stat for 10000:
State Recv-Q Send-Q Local
Address:Port Peer
Address:Port
CLOSE-WAIT 1 0 10.0.1.1:10000 10.0.3.2:41501
ts sack cubic wscale:7,7 rto:215 rtt:15/7.5 ato:40 mss:1448 rcvmss:536 advmss:1448 cwnd:10 bytes_received:1 segs_out:1 segs_in:3 send 7.7Mbps lastsnd:30699 lastrcv:30702 lastack:30078 pacing_rate 15.4Mbps rcv_space:14600 minrtt:15
\nnetns ns2-0-pjF9LD socket stat for 10000:
State Recv-Q Send-Q Local Address:Port Peer Address:Port
FIN-WAIT-2 0 0 10.0.3.2:41501 10.0.1.1:10000 timer:(timewait,59sec,0)
TIME-WAIT 0 0 10.0.1.2:35014 10.0.1.1:10000 timer:(timewait,29sec,0)
single subflow syn[ ok ] - synack[ ok ] - ack[ ok ]
---
e.g. the MP_JOIN handshake is successful, but we miss a state change on
the msk client socket.
The pcap captures shows that the server _is not_ sending the TCP fin
for the MP_JOIN subflow. Due to the current mptcp_check_for_eof() hack,
that causes the missing state transition (see the attached pcap
capture).
Full DATA FIN support will addresses the above for good, but I was
wondering why the server don't send that FIN pkt?!?
[much later the above self-question, after digging more]
It looks like we need an additional __mptcp_flush_join_list() in
mptcp_shutdown(). I'll test a patch ASAP.
Cheers,
Paolo
6 months
[PATCH net-next] mptcp: move msk state update to subflow_syn_recv_sock()
by Paolo Abeni
After commit 58b09919626b ("mptcp: create msk early"), the
msk socket is already available at subflow_syn_recv_sock()
time. Let's move there the state update, to mirror more
closely the first subflow state.
The above will also help multiple subflow supports.
Signed-off-by: Paolo Abeni <pabeni(a)redhat.com>
---
The idea is send this one to net-next asap, [well] before
part 3
---
net/mptcp/protocol.c | 9 +++------
net/mptcp/subflow.c | 2 ++
2 files changed, 5 insertions(+), 6 deletions(-)
diff --git a/net/mptcp/protocol.c b/net/mptcp/protocol.c
index 04c3caed92df..e959104832ef 100644
--- a/net/mptcp/protocol.c
+++ b/net/mptcp/protocol.c
@@ -861,6 +861,9 @@ struct sock *mptcp_sk_clone(const struct sock *sk, struct request_sock *req)
ack_seq++;
msk->ack_seq = ack_seq;
}
+
+ /* will be fully established after successful MPC subflow creation */
+ inet_sk_state_store(nsk, TCP_SYN_RECV);
bh_unlock_sock(nsk);
/* keep a single reference */
@@ -916,10 +919,6 @@ static struct sock *mptcp_accept(struct sock *sk, int flags, int *err,
mptcp_copy_inaddrs(newsk, ssk);
list_add(&subflow->node, &msk->conn_list);
- /* will be fully established at mptcp_stream_accept()
- * completion.
- */
- inet_sk_state_store(new_mptcp_sock, TCP_SYN_RECV);
bh_unlock_sock(new_mptcp_sock);
local_bh_enable();
}
@@ -1256,8 +1255,6 @@ static int mptcp_stream_accept(struct socket *sock, struct socket *newsock,
if (!ssk->sk_socket)
mptcp_sock_graft(ssk, newsock);
}
-
- inet_sk_state_store(newsock->sk, TCP_ESTABLISHED);
}
sock_put(ssock->sk);
diff --git a/net/mptcp/subflow.c b/net/mptcp/subflow.c
index 8434c7f5f712..052d72a1d3a2 100644
--- a/net/mptcp/subflow.c
+++ b/net/mptcp/subflow.c
@@ -234,6 +234,8 @@ static struct sock *subflow_syn_recv_sock(const struct sock *sk,
/* new mpc subflow takes ownership of the newly
* created mptcp socket
*/
+ inet_sk_state_store((struct sock *)new_msk,
+ TCP_ESTABLISHED);
ctx->conn = new_msk;
new_msk = NULL;
}
--
2.21.1
6 months, 1 week
