cregit-Linux how code gets into the kernel

Release 4.15 net/ipv4/tcp_htcp.c

Directory: net/ipv4
/*
 * H-TCP congestion control. The algorithm is detailed in:
 * R.N.Shorten, D.J.Leith:
 *   "H-TCP: TCP for high-speed and long-distance networks"
 *   Proc. PFLDnet, Argonne, 2004.
 * http://www.hamilton.ie/net/htcp3.pdf
 */

#include <linux/mm.h>
#include <linux/module.h>
#include <net/tcp.h>


#define ALPHA_BASE	(1<<7)	
/* 1.0 with shift << 7 */

#define BETA_MIN	(1<<6)	
/* 0.5 with shift << 7 */

#define BETA_MAX	102	
/* 0.8 with shift << 7 */


static int use_rtt_scaling __read_mostly = 1;
module_param(use_rtt_scaling, int, 0644);
MODULE_PARM_DESC(use_rtt_scaling, "turn on/off RTT scaling");


static int use_bandwidth_switch __read_mostly = 1;
module_param(use_bandwidth_switch, int, 0644);
MODULE_PARM_DESC(use_bandwidth_switch, "turn on/off bandwidth switcher");


struct htcp {
	
u32	alpha;		/* Fixed point arith, << 7 */
	
u8	beta;           /* Fixed point arith, << 7 */
	
u8	modeswitch;	/* Delay modeswitch
                                   until we had at least one congestion event */
	
u16	pkts_acked;
	
u32	packetcount;
	
u32	minRTT;
	
u32	maxRTT;
	
u32	last_cong;	/* Time since last congestion event end */
	
u32	undo_last_cong;

	
u32	undo_maxRTT;
	
u32	undo_old_maxB;

	/* Bandwidth estimation */
	
u32	minB;
	
u32	maxB;
	
u32	old_maxB;
	
u32	Bi;
	
u32	lasttime;
};


