blob: d5b3b21af3dd0ea57f7408f83dcfa41b9cd95eac [file] [log] [blame]
Harald Welte39315c42010-01-10 18:01:52 +01001/* ip.access nanoBTS specific code */
2
3/* (C) 2009-2010 by Harald Welte <laforge@gnumonks.org>
4 *
5 * All Rights Reserved
6 *
7 * This program is free software; you can redistribute it and/or modify
Harald Welte9af6ddf2011-01-01 15:25:50 +01008 * it under the terms of the GNU Affero General Public License as published by
9 * the Free Software Foundation; either version 3 of the License, or
Harald Welte39315c42010-01-10 18:01:52 +010010 * (at your option) any later version.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Harald Welte9af6ddf2011-01-01 15:25:50 +010015 * GNU Affero General Public License for more details.
Harald Welte39315c42010-01-10 18:01:52 +010016 *
Harald Welte9af6ddf2011-01-01 15:25:50 +010017 * You should have received a copy of the GNU Affero General Public License
18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
Harald Welte39315c42010-01-10 18:01:52 +010019 *
20 */
21
Harald Weltef338a032011-01-14 15:55:42 +010022#include <arpa/inet.h>
Maxd1f70ed2017-09-21 16:15:32 +020023#include <time.h>
Harald Weltef338a032011-01-14 15:55:42 +010024
Pablo Neira Ayuso136f4532011-03-22 16:47:59 +010025#include <osmocom/gsm/tlv.h>
Harald Welte39315c42010-01-10 18:01:52 +010026
Neels Hofmeyrc0164792017-09-04 15:15:32 +020027#include <osmocom/bsc/gsm_data.h>
28#include <osmocom/bsc/signal.h>
29#include <osmocom/bsc/abis_nm.h>
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +020030#include <osmocom/abis/e1_input.h>
31#include <osmocom/gsm/tlv.h>
32#include <osmocom/core/msgb.h>
33#include <osmocom/core/talloc.h>
Neels Hofmeyrc0164792017-09-04 15:15:32 +020034#include <osmocom/bsc/gsm_data.h>
35#include <osmocom/bsc/abis_nm.h>
36#include <osmocom/bsc/abis_rsl.h>
37#include <osmocom/bsc/debug.h>
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +020038#include <osmocom/abis/subchan_demux.h>
Harald Welte4a88a492014-08-20 23:46:40 +020039#include <osmocom/gsm/ipa.h>
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +020040#include <osmocom/abis/ipaccess.h>
41#include <osmocom/core/logging.h>
Neels Hofmeyrc0164792017-09-04 15:15:32 +020042#include <osmocom/bsc/ipaccess.h>
43#include <osmocom/bsc/bts_ipaccess_nanobts_omlattr.h>
Stefan Sperling7b709262018-04-19 14:31:11 +020044#include <osmocom/bsc/paging.h>
Pablo Neira Ayuso0d2881a2011-05-14 11:32:48 +020045
Holger Hans Peter Freythere48c1872013-04-24 11:36:15 +020046extern struct gsm_network *bsc_gsmnet;
47
Pablo Neira Ayuso0d2881a2011-05-14 11:32:48 +020048static int bts_model_nanobts_start(struct gsm_network *net);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +020049static void bts_model_nanobts_e1line_bind_ops(struct e1inp_line *line);
Harald Welte39315c42010-01-10 18:01:52 +010050
Max36bf7972017-10-12 17:46:49 +020051static char *get_oml_status(const struct gsm_bts *bts)
52{
53 if (bts->oml_link)
Maxaa954cd2017-11-29 12:18:02 +010054 return all_trx_rsl_connected_unlocked(bts) ? "connected" : "degraded";
Max36bf7972017-10-12 17:46:49 +020055
56 return "disconnected";
57}
58
Neels Hofmeyr91aa68f2018-05-09 17:46:22 +020059static bool oml_is_ts_ready(const struct gsm_bts_trx_ts *ts)
60{
61 return ts && ts->mo.nm_state.operational == NM_OPSTATE_ENABLED;
62}
63
Harald Weltef383aa12012-07-02 19:51:55 +020064struct gsm_bts_model bts_model_nanobts = {
Harald Welte39315c42010-01-10 18:01:52 +010065 .type = GSM_BTS_TYPE_NANOBTS,
Harald Welte09cefee2011-02-12 12:29:21 +010066 .name = "nanobts",
Pablo Neira Ayuso0d2881a2011-05-14 11:32:48 +020067 .start = bts_model_nanobts_start,
Harald Welte09cefee2011-02-12 12:29:21 +010068 .oml_rcvmsg = &abis_nm_rcvmsg,
Max3d049d22017-10-09 17:12:53 +020069 .oml_status = &get_oml_status,
Neels Hofmeyr91aa68f2018-05-09 17:46:22 +020070 .oml_is_ts_ready = oml_is_ts_ready,
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +020071 .e1line_bind_ops = bts_model_nanobts_e1line_bind_ops,
Harald Welte39315c42010-01-10 18:01:52 +010072 .nm_att_tlvdef = {
73 .def = {
74 /* ip.access specifics */
75 [NM_ATT_IPACC_DST_IP] = { TLV_TYPE_FIXED, 4 },
76 [NM_ATT_IPACC_DST_IP_PORT] = { TLV_TYPE_FIXED, 2 },
77 [NM_ATT_IPACC_STREAM_ID] = { TLV_TYPE_TV, },
Harald Welte39315c42010-01-10 18:01:52 +010078 [NM_ATT_IPACC_SEC_OML_CFG] = { TLV_TYPE_FIXED, 6 },
79 [NM_ATT_IPACC_IP_IF_CFG] = { TLV_TYPE_FIXED, 8 },
80 [NM_ATT_IPACC_IP_GW_CFG] = { TLV_TYPE_FIXED, 12 },
81 [NM_ATT_IPACC_IN_SERV_TIME] = { TLV_TYPE_FIXED, 4 },
82 [NM_ATT_IPACC_LOCATION] = { TLV_TYPE_TL16V },
83 [NM_ATT_IPACC_PAGING_CFG] = { TLV_TYPE_FIXED, 2 },
84 [NM_ATT_IPACC_UNIT_ID] = { TLV_TYPE_TL16V },
85 [NM_ATT_IPACC_UNIT_NAME] = { TLV_TYPE_TL16V },
86 [NM_ATT_IPACC_SNMP_CFG] = { TLV_TYPE_TL16V },
87 [NM_ATT_IPACC_PRIM_OML_CFG_LIST] = { TLV_TYPE_TL16V },
88 [NM_ATT_IPACC_NV_FLAGS] = { TLV_TYPE_TL16V },
89 [NM_ATT_IPACC_FREQ_CTRL] = { TLV_TYPE_FIXED, 2 },
90 [NM_ATT_IPACC_PRIM_OML_FB_TOUT] = { TLV_TYPE_TL16V },
91 [NM_ATT_IPACC_CUR_SW_CFG] = { TLV_TYPE_TL16V },
92 [NM_ATT_IPACC_TIMING_BUS] = { TLV_TYPE_TL16V },
93 [NM_ATT_IPACC_CGI] = { TLV_TYPE_TL16V },
94 [NM_ATT_IPACC_RAC] = { TLV_TYPE_TL16V },
95 [NM_ATT_IPACC_OBJ_VERSION] = { TLV_TYPE_TL16V },
96 [NM_ATT_IPACC_GPRS_PAGING_CFG]= { TLV_TYPE_TL16V },
97 [NM_ATT_IPACC_NSEI] = { TLV_TYPE_TL16V },
98 [NM_ATT_IPACC_BVCI] = { TLV_TYPE_TL16V },
99 [NM_ATT_IPACC_NSVCI] = { TLV_TYPE_TL16V },
100 [NM_ATT_IPACC_NS_CFG] = { TLV_TYPE_TL16V },
101 [NM_ATT_IPACC_BSSGP_CFG] = { TLV_TYPE_TL16V },
102 [NM_ATT_IPACC_NS_LINK_CFG] = { TLV_TYPE_TL16V },
103 [NM_ATT_IPACC_RLC_CFG] = { TLV_TYPE_TL16V },
104 [NM_ATT_IPACC_ALM_THRESH_LIST]= { TLV_TYPE_TL16V },
105 [NM_ATT_IPACC_MONIT_VAL_LIST] = { TLV_TYPE_TL16V },
106 [NM_ATT_IPACC_TIB_CONTROL] = { TLV_TYPE_TL16V },
107 [NM_ATT_IPACC_SUPP_FEATURES] = { TLV_TYPE_TL16V },
108 [NM_ATT_IPACC_CODING_SCHEMES] = { TLV_TYPE_TL16V },
109 [NM_ATT_IPACC_RLC_CFG_2] = { TLV_TYPE_TL16V },
110 [NM_ATT_IPACC_HEARTB_TOUT] = { TLV_TYPE_TL16V },
111 [NM_ATT_IPACC_UPTIME] = { TLV_TYPE_TL16V },
112 [NM_ATT_IPACC_RLC_CFG_3] = { TLV_TYPE_TL16V },
113 [NM_ATT_IPACC_SSL_CFG] = { TLV_TYPE_TL16V },
114 [NM_ATT_IPACC_SEC_POSSIBLE] = { TLV_TYPE_TL16V },
115 [NM_ATT_IPACC_IML_SSL_STATE] = { TLV_TYPE_TL16V },
116 [NM_ATT_IPACC_REVOC_DATE] = { TLV_TYPE_TL16V },
117 },
118 },
119};
120
Harald Weltef338a032011-01-14 15:55:42 +0100121
122/* Callback function to be called whenever we get a GSM 12.21 state change event */
123static int nm_statechg_event(int evt, struct nm_statechg_signal_data *nsd)
124{
Holger Hans Peter Freytherc42ad8b2011-04-18 17:04:00 +0200125 uint8_t obj_class = nsd->obj_class;
Harald Weltef338a032011-01-14 15:55:42 +0100126 void *obj = nsd->obj;
127 struct gsm_nm_state *new_state = nsd->new_state;
128
129 struct gsm_bts *bts;
130 struct gsm_bts_trx *trx;
131 struct gsm_bts_trx_ts *ts;
132 struct gsm_bts_gprs_nsvc *nsvc;
133
Philippb4cb8382016-09-29 17:01:57 +0200134 struct msgb *msgb;
Holger Hans Peter Freyther9303df22013-08-29 18:29:46 +0200135
Holger Hans Peter Freyther4b0e36a2013-04-24 11:33:13 +0200136 if (!is_ipaccess_bts(nsd->bts))
Harald Weltef38ca9a2011-03-06 22:11:32 +0100137 return 0;
138
Harald Weltef338a032011-01-14 15:55:42 +0100139 /* This event-driven BTS setup is currently only required on nanoBTS */
140
141 /* S_NM_STATECHG_ADM is called after we call chg_adm_state() and would create
142 * endless loop */
143 if (evt != S_NM_STATECHG_OPER)
144 return 0;
145
146 switch (obj_class) {
147 case NM_OC_SITE_MANAGER:
148 bts = container_of(obj, struct gsm_bts, site_mgr);
149 if ((new_state->operational == NM_OPSTATE_ENABLED &&
150 new_state->availability == NM_AVSTATE_OK) ||
151 (new_state->operational == NM_OPSTATE_DISABLED &&
152 new_state->availability == NM_AVSTATE_OFF_LINE))
153 abis_nm_opstart(bts, obj_class, 0xff, 0xff, 0xff);
154 break;
155 case NM_OC_BTS:
156 bts = obj;
157 if (new_state->availability == NM_AVSTATE_DEPENDENCY) {
Philippb4cb8382016-09-29 17:01:57 +0200158 msgb = nanobts_attr_bts_get(bts);
159 abis_nm_set_bts_attr(bts, msgb->data, msgb->len);
160 msgb_free(msgb);
Harald Weltef338a032011-01-14 15:55:42 +0100161 abis_nm_chg_adm_state(bts, obj_class,
162 bts->bts_nr, 0xff, 0xff,
163 NM_STATE_UNLOCKED);
164 abis_nm_opstart(bts, obj_class,
165 bts->bts_nr, 0xff, 0xff);
166 }
167 break;
168 case NM_OC_CHANNEL:
169 ts = obj;
170 trx = ts->trx;
171 if (new_state->operational == NM_OPSTATE_DISABLED &&
172 new_state->availability == NM_AVSTATE_DEPENDENCY) {
Harald Weltef338a032011-01-14 15:55:42 +0100173 enum abis_nm_chan_comb ccomb =
174 abis_nm_chcomb4pchan(ts->pchan);
Holger Hans Peter Freyther33f2c4d2014-11-07 09:54:57 +0100175 if (abis_nm_set_channel_attr(ts, ccomb) == -EINVAL) {
176 ipaccess_drop_oml(trx->bts);
177 return -1;
178 }
Harald Weltef338a032011-01-14 15:55:42 +0100179 abis_nm_chg_adm_state(trx->bts, obj_class,
180 trx->bts->bts_nr, trx->nr, ts->nr,
181 NM_STATE_UNLOCKED);
182 abis_nm_opstart(trx->bts, obj_class,
183 trx->bts->bts_nr, trx->nr, ts->nr);
184 }
185 break;
186 case NM_OC_RADIO_CARRIER:
187 trx = obj;
188 if (new_state->operational == NM_OPSTATE_DISABLED &&
189 new_state->availability == NM_AVSTATE_OK)
190 abis_nm_opstart(trx->bts, obj_class, trx->bts->bts_nr,
191 trx->nr, 0xff);
192 break;
193 case NM_OC_GPRS_NSE:
194 bts = container_of(obj, struct gsm_bts, gprs.nse);
195 if (bts->gprs.mode == BTS_GPRS_NONE)
196 break;
197 if (new_state->availability == NM_AVSTATE_DEPENDENCY) {
Philippb4cb8382016-09-29 17:01:57 +0200198 msgb = nanobts_attr_nse_get(bts);
Harald Weltef338a032011-01-14 15:55:42 +0100199 abis_nm_ipaccess_set_attr(bts, obj_class, bts->bts_nr,
Philippb4cb8382016-09-29 17:01:57 +0200200 0xff, 0xff, msgb->data,
201 msgb->len);
202 msgb_free(msgb);
Harald Weltef338a032011-01-14 15:55:42 +0100203 abis_nm_opstart(bts, obj_class, bts->bts_nr,
204 0xff, 0xff);
205 }
206 break;
207 case NM_OC_GPRS_CELL:
208 bts = container_of(obj, struct gsm_bts, gprs.cell);
209 if (bts->gprs.mode == BTS_GPRS_NONE)
210 break;
211 if (new_state->availability == NM_AVSTATE_DEPENDENCY) {
Philippb4cb8382016-09-29 17:01:57 +0200212 msgb = nanobts_attr_cell_get(bts);
Harald Weltef338a032011-01-14 15:55:42 +0100213 abis_nm_ipaccess_set_attr(bts, obj_class, bts->bts_nr,
Philippb4cb8382016-09-29 17:01:57 +0200214 0, 0xff, msgb->data,
215 msgb->len);
216 msgb_free(msgb);
Harald Weltef338a032011-01-14 15:55:42 +0100217 abis_nm_opstart(bts, obj_class, bts->bts_nr,
218 0, 0xff);
219 abis_nm_chg_adm_state(bts, obj_class, bts->bts_nr,
220 0, 0xff, NM_STATE_UNLOCKED);
221 abis_nm_chg_adm_state(bts, NM_OC_GPRS_NSE, bts->bts_nr,
222 0xff, 0xff, NM_STATE_UNLOCKED);
223 }
224 break;
225 case NM_OC_GPRS_NSVC:
226 nsvc = obj;
227 bts = nsvc->bts;
228 if (bts->gprs.mode == BTS_GPRS_NONE)
229 break;
230 /* We skip NSVC1 since we only use NSVC0 */
231 if (nsvc->id == 1)
232 break;
Sylvain Munaut67c0c7f2011-10-17 13:57:58 +0200233 if ((new_state->availability == NM_AVSTATE_OFF_LINE) ||
234 (new_state->availability == NM_AVSTATE_DEPENDENCY)) {
Philippb4cb8382016-09-29 17:01:57 +0200235 msgb = nanobts_attr_nscv_get(bts);
Harald Weltef338a032011-01-14 15:55:42 +0100236 abis_nm_ipaccess_set_attr(bts, obj_class, bts->bts_nr,
237 nsvc->id, 0xff,
Philippb4cb8382016-09-29 17:01:57 +0200238 msgb->data, msgb->len);
239 msgb_free(msgb);
Harald Weltef338a032011-01-14 15:55:42 +0100240 abis_nm_opstart(bts, obj_class, bts->bts_nr,
241 nsvc->id, 0xff);
242 abis_nm_chg_adm_state(bts, obj_class, bts->bts_nr,
243 nsvc->id, 0xff,
244 NM_STATE_UNLOCKED);
245 }
246 default:
247 break;
248 }
249 return 0;
250}
251
252/* Callback function to be called every time we receive a 12.21 SW activated report */
253static int sw_activ_rep(struct msgb *mb)
254{
255 struct abis_om_fom_hdr *foh = msgb_l3(mb);
Pablo Neira Ayuso7abecfc2011-08-17 22:43:54 +0200256 struct e1inp_sign_link *sign_link = mb->dst;
257 struct gsm_bts *bts = sign_link->trx->bts;
Harald Weltef338a032011-01-14 15:55:42 +0100258 struct gsm_bts_trx *trx = gsm_bts_trx_num(bts, foh->obj_inst.trx_nr);
259
260 if (!trx)
261 return -EINVAL;
262
Holger Hans Peter Freyther4b0e36a2013-04-24 11:33:13 +0200263 if (!is_ipaccess_bts(trx->bts))
Harald Weltef338a032011-01-14 15:55:42 +0100264 return 0;
265
266 switch (foh->obj_class) {
267 case NM_OC_BASEB_TRANSC:
268 abis_nm_chg_adm_state(trx->bts, foh->obj_class,
269 trx->bts->bts_nr, trx->nr, 0xff,
270 NM_STATE_UNLOCKED);
271 abis_nm_opstart(trx->bts, foh->obj_class,
272 trx->bts->bts_nr, trx->nr, 0xff);
273 /* TRX software is active, tell it to initiate RSL Link */
Harald Welte8b291802013-03-12 13:57:05 +0100274 abis_nm_ipaccess_rsl_connect(trx, trx->bts->ip_access.rsl_ip,
275 3003, trx->rsl_tei);
Harald Weltef338a032011-01-14 15:55:42 +0100276 break;
277 case NM_OC_RADIO_CARRIER: {
278 /*
279 * Locking the radio carrier will make it go
280 * offline again and we would come here. The
281 * framework should determine that there was
282 * no change and avoid recursion.
283 *
284 * This code is here to make sure that on start
285 * a TRX remains locked.
286 */
Harald Welted64c0bc2011-05-30 12:07:53 +0200287 int rc_state = trx->mo.nm_state.administrative;
Harald Weltef338a032011-01-14 15:55:42 +0100288 /* Patch ARFCN into radio attribute */
Philippb4cb8382016-09-29 17:01:57 +0200289 struct msgb *msgb = nanobts_attr_radio_get(trx->bts, trx);
290 abis_nm_set_radio_attr(trx, msgb->data, msgb->len);
291 msgb_free(msgb);
Harald Weltef338a032011-01-14 15:55:42 +0100292 abis_nm_chg_adm_state(trx->bts, foh->obj_class,
293 trx->bts->bts_nr, trx->nr, 0xff,
294 rc_state);
295 abis_nm_opstart(trx->bts, foh->obj_class, trx->bts->bts_nr,
296 trx->nr, 0xff);
297 break;
298 }
299 }
300 return 0;
301}
302
Neels Hofmeyrbf709922018-05-03 16:11:28 +0200303static struct gsm_bts_trx_ts *gsm_bts_trx_ts(struct gsm_network *net,
304 int bts_nr, int trx_nr, int ts_nr)
305{
306 struct gsm_bts *bts;
307 struct gsm_bts_trx *trx;
308 bts = gsm_bts_num(net, bts_nr);
309 if (!bts)
310 return NULL;
311 trx = gsm_bts_trx_by_nr(bts, trx_nr);
312 if (!trx)
313 return NULL;
314 if (ts_nr < 0 || ts_nr > ARRAY_SIZE(trx->ts))
315 return NULL;
316 return &trx->ts[ts_nr];
317}
318
319static void nm_rx_opstart_ack_chan(struct abis_om_fom_hdr *foh)
320{
321 struct gsm_bts_trx_ts *ts;
322 ts = gsm_bts_trx_ts(bsc_gsmnet, foh->obj_inst.bts_nr, foh->obj_inst.trx_nr, foh->obj_inst.ts_nr);
323 if (!ts) {
324 LOGP(DNM, LOGL_ERROR, "%s Channel OPSTART ACK for non-existent TS\n",
325 abis_nm_dump_foh(foh));
326 return;
327 }
328
Neels Hofmeyr91aa68f2018-05-09 17:46:22 +0200329 gsm_ts_check_init(ts);
Neels Hofmeyrbf709922018-05-03 16:11:28 +0200330}
331
332static void nm_rx_opstart_ack(struct abis_om_fom_hdr *foh)
333{
334 switch (foh->obj_class) {
335 case NM_OC_CHANNEL:
336 nm_rx_opstart_ack_chan(foh);
337 break;
338 default:
339 break;
340 }
341}
342
Harald Weltef338a032011-01-14 15:55:42 +0100343/* Callback function to be called every time we receive a signal from NM */
Holger Hans Peter Freyther84b033f2013-04-24 11:26:44 +0200344static int bts_ipa_nm_sig_cb(unsigned int subsys, unsigned int signal,
Harald Weltef338a032011-01-14 15:55:42 +0100345 void *handler_data, void *signal_data)
346{
347 if (subsys != SS_NM)
348 return 0;
349
350 switch (signal) {
351 case S_NM_SW_ACTIV_REP:
352 return sw_activ_rep(signal_data);
353 case S_NM_STATECHG_OPER:
354 case S_NM_STATECHG_ADM:
355 return nm_statechg_event(signal, signal_data);
Neels Hofmeyrbf709922018-05-03 16:11:28 +0200356 case S_NM_OPSTART_ACK:
357 nm_rx_opstart_ack(signal_data);
358 return 0;
Harald Weltef338a032011-01-14 15:55:42 +0100359 default:
360 break;
361 }
362 return 0;
363}
364
Pablo Neira Ayuso0d2881a2011-05-14 11:32:48 +0200365static int bts_model_nanobts_start(struct gsm_network *net)
Harald Welte39315c42010-01-10 18:01:52 +0100366{
Holger Hans Peter Freyther84b033f2013-04-24 11:26:44 +0200367 osmo_signal_unregister_handler(SS_NM, bts_ipa_nm_sig_cb, NULL);
Holger Hans Peter Freythere84dd982013-04-24 10:54:02 +0200368 osmo_signal_register_handler(SS_NM, bts_ipa_nm_sig_cb, NULL);
Holger Hans Peter Freythere84dd982013-04-24 10:54:02 +0200369 return 0;
370}
371
372int bts_model_nanobts_init(void)
373{
Harald Weltef383aa12012-07-02 19:51:55 +0200374 bts_model_nanobts.features.data = &bts_model_nanobts._features_data[0];
375 bts_model_nanobts.features.data_len =
376 sizeof(bts_model_nanobts._features_data);
Harald Weltef3d8e922010-06-14 22:44:42 +0200377
Philipp Maier8c498fc2018-02-21 13:24:36 +0100378 osmo_bts_set_feature(&bts_model_nanobts.features, BTS_FEAT_GPRS);
379 osmo_bts_set_feature(&bts_model_nanobts.features, BTS_FEAT_EGPRS);
380 osmo_bts_set_feature(&bts_model_nanobts.features, BTS_FEAT_MULTI_TSC);
Harald Weltef3d8e922010-06-14 22:44:42 +0200381
Harald Weltef383aa12012-07-02 19:51:55 +0200382 return gsm_bts_model_register(&bts_model_nanobts);
Harald Welte39315c42010-01-10 18:01:52 +0100383}
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200384
385#define OML_UP 0x0001
386#define RSL_UP 0x0002
387
388static struct gsm_bts *
389find_bts_by_unitid(struct gsm_network *net, uint16_t site_id, uint16_t bts_id)
390{
391 struct gsm_bts *bts;
392
393 llist_for_each_entry(bts, &net->bts_list, list) {
394 if (!is_ipaccess_bts(bts))
395 continue;
396
397 if (bts->ip_access.site_id == site_id &&
398 bts->ip_access.bts_id == bts_id)
399 return bts;
400 }
401 return NULL;
402}
403
404/* These are exported because they are used by the VTY interface. */
405void ipaccess_drop_rsl(struct gsm_bts_trx *trx)
406{
407 if (!trx->rsl_link)
408 return;
409
Stefan Sperling7b709262018-04-19 14:31:11 +0200410 LOGP(DLINP, LOGL_NOTICE, "(bts=%d,trx=%d) Dropping RSL link.\n", trx->bts->nr, trx->nr);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200411 e1inp_sign_link_destroy(trx->rsl_link);
412 trx->rsl_link = NULL;
Stefan Sperling7b709262018-04-19 14:31:11 +0200413
414 if (trx->bts->c0 == trx)
415 paging_flush_bts(trx->bts, NULL);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200416}
417
418void ipaccess_drop_oml(struct gsm_bts *bts)
419{
Holger Hans Peter Freytherf7e23c52014-12-17 15:44:32 +0100420 struct gsm_bts *rdep_bts;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200421 struct gsm_bts_trx *trx;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200422
423 if (!bts->oml_link)
424 return;
425
Stefan Sperling7b709262018-04-19 14:31:11 +0200426 LOGP(DLINP, LOGL_NOTICE, "(bts=%d) Dropping OML link.\n", bts->nr);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200427 e1inp_sign_link_destroy(bts->oml_link);
428 bts->oml_link = NULL;
Maxd1f70ed2017-09-21 16:15:32 +0200429 bts->uptime = 0;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200430
431 /* we have issues reconnecting RSL, drop everything. */
432 llist_for_each_entry(trx, &bts->trx_list, list)
433 ipaccess_drop_rsl(trx);
434
Neels Hofmeyr91aa68f2018-05-09 17:46:22 +0200435 gsm_bts_mark_all_ts_uninitialized(bts);
436
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200437 bts->ip_access.flags = 0;
Holger Hans Peter Freytherf7e23c52014-12-17 15:44:32 +0100438
439 /*
440 * Go through the list and see if we are the depndency of a BTS
441 * and then drop the BTS. This can lead to some recursion but it
442 * should be fine in userspace.
443 * The oml_link is serving as recursion anchor for us and
444 * it is set to NULL some lines above.
445 */
446 llist_for_each_entry(rdep_bts, &bts->network->bts_list, list) {
447 if (!bts_depend_is_depedency(rdep_bts, bts))
448 continue;
449 LOGP(DLINP, LOGL_NOTICE, "Dropping BTS(%u) due BTS(%u).\n",
450 rdep_bts->nr, bts->nr);
451 ipaccess_drop_oml(rdep_bts);
452 }
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200453}
454
455/* This function is called once the OML/RSL link becomes up. */
456static struct e1inp_sign_link *
457ipaccess_sign_link_up(void *unit_data, struct e1inp_line *line,
458 enum e1inp_sign_type type)
459{
460 struct gsm_bts *bts;
461 struct ipaccess_unit *dev = unit_data;
462 struct e1inp_sign_link *sign_link = NULL;
Maxd1f70ed2017-09-21 16:15:32 +0200463 struct timespec tp;
464 int rc;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200465
Holger Hans Peter Freythere48c1872013-04-24 11:36:15 +0200466 bts = find_bts_by_unitid(bsc_gsmnet, dev->site_id, dev->bts_id);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200467 if (!bts) {
468 LOGP(DLINP, LOGL_ERROR, "Unable to find BTS configuration for "
469 " %u/%u/%u, disconnecting\n", dev->site_id,
470 dev->bts_id, dev->trx_id);
471 return NULL;
472 }
473 DEBUGP(DLINP, "Identified BTS %u/%u/%u\n",
474 dev->site_id, dev->bts_id, dev->trx_id);
475
476 switch(type) {
477 case E1INP_SIGN_OML:
478 /* remove old OML signal link for this BTS. */
479 ipaccess_drop_oml(bts);
480
Holger Hans Peter Freytherc22930e2014-12-17 14:46:17 +0100481 if (!bts_depend_check(bts)) {
482 LOGP(DLINP, LOGL_NOTICE,
483 "Dependency not full-filled for %u/%u/%u\n",
484 dev->site_id, dev->bts_id, dev->trx_id);
485 return NULL;
486 }
487
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200488 /* create new OML link. */
489 sign_link = bts->oml_link =
490 e1inp_sign_link_create(&line->ts[E1INP_SIGN_OML - 1],
491 E1INP_SIGN_OML, bts->c0,
492 bts->oml_tei, 0);
Maxd1f70ed2017-09-21 16:15:32 +0200493 rc = clock_gettime(CLOCK_MONOTONIC, &tp);
494 bts->uptime = (rc < 0) ? 0 : tp.tv_sec; /* we don't need sub-second precision for uptime */
Stefan Sperling44311ea2018-03-26 13:02:33 +0200495 if (!(sign_link->trx->bts->ip_access.flags & OML_UP)) {
496 e1inp_event(sign_link->ts, S_L_INP_TEI_UP,
497 sign_link->tei, sign_link->sapi);
498 sign_link->trx->bts->ip_access.flags |= OML_UP;
499 }
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200500 break;
501 case E1INP_SIGN_RSL: {
502 struct e1inp_ts *ts;
503 struct gsm_bts_trx *trx = gsm_bts_trx_num(bts, dev->trx_id);
504
505 /* no OML link set yet? give up. */
Holger Hans Peter Freyther8bb07202013-06-30 19:02:57 +0200506 if (!bts->oml_link || !trx)
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200507 return NULL;
508
509 /* remove old RSL link for this TRX. */
510 ipaccess_drop_rsl(trx);
511
512 /* set new RSL link for this TRX. */
513 line = bts->oml_link->ts->line;
514 ts = &line->ts[E1INP_SIGN_RSL + dev->trx_id - 1];
515 e1inp_ts_config_sign(ts, line);
516 sign_link = trx->rsl_link =
517 e1inp_sign_link_create(ts, E1INP_SIGN_RSL,
518 trx, trx->rsl_tei, 0);
519 trx->rsl_link->ts->sign.delay = 0;
Stefan Sperling44311ea2018-03-26 13:02:33 +0200520 if (!(sign_link->trx->bts->ip_access.flags &
521 (RSL_UP << sign_link->trx->nr))) {
522 e1inp_event(sign_link->ts, S_L_INP_TEI_UP,
523 sign_link->tei, sign_link->sapi);
524 sign_link->trx->bts->ip_access.flags |=
525 (RSL_UP << sign_link->trx->nr);
526 }
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200527 break;
528 }
529 default:
530 break;
531 }
532 return sign_link;
533}
534
535static void ipaccess_sign_link_down(struct e1inp_line *line)
536{
537 /* No matter what link went down, we close both signal links. */
538 struct e1inp_ts *ts = &line->ts[E1INP_SIGN_OML-1];
Stefan Sperling73acbca2018-02-12 14:28:52 +0100539 struct gsm_bts *bts = NULL;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200540 struct e1inp_sign_link *link;
541
542 llist_for_each_entry(link, &ts->sign.sign_links, list) {
Stefan Sperling73acbca2018-02-12 14:28:52 +0100543 /* Get bts pointer from the first element of the list. */
544 if (bts == NULL)
545 bts = link->trx->bts;
546 /* Cancel RSL connection timeout in case are still waiting for an RSL connection. */
547 if (link->trx->mo.nm_state.administrative == NM_STATE_UNLOCKED)
548 osmo_timer_del(&link->trx->rsl_connect_timeout);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200549 }
Stefan Sperling73acbca2018-02-12 14:28:52 +0100550 if (bts != NULL)
551 ipaccess_drop_oml(bts);
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200552}
553
554/* This function is called if we receive one OML/RSL message. */
555static int ipaccess_sign_link(struct msgb *msg)
556{
557 int ret = 0;
558 struct e1inp_sign_link *link = msg->dst;
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200559
560 switch (link->type) {
561 case E1INP_SIGN_RSL:
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200562 ret = abis_rsl_rcvmsg(msg);
563 break;
564 case E1INP_SIGN_OML:
Pablo Neira Ayusoed5cacb2011-08-17 22:44:07 +0200565 ret = abis_nm_rcvmsg(msg);
566 break;
567 default:
568 LOGP(DLINP, LOGL_ERROR, "Unknown signal link type %d\n",
569 link->type);
570 msgb_free(msg);
571 break;
572 }
573 return ret;
574}
575
576/* not static, ipaccess-config needs it. */
577struct e1inp_line_ops ipaccess_e1inp_line_ops = {
578 .cfg = {
579 .ipa = {
580 .addr = "0.0.0.0",
581 .role = E1INP_LINE_R_BSC,
582 },
583 },
584 .sign_link_up = ipaccess_sign_link_up,
585 .sign_link_down = ipaccess_sign_link_down,
586 .sign_link = ipaccess_sign_link,
587};
588
589static void bts_model_nanobts_e1line_bind_ops(struct e1inp_line *line)
590{
591 e1inp_line_bind_ops(line, &ipaccess_e1inp_line_ops);
592}