diff options
| author | Takashi Iwai <tiwai@suse.de> | 2009-12-15 04:29:06 -0500 |
|---|---|---|
| committer | Takashi Iwai <tiwai@suse.de> | 2009-12-15 04:29:06 -0500 |
| commit | 709334c87dbdb44150ce436b3d13c814db0dcae9 (patch) | |
| tree | 5861a45f70c1f283720337abd864498f5afb3dbe /net/dccp/ccids/ccid2.c | |
| parent | 0d64b568fcd48b133721c1d322e7c51d85eb12df (diff) | |
| parent | f74890277a196949e4004fe2955e1d4fb3930f98 (diff) | |
Merge branch 'fixes' of git://git.alsa-project.org/alsa-kernel into for-linus
Diffstat (limited to 'net/dccp/ccids/ccid2.c')
| -rw-r--r-- | net/dccp/ccids/ccid2.c | 327 |
1 files changed, 162 insertions, 165 deletions
diff --git a/net/dccp/ccids/ccid2.c b/net/dccp/ccids/ccid2.c index e8cf99e880b0..a47a8c918ee8 100644 --- a/net/dccp/ccids/ccid2.c +++ b/net/dccp/ccids/ccid2.c | |||
| @@ -33,20 +33,20 @@ | |||
| 33 | static int ccid2_debug; | 33 | static int ccid2_debug; |
| 34 | #define ccid2_pr_debug(format, a...) DCCP_PR_DEBUG(ccid2_debug, format, ##a) | 34 | #define ccid2_pr_debug(format, a...) DCCP_PR_DEBUG(ccid2_debug, format, ##a) |
| 35 | 35 | ||
| 36 | static void ccid2_hc_tx_check_sanity(const struct ccid2_hc_tx_sock *hctx) | 36 | static void ccid2_hc_tx_check_sanity(const struct ccid2_hc_tx_sock *hc) |
| 37 | { | 37 | { |
| 38 | int len = 0; | 38 | int len = 0; |
| 39 | int pipe = 0; | 39 | int pipe = 0; |
| 40 | struct ccid2_seq *seqp = hctx->ccid2hctx_seqh; | 40 | struct ccid2_seq *seqp = hc->tx_seqh; |
| 41 | 41 | ||
| 42 | /* there is data in the chain */ | 42 | /* there is data in the chain */ |
| 43 | if (seqp != hctx->ccid2hctx_seqt) { | 43 | if (seqp != hc->tx_seqt) { |
| 44 | seqp = seqp->ccid2s_prev; | 44 | seqp = seqp->ccid2s_prev; |
| 45 | len++; | 45 | len++; |
| 46 | if (!seqp->ccid2s_acked) | 46 | if (!seqp->ccid2s_acked) |
| 47 | pipe++; | 47 | pipe++; |
| 48 | 48 | ||
| 49 | while (seqp != hctx->ccid2hctx_seqt) { | 49 | while (seqp != hc->tx_seqt) { |
| 50 | struct ccid2_seq *prev = seqp->ccid2s_prev; | 50 | struct ccid2_seq *prev = seqp->ccid2s_prev; |
| 51 | 51 | ||
| 52 | len++; | 52 | len++; |
| @@ -63,30 +63,30 @@ static void ccid2_hc_tx_check_sanity(const struct ccid2_hc_tx_sock *hctx) | |||
| 63 | } | 63 | } |
| 64 | } | 64 | } |
| 65 | 65 | ||
| 66 | BUG_ON(pipe != hctx->ccid2hctx_pipe); | 66 | BUG_ON(pipe != hc->tx_pipe); |
| 67 | ccid2_pr_debug("len of chain=%d\n", len); | 67 | ccid2_pr_debug("len of chain=%d\n", len); |
| 68 | 68 | ||
| 69 | do { | 69 | do { |
| 70 | seqp = seqp->ccid2s_prev; | 70 | seqp = seqp->ccid2s_prev; |
| 71 | len++; | 71 | len++; |
| 72 | } while (seqp != hctx->ccid2hctx_seqh); | 72 | } while (seqp != hc->tx_seqh); |
| 73 | 73 | ||
| 74 | ccid2_pr_debug("total len=%d\n", len); | 74 | ccid2_pr_debug("total len=%d\n", len); |
| 75 | BUG_ON(len != hctx->ccid2hctx_seqbufc * CCID2_SEQBUF_LEN); | 75 | BUG_ON(len != hc->tx_seqbufc * CCID2_SEQBUF_LEN); |
| 76 | } | 76 | } |
| 77 | #else | 77 | #else |
| 78 | #define ccid2_pr_debug(format, a...) | 78 | #define ccid2_pr_debug(format, a...) |
| 79 | #define ccid2_hc_tx_check_sanity(hctx) | 79 | #define ccid2_hc_tx_check_sanity(hc) |
| 80 | #endif | 80 | #endif |
| 81 | 81 | ||
| 82 | static int ccid2_hc_tx_alloc_seq(struct ccid2_hc_tx_sock *hctx) | 82 | static int ccid2_hc_tx_alloc_seq(struct ccid2_hc_tx_sock *hc) |
| 83 | { | 83 | { |
| 84 | struct ccid2_seq *seqp; | 84 | struct ccid2_seq *seqp; |
| 85 | int i; | 85 | int i; |
| 86 | 86 | ||
| 87 | /* check if we have space to preserve the pointer to the buffer */ | 87 | /* check if we have space to preserve the pointer to the buffer */ |
| 88 | if (hctx->ccid2hctx_seqbufc >= (sizeof(hctx->ccid2hctx_seqbuf) / | 88 | if (hc->tx_seqbufc >= (sizeof(hc->tx_seqbuf) / |
| 89 | sizeof(struct ccid2_seq*))) | 89 | sizeof(struct ccid2_seq *))) |
| 90 | return -ENOMEM; | 90 | return -ENOMEM; |
| 91 | 91 | ||
| 92 | /* allocate buffer and initialize linked list */ | 92 | /* allocate buffer and initialize linked list */ |
| @@ -102,29 +102,29 @@ static int ccid2_hc_tx_alloc_seq(struct ccid2_hc_tx_sock *hctx) | |||
| 102 | seqp->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1]; | 102 | seqp->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1]; |
| 103 | 103 | ||
| 104 | /* This is the first allocation. Initiate the head and tail. */ | 104 | /* This is the first allocation. Initiate the head and tail. */ |
| 105 | if (hctx->ccid2hctx_seqbufc == 0) | 105 | if (hc->tx_seqbufc == 0) |
| 106 | hctx->ccid2hctx_seqh = hctx->ccid2hctx_seqt = seqp; | 106 | hc->tx_seqh = hc->tx_seqt = seqp; |
| 107 | else { | 107 | else { |
| 108 | /* link the existing list with the one we just created */ | 108 | /* link the existing list with the one we just created */ |
| 109 | hctx->ccid2hctx_seqh->ccid2s_next = seqp; | 109 | hc->tx_seqh->ccid2s_next = seqp; |
| 110 | seqp->ccid2s_prev = hctx->ccid2hctx_seqh; | 110 | seqp->ccid2s_prev = hc->tx_seqh; |
| 111 | 111 | ||
| 112 | hctx->ccid2hctx_seqt->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1]; | 112 | hc->tx_seqt->ccid2s_prev = &seqp[CCID2_SEQBUF_LEN - 1]; |
| 113 | seqp[CCID2_SEQBUF_LEN - 1].ccid2s_next = hctx->ccid2hctx_seqt; | 113 | seqp[CCID2_SEQBUF_LEN - 1].ccid2s_next = hc->tx_seqt; |
| 114 | } | 114 | } |
| 115 | 115 | ||
| 116 | /* store the original pointer to the buffer so we can free it */ | 116 | /* store the original pointer to the buffer so we can free it */ |
| 117 | hctx->ccid2hctx_seqbuf[hctx->ccid2hctx_seqbufc] = seqp; | 117 | hc->tx_seqbuf[hc->tx_seqbufc] = seqp; |
| 118 | hctx->ccid2hctx_seqbufc++; | 118 | hc->tx_seqbufc++; |
| 119 | 119 | ||
| 120 | return 0; | 120 | return 0; |
| 121 | } | 121 | } |
| 122 | 122 | ||
| 123 | static int ccid2_hc_tx_send_packet(struct sock *sk, struct sk_buff *skb) | 123 | static int ccid2_hc_tx_send_packet(struct sock *sk, struct sk_buff *skb) |
| 124 | { | 124 | { |
| 125 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 125 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 126 | 126 | ||
| 127 | if (hctx->ccid2hctx_pipe < hctx->ccid2hctx_cwnd) | 127 | if (hc->tx_pipe < hc->tx_cwnd) |
| 128 | return 0; | 128 | return 0; |
| 129 | 129 | ||
| 130 | return 1; /* XXX CCID should dequeue when ready instead of polling */ | 130 | return 1; /* XXX CCID should dequeue when ready instead of polling */ |
| @@ -133,7 +133,7 @@ static int ccid2_hc_tx_send_packet(struct sock *sk, struct sk_buff *skb) | |||
| 133 | static void ccid2_change_l_ack_ratio(struct sock *sk, u32 val) | 133 | static void ccid2_change_l_ack_ratio(struct sock *sk, u32 val) |
| 134 | { | 134 | { |
| 135 | struct dccp_sock *dp = dccp_sk(sk); | 135 | struct dccp_sock *dp = dccp_sk(sk); |
| 136 | u32 max_ratio = DIV_ROUND_UP(ccid2_hc_tx_sk(sk)->ccid2hctx_cwnd, 2); | 136 | u32 max_ratio = DIV_ROUND_UP(ccid2_hc_tx_sk(sk)->tx_cwnd, 2); |
| 137 | 137 | ||
| 138 | /* | 138 | /* |
| 139 | * Ensure that Ack Ratio does not exceed ceil(cwnd/2), which is (2) from | 139 | * Ensure that Ack Ratio does not exceed ceil(cwnd/2), which is (2) from |
| @@ -155,10 +155,10 @@ static void ccid2_change_l_ack_ratio(struct sock *sk, u32 val) | |||
| 155 | dp->dccps_l_ack_ratio = val; | 155 | dp->dccps_l_ack_ratio = val; |
| 156 | } | 156 | } |
| 157 | 157 | ||
| 158 | static void ccid2_change_srtt(struct ccid2_hc_tx_sock *hctx, long val) | 158 | static void ccid2_change_srtt(struct ccid2_hc_tx_sock *hc, long val) |
| 159 | { | 159 | { |
| 160 | ccid2_pr_debug("change SRTT to %ld\n", val); | 160 | ccid2_pr_debug("change SRTT to %ld\n", val); |
| 161 | hctx->ccid2hctx_srtt = val; | 161 | hc->tx_srtt = val; |
| 162 | } | 162 | } |
| 163 | 163 | ||
| 164 | static void ccid2_start_rto_timer(struct sock *sk); | 164 | static void ccid2_start_rto_timer(struct sock *sk); |
| @@ -166,45 +166,44 @@ static void ccid2_start_rto_timer(struct sock *sk); | |||
| 166 | static void ccid2_hc_tx_rto_expire(unsigned long data) | 166 | static void ccid2_hc_tx_rto_expire(unsigned long data) |
| 167 | { | 167 | { |
| 168 | struct sock *sk = (struct sock *)data; | 168 | struct sock *sk = (struct sock *)data; |
| 169 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 169 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 170 | long s; | 170 | long s; |
| 171 | 171 | ||
| 172 | bh_lock_sock(sk); | 172 | bh_lock_sock(sk); |
| 173 | if (sock_owned_by_user(sk)) { | 173 | if (sock_owned_by_user(sk)) { |
| 174 | sk_reset_timer(sk, &hctx->ccid2hctx_rtotimer, | 174 | sk_reset_timer(sk, &hc->tx_rtotimer, jiffies + HZ / 5); |
| 175 | jiffies + HZ / 5); | ||
| 176 | goto out; | 175 | goto out; |
| 177 | } | 176 | } |
| 178 | 177 | ||
| 179 | ccid2_pr_debug("RTO_EXPIRE\n"); | 178 | ccid2_pr_debug("RTO_EXPIRE\n"); |
| 180 | 179 | ||
| 181 | ccid2_hc_tx_check_sanity(hctx); | 180 | ccid2_hc_tx_check_sanity(hc); |
| 182 | 181 | ||
| 183 | /* back-off timer */ | 182 | /* back-off timer */ |
| 184 | hctx->ccid2hctx_rto <<= 1; | 183 | hc->tx_rto <<= 1; |
| 185 | 184 | ||
| 186 | s = hctx->ccid2hctx_rto / HZ; | 185 | s = hc->tx_rto / HZ; |
| 187 | if (s > 60) | 186 | if (s > 60) |
| 188 | hctx->ccid2hctx_rto = 60 * HZ; | 187 | hc->tx_rto = 60 * HZ; |
| 189 | 188 | ||
| 190 | ccid2_start_rto_timer(sk); | 189 | ccid2_start_rto_timer(sk); |
| 191 | 190 | ||
| 192 | /* adjust pipe, cwnd etc */ | 191 | /* adjust pipe, cwnd etc */ |
| 193 | hctx->ccid2hctx_ssthresh = hctx->ccid2hctx_cwnd / 2; | 192 | hc->tx_ssthresh = hc->tx_cwnd / 2; |
| 194 | if (hctx->ccid2hctx_ssthresh < 2) | 193 | if (hc->tx_ssthresh < 2) |
| 195 | hctx->ccid2hctx_ssthresh = 2; | 194 | hc->tx_ssthresh = 2; |
| 196 | hctx->ccid2hctx_cwnd = 1; | 195 | hc->tx_cwnd = 1; |
| 197 | hctx->ccid2hctx_pipe = 0; | 196 | hc->tx_pipe = 0; |
| 198 | 197 | ||
| 199 | /* clear state about stuff we sent */ | 198 | /* clear state about stuff we sent */ |
| 200 | hctx->ccid2hctx_seqt = hctx->ccid2hctx_seqh; | 199 | hc->tx_seqt = hc->tx_seqh; |
| 201 | hctx->ccid2hctx_packets_acked = 0; | 200 | hc->tx_packets_acked = 0; |
| 202 | 201 | ||
| 203 | /* clear ack ratio state. */ | 202 | /* clear ack ratio state. */ |
| 204 | hctx->ccid2hctx_rpseq = 0; | 203 | hc->tx_rpseq = 0; |
| 205 | hctx->ccid2hctx_rpdupack = -1; | 204 | hc->tx_rpdupack = -1; |
| 206 | ccid2_change_l_ack_ratio(sk, 1); | 205 | ccid2_change_l_ack_ratio(sk, 1); |
| 207 | ccid2_hc_tx_check_sanity(hctx); | 206 | ccid2_hc_tx_check_sanity(hc); |
| 208 | out: | 207 | out: |
| 209 | bh_unlock_sock(sk); | 208 | bh_unlock_sock(sk); |
| 210 | sock_put(sk); | 209 | sock_put(sk); |
| @@ -212,42 +211,40 @@ out: | |||
| 212 | 211 | ||
| 213 | static void ccid2_start_rto_timer(struct sock *sk) | 212 | static void ccid2_start_rto_timer(struct sock *sk) |
| 214 | { | 213 | { |
| 215 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 214 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 216 | 215 | ||
| 217 | ccid2_pr_debug("setting RTO timeout=%ld\n", hctx->ccid2hctx_rto); | 216 | ccid2_pr_debug("setting RTO timeout=%ld\n", hc->tx_rto); |
| 218 | 217 | ||
| 219 | BUG_ON(timer_pending(&hctx->ccid2hctx_rtotimer)); | 218 | BUG_ON(timer_pending(&hc->tx_rtotimer)); |
| 220 | sk_reset_timer(sk, &hctx->ccid2hctx_rtotimer, | 219 | sk_reset_timer(sk, &hc->tx_rtotimer, jiffies + hc->tx_rto); |
| 221 | jiffies + hctx->ccid2hctx_rto); | ||
| 222 | } | 220 | } |
| 223 | 221 | ||
| 224 | static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, unsigned int len) | 222 | static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, unsigned int len) |
| 225 | { | 223 | { |
| 226 | struct dccp_sock *dp = dccp_sk(sk); | 224 | struct dccp_sock *dp = dccp_sk(sk); |
| 227 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 225 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 228 | struct ccid2_seq *next; | 226 | struct ccid2_seq *next; |
| 229 | 227 | ||
| 230 | hctx->ccid2hctx_pipe++; | 228 | hc->tx_pipe++; |
| 231 | 229 | ||
| 232 | hctx->ccid2hctx_seqh->ccid2s_seq = dp->dccps_gss; | 230 | hc->tx_seqh->ccid2s_seq = dp->dccps_gss; |
| 233 | hctx->ccid2hctx_seqh->ccid2s_acked = 0; | 231 | hc->tx_seqh->ccid2s_acked = 0; |
| 234 | hctx->ccid2hctx_seqh->ccid2s_sent = jiffies; | 232 | hc->tx_seqh->ccid2s_sent = jiffies; |
| 235 | 233 | ||
| 236 | next = hctx->ccid2hctx_seqh->ccid2s_next; | 234 | next = hc->tx_seqh->ccid2s_next; |
| 237 | /* check if we need to alloc more space */ | 235 | /* check if we need to alloc more space */ |
| 238 | if (next == hctx->ccid2hctx_seqt) { | 236 | if (next == hc->tx_seqt) { |
| 239 | if (ccid2_hc_tx_alloc_seq(hctx)) { | 237 | if (ccid2_hc_tx_alloc_seq(hc)) { |
| 240 | DCCP_CRIT("packet history - out of memory!"); | 238 | DCCP_CRIT("packet history - out of memory!"); |
| 241 | /* FIXME: find a more graceful way to bail out */ | 239 | /* FIXME: find a more graceful way to bail out */ |
| 242 | return; | 240 | return; |
| 243 | } | 241 | } |
| 244 | next = hctx->ccid2hctx_seqh->ccid2s_next; | 242 | next = hc->tx_seqh->ccid2s_next; |
| 245 | BUG_ON(next == hctx->ccid2hctx_seqt); | 243 | BUG_ON(next == hc->tx_seqt); |
| 246 | } | 244 | } |
| 247 | hctx->ccid2hctx_seqh = next; | 245 | hc->tx_seqh = next; |
| 248 | 246 | ||
| 249 | ccid2_pr_debug("cwnd=%d pipe=%d\n", hctx->ccid2hctx_cwnd, | 247 | ccid2_pr_debug("cwnd=%d pipe=%d\n", hc->tx_cwnd, hc->tx_pipe); |
| 250 | hctx->ccid2hctx_pipe); | ||
| 251 | 248 | ||
| 252 | /* | 249 | /* |
| 253 | * FIXME: The code below is broken and the variables have been removed | 250 | * FIXME: The code below is broken and the variables have been removed |
| @@ -270,12 +267,12 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, unsigned int len) | |||
| 270 | */ | 267 | */ |
| 271 | #if 0 | 268 | #if 0 |
| 272 | /* Ack Ratio. Need to maintain a concept of how many windows we sent */ | 269 | /* Ack Ratio. Need to maintain a concept of how many windows we sent */ |
| 273 | hctx->ccid2hctx_arsent++; | 270 | hc->tx_arsent++; |
| 274 | /* We had an ack loss in this window... */ | 271 | /* We had an ack loss in this window... */ |
| 275 | if (hctx->ccid2hctx_ackloss) { | 272 | if (hc->tx_ackloss) { |
| 276 | if (hctx->ccid2hctx_arsent >= hctx->ccid2hctx_cwnd) { | 273 | if (hc->tx_arsent >= hc->tx_cwnd) { |
| 277 | hctx->ccid2hctx_arsent = 0; | 274 | hc->tx_arsent = 0; |
| 278 | hctx->ccid2hctx_ackloss = 0; | 275 | hc->tx_ackloss = 0; |
| 279 | } | 276 | } |
| 280 | } else { | 277 | } else { |
| 281 | /* No acks lost up to now... */ | 278 | /* No acks lost up to now... */ |
| @@ -285,28 +282,28 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, unsigned int len) | |||
| 285 | int denom = dp->dccps_l_ack_ratio * dp->dccps_l_ack_ratio - | 282 | int denom = dp->dccps_l_ack_ratio * dp->dccps_l_ack_ratio - |
| 286 | dp->dccps_l_ack_ratio; | 283 | dp->dccps_l_ack_ratio; |
| 287 | 284 | ||
| 288 | denom = hctx->ccid2hctx_cwnd * hctx->ccid2hctx_cwnd / denom; | 285 | denom = hc->tx_cwnd * hc->tx_cwnd / denom; |
| 289 | 286 | ||
| 290 | if (hctx->ccid2hctx_arsent >= denom) { | 287 | if (hc->tx_arsent >= denom) { |
| 291 | ccid2_change_l_ack_ratio(sk, dp->dccps_l_ack_ratio - 1); | 288 | ccid2_change_l_ack_ratio(sk, dp->dccps_l_ack_ratio - 1); |
| 292 | hctx->ccid2hctx_arsent = 0; | 289 | hc->tx_arsent = 0; |
| 293 | } | 290 | } |
| 294 | } else { | 291 | } else { |
| 295 | /* we can't increase ack ratio further [1] */ | 292 | /* we can't increase ack ratio further [1] */ |
| 296 | hctx->ccid2hctx_arsent = 0; /* or maybe set it to cwnd*/ | 293 | hc->tx_arsent = 0; /* or maybe set it to cwnd*/ |
| 297 | } | 294 | } |
| 298 | } | 295 | } |
| 299 | #endif | 296 | #endif |
| 300 | 297 | ||
| 301 | /* setup RTO timer */ | 298 | /* setup RTO timer */ |
| 302 | if (!timer_pending(&hctx->ccid2hctx_rtotimer)) | 299 | if (!timer_pending(&hc->tx_rtotimer)) |
| 303 | ccid2_start_rto_timer(sk); | 300 | ccid2_start_rto_timer(sk); |
| 304 | 301 | ||
| 305 | #ifdef CONFIG_IP_DCCP_CCID2_DEBUG | 302 | #ifdef CONFIG_IP_DCCP_CCID2_DEBUG |
| 306 | do { | 303 | do { |
| 307 | struct ccid2_seq *seqp = hctx->ccid2hctx_seqt; | 304 | struct ccid2_seq *seqp = hc->tx_seqt; |
| 308 | 305 | ||
| 309 | while (seqp != hctx->ccid2hctx_seqh) { | 306 | while (seqp != hc->tx_seqh) { |
| 310 | ccid2_pr_debug("out seq=%llu acked=%d time=%lu\n", | 307 | ccid2_pr_debug("out seq=%llu acked=%d time=%lu\n", |
| 311 | (unsigned long long)seqp->ccid2s_seq, | 308 | (unsigned long long)seqp->ccid2s_seq, |
| 312 | seqp->ccid2s_acked, seqp->ccid2s_sent); | 309 | seqp->ccid2s_acked, seqp->ccid2s_sent); |
| @@ -314,7 +311,7 @@ static void ccid2_hc_tx_packet_sent(struct sock *sk, int more, unsigned int len) | |||
| 314 | } | 311 | } |
| 315 | } while (0); | 312 | } while (0); |
| 316 | ccid2_pr_debug("=========\n"); | 313 | ccid2_pr_debug("=========\n"); |
| 317 | ccid2_hc_tx_check_sanity(hctx); | 314 | ccid2_hc_tx_check_sanity(hc); |
| 318 | #endif | 315 | #endif |
| 319 | } | 316 | } |
| 320 | 317 | ||
| @@ -382,9 +379,9 @@ out_invalid_option: | |||
| 382 | 379 | ||
| 383 | static void ccid2_hc_tx_kill_rto_timer(struct sock *sk) | 380 | static void ccid2_hc_tx_kill_rto_timer(struct sock *sk) |
| 384 | { | 381 | { |
| 385 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 382 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 386 | 383 | ||
| 387 | sk_stop_timer(sk, &hctx->ccid2hctx_rtotimer); | 384 | sk_stop_timer(sk, &hc->tx_rtotimer); |
| 388 | ccid2_pr_debug("deleted RTO timer\n"); | 385 | ccid2_pr_debug("deleted RTO timer\n"); |
| 389 | } | 386 | } |
| 390 | 387 | ||
| @@ -392,75 +389,75 @@ static inline void ccid2_new_ack(struct sock *sk, | |||
| 392 | struct ccid2_seq *seqp, | 389 | struct ccid2_seq *seqp, |
| 393 | unsigned int *maxincr) | 390 | unsigned int *maxincr) |
| 394 | { | 391 | { |
| 395 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 392 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 396 | 393 | ||
| 397 | if (hctx->ccid2hctx_cwnd < hctx->ccid2hctx_ssthresh) { | 394 | if (hc->tx_cwnd < hc->tx_ssthresh) { |
| 398 | if (*maxincr > 0 && ++hctx->ccid2hctx_packets_acked == 2) { | 395 | if (*maxincr > 0 && ++hc->tx_packets_acked == 2) { |
| 399 | hctx->ccid2hctx_cwnd += 1; | 396 | hc->tx_cwnd += 1; |
| 400 | *maxincr -= 1; | 397 | *maxincr -= 1; |
| 401 | hctx->ccid2hctx_packets_acked = 0; | 398 | hc->tx_packets_acked = 0; |
| 402 | } | 399 | } |
| 403 | } else if (++hctx->ccid2hctx_packets_acked >= hctx->ccid2hctx_cwnd) { | 400 | } else if (++hc->tx_packets_acked >= hc->tx_cwnd) { |
| 404 | hctx->ccid2hctx_cwnd += 1; | 401 | hc->tx_cwnd += 1; |
| 405 | hctx->ccid2hctx_packets_acked = 0; | 402 | hc->tx_packets_acked = 0; |
| 406 | } | 403 | } |
| 407 | 404 | ||
| 408 | /* update RTO */ | 405 | /* update RTO */ |
| 409 | if (hctx->ccid2hctx_srtt == -1 || | 406 | if (hc->tx_srtt == -1 || |
| 410 | time_after(jiffies, hctx->ccid2hctx_lastrtt + hctx->ccid2hctx_srtt)) { | 407 | time_after(jiffies, hc->tx_lastrtt + hc->tx_srtt)) { |
| 411 | unsigned long r = (long)jiffies - (long)seqp->ccid2s_sent; | 408 | unsigned long r = (long)jiffies - (long)seqp->ccid2s_sent; |
| 412 | int s; | 409 | int s; |
| 413 | 410 | ||
| 414 | /* first measurement */ | 411 | /* first measurement */ |
| 415 | if (hctx->ccid2hctx_srtt == -1) { | 412 | if (hc->tx_srtt == -1) { |
| 416 | ccid2_pr_debug("R: %lu Time=%lu seq=%llu\n", | 413 | ccid2_pr_debug("R: %lu Time=%lu seq=%llu\n", |
| 417 | r, jiffies, | 414 | r, jiffies, |
| 418 | (unsigned long long)seqp->ccid2s_seq); | 415 | (unsigned long long)seqp->ccid2s_seq); |
| 419 | ccid2_change_srtt(hctx, r); | 416 | ccid2_change_srtt(hc, r); |
| 420 | hctx->ccid2hctx_rttvar = r >> 1; | 417 | hc->tx_rttvar = r >> 1; |
| 421 | } else { | 418 | } else { |
| 422 | /* RTTVAR */ | 419 | /* RTTVAR */ |
| 423 | long tmp = hctx->ccid2hctx_srtt - r; | 420 | long tmp = hc->tx_srtt - r; |
| 424 | long srtt; | 421 | long srtt; |
| 425 | 422 | ||
| 426 | if (tmp < 0) | 423 | if (tmp < 0) |
| 427 | tmp *= -1; | 424 | tmp *= -1; |
| 428 | 425 | ||
| 429 | tmp >>= 2; | 426 | tmp >>= 2; |
| 430 | hctx->ccid2hctx_rttvar *= 3; | 427 | hc->tx_rttvar *= 3; |
| 431 | hctx->ccid2hctx_rttvar >>= 2; | 428 | hc->tx_rttvar >>= 2; |
| 432 | hctx->ccid2hctx_rttvar += tmp; | 429 | hc->tx_rttvar += tmp; |
| 433 | 430 | ||
| 434 | /* SRTT */ | 431 | /* SRTT */ |
| 435 | srtt = hctx->ccid2hctx_srtt; | 432 | srtt = hc->tx_srtt; |
| 436 | srtt *= 7; | 433 | srtt *= 7; |
| 437 | srtt >>= 3; | 434 | srtt >>= 3; |
| 438 | tmp = r >> 3; | 435 | tmp = r >> 3; |
| 439 | srtt += tmp; | 436 | srtt += tmp; |
| 440 | ccid2_change_srtt(hctx, srtt); | 437 | ccid2_change_srtt(hc, srtt); |
| 441 | } | 438 | } |
| 442 | s = hctx->ccid2hctx_rttvar << 2; | 439 | s = hc->tx_rttvar << 2; |
| 443 | /* clock granularity is 1 when based on jiffies */ | 440 | /* clock granularity is 1 when based on jiffies */ |
| 444 | if (!s) | 441 | if (!s) |
| 445 | s = 1; | 442 | s = 1; |
| 446 | hctx->ccid2hctx_rto = hctx->ccid2hctx_srtt + s; | 443 | hc->tx_rto = hc->tx_srtt + s; |
| 447 | 444 | ||
| 448 | /* must be at least a second */ | 445 | /* must be at least a second */ |
| 449 | s = hctx->ccid2hctx_rto / HZ; | 446 | s = hc->tx_rto / HZ; |
| 450 | /* DCCP doesn't require this [but I like it cuz my code sux] */ | 447 | /* DCCP doesn't require this [but I like it cuz my code sux] */ |
| 451 | #if 1 | 448 | #if 1 |
| 452 | if (s < 1) | 449 | if (s < 1) |
| 453 | hctx->ccid2hctx_rto = HZ; | 450 | hc->tx_rto = HZ; |
| 454 | #endif | 451 | #endif |
| 455 | /* max 60 seconds */ | 452 | /* max 60 seconds */ |
| 456 | if (s > 60) | 453 | if (s > 60) |
| 457 | hctx->ccid2hctx_rto = HZ * 60; | 454 | hc->tx_rto = HZ * 60; |
| 458 | 455 | ||
| 459 | hctx->ccid2hctx_lastrtt = jiffies; | 456 | hc->tx_lastrtt = jiffies; |
| 460 | 457 | ||
| 461 | ccid2_pr_debug("srtt: %ld rttvar: %ld rto: %ld (HZ=%d) R=%lu\n", | 458 | ccid2_pr_debug("srtt: %ld rttvar: %ld rto: %ld (HZ=%d) R=%lu\n", |
| 462 | hctx->ccid2hctx_srtt, hctx->ccid2hctx_rttvar, | 459 | hc->tx_srtt, hc->tx_rttvar, |
| 463 | hctx->ccid2hctx_rto, HZ, r); | 460 | hc->tx_rto, HZ, r); |
| 464 | } | 461 | } |
| 465 | 462 | ||
| 466 | /* we got a new ack, so re-start RTO timer */ | 463 | /* we got a new ack, so re-start RTO timer */ |
| @@ -470,40 +467,40 @@ static inline void ccid2_new_ack(struct sock *sk, | |||
| 470 | 467 | ||
| 471 | static void ccid2_hc_tx_dec_pipe(struct sock *sk) | 468 | static void ccid2_hc_tx_dec_pipe(struct sock *sk) |
| 472 | { | 469 | { |
| 473 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 470 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 474 | 471 | ||
| 475 | if (hctx->ccid2hctx_pipe == 0) | 472 | if (hc->tx_pipe == 0) |
| 476 | DCCP_BUG("pipe == 0"); | 473 | DCCP_BUG("pipe == 0"); |
| 477 | else | 474 | else |
| 478 | hctx->ccid2hctx_pipe--; | 475 | hc->tx_pipe--; |
| 479 | 476 | ||
| 480 | if (hctx->ccid2hctx_pipe == 0) | 477 | if (hc->tx_pipe == 0) |
| 481 | ccid2_hc_tx_kill_rto_timer(sk); | 478 | ccid2_hc_tx_kill_rto_timer(sk); |
| 482 | } | 479 | } |
| 483 | 480 | ||
| 484 | static void ccid2_congestion_event(struct sock *sk, struct ccid2_seq *seqp) | 481 | static void ccid2_congestion_event(struct sock *sk, struct ccid2_seq *seqp) |
| 485 | { | 482 | { |
| 486 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 483 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 487 | 484 | ||
| 488 | if (time_before(seqp->ccid2s_sent, hctx->ccid2hctx_last_cong)) { | 485 | if (time_before(seqp->ccid2s_sent, hc->tx_last_cong)) { |
| 489 | ccid2_pr_debug("Multiple losses in an RTT---treating as one\n"); | 486 | ccid2_pr_debug("Multiple losses in an RTT---treating as one\n"); |
| 490 | return; | 487 | return; |
| 491 | } | 488 | } |
| 492 | 489 | ||
| 493 | hctx->ccid2hctx_last_cong = jiffies; | 490 | hc->tx_last_cong = jiffies; |
| 494 | 491 | ||
| 495 | hctx->ccid2hctx_cwnd = hctx->ccid2hctx_cwnd / 2 ? : 1U; | 492 | hc->tx_cwnd = hc->tx_cwnd / 2 ? : 1U; |
| 496 | hctx->ccid2hctx_ssthresh = max(hctx->ccid2hctx_cwnd, 2U); | 493 | hc->tx_ssthresh = max(hc->tx_cwnd, 2U); |
| 497 | 494 | ||
| 498 | /* Avoid spurious timeouts resulting from Ack Ratio > cwnd */ | 495 | /* Avoid spurious timeouts resulting from Ack Ratio > cwnd */ |
| 499 | if (dccp_sk(sk)->dccps_l_ack_ratio > hctx->ccid2hctx_cwnd) | 496 | if (dccp_sk(sk)->dccps_l_ack_ratio > hc->tx_cwnd) |
| 500 | ccid2_change_l_ack_ratio(sk, hctx->ccid2hctx_cwnd); | 497 | ccid2_change_l_ack_ratio(sk, hc->tx_cwnd); |
| 501 | } | 498 | } |
| 502 | 499 | ||
| 503 | static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | 500 | static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) |
| 504 | { | 501 | { |
| 505 | struct dccp_sock *dp = dccp_sk(sk); | 502 | struct dccp_sock *dp = dccp_sk(sk); |
| 506 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 503 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 507 | u64 ackno, seqno; | 504 | u64 ackno, seqno; |
| 508 | struct ccid2_seq *seqp; | 505 | struct ccid2_seq *seqp; |
| 509 | unsigned char *vector; | 506 | unsigned char *vector; |
| @@ -512,7 +509,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 512 | int done = 0; | 509 | int done = 0; |
| 513 | unsigned int maxincr = 0; | 510 | unsigned int maxincr = 0; |
| 514 | 511 | ||
| 515 | ccid2_hc_tx_check_sanity(hctx); | 512 | ccid2_hc_tx_check_sanity(hc); |
| 516 | /* check reverse path congestion */ | 513 | /* check reverse path congestion */ |
| 517 | seqno = DCCP_SKB_CB(skb)->dccpd_seq; | 514 | seqno = DCCP_SKB_CB(skb)->dccpd_seq; |
| 518 | 515 | ||
| @@ -521,21 +518,21 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 521 | * -sorbo. | 518 | * -sorbo. |
| 522 | */ | 519 | */ |
| 523 | /* need to bootstrap */ | 520 | /* need to bootstrap */ |
| 524 | if (hctx->ccid2hctx_rpdupack == -1) { | 521 | if (hc->tx_rpdupack == -1) { |
| 525 | hctx->ccid2hctx_rpdupack = 0; | 522 | hc->tx_rpdupack = 0; |
| 526 | hctx->ccid2hctx_rpseq = seqno; | 523 | hc->tx_rpseq = seqno; |
| 527 | } else { | 524 | } else { |
| 528 | /* check if packet is consecutive */ | 525 | /* check if packet is consecutive */ |
| 529 | if (dccp_delta_seqno(hctx->ccid2hctx_rpseq, seqno) == 1) | 526 | if (dccp_delta_seqno(hc->tx_rpseq, seqno) == 1) |
| 530 | hctx->ccid2hctx_rpseq = seqno; | 527 | hc->tx_rpseq = seqno; |
| 531 | /* it's a later packet */ | 528 | /* it's a later packet */ |
| 532 | else if (after48(seqno, hctx->ccid2hctx_rpseq)) { | 529 | else if (after48(seqno, hc->tx_rpseq)) { |
| 533 | hctx->ccid2hctx_rpdupack++; | 530 | hc->tx_rpdupack++; |
| 534 | 531 | ||
| 535 | /* check if we got enough dupacks */ | 532 | /* check if we got enough dupacks */ |
| 536 | if (hctx->ccid2hctx_rpdupack >= NUMDUPACK) { | 533 | if (hc->tx_rpdupack >= NUMDUPACK) { |
| 537 | hctx->ccid2hctx_rpdupack = -1; /* XXX lame */ | 534 | hc->tx_rpdupack = -1; /* XXX lame */ |
| 538 | hctx->ccid2hctx_rpseq = 0; | 535 | hc->tx_rpseq = 0; |
| 539 | 536 | ||
| 540 | ccid2_change_l_ack_ratio(sk, 2 * dp->dccps_l_ack_ratio); | 537 | ccid2_change_l_ack_ratio(sk, 2 * dp->dccps_l_ack_ratio); |
| 541 | } | 538 | } |
| @@ -544,7 +541,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 544 | 541 | ||
| 545 | /* check forward path congestion */ | 542 | /* check forward path congestion */ |
| 546 | /* still didn't send out new data packets */ | 543 | /* still didn't send out new data packets */ |
| 547 | if (hctx->ccid2hctx_seqh == hctx->ccid2hctx_seqt) | 544 | if (hc->tx_seqh == hc->tx_seqt) |
| 548 | return; | 545 | return; |
| 549 | 546 | ||
| 550 | switch (DCCP_SKB_CB(skb)->dccpd_type) { | 547 | switch (DCCP_SKB_CB(skb)->dccpd_type) { |
| @@ -556,14 +553,14 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 556 | } | 553 | } |
| 557 | 554 | ||
| 558 | ackno = DCCP_SKB_CB(skb)->dccpd_ack_seq; | 555 | ackno = DCCP_SKB_CB(skb)->dccpd_ack_seq; |
| 559 | if (after48(ackno, hctx->ccid2hctx_high_ack)) | 556 | if (after48(ackno, hc->tx_high_ack)) |
| 560 | hctx->ccid2hctx_high_ack = ackno; | 557 | hc->tx_high_ack = ackno; |
| 561 | 558 | ||
| 562 | seqp = hctx->ccid2hctx_seqt; | 559 | seqp = hc->tx_seqt; |
| 563 | while (before48(seqp->ccid2s_seq, ackno)) { | 560 | while (before48(seqp->ccid2s_seq, ackno)) { |
| 564 | seqp = seqp->ccid2s_next; | 561 | seqp = seqp->ccid2s_next; |
| 565 | if (seqp == hctx->ccid2hctx_seqh) { | 562 | if (seqp == hc->tx_seqh) { |
| 566 | seqp = hctx->ccid2hctx_seqh->ccid2s_prev; | 563 | seqp = hc->tx_seqh->ccid2s_prev; |
| 567 | break; | 564 | break; |
| 568 | } | 565 | } |
| 569 | } | 566 | } |
| @@ -573,7 +570,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 573 | * packets per acknowledgement. Rounding up avoids that cwnd is not | 570 | * packets per acknowledgement. Rounding up avoids that cwnd is not |
| 574 | * advanced when Ack Ratio is 1 and gives a slight edge otherwise. | 571 | * advanced when Ack Ratio is 1 and gives a slight edge otherwise. |
| 575 | */ | 572 | */ |
| 576 | if (hctx->ccid2hctx_cwnd < hctx->ccid2hctx_ssthresh) | 573 | if (hc->tx_cwnd < hc->tx_ssthresh) |
| 577 | maxincr = DIV_ROUND_UP(dp->dccps_l_ack_ratio, 2); | 574 | maxincr = DIV_ROUND_UP(dp->dccps_l_ack_ratio, 2); |
| 578 | 575 | ||
| 579 | /* go through all ack vectors */ | 576 | /* go through all ack vectors */ |
| @@ -592,7 +589,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 592 | * seqnos. | 589 | * seqnos. |
| 593 | */ | 590 | */ |
| 594 | while (after48(seqp->ccid2s_seq, ackno)) { | 591 | while (after48(seqp->ccid2s_seq, ackno)) { |
| 595 | if (seqp == hctx->ccid2hctx_seqt) { | 592 | if (seqp == hc->tx_seqt) { |
| 596 | done = 1; | 593 | done = 1; |
| 597 | break; | 594 | break; |
| 598 | } | 595 | } |
| @@ -624,7 +621,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 624 | (unsigned long long)seqp->ccid2s_seq); | 621 | (unsigned long long)seqp->ccid2s_seq); |
| 625 | ccid2_hc_tx_dec_pipe(sk); | 622 | ccid2_hc_tx_dec_pipe(sk); |
| 626 | } | 623 | } |
| 627 | if (seqp == hctx->ccid2hctx_seqt) { | 624 | if (seqp == hc->tx_seqt) { |
| 628 | done = 1; | 625 | done = 1; |
| 629 | break; | 626 | break; |
| 630 | } | 627 | } |
| @@ -643,11 +640,11 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 643 | /* The state about what is acked should be correct now | 640 | /* The state about what is acked should be correct now |
| 644 | * Check for NUMDUPACK | 641 | * Check for NUMDUPACK |
| 645 | */ | 642 | */ |
| 646 | seqp = hctx->ccid2hctx_seqt; | 643 | seqp = hc->tx_seqt; |
| 647 | while (before48(seqp->ccid2s_seq, hctx->ccid2hctx_high_ack)) { | 644 | while (before48(seqp->ccid2s_seq, hc->tx_high_ack)) { |
| 648 | seqp = seqp->ccid2s_next; | 645 | seqp = seqp->ccid2s_next; |
| 649 | if (seqp == hctx->ccid2hctx_seqh) { | 646 | if (seqp == hc->tx_seqh) { |
| 650 | seqp = hctx->ccid2hctx_seqh->ccid2s_prev; | 647 | seqp = hc->tx_seqh->ccid2s_prev; |
| 651 | break; | 648 | break; |
| 652 | } | 649 | } |
| 653 | } | 650 | } |
| @@ -658,7 +655,7 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 658 | if (done == NUMDUPACK) | 655 | if (done == NUMDUPACK) |
| 659 | break; | 656 | break; |
| 660 | } | 657 | } |
| 661 | if (seqp == hctx->ccid2hctx_seqt) | 658 | if (seqp == hc->tx_seqt) |
| 662 | break; | 659 | break; |
| 663 | seqp = seqp->ccid2s_prev; | 660 | seqp = seqp->ccid2s_prev; |
| 664 | } | 661 | } |
| @@ -681,86 +678,86 @@ static void ccid2_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb) | |||
| 681 | ccid2_congestion_event(sk, seqp); | 678 | ccid2_congestion_event(sk, seqp); |
| 682 | ccid2_hc_tx_dec_pipe(sk); | 679 | ccid2_hc_tx_dec_pipe(sk); |
| 683 | } | 680 | } |
| 684 | if (seqp == hctx->ccid2hctx_seqt) | 681 | if (seqp == hc->tx_seqt) |
| 685 | break; | 682 | break; |
| 686 | seqp = seqp->ccid2s_prev; | 683 | seqp = seqp->ccid2s_prev; |
| 687 | } | 684 | } |
| 688 | 685 | ||
| 689 | hctx->ccid2hctx_seqt = last_acked; | 686 | hc->tx_seqt = last_acked; |
| 690 | } | 687 | } |
| 691 | 688 | ||
| 692 | /* trim acked packets in tail */ | 689 | /* trim acked packets in tail */ |
| 693 | while (hctx->ccid2hctx_seqt != hctx->ccid2hctx_seqh) { | 690 | while (hc->tx_seqt != hc->tx_seqh) { |
| 694 | if (!hctx->ccid2hctx_seqt->ccid2s_acked) | 691 | if (!hc->tx_seqt->ccid2s_acked) |
| 695 | break; | 692 | break; |
| 696 | 693 | ||
| 697 | hctx->ccid2hctx_seqt = hctx->ccid2hctx_seqt->ccid2s_next; | 694 | hc->tx_seqt = hc->tx_seqt->ccid2s_next; |
| 698 | } | 695 | } |
| 699 | 696 | ||
| 700 | ccid2_hc_tx_check_sanity(hctx); | 697 | ccid2_hc_tx_check_sanity(hc); |
| 701 | } | 698 | } |
| 702 | 699 | ||
| 703 | static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk) | 700 | static int ccid2_hc_tx_init(struct ccid *ccid, struct sock *sk) |
| 704 | { | 701 | { |
| 705 | struct ccid2_hc_tx_sock *hctx = ccid_priv(ccid); | 702 | struct ccid2_hc_tx_sock *hc = ccid_priv(ccid); |
| 706 | struct dccp_sock *dp = dccp_sk(sk); | 703 | struct dccp_sock *dp = dccp_sk(sk); |
| 707 | u32 max_ratio; | 704 | u32 max_ratio; |
| 708 | 705 | ||
| 709 | /* RFC 4341, 5: initialise ssthresh to arbitrarily high (max) value */ | 706 | /* RFC 4341, 5: initialise ssthresh to arbitrarily high (max) value */ |
| 710 | hctx->ccid2hctx_ssthresh = ~0U; | 707 | hc->tx_ssthresh = ~0U; |
| 711 | 708 | ||
| 712 | /* | 709 | /* |
| 713 | * RFC 4341, 5: "The cwnd parameter is initialized to at most four | 710 | * RFC 4341, 5: "The cwnd parameter is initialized to at most four |
| 714 | * packets for new connections, following the rules from [RFC3390]". | 711 | * packets for new connections, following the rules from [RFC3390]". |
| 715 | * We need to convert the bytes of RFC3390 into the packets of RFC 4341. | 712 | * We need to convert the bytes of RFC3390 into the packets of RFC 4341. |
| 716 | */ | 713 | */ |
| 717 | hctx->ccid2hctx_cwnd = clamp(4380U / dp->dccps_mss_cache, 2U, 4U); | 714 | hc->tx_cwnd = clamp(4380U / dp->dccps_mss_cache, 2U, 4U); |
| 718 | 715 | ||
| 719 | /* Make sure that Ack Ratio is enabled and within bounds. */ | 716 | /* Make sure that Ack Ratio is enabled and within bounds. */ |
| 720 | max_ratio = DIV_ROUND_UP(hctx->ccid2hctx_cwnd, 2); | 717 | max_ratio = DIV_ROUND_UP(hc->tx_cwnd, 2); |
| 721 | if (dp->dccps_l_ack_ratio == 0 || dp->dccps_l_ack_ratio > max_ratio) | 718 | if (dp->dccps_l_ack_ratio == 0 || dp->dccps_l_ack_ratio > max_ratio) |
| 722 | dp->dccps_l_ack_ratio = max_ratio; | 719 | dp->dccps_l_ack_ratio = max_ratio; |
| 723 | 720 | ||
| 724 | /* XXX init ~ to window size... */ | 721 | /* XXX init ~ to window size... */ |
| 725 | if (ccid2_hc_tx_alloc_seq(hctx)) | 722 | if (ccid2_hc_tx_alloc_seq(hc)) |
| 726 | return -ENOMEM; | 723 | return -ENOMEM; |
| 727 | 724 | ||
| 728 | hctx->ccid2hctx_rto = 3 * HZ; | 725 | hc->tx_rto = 3 * HZ; |
| 729 | ccid2_change_srtt(hctx, -1); | 726 | ccid2_change_srtt(hc, -1); |
| 730 | hctx->ccid2hctx_rttvar = -1; | 727 | hc->tx_rttvar = -1; |
| 731 | hctx->ccid2hctx_rpdupack = -1; | 728 | hc->tx_rpdupack = -1; |
| 732 | hctx->ccid2hctx_last_cong = jiffies; | 729 | hc->tx_last_cong = jiffies; |
| 733 | setup_timer(&hctx->ccid2hctx_rtotimer, ccid2_hc_tx_rto_expire, | 730 | setup_timer(&hc->tx_rtotimer, ccid2_hc_tx_rto_expire, |
| 734 | (unsigned long)sk); | 731 | (unsigned long)sk); |
| 735 | 732 | ||
| 736 | ccid2_hc_tx_check_sanity(hctx); | 733 | ccid2_hc_tx_check_sanity(hc); |
| 737 | return 0; | 734 | return 0; |
| 738 | } | 735 | } |
| 739 | 736 | ||
| 740 | static void ccid2_hc_tx_exit(struct sock *sk) | 737 | static void ccid2_hc_tx_exit(struct sock *sk) |
| 741 | { | 738 | { |
| 742 | struct ccid2_hc_tx_sock *hctx = ccid2_hc_tx_sk(sk); | 739 | struct ccid2_hc_tx_sock *hc = ccid2_hc_tx_sk(sk); |
| 743 | int i; | 740 | int i; |
| 744 | 741 | ||
| 745 | ccid2_hc_tx_kill_rto_timer(sk); | 742 | ccid2_hc_tx_kill_rto_timer(sk); |
| 746 | 743 | ||
| 747 | for (i = 0; i < hctx->ccid2hctx_seqbufc; i++) | 744 | for (i = 0; i < hc->tx_seqbufc; i++) |
| 748 | kfree(hctx->ccid2hctx_seqbuf[i]); | 745 | kfree(hc->tx_seqbuf[i]); |
| 749 | hctx->ccid2hctx_seqbufc = 0; | 746 | hc->tx_seqbufc = 0; |
| 750 | } | 747 | } |
| 751 | 748 | ||
| 752 | static void ccid2_hc_rx_packet_recv(struct sock *sk, struct sk_buff *skb) | 749 | static void ccid2_hc_rx_packet_recv(struct sock *sk, struct sk_buff *skb) |
| 753 | { | 750 | { |
| 754 | const struct dccp_sock *dp = dccp_sk(sk); | 751 | const struct dccp_sock *dp = dccp_sk(sk); |
| 755 | struct ccid2_hc_rx_sock *hcrx = ccid2_hc_rx_sk(sk); | 752 | struct ccid2_hc_rx_sock *hc = ccid2_hc_rx_sk(sk); |
| 756 | 753 | ||
| 757 | switch (DCCP_SKB_CB(skb)->dccpd_type) { | 754 | switch (DCCP_SKB_CB(skb)->dccpd_type) { |
| 758 | case DCCP_PKT_DATA: | 755 | case DCCP_PKT_DATA: |
| 759 | case DCCP_PKT_DATAACK: | 756 | case DCCP_PKT_DATAACK: |
| 760 | hcrx->ccid2hcrx_data++; | 757 | hc->rx_data++; |
| 761 | if (hcrx->ccid2hcrx_data >= dp->dccps_r_ack_ratio) { | 758 | if (hc->rx_data >= dp->dccps_r_ack_ratio) { |
| 762 | dccp_send_ack(sk); | 759 | dccp_send_ack(sk); |
| 763 | hcrx->ccid2hcrx_data = 0; | 760 | hc->rx_data = 0; |
| 764 | } | 761 | } |
| 765 | break; | 762 | break; |
| 766 | } | 763 | } |
