Blame view
net/ipv4/tcp_bic.c
6.23 KB
83803034f
|
1 2 |
/* * Binary Increase Congestion control for TCP |
0bc8c7bf9
|
3 4 |
* Home page: * http://netsrv.csc.ncsu.edu/twiki/bin/view/Main/BIC |
83803034f
|
5 6 7 8 9 |
* 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
|
10 |
* http://netsrv.csc.ncsu.edu/export/bitcp.pdf |
83803034f
|
11 12 13 14 |
* * Unless BIC is enabled and congestion window is large * this behaves the same as the original Reno. */ |
83803034f
|
15 16 17 |
#include <linux/mm.h> #include <linux/module.h> #include <net/tcp.h> |
83803034f
|
18 19 20 21 22 23 24 25 26 |
#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
|
27 |
static int max_increment = 16; |
83803034f
|
28 29 |
static int low_window = 14; static int beta = 819; /* = 819/1024 (BICTCP_BETA_SCALE) */ |
66e1e3b20
|
30 |
static int initial_ssthresh; |
83803034f
|
31 32 33 34 35 36 37 38 39 40 |
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
|
41 42 43 44 |
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
|
45 46 47 |
/* BIC TCP Parameters */ struct bictcp { u32 cnt; /* increase cwnd by 1 after ACKs */ |
688d1945b
|
48 |
u32 last_max_cwnd; /* last maximum snd_cwnd */ |
83803034f
|
49 50 51 |
u32 loss_cwnd; /* congestion window at last loss */ u32 last_cwnd; /* the last snd_cwnd */ u32 last_time; /* time when updated last_cwnd */ |
83803034f
|
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
|
61 62 |
ca->last_cwnd = 0; ca->last_time = 0; |
83803034f
|
63 64 65 |
ca->epoch_start = 0; ca->delayed_ack = 2 << ACK_RATIO_SHIFT; } |
6687e988d
|
66 |
static void bictcp_init(struct sock *sk) |
83803034f
|
67 |
{ |
fc16dcd8c
|
68 69 70 71 |
struct bictcp *ca = inet_csk_ca(sk); bictcp_reset(ca); ca->loss_cwnd = 0; |
83803034f
|
72 |
if (initial_ssthresh) |
6687e988d
|
73 |
tcp_sk(sk)->snd_ssthresh = initial_ssthresh; |
83803034f
|
74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 |
} /* * Compute congestion window to use. */ static inline void bictcp_update(struct bictcp *ca, u32 cwnd) { if (ca->last_cwnd == cwnd && (s32)(tcp_time_stamp - ca->last_time) <= HZ / 32) return; ca->last_cwnd = cwnd; ca->last_time = tcp_time_stamp; if (ca->epoch_start == 0) /* record the beginning of an epoch */ ca->epoch_start = tcp_time_stamp; /* start off normal */ if (cwnd <= low_window) { ca->cnt = cwnd; return; } /* binary increase */ if (cwnd < ca->last_max_cwnd) { |
688d1945b
|
99 |
__u32 dist = (ca->last_max_cwnd - cwnd) |
83803034f
|
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
|
119 |
/ (cwnd - ca->last_max_cwnd); |
83803034f
|
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
|
126 |
if (ca->last_max_cwnd == 0) { |
83803034f
|
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
|
135 |
static void bictcp_cong_avoid(struct sock *sk, u32 ack, u32 acked) |
83803034f
|
136 |
{ |
6687e988d
|
137 138 |
struct tcp_sock *tp = tcp_sk(sk); struct bictcp *ca = inet_csk_ca(sk); |
83803034f
|
139 |
|
249015515
|
140 |
if (!tcp_is_cwnd_limited(sk)) |
83803034f
|
141 |
return; |
071d5080e
|
142 |
if (tcp_in_slow_start(tp)) |
9f9843a75
|
143 |
tcp_slow_start(tp, acked); |
7faffa1c7
|
144 |
else { |
83803034f
|
145 |
bictcp_update(ca, tp->snd_cwnd); |
e73ebb088
|
146 |
tcp_cong_avoid_ai(tp, ca->cnt, 1); |
83803034f
|
147 |
} |
83803034f
|
148 149 150 151 152 153 |
} /* * behave like Reno until low_window is reached, * then increase congestion window slowly */ |
6687e988d
|
154 |
static u32 bictcp_recalc_ssthresh(struct sock *sk) |
83803034f
|
155 |
{ |
6687e988d
|
156 157 |
const struct tcp_sock *tp = tcp_sk(sk); struct bictcp *ca = inet_csk_ca(sk); |
83803034f
|
158 159 |
ca->epoch_start = 0; /* end of epoch */ |
83803034f
|
160 161 162 163 164 165 166 167 |
/* 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; ca->loss_cwnd = tp->snd_cwnd; |
83803034f
|
168 169 170 171 172 |
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
|
173 |
static u32 bictcp_undo_cwnd(struct sock *sk) |
83803034f
|
174 |
{ |
6687e988d
|
175 176 |
const struct tcp_sock *tp = tcp_sk(sk); const struct bictcp *ca = inet_csk_ca(sk); |
688d1945b
|
177 |
|
fc16dcd8c
|
178 |
return max(tp->snd_cwnd, ca->loss_cwnd); |
83803034f
|
179 |
} |
6687e988d
|
180 |
static void bictcp_state(struct sock *sk, u8 new_state) |
83803034f
|
181 182 |
{ if (new_state == TCP_CA_Loss) |
6687e988d
|
183 |
bictcp_reset(inet_csk_ca(sk)); |
83803034f
|
184 |
} |
05d054503
|
185 |
/* Track delayed acknowledgment ratio using sliding window |
83803034f
|
186 187 |
* ratio = (15*ratio + sample) / 16 */ |
756ee1729
|
188 |
static void bictcp_acked(struct sock *sk, const struct ack_sample *sample) |
83803034f
|
189 |
{ |
6687e988d
|
190 |
const struct inet_connection_sock *icsk = inet_csk(sk); |
35e869419
|
191 |
if (icsk->icsk_ca_state == TCP_CA_Open) { |
6687e988d
|
192 |
struct bictcp *ca = inet_csk_ca(sk); |
688d1945b
|
193 |
|
756ee1729
|
194 195 |
ca->delayed_ack += sample->pkts_acked - (ca->delayed_ack >> ACK_RATIO_SHIFT); |
83803034f
|
196 197 |
} } |
a252bebe2
|
198 |
static struct tcp_congestion_ops bictcp __read_mostly = { |
83803034f
|
199 200 201 202 203 |
.init = bictcp_init, .ssthresh = bictcp_recalc_ssthresh, .cong_avoid = bictcp_cong_avoid, .set_state = bictcp_state, .undo_cwnd = bictcp_undo_cwnd, |
83803034f
|
204 205 206 207 208 209 210 |
.pkts_acked = bictcp_acked, .owner = THIS_MODULE, .name = "bic", }; static int __init bictcp_register(void) { |
65e3d7265
|
211 |
BUILD_BUG_ON(sizeof(struct bictcp) > ICSK_CA_PRIV_SIZE); |
83803034f
|
212 213 214 215 216 217 218 219 220 221 222 223 224 225 |
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"); |