Commit 382c6001 authored by Jason Xing's avatar Jason Xing Committed by David S. Miller

mptcp: add reset reason options in some places

The reason codes are handled in two ways nowadays (quoting Mat Martineau):
1. Sending in the MPTCP option on RST packets when there is no subflow
context available (these use subflow_add_reset_reason() and directly call
a TCP-level send_reset function)
2. The "normal" way via subflow->reset_reason. This will propagate to both
the outgoing reset packet and to a local path manager process via netlink
in mptcp_event_sub_closed()

RFC 8684 defines the skb reset reason behaviour which is not required
even though in some places:

    A host sends a TCP RST in order to close a subflow or reject
    an attempt to open a subflow (MP_JOIN). In order to let the
    receiving host know why a subflow is being closed or rejected,
    the TCP RST packet MAY include the MP_TCPRST option (Figure 15).
    The host MAY use this information to decide, for example, whether
    it tries to re-establish the subflow immediately, later, or never.

Since the commit dc87efdb ("mptcp: add mptcp reset option support")
introduced this feature about three years ago, we can fully use it.
There remains some places where we could insert reason into skb as
we can see in this patch.

Many thanks to Mat and Paolo for help:)
Signed-off-by: default avatarJason Xing <kernelxing@tencent.com>
Acked-by: default avatarPaolo Abeni <pabeni@redhat.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent ec20b283
...@@ -150,8 +150,10 @@ static int subflow_check_req(struct request_sock *req, ...@@ -150,8 +150,10 @@ static int subflow_check_req(struct request_sock *req,
/* no MPTCP if MD5SIG is enabled on this socket or we may run out of /* no MPTCP if MD5SIG is enabled on this socket or we may run out of
* TCP option space. * TCP option space.
*/ */
if (rcu_access_pointer(tcp_sk(sk_listener)->md5sig_info)) if (rcu_access_pointer(tcp_sk(sk_listener)->md5sig_info)) {
subflow_add_reset_reason(skb, MPTCP_RST_EMPTCP);
return -EINVAL; return -EINVAL;
}
#endif #endif
mptcp_get_options(skb, &mp_opt); mptcp_get_options(skb, &mp_opt);
...@@ -219,6 +221,7 @@ static int subflow_check_req(struct request_sock *req, ...@@ -219,6 +221,7 @@ static int subflow_check_req(struct request_sock *req,
ntohs(inet_sk((struct sock *)subflow_req->msk)->inet_sport)); ntohs(inet_sk((struct sock *)subflow_req->msk)->inet_sport));
if (!mptcp_pm_sport_in_anno_list(subflow_req->msk, sk_listener)) { if (!mptcp_pm_sport_in_anno_list(subflow_req->msk, sk_listener)) {
SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_MISMATCHPORTSYNRX); SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_MISMATCHPORTSYNRX);
subflow_add_reset_reason(skb, MPTCP_RST_EPROHIBIT);
return -EPERM; return -EPERM;
} }
SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINPORTSYNRX); SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINPORTSYNRX);
...@@ -227,10 +230,12 @@ static int subflow_check_req(struct request_sock *req, ...@@ -227,10 +230,12 @@ static int subflow_check_req(struct request_sock *req,
subflow_req_create_thmac(subflow_req); subflow_req_create_thmac(subflow_req);
if (unlikely(req->syncookie)) { if (unlikely(req->syncookie)) {
if (mptcp_can_accept_new_subflow(subflow_req->msk)) if (!mptcp_can_accept_new_subflow(subflow_req->msk)) {
subflow_init_req_cookie_join_save(subflow_req, skb); subflow_add_reset_reason(skb, MPTCP_RST_EPROHIBIT);
else
return -EPERM; return -EPERM;
}
subflow_init_req_cookie_join_save(subflow_req, skb);
} }
pr_debug("token=%u, remote_nonce=%u msk=%p", subflow_req->token, pr_debug("token=%u, remote_nonce=%u msk=%p", subflow_req->token,
...@@ -873,13 +878,18 @@ static struct sock *subflow_syn_recv_sock(const struct sock *sk, ...@@ -873,13 +878,18 @@ static struct sock *subflow_syn_recv_sock(const struct sock *sk,
ntohs(inet_sk((struct sock *)owner)->inet_sport)); ntohs(inet_sk((struct sock *)owner)->inet_sport));
if (!mptcp_pm_sport_in_anno_list(owner, sk)) { if (!mptcp_pm_sport_in_anno_list(owner, sk)) {
SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_MISMATCHPORTACKRX); SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_MISMATCHPORTACKRX);
subflow_add_reset_reason(skb, MPTCP_RST_EPROHIBIT);
goto dispose_child; goto dispose_child;
} }
SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINPORTACKRX); SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINPORTACKRX);
} }
if (!mptcp_finish_join(child)) if (!mptcp_finish_join(child)) {
struct mptcp_subflow_context *subflow = mptcp_subflow_ctx(child);
subflow_add_reset_reason(skb, subflow->reset_reason);
goto dispose_child; goto dispose_child;
}
SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINACKRX); SUBFLOW_REQ_INC_STATS(req, MPTCP_MIB_JOINACKRX);
tcp_rsk(req)->drop_req = true; tcp_rsk(req)->drop_req = true;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment