Commit f6909dc1 authored by Paolo Abeni's avatar Paolo Abeni Committed by David S. Miller

mptcp: rename timer related helper to less confusing names

The msk socket uses to different timeout to track close related
events and retransmissions. The existing helpers do not indicate
clearly which timer they actually touch, making the related code
quite confusing.

Change the existing helpers name to avoid such confusion. No
functional change intended.

This patch is linked to the next one ("mptcp: fix dangling connection
hang-up"). The two patches are supposed to be backported together.

Cc: stable@vger.kernel.org # v5.11+
Signed-off-by: default avatarPaolo Abeni <pabeni@redhat.com>
Reviewed-by: default avatarMatthieu Baerts <matthieu.baerts@tessares.net>
Reviewed-by: default avatarMat Martineau <martineau@kernel.org>
Signed-off-by: default avatarMatthieu Baerts <matthieu.baerts@tessares.net>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 9f1a9881
...@@ -405,7 +405,7 @@ static bool __mptcp_move_skb(struct mptcp_sock *msk, struct sock *ssk, ...@@ -405,7 +405,7 @@ static bool __mptcp_move_skb(struct mptcp_sock *msk, struct sock *ssk,
return false; return false;
} }
static void mptcp_stop_timer(struct sock *sk) static void mptcp_stop_rtx_timer(struct sock *sk)
{ {
struct inet_connection_sock *icsk = inet_csk(sk); struct inet_connection_sock *icsk = inet_csk(sk);
...@@ -911,12 +911,12 @@ static void __mptcp_flush_join_list(struct sock *sk, struct list_head *join_list ...@@ -911,12 +911,12 @@ static void __mptcp_flush_join_list(struct sock *sk, struct list_head *join_list
} }
} }
static bool mptcp_timer_pending(struct sock *sk) static bool mptcp_rtx_timer_pending(struct sock *sk)
{ {
return timer_pending(&inet_csk(sk)->icsk_retransmit_timer); return timer_pending(&inet_csk(sk)->icsk_retransmit_timer);
} }
static void mptcp_reset_timer(struct sock *sk) static void mptcp_reset_rtx_timer(struct sock *sk)
{ {
struct inet_connection_sock *icsk = inet_csk(sk); struct inet_connection_sock *icsk = inet_csk(sk);
unsigned long tout; unsigned long tout;
...@@ -1050,10 +1050,10 @@ static void __mptcp_clean_una(struct sock *sk) ...@@ -1050,10 +1050,10 @@ static void __mptcp_clean_una(struct sock *sk)
out: out:
if (snd_una == READ_ONCE(msk->snd_nxt) && if (snd_una == READ_ONCE(msk->snd_nxt) &&
snd_una == READ_ONCE(msk->write_seq)) { snd_una == READ_ONCE(msk->write_seq)) {
if (mptcp_timer_pending(sk) && !mptcp_data_fin_enabled(msk)) if (mptcp_rtx_timer_pending(sk) && !mptcp_data_fin_enabled(msk))
mptcp_stop_timer(sk); mptcp_stop_rtx_timer(sk);
} else { } else {
mptcp_reset_timer(sk); mptcp_reset_rtx_timer(sk);
} }
} }
...@@ -1626,8 +1626,8 @@ void __mptcp_push_pending(struct sock *sk, unsigned int flags) ...@@ -1626,8 +1626,8 @@ void __mptcp_push_pending(struct sock *sk, unsigned int flags)
mptcp_push_release(ssk, &info); mptcp_push_release(ssk, &info);
/* ensure the rtx timer is running */ /* ensure the rtx timer is running */
if (!mptcp_timer_pending(sk)) if (!mptcp_rtx_timer_pending(sk))
mptcp_reset_timer(sk); mptcp_reset_rtx_timer(sk);
if (do_check_data_fin) if (do_check_data_fin)
mptcp_check_send_data_fin(sk); mptcp_check_send_data_fin(sk);
} }
...@@ -1690,8 +1690,8 @@ static void __mptcp_subflow_push_pending(struct sock *sk, struct sock *ssk, bool ...@@ -1690,8 +1690,8 @@ static void __mptcp_subflow_push_pending(struct sock *sk, struct sock *ssk, bool
if (copied) { if (copied) {
tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle, tcp_push(ssk, 0, info.mss_now, tcp_sk(ssk)->nonagle,
info.size_goal); info.size_goal);
if (!mptcp_timer_pending(sk)) if (!mptcp_rtx_timer_pending(sk))
mptcp_reset_timer(sk); mptcp_reset_rtx_timer(sk);
if (msk->snd_data_fin_enable && if (msk->snd_data_fin_enable &&
msk->snd_nxt + 1 == msk->write_seq) msk->snd_nxt + 1 == msk->write_seq)
...@@ -2260,7 +2260,7 @@ static void mptcp_retransmit_timer(struct timer_list *t) ...@@ -2260,7 +2260,7 @@ static void mptcp_retransmit_timer(struct timer_list *t)
sock_put(sk); sock_put(sk);
} }
static void mptcp_timeout_timer(struct timer_list *t) static void mptcp_tout_timer(struct timer_list *t)
{ {
struct sock *sk = from_timer(sk, t, sk_timer); struct sock *sk = from_timer(sk, t, sk_timer);
...@@ -2629,14 +2629,14 @@ static void __mptcp_retrans(struct sock *sk) ...@@ -2629,14 +2629,14 @@ static void __mptcp_retrans(struct sock *sk)
reset_timer: reset_timer:
mptcp_check_and_set_pending(sk); mptcp_check_and_set_pending(sk);
if (!mptcp_timer_pending(sk)) if (!mptcp_rtx_timer_pending(sk))
mptcp_reset_timer(sk); mptcp_reset_rtx_timer(sk);
} }
/* schedule the timeout timer for the relevant event: either close timeout /* schedule the timeout timer for the relevant event: either close timeout
* or mp_fail timeout. The close timeout takes precedence on the mp_fail one * or mp_fail timeout. The close timeout takes precedence on the mp_fail one
*/ */
void mptcp_reset_timeout(struct mptcp_sock *msk, unsigned long fail_tout) void mptcp_reset_tout_timer(struct mptcp_sock *msk, unsigned long fail_tout)
{ {
struct sock *sk = (struct sock *)msk; struct sock *sk = (struct sock *)msk;
unsigned long timeout, close_timeout; unsigned long timeout, close_timeout;
...@@ -2669,7 +2669,7 @@ static void mptcp_mp_fail_no_response(struct mptcp_sock *msk) ...@@ -2669,7 +2669,7 @@ static void mptcp_mp_fail_no_response(struct mptcp_sock *msk)
WRITE_ONCE(mptcp_subflow_ctx(ssk)->fail_tout, 0); WRITE_ONCE(mptcp_subflow_ctx(ssk)->fail_tout, 0);
unlock_sock_fast(ssk, slow); unlock_sock_fast(ssk, slow);
mptcp_reset_timeout(msk, 0); mptcp_reset_tout_timer(msk, 0);
} }
static void mptcp_do_fastclose(struct sock *sk) static void mptcp_do_fastclose(struct sock *sk)
...@@ -2758,7 +2758,7 @@ static void __mptcp_init_sock(struct sock *sk) ...@@ -2758,7 +2758,7 @@ static void __mptcp_init_sock(struct sock *sk)
/* re-use the csk retrans timer for MPTCP-level retrans */ /* re-use the csk retrans timer for MPTCP-level retrans */
timer_setup(&msk->sk.icsk_retransmit_timer, mptcp_retransmit_timer, 0); timer_setup(&msk->sk.icsk_retransmit_timer, mptcp_retransmit_timer, 0);
timer_setup(&sk->sk_timer, mptcp_timeout_timer, 0); timer_setup(&sk->sk_timer, mptcp_tout_timer, 0);
} }
static void mptcp_ca_reset(struct sock *sk) static void mptcp_ca_reset(struct sock *sk)
...@@ -2849,8 +2849,8 @@ void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how) ...@@ -2849,8 +2849,8 @@ void mptcp_subflow_shutdown(struct sock *sk, struct sock *ssk, int how)
} else { } else {
pr_debug("Sending DATA_FIN on subflow %p", ssk); pr_debug("Sending DATA_FIN on subflow %p", ssk);
tcp_send_ack(ssk); tcp_send_ack(ssk);
if (!mptcp_timer_pending(sk)) if (!mptcp_rtx_timer_pending(sk))
mptcp_reset_timer(sk); mptcp_reset_rtx_timer(sk);
} }
break; break;
} }
...@@ -2933,7 +2933,7 @@ static void __mptcp_destroy_sock(struct sock *sk) ...@@ -2933,7 +2933,7 @@ static void __mptcp_destroy_sock(struct sock *sk)
might_sleep(); might_sleep();
mptcp_stop_timer(sk); mptcp_stop_rtx_timer(sk);
sk_stop_timer(sk, &sk->sk_timer); sk_stop_timer(sk, &sk->sk_timer);
msk->pm.status = 0; msk->pm.status = 0;
mptcp_release_sched(msk); mptcp_release_sched(msk);
...@@ -3053,7 +3053,7 @@ bool __mptcp_close(struct sock *sk, long timeout) ...@@ -3053,7 +3053,7 @@ bool __mptcp_close(struct sock *sk, long timeout)
__mptcp_destroy_sock(sk); __mptcp_destroy_sock(sk);
do_cancel_work = true; do_cancel_work = true;
} else { } else {
mptcp_reset_timeout(msk, 0); mptcp_reset_tout_timer(msk, 0);
} }
return do_cancel_work; return do_cancel_work;
...@@ -3116,7 +3116,7 @@ static int mptcp_disconnect(struct sock *sk, int flags) ...@@ -3116,7 +3116,7 @@ static int mptcp_disconnect(struct sock *sk, int flags)
mptcp_check_listen_stop(sk); mptcp_check_listen_stop(sk);
inet_sk_state_store(sk, TCP_CLOSE); inet_sk_state_store(sk, TCP_CLOSE);
mptcp_stop_timer(sk); mptcp_stop_rtx_timer(sk);
sk_stop_timer(sk, &sk->sk_timer); sk_stop_timer(sk, &sk->sk_timer);
if (msk->token) if (msk->token)
......
...@@ -718,7 +718,7 @@ void mptcp_get_options(const struct sk_buff *skb, ...@@ -718,7 +718,7 @@ void mptcp_get_options(const struct sk_buff *skb,
void mptcp_finish_connect(struct sock *sk); void mptcp_finish_connect(struct sock *sk);
void __mptcp_set_connected(struct sock *sk); void __mptcp_set_connected(struct sock *sk);
void mptcp_reset_timeout(struct mptcp_sock *msk, unsigned long fail_tout); void mptcp_reset_tout_timer(struct mptcp_sock *msk, unsigned long fail_tout);
static inline bool mptcp_is_fully_established(struct sock *sk) static inline bool mptcp_is_fully_established(struct sock *sk)
{ {
return inet_sk_state_load(sk) == TCP_ESTABLISHED && return inet_sk_state_load(sk) == TCP_ESTABLISHED &&
......
...@@ -1226,7 +1226,7 @@ static void mptcp_subflow_fail(struct mptcp_sock *msk, struct sock *ssk) ...@@ -1226,7 +1226,7 @@ static void mptcp_subflow_fail(struct mptcp_sock *msk, struct sock *ssk)
WRITE_ONCE(subflow->fail_tout, fail_tout); WRITE_ONCE(subflow->fail_tout, fail_tout);
tcp_send_ack(ssk); tcp_send_ack(ssk);
mptcp_reset_timeout(msk, subflow->fail_tout); mptcp_reset_tout_timer(msk, subflow->fail_tout);
} }
static bool subflow_check_data_avail(struct sock *ssk) static bool subflow_check_data_avail(struct sock *ssk)
......
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