diff options
Diffstat (limited to 'net/ipv4/tcp_input.c')
-rw-r--r-- | net/ipv4/tcp_input.c | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/net/ipv4/tcp_input.c b/net/ipv4/tcp_input.c index 577424323d59..b27be2f819ac 100644 --- a/net/ipv4/tcp_input.c +++ b/net/ipv4/tcp_input.c | |||
@@ -3346,12 +3346,9 @@ static inline void tcp_check_space(struct sock *sk) | |||
3346 | } | 3346 | } |
3347 | } | 3347 | } |
3348 | 3348 | ||
3349 | static __inline__ void tcp_data_snd_check(struct sock *sk) | 3349 | static __inline__ void tcp_data_snd_check(struct sock *sk, struct tcp_sock *tp) |
3350 | { | 3350 | { |
3351 | struct sk_buff *skb = sk->sk_send_head; | 3351 | tcp_push_pending_frames(sk, tp); |
3352 | |||
3353 | if (skb != NULL) | ||
3354 | __tcp_data_snd_check(sk, skb); | ||
3355 | tcp_check_space(sk); | 3352 | tcp_check_space(sk); |
3356 | } | 3353 | } |
3357 | 3354 | ||
@@ -3645,7 +3642,7 @@ int tcp_rcv_established(struct sock *sk, struct sk_buff *skb, | |||
3645 | */ | 3642 | */ |
3646 | tcp_ack(sk, skb, 0); | 3643 | tcp_ack(sk, skb, 0); |
3647 | __kfree_skb(skb); | 3644 | __kfree_skb(skb); |
3648 | tcp_data_snd_check(sk); | 3645 | tcp_data_snd_check(sk, tp); |
3649 | return 0; | 3646 | return 0; |
3650 | } else { /* Header too small */ | 3647 | } else { /* Header too small */ |
3651 | TCP_INC_STATS_BH(TCP_MIB_INERRS); | 3648 | TCP_INC_STATS_BH(TCP_MIB_INERRS); |
@@ -3711,7 +3708,7 @@ int tcp_rcv_established(struct sock *sk, struct sk_buff *skb, | |||
3711 | if (TCP_SKB_CB(skb)->ack_seq != tp->snd_una) { | 3708 | if (TCP_SKB_CB(skb)->ack_seq != tp->snd_una) { |
3712 | /* Well, only one small jumplet in fast path... */ | 3709 | /* Well, only one small jumplet in fast path... */ |
3713 | tcp_ack(sk, skb, FLAG_DATA); | 3710 | tcp_ack(sk, skb, FLAG_DATA); |
3714 | tcp_data_snd_check(sk); | 3711 | tcp_data_snd_check(sk, tp); |
3715 | if (!tcp_ack_scheduled(tp)) | 3712 | if (!tcp_ack_scheduled(tp)) |
3716 | goto no_ack; | 3713 | goto no_ack; |
3717 | } | 3714 | } |
@@ -3789,7 +3786,7 @@ step5: | |||
3789 | /* step 7: process the segment text */ | 3786 | /* step 7: process the segment text */ |
3790 | tcp_data_queue(sk, skb); | 3787 | tcp_data_queue(sk, skb); |
3791 | 3788 | ||
3792 | tcp_data_snd_check(sk); | 3789 | tcp_data_snd_check(sk, tp); |
3793 | tcp_ack_snd_check(sk); | 3790 | tcp_ack_snd_check(sk); |
3794 | return 0; | 3791 | return 0; |
3795 | 3792 | ||
@@ -4099,7 +4096,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb, | |||
4099 | /* Do step6 onward by hand. */ | 4096 | /* Do step6 onward by hand. */ |
4100 | tcp_urg(sk, skb, th); | 4097 | tcp_urg(sk, skb, th); |
4101 | __kfree_skb(skb); | 4098 | __kfree_skb(skb); |
4102 | tcp_data_snd_check(sk); | 4099 | tcp_data_snd_check(sk, tp); |
4103 | return 0; | 4100 | return 0; |
4104 | } | 4101 | } |
4105 | 4102 | ||
@@ -4290,7 +4287,7 @@ int tcp_rcv_state_process(struct sock *sk, struct sk_buff *skb, | |||
4290 | 4287 | ||
4291 | /* tcp_data could move socket to TIME-WAIT */ | 4288 | /* tcp_data could move socket to TIME-WAIT */ |
4292 | if (sk->sk_state != TCP_CLOSE) { | 4289 | if (sk->sk_state != TCP_CLOSE) { |
4293 | tcp_data_snd_check(sk); | 4290 | tcp_data_snd_check(sk, tp); |
4294 | tcp_ack_snd_check(sk); | 4291 | tcp_ack_snd_check(sk); |
4295 | } | 4292 | } |
4296 | 4293 | ||