diff options
Diffstat (limited to 'net/ipv4/tcp_vegas.c')
| -rw-r--r-- | net/ipv4/tcp_vegas.c | 50 |
1 files changed, 26 insertions, 24 deletions
diff --git a/net/ipv4/tcp_vegas.c b/net/ipv4/tcp_vegas.c index 9bd443db5193..93c5f92070f9 100644 --- a/net/ipv4/tcp_vegas.c +++ b/net/ipv4/tcp_vegas.c | |||
| @@ -35,7 +35,7 @@ | |||
| 35 | #include <linux/mm.h> | 35 | #include <linux/mm.h> |
| 36 | #include <linux/module.h> | 36 | #include <linux/module.h> |
| 37 | #include <linux/skbuff.h> | 37 | #include <linux/skbuff.h> |
| 38 | #include <linux/tcp_diag.h> | 38 | #include <linux/inet_diag.h> |
| 39 | 39 | ||
| 40 | #include <net/tcp.h> | 40 | #include <net/tcp.h> |
| 41 | 41 | ||
| @@ -82,9 +82,10 @@ struct vegas { | |||
| 82 | * Instead we must wait until the completion of an RTT during | 82 | * Instead we must wait until the completion of an RTT during |
| 83 | * which we actually receive ACKs. | 83 | * which we actually receive ACKs. |
| 84 | */ | 84 | */ |
| 85 | static inline void vegas_enable(struct tcp_sock *tp) | 85 | static inline void vegas_enable(struct sock *sk) |
| 86 | { | 86 | { |
| 87 | struct vegas *vegas = tcp_ca(tp); | 87 | const struct tcp_sock *tp = tcp_sk(sk); |
| 88 | struct vegas *vegas = inet_csk_ca(sk); | ||
| 88 | 89 | ||
| 89 | /* Begin taking Vegas samples next time we send something. */ | 90 | /* Begin taking Vegas samples next time we send something. */ |
| 90 | vegas->doing_vegas_now = 1; | 91 | vegas->doing_vegas_now = 1; |
| @@ -97,19 +98,19 @@ static inline void vegas_enable(struct tcp_sock *tp) | |||
| 97 | } | 98 | } |
| 98 | 99 | ||
| 99 | /* Stop taking Vegas samples for now. */ | 100 | /* Stop taking Vegas samples for now. */ |
| 100 | static inline void vegas_disable(struct tcp_sock *tp) | 101 | static inline void vegas_disable(struct sock *sk) |
| 101 | { | 102 | { |
| 102 | struct vegas *vegas = tcp_ca(tp); | 103 | struct vegas *vegas = inet_csk_ca(sk); |
| 103 | 104 | ||
| 104 | vegas->doing_vegas_now = 0; | 105 | vegas->doing_vegas_now = 0; |
| 105 | } | 106 | } |
| 106 | 107 | ||
| 107 | static void tcp_vegas_init(struct tcp_sock *tp) | 108 | static void tcp_vegas_init(struct sock *sk) |
| 108 | { | 109 | { |
| 109 | struct vegas *vegas = tcp_ca(tp); | 110 | struct vegas *vegas = inet_csk_ca(sk); |
| 110 | 111 | ||
| 111 | vegas->baseRTT = 0x7fffffff; | 112 | vegas->baseRTT = 0x7fffffff; |
| 112 | vegas_enable(tp); | 113 | vegas_enable(sk); |
| 113 | } | 114 | } |
| 114 | 115 | ||
| 115 | /* Do RTT sampling needed for Vegas. | 116 | /* Do RTT sampling needed for Vegas. |
| @@ -120,9 +121,9 @@ static void tcp_vegas_init(struct tcp_sock *tp) | |||
| 120 | * o min-filter RTT samples from a much longer window (forever for now) | 121 | * o min-filter RTT samples from a much longer window (forever for now) |
| 121 | * to find the propagation delay (baseRTT) | 122 | * to find the propagation delay (baseRTT) |
| 122 | */ | 123 | */ |
| 123 | static void tcp_vegas_rtt_calc(struct tcp_sock *tp, u32 usrtt) | 124 | static void tcp_vegas_rtt_calc(struct sock *sk, u32 usrtt) |
| 124 | { | 125 | { |
| 125 | struct vegas *vegas = tcp_ca(tp); | 126 | struct vegas *vegas = inet_csk_ca(sk); |
| 126 | u32 vrtt = usrtt + 1; /* Never allow zero rtt or baseRTT */ | 127 | u32 vrtt = usrtt + 1; /* Never allow zero rtt or baseRTT */ |
| 127 | 128 | ||
| 128 | /* Filter to find propagation delay: */ | 129 | /* Filter to find propagation delay: */ |
| @@ -136,13 +137,13 @@ static void tcp_vegas_rtt_calc(struct tcp_sock *tp, u32 usrtt) | |||
| 136 | vegas->cntRTT++; | 137 | vegas->cntRTT++; |
| 137 | } | 138 | } |
| 138 | 139 | ||
| 139 | static void tcp_vegas_state(struct tcp_sock *tp, u8 ca_state) | 140 | static void tcp_vegas_state(struct sock *sk, u8 ca_state) |
| 140 | { | 141 | { |
| 141 | 142 | ||
| 142 | if (ca_state == TCP_CA_Open) | 143 | if (ca_state == TCP_CA_Open) |
| 143 | vegas_enable(tp); | 144 | vegas_enable(sk); |
| 144 | else | 145 | else |
| 145 | vegas_disable(tp); | 146 | vegas_disable(sk); |
| 146 | } | 147 | } |
| 147 | 148 | ||
| 148 | /* | 149 | /* |
| @@ -154,20 +155,21 @@ static void tcp_vegas_state(struct tcp_sock *tp, u8 ca_state) | |||
| 154 | * packets, _then_ we can make Vegas calculations | 155 | * packets, _then_ we can make Vegas calculations |
| 155 | * again. | 156 | * again. |
| 156 | */ | 157 | */ |
| 157 | static void tcp_vegas_cwnd_event(struct tcp_sock *tp, enum tcp_ca_event event) | 158 | static void tcp_vegas_cwnd_event(struct sock *sk, enum tcp_ca_event event) |
| 158 | { | 159 | { |
| 159 | if (event == CA_EVENT_CWND_RESTART || | 160 | if (event == CA_EVENT_CWND_RESTART || |
| 160 | event == CA_EVENT_TX_START) | 161 | event == CA_EVENT_TX_START) |
| 161 | tcp_vegas_init(tp); | 162 | tcp_vegas_init(sk); |
| 162 | } | 163 | } |
| 163 | 164 | ||
| 164 | static void tcp_vegas_cong_avoid(struct tcp_sock *tp, u32 ack, | 165 | static void tcp_vegas_cong_avoid(struct sock *sk, u32 ack, |
| 165 | u32 seq_rtt, u32 in_flight, int flag) | 166 | u32 seq_rtt, u32 in_flight, int flag) |
| 166 | { | 167 | { |
| 167 | struct vegas *vegas = tcp_ca(tp); | 168 | struct tcp_sock *tp = tcp_sk(sk); |
| 169 | struct vegas *vegas = inet_csk_ca(sk); | ||
| 168 | 170 | ||
| 169 | if (!vegas->doing_vegas_now) | 171 | if (!vegas->doing_vegas_now) |
| 170 | return tcp_reno_cong_avoid(tp, ack, seq_rtt, in_flight, flag); | 172 | return tcp_reno_cong_avoid(sk, ack, seq_rtt, in_flight, flag); |
| 171 | 173 | ||
| 172 | /* The key players are v_beg_snd_una and v_beg_snd_nxt. | 174 | /* The key players are v_beg_snd_una and v_beg_snd_nxt. |
| 173 | * | 175 | * |
| @@ -219,7 +221,7 @@ static void tcp_vegas_cong_avoid(struct tcp_sock *tp, u32 ack, | |||
| 219 | * but that's not too awful, since we're taking the min, | 221 | * but that's not too awful, since we're taking the min, |
| 220 | * rather than averaging. | 222 | * rather than averaging. |
| 221 | */ | 223 | */ |
| 222 | tcp_vegas_rtt_calc(tp, seq_rtt*1000); | 224 | tcp_vegas_rtt_calc(sk, seq_rtt * 1000); |
| 223 | 225 | ||
| 224 | /* We do the Vegas calculations only if we got enough RTT | 226 | /* We do the Vegas calculations only if we got enough RTT |
| 225 | * samples that we can be reasonably sure that we got | 227 | * samples that we can be reasonably sure that we got |
| @@ -359,14 +361,14 @@ static void tcp_vegas_cong_avoid(struct tcp_sock *tp, u32 ack, | |||
| 359 | } | 361 | } |
| 360 | 362 | ||
| 361 | /* Extract info for Tcp socket info provided via netlink. */ | 363 | /* Extract info for Tcp socket info provided via netlink. */ |
| 362 | static void tcp_vegas_get_info(struct tcp_sock *tp, u32 ext, | 364 | static void tcp_vegas_get_info(struct sock *sk, u32 ext, |
| 363 | struct sk_buff *skb) | 365 | struct sk_buff *skb) |
| 364 | { | 366 | { |
| 365 | const struct vegas *ca = tcp_ca(tp); | 367 | const struct vegas *ca = inet_csk_ca(sk); |
| 366 | if (ext & (1<<(TCPDIAG_VEGASINFO-1))) { | 368 | if (ext & (1 << (INET_DIAG_VEGASINFO - 1))) { |
| 367 | struct tcpvegas_info *info; | 369 | struct tcpvegas_info *info; |
| 368 | 370 | ||
| 369 | info = RTA_DATA(__RTA_PUT(skb, TCPDIAG_VEGASINFO, | 371 | info = RTA_DATA(__RTA_PUT(skb, INET_DIAG_VEGASINFO, |
| 370 | sizeof(*info))); | 372 | sizeof(*info))); |
| 371 | 373 | ||
| 372 | info->tcpv_enabled = ca->doing_vegas_now; | 374 | info->tcpv_enabled = ca->doing_vegas_now; |
| @@ -393,7 +395,7 @@ static struct tcp_congestion_ops tcp_vegas = { | |||
| 393 | 395 | ||
| 394 | static int __init tcp_vegas_register(void) | 396 | static int __init tcp_vegas_register(void) |
| 395 | { | 397 | { |
| 396 | BUG_ON(sizeof(struct vegas) > TCP_CA_PRIV_SIZE); | 398 | BUG_ON(sizeof(struct vegas) > ICSK_CA_PRIV_SIZE); |
| 397 | tcp_register_congestion_control(&tcp_vegas); | 399 | tcp_register_congestion_control(&tcp_vegas); |
| 398 | return 0; | 400 | return 0; |
| 399 | } | 401 | } |
