tcp: Repair connection-time negotiated parameters

There are options, which are set up on a socket while performing
TCP handshake. Need to resurrect them on a socket while repairing.
A new sockoption accepts a buffer and parses it. The buffer should
be CODE:VALUE sequence of bytes, where CODE is standard option
code and VALUE is the respective value.

Only 4 options should be handled on repaired socket.

To read 3 out of 4 of these options the TCP_INFO sockoption can be
used. An ability to get the last one (the mss_clamp) was added by
the previous patch.

Now the restore. Three of these options -- timestamp_ok, mss_clamp
and snd_wscale -- are just restored on a coket.

The sack_ok flags has 2 issues. First, whether or not to do sacks
at all. This flag is just read and set back. No other sack  info is
saved or restored, since according to the standart and the code
dropping all sack-ed segments is OK, the sender will resubmit them
again, so after the repair we will probably experience a pause in
connection. Next, the fack bit. It's just set back on a socket if
the respective sysctl is set. No collected stats about packets flow
is preserved. As far as I see (plz, correct me if I'm wrong) the
fack-based congestion algorithm survives dropping all of the stats
and repairs itself eventually, probably losing the performance for
that period.

Signed-off-by: Pavel Emelyanov <xemul@openvz.org>
Signed-off-by: David S. Miller <davem@davemloft.net>

1 files changed, 71 insertions, 0 deletions

diff --git a/net/ipv4/tcp.c b/net/ipv4/tcp.c
index b4e690ddb08c..3ce3bd031f33 100644
--- a/net/ipv4/tcp.c
+++ b/net/ipv4/tcp.c
@@ -2218,6 +2218,68 @@ static inline int tcp_can_repair_sock(struct sock *sk)
                 ((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_ESTABLISHED));
 }
 
+static int tcp_repair_options_est(struct tcp_sock *tp, char __user *optbuf, unsigned int len)
+{
+        /*
+         * Options are stored in CODE:VALUE form where CODE is 8bit and VALUE
+         * fits the respective TCPOLEN_ size
+         */
+
+        while (len > 0) {
+                u8 opcode;
+
+                if (get_user(opcode, optbuf))
+                        return -EFAULT;
+
+                optbuf++;
+                len--;
+
+                switch (opcode) {
+                case TCPOPT_MSS: {
+                        u16 in_mss;
+
+                        if (len < sizeof(in_mss))
+                                return -ENODATA;
+                        if (get_user(in_mss, optbuf))
+                                return -EFAULT;
+
+                        tp->rx_opt.mss_clamp = in_mss;
+
+                        optbuf += sizeof(in_mss);
+                        len -= sizeof(in_mss);
+                        break;
+                }
+                case TCPOPT_WINDOW: {
+                        u8 wscale;
+
+                        if (len < sizeof(wscale))
+                                return -ENODATA;
+                        if (get_user(wscale, optbuf))
+                                return -EFAULT;
+
+                        if (wscale > 14)
+                                return -EFBIG;
+
+                        tp->rx_opt.snd_wscale = wscale;
+
+                        optbuf += sizeof(wscale);
+                        len -= sizeof(wscale);
+                        break;
+                }
+                case TCPOPT_SACK_PERM:
+                        tp->rx_opt.sack_ok |= TCP_SACK_SEEN;
+                        if (sysctl_tcp_fack)
+                                tcp_enable_fack(tp);
+                        break;
+                case TCPOPT_TIMESTAMP:
+                        tp->rx_opt.tstamp_ok = 1;
+                        break;
+                }
+        }
+
+        return 0;
+}
+
 /*
  *      Socket option code for TCP.
  */
@@ -2426,6 +2488,15 @@ static int do_tcp_setsockopt(struct sock *sk, int level,
                         err = -EINVAL;
                 break;
 
+        case TCP_REPAIR_OPTIONS:
+                if (!tp->repair)
+                        err = -EINVAL;
+                else if (sk->sk_state == TCP_ESTABLISHED)
+                        err = tcp_repair_options_est(tp, optval, optlen);
+                else
+                        err = -EPERM;
+                break;
+
         case TCP_CORK:
                 /* When set indicates to always queue non-full frames.
                  * Later the user clears this option and we transmit