blob: 61c0252b1ba9e9516d0f7359e853ad31618f6291 [file] [log] [blame]
Marco Varlese191a5942017-10-30 18:17:21 +01001/*
2 * Copyright (c) 2017 SUSE LLC.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15#include <vnet/sctp/sctp.h>
16#include <vnet/sctp/sctp_debug.h>
17
18sctp_main_t sctp_main;
19
20static u32
21sctp_connection_bind (u32 session_index, transport_endpoint_t * tep)
22{
23 sctp_main_t *tm = &sctp_main;
24 sctp_connection_t *listener;
25 void *iface_ip;
26
27 pool_get (tm->listener_pool, listener);
28 memset (listener, 0, sizeof (*listener));
29
30 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].parent = listener;
31 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_c_index =
32 listener - tm->listener_pool;
33 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.lcl_port = tep->port;
34
35 /* If we are provided a sw_if_index, bind using one of its IPs */
36 if (ip_is_zero (&tep->ip, 1) && tep->sw_if_index != ENDPOINT_INVALID_INDEX)
37 {
38 if ((iface_ip = ip_interface_get_first_ip (tep->sw_if_index,
39 tep->is_ip4)))
40 ip_set (&tep->ip, iface_ip, tep->is_ip4);
41 }
42 ip_copy (&listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.lcl_ip,
43 &tep->ip, tep->is_ip4);
44
45 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.is_ip4 = tep->is_ip4;
46 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.proto =
47 TRANSPORT_PROTO_SCTP;
48 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_s_index = session_index;
49 listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.fib_index =
50 tep->fib_index;
51 listener->state = SCTP_STATE_CLOSED;
52
53 sctp_connection_timers_init (listener);
54
55 return listener->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_c_index;
56}
57
58u32
59sctp_session_bind (u32 session_index, transport_endpoint_t * tep)
60{
61 return sctp_connection_bind (session_index, tep);
62}
63
64static void
65sctp_connection_unbind (u32 listener_index)
66{
67 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +010068 sctp_connection_t *sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +010069
Marco Varlese8ad6a2d2018-01-26 16:50:01 +010070 sctp_conn = pool_elt_at_index (tm->listener_pool, listener_index);
Marco Varlese191a5942017-10-30 18:17:21 +010071
72 /* Poison the entry */
73 if (CLIB_DEBUG > 0)
Marco Varlese8ad6a2d2018-01-26 16:50:01 +010074 memset (sctp_conn, 0xFA, sizeof (*sctp_conn));
Marco Varlese191a5942017-10-30 18:17:21 +010075
76 pool_put_index (tm->listener_pool, listener_index);
77}
78
79u32
80sctp_session_unbind (u32 listener_index)
81{
82 sctp_connection_unbind (listener_index);
83 return 0;
84}
85
86void
87sctp_punt_unknown (vlib_main_t * vm, u8 is_ip4, u8 is_add)
88{
89 sctp_main_t *tm = &sctp_main;
90 if (is_ip4)
91 tm->punt_unknown4 = is_add;
92 else
93 tm->punt_unknown6 = is_add;
94}
95
96static int
97sctp_alloc_custom_local_endpoint (sctp_main_t * tm, ip46_address_t * lcl_addr,
98 u16 * lcl_port, u8 is_ip4)
99{
100 int index, port;
101 if (is_ip4)
102 {
103 index = tm->last_v4_address_rotor++;
104 if (tm->last_v4_address_rotor >= vec_len (tm->ip4_src_addresses))
105 tm->last_v4_address_rotor = 0;
106 lcl_addr->ip4.as_u32 = tm->ip4_src_addresses[index].as_u32;
107 }
108 else
109 {
110 index = tm->last_v6_address_rotor++;
111 if (tm->last_v6_address_rotor >= vec_len (tm->ip6_src_addresses))
112 tm->last_v6_address_rotor = 0;
113 clib_memcpy (&lcl_addr->ip6, &tm->ip6_src_addresses[index],
114 sizeof (ip6_address_t));
115 }
116 port = transport_alloc_local_port (TRANSPORT_PROTO_SCTP, lcl_addr);
117 if (port < 1)
118 {
119 clib_warning ("Failed to allocate src port");
120 return -1;
121 }
122 *lcl_port = port;
123 return 0;
124}
125
126/**
127 * Initialize all connection timers as invalid
128 */
129void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100130sctp_connection_timers_init (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100131{
132 int i, j;
133
134 /* Set all to invalid */
135 for (i = 0; i < MAX_SCTP_CONNECTIONS; i++)
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100136 {
137 sctp_conn->sub_conn[i].RTO = SCTP_RTO_INIT;
Marco Varlese21c8baf2018-02-02 17:17:51 +0100138
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100139 for (j = 0; j < SCTP_N_TIMERS; j++)
140 {
141 sctp_conn->sub_conn[i].timers[j] = SCTP_TIMER_HANDLE_INVALID;
142 }
143 }
Marco Varlese191a5942017-10-30 18:17:21 +0100144}
145
146/**
147 * Stop all connection timers
148 */
149void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100150sctp_connection_timers_reset (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100151{
152 int i, j;
153 for (i = 0; i < MAX_SCTP_CONNECTIONS; i++)
154 {
155 for (j = 0; j < SCTP_N_TIMERS; j++)
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100156 sctp_timer_reset (sctp_conn, i, j);
Marco Varlese191a5942017-10-30 18:17:21 +0100157 }
158}
159
160const char *sctp_fsm_states[] = {
161#define _(sym, str) str,
162 foreach_sctp_fsm_state
163#undef _
164};
165
166u8 *
167format_sctp_state (u8 * s, va_list * args)
168{
169 u32 state = va_arg (*args, u32);
170
171 if (state < SCTP_N_STATES)
172 s = format (s, "%s", sctp_fsm_states[state]);
173 else
174 s = format (s, "UNKNOWN (%d (0x%x))", state, state);
175 return s;
176}
177
178u8 *
179format_sctp_connection_id (u8 * s, va_list * args)
180{
181 /*
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100182 sctp_connection_t *sctp_conn = va_arg (*args, sctp_connection_t *);
183 if (!sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100184 return s;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100185 if (sctp_conn->c_is_ip4)
Marco Varlese191a5942017-10-30 18:17:21 +0100186 {
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100187 s = format (s, "[#%d][%s] %U:%d->%U:%d", sctp_conn->c_thread_index, "T",
188 format_ip4_address, &sctp_conn->c_lcl_ip4,
189 clib_net_to_host_u16 (sctp_conn->c_lcl_port), format_ip4_address,
190 &sctp_conn->c_rmt_ip4, clib_net_to_host_u16 (sctp_conn->c_rmt_port));
Marco Varlese191a5942017-10-30 18:17:21 +0100191 }
192 else
193 {
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100194 s = format (s, "[#%d][%s] %U:%d->%U:%d", sctp_conn->c_thread_index, "T",
195 format_ip6_address, &sctp_conn->c_lcl_ip6,
196 clib_net_to_host_u16 (sctp_conn->c_lcl_port), format_ip6_address,
197 &sctp_conn->c_rmt_ip6, clib_net_to_host_u16 (sctp_conn->c_rmt_port));
Marco Varlese191a5942017-10-30 18:17:21 +0100198 }
199 */
200 return s;
201}
202
203u8 *
204format_sctp_connection (u8 * s, va_list * args)
205{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100206 sctp_connection_t *sctp_conn = va_arg (*args, sctp_connection_t *);
Marco Varlese191a5942017-10-30 18:17:21 +0100207 u32 verbose = va_arg (*args, u32);
208
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100209 if (!sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100210 return s;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100211 s = format (s, "%-50U", format_sctp_connection_id, sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100212 if (verbose)
213 {
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100214 s = format (s, "%-15U", format_sctp_state, sctp_conn->state);
Marco Varlese191a5942017-10-30 18:17:21 +0100215 }
216
217 return s;
218}
219
220/**
221 * Initialize connection send variables.
222 */
223void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100224sctp_init_snd_vars (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100225{
226 u32 time_now;
Marco Varlese191a5942017-10-30 18:17:21 +0100227 /*
228 * We use the time to randomize iss and for setting up the initial
229 * timestamp. Make sure it's updated otherwise syn and ack in the
230 * handshake may make it look as if time has flown in the opposite
231 * direction for us.
232 */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100233
Marco Varlese191a5942017-10-30 18:17:21 +0100234 sctp_set_time_now (vlib_get_thread_index ());
235 time_now = sctp_time_now ();
236
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100237 sctp_conn->local_initial_tsn = random_u32 (&time_now);
238 sctp_conn->remote_initial_tsn = 0x0;
239 sctp_conn->last_rcvd_tsn = sctp_conn->remote_initial_tsn;
240 sctp_conn->next_tsn = sctp_conn->local_initial_tsn + 1;
Marco Varlese191a5942017-10-30 18:17:21 +0100241}
242
243/**
244 * Update max segment size we're able to process.
245 *
246 * The value is constrained by our interface's MTU and IP options. It is
247 * also what we advertise to our peer.
248 */
249void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100250sctp_update_rcv_mss (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100251{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100252 sctp_conn->smallest_PMTU = DEFAULT_A_RWND; /* TODO find our iface MTU */
253 sctp_conn->a_rwnd = DEFAULT_A_RWND - sizeof (sctp_full_hdr_t);
254 sctp_conn->rcv_opts.a_rwnd = sctp_conn->a_rwnd;
255 sctp_conn->rcv_a_rwnd = sctp_conn->a_rwnd; /* This will be updated by our congestion algos */
Marco Varlese191a5942017-10-30 18:17:21 +0100256}
257
258void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100259sctp_init_mss (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100260{
261 SCTP_DBG ("CONN_INDEX = %u",
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100262 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.c_index);
Marco Varlese191a5942017-10-30 18:17:21 +0100263
264 u16 default_a_rwnd = 536;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100265 sctp_update_rcv_mss (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100266
267 /* TODO cache mss and consider PMTU discovery */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100268 sctp_conn->snd_a_rwnd =
269 clib_min (sctp_conn->rcv_opts.a_rwnd, sctp_conn->a_rwnd);
Marco Varlese191a5942017-10-30 18:17:21 +0100270
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100271 if (sctp_conn->snd_a_rwnd < sizeof (sctp_full_hdr_t))
Marco Varlese191a5942017-10-30 18:17:21 +0100272 {
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100273 SCTP_ADV_DBG ("sctp_conn->snd_a_rwnd < sizeof(sctp_full_hdr_t)");
Marco Varlese191a5942017-10-30 18:17:21 +0100274 /* Assume that at least the min default mss works */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100275 sctp_conn->snd_a_rwnd = default_a_rwnd;
276 sctp_conn->rcv_opts.a_rwnd = default_a_rwnd;
Marco Varlese191a5942017-10-30 18:17:21 +0100277 }
278
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100279 ASSERT (sctp_conn->snd_a_rwnd > sizeof (sctp_full_hdr_t));
Marco Varlese191a5942017-10-30 18:17:21 +0100280}
281
282always_inline sctp_connection_t *
283sctp_sub_connection_add (u8 thread_index)
284{
285 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100286 sctp_connection_t *sctp_conn = tm->connections[thread_index];
Marco Varlese191a5942017-10-30 18:17:21 +0100287
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100288 sctp_conn->sub_conn[sctp_conn->next_avail_sub_conn].connection.c_index =
289 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.c_index;
290 sctp_conn->sub_conn[sctp_conn->next_avail_sub_conn].
291 connection.thread_index = thread_index;
292 sctp_conn->sub_conn[sctp_conn->next_avail_sub_conn].parent = sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100293
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100294 sctp_conn->next_avail_sub_conn += 1;
Marco Varlese191a5942017-10-30 18:17:21 +0100295
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100296 return sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100297}
298
299void
300sctp_sub_connection_add_ip4 (u8 thread_index,
301 sctp_ipv4_addr_param_t * ipv4_addr)
302{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100303 sctp_connection_t *sctp_conn = sctp_sub_connection_add (thread_index);
Marco Varlese191a5942017-10-30 18:17:21 +0100304
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100305 clib_memcpy (&sctp_conn->
306 sub_conn[sctp_conn->next_avail_sub_conn].connection.lcl_ip.ip4,
Marco Varlese191a5942017-10-30 18:17:21 +0100307 &ipv4_addr->address, sizeof (ipv4_addr->address));
308}
309
310void
311sctp_sub_connection_add_ip6 (u8 thread_index,
312 sctp_ipv6_addr_param_t * ipv6_addr)
313{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100314 sctp_connection_t *sctp_conn = sctp_sub_connection_add (thread_index);
Marco Varlese191a5942017-10-30 18:17:21 +0100315
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100316 clib_memcpy (&sctp_conn->
317 sub_conn[sctp_conn->next_avail_sub_conn].connection.lcl_ip.ip6,
Marco Varlese191a5942017-10-30 18:17:21 +0100318 &ipv6_addr->address, sizeof (ipv6_addr->address));
319}
320
321sctp_connection_t *
322sctp_connection_new (u8 thread_index)
323{
324 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100325 sctp_connection_t *sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100326
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100327 pool_get (tm->connections[thread_index], sctp_conn);
328 memset (sctp_conn, 0, sizeof (*sctp_conn));
329 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].parent = sctp_conn;
330 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_c_index =
331 sctp_conn - tm->connections[thread_index];
332 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_thread_index = thread_index;
333 sctp_conn->local_tag = 0;
334 sctp_conn->next_avail_sub_conn = 1;
Marco Varlese191a5942017-10-30 18:17:21 +0100335
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100336 return sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100337}
338
339sctp_connection_t *
340sctp_half_open_connection_new (u8 thread_index)
341{
342 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100343 sctp_connection_t *sctp_conn = 0;
Marco Varlese191a5942017-10-30 18:17:21 +0100344 ASSERT (vlib_get_thread_index () == 0);
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100345 pool_get (tm->half_open_connections, sctp_conn);
346 memset (sctp_conn, 0, sizeof (*sctp_conn));
347 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].c_c_index =
348 sctp_conn - tm->half_open_connections;
349 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].parent = sctp_conn;
350 return sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100351}
352
353static inline int
354sctp_connection_open (transport_endpoint_t * rmt)
355{
356 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100357 sctp_connection_t *sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100358 ip46_address_t lcl_addr;
359 u16 lcl_port;
360 uword thread_id;
361 int rv;
362
363 u8 idx = sctp_pick_conn_idx_on_state (SCTP_STATE_CLOSED);
364
365 /*
366 * Allocate local endpoint
367 */
368 if ((rmt->is_ip4 && vec_len (tm->ip4_src_addresses))
369 || (!rmt->is_ip4 && vec_len (tm->ip6_src_addresses)))
370 rv = sctp_alloc_custom_local_endpoint (tm, &lcl_addr, &lcl_port,
371 rmt->is_ip4);
372 else
373 rv = transport_alloc_local_endpoint (TRANSPORT_PROTO_SCTP,
374 rmt, &lcl_addr, &lcl_port);
375
376 if (rv)
377 return -1;
378
379 /*
380 * Create connection and send INIT CHUNK
381 */
382 thread_id = vlib_get_thread_index ();
383 ASSERT (thread_id == 0);
384
385 clib_spinlock_lock_if_init (&tm->half_open_lock);
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100386 sctp_conn = sctp_half_open_connection_new (thread_id);
Marco Varlese191a5942017-10-30 18:17:21 +0100387
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100388 transport_connection_t *trans_conn = &sctp_conn->sub_conn[idx].connection;
389 ip_copy (&trans_conn->rmt_ip, &rmt->ip, rmt->is_ip4);
390 ip_copy (&trans_conn->lcl_ip, &lcl_addr, rmt->is_ip4);
391 sctp_conn->sub_conn[idx].parent = sctp_conn;
392 trans_conn->rmt_port = rmt->port;
393 trans_conn->lcl_port = clib_host_to_net_u16 (lcl_port);
394 trans_conn->is_ip4 = rmt->is_ip4;
395 trans_conn->proto = TRANSPORT_PROTO_SCTP;
396 trans_conn->fib_index = rmt->fib_index;
Marco Varlese191a5942017-10-30 18:17:21 +0100397
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100398 sctp_connection_timers_init (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100399 /* The other connection vars will be initialized after INIT_ACK chunk received */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100400 sctp_init_snd_vars (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100401
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100402 sctp_send_init (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100403
404 clib_spinlock_unlock_if_init (&tm->half_open_lock);
405
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100406 return sctp_conn->sub_conn[idx].connection.c_index;
Marco Varlese191a5942017-10-30 18:17:21 +0100407}
408
409/**
410 * Cleans up connection state.
411 *
412 * No notifications.
413 */
414void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100415sctp_connection_cleanup (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100416{
417 sctp_main_t *tm = &sctp_main;
418 u8 i;
419
420 /* Cleanup local endpoint if this was an active connect */
421 for (i = 0; i < MAX_SCTP_CONNECTIONS; i++)
422 transport_endpoint_cleanup (TRANSPORT_PROTO_SCTP,
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100423 &sctp_conn->sub_conn[i].connection.lcl_ip,
424 sctp_conn->sub_conn[i].connection.lcl_port);
Marco Varlese191a5942017-10-30 18:17:21 +0100425
426 /* Check if connection is not yet fully established */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100427 if (sctp_conn->state == SCTP_STATE_COOKIE_WAIT)
Marco Varlese191a5942017-10-30 18:17:21 +0100428 {
429
430 }
431 else
432 {
433 int thread_index =
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100434 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.thread_index;
Marco Varlese191a5942017-10-30 18:17:21 +0100435
436 /* Make sure all timers are cleared */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100437 sctp_connection_timers_reset (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100438
439 /* Poison the entry */
440 if (CLIB_DEBUG > 0)
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100441 memset (sctp_conn, 0xFA, sizeof (*sctp_conn));
442 pool_put (tm->connections[thread_index], sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100443 }
444}
445
446int
447sctp_session_open (transport_endpoint_t * tep)
448{
449 return sctp_connection_open (tep);
450}
451
452u16
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100453sctp_check_outstanding_data_chunks (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100454{
455 return 0; /* Indicates no more data to be read/sent */
456}
457
458void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100459sctp_connection_close (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100460{
461 SCTP_DBG ("Closing connection %u...",
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100462 sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection.c_index);
Marco Varlese191a5942017-10-30 18:17:21 +0100463
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100464 sctp_conn->state = SCTP_STATE_SHUTDOWN_PENDING;
Marco Varlese191a5942017-10-30 18:17:21 +0100465
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100466 sctp_send_shutdown (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100467}
468
469void
470sctp_session_close (u32 conn_index, u32 thread_index)
471{
472 ASSERT (thread_index == 0);
473
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100474 sctp_connection_t *sctp_conn;
475 sctp_conn = sctp_connection_get (conn_index, thread_index);
476 sctp_connection_close (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100477}
478
479void
480sctp_session_cleanup (u32 conn_index, u32 thread_index)
481{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100482 sctp_connection_t *sctp_conn;
483 sctp_conn = sctp_connection_get (conn_index, thread_index);
484 sctp_connection_timers_reset (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100485
486 /* Wait for the session tx events to clear */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100487 sctp_conn->state = SCTP_STATE_CLOSED;
Marco Varlese191a5942017-10-30 18:17:21 +0100488}
489
490/**
491 * Update snd_mss to reflect the effective segment size that we can send
492 */
493void
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100494sctp_update_snd_mss (sctp_connection_t * sctp_conn)
Marco Varlese191a5942017-10-30 18:17:21 +0100495{
496 /* The overhead for the sctp_header_t and sctp_chunks_common_hdr_t
497 * (the sum equals to sctp_full_hdr_t) is already taken into account
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100498 * for the sctp_conn->a_rwnd computation.
Marco Varlese191a5942017-10-30 18:17:21 +0100499 * So let's not account it again here.
500 */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100501 sctp_conn->snd_hdr_length =
Marco Varlese191a5942017-10-30 18:17:21 +0100502 sizeof (sctp_payload_data_chunk_t) - sizeof (sctp_full_hdr_t);
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100503 sctp_conn->snd_a_rwnd =
504 clib_min (sctp_conn->a_rwnd,
505 sctp_conn->rcv_opts.a_rwnd) - sctp_conn->snd_hdr_length;
Marco Varlese191a5942017-10-30 18:17:21 +0100506
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100507 SCTP_DBG ("sctp_conn->snd_a_rwnd = %u, sctp_conn->snd_hdr_length = %u ",
508 sctp_conn->snd_a_rwnd, sctp_conn->snd_hdr_length);
Marco Varlese191a5942017-10-30 18:17:21 +0100509
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100510 ASSERT (sctp_conn->snd_a_rwnd > 0);
Marco Varlese191a5942017-10-30 18:17:21 +0100511}
512
513u16
514sctp_session_send_mss (transport_connection_t * trans_conn)
515{
516 SCTP_DBG ("CONN_INDEX: %u", trans_conn->c_index);
517
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100518 sctp_connection_t *sctp_conn =
519 sctp_get_connection_from_transport (trans_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100520
521 if (trans_conn == NULL)
522 {
523 SCTP_DBG ("trans_conn == NULL");
524 return 0;
525 }
526
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100527 if (sctp_conn == NULL)
Marco Varlese191a5942017-10-30 18:17:21 +0100528 {
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100529 SCTP_DBG ("sctp_conn == NULL");
Marco Varlese191a5942017-10-30 18:17:21 +0100530 return 0;
531 }
532 /* Ensure snd_mss does accurately reflect the amount of data we can push
533 * in a segment. This also makes sure that options are updated according to
534 * the current state of the connection. */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100535 sctp_update_snd_mss (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100536
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100537 return sctp_conn->snd_a_rwnd;
Marco Varlese191a5942017-10-30 18:17:21 +0100538}
539
540u16
541sctp_snd_space (sctp_connection_t * sctp_conn)
542{
543 /* TODO: This requires a real implementation */
544 if (sctp_conn == NULL)
545 {
546 SCTP_DBG ("sctp_conn == NULL");
547 return 0;
548 }
549
550 if (sctp_conn->state != SCTP_STATE_ESTABLISHED)
551 {
552 SCTP_DBG_STATE_MACHINE
553 ("Trying to send DATA while not in SCTP_STATE_ESTABLISHED");
554 return 0;
555 }
556
557 return sctp_conn->snd_a_rwnd;
558}
559
560u32
561sctp_session_send_space (transport_connection_t * trans_conn)
562{
563 SCTP_DBG ("CONN_INDEX: %u", trans_conn->c_index);
564
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100565 sctp_connection_t *sctp_conn =
566 sctp_get_connection_from_transport (trans_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100567
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100568 return sctp_snd_space (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100569}
570
571transport_connection_t *
572sctp_session_get_transport (u32 conn_index, u32 thread_index)
573{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100574 sctp_connection_t *sctp_conn =
575 sctp_connection_get (conn_index, thread_index);
576 return &sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection;
Marco Varlese191a5942017-10-30 18:17:21 +0100577}
578
579transport_connection_t *
580sctp_session_get_listener (u32 listener_index)
581{
582 sctp_main_t *tm = vnet_get_sctp_main ();
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100583 sctp_connection_t *sctp_conn;
584 sctp_conn = pool_elt_at_index (tm->listener_pool, listener_index);
585 return &sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection;
Marco Varlese191a5942017-10-30 18:17:21 +0100586}
587
588u8 *
589format_sctp_session (u8 * s, va_list * args)
590{
591 return NULL;
592}
593
594u8 *
595format_sctp_listener_session (u8 * s, va_list * args)
596{
597 return NULL;
598}
599
600void
Marco Varlesef47276f2018-02-06 09:01:39 +0100601sctp_expired_timers_cb (u32 conn_index, u32 timer_id)
Marco Varlese191a5942017-10-30 18:17:21 +0100602{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100603 sctp_connection_t *sctp_conn;
Marco Varlese191a5942017-10-30 18:17:21 +0100604
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100605 sctp_conn = sctp_connection_get (conn_index, vlib_get_thread_index ());
Marco Varlese191a5942017-10-30 18:17:21 +0100606 /* note: the connection may have already disappeared */
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100607 if (PREDICT_FALSE (sctp_conn == 0))
Marco Varlese191a5942017-10-30 18:17:21 +0100608 return;
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100609
610 SCTP_DBG ("%s expired", sctp_timer_to_string (timer_id));
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100611
612 switch (timer_id)
613 {
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100614 case SCTP_TIMER_T1_INIT:
615 case SCTP_TIMER_T1_COOKIE:
616 case SCTP_TIMER_T2_SHUTDOWN:
617 case SCTP_TIMER_T3_RXTX:
618 clib_smp_atomic_add (&sctp_conn->sub_conn[conn_index].unacknowledged_hb,
619 1);
620 sctp_timer_reset (sctp_conn, conn_index, timer_id);
621 break;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100622 case SCTP_TIMER_T4_HEARTBEAT:
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100623 sctp_timer_reset (sctp_conn, conn_index, timer_id);
624 goto heartbeat;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100625 }
Marco Varlese191a5942017-10-30 18:17:21 +0100626
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100627 if (sctp_conn->sub_conn[conn_index].unacknowledged_hb >
628 SCTP_ASSOCIATION_MAX_RETRANS)
629 {
630 // The remote-peer is considered to be unreachable hence shutting down
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100631
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100632 /* Start cleanup. App wasn't notified yet so use delete notify as
633 * opposed to delete to cleanup session layer state. */
634 stream_session_delete_notify (&sctp_conn->sub_conn
635 [MAIN_SCTP_SUB_CONN_IDX].connection);
636
637 sctp_connection_timers_reset (sctp_conn);
638
639 sctp_connection_cleanup (sctp_conn);
640 }
641 return;
642
643heartbeat:
644 sctp_send_heartbeat (sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100645}
646
Marco Varlese191a5942017-10-30 18:17:21 +0100647static void
648sctp_expired_timers_dispatch (u32 * expired_timers)
649{
650 int i;
651 u32 connection_index, timer_id;
652
653 for (i = 0; i < vec_len (expired_timers); i++)
654 {
655 /* Get session index and timer id */
656 connection_index = expired_timers[i] & 0x0FFFFFFF;
657 timer_id = expired_timers[i] >> 28;
658
Marco Varlesef47276f2018-02-06 09:01:39 +0100659 SCTP_DBG ("Expired timer ID: %u", timer_id);
660
Marco Varlese191a5942017-10-30 18:17:21 +0100661 /* Handle expiration */
Marco Varlesedf5a99c2018-02-06 13:48:30 +0100662 sctp_expired_timers_cb (connection_index, timer_id);
Marco Varlese191a5942017-10-30 18:17:21 +0100663 }
664}
665
666void
667sctp_initialize_timer_wheels (sctp_main_t * tm)
668{
669 tw_timer_wheel_16t_2w_512sl_t *tw;
670 /* *INDENT-OFF* */
671 foreach_vlib_main (({
672 tw = &tm->timer_wheels[ii];
673 tw_timer_wheel_init_16t_2w_512sl (tw, sctp_expired_timers_dispatch,
674 100e-3 /* timer period 100ms */ , ~0);
675 tw->last_run_time = vlib_time_now (this_vlib_main);
676 }));
677 /* *INDENT-ON* */
678}
679
680clib_error_t *
681sctp_main_enable (vlib_main_t * vm)
682{
683 sctp_main_t *tm = vnet_get_sctp_main ();
684 vlib_thread_main_t *vtm = vlib_get_thread_main ();
685 clib_error_t *error = 0;
686 u32 num_threads;
687 int thread;
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100688 sctp_connection_t *sctp_conn __attribute__ ((unused));
Marco Varlese191a5942017-10-30 18:17:21 +0100689 u32 preallocated_connections_per_thread;
690
691 if ((error = vlib_call_init_function (vm, ip_main_init)))
692 return error;
693 if ((error = vlib_call_init_function (vm, ip4_lookup_init)))
694 return error;
695 if ((error = vlib_call_init_function (vm, ip6_lookup_init)))
696 return error;
697
698 /*
699 * Registrations
700 */
701
702 ip4_register_protocol (IP_PROTOCOL_SCTP, sctp4_input_node.index);
703 ip6_register_protocol (IP_PROTOCOL_SCTP, sctp6_input_node.index);
704
705 /*
706 * Initialize data structures
707 */
708
709 num_threads = 1 /* main thread */ + vtm->n_threads;
710 vec_validate (tm->connections, num_threads - 1);
711
712 /*
713 * Preallocate connections. Assume that thread 0 won't
714 * use preallocated threads when running multi-core
715 */
716 if (num_threads == 1)
717 {
718 thread = 0;
719 preallocated_connections_per_thread = tm->preallocated_connections;
720 }
721 else
722 {
723 thread = 1;
724 preallocated_connections_per_thread =
725 tm->preallocated_connections / (num_threads - 1);
726 }
727 for (; thread < num_threads; thread++)
728 {
729 if (preallocated_connections_per_thread)
730 pool_init_fixed (tm->connections[thread],
731 preallocated_connections_per_thread);
732 }
733
734 /* Initialize per worker thread tx buffers (used for control messages) */
735 vec_validate (tm->tx_buffers, num_threads - 1);
736
737 /* Initialize timer wheels */
738 vec_validate (tm->timer_wheels, num_threads - 1);
739 sctp_initialize_timer_wheels (tm);
740
741 /* Initialize clocks per tick for SCTP timestamp. Used to compute
742 * monotonically increasing timestamps. */
743 tm->tstamp_ticks_per_clock = vm->clib_time.seconds_per_clock
744 / SCTP_TSTAMP_RESOLUTION;
745
746 if (num_threads > 1)
747 {
Marco Varlesef47276f2018-02-06 09:01:39 +0100748 clib_spinlock_init (&tm->half_open_lock);
Marco Varlese191a5942017-10-30 18:17:21 +0100749 }
750
751 vec_validate (tm->tx_frames[0], num_threads - 1);
752 vec_validate (tm->tx_frames[1], num_threads - 1);
753 vec_validate (tm->ip_lookup_tx_frames[0], num_threads - 1);
754 vec_validate (tm->ip_lookup_tx_frames[1], num_threads - 1);
755
756 tm->bytes_per_buffer = vlib_buffer_free_list_buffer_size
757 (vm, VLIB_BUFFER_DEFAULT_FREE_LIST_INDEX);
758
759 vec_validate (tm->time_now, num_threads - 1);
760 return error;
761}
762
763clib_error_t *
764sctp_enable_disable (vlib_main_t * vm, u8 is_en)
765{
766 if (is_en)
767 {
768 if (sctp_main.is_enabled)
769 return 0;
770
771 return sctp_main_enable (vm);
772 }
773 else
774 {
775 sctp_main.is_enabled = 0;
776 }
777
778 return 0;
779}
780
781transport_connection_t *
782sctp_half_open_session_get_transport (u32 conn_index)
783{
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100784 sctp_connection_t *sctp_conn = sctp_half_open_connection_get (conn_index);
785 return &sctp_conn->sub_conn[MAIN_SCTP_SUB_CONN_IDX].connection;
Marco Varlese191a5942017-10-30 18:17:21 +0100786}
787
788u8 *
789format_sctp_half_open (u8 * s, va_list * args)
790{
791 u32 tci = va_arg (*args, u32);
Marco Varlese8ad6a2d2018-01-26 16:50:01 +0100792 sctp_connection_t *sctp_conn = sctp_half_open_connection_get (tci);
793 return format (s, "%U", format_sctp_connection_id, sctp_conn);
Marco Varlese191a5942017-10-30 18:17:21 +0100794}
795
Marco Varlese21c8baf2018-02-02 17:17:51 +0100796void
797sctp_update_time (f64 now, u8 thread_index)
798{
799 sctp_set_time_now (thread_index);
800 tw_timer_expire_timers_16t_2w_512sl (&sctp_main.timer_wheels[thread_index],
801 now);
802 sctp_flush_frames_to_output (thread_index);
803}
804
Marco Varlese191a5942017-10-30 18:17:21 +0100805/* *INDENT OFF* */
806const static transport_proto_vft_t sctp_proto = {
807 .enable = sctp_enable_disable,
808 .bind = sctp_session_bind,
809 .unbind = sctp_session_unbind,
810 .open = sctp_session_open,
811 .close = sctp_session_close,
812 .cleanup = sctp_session_cleanup,
813 .push_header = sctp_push_header,
814 .send_mss = sctp_session_send_mss,
815 .send_space = sctp_session_send_space,
816 .tx_fifo_offset = NULL, //sctp_session_tx_fifo_offset,
Marco Varlese21c8baf2018-02-02 17:17:51 +0100817 .update_time = sctp_update_time,
Marco Varlese191a5942017-10-30 18:17:21 +0100818 .get_connection = sctp_session_get_transport,
819 .get_listener = sctp_session_get_listener,
820 .get_half_open = sctp_half_open_session_get_transport,
821 .format_connection = format_sctp_session,
822 .format_listener = format_sctp_listener_session,
823 .format_half_open = format_sctp_half_open,
824};
825
826/* *INDENT ON* */
827
828clib_error_t *
829sctp_init (vlib_main_t * vm)
830{
831 sctp_main_t *tm = vnet_get_sctp_main ();
832 ip_main_t *im = &ip_main;
833 ip_protocol_info_t *pi;
834 /* Session layer, and by implication SCTP, are disabled by default */
835 tm->is_enabled = 0;
836
837 /* Register with IP for header parsing */
838 pi = ip_get_protocol_info (im, IP_PROTOCOL_SCTP);
839 if (pi == 0)
840 return clib_error_return (0, "SCTP protocol info AWOL");
841 pi->format_header = format_sctp_header;
842 pi->unformat_pg_edit = unformat_pg_sctp_header;
843
844 /* Register as transport with session layer */
845 transport_register_protocol (TRANSPORT_PROTO_SCTP, &sctp_proto,
846 FIB_PROTOCOL_IP4, sctp4_output_node.index);
847 transport_register_protocol (TRANSPORT_PROTO_SCTP, &sctp_proto,
848 FIB_PROTOCOL_IP6, sctp6_output_node.index);
849
850 return 0;
851}
852
853VLIB_INIT_FUNCTION (sctp_init);
854
855/*
856 * fd.io coding-style-patch-verification: ON
857 *
858 * Local Variables:
859 * eval: (c-set-style "gnu")
860 * End:
861 */