October 2024 - gerrit-log - lists.osmocom.org

[S] Change in osmo-ttcn3-hacks[master]: testenv: osmo-dev: add hint for gen_makefile fail
by osmith 25 Oct '24

25 Oct '24

osmith has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38530?usp=email ) Change subject: testenv: osmo-dev: add hint for gen_makefile fail ...................................................................... testenv: osmo-dev: add hint for gen_makefile fail When gen_makefile.py from osmo-dev fails, it is likely that the osmo-dev git clone is outdated, for example if a new file with configure options was added to osmo-dev.git and is now being used by testenv. Display a hint for pulling this repository to the user. Change-Id: Ia9ed23fa910876252093054f5f389865632c7593 --- M _testenv/testenv/osmo_dev.py M _testenv/testenv/podman.py 2 files changed, 8 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/30/38530/1 diff --git a/_testenv/testenv/osmo_dev.py b/_testenv/testenv/osmo_dev.py index 4dd581a..9a10462 100644 --- a/_testenv/testenv/osmo_dev.py +++ b/_testenv/testenv/osmo_dev.py @@ -2,6 +2,7 @@ # SPDX-License-Identifier: GPL-3.0-or-later import logging import os +import shlex import sys import testenv import testenv.cmd @@ -92,7 +93,12 @@ os.path.join(testenv.data_dir, "osmo-dev/osmo-bts-trx.opts"), ] + extra_opts - testenv.cmd.run(cmd, cwd=get_osmo_dev_dir()) + cwd = get_osmo_dev_dir() + if testenv.cmd.run(cmd, cwd=cwd, check=False).returncode: + logging.critical("gen_makefile.py from osmo-dev failed!") + logging.critical("Your osmo-dev.git clone might be outdated, try:") + logging.critical(f"$ git -C {shlex.quote(cwd)} pull") + sys.exit(1) init_done = True diff --git a/_testenv/testenv/podman.py b/_testenv/testenv/podman.py index 683f468..faa1837 100644 --- a/_testenv/testenv/podman.py +++ b/_testenv/testenv/podman.py @@ -146,7 +146,7 @@ if isinstance(cmd, str): cmd = ["sh", "-c", cmd] - testenv.cmd.run( + return testenv.cmd.run( ["podman", "exec"] + podman_opts + [container_name] + cmd, no_podman=True, *args, -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38530?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Ia9ed23fa910876252093054f5f389865632c7593 Gerrit-Change-Number: 38530 Gerrit-PatchSet: 1 Gerrit-Owner: osmith <osmith(a)sysmocom.de>

1 0

[S] Change in osmo-ttcn3-hacks[master]: testenv: remove dead code for [testsuite] prepare=
by osmith 25 Oct '24

25 Oct '24

osmith has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38531?usp=email ) Change subject: testenv: remove dead code for [testsuite] prepare= ...................................................................... testenv: remove dead code for [testsuite] prepare= Remove some WIP code that I intended to use for enabling the mongodb repository before installing binary packages, to be able to dynamically install mongodb from there. I solved it differently by just always having mongodb in the podman image. This was a dead code path because configs with prepare= in [testsuite] are currently not valid, and therefore testenv refuses to use these configs (see keys_valid_testsuite in testenv_cfg.py's verify()). I have a different use case for running prepare= before running the testsuite, to replace a module parameter in the testsuite's config. This will be done in the next patch. Change-Id: I9bed48612fad690f86017c298372dc6cea22b94b --- M _testenv/testenv.py M _testenv/testenv/testsuite.py 2 files changed, 0 insertions(+), 14 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/31/38531/1 diff --git a/_testenv/testenv.py b/_testenv/testenv.py index e1f1210..23a2922 100755 --- a/_testenv/testenv.py +++ b/_testenv/testenv.py @@ -38,11 +38,6 @@ testenv.testsuite.init() testenv.testsuite.build() - # Run prepare functions of testsuites (may enable extra repos) - for cfg_name, cfg in testenv.testenv_cfg.cfgs.items(): - testenv.testenv_cfg.set_current(cfg_name) - testenv.testsuite.run_prepare_script(cfg) - # Build all components first if not testenv.args.binary_repo: for cfg_name, cfg in testenv.testenv_cfg.cfgs.items(): diff --git a/_testenv/testenv/testsuite.py b/_testenv/testenv/testsuite.py index 7fc4344..601f339 100644 --- a/_testenv/testenv/testsuite.py +++ b/_testenv/testenv/testsuite.py @@ -205,15 +205,6 @@ format_log_files(cfg) -def run_prepare_script(cfg): - section_data = cfg["testsuite"] - if "prepare" not in section_data: - return - - logging.info("Running testsuite prepare script") - testenv.cmd.run(section_data["prepare"]) - - def get_current_test(): path = os.path.join(testenv.testdir.testdir, "testsuite/.current_test") try: -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38531?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I9bed48612fad690f86017c298372dc6cea22b94b Gerrit-Change-Number: 38531 Gerrit-PatchSet: 1 Gerrit-Owner: osmith <osmith(a)sysmocom.de>

1 0

[S] Change in osmo-ttcn3-hacks[master]: testenv: add proper [testsuite] prepare= support
by osmith 25 Oct '24

25 Oct '24

osmith has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38532?usp=email ) Change subject: testenv: add proper [testsuite] prepare= support ...................................................................... testenv: add proper [testsuite] prepare= support Support using prepare= in the [testsuite] section to e.g. change module parameters: [testsuite] prepare=sed -i 's/mp_my_parameter := false/mp_my_parameter := true/' Testsuite.cfg Move the execution time of prepare and clean scripts in testdir.prepare() after the testsuite config has been copied to the testdir, so it can be modified by the prepare script. Change-Id: Ia78a4eba061e5e070f156f75eae1dfa4cede1ee3 --- M _testenv/README.md M _testenv/testenv/testdir.py M _testenv/testenv/testenv_cfg.py 3 files changed, 23 insertions(+), 10 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/32/38532/1 diff --git a/_testenv/README.md b/_testenv/README.md index 3fed9c9..bd102a8 100644 --- a/_testenv/README.md +++ b/_testenv/README.md @@ -70,6 +70,10 @@ directory, useful for include files mentioned in the config. Multiple values are separated by spaces. +* `prepare=`: optional script to run before staring the testsuite (after files + are copied to the test directory). This can be used to change module + parameters in the testsuite's config. + * `clean=`: optional script to run before running the testsuite and on exit. This can be used to clean up network devices for example, or to fix name collisions when running a test with multiple configs diff --git a/_testenv/testenv/testdir.py b/_testenv/testenv/testdir.py index aa0ba47..88a2dca 100644 --- a/_testenv/testenv/testdir.py +++ b/_testenv/testenv/testdir.py @@ -94,16 +94,6 @@ mode = 755 if os.access(path, os.X_OK) else 644 testenv.cmd.run(["install", f"-Dm{mode}", path, path_dest]) - if "clean" in section_data: - logging.info(f"Running {section} clean script (reason: prepare)") - clean_scripts[section] = section_data["clean"] - env = {"TESTENV_CLEAN_REASON": "prepare"} - testenv.cmd.run(section_data["clean"], cwd=section_dir, env=env) - - if "prepare" in section_data: - logging.info(f"Running {section} prepare script") - testenv.cmd.run(section_data["prepare"], cwd=section_dir) - # Referenced in testsuite cfgs: *.default pattern = os.path.join(testsuite_dir, "*.default") for path in glob.glob(pattern): @@ -147,6 +137,24 @@ ] ) + # Run prepare and clean scripts + for section in cfg: + if section in ["DEFAULT"]: + continue + + section_data = cfg[section] + section_dir = os.path.join(testdir, section) + + if "clean" in section_data: + logging.info(f"Running {section} clean script (reason: prepare)") + clean_scripts[section] = section_data["clean"] + env = {"TESTENV_CLEAN_REASON": "prepare"} + testenv.cmd.run(section_data["clean"], cwd=section_dir, env=env) + + if "prepare" in section_data: + logging.info(f"Running {section} prepare script") + testenv.cmd.run(section_data["prepare"], cwd=section_dir) + def clean(): """Don't leave behind an empty testdir_topdir, e.g. if testenv.py aborted diff --git a/_testenv/testenv/testenv_cfg.py b/_testenv/testenv/testenv_cfg.py index ea25614..fefaf5c 100644 --- a/_testenv/testenv/testenv_cfg.py +++ b/_testenv/testenv/testenv_cfg.py @@ -109,6 +109,7 @@ "clean", "config", "copy", + "prepare", "program", ] keys_valid_component = [ -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38532?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Ia78a4eba061e5e070f156f75eae1dfa4cede1ee3 Gerrit-Change-Number: 38532 Gerrit-PatchSet: 1 Gerrit-Owner: osmith <osmith(a)sysmocom.de>

1 0

[XL] Change in osmo-ttcn3-hacks[master]: hnbgw: Split ConnHdlr component code to its own file
by osmith 25 Oct '24

25 Oct '24

Attention is currently required from: pespin. osmith has posted comments on this change by pespin. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38528?usp=email ) Change subject: hnbgw: Split ConnHdlr component code to its own file ...................................................................... Patch Set 1: Code-Review+1 -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38528?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: comment Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I3a58c27a7472eea2421a45c31ac0145eb57a1f7e Gerrit-Change-Number: 38528 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Fri, 25 Oct 2024 09:36:26 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes

1 0

[M] Change in osmo-ttcn3-hacks[master]: hnbgw: Support testenv
by osmith 25 Oct '24

25 Oct '24

Attention is currently required from: pespin. osmith has posted comments on this change by pespin. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email ) Change subject: hnbgw: Support testenv ...................................................................... Patch Set 2: (1 comment) File _testenv/data/podman/Dockerfile: https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527/comment/c048bad5_025f… : PS2, Line 22: asciidoc-base \ instead of adding asciidoc-base, let's configure nftables to not build man pages: https://gerrit.osmocom.org/c/osmo-dev/+/38529 and ```diff --- a/_testenv/testenv/osmo_dev.py +++ b/_testenv/testenv/osmo_dev.py @@ -89,6 +89,7 @@ def init(): "iu.opts", "no_dahdi.opts", "no_doxygen.opts", + "no_man_pages.opts", "no_systemd.opts", "werror.opts", os.path.join(testenv.data_dir, "osmo-dev/osmo-bts-trx.opts"), ``` -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: comment Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 Gerrit-Change-Number: 38527 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-CC: osmith <osmith(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Fri, 25 Oct 2024 09:33:12 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No

1 0

[XS] Change in osmo-dev[master]: no_man_pages.opts: new file
by osmith 25 Oct '24

25 Oct '24

