Commit 839a6094 authored by Kees Cook's avatar Kees Cook Committed by David S. Miller

net: dccp: Convert timers to use timer_setup()

In preparation for unconditionally passing the struct timer_list pointer to
all timer callbacks, switch to using the new timer_setup() and from_timer()
to pass the timer pointer explicitly. Adds a pointer back to the sock.

Cc: Gerrit Renker <gerrit@erg.abdn.ac.uk>
Cc: "David S. Miller" <davem@davemloft.net>
Cc: Soheil Hassas Yeganeh <soheil@google.com>
Cc: Hannes Frederic Sowa <hannes@stressinduktion.org>
Cc: Eric Dumazet <edumazet@google.com>
Cc: dccp@vger.kernel.org
Cc: netdev@vger.kernel.org
Signed-off-by: default avatarKees Cook <keescook@chromium.org>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 7aa1402e
...@@ -126,10 +126,10 @@ static void ccid2_change_l_seq_window(struct sock *sk, u64 val) ...@@ -126,10 +126,10 @@ static void ccid2_change_l_seq_window(struct sock *sk, u64 val)
DCCPF_SEQ_WMAX)); DCCPF_SEQ_WMAX));
} }
static void ccid2_hc_tx_rto_expire(unsigned long data) static void ccid2_hc_tx_rto_expire(struct timer_list *t)
{ {
struct sock *sk = (struct sock *)data; struct ccid2_hc_tx_sock *hc = from_timer(hc, t, tx_rtotimer);
struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); struct sock *sk = hc->sk;
const bool sender_was_blocked = ccid2_cwnd_network_limited(hc); const bool sender_was_blocked = ccid2_cwnd_network_limited(hc);
bh_lock_sock(sk); bh_lock_sock(sk);
...@@ -733,8 +733,8 @@ static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk) ...@@ -733,8 +733,8 @@ static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk)
hc->tx_rpdupack = -1; hc->tx_rpdupack = -1;
hc->tx_last_cong = hc->tx_lsndtime = hc->tx_cwnd_stamp = ccid2_jiffies32; hc->tx_last_cong = hc->tx_lsndtime = hc->tx_cwnd_stamp = ccid2_jiffies32;
hc->tx_cwnd_used = 0; hc->tx_cwnd_used = 0;
setup_timer(&hc->tx_rtotimer, ccid2_hc_tx_rto_expire, hc->sk = sk;
(unsigned long)sk); timer_setup(&hc->tx_rtotimer, ccid2_hc_tx_rto_expire, 0);
INIT_LIST_HEAD(&hc->tx_av_chunks); INIT_LIST_HEAD(&hc->tx_av_chunks);
return 0; return 0;
} }
......
...@@ -85,6 +85,7 @@ struct ccid2_hc_tx_sock { ...@@ -85,6 +85,7 @@ struct ccid2_hc_tx_sock {
tx_rto; tx_rto;
u64 tx_rtt_seq:48; u64 tx_rtt_seq:48;
struct timer_list tx_rtotimer; struct timer_list tx_rtotimer;
struct sock *sk;
/* Congestion Window validation (optional, RFC 2861) */ /* Congestion Window validation (optional, RFC 2861) */
u32 tx_cwnd_used, u32 tx_cwnd_used,
......
...@@ -195,10 +195,10 @@ static inline void ccid3_hc_tx_update_win_count(struct ccid3_hc_tx_sock *hc, ...@@ -195,10 +195,10 @@ static inline void ccid3_hc_tx_update_win_count(struct ccid3_hc_tx_sock *hc,
} }
} }
static void ccid3_hc_tx_no_feedback_timer(unsigned long data) static void ccid3_hc_tx_no_feedback_timer(struct timer_list *t)
{ {
struct sock *sk = (struct sock *)data; struct ccid3_hc_tx_sock *hc = from_timer(hc, t, tx_no_feedback_timer);
struct ccid3_hc_tx_sock *hc = ccid3_hc_tx_sk(sk); struct sock *sk = hc->sk;
unsigned long t_nfb = USEC_PER_SEC / 5; unsigned long t_nfb = USEC_PER_SEC / 5;
bh_lock_sock(sk); bh_lock_sock(sk);
...@@ -505,8 +505,9 @@ static int ccid3_hc_tx_init(struct ccid *ccid, struct sock *sk) ...@@ -505,8 +505,9 @@ static int ccid3_hc_tx_init(struct ccid *ccid, struct sock *sk)
hc->tx_state = TFRC_SSTATE_NO_SENT; hc->tx_state = TFRC_SSTATE_NO_SENT;
hc->tx_hist = NULL; hc->tx_hist = NULL;
setup_timer(&hc->tx_no_feedback_timer, hc->sk = sk;
ccid3_hc_tx_no_feedback_timer, (unsigned long)sk); timer_setup(&hc->tx_no_feedback_timer,
ccid3_hc_tx_no_feedback_timer, 0);
return 0; return 0;
} }
......
...@@ -106,6 +106,7 @@ struct ccid3_hc_tx_sock { ...@@ -106,6 +106,7 @@ struct ccid3_hc_tx_sock {
u8 tx_last_win_count; u8 tx_last_win_count;
ktime_t tx_t_last_win_count; ktime_t tx_t_last_win_count;
struct timer_list tx_no_feedback_timer; struct timer_list tx_no_feedback_timer;
struct sock *sk;
ktime_t tx_t_ld; ktime_t tx_t_ld;
ktime_t tx_t_nom; ktime_t tx_t_nom;
struct tfrc_tx_hist_entry *tx_hist; struct tfrc_tx_hist_entry *tx_hist;
......
...@@ -234,10 +234,13 @@ static void dccp_write_xmitlet(unsigned long data) ...@@ -234,10 +234,13 @@ static void dccp_write_xmitlet(unsigned long data)
bh_unlock_sock(sk); bh_unlock_sock(sk);
} }
static void dccp_write_xmit_timer(unsigned long data) static void dccp_write_xmit_timer(struct timer_list *t)
{ {
dccp_write_xmitlet(data); struct dccp_sock *dp = from_timer(dp, t, dccps_xmit_timer);
sock_put((struct sock *)data); struct sock *sk = &dp->dccps_inet_connection.icsk_inet.sk;
dccp_write_xmitlet((unsigned long)sk);
sock_put(sk);
} }
void dccp_init_xmit_timers(struct sock *sk) void dccp_init_xmit_timers(struct sock *sk)
...@@ -245,8 +248,7 @@ void dccp_init_xmit_timers(struct sock *sk) ...@@ -245,8 +248,7 @@ void dccp_init_xmit_timers(struct sock *sk)
struct dccp_sock *dp = dccp_sk(sk); struct dccp_sock *dp = dccp_sk(sk);
tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk); tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk);
setup_timer(&dp->dccps_xmit_timer, dccp_write_xmit_timer, timer_setup(&dp->dccps_xmit_timer, dccp_write_xmit_timer, 0);
(unsigned long)sk);
inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer, inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer,
&dccp_keepalive_timer); &dccp_keepalive_timer);
} }
......
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