From 536708617505a017b6b263a32f592471913ec464 Mon Sep 17 00:00:00 2001 From: Jacob Erlbeck Date: Tue, 12 May 2015 17:54:33 +0200 Subject: ms: Add MS storage class Currently the MS objects are contained in the TBF objects only. To allow for an extended life time after the TBF objects have been freed and to find them based on TLLI, a container for the MS objects is needed. This commit adds the container class and also adds the corresponding m_list member to GprsMs. Further integration into the PCU code is not yet done. Ticket: #1674 Sponsored-by: On-Waves ehf --- tests/ms/MsTest.cpp | 54 +++++++++++++++++++++++++++++++++++++++++++++++++++++ tests/ms/MsTest.err | 8 ++++++++ tests/ms/MsTest.ok | 2 ++ 3 files changed, 64 insertions(+) (limited to 'tests') diff --git a/tests/ms/MsTest.cpp b/tests/ms/MsTest.cpp index 03b1c18d..0895e4db 100644 --- a/tests/ms/MsTest.cpp +++ b/tests/ms/MsTest.cpp @@ -23,6 +23,7 @@ #include "tbf.h" #include "gprs_debug.h" #include "gprs_ms.h" +#include "gprs_ms_storage.h" extern "C" { #include "pcu_vty.h" @@ -231,6 +232,58 @@ static void test_ms_replace_tbf() printf("=== end %s ===\n", __func__); } +static void test_ms_storage() +{ + uint32_t tlli = 0xffeeddbb; + gprs_rlcmac_ul_tbf *ul_tbf; + GprsMs *ms; + GprsMsStorage store; + + printf("=== start %s ===\n", __func__); + + ul_tbf = talloc_zero(tall_pcu_ctx, struct gprs_rlcmac_ul_tbf); + ul_tbf->direction = GPRS_RLCMAC_UL_TBF; + + ms = store.get_ms(tlli + 0); + OSMO_ASSERT(ms == NULL); + + ms = store.get_or_create_ms(tlli + 0); + OSMO_ASSERT(ms->tlli() == tlli + 0); + + ms = store.get_ms(tlli + 0); + OSMO_ASSERT(ms != NULL); + OSMO_ASSERT(ms->tlli() == tlli + 0); + + ms = store.get_or_create_ms(tlli + 1); + OSMO_ASSERT(ms->tlli() == tlli + 1); + + ms = store.get_ms(tlli + 1); + OSMO_ASSERT(ms != NULL); + OSMO_ASSERT(ms->tlli() == tlli + 1); + + /* delete ms */ + ms = store.get_ms(tlli + 0); + OSMO_ASSERT(ms != NULL); + ms->attach_tbf(ul_tbf); + ms->detach_tbf(ul_tbf); + ms = store.get_ms(tlli + 0); + OSMO_ASSERT(ms == NULL); + ms = store.get_ms(tlli + 1); + OSMO_ASSERT(ms != NULL); + + /* delete ms */ + ms = store.get_ms(tlli + 1); + OSMO_ASSERT(ms != NULL); + ms->attach_tbf(ul_tbf); + ms->detach_tbf(ul_tbf); + ms = store.get_ms(tlli + 1); + OSMO_ASSERT(ms == NULL); + + talloc_free(ul_tbf); + + printf("=== end %s ===\n", __func__); +} + static const struct log_info_cat default_categories[] = { {"DPCU", "", "GPRS Packet Control Unit (PCU)", LOGL_INFO, 1}, }; @@ -267,6 +320,7 @@ int main(int argc, char **argv) test_ms_state(); test_ms_callback(); test_ms_replace_tbf(); + test_ms_storage(); if (getenv("TALLOC_REPORT_FULL")) talloc_report_full(tall_pcu_ctx, stderr); diff --git a/tests/ms/MsTest.err b/tests/ms/MsTest.err index d2e20c43..091e0c85 100644 --- a/tests/ms/MsTest.err +++ b/tests/ms/MsTest.err @@ -18,3 +18,11 @@ Attaching TBF to MS object, TLLI = 0xffeeddbb, TBF = TBF(TFI=0 TLLI=0x00000000 D Detaching TBF from MS object, TLLI = 0xffeeddbb, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=UL STATE=NULL) Detaching TBF from MS object, TLLI = 0xffeeddbb, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=DL STATE=NULL) Destroying MS object, TLLI = 0xffeeddbb +Creating MS object, TLLI = 0xffeeddbb +Creating MS object, TLLI = 0xffeeddbc +Attaching TBF to MS object, TLLI = 0xffeeddbb, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=UL STATE=NULL) +Detaching TBF from MS object, TLLI = 0xffeeddbb, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=UL STATE=NULL) +Destroying MS object, TLLI = 0xffeeddbb +Attaching TBF to MS object, TLLI = 0xffeeddbc, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=UL STATE=NULL) +Detaching TBF from MS object, TLLI = 0xffeeddbc, TBF = TBF(TFI=0 TLLI=0x00000000 DIR=UL STATE=NULL) +Destroying MS object, TLLI = 0xffeeddbc diff --git a/tests/ms/MsTest.ok b/tests/ms/MsTest.ok index a0d4e9e6..219eec1a 100644 --- a/tests/ms/MsTest.ok +++ b/tests/ms/MsTest.ok @@ -8,3 +8,5 @@ ms_active() was called ms_idle() was called === end test_ms_replace_tbf === +=== start test_ms_storage === +=== end test_ms_storage === -- cgit v1.2.3