blob: 315361089b7da65e395957eb0eeaff957eed5918 [file] [log] [blame]
Daniel Willmann8b3390e2008-12-28 00:31:09 +00001/* Point-to-Point (PP) Short Message Service (SMS)
2 * Support on Mobile Radio Interface
3 * 3GPP TS 04.11 version 7.1.0 Release 1998 / ETSI TS 100 942 V7.1.0 */
4
5/* (C) 2008 by Daniel Willmann <daniel@totalueberwachung.de>
Harald Welte7e310b12009-03-30 20:56:32 +00006 * (C) 2009 by Harald Welte <laforge@gnumonks.org>
Holger Hans Peter Freyther75172122012-11-10 18:11:22 +01007 * (C) 2010-2012 by Holger Hans Peter Freyther <zecke@selfish.org>
Holger Hans Peter Freyther85531cc2010-10-06 20:37:09 +08008 * (C) 2010 by On-Waves
Andreas Eversbergf7396ea2011-10-28 04:07:07 +02009 * (C) 2011 by Andreas Eversberg <jolly@eversberg.eu>
Daniel Willmann8b3390e2008-12-28 00:31:09 +000010 *
11 * All Rights Reserved
12 *
13 * This program is free software; you can redistribute it and/or modify
Harald Welte9af6ddf2011-01-01 15:25:50 +010014 * it under the terms of the GNU Affero General Public License as published by
15 * the Free Software Foundation; either version 3 of the License, or
Daniel Willmann8b3390e2008-12-28 00:31:09 +000016 * (at your option) any later version.
17 *
18 * This program is distributed in the hope that it will be useful,
19 * but WITHOUT ANY WARRANTY; without even the implied warranty of
20 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Harald Welte9af6ddf2011-01-01 15:25:50 +010021 * GNU Affero General Public License for more details.
Daniel Willmann8b3390e2008-12-28 00:31:09 +000022 *
Harald Welte9af6ddf2011-01-01 15:25:50 +010023 * You should have received a copy of the GNU Affero General Public License
24 * along with this program. If not, see <http://www.gnu.org/licenses/>.
Daniel Willmann8b3390e2008-12-28 00:31:09 +000025 *
26 */
27
28
29#include <stdio.h>
30#include <stdlib.h>
31#include <string.h>
32#include <errno.h>
Harald Weltef3efc592009-07-27 20:11:35 +020033#include <time.h>
Daniel Willmann8b3390e2008-12-28 00:31:09 +000034#include <netinet/in.h>
35
Harald Welte9c3dc902012-04-08 16:59:24 +020036#include "bscconfig.h"
37
Pablo Neira Ayuso136f4532011-03-22 16:47:59 +010038#include <osmocom/core/msgb.h>
Holger Hans Peter Freyther75172122012-11-10 18:11:22 +010039#include <osmocom/core/talloc.h>
Neels Hofmeyr93bafb62017-01-13 03:12:08 +010040#include <osmocom/core/utils.h>
Holger Hans Peter Freyther75172122012-11-10 18:11:22 +010041
Holger Hans Peter Freyther75172122012-11-10 18:11:22 +010042#include <osmocom/gsm/gsm_utils.h>
Holger Hans Peter Freyther366c3312012-11-10 18:24:54 +010043#include <osmocom/gsm/gsm0411_utils.h>
Alexander Couzensaa386d22016-08-21 20:16:33 +020044#include <osmocom/gsm/protocol/gsm_04_11.h>
Holger Hans Peter Freyther75172122012-11-10 18:11:22 +010045
Daniel Willmann8b3390e2008-12-28 00:31:09 +000046#include <openbsc/debug.h>
Daniel Willmann471712b2008-12-29 01:54:02 +000047#include <openbsc/gsm_data.h>
Nico Goldef11af072010-09-15 19:49:55 +020048#include <openbsc/db.h>
Daniel Willmann471712b2008-12-29 01:54:02 +000049#include <openbsc/gsm_subscriber.h>
Daniel Willmann8b3390e2008-12-28 00:31:09 +000050#include <openbsc/gsm_04_08.h>
51#include <openbsc/abis_rsl.h>
Holger Freyther9b177762009-02-16 19:07:18 +000052#include <openbsc/signal.h>
Harald Welte7e310b12009-03-30 20:56:32 +000053#include <openbsc/db.h>
Harald Weltef3efc592009-07-27 20:11:35 +020054#include <openbsc/transaction.h>
Harald Welte76042182009-08-08 16:03:15 +020055#include <openbsc/paging.h>
Harald Weltecb8f4432009-08-09 14:59:02 +020056#include <openbsc/bsc_rll.h>
Holger Hans Peter Freyther34e97492009-08-10 07:54:02 +020057#include <openbsc/chan_alloc.h>
Neels Hofmeyr84da6b12016-05-20 21:59:55 +020058#include <openbsc/msc_ifaces.h>
Harald Welte2483f1b2016-06-19 18:06:02 +020059#include <openbsc/osmo_msc.h>
60#include <openbsc/vlr.h>
Daniel Willmann8b3390e2008-12-28 00:31:09 +000061
Harald Weltee07b6a72012-11-23 19:02:37 +010062#ifdef BUILD_SMPP
63#include "smpp_smsc.h"
Harald Weltee07b6a72012-11-23 19:02:37 +010064#endif
65
Harald Welte (local)d19e58b2009-08-15 02:30:58 +020066void *tall_gsms_ctx;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +020067static uint32_t new_callref = 0x40000001;
Harald Weltef3efc592009-07-27 20:11:35 +020068
Holger Hans Peter Freyther0fbb3ec2010-06-16 14:19:31 +080069
Harald Welte76042182009-08-08 16:03:15 +020070struct gsm_sms *sms_alloc(void)
71{
72 return talloc_zero(tall_gsms_ctx, struct gsm_sms);
73}
74
75void sms_free(struct gsm_sms *sms)
76{
77 /* drop references to subscriber structure */
Harald Welte76042182009-08-08 16:03:15 +020078 if (sms->receiver)
Harald Welte2483f1b2016-06-19 18:06:02 +020079 vlr_subscr_put(sms->receiver);
Harald Welte6c7680d2012-11-16 22:15:22 +010080#ifdef BUILD_SMPP
Harald Weltee94db492012-11-08 20:11:05 +010081 if (sms->smpp.esme)
82 smpp_esme_put(sms->smpp.esme);
Harald Welte6c7680d2012-11-16 22:15:22 +010083#endif
Harald Welte76042182009-08-08 16:03:15 +020084
85 talloc_free(sms);
86}
87
Harald Welte2483f1b2016-06-19 18:06:02 +020088struct gsm_sms *sms_from_text(struct vlr_subscr *receiver,
89 struct vlr_subscr *sender,
Sylvain Munaut01c13a32012-12-28 00:49:01 +010090 int dcs, const char *text)
Holger Hans Peter Freytherc4644912011-01-10 15:21:34 +010091{
92 struct gsm_sms *sms = sms_alloc();
93
94 if (!sms)
95 return NULL;
96
Harald Welte2483f1b2016-06-19 18:06:02 +020097 sms->receiver = vlr_subscr_get(receiver);
Neels Hofmeyr93bafb62017-01-13 03:12:08 +010098 osmo_strlcpy(sms->text, text, sizeof(sms->text));
Holger Hans Peter Freytherc4644912011-01-10 15:21:34 +010099
Harald Welte2483f1b2016-06-19 18:06:02 +0200100 osmo_strlcpy(sms->src.addr, sender->msisdn, sizeof(sms->src.addr));
Holger Hans Peter Freytherc4644912011-01-10 15:21:34 +0100101 sms->reply_path_req = 0;
102 sms->status_rep_req = 0;
103 sms->ud_hdr_ind = 0;
104 sms->protocol_id = 0; /* implicit */
Holger Hans Peter Freythercdfcbee2011-01-10 15:34:09 +0100105 sms->data_coding_scheme = dcs;
Harald Welte2483f1b2016-06-19 18:06:02 +0200106 osmo_strlcpy(sms->dst.addr, receiver->msisdn, sizeof(sms->dst.addr));
Holger Hans Peter Freytherc4644912011-01-10 15:21:34 +0100107 /* Generate user_data */
Holger Hans Peter Freyther91acfa02013-12-26 22:33:02 +0100108 sms->user_data_len = gsm_7bit_encode_n(sms->user_data, sizeof(sms->user_data),
109 sms->text, NULL);
Holger Hans Peter Freytherc4644912011-01-10 15:21:34 +0100110
111 return sms;
112}
113
114
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100115static void send_signal(int sig_no,
116 struct gsm_trans *trans,
117 struct gsm_sms *sms,
118 int paging_result)
119{
120 struct sms_signal_data sig;
121 sig.trans = trans;
122 sig.sms = sms;
123 sig.paging_result = paging_result;
Pablo Neira Ayusobbc5b992011-05-06 12:12:31 +0200124 osmo_signal_dispatch(SS_SMS, sig_no, &sig);
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100125}
126
Holger Hans Peter Freyther536a10b2012-11-24 17:13:56 +0100127static int gsm411_sendmsg(struct gsm_subscriber_connection *conn, struct msgb *msg)
Daniel Willmann471712b2008-12-29 01:54:02 +0000128{
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100129 DEBUGP(DLSMS, "GSM4.11 TX %s\n", osmo_hexdump(msg->data, msg->len));
Holger Hans Peter Freytherec32b582010-03-23 07:40:46 +0100130 msg->l3h = msg->data;
Neels Hofmeyr84da6b12016-05-20 21:59:55 +0200131 return msc_tx_dtap(conn, msg);
Daniel Willmann471712b2008-12-29 01:54:02 +0000132}
133
Harald Welte87f5d632009-07-04 17:39:00 +0200134/* Prefix msg with a 04.08/04.11 CP header */
Harald Weltef3efc592009-07-27 20:11:35 +0200135static int gsm411_cp_sendmsg(struct msgb *msg, struct gsm_trans *trans,
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200136 uint8_t msg_type)
Harald Welte87f5d632009-07-04 17:39:00 +0200137{
138 struct gsm48_hdr *gh;
139
140 gh = (struct gsm48_hdr *) msgb_push(msg, sizeof(*gh));
141 /* Outgoing needs the highest bit set */
Harald Weltef3efc592009-07-27 20:11:35 +0200142 gh->proto_discr = trans->protocol | (trans->transaction_id<<4);
Harald Welte87f5d632009-07-04 17:39:00 +0200143 gh->msg_type = msg_type;
144
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200145 DEBUGP(DLSMS, "sending CP message (trans=%x)\n", trans->transaction_id);
Harald Welte (local)c89a5112009-08-14 10:42:43 +0200146
Holger Hans Peter Freyther536a10b2012-11-24 17:13:56 +0100147 return gsm411_sendmsg(trans->conn, msg);
Harald Welte87f5d632009-07-04 17:39:00 +0200148}
149
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200150/* mm_send: receive MMCCSMS sap message from SMC */
151static int gsm411_mm_send(struct gsm411_smc_inst *inst, int msg_type,
152 struct msgb *msg, int cp_msg_type)
153{
154 struct gsm_trans *trans =
155 container_of(inst, struct gsm_trans, sms.smc_inst);
156 int rc = 0;
157
158 switch (msg_type) {
159 case GSM411_MMSMS_EST_REQ:
160 /* recycle msg */
161 rc = gsm411_smc_recv(inst, GSM411_MMSMS_EST_CNF, msg, 0);
162 msgb_free(msg); /* upper layer does not free msg */
163 break;
164 case GSM411_MMSMS_DATA_REQ:
165 rc = gsm411_cp_sendmsg(msg, trans, cp_msg_type);
166 break;
167 case GSM411_MMSMS_REL_REQ:
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200168 DEBUGP(DLSMS, "Got MMSMS_REL_REQ, destroying transaction.\n");
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200169 msgb_free(msg);
170 trans_free(trans);
171 break;
172 default:
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200173 LOGP(DLSMS, LOGL_NOTICE, "Unhandled MMCCSMS msg 0x%x\n", msg_type);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200174 msgb_free(msg);
175 rc = -EINVAL;
176 }
177
178 return rc;
179}
180
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200181/* mm_send: receive MNCCSMS sap message from SMR */
182int gsm411_mn_send(struct gsm411_smr_inst *inst, int msg_type,
183 struct msgb *msg)
Harald Welte87f5d632009-07-04 17:39:00 +0200184{
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200185 struct gsm_trans *trans =
186 container_of(inst, struct gsm_trans, sms.smr_inst);
Harald Welte87f5d632009-07-04 17:39:00 +0200187
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200188 /* forward to SMC */
189 return gsm411_smc_send(&trans->sms.smc_inst, msg_type, msg);
Harald Welte87f5d632009-07-04 17:39:00 +0200190}
191
Pablo Neira Ayusoc0227192017-07-24 18:32:41 +0200192static int gsm340_rx_sms_submit(struct gsm_sms *gsms)
Harald Welte7e310b12009-03-30 20:56:32 +0000193{
194 if (db_sms_store(gsms) != 0) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100195 LOGP(DLSMS, LOGL_ERROR, "Failed to store SMS in Database\n");
Harald Welteb9c758b2009-07-05 14:02:46 +0200196 return GSM411_RP_CAUSE_MO_NET_OUT_OF_ORDER;
Harald Welte7e310b12009-03-30 20:56:32 +0000197 }
Harald Welte76042182009-08-08 16:03:15 +0200198 /* dispatch a signal to tell higher level about it */
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100199 send_signal(S_SMS_SUBMITTED, NULL, gsms, 0);
Harald Welte (local)ee4410a2009-08-17 09:39:55 +0200200
Harald Welte7e310b12009-03-30 20:56:32 +0000201 return 0;
202}
203
Harald Welte76042182009-08-08 16:03:15 +0200204/* generate a TPDU address field compliant with 03.40 sec. 9.1.2.5 */
Holger Hans Peter Freyther366c3312012-11-10 18:24:54 +0100205static int gsm340_gen_oa_sub(uint8_t *oa, unsigned int oa_len,
Harald Weltec0de14d2012-11-23 23:35:01 +0100206 const struct gsm_sms_addr *src)
Harald Weltef3efc592009-07-27 20:11:35 +0200207{
Holger Hans Peter Freyther366c3312012-11-10 18:24:54 +0100208 /* network specific, private numbering plan */
Harald Weltec0de14d2012-11-23 23:35:01 +0100209 return gsm340_gen_oa(oa, oa_len, src->ton, src->npi, src->addr);
Harald Weltef3efc592009-07-27 20:11:35 +0200210}
211
Alexander Chemeris9e15e182014-03-08 23:54:28 +0100212/* generate a msgb containing an 03.40 9.2.2.1 SMS-DELIVER TPDU derived from
213 * struct gsm_sms, returns total size of TPDU */
214static int gsm340_gen_sms_deliver_tpdu(struct msgb *msg, struct gsm_sms *sms)
Harald Weltef3efc592009-07-27 20:11:35 +0200215{
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200216 uint8_t *smsp;
217 uint8_t oa[12]; /* max len per 03.40 */
218 uint8_t oa_len = 0;
219 uint8_t octet_len;
Harald Welte76042182009-08-08 16:03:15 +0200220 unsigned int old_msg_len = msg->len;
Harald Weltef3efc592009-07-27 20:11:35 +0200221
222 /* generate first octet with masked bits */
223 smsp = msgb_put(msg, 1);
Harald Welte76042182009-08-08 16:03:15 +0200224 /* TP-MTI (message type indicator) */
Harald Weltef3efc592009-07-27 20:11:35 +0200225 *smsp = GSM340_SMS_DELIVER_SC2MS;
Harald Welte76042182009-08-08 16:03:15 +0200226 /* TP-MMS (more messages to send) */
227 if (0 /* FIXME */)
Harald Weltef3efc592009-07-27 20:11:35 +0200228 *smsp |= 0x04;
Harald Welte76042182009-08-08 16:03:15 +0200229 /* TP-SRI(deliver)/SRR(submit) */
Harald Weltef3efc592009-07-27 20:11:35 +0200230 if (sms->status_rep_req)
231 *smsp |= 0x20;
Harald Welte76042182009-08-08 16:03:15 +0200232 /* TP-UDHI (indicating TP-UD contains a header) */
233 if (sms->ud_hdr_ind)
Harald Weltef3efc592009-07-27 20:11:35 +0200234 *smsp |= 0x40;
Harald Weltec0de14d2012-11-23 23:35:01 +0100235
Harald Weltef3efc592009-07-27 20:11:35 +0200236 /* generate originator address */
Harald Weltec0de14d2012-11-23 23:35:01 +0100237 oa_len = gsm340_gen_oa_sub(oa, sizeof(oa), &sms->src);
Harald Weltef3efc592009-07-27 20:11:35 +0200238 smsp = msgb_put(msg, oa_len);
Harald Weltef3efc592009-07-27 20:11:35 +0200239 memcpy(smsp, oa, oa_len);
240
241 /* generate TP-PID */
242 smsp = msgb_put(msg, 1);
243 *smsp = sms->protocol_id;
244
245 /* generate TP-DCS */
246 smsp = msgb_put(msg, 1);
247 *smsp = sms->data_coding_scheme;
248
249 /* generate TP-SCTS */
250 smsp = msgb_put(msg, 7);
251 gsm340_gen_scts(smsp, time(NULL));
Harald Welte76042182009-08-08 16:03:15 +0200252
Harald Weltef3efc592009-07-27 20:11:35 +0200253 /* generate TP-UDL */
254 smsp = msgb_put(msg, 1);
Harald Welte76042182009-08-08 16:03:15 +0200255 *smsp = sms->user_data_len;
Harald Weltef3efc592009-07-27 20:11:35 +0200256
257 /* generate TP-UD */
Daniel Willmann6b024cb2009-08-15 03:01:46 +0200258 switch (gsm338_get_sms_alphabet(sms->data_coding_scheme)) {
259 case DCS_7BIT_DEFAULT:
Daniel Willmann9aef1452009-08-13 03:39:07 +0200260 octet_len = sms->user_data_len*7/8;
261 if (sms->user_data_len*7%8 != 0)
262 octet_len++;
Daniel Willmann6b1e8222009-08-12 21:17:06 +0200263 /* Warning, user_data_len indicates the amount of septets
264 * (characters), we need amount of octets occupied */
Daniel Willmann9aef1452009-08-13 03:39:07 +0200265 smsp = msgb_put(msg, octet_len);
266 memcpy(smsp, sms->user_data, octet_len);
Daniel Willmann6b024cb2009-08-15 03:01:46 +0200267 break;
268 case DCS_UCS2:
269 case DCS_8BIT_DATA:
270 smsp = msgb_put(msg, sms->user_data_len);
271 memcpy(smsp, sms->user_data, sms->user_data_len);
272 break;
273 default:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100274 LOGP(DLSMS, LOGL_NOTICE, "Unhandled Data Coding Scheme: 0x%02X\n",
Harald Welted0cf7ba2009-12-24 15:08:18 +0100275 sms->data_coding_scheme);
Daniel Willmann6b024cb2009-08-15 03:01:46 +0200276 break;
Daniel Willmann6b1e8222009-08-12 21:17:06 +0200277 }
Harald Weltef3efc592009-07-27 20:11:35 +0200278
Harald Welte76042182009-08-08 16:03:15 +0200279 return msg->len - old_msg_len;
Harald Weltef3efc592009-07-27 20:11:35 +0200280}
281
Pablo Neira Ayusoc0227192017-07-24 18:32:41 +0200282static int sms_route_mt_sms(struct gsm_subscriber_connection *conn,
283 struct gsm_sms *gsms, uint8_t sms_mti,
284 bool *deferred)
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200285{
286 int rc;
287
Holger Hans Peter Freyther42cf2e02015-07-06 16:41:30 +0200288#ifdef BUILD_SMPP
Holger Hans Peter Freyther7c19c6b2015-07-13 10:39:51 +0200289 int smpp_first = smpp_route_smpp_first(gsms, conn);
290
Holger Hans Peter Freyther42cf2e02015-07-06 16:41:30 +0200291 /*
292 * Route through SMPP first before going to the local database. In case
293 * of a unroutable message and no local subscriber, SMPP will be tried
294 * twice. In case of an unknown subscriber continue with the normal
295 * delivery of the SMS.
296 */
Holger Hans Peter Freyther7c19c6b2015-07-13 10:39:51 +0200297 if (smpp_first) {
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200298 rc = smpp_try_deliver(gsms, conn, deferred);
Pablo Neira Ayuso638ad062017-05-03 18:59:05 +0200299 if (rc == GSM411_RP_CAUSE_MO_NUM_UNASSIGNED)
Benoit Bolseed34ed572017-07-05 11:46:55 +0200300 /* unknown subscriber, try local */
Holger Hans Peter Freyther42cf2e02015-07-06 16:41:30 +0200301 goto try_local;
302 if (rc < 0) {
Alexander Couzensaa386d22016-08-21 20:16:33 +0200303 LOGP(DLSMS, LOGL_ERROR, "%s: SMS delivery error: %d.",
Harald Welte2483f1b2016-06-19 18:06:02 +0200304 vlr_subscr_name(conn->vsub), rc);
Alexander Couzensaa386d22016-08-21 20:16:33 +0200305 rc = GSM411_RP_CAUSE_MO_TEMP_FAIL;
306 /* rc will be logged by gsm411_send_rp_error() */
307 rate_ctr_inc(&conn->bts->network->msc_ctrs->ctr[
308 MSC_CTR_SMS_DELIVER_UNKNOWN_ERROR]);
Holger Hans Peter Freyther42cf2e02015-07-06 16:41:30 +0200309 }
310 return rc;
311 }
312
313try_local:
314#endif
315
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200316 /* determine gsms->receiver based on dialled number */
Harald Welte2483f1b2016-06-19 18:06:02 +0200317 gsms->receiver = vlr_subscr_find_by_msisdn(conn->network->vlr,
318 gsms->dst.addr);
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200319 if (!gsms->receiver) {
320#ifdef BUILD_SMPP
Holger Hans Peter Freyther7c19c6b2015-07-13 10:39:51 +0200321 /* Avoid a second look-up */
Alexander Couzens71306832016-07-12 16:52:32 +0200322 if (smpp_first) {
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200323 rate_ctr_inc(&conn->network->msc_ctrs->ctr[MSC_CTR_SMS_NO_RECEIVER]);
Pablo Neira Ayuso638ad062017-05-03 18:59:05 +0200324 return GSM411_RP_CAUSE_MO_NUM_UNASSIGNED;
Alexander Couzens71306832016-07-12 16:52:32 +0200325 }
Holger Hans Peter Freyther7c19c6b2015-07-13 10:39:51 +0200326
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200327 rc = smpp_try_deliver(gsms, conn, deferred);
Pablo Neira Ayuso638ad062017-05-03 18:59:05 +0200328 if (rc == GSM411_RP_CAUSE_MO_NUM_UNASSIGNED) {
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200329 rate_ctr_inc(&conn->network->msc_ctrs->ctr[MSC_CTR_SMS_NO_RECEIVER]);
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200330 } else if (rc < 0) {
Alexander Couzensaa386d22016-08-21 20:16:33 +0200331 LOGP(DLSMS, LOGL_ERROR, "%s: SMS delivery error: %d.",
Harald Welte2483f1b2016-06-19 18:06:02 +0200332 vlr_subscr_name(conn->vsub), rc);
Alexander Couzensaa386d22016-08-21 20:16:33 +0200333 rc = GSM411_RP_CAUSE_MO_TEMP_FAIL;
334 /* rc will be logged by gsm411_send_rp_error() */
335 rate_ctr_inc(&conn->bts->network->msc_ctrs->ctr[
336 MSC_CTR_SMS_DELIVER_UNKNOWN_ERROR]);
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200337 }
338#else
Pablo Neira Ayuso638ad062017-05-03 18:59:05 +0200339 rc = GSM411_RP_CAUSE_MO_NUM_UNASSIGNED;
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200340 rate_ctr_inc(&conn->network->msc_ctrs->ctr[MSC_CTR_SMS_NO_RECEIVER]);
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200341#endif
Holger Hans Peter Freytherdcbc8332015-07-06 16:40:51 +0200342 return rc;
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200343 }
344
345 switch (sms_mti) {
346 case GSM340_SMS_SUBMIT_MS2SC:
347 /* MS is submitting a SMS */
Pablo Neira Ayusoc0227192017-07-24 18:32:41 +0200348 rc = gsm340_rx_sms_submit(gsms);
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200349 break;
350 case GSM340_SMS_COMMAND_MS2SC:
351 case GSM340_SMS_DELIVER_REP_MS2SC:
352 LOGP(DLSMS, LOGL_NOTICE, "Unimplemented MTI 0x%02x\n", sms_mti);
353 rc = GSM411_RP_CAUSE_IE_NOTEXIST;
354 break;
355 default:
356 LOGP(DLSMS, LOGL_NOTICE, "Undefined MTI 0x%02x\n", sms_mti);
357 rc = GSM411_RP_CAUSE_IE_NOTEXIST;
358 break;
359 }
360
361 if (!rc && !gsms->receiver)
362 rc = GSM411_RP_CAUSE_MO_NUM_UNASSIGNED;
363
Holger Hans Peter Freytheraf1b9682015-07-06 15:54:25 +0200364 return rc;
365}
366
367
Holger Hans Peter Freytheracf8a0c2010-03-29 08:47:44 +0200368/* process an incoming TPDU (called from RP-DATA)
369 * return value > 0: RP CAUSE for ERROR; < 0: silent error; 0 = success */
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200370static int gsm340_rx_tpdu(struct gsm_trans *trans, struct msgb *msg,
371 uint32_t gsm411_msg_ref, bool *deferred)
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000372{
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200373 struct gsm_subscriber_connection *conn = trans->conn;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200374 uint8_t *smsp = msgb_sms(msg);
Harald Welte7e310b12009-03-30 20:56:32 +0000375 struct gsm_sms *gsms;
Harald Welte258c7132011-07-16 13:34:52 +0200376 unsigned int sms_alphabet;
Neels Hofmeyr58d54302016-02-24 19:30:52 +0100377 uint8_t sms_mti, sms_vpf;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200378 uint8_t *sms_vp;
379 uint8_t da_len_bytes;
380 uint8_t address_lv[12]; /* according to 03.40 / 9.1.2.5 */
Harald Welte7e310b12009-03-30 20:56:32 +0000381 int rc = 0;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000382
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200383 rate_ctr_inc(&conn->network->msc_ctrs->ctr[MSC_CTR_SMS_SUBMITTED]);
Harald Welte24ff6ee2009-12-22 00:41:05 +0100384
Harald Welte76042182009-08-08 16:03:15 +0200385 gsms = sms_alloc();
386 if (!gsms)
Harald Welteb9c758b2009-07-05 14:02:46 +0200387 return GSM411_RP_CAUSE_MO_NET_OUT_OF_ORDER;
Harald Welte7e310b12009-03-30 20:56:32 +0000388
389 /* invert those fields where 0 means active/present */
Harald Welte76042182009-08-08 16:03:15 +0200390 sms_mti = *smsp & 0x03;
Harald Welte76042182009-08-08 16:03:15 +0200391 sms_vpf = (*smsp & 0x18) >> 3;
392 gsms->status_rep_req = (*smsp & 0x20);
393 gsms->ud_hdr_ind = (*smsp & 0x40);
Neels Hofmeyr58d54302016-02-24 19:30:52 +0100394 /*
395 * Not evaluating MMS (More Messages to Send) because the
396 * lchan stays open anyway.
397 * Not evaluating RP (Reply Path) because we're not aware of its
398 * benefits.
399 */
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000400
401 smsp++;
Harald Welte76042182009-08-08 16:03:15 +0200402 gsms->msg_ref = *smsp++;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000403
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200404 gsms->gsm411.transaction_id = trans->transaction_id;
405 gsms->gsm411.msg_ref = gsm411_msg_ref;
406
Harald Welte7e310b12009-03-30 20:56:32 +0000407 /* length in bytes of the destination address */
408 da_len_bytes = 2 + *smsp/2 + *smsp%2;
409 if (da_len_bytes > 12) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100410 LOGP(DLSMS, LOGL_ERROR, "Destination Address > 12 bytes ?!?\n");
Harald Welteb9c758b2009-07-05 14:02:46 +0200411 rc = GSM411_RP_CAUSE_SEMANT_INC_MSG;
Harald Welte7e310b12009-03-30 20:56:32 +0000412 goto out;
Harald Weltee07b6a72012-11-23 19:02:37 +0100413 } else if (da_len_bytes < 4) {
414 LOGP(DLSMS, LOGL_ERROR, "Destination Address < 4 bytes ?!?\n");
415 rc = GSM411_RP_CAUSE_SEMANT_INC_MSG;
416 goto out;
Harald Welte7e310b12009-03-30 20:56:32 +0000417 }
Harald Welte3cfdb222009-06-12 02:42:11 +0800418 memset(address_lv, 0, sizeof(address_lv));
Harald Welte7e310b12009-03-30 20:56:32 +0000419 memcpy(address_lv, smsp, da_len_bytes);
420 /* mangle first byte to reflect length in bytes, not digits */
Harald Welte3cfdb222009-06-12 02:42:11 +0800421 address_lv[0] = da_len_bytes - 1;
Harald Weltee07b6a72012-11-23 19:02:37 +0100422
Harald Weltec0de14d2012-11-23 23:35:01 +0100423 gsms->dst.ton = (address_lv[1] >> 4) & 7;
424 gsms->dst.npi = address_lv[1] & 0xF;
Harald Welte7e310b12009-03-30 20:56:32 +0000425 /* convert to real number */
Harald Weltec0de14d2012-11-23 23:35:01 +0100426 gsm48_decode_bcd_number(gsms->dst.addr,
427 sizeof(gsms->dst.addr), address_lv, 1);
Harald Welte7e310b12009-03-30 20:56:32 +0000428 smsp += da_len_bytes;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000429
Harald Welte76042182009-08-08 16:03:15 +0200430 gsms->protocol_id = *smsp++;
431 gsms->data_coding_scheme = *smsp++;
Harald Welte7e310b12009-03-30 20:56:32 +0000432
Harald Welte76042182009-08-08 16:03:15 +0200433 sms_alphabet = gsm338_get_sms_alphabet(gsms->data_coding_scheme);
Holger Hans Peter Freyther8e78fa72010-06-14 16:13:16 +0800434 if (sms_alphabet == 0xffffffff) {
Alexander Chemeris4ad593c2013-10-04 02:42:27 +0200435 rc = GSM411_RP_CAUSE_MO_NET_OUT_OF_ORDER;
436 goto out;
Holger Hans Peter Freyther8e78fa72010-06-14 16:13:16 +0800437 }
Harald Welte7e310b12009-03-30 20:56:32 +0000438
Harald Welte76042182009-08-08 16:03:15 +0200439 switch (sms_vpf) {
Harald Welte7e310b12009-03-30 20:56:32 +0000440 case GSM340_TP_VPF_RELATIVE:
Harald Welte76042182009-08-08 16:03:15 +0200441 sms_vp = smsp++;
Harald Welte7e310b12009-03-30 20:56:32 +0000442 break;
443 case GSM340_TP_VPF_ABSOLUTE:
444 case GSM340_TP_VPF_ENHANCED:
Harald Welte76042182009-08-08 16:03:15 +0200445 sms_vp = smsp;
Steffen Neubauerf3262672009-11-26 12:28:41 +0100446 /* the additional functionality indicator... */
Steffen Neubauerac0c13c2009-12-05 12:44:41 +0100447 if (sms_vpf == GSM340_TP_VPF_ENHANCED && *smsp & (1<<7))
448 smsp++;
Harald Welte7e310b12009-03-30 20:56:32 +0000449 smsp += 7;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000450 break;
Daniel Willmann58c83d82009-08-13 03:40:49 +0200451 case GSM340_TP_VPF_NONE:
452 sms_vp = 0;
453 break;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000454 default:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100455 LOGP(DLSMS, LOGL_NOTICE,
Harald Welted0cf7ba2009-12-24 15:08:18 +0100456 "SMS Validity period not implemented: 0x%02x\n", sms_vpf);
Alexander Chemeris4ad593c2013-10-04 02:42:27 +0200457 rc = GSM411_RP_CAUSE_MO_NET_OUT_OF_ORDER;
458 goto out;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000459 }
Harald Welte76042182009-08-08 16:03:15 +0200460 gsms->user_data_len = *smsp++;
461 if (gsms->user_data_len) {
462 memcpy(gsms->user_data, smsp, gsms->user_data_len);
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000463
Harald Welte76042182009-08-08 16:03:15 +0200464 switch (sms_alphabet) {
Harald Welte7e310b12009-03-30 20:56:32 +0000465 case DCS_7BIT_DEFAULT:
Harald Welte5468f762015-01-01 12:41:17 +0100466 gsm_7bit_decode_n(gsms->text, sizeof(gsms->text), smsp,
467 gsms->user_data_len);
Harald Welte7e310b12009-03-30 20:56:32 +0000468 break;
469 case DCS_8BIT_DATA:
470 case DCS_UCS2:
471 case DCS_NONE:
Harald Welte7e310b12009-03-30 20:56:32 +0000472 break;
473 }
474 }
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000475
Harald Welte2483f1b2016-06-19 18:06:02 +0200476 osmo_strlcpy(gsms->src.addr, conn->vsub->msisdn, sizeof(gsms->src.addr));
Harald Welted0cf7ba2009-12-24 15:08:18 +0100477
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100478 LOGP(DLSMS, LOGL_INFO, "RX SMS: Sender: %s, MTI: 0x%02x, VPF: 0x%02x, "
Harald Welted0cf7ba2009-12-24 15:08:18 +0100479 "MR: 0x%02x PID: 0x%02x, DCS: 0x%02x, DA: %s, "
480 "UserDataLength: 0x%02x, UserData: \"%s\"\n",
Harald Welte2483f1b2016-06-19 18:06:02 +0200481 vlr_subscr_name(conn->vsub), sms_mti, sms_vpf, gsms->msg_ref,
Harald Weltec0de14d2012-11-23 23:35:01 +0100482 gsms->protocol_id, gsms->data_coding_scheme, gsms->dst.addr,
Harald Welted0cf7ba2009-12-24 15:08:18 +0100483 gsms->user_data_len,
Holger Hans Peter Freytheracf8a0c2010-03-29 08:47:44 +0200484 sms_alphabet == DCS_7BIT_DEFAULT ? gsms->text :
Pablo Neira Ayusoc0d17f22011-05-07 12:12:48 +0200485 osmo_hexdump(gsms->user_data, gsms->user_data_len));
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000486
Harald Welte76042182009-08-08 16:03:15 +0200487 gsms->validity_minutes = gsm340_validity_period(sms_vpf, sms_vp);
Harald Welteb9c758b2009-07-05 14:02:46 +0200488
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100489 /* FIXME: This looks very wrong */
490 send_signal(0, NULL, gsms, 0);
Harald Welteb9c758b2009-07-05 14:02:46 +0200491
Pablo Neira Ayusoc0227192017-07-24 18:32:41 +0200492 rc = sms_route_mt_sms(conn, gsms, sms_mti, deferred);
Harald Welte7e310b12009-03-30 20:56:32 +0000493out:
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200494 if (!deferred)
495 sms_free(gsms);
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000496
Harald Welte7e310b12009-03-30 20:56:32 +0000497 return rc;
Daniel Willmanne0fbec82008-12-29 00:44:41 +0000498}
499
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200500/* Prefix msg with a RP-DATA header and send as SMR DATA */
501static int gsm411_rp_sendmsg(struct gsm411_smr_inst *inst, struct msgb *msg,
502 uint8_t rp_msg_type, uint8_t rp_msg_ref,
503 int rl_msg_type)
504{
505 struct gsm411_rp_hdr *rp;
506 uint8_t len = msg->len;
507
508 /* GSM 04.11 RP-DATA header */
509 rp = (struct gsm411_rp_hdr *)msgb_push(msg, sizeof(*rp));
510 rp->len = len + 2;
511 rp->msg_type = rp_msg_type;
Holger Hans Peter Freytherca114432014-02-08 15:20:48 +0100512 rp->msg_ref = rp_msg_ref;
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200513
514 return gsm411_smr_send(inst, rl_msg_type, msg);
515}
516
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200517int gsm411_send_rp_ack(struct gsm_trans *trans, uint8_t msg_ref)
Daniel Willmann471712b2008-12-29 01:54:02 +0000518{
519 struct msgb *msg = gsm411_msgb_alloc();
Daniel Willmann471712b2008-12-29 01:54:02 +0000520
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100521 DEBUGP(DLSMS, "TX: SMS RP ACK\n");
Daniel Willmann471712b2008-12-29 01:54:02 +0000522
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200523 return gsm411_rp_sendmsg(&trans->sms.smr_inst, msg, GSM411_MT_RP_ACK_MT,
524 msg_ref, GSM411_SM_RL_REPORT_REQ);
Daniel Willmann471712b2008-12-29 01:54:02 +0000525}
526
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200527int gsm411_send_rp_error(struct gsm_trans *trans, uint8_t msg_ref,
528 uint8_t cause)
Daniel Willmann471712b2008-12-29 01:54:02 +0000529{
530 struct msgb *msg = gsm411_msgb_alloc();
Daniel Willmann471712b2008-12-29 01:54:02 +0000531
Harald Welte7e310b12009-03-30 20:56:32 +0000532 msgb_tv_put(msg, 1, cause);
Daniel Willmann471712b2008-12-29 01:54:02 +0000533
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100534 LOGP(DLSMS, LOGL_NOTICE, "TX: SMS RP ERROR, cause %d (%s)\n", cause,
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200535 get_value_string(gsm411_rp_cause_strs, cause));
Daniel Willmann471712b2008-12-29 01:54:02 +0000536
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200537 return gsm411_rp_sendmsg(&trans->sms.smr_inst, msg,
538 GSM411_MT_RP_ERROR_MT, msg_ref, GSM411_SM_RL_REPORT_REQ);
Daniel Willmann471712b2008-12-29 01:54:02 +0000539}
540
Harald Welte7e310b12009-03-30 20:56:32 +0000541/* Receive a 04.11 TPDU inside RP-DATA / user data */
Harald Weltef3efc592009-07-27 20:11:35 +0200542static int gsm411_rx_rp_ud(struct msgb *msg, struct gsm_trans *trans,
543 struct gsm411_rp_hdr *rph,
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200544 uint8_t src_len, uint8_t *src,
545 uint8_t dst_len, uint8_t *dst,
546 uint8_t tpdu_len, uint8_t *tpdu)
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000547{
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200548 bool deferred = false;
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000549 int rc = 0;
550
Harald Welte7e310b12009-03-30 20:56:32 +0000551 if (src_len && src)
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100552 LOGP(DLSMS, LOGL_ERROR, "RP-DATA (MO) with SRC ?!?\n");
Harald Welte7e310b12009-03-30 20:56:32 +0000553
554 if (!dst_len || !dst || !tpdu_len || !tpdu) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100555 LOGP(DLSMS, LOGL_ERROR,
Harald Welted0cf7ba2009-12-24 15:08:18 +0100556 "RP-DATA (MO) without DST or TPDU ?!?\n");
Harald Weltef3efc592009-07-27 20:11:35 +0200557 gsm411_send_rp_error(trans, rph->msg_ref,
Harald Welteb9c758b2009-07-05 14:02:46 +0200558 GSM411_RP_CAUSE_INV_MAND_INF);
Harald Welte7e310b12009-03-30 20:56:32 +0000559 return -EIO;
560 }
Harald Weltee9dd9b02010-04-30 14:27:05 +0200561 msg->l4h = tpdu;
Harald Welte7e310b12009-03-30 20:56:32 +0000562
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100563 DEBUGP(DLSMS, "DST(%u,%s)\n", dst_len, osmo_hexdump(dst, dst_len));
Harald Welte7e310b12009-03-30 20:56:32 +0000564
Pablo Neira Ayuso93ffbd02017-05-04 18:44:22 +0200565 rc = gsm340_rx_tpdu(trans, msg, rph->msg_ref, &deferred);
566 if (rc == 0 && !deferred)
Harald Weltef3efc592009-07-27 20:11:35 +0200567 return gsm411_send_rp_ack(trans, rph->msg_ref);
Harald Welte7e310b12009-03-30 20:56:32 +0000568 else if (rc > 0)
Harald Weltef3efc592009-07-27 20:11:35 +0200569 return gsm411_send_rp_error(trans, rph->msg_ref, rc);
Harald Welte7e310b12009-03-30 20:56:32 +0000570 else
571 return rc;
572}
573
574/* Receive a 04.11 RP-DATA message in accordance with Section 7.3.1.2 */
Harald Weltef3efc592009-07-27 20:11:35 +0200575static int gsm411_rx_rp_data(struct msgb *msg, struct gsm_trans *trans,
576 struct gsm411_rp_hdr *rph)
Harald Welte7e310b12009-03-30 20:56:32 +0000577{
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200578 uint8_t src_len, dst_len, rpud_len;
579 uint8_t *src = NULL, *dst = NULL , *rp_ud = NULL;
Harald Welte7e310b12009-03-30 20:56:32 +0000580
581 /* in the MO case, this should always be zero length */
582 src_len = rph->data[0];
583 if (src_len)
584 src = &rph->data[1];
585
586 dst_len = rph->data[1+src_len];
587 if (dst_len)
588 dst = &rph->data[1+src_len+1];
589
590 rpud_len = rph->data[1+src_len+1+dst_len];
591 if (rpud_len)
592 rp_ud = &rph->data[1+src_len+1+dst_len+1];
593
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100594 DEBUGP(DLSMS, "RX_RP-DATA: src_len=%u, dst_len=%u ud_len=%u\n",
Harald Welteb9c758b2009-07-05 14:02:46 +0200595 src_len, dst_len, rpud_len);
Harald Weltef3efc592009-07-27 20:11:35 +0200596 return gsm411_rx_rp_ud(msg, trans, rph, src_len, src, dst_len, dst,
Harald Welte7e310b12009-03-30 20:56:32 +0000597 rpud_len, rp_ud);
598}
599
Harald Weltecb8f4432009-08-09 14:59:02 +0200600/* Receive a 04.11 RP-ACK message (response to RP-DATA from us) */
Harald Weltef3efc592009-07-27 20:11:35 +0200601static int gsm411_rx_rp_ack(struct msgb *msg, struct gsm_trans *trans,
602 struct gsm411_rp_hdr *rph)
Harald Welteb9c758b2009-07-05 14:02:46 +0200603{
Harald Welte76042182009-08-08 16:03:15 +0200604 struct gsm_sms *sms = trans->sms.sms;
605
Harald Welteb9c758b2009-07-05 14:02:46 +0200606 /* Acnkowledgement to MT RP_DATA, i.e. the MS confirms it
607 * successfully received a SMS. We can now safely mark it as
608 * transmitted */
609
Harald Welte76042182009-08-08 16:03:15 +0200610 if (!sms) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100611 LOGP(DLSMS, LOGL_ERROR, "RX RP-ACK but no sms in transaction?!?\n");
Harald Weltecb8f4432009-08-09 14:59:02 +0200612 return gsm411_send_rp_error(trans, rph->msg_ref,
613 GSM411_RP_CAUSE_PROTOCOL_ERR);
Harald Welte76042182009-08-08 16:03:15 +0200614 }
615
616 /* mark this SMS as sent in database */
Alexander Chemeris1e77e3d2014-03-08 21:27:37 +0100617 db_sms_mark_delivered(sms);
Harald Welte76042182009-08-08 16:03:15 +0200618
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100619 send_signal(S_SMS_DELIVERED, trans, sms, 0);
Harald Welte76042182009-08-08 16:03:15 +0200620
621 sms_free(sms);
622 trans->sms.sms = NULL;
623
Harald Welte76042182009-08-08 16:03:15 +0200624 return 0;
Harald Welteb9c758b2009-07-05 14:02:46 +0200625}
626
Harald Weltef3efc592009-07-27 20:11:35 +0200627static int gsm411_rx_rp_error(struct msgb *msg, struct gsm_trans *trans,
628 struct gsm411_rp_hdr *rph)
Harald Welteb9c758b2009-07-05 14:02:46 +0200629{
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200630 struct gsm_network *net = trans->conn->network;
Harald Welte76042182009-08-08 16:03:15 +0200631 struct gsm_sms *sms = trans->sms.sms;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200632 uint8_t cause_len = rph->data[0];
633 uint8_t cause = rph->data[1];
Harald Weltef3efc592009-07-27 20:11:35 +0200634
Harald Welteb9c758b2009-07-05 14:02:46 +0200635 /* Error in response to MT RP_DATA, i.e. the MS did not
636 * successfully receive the SMS. We need to investigate
637 * the cause and take action depending on it */
638
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100639 LOGP(DLSMS, LOGL_NOTICE, "%s: RX SMS RP-ERROR, cause %d:%d (%s)\n",
Harald Welte2483f1b2016-06-19 18:06:02 +0200640 vlr_subscr_name(trans->conn->vsub), cause_len, cause,
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200641 get_value_string(gsm411_rp_cause_strs, cause));
Harald Welte3e0f6172009-07-09 23:52:59 +0200642
Harald Welte76042182009-08-08 16:03:15 +0200643 if (!sms) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100644 LOGP(DLSMS, LOGL_ERROR,
Harald Welted0cf7ba2009-12-24 15:08:18 +0100645 "RX RP-ERR, but no sms in transaction?!?\n");
Harald Welte (local)ee4410a2009-08-17 09:39:55 +0200646 return -EINVAL;
647#if 0
Harald Weltecb8f4432009-08-09 14:59:02 +0200648 return gsm411_send_rp_error(trans, rph->msg_ref,
649 GSM411_RP_CAUSE_PROTOCOL_ERR);
Harald Welte (local)ee4410a2009-08-17 09:39:55 +0200650#endif
Harald Weltecb8f4432009-08-09 14:59:02 +0200651 }
652
653 if (cause == GSM411_RP_CAUSE_MT_MEM_EXCEEDED) {
654 /* MS has not enough memory to store the message. We need
Holger Hans Peter Freytherdd715bd2010-12-23 22:23:15 +0100655 * to store this in our database and wait for a SMMA message */
Harald Weltecb8f4432009-08-09 14:59:02 +0200656 /* FIXME */
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100657 send_signal(S_SMS_MEM_EXCEEDED, trans, sms, 0);
Alexander Couzensb847a212016-08-02 11:34:11 +0200658 rate_ctr_inc(&net->msc_ctrs->ctr[MSC_CTR_SMS_RP_ERR_MEM]);
Holger Hans Peter Freyther0eb76662010-12-24 09:47:04 +0100659 } else {
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100660 send_signal(S_SMS_UNKNOWN_ERROR, trans, sms, 0);
Alexander Couzensb847a212016-08-02 11:34:11 +0200661 rate_ctr_inc(&net->msc_ctrs->ctr[MSC_CTR_SMS_RP_ERR_OTHER]);
Holger Hans Peter Freyther0eb76662010-12-24 09:47:04 +0100662 }
Harald Welte76042182009-08-08 16:03:15 +0200663
664 sms_free(sms);
665 trans->sms.sms = NULL;
666
Harald Weltef3efc592009-07-27 20:11:35 +0200667 return 0;
Harald Welteb9c758b2009-07-05 14:02:46 +0200668}
669
Harald Weltef3efc592009-07-27 20:11:35 +0200670static int gsm411_rx_rp_smma(struct msgb *msg, struct gsm_trans *trans,
671 struct gsm411_rp_hdr *rph)
Harald Welteb9c758b2009-07-05 14:02:46 +0200672{
Harald Weltef3efc592009-07-27 20:11:35 +0200673 int rc;
674
Harald Weltecf6a3812009-08-09 19:07:41 +0200675 rc = gsm411_send_rp_ack(trans, rph->msg_ref);
Harald Weltecf6a3812009-08-09 19:07:41 +0200676
Harald Welteb9c758b2009-07-05 14:02:46 +0200677 /* MS tells us that it has memory for more SMS, we need
678 * to check if we have any pending messages for it and then
679 * transfer those */
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100680 send_signal(S_SMS_SMMA, trans, NULL, 0);
Harald Weltef3efc592009-07-27 20:11:35 +0200681
Harald Weltef3efc592009-07-27 20:11:35 +0200682 return rc;
Harald Welteb9c758b2009-07-05 14:02:46 +0200683}
684
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200685/* receive RL DATA */
686static int gsm411_rx_rl_data(struct msgb *msg, struct gsm48_hdr *gh,
Harald Weltef3efc592009-07-27 20:11:35 +0200687 struct gsm_trans *trans)
Harald Welte7e310b12009-03-30 20:56:32 +0000688{
Daniel Willmann471712b2008-12-29 01:54:02 +0000689 struct gsm411_rp_hdr *rp_data = (struct gsm411_rp_hdr*)&gh->data;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200690 uint8_t msg_type = rp_data->msg_type & 0x07;
Harald Welte7e310b12009-03-30 20:56:32 +0000691 int rc = 0;
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000692
693 switch (msg_type) {
694 case GSM411_MT_RP_DATA_MO:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100695 DEBUGP(DLSMS, "RX SMS RP-DATA (MO)\n");
Harald Weltef3efc592009-07-27 20:11:35 +0200696 rc = gsm411_rx_rp_data(msg, trans, rp_data);
Harald Welte7e310b12009-03-30 20:56:32 +0000697 break;
Harald Welte7e310b12009-03-30 20:56:32 +0000698 case GSM411_MT_RP_SMMA_MO:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100699 DEBUGP(DLSMS, "RX SMS RP-SMMA\n");
Harald Weltef3efc592009-07-27 20:11:35 +0200700 rc = gsm411_rx_rp_smma(msg, trans, rp_data);
701 break;
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200702 default:
703 LOGP(DLSMS, LOGL_NOTICE, "Invalid RP type 0x%02x\n", msg_type);
704 rc = -EINVAL;
705 break;
706 }
707
708 return rc;
709}
710
711/* receive RL REPORT */
712static int gsm411_rx_rl_report(struct msgb *msg, struct gsm48_hdr *gh,
713 struct gsm_trans *trans)
714{
715 struct gsm411_rp_hdr *rp_data = (struct gsm411_rp_hdr*)&gh->data;
716 uint8_t msg_type = rp_data->msg_type & 0x07;
717 int rc = 0;
718
719 switch (msg_type) {
720 case GSM411_MT_RP_ACK_MO:
721 DEBUGP(DLSMS, "RX SMS RP-ACK (MO)\n");
722 rc = gsm411_rx_rp_ack(msg, trans, rp_data);
723 break;
Harald Weltef3efc592009-07-27 20:11:35 +0200724 case GSM411_MT_RP_ERROR_MO:
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200725 DEBUGP(DLSMS, "RX SMS RP-ERROR (MO)\n");
Harald Weltef3efc592009-07-27 20:11:35 +0200726 rc = gsm411_rx_rp_error(msg, trans, rp_data);
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000727 break;
728 default:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100729 LOGP(DLSMS, LOGL_NOTICE, "Invalid RP type 0x%02x\n", msg_type);
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200730 rc = -EINVAL;
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000731 break;
732 }
733
734 return rc;
735}
736
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200737/* receive SM-RL sap message from SMR
738 * NOTE: Message is freed by sender
739 */
740int gsm411_rl_recv(struct gsm411_smr_inst *inst, int msg_type,
741 struct msgb *msg)
742{
743 struct gsm_trans *trans =
744 container_of(inst, struct gsm_trans, sms.smr_inst);
745 struct gsm48_hdr *gh = msgb_l3(msg);
746 int rc = 0;
747
748 switch (msg_type) {
749 case GSM411_SM_RL_DATA_IND:
750 rc = gsm411_rx_rl_data(msg, gh, trans);
751 break;
752 case GSM411_SM_RL_REPORT_IND:
753 if (gh)
754 rc = gsm411_rx_rl_report(msg, gh, trans);
755 break;
756 default:
757 LOGP(DLSMS, LOGL_NOTICE, "Unhandled SM-RL message 0x%x\n", msg_type);
758 rc = -EINVAL;
759 }
760
761 return rc;
762}
763
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200764/* receive MNCCSMS sap message from SMC
765 * NOTE: Message is freed by sender
766 */
767static int gsm411_mn_recv(struct gsm411_smc_inst *inst, int msg_type,
768 struct msgb *msg)
Harald Weltef3efc592009-07-27 20:11:35 +0200769{
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200770 struct gsm_trans *trans =
771 container_of(inst, struct gsm_trans, sms.smc_inst);
772 struct gsm48_hdr *gh = msgb_l3(msg);
773 int rc = 0;
Harald Weltef3efc592009-07-27 20:11:35 +0200774
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200775 switch (msg_type) {
776 case GSM411_MNSMS_EST_IND:
777 case GSM411_MNSMS_DATA_IND:
778 DEBUGP(DLSMS, "MNSMS-DATA/EST-IND\n");
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200779 rc = gsm411_smr_recv(&trans->sms.smr_inst, msg_type, msg);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200780 break;
781 case GSM411_MNSMS_ERROR_IND:
782 if (gh)
783 DEBUGP(DLSMS, "MNSMS-ERROR-IND, cause %d (%s)\n",
784 gh->data[0],
785 get_value_string(gsm411_cp_cause_strs,
786 gh->data[0]));
787 else
788 DEBUGP(DLSMS, "MNSMS-ERROR-IND, no cause\n");
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200789 rc = gsm411_smr_recv(&trans->sms.smr_inst, msg_type, msg);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200790 break;
791 default:
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200792 LOGP(DLSMS, LOGL_NOTICE, "Unhandled MNCCSMS msg 0x%x\n", msg_type);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200793 rc = -EINVAL;
Harald Weltecf6a3812009-08-09 19:07:41 +0200794 }
Holger Hans Peter Freyther09e364b2009-08-10 07:59:27 +0200795
796 return rc;
Harald Weltef3efc592009-07-27 20:11:35 +0200797}
798
Harald Weltef3efc592009-07-27 20:11:35 +0200799/* Entry point for incoming GSM48_PDISC_SMS from abis_rsl.c */
Holger Hans Peter Freyther57c4dec2010-06-16 14:24:55 +0800800int gsm0411_rcv_sms(struct gsm_subscriber_connection *conn,
Holger Hans Peter Freyther97643312010-06-17 16:41:25 +0800801 struct msgb *msg)
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000802{
803 struct gsm48_hdr *gh = msgb_l3(msg);
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200804 uint8_t msg_type = gh->msg_type;
Neels Hofmeyr961bd0b2016-03-14 16:13:25 +0100805 uint8_t transaction_id = gsm48_hdr_trans_id_flip_ti(gh);
Harald Weltef3efc592009-07-27 20:11:35 +0200806 struct gsm_trans *trans;
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200807 int new_trans = 0;
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000808 int rc = 0;
809
Harald Welte2483f1b2016-06-19 18:06:02 +0200810 if (!conn->vsub)
Harald Weltef3efc592009-07-27 20:11:35 +0200811 return -EIO;
812 /* FIXME: send some error message */
813
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200814 DEBUGP(DLSMS, "receiving data (trans_id=%x)\n", transaction_id);
Jacob Erlbeckdae1f642014-12-02 14:22:53 +0100815 trans = trans_find_by_id(conn, GSM48_PDISC_SMS, transaction_id);
Holger Hans Peter Freytherba36bf42013-01-13 16:23:36 +0100816
817 /*
818 * A transaction we created but don't know about?
819 */
820 if (!trans && (transaction_id & 0x8) == 0) {
821 LOGP(DLSMS, LOGL_ERROR, "trans_id=%x allocated by us but known "
822 "to us anymore. We are ignoring it, maybe a CP-ERROR "
823 "from a MS?\n",
824 transaction_id);
825 return -EINVAL;
826 }
827
Harald Weltef3efc592009-07-27 20:11:35 +0200828 if (!trans) {
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200829 DEBUGP(DLSMS, " -> (new transaction)\n");
Harald Welte2483f1b2016-06-19 18:06:02 +0200830 trans = trans_alloc(conn->network, conn->vsub,
Jacob Erlbeckaf792d62014-12-02 14:22:53 +0100831 GSM48_PDISC_SMS,
Harald Weltef3efc592009-07-27 20:11:35 +0200832 transaction_id, new_callref++);
833 if (!trans) {
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200834 DEBUGP(DLSMS, " -> No memory for trans\n");
Harald Weltef3efc592009-07-27 20:11:35 +0200835 /* FIXME: send some error message */
836 return -ENOMEM;
837 }
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200838 gsm411_smc_init(&trans->sms.smc_inst, 0, 1,
839 gsm411_mn_recv, gsm411_mm_send);
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200840 gsm411_smr_init(&trans->sms.smr_inst, 0, 1,
841 gsm411_rl_recv, gsm411_mn_send);
Harald Weltef3efc592009-07-27 20:11:35 +0200842
Harald Welte2483f1b2016-06-19 18:06:02 +0200843 trans->conn = msc_subscr_conn_get(conn);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200844
845 new_trans = 1;
Harald Welte2483f1b2016-06-19 18:06:02 +0200846 cm_service_request_concludes(conn, msg);
Harald Weltef3efc592009-07-27 20:11:35 +0200847 }
848
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200849 /* 5.4: For MO, if a CP-DATA is received for a new
850 * transaction, equals reception of an implicit
851 * last CP-ACK for previous transaction */
852 if (trans->sms.smc_inst.cp_state == GSM411_CPS_IDLE
853 && msg_type == GSM411_MT_CP_DATA) {
854 int i;
855 struct gsm_trans *ptrans;
Sylvain Munaut258e2f92009-12-24 16:47:08 +0100856
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200857 /* Scan through all remote initiated transactions */
858 for (i=8; i<15; i++) {
859 if (i == transaction_id)
860 continue;
Sylvain Munaut258e2f92009-12-24 16:47:08 +0100861
Jacob Erlbeckdae1f642014-12-02 14:22:53 +0100862 ptrans = trans_find_by_id(conn, GSM48_PDISC_SMS, i);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200863 if (!ptrans)
864 continue;
Sylvain Munaut258e2f92009-12-24 16:47:08 +0100865
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200866 DEBUGP(DLSMS, "Implicit CP-ACK for trans_id=%x\n", i);
Sylvain Munaut258e2f92009-12-24 16:47:08 +0100867
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200868 /* Finish it for good */
869 trans_free(ptrans);
Sylvain Munaut258e2f92009-12-24 16:47:08 +0100870 }
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000871 }
872
Harald Welte2483f1b2016-06-19 18:06:02 +0200873 msc_subscr_conn_communicating(conn);
874
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200875 gsm411_smc_recv(&trans->sms.smc_inst,
876 (new_trans) ? GSM411_MMSMS_EST_IND : GSM411_MMSMS_DATA_IND,
877 msg, msg_type);
878
Daniel Willmann8b3390e2008-12-28 00:31:09 +0000879 return rc;
880}
881
Harald Weltecf6a3812009-08-09 19:07:41 +0200882/* Take a SMS in gsm_sms structure and send it through an already
Neels Hofmeyre2f24d52017-05-08 15:12:20 +0200883 * existing conn. We also assume that the caller ensured this conn already
Harald Weltecf6a3812009-08-09 19:07:41 +0200884 * has a SAPI3 RLL connection! */
Holger Hans Peter Freyther11b28f92010-12-24 13:48:27 +0100885int gsm411_send_sms(struct gsm_subscriber_connection *conn, struct gsm_sms *sms)
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000886{
887 struct msgb *msg = gsm411_msgb_alloc();
Harald Weltef3efc592009-07-27 20:11:35 +0200888 struct gsm_trans *trans;
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200889 uint8_t *data, *rp_ud_len;
Neels Hofmeyr05667a02016-05-10 13:27:32 +0200890 uint8_t msg_ref = sms_next_rp_msg_ref(&conn->next_rp_ref);
Sylvain Munautc4052cf2009-12-24 13:27:36 +0100891 int transaction_id;
Harald Welte76042182009-08-08 16:03:15 +0200892 int rc;
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000893
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200894 transaction_id =
Harald Welte2483f1b2016-06-19 18:06:02 +0200895 trans_assign_trans_id(conn->network, conn->vsub,
Jacob Erlbeckdae1f642014-12-02 14:22:53 +0100896 GSM48_PDISC_SMS, 0);
Harald Welte49839212009-12-22 13:45:58 +0100897 if (transaction_id == -1) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100898 LOGP(DLSMS, LOGL_ERROR, "No available transaction ids\n");
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100899 send_signal(S_SMS_UNKNOWN_ERROR, NULL, sms, 0);
Holger Hans Peter Freyther8e78fa72010-06-14 16:13:16 +0800900 sms_free(sms);
Holger Hans Peter Freyther29d58b72015-08-12 13:35:46 +0200901 msgb_free(msg);
Harald Welte49839212009-12-22 13:45:58 +0100902 return -EBUSY;
903 }
Harald Weltecf6a3812009-08-09 19:07:41 +0200904
Neels Hofmeyr1e918c32016-05-09 21:48:53 +0200905 DEBUGP(DLSMS, "%s()\n", __func__);
Harald Weltef3efc592009-07-27 20:11:35 +0200906
Harald Welte76042182009-08-08 16:03:15 +0200907 /* FIXME: allocate transaction with message reference */
Harald Welte2483f1b2016-06-19 18:06:02 +0200908 trans = trans_alloc(conn->network, conn->vsub,
Jacob Erlbeckaf792d62014-12-02 14:22:53 +0100909 GSM48_PDISC_SMS,
Harald Welte76042182009-08-08 16:03:15 +0200910 transaction_id, new_callref++);
911 if (!trans) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100912 LOGP(DLSMS, LOGL_ERROR, "No memory for trans\n");
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100913 send_signal(S_SMS_UNKNOWN_ERROR, NULL, sms, 0);
Holger Hans Peter Freyther8e78fa72010-06-14 16:13:16 +0800914 sms_free(sms);
Holger Hans Peter Freyther29d58b72015-08-12 13:35:46 +0200915 msgb_free(msg);
Harald Welte76042182009-08-08 16:03:15 +0200916 /* FIXME: send some error message */
917 return -ENOMEM;
918 }
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200919 gsm411_smc_init(&trans->sms.smc_inst, sms->id, 1,
920 gsm411_mn_recv, gsm411_mm_send);
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200921 gsm411_smr_init(&trans->sms.smr_inst, sms->id, 1,
922 gsm411_rl_recv, gsm411_mn_send);
Harald Welte76042182009-08-08 16:03:15 +0200923 trans->sms.sms = sms;
924
Harald Welte2483f1b2016-06-19 18:06:02 +0200925 trans->conn = msc_subscr_conn_get(conn);
Harald Welte76042182009-08-08 16:03:15 +0200926
927 /* Hardcode SMSC Originating Address for now */
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200928 data = (uint8_t *)msgb_put(msg, 8);
Harald Welte87f5d632009-07-04 17:39:00 +0200929 data[0] = 0x07; /* originator length == 7 */
Harald Welteb9c758b2009-07-05 14:02:46 +0200930 data[1] = 0x91; /* type of number: international, ISDN */
931 data[2] = 0x44; /* 447785016005 */
Daniel Willmanna3e29842008-12-29 16:03:54 +0000932 data[3] = 0x77;
933 data[4] = 0x58;
934 data[5] = 0x10;
935 data[6] = 0x06;
936 data[7] = 0x50;
Harald Welte87f5d632009-07-04 17:39:00 +0200937
938 /* Hardcoded Destination Address */
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200939 data = (uint8_t *)msgb_put(msg, 1);
Harald Welte87f5d632009-07-04 17:39:00 +0200940 data[0] = 0; /* destination length == 0 */
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000941
Harald Welte76042182009-08-08 16:03:15 +0200942 /* obtain a pointer for the rp_ud_len, so we can fill it later */
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200943 rp_ud_len = (uint8_t *)msgb_put(msg, 1);
Daniel Willmann4a1e8792008-12-29 06:23:56 +0000944
Alexander Chemeris9e15e182014-03-08 23:54:28 +0100945 /* generate the 03.40 SMS-DELIVER TPDU */
946 rc = gsm340_gen_sms_deliver_tpdu(msg, sms);
Harald Welte76042182009-08-08 16:03:15 +0200947 if (rc < 0) {
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100948 send_signal(S_SMS_UNKNOWN_ERROR, trans, sms, 0);
Holger Hans Peter Freyther8e78fa72010-06-14 16:13:16 +0800949 sms_free(sms);
Andreas Eversbergf7396ea2011-10-28 04:07:07 +0200950 trans->sms.sms = NULL;
951 trans_free(trans);
Harald Welte76042182009-08-08 16:03:15 +0200952 msgb_free(msg);
953 return rc;
954 }
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000955
Harald Welte76042182009-08-08 16:03:15 +0200956 *rp_ud_len = rc;
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000957
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100958 DEBUGP(DLSMS, "TX: SMS DELIVER\n");
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000959
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +0200960 rate_ctr_inc(&conn->network->msc_ctrs->ctr[MSC_CTR_SMS_DELIVERED]);
Nico Golde1e5ed4e2010-09-16 17:50:29 +0200961 db_sms_inc_deliver_attempts(trans->sms.sms);
Harald Welte24ff6ee2009-12-22 00:41:05 +0100962
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +0200963 return gsm411_rp_sendmsg(&trans->sms.smr_inst, msg,
964 GSM411_MT_RP_DATA_MT, msg_ref, GSM411_SM_RL_DATA_REQ);
Daniel Willmann6fe997e2008-12-29 04:20:41 +0000965}
Harald Weltef3efc592009-07-27 20:11:35 +0200966
Harald Weltecf6a3812009-08-09 19:07:41 +0200967/* paging callback. Here we get called if paging a subscriber has
968 * succeeded or failed. */
Harald Welte76042182009-08-08 16:03:15 +0200969static int paging_cb_send_sms(unsigned int hooknum, unsigned int event,
Holger Hans Peter Freyther86481c22010-06-17 15:05:57 +0800970 struct msgb *msg, void *_conn, void *_sms)
Harald Weltef3efc592009-07-27 20:11:35 +0200971{
Holger Hans Peter Freyther86481c22010-06-17 15:05:57 +0800972 struct gsm_subscriber_connection *conn = _conn;
Harald Welte76042182009-08-08 16:03:15 +0200973 struct gsm_sms *sms = _sms;
Holger Hans Peter Freyther4cd51582010-06-14 16:03:03 +0800974 int rc = 0;
Harald Weltef3efc592009-07-27 20:11:35 +0200975
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100976 DEBUGP(DLSMS, "paging_cb_send_sms(hooknum=%u, event=%u, msg=%p,"
Holger Hans Peter Freyther52ffb922010-12-29 14:02:34 +0100977 "conn=%p, sms=%p/id: %llu)\n", hooknum, event, msg, conn, sms, sms->id);
Harald Welte76042182009-08-08 16:03:15 +0200978
979 if (hooknum != GSM_HOOK_RR_PAGING)
980 return -EINVAL;
981
982 switch (event) {
983 case GSM_PAGING_SUCCEEDED:
Holger Hans Peter Freyther86481c22010-06-17 15:05:57 +0800984 gsm411_send_sms(conn, sms);
Harald Welte76042182009-08-08 16:03:15 +0200985 break;
986 case GSM_PAGING_EXPIRED:
Holger Hans Peter Freytherca5702a2010-06-10 18:20:54 +0800987 case GSM_PAGING_OOM:
Holger Hans Peter Freytherd3baf412010-12-23 18:19:17 +0100988 case GSM_PAGING_BUSY:
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +0100989 send_signal(S_SMS_UNKNOWN_ERROR, NULL, sms, event);
Harald Welte76042182009-08-08 16:03:15 +0200990 sms_free(sms);
991 rc = -ETIMEDOUT;
992 break;
Holger Hans Peter Freyther52ffb922010-12-29 14:02:34 +0100993 default:
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +0100994 LOGP(DLSMS, LOGL_ERROR, "Unhandled paging event: %d\n", event);
Harald Welte76042182009-08-08 16:03:15 +0200995 }
996
997 return rc;
998}
999
Harald Weltecf6a3812009-08-09 19:07:41 +02001000/* high-level function to send a SMS to a given subscriber. The function
1001 * will take care of paging the subscriber, establishing the RLL SAPI3
1002 * connection, etc. */
Harald Welte2483f1b2016-06-19 18:06:02 +02001003int gsm411_send_sms_subscr(struct vlr_subscr *vsub,
Harald Welte76042182009-08-08 16:03:15 +02001004 struct gsm_sms *sms)
1005{
Holger Hans Peter Freytherb2be1952010-06-16 13:23:55 +08001006 struct gsm_subscriber_connection *conn;
Holger Hans Peter Freytherd6d7aff2015-04-06 12:03:45 +02001007 void *res;
Harald Weltecf6a3812009-08-09 19:07:41 +02001008
Neels Hofmeyre2f24d52017-05-08 15:12:20 +02001009 /* check if we already have an open conn to the subscriber.
Harald Welte76042182009-08-08 16:03:15 +02001010 * if yes, send the SMS this way */
Harald Welte2483f1b2016-06-19 18:06:02 +02001011 conn = connection_for_subscr(vsub);
Holger Hans Peter Freytherb2be1952010-06-16 13:23:55 +08001012 if (conn) {
Neels Hofmeyr1e918c32016-05-09 21:48:53 +02001013 LOGP(DLSMS, LOGL_DEBUG, "Sending SMS via already open connection %p to %s\n",
Harald Welte2483f1b2016-06-19 18:06:02 +02001014 conn, vlr_subscr_name(vsub));
Holger Hans Peter Freyther0fbb3ec2010-06-16 14:19:31 +08001015 return gsm411_send_sms(conn, sms);
Holger Hans Peter Freytherecd99332010-06-15 12:53:08 +08001016 }
Harald Welte76042182009-08-08 16:03:15 +02001017
1018 /* if not, we have to start paging */
Neels Hofmeyr1e918c32016-05-09 21:48:53 +02001019 LOGP(DLSMS, LOGL_DEBUG, "Sending SMS: no connection open, start paging %s\n",
Harald Welte2483f1b2016-06-19 18:06:02 +02001020 vlr_subscr_name(vsub));
Neels Hofmeyr84da6b12016-05-20 21:59:55 +02001021 res = subscr_request_conn(vsub, paging_cb_send_sms, sms, "send SMS");
Holger Hans Peter Freytherd6d7aff2015-04-06 12:03:45 +02001022 if (!res) {
1023 send_signal(S_SMS_UNKNOWN_ERROR, NULL, sms, GSM_PAGING_BUSY);
1024 sms_free(sms);
1025 }
Harald Welte76042182009-08-08 16:03:15 +02001026 return 0;
1027}
Harald Welte3366a942009-07-28 00:44:49 +02001028
Harald Welte (local)86b17172009-08-14 14:52:17 +02001029void _gsm411_sms_trans_free(struct gsm_trans *trans)
1030{
Andreas Eversbergf7396ea2011-10-28 04:07:07 +02001031 /* cleanup SMS instance */
Andreas Eversbergbc6c43f2011-10-28 11:11:13 +02001032 gsm411_smr_clear(&trans->sms.smr_inst);
1033 trans->sms.smr_inst.rl_recv = NULL;
1034 trans->sms.smr_inst.mn_send = NULL;
1035
Andreas Eversbergf7396ea2011-10-28 04:07:07 +02001036 gsm411_smc_clear(&trans->sms.smc_inst);
1037 trans->sms.smc_inst.mn_recv = NULL;
1038 trans->sms.smc_inst.mm_send = NULL;
1039
Holger Hans Peter Freythercea722b2010-06-15 12:29:37 +08001040 if (trans->sms.sms) {
Holger Hans Peter Freythereff409492012-11-10 19:46:58 +01001041 LOGP(DLSMS, LOGL_ERROR, "Transaction contains SMS.\n");
Holger Hans Peter Freyther04144c12010-12-24 10:15:55 +01001042 send_signal(S_SMS_UNKNOWN_ERROR, trans, trans->sms.sms, 0);
Holger Hans Peter Freythercea722b2010-06-15 12:29:37 +08001043 sms_free(trans->sms.sms);
1044 trans->sms.sms = NULL;
1045 }
Harald Welte (local)86b17172009-08-14 14:52:17 +02001046}
1047
Harald Welte2483f1b2016-06-19 18:06:02 +02001048/* Process incoming SAPI N-REJECT from BSC */
Holger Hans Peter Freyther6a3d7652010-06-15 12:03:10 +08001049void gsm411_sapi_n_reject(struct gsm_subscriber_connection *conn)
1050{
Holger Hans Peter Freyther79eff7e2010-12-27 23:25:53 +01001051 struct gsm_network *net;
Holger Hans Peter Freyther6a3d7652010-06-15 12:03:10 +08001052 struct gsm_trans *trans, *tmp;
1053
Neels Hofmeyra9f2bb52016-05-09 21:09:47 +02001054 net = conn->network;
Holger Hans Peter Freyther79eff7e2010-12-27 23:25:53 +01001055
Holger Hans Peter Freytherf76ed2d2013-12-27 22:47:09 +01001056 llist_for_each_entry_safe(trans, tmp, &net->trans_list, entry) {
1057 struct gsm_sms *sms;
Holger Hans Peter Freyther6a3d7652010-06-15 12:03:10 +08001058
Holger Hans Peter Freytherf76ed2d2013-12-27 22:47:09 +01001059 if (trans->conn != conn)
1060 continue;
1061 if (trans->protocol != GSM48_PDISC_SMS)
1062 continue;
1063
1064 sms = trans->sms.sms;
1065 if (!sms) {
1066 LOGP(DLSMS, LOGL_ERROR, "SAPI Reject but no SMS.\n");
1067 continue;
Holger Hans Peter Freyther6a3d7652010-06-15 12:03:10 +08001068 }
Holger Hans Peter Freytherf76ed2d2013-12-27 22:47:09 +01001069
1070 send_signal(S_SMS_UNKNOWN_ERROR, trans, sms, 0);
1071 sms_free(sms);
1072 trans->sms.sms = NULL;
1073 trans_free(trans);
1074 }
Holger Hans Peter Freyther6a3d7652010-06-15 12:03:10 +08001075}
1076