diff options
| -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 | } |
