Commit f6302d1d authored by David S. Miller's avatar David S. Miller
Browse files

[TCP]: Move send test logic out of net/tcp.h 



This just moves the code into tcp_output.c, no code logic changes are
made by this patch.

Using this as a baseline, we can begin to untangle the mess of
comparisons for the Nagle test et al.  We will also be able to reduce
all of the redundant computation that occurs when outputting data
packets.

Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent fc6415bc

include/net/tcp.h

+3 −110
Original line number Diff line number Diff line
@@ -849,6 +849,9 @@ extern __u32 cookie_v4_init_sequence(struct sock *sk, struct sk_buff *skb, 
/* tcp_output.c */



extern int tcp_write_xmit(struct sock *, int nonagle);

extern void __tcp_push_pending_frames(struct sock *sk, struct tcp_sock *tp,

				      unsigned cur_mss, int nonagle);

extern int tcp_may_send_now(struct sock *sk, struct tcp_sock *tp);

extern int tcp_retransmit_skb(struct sock *, struct sk_buff *);

extern void tcp_xmit_retransmit_queue(struct sock *);

extern void tcp_simple_retransmit(struct sock *);
@@ -1284,12 +1287,6 @@ static __inline__ __u32 tcp_max_burst(const struct tcp_sock *tp) 
	return 3;

}



static __inline__ int tcp_minshall_check(const struct tcp_sock *tp)

{

	return after(tp->snd_sml,tp->snd_una) &&

		!after(tp->snd_sml, tp->snd_nxt);

}



static __inline__ void tcp_minshall_update(struct tcp_sock *tp, int mss, 

					   const struct sk_buff *skb)

{
@@ -1297,122 +1294,18 @@ static __inline__ void tcp_minshall_update(struct tcp_sock *tp, int mss, 
		tp->snd_sml = TCP_SKB_CB(skb)->end_seq;

}



/* Return 0, if packet can be sent now without violation Nagle's rules:

   1. It is full sized.

   2. Or it contains FIN.

   3. Or TCP_NODELAY was set.

   4. Or TCP_CORK is not set, and all sent packets are ACKed.

      With Minshall's modification: all sent small packets are ACKed.

 */



static __inline__ int

tcp_nagle_check(const struct tcp_sock *tp, const struct sk_buff *skb, 

		unsigned mss_now, int nonagle)

{

	return (skb->len < mss_now &&

		!(TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN) &&

		((nonagle&TCP_NAGLE_CORK) ||

		 (!nonagle &&

		  tp->packets_out &&

		  tcp_minshall_check(tp))));

}



extern void tcp_set_skb_tso_segs(struct sock *, struct sk_buff *);



/* This checks if the data bearing packet SKB (usually sk->sk_send_head)

 * should be put on the wire right now.

 */

static __inline__ int tcp_snd_test(struct sock *sk,

				   struct sk_buff *skb,

				   unsigned cur_mss, int nonagle)

{

	struct tcp_sock *tp = tcp_sk(sk);

	int pkts = tcp_skb_pcount(skb);



	if (!pkts) {

		tcp_set_skb_tso_segs(sk, skb);

		pkts = tcp_skb_pcount(skb);

	}



	/*	RFC 1122 - section 4.2.3.4

	 *

	 *	We must queue if

	 *

	 *	a) The right edge of this frame exceeds the window

	 *	b) There are packets in flight and we have a small segment

	 *	   [SWS avoidance and Nagle algorithm]

	 *	   (part of SWS is done on packetization)

	 *	   Minshall version sounds: there are no _small_

	 *	   segments in flight. (tcp_nagle_check)

	 *	c) We have too many packets 'in flight'

	 *

	 * 	Don't use the nagle rule for urgent data (or

	 *	for the final FIN -DaveM).

	 *

	 *	Also, Nagle rule does not apply to frames, which

	 *	sit in the middle of queue (they have no chances

	 *	to get new data) and if room at tail of skb is

	 *	not enough to save something seriously (<32 for now).

	 */



	/* Don't be strict about the congestion window for the

	 * final FIN frame.  -DaveM

	 */

	return (((nonagle&TCP_NAGLE_PUSH) || tp->urg_mode

		 || !tcp_nagle_check(tp, skb, cur_mss, nonagle)) &&

		(((tcp_packets_in_flight(tp) + (pkts-1)) < tp->snd_cwnd) ||

		 (TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN)) &&

		!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una + tp->snd_wnd));

}



