aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMax <msuraev@sysmocom.de>2018-01-31 15:22:36 +0100
committerHarald Welte <laforge@gnumonks.org>2018-02-19 09:00:20 +0000
commitadca67bcbbc461bb8ff9c860ded8e8fa23e74aab (patch)
tree210393d48b6f0b10ae22cae80957b94688903b7c
parentf633b8d8b2ce04756530e7000f579085a2660a9b (diff)
Simplify TS alloc: separate capacity computation
Move TRX capacity computation into separate function and document it. Change-Id: Ifd88fc7ff818ea2a041eae61c5d457926a0df0f2 Related: OS#2282
-rw-r--r--src/gprs_rlcmac_ts_alloc.cpp73
-rw-r--r--src/mslot_class.c16
-rw-r--r--src/mslot_class.h1
3 files changed, 50 insertions, 40 deletions
diff --git a/src/gprs_rlcmac_ts_alloc.cpp b/src/gprs_rlcmac_ts_alloc.cpp
index 7be9654d..9c2b9211 100644
--- a/src/gprs_rlcmac_ts_alloc.cpp
+++ b/src/gprs_rlcmac_ts_alloc.cpp
@@ -61,24 +61,6 @@ static bool test_and_set_bit(uint32_t *bits, size_t elem)
return was_set;
}
-static inline int8_t find_free_usf(const struct gprs_rlcmac_pdch *pdch)
-{
- uint8_t usf_map = 0;
- uint8_t usf;
-
- usf_map = pdch->assigned_usf();
- if (usf_map == (1 << 7) - 1)
- return -1;
-
- /* look for USF, don't use USF=7 */
- for (usf = 0; usf < 7; usf++) {
- if (!(usf_map & (1 << usf)))
- return usf;
- }
-
- return -1;
-}
-
static inline int8_t find_free_tfi(const struct gprs_rlcmac_pdch *pdch, enum gprs_rlcmac_tbf_direction dir)
{
uint32_t tfi_map = pdch->assigned_tfi(dir);
@@ -214,7 +196,7 @@ static int find_least_busy_pdch(const struct gprs_rlcmac_trx *trx, enum gprs_rlc
}
/* Make sure that an USF is available */
if (dir == GPRS_RLCMAC_UL_TBF) {
- usf = find_free_usf(pdch);
+ usf = find_free_usf(pdch->assigned_usf());
if (usf < 0) {
LOGP(DRLCMAC, LOGL_DEBUG,
"- Skipping TS %d, because "
@@ -464,6 +446,33 @@ int alloc_algorithm_a(struct gprs_rlcmac_bts *bts, GprsMs *ms_, struct gprs_rlcm
return 0;
}
+/*! Compute capacity of a given TRX
+ *
+ * \param[in] trx Pointer to TRX object
+ * \param[in] rx_window Receive window
+ * \param[in] tx_window Transmit window
+ * \returns non-negative capacity
+ */
+static inline unsigned compute_capacity(const struct gprs_rlcmac_trx *trx, int rx_window, int tx_window)
+{
+ const struct gprs_rlcmac_pdch *pdch;
+ unsigned ts, capacity = 0;
+
+ for (ts = 0; ts < ARRAY_SIZE(trx->pdch); ts++) {
+ pdch = &trx->pdch[ts];
+ if (rx_window & (1 << ts))
+ capacity += OSMO_MAX(32 - pdch->num_reserved(GPRS_RLCMAC_DL_TBF), 1);
+
+ /* Only consider common slots for UL */
+ if (tx_window & rx_window & (1 << ts)) {
+ if (find_free_usf(pdch->assigned_usf()) >= 0)
+ capacity += OSMO_MAX(32 - pdch->num_reserved(GPRS_RLCMAC_UL_TBF), 1);
+ }
+ }
+
+ return capacity;
+}
+
/*! Find set of slots available for allocation while taking MS class into account
*
* \param[in] trx Pointer to TRX object
@@ -564,7 +573,6 @@ int find_multi_slots(struct gprs_rlcmac_trx *trx, uint8_t mslot_class, uint8_t *
unsigned rx_slot_count;
uint16_t rx_bad;
uint8_t rx_good;
- unsigned ts;
int capacity;
/* Filter out bad slots */
@@ -663,25 +671,7 @@ int find_multi_slots(struct gprs_rlcmac_trx *trx, uint8_t mslot_class, uint8_t *
}
/* Compute capacity */
- capacity = 0;
-
- for (ts = 0; ts < ARRAY_SIZE(trx->pdch); ts++) {
- int c;
- const struct gprs_rlcmac_pdch *pdch = &trx->pdch[ts];
- if (rx_window & (1 << ts)) {
- c = 32 - pdch->num_reserved(GPRS_RLCMAC_DL_TBF);
- c = OSMO_MAX(c, 1);
- capacity += c;
- }
- /* Only consider common slots for UL */
- if (tx_window & rx_window & (1 << ts)) {
- if (find_free_usf(pdch) >= 0) {
- c = 32 - pdch->num_reserved(GPRS_RLCMAC_UL_TBF);
- c = OSMO_MAX(c, 1);
- capacity += c;
- }
- }
- }
+ capacity = compute_capacity(trx, rx_window, tx_window);
#ifdef ENABLE_TS_ALLOC_DEBUG
LOGP(DRLCMAC, LOGL_DEBUG,
@@ -702,7 +692,10 @@ int find_multi_slots(struct gprs_rlcmac_trx *trx, uint8_t mslot_class, uint8_t *
max_capacity = capacity;
max_ul_slots = tx_window;
max_dl_slots = rx_window;
- }}}}
+ }
+ }
+ }
+ }
if (!max_ul_slots || !max_dl_slots) {
LOGP(DRLCMAC, LOGL_NOTICE,
diff --git a/src/mslot_class.c b/src/mslot_class.c
index 1c79a214..87e37ca1 100644
--- a/src/mslot_class.c
+++ b/src/mslot_class.c
@@ -212,3 +212,19 @@ void mslot_fill_rx_mask(uint8_t mslot_class, uint8_t num_tx, uint8_t *rx_mask)
rx_mask[MASK_TT] = (rx_mask[MASK_TT] << 3) | (rx_mask[MASK_TT] >> 5);
rx_mask[MASK_TR] = (rx_mask[MASK_TR] << 3) | (rx_mask[MASK_TR] >> 5);
}
+
+/* look for USF, don't use USF=7 */
+int8_t find_free_usf(uint8_t usf_map)
+{
+ uint8_t usf;
+
+ if (usf_map == (1 << 7) - 1)
+ return -1;
+
+ for (usf = 0; usf < 7; usf++) {
+ if (!(usf_map & (1 << usf)))
+ return usf;
+ }
+
+ return -1;
+}
diff --git a/src/mslot_class.h b/src/mslot_class.h
index 4f5a7ff0..d2485262 100644
--- a/src/mslot_class.h
+++ b/src/mslot_class.h
@@ -50,3 +50,4 @@ uint8_t mslot_class_get_type(uint8_t ms_cl);
uint8_t mslot_class_max();
void mslot_fill_rx_mask(uint8_t mslot_class, uint8_t num_tx, uint8_t *rx_mask);
+int8_t find_free_usf(uint8_t usf_map);