static inline u32 htcp_cong_time(const struct htcp *ca) { return jiffies - ca->last_cong; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even1995.00%150.00%
Stephen Hemminger15.00%150.00%
Total20100.00%2100.00%


static inline u32 htcp_ccount(const struct htcp *ca) { return htcp_cong_time(ca) / ca->minRTT; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even2295.65%150.00%
Stephen Hemminger14.35%150.00%
Total23100.00%2100.00%


static inline void htcp_reset(struct htcp *ca) { ca->undo_last_cong = ca->last_cong; ca->undo_maxRTT = ca->maxRTT; ca->undo_old_maxB = ca->old_maxB; ca->last_cong = jiffies; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even42100.00%2100.00%
Total42100.00%2100.00%


static u32 htcp_cwnd_undo(struct sock *sk) { struct htcp *ca = inet_csk_ca(sk); if (ca->undo_last_cong) { ca->last_cong = ca->undo_last_cong; ca->maxRTT = ca->undo_maxRTT; ca->old_maxB = ca->undo_old_maxB; ca->undo_last_cong = 0; } return tcp_reno_undo_cwnd(sk); }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even4569.23%240.00%
Doug Leith1421.54%120.00%
Arnaldo Carvalho de Melo46.15%120.00%
Yuchung Cheng23.08%120.00%
Total65100.00%5100.00%


static inline void measure_rtt(struct sock *sk, u32 srtt) { const struct inet_connection_sock *icsk = inet_csk(sk); struct htcp *ca = inet_csk_ca(sk); /* keep track of minimum RTT seen so far, minRTT is zero at first */ if (ca->minRTT > srtt || !ca->minRTT) ca->minRTT = srtt; /* max RTT */ if (icsk->icsk_ca_state == TCP_CA_Open) { if (ca->maxRTT < ca->minRTT) ca->maxRTT = ca->minRTT; if (ca->maxRTT < srtt && srtt <= ca->maxRTT + msecs_to_jiffies(20)) ca->maxRTT = srtt; } }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even9081.82%250.00%
Arnaldo Carvalho de Melo1715.45%125.00%
Stephen Hemminger32.73%125.00%
Total110100.00%4100.00%


static void measure_achieved_throughput(struct sock *sk, const struct ack_sample *sample) { const struct inet_connection_sock *icsk = inet_csk(sk); const struct tcp_sock *tp = tcp_sk(sk); struct htcp *ca = inet_csk_ca(sk); u32 now = tcp_jiffies32; if (icsk->icsk_ca_state == TCP_CA_Open) ca->pkts_acked = sample->pkts_acked; if (sample->rtt_us > 0) measure_rtt(sk, usecs_to_jiffies(sample->rtt_us)); if (!use_bandwidth_switch) return; /* achieved throughput calculations */ if (!((1 << icsk->icsk_ca_state) & (TCPF_CA_Open | TCPF_CA_Disorder))) { ca->packetcount = 0; ca->lasttime = now; return; } ca->packetcount += sample->pkts_acked; if (ca->packetcount >= tp->snd_cwnd - (ca->alpha >> 7 ? : 1) && now - ca->lasttime >= ca->minRTT && ca->minRTT > 0) { __u32 cur_Bi = ca->packetcount * HZ / (now - ca->lasttime); if (htcp_ccount(ca) <= 3) { /* just after backoff */ ca->minB = ca->maxB = ca->Bi = cur_Bi; } else { ca->Bi = (3 * ca->Bi + cur_Bi) / 4; if (ca->Bi > ca->maxB) ca->maxB = ca->Bi; if (ca->minB > ca->maxB) ca->minB = ca->maxB; } ca->packetcount = 0; ca->lasttime = now; } }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even21775.35%337.50%
Arnaldo Carvalho de Melo289.72%112.50%
Lawrence Brakmo155.21%112.50%
Stephen Hemminger144.86%112.50%
Ilpo Järvinen134.51%112.50%
Eric Dumazet10.35%112.50%
Total288100.00%8100.00%


static inline void htcp_beta_update(struct htcp *ca, u32 minRTT, u32 maxRTT) { if (use_bandwidth_switch) { u32 maxB = ca->maxB; u32 old_maxB = ca->old_maxB; ca->old_maxB = ca->maxB; if (!between(5 * maxB, 4 * old_maxB, 6 * old_maxB)) { ca->beta = BETA_MIN; ca->modeswitch = 0; return; } } if (ca->modeswitch && minRTT > msecs_to_jiffies(10) && maxRTT) { ca->beta = (minRTT << 7) / maxRTT; if (ca->beta < BETA_MIN) ca->beta = BETA_MIN; else if (ca->beta > BETA_MAX) ca->beta = BETA_MAX; } else { ca->beta = BETA_MIN; ca->modeswitch = 1; } }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even152100.00%2100.00%
Total152100.00%2100.00%


static inline void htcp_alpha_update(struct htcp *ca) { u32 minRTT = ca->minRTT; u32 factor = 1; u32 diff = htcp_cong_time(ca); if (diff > HZ) { diff -= HZ; factor = 1 + (10 * diff + ((diff / 2) * (diff / 2) / HZ)) / HZ; } if (use_rtt_scaling && minRTT) { u32 scale = (HZ << 3) / (10 * minRTT); /* clamping ratio to interval [0.5,10]<<3 */ scale = min(max(scale, 1U << 2), 10U << 3); factor = (factor << 3) / scale; if (!factor) factor = 1; } ca->alpha = 2 * factor * ((1 << 7) - ca->beta); if (!ca->alpha) ca->alpha = ALPHA_BASE; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even16599.40%266.67%
Stephen Hemminger10.60%133.33%
Total166100.00%3100.00%

/* * After we have the rtt data to calculate beta, we'd still prefer to wait one * rtt before we adjust our beta to ensure we are working from a consistent * data. * * This function should be called when we hit a congestion event since only at * that point do we really have a real sense of maxRTT (the queues en route * were getting just too full now). */
static void htcp_param_update(struct sock *sk) { struct htcp *ca = inet_csk_ca(sk); u32 minRTT = ca->minRTT; u32 maxRTT = ca->maxRTT; htcp_beta_update(ca, minRTT, maxRTT); htcp_alpha_update(ca); /* add slowly fading memory for maxRTT to accommodate routing changes */ if (minRTT > 0 && maxRTT > minRTT) ca->maxRTT = minRTT + ((maxRTT - minRTT) * 95) / 100; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even7393.59%133.33%
Arnaldo Carvalho de Melo45.13%133.33%
Stephen Hemminger11.28%133.33%
Total78100.00%3100.00%


static u32 htcp_recalc_ssthresh(struct sock *sk) { const struct tcp_sock *tp = tcp_sk(sk); const struct htcp *ca = inet_csk_ca(sk); htcp_param_update(sk); return max((tp->snd_cwnd * ca->beta) >> 7, 2U); }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even3969.64%150.00%
Arnaldo Carvalho de Melo1730.36%150.00%
Total56100.00%2100.00%


static void htcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) { struct tcp_sock *tp = tcp_sk(sk); struct htcp *ca = inet_csk_ca(sk); if (!tcp_is_cwnd_limited(sk)) return; if (tcp_in_slow_start(tp)) tcp_slow_start(tp, acked); else { /* In dangerous area, increase slowly. * In theory this is tp->snd_cwnd += alpha / tp->snd_cwnd */ if ((tp->snd_cwnd_cnt * ca->alpha)>>7 >= tp->snd_cwnd) { if (tp->snd_cwnd < tp->snd_cwnd_clamp) tp->snd_cwnd++; tp->snd_cwnd_cnt = 0; htcp_alpha_update(ca); } else tp->snd_cwnd_cnt += ca->pkts_acked; ca->pkts_acked = 1; } }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even9777.60%337.50%
Arnaldo Carvalho de Melo1411.20%112.50%
Stephen Hemminger86.40%225.00%
Yuchung Cheng64.80%225.00%
Total125100.00%8100.00%


static void htcp_init(struct sock *sk) { struct htcp *ca = inet_csk_ca(sk); memset(ca, 0, sizeof(struct htcp)); ca->alpha = ALPHA_BASE; ca->beta = BETA_MIN; ca->pkts_acked = 1; ca->last_cong = jiffies; }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even5493.10%375.00%
Arnaldo Carvalho de Melo46.90%125.00%
Total58100.00%4100.00%


static void htcp_state(struct sock *sk, u8 new_state) { switch (new_state) { case TCP_CA_Open: { struct htcp *ca = inet_csk_ca(sk); if (ca->undo_last_cong) { ca->last_cong = jiffies; ca->undo_last_cong = 0; } } break; case TCP_CA_CWR: case TCP_CA_Recovery: case TCP_CA_Loss: htcp_reset(inet_csk_ca(sk)); break; } }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even5675.68%250.00%
Doug Leith1418.92%125.00%
Arnaldo Carvalho de Melo45.41%125.00%
Total74100.00%4100.00%

static struct tcp_congestion_ops htcp __read_mostly = { .init = htcp_init, .ssthresh = htcp_recalc_ssthresh, .cong_avoid = htcp_cong_avoid, .set_state = htcp_state, .undo_cwnd = htcp_cwnd_undo, .pkts_acked = measure_achieved_throughput, .owner = THIS_MODULE, .name = "htcp", };
static int __init htcp_register(void) { BUILD_BUG_ON(sizeof(struct htcp) > ICSK_CA_PRIV_SIZE); BUILD_BUG_ON(BETA_MIN >= BETA_MAX); return tcp_register_congestion_control(&htcp); }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even3294.12%133.33%
Alexey Dobriyan12.94%133.33%
Arnaldo Carvalho de Melo12.94%133.33%
Total34100.00%3100.00%


static void __exit htcp_unregister(void) { tcp_unregister_congestion_control(&htcp); }

Contributors

PersonTokensPropCommitsCommitProp
Baruch Even15100.00%1100.00%
Total15100.00%1100.00%

module_init(htcp_register); module_exit(htcp_unregister); MODULE_AUTHOR("Baruch Even"); MODULE_LICENSE("GPL"); MODULE_DESCRIPTION("H-TCP");

Overall Contributors

PersonTokensPropCommitsCommitProp
Baruch Even130886.68%420.00%
Arnaldo Carvalho de Melo936.16%15.00%
Stephen Hemminger342.25%525.00%
Doug Leith281.86%15.00%
Lawrence Brakmo150.99%15.00%
Ilpo Järvinen130.86%15.00%
Yuchung Cheng80.53%315.00%
David S. Miller70.46%15.00%
Eric Dumazet10.07%15.00%
Alexey Dobriyan10.07%15.00%
Gavin McCullagh10.07%15.00%
Total1509100.00%20100.00%
Directory: net/ipv4
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.