aboutsummaryrefslogtreecommitdiffstats
path: root/net/ipv4/tcp_output.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/ipv4/tcp_output.c')
-rw-r--r--net/ipv4/tcp_output.c19
1 files changed, 12 insertions, 7 deletions
diff --git a/net/ipv4/tcp_output.c b/net/ipv4/tcp_output.c
index 5b6690d05abb..a85a8c2948e5 100644
--- a/net/ipv4/tcp_output.c
+++ b/net/ipv4/tcp_output.c
@@ -991,6 +991,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
991 struct tcp_skb_cb *tcb; 991 struct tcp_skb_cb *tcb;
992 struct tcp_out_options opts; 992 struct tcp_out_options opts;
993 unsigned int tcp_options_size, tcp_header_size; 993 unsigned int tcp_options_size, tcp_header_size;
994 struct sk_buff *oskb = NULL;
994 struct tcp_md5sig_key *md5; 995 struct tcp_md5sig_key *md5;
995 struct tcphdr *th; 996 struct tcphdr *th;
996 int err; 997 int err;
@@ -998,12 +999,12 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
998 BUG_ON(!skb || !tcp_skb_pcount(skb)); 999 BUG_ON(!skb || !tcp_skb_pcount(skb));
999 tp = tcp_sk(sk); 1000 tp = tcp_sk(sk);
1000 1001
1001 skb->skb_mstamp = tp->tcp_mstamp;
1002 if (clone_it) { 1002 if (clone_it) {
1003 TCP_SKB_CB(skb)->tx.in_flight = TCP_SKB_CB(skb)->end_seq 1003 TCP_SKB_CB(skb)->tx.in_flight = TCP_SKB_CB(skb)->end_seq
1004 - tp->snd_una; 1004 - tp->snd_una;
1005 tcp_rate_skb_sent(sk, skb); 1005 tcp_rate_skb_sent(sk, skb);
1006 1006
1007 oskb = skb;
1007 if (unlikely(skb_cloned(skb))) 1008 if (unlikely(skb_cloned(skb)))
1008 skb = pskb_copy(skb, gfp_mask); 1009 skb = pskb_copy(skb, gfp_mask);
1009 else 1010 else
@@ -1011,6 +1012,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
1011 if (unlikely(!skb)) 1012 if (unlikely(!skb))
1012 return -ENOBUFS; 1013 return -ENOBUFS;
1013 } 1014 }
1015 skb->skb_mstamp = tp->tcp_mstamp;
1014 1016
1015 inet = inet_sk(sk); 1017 inet = inet_sk(sk);
1016 tcb = TCP_SKB_CB(skb); 1018 tcb = TCP_SKB_CB(skb);
@@ -1122,12 +1124,14 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it,
1122 1124
1123 err = icsk->icsk_af_ops->queue_xmit(sk, skb, &inet->cork.fl); 1125 err = icsk->icsk_af_ops->queue_xmit(sk, skb, &inet->cork.fl);
1124 1126
1125 if (likely(err <= 0)) 1127 if (unlikely(err > 0)) {
1126 return err; 1128 tcp_enter_cwr(sk);
1127 1129 err = net_xmit_eval(err);
1128 tcp_enter_cwr(sk); 1130 }
1131 if (!err && oskb)
1132 oskb->skb_mstamp = tp->tcp_mstamp;
1129 1133
1130 return net_xmit_eval(err); 1134 return err;
1131} 1135}
1132 1136
1133/* This routine just queues the buffer for sending. 1137/* This routine just queues the buffer for sending.
@@ -2869,10 +2873,11 @@ int __tcp_retransmit_skb(struct sock *sk, struct sk_buff *skb, int segs)
2869 skb_headroom(skb) >= 0xFFFF)) { 2873 skb_headroom(skb) >= 0xFFFF)) {
2870 struct sk_buff *nskb; 2874 struct sk_buff *nskb;
2871 2875
2872 skb->skb_mstamp = tp->tcp_mstamp;
2873 nskb = __pskb_copy(skb, MAX_TCP_HEADER, GFP_ATOMIC); 2876 nskb = __pskb_copy(skb, MAX_TCP_HEADER, GFP_ATOMIC);
2874 err = nskb ? tcp_transmit_skb(sk, nskb, 0, GFP_ATOMIC) : 2877 err = nskb ? tcp_transmit_skb(sk, nskb, 0, GFP_ATOMIC) :
2875 -ENOBUFS; 2878 -ENOBUFS;
2879 if (!err)
2880 skb->skb_mstamp = tp->tcp_mstamp;
2876 } else { 2881 } else {
2877 err = tcp_transmit_skb(sk, skb, 1, GFP_ATOMIC); 2882 err = tcp_transmit_skb(sk, skb, 1, GFP_ATOMIC);
2878 } 2883 }