blob: f57dbe3c5eb4850c72b82169264fec40ee05c1d8 [file] [log] [blame]
Holger Hans Peter Freyther17c31ce2013-08-24 18:31:27 +02001/*
2 * Copyright (C) 2013 by Holger Hans Peter Freyther
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License
6 * as published by the Free Software Foundation; either version 2
7 * of the License, or (at your option) any later version.
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
17 */
18
19#pragma once
20
Daniel Willmannafa72f52014-01-15 17:06:19 +010021#ifdef __cplusplus
22
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +020023#include "gprs_rlcmac.h"
Holger Hans Peter Freytherbe570812013-11-07 08:01:49 +010024#include "llc.h"
Holger Hans Peter Freyther6b5660c2013-11-23 16:10:48 +010025#include "rlc.h"
Jacob Erlbeck6835cea2015-08-21 15:24:02 +020026#include "cxx_linuxlist.h"
Daniel Willmanneb100242014-08-08 11:43:53 +020027#include <gprs_debug.h>
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +020028
Holger Hans Peter Freyther17c31ce2013-08-24 18:31:27 +020029#include <stdint.h>
Maxe66de5b2017-01-05 18:26:58 +010030extern "C" {
31#include <osmocom/core/utils.h>
32}
Holger Hans Peter Freyther17c31ce2013-08-24 18:31:27 +020033
Holger Hans Peter Freyther1702f102013-10-20 08:44:02 +020034struct bssgp_bvc_ctx;
Jacob Erlbeck20f6fd12015-06-08 11:05:45 +020035struct pcu_l1_meas;
Jacob Erlbeckfecece02015-05-08 12:13:08 +020036class GprsMs;
Holger Hans Peter Freyther1702f102013-10-20 08:44:02 +020037
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020038/*
39 * TBF instance
40 */
41
Maxb2de1f72017-12-20 18:05:29 +010042#define T_ASS_AGCH_USEC 200000 /* waiting after IMM.ASS confirm */
43#define T_ASS_PACCH_SEC 2 /* timeout for pacch assigment */
44#define T_REJ_PACCH_USEC 2000 /* timeout for tbf reject for PRR*/
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020045
46enum gprs_rlcmac_tbf_state {
47 GPRS_RLCMAC_NULL = 0, /* new created TBF */
Neels Hofmeyr4ea45262016-06-08 15:27:40 +020048 GPRS_RLCMAC_ASSIGN, /* wait for downlink assignment */
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020049 GPRS_RLCMAC_FLOW, /* RLC/MAC flow, resource needed */
50 GPRS_RLCMAC_FINISHED, /* flow finished, wait for release */
51 GPRS_RLCMAC_WAIT_RELEASE,/* wait for release or restart of DL TBF */
52 GPRS_RLCMAC_RELEASING, /* releasing, wait to free TBI/USF */
53};
54
Maxf60cf622017-07-10 14:40:09 +020055enum gprs_rlcmac_tbf_poll_type {
56 GPRS_RLCMAC_POLL_UL_ASS,
57 GPRS_RLCMAC_POLL_DL_ASS,
58 GPRS_RLCMAC_POLL_UL_ACK,
59 GPRS_RLCMAC_POLL_DL_ACK,
60};
61
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020062enum gprs_rlcmac_tbf_poll_state {
63 GPRS_RLCMAC_POLL_NONE = 0,
64 GPRS_RLCMAC_POLL_SCHED, /* a polling was scheduled */
65};
66
67enum gprs_rlcmac_tbf_dl_ass_state {
68 GPRS_RLCMAC_DL_ASS_NONE = 0,
69 GPRS_RLCMAC_DL_ASS_SEND_ASS, /* send downlink assignment on next RTS */
70 GPRS_RLCMAC_DL_ASS_WAIT_ACK, /* wait for PACKET CONTROL ACK */
71};
72
Maxe66de5b2017-01-05 18:26:58 +010073extern const struct value_string gprs_rlcmac_tbf_dl_ass_state_names[];
74
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020075enum gprs_rlcmac_tbf_ul_ass_state {
76 GPRS_RLCMAC_UL_ASS_NONE = 0,
77 GPRS_RLCMAC_UL_ASS_SEND_ASS, /* send uplink assignment on next RTS */
aravind sirsikared3413e2016-11-11 17:15:10 +053078 GPRS_RLCMAC_UL_ASS_SEND_ASS_REJ, /* send assignment reject next RTS */
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020079 GPRS_RLCMAC_UL_ASS_WAIT_ACK, /* wait for PACKET CONTROL ACK */
80};
81
Maxe66de5b2017-01-05 18:26:58 +010082extern const struct value_string gprs_rlcmac_tbf_ul_ass_state_names[];
83
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +020084enum gprs_rlcmac_tbf_ul_ack_state {
85 GPRS_RLCMAC_UL_ACK_NONE = 0,
86 GPRS_RLCMAC_UL_ACK_SEND_ACK, /* send acknowledge on next RTS */
87 GPRS_RLCMAC_UL_ACK_WAIT_ACK, /* wait for PACKET CONTROL ACK */
88};
89
90enum gprs_rlcmac_tbf_direction {
91 GPRS_RLCMAC_DL_TBF,
92 GPRS_RLCMAC_UL_TBF
93};
94
sivasankari53950732016-12-08 17:15:17 +053095enum tbf_counters {
96 TBF_CTR_RLC_NACKED,
97};
98
99enum tbf_gprs_counters {
100 TBF_CTR_GPRS_DL_CS1,
101 TBF_CTR_GPRS_DL_CS2,
102 TBF_CTR_GPRS_DL_CS3,
103 TBF_CTR_GPRS_DL_CS4,
104};
105
106enum tbf_egprs_counters {
107 TBF_CTR_EGPRS_DL_MCS1,
108 TBF_CTR_EGPRS_DL_MCS2,
109 TBF_CTR_EGPRS_DL_MCS3,
110 TBF_CTR_EGPRS_DL_MCS4,
111 TBF_CTR_EGPRS_DL_MCS5,
112 TBF_CTR_EGPRS_DL_MCS6,
113 TBF_CTR_EGPRS_DL_MCS7,
114 TBF_CTR_EGPRS_DL_MCS8,
115 TBF_CTR_EGPRS_DL_MCS9,
116};
117
sivasankarida7250a2016-12-16 12:57:18 +0530118enum tbf_gprs_ul_counters {
119 TBF_CTR_GPRS_UL_CS1,
120 TBF_CTR_GPRS_UL_CS2,
121 TBF_CTR_GPRS_UL_CS3,
122 TBF_CTR_GPRS_UL_CS4,
123};
124
125enum tbf_egprs_ul_counters {
126 TBF_CTR_EGPRS_UL_MCS1,
127 TBF_CTR_EGPRS_UL_MCS2,
128 TBF_CTR_EGPRS_UL_MCS3,
129 TBF_CTR_EGPRS_UL_MCS4,
130 TBF_CTR_EGPRS_UL_MCS5,
131 TBF_CTR_EGPRS_UL_MCS6,
132 TBF_CTR_EGPRS_UL_MCS7,
133 TBF_CTR_EGPRS_UL_MCS8,
134 TBF_CTR_EGPRS_UL_MCS9,
135};
136
Maxc21f0072017-12-15 17:36:45 +0100137#define LOGPTBF(tbf, level, fmt, args...) LOGP(DRLCMAC, level, "%s " fmt, tbf_name(tbf), ## args)
138#define LOGPTBFUL(tbf, level, fmt, args...) LOGP(DRLCMACUL, level, "%s " fmt, tbf_name(tbf), ## args)
139#define LOGPTBFDL(tbf, level, fmt, args...) LOGP(DRLCMACDL, level, "%s " fmt, tbf_name(tbf), ## args)
140
Maxee5be3a2017-12-20 17:31:13 +0100141enum tbf_timers {
Maxb2de1f72017-12-20 18:05:29 +0100142 /* internal assign/reject timer */
143 T0,
144
Maxee5be3a2017-12-20 17:31:13 +0100145 /* Wait for reuse of USF and TFI(s) after the MS uplink assignment for this TBF is invalid. */
146 T3169,
147
148 /* Wait for reuse of TFI(s) after sending of the last RLC Data Block on this TBF.
149 Wait for reuse of TFI(s) after sending the PACKET TBF RELEASE for an MBMS radio bearer. */
150 T3191,
151
152 /* Wait for reuse of TFI(s) after reception of the final PACKET DOWNLINK ACK/NACK from the
153 MS for this TBF. */
154 T3193,
155
156 /* Wait for reuse of TFI(s) when there is no response from the MS
157 (radio failure or cell change) for this TBF/MBMS radio bearer. */
158 T3195,
159 T_MAX
160};
161
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +0200162#define GPRS_RLCMAC_FLAG_CCCH 0 /* assignment on CCCH */
163#define GPRS_RLCMAC_FLAG_PACCH 1 /* assignment on PACCH */
164#define GPRS_RLCMAC_FLAG_UL_DATA 2 /* uplink data received */
165#define GPRS_RLCMAC_FLAG_DL_ACK 3 /* downlink acknowledge received */
166#define GPRS_RLCMAC_FLAG_TO_UL_ACK 4
167#define GPRS_RLCMAC_FLAG_TO_DL_ACK 5
168#define GPRS_RLCMAC_FLAG_TO_UL_ASS 6
169#define GPRS_RLCMAC_FLAG_TO_DL_ASS 7
170#define GPRS_RLCMAC_FLAG_TO_MASK 0xf0 /* timeout bits */
171
Max467f6332017-12-20 18:13:29 +0100172#define T_START(tbf, t, sec, usec, r, f) tbf->t_start(t, sec, usec, r, f, __FILE__, __LINE__)
173
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200174struct gprs_rlcmac_tbf {
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200175 gprs_rlcmac_tbf(BTS *bts_, gprs_rlcmac_tbf_direction dir);
Holger Hans Peter Freyther964ddb62013-10-16 17:53:23 +0200176
177 static void free_all(struct gprs_rlcmac_trx *trx);
Holger Hans Peter Freyther4f6a4e5d2013-10-16 17:58:46 +0200178 static void free_all(struct gprs_rlcmac_pdch *pdch);
Holger Hans Peter Freyther964ddb62013-10-16 17:53:23 +0200179
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200180 bool state_is(enum gprs_rlcmac_tbf_state rhs) const;
181 bool state_is_not(enum gprs_rlcmac_tbf_state rhs) const;
182 void set_state(enum gprs_rlcmac_tbf_state new_state);
Daniel Willmann08e57c82014-08-15 18:11:57 +0200183 const char *state_name() const;
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200184
Jacob Erlbeckadcdf152015-03-03 14:45:55 +0100185 const char *name() const;
186
Jacob Erlbeck5a3c84d2016-01-22 17:25:38 +0100187 struct msgb *create_dl_ass(uint32_t fn, uint8_t ts);
188 struct msgb *create_ul_ass(uint32_t fn, uint8_t ts);
aravind sirsikared3413e2016-11-11 17:15:10 +0530189 struct msgb *create_packet_access_reject();
Holger Hans Peter Freyther2db7e7e2013-10-26 20:45:35 +0200190
Jacob Erlbeck10ed7952015-06-02 11:37:22 +0200191 GprsMs *ms() const;
Jacob Erlbeckfecece02015-05-08 12:13:08 +0200192 void set_ms(GprsMs *ms);
193
Jacob Erlbeck13965ae2016-01-19 14:10:40 +0100194 gprs_rlc_window *window();
195
Holger Hans Peter Freyther8f399de2013-12-25 20:22:35 +0100196 uint8_t tsc() const;
Holger Hans Peter Freythera1da2512013-11-07 07:32:51 +0100197
Holger Hans Peter Freyther7380bab2013-10-16 18:09:19 +0200198 int rlcmac_diag();
Holger Hans Peter Freyther964ddb62013-10-16 17:53:23 +0200199
Jacob Erlbecke0c734d2015-07-03 14:03:33 +0200200 int update();
Holger Hans Peter Freytheraf8094d2013-10-26 17:56:15 +0200201 void handle_timeout();
Maxee5be3a2017-12-20 17:31:13 +0100202 void stop_timers(const char *reason);
203 bool timers_pending(enum tbf_timers t);
204 void t_stop(enum tbf_timers t, const char *reason);
Max467f6332017-12-20 18:13:29 +0100205 void t_start(enum tbf_timers t, uint32_t sec, uint32_t microsec, const char *reason, bool force,
206 const char *file, unsigned line);
Jacob Erlbeck91ff7d12015-09-01 11:20:29 +0200207 int establish_dl_tbf_on_pacch();
Holger Hans Peter Freytheraa9c3262013-10-26 17:49:36 +0200208
Jacob Erlbeckf2694b72016-01-26 21:46:26 +0100209 int check_polling(uint32_t fn, uint8_t ts,
210 uint32_t *poll_fn, unsigned int *rrbp);
Maxf60cf622017-07-10 14:40:09 +0200211 void set_polling(uint32_t poll_fn, uint8_t ts, enum gprs_rlcmac_tbf_poll_type t);
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200212 void poll_timeout();
213
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100214 /** tlli handling */
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100215 uint32_t tlli() const;
216 bool is_tlli_valid() const;
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100217
Jacob Erlbeckfecece02015-05-08 12:13:08 +0200218 /** MS updating */
Jacob Erlbeckbe0cbc12015-05-18 14:35:11 +0200219 void update_ms(uint32_t tlli, enum gprs_rlcmac_tbf_direction);
Jacob Erlbeckfecece02015-05-08 12:13:08 +0200220
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +0100221 uint8_t tfi() const;
Jacob Erlbeck6b356a52016-01-29 16:39:21 +0100222 bool is_tfi_assigned() const;
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +0100223
Holger Hans Peter Freyther5464c9b2013-10-27 20:57:35 +0100224 const char *imsi() const;
225 void assign_imsi(const char *imsi);
Jacob Erlbeck9200ce62015-05-22 17:48:04 +0200226 uint8_t ta() const;
227 void set_ta(uint8_t);
Jacob Erlbeckbefc7602015-06-02 12:33:30 +0200228 uint8_t ms_class() const;
229 void set_ms_class(uint8_t);
Jacob Erlbeckcb728902016-01-05 15:33:03 +0100230 GprsCodingScheme current_cs() const;
Max869c0c22018-01-03 12:00:36 +0100231 size_t llc_queue_size() const;
Holger Hans Peter Freyther5464c9b2013-10-27 20:57:35 +0100232
Holger Hans Peter Freythera0047992014-01-16 10:07:20 +0100233 time_t created_ts() const;
Jacob Erlbeck617c7122015-06-30 09:18:30 +0200234 uint8_t dl_slots() const;
235 uint8_t ul_slots() const;
Daniel Willmann80367aa2014-01-15 17:40:28 +0100236
Jacob Erlbeck646da1b2016-01-22 17:41:33 +0100237 bool is_control_ts(uint8_t ts) const;
238
Jacob Erlbeck5643f352015-11-27 16:17:40 +0100239 /* EGPRS */
240 bool is_egprs_enabled() const;
Jacob Erlbeck5643f352015-11-27 16:17:40 +0100241 void disable_egprs();
242
Holger Hans Peter Freyther7a5f3c22013-11-26 13:08:12 +0100243 /* attempt to make things a bit more fair */
244 void rotate_in_list();
245
Jacob Erlbeck6835cea2015-08-21 15:24:02 +0200246 LListHead<gprs_rlcmac_tbf>& ms_list() {return this->m_ms_list;}
247 const LListHead<gprs_rlcmac_tbf>& ms_list() const {return this->m_ms_list;}
248
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100249 LListHead<gprs_rlcmac_tbf>& list();
250 const LListHead<gprs_rlcmac_tbf>& list() const;
251
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200252 uint32_t state_flags;
253 enum gprs_rlcmac_tbf_direction direction;
Holger Hans Peter Freyther743bafa2013-09-29 07:50:50 +0200254 struct gprs_rlcmac_trx *trx;
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200255 uint8_t first_ts; /* first TS used by TBF */
256 uint8_t first_common_ts; /* first TS that the phone can send and
257 reveive simultaniously */
258 uint8_t control_ts; /* timeslot control messages and polling */
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200259 struct gprs_rlcmac_pdch *pdch[8]; /* list of PDCHs allocated to TBF */
Holger Hans Peter Freyther28e53782013-11-06 20:23:56 +0100260
261 gprs_llc m_llc;
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200262
263 enum gprs_rlcmac_tbf_dl_ass_state dl_ass_state;
264 enum gprs_rlcmac_tbf_ul_ass_state ul_ass_state;
265 enum gprs_rlcmac_tbf_ul_ack_state ul_ack_state;
266
267 enum gprs_rlcmac_tbf_poll_state poll_state;
268 uint32_t poll_fn; /* frame number to poll */
Jacob Erlbeck8eb17142016-01-22 17:58:17 +0100269 uint8_t poll_ts; /* TS to poll */
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200270
Holger Hans Peter Freyther9241fd02013-11-13 19:51:55 +0100271 gprs_rlc m_rlc;
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200272
273 uint8_t n3105; /* N3105 counter */
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200274
275 struct osmo_gsm_timer_list gsm_timer;
276 unsigned int fT; /* fTxxxx number */
277 unsigned int num_fT_exp; /* number of consecutive fT expirations */
278
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200279 struct Meas {
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200280 struct timeval rssi_tv; /* timestamp for rssi calculation */
281 int32_t rssi_sum; /* sum of rssi values */
282 int rssi_num; /* number of rssi values added since rssi_tv */
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200283
284 Meas();
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200285 } meas;
286
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200287 /* these should become protected but only after gprs_rlcmac_data.c
288 * stops to iterate over all tbf in its current form */
289 enum gprs_rlcmac_tbf_state state;
Holger Hans Peter Freyther9f0c1d22013-10-19 21:24:34 +0200290
Daniel Willmann73191a42014-05-30 17:58:00 +0200291 /* Remember if the tbf was in wait_release state when we want to
292 * schedule a new dl assignment */
293 uint8_t was_releasing;
294
Daniel Willmanncf1fae72014-05-30 17:58:01 +0200295 /* Can/should we upgrade this tbf to use multiple slots? */
296 uint8_t upgrade_to_multislot;
297
Holger Hans Peter Freyther9f0c1d22013-10-19 21:24:34 +0200298 /* store the BTS this TBF belongs to */
299 BTS *bts;
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200300
Max59e4a4f2017-12-20 18:01:55 +0100301 uint8_t m_n3101; /* N3101 counter */
302
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100303 /*
304 * private fields. We can't make it private as it is breaking the
305 * llist macros.
306 */
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +0100307 uint8_t m_tfi;
Holger Hans Peter Freythera0047992014-01-16 10:07:20 +0100308 time_t m_created_ts;
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100309
sivasankari53950732016-12-08 17:15:17 +0530310 struct rate_ctr_group *m_ctrs;
311
Holger Hans Peter Freytherd9262b32013-10-26 20:12:59 +0200312protected:
313 gprs_rlcmac_bts *bts_data() const;
Max25a3ca42017-12-13 18:47:52 +0100314 void enable_egprs();
Jacob Erlbecke8f5fe52015-12-14 13:23:15 +0100315 int set_tlli_from_ul(uint32_t new_tlli);
Jacob Erlbeck28c40b12015-08-16 18:19:32 +0200316 void merge_and_clear_ms(GprsMs *old_ms);
Holger Hans Peter Freyther4c06d912013-11-25 23:05:26 +0100317
Alexander Couzensd38b92e2016-08-21 19:38:30 +0200318 gprs_llc_queue *llc_queue();
319 const gprs_llc_queue *llc_queue() const;
320
Neels Hofmeyr4ea45262016-06-08 15:27:40 +0200321 static const char *tbf_state_name[6];
Jacob Erlbeckadcdf152015-03-03 14:45:55 +0100322
Jacob Erlbeckfecece02015-05-08 12:13:08 +0200323 class GprsMs *m_ms;
Jacob Erlbeck9200ce62015-05-22 17:48:04 +0200324
Jacob Erlbeckbefc7602015-06-02 12:33:30 +0200325 /* Fields to take the TA/MS class values if no MS is associated */
Jacob Erlbeck9200ce62015-05-22 17:48:04 +0200326 uint8_t m_ta;
Jacob Erlbeckbefc7602015-06-02 12:33:30 +0200327 uint8_t m_ms_class;
Jacob Erlbeck6dbe8222015-05-29 10:37:09 +0200328
Jacob Erlbeckadcdf152015-03-03 14:45:55 +0100329private:
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100330 LListHead<gprs_rlcmac_tbf> m_list;
Jacob Erlbeck6835cea2015-08-21 15:24:02 +0200331 LListHead<gprs_rlcmac_tbf> m_ms_list;
Jacob Erlbeck5643f352015-11-27 16:17:40 +0100332 bool m_egprs_enabled;
Maxb2de1f72017-12-20 18:05:29 +0100333 struct osmo_timer_list T[T_MAX];
Jacob Erlbeckadcdf152015-03-03 14:45:55 +0100334 mutable char m_name_buf[60];
Holger Hans Peter Freyther099535a2013-10-16 17:42:31 +0200335};
336
Holger Hans Peter Freyther17c31ce2013-08-24 18:31:27 +0200337
Daniel Willmann0d12a2f2014-07-10 17:44:07 +0200338struct gprs_rlcmac_ul_tbf *tbf_alloc_ul(struct gprs_rlcmac_bts *bts,
Jacob Erlbeck86b6f052015-11-27 15:17:34 +0100339 int8_t use_trx, uint8_t ms_class, uint8_t egprs_ms_class,
Jacob Erlbecke2e004e2015-06-18 17:16:26 +0200340 uint32_t tlli, uint8_t ta, GprsMs *ms);
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +0200341
Daniel Willmann48aa0b02014-07-16 18:54:10 +0200342struct gprs_rlcmac_ul_tbf *tbf_alloc_ul_tbf(struct gprs_rlcmac_bts *bts,
Jacob Erlbeck5879c642015-07-10 10:41:36 +0200343 GprsMs *ms, int8_t use_trx,
Jacob Erlbeck86b6f052015-11-27 15:17:34 +0100344 uint8_t ms_class, uint8_t egprs_ms_class, uint8_t single_slot);
Daniel Willmann48aa0b02014-07-16 18:54:10 +0200345
346struct gprs_rlcmac_dl_tbf *tbf_alloc_dl_tbf(struct gprs_rlcmac_bts *bts,
Jacob Erlbeck5879c642015-07-10 10:41:36 +0200347 GprsMs *ms, int8_t use_trx,
Jacob Erlbeck86b6f052015-11-27 15:17:34 +0100348 uint8_t ms_class, uint8_t egprs_ms_class, uint8_t single_slot);
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +0200349
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +0200350void tbf_free(struct gprs_rlcmac_tbf *tbf);
351
aravind sirsikare9a138e2017-01-24 12:36:08 +0530352struct gprs_rlcmac_ul_tbf *handle_tbf_reject(struct gprs_rlcmac_bts *bts,
353 GprsMs *ms, uint32_t tlli, uint8_t trx_no, uint8_t ts_no);
354
Holger Hans Peter Freyther9e21d842013-10-16 17:48:12 +0200355int tbf_assign_control_ts(struct gprs_rlcmac_tbf *tbf);
356
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200357inline bool gprs_rlcmac_tbf::state_is(enum gprs_rlcmac_tbf_state rhs) const
358{
359 return state == rhs;
360}
361
362inline bool gprs_rlcmac_tbf::state_is_not(enum gprs_rlcmac_tbf_state rhs) const
363{
364 return state != rhs;
365}
366
Daniel Willmanneb100242014-08-08 11:43:53 +0200367const char *tbf_name(gprs_rlcmac_tbf *tbf);
368
Daniel Willmann08e57c82014-08-15 18:11:57 +0200369inline const char *gprs_rlcmac_tbf::state_name() const
370{
371 return tbf_state_name[state];
372}
373
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200374inline void gprs_rlcmac_tbf::set_state(enum gprs_rlcmac_tbf_state new_state)
375{
Daniel Willmanneb100242014-08-08 11:43:53 +0200376 LOGP(DRLCMAC, LOGL_DEBUG, "%s changes state from %s to %s\n",
377 tbf_name(this),
378 tbf_state_name[state], tbf_state_name[new_state]);
Holger Hans Peter Freyther1c344e22013-10-16 18:33:18 +0200379 state = new_state;
380}
Holger Hans Peter Freytherbd449f52013-10-27 16:39:36 +0100381
Jacob Erlbecked2dbf62015-12-28 19:15:40 +0100382inline LListHead<gprs_rlcmac_tbf>& gprs_rlcmac_tbf::list()
383{
384 return this->m_list;
385}
386
387inline const LListHead<gprs_rlcmac_tbf>& gprs_rlcmac_tbf::list() const
388{
389 return this->m_list;
390}
391
Jacob Erlbeck10ed7952015-06-02 11:37:22 +0200392inline GprsMs *gprs_rlcmac_tbf::ms() const
Jacob Erlbeckfecece02015-05-08 12:13:08 +0200393{
394 return m_ms;
395}
396
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100397inline bool gprs_rlcmac_tbf::is_tlli_valid() const
398{
Jacob Erlbeck767193e2015-05-20 12:06:46 +0200399 return tlli() != 0;
Holger Hans Peter Freyther474685e2013-10-27 17:01:14 +0100400}
401
Jacob Erlbeck6b356a52016-01-29 16:39:21 +0100402inline bool gprs_rlcmac_tbf::is_tfi_assigned() const
403{
404 /* The TBF is established or has been assigned by a IMM.ASS for
405 * download */
Neels Hofmeyr4ea45262016-06-08 15:27:40 +0200406 return state > GPRS_RLCMAC_ASSIGN ||
407 (direction == GPRS_RLCMAC_DL_TBF &&
408 state == GPRS_RLCMAC_ASSIGN &&
409 (state_flags & (1 << GPRS_RLCMAC_FLAG_CCCH)));
Jacob Erlbeck6b356a52016-01-29 16:39:21 +0100410}
411
Holger Hans Peter Freyther34f6e5e2013-10-27 20:31:47 +0100412inline uint8_t gprs_rlcmac_tbf::tfi() const
413{
414 return m_tfi;
415}
416
Holger Hans Peter Freythera0047992014-01-16 10:07:20 +0100417inline time_t gprs_rlcmac_tbf::created_ts() const
Daniel Willmann80367aa2014-01-15 17:40:28 +0100418{
Holger Hans Peter Freythera0047992014-01-16 10:07:20 +0100419 return m_created_ts;
Daniel Willmann80367aa2014-01-15 17:40:28 +0100420}
421
Jacob Erlbeck5643f352015-11-27 16:17:40 +0100422inline bool gprs_rlcmac_tbf::is_egprs_enabled() const
423{
424 return m_egprs_enabled;
425}
426
427inline void gprs_rlcmac_tbf::enable_egprs()
428{
429 m_egprs_enabled = true;
430}
431
432inline void gprs_rlcmac_tbf::disable_egprs()
433{
434 m_egprs_enabled = false;
435}
436
Daniel Willmann078bb712014-07-10 17:44:06 +0200437struct gprs_rlcmac_dl_tbf : public gprs_rlcmac_tbf {
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200438 gprs_rlcmac_dl_tbf(BTS *bts);
Jacob Erlbeck444bc822015-08-20 17:49:03 +0200439
Jacob Erlbeckd0261b72015-04-02 13:58:09 +0200440 void cleanup();
Max25a3ca42017-12-13 18:47:52 +0100441 void enable_egprs();
Daniel Willmann30168882014-08-07 12:48:29 +0200442 /* dispatch Unitdata.DL messages */
443 static int handle(struct gprs_rlcmac_bts *bts,
Jacob Erlbeck93990462015-05-15 15:50:43 +0200444 const uint32_t tlli, const uint32_t old_tlli,
445 const char *imsi, const uint8_t ms_class,
Jacob Erlbeck14e00f82015-11-27 18:10:39 +0100446 const uint8_t egprs_ms_class, const uint16_t delay_csec,
447 const uint8_t *data, const uint16_t len);
Daniel Willmann30168882014-08-07 12:48:29 +0200448
Daniel Willmann538ac5b2014-07-30 19:12:27 +0200449 int append_data(const uint8_t ms_class,
450 const uint16_t pdu_delay_csec,
451 const uint8_t *data, const uint16_t len);
452
Max7df82d42017-12-15 11:14:30 +0100453 int rcvd_dl_ack(bool final, uint8_t ssn, uint8_t *rbb);
454 int rcvd_dl_ack(bool final_ack, unsigned first_bsn, struct bitvec *rbb);
Daniel Willmannb8f26012014-07-30 19:12:28 +0200455 struct msgb *create_dl_acked_block(uint32_t fn, uint8_t ts);
Maxa10c3982017-07-07 18:25:41 +0200456 void trigger_ass(struct gprs_rlcmac_tbf *old_tbf);
Maxaae1bfb2017-07-07 13:49:29 +0200457 void clear_poll_timeout_flag();
458 bool handle_ack_nack();
Jacob Erlbeck7c444152015-03-12 12:08:54 +0100459 void request_dl_ack();
Jacob Erlbeckeceb9102015-03-20 14:41:50 +0100460 bool need_control_ts() const;
461 bool have_data() const;
Jacob Erlbeck005ee7f2015-03-20 14:53:54 +0100462 int frames_since_last_poll(unsigned fn) const;
Jacob Erlbeck3bed5d12015-03-19 11:22:38 +0100463 int frames_since_last_drain(unsigned fn) const;
464 bool keep_open(unsigned fn) const;
Jacob Erlbeck91ff7d12015-09-01 11:20:29 +0200465 int release();
Jacob Erlbeckf04a5b32016-01-21 20:42:40 +0100466 int abort();
Jacob Erlbeckeceb9102015-03-20 14:41:50 +0100467
Aravind Sirsikar8e70bb52016-09-15 17:51:16 +0530468 void egprs_calc_window_size();
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530469 void update_coding_scheme_counter_dl(const GprsCodingScheme cs);
Aravind Sirsikar8e70bb52016-09-15 17:51:16 +0530470
Daniel Willmanncf706b02014-08-07 17:35:22 +0200471 /* TODO: add the gettimeofday as parameter */
472 struct msgb *llc_dequeue(bssgp_bvc_ctx *bctx);
473
Daniel Willmann6a8a1dc2014-08-07 15:14:08 +0200474 /* Please note that all variables here will be reset when changing
475 * from WAIT RELEASE back to FLOW state (re-use of TBF).
476 * All states that need reset must be in this struct, so this is why
477 * variables are in both (dl and ul) structs and not outside union.
478 */
Daniel Willmann7e994e32014-08-07 15:49:21 +0200479 gprs_rlc_dl_window m_window;
480 int32_t m_tx_counter; /* count all transmitted blocks */
481 uint8_t m_wait_confirm; /* wait for CCCH IMM.ASS cnf */
Jacob Erlbeck7c444152015-03-12 12:08:54 +0100482 bool m_dl_ack_requested;
Jacob Erlbeck005ee7f2015-03-20 14:53:54 +0100483 int32_t m_last_dl_poll_fn;
Jacob Erlbeck3bed5d12015-03-19 11:22:38 +0100484 int32_t m_last_dl_drained_fn;
Daniel Willmann6a8a1dc2014-08-07 15:14:08 +0200485
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200486 struct BandWidth {
Daniel Willmann418a4232014-08-08 11:21:04 +0200487 struct timeval dl_bw_tv; /* timestamp for dl bw calculation */
488 uint32_t dl_bw_octets; /* number of octets since bw_tv */
sivasankari53950732016-12-08 17:15:17 +0530489 uint32_t dl_throughput; /* throughput to be displayed in stats */
Daniel Willmann418a4232014-08-08 11:21:04 +0200490
491 struct timeval dl_loss_tv; /* timestamp for loss calculation */
492 uint16_t dl_loss_lost; /* sum of lost packets */
493 uint16_t dl_loss_received; /* sum of received packets */
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200494
495 BandWidth();
Daniel Willmann418a4232014-08-08 11:21:04 +0200496 } m_bw;
497
sivasankari53950732016-12-08 17:15:17 +0530498 struct rate_ctr_group *m_dl_gprs_ctrs;
499 struct rate_ctr_group *m_dl_egprs_ctrs;
500
Daniel Willmannb8f26012014-07-30 19:12:28 +0200501protected:
Jacob Erlbeck2db0f082015-09-07 18:49:00 +0200502 struct ana_result {
503 unsigned received_packets;
504 unsigned lost_packets;
505 unsigned received_bytes;
506 unsigned lost_bytes;
507 };
508
Jacob Erlbeckd6752492016-02-02 18:12:46 +0100509 int take_next_bsn(uint32_t fn, int previous_bsn,
Jacob Erlbeck64e7b832016-02-04 15:16:47 +0100510 bool *may_combine);
Jacob Erlbeckd6752492016-02-02 18:12:46 +0100511 bool restart_bsn_cycle();
512 int create_new_bsn(const uint32_t fn, GprsCodingScheme cs);
Daniel Willmannb8f26012014-07-30 19:12:28 +0200513 struct msgb *create_dl_acked_block(const uint32_t fn, const uint8_t ts,
Jacob Erlbeckbe314d92016-02-02 15:32:10 +0100514 int index, int index2 = -1);
Daniel Willmann30168882014-08-07 12:48:29 +0200515 int update_window(const uint8_t ssn, const uint8_t *rbb);
Jacob Erlbeckeb08f862016-02-05 17:07:12 +0100516 int update_window(unsigned first_bsn, const struct bitvec *rbb);
Daniel Willmann30168882014-08-07 12:48:29 +0200517 int maybe_start_new_window();
518 bool dl_window_stalled() const;
Jacob Erlbeck409efa12015-06-12 14:06:09 +0200519 void reuse_tbf();
Jacob Erlbeckd0261b72015-04-02 13:58:09 +0200520 void start_llc_timer();
Jacob Erlbeck2db0f082015-09-07 18:49:00 +0200521 int analyse_errors(char *show_rbb, uint8_t ssn, ana_result *res);
Jacob Erlbeck409efa12015-06-12 14:06:09 +0200522 void schedule_next_frame();
Jacob Erlbeckd0261b72015-04-02 13:58:09 +0200523
Aravind Sirsikar50b09702016-08-22 17:21:10 +0530524 enum egprs_rlc_dl_reseg_bsn_state egprs_dl_get_data
525 (int bsn, uint8_t **block_data);
526 unsigned int get_egprs_dl_spb_status(int bsn);
527 enum egprs_rlcmac_dl_spb get_egprs_dl_spb(int bsn);
528
Jacob Erlbeckd0261b72015-04-02 13:58:09 +0200529 struct osmo_timer_list m_llc_timer;
Daniel Willmann078bb712014-07-10 17:44:06 +0200530};
531
532struct gprs_rlcmac_ul_tbf : public gprs_rlcmac_tbf {
Jacob Erlbeckb6b3c7e2015-08-28 12:07:14 +0200533 gprs_rlcmac_ul_tbf(BTS *bts);
Jacob Erlbeck444bc822015-08-20 17:49:03 +0200534
Jacob Erlbeck5a3c84d2016-01-22 17:25:38 +0100535 struct msgb *create_ul_ack(uint32_t fn, uint8_t ts);
Maxfd13f6c2017-07-07 14:29:36 +0200536 bool ctrl_ack_to_toggle();
537 bool handle_ctrl_ack();
Max25a3ca42017-12-13 18:47:52 +0100538 void enable_egprs();
Daniel Willmann350f64d2014-08-07 14:54:11 +0200539 /* blocks were acked */
Jacob Erlbeckb3100e12015-12-14 13:36:13 +0100540 int rcv_data_block_acknowledged(
Jacob Erlbeckf2ba4cb2016-01-07 18:59:28 +0100541 const struct gprs_rlc_data_info *rlc,
Jacob Erlbeckfc1b3e62016-01-11 09:58:11 +0100542 uint8_t *data, struct pcu_l1_meas *meas);
Jacob Erlbeckb3100e12015-12-14 13:36:13 +0100543
Daniel Willmann350f64d2014-08-07 14:54:11 +0200544
Daniel Willmanne2732e22014-08-07 17:32:01 +0200545 /* TODO: extract LLC class? */
546 int assemble_forward_llc(const gprs_rlc_data *data);
547 int snd_ul_ud();
548
Aravind Sirsikar505a86d2016-07-26 18:26:21 +0530549 egprs_rlc_ul_reseg_bsn_state handle_egprs_ul_spb(
550 const struct gprs_rlc_data_info *rlc,
551 struct gprs_rlc_data *block,
552 uint8_t *data, const uint8_t block_idx);
553
554 egprs_rlc_ul_reseg_bsn_state handle_egprs_ul_first_seg(
555 const struct gprs_rlc_data_info *rlc,
556 struct gprs_rlc_data *block,
557 uint8_t *data, const uint8_t block_idx);
558
559 egprs_rlc_ul_reseg_bsn_state handle_egprs_ul_second_seg(
560 const struct gprs_rlc_data_info *rlc,
561 struct gprs_rlc_data *block,
562 uint8_t *data, const uint8_t block_idx);
563
sivasankari8adfcd02017-01-16 15:41:21 +0530564 void egprs_calc_ulwindow_size();
565
Mrinal Mishraf86307e2016-11-10 18:16:30 +0530566 void update_coding_scheme_counter_ul(const GprsCodingScheme cs);
567
Daniel Willmann6a8a1dc2014-08-07 15:14:08 +0200568 /* Please note that all variables here will be reset when changing
569 * from WAIT RELEASE back to FLOW state (re-use of TBF).
570 * All states that need reset must be in this struct, so this is why
571 * variables are in both (dl and ul) structs and not outside union.
572 */
Daniel Willmann7e994e32014-08-07 15:49:21 +0200573 gprs_rlc_ul_window m_window;
574 int32_t m_rx_counter; /* count all received blocks */
575 uint8_t m_n3103; /* N3103 counter */
576 uint8_t m_usf[8]; /* list USFs per PDCH (timeslot) */
577 uint8_t m_contention_resolution_done; /* set after done */
578 uint8_t m_final_ack_sent; /* set if we sent final ack */
Daniel Willmann6a8a1dc2014-08-07 15:14:08 +0200579
sivasankarida7250a2016-12-16 12:57:18 +0530580 struct rate_ctr_group *m_ul_gprs_ctrs;
581 struct rate_ctr_group *m_ul_egprs_ctrs;
582
Daniel Willmann350f64d2014-08-07 14:54:11 +0200583protected:
Jacob Erlbeckf2ba4cb2016-01-07 18:59:28 +0100584 void maybe_schedule_uplink_acknack(const gprs_rlc_data_info *rlc);
Daniel Willmann078bb712014-07-10 17:44:06 +0200585};
586
Max701afa42017-12-01 17:13:22 +0100587#ifdef __cplusplus
588extern "C" {
589#endif
590void update_tbf_ta(struct gprs_rlcmac_ul_tbf *tbf, int8_t ta_delta);
591void set_tbf_ta(struct gprs_rlcmac_ul_tbf *tbf, uint8_t ta);
592#ifdef __cplusplus
593}
594#endif
595
Jacob Erlbeckac89a552015-06-29 14:18:46 +0200596inline enum gprs_rlcmac_tbf_direction reverse(enum gprs_rlcmac_tbf_direction dir)
597{
598 return (enum gprs_rlcmac_tbf_direction)
599 ((int)GPRS_RLCMAC_UL_TBF - (int)dir + (int)GPRS_RLCMAC_DL_TBF);
600}
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +0100601
Max25a3ca42017-12-13 18:47:52 +0100602inline void gprs_rlcmac_ul_tbf::enable_egprs()
603{
604 m_window.set_sns(RLC_EGPRS_SNS);
605 gprs_rlcmac_tbf::enable_egprs();
606}
607
608inline void gprs_rlcmac_dl_tbf::enable_egprs()
609{
610 m_window.set_sns(RLC_EGPRS_SNS);
611 gprs_rlcmac_tbf::enable_egprs();
612}
613
Jacob Erlbeckaa9daa12015-12-28 18:49:12 +0100614inline gprs_rlcmac_ul_tbf *as_ul_tbf(gprs_rlcmac_tbf *tbf)
615{
616 if (tbf && tbf->direction == GPRS_RLCMAC_UL_TBF)
617 return static_cast<gprs_rlcmac_ul_tbf *>(tbf);
618 else
619 return NULL;
620}
621
622inline gprs_rlcmac_dl_tbf *as_dl_tbf(gprs_rlcmac_tbf *tbf)
623{
624 if (tbf && tbf->direction == GPRS_RLCMAC_DL_TBF)
625 return static_cast<gprs_rlcmac_dl_tbf *>(tbf);
626 else
627 return NULL;
628}
629
Jacob Erlbeck13965ae2016-01-19 14:10:40 +0100630inline gprs_rlc_window *gprs_rlcmac_tbf::window()
631{
632 switch (direction)
633 {
634 case GPRS_RLCMAC_UL_TBF: return &as_ul_tbf(this)->m_window;
635 case GPRS_RLCMAC_DL_TBF: return &as_dl_tbf(this)->m_window;
636 }
637 return NULL;
638}
639
Daniel Willmannafa72f52014-01-15 17:06:19 +0100640#endif