@@ -406,6 +406,18 @@ static int mptcp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)
return ret;
}
+ timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
+
+ mptcp_clean_una(sk);
+
+ while (!sk_stream_is_writeable(sk)) {
+ ret = sk_stream_wait_memory(sk, &timeo);
+ if (ret)
+ goto out;
+
+ mptcp_clean_una(sk);
+ }
+
ssk = mptcp_subflow_get(msk);
if (!ssk) {
release_sock(sk);
@@ -421,8 +433,6 @@ static int mptcp_sendmsg(struct sock *sk, struct msghdr *msg, size_t len)
pr_debug("conn_list->subflow=%p", ssk);
lock_sock(ssk);
- mptcp_clean_una(sk);
- timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
while (msg_data_left(msg)) {
ret = mptcp_sendmsg_frag(sk, ssk, msg, NULL, &timeo, &mss_now,
&size_goal);
@@ -1315,6 +1325,10 @@ static __poll_t mptcp_poll(struct file *file, struct socket *sock,
tcp_sock = mptcp_subflow_tcp_socket(subflow);
ret |= __tcp_poll(tcp_sock->sk);
}
+
+ if (!sk_stream_is_writeable(sk))
+ ret &= ~(EPOLLOUT|EPOLLWRNORM);
+
release_sock(sk);
return ret;
This disables transmit of new data until the peer has acked enough mptcp data to get below the wspace write threshold (more than half of wspace upperlimit is available again). Also have poll not report EPOLLOUT in this case, its not relevant if a subflow is writeable. The latter is a temporary workaround that is needed because mptcp_poll walks the subflows and calls __tcp_poll on each of them. Because subflow ssk is usually writable, we will have to undo-that if the mptcp sndbuf is exhausted. This won't be needed anymore once __tcp_poll is removed, I am working on this. Signed-off-by: Florian Westphal <fw@strlen.de> --- net/mptcp/protocol.c | 18 ++++++++++++++++-- 1 file changed, 16 insertions(+), 2 deletions(-)