diff options
Diffstat (limited to 'net/ipv4/tcp_timer.c')
| -rw-r--r-- | net/ipv4/tcp_timer.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/net/ipv4/tcp_timer.c b/net/ipv4/tcp_timer.c index a9243cfc1bea..2ca97b20929d 100644 --- a/net/ipv4/tcp_timer.c +++ b/net/ipv4/tcp_timer.c | |||
| @@ -233,7 +233,7 @@ static void tcp_probe_timer(struct sock *sk) | |||
| 233 | struct tcp_sock *tp = tcp_sk(sk); | 233 | struct tcp_sock *tp = tcp_sk(sk); |
| 234 | int max_probes; | 234 | int max_probes; |
| 235 | 235 | ||
| 236 | if (tp->packets_out || !sk->sk_send_head) { | 236 | if (tp->packets_out || !tcp_send_head(sk)) { |
| 237 | icsk->icsk_probes_out = 0; | 237 | icsk->icsk_probes_out = 0; |
| 238 | return; | 238 | return; |
| 239 | } | 239 | } |
| @@ -284,7 +284,7 @@ static void tcp_retransmit_timer(struct sock *sk) | |||
| 284 | if (!tp->packets_out) | 284 | if (!tp->packets_out) |
| 285 | goto out; | 285 | goto out; |
| 286 | 286 | ||
| 287 | BUG_TRAP(!skb_queue_empty(&sk->sk_write_queue)); | 287 | BUG_TRAP(!tcp_write_queue_empty(sk)); |
| 288 | 288 | ||
| 289 | if (!tp->snd_wnd && !sock_flag(sk, SOCK_DEAD) && | 289 | if (!tp->snd_wnd && !sock_flag(sk, SOCK_DEAD) && |
| 290 | !((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV))) { | 290 | !((1 << sk->sk_state) & (TCPF_SYN_SENT | TCPF_SYN_RECV))) { |
| @@ -306,7 +306,7 @@ static void tcp_retransmit_timer(struct sock *sk) | |||
| 306 | goto out; | 306 | goto out; |
| 307 | } | 307 | } |
| 308 | tcp_enter_loss(sk, 0); | 308 | tcp_enter_loss(sk, 0); |
| 309 | tcp_retransmit_skb(sk, skb_peek(&sk->sk_write_queue)); | 309 | tcp_retransmit_skb(sk, tcp_write_queue_head(sk)); |
| 310 | __sk_dst_reset(sk); | 310 | __sk_dst_reset(sk); |
| 311 | goto out_reset_timer; | 311 | goto out_reset_timer; |
| 312 | } | 312 | } |
| @@ -341,7 +341,7 @@ static void tcp_retransmit_timer(struct sock *sk) | |||
| 341 | tcp_enter_loss(sk, 0); | 341 | tcp_enter_loss(sk, 0); |
| 342 | } | 342 | } |
| 343 | 343 | ||
| 344 | if (tcp_retransmit_skb(sk, skb_peek(&sk->sk_write_queue)) > 0) { | 344 | if (tcp_retransmit_skb(sk, tcp_write_queue_head(sk)) > 0) { |
| 345 | /* Retransmission failed because of local congestion, | 345 | /* Retransmission failed because of local congestion, |
| 346 | * do not backoff. | 346 | * do not backoff. |
| 347 | */ | 347 | */ |
| @@ -482,7 +482,7 @@ static void tcp_keepalive_timer (unsigned long data) | |||
| 482 | elapsed = keepalive_time_when(tp); | 482 | elapsed = keepalive_time_when(tp); |
| 483 | 483 | ||
| 484 | /* It is alive without keepalive 8) */ | 484 | /* It is alive without keepalive 8) */ |
| 485 | if (tp->packets_out || sk->sk_send_head) | 485 | if (tp->packets_out || tcp_send_head(sk)) |
| 486 | goto resched; | 486 | goto resched; |
| 487 | 487 | ||
| 488 | elapsed = tcp_time_stamp - tp->rcv_tstamp; | 488 | elapsed = tcp_time_stamp - tp->rcv_tstamp; |
