diff options
| author | James Morris <james.l.morris@oracle.com> | 2014-11-19 05:32:12 -0500 |
|---|---|---|
| committer | James Morris <james.l.morris@oracle.com> | 2014-11-19 05:32:12 -0500 |
| commit | b10778a00d40b3d9fdaaf5891e802794781ff71c (patch) | |
| tree | 6ba4cbac86eecedc3f30650e7f764ecf00c83898 /net/ipv4/tcp_output.c | |
| parent | 594081ee7145cc30a3977cb4e218f81213b63dc5 (diff) | |
| parent | bfe01a5ba2490f299e1d2d5508cbbbadd897bbe9 (diff) | |
Merge commit 'v3.17' into next
Diffstat (limited to 'net/ipv4/tcp_output.c')
| -rw-r--r-- | net/ipv4/tcp_output.c | 42 |
1 files changed, 39 insertions, 3 deletions
diff --git a/net/ipv4/tcp_output.c b/net/ipv4/tcp_output.c index 179b51e6bda3..5a7c41fbc6d3 100644 --- a/net/ipv4/tcp_output.c +++ b/net/ipv4/tcp_output.c | |||
| @@ -800,7 +800,7 @@ void tcp_release_cb(struct sock *sk) | |||
| 800 | __sock_put(sk); | 800 | __sock_put(sk); |
| 801 | } | 801 | } |
| 802 | if (flags & (1UL << TCP_MTU_REDUCED_DEFERRED)) { | 802 | if (flags & (1UL << TCP_MTU_REDUCED_DEFERRED)) { |
| 803 | sk->sk_prot->mtu_reduced(sk); | 803 | inet_csk(sk)->icsk_af_ops->mtu_reduced(sk); |
| 804 | __sock_put(sk); | 804 | __sock_put(sk); |
| 805 | } | 805 | } |
| 806 | } | 806 | } |
| @@ -916,6 +916,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it, | |||
| 916 | skb_orphan(skb); | 916 | skb_orphan(skb); |
| 917 | skb->sk = sk; | 917 | skb->sk = sk; |
| 918 | skb->destructor = tcp_wfree; | 918 | skb->destructor = tcp_wfree; |
| 919 | skb_set_hash_from_sk(skb, sk); | ||
| 919 | atomic_add(skb->truesize, &sk->sk_wmem_alloc); | 920 | atomic_add(skb->truesize, &sk->sk_wmem_alloc); |
| 920 | 921 | ||
| 921 | /* Build TCP header and checksum it. */ | 922 | /* Build TCP header and checksum it. */ |
| @@ -978,7 +979,7 @@ static int tcp_transmit_skb(struct sock *sk, struct sk_buff *skb, int clone_it, | |||
| 978 | if (likely(err <= 0)) | 979 | if (likely(err <= 0)) |
| 979 | return err; | 980 | return err; |
| 980 | 981 | ||
| 981 | tcp_enter_cwr(sk, 1); | 982 | tcp_enter_cwr(sk); |
| 982 | 983 | ||
| 983 | return net_xmit_eval(err); | 984 | return net_xmit_eval(err); |
| 984 | } | 985 | } |
| @@ -1068,6 +1069,21 @@ static void tcp_adjust_pcount(struct sock *sk, const struct sk_buff *skb, int de | |||
| 1068 | tcp_verify_left_out(tp); | 1069 | tcp_verify_left_out(tp); |
| 1069 | } | 1070 | } |
| 1070 | 1071 | ||
| 1072 | static void tcp_fragment_tstamp(struct sk_buff *skb, struct sk_buff *skb2) | ||
| 1073 | { | ||
| 1074 | struct skb_shared_info *shinfo = skb_shinfo(skb); | ||
| 1075 | |||
| 1076 | if (unlikely(shinfo->tx_flags & SKBTX_ANY_TSTAMP) && | ||
| 1077 | !before(shinfo->tskey, TCP_SKB_CB(skb2)->seq)) { | ||
| 1078 | struct skb_shared_info *shinfo2 = skb_shinfo(skb2); | ||
| 1079 | u8 tsflags = shinfo->tx_flags & SKBTX_ANY_TSTAMP; | ||
| 1080 | |||
| 1081 | shinfo->tx_flags &= ~tsflags; | ||
| 1082 | shinfo2->tx_flags |= tsflags; | ||
| 1083 | swap(shinfo->tskey, shinfo2->tskey); | ||
| 1084 | } | ||
| 1085 | } | ||
| 1086 | |||
| 1071 | /* Function to create two new TCP segments. Shrinks the given segment | 1087 | /* Function to create two new TCP segments. Shrinks the given segment |
| 1072 | * to the specified size and appends a new segment with the rest of the | 1088 | * to the specified size and appends a new segment with the rest of the |
| 1073 | * packet to the list. This won't be called frequently, I hope. | 1089 | * packet to the list. This won't be called frequently, I hope. |
| @@ -1135,6 +1151,7 @@ int tcp_fragment(struct sock *sk, struct sk_buff *skb, u32 len, | |||
| 1135 | */ | 1151 | */ |
| 1136 | TCP_SKB_CB(buff)->when = TCP_SKB_CB(skb)->when; | 1152 | TCP_SKB_CB(buff)->when = TCP_SKB_CB(skb)->when; |
| 1137 | buff->tstamp = skb->tstamp; | 1153 | buff->tstamp = skb->tstamp; |
| 1154 | tcp_fragment_tstamp(skb, buff); | ||
| 1138 | 1155 | ||
| 1139 | old_factor = tcp_skb_pcount(skb); | 1156 | old_factor = tcp_skb_pcount(skb); |
| 1140 | 1157 | ||
| @@ -1651,6 +1668,7 @@ static int tso_fragment(struct sock *sk, struct sk_buff *skb, unsigned int len, | |||
| 1651 | 1668 | ||
| 1652 | buff->ip_summed = skb->ip_summed = CHECKSUM_PARTIAL; | 1669 | buff->ip_summed = skb->ip_summed = CHECKSUM_PARTIAL; |
| 1653 | skb_split(skb, buff, len); | 1670 | skb_split(skb, buff, len); |
| 1671 | tcp_fragment_tstamp(skb, buff); | ||
| 1654 | 1672 | ||
| 1655 | /* Fix up tso_factor for both original and new SKB. */ | 1673 | /* Fix up tso_factor for both original and new SKB. */ |
| 1656 | tcp_set_skb_tso_segs(sk, skb, mss_now); | 1674 | tcp_set_skb_tso_segs(sk, skb, mss_now); |
| @@ -1916,8 +1934,11 @@ static bool tcp_write_xmit(struct sock *sk, unsigned int mss_now, int nonagle, | |||
| 1916 | tso_segs = tcp_init_tso_segs(sk, skb, mss_now); | 1934 | tso_segs = tcp_init_tso_segs(sk, skb, mss_now); |
| 1917 | BUG_ON(!tso_segs); | 1935 | BUG_ON(!tso_segs); |
| 1918 | 1936 | ||
| 1919 | if (unlikely(tp->repair) && tp->repair_queue == TCP_SEND_QUEUE) | 1937 | if (unlikely(tp->repair) && tp->repair_queue == TCP_SEND_QUEUE) { |
| 1938 | /* "when" is used as a start point for the retransmit timer */ | ||
| 1939 | TCP_SKB_CB(skb)->when = tcp_time_stamp; | ||
| 1920 | goto repair; /* Skip network transmission */ | 1940 | goto repair; /* Skip network transmission */ |
| 1941 | } | ||
| 1921 | 1942 | ||
| 1922 | cwnd_quota = tcp_cwnd_test(tp, skb); | 1943 | cwnd_quota = tcp_cwnd_test(tp, skb); |
| 1923 | if (!cwnd_quota) { | 1944 | if (!cwnd_quota) { |
| @@ -3301,3 +3322,18 @@ void tcp_send_probe0(struct sock *sk) | |||
| 3301 | TCP_RTO_MAX); | 3322 | TCP_RTO_MAX); |
| 3302 | } | 3323 | } |
| 3303 | } | 3324 | } |
| 3325 | |||
| 3326 | int tcp_rtx_synack(struct sock *sk, struct request_sock *req) | ||
| 3327 | { | ||
| 3328 | const struct tcp_request_sock_ops *af_ops = tcp_rsk(req)->af_specific; | ||
| 3329 | struct flowi fl; | ||
| 3330 | int res; | ||
| 3331 | |||
| 3332 | res = af_ops->send_synack(sk, NULL, &fl, req, 0, NULL); | ||
| 3333 | if (!res) { | ||
| 3334 | TCP_INC_STATS_BH(sock_net(sk), TCP_MIB_RETRANSSEGS); | ||
| 3335 | NET_INC_STATS_BH(sock_net(sk), LINUX_MIB_TCPSYNRETRANS); | ||
| 3336 | } | ||
| 3337 | return res; | ||
| 3338 | } | ||
| 3339 | EXPORT_SYMBOL(tcp_rtx_synack); | ||
