blob: 43bd36e375c56a42c60e12d0ec6a093a2b2c7495 [file] [log] [blame]
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +04001/* pcu_l1_if.cpp
2 *
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +04003 * Copyright (C) 2012 Andreas Eversberg <jolly@eversberg.eu>
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +04004 *
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU General Public License
7 * as published by the Free Software Foundation; either version 2
8 * of the License, or (at your option) any later version.
9 *
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
14 *
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18 */
19
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040020#include <stdio.h>
21#include <unistd.h>
22#include <stdlib.h>
Andreas Eversberg0aed6542012-06-23 10:33:16 +020023#include <string.h>
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040024#include <errno.h>
25#include <assert.h>
Andreas Eversberg0aed6542012-06-23 10:33:16 +020026#include <sys/socket.h>
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040027#include <sys/un.h>
Andreas Eversberg81a12be2013-03-16 16:16:41 +010028#include <arpa/inet.h>
Andreas Eversberg0aed6542012-06-23 10:33:16 +020029extern "C" {
30#include <osmocom/core/talloc.h>
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040031#include <osmocom/core/select.h>
32#include <osmocom/core/msgb.h>
Andreas Eversberg0aed6542012-06-23 10:33:16 +020033}
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +040034
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +040035#include <gprs_rlcmac.h>
36#include <pcu_l1_if.h>
37#include <gprs_debug.h>
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040038#include <gprs_bssgp_pcu.h>
39#include <pcuif_proto.h>
Andreas Eversberg0aed6542012-06-23 10:33:16 +020040
Andreas Eversberga23c7ee2012-12-18 10:47:28 +010041// FIXME: move this, when changed from c++ to c.
42extern "C" {
43void *l1if_open_pdch(void *priv, uint32_t hlayer1);
Andreas Eversberga23c7ee2012-12-18 10:47:28 +010044int l1if_connect_pdch(void *obj, uint8_t ts);
45int l1if_pdch_req(void *obj, uint8_t ts, int is_ptcch, uint32_t fn,
46 uint16_t arfcn, uint8_t block_nr, uint8_t *data, uint8_t len);
47}
48
Andreas Eversberge266bd42012-07-13 14:00:21 +020049extern void *tall_pcu_ctx;
50
Ivan Kluchnikov4277f0c2012-04-12 14:24:35 +040051// Variable for storage current FN.
52int frame_number;
53
54int get_current_fn()
55{
56 return frame_number;
57}
58
59void set_current_fn(int fn)
60{
61 frame_number = fn;
62}
Ivan Kluchnikove3a05962012-03-18 15:48:51 +040063
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040064/*
65 * PCU messages
66 */
Ivan Kluchnikove3a05962012-03-18 15:48:51 +040067
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040068struct msgb *pcu_msgb_alloc(uint8_t msg_type, uint8_t bts_nr)
69{
70 struct msgb *msg;
71 struct gsm_pcu_if *pcu_prim;
72
73 msg = msgb_alloc(sizeof(struct gsm_pcu_if), "pcu_sock_tx");
74 if (!msg)
75 return NULL;
76 msgb_put(msg, sizeof(struct gsm_pcu_if));
77 pcu_prim = (struct gsm_pcu_if *) msg->data;
78 pcu_prim->msg_type = msg_type;
79 pcu_prim->bts_nr = bts_nr;
Ivan Kluchnikove3a05962012-03-18 15:48:51 +040080
81 return msg;
82}
83
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040084static int pcu_tx_act_req(uint8_t trx, uint8_t ts, uint8_t activate)
Ivan Kluchnikov4277f0c2012-04-12 14:24:35 +040085{
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +040086 struct msgb *msg;
87 struct gsm_pcu_if *pcu_prim;
88 struct gsm_pcu_if_act_req *act_req;
89
90 LOGP(DL1IF, LOGL_INFO, "Sending %s request: trx=%d ts=%d\n",
91 (activate) ? "activate" : "deactivate", trx, ts);
92
93 msg = pcu_msgb_alloc(PCU_IF_MSG_ACT_REQ, 0);
94 if (!msg)
95 return -ENOMEM;
96 pcu_prim = (struct gsm_pcu_if *) msg->data;
97 act_req = &pcu_prim->u.act_req;
98 act_req->activate = activate;
99 act_req->trx_nr = trx;
100 act_req->ts_nr = ts;
101
102 return pcu_sock_send(msg);
103}
104
105static int pcu_tx_data_req(uint8_t trx, uint8_t ts, uint8_t sapi,
106 uint16_t arfcn, uint32_t fn, uint8_t block_nr, uint8_t *data,
107 uint8_t len)
108{
109 struct msgb *msg;
110 struct gsm_pcu_if *pcu_prim;
111 struct gsm_pcu_if_data *data_req;
112
113 LOGP(DL1IF, LOGL_DEBUG, "Sending data request: trx=%d ts=%d sapi=%d "
114 "arfcn=%d fn=%d block=%d data=%s\n", trx, ts, sapi, arfcn, fn,
115 block_nr, osmo_hexdump(data, len));
116
117 msg = pcu_msgb_alloc(PCU_IF_MSG_DATA_REQ, 0);
118 if (!msg)
119 return -ENOMEM;
120 pcu_prim = (struct gsm_pcu_if *) msg->data;
121 data_req = &pcu_prim->u.data_req;
122
123 data_req->sapi = sapi;
124 data_req->fn = fn;
125 data_req->arfcn = arfcn;
126 data_req->trx_nr = trx;
127 data_req->ts_nr = ts;
128 data_req->block_nr = block_nr;
129 memcpy(data_req->data, data, len);
130 data_req->len = len;
131
132 return pcu_sock_send(msg);
133}
134
135void pcu_l1if_tx_pdtch(msgb *msg, uint8_t trx, uint8_t ts, uint16_t arfcn,
136 uint32_t fn, uint8_t block_nr)
137{
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100138#ifdef ENABLE_SYSMODSP
139 struct gprs_rlcmac_bts *bts = gprs_rlcmac_bts;
140
141 if (bts->trx[trx].fl1h)
142 l1if_pdch_req(bts->trx[trx].fl1h, ts, 0, fn, arfcn, block_nr,
143 msg->data, msg->len);
144 else
145#endif
146 pcu_tx_data_req(trx, ts, PCU_IF_SAPI_PDTCH, arfcn, fn, block_nr,
147 msg->data, msg->len);
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200148 msgb_free(msg);
Ivan Kluchnikov4277f0c2012-04-12 14:24:35 +0400149}
150
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400151void pcu_l1if_tx_ptcch(msgb *msg, uint8_t trx, uint8_t ts, uint16_t arfcn,
152 uint32_t fn, uint8_t block_nr)
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400153{
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100154#ifdef ENABLE_SYSMODSP
155 struct gprs_rlcmac_bts *bts = gprs_rlcmac_bts;
156
157 if (bts->trx[trx].fl1h)
158 l1if_pdch_req(bts->trx[trx].fl1h, ts, 1, fn, arfcn, block_nr,
159 msg->data, msg->len);
160 else
161#endif
162 pcu_tx_data_req(trx, ts, PCU_IF_SAPI_PTCCH, arfcn, fn, block_nr,
163 msg->data, msg->len);
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400164 msgb_free(msg);
165}
166
Andreas Eversberg7b045012012-07-05 07:38:49 +0200167void pcu_l1if_tx_agch(bitvec * block, int plen)
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400168{
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400169 uint8_t data[23]; /* prefix PLEN */
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400170
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400171 /* FIXME: why does OpenBTS has no PLEN and no fill in message? */
172 bitvec_pack(block, data + 1);
173 data[0] = (plen << 2) | 0x01;
174 pcu_tx_data_req(0, 0, PCU_IF_SAPI_AGCH, 0, 0, 0, data, 23);
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400175}
176
Andreas Eversberge13fa2d2012-07-09 17:10:44 +0200177void pcu_l1if_tx_pch(bitvec * block, int plen, char *imsi)
Ivan Kluchnikovc7e7f682012-06-29 22:53:15 +0400178{
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400179 uint8_t data[23+3]; /* prefix PLEN */
180
181 /* paging group */
182 if (!imsi || strlen(imsi) < 3)
183 return;
184 imsi += strlen(imsi) - 3;
185 data[0] = imsi[0];
186 data[1] = imsi[1];
187 data[2] = imsi[2];
188
189 bitvec_pack(block, data + 3+1);
190 data[3] = (plen << 2) | 0x01;
191 pcu_tx_data_req(0, 0, PCU_IF_SAPI_PCH, 0, 0, 0, data, 23+3);
Ivan Kluchnikovc7e7f682012-06-29 22:53:15 +0400192}
193
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100194extern "C" int pcu_rx_data_ind_pdtch(uint8_t trx, uint8_t ts, uint8_t *data,
Andreas Eversberg570b44b2013-03-16 16:15:01 +0100195 uint8_t len, uint32_t fn, int8_t rssi)
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100196{
Andreas Eversberg570b44b2013-03-16 16:15:01 +0100197 return gprs_rlcmac_rcv_block(trx, ts, data, len, fn, rssi);
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100198}
199
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400200static int pcu_rx_data_ind(struct gsm_pcu_if_data *data_ind)
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400201{
202 int rc = 0;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400203
204 LOGP(DL1IF, LOGL_DEBUG, "Data indication received: sapi=%d arfcn=%d "
205 "block=%d data=%s\n", data_ind->sapi,
206 data_ind->arfcn, data_ind->block_nr,
207 osmo_hexdump(data_ind->data, data_ind->len));
208
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400209 switch (data_ind->sapi) {
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400210 case PCU_IF_SAPI_PDTCH:
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100211 rc = pcu_rx_data_ind_pdtch(data_ind->trx_nr, data_ind->ts_nr,
Andreas Eversberg570b44b2013-03-16 16:15:01 +0100212 data_ind->data, data_ind->len, data_ind->fn,
213 data_ind->rssi);
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400214 break;
215 default:
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400216 LOGP(DL1IF, LOGL_ERROR, "Received PCU data indication with "
217 "unsupported sapi %d\n", data_ind->sapi);
218 rc = -EINVAL;
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400219 }
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400220
221 return rc;
222}
223
Andreas Eversberga9be1542012-09-27 09:23:24 +0200224static int pcu_rx_data_cnf(struct gsm_pcu_if_data *data_cnf)
225{
226 int rc = 0;
227
228 LOGP(DL1IF, LOGL_DEBUG, "Data confirm received: sapi=%d fn=%d\n",
229 data_cnf->sapi, data_cnf->fn);
230
231 switch (data_cnf->sapi) {
232 case PCU_IF_SAPI_PCH:
Andreas Eversberg8c3680d2012-10-08 12:30:56 +0200233 if (data_cnf->data[2] == 0x3f)
234 rc = gprs_rlcmac_imm_ass_cnf(data_cnf->data,
235 data_cnf->fn);
Andreas Eversberga9be1542012-09-27 09:23:24 +0200236 break;
237 default:
238 LOGP(DL1IF, LOGL_ERROR, "Received PCU data confirm with "
239 "unsupported sapi %d\n", data_cnf->sapi);
240 rc = -EINVAL;
241 }
242
243 return rc;
244}
245
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100246// FIXME: remove this, when changed from c++ to c.
247extern "C" int pcu_rx_rts_req_pdtch(uint8_t trx, uint8_t ts, uint16_t arfcn,
248 uint32_t fn, uint8_t block_nr)
249{
250 return gprs_rlcmac_rcv_rts_block(trx, ts, arfcn, fn, block_nr);
251}
252
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400253static int pcu_rx_rts_req(struct gsm_pcu_if_rts_req *rts_req)
Ivan Kluchnikov5310d452012-04-17 22:00:31 +0400254{
255 int rc = 0;
Ivan Kluchnikov5310d452012-04-17 22:00:31 +0400256
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400257 LOGP(DL1IF, LOGL_DEBUG, "RTS request received: trx=%d ts=%d sapi=%d "
258 "arfcn=%d fn=%d block=%d\n", rts_req->trx_nr, rts_req->ts_nr,
259 rts_req->sapi, rts_req->arfcn, rts_req->fn, rts_req->block_nr);
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400260
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400261 switch (rts_req->sapi) {
262 case PCU_IF_SAPI_PDTCH:
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100263 pcu_rx_rts_req_pdtch(rts_req->trx_nr, rts_req->ts_nr,
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400264 rts_req->arfcn, rts_req->fn, rts_req->block_nr);
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400265 break;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400266 case PCU_IF_SAPI_PTCCH:
267 /* FIXME */
268 {
269 struct msgb *msg = msgb_alloc(23, "l1_prim");
270 memset(msgb_put(msg, 23), 0x2b, 23);
271 pcu_l1if_tx_ptcch(msg, rts_req->trx_nr, rts_req->ts_nr,
272 rts_req->arfcn, rts_req->fn, rts_req->block_nr);
273 }
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400274 break;
275 default:
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400276 LOGP(DL1IF, LOGL_ERROR, "Received PCU RTS request with "
277 "unsupported sapi %d\n", rts_req->sapi);
278 rc = -EINVAL;
279 }
280
281 return rc;
282}
283
284static int pcu_rx_rach_ind(struct gsm_pcu_if_rach_ind *rach_ind)
285{
286 int rc = 0;
287
288 LOGP(DL1IF, LOGL_INFO, "RACH request received: sapi=%d "
289 "qta=%d, ra=%d, fn=%d\n", rach_ind->sapi, rach_ind->qta,
290 rach_ind->ra, rach_ind->fn);
291
292 switch (rach_ind->sapi) {
293 case PCU_IF_SAPI_RACH:
294 rc = gprs_rlcmac_rcv_rach(rach_ind->ra, rach_ind->fn,
295 rach_ind->qta);
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400296 break;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400297 default:
298 LOGP(DL1IF, LOGL_ERROR, "Received PCU rach request with "
299 "unsupported sapi %d\n", rach_ind->sapi);
300 rc = -EINVAL;
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400301 }
302
Ivan Kluchnikove3a05962012-03-18 15:48:51 +0400303 return rc;
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400304}
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200305
Andreas Eversberg07e97cf2012-08-07 16:00:56 +0200306int flush_pdch(struct gprs_rlcmac_pdch *pdch, uint8_t trx, uint8_t ts)
Andreas Eversberg2b914642012-07-19 13:06:26 +0200307{
308 uint8_t tfi;
309 struct gprs_rlcmac_tbf *tbf;
310 struct gprs_rlcmac_paging *pag;
Andreas Eversberg07e97cf2012-08-07 16:00:56 +0200311 struct gprs_rlcmac_sba *sba, *sba2;
Andreas Eversberg2b914642012-07-19 13:06:26 +0200312
313 /* kick all TBF on slot */
314 for (tfi = 0; tfi < 32; tfi++) {
315 tbf = pdch->ul_tbf[tfi];
316 if (tbf)
317 tbf_free(tbf);
318 tbf = pdch->dl_tbf[tfi];
319 if (tbf)
320 tbf_free(tbf);
321 }
322 /* flush all pending paging messages */
323 while ((pag = gprs_rlcmac_dequeue_paging(pdch)))
324 talloc_free(pag);
325
Andreas Eversberg07e97cf2012-08-07 16:00:56 +0200326 llist_for_each_entry_safe(sba, sba2, &gprs_rlcmac_sbas, list) {
327 if (sba->trx == trx && sba->ts == ts) {
328 llist_del(&sba->list);
329 talloc_free(sba);
330 }
331 }
332
Andreas Eversberg2b914642012-07-19 13:06:26 +0200333 return 0;
334}
335
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400336static int pcu_rx_info_ind(struct gsm_pcu_if_info_ind *info_ind)
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200337{
Andreas Eversberg5dac2f02012-06-27 15:52:04 +0200338 struct gprs_rlcmac_bts *bts = gprs_rlcmac_bts;
Holger Hans Peter Freythere8d9a5f2013-07-28 19:11:20 +0200339 struct gprs_bssgp_pcu *pcu;
Andreas Eversberg2b914642012-07-19 13:06:26 +0200340 struct gprs_rlcmac_pdch *pdch;
Andreas Eversberg81a12be2013-03-16 16:16:41 +0100341 struct in_addr ia;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400342 int rc = 0;
Andreas Eversberg2b914642012-07-19 13:06:26 +0200343 int trx, ts;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400344 int i;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200345
Andreas Eversberg8389fd02012-07-18 10:06:48 +0200346 if (info_ind->version != PCU_IF_VERSION) {
347 fprintf(stderr, "PCU interface version number of BTS (%d) is "
348 "different (%d).\nPlease re-compile!\n",
349 info_ind->version, PCU_IF_VERSION);
350 exit(-1);
351 }
352
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400353 LOGP(DL1IF, LOGL_DEBUG, "Info indication received:\n");
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200354
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400355 if (!(info_ind->flags & PCU_IF_FLAG_ACTIVE)) {
356 LOGP(DL1IF, LOGL_NOTICE, "BTS not available\n");
357bssgp_failed:
358 /* free all TBF */
359 for (trx = 0; trx < 8; trx++) {
360 bts->trx[trx].arfcn = info_ind->trx[trx].arfcn;
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200361 for (ts = 0; ts < 8; ts++) {
362 if (bts->trx[trx].pdch[ts].enable)
Andreas Eversberg07e97cf2012-08-07 16:00:56 +0200363 flush_pdch(&bts->trx[trx].pdch[ts],
364 trx, ts);
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200365 }
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400366 }
Holger Hans Peter Freythera30f4762013-07-11 16:13:38 +0200367 gprs_bssgp_destroy_or_exit();
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400368 return 0;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200369 }
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400370 LOGP(DL1IF, LOGL_INFO, "BTS available\n");
Andreas Eversberg514491d2012-09-23 06:42:07 +0200371 LOGP(DL1IF, LOGL_DEBUG, " mcc=%x\n", info_ind->mcc);
372 LOGP(DL1IF, LOGL_DEBUG, " mnc=%x\n", info_ind->mnc);
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400373 LOGP(DL1IF, LOGL_DEBUG, " lac=%d\n", info_ind->lac);
374 LOGP(DL1IF, LOGL_DEBUG, " rac=%d\n", info_ind->rac);
Andreas Eversberg514491d2012-09-23 06:42:07 +0200375 LOGP(DL1IF, LOGL_DEBUG, " cell_id=%d\n", ntohs(info_ind->cell_id));
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100376 LOGP(DL1IF, LOGL_DEBUG, " bsic=%d\n", info_ind->bsic);
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400377 LOGP(DL1IF, LOGL_DEBUG, " nsei=%d\n", info_ind->nsei);
378 LOGP(DL1IF, LOGL_DEBUG, " nse_timer=%d %d %d %d %d %d %d\n",
379 info_ind->nse_timer[0], info_ind->nse_timer[1],
380 info_ind->nse_timer[2], info_ind->nse_timer[3],
381 info_ind->nse_timer[4], info_ind->nse_timer[5],
382 info_ind->nse_timer[6]);
383 LOGP(DL1IF, LOGL_DEBUG, " cell_timer=%d %d %d %d %d %d %d %d %d %d "
384 "%d\n",
385 info_ind->cell_timer[0], info_ind->cell_timer[1],
386 info_ind->cell_timer[2], info_ind->cell_timer[3],
387 info_ind->cell_timer[4], info_ind->cell_timer[5],
388 info_ind->cell_timer[6], info_ind->cell_timer[7],
389 info_ind->cell_timer[8], info_ind->cell_timer[9],
390 info_ind->cell_timer[10]);
391 LOGP(DL1IF, LOGL_DEBUG, " repeat_time=%d\n", info_ind->repeat_time);
392 LOGP(DL1IF, LOGL_DEBUG, " repeat_count=%d\n", info_ind->repeat_count);
393 LOGP(DL1IF, LOGL_DEBUG, " bvci=%d\n", info_ind->bvci);
394 LOGP(DL1IF, LOGL_DEBUG, " t3142=%d\n", info_ind->t3142);
395 LOGP(DL1IF, LOGL_DEBUG, " t3169=%d\n", info_ind->t3169);
396 LOGP(DL1IF, LOGL_DEBUG, " t3191=%d\n", info_ind->t3191);
397 LOGP(DL1IF, LOGL_DEBUG, " t3193=%d (ms)\n", info_ind->t3193_10ms * 10);
398 LOGP(DL1IF, LOGL_DEBUG, " t3195=%d\n", info_ind->t3195);
399 LOGP(DL1IF, LOGL_DEBUG, " n3101=%d\n", info_ind->n3101);
400 LOGP(DL1IF, LOGL_DEBUG, " n3103=%d\n", info_ind->n3103);
401 LOGP(DL1IF, LOGL_DEBUG, " n3105=%d\n", info_ind->n3105);
402 LOGP(DL1IF, LOGL_DEBUG, " cv_countdown=%d\n", info_ind->cv_countdown);
403 LOGP(DL1IF, LOGL_DEBUG, " dl_tbf_ext=%d\n", info_ind->dl_tbf_ext);
404 LOGP(DL1IF, LOGL_DEBUG, " ul_tbf_ext=%d\n", info_ind->ul_tbf_ext);
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100405 bts->bsic = info_ind->bsic;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400406 for (i = 0; i < 4; i++) {
407 if ((info_ind->flags & (PCU_IF_FLAG_CS1 << i)))
408 LOGP(DL1IF, LOGL_DEBUG, " Use CS%d\n", i+1);
409 }
410 for (i = 0; i < 9; i++) {
411 if ((info_ind->flags & (PCU_IF_FLAG_MCS1 << i)))
412 LOGP(DL1IF, LOGL_DEBUG, " Use MCS%d\n", i+1);
413 }
414 LOGP(DL1IF, LOGL_DEBUG, " initial_cs=%d\n", info_ind->initial_cs);
415 LOGP(DL1IF, LOGL_DEBUG, " initial_mcs=%d\n", info_ind->initial_mcs);
416 LOGP(DL1IF, LOGL_DEBUG, " nsvci=%d\n", info_ind->nsvci[0]);
417 LOGP(DL1IF, LOGL_DEBUG, " local_port=%d\n", info_ind->local_port[0]);
418 LOGP(DL1IF, LOGL_DEBUG, " remote_port=%d\n", info_ind->remote_port[0]);
Andreas Eversberg81a12be2013-03-16 16:16:41 +0100419 ia.s_addr = htonl(info_ind->remote_ip[0]);
420 LOGP(DL1IF, LOGL_DEBUG, " remote_ip=%s\n", inet_ntoa(ia));
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200421
Holger Hans Peter Freythere8d9a5f2013-07-28 19:11:20 +0200422 pcu = gprs_bssgp_create_and_connect(bts, info_ind->local_port[0],
Harald Welte30a73d82013-03-10 08:54:30 +0000423 info_ind->remote_ip[0], info_ind->remote_port[0],
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400424 info_ind->nsei, info_ind->nsvci[0], info_ind->bvci,
425 info_ind->mcc, info_ind->mnc, info_ind->lac, info_ind->rac,
426 info_ind->cell_id);
Holger Hans Peter Freythere8d9a5f2013-07-28 19:11:20 +0200427 if (!pcu) {
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400428 LOGP(DL1IF, LOGL_NOTICE, "SGSN not available\n");
429 goto bssgp_failed;
430 }
431
432 bts->cs1 = !!(info_ind->flags & PCU_IF_FLAG_CS1);
433 bts->cs2 = !!(info_ind->flags & PCU_IF_FLAG_CS2);
434 bts->cs3 = !!(info_ind->flags & PCU_IF_FLAG_CS3);
435 bts->cs4 = !!(info_ind->flags & PCU_IF_FLAG_CS4);
436 if (!bts->cs1 && !bts->cs2 && !bts->cs3 && !bts->cs4)
437 bts->cs1 = 1;
438 if (info_ind->t3142) { /* if timer values are set */
439 bts->t3142 = info_ind->t3142;
440 bts->t3169 = info_ind->t3169;
441 bts->t3191 = info_ind->t3191;
442 bts->t3193_msec = info_ind->t3193_10ms * 10;
443 bts->t3195 = info_ind->t3195;
444 bts->n3101 = info_ind->n3101;
445 bts->n3103 = info_ind->n3103;
446 bts->n3105 = info_ind->n3105;
447 }
Andreas Eversberg8b761a32012-07-20 21:50:31 +0200448 if (!bts->force_cs) {
449 if (info_ind->initial_cs < 1 || info_ind->initial_cs > 4)
Andreas Eversberg499ff412012-10-03 14:21:36 +0200450 bts->initial_cs_dl = 1;
Andreas Eversberg8b761a32012-07-20 21:50:31 +0200451 else
Andreas Eversberg499ff412012-10-03 14:21:36 +0200452 bts->initial_cs_dl = info_ind->initial_cs;
453 bts->initial_cs_ul = bts->initial_cs_dl;
Andreas Eversberg8b761a32012-07-20 21:50:31 +0200454 }
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400455
456 for (trx = 0; trx < 8; trx++) {
457 bts->trx[trx].arfcn = info_ind->trx[trx].arfcn;
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100458 if ((info_ind->flags & PCU_IF_FLAG_SYSMO)
459 && info_ind->trx[trx].hlayer1) {
460#ifdef ENABLE_SYSMODSP
461 LOGP(DL1IF, LOGL_DEBUG, " TRX %d hlayer1=%x\n", trx,
462 info_ind->trx[trx].hlayer1);
463 if (!bts->trx[trx].fl1h)
464 bts->trx[trx].fl1h = l1if_open_pdch(
465 (void *)trx,
466 info_ind->trx[trx].hlayer1);
467 if (!bts->trx[trx].fl1h) {
468 LOGP(DL1IF, LOGL_FATAL, "Failed to open direct "
469 "DSP access for PDCH.\n");
470 exit(0);
471 }
472#else
473 LOGP(DL1IF, LOGL_FATAL, "Compiled without direct DSP "
474 "access for PDCH, but enabled at "
475 "BTS. Please deactivate it!\n");
476 exit(0);
477#endif
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100478 }
479
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400480 for (ts = 0; ts < 8; ts++) {
Andreas Eversberg2b914642012-07-19 13:06:26 +0200481 pdch = &bts->trx[trx].pdch[ts];
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400482 if ((info_ind->trx[trx].pdch_mask & (1 << ts))) {
483 /* FIXME: activate dynamically at RLCMAC */
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200484 if (!pdch->enable) {
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100485#ifdef ENABLE_SYSMODSP
486 if ((info_ind->flags &
487 PCU_IF_FLAG_SYSMO))
488 l1if_connect_pdch(
489 bts->trx[trx].fl1h, ts);
490#endif
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400491 pcu_tx_act_req(trx, ts, 1);
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200492 INIT_LLIST_HEAD(&pdch->paging_list);
493 pdch->enable = 1;
494 }
Andreas Eversberg2b914642012-07-19 13:06:26 +0200495 pdch->tsc = info_ind->trx[trx].tsc[ts];
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400496 LOGP(DL1IF, LOGL_INFO, "PDCH: trx=%d ts=%d\n",
497 trx, ts);
498 } else {
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200499 if (pdch->enable) {
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400500 pcu_tx_act_req(trx, ts, 0);
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200501 pdch->enable = 0;
Andreas Eversberg07e97cf2012-08-07 16:00:56 +0200502 flush_pdch(pdch, trx, ts);
Andreas Eversberg3b7461c2012-07-20 11:19:59 +0200503 }
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400504 }
505 }
506 }
507
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200508 return rc;
509}
510
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400511static int pcu_rx_time_ind(struct gsm_pcu_if_time_ind *time_ind)
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200512{
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400513 struct gprs_rlcmac_tbf *tbf;
Andreas Eversberga004e6a2013-05-13 16:45:21 +0200514 struct gprs_rlcmac_sba *sba, *sba2;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400515 uint32_t elapsed;
516 uint8_t fn13 = time_ind->fn % 13;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200517
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400518 /* omit frame numbers not starting at a MAC block */
519 if (fn13 != 0 && fn13 != 4 && fn13 != 8)
520 return 0;
Andreas Eversberga23c7ee2012-12-18 10:47:28 +0100521#warning uncomment
522// LOGP(DL1IF, LOGL_DEBUG, "Time indication received: %d\n",
523// time_ind->fn % 52);
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400524
525 set_current_fn(time_ind->fn);
526
527 /* check for poll timeout */
Andreas Eversbergb0c7ea72012-07-13 14:46:03 +0200528 llist_for_each_entry(tbf, &gprs_rlcmac_ul_tbfs, list) {
529 if (tbf->poll_state == GPRS_RLCMAC_POLL_SCHED) {
Andreas Eversberga004e6a2013-05-13 16:45:21 +0200530 elapsed = (frame_number + 2715648 - tbf->poll_fn)
531 % 2715648;
532 if (elapsed >= 20 && elapsed < 2715400)
Andreas Eversbergb0c7ea72012-07-13 14:46:03 +0200533 gprs_rlcmac_poll_timeout(tbf);
534 }
535 }
536 llist_for_each_entry(tbf, &gprs_rlcmac_dl_tbfs, list) {
537 if (tbf->poll_state == GPRS_RLCMAC_POLL_SCHED) {
Andreas Eversberga004e6a2013-05-13 16:45:21 +0200538 elapsed = (frame_number + 2715648 - tbf->poll_fn)
539 % 2715648;
540 if (elapsed >= 20 && elapsed < 2715400)
Andreas Eversbergb0c7ea72012-07-13 14:46:03 +0200541 gprs_rlcmac_poll_timeout(tbf);
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400542 }
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200543 }
Andreas Eversberga004e6a2013-05-13 16:45:21 +0200544 llist_for_each_entry_safe(sba, sba2, &gprs_rlcmac_sbas, list) {
545 elapsed = (frame_number + 2715648 - sba->fn) % 2715648;
546 if (elapsed >= 20 && elapsed < 2715400) {
547 /* sba will be freed here */
548 gprs_rlcmac_sba_timeout(sba);
549 }
550 }
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200551
552 return 0;
553}
554
Andreas Eversberg2b914642012-07-19 13:06:26 +0200555static int pcu_rx_pag_req(struct gsm_pcu_if_pag_req *pag_req)
556{
557 LOGP(DL1IF, LOGL_DEBUG, "Paging request received: chan_needed=%d "
558 "length=%d\n", pag_req->chan_needed, pag_req->identity_lv[0]);
559
560 return gprs_rlcmac_add_paging(pag_req->chan_needed,
561 pag_req->identity_lv);
562}
563
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400564int pcu_rx(uint8_t msg_type, struct gsm_pcu_if *pcu_prim)
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200565{
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400566 int rc = 0;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200567
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400568 switch (msg_type) {
569 case PCU_IF_MSG_DATA_IND:
570 rc = pcu_rx_data_ind(&pcu_prim->u.data_ind);
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400571 break;
Andreas Eversberga9be1542012-09-27 09:23:24 +0200572 case PCU_IF_MSG_DATA_CNF:
573 rc = pcu_rx_data_cnf(&pcu_prim->u.data_cnf);
574 break;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400575 case PCU_IF_MSG_RTS_REQ:
576 rc = pcu_rx_rts_req(&pcu_prim->u.rts_req);
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400577 break;
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400578 case PCU_IF_MSG_RACH_IND:
579 rc = pcu_rx_rach_ind(&pcu_prim->u.rach_ind);
580 break;
581 case PCU_IF_MSG_INFO_IND:
582 rc = pcu_rx_info_ind(&pcu_prim->u.info_ind);
583 break;
584 case PCU_IF_MSG_TIME_IND:
585 rc = pcu_rx_time_ind(&pcu_prim->u.time_ind);
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400586 break;
Andreas Eversberg2b914642012-07-19 13:06:26 +0200587 case PCU_IF_MSG_PAG_REQ:
588 rc = pcu_rx_pag_req(&pcu_prim->u.pag_req);
589 break;
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400590 default:
Ivan Kluchnikovef7f28c2012-07-12 14:49:15 +0400591 LOGP(DL1IF, LOGL_ERROR, "Received unknwon PCU msg type %d\n",
592 msg_type);
593 rc = -EINVAL;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200594 }
595
Ivan Kluchnikov8ee60512012-03-05 19:24:57 +0400596 return rc;
Andreas Eversberg0aed6542012-06-23 10:33:16 +0200597}