blob: ac24fd8084d8d4f2a6d63328c0a451858e128374 [file] [log] [blame]
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +02001/* OpenBSC minimal LAPD implementation */
2
3/* (C) 2009 by oystein@homelien.no
4 * (C) 2009 by Holger Hans Peter Freyther <zecke@selfish.org>
5 * (C) 2010 by Digium and Matthew Fredrickson <creslin@digium.com>
6 * (C) 2011 by Harald Welte <laforge@gnumonks.org>
Andreas Eversberga7ff0012011-09-26 11:29:30 +02007 * (C) 2011 by Andreas Eversberg <jolly@eversberg.eu>
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +02008 *
9 * All Rights Reserved
10 *
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2 of the License, or
14 * (at your option) any later version.
15 *
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License along
22 * with this program; if not, write to the Free Software Foundation, Inc.,
23 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
24 *
25 */
26
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020027#include "internal.h"
28
29#include <stdio.h>
30#include <string.h>
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020031#include <errno.h>
32
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020033#include <osmocom/core/linuxlist.h>
34#include <osmocom/core/logging.h>
Harald Welte71d87b22011-07-18 14:49:56 +020035#include <osmocom/core/talloc.h>
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020036#include <osmocom/core/msgb.h>
37#include <osmocom/core/timer.h>
Andreas Eversberga7ff0012011-09-26 11:29:30 +020038#include <osmocom/abis/lapd.h>
Pablo Neira Ayuso95306002012-08-22 16:43:59 +020039#include <osmocom/abis/lapd_pcap.h>
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020040
Andreas Eversberga7ff0012011-09-26 11:29:30 +020041#define LAPD_ADDR2(sapi, cr) ((((sapi) & 0x3f) << 2) | (((cr) & 0x1) << 1))
42#define LAPD_ADDR3(tei) ((((tei) & 0x7f) << 1) | 0x1)
43
44#define LAPD_ADDR_SAPI(addr) ((addr) >> 2)
45#define LAPD_ADDR_CR(addr) (((addr) >> 1) & 0x1)
46#define LAPD_ADDR_EA(addr) ((addr) & 0x1)
47#define LAPD_ADDR_TEI(addr) ((addr) >> 1)
48
49#define LAPD_CTRL_I4(ns) (((ns) & 0x7f) << 1)
50#define LAPD_CTRL_I5(nr, p) ((((nr) & 0x7f) << 1) | ((p) & 0x1))
51#define LAPD_CTRL_S4(s) ((((s) & 0x3) << 2) | 0x1)
52#define LAPD_CTRL_S5(nr, p) ((((nr) & 0x7f) << 1) | ((p) & 0x1))
53#define LAPD_CTRL_U4(u, p) ((((u) & 0x1c) << (5-2)) | (((p) & 0x1) << 4) | (((u) & 0x3) << 2) | 0x3)
54
55#define LAPD_CTRL_is_I(ctrl) (((ctrl) & 0x1) == 0)
56#define LAPD_CTRL_is_S(ctrl) (((ctrl) & 0x3) == 1)
57#define LAPD_CTRL_is_U(ctrl) (((ctrl) & 0x3) == 3)
58
59#define LAPD_CTRL_U_BITS(ctrl) ((((ctrl) & 0xC) >> 2) | ((ctrl) & 0xE0) >> 3)
60#define LAPD_CTRL_U_PF(ctrl) (((ctrl) >> 4) & 0x1)
61
62#define LAPD_CTRL_S_BITS(ctrl) (((ctrl) & 0xC) >> 2)
63#define LAPD_CTRL_S_PF(ctrl) (ctrl & 0x1)
64
65#define LAPD_CTRL_I_Ns(ctrl) (((ctrl) & 0xFE) >> 1)
66#define LAPD_CTRL_I_P(ctrl) (ctrl & 0x1)
67#define LAPD_CTRL_Nr(ctrl) (((ctrl) & 0xFE) >> 1)
68
69#define LAPD_LEN(len) ((len << 2) | 0x1)
70#define LAPD_EL 0x1
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +020071
Andreas Eversberg3c460442011-09-28 02:46:16 +020072#define LAPD_SET_K(n, o) {n,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o,o}
73
Andreas Eversberg3744b872011-09-27 12:12:36 +020074const struct lapd_profile lapd_profile_isdn = {
Pablo Neira Ayusof42280b2012-03-12 18:17:31 +010075 .k = LAPD_SET_K(7,7),
76 .n200 = 3,
77 .n201 = 260,
78 .n202 = 3,
79 .t200_sec = 1, .t200_usec = 0,
80 .t201_sec = 1, .t201_usec = 0,
81 .t202_sec = 2, .t202_usec = 0,
82 .t203_sec = 10, .t203_usec = 0,
83 .short_address = 0
Andreas Eversberg3744b872011-09-27 12:12:36 +020084};
85
86const struct lapd_profile lapd_profile_abis = {
Pablo Neira Ayusof42280b2012-03-12 18:17:31 +010087 .k = LAPD_SET_K(2,1),
88 .n200 = 3,
89 .n201 = 260,
90 .n202 = 0, /* infinite */
91 .t200_sec = 0, .t200_usec = 240000,
92 .t201_sec = 1, .t201_usec = 0,
93 .t202_sec = 2, .t202_usec = 0,
94 .t203_sec = 10, .t203_usec = 0,
95 .short_address = 0
Andreas Eversberg3744b872011-09-27 12:12:36 +020096};
97
98const struct lapd_profile lapd_profile_sat = {
Pablo Neira Ayusof42280b2012-03-12 18:17:31 +010099 .k = LAPD_SET_K(15,15),
100 .n200 = 5,
101 .n201 = 260,
102 .n202 = 5,
103 .t200_sec = 2, .t200_usec = 400000,
104 .t201_sec = 2, .t201_usec = 400000,
105 .t202_sec = 2, .t202_usec = 400000,
Holger Hans Peter Freyther4b6860d2013-03-09 17:32:33 +0100106 .t203_sec = 20, .t203_usec = 0,
Pablo Neira Ayusof42280b2012-03-12 18:17:31 +0100107 .short_address = 1
Andreas Eversberg3744b872011-09-27 12:12:36 +0200108};
109
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200110typedef enum {
111 LAPD_TEI_NONE = 0,
112 LAPD_TEI_ASSIGNED,
113 LAPD_TEI_ACTIVE,
114} lapd_tei_state;
115
116const char *lapd_tei_states[] = {
117 "NONE",
118 "ASSIGNED",
119 "ACTIVE",
120};
121
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200122/* Structure representing an allocated TEI within a LAPD instance. */
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200123struct lapd_tei {
124 struct llist_head list;
125 struct lapd_instance *li;
126 uint8_t tei;
127 lapd_tei_state state;
128
129 struct llist_head sap_list;
130};
131
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200132/* Structure representing a SAP within a TEI. It includes exactly one datalink
133 * instance. */
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200134struct lapd_sap {
135 struct llist_head list;
136 struct lapd_tei *tei;
137 uint8_t sapi;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200138
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200139 struct lapd_datalink dl;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200140};
141
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200142/* Resolve TEI structure from given numeric TEI */
143static struct lapd_tei *teip_from_tei(struct lapd_instance *li, uint8_t tei)
144{
145 struct lapd_tei *lt;
146
147 llist_for_each_entry(lt, &li->tei_list, list) {
148 if (lt->tei == tei)
149 return lt;
150 }
151 return NULL;
152};
153
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200154/* Change state of TEI */
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200155static void lapd_tei_set_state(struct lapd_tei *teip, int newstate)
156{
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200157 LOGP(DLLAPD, LOGL_INFO, "LAPD state change on TEI %d: %s -> %s\n",
158 teip->tei, lapd_tei_states[teip->state],
159 lapd_tei_states[newstate]);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200160 teip->state = newstate;
161};
162
163/* Allocate a new TEI */
164struct lapd_tei *lapd_tei_alloc(struct lapd_instance *li, uint8_t tei)
165{
166 struct lapd_tei *teip;
167
168 teip = talloc_zero(li, struct lapd_tei);
169 if (!teip)
170 return NULL;
171
172 teip->li = li;
173 teip->tei = tei;
174 llist_add(&teip->list, &li->tei_list);
175 INIT_LLIST_HEAD(&teip->sap_list);
176
177 lapd_tei_set_state(teip, LAPD_TEI_ASSIGNED);
178
179 return teip;
180}
181
182/* Find a SAP within a given TEI */
183static struct lapd_sap *lapd_sap_find(struct lapd_tei *teip, uint8_t sapi)
184{
185 struct lapd_sap *sap;
186
187 llist_for_each_entry(sap, &teip->sap_list, list) {
188 if (sap->sapi == sapi)
189 return sap;
190 }
191
192 return NULL;
193}
194
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200195static int send_ph_data_req(struct lapd_msg_ctx *lctx, struct msgb *msg);
196static int send_dlsap(struct osmo_dlsap_prim *dp, struct lapd_msg_ctx *lctx);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200197
198/* Allocate a new SAP within a given TEI */
199static struct lapd_sap *lapd_sap_alloc(struct lapd_tei *teip, uint8_t sapi)
200{
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200201 struct lapd_sap *sap;
202 struct lapd_datalink *dl;
203 struct lapd_instance *li;
Andreas Eversberg3744b872011-09-27 12:12:36 +0200204 struct lapd_profile *profile;
205 int k;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200206
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200207 sap = talloc_zero(teip, struct lapd_sap);
208 if (!sap)
209 return NULL;
210
Andreas Eversberg3c460442011-09-28 02:46:16 +0200211 LOGP(DLLAPD, LOGL_NOTICE, "LAPD Allocating SAP for SAPI=%u / TEI=%u\n",
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200212 sapi, teip->tei);
213
214 sap->sapi = sapi;
215 sap->tei = teip;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200216 dl = &sap->dl;
217 li = teip->li;
Andreas Eversberg3744b872011-09-27 12:12:36 +0200218 profile = &li->profile;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200219
Andreas Eversberg3c460442011-09-28 02:46:16 +0200220 k = profile->k[sapi & 0x3f];
221 LOGP(DLLAPD, LOGL_NOTICE, "k=%d N200=%d N201=%d T200=%d.%d T203=%d.%d"
222 "\n", k, profile->n200, profile->n201, profile->t200_sec,
223 profile->t200_usec, profile->t203_sec, profile->t203_usec);
Andreas Eversberg3744b872011-09-27 12:12:36 +0200224 lapd_dl_init(dl, k, 128, profile->n201);
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200225 dl->use_sabme = 1; /* use SABME instead of SABM (GSM) */
226 dl->send_ph_data_req = send_ph_data_req;
227 dl->send_dlsap = send_dlsap;
Andreas Eversberg3744b872011-09-27 12:12:36 +0200228 dl->n200 = profile->n200;
229 dl->n200_est_rel = profile->n200;
230 dl->t200_sec = profile->t200_sec; dl->t200_usec = profile->t200_usec;
231 dl->t203_sec = profile->t203_sec; dl->t203_usec = profile->t203_usec;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200232 dl->lctx.dl = &sap->dl;
233 dl->lctx.sapi = sapi;
234 dl->lctx.tei = teip->tei;
Andreas Eversberg3744b872011-09-27 12:12:36 +0200235 dl->lctx.n201 = profile->n201;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200236
237 lapd_set_mode(&sap->dl, (teip->li->network_side) ? LAPD_MODE_NETWORK
238 : LAPD_MODE_USER);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200239
240 llist_add(&sap->list, &teip->sap_list);
241
242 return sap;
243}
244
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200245/* Free SAP instance, including the datalink */
246static void lapd_sap_free(struct lapd_sap *sap)
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200247{
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200248 /* free datalink structures and timers */
249 lapd_dl_exit(&sap->dl);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200250
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200251 llist_del(&sap->list);
252 talloc_free(sap);
253}
254
255/* Free TEI instance */
256static void lapd_tei_free(struct lapd_tei *teip)
257{
258 struct lapd_sap *sap, *sap2;
259
260 llist_for_each_entry_safe(sap, sap2, &teip->sap_list, list) {
261 lapd_sap_free(sap);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200262 }
263
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200264 llist_del(&teip->list);
265 talloc_free(teip);
266}
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200267
268/* Input function into TEI manager */
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200269static int lapd_tei_receive(struct lapd_instance *li, uint8_t *data, int len)
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200270{
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200271 uint8_t entity;
272 uint8_t ref;
273 uint8_t mt;
274 uint8_t action;
275 uint8_t e;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200276 uint8_t resp[8];
277 struct lapd_tei *teip;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200278 struct msgb *msg;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200279
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200280 if (len < 5) {
281 LOGP(DLLAPD, LOGL_ERROR, "LAPD TEIMGR frame receive len %d < 5"
282 ", ignoring\n", len);
283 return -EINVAL;
284 };
285
286 entity = data[0];
287 ref = data[1];
288 mt = data[3];
289 action = data[4] >> 1;
290 e = data[4] & 1;
291
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200292 DEBUGP(DLLAPD, "LAPD TEIMGR: entity %x, ref %x, mt %x, action %x, "
293 "e %x\n", entity, ref, mt, action, e);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200294
295 switch (mt) {
296 case 0x01: /* IDENTITY REQUEST */
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200297 DEBUGP(DLLAPD, "LAPD TEIMGR: identity request for TEI %u\n",
298 action);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200299
300 teip = teip_from_tei(li, action);
301 if (!teip) {
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200302 LOGP(DLLAPD, LOGL_INFO, "TEI MGR: New TEI %u\n",
303 action);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200304 teip = lapd_tei_alloc(li, action);
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200305 if (!teip)
306 return -ENOMEM;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200307 }
308
309 /* Send ACCEPT */
310 memmove(resp, "\xfe\xff\x03\x0f\x00\x00\x02\x00", 8);
311 resp[7] = (action << 1) | 1;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200312 msg = msgb_alloc_headroom(56, 56, "DL EST");
313 msg->l2h = msgb_push(msg, 8);
314 memcpy(msg->l2h, resp, 8);
Pablo Neira Ayuso95306002012-08-22 16:43:59 +0200315
316 /* write to PCAP file, if enabled. */
317 osmo_pcap_lapd_write(li->pcap_fd, OSMO_LAPD_PCAP_OUTPUT, msg);
318
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200319 LOGP(DLLAPD, LOGL_DEBUG, "TX: %s\n",
320 osmo_hexdump(msg->data, msg->len));
321 li->transmit_cb(msg, li->transmit_cbdata);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200322
323 if (teip->state == LAPD_TEI_NONE)
324 lapd_tei_set_state(teip, LAPD_TEI_ASSIGNED);
325 break;
326 default:
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200327 LOGP(DLLAPD, LOGL_NOTICE, "LAPD TEIMGR: unknown mt %x "
328 "action %x\n", mt, action);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200329 break;
330 };
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200331
332 return 0;
333}
334
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200335/* General input function for any data received for this LAPD instance */
336int lapd_receive(struct lapd_instance *li, struct msgb *msg, int *error)
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200337{
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200338 int i;
339 struct lapd_msg_ctx lctx;
340 int rc;
341 struct lapd_sap *sap;
342 struct lapd_tei *teip;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200343
Pablo Neira Ayuso95306002012-08-22 16:43:59 +0200344 /* write to PCAP file, if enabled. */
345 osmo_pcap_lapd_write(li->pcap_fd, OSMO_LAPD_PCAP_INPUT, msg);
346
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200347 LOGP(DLLAPD, LOGL_DEBUG, "RX: %s\n", osmo_hexdump(msg->data, msg->len));
348 if (msg->len < 2) {
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200349 LOGP(DLLAPD, LOGL_ERROR, "LAPD frame receive len %d < 2, "
350 "ignoring\n", msg->len);
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200351 *error = LAPD_ERR_BAD_LEN;
352 return -EINVAL;
353 };
354 msg->l2h = msg->data;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200355
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200356 memset(&lctx, 0, sizeof(lctx));
357
358 i = 0;
359 /* adress field */
360 lctx.sapi = LAPD_ADDR_SAPI(msg->l2h[i]);
361 lctx.cr = LAPD_ADDR_CR(msg->l2h[i]);
362 lctx.lpd = 0;
363 if (!LAPD_ADDR_EA(msg->l2h[i])) {
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200364 if (msg->len < 3) {
365 LOGP(DLLAPD, LOGL_ERROR, "LAPD frame with TEI receive "
366 "len %d < 3, ignoring\n", msg->len);
367 *error = LAPD_ERR_BAD_LEN;
368 return -EINVAL;
369 };
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200370 i++;
371 lctx.tei = LAPD_ADDR_TEI(msg->l2h[i]);
372 }
373 i++;
374 /* control field */
375 if (LAPD_CTRL_is_I(msg->l2h[i])) {
376 lctx.format = LAPD_FORM_I;
377 lctx.n_send = LAPD_CTRL_I_Ns(msg->l2h[i]);
378 i++;
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200379 if (msg->len < 3 && i == 2) {
380 LOGP(DLLAPD, LOGL_ERROR, "LAPD I frame without TEI "
381 "receive len %d < 3, ignoring\n", msg->len);
382 *error = LAPD_ERR_BAD_LEN;
383 return -EINVAL;
384 };
385 if (msg->len < 4 && i == 3) {
386 LOGP(DLLAPD, LOGL_ERROR, "LAPD I frame with TEI "
387 "receive len %d < 4, ignoring\n", msg->len);
388 *error = LAPD_ERR_BAD_LEN;
389 return -EINVAL;
390 };
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200391 lctx.n_recv = LAPD_CTRL_Nr(msg->l2h[i]);
392 lctx.p_f = LAPD_CTRL_I_P(msg->l2h[i]);
393 } else if (LAPD_CTRL_is_S(msg->l2h[i])) {
394 lctx.format = LAPD_FORM_S;
395 lctx.s_u = LAPD_CTRL_S_BITS(msg->l2h[i]);
396 i++;
Andreas Eversberg8aaed052011-10-01 04:10:57 +0200397 if (msg->len < 3 && i == 2) {
398 LOGP(DLLAPD, LOGL_ERROR, "LAPD S frame without TEI "
399 "receive len %d < 3, ignoring\n", msg->len);
400 *error = LAPD_ERR_BAD_LEN;
401 return -EINVAL;
402 };
403 if (msg->len < 4 && i == 3) {
404 LOGP(DLLAPD, LOGL_ERROR, "LAPD S frame with TEI "
405 "receive len %d < 4, ignoring\n", msg->len);
406 *error = LAPD_ERR_BAD_LEN;
407 return -EINVAL;
408 };
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200409 lctx.n_recv = LAPD_CTRL_Nr(msg->l2h[i]);
410 lctx.p_f = LAPD_CTRL_S_PF(msg->l2h[i]);
411 } else if (LAPD_CTRL_is_U(msg->l2h[i])) {
412 lctx.format = LAPD_FORM_U;
413 lctx.s_u = LAPD_CTRL_U_BITS(msg->l2h[i]);
414 lctx.p_f = LAPD_CTRL_U_PF(msg->l2h[i]);
415 } else
416 lctx.format = LAPD_FORM_UKN;
417 i++;
418 /* length */
419 msg->l3h = msg->l2h + i;
420 msgb_pull(msg, i);
421 lctx.length = msg->len;
422
423 /* perform TEI assignment, if received */
424 if (lctx.tei == 127) {
425 rc = lapd_tei_receive(li, msg->data, msg->len);
426 msgb_free(msg);
427 return rc;
428 }
429
430 /* resolve TEI and SAPI */
431 teip = teip_from_tei(li, lctx.tei);
432 if (!teip) {
433 LOGP(DLLAPD, LOGL_NOTICE, "LAPD Unknown TEI %u\n", lctx.tei);
434 *error = LAPD_ERR_UNKNOWN_TEI;
435 msgb_free(msg);
436 return -EINVAL;
437 }
438 sap = lapd_sap_find(teip, lctx.sapi);
439 if (!sap) {
440 LOGP(DLLAPD, LOGL_INFO, "LAPD No SAP for TEI=%u / SAPI=%u, "
441 "allocating\n", lctx.tei, lctx.sapi);
442 sap = lapd_sap_alloc(teip, lctx.sapi);
443 if (!sap) {
444 *error = LAPD_ERR_NO_MEM;
445 msgb_free(msg);
446 return -ENOMEM;
447 }
448 }
449 lctx.dl = &sap->dl;
450 lctx.n201 = lctx.dl->maxf;
451
452 if (msg->len > lctx.n201) {
453 LOGP(DLLAPD, LOGL_ERROR, "message len %d > N201(%d) "
454 "(discarding)\n", msg->len, lctx.n201);
455 msgb_free(msg);
456 *error = LAPD_ERR_BAD_LEN;
457 return -EINVAL;
458 }
459
460 /* send to LAPD */
461 return lapd_ph_data_ind(msg, &lctx);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200462}
463
464/* Start a (user-side) SAP for the specified TEI/SAPI on the LAPD instance */
465int lapd_sap_start(struct lapd_instance *li, uint8_t tei, uint8_t sapi)
466{
467 struct lapd_sap *sap;
468 struct lapd_tei *teip;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200469 struct osmo_dlsap_prim dp;
470 struct msgb *msg;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200471
472 teip = teip_from_tei(li, tei);
473 if (!teip)
474 teip = lapd_tei_alloc(li, tei);
475
476 sap = lapd_sap_find(teip, sapi);
477 if (sap)
478 return -EEXIST;
479
480 sap = lapd_sap_alloc(teip, sapi);
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200481 if (!sap)
482 return -ENOMEM;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200483
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200484 LOGP(DLLAPD, LOGL_NOTICE, "LAPD DL-ESTABLISH request TEI=%d SAPI=%d\n",
485 tei, sapi);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200486
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200487 /* prepare prim */
488 msg = msgb_alloc_headroom(56, 56, "DL EST");
489 msg->l3h = msg->data;
490 osmo_prim_init(&dp.oph, 0, PRIM_DL_EST, PRIM_OP_REQUEST, msg);
491
492 /* send to L2 */
493 return lapd_recv_dlsap(&dp, &sap->dl.lctx);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200494}
495
496/* Stop a (user-side) SAP for the specified TEI/SAPI on the LAPD instance */
497int lapd_sap_stop(struct lapd_instance *li, uint8_t tei, uint8_t sapi)
498{
499 struct lapd_tei *teip;
500 struct lapd_sap *sap;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200501 struct osmo_dlsap_prim dp;
502 struct msgb *msg;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200503
504 teip = teip_from_tei(li, tei);
505 if (!teip)
506 return -ENODEV;
507
508 sap = lapd_sap_find(teip, sapi);
509 if (!sap)
510 return -ENODEV;
511
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200512 LOGP(DLLAPD, LOGL_NOTICE, "LAPD DL-RELEASE request TEI=%d SAPI=%d\n",
513 tei, sapi);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200514
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200515 /* prepare prim */
516 msg = msgb_alloc_headroom(56, 56, "DL REL");
517 msg->l3h = msg->data;
518 osmo_prim_init(&dp.oph, 0, PRIM_DL_REL, PRIM_OP_REQUEST, msg);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200519
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200520 /* send to L2 */
521 return lapd_recv_dlsap(&dp, &sap->dl.lctx);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200522}
523
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200524/* Transmit Data (DL-DATA request) on the given LAPD Instance / TEI / SAPI */
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200525void lapd_transmit(struct lapd_instance *li, uint8_t tei, uint8_t sapi,
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200526 struct msgb *msg)
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200527{
528 struct lapd_tei *teip = teip_from_tei(li, tei);
529 struct lapd_sap *sap;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200530 struct osmo_dlsap_prim dp;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200531
532 if (!teip) {
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200533 LOGP(DLLAPD, LOGL_ERROR, "LAPD Cannot transmit on "
Harald Welte4ca16c72011-08-16 14:01:49 +0200534 "non-existing TEI %u\n", tei);
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200535 msgb_free(msg);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200536 return;
537 }
538
539 sap = lapd_sap_find(teip, sapi);
540 if (!sap) {
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200541 LOGP(DLLAPD, LOGL_INFO, "LAPD Tx on unknown SAPI=%u "
542 "in TEI=%u\n", sapi, tei);
543 msgb_free(msg);
544 return;
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200545 }
546
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200547 /* prepare prim */
548 msg->l3h = msg->data;
549 osmo_prim_init(&dp.oph, 0, PRIM_DL_DATA, PRIM_OP_REQUEST, msg);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200550
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200551 /* send to L2 */
552 lapd_recv_dlsap(&dp, &sap->dl.lctx);
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200553};
554
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200555static int send_ph_data_req(struct lapd_msg_ctx *lctx, struct msgb *msg)
556{
557 struct lapd_datalink *dl = lctx->dl;
558 struct lapd_sap *sap =
559 container_of(dl, struct lapd_sap, dl);
560 struct lapd_instance *li = sap->tei->li;
561 int format = lctx->format;
562 int addr_len;
563
564 /* control field */
565 switch (format) {
566 case LAPD_FORM_I:
567 msg->l2h = msgb_push(msg, 2);
568 msg->l2h[0] = LAPD_CTRL_I4(lctx->n_send);
569 msg->l2h[1] = LAPD_CTRL_I5(lctx->n_recv, lctx->p_f);
570 break;
571 case LAPD_FORM_S:
572 msg->l2h = msgb_push(msg, 2);
573 msg->l2h[0] = LAPD_CTRL_S4(lctx->s_u);
574 msg->l2h[1] = LAPD_CTRL_S5(lctx->n_recv, lctx->p_f);
575 break;
576 case LAPD_FORM_U:
577 msg->l2h = msgb_push(msg, 1);
578 msg->l2h[0] = LAPD_CTRL_U4(lctx->s_u, lctx->p_f);
579 break;
580 default:
581 msgb_free(msg);
582 return -EINVAL;
583 }
584 /* address field */
Andreas Eversberg3744b872011-09-27 12:12:36 +0200585 if (li->profile.short_address && lctx->tei == 0)
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200586 addr_len = 1;
587 else
588 addr_len = 2;
589 msg->l2h = msgb_push(msg, addr_len);
590 msg->l2h[0] = LAPD_ADDR2(lctx->sapi, lctx->cr);
591 if (addr_len == 1)
592 msg->l2h[0] |= 0x1;
593 else
594 msg->l2h[1] = LAPD_ADDR3(lctx->tei);
595
Pablo Neira Ayuso95306002012-08-22 16:43:59 +0200596 /* write to PCAP file, if enabled. */
597 osmo_pcap_lapd_write(li->pcap_fd, OSMO_LAPD_PCAP_OUTPUT, msg);
598
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200599 /* forward frame to L1 */
600 LOGP(DLLAPD, LOGL_DEBUG, "TX: %s\n", osmo_hexdump(msg->data, msg->len));
601 li->transmit_cb(msg, li->transmit_cbdata);
602
603 return 0;
604}
605
606/* A DL-SAP message is received from datalink instance and forwarded to L3 */
607static int send_dlsap(struct osmo_dlsap_prim *dp, struct lapd_msg_ctx *lctx)
608{
609 struct lapd_datalink *dl = lctx->dl;
610 struct lapd_sap *sap =
611 container_of(dl, struct lapd_sap, dl);
612 struct lapd_instance *li;
613 uint8_t tei, sapi;
614 char *op = (dp->oph.operation == PRIM_OP_INDICATION) ? "indication"
615 : "confirm";
616
617 li = sap->tei->li;
618 tei = lctx->tei;
619 sapi = lctx->sapi;
620
621 switch (dp->oph.primitive) {
622 case PRIM_DL_EST:
623 LOGP(DLLAPD, LOGL_NOTICE, "LAPD DL-ESTABLISH %s TEI=%d "
624 "SAPI=%d\n", op, lctx->tei, lctx->sapi);
625 break;
626 case PRIM_DL_REL:
627 LOGP(DLLAPD, LOGL_NOTICE, "LAPD DL-RELEASE %s TEI=%d "
628 "SAPI=%d\n", op, lctx->tei, lctx->sapi);
629 lapd_sap_free(sap);
630 /* note: sap and dl is now gone, don't use it anymore */
631 break;
632 default:
633 ;
634 }
635
636 li->receive_cb(dp, tei, sapi, li->receive_cbdata);
637
638 return 0;
639}
640
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200641/* Allocate a new LAPD instance */
642struct lapd_instance *lapd_instance_alloc(int network_side,
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200643 void (*tx_cb)(struct msgb *msg, void *cbdata), void *tx_cbdata,
644 void (*rx_cb)(struct osmo_dlsap_prim *odp, uint8_t tei, uint8_t sapi,
645 void *rx_cbdata), void *rx_cbdata,
Andreas Eversberg3744b872011-09-27 12:12:36 +0200646 const struct lapd_profile *profile)
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200647{
648 struct lapd_instance *li;
649
650 li = talloc_zero(NULL, struct lapd_instance);
651 if (!li)
652 return NULL;
653
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200654 li->network_side = network_side;
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200655 li->transmit_cb = tx_cb;
656 li->transmit_cbdata = tx_cbdata;
657 li->receive_cb = rx_cb;
658 li->receive_cbdata = rx_cbdata;
Pablo Neira Ayuso95306002012-08-22 16:43:59 +0200659 li->pcap_fd = -1;
Andreas Eversberg3744b872011-09-27 12:12:36 +0200660 memcpy(&li->profile, profile, sizeof(li->profile));
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200661
Pablo Neira Ayuso0ba77d52011-06-05 18:32:44 +0200662 INIT_LLIST_HEAD(&li->tei_list);
663
664 return li;
665}
Harald Welte14078ea2011-08-24 09:45:11 +0200666
667void lapd_instance_free(struct lapd_instance *li)
668{
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200669 struct lapd_tei *teip, *teip2;
Harald Weltef350e252011-08-26 07:55:26 +0200670
Andreas Eversberga7ff0012011-09-26 11:29:30 +0200671 /* Free all TEI instances */
672 llist_for_each_entry_safe(teip, teip2, &li->tei_list, list) {
673 lapd_tei_free(teip);
Harald Weltef350e252011-08-26 07:55:26 +0200674 }
675
Harald Welte14078ea2011-08-24 09:45:11 +0200676 talloc_free(li);
677}