fixeria has uploaded this change for review.
osmo-bts-trx: prioritize FACCH in s/tx_tch_common()/tch_dl_dequeue()/s
Unlike SACCH, FACCH has no dedicated slots on the multiframe layout.
It's multiplexed together with TCH (speech or data) frames basically
by replacing (stealing) them. This is common for both TCH/F and
TCH/H, with the only difference that FACCH/H steals two TCH frames
(not just one) due to a longer interleaving period.
Let's implement the multiplexing in the common function, which is
used to dequeue to be transmitted frames - this slightly reduces
code duplication. Use a new name, so that it's clear what it does.
Change-Id: I9822b1a17185d5487f0f6d3ed0203e806c053d7d
Related: SYS#5919, OS#4823
---
M src/osmo-bts-trx/sched_lchan_tchf.c
M src/osmo-bts-trx/sched_lchan_tchh.c
M src/osmo-bts-trx/sched_tch.h
3 files changed, 38 insertions(+), 37 deletions(-)
git pull ssh://gerrit.osmocom.org:29418/osmo-bts refs/changes/04/27804/1
diff --git a/src/osmo-bts-trx/sched_lchan_tchf.c b/src/osmo-bts-trx/sched_lchan_tchf.c
index 05cb2bf..5466598 100644
--- a/src/osmo-bts-trx/sched_lchan_tchf.c
+++ b/src/osmo-bts-trx/sched_lchan_tchf.c
@@ -298,10 +298,10 @@
/* obtain a to-be-transmitted TCH/F (Full Traffic Channel) burst */
int tx_tchf_fn(struct l1sched_ts *l1ts, struct trx_dl_burst_req *br)
{
- struct msgb *msg_tch = NULL, *msg_facch = NULL;
struct l1sched_chan_state *chan_state = &l1ts->chan_state[br->chan];
uint8_t tch_mode = chan_state->tch_mode;
ubit_t *burst, **bursts_p = &chan_state->dl_bursts;
+ struct msgb *msg;
/* send burst, if we already got a frame */
if (br->bid > 0) {
@@ -310,8 +310,6 @@
goto send_burst;
}
- tx_tch_common(l1ts, br, &msg_tch, &msg_facch);
-
/* BURST BYPASS */
/* allocate burst memory, if not already,
@@ -325,8 +323,11 @@
memset(*bursts_p + 464, 0, 464);
}
+ /* dequeue a message to be transmitted */
+ msg = tch_dl_dequeue(l1ts, br);
+
/* no message at all, send a dummy L2 frame on FACCH */
- if (!msg_tch && !msg_facch) {
+ if (msg == NULL) {
static const uint8_t dummy[GSM_MACBLOCK_LEN] = {
0x03, 0x03, 0x01, /* TODO: use randomized padding */
0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b,
@@ -338,28 +339,24 @@
goto send_burst;
}
- /* encode bursts (prioritize FACCH) */
- if (msg_facch) {
- gsm0503_tch_fr_encode(*bursts_p, msg_facch->l2h, msgb_l2len(msg_facch),
- 1);
+ /* populate the buffer with bursts */
+ if (msgb_l2len(msg) == GSM_MACBLOCK_LEN) {
+ gsm0503_tch_fr_encode(*bursts_p, msg->l2h, msgb_l2len(msg), 1);
chan_state->dl_facch_bursts = 8;
} else if (tch_mode == GSM48_CMODE_SPEECH_AMR)
/* the first FN 4,13,21 defines that CMI is included in frame,
* the first FN 0,8,17 defines that CMR is included in frame.
*/
- gsm0503_tch_afs_encode(*bursts_p, msg_tch->l2h + 2,
- msgb_l2len(msg_tch) - 2, !dl_amr_fn_is_cmi(br->fn),
+ gsm0503_tch_afs_encode(*bursts_p, msg->l2h + 2,
+ msgb_l2len(msg) - 2, !dl_amr_fn_is_cmi(br->fn),
chan_state->codec, chan_state->codecs,
chan_state->dl_ft,
chan_state->dl_cmr);
else
- gsm0503_tch_fr_encode(*bursts_p, msg_tch->l2h, msgb_l2len(msg_tch), 1);
+ gsm0503_tch_fr_encode(*bursts_p, msg->l2h, msgb_l2len(msg), 1);
/* free message */
- if (msg_tch)
- msgb_free(msg_tch);
- if (msg_facch)
- msgb_free(msg_facch);
+ msgb_free(msg);
send_burst:
/* compose burst */
diff --git a/src/osmo-bts-trx/sched_lchan_tchh.c b/src/osmo-bts-trx/sched_lchan_tchh.c
index a993100..4b021f9 100644
--- a/src/osmo-bts-trx/sched_lchan_tchh.c
+++ b/src/osmo-bts-trx/sched_lchan_tchh.c
@@ -334,10 +334,10 @@
/* obtain a to-be-transmitted TCH/H (Half Traffic Channel) burst */
int tx_tchh_fn(struct l1sched_ts *l1ts, struct trx_dl_burst_req *br)
{
- struct msgb *msg_tch = NULL, *msg_facch = NULL;
struct l1sched_chan_state *chan_state = &l1ts->chan_state[br->chan];
uint8_t tch_mode = chan_state->tch_mode;
ubit_t *burst, **bursts_p = &chan_state->dl_bursts;
+ struct msgb *msg;
/* send burst, if we already got a frame */
if (br->bid > 0) {
@@ -346,9 +346,6 @@
goto send_burst;
}
- /* get TCH and/or FACCH */
- tx_tch_common(l1ts, br, &msg_tch, &msg_facch);
-
/* BURST BYPASS */
/* allocate burst memory, if not already,
@@ -367,8 +364,11 @@
}
}
+ /* dequeue a message to be transmitted */
+ msg = tch_dl_dequeue(l1ts, br);
+
/* no message at all, send a dummy L2 frame on FACCH */
- if (!msg_tch && !msg_facch && !chan_state->dl_ongoing_facch) {
+ if (msg == NULL && !chan_state->dl_ongoing_facch) {
static const uint8_t dummy[GSM_MACBLOCK_LEN] = {
0x03, 0x03, 0x01, /* TODO: use randomized padding */
0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b, 0x2b,
@@ -380,9 +380,9 @@
goto send_burst;
}
- /* encode bursts (prioritize FACCH) */
- if (msg_facch) {
- gsm0503_tch_hr_encode(*bursts_p, msg_facch->l2h, msgb_l2len(msg_facch));
+ /* populate the buffer with bursts */
+ if (msgb_l2len(msg) == GSM_MACBLOCK_LEN) {
+ gsm0503_tch_hr_encode(*bursts_p, msg->l2h, msgb_l2len(msg));
chan_state->dl_ongoing_facch = 1; /* first of two TCH frames */
chan_state->dl_facch_bursts = 6;
} else if (chan_state->dl_ongoing_facch) /* second of two TCH frames */
@@ -391,19 +391,16 @@
/* the first FN 4,13,21 or 5,14,22 defines that CMI is included
* in frame, the first FN 0,8,17 or 1,9,18 defines that CMR is
* included in frame. */
- gsm0503_tch_ahs_encode(*bursts_p, msg_tch->l2h + 2,
- msgb_l2len(msg_tch) - 2, !dl_amr_fn_is_cmi(br->fn),
+ gsm0503_tch_ahs_encode(*bursts_p, msg->l2h + 2,
+ msgb_l2len(msg) - 2, !dl_amr_fn_is_cmi(br->fn),
chan_state->codec, chan_state->codecs,
chan_state->dl_ft,
chan_state->dl_cmr);
else
- gsm0503_tch_hr_encode(*bursts_p, msg_tch->l2h, msgb_l2len(msg_tch));
+ gsm0503_tch_hr_encode(*bursts_p, msg->l2h, msgb_l2len(msg));
/* free message */
- if (msg_tch)
- msgb_free(msg_tch);
- if (msg_facch)
- msgb_free(msg_facch);
+ msgb_free(msg);
send_burst:
/* compose burst */
diff --git a/src/osmo-bts-trx/sched_tch.h b/src/osmo-bts-trx/sched_tch.h
index 3b0b1e8..e77e05d 100644
--- a/src/osmo-bts-trx/sched_tch.h
+++ b/src/osmo-bts-trx/sched_tch.h
@@ -62,8 +62,7 @@
}
/* Common section for generation of Downlink bursts (TCH/H and TCH/F) */
-static inline void tx_tch_common(struct l1sched_ts *l1ts, struct trx_dl_burst_req *br,
- struct msgb **_msg_tch, struct msgb **_msg_facch)
+static inline struct msgb *tch_dl_dequeue(struct l1sched_ts *l1ts, struct trx_dl_burst_req *br)
{
struct msgb *msg1, *msg2, *msg_tch = NULL, *msg_facch = NULL;
struct l1sched_chan_state *chan_state = &l1ts->chan_state[br->chan];
@@ -128,8 +127,19 @@
msg_facch = NULL;
}
+ /* prioritize FACCH over speech */
+ if (msg_facch) {
+ /* Unlike SACCH, FACCH has no dedicated slots on the multiframe layout.
+ * It's multiplexed together with TCH (speech or data) frames basically
+ * by replacing (stealing) them. This is common for both TCH/F and
+ * TCH/H, with the only difference that FACCH/H steals two TCH frames
+ * (not just one) due to a longer interleaving period. */
+ msgb_free(msg_tch);
+ return msg_facch;
+ }
+
/* check validity of message, get AMR ft and cmr */
- if (!msg_facch && msg_tch) {
+ if (msg_tch) {
int len;
uint8_t cmr_codec;
int cmr, ft, i;
@@ -209,11 +219,8 @@
/* free message */
msgb_free(msg_tch);
msg_tch = NULL;
- goto send_frame;
}
}
-send_frame:
- *_msg_tch = msg_tch;
- *_msg_facch = msg_facch;
+ return msg_tch;
}
To view, visit change 27804. To unsubscribe, or for help writing mail filters, visit settings.