blob: 5d1a50087783ef2e254159bc774a2f3691761621 [file] [log] [blame]
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +02001/*
2 * Copyright (C) 2013 by Holger Hans Peter Freyther
3 *
4 * All Rights Reserved
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU Affero General Public License as published by
8 * the Free Software Foundation; either version 3 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU Affero General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 *
19 */
20
21#include <bts.h>
Holger Hans Peter Freytherb78adcd2013-10-17 20:12:37 +020022#include <poll_controller.h>
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +020023#include <tbf.h>
Holger Hans Peter Freyther63f29d62013-10-19 19:04:03 +020024#include <encoding.h>
Holger Hans Peter Freytherd11290b2013-10-26 17:32:04 +020025#include <decoding.h>
26#include <rlc.h>
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +020027#include <pcu_l1_if.h>
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +020028
29#include <gprs_rlcmac.h>
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +020030#include <gprs_debug.h>
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +020031
32extern "C" {
33 #include <osmocom/core/talloc.h>
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +020034 #include <osmocom/core/msgb.h>
Holger Hans Peter Freyther8df447d2015-11-07 21:04:40 +010035 #include <osmocom/core/stats.h>
Max9bbe1602016-07-18 12:50:18 +020036 #include <osmocom/gsm/protocol/gsm_04_08.h>
Philipp Maier1275a3f2017-02-21 19:35:23 +010037 #include <osmocom/gsm/gsm_utils.h>
Harald Welte717cdf52017-07-21 21:56:23 +020038 #include <osmocom/core/gsmtap_util.h>
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +020039}
Holger Hans Peter Freytherb78adcd2013-10-17 20:12:37 +020040
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +020041#include <arpa/inet.h>
42
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +020043#include <errno.h>
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +020044#include <string.h>
45
Philipp Maier1275a3f2017-02-21 19:35:23 +010046#define RFN_MODULUS 42432
47#define RFN_THRESHOLD RFN_MODULUS / 2
48
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +020049extern void *tall_pcu_ctx;
50
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +020051static BTS s_bts;
52
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +010053/**
54 * For gcc-4.4 compat do not use extended initializer list but keep the
55 * order from the enum here. Once we support GCC4.7 and up we can change
56 * the code below.
57 */
58static const struct rate_ctr_desc bts_ctr_description[] = {
59 { "tbf.dl.alloc", "TBF DL Allocated "},
60 { "tbf.dl.freed", "TBF DL Freed "},
Jacob Erlbeck0316dc62016-01-21 20:12:04 +010061 { "tbf.dl.aborted", "TBF DL Aborted "},
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +010062 { "tbf.ul.alloc", "TBF UL Allocated "},
63 { "tbf.ul.freed", "TBF UL Freed "},
Jacob Erlbeck0316dc62016-01-21 20:12:04 +010064 { "tbf.ul.aborted", "TBF UL Aborted "},
Holger Hans Peter Freytheraa35ba72013-11-13 15:02:50 +010065 { "tbf.reused", "TBF Reused "},
Jacob Erlbeck5979fe92015-07-14 14:02:41 +020066 { "tbf.alloc.algo-a", "TBF Alloc Algo A "},
67 { "tbf.alloc.algo-b", "TBF Alloc Algo B "},
Jacob Erlbeck9b3d7e02016-01-19 10:44:42 +010068 { "tbf.failed.egprs-only", "TBF Failed EGPRS-only"},
Holger Hans Peter Freythere9429b52013-11-13 19:36:57 +010069 { "rlc.sent", "RLC Sent "},
70 { "rlc.resent", "RLC Resent "},
Holger Hans Peter Freytheref93bdb2013-11-24 00:01:50 +010071 { "rlc.restarted", "RLC Restarted "},
Holger Hans Peter Freytherc70aae42013-11-19 17:09:37 +010072 { "rlc.stalled", "RLC Stalled "},
Holger Hans Peter Freyther092478f2013-11-23 01:01:19 +010073 { "rlc.nacked", "RLC Nacked "},
sivasankari168911b2016-11-25 19:53:36 +053074 { "rlc.final_block_resent", "RLC Final Blk resent "},
Jacob Erlbeckc91c18e2015-07-07 09:33:29 +020075 { "rlc.ass.timedout", "RLC Assign Timeout "},
Jacob Erlbeck7c8d39a2015-09-07 14:04:56 +020076 { "rlc.ass.failed", "RLC Assign Failed "},
Jacob Erlbeckc91c18e2015-07-07 09:33:29 +020077 { "rlc.ack.timedout", "RLC Ack Timeout "},
Jacob Erlbeck7c8d39a2015-09-07 14:04:56 +020078 { "rlc.ack.failed", "RLC Ack Failed "},
Jacob Erlbeckc91c18e2015-07-07 09:33:29 +020079 { "rlc.rel.timedout", "RLC Release Timeout "},
Jacob Erlbeckbe4a08b2015-08-25 15:19:31 +020080 { "rlc.late-block", "RLC Late Block "},
Alexander Couzensc8fd4b72016-05-24 11:09:20 +020081 { "rlc.sent-dummy", "RLC Sent Dummy "},
82 { "rlc.sent-control", "RLC Sent Control "},
Alexander Couzens7fdbf892016-05-21 19:45:23 +020083 { "rlc.dl_bytes", "RLC DL Bytes "},
84 { "rlc.dl_payload_bytes", "RLC DL Payload Bytes "},
85 { "rlc.ul_bytes", "RLC UL Bytes "},
86 { "rlc.ul_payload_bytes", "RLC UL Payload Bytes "},
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +010087 { "decode.errors", "Decode Errors "},
Holger Hans Peter Freyther93e048f2013-10-27 10:00:47 +010088 { "sba.allocated", "SBA Allocated "},
89 { "sba.freed", "SBA Freed "},
90 { "sba.timedout", "SBA Timeout "},
Holger Hans Peter Freyther19977872013-10-27 10:34:31 +010091 { "llc.timeout", "Timedout Frames "},
92 { "llc.dropped", "Dropped Frames "},
Holger Hans Peter Freytherb3d5ee22013-11-13 16:43:26 +010093 { "llc.scheduled", "Scheduled Frames "},
Alexander Couzens7fdbf892016-05-21 19:45:23 +020094 { "llc.dl_bytes", "RLC encapsulated PDUs"},
95 { "llc.ul_bytes", "full PDUs received "},
Holger Hans Peter Freytherc1ae2262013-10-27 10:50:35 +010096 { "rach.requests", "RACH requests "},
Mrinal Mishraf86307e2016-11-10 18:16:30 +053097 { "11bit_rach.requests", "11BIT_RACH requests "},
sivasankarida7250a2016-12-16 12:57:18 +053098 { "spb.uplink_first_segment", "First seg of UL SPB "},
99 { "spb.uplink_second_segment", "Second seg of UL SPB "},
100 { "spb.downlink_first_segment", "First seg of DL SPB "},
101 { "spb.downlink_second_segment","Second seg of DL SPB "},
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530102 { "immediate.assignment_UL", "Immediate Assign UL "},
sivasankari168911b2016-11-25 19:53:36 +0530103 { "immediate.assignment_rej", "Immediate Assign Rej "},
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530104 { "immediate.assignment_DL", "Immediate Assign DL "},
sivasankari168911b2016-11-25 19:53:36 +0530105 { "channel.request_description","Channel Request Desc "},
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530106 { "pkt.ul_assignment", "Packet UL Assignment "},
sivasankari168911b2016-11-25 19:53:36 +0530107 { "pkt.access_reject", "Packet Access Reject "},
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530108 { "pkt.dl_assignment", "Packet DL Assignment "},
109 { "ul.control", "UL control Block "},
110 { "ul.assignment_poll_timeout", "UL Assign Timeout "},
111 { "ul.assignment_failed", "UL Assign Failed "},
112 { "dl.assignment_timeout", "DL Assign Timeout "},
113 { "dl.assignment_failed", "DL Assign Failed "},
114 { "pkt.ul_ack_nack_timeout", "PUAN Poll Timeout "},
115 { "pkt.ul_ack_nack_failed", "PUAN poll Failed "},
116 { "pkt.dl_ack_nack_timeout", "PDAN poll Timeout "},
117 { "pkt.dl_ack_nack_failed", "PDAN poll Failed "},
118 { "gprs.downlink_cs1", "CS1 downlink "},
119 { "gprs.downlink_cs2", "CS2 downlink "},
120 { "gprs.downlink_cs3", "CS3 downlink "},
121 { "gprs.downlink_cs4", "CS4 downlink "},
122 { "egprs.downlink_mcs1", "MCS1 downlink "},
123 { "egprs.downlink_mcs2", "MCS2 downlink "},
124 { "egprs.downlink_mcs3", "MCS3 downlink "},
125 { "egprs.downlink_mcs4", "MCS4 downlink "},
126 { "egprs.downlink_mcs5", "MCS5 downlink "},
127 { "egprs.downlink_mcs6", "MCS6 downlink "},
128 { "egprs.downlink_mcs7", "MCS7 downlink "},
129 { "egprs.downlink_mcs8", "MCS8 downlink "},
130 { "egprs.downlink_mcs9", "MCS9 downlink "},
131 { "gprs.uplink_cs1", "CS1 Uplink "},
132 { "gprs.uplink_cs2", "CS2 Uplink "},
133 { "gprs.uplink_cs3", "CS3 Uplink "},
134 { "gprs.uplink_cs4", "CS4 Uplink "},
135 { "egprs.uplink_mcs1", "MCS1 Uplink "},
136 { "egprs.uplink_mcs2", "MCS2 Uplink "},
137 { "egprs.uplink_mcs3", "MCS3 Uplink "},
138 { "egprs.uplink_mcs4", "MCS4 Uplink "},
139 { "egprs.uplink_mcs5", "MCS5 Uplink "},
140 { "egprs.uplink_mcs6", "MCS6 Uplink "},
141 { "egprs.uplink_mcs7", "MCS7 Uplink "},
142 { "egprs.uplink_mcs8", "MCS8 Uplink "},
143 { "egprs.uplink_mcs9", "MCS9 Uplink "},
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100144};
145
146static const struct rate_ctr_group_desc bts_ctrg_desc = {
147 "bts",
148 "BTS Statistics",
Holger Hans Peter Freytherb8a54262015-11-07 21:00:00 +0100149 OSMO_STATS_CLASS_GLOBAL,
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100150 ARRAY_SIZE(bts_ctr_description),
151 bts_ctr_description,
152};
153
Jacob Erlbeckf5898a02015-11-27 19:05:13 +0100154static const struct osmo_stat_item_desc bts_stat_item_description[] = {
155 { "ms.present", "MS Present ",
156 OSMO_STAT_ITEM_NO_UNIT, 4, 0},
157};
158
159static const struct osmo_stat_item_group_desc bts_statg_desc = {
160 "bts",
161 "BTS Statistics",
162 OSMO_STATS_CLASS_GLOBAL,
163 ARRAY_SIZE(bts_stat_item_description),
164 bts_stat_item_description,
165};
166
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +0200167BTS* BTS::main_bts()
168{
169 return &s_bts;
170}
171
172struct gprs_rlcmac_bts *BTS::bts_data()
173{
174 return &m_bts;
175}
176
177struct gprs_rlcmac_bts *bts_main_data()
178{
179 return BTS::main_bts()->bts_data();
180}
181
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100182struct rate_ctr_group *bts_main_data_stats()
183{
184 return BTS::main_bts()->rate_counters();
185}
186
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +0200187BTS::BTS()
Holger Hans Peter Freyther9b30c7f2013-10-17 19:59:56 +0200188 : m_cur_fn(0)
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200189 , m_cur_blk_fn(-1)
Holger Hans Peter Freytherb78adcd2013-10-17 20:12:37 +0200190 , m_pollController(*this)
Holger Hans Peter Freythercedf8902013-10-19 20:47:12 +0200191 , m_sba(*this)
Jacob Erlbeck17214bb2015-06-02 14:06:12 +0200192 , m_ms_store(this)
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +0200193{
194 memset(&m_bts, 0, sizeof(m_bts));
195 m_bts.bts = this;
Holger Hans Peter Freyther4ed1dae2013-10-20 10:14:03 +0200196
197 /* initialize back pointers */
198 for (size_t trx_no = 0; trx_no < ARRAY_SIZE(m_bts.trx); ++trx_no) {
199 struct gprs_rlcmac_trx *trx = &m_bts.trx[trx_no];
200 trx->trx_no = trx_no;
201 trx->bts = this;
202
203 for (size_t ts_no = 0; ts_no < ARRAY_SIZE(trx->pdch); ++ts_no) {
204 struct gprs_rlcmac_pdch *pdch = &trx->pdch[ts_no];
205 pdch->ts_no = ts_no;
206 pdch->trx = trx;
207 }
208 }
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100209
210 m_ratectrs = rate_ctr_group_alloc(tall_pcu_ctx, &bts_ctrg_desc, 0);
Harald Welte9530a402017-07-12 00:46:36 +0200211 OSMO_ASSERT(m_ratectrs);
Jacob Erlbeckf5898a02015-11-27 19:05:13 +0100212 m_statg = osmo_stat_item_group_alloc(tall_pcu_ctx, &bts_statg_desc, 0);
Harald Welte9530a402017-07-12 00:46:36 +0200213 OSMO_ASSERT(m_statg);
Holger Hans Peter Freytherb6acfda2013-10-17 19:41:11 +0200214}
Holger Hans Peter Freyther9b30c7f2013-10-17 19:59:56 +0200215
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100216BTS::~BTS()
217{
Jacob Erlbeckc362df22016-01-20 22:02:19 +0100218 /* this can cause counter updates and must not be left to the
219 * m_ms_store's destructor */
220 m_ms_store.cleanup();
221
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100222 rate_ctr_group_free(m_ratectrs);
Jacob Erlbeckc362df22016-01-20 22:02:19 +0100223 osmo_stat_item_group_free(m_statg);
Holger Hans Peter Freytherf5372982013-10-27 09:02:31 +0100224}
225
226
Holger Hans Peter Freyther9b30c7f2013-10-17 19:59:56 +0200227void BTS::set_current_frame_number(int fn)
228{
Jacob Erlbeckac49d092015-08-27 13:18:24 +0200229 /* The UL frame numbers lag 3 behind the DL frames and the data
230 * indication is only sent after all 4 frames of the block have been
231 * received. Sometimes there is an idle frame between the end of one
232 * and start of another frame (every 3 blocks). So the timeout should
233 * definitely be there if we're more than 8 frames past poll_fn. Let's
Jacob Erlbecke77d49f2015-08-27 13:28:05 +0200234 * stay on the safe side and say 13 or more. An additional delay can
235 * happen due to the block processing time in the DSP, so the delay of
236 * decoded blocks relative to the timing clock can be much larger.
237 * Values up to 50 frames have been observed under load. */
238 const static int max_delay = 60;
Jacob Erlbeckac49d092015-08-27 13:18:24 +0200239
Holger Hans Peter Freyther9b30c7f2013-10-17 19:59:56 +0200240 m_cur_fn = fn;
Jacob Erlbeckac49d092015-08-27 13:18:24 +0200241 m_pollController.expireTimedout(m_cur_fn, max_delay);
Holger Hans Peter Freyther9b30c7f2013-10-17 19:59:56 +0200242}
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200243
Max9dabfa22017-05-16 16:10:45 +0200244static inline int delta_fn(int fn, int to)
245{
246 return (fn + GSM_MAX_FN * 3 / 2 - to) % GSM_MAX_FN - GSM_MAX_FN/2;
247}
248
Jacob Erlbeckaf75ce82015-08-26 13:22:28 +0200249void BTS::set_current_block_frame_number(int fn, unsigned max_delay)
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200250{
251 int delay = 0;
252 const int late_block_delay_thresh = 13;
253 const int fn_update_ok_min_delay = -500;
254 const int fn_update_ok_max_delay = 0;
255
256 /* frame numbers in the received blocks are assumed to be strongly
257 * monotonic. */
258 if (m_cur_blk_fn >= 0) {
Max9dabfa22017-05-16 16:10:45 +0200259 int delta = delta_fn(fn, m_cur_blk_fn);
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200260 if (delta <= 0)
261 return;
262 }
263
264 /* Check block delay vs. the current frame number */
265 if (current_frame_number() != 0)
Max9dabfa22017-05-16 16:10:45 +0200266 delay = delta_fn(fn, current_frame_number());
Jacob Erlbeckbe4a08b2015-08-25 15:19:31 +0200267 if (delay <= -late_block_delay_thresh) {
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200268 LOGP(DRLCMAC, LOGL_NOTICE,
269 "Late RLC block, FN delta: %d FN: %d curFN: %d\n",
270 delay, fn, current_frame_number());
Jacob Erlbeckbe4a08b2015-08-25 15:19:31 +0200271 rlc_late_block();
272 }
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200273
274 m_cur_blk_fn = fn;
275 if (delay < fn_update_ok_min_delay || delay > fn_update_ok_max_delay ||
276 current_frame_number() == 0)
277 m_cur_fn = fn;
278
Jacob Erlbeckaf75ce82015-08-26 13:22:28 +0200279 m_pollController.expireTimedout(fn, max_delay);
Jacob Erlbeck60f77032015-08-24 14:35:14 +0200280}
281
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200282int BTS::add_paging(uint8_t chan_needed, uint8_t *identity_lv)
283{
284 uint8_t l, trx, ts, any_tbf = 0;
285 struct gprs_rlcmac_tbf *tbf;
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100286 LListHead<gprs_rlcmac_tbf> *pos;
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200287 struct gprs_rlcmac_paging *pag;
288 uint8_t slot_mask[8];
289 int8_t first_ts; /* must be signed */
290
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100291 LListHead<gprs_rlcmac_tbf> *tbfs_lists[] = {
292 &m_ul_tbfs,
293 &m_dl_tbfs,
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200294 NULL
295 };
296
297
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200298 LOGP(DRLCMAC, LOGL_INFO, "Add RR paging: chan-needed=%d MI=%s\n",
299 chan_needed, osmo_hexdump(identity_lv + 1, identity_lv[0]));
300
301 /* collect slots to page
302 * Mark slots for every TBF, but only mark one of it.
303 * Mark only the first slot found.
304 * Don't mark, if TBF uses a different slot that is already marked. */
305 memset(slot_mask, 0, sizeof(slot_mask));
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200306 for (l = 0; tbfs_lists[l]; l++) {
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100307 llist_for_each(pos, tbfs_lists[l]) {
308 tbf = pos->entry();
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200309 first_ts = -1;
310 for (ts = 0; ts < 8; ts++) {
311 if (tbf->pdch[ts]) {
312 /* remember the first slot found */
313 if (first_ts < 0)
314 first_ts = ts;
315 /* break, if we already marked a slot */
Holger Hans Peter Freytherec80f822013-10-27 13:44:37 +0100316 if ((slot_mask[tbf->trx->trx_no] & (1 << ts)))
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200317 break;
318 }
319 }
320 /* mark first slot found, if none is marked already */
321 if (ts == 8 && first_ts >= 0) {
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100322 LOGP(DRLCMAC, LOGL_DEBUG, "- %s uses "
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200323 "TRX=%d TS=%d, so we mark\n",
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100324 tbf_name(tbf),
325 tbf->trx->trx_no, first_ts);
Holger Hans Peter Freytherec80f822013-10-27 13:44:37 +0100326 slot_mask[tbf->trx->trx_no] |= (1 << first_ts);
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200327 } else
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100328 LOGP(DRLCMAC, LOGL_DEBUG, "- %s uses "
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200329 "already marked TRX=%d TS=%d\n",
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100330 tbf_name(tbf),
331 tbf->trx->trx_no, ts);
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200332 }
333 }
334
335 /* Now we have a list of marked slots. Every TBF uses at least one
336 * of these slots. */
337
338 /* schedule paging to all marked slots */
339 for (trx = 0; trx < 8; trx++) {
340 if (slot_mask[trx] == 0)
341 continue;
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200342 for (ts = 0; ts < 8; ts++) {
343 if ((slot_mask[trx] & (1 << ts))) {
344 /* schedule */
345 pag = talloc_zero(tall_pcu_ctx,
346 struct gprs_rlcmac_paging);
347 if (!pag)
348 return -ENOMEM;
349 pag->chan_needed = chan_needed;
350 memcpy(pag->identity_lv, identity_lv,
351 identity_lv[0] + 1);
352 m_bts.trx[trx].pdch[ts].add_paging(pag);
353 LOGP(DRLCMAC, LOGL_INFO, "Paging on PACCH of "
354 "TRX=%d TS=%d\n", trx, ts);
Holger Hans Peter Freyther94464852013-10-19 18:33:52 +0200355 any_tbf = 1;
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200356 }
357 }
358 }
359
360 if (!any_tbf)
361 LOGP(DRLCMAC, LOGL_INFO, "No paging, because no TBF\n");
362
363 return 0;
364}
365
Harald Welte717cdf52017-07-21 21:56:23 +0200366void BTS::send_gsmtap(enum pcu_gsmtap_category categ, bool uplink, uint8_t trx_no,
367 uint8_t ts_no, uint8_t channel, uint32_t fn,
368 const uint8_t *data, unsigned int len)
369{
370 uint16_t arfcn;
371
372 /* check if category is activated at all */
373 if (!(m_bts.gsmtap_categ_mask & (1 << categ)))
374 return;
375
376 arfcn = m_bts.trx[trx_no].arfcn;
377 if (uplink)
378 arfcn |= GSMTAP_ARFCN_F_UPLINK;
379
380 gsmtap_send(m_bts.gsmtap, arfcn, ts_no, channel, 0, fn, 0, 0, data, len);
381}
382
Daniel Willmannfe6e2e42014-07-10 17:44:06 +0200383gprs_rlcmac_dl_tbf *BTS::dl_tbf_by_poll_fn(uint32_t fn, uint8_t trx, uint8_t ts)
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200384{
Daniel Willmannfe6e2e42014-07-10 17:44:06 +0200385 struct gprs_rlcmac_dl_tbf *tbf;
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100386 LListHead<gprs_rlcmac_tbf> *pos;
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200387
388 /* only one TBF can poll on specific TS/FN, because scheduler can only
389 * schedule one downlink control block (with polling) at a FN per TS */
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100390 llist_for_each(pos, &m_dl_tbfs) {
391 tbf = as_dl_tbf(pos->entry());
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200392 if (tbf->state_is_not(GPRS_RLCMAC_RELEASING)
393 && tbf->poll_state == GPRS_RLCMAC_POLL_SCHED
Holger Hans Peter Freytherec80f822013-10-27 13:44:37 +0100394 && tbf->poll_fn == fn && tbf->trx->trx_no == trx
Jacob Erlbeck8eb17142016-01-22 17:58:17 +0100395 && tbf->poll_ts == ts) {
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +0100396 return tbf;
Daniel Willmann2207c5e2014-07-10 17:44:06 +0200397 }
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200398 }
Daniel Willmannfebf1a02014-07-02 17:58:16 +0200399 return NULL;
400}
Daniel Willmannfe6e2e42014-07-10 17:44:06 +0200401gprs_rlcmac_ul_tbf *BTS::ul_tbf_by_poll_fn(uint32_t fn, uint8_t trx, uint8_t ts)
Daniel Willmannfebf1a02014-07-02 17:58:16 +0200402{
Daniel Willmannfe6e2e42014-07-10 17:44:06 +0200403 struct gprs_rlcmac_ul_tbf *tbf;
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100404 LListHead<gprs_rlcmac_tbf> *pos;
Daniel Willmannfebf1a02014-07-02 17:58:16 +0200405
406 /* only one TBF can poll on specific TS/FN, because scheduler can only
407 * schedule one downlink control block (with polling) at a FN per TS */
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100408 llist_for_each(pos, &m_ul_tbfs) {
409 tbf = as_ul_tbf(pos->entry());
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200410 if (tbf->state_is_not(GPRS_RLCMAC_RELEASING)
411 && tbf->poll_state == GPRS_RLCMAC_POLL_SCHED
Holger Hans Peter Freytherec80f822013-10-27 13:44:37 +0100412 && tbf->poll_fn == fn && tbf->trx->trx_no == trx
Jacob Erlbeck8eb17142016-01-22 17:58:17 +0100413 && tbf->poll_ts == ts) {
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +0100414 return tbf;
Daniel Willmann2207c5e2014-07-10 17:44:06 +0200415 }
Holger Hans Peter Freyther34bd8bd2013-10-19 21:10:38 +0200416 }
417 return NULL;
418}
419
Daniel Willmann54044b02014-07-02 17:58:15 +0200420/* lookup downlink TBF Entity (by TFI) */
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200421gprs_rlcmac_dl_tbf *BTS::dl_tbf_by_tfi(uint8_t tfi, uint8_t trx, uint8_t ts)
Daniel Willmann54044b02014-07-02 17:58:15 +0200422{
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200423 if (trx >= 8 || ts >= 8)
424 return NULL;
425
426 return m_bts.trx[trx].pdch[ts].dl_tbf_by_tfi(tfi);
Daniel Willmann54044b02014-07-02 17:58:15 +0200427}
428
429/* lookup uplink TBF Entity (by TFI) */
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200430gprs_rlcmac_ul_tbf *BTS::ul_tbf_by_tfi(uint8_t tfi, uint8_t trx, uint8_t ts)
Daniel Willmann54044b02014-07-02 17:58:15 +0200431{
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200432 if (trx >= 8 || ts >= 8)
Holger Hans Peter Freytherf63cabd2013-10-26 19:10:43 +0200433 return NULL;
434
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200435 return m_bts.trx[trx].pdch[ts].ul_tbf_by_tfi(tfi);
Holger Hans Peter Freytherf63cabd2013-10-26 19:10:43 +0200436}
437
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200438/*
439 * Search for free TFI and return TFI, TRX.
440 * This method returns the first TFI that is currently not used in any PDCH of
441 * a TRX. The first TRX that contains such an TFI is returned. Negative values
442 * indicate errors.
443 */
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200444int BTS::tfi_find_free(enum gprs_rlcmac_tbf_direction dir,
445 uint8_t *_trx, int8_t use_trx)
446{
447 struct gprs_rlcmac_pdch *pdch;
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200448 uint32_t free_tfis;
449 bool has_pdch = false;
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200450 uint8_t trx_from, trx_to, trx, ts, tfi;
451
452 if (use_trx >= 0 && use_trx < 8)
453 trx_from = trx_to = use_trx;
454 else {
455 trx_from = 0;
456 trx_to = 7;
457 }
458
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200459 /* find a TFI that is unused on all PDCH */
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200460 for (trx = trx_from; trx <= trx_to; trx++) {
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200461 bool trx_has_pdch = false;
462
463 free_tfis = 0xffffffff;
464
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200465 for (ts = 0; ts < 8; ts++) {
466 pdch = &m_bts.trx[trx].pdch[ts];
467 if (!pdch->is_enabled())
468 continue;
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200469 free_tfis &= ~pdch->assigned_tfi(dir);
470 trx_has_pdch = true;
471 has_pdch = true;
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200472 }
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200473 if (trx_has_pdch && free_tfis)
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200474 break;
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200475
476 free_tfis = 0;
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200477 }
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200478 if (!has_pdch) {
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200479 LOGP(DRLCMAC, LOGL_NOTICE, "No PDCH available.\n");
480 return -EINVAL;
481 }
482
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200483 if (!free_tfis) {
484 LOGP(DRLCMAC, LOGL_NOTICE, "No TFI available.\n");
485 return -EBUSY;
486 }
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200487
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200488
489 LOGP(DRLCMAC, LOGL_DEBUG,
490 "Searching for first unallocated TFI: TRX=%d\n", trx);
491
492 /* find the first */
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200493 for (tfi = 0; tfi < 32; tfi++) {
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200494 if (free_tfis & 1 << tfi)
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200495 break;
496 }
497
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200498 OSMO_ASSERT(tfi < 32);
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200499
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +0200500 LOGP(DRLCMAC, LOGL_DEBUG, " Found TFI=%d.\n", tfi);
501 *_trx = trx;
502 return tfi;
Holger Hans Peter Freyther70ddde62013-10-26 19:17:58 +0200503}
504
Holger Hans Peter Freyther40cfaa62013-10-26 19:49:16 +0200505int BTS::rcv_imm_ass_cnf(const uint8_t *data, uint32_t fn)
506{
Jacob Erlbeck767193e2015-05-20 12:06:46 +0200507 struct gprs_rlcmac_dl_tbf *dl_tbf = NULL;
Holger Hans Peter Freyther40cfaa62013-10-26 19:49:16 +0200508 uint8_t plen;
509 uint32_t tlli;
Jacob Erlbeck767193e2015-05-20 12:06:46 +0200510 GprsMs *ms;
Holger Hans Peter Freyther40cfaa62013-10-26 19:49:16 +0200511
512 /* move to IA Rest Octets */
513 plen = data[0] >> 2;
514 data += 1 + plen;
515
516 if ((*data & 0xf0) != 0xd0) {
517 LOGP(DRLCMAC, LOGL_ERROR, "Got IMM.ASS confirm, but rest "
518 "octets do not start with bit sequence 'HH01' "
519 "(Packet Downlink Assignment)\n");
520 return -EINVAL;
521 }
522
523 /* get TLLI from downlink assignment */
524 tlli = (*data++) << 28;
525 tlli |= (*data++) << 20;
526 tlli |= (*data++) << 12;
527 tlli |= (*data++) << 4;
528 tlli |= (*data++) >> 4;
529
Jacob Erlbeck767193e2015-05-20 12:06:46 +0200530 ms = ms_by_tlli(tlli);
531 if (ms)
532 dl_tbf = ms->dl_tbf();
Daniel Willmann1dac2eb2014-08-07 12:37:34 +0200533 if (!dl_tbf) {
Holger Hans Peter Freyther40cfaa62013-10-26 19:49:16 +0200534 LOGP(DRLCMAC, LOGL_ERROR, "Got IMM.ASS confirm, but TLLI=%08x "
535 "does not exit\n", tlli);
536 return -EINVAL;
537 }
538
539 LOGP(DRLCMAC, LOGL_DEBUG, "Got IMM.ASS confirm for TLLI=%08x\n", tlli);
540
Daniel Willmann7e994e32014-08-07 15:49:21 +0200541 if (dl_tbf->m_wait_confirm)
Daniel Willmann1dac2eb2014-08-07 12:37:34 +0200542 tbf_timer_start(dl_tbf, 0, Tassign_agch);
Holger Hans Peter Freyther40cfaa62013-10-26 19:49:16 +0200543
544 return 0;
545}
546
Philipp Maier1275a3f2017-02-21 19:35:23 +0100547/* Determine the full frame number from a relative frame number */
Max5dd8d1b2017-03-08 12:06:42 +0100548uint32_t BTS::rfn_to_fn(int32_t rfn)
Philipp Maier1275a3f2017-02-21 19:35:23 +0100549{
Max5dd8d1b2017-03-08 12:06:42 +0100550 int32_t m_cur_rfn;
551 int32_t fn;
552 int32_t fn_rounded;
553
554 /* double-check that relative FN is not negative and fits into int32_t */
555 OSMO_ASSERT(rfn < GSM_MAX_FN);
556 OSMO_ASSERT(rfn >= 0);
Philipp Maier1275a3f2017-02-21 19:35:23 +0100557
558 /* Note: If a BTS is sending in a rach request it will be fully aware
559 * of the frame number. If the PCU is used in a BSC-co-located setup.
560 * The BSC will forward the incoming RACH request. The RACH request
561 * only contains the relative frame number (Fn % 42432) in its request
562 * reference. This PCU implementation has to fit both scenarios, so
563 * we need to assume that Fn is a relative frame number. */
564
565 /* Ensure that all following calculations are performed with the
566 * relative frame number */
Max5dd8d1b2017-03-08 12:06:42 +0100567 if (rfn >= RFN_MODULUS)
568 return rfn;
Philipp Maier1275a3f2017-02-21 19:35:23 +0100569
570 /* Compute an internal relative frame number from the full internal
571 frame number */
572 m_cur_rfn = m_cur_fn % RFN_MODULUS;
573
574 /* Compute a "rounded" version of the internal frame number, which
575 * exactly fits in the RFN_MODULUS raster */
576 fn_rounded = m_cur_fn - m_cur_rfn;
577
578 /* If the delta between the internal and the external relative frame
579 * number exceeds a certain limit, we need to assume that the incoming
580 * rach request belongs to a the previous rfn period. To correct this,
581 * we roll back the rounded frame number by one RFN_MODULUS */
582 if (abs(rfn - m_cur_rfn) > RFN_THRESHOLD) {
583 LOGP(DRLCMAC, LOGL_DEBUG,
584 "Race condition between rfn (%u) and m_cur_fn (%u) detected: rfn belongs to the previos modulus %u cycle, wrappng...\n",
585 rfn, m_cur_fn, RFN_MODULUS);
586 if (fn_rounded < RFN_MODULUS) {
587 LOGP(DRLCMAC, LOGL_DEBUG,
588 "Cornercase detected: wrapping crosses %u border\n",
589 GSM_MAX_FN);
590 fn_rounded = GSM_MAX_FN - (RFN_MODULUS - fn_rounded);
591 }
592 else
593 fn_rounded -= RFN_MODULUS;
594 }
595
596 /* The real frame number is the sum of the rounded frame number and the
597 * relative framenumber computed via RACH */
598 fn = fn_rounded + rfn;
599
600 return fn;
601}
602
bhargava959d1de2016-08-17 15:17:21 +0530603int BTS::rcv_rach(uint16_t ra, uint32_t Fn, int16_t qta, uint8_t is_11bit,
604 enum ph_burst_type burst_type)
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200605{
Jacob Erlbeck1f332942015-05-04 08:21:17 +0200606 struct gprs_rlcmac_ul_tbf *tbf = NULL;
Holger Hans Peter Freytherf37e5142013-12-25 18:56:34 +0100607 uint8_t trx_no, ts_no = 0;
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200608 uint8_t sb = 0;
609 uint32_t sb_fn = 0;
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530610 int rc = 0;
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100611 int plen;
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100612 uint8_t usf = 7;
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530613 uint8_t tsc = 0, ta = qta2ta(qta);
bhargava628dcfb2016-09-14 20:30:31 +0530614 uint16_t ms_class = 0;
615 uint16_t priority = 0;
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530616 bool failure = false;
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200617
Holger Hans Peter Freytherc1ae2262013-10-27 10:50:35 +0100618 rach_frame();
619
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530620 if (is_11bit)
621 rach_frame_11bit();
622
Philipp Maier1275a3f2017-02-21 19:35:23 +0100623 /* Determine full frame number */
624 Fn = rfn_to_fn(Fn);
Philippd935d882016-11-07 13:07:36 +0100625
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530626 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF on RACH, "
Philipp Maier53f0b4d2017-01-26 11:39:16 +0100627 "so we provide one: ra=0x%02x Fn=%u qta=%d is_11bit=%d:\n",
628 ra, Fn, qta, is_11bit);
bhargava628dcfb2016-09-14 20:30:31 +0530629
630 sb = is_single_block(ra, burst_type, is_11bit, &ms_class, &priority);
631
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200632 if (sb) {
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100633 rc = sba()->alloc(&trx_no, &ts_no, &sb_fn, ta);
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530634 if (rc < 0) {
635 failure = true;
636 LOGP(DRLCMAC, LOGL_NOTICE, "No PDCH resource for "
637 "single block allocation."
638 "sending Immediate "
639 "Assignment Uplink (AGCH) reject\n");
640 } else {
641 tsc = m_bts.trx[trx_no].pdch[ts_no].tsc;
642
643 LOGP(DRLCMAC, LOGL_DEBUG, "RX: [PCU <- BTS] RACH "
644 " qbit-ta=%d ra=0x%02x, Fn=%d (%d,%d,%d),"
645 " SBFn=%d\n",
646 qta, ra,
647 Fn, (Fn / (26 * 51)) % 32, Fn % 51, Fn % 26,
648 sb_fn);
649 LOGP(DRLCMAC, LOGL_INFO, "TX: Immediate Assignment "
650 "Uplink (AGCH)\n");
651 }
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200652 } else {
653 // Create new TBF
Neels Hofmeyrd32aa032016-06-20 18:17:03 +0200654 #warning "Copy and paste with other routines.."
bhargava628dcfb2016-09-14 20:30:31 +0530655
656 if (is_11bit) {
657 tbf = tbf_alloc_ul_tbf(&m_bts, NULL, -1, 0,
658 ms_class, 1);
659 } else {
660 /* set class to 0, since we don't know the multislot
661 * class yet */
662 tbf = tbf_alloc_ul_tbf(&m_bts, NULL, -1, 0, 0, 1);
663 }
664
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200665 if (!tbf) {
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530666 LOGP(DRLCMAC, LOGL_NOTICE, "No PDCH resource sending "
667 "Immediate Assignment Uplink (AGCH) "
668 "reject\n");
669 rc = -EBUSY;
670 failure = true;
671 } else {
672 tbf->set_ta(ta);
673 tbf->set_state(GPRS_RLCMAC_FLOW);
674 tbf->state_flags |= (1 << GPRS_RLCMAC_FLAG_CCCH);
675 tbf_timer_start(tbf, 3169, m_bts.t3169, 0);
676 LOGP(DRLCMAC, LOGL_DEBUG, "%s [UPLINK] START\n",
677 tbf_name(tbf));
678 LOGP(DRLCMAC, LOGL_DEBUG, "%s RX: [PCU <- BTS] RACH "
679 "qbit-ta=%d ra=0x%02x, Fn=%d "
680 " (%d,%d,%d)\n",
681 tbf_name(tbf),
682 qta, ra, Fn, (Fn / (26 * 51)) % 32,
683 Fn % 51, Fn % 26);
684 LOGP(DRLCMAC, LOGL_INFO, "%s TX: START Immediate "
685 "Assignment Uplink (AGCH)\n",
686 tbf_name(tbf));
687 trx_no = tbf->trx->trx_no;
688 ts_no = tbf->first_ts;
689 usf = tbf->m_usf[ts_no];
690 tsc = tbf->tsc();
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200691 }
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200692 }
Alexander Couzensccde5c92017-02-04 03:10:08 +0100693 bitvec *immediate_assignment = bitvec_alloc(22, tall_pcu_ctx) /* without plen */;
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200694 bitvec_unhex(immediate_assignment,
695 "2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b");
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100696
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100697
sivasankari168911b2016-11-25 19:53:36 +0530698 if (failure) {
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530699 plen = Encoding::write_immediate_assignment_reject(
700 immediate_assignment, ra, Fn,
701 burst_type);
sivasankari168911b2016-11-25 19:53:36 +0530702 immediate_assignment_reject();
703 }
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530704 else {
705 LOGP(DRLCMAC, LOGL_DEBUG,
706 " - TRX=%d (%d) TS=%d TA=%d TSC=%d TFI=%d USF=%d\n",
707 trx_no, m_bts.trx[trx_no].arfcn, ts_no, ta, tsc,
708 tbf ? tbf->tfi() : -1, usf);
709
710 plen = Encoding::write_immediate_assignment(
711 tbf, immediate_assignment, 0, ra, Fn, ta,
712 m_bts.trx[trx_no].arfcn, ts_no, tsc, usf, 0, sb_fn,
713 m_bts.alpha, m_bts.gamma, -1, burst_type, sb);
714 }
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100715
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530716 if (plen >= 0) {
717 immediate_assignment_ul_tbf();
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100718 pcu_l1if_tx_agch(immediate_assignment, plen);
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530719 }
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100720
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200721 bitvec_free(immediate_assignment);
722
aravind sirsikarc0c3afd2016-11-09 16:27:00 +0530723 return rc;
Holger Hans Peter Freyther02beed52013-10-26 20:56:20 +0200724}
725
bhargava628dcfb2016-09-14 20:30:31 +0530726uint8_t BTS::is_single_block(uint16_t ra, enum ph_burst_type burst_type,
727 uint8_t is_11bit, uint16_t *ms_class, uint16_t *priority)
728{
729 uint8_t sb = 0, val = 0;
730
731 if (!is_11bit && (burst_type == GSM_L1_BURST_TYPE_ACCESS_0)) {
732
733 if ((ra & 0xf8) == 0x70) {
734 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests single block "
735 "allocation\n");
736 sb = 1;
737 } else if (m_bts.force_two_phase) {
738 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests single "
739 "phase access, but we force two phase "
740 "access\n");
741 sb = 1;
742 }
743
744 } else if (is_11bit &&
745 ((burst_type == GSM_L1_BURST_TYPE_ACCESS_1) ||
746 (burst_type == GSM_L1_BURST_TYPE_ACCESS_2))) {
747
748 val = !!(ra & (1 << 10));
749
750 if (!val) {
751 if (m_bts.force_two_phase) {
752 LOGP(DRLCMAC, LOGL_DEBUG, "EGPRS 11 bit RACH "
753 "received. MS requests single phase "
754 "access but we force two phase "
755 "access\n");
756 sb = 1;
757 } else {
758 sb = 0;
759 *ms_class = (ra & 0x3e0) >> 5;
760 *priority = (ra & 0x18) >> 3;
761 }
762
763 } else {
764 LOGP(DRLCMAC, LOGL_DEBUG, "EGPRS 11 bit RACH received."
765 "MS requests single block allocation\n");
766 sb = 1;
767 }
768
769 } else if (is_11bit &&
770 (burst_type == GSM_L1_BURST_TYPE_ACCESS_0)) {
771 LOGP(DRLCMAC, LOGL_ERROR,
772 "Error: GPRS 11 bit RACH not supported\n");
773
774 } else if (burst_type == GSM_L1_BURST_TYPE_NONE) {
775 LOGP(DRLCMAC, LOGL_DEBUG, "pcu has not received burst type "
776 "from bts \n");
777
778 if ((ra & 0xf8) == 0x70) {
779 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests single block "
780 "allocation\n");
781 sb = 1;
782 } else if (m_bts.force_two_phase) {
783 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests single "
784 "phase access, but we force two phase "
785 "access\n");
786 sb = 1;
787 }
788 }
789
790 return sb;
791}
792
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200793/* depending on the current TBF, we assign on PACCH or AGCH */
794void BTS::trigger_dl_ass(
Daniel Willmann532a4b52014-08-07 12:39:26 +0200795 struct gprs_rlcmac_dl_tbf *dl_tbf,
Jacob Erlbeck71e55112015-05-21 11:10:15 +0200796 struct gprs_rlcmac_tbf *old_tbf)
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200797{
798 /* stop pending timer */
Daniel Willmann532a4b52014-08-07 12:39:26 +0200799 dl_tbf->stop_timer();
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200800
801 /* check for downlink tbf: */
802 if (old_tbf) {
803 LOGP(DRLCMAC, LOGL_DEBUG, "Send dowlink assignment on "
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100804 "PACCH, because %s exists\n", tbf_name(old_tbf));
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200805 old_tbf->dl_ass_state = GPRS_RLCMAC_DL_ASS_SEND_ASS;
Daniel Willmanne4818152014-08-15 16:52:09 +0200806
Daniel Willmanne4818152014-08-15 16:52:09 +0200807 old_tbf->was_releasing = old_tbf->state_is(GPRS_RLCMAC_WAIT_RELEASE);
808
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200809 /* change state */
Daniel Willmanneb100242014-08-08 11:43:53 +0200810 dl_tbf->set_state(GPRS_RLCMAC_ASSIGN);
Jacob Erlbeck9876a3b2016-01-29 18:51:04 +0100811 if (!(dl_tbf->state_flags & (1 << GPRS_RLCMAC_FLAG_CCCH)))
812 dl_tbf->state_flags |= (1 << GPRS_RLCMAC_FLAG_PACCH);
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200813 /* start timer */
Daniel Willmann532a4b52014-08-07 12:39:26 +0200814 tbf_timer_start(dl_tbf, 0, Tassign_pacch);
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200815 } else {
Jacob Erlbeck71e55112015-05-21 11:10:15 +0200816 LOGP(DRLCMAC, LOGL_DEBUG, "Send dowlink assignment for %s on PCH, no TBF exist (IMSI=%s)\n", tbf_name(dl_tbf), dl_tbf->imsi());
Daniel Willmann532a4b52014-08-07 12:39:26 +0200817 dl_tbf->was_releasing = dl_tbf->state_is(GPRS_RLCMAC_WAIT_RELEASE);
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200818 /* change state */
Daniel Willmanneb100242014-08-08 11:43:53 +0200819 dl_tbf->set_state(GPRS_RLCMAC_ASSIGN);
Daniel Willmann532a4b52014-08-07 12:39:26 +0200820 dl_tbf->state_flags |= (1 << GPRS_RLCMAC_FLAG_CCCH);
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200821 /* send immediate assignment */
Jacob Erlbeck71e55112015-05-21 11:10:15 +0200822 dl_tbf->bts->snd_dl_ass(dl_tbf, 0, dl_tbf->imsi());
Daniel Willmann7e994e32014-08-07 15:49:21 +0200823 dl_tbf->m_wait_confirm = 1;
Holger Hans Peter Freyther24c1a5b2013-10-26 20:27:44 +0200824 }
825}
826
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200827void BTS::snd_dl_ass(gprs_rlcmac_tbf *tbf, uint8_t poll, const char *imsi)
828{
829 int plen;
Jacob Erlbeck29e3a2f2016-02-05 19:04:23 +0100830 unsigned int ts = tbf->first_ts;
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200831
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100832 LOGP(DRLCMAC, LOGL_INFO, "TX: START %s Immediate Assignment Downlink (PCH)\n", tbf_name(tbf));
Alexander Couzensccde5c92017-02-04 03:10:08 +0100833 bitvec *immediate_assignment = bitvec_alloc(22, tall_pcu_ctx); /* without plen */
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200834 bitvec_unhex(immediate_assignment, "2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b2b");
835 /* use request reference that has maximum distance to current time,
836 * so the assignment will not conflict with possible RACH requests. */
Jacob Erlbeck2ca86af2016-01-20 18:26:13 +0100837 LOGP(DRLCMAC, LOGL_DEBUG, " - TRX=%d (%d) TS=%d TA=%d pollFN=%d\n",
838 tbf->trx->trx_no, tbf->trx->arfcn,
839 ts, tbf->ta(), poll ? tbf->poll_fn : -1);
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100840 plen = Encoding::write_immediate_assignment(tbf, immediate_assignment, 1, 125,
Max9dabfa22017-05-16 16:10:45 +0200841 (tbf->pdch[ts]->last_rts_fn + 21216) % GSM_MAX_FN, tbf->ta(),
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100842 tbf->trx->arfcn, ts, tbf->tsc(), 7, poll,
843 tbf->poll_fn, m_bts.alpha, m_bts.gamma, -1);
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530844 if (plen >= 0) {
845 immediate_assignment_dl_tbf();
Jacob Erlbeck2647a332016-02-01 16:13:38 +0100846 pcu_l1if_tx_pch(immediate_assignment, plen, imsi);
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530847 }
848
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200849 bitvec_free(immediate_assignment);
850}
851
Holger Hans Peter Freytherd11290b2013-10-26 17:32:04 +0200852
Jacob Erlbeck86b6f052015-11-27 15:17:34 +0100853GprsMs *BTS::ms_alloc(uint8_t ms_class, uint8_t egprs_ms_class)
Jacob Erlbeckcb1b4942015-06-19 10:59:58 +0200854{
855 GprsMs *ms;
856 ms = ms_store().create_ms();
857
858 ms->set_timeout(m_bts.ms_idle_sec);
859 ms->set_ms_class(ms_class);
Jacob Erlbeck86b6f052015-11-27 15:17:34 +0100860 ms->set_egprs_ms_class(egprs_ms_class);
Jacob Erlbeckcb1b4942015-06-19 10:59:58 +0200861
862 return ms;
863}
864
Holger Hans Peter Freytherd11290b2013-10-26 17:32:04 +0200865/*
866 * PDCH code below. TODO: move to a separate file
867 */
868
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200869void gprs_rlcmac_pdch::enable()
870{
871 /* TODO: Check if there are still allocated resources.. */
872 INIT_LLIST_HEAD(&paging_list);
873 m_is_enabled = 1;
874}
875
876void gprs_rlcmac_pdch::disable()
877{
878 /* TODO.. kick free_resources once we know the TRX/TS we are on */
879 m_is_enabled = 0;
880}
881
Holger Hans Peter Freyther09ef27a2013-10-20 16:37:05 +0200882void gprs_rlcmac_pdch::free_resources()
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200883{
884 struct gprs_rlcmac_paging *pag;
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200885
886 /* we are not enabled. there should be no resources */
887 if (!is_enabled())
888 return;
889
890 /* kick all TBF on slot */
891 gprs_rlcmac_tbf::free_all(this);
892
893 /* flush all pending paging messages */
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +0200894 while ((pag = dequeue_paging()))
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200895 talloc_free(pag);
896
Holger Hans Peter Freyther09ef27a2013-10-20 16:37:05 +0200897 trx->bts->sba()->free_resources(this);
Holger Hans Peter Freyther17b0d832013-10-19 17:37:48 +0200898}
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +0200899
900struct gprs_rlcmac_paging *gprs_rlcmac_pdch::dequeue_paging()
901{
902 struct gprs_rlcmac_paging *pag;
903
904 if (llist_empty(&paging_list))
905 return NULL;
906 pag = llist_entry(paging_list.next, struct gprs_rlcmac_paging, list);
907 llist_del(&pag->list);
908
909 return pag;
910}
911
912struct msgb *gprs_rlcmac_pdch::packet_paging_request()
913{
914 struct gprs_rlcmac_paging *pag;
915 struct msgb *msg;
916 unsigned wp = 0, len;
917
918 /* no paging, no message */
919 pag = dequeue_paging();
920 if (!pag)
921 return NULL;
922
923 LOGP(DRLCMAC, LOGL_DEBUG, "Scheduling paging\n");
924
925 /* alloc message */
926 msg = msgb_alloc(23, "pag ctrl block");
927 if (!msg) {
928 talloc_free(pag);
929 return NULL;
930 }
Alexander Couzensccde5c92017-02-04 03:10:08 +0100931 bitvec *pag_vec = bitvec_alloc(23, tall_pcu_ctx);
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +0200932 if (!pag_vec) {
933 msgb_free(msg);
934 talloc_free(pag);
935 return NULL;
936 }
Holger Hans Peter Freyther63f29d62013-10-19 19:04:03 +0200937 wp = Encoding::write_packet_paging_request(pag_vec);
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +0200938
939 /* loop until message is full */
940 while (pag) {
941 /* try to add paging */
942 if ((pag->identity_lv[1] & 0x07) == 4) {
943 /* TMSI */
944 LOGP(DRLCMAC, LOGL_DEBUG, "- TMSI=0x%08x\n",
945 ntohl(*((uint32_t *)(pag->identity_lv + 1))));
946 len = 1 + 1 + 1 + 32 + 2 + 1;
947 if (pag->identity_lv[0] != 5) {
948 LOGP(DRLCMAC, LOGL_ERROR, "TMSI paging with "
949 "MI != 5 octets!\n");
950 goto continue_next;
951 }
952 } else {
953 /* MI */
954 LOGP(DRLCMAC, LOGL_DEBUG, "- MI=%s\n",
955 osmo_hexdump(pag->identity_lv + 1,
956 pag->identity_lv[0]));
957 len = 1 + 1 + 1 + 4 + (pag->identity_lv[0]<<3) + 2 + 1;
958 if (pag->identity_lv[0] > 8) {
959 LOGP(DRLCMAC, LOGL_ERROR, "Paging with "
960 "MI > 8 octets!\n");
961 goto continue_next;
962 }
963 }
964 if (wp + len > 184) {
965 LOGP(DRLCMAC, LOGL_DEBUG, "- Does not fit, so schedule "
966 "next time\n");
967 /* put back paging record, because does not fit */
968 llist_add_tail(&pag->list, &paging_list);
969 break;
970 }
Holger Hans Peter Freyther63f29d62013-10-19 19:04:03 +0200971 Encoding::write_repeated_page_info(pag_vec, wp, pag->identity_lv[0],
Holger Hans Peter Freyther24e98d02013-10-19 18:15:44 +0200972 pag->identity_lv + 1, pag->chan_needed);
973
974continue_next:
975 talloc_free(pag);
976 pag = dequeue_paging();
977 }
978
979 bitvec_pack(pag_vec, msgb_put(msg, 23));
980 RlcMacDownlink_t * mac_control_block = (RlcMacDownlink_t *)talloc_zero(tall_pcu_ctx, RlcMacDownlink_t);
981 LOGP(DRLCMAC, LOGL_DEBUG, "+++++++++++++++++++++++++ TX : Packet Paging Request +++++++++++++++++++++++++\n");
982 decode_gsm_rlcmac_downlink(pag_vec, mac_control_block);
983 LOGPC(DCSN1, LOGL_NOTICE, "\n");
984 LOGP(DRLCMAC, LOGL_DEBUG, "------------------------- TX : Packet Paging Request -------------------------\n");
985 bitvec_free(pag_vec);
986 talloc_free(mac_control_block);
987
988 return msg;
989}
990
Holger Hans Peter Freytherf0984892013-10-19 18:28:59 +0200991void gprs_rlcmac_pdch::add_paging(struct gprs_rlcmac_paging *pag)
992{
993 llist_add(&pag->list, &paging_list);
994}
Holger Hans Peter Freyther9ae367f2013-10-26 16:42:38 +0200995
Holger Hans Peter Freythere1a075a2013-10-27 13:35:30 +0100996void gprs_rlcmac_pdch::rcv_control_ack(Packet_Control_Acknowledgement_t *packet, uint32_t fn)
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +0100997{
Daniel Willmanne4818152014-08-15 16:52:09 +0200998 struct gprs_rlcmac_tbf *tbf, *new_tbf;
Max127a1e02017-01-12 11:37:58 +0100999 uint32_t tlli = packet->TLLI;
1000 GprsMs *ms = bts()->ms_by_tlli(tlli);
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001001
Daniel Willmannfebf1a02014-07-02 17:58:16 +02001002 tbf = bts()->ul_tbf_by_poll_fn(fn, trx_no(), ts_no);
1003 if (!tbf)
1004 tbf = bts()->dl_tbf_by_poll_fn(fn, trx_no(), ts_no);
1005
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001006 if (!tbf) {
1007 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET CONTROL ACK with "
Holger Hans Peter Freyther15bb1a22013-10-27 12:30:46 +01001008 "unknown FN=%u TLLI=0x%08x (TRX %d TS %d)\n",
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001009 fn, tlli, trx_no(), ts_no);
Max127a1e02017-01-12 11:37:58 +01001010 if (ms)
1011 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET CONTROL ACK with "
1012 "unknown TBF corresponds to MS with IMSI %s, TA %d, "
Maxe8284a72017-05-18 12:38:41 +02001013 "uTBF (TFI=%d, state=%s), dTBF (TFI=%d, state=%s)\n",
Max127a1e02017-01-12 11:37:58 +01001014 ms->imsi(), ms->ta(),
1015 ms->ul_tbf() ? ms->ul_tbf()->tfi() : 0,
1016 ms->ul_tbf() ? ms->ul_tbf()->state_name() : "None",
1017 ms->dl_tbf() ? ms->dl_tbf()->tfi() : 0,
1018 ms->dl_tbf() ? ms->dl_tbf()->state_name() : "None");
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001019 return;
1020 }
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001021 tbf->update_ms(tlli, GPRS_RLCMAC_UL_TBF);
Jacob Erlbeckfecece02015-05-08 12:13:08 +02001022
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001023 LOGP(DRLCMAC, LOGL_DEBUG, "RX: [PCU <- BTS] %s Packet Control Ack\n", tbf_name(tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001024 tbf->poll_state = GPRS_RLCMAC_POLL_NONE;
1025
1026 /* check if this control ack belongs to packet uplink ack */
1027 if (tbf->ul_ack_state == GPRS_RLCMAC_UL_ACK_WAIT_ACK) {
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001028 LOGP(DRLCMAC, LOGL_DEBUG, "TBF: [UPLINK] END %s\n", tbf_name(tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001029 tbf->ul_ack_state = GPRS_RLCMAC_UL_ACK_NONE;
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001030 if ((tbf->state_flags &
1031 (1 << GPRS_RLCMAC_FLAG_TO_UL_ACK))) {
1032 tbf->state_flags &=
1033 ~(1 << GPRS_RLCMAC_FLAG_TO_UL_ACK);
1034 LOGP(DRLCMAC, LOGL_NOTICE, "Recovered uplink "
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001035 "ack for UL %s\n", tbf_name(tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001036 }
1037 tbf_free(tbf);
1038 return;
1039 }
1040 if (tbf->dl_ass_state == GPRS_RLCMAC_DL_ASS_WAIT_ACK) {
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001041 LOGP(DRLCMAC, LOGL_DEBUG, "TBF: [UPLINK] DOWNLINK ASSIGNED %s\n", tbf_name(tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001042 /* reset N3105 */
1043 tbf->n3105 = 0;
1044 tbf->dl_ass_state = GPRS_RLCMAC_DL_ASS_NONE;
Daniel Willmanne4818152014-08-15 16:52:09 +02001045
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001046 new_tbf = tbf->ms() ? tbf->ms()->dl_tbf() : NULL;
Daniel Willmanne4818152014-08-15 16:52:09 +02001047 if (!new_tbf) {
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001048 LOGP(DRLCMAC, LOGL_ERROR, "Got ACK, but DL "
Holger Hans Peter Freyther875fc892013-10-27 13:35:46 +01001049 "TBF is gone TLLI=0x%08x\n", tlli);
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001050 return;
1051 }
Jacob Erlbeck7d5157e2016-02-01 18:15:35 +01001052 if (tbf->state_is(GPRS_RLCMAC_WAIT_RELEASE) &&
1053 tbf->direction == new_tbf->direction)
Daniel Willmanne4818152014-08-15 16:52:09 +02001054 tbf_free(tbf);
1055
Jacob Erlbeck9876a3b2016-01-29 18:51:04 +01001056 if ((new_tbf->state_flags & (1 << GPRS_RLCMAC_FLAG_CCCH))) {
1057 /* We now know that the PACCH really existed */
1058 LOGP(DRLCMAC, LOGL_INFO,
1059 "The TBF has been confirmed on the PACCH, "
1060 "changed type from CCCH to PACCH for %s\n",
1061 tbf_name(new_tbf));
1062 new_tbf->state_flags &= ~(1 << GPRS_RLCMAC_FLAG_CCCH);
1063 new_tbf->state_flags |= (1 << GPRS_RLCMAC_FLAG_PACCH);
1064 }
Daniel Willmanne4818152014-08-15 16:52:09 +02001065 new_tbf->set_state(GPRS_RLCMAC_FLOW);
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001066 /* stop pending assignment timer */
Daniel Willmanne4818152014-08-15 16:52:09 +02001067 new_tbf->stop_timer();
1068 if ((new_tbf->state_flags &
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001069 (1 << GPRS_RLCMAC_FLAG_TO_DL_ASS))) {
Daniel Willmanne4818152014-08-15 16:52:09 +02001070 new_tbf->state_flags &=
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001071 ~(1 << GPRS_RLCMAC_FLAG_TO_DL_ASS);
1072 LOGP(DRLCMAC, LOGL_NOTICE, "Recovered downlink "
Daniel Willmanne4818152014-08-15 16:52:09 +02001073 "assignment for %s\n", tbf_name(new_tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001074 }
Daniel Willmanne4818152014-08-15 16:52:09 +02001075 tbf_assign_control_ts(new_tbf);
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001076 return;
1077 }
1078 if (tbf->ul_ass_state == GPRS_RLCMAC_UL_ASS_WAIT_ACK) {
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001079 LOGP(DRLCMAC, LOGL_DEBUG, "TBF: [DOWNLINK] UPLINK ASSIGNED %s\n", tbf_name(tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001080 /* reset N3105 */
1081 tbf->n3105 = 0;
1082 tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_NONE;
Daniel Willmanne4818152014-08-15 16:52:09 +02001083
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001084 new_tbf = tbf->ms() ? tbf->ms()->ul_tbf() : NULL;
Daniel Willmanne4818152014-08-15 16:52:09 +02001085 if (!new_tbf) {
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001086 LOGP(DRLCMAC, LOGL_ERROR, "Got ACK, but UL "
Holger Hans Peter Freyther8d0e4892013-10-27 12:42:58 +01001087 "TBF is gone TLLI=0x%08x\n", tlli);
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001088 return;
1089 }
Jacob Erlbeck7d5157e2016-02-01 18:15:35 +01001090 if (tbf->state_is(GPRS_RLCMAC_WAIT_RELEASE) &&
1091 tbf->direction == new_tbf->direction)
Daniel Willmanne4818152014-08-15 16:52:09 +02001092 tbf_free(tbf);
1093
1094 new_tbf->set_state(GPRS_RLCMAC_FLOW);
1095 if ((new_tbf->state_flags &
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001096 (1 << GPRS_RLCMAC_FLAG_TO_UL_ASS))) {
Daniel Willmanne4818152014-08-15 16:52:09 +02001097 new_tbf->state_flags &=
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001098 ~(1 << GPRS_RLCMAC_FLAG_TO_UL_ASS);
1099 LOGP(DRLCMAC, LOGL_NOTICE, "Recovered uplink "
Daniel Willmanne4818152014-08-15 16:52:09 +02001100 "assignment for UL %s\n", tbf_name(new_tbf));
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001101 }
Daniel Willmanne4818152014-08-15 16:52:09 +02001102 tbf_assign_control_ts(new_tbf);
Jacob Erlbeckc8cbfc22015-09-01 11:38:40 +02001103 /* there might be LLC packets waiting in the queue, but the DL
1104 * TBF might have been released while the UL TBF has been
1105 * established */
1106 if (new_tbf->ms()->need_dl_tbf())
1107 new_tbf->establish_dl_tbf_on_pacch();
1108
Holger Hans Peter Freyther396f4162013-10-27 11:02:05 +01001109 return;
1110 }
1111 LOGP(DRLCMAC, LOGL_ERROR, "Error: received PACET CONTROL ACK "
1112 "at no request\n");
1113}
1114
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001115static void get_rx_qual_meas(struct pcu_l1_meas *meas, uint8_t rx_qual_enc)
1116{
1117 static const int16_t rx_qual_map[] = {
1118 0, /* 0,14 % */
1119 0, /* 0,28 % */
1120 1, /* 0,57 % */
1121 1, /* 1,13 % */
1122 2, /* 2,26 % */
1123 5, /* 4,53 % */
1124 9, /* 9,05 % */
1125 18, /* 18,10 % */
1126 };
1127
1128 meas->set_ms_rx_qual(rx_qual_map[
1129 OSMO_MIN(rx_qual_enc, ARRAY_SIZE(rx_qual_map)-1)
1130 ]);
1131}
1132
1133static void get_meas(struct pcu_l1_meas *meas,
1134 const Packet_Resource_Request_t *qr)
1135{
1136 unsigned i;
1137
1138 meas->set_ms_c_value(qr->C_VALUE);
1139 if (qr->Exist_SIGN_VAR)
1140 meas->set_ms_sign_var((qr->SIGN_VAR + 2) / 4); /* SIGN_VAR * 0.25 dB */
1141
1142 for (i = 0; i < OSMO_MIN(ARRAY_SIZE(qr->Slot), ARRAY_SIZE(meas->ts)); i++)
1143 {
Jacob Erlbeckda1a79e2015-06-11 18:09:00 +02001144 if (qr->Slot[i].Exist) {
1145 LOGP(DRLCMAC, LOGL_INFO,
1146 "Packet resource request: i_level[%d] = %d\n",
1147 i, qr->Slot[i].I_LEVEL);
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001148 meas->set_ms_i_level(i, -2 * qr->Slot[i].I_LEVEL);
Jacob Erlbeckda1a79e2015-06-11 18:09:00 +02001149 }
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001150 }
1151}
1152
1153static void get_meas(struct pcu_l1_meas *meas,
1154 const Channel_Quality_Report_t *qr)
1155{
1156 unsigned i;
1157
1158 get_rx_qual_meas(meas, qr->RXQUAL);
1159 meas->set_ms_c_value(qr->C_VALUE);
1160 meas->set_ms_sign_var((qr->SIGN_VAR + 2) / 4); /* SIGN_VAR * 0.25 dB */
1161
1162 for (i = 0; i < OSMO_MIN(ARRAY_SIZE(qr->Slot), ARRAY_SIZE(meas->ts)); i++)
1163 {
Jacob Erlbeckda1a79e2015-06-11 18:09:00 +02001164 if (qr->Slot[i].Exist) {
1165 LOGP(DRLCMAC, LOGL_INFO,
1166 "Channel quality report: i_level[%d] = %d\n",
1167 i, qr->Slot[i].I_LEVEL_TN);
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001168 meas->set_ms_i_level(i, -2 * qr->Slot[i].I_LEVEL_TN);
Jacob Erlbeckda1a79e2015-06-11 18:09:00 +02001169 }
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001170 }
1171}
1172
Holger Hans Peter Freyther5da20142013-10-27 11:41:01 +01001173void gprs_rlcmac_pdch::rcv_control_dl_ack_nack(Packet_Downlink_Ack_Nack_t *ack_nack, uint32_t fn)
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001174{
1175 int8_t tfi = 0; /* must be signed */
Daniel Willmann6c813fc2014-07-30 19:12:27 +02001176 struct gprs_rlcmac_dl_tbf *tbf;
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001177 int rc;
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001178 struct pcu_l1_meas meas;
Jacob Erlbeck419b0342016-01-14 13:40:01 +01001179 int num_blocks;
1180 uint8_t bits_data[RLC_GPRS_WS/8];
1181 bitvec bits;
1182 int bsn_begin, bsn_end;
1183 char show_bits[RLC_GPRS_WS + 1];
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001184
Holger Hans Peter Freyther5da20142013-10-27 11:41:01 +01001185 tfi = ack_nack->DOWNLINK_TFI;
Daniel Willmannfebf1a02014-07-02 17:58:16 +02001186 tbf = bts()->dl_tbf_by_poll_fn(fn, trx_no(), ts_no);
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001187 if (!tbf) {
1188 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET DOWNLINK ACK with "
1189 "unknown FN=%u TFI=%d (TRX %d TS %d)\n",
1190 fn, tfi, trx_no(), ts_no);
1191 return;
1192 }
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +01001193 if (tbf->tfi() != tfi) {
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001194 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET DOWNLINK ACK with "
1195 "wrong TFI=%d, ignoring!\n", tfi);
1196 return;
1197 }
Maxaae1bfb2017-07-07 13:49:29 +02001198
1199 if (tbf->handle_ack_nack())
1200 LOGP(DRLCMAC, LOGL_NOTICE, "Recovered downlink ack for %s\n", tbf_name(tbf));
1201
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +01001202 LOGP(DRLCMAC, LOGL_DEBUG, "RX: [PCU <- BTS] %s Packet Downlink Ack/Nack\n", tbf_name(tbf));
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001203
Jacob Erlbeck419b0342016-01-14 13:40:01 +01001204 bits.data = bits_data;
1205 bits.data_len = sizeof(bits_data);
1206 bits.cur_bit = 0;
1207
1208 num_blocks = Decoding::decode_gprs_acknack_bits(
1209 &ack_nack->Ack_Nack_Description, &bits,
1210 &bsn_begin, &bsn_end, &tbf->m_window);
1211
1212 LOGP(DRLCMAC, LOGL_DEBUG,
1213 "Got GPRS DL ACK bitmap: SSN: %d, BSN %d to %d - 1 (%d blocks), "
1214 "\"%s\"\n",
1215 ack_nack->Ack_Nack_Description.STARTING_SEQUENCE_NUMBER,
1216 bsn_begin, bsn_end, num_blocks,
1217 (Decoding::extract_rbb(&bits, show_bits), show_bits));
1218
Daniel Willmannfc03bbe2014-05-30 17:57:59 +02001219 rc = tbf->rcvd_dl_ack(
Holger Hans Peter Freyther5da20142013-10-27 11:41:01 +01001220 ack_nack->Ack_Nack_Description.FINAL_ACK_INDICATION,
Jacob Erlbeck419b0342016-01-14 13:40:01 +01001221 bsn_begin, &bits);
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001222 if (rc == 1) {
1223 tbf_free(tbf);
1224 return;
1225 }
1226 /* check for channel request */
Holger Hans Peter Freyther5da20142013-10-27 11:41:01 +01001227 if (ack_nack->Exist_Channel_Request_Description) {
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001228
sivasankari168911b2016-11-25 19:53:36 +05301229 bts()->channel_request_description();
1230
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001231 /* This call will register the new TBF with the MS on success */
aravind sirsikared3413e2016-11-11 17:15:10 +05301232 gprs_rlcmac_ul_tbf *ul_tbf = tbf_alloc_ul(bts_data(),
1233 tbf->trx->trx_no,
Jacob Erlbeck86b6f052015-11-27 15:17:34 +01001234 tbf->ms_class(), tbf->ms()->egprs_ms_class(),
Jacob Erlbecke2e004e2015-06-18 17:16:26 +02001235 tbf->tlli(), tbf->ta(), tbf->ms());
Jacob Erlbeckd3eac282015-05-22 15:47:55 +02001236
aravind sirsikared3413e2016-11-11 17:15:10 +05301237 /* schedule uplink assignment or reject*/
1238 if (ul_tbf) {
1239 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF in ack "
1240 "message, so we provide one:\n");
1241 tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_SEND_ASS;
1242 } else {
1243 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF in ack "
1244 "message, so we pacekt access reject:\n");
1245 tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_SEND_ASS_REJ;
1246 }
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001247 }
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001248 /* get measurements */
1249 if (tbf->ms()) {
1250 get_meas(&meas, &ack_nack->Channel_Quality_Report);
1251 tbf->ms()->update_l1_meas(&meas);
1252 }
Holger Hans Peter Freyther5a965812013-10-27 11:07:17 +01001253}
1254
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001255void gprs_rlcmac_pdch::rcv_control_egprs_dl_ack_nack(EGPRS_PD_AckNack_t *ack_nack, uint32_t fn)
1256{
1257 int8_t tfi = 0; /* must be signed */
1258 struct gprs_rlcmac_dl_tbf *tbf;
1259 struct pcu_l1_meas meas;
1260 int rc;
1261 int num_blocks;
1262 uint8_t bits_data[RLC_EGPRS_MAX_WS/8];
1263 char show_bits[RLC_EGPRS_MAX_WS + 1];
1264 bitvec bits;
1265 int bsn_begin, bsn_end;
1266
1267 tfi = ack_nack->DOWNLINK_TFI;
1268 tbf = bts()->dl_tbf_by_poll_fn(fn, trx_no(), ts_no);
1269 if (!tbf) {
1270 LOGP(DRLCMAC, LOGL_NOTICE, "EGPRS PACKET DOWNLINK ACK with "
1271 "unknown FN=%u TFI=%d (TRX %d TS %d)\n",
1272 fn, tfi, trx_no(), ts_no);
1273 return;
1274 }
1275 if (tbf->tfi() != tfi) {
1276 LOGP(DRLCMAC, LOGL_NOTICE, "EGPRS PACKET DOWNLINK ACK with "
1277 "wrong TFI=%d, ignoring!\n", tfi);
1278 return;
1279 }
Maxaae1bfb2017-07-07 13:49:29 +02001280
1281 if (tbf->handle_ack_nack())
1282 LOGP(DRLCMAC, LOGL_NOTICE, "Recovered EGPRS downlink ack for %s\n", tbf_name(tbf));
1283
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001284 LOGP(DRLCMAC, LOGL_DEBUG,
1285 "RX: [PCU <- BTS] %s EGPRS Packet Downlink Ack/Nack\n",
1286 tbf_name(tbf));
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001287
1288 LOGP(DRLCMAC, LOGL_DEBUG, "EGPRS ACK/NACK: "
1289 "ut: %d, final: %d, bow: %d, eow: %d, ssn: %d, have_crbb: %d, "
1290 "urbb_len:%d, %p, %p, %d, %d, win: %d-%d, urbb: %s\n",
1291 (int)ack_nack->EGPRS_AckNack.UnionType,
1292 (int)ack_nack->EGPRS_AckNack.Desc.FINAL_ACK_INDICATION,
1293 (int)ack_nack->EGPRS_AckNack.Desc.BEGINNING_OF_WINDOW,
1294 (int)ack_nack->EGPRS_AckNack.Desc.END_OF_WINDOW,
1295 (int)ack_nack->EGPRS_AckNack.Desc.STARTING_SEQUENCE_NUMBER,
1296 (int)ack_nack->EGPRS_AckNack.Desc.Exist_CRBB,
1297 (int)ack_nack->EGPRS_AckNack.Desc.URBB_LENGTH,
1298 (void *)&ack_nack->EGPRS_AckNack.UnionType,
1299 (void *)&ack_nack->EGPRS_AckNack.Desc,
1300 (int)offsetof(EGPRS_AckNack_t, Desc),
1301 (int)offsetof(EGPRS_AckNack_w_len_t, Desc),
1302 tbf->m_window.v_a(),
1303 tbf->m_window.v_s(),
1304 osmo_hexdump((const uint8_t *)&ack_nack->EGPRS_AckNack.Desc.URBB,
1305 sizeof(ack_nack->EGPRS_AckNack.Desc.URBB)));
1306
1307 bits.data = bits_data;
1308 bits.data_len = sizeof(bits_data);
1309 bits.cur_bit = 0;
1310
1311 num_blocks = Decoding::decode_egprs_acknack_bits(
1312 &ack_nack->EGPRS_AckNack.Desc, &bits,
1313 &bsn_begin, &bsn_end, &tbf->m_window);
1314
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001315 LOGP(DRLCMAC, LOGL_DEBUG,
Jacob Erlbeckd7630f22016-01-14 18:05:44 +01001316 "Got EGPRS DL ACK bitmap: SSN: %d, BSN %d to %d - 1 (%d blocks), "
1317 "\"%s\"\n",
1318 ack_nack->EGPRS_AckNack.Desc.STARTING_SEQUENCE_NUMBER,
1319 bsn_begin, bsn_end, num_blocks,
1320 (Decoding::extract_rbb(&bits, show_bits), show_bits)
1321 );
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001322
Jacob Erlbeckd7630f22016-01-14 18:05:44 +01001323 rc = tbf->rcvd_dl_ack(
1324 ack_nack->EGPRS_AckNack.Desc.FINAL_ACK_INDICATION,
1325 bsn_begin, &bits);
1326 if (rc == 1) {
1327 tbf_free(tbf);
1328 return;
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001329 }
1330
1331 /* check for channel request */
1332 if (ack_nack->Exist_ChannelRequestDescription) {
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001333
sivasankari168911b2016-11-25 19:53:36 +05301334 bts()->channel_request_description();
1335
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001336 /* This call will register the new TBF with the MS on success */
aravind sirsikared3413e2016-11-11 17:15:10 +05301337 gprs_rlcmac_ul_tbf *ul_tbf = tbf_alloc_ul(bts_data(),
1338 tbf->trx->trx_no,
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001339 tbf->ms_class(), tbf->ms()->egprs_ms_class(),
1340 tbf->tlli(), tbf->ta(), tbf->ms());
1341
aravind sirsikared3413e2016-11-11 17:15:10 +05301342 /* schedule uplink assignment or reject*/
1343 if (ul_tbf) {
1344 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF in ack "
1345 "message, so we provide one:\n");
1346 tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_SEND_ASS;
1347 } else {
1348 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF in ack "
1349 "message, so we send packet access reject:\n");
1350 tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_SEND_ASS_REJ;
1351 }
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001352 }
1353
1354 /* get measurements */
1355 if (tbf->ms()) {
1356 /* TODO: Implement Measurements parsing for EGPRS */
1357 /*
1358 get_meas(&meas, &ack_nack->Channel_Quality_Report);
1359 tbf->ms()->update_l1_meas(&meas);
1360 */
1361 }
1362}
1363
Holger Hans Peter Freyther7a344712013-10-27 11:37:53 +01001364void gprs_rlcmac_pdch::rcv_resource_request(Packet_Resource_Request_t *request, uint32_t fn)
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001365{
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001366 struct gprs_rlcmac_sba *sba;
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001367
Holger Hans Peter Freyther7a344712013-10-27 11:37:53 +01001368 if (request->ID.UnionType) {
Jacob Erlbecke43460b2015-05-13 13:33:12 +02001369 struct gprs_rlcmac_ul_tbf *ul_tbf = NULL;
1370 struct gprs_rlcmac_dl_tbf *dl_tbf = NULL;
Holger Hans Peter Freyther80216442013-10-27 15:42:25 +01001371 uint32_t tlli = request->ID.u.TLLI;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001372 uint8_t ms_class = 0;
Jacob Erlbeckc3c58042015-09-28 17:55:32 +02001373 uint8_t egprs_ms_class = 0;
Max9bbe1602016-07-18 12:50:18 +02001374 uint8_t ta = GSM48_TA_INVALID;
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001375 struct pcu_l1_meas meas;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001376
Jacob Erlbecke43460b2015-05-13 13:33:12 +02001377 GprsMs *ms = bts()->ms_by_tlli(tlli);
1378 /* Keep the ms, even if it gets idle temporarily */
1379 GprsMs::Guard guard(ms);
1380
1381 if (ms) {
1382 ul_tbf = ms->ul_tbf();
1383 dl_tbf = ms->dl_tbf();
Jacob Erlbeck9200ce62015-05-22 17:48:04 +02001384 ta = ms->ta();
Jacob Erlbecke43460b2015-05-13 13:33:12 +02001385 }
1386
Jacob Erlbeck5f93f852016-01-21 20:48:39 +01001387 /* We got a RACH so the MS was in packet idle mode and thus
1388 * didn't have any active TBFs */
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001389 if (ul_tbf) {
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001390 LOGP(DRLCMACUL, LOGL_NOTICE, "Got RACH from "
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +01001391 "TLLI=0x%08x while %s still "
Jacob Erlbeck537b1492015-08-21 17:52:07 +02001392 "exists. Killing pending UL TBF\n",
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001393 tlli, tbf_name(ul_tbf));
1394 tbf_free(ul_tbf);
1395 ul_tbf = NULL;
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001396 }
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001397
Jacob Erlbeckcf6ae9d2015-08-31 14:32:05 +02001398 if (dl_tbf) {
1399 LOGP(DRLCMACUL, LOGL_NOTICE, "Got RACH from "
1400 "TLLI=0x%08x while %s still exists. "
Jacob Erlbeckae0a7992015-09-01 11:28:25 +02001401 "Release pending DL TBF\n", tlli,
Jacob Erlbeckcf6ae9d2015-08-31 14:32:05 +02001402 tbf_name(dl_tbf));
Jacob Erlbeck5f93f852016-01-21 20:48:39 +01001403 tbf_free(dl_tbf);
1404 dl_tbf = NULL;
Jacob Erlbeckcf6ae9d2015-08-31 14:32:05 +02001405 }
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001406 LOGP(DRLCMAC, LOGL_DEBUG, "MS requests UL TBF "
1407 "in packet resource request of single "
1408 "block, so we provide one:\n");
1409 sba = bts()->sba()->find(this, fn);
1410 if (!sba) {
1411 LOGP(DRLCMAC, LOGL_NOTICE, "MS requests UL TBF "
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001412 "in packet resource request of single "
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001413 "block, but there is no resource request "
1414 "scheduled!\n");
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001415 } else {
1416 ta = sba->ta;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001417 bts()->sba()->free_sba(sba);
1418 }
Jacob Erlbeckc3c58042015-09-28 17:55:32 +02001419 if (request->Exist_MS_Radio_Access_capability) {
1420 ms_class = Decoding::get_ms_class_by_capability(
1421 &request->MS_Radio_Access_capability);
1422 egprs_ms_class =
1423 Decoding::get_egprs_ms_class_by_capability(
1424 &request->MS_Radio_Access_capability);
1425 }
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001426 if (!ms_class)
1427 LOGP(DRLCMAC, LOGL_NOTICE, "MS does not give us a class.\n");
Jacob Erlbeckc3c58042015-09-28 17:55:32 +02001428 if (egprs_ms_class)
1429 LOGP(DRLCMAC, LOGL_NOTICE,
1430 "MS supports EGPRS multislot class %d.\n",
1431 egprs_ms_class);
Jacob Erlbeck86b6f052015-11-27 15:17:34 +01001432 ul_tbf = tbf_alloc_ul(bts_data(), trx_no(), ms_class,
1433 egprs_ms_class, tlli, ta, ms);
aravind sirsikare9a138e2017-01-24 12:36:08 +05301434
1435 if (!ul_tbf) {
1436 handle_tbf_reject(bts_data(), ms, tlli,
1437 trx_no(), ts_no);
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001438 return;
aravind sirsikare9a138e2017-01-24 12:36:08 +05301439 }
Daniel Willmanne4818152014-08-15 16:52:09 +02001440
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001441 /* set control ts to current MS's TS, until assignment complete */
1442 LOGP(DRLCMAC, LOGL_DEBUG, "Change control TS to %d until assinment is complete.\n", ts_no);
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001443 ul_tbf->control_ts = ts_no;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001444 /* schedule uplink assignment */
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001445 ul_tbf->ul_ass_state = GPRS_RLCMAC_UL_ASS_SEND_ASS;
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001446
Jacob Erlbeckc3c58042015-09-28 17:55:32 +02001447 /* get capabilities */
1448 if (ul_tbf->ms())
1449 ul_tbf->ms()->set_egprs_ms_class(egprs_ms_class);
1450
Jacob Erlbeck51b11512015-06-11 16:54:50 +02001451 /* get measurements */
1452 if (ul_tbf->ms()) {
1453 get_meas(&meas, request);
1454 ul_tbf->ms()->update_l1_meas(&meas);
1455 }
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001456 return;
1457 }
1458
1459 if (request->ID.u.Global_TFI.UnionType) {
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001460 struct gprs_rlcmac_dl_tbf *dl_tbf;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001461 int8_t tfi = request->ID.u.Global_TFI.u.DOWNLINK_TFI;
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001462 dl_tbf = bts()->dl_tbf_by_tfi(tfi, trx_no(), ts_no);
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001463 if (!dl_tbf) {
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001464 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET RESSOURCE REQ unknown downlink TFI=%d\n", tfi);
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001465 return;
1466 }
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001467 LOGP(DRLCMAC, LOGL_ERROR,
1468 "RX: [PCU <- BTS] %s FIXME: Packet resource request\n",
1469 tbf_name(dl_tbf));
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001470 } else {
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001471 struct gprs_rlcmac_ul_tbf *ul_tbf;
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001472 int8_t tfi = request->ID.u.Global_TFI.u.UPLINK_TFI;
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001473 ul_tbf = bts()->ul_tbf_by_tfi(tfi, trx_no(), ts_no);
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001474 if (!ul_tbf) {
Holger Hans Peter Freyther6b88cdd2013-10-27 15:44:21 +01001475 LOGP(DRLCMAC, LOGL_NOTICE, "PACKET RESSOURCE REQ unknown uplink TFI=%d\n", tfi);
1476 return;
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001477 }
Daniel Willmann0d12a2f2014-07-10 17:44:07 +02001478 LOGP(DRLCMAC, LOGL_ERROR,
1479 "RX: [PCU <- BTS] %s FIXME: Packet resource request\n",
1480 tbf_name(ul_tbf));
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001481 }
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001482}
1483
Holger Hans Peter Freythercb5c49b2013-10-27 11:19:13 +01001484void gprs_rlcmac_pdch::rcv_measurement_report(Packet_Measurement_Report_t *report, uint32_t fn)
Holger Hans Peter Freyther750ca672013-10-27 11:16:20 +01001485{
1486 struct gprs_rlcmac_sba *sba;
1487
1488 sba = bts()->sba()->find(this, fn);
1489 if (!sba) {
1490 LOGP(DRLCMAC, LOGL_NOTICE, "MS send measurement "
1491 "in packet resource request of single "
1492 "block, but there is no resource request "
Holger Hans Peter Freyther53a336f2013-10-27 12:47:48 +01001493 "scheduled! TLLI=0x%08x\n", report->TLLI);
Holger Hans Peter Freyther750ca672013-10-27 11:16:20 +01001494 } else {
Jacob Erlbeck1db67e02015-05-22 18:02:51 +02001495 GprsMs *ms = bts()->ms_store().get_ms(report->TLLI);
1496 if (!ms)
1497 LOGP(DRLCMAC, LOGL_NOTICE, "MS send measurement "
1498 "but TLLI 0x%08x is unknown\n", report->TLLI);
1499 else
1500 ms->set_ta(sba->ta);
1501
Holger Hans Peter Freyther750ca672013-10-27 11:16:20 +01001502 bts()->sba()->free_sba(sba);
1503 }
Holger Hans Peter Freythercb5c49b2013-10-27 11:19:13 +01001504 gprs_rlcmac_meas_rep(report);
Holger Hans Peter Freyther750ca672013-10-27 11:16:20 +01001505}
1506
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001507/* Received Uplink RLC control block. */
1508int gprs_rlcmac_pdch::rcv_control_block(
Harald Welte717cdf52017-07-21 21:56:23 +02001509 const uint8_t *data, uint8_t data_len, bitvec *rlc_block, uint32_t fn)
Holger Hans Peter Freyther84280882013-10-27 11:11:18 +01001510{
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001511 RlcMacUplink_t * ul_control_block = (RlcMacUplink_t *)talloc_zero(tall_pcu_ctx, RlcMacUplink_t);
1512 LOGP(DRLCMAC, LOGL_DEBUG, "+++++++++++++++++++++++++ RX : Uplink Control Block +++++++++++++++++++++++++\n");
1513 decode_gsm_rlcmac_uplink(rlc_block, ul_control_block);
1514 LOGPC(DCSN1, LOGL_NOTICE, "\n");
1515 LOGP(DRLCMAC, LOGL_DEBUG, "------------------------- RX : Uplink Control Block -------------------------\n");
Harald Welte717cdf52017-07-21 21:56:23 +02001516
1517 if (ul_control_block->u.MESSAGE_TYPE == MT_PACKET_UPLINK_DUMMY_CONTROL_BLOCK)
1518 bts()->send_gsmtap(PCU_GSMTAP_C_UL_DUMMY, true, trx_no(), ts_no, GSMTAP_CHANNEL_PACCH, fn, data, data_len);
1519 else
1520 bts()->send_gsmtap(PCU_GSMTAP_C_UL_CTRL, true, trx_no(), ts_no, GSMTAP_CHANNEL_PACCH, fn, data, data_len);
1521
Mrinal Mishraf86307e2016-11-10 18:16:30 +05301522 bts()->rlc_rcvd_control();
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001523 switch (ul_control_block->u.MESSAGE_TYPE) {
1524 case MT_PACKET_CONTROL_ACK:
Holger Hans Peter Freythere1a075a2013-10-27 13:35:30 +01001525 rcv_control_ack(&ul_control_block->u.Packet_Control_Acknowledgement, fn);
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001526 break;
1527 case MT_PACKET_DOWNLINK_ACK_NACK:
Holger Hans Peter Freyther5da20142013-10-27 11:41:01 +01001528 rcv_control_dl_ack_nack(&ul_control_block->u.Packet_Downlink_Ack_Nack, fn);
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001529 break;
Jacob Erlbeckae9c5752016-01-13 13:55:44 +01001530 case MT_EGPRS_PACKET_DOWNLINK_ACK_NACK:
1531 rcv_control_egprs_dl_ack_nack(&ul_control_block->u.Egprs_Packet_Downlink_Ack_Nack, fn);
1532 break;
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001533 case MT_PACKET_RESOURCE_REQUEST:
Holger Hans Peter Freyther7a344712013-10-27 11:37:53 +01001534 rcv_resource_request(&ul_control_block->u.Packet_Resource_Request, fn);
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001535 break;
1536 case MT_PACKET_MEASUREMENT_REPORT:
Holger Hans Peter Freythercb5c49b2013-10-27 11:19:13 +01001537 rcv_measurement_report(&ul_control_block->u.Packet_Measurement_Report, fn);
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001538 break;
Holger Hans Peter Freytherc1ae2262013-10-27 10:50:35 +01001539 case MT_PACKET_UPLINK_DUMMY_CONTROL_BLOCK:
1540 /* ignoring it. change the SI to not force sending these? */
1541 break;
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001542 default:
Holger Hans Peter Freyther15877642013-10-27 09:50:15 +01001543 bts()->decode_error();
Holger Hans Peter Freyther180def92013-10-27 10:36:37 +01001544 LOGP(DRLCMAC, LOGL_NOTICE,
1545 "RX: [PCU <- BTS] unknown control block(%d) received\n",
1546 ul_control_block->u.MESSAGE_TYPE);
Holger Hans Peter Freytherfcbc7022013-10-26 17:38:37 +02001547 }
1548 talloc_free(ul_control_block);
1549 return 1;
1550}
1551
Holger Hans Peter Freytherd11290b2013-10-26 17:32:04 +02001552
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001553/* received RLC/MAC block from L1 */
Jacob Erlbeck20f6fd12015-06-08 11:05:45 +02001554int gprs_rlcmac_pdch::rcv_block(uint8_t *data, uint8_t len, uint32_t fn,
1555 struct pcu_l1_meas *meas)
Holger Hans Peter Freyther9ae367f2013-10-26 16:42:38 +02001556{
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001557 GprsCodingScheme cs = GprsCodingScheme::getBySizeUL(len);
1558 if (!cs) {
1559 bts()->decode_error();
1560 LOGP(DRLCMACUL, LOGL_ERROR, "Dropping data block with invalid"
1561 "length: %d)\n", len);
1562 return -EINVAL;
1563 }
1564
Alexander Couzens7fdbf892016-05-21 19:45:23 +02001565 bts()->rlc_ul_bytes(len);
1566
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001567 LOGP(DRLCMACUL, LOGL_DEBUG, "Got RLC block, coding scheme: %s, "
Jacob Erlbeckfc1b3e62016-01-11 09:58:11 +01001568 "length: %d (%d))\n", cs.name(), len, cs.usedSizeUL());
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001569
1570 if (cs.isGprs())
Harald Welte717cdf52017-07-21 21:56:23 +02001571 return rcv_block_gprs(data, len, fn, meas, cs);
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001572
Jacob Erlbeck690a7342015-11-30 18:09:17 +01001573 if (cs.isEgprs())
Harald Welte717cdf52017-07-21 21:56:23 +02001574 return rcv_data_block(data, len, fn, meas, cs);
Jacob Erlbeck690a7342015-11-30 18:09:17 +01001575
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001576 bts()->decode_error();
1577 LOGP(DRLCMACUL, LOGL_ERROR, "Unsupported coding scheme %s\n",
1578 cs.name());
1579 return -EINVAL;
1580}
1581
Alexander Couzens2fcfc292016-05-24 14:40:03 +02001582/*! \brief process egprs and gprs data blocks */
Harald Welte717cdf52017-07-21 21:56:23 +02001583int gprs_rlcmac_pdch::rcv_data_block(uint8_t *data, uint8_t data_len, uint32_t fn,
Jacob Erlbeck690a7342015-11-30 18:09:17 +01001584 struct pcu_l1_meas *meas, GprsCodingScheme cs)
1585{
Jacob Erlbeck39c6c7f2015-12-08 15:14:05 +01001586 int rc;
Jacob Erlbeckf2ba4cb2016-01-07 18:59:28 +01001587 struct gprs_rlc_data_info rlc_dec;
Jacob Erlbeck39c6c7f2015-12-08 15:14:05 +01001588 struct gprs_rlcmac_ul_tbf *tbf;
Jacob Erlbeckfc1b3e62016-01-11 09:58:11 +01001589 unsigned len = cs.sizeUL();
Jacob Erlbeck39c6c7f2015-12-08 15:14:05 +01001590
1591 /* These are always data blocks, since EGPRS still uses CS-1 for
1592 * control blocks (see 44.060, section 10.3, 1st par.)
1593 */
Jacob Erlbeck554a8352015-12-09 17:39:56 +01001594 if (cs.isEgprs()) {
1595 if (!bts()->bts_data()->egprs_enabled) {
1596 LOGP(DRLCMACUL, LOGL_ERROR,
1597 "Got %s RLC block but EGPRS is not enabled\n",
1598 cs.name());
1599 return -EINVAL;
1600 }
Harald Welte717cdf52017-07-21 21:56:23 +02001601 bts()->send_gsmtap(PCU_GSMTAP_C_UL_DATA_EGPRS, true, trx_no(), ts_no, GSMTAP_CHANNEL_PACCH, fn, data, data_len);
1602 } else {
1603 bts()->send_gsmtap(PCU_GSMTAP_C_UL_DATA_GPRS, true, trx_no(), ts_no, GSMTAP_CHANNEL_PACCH, fn, data, data_len);
Jacob Erlbeck690a7342015-11-30 18:09:17 +01001604 }
1605
Jacob Erlbeckd88bb2e2015-12-11 14:53:29 +01001606 LOGP(DRLCMACUL, LOGL_DEBUG, " UL data: %s\n", osmo_hexdump(data, len));
1607
Jacob Erlbeck39c6c7f2015-12-08 15:14:05 +01001608 rc = Decoding::rlc_parse_ul_data_header(&rlc_dec, data, cs);
1609 if (rc < 0) {
1610 LOGP(DRLCMACUL, LOGL_ERROR,
1611 "Got %s RLC block but header parsing has failed\n",
1612 cs.name());
1613 bts()->decode_error();
1614 return rc;
1615 }
1616
1617 LOGP(DRLCMACUL, LOGL_INFO,
1618 "Got %s RLC block: "
1619 "R=%d, SI=%d, TFI=%d, CPS=%d, RSB=%d, "
1620 "rc=%d\n",
1621 cs.name(),
1622 rlc_dec.r, rlc_dec.si, rlc_dec.tfi, rlc_dec.cps, rlc_dec.rsb,
1623 rc);
1624
1625 /* find TBF inst from given TFI */
1626 tbf = ul_tbf_by_tfi(rlc_dec.tfi);
1627 if (!tbf) {
1628 LOGP(DRLCMACUL, LOGL_NOTICE, "UL DATA unknown TFI=%d\n",
1629 rlc_dec.tfi);
1630 return 0;
1631 }
1632
Jacob Erlbeckfc1b3e62016-01-11 09:58:11 +01001633 return tbf->rcv_data_block_acknowledged(&rlc_dec, data, meas);
Jacob Erlbeck690a7342015-11-30 18:09:17 +01001634}
1635
Harald Welte717cdf52017-07-21 21:56:23 +02001636int gprs_rlcmac_pdch::rcv_block_gprs(uint8_t *data, uint8_t data_len, uint32_t fn,
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001637 struct pcu_l1_meas *meas, GprsCodingScheme cs)
1638{
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001639 unsigned payload = data[0] >> 6;
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001640 bitvec *block;
1641 int rc = 0;
Jacob Erlbeck9e862e12015-12-14 15:19:12 +01001642 unsigned len = cs.maxBytesUL();
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001643
1644 switch (payload) {
1645 case GPRS_RLCMAC_DATA_BLOCK:
Harald Welte717cdf52017-07-21 21:56:23 +02001646 rc = rcv_data_block(data, data_len, fn, meas, cs);
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001647 break;
1648 case GPRS_RLCMAC_CONTROL_BLOCK:
Alexander Couzensccde5c92017-02-04 03:10:08 +01001649 block = bitvec_alloc(len, tall_pcu_ctx);
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001650 if (!block)
1651 return -ENOMEM;
1652 bitvec_unpack(block, data);
Harald Welte717cdf52017-07-21 21:56:23 +02001653 rc = rcv_control_block(data, data_len, block, fn);
Holger Hans Peter Freyther6f9f4342013-10-26 16:54:10 +02001654 bitvec_free(block);
1655 break;
1656 case GPRS_RLCMAC_CONTROL_BLOCK_OPT:
1657 LOGP(DRLCMAC, LOGL_NOTICE, "GPRS_RLCMAC_CONTROL_BLOCK_OPT block payload is not supported.\n");
1658 break;
1659 default:
1660 LOGP(DRLCMAC, LOGL_NOTICE, "Unknown RLCMAC block payload(%u).\n", payload);
1661 rc = -EINVAL;
1662 }
1663
1664 return rc;
Holger Hans Peter Freyther9ae367f2013-10-26 16:42:38 +02001665}
Daniel Willmann1e0c6102014-06-04 14:56:09 +02001666
Maxd71e8b32016-09-19 16:17:06 +02001667void bts_update_tbf_ta(const char *p, uint32_t fn, uint8_t trx_no, uint8_t ts,
1668 uint8_t ta)
1669{
1670 struct gprs_rlcmac_ul_tbf *tbf =
1671 bts_main_data()->bts->ul_tbf_by_poll_fn(fn, trx_no, ts);
1672 if (!tbf)
1673 LOGP(DL1IF, LOGL_DEBUG, "[%s] update TA = %u ignored due to "
1674 "unknown UL TBF on TRX = %d, TS = %d, FN = %d\n",
1675 p, ta, trx_no, ts, fn);
1676 else if (tbf->ta() != ta) {
1677 LOGP(DL1IF, LOGL_INFO, "[%s] Updating TA %u -> %u on "
1678 "TRX = %d, TS = %d, FN = %d\n",
1679 p, tbf->ta(), ta, trx_no, ts, fn);
1680 tbf->set_ta(ta);
1681 }
1682}
1683
Jacob Erlbecked2dbf62015-12-28 19:15:40 +01001684gprs_rlcmac_tbf *gprs_rlcmac_pdch::tbf_from_list_by_tfi(
1685 LListHead<gprs_rlcmac_tbf> *tbf_list, uint8_t tfi,
Daniel Willmann2207c5e2014-07-10 17:44:06 +02001686 enum gprs_rlcmac_tbf_direction dir)
Daniel Willmann1e0c6102014-06-04 14:56:09 +02001687{
Daniel Willmann17a1d5e2014-05-30 20:21:30 +02001688 gprs_rlcmac_tbf *tbf;
Jacob Erlbecked2dbf62015-12-28 19:15:40 +01001689 LListHead<gprs_rlcmac_tbf> *pos;
Daniel Willmann17a1d5e2014-05-30 20:21:30 +02001690
Jacob Erlbecked2dbf62015-12-28 19:15:40 +01001691 llist_for_each(pos, tbf_list) {
1692 tbf = pos->entry();
Daniel Willmann17a1d5e2014-05-30 20:21:30 +02001693 if (tbf->tfi() != tfi)
1694 continue;
1695 if (!tbf->pdch[ts_no])
1696 continue;
1697 return tbf;
1698 }
1699 return NULL;
Daniel Willmann1e0c6102014-06-04 14:56:09 +02001700}
1701
Daniel Willmannfe6e2e42014-07-10 17:44:06 +02001702gprs_rlcmac_ul_tbf *gprs_rlcmac_pdch::ul_tbf_by_tfi(uint8_t tfi)
Daniel Willmann1e0c6102014-06-04 14:56:09 +02001703{
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +01001704 return as_ul_tbf(tbf_by_tfi(tfi, GPRS_RLCMAC_UL_TBF));
Daniel Willmann17a1d5e2014-05-30 20:21:30 +02001705}
1706
Daniel Willmannfe6e2e42014-07-10 17:44:06 +02001707gprs_rlcmac_dl_tbf *gprs_rlcmac_pdch::dl_tbf_by_tfi(uint8_t tfi)
Daniel Willmann17a1d5e2014-05-30 20:21:30 +02001708{
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +01001709 return as_dl_tbf(tbf_by_tfi(tfi, GPRS_RLCMAC_DL_TBF));
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001710}
1711
1712/* lookup TBF Entity (by TFI) */
1713gprs_rlcmac_tbf *gprs_rlcmac_pdch::tbf_by_tfi(uint8_t tfi,
1714 enum gprs_rlcmac_tbf_direction dir)
1715{
1716 struct gprs_rlcmac_tbf *tbf;
1717
1718 if (tfi >= 32)
1719 return NULL;
1720
1721 tbf = m_tbfs[dir][tfi];
1722
1723 if (!tbf)
1724 return NULL;
1725
1726 if (tbf->state_is_not(GPRS_RLCMAC_RELEASING)) {
1727 return tbf;
1728 }
1729
1730 return NULL;
Daniel Willmann1e0c6102014-06-04 14:56:09 +02001731}
Jacob Erlbeckccc34e42015-06-29 13:45:05 +02001732
1733void gprs_rlcmac_pdch::attach_tbf(gprs_rlcmac_tbf *tbf)
1734{
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001735 gprs_rlcmac_ul_tbf *ul_tbf;
1736
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001737 if (m_tbfs[tbf->direction][tbf->tfi()])
1738 LOGP(DRLCMAC, LOGL_ERROR, "PDCH(TS %d, TRX %d): "
1739 "%s has not been detached, overwriting it\n",
1740 ts_no, trx_no(),
1741 m_tbfs[tbf->direction][tbf->tfi()]->name());
1742
Jacob Erlbeckccc34e42015-06-29 13:45:05 +02001743 m_num_tbfs[tbf->direction] += 1;
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001744 if (tbf->direction == GPRS_RLCMAC_UL_TBF) {
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +01001745 ul_tbf = as_ul_tbf(tbf);
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001746 m_assigned_usf |= 1 << ul_tbf->m_usf[ts_no];
1747 }
Jacob Erlbeck47a57f62015-07-08 12:53:16 +02001748 m_assigned_tfi[tbf->direction] |= 1UL << tbf->tfi();
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001749 m_tbfs[tbf->direction][tbf->tfi()] = tbf;
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001750
1751 LOGP(DRLCMAC, LOGL_INFO, "PDCH(TS %d, TRX %d): Attaching %s, %d TBFs, "
1752 "USFs = %02x, TFIs = %08x.\n",
1753 ts_no, trx_no(), tbf->name(), m_num_tbfs[tbf->direction],
Jacob Erlbeck47a57f62015-07-08 12:53:16 +02001754 m_assigned_usf, m_assigned_tfi[tbf->direction]);
Jacob Erlbeckccc34e42015-06-29 13:45:05 +02001755}
1756
1757void gprs_rlcmac_pdch::detach_tbf(gprs_rlcmac_tbf *tbf)
1758{
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001759 gprs_rlcmac_ul_tbf *ul_tbf;
1760
Jacob Erlbeckccc34e42015-06-29 13:45:05 +02001761 OSMO_ASSERT(m_num_tbfs[tbf->direction] > 0);
1762
1763 m_num_tbfs[tbf->direction] -= 1;
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001764 if (tbf->direction == GPRS_RLCMAC_UL_TBF) {
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +01001765 ul_tbf = as_ul_tbf(tbf);
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001766 m_assigned_usf &= ~(1 << ul_tbf->m_usf[ts_no]);
1767 }
Jacob Erlbeck47a57f62015-07-08 12:53:16 +02001768 m_assigned_tfi[tbf->direction] &= ~(1UL << tbf->tfi());
Jacob Erlbeck3a10dbd2015-07-10 19:52:37 +02001769 m_tbfs[tbf->direction][tbf->tfi()] = NULL;
Jacob Erlbeckcc9358f2015-06-30 14:10:13 +02001770
1771 LOGP(DRLCMAC, LOGL_INFO, "PDCH(TS %d, TRX %d): Detaching %s, %d TBFs, "
1772 "USFs = %02x, TFIs = %08x.\n",
1773 ts_no, trx_no(), tbf->name(), m_num_tbfs[tbf->direction],
Jacob Erlbeck47a57f62015-07-08 12:53:16 +02001774 m_assigned_usf, m_assigned_tfi[tbf->direction]);
Jacob Erlbeckccc34e42015-06-29 13:45:05 +02001775}
Jacob Erlbeck23f93a12015-06-30 08:52:54 +02001776
1777void gprs_rlcmac_pdch::reserve(enum gprs_rlcmac_tbf_direction dir)
1778{
1779 m_num_reserved[dir] += 1;
1780}
1781
1782void gprs_rlcmac_pdch::unreserve(enum gprs_rlcmac_tbf_direction dir)
1783{
1784 OSMO_ASSERT(m_num_reserved[dir] > 0);
1785 m_num_reserved[dir] -= 1;
1786}
1787
1788void gprs_rlcmac_trx::reserve_slots(enum gprs_rlcmac_tbf_direction dir,
1789 uint8_t slots)
1790{
1791 unsigned i;
1792 for (i = 0; i < ARRAY_SIZE(pdch); i += 1)
1793 if (slots & (1 << i))
1794 pdch[i].reserve(dir);
1795}
1796
1797void gprs_rlcmac_trx::unreserve_slots(enum gprs_rlcmac_tbf_direction dir,
1798 uint8_t slots)
1799{
1800 unsigned i;
1801 for (i = 0; i < ARRAY_SIZE(pdch); i += 1)
1802 if (slots & (1 << i))
1803 pdch[i].unreserve(dir);
1804}