aboutsummaryrefslogtreecommitdiffstats
path: root/net/ipv4/tcp_input.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/ipv4/tcp_input.c')
-rw-r--r--net/ipv4/tcp_input.c17
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
3349static __inline__ void tcp_data_snd_check(struct sock *sk) 3349static __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