static __inline__ void tcp_check_probe_timer(struct sock *sk, struct tcp_sock *tp)

{

	if (!tp->packets_out && !tp->pending)

		tcp_reset_xmit_timer(sk, TCP_TIME_PROBE0, tp->rto);

}



static __inline__ int tcp_skb_is_last(const struct sock *sk, 

				      const struct sk_buff *skb)

{

	return skb->next == (struct sk_buff *)&sk->sk_write_queue;

}



/* Push out any pending frames which were held back due to

 * TCP_CORK or attempt at coalescing tiny packets.

 * The socket must be locked by the caller.

 */

static __inline__ void __tcp_push_pending_frames(struct sock *sk,

						 struct tcp_sock *tp,

						 unsigned cur_mss,

						 int nonagle)

{

	struct sk_buff *skb = sk->sk_send_head;



	if (skb) {

		if (!tcp_skb_is_last(sk, skb))

			nonagle = TCP_NAGLE_PUSH;

		if (!tcp_snd_test(sk, skb, cur_mss, nonagle) ||

		    tcp_write_xmit(sk, nonagle))

			tcp_check_probe_timer(sk, tp);

	}

	tcp_cwnd_validate(sk, tp);

}



static __inline__ void tcp_push_pending_frames(struct sock *sk,

					       struct tcp_sock *tp)

{

	__tcp_push_pending_frames(sk, tp, tcp_current_mss(sk, 1), tp->nonagle);

}



static __inline__ int tcp_may_send_now(struct sock *sk, struct tcp_sock *tp)

{

	struct sk_buff *skb = sk->sk_send_head;



	return (skb &&

		tcp_snd_test(sk, skb, tcp_current_mss(sk, 1),

			     tcp_skb_is_last(sk, skb) ? TCP_NAGLE_PUSH : tp->nonagle));

}



static __inline__ void tcp_init_wl(struct tcp_sock *tp, u32 ack, u32 seq)

{

	tp->snd_wl1 = seq;

net/ipv4/tcp_output.c

+129 −21
Original line number Diff line number Diff line
@@ -413,6 +413,135 @@ static inline void tcp_tso_set_push(struct sk_buff *skb) 
		TCP_SKB_CB(skb)->flags |= TCPCB_FLAG_PSH;

}



static void tcp_set_skb_tso_segs(struct sock *sk, struct sk_buff *skb)

{

	struct tcp_sock *tp = tcp_sk(sk);



	if (skb->len <= tp->mss_cache_std ||

	    !(sk->sk_route_caps & NETIF_F_TSO)) {

		/* Avoid the costly divide in the normal

		 * non-TSO case.

		 */

		skb_shinfo(skb)->tso_segs = 1;

		skb_shinfo(skb)->tso_size = 0;

	} else {

		unsigned int factor;



		factor = skb->len + (tp->mss_cache_std - 1);

		factor /= tp->mss_cache_std;

		skb_shinfo(skb)->tso_segs = factor;

		skb_shinfo(skb)->tso_size = tp->mss_cache_std;

	}

}



static inline int tcp_minshall_check(const struct tcp_sock *tp)

{

	return after(tp->snd_sml,tp->snd_una) &&

		!after(tp->snd_sml, tp->snd_nxt);

}



/* Return 0, if packet can be sent now without violation Nagle's rules:

 * 1. It is full sized.

 * 2. Or it contains FIN.

 * 3. Or TCP_NODELAY was set.

 * 4. Or TCP_CORK is not set, and all sent packets are ACKed.

 *    With Minshall's modification: all sent small packets are ACKed.

 */



static inline int tcp_nagle_check(const struct tcp_sock *tp,

				  const struct sk_buff *skb, 

				  unsigned mss_now, int nonagle)

{

	return (skb->len < mss_now &&

		!(TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN) &&

		((nonagle&TCP_NAGLE_CORK) ||

		 (!nonagle &&

		  tp->packets_out &&

		  tcp_minshall_check(tp))));

}



/* This checks if the data bearing packet SKB (usually sk->sk_send_head)

 * should be put on the wire right now.

 */

