blob: cd9b9ffe2ec4aae74d3f1f065eb304157dc305e2 [file] [log] [blame]
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -07001/*
2 * net/dccp/ccids/ccid3.c
3 *
Gerrit Renker954c2db2007-12-12 14:06:14 -02004 * Copyright (c) 2007 The University of Aberdeen, Scotland, UK
Ian McDonaldb2f41ff2007-05-28 12:23:29 -03005 * Copyright (c) 2005-7 The University of Waikato, Hamilton, New Zealand.
6 * Copyright (c) 2005-7 Ian McDonald <ian.mcdonald@jandi.co.nz>
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -07007 *
8 * An implementation of the DCCP protocol
9 *
10 * This code has been developed by the University of Waikato WAND
11 * research group. For further information please see http://www.wand.net.nz/
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070012 *
13 * This code also uses code from Lulea University, rereleased as GPL by its
14 * authors:
15 * Copyright (c) 2003 Nils-Erik Mattsson, Joacim Haggmark, Magnus Erixzon
16 *
17 * Changes to meet Linux coding standards, to make it meet latest ccid3 draft
18 * and to make it work as a loadable module in the DCCP stack written by
19 * Arnaldo Carvalho de Melo <acme@conectiva.com.br>.
20 *
21 * Copyright (c) 2005 Arnaldo Carvalho de Melo <acme@conectiva.com.br>
22 *
23 * This program is free software; you can redistribute it and/or modify
24 * it under the terms of the GNU General Public License as published by
25 * the Free Software Foundation; either version 2 of the License, or
26 * (at your option) any later version.
27 *
28 * This program is distributed in the hope that it will be useful,
29 * but WITHOUT ANY WARRANTY; without even the implied warranty of
30 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
31 * GNU General Public License for more details.
32 *
33 * You should have received a copy of the GNU General Public License
34 * along with this program; if not, write to the Free Software
35 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
36 */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070037#include "../dccp.h"
38#include "ccid3.h"
39
Gerrit Renker76fd1e82007-10-24 10:46:58 -020040#include <asm/unaligned.h>
41
Gerrit Renker56724aa2006-11-20 18:28:09 -020042#ifdef CONFIG_IP_DCCP_CCID3_DEBUG
43static int ccid3_debug;
44#define ccid3_pr_debug(format, a...) DCCP_PR_DEBUG(ccid3_debug, format, ##a)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070045#else
46#define ccid3_pr_debug(format, a...)
47#endif
48
Gerrit Renker9bf17472007-03-20 13:11:24 -030049/*
50 * Transmitter Half-Connection Routines
51 */
Gerrit Renker56724aa2006-11-20 18:28:09 -020052#ifdef CONFIG_IP_DCCP_CCID3_DEBUG
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070053static const char *ccid3_tx_state_name(enum ccid3_hc_tx_states state)
54{
55 static char *ccid3_state_names[] = {
56 [TFRC_SSTATE_NO_SENT] = "NO_SENT",
57 [TFRC_SSTATE_NO_FBACK] = "NO_FBACK",
58 [TFRC_SSTATE_FBACK] = "FBACK",
59 [TFRC_SSTATE_TERM] = "TERM",
60 };
61
62 return ccid3_state_names[state];
63}
64#endif
65
Arnaldo Carvalho de Meloc25a18b2006-03-20 21:58:56 -080066static void ccid3_hc_tx_set_state(struct sock *sk,
67 enum ccid3_hc_tx_states state)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070068{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -030069 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070070 enum ccid3_hc_tx_states oldstate = hctx->ccid3hctx_state;
71
72 ccid3_pr_debug("%s(%p) %-8.8s -> %s\n",
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -030073 dccp_role(sk), sk, ccid3_tx_state_name(oldstate),
74 ccid3_tx_state_name(state));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -070075 WARN_ON(state == oldstate);
76 hctx->ccid3hctx_state = state;
77}
78
Gerrit Renker17893bc2006-11-27 20:31:33 -020079/*
Gerrit Renker6c08b2c2007-11-20 17:33:17 -020080 * Compute the initial sending rate X_init in the manner of RFC 3390:
81 *
82 * X_init = min(4 * s, max(2 * s, 4380 bytes)) / RTT
83 *
84 * Note that RFC 3390 uses MSS, RFC 4342 refers to RFC 3390, and rfc3448bis
85 * (rev-02) clarifies the use of RFC 3390 with regard to the above formula.
Gerrit Renkera21f9f92007-03-20 15:12:10 -030086 * For consistency with other parts of the code, X_init is scaled by 2^6.
87 */
88static inline u64 rfc3390_initial_rate(struct sock *sk)
89{
Gerrit Renker6c08b2c2007-11-20 17:33:17 -020090 const struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
91 const __u32 w_init = min_t(__u32, 4 * hctx->ccid3hctx_s,
92 max_t(__u32, 2 * hctx->ccid3hctx_s, 4380));
Gerrit Renkera21f9f92007-03-20 15:12:10 -030093
Gerrit Renker6c08b2c2007-11-20 17:33:17 -020094 return scaled_div(w_init << 6, hctx->ccid3hctx_rtt);
Gerrit Renkera21f9f92007-03-20 15:12:10 -030095}
96
97/*
Gerrit Renker1266ade2007-03-20 14:56:11 -030098 * Recalculate t_ipi and delta (should be called whenever X changes)
Gerrit Renker17893bc2006-11-27 20:31:33 -020099 */
Gerrit Renker1266ade2007-03-20 14:56:11 -0300100static inline void ccid3_update_send_interval(struct ccid3_hc_tx_sock *hctx)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700101{
Gerrit Renker1a21e492006-12-10 00:02:12 -0200102 /* Calculate new t_ipi = s / X_inst (X_inst is in 64 * bytes/second) */
Gerrit Renkerb2449fd2007-04-20 13:02:55 -0700103 hctx->ccid3hctx_t_ipi = scaled_div32(((u64)hctx->ccid3hctx_s) << 6,
104 hctx->ccid3hctx_x);
Gerrit Renker17893bc2006-11-27 20:31:33 -0200105
Gerrit Renker17893bc2006-11-27 20:31:33 -0200106 /* Calculate new delta by delta = min(t_ipi / 2, t_gran / 2) */
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300107 hctx->ccid3hctx_delta = min_t(u32, hctx->ccid3hctx_t_ipi / 2,
108 TFRC_OPSYS_HALF_TIME_GRAN);
Ian McDonald8699be72007-03-20 14:49:20 -0300109
Gerrit Renker1761f7d2007-03-20 15:04:30 -0300110 ccid3_pr_debug("t_ipi=%u, delta=%u, s=%u, X=%u\n",
Ian McDonald8699be72007-03-20 14:49:20 -0300111 hctx->ccid3hctx_t_ipi, hctx->ccid3hctx_delta,
Gerrit Renker1761f7d2007-03-20 15:04:30 -0300112 hctx->ccid3hctx_s, (unsigned)(hctx->ccid3hctx_x >> 6));
Ian McDonald8699be72007-03-20 14:49:20 -0300113
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700114}
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700115
Gerrit Renkera5358fd2007-11-20 18:01:59 -0200116static u32 ccid3_hc_tx_idle_rtt(struct ccid3_hc_tx_sock *hctx, ktime_t now)
117{
118 u32 delta = ktime_us_delta(now, hctx->ccid3hctx_t_last_win_count);
119
120 return delta / hctx->ccid3hctx_rtt;
121}
122
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700123/**
124 * ccid3_hc_tx_update_x - Update allowed sending rate X
125 * @stamp: most recent time if available - can be left NULL.
126 * This function tracks draft rfc3448bis, check there for latest details.
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200127 *
Gerrit Renker1a21e492006-12-10 00:02:12 -0200128 * Note: X and X_recv are both stored in units of 64 * bytes/second, to support
129 * fine-grained resolution of sending rates. This requires scaling by 2^6
130 * throughout the code. Only X_calc is unscaled (in bytes/second).
131 *
Gerrit Renker1a21e492006-12-10 00:02:12 -0200132 */
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700133static void ccid3_hc_tx_update_x(struct sock *sk, ktime_t *stamp)
Gerrit Renkera79ef762006-11-28 19:51:42 -0200134
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700135{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300136 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300137 __u64 min_rate = 2 * hctx->ccid3hctx_x_recv;
Gerrit Renker1a21e492006-12-10 00:02:12 -0200138 const __u64 old_x = hctx->ccid3hctx_x;
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700139 ktime_t now = stamp? *stamp : ktime_get_real();
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700140
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300141 /*
142 * Handle IDLE periods: do not reduce below RFC3390 initial sending rate
Gerrit Renkera5358fd2007-11-20 18:01:59 -0200143 * when idling [RFC 4342, 5.1]. Definition of idling is from rfc3448bis:
144 * a sender is idle if it has not sent anything over a 2-RTT-period.
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300145 * For consistency with X and X_recv, min_rate is also scaled by 2^6.
146 */
Gerrit Renkera5358fd2007-11-20 18:01:59 -0200147 if (ccid3_hc_tx_idle_rtt(hctx, now) >= 2) {
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300148 min_rate = rfc3390_initial_rate(sk);
149 min_rate = max(min_rate, 2 * hctx->ccid3hctx_x_recv);
150 }
151
Gerrit Renker44158302006-12-03 14:53:07 -0200152 if (hctx->ccid3hctx_p > 0) {
Gerrit Renker1a21e492006-12-10 00:02:12 -0200153
Gerrit Renker9e8efc82006-12-10 00:24:57 -0200154 hctx->ccid3hctx_x = min(((__u64)hctx->ccid3hctx_x_calc) << 6,
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300155 min_rate);
Gerrit Renker9e8efc82006-12-10 00:24:57 -0200156 hctx->ccid3hctx_x = max(hctx->ccid3hctx_x,
157 (((__u64)hctx->ccid3hctx_s) << 6) /
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200158 TFRC_T_MBI);
Arnaldo Carvalho de Melob6ee3d42005-08-27 18:18:18 -0300159
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700160 } else if (ktime_us_delta(now, hctx->ccid3hctx_t_ld)
161 - (s64)hctx->ccid3hctx_rtt >= 0) {
Gerrit Renker1a21e492006-12-10 00:02:12 -0200162
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700163 hctx->ccid3hctx_x =
164 max(min(2 * hctx->ccid3hctx_x, min_rate),
165 scaled_div(((__u64)hctx->ccid3hctx_s) << 6,
166 hctx->ccid3hctx_rtt));
167 hctx->ccid3hctx_t_ld = now;
Gerrit Renkerff586292006-12-10 00:00:14 -0200168 }
Gerrit Renkera79ef762006-11-28 19:51:42 -0200169
Ian McDonald8699be72007-03-20 14:49:20 -0300170 if (hctx->ccid3hctx_x != old_x) {
Gerrit Renker1761f7d2007-03-20 15:04:30 -0300171 ccid3_pr_debug("X_prev=%u, X_now=%u, X_calc=%u, "
172 "X_recv=%u\n", (unsigned)(old_x >> 6),
173 (unsigned)(hctx->ccid3hctx_x >> 6),
174 hctx->ccid3hctx_x_calc,
175 (unsigned)(hctx->ccid3hctx_x_recv >> 6));
Ian McDonald8699be72007-03-20 14:49:20 -0300176
Gerrit Renker1266ade2007-03-20 14:56:11 -0300177 ccid3_update_send_interval(hctx);
Ian McDonald8699be72007-03-20 14:49:20 -0300178 }
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700179}
180
Gerrit Renker78ad7132006-11-28 19:22:33 -0200181/*
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200182 * Track the mean packet size `s' (cf. RFC 4342, 5.3 and RFC 3448, 4.1)
183 * @len: DCCP packet payload size in bytes
Gerrit Renker78ad7132006-11-28 19:22:33 -0200184 */
185static inline void ccid3_hc_tx_update_s(struct ccid3_hc_tx_sock *hctx, int len)
186{
Gerrit Renker1266ade2007-03-20 14:56:11 -0300187 const u16 old_s = hctx->ccid3hctx_s;
188
Gerrit Renkerc3ada462007-11-20 18:09:59 -0200189 hctx->ccid3hctx_s = tfrc_ewma(hctx->ccid3hctx_s, len, 9);
Gerrit Renker1266ade2007-03-20 14:56:11 -0300190
191 if (hctx->ccid3hctx_s != old_s)
192 ccid3_update_send_interval(hctx);
Gerrit Renker78ad7132006-11-28 19:22:33 -0200193}
194
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200195/*
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200196 * Update Window Counter using the algorithm from [RFC 4342, 8.1].
197 * The algorithm is not applicable if RTT < 4 microseconds.
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200198 */
199static inline void ccid3_hc_tx_update_win_count(struct ccid3_hc_tx_sock *hctx,
Gerrit Renker8132da42007-06-16 13:34:02 -0300200 ktime_t now)
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200201{
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200202 u32 quarter_rtts;
203
204 if (unlikely(hctx->ccid3hctx_rtt < 4)) /* avoid divide-by-zero */
205 return;
206
Gerrit Renker8132da42007-06-16 13:34:02 -0300207 quarter_rtts = ktime_us_delta(now, hctx->ccid3hctx_t_last_win_count);
208 quarter_rtts /= hctx->ccid3hctx_rtt / 4;
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200209
210 if (quarter_rtts > 0) {
Gerrit Renker8132da42007-06-16 13:34:02 -0300211 hctx->ccid3hctx_t_last_win_count = now;
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200212 hctx->ccid3hctx_last_win_count += min_t(u32, quarter_rtts, 5);
213 hctx->ccid3hctx_last_win_count &= 0xF; /* mod 16 */
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200214 }
215}
216
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700217static void ccid3_hc_tx_no_feedback_timer(unsigned long data)
218{
219 struct sock *sk = (struct sock *)data;
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300220 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Gerrit Renker2a1fda62006-11-28 18:34:34 -0200221 unsigned long t_nfb = USEC_PER_SEC / 5;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700222
223 bh_lock_sock(sk);
224 if (sock_owned_by_user(sk)) {
225 /* Try again later. */
226 /* XXX: set some sensible MIB */
Gerrit Renker48e03ee2006-11-27 20:29:27 -0200227 goto restart_timer;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700228 }
229
Gerrit Renkera9672412006-12-10 00:14:12 -0200230 ccid3_pr_debug("%s(%p, state=%s) - entry \n", dccp_role(sk), sk,
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700231 ccid3_tx_state_name(hctx->ccid3hctx_state));
Gerrit Renkera9672412006-12-10 00:14:12 -0200232
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700233 switch (hctx->ccid3hctx_state) {
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700234 case TFRC_SSTATE_NO_FBACK:
Gerrit Renkera79ef762006-11-28 19:51:42 -0200235 /* RFC 3448, 4.4: Halve send rate directly */
Gerrit Renker9e8efc82006-12-10 00:24:57 -0200236 hctx->ccid3hctx_x = max(hctx->ccid3hctx_x / 2,
237 (((__u64)hctx->ccid3hctx_s) << 6) /
238 TFRC_T_MBI);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700239
Gerrit Renkera9672412006-12-10 00:14:12 -0200240 ccid3_pr_debug("%s(%p, state=%s), updated tx rate to %u "
241 "bytes/s\n", dccp_role(sk), sk,
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300242 ccid3_tx_state_name(hctx->ccid3hctx_state),
Gerrit Renker1a21e492006-12-10 00:02:12 -0200243 (unsigned)(hctx->ccid3hctx_x >> 6));
Gerrit Renker48e03ee2006-11-27 20:29:27 -0200244 /* The value of R is still undefined and so we can not recompute
Joe Perches5e8e0342007-12-20 13:59:39 -0800245 * the timeout value. Keep initial value as per [RFC 4342, 5]. */
Gerrit Renker2a1fda62006-11-28 18:34:34 -0200246 t_nfb = TFRC_INITIAL_TIMEOUT;
Gerrit Renker1266ade2007-03-20 14:56:11 -0300247 ccid3_update_send_interval(hctx);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700248 break;
249 case TFRC_SSTATE_FBACK:
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300250 /*
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300251 * Modify the cached value of X_recv [RFC 3448, 4.4]
252 *
253 * If (p == 0 || X_calc > 2 * X_recv)
254 * X_recv = max(X_recv / 2, s / (2 * t_mbi));
255 * Else
256 * X_recv = X_calc / 4;
257 *
258 * Note that X_recv is scaled by 2^6 while X_calc is not
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300259 */
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300260 BUG_ON(hctx->ccid3hctx_p && !hctx->ccid3hctx_x_calc);
Gerrit Renkera79ef762006-11-28 19:51:42 -0200261
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300262 if (hctx->ccid3hctx_p == 0 ||
263 (hctx->ccid3hctx_x_calc > (hctx->ccid3hctx_x_recv >> 5))) {
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700264
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300265 hctx->ccid3hctx_x_recv =
266 max(hctx->ccid3hctx_x_recv / 2,
267 (((__u64)hctx->ccid3hctx_s) << 6) /
268 (2 * TFRC_T_MBI));
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300269 } else {
270 hctx->ccid3hctx_x_recv = hctx->ccid3hctx_x_calc;
271 hctx->ccid3hctx_x_recv <<= 4;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700272 }
Gerrit Renker0c150ef2007-03-20 15:19:07 -0300273 /* Now recalculate X [RFC 3448, 4.3, step (4)] */
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700274 ccid3_hc_tx_update_x(sk, NULL);
Arnaldo Carvalho de Melo6b5e6332005-08-27 20:11:28 -0300275 /*
276 * Schedule no feedback timer to expire in
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200277 * max(t_RTO, 2 * s/X) = max(t_RTO, 2 * t_ipi)
278 * See comments in packet_recv() regarding the value of t_RTO.
Arnaldo Carvalho de Melo6b5e6332005-08-27 20:11:28 -0300279 */
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200280 t_nfb = max(hctx->ccid3hctx_t_rto, 2 * hctx->ccid3hctx_t_ipi);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700281 break;
Gerrit Renker59348b12006-11-20 18:39:23 -0200282 case TFRC_SSTATE_NO_SENT:
Gerrit Renkera9672412006-12-10 00:14:12 -0200283 DCCP_BUG("%s(%p) - Illegal state NO_SENT", dccp_role(sk), sk);
Gerrit Renker59348b12006-11-20 18:39:23 -0200284 /* fall through */
285 case TFRC_SSTATE_TERM:
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700286 goto out;
287 }
288
Gerrit Renker48e03ee2006-11-27 20:29:27 -0200289restart_timer:
290 sk_reset_timer(sk, &hctx->ccid3hctx_no_feedback_timer,
YOSHIFUJI Hideakic9eaf172007-02-09 23:24:38 +0900291 jiffies + usecs_to_jiffies(t_nfb));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700292out:
293 bh_unlock_sock(sk);
294 sock_put(sk);
295}
296
Gerrit Renker7da7f452006-11-27 12:26:03 -0200297/*
298 * returns
299 * > 0: delay (in msecs) that should pass before actually sending
300 * = 0: can send immediately
301 * < 0: error condition; do not send packet
302 */
Gerrit Renker6b57c932006-11-28 19:55:06 -0200303static int ccid3_hc_tx_send_packet(struct sock *sk, struct sk_buff *skb)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700304{
305 struct dccp_sock *dp = dccp_sk(sk);
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300306 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Gerrit Renker8132da42007-06-16 13:34:02 -0300307 ktime_t now = ktime_get_real();
308 s64 delay;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700309
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700310 /*
Gerrit Renkerda335ba2006-11-27 12:26:57 -0200311 * This function is called only for Data and DataAck packets. Sending
312 * zero-sized Data(Ack)s is theoretically possible, but for congestion
313 * control this case is pathological - ignore it.
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700314 */
Gerrit Renker6b57c932006-11-28 19:55:06 -0200315 if (unlikely(skb->len == 0))
Gerrit Renkerda335ba2006-11-27 12:26:57 -0200316 return -EBADMSG;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700317
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700318 switch (hctx->ccid3hctx_state) {
319 case TFRC_SSTATE_NO_SENT:
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300320 sk_reset_timer(sk, &hctx->ccid3hctx_no_feedback_timer,
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200321 (jiffies +
YOSHIFUJI Hideakic9eaf172007-02-09 23:24:38 +0900322 usecs_to_jiffies(TFRC_INITIAL_TIMEOUT)));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700323 hctx->ccid3hctx_last_win_count = 0;
324 hctx->ccid3hctx_t_last_win_count = now;
Gerrit Renker90feeb92006-11-27 12:13:38 -0200325
326 /* Set t_0 for initial packet */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700327 hctx->ccid3hctx_t_nom = now;
Gerrit Renker30833ff2007-03-20 15:31:56 -0300328
329 hctx->ccid3hctx_s = skb->len;
330
331 /*
332 * Use initial RTT sample when available: recommended by erratum
333 * to RFC 4342. This implements the initialisation procedure of
334 * draft rfc3448bis, section 4.2. Remember, X is scaled by 2^6.
335 */
336 if (dp->dccps_syn_rtt) {
337 ccid3_pr_debug("SYN RTT = %uus\n", dp->dccps_syn_rtt);
338 hctx->ccid3hctx_rtt = dp->dccps_syn_rtt;
339 hctx->ccid3hctx_x = rfc3390_initial_rate(sk);
Arnaldo Carvalho de Melo23f062a2007-08-19 17:14:52 -0700340 hctx->ccid3hctx_t_ld = now;
Gerrit Renker30833ff2007-03-20 15:31:56 -0300341 } else {
Gerrit Renker6c08b2c2007-11-20 17:33:17 -0200342 /* Sender does not have RTT sample: X_pps = 1 pkt/sec */
343 hctx->ccid3hctx_x = hctx->ccid3hctx_s;
Gerrit Renker30833ff2007-03-20 15:31:56 -0300344 hctx->ccid3hctx_x <<= 6;
345 }
346 ccid3_update_send_interval(hctx);
347
348 ccid3_hc_tx_set_state(sk, TFRC_SSTATE_NO_FBACK);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700349 break;
350 case TFRC_SSTATE_NO_FBACK:
351 case TFRC_SSTATE_FBACK:
Gerrit Renker8132da42007-06-16 13:34:02 -0300352 delay = ktime_us_delta(hctx->ccid3hctx_t_nom, now);
Ian McDonald8699be72007-03-20 14:49:20 -0300353 ccid3_pr_debug("delay=%ld\n", (long)delay);
Gerrit Renker91cf5a12006-11-27 12:25:10 -0200354 /*
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200355 * Scheduling of packet transmissions [RFC 3448, 4.6]
Gerrit Renker91cf5a12006-11-27 12:25:10 -0200356 *
357 * if (t_now > t_nom - delta)
358 * // send the packet now
359 * else
360 * // send the packet in (t_nom - t_now) milliseconds.
361 */
Gerrit Renker49d66a72007-06-16 13:48:50 -0300362 if (delay - (s64)hctx->ccid3hctx_delta >= 1000)
Gerrit Renker8132da42007-06-16 13:34:02 -0300363 return (u32)delay / 1000L;
Gerrit Renker9f8681d2006-12-10 00:07:37 -0200364
Gerrit Renker8132da42007-06-16 13:34:02 -0300365 ccid3_hc_tx_update_win_count(hctx, now);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700366 break;
Gerrit Renker59348b12006-11-20 18:39:23 -0200367 case TFRC_SSTATE_TERM:
Gerrit Renkera9672412006-12-10 00:14:12 -0200368 DCCP_BUG("%s(%p) - Illegal state TERM", dccp_role(sk), sk);
Gerrit Renker7da7f452006-11-27 12:26:03 -0200369 return -EINVAL;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700370 }
371
Gerrit Renker7da7f452006-11-27 12:26:03 -0200372 /* prepare to send now (add options etc.) */
373 dp->dccps_hc_tx_insert_options = 1;
Gerrit Renkere312d102006-12-10 00:08:09 -0200374 DCCP_SKB_CB(skb)->dccpd_ccval = hctx->ccid3hctx_last_win_count;
375
376 /* set the nominal send time for the next following packet */
Gerrit Renker8132da42007-06-16 13:34:02 -0300377 hctx->ccid3hctx_t_nom = ktime_add_us(hctx->ccid3hctx_t_nom,
378 hctx->ccid3hctx_t_ipi);
Gerrit Renker7da7f452006-11-27 12:26:03 -0200379 return 0;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700380}
381
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200382static void ccid3_hc_tx_packet_sent(struct sock *sk, int more,
383 unsigned int len)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700384{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300385 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700386
Gerrit Renker6b57c932006-11-28 19:55:06 -0200387 ccid3_hc_tx_update_s(hctx, len);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700388
Arnaldo Carvalho de Melo276f2ed2007-11-28 11:15:40 -0200389 if (tfrc_tx_hist_add(&hctx->ccid3hctx_hist, dccp_sk(sk)->dccps_gss))
Gerrit Renkerc5a1ae92006-12-10 00:09:21 -0200390 DCCP_CRIT("packet history - out of memory!");
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700391}
392
393static void ccid3_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb)
394{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300395 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700396 struct ccid3_options_received *opt_recv;
Arnaldo Carvalho de Melo0740d492007-08-19 17:18:13 -0700397 ktime_t now;
Gerrit Renker2a1fda62006-11-28 18:34:34 -0200398 unsigned long t_nfb;
Gerrit Renker7dfee1a2007-03-20 15:24:37 -0300399 u32 pinv, r_sample;
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300400
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700401 /* we are only interested in ACKs */
402 if (!(DCCP_SKB_CB(skb)->dccpd_type == DCCP_PKT_ACK ||
403 DCCP_SKB_CB(skb)->dccpd_type == DCCP_PKT_DATAACK))
404 return;
405
406 opt_recv = &hctx->ccid3hctx_options_received;
407
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700408 switch (hctx->ccid3hctx_state) {
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700409 case TFRC_SSTATE_NO_FBACK:
410 case TFRC_SSTATE_FBACK:
Arnaldo Carvalho de Melo9108d5f2007-11-29 22:47:15 -0200411 now = ktime_get_real();
412
Arnaldo Carvalho de Melo276f2ed2007-11-28 11:15:40 -0200413 /* estimate RTT from history if ACK number is valid */
Arnaldo Carvalho de Melo9108d5f2007-11-29 22:47:15 -0200414 r_sample = tfrc_tx_hist_rtt(hctx->ccid3hctx_hist,
415 DCCP_SKB_CB(skb)->dccpd_ack_seq, now);
416 if (r_sample == 0) {
Arnaldo Carvalho de Melo276f2ed2007-11-28 11:15:40 -0200417 DCCP_WARN("%s(%p): %s with bogus ACK-%llu\n", dccp_role(sk), sk,
418 dccp_packet_name(DCCP_SKB_CB(skb)->dccpd_type),
419 (unsigned long long)DCCP_SKB_CB(skb)->dccpd_ack_seq);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700420 return;
421 }
422
Gerrit Renker1a21e492006-12-10 00:02:12 -0200423 /* Update receive rate in units of 64 * bytes/second */
Gerrit Renker9e8efc82006-12-10 00:24:57 -0200424 hctx->ccid3hctx_x_recv = opt_recv->ccid3or_receive_rate;
425 hctx->ccid3hctx_x_recv <<= 6;
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200426
427 /* Update loss event rate */
428 pinv = opt_recv->ccid3or_loss_event_rate;
Gerrit Renker45393a62006-12-09 23:59:14 -0200429 if (pinv == ~0U || pinv == 0) /* see RFC 4342, 8.5 */
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200430 hctx->ccid3hctx_p = 0;
Gerrit Renker45393a62006-12-09 23:59:14 -0200431 else /* can not exceed 100% */
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200432 hctx->ccid3hctx_p = 1000000 / pinv;
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200433 /*
Arnaldo Carvalho de Melo9108d5f2007-11-29 22:47:15 -0200434 * Validate new RTT sample and update moving average
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200435 */
Arnaldo Carvalho de Melo9108d5f2007-11-29 22:47:15 -0200436 r_sample = dccp_sample_rtt(sk, r_sample);
Gerrit Renkerc3ada462007-11-20 18:09:59 -0200437 hctx->ccid3hctx_rtt = tfrc_ewma(hctx->ccid3hctx_rtt, r_sample, 9);
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200438
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700439 if (hctx->ccid3hctx_state == TFRC_SSTATE_NO_FBACK) {
Gerrit Renker1a21e492006-12-10 00:02:12 -0200440 /*
441 * Larger Initial Windows [RFC 4342, sec. 5]
Gerrit Renker1a21e492006-12-10 00:02:12 -0200442 */
Gerrit Renkera21f9f92007-03-20 15:12:10 -0300443 hctx->ccid3hctx_x = rfc3390_initial_rate(sk);
Arnaldo Carvalho de Melo9823b7b2007-08-19 17:16:35 -0700444 hctx->ccid3hctx_t_ld = now;
Gerrit Renkera79ef762006-11-28 19:51:42 -0200445
Gerrit Renker1266ade2007-03-20 14:56:11 -0300446 ccid3_update_send_interval(hctx);
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200447
Gerrit Renkera21f9f92007-03-20 15:12:10 -0300448 ccid3_pr_debug("%s(%p), s=%u, MSS=%u, "
Gerrit Renker7dfee1a2007-03-20 15:24:37 -0300449 "R_sample=%uus, X=%u\n", dccp_role(sk),
Andrew Morton0f084612007-02-05 18:18:21 -0800450 sk, hctx->ccid3hctx_s,
David S. Miller1b07a952007-05-23 17:43:11 -0700451 dccp_sk(sk)->dccps_mss_cache, r_sample,
Gerrit Renker1a21e492006-12-10 00:02:12 -0200452 (unsigned)(hctx->ccid3hctx_x >> 6));
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200453
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700454 ccid3_hc_tx_set_state(sk, TFRC_SSTATE_FBACK);
Gerrit Renkera79ef762006-11-28 19:51:42 -0200455 } else {
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200456
Gerrit Renkerff586292006-12-10 00:00:14 -0200457 /* Update sending rate (step 4 of [RFC 3448, 4.3]) */
458 if (hctx->ccid3hctx_p > 0)
459 hctx->ccid3hctx_x_calc =
460 tfrc_calc_x(hctx->ccid3hctx_s,
461 hctx->ccid3hctx_rtt,
462 hctx->ccid3hctx_p);
Gerrit Renkeraa97efd2007-09-25 22:39:16 -0700463 ccid3_hc_tx_update_x(sk, &now);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700464
Gerrit Renker7dfee1a2007-03-20 15:24:37 -0300465 ccid3_pr_debug("%s(%p), RTT=%uus (sample=%uus), s=%u, "
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200466 "p=%u, X_calc=%u, X_recv=%u, X=%u\n",
467 dccp_role(sk),
Gerrit Renker7dfee1a2007-03-20 15:24:37 -0300468 sk, hctx->ccid3hctx_rtt, r_sample,
Gerrit Renker5c3fbb62006-12-03 14:50:56 -0200469 hctx->ccid3hctx_s, hctx->ccid3hctx_p,
470 hctx->ccid3hctx_x_calc,
Gerrit Renker9e8efc82006-12-10 00:24:57 -0200471 (unsigned)(hctx->ccid3hctx_x_recv >> 6),
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200472 (unsigned)(hctx->ccid3hctx_x >> 6));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700473 }
474
475 /* unschedule no feedback timer */
476 sk_stop_timer(sk, &hctx->ccid3hctx_no_feedback_timer);
477
Arnaldo Carvalho de Meloc530cfb2005-08-29 02:15:54 -0300478 /*
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200479 * As we have calculated new ipi, delta, t_nom it is possible
480 * that we now can send a packet, so wake up dccp_wait_for_ccid
Arnaldo Carvalho de Meloc530cfb2005-08-29 02:15:54 -0300481 */
482 sk->sk_write_space(sk);
Arnaldo Carvalho de Melo8c60f3f2005-08-10 12:59:38 -0300483
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200484 /*
485 * Update timeout interval for the nofeedback timer.
486 * We use a configuration option to increase the lower bound.
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200487 * This can help avoid triggering the nofeedback timer too
488 * often ('spinning') on LANs with small RTTs.
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200489 */
Gerrit Renker5d0dbc42006-11-27 20:32:37 -0200490 hctx->ccid3hctx_t_rto = max_t(u32, 4 * hctx->ccid3hctx_rtt,
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200491 CONFIG_IP_DCCP_CCID3_RTO *
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200492 (USEC_PER_SEC/1000));
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300493 /*
494 * Schedule no feedback timer to expire in
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200495 * max(t_RTO, 2 * s/X) = max(t_RTO, 2 * t_ipi)
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300496 */
Gerrit Renker8a508ac2006-12-03 14:50:23 -0200497 t_nfb = max(hctx->ccid3hctx_t_rto, 2 * hctx->ccid3hctx_t_ipi);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700498
Gerrit Renkera9672412006-12-10 00:14:12 -0200499 ccid3_pr_debug("%s(%p), Scheduled no feedback timer to "
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200500 "expire in %lu jiffies (%luus)\n",
501 dccp_role(sk),
Gerrit Renkera9672412006-12-10 00:14:12 -0200502 sk, usecs_to_jiffies(t_nfb), t_nfb);
503
504 sk_reset_timer(sk, &hctx->ccid3hctx_no_feedback_timer,
Gerrit Renker2a1fda62006-11-28 18:34:34 -0200505 jiffies + usecs_to_jiffies(t_nfb));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700506 break;
Gerrit Renker151a9932007-03-07 12:53:48 -0800507 case TFRC_SSTATE_NO_SENT: /* fall through */
Gerrit Renker5e19e3f2006-11-27 12:28:48 -0200508 case TFRC_SSTATE_TERM: /* ignore feedback when closing */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700509 break;
510 }
511}
512
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700513static int ccid3_hc_tx_parse_options(struct sock *sk, unsigned char option,
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300514 unsigned char len, u16 idx,
515 unsigned char *value)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700516{
517 int rc = 0;
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300518 const struct dccp_sock *dp = dccp_sk(sk);
519 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700520 struct ccid3_options_received *opt_recv;
Gerrit Renker76fd1e82007-10-24 10:46:58 -0200521 __be32 opt_val;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700522
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700523 opt_recv = &hctx->ccid3hctx_options_received;
524
525 if (opt_recv->ccid3or_seqno != dp->dccps_gsr) {
526 opt_recv->ccid3or_seqno = dp->dccps_gsr;
527 opt_recv->ccid3or_loss_event_rate = ~0;
528 opt_recv->ccid3or_loss_intervals_idx = 0;
529 opt_recv->ccid3or_loss_intervals_len = 0;
530 opt_recv->ccid3or_receive_rate = 0;
531 }
532
533 switch (option) {
534 case TFRC_OPT_LOSS_EVENT_RATE:
Arnaldo Carvalho de Melo59d203f2005-09-09 20:01:25 -0300535 if (unlikely(len != 4)) {
Gerrit Renkera9672412006-12-10 00:14:12 -0200536 DCCP_WARN("%s(%p), invalid len %d "
Gerrit Renker59348b12006-11-20 18:39:23 -0200537 "for TFRC_OPT_LOSS_EVENT_RATE\n",
538 dccp_role(sk), sk, len);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700539 rc = -EINVAL;
540 } else {
Gerrit Renker76fd1e82007-10-24 10:46:58 -0200541 opt_val = get_unaligned((__be32 *)value);
542 opt_recv->ccid3or_loss_event_rate = ntohl(opt_val);
Gerrit Renkera9672412006-12-10 00:14:12 -0200543 ccid3_pr_debug("%s(%p), LOSS_EVENT_RATE=%u\n",
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700544 dccp_role(sk), sk,
545 opt_recv->ccid3or_loss_event_rate);
546 }
547 break;
548 case TFRC_OPT_LOSS_INTERVALS:
549 opt_recv->ccid3or_loss_intervals_idx = idx;
550 opt_recv->ccid3or_loss_intervals_len = len;
Gerrit Renkera9672412006-12-10 00:14:12 -0200551 ccid3_pr_debug("%s(%p), LOSS_INTERVALS=(%u, %u)\n",
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700552 dccp_role(sk), sk,
553 opt_recv->ccid3or_loss_intervals_idx,
554 opt_recv->ccid3or_loss_intervals_len);
555 break;
556 case TFRC_OPT_RECEIVE_RATE:
Arnaldo Carvalho de Melo59d203f2005-09-09 20:01:25 -0300557 if (unlikely(len != 4)) {
Gerrit Renkera9672412006-12-10 00:14:12 -0200558 DCCP_WARN("%s(%p), invalid len %d "
Gerrit Renker59348b12006-11-20 18:39:23 -0200559 "for TFRC_OPT_RECEIVE_RATE\n",
560 dccp_role(sk), sk, len);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700561 rc = -EINVAL;
562 } else {
Gerrit Renker76fd1e82007-10-24 10:46:58 -0200563 opt_val = get_unaligned((__be32 *)value);
564 opt_recv->ccid3or_receive_rate = ntohl(opt_val);
Gerrit Renkera9672412006-12-10 00:14:12 -0200565 ccid3_pr_debug("%s(%p), RECEIVE_RATE=%u\n",
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700566 dccp_role(sk), sk,
567 opt_recv->ccid3or_receive_rate);
568 }
569 break;
570 }
571
572 return rc;
573}
574
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800575static int ccid3_hc_tx_init(struct ccid *ccid, struct sock *sk)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700576{
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800577 struct ccid3_hc_tx_sock *hctx = ccid_priv(ccid);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700578
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700579 hctx->ccid3hctx_state = TFRC_SSTATE_NO_SENT;
Arnaldo Carvalho de Melo276f2ed2007-11-28 11:15:40 -0200580 hctx->ccid3hctx_hist = NULL;
Pavel Emelyanovb24b8a22008-01-23 21:20:07 -0800581 setup_timer(&hctx->ccid3hctx_no_feedback_timer,
582 ccid3_hc_tx_no_feedback_timer, (unsigned long)sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700583
584 return 0;
585}
586
587static void ccid3_hc_tx_exit(struct sock *sk)
588{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300589 struct ccid3_hc_tx_sock *hctx = ccid3_hc_tx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700590
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700591 ccid3_hc_tx_set_state(sk, TFRC_SSTATE_TERM);
592 sk_stop_timer(sk, &hctx->ccid3hctx_no_feedback_timer);
593
Arnaldo Carvalho de Melo276f2ed2007-11-28 11:15:40 -0200594 tfrc_tx_hist_purge(&hctx->ccid3hctx_hist);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700595}
596
Gerrit Renker9bf17472007-03-20 13:11:24 -0300597static void ccid3_hc_tx_get_info(struct sock *sk, struct tcp_info *info)
598{
Gerrit Renker2e869082007-09-26 11:24:28 -0300599 struct ccid3_hc_tx_sock *hctx;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700600
Gerrit Renker9bf17472007-03-20 13:11:24 -0300601 /* Listen socks doesn't have a private CCID block */
602 if (sk->sk_state == DCCP_LISTEN)
603 return;
604
Gerrit Renker2e869082007-09-26 11:24:28 -0300605 hctx = ccid3_hc_tx_sk(sk);
Gerrit Renker9bf17472007-03-20 13:11:24 -0300606 info->tcpi_rto = hctx->ccid3hctx_t_rto;
607 info->tcpi_rtt = hctx->ccid3hctx_rtt;
608}
609
610static int ccid3_hc_tx_getsockopt(struct sock *sk, const int optname, int len,
611 u32 __user *optval, int __user *optlen)
612{
Gerrit Renker2e869082007-09-26 11:24:28 -0300613 const struct ccid3_hc_tx_sock *hctx;
Gerrit Renker9bf17472007-03-20 13:11:24 -0300614 const void *val;
615
616 /* Listen socks doesn't have a private CCID block */
617 if (sk->sk_state == DCCP_LISTEN)
618 return -EINVAL;
619
Gerrit Renker2e869082007-09-26 11:24:28 -0300620 hctx = ccid3_hc_tx_sk(sk);
Gerrit Renker9bf17472007-03-20 13:11:24 -0300621 switch (optname) {
622 case DCCP_SOCKOPT_CCID_TX_INFO:
623 if (len < sizeof(hctx->ccid3hctx_tfrc))
624 return -EINVAL;
625 len = sizeof(hctx->ccid3hctx_tfrc);
626 val = &hctx->ccid3hctx_tfrc;
627 break;
628 default:
629 return -ENOPROTOOPT;
630 }
631
632 if (put_user(len, optlen) || copy_to_user(optval, val, len))
633 return -EFAULT;
634
635 return 0;
636}
637
638/*
639 * Receiver Half-Connection Routines
640 */
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200641
642/* CCID3 feedback types */
643enum ccid3_fback_type {
644 CCID3_FBACK_NONE = 0,
645 CCID3_FBACK_INITIAL,
646 CCID3_FBACK_PERIODIC,
647 CCID3_FBACK_PARAM_CHANGE
648};
649
Gerrit Renker56724aa2006-11-20 18:28:09 -0200650#ifdef CONFIG_IP_DCCP_CCID3_DEBUG
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700651static const char *ccid3_rx_state_name(enum ccid3_hc_rx_states state)
652{
653 static char *ccid3_rx_state_names[] = {
654 [TFRC_RSTATE_NO_DATA] = "NO_DATA",
655 [TFRC_RSTATE_DATA] = "DATA",
656 [TFRC_RSTATE_TERM] = "TERM",
657 };
658
659 return ccid3_rx_state_names[state];
660}
661#endif
662
Arnaldo Carvalho de Meloc25a18b2006-03-20 21:58:56 -0800663static void ccid3_hc_rx_set_state(struct sock *sk,
664 enum ccid3_hc_rx_states state)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700665{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300666 struct ccid3_hc_rx_sock *hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700667 enum ccid3_hc_rx_states oldstate = hcrx->ccid3hcrx_state;
668
669 ccid3_pr_debug("%s(%p) %-8.8s -> %s\n",
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300670 dccp_role(sk), sk, ccid3_rx_state_name(oldstate),
671 ccid3_rx_state_name(state));
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700672 WARN_ON(state == oldstate);
673 hcrx->ccid3hcrx_state = state;
674}
675
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200676static void ccid3_hc_rx_send_feedback(struct sock *sk,
677 const struct sk_buff *skb,
678 enum ccid3_fback_type fbtype)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700679{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300680 struct ccid3_hc_rx_sock *hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700681 struct dccp_sock *dp = dccp_sk(sk);
Arnaldo Carvalho de Meloe7c23352007-08-19 17:17:51 -0700682 ktime_t now;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200683 s64 delta = 0;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700684
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200685 if (unlikely(hcrx->ccid3hcrx_state == TFRC_RSTATE_TERM))
686 return;
687
Arnaldo Carvalho de Meloe7a81c62007-08-19 17:15:37 -0700688 now = ktime_get_real();
Arnaldo Carvalho de Melob6ee3d42005-08-27 18:18:18 -0300689
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200690 switch (fbtype) {
691 case CCID3_FBACK_INITIAL:
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700692 hcrx->ccid3hcrx_x_recv = 0;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200693 hcrx->ccid3hcrx_pinv = ~0U; /* see RFC 4342, 8.5 */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700694 break;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200695 case CCID3_FBACK_PARAM_CHANGE:
696 /*
697 * When parameters change (new loss or p > p_prev), we do not
698 * have a reliable estimate for R_m of [RFC 3448, 6.2] and so
699 * need to reuse the previous value of X_recv. However, when
700 * X_recv was 0 (due to early loss), this would kill X down to
701 * s/t_mbi (i.e. one packet in 64 seconds).
702 * To avoid such drastic reduction, we approximate X_recv as
703 * the number of bytes since last feedback.
704 * This is a safe fallback, since X is bounded above by X_calc.
705 */
706 if (hcrx->ccid3hcrx_x_recv > 0)
707 break;
708 /* fall through */
709 case CCID3_FBACK_PERIODIC:
710 delta = ktime_us_delta(now, hcrx->ccid3hcrx_tstamp_last_feedback);
711 if (delta <= 0)
712 DCCP_BUG("delta (%ld) <= 0", (long)delta);
713 else
714 hcrx->ccid3hcrx_x_recv =
715 scaled_div32(hcrx->ccid3hcrx_bytes_recv, delta);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700716 break;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200717 default:
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700718 return;
719 }
720
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200721 ccid3_pr_debug("Interval %ldusec, X_recv=%u, 1/p=%u\n", (long)delta,
722 hcrx->ccid3hcrx_x_recv, hcrx->ccid3hcrx_pinv);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700723
Arnaldo Carvalho de Melob6ee3d42005-08-27 18:18:18 -0300724 hcrx->ccid3hcrx_tstamp_last_feedback = now;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200725 hcrx->ccid3hcrx_last_counter = dccp_hdr(skb)->dccph_ccval;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700726 hcrx->ccid3hcrx_bytes_recv = 0;
727
Arnaldo Carvalho de Melo507d37c2005-09-09 02:30:07 -0300728 dp->dccps_hc_rx_insert_options = 1;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700729 dccp_send_ack(sk);
730}
731
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800732static int ccid3_hc_rx_insert_options(struct sock *sk, struct sk_buff *skb)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700733{
Gerrit Renker2e869082007-09-26 11:24:28 -0300734 const struct ccid3_hc_rx_sock *hcrx;
Andrea Bittau60fe62e2006-03-20 19:23:32 -0800735 __be32 x_recv, pinv;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700736
Arnaldo Carvalho de Melo59d203f2005-09-09 20:01:25 -0300737 if (!(sk->sk_state == DCCP_OPEN || sk->sk_state == DCCP_PARTOPEN))
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800738 return 0;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700739
Gerrit Renker2e869082007-09-26 11:24:28 -0300740 hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo4fded332005-08-23 21:51:59 -0700741
742 if (dccp_packet_without_ack(skb))
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800743 return 0;
744
Arnaldo Carvalho de Melo4fded332005-08-23 21:51:59 -0700745 x_recv = htonl(hcrx->ccid3hcrx_x_recv);
746 pinv = htonl(hcrx->ccid3hcrx_pinv);
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800747
Gerrit Renker385ac2e2007-12-08 16:26:59 -0200748 if (dccp_insert_option(sk, skb, TFRC_OPT_LOSS_EVENT_RATE,
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200749 &pinv, sizeof(pinv)) ||
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800750 dccp_insert_option(sk, skb, TFRC_OPT_RECEIVE_RATE,
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200751 &x_recv, sizeof(x_recv)))
Arnaldo Carvalho de Melo2d0817d2006-03-20 22:32:06 -0800752 return -1;
753
754 return 0;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700755}
756
Gerrit Renker954c2db2007-12-12 14:06:14 -0200757/** ccid3_first_li - Implements [RFC 3448, 6.3.1]
758 *
759 * Determine the length of the first loss interval via inverse lookup.
760 * Assume that X_recv can be computed by the throughput equation
761 * s
762 * X_recv = --------
763 * R * fval
764 * Find some p such that f(p) = fval; return 1/p (scaled).
765 */
766static u32 ccid3_first_li(struct sock *sk)
767{
768 struct ccid3_hc_rx_sock *hcrx = ccid3_hc_rx_sk(sk);
769 u32 x_recv, p, delta;
770 u64 fval;
771
772 if (hcrx->ccid3hcrx_rtt == 0) {
773 DCCP_WARN("No RTT estimate available, using fallback RTT\n");
774 hcrx->ccid3hcrx_rtt = DCCP_FALLBACK_RTT;
775 }
776
777 delta = ktime_to_us(net_timedelta(hcrx->ccid3hcrx_tstamp_last_feedback));
778 x_recv = scaled_div32(hcrx->ccid3hcrx_bytes_recv, delta);
779 if (x_recv == 0) { /* would also trigger divide-by-zero */
780 DCCP_WARN("X_recv==0\n");
781 if ((x_recv = hcrx->ccid3hcrx_x_recv) == 0) {
782 DCCP_BUG("stored value of X_recv is zero");
783 return ~0U;
784 }
785 }
786
787 fval = scaled_div(hcrx->ccid3hcrx_s, hcrx->ccid3hcrx_rtt);
788 fval = scaled_div32(fval, x_recv);
789 p = tfrc_calc_x_reverse_lookup(fval);
790
791 ccid3_pr_debug("%s(%p), receive rate=%u bytes/s, implied "
792 "loss rate=%u\n", dccp_role(sk), sk, x_recv, p);
793
794 return p == 0 ? ~0U : scaled_div(1, p);
795}
796
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700797static void ccid3_hc_rx_packet_recv(struct sock *sk, struct sk_buff *skb)
798{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300799 struct ccid3_hc_rx_sock *hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200800 enum ccid3_fback_type do_feedback = CCID3_FBACK_NONE;
801 const u32 ndp = dccp_sk(sk)->dccps_options_received.dccpor_ndp;
802 const bool is_data_packet = dccp_data_packet(skb);
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300803
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200804 if (unlikely(hcrx->ccid3hcrx_state == TFRC_RSTATE_NO_DATA)) {
805 if (is_data_packet) {
806 const u32 payload = skb->len - dccp_hdr(skb)->dccph_doff * 4;
807 do_feedback = CCID3_FBACK_INITIAL;
808 ccid3_hc_rx_set_state(sk, TFRC_RSTATE_DATA);
809 hcrx->ccid3hcrx_s = payload;
810 /*
811 * Not necessary to update ccid3hcrx_bytes_recv here,
812 * since X_recv = 0 for the first feedback packet (cf.
813 * RFC 3448, 6.3) -- gerrit
814 */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700815 }
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200816 goto update_records;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700817 }
818
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200819 if (tfrc_rx_hist_duplicate(&hcrx->ccid3hcrx_hist, skb))
820 return; /* done receiving */
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700821
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200822 if (is_data_packet) {
823 const u32 payload = skb->len - dccp_hdr(skb)->dccph_doff * 4;
824 /*
825 * Update moving-average of s and the sum of received payload bytes
826 */
827 hcrx->ccid3hcrx_s = tfrc_ewma(hcrx->ccid3hcrx_s, payload, 9);
828 hcrx->ccid3hcrx_bytes_recv += payload;
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700829 }
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200830
831 /*
832 * Handle pending losses and otherwise check for new loss
833 */
Gerrit Renker954c2db2007-12-12 14:06:14 -0200834 if (tfrc_rx_hist_loss_pending(&hcrx->ccid3hcrx_hist) &&
835 tfrc_rx_handle_loss(&hcrx->ccid3hcrx_hist,
836 &hcrx->ccid3hcrx_li_hist,
837 skb, ndp, ccid3_first_li, sk) ) {
838 do_feedback = CCID3_FBACK_PARAM_CHANGE;
839 goto done_receiving;
840 }
841
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200842 if (tfrc_rx_hist_new_loss_indicated(&hcrx->ccid3hcrx_hist, skb, ndp))
843 goto update_records;
844
845 /*
846 * Handle data packets: RTT sampling and monitoring p
847 */
848 if (unlikely(!is_data_packet))
849 goto update_records;
850
Gerrit Renker954c2db2007-12-12 14:06:14 -0200851 if (!tfrc_lh_is_initialised(&hcrx->ccid3hcrx_li_hist)) {
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200852 const u32 sample = tfrc_rx_hist_sample_rtt(&hcrx->ccid3hcrx_hist, skb);
853 /*
854 * Empty loss history: no loss so far, hence p stays 0.
855 * Sample RTT values, since an RTT estimate is required for the
856 * computation of p when the first loss occurs; RFC 3448, 6.3.1.
857 */
858 if (sample != 0)
859 hcrx->ccid3hcrx_rtt = tfrc_ewma(hcrx->ccid3hcrx_rtt, sample, 9);
Gerrit Renker954c2db2007-12-12 14:06:14 -0200860
861 } else if (tfrc_lh_update_i_mean(&hcrx->ccid3hcrx_li_hist, skb)) {
862 /*
863 * Step (3) of [RFC 3448, 6.1]: Recompute I_mean and, if I_mean
864 * has decreased (resp. p has increased), send feedback now.
865 */
866 do_feedback = CCID3_FBACK_PARAM_CHANGE;
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200867 }
868
869 /*
870 * Check if the periodic once-per-RTT feedback is due; RFC 4342, 10.3
871 */
872 if (SUB16(dccp_hdr(skb)->dccph_ccval, hcrx->ccid3hcrx_last_counter) > 3)
873 do_feedback = CCID3_FBACK_PERIODIC;
874
875update_records:
876 tfrc_rx_hist_add_packet(&hcrx->ccid3hcrx_hist, skb, ndp);
877
Gerrit Renker954c2db2007-12-12 14:06:14 -0200878done_receiving:
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200879 if (do_feedback)
880 ccid3_hc_rx_send_feedback(sk, skb, do_feedback);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700881}
882
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800883static int ccid3_hc_rx_init(struct ccid *ccid, struct sock *sk)
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700884{
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800885 struct ccid3_hc_rx_sock *hcrx = ccid_priv(ccid);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700886
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700887 hcrx->ccid3hcrx_state = TFRC_RSTATE_NO_DATA;
Gerrit Renker954c2db2007-12-12 14:06:14 -0200888 tfrc_lh_init(&hcrx->ccid3hcrx_li_hist);
Arnaldo Carvalho de Melob84a2182007-12-06 13:18:11 -0200889 return tfrc_rx_hist_alloc(&hcrx->ccid3hcrx_hist);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700890}
891
892static void ccid3_hc_rx_exit(struct sock *sk)
893{
Arnaldo Carvalho de Melo59725dc2005-09-09 02:40:58 -0300894 struct ccid3_hc_rx_sock *hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700895
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700896 ccid3_hc_rx_set_state(sk, TFRC_RSTATE_TERM);
897
Arnaldo Carvalho de Melod58d1af2007-12-06 12:28:39 -0200898 tfrc_rx_hist_purge(&hcrx->ccid3hcrx_hist);
Gerrit Renker954c2db2007-12-12 14:06:14 -0200899 tfrc_lh_cleanup(&hcrx->ccid3hcrx_li_hist);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700900}
901
Arnaldo Carvalho de Melo2babe1f2005-08-23 21:52:35 -0700902static void ccid3_hc_rx_get_info(struct sock *sk, struct tcp_info *info)
903{
Gerrit Renker2e869082007-09-26 11:24:28 -0300904 const struct ccid3_hc_rx_sock *hcrx;
Arnaldo Carvalho de Melo2babe1f2005-08-23 21:52:35 -0700905
Arnaldo Carvalho de Melo59c23532005-09-12 14:16:58 -0700906 /* Listen socks doesn't have a private CCID block */
907 if (sk->sk_state == DCCP_LISTEN)
908 return;
909
Gerrit Renker2e869082007-09-26 11:24:28 -0300910 hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200911 info->tcpi_ca_state = hcrx->ccid3hcrx_state;
912 info->tcpi_options |= TCPI_OPT_TIMESTAMPS;
913 info->tcpi_rcv_rtt = hcrx->ccid3hcrx_rtt;
Arnaldo Carvalho de Melo2babe1f2005-08-23 21:52:35 -0700914}
915
Arnaldo Carvalho de Melo88f964d2005-09-18 00:19:32 -0700916static int ccid3_hc_rx_getsockopt(struct sock *sk, const int optname, int len,
917 u32 __user *optval, int __user *optlen)
918{
Gerrit Renker2e869082007-09-26 11:24:28 -0300919 const struct ccid3_hc_rx_sock *hcrx;
Arnaldo Carvalho de Melo88f964d2005-09-18 00:19:32 -0700920 const void *val;
YOSHIFUJI Hideakic9eaf172007-02-09 23:24:38 +0900921
Arnaldo Carvalho de Melo88f964d2005-09-18 00:19:32 -0700922 /* Listen socks doesn't have a private CCID block */
923 if (sk->sk_state == DCCP_LISTEN)
924 return -EINVAL;
925
Gerrit Renker2e869082007-09-26 11:24:28 -0300926 hcrx = ccid3_hc_rx_sk(sk);
Arnaldo Carvalho de Melo88f964d2005-09-18 00:19:32 -0700927 switch (optname) {
928 case DCCP_SOCKOPT_CCID_RX_INFO:
929 if (len < sizeof(hcrx->ccid3hcrx_tfrc))
930 return -EINVAL;
931 len = sizeof(hcrx->ccid3hcrx_tfrc);
932 val = &hcrx->ccid3hcrx_tfrc;
933 break;
934 default:
935 return -ENOPROTOOPT;
936 }
937
938 if (put_user(len, optlen) || copy_to_user(optval, val, len))
939 return -EFAULT;
940
941 return 0;
942}
943
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800944static struct ccid_operations ccid3 = {
Ian McDonald3dd9a7c2006-09-22 14:26:44 +1200945 .ccid_id = DCCPC_CCID3,
Gerrit Renker84a97b02007-12-13 23:33:25 -0200946 .ccid_name = "TCP-Friendly Rate Control",
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700947 .ccid_owner = THIS_MODULE,
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800948 .ccid_hc_tx_obj_size = sizeof(struct ccid3_hc_tx_sock),
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700949 .ccid_hc_tx_init = ccid3_hc_tx_init,
950 .ccid_hc_tx_exit = ccid3_hc_tx_exit,
951 .ccid_hc_tx_send_packet = ccid3_hc_tx_send_packet,
952 .ccid_hc_tx_packet_sent = ccid3_hc_tx_packet_sent,
953 .ccid_hc_tx_packet_recv = ccid3_hc_tx_packet_recv,
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700954 .ccid_hc_tx_parse_options = ccid3_hc_tx_parse_options,
Arnaldo Carvalho de Melo91f0ebf2006-03-20 19:21:44 -0800955 .ccid_hc_rx_obj_size = sizeof(struct ccid3_hc_rx_sock),
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700956 .ccid_hc_rx_init = ccid3_hc_rx_init,
957 .ccid_hc_rx_exit = ccid3_hc_rx_exit,
958 .ccid_hc_rx_insert_options = ccid3_hc_rx_insert_options,
959 .ccid_hc_rx_packet_recv = ccid3_hc_rx_packet_recv,
Arnaldo Carvalho de Melo2babe1f2005-08-23 21:52:35 -0700960 .ccid_hc_rx_get_info = ccid3_hc_rx_get_info,
961 .ccid_hc_tx_get_info = ccid3_hc_tx_get_info,
Arnaldo Carvalho de Melo88f964d2005-09-18 00:19:32 -0700962 .ccid_hc_rx_getsockopt = ccid3_hc_rx_getsockopt,
963 .ccid_hc_tx_getsockopt = ccid3_hc_tx_getsockopt,
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700964};
Arnaldo Carvalho de Melo8109b022006-12-10 16:01:18 -0200965
Gerrit Renker56724aa2006-11-20 18:28:09 -0200966#ifdef CONFIG_IP_DCCP_CCID3_DEBUG
Gerrit Renker042d18f2007-10-04 14:39:53 -0700967module_param(ccid3_debug, bool, 0444);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700968MODULE_PARM_DESC(ccid3_debug, "Enable debug messages");
Gerrit Renker56724aa2006-11-20 18:28:09 -0200969#endif
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700970
971static __init int ccid3_module_init(void)
972{
Arnaldo Carvalho de Melo34a9e7e2007-12-06 12:28:13 -0200973 return ccid_register(&ccid3);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700974}
975module_init(ccid3_module_init);
976
977static __exit void ccid3_module_exit(void)
978{
979 ccid_unregister(&ccid3);
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700980}
981module_exit(ccid3_module_exit);
982
Ian McDonalde6bccd32006-08-26 19:01:30 -0700983MODULE_AUTHOR("Ian McDonald <ian.mcdonald@jandi.co.nz>, "
Arnaldo Carvalho de Melo1f2333a2005-08-27 03:51:58 -0300984 "Arnaldo Carvalho de Melo <acme@ghostprotocols.net>");
Arnaldo Carvalho de Melo7c657872005-08-09 20:14:34 -0700985MODULE_DESCRIPTION("DCCP TFRC CCID3 CCID");
986MODULE_LICENSE("GPL");
987MODULE_ALIAS("net-dccp-ccid-3");