pespin has uploaded this change for review. (
https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/34714?usp=email )
Change subject: Introduce HSS_Tests testsuite
......................................................................
Introduce HSS_Tests testsuite
Change-Id: Ic2fccd9c54aea04f1a31649a0af47c974939fb2f
Related: SYS#6588
---
M Makefile
A hss/HSS_Tests.cfg
A hss/HSS_Tests.default
A hss/HSS_Tests.ttcn
A hss/expected-results.xml
A hss/gen_links.sh
A hss/regen_makefile.sh
7 files changed, 352 insertions(+), 0 deletions(-)
git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks
refs/changes/14/34714/1
diff --git a/Makefile b/Makefile
index 1d119d1..0ed632f 100644
--- a/Makefile
+++ b/Makefile
@@ -27,6 +27,7 @@
hlr \
hnbgw \
hnodeb \
+ hss \
mgw \
mme \
msc \
diff --git a/hss/HSS_Tests.cfg b/hss/HSS_Tests.cfg
new file mode 100644
index 0000000..24fe9c4
--- /dev/null
+++ b/hss/HSS_Tests.cfg
@@ -0,0 +1,18 @@
+[ORDERED_INCLUDE]
+# Common configuration, shared between test suites
+"../Common.cfg"
+# testsuite specific configuration, not expected to change
+"./HSS_Tests.default"
+
+# Local configuration below
+
+[LOGGING]
+
+[TESTPORT_PARAMETERS]
+
+[MODULE_PARAMETERS]
+
+[MAIN_CONTROLLER]
+
+[EXECUTE]
+HSS_Tests.control
diff --git a/hss/HSS_Tests.default b/hss/HSS_Tests.default
new file mode 100644
index 0000000..4c0b502
--- /dev/null
+++ b/hss/HSS_Tests.default
@@ -0,0 +1,7 @@
+[LOGGING]
+
+[TESTPORT_PARAMETERS]
+
+[MODULE_PARAMETERS]
+
+[EXECUTE]
diff --git a/hss/HSS_Tests.ttcn b/hss/HSS_Tests.ttcn
new file mode 100644
index 0000000..bd18e9e
--- /dev/null
+++ b/hss/HSS_Tests.ttcn
@@ -0,0 +1,263 @@
+module HSS_Tests {
+
+import from General_Types all;
+import from Osmocom_Types all;
+import from Native_Functions all;
+import from Misc_Helpers all;
+
+import from DIAMETER_Types all;
+import from DIAMETER_Templates all;
+import from DIAMETER_Emulation all;
+
+type record of hexstring SubscriberConfigs;
+
+modulepar {
+ charstring mp_hss_hostname := "127.0.0.4";
+ integer mp_hss_port := 3868;
+ charstring mp_diam_local_hostname := "127.0.0.1";
+ integer mp_diam_local_port := 3868;
+ charstring mp_diam_orig_realm := "localdomain";
+ charstring mp_diam_orig_host := "mme.localdomain";
+ charstring mp_diam_dest_realm := "localdomain";
+ charstring mp_diam_dest_host := "hss.localdomain";
+ SubscriberConfigs subscribers := {
+ /* Existing subscriber, ULA returns SERVICE_GRANTED */
+ '001010000000000'H
+ };
+}
+
+/* main component, we typically have one per testcase */
+type component MTC_CT {
+
+ /* emulated MME/SGSN */
+ var DIAMETER_Emulation_CT vc_S6a;
+ port DIAMETER_PT S6a_UNIT;
+ port DIAMETEREM_PROC_PT S6a_PROC;
+ /* global test case guard timer (actual timeout value is set in
f_init()) */
+ timer T_guard;
+}
+
+/* global altstep for global guard timer; */
+altstep as_Tguard() runs on MTC_CT {
+ [] T_guard.timeout {
+ setverdict(fail, "Timeout of T_guard");
+ mtc.stop;
+ }
+}
+
+type component DIAMETER_ConnHdlr_CT extends DIAMETER_ConnHdlr {
+ port DIAMETER_Conn_PT DIAMETER_CLIENT;
+ port DIAMETEREM_PROC_PT DIAMETER_PROC_CLIENT;
+}
+
+function f_diam_connhldr_ct_main(hexstring imsi) runs on DIAMETER_ConnHdlr_CT {
+ var DIAMETER_ConnHdlr vc_conn_unused;
+ var PDU_DIAMETER msg;
+ var UINT32 ete_id;
+
+ f_diameter_expect_imsi(imsi);
+
+ while (true) {
+ alt {
+ [] DIAMETER_CLIENT.receive(PDU_DIAMETER:?) -> value msg {
+ DIAMETER.send(msg);
+ }
+ [] DIAMETER.receive(PDU_DIAMETER:?) -> value msg {
+ DIAMETER_CLIENT.send(msg);
+ }
+ []
DIAMETER_PROC_CLIENT.getcall(DIAMETEREM_register_eteid:{?,?}) -> param(ete_id,
vc_conn_unused) {
+ DIAMETER_PROC.call(DIAMETEREM_register_eteid:{ete_id,
self}) {
+ []
DIAMETER_PROC.getreply(DIAMETEREM_register_eteid:{?,?}) {};
+ }
+
DIAMETER_PROC_CLIENT.reply(DIAMETEREM_register_eteid:{ete_id, vc_conn_unused});
+ }
+ }
+ }
+}
+
+/* per-session component; we typically have 1..N per testcase */
+type component Cli_Session_CT {
+ var SessionPars g_pars;
+
+ port DIAMETER_Conn_PT S6a;
+ port DIAMETEREM_PROC_PT S6a_PROC;
+}
+function f_diam_connhldr_expect_eteid(UINT32 ete_id) runs on Cli_Session_CT {
+ S6a_PROC.call(DIAMETEREM_register_eteid:{ete_id, null}) {
+ [] S6a_PROC.getreply(DIAMETEREM_register_eteid:{?,?}) {};
+ }
+}
+
+/* configuration data for a given Session */
+type record SessionPars {
+ hexstring imsi,
+ uint32_t s6a_next_hbh_id,
+ uint32_t s6a_next_ete_id
+ //hexstring msisdn optional,
+
+
+ // serving network
+ //integer rat_type,
+ // flags?
+ //charstring apn,
+ /* Apn subscribed or non-subscribed */
+ //boolean selection_mode,
+ //BIT3 pdn_type
+}
+
+template (value) SessionPars
+t_SessionPars(hexstring imsi, uint32_t s6a_next_hbh_id := 1000, uint32_t
s6a_next_ete_id := 22220
+ //, integer rat_type := 6, charstring apn := "internet", boolean
selection_mode := false, BIT3 pdn_type := '001'B
+ ) := {
+ imsi := imsi,
+ s6a_next_hbh_id := s6a_next_hbh_id,
+ s6a_next_ete_id := s6a_next_ete_id
+ //msisdn := '1234'H,
+ //rat_type := rat_type,
+ //apn := apn,
+ //selection_mode := selection_mode,
+ //pdn_type := pdn_type
+}
+
+type function void_fn() runs on Cli_Session_CT;
+
+friend function DiameterForwardUnitdataCallback(PDU_DIAMETER msg)
+runs on DIAMETER_Emulation_CT return template PDU_DIAMETER {
+ DIAMETER_UNIT.send(msg);
+ return omit;
+}
+
+friend function f_init_diameter(charstring id) runs on MTC_CT {
+ var DIAMETEROps ops := {
+ create_cb := refers(DIAMETER_Emulation.ExpectedCreateCallback),
+ unitdata_cb := refers(DiameterForwardUnitdataCallback),
+ raw := false /* handler mode (IMSI based routing) */
+ };
+ var DIAMETER_conn_parameters pars;
+
+ /* S6a setup: */
+ pars := {
+ remote_ip := mp_hss_hostname,
+ remote_sctp_port := mp_hss_port,
+ local_ip := mp_diam_local_hostname,
+ local_sctp_port := mp_diam_local_port,
+ origin_host := mp_diam_orig_host,
+ origin_realm := mp_diam_orig_realm,
+ auth_app_id := omit,
+ vendor_app_id := c_DIAMETER_3GPP_S6_AID
+ };
+ vc_S6a := DIAMETER_Emulation_CT.create(id);
+ map(vc_S6a:DIAMETER, system:DIAMETER_CODEC_PT);
+ connect(vc_S6a:DIAMETER_UNIT, self:S6a_UNIT);
+ connect(vc_S6a:DIAMETER_PROC, self:S6a_PROC);
+ vc_S6a.start(DIAMETER_Emulation.main(ops, pars, id));
+
+ f_diameter_wait_capability(S6a_UNIT);
+ /* Give some time for our emulation to get out of SUSPECT list of SUT
(3 watchdong ping-pongs):
+ * RFC6733 sec 5.1
+ * RFC3539 sec 3.4.1 [5]
+ *
https://github.com/freeDiameter/freeDiameter/blob/master/libfdcore/p_psm.c#L49
+ */
+ f_sleep(1.0);
+}
+
+private function f_init(float guard_timeout := 60.0) runs on MTC_CT {
+ T_guard.start(guard_timeout);
+ activate(as_Tguard());
+ f_init_diameter(testcasename());
+}
+
+function f_start_handler(void_fn fn, template (omit) SessionPars pars_tmpl :=
omit)
+runs on MTC_CT return Cli_Session_CT {
+ var charstring id := testcasename();
+ var DIAMETER_ConnHdlr_CT vc_conn_s6a;
+ var Cli_Session_CT vc_conn;
+ var SessionPars pars;
+
+ if (isvalue(pars_tmpl)) {
+ pars := valueof(pars_tmpl);
+ } else {
+ /*TODO: set default values */
+ }
+
+ vc_conn := Cli_Session_CT.create(id);
+
+ vc_conn_s6a := DIAMETER_ConnHdlr_CT.create(id);
+ connect(vc_conn_s6a:DIAMETER, vc_S6a:DIAMETER_CLIENT);
+ connect(vc_conn_s6a:DIAMETER_PROC, vc_S6a:DIAMETER_PROC);
+ connect(vc_conn:S6a, vc_conn_s6a:DIAMETER_CLIENT);
+ connect(vc_conn:S6a_PROC, vc_conn_s6a:DIAMETER_PROC_CLIENT);
+ vc_conn_s6a.start(f_diam_connhldr_ct_main(pars.imsi));
+
+ vc_conn.start(f_handler_init(fn, pars));
+ return vc_conn;
+}
+
+private function f_handler_init(void_fn fn, SessionPars pars)
+runs on Cli_Session_CT {
+ g_pars := valueof(pars);
+ fn.apply();
+}
+
+/* ULR + ULA against HSS */
+private function f_dia_ulr_ula() runs on Cli_Session_CT {
+ var octetstring sess_id := char2oct("foobar");
+ var template (present) AVP_list sub_data;
+ var PDU_DIAMETER rx_dia;
+ var UINT32 hbh_id := int2oct(g_pars.s6a_next_hbh_id, 4);
+ var UINT32 ete_id := int2oct(g_pars.s6a_next_ete_id, 4);
+
+ /* Unlike ULR, ULA contains no IMSI. Register ete_id in
DIAMETER_Emulation,
+ * so AIA is forwarded back to us in DIAMETER port instead of
MTC_CT.DIAMETER_UNIT.
+ */
+ f_diam_connhldr_expect_eteid(ete_id);
+
+ /* TODO: change this into a ts_DIA_ULR */
+ S6a.send(ts_DIA_ULR(g_pars.imsi, '111F11'O, sess_id,
+ mp_diam_orig_host, mp_diam_orig_realm,
+ mp_diam_dest_realm, hbh_id, ete_id));
+ g_pars.s6a_next_hbh_id := g_pars.s6a_next_hbh_id + 1;
+ g_pars.s6a_next_ete_id := g_pars.s6a_next_ete_id + 1;
+
+ sub_data := superset(
+ ts_AVP_3GPP_SubscriberStatus(SERVICE_GRANTED),
+ tr_AVP_3GPP_SubscrRauTauTmr(?),
+ tr_AVP_3GPP_AMBR(?, ?),
+ tr_AVP_3GPP_ApnConfigProfile({
+ tr_AVP_3GPP_ContextId(?),
+ tr_AVP_3GPP_AllApnConfigsIncl,
+ tr_AVP_3GPP_ApnConfig(?, ?, ?)
+ })
+ );
+
+ alt {
+ [] S6a.receive(tr_DIA_ULA(/* sub_data */ ?, sess_id, ?, ?, hbh_id,
ete_id)) -> value rx_dia {
+ setverdict(pass);
+ }
+ [] S6a.receive(PDU_DIAMETER:?) -> value rx_dia {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Received unexpected DIAMETER
", rx_dia));
+ }
+ }
+}
+
+/* create a session, expect it to succeed */
+private function f_TC_ulr_ula() runs on Cli_Session_CT {
+ f_dia_ulr_ula();
+ setverdict(pass);
+}
+testcase TC_ulr_ula() runs on MTC_CT {
+ var Cli_Session_CT vc_conn;
+ var SessionPars pars := valueof(t_SessionPars(subscribers[0]));
+ f_init();
+ vc_conn := f_start_handler(refers(f_TC_ulr_ula), pars);
+ vc_conn.done;
+}
+
+
+control {
+ execute( TC_ulr_ula() );
+}
+
+
+}
diff --git a/hss/expected-results.xml b/hss/expected-results.xml
new file mode 100644
index 0000000..8e8d1df
--- /dev/null
+++ b/hss/expected-results.xml
@@ -0,0 +1,4 @@
+<?xml version="1.0"?>
+<testsuite name='Titan' tests='1' failures='0' errors='0' skipped='0'
inconc='0' time='MASKED'>
+ <testcase classname='HSS_Tests' name='TC_ulr_ula' time='MASKED'/>
+</testsuite>
diff --git a/hss/gen_links.sh b/hss/gen_links.sh
new file mode 100755
index 0000000..b97d53f
--- /dev/null
+++ b/hss/gen_links.sh
@@ -0,0 +1,29 @@
+#!/bin/bash
+
+BASEDIR=../deps
+
+. ../gen_links.sh.inc
+
+DIR=$BASEDIR/titan.Libraries.TCCUsefulFunctions/src
+FILES="TCCInterface_Functions.ttcn TCCConversion_Functions.ttcn
TCCConversion.cc TCCInterface.cc TCCInterface_ip.h"
+FILES+=" TCCEncoding_Functions.ttcn TCCEncoding.cc " # GSM 7-bit coding
+gen_links $DIR $FILES
+
+DIR=$BASEDIR/titan.TestPorts.Common_Components.Socket-API/src
+FILES="Socket_API_Definitions.ttcn"
+gen_links $DIR $FILES
+
+DIR=$BASEDIR/titan.TestPorts.IPL4asp/src
+FILES="IPL4asp_Functions.ttcn IPL4asp_PT.cc IPL4asp_PT.hh
IPL4asp_PortType.ttcn IPL4asp_Types.ttcn IPL4asp_discovery.cc
IPL4asp_protocol_L234.hh"
+gen_links $DIR $FILES
+
+DIR=$BASEDIR/titan.ProtocolModules.DIAMETER_ProtocolModule_Generator/src
+FILES="DIAMETER_EncDec.cc"
+gen_links $DIR $FILES
+
+DIR=../library
+FILES="Misc_Helpers.ttcn General_Types.ttcn Osmocom_Types.ttcn
Native_Functions.ttcn Native_FunctionDefs.cc "
+FILES+="DIAMETER_Types.ttcn DIAMETER_CodecPort.ttcn
DIAMETER_CodecPort_CtrlFunct.ttcn DIAMETER_CodecPort_CtrlFunctDef.cc
DIAMETER_Emulation.ttcn DIAMETER_Templates.ttcn "
+gen_links $DIR $FILES
+
+ignore_pp_results
diff --git a/hss/regen_makefile.sh b/hss/regen_makefile.sh
new file mode 100755
index 0000000..23fbd73
--- /dev/null
+++ b/hss/regen_makefile.sh
@@ -0,0 +1,20 @@
+#!/bin/bash
+
+NAME=HSS_Tests
+
+FILES="
+ *.ttcn
+ DIAMETER_CodecPort_CtrlFunctDef.cc
+ DIAMETER_EncDec.cc
+ IPL4asp_PT.cc
+ IPL4asp_discovery.cc
+ Native_FunctionDefs.cc
+ TCCConversion.cc
+ TCCEncoding.cc
+ TCCInterface.cc
+"
+
+export CPPFLAGS_TTCN3="
+"
+
+../regen-makefile.sh -e $NAME $FILES
--
To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/34714?usp=email
To unsubscribe, or for help writing mail filters, visit
https://gerrit.osmocom.org/settings
Gerrit-Project: osmo-ttcn3-hacks
Gerrit-Branch: master
Gerrit-Change-Id: Ic2fccd9c54aea04f1a31649a0af47c974939fb2f
Gerrit-Change-Number: 34714
Gerrit-PatchSet: 1
Gerrit-Owner: pespin <pes...@sysmocom.de>
Gerrit-MessageType: newchange
