diff options
Diffstat (limited to 'net/ipv4/tcp_output.c')
-rw-r--r-- | net/ipv4/tcp_output.c | 19 |
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 | } |