tcp: add SACK compression

When TCP receives an out-of-order packet, it immediately sends
a SACK packet, generating network load but also forcing the
receiver to send 1-MSS pathological packets, increasing its
RTX queue length/depth, and thus processing time.

Wifi networks suffer from this aggressive behavior, but generally
speaking, all these SACK packets add fuel to the fire when networks
are under congestion.

This patch adds a high resolution timer and tp->compressed_ack counter.

Instead of sending a SACK, we program this timer with a small delay,
based on RTT and capped to 1 ms :

	delay = min ( 5 % of RTT, 1 ms)

If subsequent SACKs need to be sent while the timer has not yet
expired, we simply increment tp->compressed_ack.

When timer expires, a SACK is sent with the latest information.
Whenever an ACK is sent (if data is sent, or if in-order
data is received) timer is canceled.

Note that tcp_sack_new_ofo_skb() is able to force a SACK to be sent
if the sack blocks need to be shuffled, even if the timer has not
expired.

A new SNMP counter is added in the following patch.

Two other patches add sysctls to allow changing the 1,000,000 and 44
values that this commit hard-coded.

Signed-off-by: Eric Dumazet <edumazet@google.com>
Acked-by: Neal Cardwell <ncardwell@google.com>
Acked-by: Yuchung Cheng <ycheng@google.com>
Acked-by: Toke Høiland-Jørgensen <toke@toke.dk>
Signed-off-by: David S. Miller <davem@davemloft.net>

1 files changed, 25 insertions, 0 deletions

diff --git a/net/ipv4/tcp_timer.c b/net/ipv4/tcp_timer.c
index 92bdf64fffae..3b3611729928 100644
--- a/net/ipv4/tcp_timer.c
+++ b/net/ipv4/tcp_timer.c
@@ -708,6 +708,27 @@ out:
         sock_put(sk);
 }
 
+static enum hrtimer_restart tcp_compressed_ack_kick(struct hrtimer *timer)
+{
+        struct tcp_sock *tp = container_of(timer, struct tcp_sock, compressed_ack_timer);
+        struct sock *sk = (struct sock *)tp;
+
+        bh_lock_sock(sk);
+        if (!sock_owned_by_user(sk)) {
+                if (tp->compressed_ack)
+                        tcp_send_ack(sk);
+        } else {
+                if (!test_and_set_bit(TCP_DELACK_TIMER_DEFERRED,
+                                      &sk->sk_tsq_flags))
+                        sock_hold(sk);
+        }
+        bh_unlock_sock(sk);
+
+        sock_put(sk);
+
+        return HRTIMER_NORESTART;
+}
+
 void tcp_init_xmit_timers(struct sock *sk)
 {
         inet_csk_init_xmit_timers(sk, &tcp_write_timer, &tcp_delack_timer,
@@ -715,4 +736,8 @@ void tcp_init_xmit_timers(struct sock *sk)
         hrtimer_init(&tcp_sk(sk)->pacing_timer, CLOCK_MONOTONIC,
                      HRTIMER_MODE_ABS_PINNED_SOFT);
         tcp_sk(sk)->pacing_timer.function = tcp_pace_kick;
+
+        hrtimer_init(&tcp_sk(sk)->compressed_ack_timer, CLOCK_MONOTONIC,
+                     HRTIMER_MODE_REL_PINNED_SOFT);
+        tcp_sk(sk)->compressed_ack_timer.function = tcp_compressed_ack_kick;
 }