aboutsummaryrefslogtreecommitdiffstats
path: root/net/dccp/timer.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/dccp/timer.c')
-rw-r--r--net/dccp/timer.c42
1 files changed, 16 insertions, 26 deletions
diff --git a/net/dccp/timer.c b/net/dccp/timer.c
index 54b3c7e9e016..16359e29e7f5 100644
--- a/net/dccp/timer.c
+++ b/net/dccp/timer.c
@@ -87,17 +87,6 @@ static void dccp_retransmit_timer(struct sock *sk)
87{ 87{
88 struct inet_connection_sock *icsk = inet_csk(sk); 88 struct inet_connection_sock *icsk = inet_csk(sk);
89 89
90 /* retransmit timer is used for feature negotiation throughout
91 * connection. In this case, no packet is re-transmitted, but rather an
92 * ack is generated and pending changes are placed into its options.
93 */
94 if (sk->sk_send_head == NULL) {
95 dccp_pr_debug("feat negotiation retransmit timeout %p\n", sk);
96 if (sk->sk_state == DCCP_OPEN)
97 dccp_send_ack(sk);
98 goto backoff;
99 }
100
101 /* 90 /*
102 * More than than 4MSL (8 minutes) has passed, a RESET(aborted) was 91 * More than than 4MSL (8 minutes) has passed, a RESET(aborted) was
103 * sent, no need to retransmit, this sock is dead. 92 * sent, no need to retransmit, this sock is dead.
@@ -126,7 +115,6 @@ static void dccp_retransmit_timer(struct sock *sk)
126 return; 115 return;
127 } 116 }
128 117
129backoff:
130 icsk->icsk_backoff++; 118 icsk->icsk_backoff++;
131 119
132 icsk->icsk_rto = min(icsk->icsk_rto << 1, DCCP_RTO_MAX); 120 icsk->icsk_rto = min(icsk->icsk_rto << 1, DCCP_RTO_MAX);
@@ -249,32 +237,35 @@ out:
249 sock_put(sk); 237 sock_put(sk);
250} 238}
251 239
252/* Transmit-delay timer: used by the CCIDs to delay actual send time */ 240/**
253static void dccp_write_xmit_timer(unsigned long data) 241 * dccp_write_xmitlet - Workhorse for CCID packet dequeueing interface
242 * See the comments above %ccid_dequeueing_decision for supported modes.
243 */
244static void dccp_write_xmitlet(unsigned long data)
254{ 245{
255 struct sock *sk = (struct sock *)data; 246 struct sock *sk = (struct sock *)data;
256 struct dccp_sock *dp = dccp_sk(sk);
257 247
258 bh_lock_sock(sk); 248 bh_lock_sock(sk);
259 if (sock_owned_by_user(sk)) 249 if (sock_owned_by_user(sk))
260 sk_reset_timer(sk, &dp->dccps_xmit_timer, jiffies+1); 250 sk_reset_timer(sk, &dccp_sk(sk)->dccps_xmit_timer, jiffies + 1);
261 else 251 else
262 dccp_write_xmit(sk, 0); 252 dccp_write_xmit(sk);
263 bh_unlock_sock(sk); 253 bh_unlock_sock(sk);
264 sock_put(sk);
265} 254}
266 255
267static void dccp_init_write_xmit_timer(struct sock *sk) 256static void dccp_write_xmit_timer(unsigned long data)
268{ 257{
269 struct dccp_sock *dp = dccp_sk(sk); 258 dccp_write_xmitlet(data);
270 259 sock_put((struct sock *)data);
271 setup_timer(&dp->dccps_xmit_timer, dccp_write_xmit_timer,
272 (unsigned long)sk);
273} 260}
274 261
275void dccp_init_xmit_timers(struct sock *sk) 262void dccp_init_xmit_timers(struct sock *sk)
276{ 263{
277 dccp_init_write_xmit_timer(sk); 264 struct dccp_sock *dp = dccp_sk(sk);
265
266 tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk);
267 setup_timer(&dp->dccps_xmit_timer, dccp_write_xmit_timer,
268 (unsigned long)sk);
278 inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer, 269 inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer,
279 &dccp_keepalive_timer); 270 &dccp_keepalive_timer);
280} 271}
@@ -290,8 +281,7 @@ u32 dccp_timestamp(void)
290{ 281{
291 s64 delta = ktime_us_delta(ktime_get_real(), dccp_timestamp_seed); 282 s64 delta = ktime_us_delta(ktime_get_real(), dccp_timestamp_seed);
292 283
293 do_div(delta, 10); 284 return div_u64(delta, DCCP_TIME_RESOLUTION);
294 return delta;
295} 285}
296EXPORT_SYMBOL_GPL(dccp_timestamp); 286EXPORT_SYMBOL_GPL(dccp_timestamp);
297 287