osmith has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-dev/+/38529?usp=email ) Change subject: no_man_pages.opts: new file ...................................................................... no_man_pages.opts: new file Disable building man pages for nftables, which requires asciidoc. Related: osmo-ttcn3-hacks Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 Change-Id: I53342830d75b879a28334090df9d5cb935c43637 --- A no_man_pages.opts 1 file changed, 1 insertion(+), 0 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-dev refs/changes/29/38529/1 diff --git a/no_man_pages.opts b/no_man_pages.opts new file mode 100644 index 0000000..aee63e8 --- /dev/null +++ b/no_man_pages.opts @@ -0,0 +1 @@ +nftables --disable-man-doc -- To view, visit https://gerrit.osmocom.org/c/osmo-dev/+/38529?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-dev Gerrit-Branch: master Gerrit-Change-Id: I53342830d75b879a28334090df9d5cb935c43637 Gerrit-Change-Number: 38529 Gerrit-PatchSet: 1 Gerrit-Owner: osmith <osmith(a)sysmocom.de>

1 0

[XS] Change in ...osmo-s1gw[master]: pfcp_peer: do not route incoming PDUs without SEID
by fixeria 24 Oct '24

24 Oct '24

Attention is currently required from: laforge, pespin. fixeria has posted comments on this change by fixeria. ( https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/37964?usp=email ) Change subject: pfcp_peer: do not route incoming PDUs without SEID ...................................................................... Patch Set 4: (1 comment) This change is ready for review. File src/pfcp_peer.erl: https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/37964/comment/ae4d5fe2_840c… : PS1, Line 233: ?LOG_NOTICE("Rx unexpected PFCP PDU: ~p", [PDU]) > Acknowledged Going back to this idea, I checked 3GPP TS 29.244 and here is what it states: ``` 7.6.4 Unknown PFCP Message If a PFCP entity receives a message with an unknown Message Type value, it shall silently discard the message. 7.6.5 Unexpected PFCP Message If a PFCP entity receives an unexpected request message, for example a known message that is sent over an interface for which the message is not defined, or a message that is sent over an interface for which the message is defined, but the direction is incorrect, then the PFCP entity shall silently discard the message and shall log an error. If a PFCP entity receives an unexpected response message which is not a request message, for example a message for which there is no corresponding outstanding request, it shall discard the message and may log an error. ``` In our specific case we implement only a limited subset of PFCP procedures/messages, and I am not sure if the rules described in 7.6.4-5 apply to not supported messages. From the spec. point of view we shall implement all procedures and the related messages. Regardless of how we interpret the spec. requirements, implementing the response logic is a significant effort. The problem is that there exists no single message type to indicate an error, so we would need to craft a proper response for each unexpected request kind, which involves adding all mandatory IEs. Taking the above into account, I suggest merging this patch as-is. -- To view, visit https://gerrit.osmocom.org/c/erlang/osmo-s1gw/+/37964?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: comment Gerrit-Project: erlang/osmo-s1gw Gerrit-Branch: master Gerrit-Change-Id: I7d33ec4e883b217b2b4f65e4866d9365c32c753d Gerrit-Change-Number: 37964 Gerrit-PatchSet: 4 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: laforge <laforge(a)osmocom.org> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: laforge <laforge(a)osmocom.org> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Thu, 24 Oct 2024 19:47:32 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No Comment-In-Reply-To: laforge <laforge(a)osmocom.org> Comment-In-Reply-To: fixeria <vyanitskiy(a)sysmocom.de>

1 0

[XL] Change in osmo-ttcn3-hacks[master]: hnbgw: Split ConnHdlr component code to its own file
by pespin 24 Oct '24

