Blame view
net/ipv4/tcp_bic.c
6.02 KB
09c434b8a treewide: Add SPD... |
1 |
// SPDX-License-Identifier: GPL-2.0-only |
83803034f [TCP]: Add TCP BI... |
2 3 |
/* * Binary Increase Congestion control for TCP |
0bc8c7bf9 [TCP]: BIC web pa... |
4 5 |
* Home page: * http://netsrv.csc.ncsu.edu/twiki/bin/view/Main/BIC |
83803034f [TCP]: Add TCP BI... |
6 7 8 9 10 |
* This is from the implementation of BICTCP in * Lison-Xu, Kahaled Harfoush, and Injong Rhee. * "Binary Increase Congestion Control for Fast, Long Distance * Networks" in InfoComm 2004 * Available from: |
0bc8c7bf9 [TCP]: BIC web pa... |
11 |
* http://netsrv.csc.ncsu.edu/export/bitcp.pdf |
83803034f [TCP]: Add TCP BI... |
12 13 14 15 |
* * Unless BIC is enabled and congestion window is large * this behaves the same as the original Reno. */ |
83803034f [TCP]: Add TCP BI... |
16 17 18 |
#include <linux/mm.h> #include <linux/module.h> #include <net/tcp.h> |
83803034f [TCP]: Add TCP BI... |
19 20 21 22 23 24 25 26 27 |
#define BICTCP_BETA_SCALE 1024 /* Scale factor beta calculation * max_cwnd = snd_cwnd * beta */ #define BICTCP_B 4 /* * In binary search, * go to point (max+min)/N */ static int fast_convergence = 1; |
450b5b189 [TCP]: BIC max in... |
28 |
static int max_increment = 16; |
83803034f [TCP]: Add TCP BI... |
29 30 |
static int low_window = 14; static int beta = 819; /* = 819/1024 (BICTCP_BETA_SCALE) */ |
66e1e3b20 [TCP]: Set initia... |
31 |
static int initial_ssthresh; |
83803034f [TCP]: Add TCP BI... |
32 33 34 35 36 37 38 39 40 41 |
static int smooth_part = 20; module_param(fast_convergence, int, 0644); MODULE_PARM_DESC(fast_convergence, "turn on/off fast convergence"); module_param(max_increment, int, 0644); MODULE_PARM_DESC(max_increment, "Limit on increment allowed during binary search"); module_param(low_window, int, 0644); MODULE_PARM_DESC(low_window, "lower bound on congestion window (for TCP friendliness)"); module_param(beta, int, 0644); MODULE_PARM_DESC(beta, "beta for multiplicative increase"); |
83803034f [TCP]: Add TCP BI... |
42 43 44 45 |
module_param(initial_ssthresh, int, 0644); MODULE_PARM_DESC(initial_ssthresh, "initial value of slow start threshold"); module_param(smooth_part, int, 0644); MODULE_PARM_DESC(smooth_part, "log(B/(B*Smin))/log(B/(B-1))+B, # of RTT from Wmax-B to Wmax"); |
83803034f [TCP]: Add TCP BI... |
46 47 48 |
/* BIC TCP Parameters */ struct bictcp { u32 cnt; /* increase cwnd by 1 after ACKs */ |
688d1945b tcp: whitespace f... |
49 |
u32 last_max_cwnd; /* last maximum snd_cwnd */ |
83803034f [TCP]: Add TCP BI... |
50 51 |
u32 last_cwnd; /* the last snd_cwnd */ u32 last_time; /* time when updated last_cwnd */ |
83803034f [TCP]: Add TCP BI... |
52 53 54 55 56 57 58 59 60 |
u32 epoch_start; /* beginning of an epoch */ #define ACK_RATIO_SHIFT 4 u32 delayed_ack; /* estimate the ratio of Packets/ACKs << 4 */ }; static inline void bictcp_reset(struct bictcp *ca) { ca->cnt = 0; ca->last_max_cwnd = 0; |
83803034f [TCP]: Add TCP BI... |
61 62 |
ca->last_cwnd = 0; ca->last_time = 0; |
83803034f [TCP]: Add TCP BI... |
63 64 65 |
ca->epoch_start = 0; ca->delayed_ack = 2 << ACK_RATIO_SHIFT; } |
6687e988d [ICSK]: Move TCP ... |
66 |
static void bictcp_init(struct sock *sk) |
83803034f [TCP]: Add TCP BI... |
67 |
{ |
fc16dcd8c tcp: fix undo aft... |
68 69 70 |
struct bictcp *ca = inet_csk_ca(sk); bictcp_reset(ca); |
fc16dcd8c tcp: fix undo aft... |
71 |
|
83803034f [TCP]: Add TCP BI... |
72 |
if (initial_ssthresh) |
6687e988d [ICSK]: Move TCP ... |
73 |
tcp_sk(sk)->snd_ssthresh = initial_ssthresh; |
83803034f [TCP]: Add TCP BI... |
74 75 76 77 78 79 80 81 |
} /* * Compute congestion window to use. */ static inline void bictcp_update(struct bictcp *ca, u32 cwnd) { if (ca->last_cwnd == cwnd && |
ac35f5622 tcp: bic, cubic: ... |
82 |
(s32)(tcp_jiffies32 - ca->last_time) <= HZ / 32) |
83803034f [TCP]: Add TCP BI... |
83 84 85 |
return; ca->last_cwnd = cwnd; |
ac35f5622 tcp: bic, cubic: ... |
86 |
ca->last_time = tcp_jiffies32; |
83803034f [TCP]: Add TCP BI... |
87 88 |
if (ca->epoch_start == 0) /* record the beginning of an epoch */ |
ac35f5622 tcp: bic, cubic: ... |
89 |
ca->epoch_start = tcp_jiffies32; |
83803034f [TCP]: Add TCP BI... |
90 91 92 93 94 95 96 97 98 |
/* start off normal */ if (cwnd <= low_window) { ca->cnt = cwnd; return; } /* binary increase */ if (cwnd < ca->last_max_cwnd) { |
688d1945b tcp: whitespace f... |
99 |
__u32 dist = (ca->last_max_cwnd - cwnd) |
83803034f [TCP]: Add TCP BI... |
100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 |
/ BICTCP_B; if (dist > max_increment) /* linear increase */ ca->cnt = cwnd / max_increment; else if (dist <= 1U) /* binary search increase */ ca->cnt = (cwnd * smooth_part) / BICTCP_B; else /* binary search increase */ ca->cnt = cwnd / dist; } else { /* slow start AMD linear increase */ if (cwnd < ca->last_max_cwnd + BICTCP_B) /* slow start */ ca->cnt = (cwnd * smooth_part) / BICTCP_B; else if (cwnd < ca->last_max_cwnd + max_increment*(BICTCP_B-1)) /* slow start */ ca->cnt = (cwnd * (BICTCP_B-1)) |
42a39450f [TCP]: BIC coding... |
119 |
/ (cwnd - ca->last_max_cwnd); |
83803034f [TCP]: Add TCP BI... |
120 121 122 123 124 125 |
else /* linear increase */ ca->cnt = cwnd / max_increment; } /* if in slow start or link utilization is very low */ |
fc16dcd8c tcp: fix undo aft... |
126 |
if (ca->last_max_cwnd == 0) { |
83803034f [TCP]: Add TCP BI... |
127 128 129 130 131 132 133 134 |
if (ca->cnt > 20) /* increase cwnd 5% per RTT */ ca->cnt = 20; } ca->cnt = (ca->cnt << ACK_RATIO_SHIFT) / ca->delayed_ack; if (ca->cnt == 0) /* cannot be zero */ ca->cnt = 1; } |
249015515 tcp: remove in_fl... |
135 |
static void bictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) |
83803034f [TCP]: Add TCP BI... |
136 |
{ |
6687e988d [ICSK]: Move TCP ... |
137 138 |
struct tcp_sock *tp = tcp_sk(sk); struct bictcp *ca = inet_csk_ca(sk); |
83803034f [TCP]: Add TCP BI... |
139 |
|
249015515 tcp: remove in_fl... |
140 |
if (!tcp_is_cwnd_limited(sk)) |
83803034f [TCP]: Add TCP BI... |
141 |
return; |
be0d935eb tcp: fix stretch ... |
142 143 144 145 |
if (tcp_in_slow_start(tp)) { acked = tcp_slow_start(tp, acked); if (!acked) return; |
83803034f [TCP]: Add TCP BI... |
146 |
} |
be0d935eb tcp: fix stretch ... |
147 148 |
bictcp_update(ca, tp->snd_cwnd); tcp_cong_avoid_ai(tp, ca->cnt, acked); |
83803034f [TCP]: Add TCP BI... |
149 150 151 152 153 154 |
} /* * behave like Reno until low_window is reached, * then increase congestion window slowly */ |
6687e988d [ICSK]: Move TCP ... |
155 |
static u32 bictcp_recalc_ssthresh(struct sock *sk) |
83803034f [TCP]: Add TCP BI... |
156 |
{ |
6687e988d [ICSK]: Move TCP ... |
157 158 |
const struct tcp_sock *tp = tcp_sk(sk); struct bictcp *ca = inet_csk_ca(sk); |
83803034f [TCP]: Add TCP BI... |
159 160 |
ca->epoch_start = 0; /* end of epoch */ |
83803034f [TCP]: Add TCP BI... |
161 162 163 164 165 166 |
/* Wmax and fast convergence */ if (tp->snd_cwnd < ca->last_max_cwnd && fast_convergence) ca->last_max_cwnd = (tp->snd_cwnd * (BICTCP_BETA_SCALE + beta)) / (2 * BICTCP_BETA_SCALE); else ca->last_max_cwnd = tp->snd_cwnd; |
83803034f [TCP]: Add TCP BI... |
167 168 169 170 171 |
if (tp->snd_cwnd <= low_window) return max(tp->snd_cwnd >> 1U, 2U); else return max((tp->snd_cwnd * beta) / BICTCP_BETA_SCALE, 2U); } |
6687e988d [ICSK]: Move TCP ... |
172 |
static void bictcp_state(struct sock *sk, u8 new_state) |
83803034f [TCP]: Add TCP BI... |
173 174 |
{ if (new_state == TCP_CA_Loss) |
6687e988d [ICSK]: Move TCP ... |
175 |
bictcp_reset(inet_csk_ca(sk)); |
83803034f [TCP]: Add TCP BI... |
176 |
} |
05d054503 [TCP] BIC: spelli... |
177 |
/* Track delayed acknowledgment ratio using sliding window |
83803034f [TCP]: Add TCP BI... |
178 179 |
* ratio = (15*ratio + sample) / 16 */ |
756ee1729 tcp: replace cnt ... |
180 |
static void bictcp_acked(struct sock *sk, const struct ack_sample *sample) |
83803034f [TCP]: Add TCP BI... |
181 |
{ |
6687e988d [ICSK]: Move TCP ... |
182 |
const struct inet_connection_sock *icsk = inet_csk(sk); |
35e869419 [TCP]: Remove num... |
183 |
if (icsk->icsk_ca_state == TCP_CA_Open) { |
6687e988d [ICSK]: Move TCP ... |
184 |
struct bictcp *ca = inet_csk_ca(sk); |
688d1945b tcp: whitespace f... |
185 |
|
756ee1729 tcp: replace cnt ... |
186 187 |
ca->delayed_ack += sample->pkts_acked - (ca->delayed_ack >> ACK_RATIO_SHIFT); |
83803034f [TCP]: Add TCP BI... |
188 189 |
} } |
a252bebe2 tcp: mark tcp_con... |
190 |
static struct tcp_congestion_ops bictcp __read_mostly = { |
83803034f [TCP]: Add TCP BI... |
191 192 193 194 |
.init = bictcp_init, .ssthresh = bictcp_recalc_ssthresh, .cong_avoid = bictcp_cong_avoid, .set_state = bictcp_state, |
f1722a1be tcp: consolidate ... |
195 |
.undo_cwnd = tcp_reno_undo_cwnd, |
83803034f [TCP]: Add TCP BI... |
196 197 198 199 200 201 202 |
.pkts_acked = bictcp_acked, .owner = THIS_MODULE, .name = "bic", }; static int __init bictcp_register(void) { |
65e3d7265 [TCP] tcp_bic: us... |
203 |
BUILD_BUG_ON(sizeof(struct bictcp) > ICSK_CA_PRIV_SIZE); |
83803034f [TCP]: Add TCP BI... |
204 205 206 207 208 209 210 211 212 213 214 215 216 217 |
return tcp_register_congestion_control(&bictcp); } static void __exit bictcp_unregister(void) { tcp_unregister_congestion_control(&bictcp); } module_init(bictcp_register); module_exit(bictcp_unregister); MODULE_AUTHOR("Stephen Hemminger"); MODULE_LICENSE("GPL"); MODULE_DESCRIPTION("BIC TCP"); |