Commit b139ba4e authored by Pavel Emelyanov's avatar Pavel Emelyanov Committed by David S. Miller
Browse files

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: default avatarPavel Emelyanov <xemul@openvz.org>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 5e6a3ce6

include/linux/tcp.h

+1 −0
Original line number Original line Diff line number Diff line
@@ -109,6 +109,7 @@ enum { 
#define TCP_REPAIR		19	/* TCP sock is under repair right now */

#define TCP_REPAIR		19	/* TCP sock is under repair right now */

#define TCP_REPAIR_QUEUE	20

#define TCP_REPAIR_QUEUE	20

#define TCP_QUEUE_SEQ		21

#define TCP_QUEUE_SEQ		21

#define TCP_REPAIR_OPTIONS	22





enum {

enum {

	TCP_NO_QUEUE,

	TCP_NO_QUEUE,

net/ipv4/tcp.c

+71 −0
Original line number Original line Diff line number Diff line
@@ -2218,6 +2218,68 @@ static inline int tcp_can_repair_sock(struct sock *sk) 
		((1 << sk->sk_state) & (TCPF_CLOSE | TCPF_ESTABLISHED));

		((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.

 *	Socket option code for TCP.

 */

 */
@@ -2426,6 +2488,15 @@ static int do_tcp_setsockopt(struct sock *sk, int level, 
			err = -EINVAL;

			err = -EINVAL;

		break;

		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:

	case TCP_CORK:

		/* When set indicates to always queue non-full frames.

		/* When set indicates to always queue non-full frames.

		 * Later the user clears this option and we transmit

		 * Later the user clears this option and we transmit

CRA Git | Maintained and supported by SUSTech CRA and CCSE