24 Oct '24

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38528?usp=email ) Change subject: hnbgw: Split ConnHdlr component code to its own file ...................................................................... hnbgw: Split ConnHdlr component code to its own file Similar to what we do in most of the testsuites, split Component generic code from test specific code. Change-Id: I3a58c27a7472eea2421a45c31ac0145eb57a1f7e --- A hnbgw/ConnHdlr.ttcn M hnbgw/HNBGW_Tests.ttcn 2 files changed, 783 insertions(+), 685 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/28/38528/1 diff --git a/hnbgw/ConnHdlr.ttcn b/hnbgw/ConnHdlr.ttcn new file mode 100644 index 0000000..b304f18 --- /dev/null +++ b/hnbgw/ConnHdlr.ttcn @@ -0,0 +1,722 @@ +/* Connection Handler of HNBGW test suite in TTCN-3 + * (C) 2021-2024 by sysmocom - s.f.m.c. GmbH <info(a)sysmocom.de> + * All rights reserved. + * + * Released under the terms of GNU General Public License, Version 2 or + * (at your option) any later version. + * + * SPDX-License-Identifier: GPL-2.0-or-later + * + * This test suite tests OsmoHNBGW while emulating the hNodeB as well as MSC, SGSN, MGW + * See README for more details. + */ + +module ConnHdlr { + +import from Misc_Helpers all; +import from General_Types all; +import from GSM_Types all; +import from Osmocom_Types all; +import from IPL4asp_Types all; +import from Native_Functions all; + +import from Osmocom_CTRL_Functions all; +import from Osmocom_CTRL_Types all; +import from Osmocom_CTRL_Adapter all; + +import from StatsD_Types all; +import from StatsD_CodecPort all; +import from StatsD_CodecPort_CtrlFunct all; +import from StatsD_Checker all; + +import from Osmocom_VTY_Functions all; +import from TELNETasp_PortType all; + +import from HNBAP_Templates all; +import from HNBAP_IEs all; +import from HNBAP_PDU_Descriptions all; + +import from RUA_IEs all; +import from RUA_Templates all; +import from RUA_Emulation all; + +import from Iuh_Emulation all; + +import from RANAP_Types all; +import from RANAP_PDU_Descriptions all; +import from RANAP_PDU_Contents all; +import from RANAP_IEs all; +import from RANAP_Templates all; +import from RANAP_CodecPort all; + +import from RAN_Adapter all; +import from RAN_Emulation all; + +import from MGCP_Emulation all; +import from MGCP_Types all; +import from MGCP_Templates all; +import from MGCP_CodecPort all; +import from SDP_Types all; +import from SDP_Templates all; + +import from PFCP_Types all; +import from PFCP_Emulation all; +import from PFCP_Templates all; +import from PFCP_CodecPort all; + +import from TCCConversion_Functions all; +import from MobileL3_Types all; +import from MobileL3_CommonIE_Types all; +import from MobileL3_GMM_SM_Types all; +import from L3_Templates all; +import from L3_Common all; + +import from SCCPasp_Types all; + +/*********************************************************************** + * code running inside per-UE ConnHdlr + ***********************************************************************/ + +/* We extend: + * RUA_ConnHdlr (for the Iuh side, emulating the HNB) + * RAN_ConnHdlr (for the Iu side, emulating the MSC) + * MGCP_ConnHdlr (for the MGCP side, emulating the MGW) + * StatsD_ConnHdlr (for the statsd interface, verifying counters) + */ +type component ConnHdlr extends RAN_ConnHdlr, MGCP_ConnHdlr, RUA_ConnHdlr, PFCP_ConnHdlr, StatsD_ConnHdlr { + var integer g_sccp_conn_id; + var TestHdlrParams g_pars; + timer g_Tguard; + + port TELNETasp_PT HNBGWVTY; +} + +type record MgwResponse { + integer resp, + HostName mgw_rtp_ip, + /* if set, used after first received MDCX: */ + HostName mgw_rtp_ip_mdcx optional, + PortNumber mgw_rtp_port, + MgcpConnectionId mgcp_connection_id +} + +type record MgcpParameters { + integer got_crcx_count, + integer got_dlcx_count, + MgcpCallId mgcp_call_id optional, + MgcpEndpoint mgcp_ep, + MgwResponse mgw_conn_ran, + MgwResponse mgw_conn_cn, + uint7_t rtp_payload_type, + charstring rtp_sdp_format, + HostName hnb_rtp_ip, + PortNumber hnb_rtp_port, + HostName cn_rtp_ip, + PortNumber cn_rtp_port, + boolean use_osmux, + integer got_osmux_count +} + +template (value) MgcpParameters t_MgcpParams := { + got_crcx_count := 0, + got_dlcx_count := 0, + mgcp_call_id := omit, + mgcp_ep := "rtpbridge/1@mgw", + mgw_conn_ran := { + resp := 1, + mgw_rtp_ip := "127.1.2.1", + mgw_rtp_ip_mdcx := omit, + mgw_rtp_port := 10000, + mgcp_connection_id := '11111'H + }, + mgw_conn_cn := { + resp := 1, + mgw_rtp_ip := "127.1.2.2", + mgw_rtp_ip_mdcx := omit, + mgw_rtp_port := 20000, + mgcp_connection_id := '22222'H + }, + rtp_payload_type := 112, + rtp_sdp_format := "VND.3GPP.IUFP", + hnb_rtp_ip := "127.1.1.1", + hnb_rtp_port := 10001, + cn_rtp_ip := "127.1.3.1", + cn_rtp_port := 20001, + use_osmux := false, + got_osmux_count := 0 +} + +type record HnbConfig { + LocationAreaIdentification lai, + integer sac +} + +type record TestHdlrParams { + integer hnb_idx, + /* cn_idx indicates which CN link from g_cn[] to connect to the test component. + * See also f_cn_idx(). */ + integer cn_idx, + hexstring imsi, + boolean ps_domain, + MgcpParameters mgcp_pars optional, + HnbConfig hnb optional, + boolean expect_separate_sccp_cr, + integer tx_sccp_cr_data_len, + charstring pfcp_local_addr, + octetstring nas_pdu optional, + /* local and remote SCCP addresses, used in TC_mscpool_paging_* */ + SCCP_PAR_Address sccp_addr_msc optional, + SCCP_PAR_Address sccp_addr_hnbgw optional, + /* RAB release cause */ + RANAP_IEs.Cause rab_rel_cause, + integer hnbgw_timer_x31 +} + +template (value) TestHdlrParams +t_pars(integer imsi_suffix, + boolean ps_domain := false, + integer hnb_idx := 0, + boolean expect_separate_sccp_cr := false, + integer tx_sccp_cr_data_len := 0, + integer cn_idx := 0, + charstring pfcp_local_addr := "127.0.0.1", + template (value) RANAP_IEs.Cause rab_rel_cause := ts_RanapCause_nas_normal, + integer hnbgw_timer_x31 := 5) := { + hnb_idx := hnb_idx, + cn_idx := cn_idx, + imsi := f_gen_imsi(imsi_suffix), + ps_domain := ps_domain, + mgcp_pars := t_MgcpParams, + hnb := omit, /* filled in later */ + expect_separate_sccp_cr := expect_separate_sccp_cr, + tx_sccp_cr_data_len := tx_sccp_cr_data_len, + pfcp_local_addr := pfcp_local_addr, + nas_pdu := omit, + sccp_addr_msc := omit, + sccp_addr_hnbgw := omit, + rab_rel_cause := rab_rel_cause, + hnbgw_timer_x31 := hnbgw_timer_x31 +} + + +function f_create_ranap_exp(octetstring l3_enc) runs on ConnHdlr { + BSSAP_PROC.call(RAN_register:{l3_enc, self}) { + [] BSSAP_PROC.getreply(RAN_register:{?, ?}) {}; + } +} + +type function void_fn(charstring id, TestHdlrParams pars) runs on ConnHdlr; + +function f_init_handler(TestHdlrParams pars, float t_guard := 20.0) runs on ConnHdlr { + /* make parameters available via component variable */ + g_pars := pars; + + /* start guard timer and activate it as default */ + g_Tguard.start(t_guard); + activate(as_Tguard_ConnHdlr()); + + map(self:HNBGWVTY, system:HNBGWVTY); + f_vty_set_prompts(HNBGWVTY); + f_vty_transceive(HNBGWVTY, "enable"); + + /* TODO: CTRL? */ + + f_sleep(1.0); +} + +/* global altstep for global guard timer; */ +private altstep as_Tguard_ConnHdlr() runs on ConnHdlr { + [] g_Tguard.timeout { + setverdict(fail, "Timeout of T_guard"); + mtc.stop; + } +} + +function f_bssap_expect(template (present) RANAP_PDU exp_rx) runs on ConnHdlr return RANAP_PDU +{ + var RANAP_PDU rx; + timer T := 5.0; + T.start; + alt { + [] BSSAP.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] BSSAP.receive(RANAP_PDU:?) { + setverdict(fail, "Got an unexpected RANAP message on BSSAP port, was waiting for ", exp_rx); + mtc.stop; + } + [] T.timeout { + setverdict(fail, "Timeout waiting for RANAP on BSSAP port: ", exp_rx); + mtc.stop; + } + } + T.stop; + return rx; +} + +/* send RANAP on Iuh and expect it to show up on Iu */ +function f_iuh2iu(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) +runs on ConnHdlr return RANAP_PDU { + var RANAP_PDU rx; + timer T := 5.0; + + if (istemplatekind(exp_rx, "omit")) { + exp_rx := tx; + } + + RUA.send(tx); + + return f_bssap_expect(exp_rx); +} + +/* send RANAP on Iu and expect it to show up on Iuh */ +function f_iu2iuh(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) +runs on ConnHdlr return RANAP_PDU { + if (istemplatekind(exp_rx, "omit")) { + exp_rx := tx; + } + + BSSAP.send(tx); + + return f_rua_expect(exp_rx) +} + +/* expect to receive a specific RUA message on Iuh */ +function f_rua_expect(template (present) RANAP_PDU exp_rx) runs on ConnHdlr return RANAP_PDU +{ + var RANAP_PDU rx; + timer T := 5.0; + T.start; + alt { + [] RUA.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] RUA.receive(RANAP_PDU:?) { + setverdict(fail, "Got an unexpected RUA message, was waiting for ", exp_rx); + mtc.stop; + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iuh ", exp_rx); + mtc.stop; + } + } + T.stop; + return rx; +} + +/* send RANAP on Iuh and expect it to show up on Iu */ +function f_iuh2iu_connect(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) +runs on ConnHdlr return RANAP_PDU { + var RANAP_PDU rx; + timer T := 5.0; + + if (istemplatekind(exp_rx, "omit")) { + exp_rx := tx; + } + + /* create an expect on the Iu side for the random NAS portion */ + if (g_pars.expect_separate_sccp_cr) { + f_ran_register_sccp_cr_without_payload(); + } else { + var template (omit) octetstring nas := f_ranap_extract_l3(valueof(tx)); + f_ran_register_exp(valueof(nas)); + } + + /* send it via Iuh (creating a RUA connection) */ + RUA.send(RUA_Conn_Req:{g_pars.ps_domain, tx}); + + if (g_pars.expect_separate_sccp_cr) { + /* Acknowledge the empty SCCP CR. RAN_Emulation does the confirmation, no need to respond. */ + BSSAP.receive(tr_RANAP_Conn_Req()); + } + + /* expect to receive it on the Iu side */ + return f_bssap_expect(exp_rx); +} + +/* 3GPP TS 48.006 9.2 Connection release: + * + * The MSC sends a SCCP released message. This message shall not contain + * any user data field. + * + * So what we expect normally is: + * + * HNBGW MSC + * RUA --id-Disconnect-------> | ---Data-Form-1(!)---> | Iu-ReleaseComplete + * | <--Released---------- | (no data) + * + * This function tests osmo-hnbgw behavior if the CN fails to send a RLSD: + * after some timeout, osmo-hnbgw should send a RLSD to the CN. + */ +function f_iuh2iu_disconnect(template (present) RANAP_PDU tx, RUA_IEs.Cause cause, + template RANAP_PDU exp_rx := omit) +runs on ConnHdlr return RANAP_PDU { + var RANAP_PDU rx + timer T := int2float(g_pars.hnbgw_timer_x31) + 1.0; + + if (istemplatekind(exp_rx, "omit")) { + exp_rx := tx; + } + + /* send it via Iuh (creating a RUA connection) */ + RUA.send(RUA_Disc_Req:{tx, cause}); + + /* expect to receive it on the Iu side */ + rx := f_bssap_expect(exp_rx); + + /* expect disconnect on the Iu side */ + T.start; + alt { + [] BSSAP.receive(RAN_Conn_Prim:MSC_CONN_PRIM_DISC_IND) { + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iu disconnect"); + return rx; + } + + } + return rx; +} + +private function f_build_initial_ue_with_nas(TestHdlrParams pars, octetstring nas) + return RANAP_PDU { + var RANAP_IEs.LAI lai := { + pLMNidentity := hex2oct(pars.hnb.lai.mcc_mnc), + lAC := int2oct(pars.hnb.lai.lac, 2), + iE_Extensions := omit + }; + var RANAP_IEs.SAI sai := { + pLMNidentity := lai.pLMNidentity, + lAC := lai.lAC, + sAC := int2oct(pars.hnb.sac, 2), + iE_Extensions := omit + } + var IuSignallingConnectionIdentifier sigc_id := int2bit(f_rnd_int(1000), 24); + var GlobalRNC_ID grnc_id := { + pLMNidentity := lai.pLMNidentity, + rNC_ID := 2342 + } + var template RANAP_PDU ret; + if (pars.ps_domain) { + var RANAP_IEs.RAC rac := '00'O; + ret := ts_RANAP_initialUE_PS(lai, rac, sai, nas, sigc_id, grnc_id); + } else { + ret := ts_RANAP_initialUE_CS(lai, sai, nas, sigc_id, grnc_id); + } + return valueof(ret); +} + +/* build a RANAP InitialUE based on the TestHdlrParams */ +function f_build_initial_ue(TestHdlrParams pars) return RANAP_PDU { + + var octetstring nas; + + if (pars.tx_sccp_cr_data_len == 0) { + nas := f_rnd_octstring(10); + } else { + /* The test asks for an exact number of Optional Data bytes. */ + + /* First see what size the RANAP part of the payload data is, + * to adjust the NAS PDU size to the size requested by the test (pars.tx_sccp_cr_data_len). */ + var RANAP_PDU initial_ue := f_build_initial_ue_with_nas(pars, '00'O); + + var octetstring ranap_plus_one_byte_nas := enc_RANAP_PDU(initial_ue); + var integer ranap_length := lengthof(ranap_plus_one_byte_nas) - 1; + + log("ranap_plus_one_byte_nas = ", lengthof(ranap_plus_one_byte_nas), " bytes, ", initial_ue, " = ", + ranap_plus_one_byte_nas); + log("ranap_length = ", ranap_length); + + /* SCCP CR has a payload length limit of 130 bytes. To trigger this limit, the RANAP + NAS PDU has to be + * > 130 bytes. It doesn't need to be 131 bytes in the NAS PDU alone, but let's just make it definitely + * large enough. To test for this limit, pars.tx_sccp_cr_data_len asks for a specific amount of data len. */ + nas := f_rnd_octstring(pars.tx_sccp_cr_data_len - ranap_length); + } + + var RANAP_PDU ret := f_build_initial_ue_with_nas(pars, nas); + + if (pars.tx_sccp_cr_data_len != 0) { + for (var integer attempts := 0; attempts < 2; attempts := attempts + 1) { + var octetstring check_len := enc_RANAP_PDU(ret); + log("final RANAP PDU length = ", lengthof(check_len)); + if (lengthof(check_len) == pars.tx_sccp_cr_data_len) { + return ret; + } + nas := f_rnd_octstring(lengthof(nas) + (pars.tx_sccp_cr_data_len - lengthof(check_len))); + log("that was off, changed NAS length to ", lengthof(nas), " and trying again"); + ret := f_build_initial_ue_with_nas(pars, nas); + } + setverdict(fail, "Ended up with wrong Optional Data length"); + mtc.stop; + } + return ret; +} + +/* build a RANAP RAB AssignmentResponse based on the TestHdlrParams */ +function f_build_rab_ass_resp(TestHdlrParams pars) return RANAP_PDU { + var template RAB_SetupOrModifiedList rab_sml; + + rab_sml := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA("192.168.1.23"), t_RAB_binding_port(1234)); + + return valueof(ts_RANAP_RabAssResp(rab_sml)); +} + +/* Reply to a received CRCX with an OK (or the reply configured in cpars), using the given parameters. + * Return true when an OK reply was sent, false otherwise. + * Count occurrence of Osmux, include Osmux parameters in the reply if necessary. */ +function f_handle_crcx(inout MgcpParameters pars, MgcpCommand mgcp_cmd) return template MgcpResponse { + var MgwResponse conn := pars.mgw_conn_ran; + if (pars.got_crcx_count > 0) { + conn := pars.mgw_conn_cn; + } + pars.got_crcx_count := pars.got_crcx_count + 1; + + var MgcpMessage mgcp_msg := { + command := mgcp_cmd + } + var template MgcpResponse mgcp_resp; + var MgcpOsmuxCID osmux_cid; + var MgcpCallId call_id := f_MgcpCmd_extract_call_id(mgcp_cmd); + if (ispresent(pars.mgcp_call_id)) { + if (pars.mgcp_call_id != call_id) { + setverdict(fail, "CRCX contained unexpected call id. Expected:", pars.mgcp_call_id, " got:", call_id); + mtc.stop; + } + } else { + pars.mgcp_call_id := call_id; + } + + /* When the endpoint contains a wildcard we keep the endpoint + * identifier we have set up in pars. Otherwise we use the + * endpoint name that the call agent has supplied */ + if (match(mgcp_cmd.line.ep, t_MGCP_EP_wildcard) == false) { + pars.mgcp_ep := mgcp_cmd.line.ep; + } + + if (conn.resp == -1) { + /* Reply with rror */ + var MgcpResponse mgcp_rsp := { + line := { + code := "542", + trans_id := mgcp_cmd.line.trans_id, + string := "FORCED_FAIL" + }, + sdp := omit + + } + var MgcpParameter mgcp_rsp_param := { + code := "Z", + val := pars.mgcp_ep + }; + mgcp_rsp.params[0] := mgcp_rsp_param; + return mgcp_rsp; + } + + if (conn.resp == 0) { + /* Do not reply at all */ + return omit; + } + + if (conn.resp != 1) { + setverdict(fail, "Unexpected value for pars.mgw_conn_*.resp, expect -1, 0 or 1"); + mtc.stop; + } + + var SDP_Message sdp := valueof(ts_SDP(conn.mgw_rtp_ip, conn.mgw_rtp_ip, + hex2str(pars.mgcp_call_id), "42", + conn.mgw_rtp_port, + { int2str(pars.rtp_payload_type) }, + { valueof(ts_SDP_rtpmap(pars.rtp_payload_type, + pars.rtp_sdp_format)), + valueof(ts_SDP_ptime(20)) })); + + if (f_mgcp_contains_par(mgcp_msg, "X-OSMUX")) { + if (not pars.use_osmux) { + setverdict(fail, "MSC sent X-Osmux parameter in MGCP, but not expecting any Osmux"); + mtc.stop; + } + pars.got_osmux_count := pars.got_osmux_count + 1; + /* we expect MSC to use wildcard here, i.e. osmux_cid == -1 */ + osmux_cid := f_MgcpCmd_extract_osmux_cid(mgcp_cmd); + log("f_handle_crcx(): got Osmux CID: ", osmux_cid); + if (osmux_cid != -1) { + setverdict(fail, "MSC using unexpected CID " & int2str(osmux_cid) & " != -1"); + mtc.stop; + } + + osmux_cid := 0; + mgcp_resp := ts_CRCX_ACK_osmux(mgcp_cmd.line.trans_id, conn.mgcp_connection_id, osmux_cid, sdp); + } else { + mgcp_resp := ts_CRCX_ACK(mgcp_cmd.line.trans_id, conn.mgcp_connection_id, sdp); + } + + f_mgcp_par_append(mgcp_resp.params, ts_MgcpParSpecEP(pars.mgcp_ep)); + + return mgcp_resp; +} + +function f_rab_ass_req(inout MgcpParameters pars) runs on ConnHdlr { + var MgcpCommand mgcp_cmd; + var RANAP_PDU tx; + var template RAB_SetupOrModifyList rab_sml; + timer T := 5.0; + + /* Send RAB Assignment Request */ + rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.cn_rtp_ip), t_RAB_binding_port(pars.cn_rtp_port)); + tx := valueof(ts_RANAP_RabAssReq(rab_sml)); + BSSAP.send(tx); + T.start; + + /* Handle MGCP CRCX */ + alt { + [] MGCP.receive(tr_CRCX) -> value mgcp_cmd { + log("CRCX1", mgcp_cmd); + var template MgcpResponse mgcp_rsp := f_handle_crcx(pars, mgcp_cmd); + MGCP.send(valueof(mgcp_rsp)); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for MGCP"); + } + } + T.stop; + + /* Expect RAB Assignment Request with IP/port from CRCX ACK via Iuh */ + rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_ran.mgw_rtp_ip), t_RAB_binding_port(pars.mgw_conn_ran.mgw_rtp_port)); + tx := valueof(ts_RANAP_RabAssReq(rab_sml)); + + f_rua_expect(tx); +} + +friend function f_rab_ass_resp(inout MgcpParameters pars) runs on ConnHdlr { + var MgcpCommand mgcp_cmd; + var RANAP_PDU tx; + var template RAB_SetupOrModifiedList rab_smdl; + + /* Send back RAB Assignment Response via Iuh */ + rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.hnb_rtp_ip), t_RAB_binding_port(pars.hnb_rtp_port)); + tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); + RUA.send(tx); + + interleave { + /* Expect MDCX with IP/port from RAB Assignment Response */ + [] MGCP.receive(tr_MDCX(tr_SDP(pars.hnb_rtp_ip, pars.hnb_rtp_port))) -> value mgcp_cmd { + var HostName mgw_rtp_ip; + var boolean exp_rua_rab_reass := false; + log("MDCX1", mgcp_cmd); + if (ispresent(pars.mgw_conn_ran.mgw_rtp_ip_mdcx)) { + mgw_rtp_ip := pars.mgw_conn_ran.mgw_rtp_ip_mdcx; + if (pars.mgw_conn_ran.mgw_rtp_ip != pars.mgw_conn_ran.mgw_rtp_ip_mdcx) { + exp_rua_rab_reass := true; + } + } else { + mgw_rtp_ip := pars.mgw_conn_ran.mgw_rtp_ip; + } + + /* Verify SDP of MDCX */ + var SDP_Message sdp := valueof(ts_SDP(mgw_rtp_ip, mgw_rtp_ip, hex2str(pars.mgcp_call_id), "42", pars.mgw_conn_ran.mgw_rtp_port, + { int2str(pars.rtp_payload_type) }, { valueof(ts_SDP_rtpmap(pars.rtp_payload_type, pars.rtp_sdp_format)), valueof(ts_SDP_ptime(20)) } )); + var template MgcpResponse mgcp_rsp := ts_MDCX_ACK(mgcp_cmd.line.trans_id, pars.mgw_conn_ran.mgcp_connection_id, sdp); + MGCP.send(valueof(mgcp_rsp)); + + /* If IP address changed, we expect HNBGW to Modify the RAB through RAB-Ass-Req: */ + if (exp_rua_rab_reass) { + var template RAB_SetupOrModifyList rab_sml; + /* Expect RAB Assignment Request with IP/port from MDCX ACK via Iuh */ + rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_ran.mgw_rtp_ip_mdcx), t_RAB_binding_port(pars.mgw_conn_ran.mgw_rtp_port)); + tx := valueof(ts_RANAP_RabAssReq(rab_sml)); + + f_rua_expect(tx); + /* Send back RAB Assignment Response via Iuh */ + rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.hnb_rtp_ip), t_RAB_binding_port(pars.hnb_rtp_port)); + tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); + RUA.send(tx); + /* This shouldn't trigger any MGCP, since nothing changed on the HNB IP side. Continue below. */ + } + } + /* Handle CRCX for second leg of endpoint, answer with IP/port */ + [] MGCP.receive(tr_CRCX(pars.mgcp_ep, tr_SDP(pars.cn_rtp_ip, pars.cn_rtp_port))) -> value mgcp_cmd { + log("CRCX2", mgcp_cmd); + /* Verify SDP of CRCX */ + var template MgcpResponse mgcp_rsp := f_handle_crcx(pars, mgcp_cmd); + MGCP.send(valueof(mgcp_rsp)); + } + } + + /* Expect RAB Assignment Response with IP/port from second CRCX ACK */ + rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_cn.mgw_rtp_ip), t_RAB_binding_port(pars.mgw_conn_cn.mgw_rtp_port)); + tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); + + f_bssap_expect(tx); +} + +function f_create_rab(inout MgcpParameters pars) runs on ConnHdlr { + f_rab_ass_req(pars); + f_rab_ass_resp(pars); +} + +altstep as_mgcp_dlcx(inout TestHdlrParams pars) runs on ConnHdlr { + var MgcpCommand mgcp_cmd; + + [] MGCP.receive(tr_DLCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { + log("DLCX", mgcp_cmd); + MGCP.send(ts_DLCX_ACK2(mgcp_cmd.line.trans_id)); + pars.mgcp_pars.got_dlcx_count := pars.mgcp_pars.got_dlcx_count + 1; + if (pars.mgcp_pars.got_dlcx_count != pars.mgcp_pars.got_crcx_count) { + repeat; + } + setverdict(pass); + } +} + +function f_pfcp_expect(template (present) PDU_PFCP exp_rx, float wait_time := 5.0) runs on ConnHdlr return PDU_PFCP +{ + var PDU_PFCP rx; + timer T := wait_time; + T.start; + alt { + [] PFCP.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] PFCP.receive(PDU_PFCP:?) { + setverdict(fail, "Got an unexpected PFCP message, was waiting for ", exp_rx); + mtc.stop; + } + [] T.timeout { + setverdict(fail, "Timeout waiting for PFCP ", exp_rx); + mtc.stop; + } + } + T.stop; + return rx; +} + +altstep as_disallow_pfcp() runs on ConnHdlr { + [] PFCP.receive(PDU_PFCP:?) { + setverdict(fail, "Received PFCP message, but no PFCP communication expected"); + mtc.stop; + } +} + +function f_perform_compl_l3(octetstring nas, boolean do_clear := true, boolean expect_iu_l3 := true) +runs on ConnHdlr { + timer T := 10.0; + + /* create an expect on the Iu side for the random NAS portion */ + if (g_pars.expect_separate_sccp_cr) { + f_ran_register_sccp_cr_without_payload(); + } else { + f_ran_register_exp(nas); + } + + /* send Connect via Iuh (creating a RUA connection) */ + var RANAP_PDU tx := f_build_initial_ue_with_nas(g_pars, nas); + RUA.send(RUA_Conn_Req:{g_pars.ps_domain, tx}); + + if (expect_iu_l3) { + /* Expect same message to arrive at CN */ + f_bssap_expect(tx); + } +} + +} /* module BSC_ConnectionHandler */ \ No newline at end of file diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 203b11e..30e624f 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -73,12 +73,30 @@ import from SCCPasp_Types all; +import from ConnHdlr all; + const integer NUM_MSC := 4; const integer NUM_SGSN := 4; const integer FIRST_MSC_IDX := 0; const integer FIRST_SGSN_IDX := NUM_MSC; +/* Translate from {msc,sgsn}x{0..n} to the proper index to use in g_cn[]. + * g_cn[] stores CN links, MSCs and SGSNs in the same array. + * For example, for 'sgsn 23', use g_cn[ f_cn_idx(ps_domain := true, cn_nr := 23) ]. + * + * Note the naming: + * cn_nr is the number used in the cfg file, as in 'msc 0'. + * cn_idx is the array index in g_cn[]. + */ +private function f_cn_idx(boolean ps_domain, integer cn_nr := 0) return integer +{ + if (ps_domain) { + return FIRST_SGSN_IDX + cn_nr; + } + return FIRST_MSC_IDX + cn_nr; +} + modulepar { /* IP address at which the HNodeB can be reached */ charstring mp_hnodeb_ip := "127.0.0.1"; @@ -225,114 +243,8 @@ sccp_addr_peer := omit } -type record MgwResponse { - integer resp, - HostName mgw_rtp_ip, - /* if set, used after first received MDCX: */ - HostName mgw_rtp_ip_mdcx optional, - PortNumber mgw_rtp_port, - MgcpConnectionId mgcp_connection_id -} -type record MgcpParameters { - integer got_crcx_count, - integer got_dlcx_count, - MgcpCallId mgcp_call_id optional, - MgcpEndpoint mgcp_ep, - MgwResponse mgw_conn_ran, - MgwResponse mgw_conn_cn, - uint7_t rtp_payload_type, - charstring rtp_sdp_format, - HostName hnb_rtp_ip, - PortNumber hnb_rtp_port, - HostName cn_rtp_ip, - PortNumber cn_rtp_port, - boolean use_osmux, - integer got_osmux_count -} - -template (value) MgcpParameters t_MgcpParams := { - got_crcx_count := 0, - got_dlcx_count := 0, - mgcp_call_id := omit, - mgcp_ep := "rtpbridge/1@mgw", - mgw_conn_ran := { - resp := 1, - mgw_rtp_ip := "127.1.2.1", - mgw_rtp_ip_mdcx := omit, - mgw_rtp_port := 10000, - mgcp_connection_id := '11111'H - }, - mgw_conn_cn := { - resp := 1, - mgw_rtp_ip := "127.1.2.2", - mgw_rtp_ip_mdcx := omit, - mgw_rtp_port := 20000, - mgcp_connection_id := '22222'H - }, - rtp_payload_type := 112, - rtp_sdp_format := "VND.3GPP.IUFP", - hnb_rtp_ip := "127.1.1.1", - hnb_rtp_port := 10001, - cn_rtp_ip := "127.1.3.1", - cn_rtp_port := 20001, - use_osmux := false, - got_osmux_count := 0 -} - -type record TestHdlrParams { - integer hnb_idx, - /* cn_idx indicates which CN link from g_cn[] to connect to the test component. - * See also f_cn_idx(). */ - integer cn_idx, - hexstring imsi, - boolean ps_domain, - MgcpParameters mgcp_pars optional, - HnbConfig hnb optional, - boolean expect_separate_sccp_cr, - integer tx_sccp_cr_data_len, - charstring pfcp_local_addr, - octetstring nas_pdu optional, - /* local and remote SCCP addresses, used in TC_mscpool_paging_* */ - SCCP_PAR_Address sccp_addr_msc optional, - SCCP_PAR_Address sccp_addr_hnbgw optional, - /* RAB release cause */ - RANAP_IEs.Cause rab_rel_cause -} - -/* We extend: - * RUA_ConnHdlr (for the Iuh side, emulating the HNB) - * RAN_ConnHdlr (for the Iu side, emulating the MSC) - * MGCP_ConnHdlr (for the MGCP side, emulating the MGW) - * StatsD_ConnHdlr (for the statsd interface, verifying counters) - */ -type component ConnHdlr extends RAN_ConnHdlr, MGCP_ConnHdlr, RUA_ConnHdlr, PFCP_ConnHdlr, StatsD_ConnHdlr { - var integer g_sccp_conn_id; - var TestHdlrParams g_pars; - timer g_Tguard; - - port TELNETasp_PT HNBGWVTY; -} - - -const MGCPOps MSC_MGCPOps := { - create_cb := refers(MGCP_Emulation.ExpectedCreateCallback), - unitdata_cb := refers(MGCP_Emulation.DummyUnitdataCallback) -} - -function f_create_ranap_exp(octetstring l3_enc) runs on ConnHdlr { - BSSAP_PROC.call(RAN_register:{l3_enc, self}) { - [] BSSAP_PROC.getreply(RAN_register:{?, ?}) {}; - } -} - - const integer NUM_HNB := 2; -type record HnbConfig { - LocationAreaIdentification lai, - integer sac -} - type component test_CT extends CTRL_Adapter_CT, StatsD_Checker_CT { var boolean g_initialized := false; @@ -587,6 +499,24 @@ /*********************************************************************** * code running in test_CT, preparing start of per-UE ConnHdlr ***********************************************************************/ +private function f_TestHdlrParams(integer imsi_suffix, + boolean ps_domain := false, + boolean expect_separate_sccp_cr := false, + integer tx_sccp_cr_data_len := 0, + integer cn_nr := 0, + template (value) RANAP_IEs.Cause rab_rel_cause := ts_RanapCause_nas_normal) +return TestHdlrParams { + var template (value) TestHdlrParams pars; + pars := t_pars(imsi_suffix, + ps_domain := ps_domain, + expect_separate_sccp_cr := expect_separate_sccp_cr, + tx_sccp_cr_data_len := tx_sccp_cr_data_len, + cn_idx := f_cn_idx(ps_domain, cn_nr), + pfcp_local_addr := mp_pfcp_ip_local, + rab_rel_cause := rab_rel_cause, + hnbgw_timer_x31 := mp_hnbgw_timer_x31); + return valueof(pars); +} /* inbound RUA connection establishment on Iuh side */ function IuhRanapCreateCallback(ContextId context_id, RUA_IEs.CN_DomainIndicator domain, charstring id) @@ -646,268 +576,6 @@ } /*********************************************************************** - * code running inside per-UE ConnHdlr - ***********************************************************************/ - -type function void_fn(charstring id, TestHdlrParams pars) runs on ConnHdlr; - -function f_init_handler(TestHdlrParams pars, float t_guard := 20.0) runs on ConnHdlr { - /* make parameters available via component variable */ - g_pars := pars; - - /* start guard timer and activate it as default */ - g_Tguard.start(t_guard); - activate(as_Tguard_ConnHdlr()); - - map(self:HNBGWVTY, system:HNBGWVTY); - f_vty_set_prompts(HNBGWVTY); - f_vty_transceive(HNBGWVTY, "enable"); - - /* TODO: CTRL? */ - - f_sleep(1.0); -} - -/* global altstep for global guard timer; */ -private altstep as_Tguard_ConnHdlr() runs on ConnHdlr { - [] g_Tguard.timeout { - setverdict(fail, "Timeout of T_guard"); - mtc.stop; - } -} - -private function f_bssap_expect(template (present) RANAP_PDU exp_rx) runs on ConnHdlr return RANAP_PDU -{ - var RANAP_PDU rx; - timer T := 5.0; - T.start; - alt { - [] BSSAP.receive(exp_rx) -> value rx { - setverdict(pass); - } - [] BSSAP.receive(RANAP_PDU:?) { - setverdict(fail, "Got an unexpected RANAP message on BSSAP port, was waiting for ", exp_rx); - mtc.stop; - } - [] T.timeout { - setverdict(fail, "Timeout waiting for RANAP on BSSAP port: ", exp_rx); - mtc.stop; - } - } - T.stop; - return rx; -} - -/* send RANAP on Iuh and expect it to show up on Iu */ -function f_iuh2iu(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) -runs on ConnHdlr return RANAP_PDU { - var RANAP_PDU rx; - timer T := 5.0; - - if (istemplatekind(exp_rx, "omit")) { - exp_rx := tx; - } - - RUA.send(tx); - - return f_bssap_expect(exp_rx); -} - -/* send RANAP on Iu and expect it to show up on Iuh */ -function f_iu2iuh(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) -runs on ConnHdlr return RANAP_PDU { - if (istemplatekind(exp_rx, "omit")) { - exp_rx := tx; - } - - BSSAP.send(tx); - - return f_rua_expect(exp_rx) -} - -/* expect to receive a specific RUA message on Iuh */ -private function f_rua_expect(template (present) RANAP_PDU exp_rx) runs on ConnHdlr return RANAP_PDU -{ - var RANAP_PDU rx; - timer T := 5.0; - T.start; - alt { - [] RUA.receive(exp_rx) -> value rx { - setverdict(pass); - } - [] RUA.receive(RANAP_PDU:?) { - setverdict(fail, "Got an unexpected RUA message, was waiting for ", exp_rx); - mtc.stop; - } - [] T.timeout { - setverdict(fail, "Timeout waiting for Iuh ", exp_rx); - mtc.stop; - } - } - T.stop; - return rx; -} - -/* send RANAP on Iuh and expect it to show up on Iu */ -function f_iuh2iu_connect(template (present) RANAP_PDU tx, template RANAP_PDU exp_rx := omit) -runs on ConnHdlr return RANAP_PDU { - var RANAP_PDU rx; - timer T := 5.0; - - if (istemplatekind(exp_rx, "omit")) { - exp_rx := tx; - } - - /* create an expect on the Iu side for the random NAS portion */ - if (g_pars.expect_separate_sccp_cr) { - f_ran_register_sccp_cr_without_payload(); - } else { - var template (omit) octetstring nas := f_ranap_extract_l3(valueof(tx)); - f_ran_register_exp(valueof(nas)); - } - - /* send it via Iuh (creating a RUA connection) */ - RUA.send(RUA_Conn_Req:{g_pars.ps_domain, tx}); - - if (g_pars.expect_separate_sccp_cr) { - /* Acknowledge the empty SCCP CR. RAN_Emulation does the confirmation, no need to respond. */ - BSSAP.receive(tr_RANAP_Conn_Req()); - } - - /* expect to receive it on the Iu side */ - return f_bssap_expect(exp_rx); -} - -/* 3GPP TS 48.006 9.2 Connection release: - * - * The MSC sends a SCCP released message. This message shall not contain - * any user data field. - * - * So what we expect normally is: - * - * HNBGW MSC - * RUA --id-Disconnect-------> | ---Data-Form-1(!)---> | Iu-ReleaseComplete - * | <--Released---------- | (no data) - * - * This function tests osmo-hnbgw behavior if the CN fails to send a RLSD: - * after some timeout, osmo-hnbgw should send a RLSD to the CN. - */ -function f_iuh2iu_disconnect(template (present) RANAP_PDU tx, RUA_IEs.Cause cause, - template RANAP_PDU exp_rx := omit) -runs on ConnHdlr return RANAP_PDU { - var RANAP_PDU rx - timer T := int2float(mp_hnbgw_timer_x31) + 1.0; - - if (istemplatekind(exp_rx, "omit")) { - exp_rx := tx; - } - - /* send it via Iuh (creating a RUA connection) */ - RUA.send(RUA_Disc_Req:{tx, cause}); - - /* expect to receive it on the Iu side */ - rx := f_bssap_expect(exp_rx); - - /* expect disconnect on the Iu side */ - T.start; - alt { - [] BSSAP.receive(RAN_Conn_Prim:MSC_CONN_PRIM_DISC_IND) { - setverdict(pass); - } - [] T.timeout { - setverdict(fail, "Timeout waiting for Iu disconnect"); - return rx; - } - - } - return rx; -} - -private function f_build_initial_ue_with_nas(TestHdlrParams pars, octetstring nas) - return RANAP_PDU { - var RANAP_IEs.LAI lai := { - pLMNidentity := hex2oct(pars.hnb.lai.mcc_mnc), - lAC := int2oct(pars.hnb.lai.lac, 2), - iE_Extensions := omit - }; - var RANAP_IEs.SAI sai := { - pLMNidentity := lai.pLMNidentity, - lAC := lai.lAC, - sAC := int2oct(pars.hnb.sac, 2), - iE_Extensions := omit - } - var IuSignallingConnectionIdentifier sigc_id := int2bit(f_rnd_int(1000), 24); - var GlobalRNC_ID grnc_id := { - pLMNidentity := lai.pLMNidentity, - rNC_ID := 2342 - } - var template RANAP_PDU ret; - if (pars.ps_domain) { - var RANAP_IEs.RAC rac := '00'O; - ret := ts_RANAP_initialUE_PS(lai, rac, sai, nas, sigc_id, grnc_id); - } else { - ret := ts_RANAP_initialUE_CS(lai, sai, nas, sigc_id, grnc_id); - } - return valueof(ret); -} - -/* build a RANAP InitialUE based on the TestHdlrParams */ -friend function f_build_initial_ue(TestHdlrParams pars) return RANAP_PDU { - - var octetstring nas; - - if (pars.tx_sccp_cr_data_len == 0) { - nas := f_rnd_octstring(10); - } else { - /* The test asks for an exact number of Optional Data bytes. */ - - /* First see what size the RANAP part of the payload data is, - * to adjust the NAS PDU size to the size requested by the test (pars.tx_sccp_cr_data_len). */ - var RANAP_PDU initial_ue := f_build_initial_ue_with_nas(pars, '00'O); - - var octetstring ranap_plus_one_byte_nas := enc_RANAP_PDU(initial_ue); - var integer ranap_length := lengthof(ranap_plus_one_byte_nas) - 1; - - log("ranap_plus_one_byte_nas = ", lengthof(ranap_plus_one_byte_nas), " bytes, ", initial_ue, " = ", - ranap_plus_one_byte_nas); - log("ranap_length = ", ranap_length); - - /* SCCP CR has a payload length limit of 130 bytes. To trigger this limit, the RANAP + NAS PDU has to be - * > 130 bytes. It doesn't need to be 131 bytes in the NAS PDU alone, but let's just make it definitely - * large enough. To test for this limit, pars.tx_sccp_cr_data_len asks for a specific amount of data len. */ - nas := f_rnd_octstring(pars.tx_sccp_cr_data_len - ranap_length); - } - - var RANAP_PDU ret := f_build_initial_ue_with_nas(pars, nas); - - if (pars.tx_sccp_cr_data_len != 0) { - for (var integer attempts := 0; attempts < 2; attempts := attempts + 1) { - var octetstring check_len := enc_RANAP_PDU(ret); - log("final RANAP PDU length = ", lengthof(check_len)); - if (lengthof(check_len) == pars.tx_sccp_cr_data_len) { - return ret; - } - nas := f_rnd_octstring(lengthof(nas) + (pars.tx_sccp_cr_data_len - lengthof(check_len))); - log("that was off, changed NAS length to ", lengthof(nas), " and trying again"); - ret := f_build_initial_ue_with_nas(pars, nas); - } - setverdict(fail, "Ended up with wrong Optional Data length"); - mtc.stop; - } - return ret; -} - -/* build a RANAP RAB AssignmentResponse based on the TestHdlrParams */ -friend function f_build_rab_ass_resp(TestHdlrParams pars) return RANAP_PDU { - var template RAB_SetupOrModifiedList rab_sml; - - rab_sml := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA("192.168.1.23"), t_RAB_binding_port(1234)); - - return valueof(ts_RANAP_RabAssResp(rab_sml)); -} - - -/*********************************************************************** * HNBAP Testing ***********************************************************************/ @@ -1171,41 +839,6 @@ * RUA / RANAP Testing ***********************************************************************/ -/* Translate from {msc,sgsn}x{0..n} to the proper index to use in g_cn[]. - * g_cn[] stores CN links, MSCs and SGSNs in the same array. - * For example, for 'sgsn 23', use g_cn[ f_cn_idx(ps_domain := true, cn_nr := 23) ]. - * - * Note the naming: - * cn_nr is the number used in the cfg file, as in 'msc 0'. - * cn_idx is the array index in g_cn[]. - */ -private function f_cn_idx(boolean ps_domain, integer cn_nr := 0) return integer -{ - if (ps_domain) { - return FIRST_SGSN_IDX + cn_nr; - } - return FIRST_MSC_IDX + cn_nr; -} - -private template (value) TestHdlrParams -t_pars(integer imsi_suffix, boolean ps_domain := false, integer hnb_idx := 0, - boolean expect_separate_sccp_cr := false, integer tx_sccp_cr_data_len := 0, - integer cn_nr := 0, template (value) RANAP_IEs.Cause rab_rel_cause := ts_RanapCause_nas_normal) := { - hnb_idx := hnb_idx, - cn_idx := f_cn_idx(ps_domain, cn_nr), - imsi := f_gen_imsi(imsi_suffix), - ps_domain := ps_domain, - mgcp_pars := t_MgcpParams, - hnb := omit, /* filled in later */ - expect_separate_sccp_cr := expect_separate_sccp_cr, - tx_sccp_cr_data_len := tx_sccp_cr_data_len, - pfcp_local_addr := mp_pfcp_ip_local, - nas_pdu := omit, - sccp_addr_msc := omit, - sccp_addr_hnbgw := omit, - rab_rel_cause := rab_rel_cause -} - /* Create an Iuh connection; send InitialUE; expect it to appear on new SCCP conenction */ friend function f_tc_initial_ue(charstring id, TestHdlrParams pars) runs on ConnHdlr { f_init_handler(pars); @@ -1218,7 +851,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(1)); + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), f_TestHdlrParams(1)); vc_conn.done; f_shutdown_helper(); @@ -1229,7 +862,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(2, true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), f_TestHdlrParams(2, true)); vc_conn.done; f_shutdown_helper(); @@ -1257,7 +890,7 @@ f_vty_set_sccp_max_optional_data(HNBGWVTY, 0); - vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(1, expect_separate_sccp_cr := true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), f_TestHdlrParams(1, expect_separate_sccp_cr := true)); vc_conn.done; /* reset */ @@ -1273,7 +906,7 @@ f_vty_set_sccp_max_optional_data(HNBGWVTY, 0); - vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(2, true, expect_separate_sccp_cr := true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), f_TestHdlrParams(2, true, expect_separate_sccp_cr := true)); vc_conn.done; /* reset */ @@ -1321,10 +954,10 @@ f_vty_set_sccp_max_optional_data(HNBGWVTY, t.max_optional_data); var ConnHdlr vc_conn; vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), - t_pars(100 + i, - ps_domain := ps_domain, - expect_separate_sccp_cr := t.expect_separate_sccp_cr, - tx_sccp_cr_data_len := t.data_len)); + f_TestHdlrParams(100 + i, + ps_domain := ps_domain, + expect_separate_sccp_cr := t.expect_separate_sccp_cr, + tx_sccp_cr_data_len := t.data_len)); vc_conn.done; } } @@ -1335,213 +968,6 @@ f_shutdown_helper(); } -/* Reply to a received CRCX with an OK (or the reply configured in cpars), using the given parameters. - * Return true when an OK reply was sent, false otherwise. - * Count occurrence of Osmux, include Osmux parameters in the reply if necessary. */ -function f_handle_crcx(inout MgcpParameters pars, MgcpCommand mgcp_cmd) return template MgcpResponse { - var MgwResponse conn := pars.mgw_conn_ran; - if (pars.got_crcx_count > 0) { - conn := pars.mgw_conn_cn; - } - pars.got_crcx_count := pars.got_crcx_count + 1; - - var MgcpMessage mgcp_msg := { - command := mgcp_cmd - } - var template MgcpResponse mgcp_resp; - var MgcpOsmuxCID osmux_cid; - var MgcpCallId call_id := f_MgcpCmd_extract_call_id(mgcp_cmd); - if (ispresent(pars.mgcp_call_id)) { - if (pars.mgcp_call_id != call_id) { - setverdict(fail, "CRCX contained unexpected call id. Expected:", pars.mgcp_call_id, " got:", call_id); - mtc.stop; - } - } else { - pars.mgcp_call_id := call_id; - } - - /* When the endpoint contains a wildcard we keep the endpoint - * identifier we have set up in pars. Otherwise we use the - * endpoint name that the call agent has supplied */ - if (match(mgcp_cmd.line.ep, t_MGCP_EP_wildcard) == false) { - pars.mgcp_ep := mgcp_cmd.line.ep; - } - - if (conn.resp == -1) { - /* Reply with rror */ - var MgcpResponse mgcp_rsp := { - line := { - code := "542", - trans_id := mgcp_cmd.line.trans_id, - string := "FORCED_FAIL" - }, - sdp := omit - - } - var MgcpParameter mgcp_rsp_param := { - code := "Z", - val := pars.mgcp_ep - }; - mgcp_rsp.params[0] := mgcp_rsp_param; - return mgcp_rsp; - } - - if (conn.resp == 0) { - /* Do not reply at all */ - return omit; - } - - if (conn.resp != 1) { - setverdict(fail, "Unexpected value for pars.mgw_conn_*.resp, expect -1, 0 or 1"); - mtc.stop; - } - - var SDP_Message sdp := valueof(ts_SDP(conn.mgw_rtp_ip, conn.mgw_rtp_ip, - hex2str(pars.mgcp_call_id), "42", - conn.mgw_rtp_port, - { int2str(pars.rtp_payload_type) }, - { valueof(ts_SDP_rtpmap(pars.rtp_payload_type, - pars.rtp_sdp_format)), - valueof(ts_SDP_ptime(20)) })); - - if (f_mgcp_contains_par(mgcp_msg, "X-OSMUX")) { - if (not pars.use_osmux) { - setverdict(fail, "MSC sent X-Osmux parameter in MGCP, but not expecting any Osmux"); - mtc.stop; - } - pars.got_osmux_count := pars.got_osmux_count + 1; - /* we expect MSC to use wildcard here, i.e. osmux_cid == -1 */ - osmux_cid := f_MgcpCmd_extract_osmux_cid(mgcp_cmd); - log("f_handle_crcx(): got Osmux CID: ", osmux_cid); - if (osmux_cid != -1) { - setverdict(fail, "MSC using unexpected CID " & int2str(osmux_cid) & " != -1"); - mtc.stop; - } - - osmux_cid := 0; - mgcp_resp := ts_CRCX_ACK_osmux(mgcp_cmd.line.trans_id, conn.mgcp_connection_id, osmux_cid, sdp); - } else { - mgcp_resp := ts_CRCX_ACK(mgcp_cmd.line.trans_id, conn.mgcp_connection_id, sdp); - } - - f_mgcp_par_append(mgcp_resp.params, ts_MgcpParSpecEP(pars.mgcp_ep)); - - return mgcp_resp; -} - -friend function f_create_rab(inout MgcpParameters pars) runs on ConnHdlr { - f_rab_ass_req(pars); - f_rab_ass_resp(pars); -} - -friend function f_rab_ass_req(inout MgcpParameters pars) runs on ConnHdlr { - var MgcpCommand mgcp_cmd; - var RANAP_PDU tx; - var template RAB_SetupOrModifyList rab_sml; - timer T := 5.0; - - /* Send RAB Assignment Request */ - rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.cn_rtp_ip), t_RAB_binding_port(pars.cn_rtp_port)); - tx := valueof(ts_RANAP_RabAssReq(rab_sml)); - BSSAP.send(tx); - T.start; - - /* Handle MGCP CRCX */ - alt { - [] MGCP.receive(tr_CRCX) -> value mgcp_cmd { - log("CRCX1", mgcp_cmd); - var template MgcpResponse mgcp_rsp := f_handle_crcx(pars, mgcp_cmd); - MGCP.send(valueof(mgcp_rsp)); - } - [] T.timeout { - setverdict(fail, "Timeout waiting for MGCP"); - } - } - T.stop; - - /* Expect RAB Assignment Request with IP/port from CRCX ACK via Iuh */ - rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_ran.mgw_rtp_ip), t_RAB_binding_port(pars.mgw_conn_ran.mgw_rtp_port)); - tx := valueof(ts_RANAP_RabAssReq(rab_sml)); - - f_rua_expect(tx); -} - -friend function f_rab_ass_resp(inout MgcpParameters pars) runs on ConnHdlr { - var MgcpCommand mgcp_cmd; - var RANAP_PDU tx; - var template RAB_SetupOrModifiedList rab_smdl; - - /* Send back RAB Assignment Response via Iuh */ - rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.hnb_rtp_ip), t_RAB_binding_port(pars.hnb_rtp_port)); - tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); - RUA.send(tx); - - interleave { - /* Expect MDCX with IP/port from RAB Assignment Response */ - [] MGCP.receive(tr_MDCX(tr_SDP(pars.hnb_rtp_ip, pars.hnb_rtp_port))) -> value mgcp_cmd { - var HostName mgw_rtp_ip; - var boolean exp_rua_rab_reass := false; - log("MDCX1", mgcp_cmd); - if (ispresent(pars.mgw_conn_ran.mgw_rtp_ip_mdcx)) { - mgw_rtp_ip := pars.mgw_conn_ran.mgw_rtp_ip_mdcx; - if (pars.mgw_conn_ran.mgw_rtp_ip != pars.mgw_conn_ran.mgw_rtp_ip_mdcx) { - exp_rua_rab_reass := true; - } - } else { - mgw_rtp_ip := pars.mgw_conn_ran.mgw_rtp_ip; - } - - /* Verify SDP of MDCX */ - var SDP_Message sdp := valueof(ts_SDP(mgw_rtp_ip, mgw_rtp_ip, hex2str(pars.mgcp_call_id), "42", pars.mgw_conn_ran.mgw_rtp_port, - { int2str(pars.rtp_payload_type) }, { valueof(ts_SDP_rtpmap(pars.rtp_payload_type, pars.rtp_sdp_format)), valueof(ts_SDP_ptime(20)) } )); - var template MgcpResponse mgcp_rsp := ts_MDCX_ACK(mgcp_cmd.line.trans_id, pars.mgw_conn_ran.mgcp_connection_id, sdp); - MGCP.send(valueof(mgcp_rsp)); - - /* If IP address changed, we expect HNBGW to Modify the RAB through RAB-Ass-Req: */ - if (exp_rua_rab_reass) { - var template RAB_SetupOrModifyList rab_sml; - /* Expect RAB Assignment Request with IP/port from MDCX ACK via Iuh */ - rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_ran.mgw_rtp_ip_mdcx), t_RAB_binding_port(pars.mgw_conn_ran.mgw_rtp_port)); - tx := valueof(ts_RANAP_RabAssReq(rab_sml)); - - f_rua_expect(tx); - /* Send back RAB Assignment Response via Iuh */ - rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.hnb_rtp_ip), t_RAB_binding_port(pars.hnb_rtp_port)); - tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); - RUA.send(tx); - /* This shouldn't trigger any MGCP, since nothing changed on the HNB IP side. Continue below. */ - } - } - /* Handle CRCX for second leg of endpoint, answer with IP/port */ - [] MGCP.receive(tr_CRCX(pars.mgcp_ep, tr_SDP(pars.cn_rtp_ip, pars.cn_rtp_port))) -> value mgcp_cmd { - log("CRCX2", mgcp_cmd); - /* Verify SDP of CRCX */ - var template MgcpResponse mgcp_rsp := f_handle_crcx(pars, mgcp_cmd); - MGCP.send(valueof(mgcp_rsp)); - } - } - - /* Expect RAB Assignment Response with IP/port from second CRCX ACK */ - rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.mgw_conn_cn.mgw_rtp_ip), t_RAB_binding_port(pars.mgw_conn_cn.mgw_rtp_port)); - tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); - - f_bssap_expect(tx); -} - -private altstep as_mgcp_dlcx(inout TestHdlrParams pars) runs on ConnHdlr { - var MgcpCommand mgcp_cmd; - - [] MGCP.receive(tr_DLCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { - log("DLCX", mgcp_cmd); - MGCP.send(ts_DLCX_ACK2(mgcp_cmd.line.trans_id)); - pars.mgcp_pars.got_dlcx_count := pars.mgcp_pars.got_dlcx_count + 1; - if (pars.mgcp_pars.got_dlcx_count != pars.mgcp_pars.got_crcx_count) { - repeat; - } - setverdict(pass); - } -} - friend function f_tc_rab_assignment(charstring id, TestHdlrParams pars) runs on ConnHdlr { const charstring hnb0_ctr_prefix := "TTCN3.hnb.001-01-L2342-R0-S55-C1."; var MgcpCommand mgcp_cmd; @@ -1594,7 +1020,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assignment), t_pars(3)); + vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assignment), f_TestHdlrParams(3)); vc_conn.done; f_shutdown_helper(); @@ -1650,7 +1076,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assign_fail), t_pars(4, rab_rel_cause := ts_RanapCause_radio_conn_lost)); + vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assign_fail), f_TestHdlrParams(4, rab_rel_cause := ts_RanapCause_radio_conn_lost)); vc_conn.done; f_shutdown_helper(); @@ -1713,7 +1139,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_rab_release), t_pars(5)); + vc_conn := f_start_handler_with_pars(refers(f_tc_rab_release), f_TestHdlrParams(5)); vc_conn.done; f_shutdown_helper(); @@ -1726,7 +1152,7 @@ f_init(); vc_conn := f_start_handler_with_pars(refers(f_tc_rab_release), - t_pars(8, rab_rel_cause := ts_RanapCause_radio_conn_lost)); + f_TestHdlrParams(8, rab_rel_cause := ts_RanapCause_radio_conn_lost)); vc_conn.done; f_shutdown_helper(); @@ -1776,7 +1202,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assign_mgcp_to), t_pars(6)); + vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assign_mgcp_to), f_TestHdlrParams(6)); vc_conn.done; f_shutdown_helper(); @@ -1789,7 +1215,7 @@ var ConnHdlr vc_conn; g_num_hnbs := 1; f_init(); - var template (value) TestHdlrParams pars := t_pars(3); + var template (value) TestHdlrParams pars := f_TestHdlrParams(3); /* Emulate change of local IuUP IP address after rx MDCX: */ pars.mgcp_pars.mgw_conn_ran.mgw_rtp_ip_mdcx := "127.3.2.1"; @@ -1819,7 +1245,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), t_pars(3)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), f_TestHdlrParams(3)); vc_conn.done; f_shutdown_helper(); @@ -1829,7 +1255,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), t_pars(4, true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), f_TestHdlrParams(4, true)); vc_conn.done; f_shutdown_helper(); @@ -1855,7 +1281,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), t_pars(5)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), f_TestHdlrParams(5)); vc_conn.done; f_shutdown_helper(); @@ -1865,7 +1291,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), t_pars(6)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), f_TestHdlrParams(6)); vc_conn.done; f_shutdown_helper(); @@ -1919,28 +1345,6 @@ } } -private function f_pfcp_expect(template (present) PDU_PFCP exp_rx, float wait_time := 5.0) runs on ConnHdlr return PDU_PFCP -{ - var PDU_PFCP rx; - timer T := wait_time; - T.start; - alt { - [] PFCP.receive(exp_rx) -> value rx { - setverdict(pass); - } - [] PFCP.receive(PDU_PFCP:?) { - setverdict(fail, "Got an unexpected PFCP message, was waiting for ", exp_rx); - mtc.stop; - } - [] T.timeout { - setverdict(fail, "Timeout waiting for PFCP ", exp_rx); - mtc.stop; - } - } - T.stop; - return rx; -} - friend function f_tc_ps_rab_assignment_with_pfcp(charstring id, TestHdlrParams pars) runs on ConnHdlr { const OCT8 c_SEID0 := '0000000000000000'O; const OCT8 c_SEID1 := '1111111111111111'O; @@ -2048,19 +1452,12 @@ f_init_pfcp(testcasename()); f_sleep(1.0); - vc_conn := f_start_handler_with_pars(refers(f_tc_ps_rab_assignment_with_pfcp), t_pars(7, ps_domain := true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ps_rab_assignment_with_pfcp), f_TestHdlrParams(7, ps_domain := true)); vc_conn.done; f_shutdown_helper(); } -altstep as_disallow_pfcp() runs on ConnHdlr { - [] PFCP.receive(PDU_PFCP:?) { - setverdict(fail, "Received PFCP message, but no PFCP communication expected"); - mtc.stop; - } -} - friend function f_tc_ps_rab_assignment_without_pfcp(charstring id, TestHdlrParams pars) runs on ConnHdlr { var RANAP_PDU tx; var RANAP_PDU rx; @@ -2113,7 +1510,7 @@ f_init_pfcp(testcasename()); f_sleep(1.0); - vc_conn := f_start_handler_with_pars(refers(f_tc_ps_rab_assignment_without_pfcp), t_pars(7, ps_domain := true)); + vc_conn := f_start_handler_with_pars(refers(f_tc_ps_rab_assignment_without_pfcp), f_TestHdlrParams(7, ps_domain := true)); vc_conn.done; f_shutdown_helper(); @@ -2173,27 +1570,6 @@ f_counter_name_vals_list_add(g_ctr_cn, cn_nr, countername, val); } -private function f_perform_compl_l3(octetstring nas, boolean do_clear := true, boolean expect_iu_l3 := true) -runs on ConnHdlr { - timer T := 10.0; - - /* create an expect on the Iu side for the random NAS portion */ - if (g_pars.expect_separate_sccp_cr) { - f_ran_register_sccp_cr_without_payload(); - } else { - f_ran_register_exp(nas); - } - - /* send Connect via Iuh (creating a RUA connection) */ - var RANAP_PDU tx := f_build_initial_ue_with_nas(g_pars, nas); - RUA.send(RUA_Conn_Req:{g_pars.ps_domain, tx}); - - if (expect_iu_l3) { - /* Expect same message to arrive at CN */ - f_bssap_expect(tx); - } -} - private function f_tc_cnpool_compl_l3(charstring id, TestHdlrParams pars) runs on ConnHdlr { f_init_handler(pars); f_perform_compl_l3(g_pars.nas_pdu); @@ -2202,7 +1578,7 @@ private function f_TC_cnpool_compl_l3(boolean ps_domain, octetstring nas_pdu, integer cn_nr, template (omit) charstring inc_countername := omit) runs on test_CT { var ConnHdlr vc_conn; - var template (value) TestHdlrParams pars := t_pars(0, ps_domain := ps_domain, cn_nr := cn_nr); + var template (value) TestHdlrParams pars := f_TestHdlrParams(0, ps_domain := ps_domain, cn_nr := cn_nr); pars.nas_pdu := nas_pdu; log("XXX ", pars); vc_conn := f_start_handler_with_pars(refers(f_tc_cnpool_compl_l3), pars); @@ -2671,7 +2047,7 @@ f_ctrs_cn_init(ps_domain := ps_domain); var ConnHdlr vc_conn1; - var template (value) TestHdlrParams pars1 := t_pars(0, ps_domain := ps_domain, cn_nr := 0); + var template (value) TestHdlrParams pars1 := f_TestHdlrParams(0, ps_domain := ps_domain, cn_nr := 0); pars1.sccp_addr_hnbgw := g_cn[valueof(pars1.cn_idx)].sccp_addr_peer; pars1.sccp_addr_msc := g_cn[valueof(pars1.cn_idx)].sccp_addr_own; vc_conn1 := f_start_handler_with_pars(refers(f_tc_mscpool_paging_imsi), pars1); @@ -2724,7 +2100,7 @@ f_ctrs_cn_init(ps_domain := ps_domain); var ConnHdlr vc_conn1; - var template (value) TestHdlrParams pars1 := t_pars(0, ps_domain := ps_domain, cn_nr := 0); + var template (value) TestHdlrParams pars1 := f_TestHdlrParams(0, ps_domain := ps_domain, cn_nr := 0); pars1.sccp_addr_hnbgw := g_cn[valueof(pars1.cn_idx)].sccp_addr_peer; pars1.sccp_addr_msc := g_cn[valueof(pars1.cn_idx)].sccp_addr_own; vc_conn1 := f_start_handler_with_pars(refers(f_tc_mscpool_paging_tmsi), pars1); @@ -2928,7 +2304,7 @@ f_sleep(1.0); var ConnHdlr vc_conn; - var template (value) TestHdlrParams pars := t_pars(0); + var template (value) TestHdlrParams pars := f_TestHdlrParams(0); vc_conn := f_start_handler_with_pars(refers(f_tc_apply_sccp), pars); vc_conn.done; @@ -2996,7 +2372,7 @@ g_num_hnbs := 1; f_init(); - vc_conn := f_start_handler_with_pars(refers(f_tc_second_rab_assignment), t_pars(3)); + vc_conn := f_start_handler_with_pars(refers(f_tc_second_rab_assignment), f_TestHdlrParams(3)); vc_conn.done; f_shutdown_helper(); -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38528?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I3a58c27a7472eea2421a45c31ac0145eb57a1f7e Gerrit-Change-Number: 38528 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de>

1 0

[M] Change in osmo-ttcn3-hacks[master]: hnbgw: Support testenv
by pespin 24 Oct '24

24 Oct '24

Hello Jenkins Builder, I'd like you to reexamine a change. Please visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email to look at the new patch set (#2). The following approvals got outdated and were removed: Verified+1 by Jenkins Builder Change subject: hnbgw: Support testenv ...................................................................... hnbgw: Support testenv Dependency package asciidoc-base is installed due to nftables checking for a2x presence during configure stage. Change-Id: Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 --- M _testenv/data/podman/Dockerfile M _testenv/testenv/osmo_dev.py A hnbgw/HNBGW_Tests-with-pfcp.cfg M hnbgw/osmo-hnbgw-with-pfcp.cfg M hnbgw/osmo-hnbgw.cfg A hnbgw/testenv_generic.cfg A hnbgw/testenv_with-pfcp.cfg 7 files changed, 86 insertions(+), 11 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/27/38527/2 -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newpatchset Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 Gerrit-Change-Number: 38527 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder

1 0

[M] Change in osmo-ttcn3-hacks[master]: hnbgw: Support testenv
by pespin 24 Oct '24

24 Oct '24

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email ) Change subject: hnbgw: Support testenv ...................................................................... hnbgw: Support testenv Dependency package asciidoc-base is installed due to nftables checking for a2x presence during configure stage. Change-Id: Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 --- M _testenv/data/podman/Dockerfile M _testenv/testenv/osmo_dev.py A hnbgw/HNBGW_Tests-with-pfcp.cfg M hnbgw/osmo-hnbgw.cfg A hnbgw/testenv_generic.cfg A hnbgw/testenv_with-pfcp.cfg 6 files changed, 65 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/27/38527/1 diff --git a/_testenv/data/podman/Dockerfile b/_testenv/data/podman/Dockerfile index 6f6c739..5348e2b 100644 --- a/_testenv/data/podman/Dockerfile +++ b/_testenv/data/podman/Dockerfile @@ -19,6 +19,7 @@ -y \ --no-install-recommends \ -o Dpkg::Options::="--force-confold" \ + asciidoc-base \ autoconf \ automake \ bc \ diff --git a/_testenv/testenv/osmo_dev.py b/_testenv/testenv/osmo_dev.py index 4dd581a..eb541aa 100644 --- a/_testenv/testenv/osmo_dev.py +++ b/_testenv/testenv/osmo_dev.py @@ -84,6 +84,8 @@ "default.opts", "ccache.opts", "gtp_linux.opts", + "hnbgw_with_nftables.opts", + "hnbgw_with_pfcp.opts", "iu.opts", "no_dahdi.opts", "no_doxygen.opts", diff --git a/hnbgw/HNBGW_Tests-with-pfcp.cfg b/hnbgw/HNBGW_Tests-with-pfcp.cfg new file mode 100644 index 0000000..7024bb9 --- /dev/null +++ b/hnbgw/HNBGW_Tests-with-pfcp.cfg @@ -0,0 +1,20 @@ +[ORDERED_INCLUDE] +# Common configuration, shared between test suites +"../Common.cfg" +# testsuite specific configuration, not expected to change +"./HNBGW_Tests.default" + +# Local configuration below + + [LOGGING] +*.JUnitLogger.filename_stem := "junit-xml-with-pfcp" + +[TESTPORT_PARAMETERS] + +[MODULE_PARAMETERS] +HNBGW_Tests.mp_enable_pfcp_tests := true; + +[MAIN_CONTROLLER] + +[EXECUTE] +HNBGW_Tests.control diff --git a/hnbgw/osmo-hnbgw.cfg b/hnbgw/osmo-hnbgw.cfg index 8a9774b..854e4cc 100644 --- a/hnbgw/osmo-hnbgw.cfg +++ b/hnbgw/osmo-hnbgw.cfg @@ -2,18 +2,26 @@ ! OsmoHNBGW (1.1.0) configuration saved from vty !! ! +log gsmtap 172.0.0.1 + logging level set-all debug + logging filter all 1 +! log stderr logging filter all 1 logging color 1 - logging print category-hex 1 + logging print category-hex 0 logging print category 1 + logging print level 1 logging print thread-id 0 logging print extended-timestamp 1 - logging print file 1 + logging print file basename last logging level set-all debug ! line vty no login + bind 127.0.0.1 +ctrl + bind 127.0.0.1 ! stats interval 0 diff --git a/hnbgw/testenv_generic.cfg b/hnbgw/testenv_generic.cfg new file mode 100644 index 0000000..d1daeab --- /dev/null +++ b/hnbgw/testenv_generic.cfg @@ -0,0 +1,16 @@ +[testsuite] +program=HNBGW_Tests +config=HNBGW_Tests.cfg + +[stp] +program=osmo-stp +make=libosmo-sigtran +package=osmo-stp +copy=osmo-stp.cfg + +[hnbgw] +program=osmo-hnbgw +make=osmo-hnbgw +package=osmo-hnbgw +copy=osmo-hnbgw.cfg +vty_port=4261 diff --git a/hnbgw/testenv_with-pfcp.cfg b/hnbgw/testenv_with-pfcp.cfg new file mode 100644 index 0000000..a86ea92 --- /dev/null +++ b/hnbgw/testenv_with-pfcp.cfg @@ -0,0 +1,16 @@ +[testsuite] +program=HNBGW_Tests +config=HNBGW_Tests-with-pfcp.cfg + +[stp] +program=osmo-stp +make=libosmo-sigtran +package=osmo-stp +copy=osmo-stp.cfg + +[hnbgw] +program=osmo-hnbgw -c osmo-hnbgw-with-pfcp.cfg +make=osmo-hnbgw +package=osmo-hnbgw +copy=osmo-hnbgw-with-pfcp.cfg +vty_port=4261 -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/38527?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email Gerrit-MessageType: newchange Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Id2bcc4e13881db01b8e4d9f1738355b8d779fa63 Gerrit-Change-Number: 38527 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de>

1 0