static int tcp_snd_test(struct sock *sk, struct sk_buff *skb,

			unsigned cur_mss, int nonagle)

{

	struct tcp_sock *tp = tcp_sk(sk);

	int pkts = tcp_skb_pcount(skb);



	if (!pkts) {

		tcp_set_skb_tso_segs(sk, skb);

		pkts = tcp_skb_pcount(skb);

	}



	/*	RFC 1122 - section 4.2.3.4

	 *

	 *	We must queue if

	 *

	 *	a) The right edge of this frame exceeds the window

	 *	b) There are packets in flight and we have a small segment

	 *	   [SWS avoidance and Nagle algorithm]

	 *	   (part of SWS is done on packetization)

	 *	   Minshall version sounds: there are no _small_

	 *	   segments in flight. (tcp_nagle_check)

	 *	c) We have too many packets 'in flight'

	 *

	 * 	Don't use the nagle rule for urgent data (or

	 *	for the final FIN -DaveM).

	 *

	 *	Also, Nagle rule does not apply to frames, which

	 *	sit in the middle of queue (they have no chances

	 *	to get new data) and if room at tail of skb is

	 *	not enough to save something seriously (<32 for now).

	 */



	/* Don't be strict about the congestion window for the

	 * final FIN frame.  -DaveM

	 */

	return (((nonagle&TCP_NAGLE_PUSH) || tp->urg_mode

		 || !tcp_nagle_check(tp, skb, cur_mss, nonagle)) &&

		(((tcp_packets_in_flight(tp) + (pkts-1)) < tp->snd_cwnd) ||

		 (TCP_SKB_CB(skb)->flags & TCPCB_FLAG_FIN)) &&

		!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una + tp->snd_wnd));

}



static inline int tcp_skb_is_last(const struct sock *sk, 

				  const struct sk_buff *skb)

{

	return skb->next == (struct sk_buff *)&sk->sk_write_queue;

}



/* Push out any pending frames which were held back due to

 * TCP_CORK or attempt at coalescing tiny packets.

 * The socket must be locked by the caller.

 */

void __tcp_push_pending_frames(struct sock *sk, struct tcp_sock *tp,

			       unsigned cur_mss, int nonagle)

{

	struct sk_buff *skb = sk->sk_send_head;



	if (skb) {

		if (!tcp_skb_is_last(sk, skb))

			nonagle = TCP_NAGLE_PUSH;

		if (!tcp_snd_test(sk, skb, cur_mss, nonagle) ||

		    tcp_write_xmit(sk, nonagle))

			tcp_check_probe_timer(sk, tp);

	}

	tcp_cwnd_validate(sk, tp);

}



int tcp_may_send_now(struct sock *sk, struct tcp_sock *tp)

{

	struct sk_buff *skb = sk->sk_send_head;



	return (skb &&

		tcp_snd_test(sk, skb, tcp_current_mss(sk, 1),

			     (tcp_skb_is_last(sk, skb) ?

			      TCP_NAGLE_PUSH :

			      tp->nonagle)));

}





/* Send _single_ skb sitting at the send head. This function requires

 * true push pending frames to setup probe timer etc.

 */
@@ -434,27 +563,6 @@ void tcp_push_one(struct sock *sk, unsigned cur_mss) 
	}

}



void tcp_set_skb_tso_segs(struct sock *sk, struct sk_buff *skb)

{

	struct tcp_sock *tp = tcp_sk(sk);



	if (skb->len <= tp->mss_cache_std ||

	    !(sk->sk_route_caps & NETIF_F_TSO)) {

		/* Avoid the costly divide in the normal

		 * non-TSO case.

		 */

		skb_shinfo(skb)->tso_segs = 1;

		skb_shinfo(skb)->tso_size = 0;

	} else {

		unsigned int factor;



		factor = skb->len + (tp->mss_cache_std - 1);

		factor /= tp->mss_cache_std;

		skb_shinfo(skb)->tso_segs = factor;

		skb_shinfo(skb)->tso_size = tp->mss_cache_std;

	}

}



/* Function to create two new TCP segments.  Shrinks the given segment

 * to the specified size and appends a new segment with the rest of the

 * packet to the list.  This won't be called frequently, I hope.

CRA Git | Maintained and supported by SUSTech CRA and CCSE