February 2022 - gerrit-log - lists.osmocom.org

Change in osmo-ttcn3-hacks[master]: MGCP_Templates: Add receive templates for SDP and use those in {CR,MD}CX

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27117 ) Change subject: MGCP_Templates: Add receive templates for SDP and use those in {CR,MD}CX ...................................................................... MGCP_Templates: Add receive templates for SDP and use those in {CR,MD}CX Change-Id: Ibc46888b1b7913d399c79ab735841844ff0487ad --- M library/MGCP_Templates.ttcn 1 file changed, 52 insertions(+), 4 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/17/27117/1 diff --git a/library/MGCP_Templates.ttcn b/library/MGCP_Templates.ttcn index 917ef89..59aeb7b 100644 --- a/library/MGCP_Templates.ttcn +++ b/library/MGCP_Templates.ttcn @@ -113,10 +113,10 @@ sdp := sdp } - template MgcpCommand tr_CRCX(template MgcpEndpoint ep := ?) := { + template MgcpCommand tr_CRCX(template MgcpEndpoint ep := ?, template SDP_Message sdp := *) := { line := t_MgcpCmdLine("CRCX", ?, ep), params := *, - sdp := * + sdp := sdp } template MgcpResponse tr_CRCX_ACK := { @@ -187,10 +187,10 @@ sdp := sdp } - template MgcpCommand tr_MDCX := { + template MgcpCommand tr_MDCX(template SDP_Message sdp := *) := { line := t_MgcpCmdLine("MDCX", ?, ?), params := *, - sdp := * + sdp := sdp } template MgcpResponse tr_MDCX_ACK := { @@ -284,6 +284,18 @@ } } + template SDP_connection tr_SDP_connection_IP(template charstring addr, template charstring addr_type := ?, + template integer ttl := *, + template integer num_of_addr := *) := { + net_type := "IN", + addr_type := addr_type, + conn_addr := { + addr := addr, + ttl := ttl, + num_of_addr := num_of_addr + } + } + template SDP_time ts_SDP_time(charstring beg, charstring end) := { time_field := { start_time := beg, @@ -310,6 +322,25 @@ attributes := attributes } + template SDP_media_desc tr_SDP_media_desc(template integer port_number := ?, + template SDP_fmt_list fmts := ?, + template SDP_attribute_list attributes := ?) := { + media_field := { + media := "audio", + ports := { + port_number := port_number, + num_of_ports := omit + }, + transport := "RTP/AVP", + fmts := fmts + }, + information := omit, + connections := omit, + bandwidth := omit, + key := omit, + attributes := attributes + } + /* master template for generating SDP based in template arguments */ template SDP_Message ts_SDP(charstring local_addr, charstring remote_addr, charstring session_id, charstring session_version, @@ -331,6 +362,23 @@ media_list := { ts_SDP_media_desc(rtp_port, fmts, attributes) } } + template SDP_Message tr_SDP(template charstring remote_addr := ?, template integer rtp_port := ?) := { + protocol_version := 0, + origin := ?, + session_name := ?, + information := *, + uri := *, + emails := *, + phone_numbers := *, + connection := tr_SDP_connection_IP(remote_addr, ?), + bandwidth := *, + times := ?, + timezone_adjustments := *, + key := *, + attributes := *, + media_list := { tr_SDP_media_desc(rtp_port) } + } + template SDP_attribute ts_SDP_rtpmap(integer fmt, charstring val) := { rtpmap := { attr_value := int2str(fmt) & " " & val -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27117 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: Ibc46888b1b7913d399c79ab735841844ff0487ad Gerrit-Change-Number: 27117 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: hnbgw: Match on connection IP/port in CRCX/MDCX

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27118 ) Change subject: hnbgw: Match on connection IP/port in CRCX/MDCX ...................................................................... hnbgw: Match on connection IP/port in CRCX/MDCX Change-Id: I465a677a29bf4e7a95245d480a241bd840eea75f --- M hnbgw/HNBGW_Tests.ttcn 1 file changed, 2 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/18/27118/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 7de0959..e3aa293 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -800,7 +800,7 @@ interleave { /* Expect MDCX with IP/port from RAB Assignment Response */ - [] MGCP.receive(tr_MDCX) -> value mgcp_cmd { + [] MGCP.receive(tr_MDCX(tr_SDP(pars.hnb_rtp_ip, pars.hnb_rtp_port))) -> value mgcp_cmd { log("MDCX1", mgcp_cmd); /* Verify SDP of MDCX */ var SDP_Message sdp := valueof(ts_SDP(pars.mgw_conn_1.mgw_rtp_ip, pars.mgw_conn_1.mgw_rtp_ip, hex2str(pars.mgcp_call_id), "42", pars.mgw_conn_1.mgw_rtp_port, @@ -809,7 +809,7 @@ MGCP.send(valueof(mgcp_rsp)); } /* Handle CRCX for second leg of endpoint, answer with IP/port */ - [] MGCP.receive(tr_CRCX(pars.mgcp_ep)) -> value mgcp_cmd { + [] 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); -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27118 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: I465a677a29bf4e7a95245d480a241bd840eea75f Gerrit-Change-Number: 27118 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: ranap: Add more RAB-related templates

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27113 ) Change subject: ranap: Add more RAB-related templates ...................................................................... ranap: Add more RAB-related templates Change-Id: I363428ab4af869bb1aa4470b33fa52366cbda8b4 --- M library/ranap/RANAP_Templates.ttcn 1 file changed, 60 insertions(+), 1 deletion(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/13/27113/1 diff --git a/library/ranap/RANAP_Templates.ttcn b/library/ranap/RANAP_Templates.ttcn index a1b0a59..db4145f 100644 --- a/library/ranap/RANAP_Templates.ttcn +++ b/library/ranap/RANAP_Templates.ttcn @@ -1,6 +1,8 @@ module RANAP_Templates { import from General_Types all; +import from Misc_Helpers all; +import from Native_Functions all; import from RANAP_IEs all; import from RANAP_CommonDataTypes all; @@ -487,6 +489,24 @@ * RAB Release *****************************************************************************************************/ +template (value) RAB_ID +t_RAB_id(integer rab_id) := int2bit(rab_id, 8) + +template (value) TransportLayerAddress ts_RAB_TLA4(OCT4 ip) := hex2bit('350001'H & oct2hex(ip) & '00000000000000000000000000'H) +template (value) TransportLayerAddress ts_RAB_TLA6(OCT16 ip) := hex2bit('350000'H & oct2hex(ip) & '00'H) +function f_ts_RAB_TLA(charstring addr) return template (value) TransportLayerAddress { + if (f_addr_is_ipv6(addr)) { + var OCT16 ip6 := f_inet6_addr(addr); + return ts_RAB_TLA6(ip6); + } else { + var OCT4 ip4 := f_inet_addr(addr); + return ts_RAB_TLA4(ip4); + } +} + +template (value) BindingID +t_RAB_binding_port(integer prt) := int2oct(prt, 2) & '0000'O + template (value) RANAP_PDU ts_RANAP_RabReleaseRequest(template (value) RAB_ID rab_id, template (value) Cause cause, template (omit) RAB_ReleaseRequest.protocolExtensions exts := omit) := { @@ -1271,6 +1291,45 @@ } } } +template (value) RAB_SetupOrModifiedList ts_RAB_SMdL(template (value) RAB_ID rab_id, + template (value) TransportLayerAddress tla, + template (value) BindingID binding_id) := { { + { + id := id_RAB_SetupOrModifiedItem, + criticality := ignore, + value_ := { + rAB_SetupOrModifiedItem := { + rAB_ID := rab_id, + transportLayerAddress := tla, + iuTransportAssociation := { + bindingID := binding_id + }, + dl_dataVolumes := omit, + iE_Extensions := omit + } + } + } +} } + +template RAB_SetupOrModifiedList tr_RAB_SMdL(template RAB_ID rab_id, + template TransportLayerAddress tla, + template BindingID binding_id) := { { + { + id := id_RAB_SetupOrModifiedItem, + criticality := ignore, + value_ := { + rAB_SetupOrModifiedItem := { + rAB_ID := rab_id, + transportLayerAddress := tla, + iuTransportAssociation := { + bindingID := binding_id + }, + dl_dataVolumes := *, + iE_Extensions := * + } + } + } +} } template (value) RANAP_PDU ts_RANAP_RabAssReq(template (value) RAB_SetupOrModifyList rab_sml, @@ -1283,7 +1342,7 @@ protocolIEs := { { id := id_RAB_SetupOrModifyList, - criticality := reject, + criticality := ignore, value_ := { rAB_SetupOrModifyList := rab_sml } -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27113 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: I363428ab4af869bb1aa4470b33fa52366cbda8b4 Gerrit-Change-Number: 27113 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: hnbgw: First working RAB Assignment

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27114 ) Change subject: hnbgw: First working RAB Assignment ...................................................................... hnbgw: First working RAB Assignment Change-Id: I5eae9f23ba6cf5e85a7daa025c4672c0a02031ca --- M hnbgw/HNBGW_Tests.ttcn 1 file changed, 240 insertions(+), 28 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/14/27114/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 42b16fc..3973a0e 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -111,10 +111,50 @@ sccp_addr_peer := omit } +type record CrcxResponse { + integer resp, + HostName mgw_rtp_ip, + PortNumber mgw_rtp_port, + MgcpConnectionId mgcp_connection_id +} +type record MgcpParameters { + integer got_crcx_count, + MgcpCallId mgcp_call_id optional, + MgcpEndpoint mgcp_ep, + CrcxResponse mgw_conn_1, + CrcxResponse mgw_conn_2, + uint7_t rtp_payload_type, + charstring rtp_sdp_format, + boolean use_osmux, + integer got_osmux_count +} + +template (value) MgcpParameters t_MgcpParams := { + got_crcx_count := 0, + mgcp_call_id := omit, + mgcp_ep := "rtpbridge/1@mgw", + mgw_conn_1 := { + resp := 1, + mgw_rtp_ip := "1.1.1.1", + mgw_rtp_port := 10000, + mgcp_connection_id := '11111'H + }, + mgw_conn_2 := { + resp := 1, + mgw_rtp_ip := "2.2.2.2", + mgw_rtp_port := 11000, + mgcp_connection_id := '22222'H + }, + rtp_payload_type := 23, + rtp_sdp_format := "FOO", + use_osmux := false, + got_osmux_count := 0 +} type record TestHdlrParams { integer hnb_idx, hexstring imsi, boolean ps_domain, + MgcpParameters mgcp_pars optional, HnbConfig hnb optional }; @@ -350,6 +390,7 @@ /* We cannot use vc_conn.start(f_init_handler(fn, id, pars)); as we cannot have * a stand-alone 'derefers()' call, see https://www.eclipse.org/forums/index.php/t/1091364/ */ pars.hnb := g_hnb_cfg[pars.hnb_idx]; + pars.mgcp_pars := valueof(t_MgcpParams); vc_conn.start(derefers(fn)(id, pars)); } @@ -530,6 +571,15 @@ } } +/* build a RANAP RAB AssignmentRespons 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 @@ -568,34 +618,6 @@ * RUA / RANAP Testing ***********************************************************************/ -testcase TC_RAB_Assignment() runs on test_CT { - //var HNBGW_ConnHdlr vc_conn; - f_init(); -/* - f_sleep(3.0); - HNBAP.send(tr_HNBAP_HNBRegisterRequest(char2oct("TTCN3 HNodeB"), - '00F110'O, - int2bit(1, 28), - int2oct(2, 2), - int2oct(3, 1), - int2oct(4, 2))); - - alt { - [] HNBAP.receive(tr_HNBAP_HNBRegisterAccept(?)) { - setverdict(pass); - } - [] HNBAP.receive(IUHEM_Event:?) { - repeat; - } - } - - //RUA.send(tr_RUA_Connect(cs_domain, int2bit(23, 24), normal_call, hex2oct(ranap_cm_service_req))); - //RANAP.receive(); -*/ - f_sleep(2.0); - f_shutdown_helper(); -} - private template (value) TestHdlrParams t_pars(integer imsi_suffix, boolean ps_domain := false,integer hnb_idx := 0) := { hnb_idx := hnb_idx, @@ -629,6 +651,195 @@ vc_conn.done; } +/* 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 occurence of Osmux, include Osmux parameters in the reply if necessary. */ +function f_handle_crcx(inout MgcpParameters pars, MgcpCommand mgcp_cmd) return template MgcpResponse { + var CrcxResponse conn := pars.mgw_conn_1; + if (pars.got_crcx_count > 0) { + conn := pars.mgw_conn_2; + } + 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_tc_rab_assignment(charstring id, TestHdlrParams pars) runs on ConnHdlr { + var MgcpCommand mgcp_cmd; + var RANAP_PDU tx; + var template RAB_SetupOrModifyList rab_sml; + var template RAB_SetupOrModifiedList rab_smdl; + timer T := 5.0; + + f_init_handler(pars); + f_create_mgcp_expect(ExpectCriteria:{omit,omit,omit}); + + tx := f_build_initial_ue(g_pars); + f_iuh2iu_connect(tx); + + /** BSSAP send: RAB Assignment Request + * MGCP receive: CRCXf_handle_crcx + * MGCP send: ACK + * RUA receive: RAB Assignment Request (*) + * RUA send: RAB Assignment Response + * MGCP receive: MDCX + * MGCP send: ACK + * BSSAP receive: RAB Assignment Response (*) + */ + + + rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA("192.168.0.1"), t_RAB_binding_port(1234)); + tx := valueof(ts_RANAP_RabAssReq(rab_sml)); + BSSAP.send(tx); + T.start; + + alt { + [] MGCP.receive(tr_CRCX) -> value mgcp_cmd { + var template MgcpResponse mgcp_rsp := f_handle_crcx(pars.mgcp_pars, mgcp_cmd); + MGCP.send(valueof(mgcp_rsp)); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for MGCP"); + } + } + + rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA(pars.mgcp_pars.mgw_conn_1.mgw_rtp_ip), t_RAB_binding_port(pars.mgcp_pars.mgw_conn_1.mgw_rtp_port)); + tx := valueof(ts_RANAP_RabAssReq(rab_sml)); + + alt { + [] RUA.receive(tx) { + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iuh ", tx); + } + } + + rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA("192.168.0.2"), t_RAB_binding_port(1235)); + tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); + RUA.send(tx); + T.start; + + interleave { + [] MGCP.receive(tr_MDCX) -> value mgcp_cmd { + log("MDCX1", mgcp_cmd); + var SDP_Message sdp := valueof(ts_SDP(pars.mgcp_pars.mgw_conn_1.mgw_rtp_ip, pars.mgcp_pars.mgw_conn_1.mgw_rtp_ip, hex2str(pars.mgcp_pars.mgcp_call_id), "42", pars.mgcp_pars.mgw_conn_1.mgw_rtp_port, + { int2str(pars.mgcp_pars.rtp_payload_type) }, { valueof(ts_SDP_rtpmap(pars.mgcp_pars.rtp_payload_type, pars.mgcp_pars.rtp_sdp_format)), valueof(ts_SDP_ptime(20)) } )); + var template MgcpResponse mgcp_rsp := ts_MDCX_ACK(mgcp_cmd.line.trans_id, pars.mgcp_pars.mgw_conn_1.mgcp_connection_id, sdp); + MGCP.send(valueof(mgcp_rsp)); + } + /* Second CRCX */ + [] MGCP.receive(tr_CRCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { + log("CRCX2", mgcp_cmd); + var template MgcpResponse mgcp_rsp := f_handle_crcx(pars.mgcp_pars, mgcp_cmd); + MGCP.send(valueof(mgcp_rsp)); + } + } + + rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA(pars.mgcp_pars.mgw_conn_2.mgw_rtp_ip), t_RAB_binding_port(pars.mgcp_pars.mgw_conn_2.mgw_rtp_port)); + tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); + + log("Resp:", tx); + alt { + [] BSSAP.receive(tx) { + log("Got RAB Resp") + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iuh ", tx); + } + } +} + +testcase TC_rab_assignment() runs on test_CT { + var ConnHdlr vc_conn; + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_rab_assignment), t_pars(3)); + vc_conn.done; +} /* Create an Iuh connection; send InitialUE; transceive data both directions */ friend function f_tc_ranap_bidir(charstring id, TestHdlrParams pars) runs on ConnHdlr { @@ -707,6 +918,7 @@ execute(TC_ranap_ps_initial_ue()); execute(TC_ranap_cs_bidir()); execute(TC_ranap_ps_bidir()); + execute(TC_rab_assignment()); execute(TC_ranap_cs_mo_disconnect()); execute(TC_ranap_ps_mo_disconnect()); } -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27114 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: I5eae9f23ba6cf5e85a7daa025c4672c0a02031ca Gerrit-Change-Number: 27114 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: hnbgw: Check for DLCX on Iu Release as well

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27115 ) Change subject: hnbgw: Check for DLCX on Iu Release as well ...................................................................... hnbgw: Check for DLCX on Iu Release as well Change-Id: Id53e99e51dbc6b9af67503ba6ecbc8990a7de4c9 --- M hnbgw/HNBGW_Tests.ttcn 1 file changed, 37 insertions(+), 12 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/15/27115/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 3973a0e..8a3c885 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -758,24 +758,16 @@ tx := f_build_initial_ue(g_pars); f_iuh2iu_connect(tx); - /** BSSAP send: RAB Assignment Request - * MGCP receive: CRCXf_handle_crcx - * MGCP send: ACK - * RUA receive: RAB Assignment Request (*) - * RUA send: RAB Assignment Response - * MGCP receive: MDCX - * MGCP send: ACK - * BSSAP receive: RAB Assignment Response (*) - */ - - + /* Send RAB Assignment Request */ rab_sml := ts_RAB_SML(t_RAB_id(23), f_ts_RAB_TLA("192.168.0.1"), t_RAB_binding_port(1234)); 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_pars, mgcp_cmd); MGCP.send(valueof(mgcp_rsp)); } @@ -784,6 +776,7 @@ } } + /* 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.mgcp_pars.mgw_conn_1.mgw_rtp_ip), t_RAB_binding_port(pars.mgcp_pars.mgw_conn_1.mgw_rtp_port)); tx := valueof(ts_RANAP_RabAssReq(rab_sml)); @@ -796,27 +789,32 @@ } } + /* Send back RAB Assignment Response via Iuh */ rab_smdl := ts_RAB_SMdL(t_RAB_id(23), f_ts_RAB_TLA("192.168.0.2"), t_RAB_binding_port(1235)); tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); RUA.send(tx); T.start; interleave { + /* Expect MDCX with IP/port from RAB Assignment Response */ [] MGCP.receive(tr_MDCX) -> value mgcp_cmd { log("MDCX1", mgcp_cmd); + /* Verify SDP of MDCX */ var SDP_Message sdp := valueof(ts_SDP(pars.mgcp_pars.mgw_conn_1.mgw_rtp_ip, pars.mgcp_pars.mgw_conn_1.mgw_rtp_ip, hex2str(pars.mgcp_pars.mgcp_call_id), "42", pars.mgcp_pars.mgw_conn_1.mgw_rtp_port, { int2str(pars.mgcp_pars.rtp_payload_type) }, { valueof(ts_SDP_rtpmap(pars.mgcp_pars.rtp_payload_type, pars.mgcp_pars.rtp_sdp_format)), valueof(ts_SDP_ptime(20)) } )); var template MgcpResponse mgcp_rsp := ts_MDCX_ACK(mgcp_cmd.line.trans_id, pars.mgcp_pars.mgw_conn_1.mgcp_connection_id, sdp); MGCP.send(valueof(mgcp_rsp)); } - /* Second CRCX */ + /* Handle CRCX for second leg of endpoint, answer with IP/port */ [] MGCP.receive(tr_CRCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { log("CRCX2", mgcp_cmd); + /* Verify SDP of CRCX */ var template MgcpResponse mgcp_rsp := f_handle_crcx(pars.mgcp_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.mgcp_pars.mgw_conn_2.mgw_rtp_ip), t_RAB_binding_port(pars.mgcp_pars.mgw_conn_2.mgw_rtp_port)); tx := valueof(ts_RANAP_RabAssResp(rab_smdl)); @@ -830,6 +828,33 @@ setverdict(fail, "Timeout waiting for Iuh ", tx); } } + + /* Send Iu Release */ + tx := valueof(ts_RANAP_IuReleaseCommand(ts_RanapCause_om_intervention)); + f_iu2iuh(tx); + + T.start; + var integer count := 0; + + alt { + [count == 0] MGCP.receive(tr_DLCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { + log("DLCX1", mgcp_cmd); + MGCP.send(ts_DLCX_ACK2(mgcp_cmd.line.trans_id)); + count := 1; + repeat; + } + [count == 1] MGCP.receive(tr_DLCX(pars.mgcp_pars.mgcp_ep)) -> value mgcp_cmd { + log("DLCX2", mgcp_cmd); + MGCP.send(ts_DLCX_ACK2(mgcp_cmd.line.trans_id)); + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for DLCX"); + } + } + + tx := valueof(ts_RANAP_IuReleaseComplete()); + f_iuh2iu(tx); } testcase TC_rab_assignment() runs on test_CT { -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27115 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: Id53e99e51dbc6b9af67503ba6ecbc8990a7de4c9 Gerrit-Change-Number: 27115 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: hnbgw: Connect MGCP ports in f_start_handler_create

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27112 ) Change subject: hnbgw: Connect MGCP ports in f_start_handler_create ...................................................................... hnbgw: Connect MGCP ports in f_start_handler_create Change-Id: I0c9c0c84bc38abded319581eae46807f0294115e --- M hnbgw/HNBGW_Tests.ttcn 1 file changed, 3 insertions(+), 0 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/12/27112/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 6b87f72..42b16fc 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -338,6 +338,9 @@ connect(vc_conn:BSSAP, g_msc.vc_RAN:CLIENT); connect(vc_conn:BSSAP_PROC, g_msc.vc_RAN:PROC); } + /* MGCP part */ + connect(vc_conn:MGCP, vc_MGCP:MGCP_CLIENT); + connect(vc_conn:MGCP_PROC, vc_MGCP:MGCP_PROC); return vc_conn; } -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27112 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: I0c9c0c84bc38abded319581eae46807f0294115e Gerrit-Change-Number: 27112 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: hnbgw: Add tests for Iuh->Iu disconnect

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27111 ) Change subject: hnbgw: Add tests for Iuh->Iu disconnect ...................................................................... hnbgw: Add tests for Iuh->Iu disconnect Change-Id: I8c1858382483af94542af9eb6977d360f26fdaef --- M hnbgw/HNBGW_Tests.ttcn M library/RUA_Emulation.ttcn 2 files changed, 108 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/11/27111/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 59cda1a..6b87f72 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -461,6 +461,44 @@ return rx; } +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 := 5.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 */ + T.start; + alt { + [] BSSAP.receive(exp_rx) -> value rx { + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iu ", exp_rx); + return rx; + } + } + + /* expect disconnect on the Iu side */ + 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; +} + /* build a RANAP InitialUE based on the TestHdlrParams */ friend function f_build_initial_ue(TestHdlrParams pars) return RANAP_PDU { var LAI lai := { @@ -624,6 +662,40 @@ } +private function f_tc_ranap_mo_disconnect(charstring id, TestHdlrParams pars) runs on ConnHdlr { + f_init_handler(pars); + + /* HNB -> MSC: InitialUE */ + f_iuh2iu_connect(f_build_initial_ue(g_pars)); + + /* MSC <- HNB: DirectTransfer */ + f_iu2iuh(ts_RANAP_DirectTransfer(f_rnd_octstring(10))); + /* MSC -> HNB: DirectTransfer */ + f_iuh2iu(ts_RANAP_DirectTransfer(f_rnd_octstring(10))); + + /* MSC <- HNB: RUA disconnect */ + f_iuh2iu_disconnect(ts_RANAP_IuReleaseComplete, RUA_IEs.Cause:{misc:=processing_overload}); +} +testcase TC_ranap_cs_mo_disconnect() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), t_pars(5)); + vc_conn.done; +} +testcase TC_ranap_ps_mo_disconnect() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_mo_disconnect), t_pars(6)); + vc_conn.done; +} + + control { @@ -632,6 +704,8 @@ execute(TC_ranap_ps_initial_ue()); execute(TC_ranap_cs_bidir()); execute(TC_ranap_ps_bidir()); + execute(TC_ranap_cs_mo_disconnect()); + execute(TC_ranap_ps_mo_disconnect()); } } diff --git a/library/RUA_Emulation.ttcn b/library/RUA_Emulation.ttcn index 23b4a7a..98e5a1f 100644 --- a/library/RUA_Emulation.ttcn +++ b/library/RUA_Emulation.ttcn @@ -53,11 +53,12 @@ port RUA_Conn_PT RUA; } - /* port between individual per-connection components and this dispatcher */ type port RUA_Conn_PT message { inout RANAP_PDU, - RUA_Conn_Req; + RUA_Conn_Req, + RUA_Disc_Req, + RUA_Disc_Ind; } with { extension "internal" }; type record RUA_Conn_Req { @@ -65,6 +66,15 @@ RANAP_PDU ranap }; +type record RUA_Disc_Req { + RANAP_PDU ranap, + RUA_IEs.Cause cause +}; + +type record RUA_Disc_Ind { + RUA_IEs.Cause cause +}; + type bitstring ContextId length(24); // with { variant "FIELDLENGTH(24)" }; /* represents a single RANAP connection over RUA */ @@ -257,6 +267,8 @@ var RUA_IEs.CN_DomainIndicator domain_ind; var RUA_ConnHdlr vc_conn; var RUA_Conn_Req creq; + var RUA_Disc_Req dreq; + var RUA_IEs.Cause cause; /* RUA -> Client: UNIT-DATA (connectionless RUA) from CN */ [] RUA.receive(tr_RUA_ConnectionlessTransfer) -> value rua { @@ -277,6 +289,7 @@ vc_conn := g_rua_ops.create_cb.apply(context_id, domain_ind, g_rua_id); /* store mapping between client components and RUA contextId */ f_conn_table_add(vc_conn, domain_ind, context_id); + /* TODO: notify user about incoming connection? */ /* handle user payload */ f_handle_userData_RANAP(vc_conn, ranap); } @@ -291,6 +304,15 @@ /* RUA -> Client: disconnect of an existing connection */ [] RUA.receive(tr_RUA_Disconnect) -> value rua { + cause := rua.initiatingMessage.value_.disconnect_.protocolIEs[2].value_.cause; + context_id := rua.initiatingMessage.value_.disconnect_.protocolIEs[1].value_.context_ID; + vc_conn := f_comp_by_context_id(context_id); + /* send contained RANAP message to user */ + ranap_enc := rua.initiatingMessage.value_.disconnect_.protocolIEs[3].value_.rANAP_Message; + f_handle_userData_RANAP(vc_conn, dec_RANAP_PDU(ranap_enc)); + /* notify user of disconnect */ + CLIENT.send(RUA_Disc_Ind:{cause}); + f_conn_table_del(context_id); } /* RANAP from client through an existing RANAP connection */ @@ -301,6 +323,16 @@ RUA.send(ts_RUA_DirectTransfer(domain_ind, context_id, enc_RANAP_PDU(ranap))); } + /* Disconnect request from client */ + [] CLIENT.receive(RUA_Disc_Req:?) -> value dreq sender vc_conn { + var octetstring enc_ranap := enc_RANAP_PDU(dreq.ranap); + var integer idx := f_idx_by_comp(vc_conn); + context_id := int2bit(ConnectionTable[idx].context_id, 24); + domain_ind := ConnectionTable[idx].domain; + RUA.send(ts_RUA_Disconnect(domain_ind, context_id, dreq.cause, enc_ranap)); + f_conn_table_del(context_id); + } + /* RANAP from client, for a new RANAP connection */ [] CLIENT.receive(RUA_Conn_Req:?) -> value creq sender vc_conn { var octetstring enc_ranap := enc_RANAP_PDU(creq.ranap); -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27111 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: I8c1858382483af94542af9eb6977d360f26fdaef Gerrit-Change-Number: 27111 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-CC: laforge <laforge(a)osmocom.org> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: WIP: more work towards HNBGW_Tests

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27110 ) Change subject: WIP: more work towards HNBGW_Tests ...................................................................... WIP: more work towards HNBGW_Tests Change-Id: I99ddd30fd2a27f2025928006db79388625e26b01 --- M hnbgw/HNBGW_Tests.ttcn D hnbgw/MSC_ConnHdlr.ttcn M hnbgw/gen_links.sh M hnbgw/osmo-hnbgw.cfg M hnbgw/osmo-stp.cfg M hnbgw/regen_makefile.sh A library/RUA_Emulation.ttcn 7 files changed, 790 insertions(+), 181 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/10/27110/1 diff --git a/hnbgw/HNBGW_Tests.ttcn b/hnbgw/HNBGW_Tests.ttcn index 750c927..59cda1a 100644 --- a/hnbgw/HNBGW_Tests.ttcn +++ b/hnbgw/HNBGW_Tests.ttcn @@ -15,6 +15,7 @@ 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; @@ -31,23 +32,24 @@ import from TELNETasp_PortType all; import from HNBAP_Templates all; +import from HNBAP_PDU_Descriptions all; + import from RUA_IEs all; import from RUA_Templates all; -import from HNBAP_PDU_Descriptions 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 RAN_Adapter all; -import from BSSAP_Types all; import from RAN_Adapter all; import from RAN_Emulation all; -import from BSSAP_CodecPort all; -import from IPA_Emulation all; -import from IPA_CodecPort all; -import from IPA_Types all; - import from MGCP_Emulation all; import from MGCP_Types all; @@ -55,8 +57,6 @@ import from MGCP_CodecPort all; import from SDP_Types all; -import from MSC_ConnHdlr all; - modulepar { /* IP address at which the HNodeB can be reached */ charstring mp_hnodeb_ip := "127.0.0.1"; @@ -83,16 +83,68 @@ RAN_Configuration mp_sgsn_cfg := { transport := RANAP_TRANSPORT_IuCS, sccp_service_type := "mtp3_itu", - sctp_addr := { 23905, "127.0.0.1", 2905, "127.0.0.1" }, - own_pc := 185, /* 0.23.1 first MSC emulation */ + sctp_addr := { 23906, "127.0.0.1", 2905, "127.0.0.1" }, + own_pc := 185, /* 0.23.1 first SGSN emulation */ own_ssn := 142, peer_pc := 189, /* 0.23.5 osmo-hnbgw */ peer_ssn := 142, sio := '83'O, - rctx := 1 + rctx := 2 }; } +function MSC_UnitdataCallback(RANAP_PDU ranap) runs on RAN_Emulation_CT return template RANAP_PDU { + // FIXME + return ts_RANAP_Reset(ts_RanapCause_om_intervention, cs_domain); +} + +const RanOps MSC_RanOps := { + ranap_create_cb := refers(RAN_Emulation.RanapExpectedCreateCallback), + ranap_unitdata_cb := refers(MSC_UnitdataCallback), + ps_domain := false, + decode_dtap := false, + role_ms := false, + protocol := RAN_PROTOCOL_RANAP, + transport := RANAP_TRANSPORT_IuCS, + use_osmux := false, + sccp_addr_local := omit, + sccp_addr_peer := omit +} + +type record TestHdlrParams { + integer hnb_idx, + hexstring imsi, + boolean ps_domain, + HnbConfig hnb optional +}; + +/* 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) + */ +type component ConnHdlr extends RAN_ConnHdlr, MGCP_ConnHdlr, RUA_ConnHdlr { + var integer g_sccp_conn_id; + + var TestHdlrParams g_pars; + timer g_Tguard; +} + + +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 := 1; + const hexstring ranap_cm_service_req := '001340400000060003400100000f40060000f11028b6003a40080000f110ffffffff0010400e0d052411035758a605f44e9d4aef004f400300001c0056400500f1100017'H; const hexstring ranap_auth_req := '00144032000002001040262505120217dc146aeac56cb5ff6d5fb51f47f19220108ca5a6d0c8110000b9e9272498872764003b400100'H; const hexstring ranap_auth_resp := '001440140000010010400d0c0554ccbdd0302104002f3ae4'H; @@ -100,20 +152,27 @@ const hexstring ranap_rab_ass_req := '0000005900000100364052000001003500487824cd80102fa7201a2c0000f44c080a028000514000272028140067400000222814003c40000000503d02000227c03500010a0901a200000000000000000000000000401f4a0000400100'H; const hexstring iu_release_compl := '20010003000000'H; +type record HnbConfig { + LocationAreaIdentification lai, + integer sac +} + type component test_CT extends CTRL_Adapter_CT { var boolean g_initialized := false; - var MGCP_Emulation_CT vc_MGCP; - var Iuh_Emulation_CT vc_Iuh; - + /********************* Iu side */ var RAN_Adapter g_msc; var RAN_Adapter g_sgsn; /* SGSN IuPS missing */ - port TELNETasp_PT HNBGWVTY; - port HNBAP_PT HNBAP; - port RUA_PT RUA; + /********************* Iuh side */ + var HnbConfig g_hnb_cfg[NUM_HNB]; + var Iuh_Emulation_CT vc_Iuh[NUM_HNB]; + var RUA_Emulation_CT vc_RUA[NUM_HNB]; + port HNBAP_PT HNBAP[NUM_HNB]; + var MGCP_Emulation_CT vc_MGCP; + port TELNETasp_PT HNBGWVTY; /* global test case guard timer (actual timeout value is set in f_init()) */ timer T_guard := 30.0; } @@ -163,25 +222,49 @@ vc_MGCP.start(MGCP_Emulation.main(ops, pars, id)); } -/* global initialization function */ -function f_init(charstring id := "HBGW", float guard_timeout := 30.0) runs on test_CT { +function f_init_hnodeb(charstring id, integer hnb_idx, RuaOps rua_ops) runs on test_CT { + id := id & "-Iuh" & int2str(hnb_idx); - T_guard.start(guard_timeout); - activate(as_Tguard()); - + /* Iuh lower layer (RUA/HNBAP demux) */ var Iuh_conn_parameters iuh_pars; iuh_pars.remote_ip := mp_hnbgw_ip; iuh_pars.remote_sctp_port := mp_hnbgw_iuh_port; iuh_pars.local_ip := mp_hnodeb_ip; - iuh_pars.local_sctp_port := mp_hnodeb_port; - vc_Iuh := Iuh_Emulation_CT.create(id & "-Iuh"); - connect(self:HNBAP, vc_Iuh:HNBAP); - connect(self:RUA, vc_Iuh:RUA); + iuh_pars.local_sctp_port := mp_hnodeb_port + hnb_idx; + vc_Iuh[hnb_idx] := Iuh_Emulation_CT.create(id); + connect(self:HNBAP[hnb_idx], vc_Iuh[hnb_idx]:HNBAP); - vc_Iuh.start(Iuh_Emulation.main(iuh_pars, id & "-Iuh")); - f_init_mgcp(id); + vc_RUA[hnb_idx] := RUA_Emulation_CT.create(id & "-RUA"); + connect(vc_RUA[hnb_idx]:RUA, vc_Iuh[hnb_idx]:RUA); - /* MSC */ + /* Start Iuh side components */ + vc_Iuh[hnb_idx].start(Iuh_Emulation.main(iuh_pars, id)); + vc_RUA[hnb_idx].start(RUA_Emulation.main(rua_ops, id & "-RUA")); +} + +/* global initialization function */ +function f_init(charstring id := "HBGW", float guard_timeout := 30.0) runs on test_CT { + + g_hnb_cfg[0] := { + lai := { + mcc_mnc := '00101'H, + lac := 2342 + }, + sac := 55 + } + T_guard.start(guard_timeout); + activate(as_Tguard()); + + /* RUA/RANAP emulation on top of lower-layer Iuh */ + var RuaOps rua_ops := { + create_cb := refers(IuhRanapCreateCallback), + unitdata_cb := refers(IuhRanapUnitdataCallback) + }; + for (var integer i := 0; i < NUM_HNB; i := i+1) { + f_init_hnodeb(testcasename(), i, rua_ops); + } + + /* MSC emulation */ var RanOps ranops := { ranap_create_cb := refers(RAN_Emulation.RanapExpectedCreateCallback), ranap_unitdata_cb := omit, @@ -197,9 +280,12 @@ f_ran_adapter_init(g_msc, mp_msc_cfg, "HNBGW_Test", ranops); f_ran_adapter_start(g_msc); - /* SGSN*/ + /* SGSN emulation */ + ranops.ps_domain := true; + f_ran_adapter_init(g_sgsn, mp_sgsn_cfg, "HNBGW_Test", ranops); + f_ran_adapter_start(g_sgsn); - + f_init_mgcp(id); f_init_vty("VirtHNBGW"); } @@ -209,43 +295,242 @@ mtc.stop; } -/*function f_start_handler(void_fn fn, template (omit) TestHdlrParams pars := omit) -runs on test_CT return MSC_ConnHdlr { - return f_start_handler_run(f_start_handler_create(pars), fn, pars); -}*/ +/* helper function to start all of the simulated hNodeBs */ +function f_start_hnbs() runs on test_CT { + for (var integer i:= 0; i < NUM_HNB; i := i+1) { + f_hnbap_register(i); + } +} + +/*********************************************************************** + * code running in test_CT, preparing start of per-UE ConnHdlr + ***********************************************************************/ + +/* inbound RUA connection establishment on Iuh side */ +function IuhRanapCreateCallback(ContextId context_id, RUA_IEs.CN_DomainIndicator domain, charstring id) +runs on RUA_Emulation_CT return RUA_ConnHdlr { + log("CreateCallback"); + return null; +} + +/* inbound RUA connectionless data on Iuh side */ +function IuhRanapUnitdataCallback(RANAP_PDU ranap) +runs on RUA_Emulation_CT return template RANAP_PDU { + log("UnitdataCallback"); + return omit; +} + +private function f_start_handler_create(TestHdlrParams pars) runs on test_CT return ConnHdlr { + var ConnHdlr vc_conn; + var charstring id := testcasename() & int2str(pars.hnb_idx); + + vc_conn := ConnHdlr.create(id); + + /* Iuh RUA part */ + connect(vc_conn:RUA, vc_RUA[pars.hnb_idx]:CLIENT); + + if (pars.ps_domain) { + /* SGSN side */ + connect(vc_conn:BSSAP, g_sgsn.vc_RAN:CLIENT); + connect(vc_conn:BSSAP_PROC, g_sgsn.vc_RAN:PROC); + } else { + /* MSC side */ + connect(vc_conn:BSSAP, g_msc.vc_RAN:CLIENT); + connect(vc_conn:BSSAP_PROC, g_msc.vc_RAN:PROC); + } + + return vc_conn; +} + +private function f_start_handler_run(ConnHdlr vc_conn, void_fn fn, TestHdlrParams pars) runs on test_CT { + var charstring id := testcasename(); // & int2str(pars.ran_idx); + /* We cannot use vc_conn.start(f_init_handler(fn, id, pars)); as we cannot have + * a stand-alone 'derefers()' call, see https://www.eclipse.org/forums/index.php/t/1091364/ */ + pars.hnb := g_hnb_cfg[pars.hnb_idx]; + vc_conn.start(derefers(fn)(id, pars)); +} + +function f_start_handler_with_pars(void_fn fn, template (value) TestHdlrParams pars) +runs on test_CT return ConnHdlr { + var ConnHdlr vc_conn; + vc_conn := f_start_handler_create(valueof(pars)); + f_start_handler_run(vc_conn, fn, valueof(pars)); + return vc_conn; +} + +/*********************************************************************** + * 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()); + + /* TODO: CTRL? */ + /* TODO: VTY? */ +} + +/* 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; + } +} + +/* 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); + T.start; + + alt { + [] BSSAP.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iu ", exp_rx); + } + } + return 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 { + var RANAP_PDU rx; + timer T := 5.0; + + if (istemplatekind(exp_rx, "omit")) { + exp_rx := tx; + } + + BSSAP.send(tx); + T.start; + + alt { + [] RUA.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iuh ", exp_rx); + } + } + 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 */ + 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}); + + /* expect to receive it on the Iu side */ + T.start; + alt { + [] BSSAP.receive(exp_rx) -> value rx { + setverdict(pass); + } + [] T.timeout { + setverdict(fail, "Timeout waiting for Iu ", exp_rx); + } + } + return rx; +} + +/* build a RANAP InitialUE based on the TestHdlrParams */ +friend function f_build_initial_ue(TestHdlrParams pars) return RANAP_PDU { + var LAI lai := { + pLMNidentity := hex2oct(pars.hnb.lai.mcc_mnc), + lAC := int2oct(pars.hnb.lai.lac, 2), + iE_Extensions := omit + }; + var SAI sai := { + pLMNidentity := lai.pLMNidentity, + lAC := lai.lAC, + sAC := int2oct(pars.hnb.sac, 2), + iE_Extensions := omit + } + var octetstring nas := f_rnd_octstring(10); + var IuSignallingConnectionIdentifier sigc_id := int2bit(f_rnd_int(1000), 24); + var GlobalRNC_ID grnc_id := { + pLMNidentity := lai.pLMNidentity, + rNC_ID := 2342 + } + + if (pars.ps_domain) { + var RAC rac := '00'O; + return valueof(ts_RANAP_initialUE_PS(lai, rac, sai, nas, sigc_id, grnc_id)); + } else { + return valueof(ts_RANAP_initialUE_CS(lai, sai, nas, sigc_id, grnc_id)); + } +} -/*private function f_tc_hnb_register_request(charstring id) runs on HNBGW_ConnHdlr { - f_handle_hnbap_hnb_register_req(); - f_sleep(1.0); -}*/ +/*********************************************************************** + * HNBAP Testing + ***********************************************************************/ -testcase TC_hnb_register() runs on test_CT { - //var HNBGW_ConnHdlr vc_conn; - f_init(); - HNBAP.send(tr_HNBAP_HNBRegisterRequest(char2oct("TTCN3 HNodeB"), + +function f_hnbap_register(integer hnb_idx := 0) runs on test_CT +{ + HNBAP[hnb_idx].send(tr_HNBAP_HNBRegisterRequest(char2oct("TTCN3 HNodeB"), '00F110'O, - int2bit(1, 28), + int2bit(1 + hnb_idx, 28), int2oct(2, 2), int2oct(3, 1), int2oct(4, 2))); alt { - [] HNBAP.receive(tr_HNBAP_HNBRegisterAccept(?)) { + [] HNBAP[hnb_idx].receive(tr_HNBAP_HNBRegisterAccept(?)) { setverdict(pass); } - [] HNBAP.receive(IUHEM_Event:?) { + [] HNBAP[hnb_idx].receive(IUHEM_Event:?) { repeat; } } +} + +testcase TC_hnb_register() runs on test_CT { + //var HNBGW_ConnHdlr vc_conn; + f_init(); + f_hnbap_register(0); f_sleep(10.0); f_shutdown_helper(); } +/*********************************************************************** + * RUA / RANAP Testing + ***********************************************************************/ + testcase TC_RAB_Assignment() runs on test_CT { //var HNBGW_ConnHdlr vc_conn; f_init(); +/* f_sleep(3.0); HNBAP.send(tr_HNBAP_HNBRegisterRequest(char2oct("TTCN3 HNodeB"), '00F110'O, @@ -263,16 +548,90 @@ } } - RUA.send(tr_RUA_Connect(cs_domain, int2bit(23, 24), normal_call, hex2oct(ranap_cm_service_req))); + //RUA.send(tr_RUA_Connect(cs_domain, int2bit(23, 24), normal_call, hex2oct(ranap_cm_service_req))); //RANAP.receive(); - +*/ f_sleep(2.0); f_shutdown_helper(); } +private template (value) TestHdlrParams +t_pars(integer imsi_suffix, boolean ps_domain := false,integer hnb_idx := 0) := { + hnb_idx := hnb_idx, + imsi := f_gen_imsi(imsi_suffix), + ps_domain := ps_domain, + hnb := omit /* filled in later */ +} + +/* 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); + var RANAP_PDU tx := f_build_initial_ue(g_pars); + f_iuh2iu_connect(tx); +} +testcase TC_ranap_cs_initial_ue() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(1)); + vc_conn.done; +} +testcase TC_ranap_ps_initial_ue() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_initial_ue), t_pars(2, true)); + vc_conn.done; +} + + +/* Create an Iuh connection; send InitialUE; transceive data both directions */ +friend function f_tc_ranap_bidir(charstring id, TestHdlrParams pars) runs on ConnHdlr { + f_init_handler(pars); + + /* HNB -> MSC: InitialUE */ + f_iuh2iu_connect(f_build_initial_ue(g_pars)); + + /* MSC <- HNB: DirectTransfer */ + f_iu2iuh(ts_RANAP_DirectTransfer(f_rnd_octstring(10))); + /* MSC -> HNB: DirectTransfer */ + f_iuh2iu(ts_RANAP_DirectTransfer(f_rnd_octstring(10))); + + /* HNB <- MSC: CommonID */ + f_iu2iuh(ts_RANAP_CommonId(hex2oct(pars.imsi))); +} +testcase TC_ranap_cs_bidir() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), t_pars(3)); + vc_conn.done; +} +testcase TC_ranap_ps_bidir() runs on test_CT { + var ConnHdlr vc_conn; + + f_init(); + f_start_hnbs(); + + vc_conn := f_start_handler_with_pars(refers(f_tc_ranap_bidir), t_pars(4, true)); + vc_conn.done; +} + + + + control { execute(TC_hnb_register()); - execute(TC_RAB_Assignment()); + execute(TC_ranap_cs_initial_ue()); + execute(TC_ranap_ps_initial_ue()); + execute(TC_ranap_cs_bidir()); + execute(TC_ranap_ps_bidir()); } } diff --git a/hnbgw/MSC_ConnHdlr.ttcn b/hnbgw/MSC_ConnHdlr.ttcn deleted file mode 100644 index 290ee82..0000000 --- a/hnbgw/MSC_ConnHdlr.ttcn +++ /dev/null @@ -1,125 +0,0 @@ -module MSC_ConnHdlr { - -/* MSC connection handler for hnbgs tests in TTCN-3 - * (C) sysmocom - s.f.m.c. GmbH - * 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 - */ - -import from Misc_Helpers all; -import from General_Types all; -import from Osmocom_Types all; -import from IPL4asp_Types 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 RUA_IEs all; -import from RUA_Templates all; -import from HNBAP_PDU_Descriptions all; - -import from Iuh_Emulation all; - -import from RANAP_Types all; -import from RANAP_PDU_Contents all; -import from RANAP_PDU_Descriptions all; -import from RANAP_Templates all; -import from RAN_Adapter all; - -import from BSSAP_Types all; -import from RAN_Adapter all; -import from RAN_Emulation all; -import from BSSAP_CodecPort all; -import from IPA_Emulation all; -import from IPA_CodecPort all; -import from IPA_Types 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 SCCPasp_Types all; -import from BSSAP_Types all; - -import from MobileL3_Types all; -import from MobileL3_CommonIE_Types all; -import from MobileL3_RRM_Types all; -//import from L3_Templates all; - -import from TELNETasp_PortType all; -import from Osmocom_VTY_Functions all; -import from TCCConversion_Functions all; - -type record TestHdlrParams { - hexstring imsi, - integer media_nr -}; - -function f_get_test_hdlr_pars() return TestHdlrParams { - var TestHdlrParams pars := { - imsi := f_rnd_imsi('00101'H), - media_nr := 1 - }; - - return pars; -} - -type component MSC_ConnHdlr extends RAN_ConnHdlr, MGCP_ConnHdlr { /* RUA_ConnHdlr? Iuh_Emulation */ - var integer g_sccp_conn_id; - - port RAN_PROC_PT RAN; - port IPA_MGCP_PT MGCP_CLIENT; - var TestHdlrParams g_pars; - -} - -function f_MscConnHdlr_init(integer i, HostName bts, HostName mgw) runs on MSC_ConnHdlr { -} - -function UnitdataCallback(RANAP_PDU ranap) runs on RAN_Emulation_CT return template RANAP_PDU { - // FIXME - return ts_RANAP_Reset(ts_RanapCause_om_intervention, cs_domain); -} - -const RanOps MSC_RanOps := { - ranap_create_cb := refers(RAN_Emulation.RanapExpectedCreateCallback), - ranap_unitdata_cb := refers(UnitdataCallback), - ps_domain := false, - decode_dtap := false, - role_ms := false, - protocol := RAN_PROTOCOL_RANAP, - transport := BSSAP_TRANSPORT_AoIP, - use_osmux := false, - sccp_addr_local := omit, - sccp_addr_peer := omit -} - -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 MSC_ConnHdlr { - RAN.call(RAN_register:{l3_enc, self}) { - [] RAN.getreply(RAN_register:{?, ?}) {}; - } -} - - -} \ No newline at end of file diff --git a/hnbgw/gen_links.sh b/hnbgw/gen_links.sh index 197815c..5224980 100755 --- a/hnbgw/gen_links.sh +++ b/hnbgw/gen_links.sh @@ -95,8 +95,9 @@ FILES="Iuh_Types.ttcn Iuh_CodecPort.ttcn Iuh_CodecPort_CtrlFunctDef.cc Iuh_CodecPort_CtrlFunct.ttcn Iuh_Emulation.ttcn DNS_Helpers.ttcn " FILES+="MGCP_Emulation.ttcn MGCP_Types.ttcn MGCP_Templates.ttcn MGCP_CodecPort.ttcn MGCP_CodecPort_CtrlFunct.ttcn MGCP_CodecPort_CtrlFunctDef.cc " FILES+="RAN_Adapter.ttcnpp RAN_Emulation.ttcnpp BSSAP_CodecPort.ttcn SCCP_Templates.ttcn " -FILES+="Misc_Helpers.ttcn General_Types.ttcn Osmocom_Types.ttcn Osmocom_VTY_Functions.ttcn Native_Functions.ttcn Native_FunctionDefs.cc IPA_Types.ttcn IPA_CodecPort.ttcn IPA_CodecPort_CtrlFunct.ttcn IPA_CodecPort_CtrlFunctDef.cc IPA_Emulation.ttcnpp Osmocom_CTRL_Types.ttcn Osmocom_CTRL_Functions.ttcn Osmocom_CTRL_Adapter.ttcn RTP_CodecPort.ttcn RTP_CodecPort_CtrlFunct.ttcn RTP_CodecPort_CtrlFunctDef.cc RTP_Emulation.ttcn IuUP_Types.ttcn IuUP_EncDec.cc IuUP_Emulation.ttcn " +FILES+="Misc_Helpers.ttcn General_Types.ttcn Osmocom_Types.ttcn GSM_Types.ttcn Osmocom_VTY_Functions.ttcn Native_Functions.ttcn Native_FunctionDefs.cc IPA_Types.ttcn IPA_CodecPort.ttcn IPA_CodecPort_CtrlFunct.ttcn IPA_CodecPort_CtrlFunctDef.cc IPA_Emulation.ttcnpp Osmocom_CTRL_Types.ttcn Osmocom_CTRL_Functions.ttcn Osmocom_CTRL_Adapter.ttcn RTP_CodecPort.ttcn RTP_CodecPort_CtrlFunct.ttcn RTP_CodecPort_CtrlFunctDef.cc RTP_Emulation.ttcn IuUP_Types.ttcn IuUP_EncDec.cc IuUP_Emulation.ttcn " FILES+="StatsD_Types.ttcn StatsD_CodecPort.ttcn StatsD_CodecPort_CtrlFunct.ttcn StatsD_CodecPort_CtrlFunctdef.cc StatsD_Checker.ttcn " +FILES+="RUA_Emulation.ttcn " gen_links $DIR $FILES diff --git a/hnbgw/osmo-hnbgw.cfg b/hnbgw/osmo-hnbgw.cfg index dab3e39..4a87bd8 100644 --- a/hnbgw/osmo-hnbgw.cfg +++ b/hnbgw/osmo-hnbgw.cfg @@ -49,7 +49,7 @@ point-code 0.23.4 sccp-address sgsn routing-indicator PC - point-code 0.1.1 + point-code 0.23.1 hnbgw log-prefix hnb-id iuh diff --git a/hnbgw/osmo-stp.cfg b/hnbgw/osmo-stp.cfg index 7aa8735..85d60e9 100644 --- a/hnbgw/osmo-stp.cfg +++ b/hnbgw/osmo-stp.cfg @@ -37,8 +37,16 @@ as virt-msc0 m3ua asp virt-msc0-0 routing-key 1 0.23.4 + asp virt-sgsn0-0 23906 2905 m3ua + local-ip 127.0.0.1 + remote-ip 127.0.0.1 + as virt-sgsn0 m3ua + asp virt-sgsn0-0 + routing-key 2 0.23.1 + route-table system update route 0.23.4 7.255.7 linkset virt-msc0 + update route 0.23.1 7.255.7 linkset virt-sgsn0 listen m3ua 2905 accept-asp-connections dynamic-permitted diff --git a/hnbgw/regen_makefile.sh b/hnbgw/regen_makefile.sh index 1584335..47f7ee8 100755 --- a/hnbgw/regen_makefile.sh +++ b/hnbgw/regen_makefile.sh @@ -31,11 +31,7 @@ export CPPFLAGS_TTCN3=" -DIPA_EMULATION_CTRL - -DIPA_EMULATION_MGCP - -DIPA_EMULATION_SCCP -DRAN_EMULATION_RANAP - -DRAN_EMULATION_CTRL - -DRAN_EMULATION_MGCP -DUSE_MTP3_DISTRIBUTOR " diff --git a/library/RUA_Emulation.ttcn b/library/RUA_Emulation.ttcn new file mode 100644 index 0000000..23b4a7a --- /dev/null +++ b/library/RUA_Emulation.ttcn @@ -0,0 +1,370 @@ +module RUA_Emulation { + +/* RUA_Emulation runs on top of Iuh_Emulation. It multiplexes/demultiplexes + * the individuao connections, so there can be separate TTCN-3 components + * handling each of the connections (one connection per UE). + * + * The RUA_Emulation.main() function processes RUA messages from the Iuh stack + * via the RUA_PT, and dispatches them to the per-connection components. + * + * Outbound RUA connections are initiated by sending a FIXME primitive to the + * RUA_Emulation component. + * + * For each new inbound connection, the RuaOps.create_cb() is called. It can create + * or resolve a TTCN-3 component, and returns a component reference to which that inbound + * connection is routed/dispatched. + * + * If a pre-existing component wants to register to handle future inbound connection, + * it can do so by registering an "expect" with the expected RANAP payload. + + * FIXME + + * (C) 2022 by Harald Welte <laforge(a)gnumonks.org> + * All rights reserved. + * + * Released under the terms of GNU General Public License, Version 2 or + * (at your option) any later version. + */ + +import from General_Types all; +import from Osmocom_Types all; + +import from Iuh_Emulation all; + +import from RUA_Templates all; +//import from RUA_Constants all; +import from RUA_PDU_Descriptions all; +import from RUA_IEs all; + +import from RANAP_PDU_Descriptions all; +//import from RANAP_Constants all; +import from RANAP_IEs all; +import from RANAP_Types all; +import from RANAP_Templates all; + +modulepar { + integer mp_max_context_id := hex2int('FFFFFF'H); +} + + +/* General "base class" component definition, of which specific implementations + * derive themselves by means of the "extends" feature */ +type component RUA_ConnHdlr { + port RUA_Conn_PT RUA; +} + + +/* port between individual per-connection components and this dispatcher */ +type port RUA_Conn_PT message { + inout RANAP_PDU, + RUA_Conn_Req; +} with { extension "internal" }; + +type record RUA_Conn_Req { + boolean ps_domain, + RANAP_PDU ranap +}; + +type bitstring ContextId length(24); // with { variant "FIELDLENGTH(24)" }; + +/* represents a single RANAP connection over RUA */ +type record ConnectionData { + RUA_ConnHdlr comp_ref, + RUA_IEs.CN_DomainIndicator domain, + integer context_id +} + +type component RUA_Emulation_CT { + /* port to the bottom side (Iuh) */ + port RUA_PT RUA; + + /* ports to the upper side (per-connection components) */ + port RUA_Conn_PT CLIENT; + + /* use 16 as this is also the number of SCCP connections that SCCP_Emulation can handle */ + var ConnectionData ConnectionTable[16]; + + /* pending expected incoming connections */ + //var ExpectData ExpectTable[8]; + + /* tables for mapping inbound unitdata (like paging) */ + //var ImsiMapping ImsiTable[16]; + + /* procedure based port to register for incoming connections */ + //port RUA_PROC_PT PROC; + + var charstring g_rua_id; + var RuaOps g_rua_ops; +} + +type function RanapCreateCallback(ContextId context_id, RUA_IEs.CN_DomainIndicator domain, charstring id) +runs on RUA_Emulation_CT return RUA_ConnHdlr; + +type function RanapUnitdataCallback(RANAP_PDU ranap) +runs on RUA_Emulation_CT return template RANAP_PDU; + +type record RuaOps { + RanapCreateCallback create_cb optional, + RanapUnitdataCallback unitdata_cb optional + //boolean deode_dtap + //boolean role_ms +}; + +private function f_context_id_known(ContextId context_id) +runs on RUA_Emulation_CT return boolean { + var integer i; + for (i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].context_id == bit2int(context_id)){ + return true; + } + } + return false; +} + +private function f_comp_known(RUA_ConnHdlr client) +runs on RUA_Emulation_CT return boolean { + var integer i; + for (i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].comp_ref == client) { + return true; + } + } + return false; +} + +/* resolve connection ID by component reference */ +private function f_context_id_by_comp(RUA_ConnHdlr client) +runs on RUA_Emulation_CT return ContextId { + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].comp_ref == client) { + return int2bit(ConnectionTable[i].context_id, 24); + } + } + setverdict(fail, "RAN Connection table not found by component ", client); + mtc.stop; +} + +/* resolve ConnectionTable index component reference */ +private function f_idx_by_comp(RUA_ConnHdlr client) +runs on RUA_Emulation_CT return integer { + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].comp_ref == client) { + return i; + } + } + setverdict(fail, "RAN Connection table not found by component ", client); + mtc.stop; +} + +private function f_gen_context_id() +runs on RUA_Emulation_CT return ContextId { + var ContextId context_id; + + do { + context_id := int2bit(float2int(rnd()*int2float(mp_max_context_id)), 24); + } while (f_context_id_known(context_id) == true); + + return context_id; +} + +private function f_conn_table_init() +runs on RUA_Emulation_CT { + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + ConnectionTable[i].comp_ref := null; + ConnectionTable[i].context_id := -1; + } +/* + for (var integer i := 0; i < sizeof(ImsiTable); i := i+1) { + ImsiTable[i].comp_ref := null; + ImsiTable[i].imsi := omit; + ImsiTable[i].tmsi := 'FFFFFFFF'O; + } +*/ +} + +private function f_conn_table_add(RUA_ConnHdlr comp_ref, RUA_IEs.CN_DomainIndicator domain, ContextId context_id) +runs on RUA_Emulation_CT { + var integer int_context_id := bit2int(context_id); + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].context_id == -1) { + ConnectionTable[i].comp_ref := comp_ref; + ConnectionTable[i].domain := domain; + ConnectionTable[i].context_id := int_context_id; + log("Added conn table entry ", i, comp_ref, int_context_id); + return; + } + } + testcase.stop("RUA Connection table full!"); +} + +private function f_conn_table_del(ContextId context_id) +runs on RUA_Emulation_CT { + var integer int_context_id := bit2int(context_id); + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].context_id == int_context_id) { + log("Deleted conn table entry ", i, + ConnectionTable[i].comp_ref, int_context_id); + ConnectionTable[i].context_id := -1; + return + } + } + setverdict(fail, "RUA Connection table attempt to delete non-existant ", int_context_id); + mtc.stop; +} + + +/* resolve component reference by connection ID */ +private function f_comp_by_context_id(ContextId context_id) +runs on RUA_Emulation_CT return RUA_ConnHdlr { + var integer int_context_id := bit2int(context_id); + for (var integer i := 0; i < sizeof(ConnectionTable); i := i+1) { + if (ConnectionTable[i].context_id == int_context_id) { + return ConnectionTable[i].comp_ref; + } + } + setverdict(fail, "RUA Connection table not found by RUA Context ID ", int_context_id); + mtc.stop; +} + +private function CommonRanapUnitdataCallback(RANAP_PDU ranap) +runs on RUA_Emulation_CT return template RANAP_PDU { + /* TODO: paging */ + return g_rua_ops.unitdata_cb.apply(ranap); +} + +private function f_handle_userData_RANAP(RUA_ConnHdlr client, RANAP_PDU ranap) +runs on RUA_Emulation_CT { + /* TODO: L3 decoding, if requested */ + CLIENT.send(ranap) to client; +} + + +private altstep as_reset_ack() runs on RUA_Emulation_CT { + var RUA_PDU rua_clt; + [] RUA.receive(tr_RUA_ConnectionlessTransfer(decmatch tr_RANAP_Reset)) -> value rua_clt { + var RANAP_PDU rx := dec_RANAP_PDU(rua_clt.initiatingMessage.value_.connectionlessTransfer.protocolIEs[0].value_.rANAP_Message); + var RANAP_IEs.CN_DomainIndicator dom; + dom := rx.initiatingMessage.value_.Reset.protocolIEs[1].value_.cN_DomainIndicator; + RUA.send(ts_RUA_ConnectionlessTransfer(enc_RANAP_PDU(valueof(ts_RANAP_ResetAck(dom))))); + } +} + +private altstep as_main_rua() runs on RUA_Emulation_CT { + var RANAP_PDU ranap; + var RUA_PDU rua; + var octetstring ranap_enc; + var ContextId context_id; + var RUA_IEs.CN_DomainIndicator domain_ind; + var RUA_ConnHdlr vc_conn; + var RUA_Conn_Req creq; + + /* RUA -> Client: UNIT-DATA (connectionless RUA) from CN */ + [] RUA.receive(tr_RUA_ConnectionlessTransfer) -> value rua { + ranap := dec_RANAP_PDU(rua.initiatingMessage.value_.connectionlessTransfer.protocolIEs[0].value_.rANAP_Message); + var template RANAP_PDU resp; + resp := CommonRanapUnitdataCallback(ranap); + if (isvalue(resp)) { + RUA.send(ts_RUA_ConnectionlessTransfer(enc_RANAP_PDU(valueof(resp)))); + } + } + + /* RUA -> Client: new connection from CN */ + [] RUA.receive(tr_RUA_Connect) -> value rua { + domain_ind := rua.initiatingMessage.value_.connect_.protocolIEs[0].value_.cN_DomainIndicator; + context_id := rua.initiatingMessage.value_.connect_.protocolIEs[1].value_.context_ID; + ranap_enc := rua.initiatingMessage.value_.connect_.protocolIEs[3].value_.rANAP_Message; + ranap := dec_RANAP_PDU(ranap_enc); + vc_conn := g_rua_ops.create_cb.apply(context_id, domain_ind, g_rua_id); + /* store mapping between client components and RUA contextId */ + f_conn_table_add(vc_conn, domain_ind, context_id); + /* handle user payload */ + f_handle_userData_RANAP(vc_conn, ranap); + } + + /* RUA -> Client: connection-oriented data in existing connection */ + [] RUA.receive(tr_RUA_DirectTransfer) -> value rua { + context_id := rua.initiatingMessage.value_.directTransfer.protocolIEs[1].value_.context_ID; + vc_conn := f_comp_by_context_id(context_id); + ranap_enc := rua.initiatingMessage.value_.directTransfer.protocolIEs[2].value_.rANAP_Message; + f_handle_userData_RANAP(vc_conn, dec_RANAP_PDU(ranap_enc)); + } + + /* RUA -> Client: disconnect of an existing connection */ + [] RUA.receive(tr_RUA_Disconnect) -> value rua { + } + + /* RANAP from client through an existing RANAP connection */ + [] CLIENT.receive(RANAP_PDU:?) -> value ranap sender vc_conn { + var integer idx := f_idx_by_comp(vc_conn); + context_id := int2bit(ConnectionTable[idx].context_id, 24); + domain_ind := ConnectionTable[idx].domain; + RUA.send(ts_RUA_DirectTransfer(domain_ind, context_id, enc_RANAP_PDU(ranap))); + } + + /* RANAP from client, for a new RANAP connection */ + [] CLIENT.receive(RUA_Conn_Req:?) -> value creq sender vc_conn { + var octetstring enc_ranap := enc_RANAP_PDU(creq.ranap); + + if (f_comp_known(vc_conn) == false) { + /* unknown client, create new connection */ + context_id := f_gen_context_id(); + if (creq.ps_domain) { + domain_ind := ps_domain; + } else { + domain_ind := cs_domain; + } + + f_conn_table_add(vc_conn, domain_ind, context_id); + RUA.send(ts_RUA_Connect(domain_ind, context_id, normal_call, enc_ranap)); + } else { + /* known client, send via existing component */ + context_id := f_context_id_by_comp(vc_conn); + RUA.send(ts_RUA_DirectTransfer(domain_ind, context_id, enc_ranap)); + } + } + +} + + + +function f_ranap_reset(RANAP_IEs.CN_DomainIndicator dom) runs on RUA_Emulation_CT { + timer T := 5.0; + + var RANAP_PDU tx := valueof(ts_RANAP_Reset(ts_RanapCause_om_intervention,dom)); + RUA.send(ts_RUA_ConnectionlessTransfer(enc_RANAP_PDU(tx))); + T.start; + alt { + [] RUA.receive(tr_RUA_ConnectionlessTransfer(decmatch tr_RANAP_ResetAck)) { + log("RUA-RANAP: Received RESET-ACK in resposne to RESET, we're reay to go!"); + } + [] as_reset_ack(); + [] RUA.receive { repeat; } + [] T.timeout { + setverdict(fail, "RUA-RANAP: Timeout waiting for RESET-ACK after sending RESET"); + mtc.stop; + } + } +} + +function main(RuaOps ops, charstring id) runs on RUA_Emulation_CT { + g_rua_id := id; + g_rua_ops := ops; + f_conn_table_init(); + //f_expect_table_init(); + + while (true) { + alt { + [] as_main_rua(); + + /* + [] PROC.getcall(RUA_Register:{?,?}) -> param(l3_info, vc_hdlr) { + f_create_expect(l3_info, vc_hdlr); + PROC.reply(RUA_register:{l3_info, vc_hdlr}) to vc_hdlr; + } + */ + } + } +} + + +} -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27110 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: I99ddd30fd2a27f2025928006db79388625e26b01 Gerrit-Change-Number: 27110 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-CC: laforge <laforge(a)osmocom.org> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: RAN_Emulation: Don't decode L3 if g_ran_ops.decode_dtap == false

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27108 ) Change subject: RAN_Emulation: Don't decode L3 if g_ran_ops.decode_dtap == false ...................................................................... RAN_Emulation: Don't decode L3 if g_ran_ops.decode_dtap == false We must respect this flag not only in "normal" PDUs but also in the code path processing the "expect" handling. Change-Id: I04a9197ac0b68c2dcb7542d035dc70c9f2b90473 --- M library/RAN_Emulation.ttcnpp 1 file changed, 1 insertion(+), 1 deletion(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/08/27108/1 diff --git a/library/RAN_Emulation.ttcnpp b/library/RAN_Emulation.ttcnpp index 3158dc4..9873245 100644 --- a/library/RAN_Emulation.ttcnpp +++ b/library/RAN_Emulation.ttcnpp @@ -569,7 +569,7 @@ runs on RAN_Emulation_CT { /* decode + send decoded RANAP to client */ var template (omit) octetstring l3 := f_ranap_extract_l3(ranap); - if (istemplatekind(l3, "omit")) { + if (istemplatekind(l3, "omit") or not g_ran_ops.decode_dtap) { CLIENT.send(ranap) to client; } else { var template (omit) SAPI sapi := f_ranap_extract_sapi(ranap); -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27108 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: I04a9197ac0b68c2dcb7542d035dc70c9f2b90473 Gerrit-Change-Number: 27108 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-CC: laforge <laforge(a)osmocom.org> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

Change in osmo-ttcn3-hacks[master]: RAN_Emulation: Add f_ran_register_exp()

by daniel

daniel has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27109 ) Change subject: RAN_Emulation: Add f_ran_register_exp() ...................................................................... RAN_Emulation: Add f_ran_register_exp() For some reason this helper function was misssing; we only had the version to register an imsi. Change-Id: I9d38dbdf589ed0f5999a5aeeb31b10ca5d07de16 --- M library/RAN_Emulation.ttcnpp 1 file changed, 7 insertions(+), 0 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/09/27109/1 diff --git a/library/RAN_Emulation.ttcnpp b/library/RAN_Emulation.ttcnpp index 9873245..295876e 100644 --- a/library/RAN_Emulation.ttcnpp +++ b/library/RAN_Emulation.ttcnpp @@ -1442,6 +1442,13 @@ } } +/* register an expect with the BSSMAP core */ +function f_ran_register_exp(octetstring l3_enc) runs on RAN_ConnHdlr { + BSSAP_PROC.call(RAN_register:{l3_enc, self}) { + [] BSSAP_PROC.getreply(RAN_register:{?, ?}) {}; + } +} + #ifdef RAN_EMULATION_RANAP /* expect a IuReleaseCommand; Confirm that; expect SCCP-level N-DISCONNET.ind */ altstep as_iu_release_compl_disc(float t := 5.0) runs on RAN_ConnHdlr { -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/27109 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: I9d38dbdf589ed0f5999a5aeeb31b10ca5d07de16 Gerrit-Change-Number: 27109 Gerrit-PatchSet: 1 Gerrit-Owner: daniel <dwillmann(a)sysmocom.de> Gerrit-CC: laforge <laforge(a)osmocom.org> Gerrit-MessageType: newchange

3 years, 4 months

1
0
0 0

2025

2024

2023

2022

gerrit-log February 2022