blob: 0eface358a095d9abca8f0149b527b8095ad82e3 [file] [log] [blame]
Harald Welte2720e732010-05-17 00:44:57 +02001/* GPRS SGSN integration with libgtp of OpenGGSN */
Harald Welte993d0602010-06-04 17:43:19 +02002/* libgtp implements the GPRS Tunelling Protocol GTP per TS 09.60 / 29.060 */
Harald Welte2720e732010-05-17 00:44:57 +02003
4/* (C) 2010 by Harald Welte <laforge@gnumonks.org>
5 * (C) 2010 by On Waves
6 * All Rights Reserved
7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License along
19 * with this program; if not, write to the Free Software Foundation, Inc.,
20 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
21 *
22 */
23
24#include <unistd.h>
25#include <stdio.h>
26#include <stdlib.h>
27#include <string.h>
28#include <getopt.h>
29#include <errno.h>
30#include <signal.h>
31#include <sys/fcntl.h>
32#include <sys/stat.h>
33#include <sys/types.h>
34#include <sys/socket.h>
35#include <netinet/in.h>
36#include <arpa/inet.h>
37
38#include <osmocore/talloc.h>
39#include <osmocore/select.h>
40#include <osmocore/rate_ctr.h>
Harald Welte6abf94e2010-05-18 10:35:06 +020041#include <openbsc/gsm_04_08_gprs.h>
Harald Welte2720e732010-05-17 00:44:57 +020042
43#include <openbsc/signal.h>
44#include <openbsc/debug.h>
45#include <openbsc/sgsn.h>
Harald Welteebabdea2010-06-01 18:28:10 +020046#include <openbsc/gprs_llc.h>
47#include <openbsc/gprs_bssgp.h>
Harald Welte2720e732010-05-17 00:44:57 +020048#include <openbsc/gprs_sgsn.h>
Harald Welte6abf94e2010-05-18 10:35:06 +020049#include <openbsc/gprs_gmm.h>
Harald Welte2720e732010-05-17 00:44:57 +020050
51#include <gtp.h>
52#include <pdp.h>
53
Harald Welte2720e732010-05-17 00:44:57 +020054const struct value_string gtp_cause_strs[] = {
55 { GTPCAUSE_REQ_IMSI, "Request IMSI" },
56 { GTPCAUSE_REQ_IMEI, "Request IMEI" },
57 { GTPCAUSE_REQ_IMSI_IMEI, "Request IMSI and IMEI" },
58 { GTPCAUSE_NO_ID_NEEDED, "No identity needed" },
59 { GTPCAUSE_MS_REFUSES_X, "MS refuses" },
60 { GTPCAUSE_MS_NOT_RESP_X, "MS is not GPRS responding" },
61 { GTPCAUSE_ACC_REQ, "Request accepted" },
62 { GTPCAUSE_NON_EXIST, "Non-existent" },
63 { GTPCAUSE_INVALID_MESSAGE, "Invalid message format" },
64 { GTPCAUSE_IMSI_NOT_KNOWN, "IMSI not known" },
65 { GTPCAUSE_MS_DETACHED, "MS is GPRS detached" },
66 { GTPCAUSE_MS_NOT_RESP, "MS is not GPRS responding" },
67 { GTPCAUSE_MS_REFUSES, "MS refuses" },
68 { GTPCAUSE_NO_RESOURCES, "No resources available" },
69 { GTPCAUSE_NOT_SUPPORTED, "Service not supported" },
70 { GTPCAUSE_MAN_IE_INCORRECT, "Mandatory IE incorrect" },
71 { GTPCAUSE_MAN_IE_MISSING, "Mandatory IE missing" },
72 { GTPCAUSE_OPT_IE_INCORRECT, "Optional IE incorrect" },
73 { GTPCAUSE_SYS_FAIL, "System failure" },
74 { GTPCAUSE_ROAMING_REST, "Roaming restrictions" },
75 { GTPCAUSE_PTIMSI_MISMATCH, "P-TMSI Signature mismatch" },
76 { GTPCAUSE_CONN_SUSP, "GPRS connection suspended" },
77 { GTPCAUSE_AUTH_FAIL, "Authentication failure" },
78 { GTPCAUSE_USER_AUTH_FAIL, "User authentication failed" },
79 { GTPCAUSE_CONTEXT_NOT_FOUND, "Context not found" },
80 { GTPCAUSE_ADDR_OCCUPIED, "All dynamic PDP addresses occupied" },
81 { GTPCAUSE_NO_MEMORY, "No memory is available" },
82 { GTPCAUSE_RELOC_FAIL, "Relocation failure" },
83 { GTPCAUSE_UNKNOWN_MAN_EXTHEADER, "Unknown mandatory ext. header" },
84 { GTPCAUSE_SEM_ERR_TFT, "Semantic error in TFT operation" },
85 { GTPCAUSE_SYN_ERR_TFT, "Syntactic error in TFT operation" },
86 { GTPCAUSE_SEM_ERR_FILTER, "Semantic errors in packet filter" },
87 { GTPCAUSE_SYN_ERR_FILTER, "Syntactic errors in packet filter" },
88 { GTPCAUSE_MISSING_APN, "Missing or unknown APN" },
89 { GTPCAUSE_UNKNOWN_PDP, "Unknown PDP address or PDP type" },
90 { 0, NULL }
91};
92
93/* generate a PDP context based on the IE's from the 04.08 message,
94 * and send the GTP create pdp context request to the GGSN */
Harald Welte77289c22010-05-18 14:32:29 +020095struct sgsn_pdp_ctx *sgsn_create_pdp_ctx(struct sgsn_ggsn_ctx *ggsn,
Harald Welted193cb32010-05-17 22:58:03 +020096 struct sgsn_mm_ctx *mmctx,
97 uint16_t nsapi,
98 struct tlv_parsed *tp)
Harald Welte2720e732010-05-17 00:44:57 +020099{
Harald Welted193cb32010-05-17 22:58:03 +0200100 struct sgsn_pdp_ctx *pctx;
Harald Welte2720e732010-05-17 00:44:57 +0200101 struct pdp_t *pdp;
Harald Weltecd4dd4d2010-05-18 17:20:49 +0200102 uint64_t imsi_ui64 = 0;
Harald Welte2720e732010-05-17 00:44:57 +0200103 int rc;
104
Harald Welte77289c22010-05-18 14:32:29 +0200105 LOGP(DGPRS, LOGL_ERROR, "Create PDP Context\n");
Harald Welted193cb32010-05-17 22:58:03 +0200106 pctx = sgsn_pdp_ctx_alloc(mmctx, nsapi);
107 if (!pctx) {
108 LOGP(DGPRS, LOGL_ERROR, "Couldn't allocate PDP Ctx\n");
109 return NULL;
110 }
111
Harald Welte2720e732010-05-17 00:44:57 +0200112 rc = pdp_newpdp(&pdp, imsi_ui64, nsapi, NULL);
113 if (rc) {
Harald Welted193cb32010-05-17 22:58:03 +0200114 LOGP(DGPRS, LOGL_ERROR, "Out of libgtp PDP Contexts\n");
115 return NULL;
Harald Welte2720e732010-05-17 00:44:57 +0200116 }
Harald Weltebb1c8052010-06-03 06:38:38 +0200117 pdp->priv = pctx;
Harald Welted193cb32010-05-17 22:58:03 +0200118 pctx->lib = pdp;
119 pctx->ggsn = ggsn;
120
Harald Welte2720e732010-05-17 00:44:57 +0200121 //pdp->peer = /* sockaddr_in of GGSN (receive) */
122 //pdp->ipif = /* not used by library */
123 pdp->version = ggsn->gtp_version;
124 pdp->hisaddr0 = ggsn->remote_addr;
125 pdp->hisaddr1 = ggsn->remote_addr;
126 //pdp->cch_pdp = 512; /* Charging Flat Rate */
127
128 /* MS provided APN, subscription not verified */
129 pdp->selmode = 0x01;
130
131 /* IMSI, TEID/TEIC, FLLU/FLLC, TID, NSAPI set in pdp_newpdp */
132
133 /* FIXME: MSISDN in BCD format from mmctx */
134 //pdp->msisdn.l/.v
135
136 /* End User Address from GMM requested PDP address */
137 pdp->eua.l = TLVP_LEN(tp, OSMO_IE_GSM_REQ_PDP_ADDR);
138 if (pdp->eua.l > sizeof(pdp->eua.v))
139 pdp->eua.l = sizeof(pdp->eua.v);
140 memcpy(pdp->eua.v, TLVP_VAL(tp, OSMO_IE_GSM_REQ_PDP_ADDR),
141 pdp->eua.l);
142 /* Highest 4 bits of first byte need to be set to 1, otherwise
143 * the IE is identical with the 04.08 PDP Address IE */
144 pdp->eua.v[0] |= 0xf0;
145
146 /* APN name from GMM */
147 pdp->apn_use.l = TLVP_LEN(tp, GSM48_IE_GSM_APN);
148 if (pdp->apn_use.l > sizeof(pdp->apn_use.v))
149 pdp->apn_use.l = sizeof(pdp->apn_use.v);
150 memcpy(pdp->apn_use.v, TLVP_VAL(tp, GSM48_IE_GSM_APN),
151 pdp->apn_use.l);
152
153 /* Protocol Configuration Options from GMM */
154 pdp->pco_req.l = TLVP_LEN(tp, GSM48_IE_GSM_PROTO_CONF_OPT);
155 if (pdp->pco_req.l > sizeof(pdp->pco_req.v))
156 pdp->pco_req.l = sizeof(pdp->pco_req.v);
157 memcpy(pdp->pco_req.v, TLVP_VAL(tp, GSM48_IE_GSM_PROTO_CONF_OPT),
158 pdp->pco_req.l);
159
160 /* QoS options from GMM */
161 pdp->qos_req.l = TLVP_LEN(tp, OSMO_IE_GSM_REQ_QOS);
162 if (pdp->qos_req.l > sizeof(pdp->qos_req.v))
163 pdp->qos_req.l = sizeof(pdp->qos_req.v);
164 memcpy(pdp->qos_req.v, TLVP_VAL(tp, OSMO_IE_GSM_REQ_QOS),
165 pdp->qos_req.l);
166
167 /* SGSN address for control plane */
Harald Welte61ca7ce2010-06-02 23:17:33 +0200168 pdp->gsnlc.l = sizeof(sgsn->cfg.gtp_listenaddr.sin_addr);
169 memcpy(pdp->gsnlc.v, &sgsn->cfg.gtp_listenaddr.sin_addr,
170 sizeof(sgsn->cfg.gtp_listenaddr.sin_addr));
Harald Welte2720e732010-05-17 00:44:57 +0200171
172 /* SGSN address for user plane */
Harald Welte61ca7ce2010-06-02 23:17:33 +0200173 pdp->gsnlu.l = sizeof(sgsn->cfg.gtp_listenaddr.sin_addr);
174 memcpy(pdp->gsnlu.v, &sgsn->cfg.gtp_listenaddr.sin_addr,
175 sizeof(sgsn->cfg.gtp_listenaddr.sin_addr));
Harald Welte2720e732010-05-17 00:44:57 +0200176
Harald Welte6abf94e2010-05-18 10:35:06 +0200177 /* change pdp state to 'requested' */
178 pctx->state = PDP_STATE_CR_REQ;
Harald Welte2720e732010-05-17 00:44:57 +0200179
Harald Welted193cb32010-05-17 22:58:03 +0200180 rc = gtp_create_context_req(ggsn->gsn, pdp, pctx);
181 /* FIXME */
182
183 return pctx;
Harald Welte2720e732010-05-17 00:44:57 +0200184}
185
Harald Welte77289c22010-05-18 14:32:29 +0200186int sgsn_delete_pdp_ctx(struct sgsn_pdp_ctx *pctx)
187{
188 LOGP(DGPRS, LOGL_ERROR, "Delete PDP Context\n");
189
190 /* FIXME: decide if we need teardown or not ! */
191 return gtp_delete_context_req(pctx->ggsn->gsn, pctx->lib, pctx, 1);
192}
Harald Welte6abf94e2010-05-18 10:35:06 +0200193
194struct cause_map {
195 uint8_t cause_in;
196 uint8_t cause_out;
197};
198
199static uint8_t cause_map(const struct cause_map *map, uint8_t in, uint8_t deflt)
200{
201 const struct cause_map *m;
202
203 for (m = map; m->cause_in && m->cause_out; m++) {
204 if (m->cause_in == in)
205 return m->cause_out;
206 }
207 return deflt;
208}
209
210/* how do we map from gtp cause to SM cause */
211static const struct cause_map gtp2sm_cause_map[] = {
212 { GTPCAUSE_NO_RESOURCES, GSM_CAUSE_INSUFF_RSRC },
213 { GTPCAUSE_NOT_SUPPORTED, GSM_CAUSE_SERV_OPT_NOTSUPP },
214 { GTPCAUSE_MAN_IE_INCORRECT, GSM_CAUSE_INV_MAND_INFO },
215 { GTPCAUSE_MAN_IE_MISSING, GSM_CAUSE_INV_MAND_INFO },
216 { GTPCAUSE_OPT_IE_INCORRECT, GSM_CAUSE_PROTO_ERR_UNSPEC },
217 { GTPCAUSE_SYS_FAIL, GSM_CAUSE_NET_FAIL },
218 { GTPCAUSE_ROAMING_REST, GSM_CAUSE_REQ_SERV_OPT_NOTSUB },
219 { GTPCAUSE_PTIMSI_MISMATCH, GSM_CAUSE_PROTO_ERR_UNSPEC },
220 { GTPCAUSE_CONN_SUSP, GSM_CAUSE_PROTO_ERR_UNSPEC },
221 { GTPCAUSE_AUTH_FAIL, GSM_CAUSE_AUTH_FAILED },
222 { GTPCAUSE_USER_AUTH_FAIL, GSM_CAUSE_ACT_REJ_GGSN },
223 { GTPCAUSE_CONTEXT_NOT_FOUND, GSM_CAUSE_PROTO_ERR_UNSPEC },
224 { GTPCAUSE_ADDR_OCCUPIED, GSM_CAUSE_INSUFF_RSRC },
225 { GTPCAUSE_NO_MEMORY, GSM_CAUSE_INSUFF_RSRC },
226 { GTPCAUSE_RELOC_FAIL, GSM_CAUSE_PROTO_ERR_UNSPEC },
227 { GTPCAUSE_UNKNOWN_MAN_EXTHEADER, GSM_CAUSE_PROTO_ERR_UNSPEC },
228 { GTPCAUSE_MISSING_APN, GSM_CAUSE_MISSING_APN },
229 { GTPCAUSE_UNKNOWN_PDP, GSM_CAUSE_UNKNOWN_PDP },
230 { 0, 0 }
231};
232
Harald Welte2720e732010-05-17 00:44:57 +0200233/* The GGSN has confirmed the creation of a PDP Context */
234static int create_pdp_conf(struct pdp_t *pdp, void *cbp, int cause)
235{
Harald Welted193cb32010-05-17 22:58:03 +0200236 struct sgsn_pdp_ctx *pctx = cbp;
Harald Welte6abf94e2010-05-18 10:35:06 +0200237 uint8_t reject_cause;
Harald Weltef11b6d22010-06-02 10:09:50 +0200238 int rc;
Harald Welte2720e732010-05-17 00:44:57 +0200239
240 DEBUGP(DGPRS, "Received CREATE PDP CTX CONF, cause=%d(%s)\n",
241 cause, get_value_string(gtp_cause_strs, cause));
242
243 /* Check for cause value if it was really successful */
244 if (cause < 0) {
245 LOGP(DGPRS, LOGL_NOTICE, "Create PDP ctx req timed out\n");
Harald Welte1371f7d2010-06-01 11:52:41 +0200246 if (pdp && pdp->version == 1) {
Harald Welte2720e732010-05-17 00:44:57 +0200247 pdp->version = 0;
Harald Welte8fc1a462010-05-17 00:53:10 +0200248 gtp_create_context_req(sgsn->gsn, pdp, cbp);
Harald Welte2720e732010-05-17 00:44:57 +0200249 return 0;
250 } else {
Harald Welte6abf94e2010-05-18 10:35:06 +0200251 reject_cause = GSM_CAUSE_NET_FAIL;
252 goto reject;
Harald Welte2720e732010-05-17 00:44:57 +0200253 }
254 }
255
256 /* Check for cause value if it was really successful */
257 if (cause != GTPCAUSE_ACC_REQ) {
Harald Welte6abf94e2010-05-18 10:35:06 +0200258 reject_cause = cause_map(gtp2sm_cause_map, cause,
259 GSM_CAUSE_ACT_REJ_GGSN);
260 goto reject;
Harald Welte2720e732010-05-17 00:44:57 +0200261 }
262
Harald Welteebabdea2010-06-01 18:28:10 +0200263 /* Activate the SNDCP layer */
264 sndcp_sm_activate_ind(&pctx->mm->llme->lle[pctx->sapi], pctx->nsapi);
265
Harald Welte6abf94e2010-05-18 10:35:06 +0200266 /* Send PDP CTX ACT to MS */
267 return gsm48_tx_gsm_act_pdp_acc(pctx);
268
269reject:
270 pctx->state = PDP_STATE_NONE;
Harald Welte1371f7d2010-06-01 11:52:41 +0200271 if (pdp)
272 pdp_freepdp(pdp);
Harald Welte6abf94e2010-05-18 10:35:06 +0200273 /* Send PDP CTX ACT REJ to MS */
Harald Weltef11b6d22010-06-02 10:09:50 +0200274 rc = gsm48_tx_gsm_act_pdp_rej(pctx->mm, pctx->ti, reject_cause,
Harald Welte6abf94e2010-05-18 10:35:06 +0200275 0, NULL);
Harald Weltef11b6d22010-06-02 10:09:50 +0200276 sgsn_pdp_ctx_free(pctx);
Harald Welte6abf94e2010-05-18 10:35:06 +0200277
278 return EOF;
Harald Welte2720e732010-05-17 00:44:57 +0200279}
280
Harald Welte2720e732010-05-17 00:44:57 +0200281/* Confirmation of a PDP Context Delete */
Harald Welte77289c22010-05-18 14:32:29 +0200282static int delete_pdp_conf(struct pdp_t *pdp, void *cbp, int cause)
Harald Welte2720e732010-05-17 00:44:57 +0200283{
Harald Welte77289c22010-05-18 14:32:29 +0200284 struct sgsn_pdp_ctx *pctx = cbp;
285 int rc;
286
Harald Welte2720e732010-05-17 00:44:57 +0200287 DEBUGP(DGPRS, "Received DELETE PDP CTX CONF, cause=%d(%s)\n",
288 cause, get_value_string(gtp_cause_strs, cause));
Harald Welte77289c22010-05-18 14:32:29 +0200289
290 /* Confirm deactivation of PDP context to MS */
291 rc = gsm48_tx_gsm_deact_pdp_acc(pctx);
292
293 sgsn_pdp_ctx_free(pctx);
294
295 return rc;
Harald Welte2720e732010-05-17 00:44:57 +0200296}
297
298/* Confirmation of an GTP ECHO request */
299static int echo_conf(int recovery)
300{
301 if (recovery < 0) {
302 DEBUGP(DGPRS, "GTP Echo Request timed out\n");
303 /* FIXME: if version == 1, retry with version 0 */
304 } else {
305 DEBUGP(DGPRS, "GTP Rx Echo Response\n");
306 }
307 return 0;
308}
309
310/* libgtp callback for confirmations */
311static int cb_conf(int type, int cause, struct pdp_t *pdp, void *cbp)
312{
313 DEBUGP(DGPRS, "libgtp cb_conf(type=%d, cause=%d, pdp=%p, cbp=%p)\n",
314 type, cause, pdp, cbp);
315
316 if (cause == EOF)
317 LOGP(DGPRS, LOGL_ERROR, "libgtp EOF (type=%u, pdp=%p, cbp=%p)\n",
318 type, pdp, cbp);
319
320 switch (type) {
321 case GTP_ECHO_REQ:
322 return echo_conf(cause);
323 case GTP_CREATE_PDP_REQ:
324 return create_pdp_conf(pdp, cbp, cause);
325 case GTP_DELETE_PDP_REQ:
Harald Welte77289c22010-05-18 14:32:29 +0200326 return delete_pdp_conf(pdp, cbp, cause);
Harald Welte2720e732010-05-17 00:44:57 +0200327 default:
328 break;
329 }
330 return 0;
331}
332
333/* Called whenever a PDP context is deleted for any reason */
334static int cb_delete_context(struct pdp_t *pdp)
335{
336 LOGP(DGPRS, LOGL_INFO, "PDP Context was deleted\n");
337 return 0;
338}
339
340/* Called when we receive a Version Not Supported message */
341static int cb_unsup_ind(struct sockaddr_in *peer)
342{
343 LOGP(DGPRS, LOGL_INFO, "GTP Version not supported Indication "
344 "from %s:%u\n", inet_ntoa(peer->sin_addr),
345 ntohs(peer->sin_port));
346 return 0;
347}
348
349/* Called when we receive a Supported Ext Headers Notification */
350static int cb_extheader_ind(struct sockaddr_in *peer)
351{
352 LOGP(DGPRS, LOGL_INFO, "GTP Supported Ext Headers Noficiation "
353 "from %s:%u\n", inet_ntoa(peer->sin_addr),
354 ntohs(peer->sin_port));
355 return 0;
356}
357
358/* Called whenever we recive a DATA packet */
Harald Weltebb1c8052010-06-03 06:38:38 +0200359static int cb_data_ind(struct pdp_t *lib, void *packet, unsigned int len)
Harald Welte2720e732010-05-17 00:44:57 +0200360{
Harald Weltebb35c452010-06-09 16:22:28 +0200361 struct bssgp_paging_info pinfo;
Harald Weltebb1c8052010-06-03 06:38:38 +0200362 struct sgsn_pdp_ctx *pdp;
Harald Weltebb35c452010-06-09 16:22:28 +0200363 struct sgsn_mm_ctx *mm;
364 struct msgb *msg;
Harald Weltebb1c8052010-06-03 06:38:38 +0200365 uint8_t *ud;
Harald Weltebb35c452010-06-09 16:22:28 +0200366 int rc;
Harald Weltebb1c8052010-06-03 06:38:38 +0200367
Harald Welte2720e732010-05-17 00:44:57 +0200368 DEBUGP(DGPRS, "GTP DATA IND from GGSN, length=%u\n", len);
Harald Welte2720e732010-05-17 00:44:57 +0200369
Harald Weltebb1c8052010-06-03 06:38:38 +0200370 pdp = lib->priv;
371 if (!pdp) {
372 DEBUGP(DGPRS, "GTP DATA IND from GGSN for unknown PDP\n");
373 return -EIO;
374 }
Harald Weltebb35c452010-06-09 16:22:28 +0200375 mm = pdp->mm;
Harald Weltebb1c8052010-06-03 06:38:38 +0200376
Sylvain Munaut5914bad2010-06-09 20:49:24 +0200377 msg = msgb_alloc_headroom(len+256, 128, "GTP->SNDCP");
Harald Weltebb1c8052010-06-03 06:38:38 +0200378 ud = msgb_put(msg, len);
379 memcpy(ud, packet, len);
380
Harald Weltebb35c452010-06-09 16:22:28 +0200381 msgb_tlli(msg) = mm->tlli;
382 msgb_bvci(msg) = mm->bvci;
383 msgb_nsei(msg) = mm->nsei;
Harald Weltebb1c8052010-06-03 06:38:38 +0200384
Harald Weltebb35c452010-06-09 16:22:28 +0200385 switch (mm->mm_state) {
386 case GMM_REGISTERED_SUSPENDED:
387 /* initiate PS PAGING procedure */
388 memset(&pinfo, 0, sizeof(pinfo));
389 pinfo.mode = BSSGP_PAGING_PS;
390 pinfo.scope = BSSGP_PAGING_BVCI;
391 pinfo.bvci = mm->bvci;
392 pinfo.imsi = mm->imsi;
393 pinfo.ptmsi = mm->p_tmsi;
394 pinfo.drx_params = mm->drx_parms;
395 pinfo.qos[0] = 0; // FIXME
396 rc = gprs_bssgp_tx_paging(mm->nsei, 0, &pinfo);
Harald Welteefbdee92010-06-10 00:20:12 +0200397 rate_ctr_inc(&mm->ctrg->ctr[GMM_CTR_PAGING_PS]);
Harald Weltebb35c452010-06-09 16:22:28 +0200398 /* FIXME: queue the packet we received from GTP */
399 break;
400 case GMM_REGISTERED_NORMAL:
401 break;
402 default:
403 LOGP(DGPRS, LOGL_ERROR, "GTP DATA IND for TLLI %08X in state "
404 "%u\n", mm->tlli, mm->mm_state);
405 msgb_free(msg);
406 return -1;
407 }
408
Harald Welteefbdee92010-06-10 00:20:12 +0200409 rate_ctr_inc(&pdp->ctrg->ctr[PDP_CTR_PKTS_UDATA_OUT]);
410 rate_ctr_add(&pdp->ctrg->ctr[PDP_CTR_BYTES_UDATA_OUT], len);
411 rate_ctr_inc(&mm->ctrg->ctr[GMM_CTR_PKTS_UDATA_OUT]);
412 rate_ctr_add(&mm->ctrg->ctr[GMM_CTR_BYTES_UDATA_OUT], len);
413
Harald Weltebb35c452010-06-09 16:22:28 +0200414 return sndcp_unitdata_req(msg, &mm->llme->lle[pdp->sapi],
415 pdp->nsapi, mm);
Harald Welte2720e732010-05-17 00:44:57 +0200416}
417
Harald Welteebabdea2010-06-01 18:28:10 +0200418/* Called by SNDCP when it has received/re-assembled a N-PDU */
419int sgsn_rx_sndcp_ud_ind(uint32_t tlli, uint8_t nsapi, struct msgb *msg,
420 uint32_t npdu_len, uint8_t *npdu)
421{
422 struct sgsn_mm_ctx *mmctx;
423 struct sgsn_pdp_ctx *pdp;
424 struct gprs_ra_id ra_id;
425
426 /* look-up the MM context for this message */
427 bssgp_parse_cell_id(&ra_id, msgb_bcid(msg));
428 mmctx = sgsn_mm_ctx_by_tlli(tlli, &ra_id);
429 if (!mmctx) {
430 LOGP(DGPRS, LOGL_ERROR,
431 "Cannot find MM CTX for TLLI %08x\n", tlli);
432 return -EIO;
433 }
434 /* look-up the PDP context for this message */
435 pdp = sgsn_pdp_ctx_by_nsapi(mmctx, nsapi);
436 if (!pdp) {
437 LOGP(DGPRS, LOGL_ERROR, "Cannot find PDP CTX for "
438 "TLLI=%08x, NSAPI=%u\n", tlli, nsapi);
439 return -EIO;
440 }
441 if (!pdp->lib) {
442 LOGP(DGPRS, LOGL_ERROR, "PDP CTX without libgtp\n");
443 return -EIO;
444 }
Harald Welteefbdee92010-06-10 00:20:12 +0200445
446 rate_ctr_inc(&pdp->ctrg->ctr[PDP_CTR_PKTS_UDATA_IN]);
447 rate_ctr_add(&pdp->ctrg->ctr[PDP_CTR_BYTES_UDATA_IN], npdu_len);
448 rate_ctr_inc(&mmctx->ctrg->ctr[GMM_CTR_PKTS_UDATA_IN]);
449 rate_ctr_add(&mmctx->ctrg->ctr[GMM_CTR_BYTES_UDATA_IN], npdu_len);
450
451 return gtp_data_req(pdp->ggsn->gsn, pdp->lib, npdu, npdu_len);
452
Harald Welteebabdea2010-06-01 18:28:10 +0200453 return gtp_data_req(pdp->ggsn->gsn, pdp->lib, npdu, npdu_len);
454}
455
Harald Welte2720e732010-05-17 00:44:57 +0200456/* libgtp select loop integration */
457static int sgsn_gtp_fd_cb(struct bsc_fd *fd, unsigned int what)
458{
459 struct sgsn_instance *sgi = fd->data;
460 int rc;
461
462 if (!(what & BSC_FD_READ))
463 return 0;
464
465 switch (fd->priv_nr) {
466 case 0:
467 rc = gtp_decaps0(sgi->gsn);
468 break;
469 case 1:
470 rc = gtp_decaps1c(sgi->gsn);
471 break;
472 case 2:
473 rc = gtp_decaps1u(sgi->gsn);
474 break;
Harald Weltecd4dd4d2010-05-18 17:20:49 +0200475 default:
476 rc = -EINVAL;
477 break;
Harald Welte2720e732010-05-17 00:44:57 +0200478 }
479 return rc;
480}
481
Harald Welte2720e732010-05-17 00:44:57 +0200482static void sgsn_gtp_tmr_start(struct sgsn_instance *sgi)
483{
Harald Welteb4a31292010-05-18 18:24:53 +0200484 struct timeval next;
Harald Welte2720e732010-05-17 00:44:57 +0200485
486 /* Retrieve next retransmission as struct timeval */
487 gtp_retranstimeout(sgi->gsn, &next);
488
Harald Welte2720e732010-05-17 00:44:57 +0200489 /* re-schedule the timer */
Harald Welteb4a31292010-05-18 18:24:53 +0200490 bsc_schedule_timer(&sgi->gtp_timer, next.tv_sec, next.tv_usec/1000);
Harald Welte2720e732010-05-17 00:44:57 +0200491}
492
493/* timer callback for libgtp retransmissions and ping */
494static void sgsn_gtp_tmr_cb(void *data)
495{
496 struct sgsn_instance *sgi = data;
497
498 /* Do all the retransmissions as needed */
499 gtp_retrans(sgi->gsn);
500
501 sgsn_gtp_tmr_start(sgi);
502}
503
504int sgsn_gtp_init(struct sgsn_instance *sgi)
505{
506 int rc;
507 struct gsn_t *gsn;
508
509 rc = gtp_new(&sgi->gsn, sgi->cfg.gtp_statedir,
510 &sgi->cfg.gtp_listenaddr.sin_addr, GTP_MODE_SGSN);
511 if (rc) {
512 LOGP(DGPRS, LOGL_ERROR, "Failed to create GTP: %d\n", rc);
513 return rc;
514 }
515 gsn = sgi->gsn;
516
517 sgi->gtp_fd0.fd = gsn->fd0;
518 sgi->gtp_fd0.priv_nr = 0;
519 sgi->gtp_fd0.data = sgi;
Harald Welte322a5ee2010-05-18 13:13:11 +0200520 sgi->gtp_fd0.when = BSC_FD_READ;
Harald Welte2720e732010-05-17 00:44:57 +0200521 sgi->gtp_fd0.cb = sgsn_gtp_fd_cb;
522 rc = bsc_register_fd(&sgi->gtp_fd0);
523 if (rc < 0)
524 return rc;
525
526 sgi->gtp_fd1c.fd = gsn->fd1c;
527 sgi->gtp_fd1c.priv_nr = 1;
528 sgi->gtp_fd1c.data = sgi;
Harald Welte322a5ee2010-05-18 13:13:11 +0200529 sgi->gtp_fd1c.when = BSC_FD_READ;
Harald Welte2720e732010-05-17 00:44:57 +0200530 sgi->gtp_fd1c.cb = sgsn_gtp_fd_cb;
531 bsc_register_fd(&sgi->gtp_fd1c);
532 if (rc < 0)
533 return rc;
534
535 sgi->gtp_fd1u.fd = gsn->fd1u;
536 sgi->gtp_fd1u.priv_nr = 2;
537 sgi->gtp_fd1u.data = sgi;
Harald Welte322a5ee2010-05-18 13:13:11 +0200538 sgi->gtp_fd1u.when = BSC_FD_READ;
Harald Welte2720e732010-05-17 00:44:57 +0200539 sgi->gtp_fd1u.cb = sgsn_gtp_fd_cb;
540 bsc_register_fd(&sgi->gtp_fd1u);
541 if (rc < 0)
542 return rc;
543
544 /* Start GTP re-transmission timer */
545 sgi->gtp_timer.cb = sgsn_gtp_tmr_cb;
Harald Welte51537ee2010-05-18 18:28:13 +0200546 sgi->gtp_timer.data = sgi;
Harald Welte2720e732010-05-17 00:44:57 +0200547 sgsn_gtp_tmr_start(sgi);
548
549 /* Register callbackcs with libgtp */
550 gtp_set_cb_delete_context(gsn, cb_delete_context);
551 gtp_set_cb_conf(gsn, cb_conf);
552 gtp_set_cb_data_ind(gsn, cb_data_ind);
553 gtp_set_cb_unsup_ind(gsn, cb_unsup_ind);
554 gtp_set_cb_extheader_ind(gsn, cb_extheader_ind);
555
556 return 0;
557}