This test case processes RSL establish requests for SMS (SAPI 3)
on the SDCCH and the SACCH channels. The TX queues are checked
after processing each message.
Ticket: #225
Sponsored-by: On-Waves ehf
---
tests/lapd/lapd_test.c | 120 +++++++++++++++++++++++++++++++++++++++++------
tests/lapd/lapd_test.ok | 7 +++
2 files changed, 112 insertions(+), 15 deletions(-)
diff --git a/tests/lapd/lapd_test.c b/tests/lapd/lapd_test.c
index 37c0db8..b4594de 100644
--- a/tests/lapd/lapd_test.c
+++ b/tests/lapd/lapd_test.c
@@ -80,6 +80,14 @@ static const uint8_t rel_req[] = {
0x02, 0x07, 0x01, 0x0a, 0x02, 0x40, 0x14, 0x01
};
+static const uint8_t est_req_sdcch_sapi3[] = {
+ 0x02, 0x04, 0x01, 0x20, 0x02, 0x03
+};
+
+static const uint8_t est_req_sacch_sapi3[] = {
+ 0x02, 0x04, 0x01, 0x0b, 0x02, 0x43
+};
+
static struct msgb *create_cm_serv_req(void)
{
struct msgb *msg;
@@ -131,6 +139,16 @@ static struct msgb *create_rel_req(void)
return msg;
}
+static struct msgb *create_est_req(const uint8_t *est_req, size_t est_req_size)
+{
+ struct msgb *msg;
+
+ msg = msgb_from_array(est_req, est_req_size);
+ msg->l2h = msg->data;
+ msg->l3h = msg->l2h + sizeof(struct abis_rsl_rll_hdr);
+ return msg;
+}
+
static int send(struct msgb *in_msg, struct lapdm_channel *chan)
{
struct osmo_phsap_prim pp;
@@ -350,6 +368,52 @@ static void test_lapdm_polling()
lapdm_channel_exit(&ms_to_bts_channel);
}
+static void test_lapdm_contention_resolution()
+{
+ printf("I test contention resultion by having two mobiles collide and "
+ "first mobile repeating SABM.\n");
+
+ int rc;
+ struct lapdm_polling_state test_state;
+ struct osmo_phsap_prim pp;
+
+ /* Configure LAPDm on both sides */
+ struct lapdm_channel bts_to_ms_channel;
+ memset(&bts_to_ms_channel, 0, sizeof(bts_to_ms_channel));
+
+ memset(&test_state, 0, sizeof(test_state));
+ test_state.bts = &bts_to_ms_channel;
+
+ /* BTS to MS in polling mode */
+ lapdm_channel_init(&bts_to_ms_channel, LAPDM_MODE_BTS);
+ lapdm_channel_set_flags(&bts_to_ms_channel, LAPDM_ENT_F_POLLING_ONLY);
+ lapdm_channel_set_l1(&bts_to_ms_channel, NULL, &test_state);
+ lapdm_channel_set_l3(&bts_to_ms_channel, bts_to_ms_tx_cb, &test_state);
+
+ /* Send SABM MS 1, we must get UA */
+ send_sabm(&bts_to_ms_channel, 0);
+ rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
+ CHECK_RC(rc);
+ OSMO_ASSERT(memcmp(pp.oph.msg->l2h, ua, ARRAY_SIZE(ua)) == 0);
+
+ /* Send SABM MS 2, we must get nothing, due to collision */
+ send_sabm(&bts_to_ms_channel, 1);
+ rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
+ OSMO_ASSERT(rc == -ENODEV);
+
+ /* Send SABM MS 1 again, we must get UA gain */
+ send_sabm(&bts_to_ms_channel, 0);
+ rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
+ CHECK_RC(rc);
+ OSMO_ASSERT(memcmp(pp.oph.msg->l2h, ua, ARRAY_SIZE(ua)) == 0);
+
+ /* clean up */
+ lapdm_channel_exit(&bts_to_ms_channel);
+
+ /* idempotent */
+ lapdm_channel_exit(&bts_to_ms_channel);
+}
+
static void test_lapdm_early_release()
{
printf("I test RF channel release of an unestablished channel.\n");
@@ -381,14 +445,13 @@ static void test_lapdm_early_release()
lapdm_channel_exit(&bts_to_ms_channel);
}
-static void test_lapdm_contention_resolution()
+static void lapdm_establish(const uint8_t *est_req, size_t est_req_size)
{
- printf("I test contention resultion by having two mobiles collide and "
- "first mobile repeating SABM.\n");
-
int rc;
struct lapdm_polling_state test_state;
struct osmo_phsap_prim pp;
+ struct msgb *msg;
+ const char *queue_name;
/* Configure LAPDm on both sides */
struct lapdm_channel bts_to_ms_channel;
@@ -403,22 +466,39 @@ static void test_lapdm_contention_resolution()
lapdm_channel_set_l1(&bts_to_ms_channel, NULL, &test_state);
lapdm_channel_set_l3(&bts_to_ms_channel, bts_to_ms_tx_cb, &test_state);
- /* Send SABM MS 1, we must get UA */
- send_sabm(&bts_to_ms_channel, 0);
+ /* Send the release request */
+ msg = create_est_req(est_req, est_req_size);
+ rc = lapdm_rslms_recvmsg(msg, &bts_to_ms_channel);
+ fprintf(stderr, "recvmsg: got rc %d: %s\n", rc, rc <= 0 ? strerror(-rc)
: "???");
+ OSMO_ASSERT(rc == 0);
+
+ /* Take message from queue */
rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
+ if (rc >= 0)
+ queue_name = "DCCH";
+ else {
+ rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_acch,
&pp);
+ if (rc >= 0)
+ queue_name = "ACCH";
+ }
+
+ fprintf(stderr, "dequeue: got rc %d: %s\n", rc,
+ rc <= 0 ? strerror(-rc) : "-");
CHECK_RC(rc);
- OSMO_ASSERT(memcmp(pp.oph.msg->l2h, ua, ARRAY_SIZE(ua)) == 0);
- /* Send SABM MS 2, we must get nothing, due to collision */
- send_sabm(&bts_to_ms_channel, 1);
- rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
- OSMO_ASSERT(rc == -ENODEV);
+ printf("Took message from %s queue: L2 header size %d, "
+ "SAP %#x, %d/%d, Link 0x%02x\n",
+ queue_name, msgb_l2len(pp.oph.msg) - msgb_l3len(pp.oph.msg),
+ pp.oph.sap, pp.oph.primitive, pp.oph.operation,
+ pp.u.data.link_id);
+ printf("Message: %s\n", osmo_hexdump(pp.oph.msg->data,
pp.oph.msg->len));
+
+ OSMO_ASSERT(pp.oph.msg->data == msgb_l2(pp.oph.msg));
- /* Send SABM MS 1 again, we must get UA gain */
- send_sabm(&bts_to_ms_channel, 0);
rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_dcch, &pp);
- CHECK_RC(rc);
- OSMO_ASSERT(memcmp(pp.oph.msg->l2h, ua, ARRAY_SIZE(ua)) == 0);
+ OSMO_ASSERT(rc < 0);
+ rc = lapdm_phsap_dequeue_prim(&bts_to_ms_channel.lapdm_acch, &pp);
+ OSMO_ASSERT(rc < 0);
/* clean up */
lapdm_channel_exit(&bts_to_ms_channel);
@@ -427,6 +507,15 @@ static void test_lapdm_contention_resolution()
lapdm_channel_exit(&bts_to_ms_channel);
}
+static void test_lapdm_establishment()
+{
+ printf("I test RF channel establishment.\n");
+ printf("Testing SAPI3/SDCCH\n");
+ lapdm_establish(est_req_sdcch_sapi3, sizeof(est_req_sdcch_sapi3));
+ printf("Testing SAPI3/SACCH\n");
+ lapdm_establish(est_req_sacch_sapi3, sizeof(est_req_sacch_sapi3));
+}
+
int main(int argc, char **argv)
{
osmo_init_logging(&info);
@@ -434,6 +523,7 @@ int main(int argc, char **argv)
test_lapdm_polling();
test_lapdm_early_release();
test_lapdm_contention_resolution();
+ test_lapdm_establishment();
printf("Success.\n");
return 0;
diff --git a/tests/lapd/lapd_test.ok b/tests/lapd/lapd_test.ok
index 27389bf..e4b1359 100644
--- a/tests/lapd/lapd_test.ok
+++ b/tests/lapd/lapd_test.ok
@@ -21,4 +21,11 @@ I test RF channel release of an unestablished channel.
I test contention resultion by having two mobiles collide and first mobile
repeating SABM.
bts_to_ms_tx_cb: MS->BTS(us) message 25
BTS: Verifying CM request.
+I test RF channel establishment.
+Testing SAPI3/SDCCH
+Took message from DCCH queue: L2 header size 3, SAP 0x1000000, 0/0, Link 0x03
+Message: 0f 3f 01 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b
+Testing SAPI3/SACCH
+Took message from ACCH queue: L2 header size 5, SAP 0x1000000, 0/0, Link 0x43
+Message: 00 00 0f 3f 01 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b 2b
Success.
--
1.7.9.5
