net: dccp: Convert timers to use timer_setup()
authorKees Cook <keescook@chromium.org>
Tue, 24 Oct 2017 08:46:09 +0000 (01:46 -0700)
committerDavid S. Miller <davem@davemloft.net>
Wed, 25 Oct 2017 03:59:19 +0000 (12:59 +0900)
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: Kees Cook <keescook@chromium.org>
Signed-off-by: David S. Miller <davem@davemloft.net>
net/dccp/ccids/ccid2.c
net/dccp/ccids/ccid2.h
net/dccp/ccids/ccid3.c
net/dccp/ccids/ccid3.h
net/dccp/timer.c

index e1295d5f2c562e8785f59a0f5bd7064f471e85ab..1c75cd1255f69ebf0b57afb742930b7244af11a0 100644 (file)
@@ -126,10 +126,10 @@ static void ccid2_change_l_seq_window(struct sock *sk, u64 val)
                                                  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 = ccid2_hc_tx_sk(sk);
+       struct ccid2_hc_tx_sock *hc = from_timer(hc, t, tx_rtotimer);
+       struct sock *sk = hc->sk;
        const bool sender_was_blocked = ccid2_cwnd_network_limited(hc);
 
        bh_lock_sock(sk);
@@ -733,8 +733,8 @@ static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk)
        hc->tx_rpdupack  = -1;
        hc->tx_last_cong = hc->tx_lsndtime = hc->tx_cwnd_stamp = ccid2_jiffies32;
        hc->tx_cwnd_used = 0;
-       setup_timer(&hc->tx_rtotimer, ccid2_hc_tx_rto_expire,
-                       (unsigned long)sk);
+       hc->sk           = sk;
+       timer_setup(&hc->tx_rtotimer, ccid2_hc_tx_rto_expire, 0);
        INIT_LIST_HEAD(&hc->tx_av_chunks);
        return 0;
 }
index 6e50ef2898fb9dd9080217cc167defea6a2e9021..1af0116dc6cea8b1ca95b7b66fe8aabb71012117 100644 (file)
@@ -85,6 +85,7 @@ struct ccid2_hc_tx_sock {
                                tx_rto;
        u64                     tx_rtt_seq:48;
        struct timer_list       tx_rtotimer;
+       struct sock             *sk;
 
        /* Congestion Window validation (optional, RFC 2861) */
        u32                     tx_cwnd_used,
index 119c04317d48eed4abcb2bbf6071062c8d9784fd..8b5ba6dffac7ebc88fd21075793dc3db43a74a43 100644 (file)
@@ -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 = ccid3_hc_tx_sk(sk);
+       struct ccid3_hc_tx_sock *hc = from_timer(hc, t, tx_no_feedback_timer);
+       struct sock *sk = hc->sk;
        unsigned long t_nfb = USEC_PER_SEC / 5;
 
        bh_lock_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_hist  = NULL;
-       setup_timer(&hc->tx_no_feedback_timer,
-                       ccid3_hc_tx_no_feedback_timer, (unsigned long)sk);
+       hc->sk       = sk;
+       timer_setup(&hc->tx_no_feedback_timer,
+                   ccid3_hc_tx_no_feedback_timer, 0);
        return 0;
 }
 
index 1a9933c29672bfa3d1e8396a33437a5712970b5d..813d91c6e1e275e6d0f6824edc3cf06a8611d8f5 100644 (file)
@@ -106,6 +106,7 @@ struct ccid3_hc_tx_sock {
        u8                              tx_last_win_count;
        ktime_t                         tx_t_last_win_count;
        struct timer_list               tx_no_feedback_timer;
+       struct sock                     *sk;
        ktime_t                         tx_t_ld;
        ktime_t                         tx_t_nom;
        struct tfrc_tx_hist_entry       *tx_hist;
index 1e35526bf4368e4d2f69e0059e6bdf44154ac79e..b50a8732ff434db3d015202ddd8c06d7edfc88cf 100644 (file)
@@ -234,10 +234,13 @@ static void dccp_write_xmitlet(unsigned long data)
        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);
-       sock_put((struct sock *)data);
+       struct dccp_sock *dp = from_timer(dp, t, dccps_xmit_timer);
+       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)
@@ -245,8 +248,7 @@ void dccp_init_xmit_timers(struct sock *sk)
        struct dccp_sock *dp = dccp_sk(sk);
 
        tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk);
-       setup_timer(&dp->dccps_xmit_timer, dccp_write_xmit_timer,
-                                                            (unsigned long)sk);
+       timer_setup(&dp->dccps_xmit_timer, dccp_write_xmit_timer, 0);
        inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer,
                                  &dccp_keepalive_timer);
 }