gerrit-log July 2022

gerrit-log@lists.osmocom.org

3 participants
2175 discussions

Change in osmo-ttcn3-hacks[master]: Support for SBc-AP protocol as used on the MME-CBC interface

by fixeria

Attention is currently required from: pespin. fixeria has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 ) Change subject: Support for SBc-AP protocol as used on the MME-CBC interface ...................................................................... Patch Set 1: (1 comment) Commit Message: https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603/comment/2e6cd92d_bf61… PS1, Line 9: recent v0.5 I guess? -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 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: Ia6743e0a3e7974a5f2dd3ecf74ec331f646f6bc2 Gerrit-Change-Number: 28603 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-CC: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Thu, 14 Jul 2022 12:52:11 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No Gerrit-MessageType: comment

2 years, 11 months

Change in osmo-cbc[master]: Add sbcap library

by pespin

pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-cbc/+/28600 ) Change subject: Add sbcap library ...................................................................... Patch Set 1: (1 comment) Patchset: PS1: linter errors are in asn1c generated code. It adds TRAILING_WHITESPACE in some places. I can try to fix asn1c to avoid it, but not urgent really. -- To view, visit https://gerrit.osmocom.org/c/osmo-cbc/+/28600 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-cbc Gerrit-Branch: master Gerrit-Change-Id: If76f8619a9b2d46af6d94b8ae49348b8514e53aa Gerrit-Change-Number: 28600 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Comment-Date: Thu, 14 Jul 2022 12:27:14 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No Gerrit-MessageType: comment

2 years, 11 months

Change in osmo-ttcn3-hacks[master]: Support for SBc-AP protocol as used on the MME-CBC interface

by pespin

pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 ) Change subject: Support for SBc-AP protocol as used on the MME-CBC interface ...................................................................... Patch Set 1: (1 comment) Patchset: PS1: linter errors are in asn1c generated code. It adds TRAILING_WHITESPACE in some places. I can try to fix asn1c to avoid it, but not urgent really. -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 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: Ia6743e0a3e7974a5f2dd3ecf74ec331f646f6bc2 Gerrit-Change-Number: 28603 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Comment-Date: Thu, 14 Jul 2022 12:25:33 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No Gerrit-MessageType: comment

2 years, 11 months

Change in docker-playground[master]: ttcn3-cbc: Update osmo-cbc.cfg to test SBc-AP

by pespin

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/docker-playground/+/28604 ) Change subject: ttcn3-cbc: Update osmo-cbc.cfg to test SBc-AP ...................................................................... ttcn3-cbc: Update osmo-cbc.cfg to test SBc-AP Change-Id: Ie6fb464890c4b7b9816ef8602633df107e5e61ee --- M ttcn3-cbc-test/osmo-cbc.cfg 1 file changed, 11 insertions(+), 23 deletions(-) git pull ssh://gerrit.osmocom.org:29418/docker-playground refs/changes/04/28604/1 diff --git a/ttcn3-cbc-test/osmo-cbc.cfg b/ttcn3-cbc-test/osmo-cbc.cfg index dab1c8b..2c4721b 100644 --- a/ttcn3-cbc-test/osmo-cbc.cfg +++ b/ttcn3-cbc-test/osmo-cbc.cfg @@ -14,43 +14,31 @@ logging print extended-timestamp 1 logging print level 1 logging print file 1 last + logging level set-all info logging level cbsp debug + logging level sbcap debug logging level rest debug - logging level lglobal info - logging level llapd notice - logging level linp notice - logging level lmux notice - logging level lmi notice - logging level lmib notice - logging level lsms notice - logging level lctrl notice - logging level lgtp notice - logging level lstats notice - logging level lgsup notice - logging level loap notice - logging level lss7 notice - logging level lsccp notice - logging level lsua notice - logging level lm3ua notice - logging level lmgcp notice - logging level ljibuf notice - logging level lrspro notice - logging level lns notice - logging level lbssgp notice ! line vty no login - bind 0.0.0.0 + bind 172.18.27.20 ! cbc unknown-peers reject - peer ttcn3 + peer ttcn3-bsc protocol cbsp remote-port 9999 remote-ip 172.18.27.100 + peer ttcn3-mme + protocol sbcap + remote-port 9998 + remote-ip 172.18.27.100 cbsp local-ip 172.18.27.20 local-port 48049 + sbcap + local-ip 172.18.27.20 + local-port 29168 ecbe local-ip 172.18.27.20 local-port 12345 -- To view, visit https://gerrit.osmocom.org/c/docker-playground/+/28604 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: docker-playground Gerrit-Branch: master Gerrit-Change-Id: Ie6fb464890c4b7b9816ef8602633df107e5e61ee Gerrit-Change-Number: 28604 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newchange

2 years, 11 months

Change in osmo-ttcn3-hacks[master]: Support for SBc-AP protocol as used on the MME-CBC interface

by pespin

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 ) Change subject: Support for SBc-AP protocol as used on the MME-CBC interface ...................................................................... Support for SBc-AP protocol as used on the MME-CBC interface This requires a recent libfftranscode with SBC_AP support. Change-Id: Ia6743e0a3e7974a5f2dd3ecf74ec331f646f6bc2 Related: OS#4945 --- M cbc/CBC_Tests.ttcn M cbc/gen_links.sh M cbc/regen_makefile.sh A library/sbcap/SBC_AP_Adapter.ttcn A library/sbcap/SBC_AP_CodecPort.ttcn A library/sbcap/SBC_AP_CodecPort_CtrlFunct.ttcn A library/sbcap/SBC_AP_CodecPort_CtrlFunctDef.cc A library/sbcap/SBC_AP_CommonDataTypes.asn A library/sbcap/SBC_AP_Constants.asn A library/sbcap/SBC_AP_Containers.asn A library/sbcap/SBC_AP_EncDec.cc A library/sbcap/SBC_AP_IEs.asn A library/sbcap/SBC_AP_PDU_Contents.asn A library/sbcap/SBC_AP_PDU_Descriptions.asn A library/sbcap/SBC_AP_Templates.ttcn A library/sbcap/SBC_AP_Types.ttcn A library/sbcap/regen_makefile.sh 17 files changed, 2,228 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/03/28603/1 diff --git a/cbc/CBC_Tests.ttcn b/cbc/CBC_Tests.ttcn index 06fda92..0faf830 100644 --- a/cbc/CBC_Tests.ttcn +++ b/cbc/CBC_Tests.ttcn @@ -1,6 +1,7 @@ module CBC_Tests { import from Osmocom_Types all; +import from Socket_API_Definitions all; import from BSSAP_Types all; import from BSSMAP_Templates all; @@ -8,7 +9,15 @@ import from CBSP_Templates all; import from CBSP_Adapter all; import from CBSP_CodecPort all; -import from Socket_API_Definitions all; + +import from SBC_AP_IEs all; +import from SBC_AP_Constants all; +import from SBC_AP_PDU_Contents all; +import from SBC_AP_PDU_Descriptions all; +import from SBC_AP_Types all; +import from SBC_AP_Templates all; +import from SBC_AP_CodecPort all; +import from SBC_AP_Adapter all; import from HTTP_Adapter all; import from HTTPmsg_Types all; @@ -17,11 +26,13 @@ modulepar { charstring mp_cbc_host := "127.0.0.1"; integer mp_cbc_cbsp_port := 48049; + integer mp_cbc_sbcap_port := c_SBC_AP_PORT; integer mp_cbc_ecbe_port := 12345; integer mp_local_cbsp_port := 9999; + integer mp_local_sbcap_port := 9998; }; -type component test_CT extends CBSP_Adapter_CT, http_CT { +type component test_CT extends CBSP_Adapter_CT, SBC_AP_Adapter_CT, http_CT { }; /********************************************************************************* @@ -141,6 +152,7 @@ private function f_init(boolean raw := false) runs on test_CT { f_http_init(mp_cbc_host, mp_cbc_ecbe_port); CBSP_Adapter.f_connect(mp_cbc_host, mp_cbc_cbsp_port, "", mp_local_cbsp_port); + SBC_AP_Adapter.f_connect(mp_cbc_host, mp_cbc_sbcap_port, "", mp_local_sbcap_port); if (not raw) { var BSSMAP_FIELD_CellIdentificationList cell_list := { @@ -299,6 +311,86 @@ } } +private function f_sbcap_tx_write_replace_warn_resp(CBS_Message msg, integer idx := 0, + template (omit) BSSMAP_FIELD_CellIdentificationList tx_cell_list := omit, + template (omit) CBSP_IE_NumBcastComplList tx_compl_list := omit) +runs on test_CT { + var template (value) SBC_AP_PDU tx; + var template (value) BSSMAP_FIELD_CellIdentificationList tx_list; + //if (istemplatekind(tx_cell_list, "omit")) { + // /* use the "expected list" when confirming the write-replace */ + // tx_list := msg.cell_list; + //} else { + // /* use an user-provided different list of cells */ + // tx_list := valueof(tx_cell_list); + //} + if (istemplatekind(tx_compl_list, "omit")) { + tx := ts_SBCAP_WRITE_WARNING_RESP(int2bit(msg.msg_id, 16), + int2bit(msg.ser_nr, 16)); + } /*else { + tx := ts_CBSP_REPLACE_CBS_COMPL(msg.msg_id, msg.ser_nr, msg.old_ser_nr, + valueof(tx_compl_list), tx_list, + msg.channel_ind); + }*/ + f_SBC_AP_send(tx, idx); +} + +private function f_sbcap_tx_stop_warn_resp(integer idx := 0, CBS_Message msg) +runs on test_CT { + var template (value) SBC_AP_PDU tx; + tx := ts_SBCAP_STOP_WARNING_RESP(int2bit(msg.msg_id, 16), + int2bit(msg.ser_nr, 16)); + f_SBC_AP_send(tx, idx); +} + +/* handle a SBc-AP Write-Replace Request and respond to it with Response or FAILURE depending on arguments */ +private function f_sbcap_handle_write_replace_warn_req(CBS_Message msg, integer idx := 0, + template (omit) BSSMAP_FIELD_CellIdentificationList tx_cell_list := omit, + template (omit) CBSP_FailureListItems tx_fail_list := omit, + template (omit) CBSP_IE_NumBcastComplList tx_compl_list := omit) +runs on test_CT { + var template (present) SBC_AP_PDU rx_templ; + var SBC_AP_RecvFrom rf; + rx_templ := tr_SBCAP_WRITE_WARNING(int2bit(msg.msg_id, 16), + int2bit(msg.ser_nr, 16), + msg.rep_period, + msg.num_bcast_req); + alt { + [] SBC_AP[idx].receive(tr_SBC_AP_Recv(g_cbsp_conn_id[idx], rx_templ)) -> value rf { + var template (value) SBC_AP_PDU tx; + log ("received expected req:", rf); + if (istemplatekind(tx_fail_list, "omit")) { + f_sbcap_tx_write_replace_warn_resp(msg, idx, tx_cell_list, tx_compl_list); + }/* else { + f_cbsp_tx_write_fail(msg, idx, tx_cell_list, tx_fail_list); + }*/ + } + [] SBC_AP[idx].receive { + setverdict(fail, "Received unexpected SBc-AP in index ", idx); + } + } +} + +/* handle a SBc-AP Stop-Warning-Request and respond to it with Response or FAILURE depending on arguments */ +private function f_sbcap_handle_stop_warn_req(integer idx := 0, CBS_Message msg) +runs on test_CT { + var template (present) SBC_AP_PDU rx_templ; + var SBC_AP_RecvFrom rf; + + rx_templ := tr_SBCAP_STOP_WARNING(int2bit(msg.msg_id, 16), + int2bit(msg.ser_nr, 16)); + alt { + [] SBC_AP[idx].receive(tr_SBC_AP_Recv(g_cbsp_conn_id[idx], rx_templ)) -> value rf { + var template (value) SBC_AP_PDU tx; + log ("received expected req:", rf); + f_sbcap_tx_stop_warn_resp(idx, msg); + } + [] SBC_AP[idx].receive { + setverdict(fail, "Received unexpected SBc-AP in index ", idx); + } + } +} + private const BSSMAP_FIELD_CellIdentificationList cil_BSS := { cIl_allInBSS := ''O }; @@ -396,6 +488,7 @@ var EcbeCbcMessage ecbe := f_cbs2ecbe(msg, "TTCN-3"); f_ecbe_tx_post_cbs(ecbe); f_cbsp_handle_write(msg, 0, cell_list_success); + f_sbcap_handle_write_replace_warn_req(msg, 0, cell_list_success); f_ecbe_rx_resp(201); f_sleep(2.0); @@ -404,6 +497,7 @@ /* FIXME: cbc segfaults if we terminate here (if we don't wait for Connect_result? */ f_cbsp_handle_kill(0, msg.msg_id, msg.ser_nr, exp_list:=cell_list_success, tx_list:=cell_list_success, tx_fail_list:=omit, tx_compl_list:=omit, channel_ind:=msg.channel_ind); + f_sbcap_handle_stop_warn_req(0, msg); f_ecbe_rx_resp(200); } diff --git a/cbc/gen_links.sh b/cbc/gen_links.sh index 8b88605..3bb9e77 100755 --- a/cbc/gen_links.sh +++ b/cbc/gen_links.sh @@ -34,6 +34,11 @@ FILES+="SABP_CodecPort.ttcn SABP_CodecPort_CtrlFunct.ttcn SABP_CodecPort_CtrlFunctDef.cc SABP_Adapter.ttcn " gen_links $DIR $FILES +DIR=../library/sbcap +FILES="SBC_AP_CommonDataTypes.asn SBC_AP_Constants.asn SBC_AP_Containers.asn SBC_AP_IEs.asn SBC_AP_PDU_Contents.asn SBC_AP_PDU_Descriptions.asn " +FILES+="SBC_AP_Types.ttcn SBC_AP_EncDec.cc SBC_AP_Templates.ttcn SBC_AP_CodecPort.ttcn SBC_AP_CodecPort_CtrlFunct.ttcn SBC_AP_CodecPort_CtrlFunctDef.cc SBC_AP_Adapter.ttcn " +gen_links $DIR $FILES + DIR=$BASEDIR/titan.TestPorts.Common_Components.Abstract_Socket/src FILES="Abstract_Socket.cc Abstract_Socket.hh " gen_links $DIR $FILES diff --git a/cbc/regen_makefile.sh b/cbc/regen_makefile.sh index 11a93c4..96900b3 100755 --- a/cbc/regen_makefile.sh +++ b/cbc/regen_makefile.sh @@ -15,6 +15,8 @@ Native_FunctionDefs.cc SABP_CodecPort_CtrlFunctDef.cc SABP_EncDec.cc + SBC_AP_CodecPort_CtrlFunctDef.cc + SBC_AP_EncDec.cc SCTPasp_PT.cc TCCConversion.cc TCCEncoding.cc diff --git a/library/sbcap/SBC_AP_Adapter.ttcn b/library/sbcap/SBC_AP_Adapter.ttcn new file mode 100644 index 0000000..3217c5e --- /dev/null +++ b/library/sbcap/SBC_AP_Adapter.ttcn @@ -0,0 +1,91 @@ +module SBC_AP_Adapter { + +/* SBC_AP Adapter layer, sitting on top of SBC_AP_CodecPort. + * test suites can 'inherit' in order to have a SBC_AP connection to the IUT which they're testing + * + * (C) 2019 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 Osmocom_Types all; +import from General_Types all; +import from SBC_AP_Types all; +import from SBC_AP_PDU_Descriptions all; +import from SBC_AP_Templates all; +import from SBC_AP_CodecPort all; +import from SBC_AP_CodecPort_CtrlFunct all; +import from IPL4asp_Types all; +import from IPL4asp_PortType all; +import from Socket_API_Definitions all; +import from Misc_Helpers all; + + +const integer SBC_AP_HDR_LEN := 3; + +const integer NUM_SBC_AP := 3; + +type component SBC_AP_Adapter_CT { + /* down-facing port to SBC_AP Codec port */ + port SBC_AP_CODEC_PT SBC_AP[NUM_SBC_AP]; + var IPL4asp_Types.ConnectionId g_SBC_AP_conn_id[NUM_SBC_AP] := { -1, -1, -1 }; +} + +private template Socket_API_Definitions.PortEvent tr_SctpAssocChange_COMM_UP(IPL4asp_Types.ConnectionId id) := { + sctpEvent := { + sctpAssocChange := { + clientId := id, + proto := { + sctp := ? + }, + sac_state := SCTP_COMM_UP + } + } +} + +function f_connect(charstring remote_host, IPL4asp_Types.PortNumber remote_port, + charstring local_host, IPL4asp_Types.PortNumber local_port, integer idx := 0) +runs on SBC_AP_Adapter_CT { + var IPL4asp_Types.Result res; + map(self:SBC_AP[idx], system:SBC_AP); + res := SBC_AP_CodecPort_CtrlFunct.f_IPL4_connect(SBC_AP[idx], remote_host, remote_port, + local_host, local_port, 0, { sctp := valueof(ts_SBC_AP_SctpTuple) }); + if (not ispresent(res.connId)) { + setverdict(fail, "Could not connect to SBC_AP port, check your configuration"); + mtc.stop; + } + g_SBC_AP_conn_id[idx] := res.connId; + timer Tcommup := 10.0; + Tcommup.start; + alt { + [] SBC_AP[idx].receive(tr_SctpAssocChange_COMM_UP(g_SBC_AP_conn_id[idx])) {} + [] Tcommup.timeout { + Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, "Timeout waiting SCTP_COMM_UP"); + } + } +} + +/* Function to use to bind to a local port as IPA server, accepting remote clients */ +function f_bind(charstring local_host, IPL4asp_Types.PortNumber local_port, integer idx := 0) +runs on SBC_AP_Adapter_CT { + var IPL4asp_Types.Result res; + map(self:SBC_AP[idx], system:SBC_AP); + res := SBC_AP_CodecPort_CtrlFunct.f_IPL4_listen(SBC_AP[idx], local_host, local_port, { sctp := valueof(ts_SBC_AP_SctpTuple) }); + g_SBC_AP_conn_id[idx] := res.connId; +} + +function f_SBC_AP_send(template (value) SBC_AP_PDU pdu, integer idx := 0) runs on SBC_AP_Adapter_CT { + SBC_AP[idx].send(ts_SBC_AP_Send(g_SBC_AP_conn_id[idx], pdu)); +} + +function f_SBC_AP_exp(template SBC_AP_PDU exp, integer idx := 0) runs on SBC_AP_Adapter_CT return SBC_AP_PDU { + var SBC_AP_RecvFrom rf; + SBC_AP[idx].receive(tr_SBC_AP_Recv(g_SBC_AP_conn_id[idx], exp)) -> value rf; + return rf.msg; +} + + +} diff --git a/library/sbcap/SBC_AP_CodecPort.ttcn b/library/sbcap/SBC_AP_CodecPort.ttcn new file mode 100644 index 0000000..bd17031 --- /dev/null +++ b/library/sbcap/SBC_AP_CodecPort.ttcn @@ -0,0 +1,84 @@ +module SBC_AP_CodecPort { + +/* Simple SBC AP Codec Port, translating between raw SCTP primitives with + * octetstring payload towards the IPL4asp provider, and SBC-AP primitives + * which carry the decoded SBC-AP data types as payload. + * + * (C) 2019 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. + * + * SPDX-License-Identifier: GPL-2.0-or-later + */ + + import from IPL4asp_PortType all; + import from IPL4asp_Types all; + import from SBC_AP_PDU_Descriptions all; + import from SBC_AP_Types all; + + type record SBC_AP_RecvFrom { + ConnectionId connId, + HostName remName, + PortNumber remPort, + HostName locName, + PortNumber locPort, + SBC_AP_PDU msg + }; + + type record SBC_AP_Send { + ConnectionId connId, + SBC_AP_PDU msg + }; + + template (value) SctpTuple ts_SBC_AP_SctpTuple := { + sinfo_stream := omit, + sinfo_ppid := c_SBC_AP_PPID, + remSocks := omit, + assocId := omit + }; + + template (value) SBC_AP_Send ts_SBC_AP_Send(ConnectionId connId, template (value) SBC_AP_PDU msg) := { + connId := connId, + msg := msg + } + + template (present) SBC_AP_RecvFrom tr_SBC_AP_Recv(template ConnectionId connId, template SBC_AP_PDU msg) := { + connId := connId, + remName := ?, + remPort := ?, + locName := ?, + locPort := ?, + msg := msg + } + + private function IPL4_to_SBC_AP_RecvFrom(in ASP_RecvFrom pin, out SBC_AP_RecvFrom pout) { + pout.connId := pin.connId; + pout.remName := pin.remName; + pout.remPort := pin.remPort; + pout.locName := pin.locName; + pout.locPort := pin.locPort; + pout.msg := dec_SBC_AP_PDU(pin.msg); + } with { extension "prototype(fast)" }; + + private function SBC_AP_to_IPL4_Send(in SBC_AP_Send pin, out ASP_Send pout) { + pout.connId := pin.connId; + pout.proto := { + sctp := valueof(ts_SBC_AP_SctpTuple) + }; + pout.msg := enc_SBC_AP_PDU(pin.msg); + } with { extension "prototype(fast)" }; + + type port SBC_AP_CODEC_PT message { + out SBC_AP_Send; + in SBC_AP_RecvFrom, + ASP_ConnId_ReadyToRelease, + ASP_Event; + } with { extension "user IPL4asp_PT + out(SBC_AP_Send -> ASP_Send:function(SBC_AP_to_IPL4_Send)) + in(ASP_RecvFrom -> SBC_AP_RecvFrom: function(IPL4_to_SBC_AP_RecvFrom); + ASP_ConnId_ReadyToRelease -> ASP_ConnId_ReadyToRelease: simple; + ASP_Event -> ASP_Event: simple)" + } +} diff --git a/library/sbcap/SBC_AP_CodecPort_CtrlFunct.ttcn b/library/sbcap/SBC_AP_CodecPort_CtrlFunct.ttcn new file mode 100644 index 0000000..bdf1eec --- /dev/null +++ b/library/sbcap/SBC_AP_CodecPort_CtrlFunct.ttcn @@ -0,0 +1,44 @@ +module SBC_AP_CodecPort_CtrlFunct { + + import from SBC_AP_CodecPort all; + import from IPL4asp_Types all; + + external function f_IPL4_listen( + inout SBC_AP_CODEC_PT portRef, + in HostName locName, + in PortNumber locPort, + in ProtoTuple proto, + in OptionList options := {} + ) return Result; + + external function f_IPL4_connect( + inout SBC_AP_CODEC_PT portRef, + in HostName remName, + in PortNumber remPort, + in HostName locName, + in PortNumber locPort, + in ConnectionId connId, + in ProtoTuple proto, + in OptionList options := {} + ) return Result; + + external function f_IPL4_close( + inout SBC_AP_CODEC_PT portRef, + in ConnectionId id, + in ProtoTuple proto := { unspecified := {} } + ) return Result; + + external function f_IPL4_setUserData( + inout SBC_AP_CODEC_PT portRef, + in ConnectionId id, + in UserData userData + ) return Result; + + external function f_IPL4_getUserData( + inout SBC_AP_CODEC_PT portRef, + in ConnectionId id, + out UserData userData + ) return Result; + +} + diff --git a/library/sbcap/SBC_AP_CodecPort_CtrlFunctDef.cc b/library/sbcap/SBC_AP_CodecPort_CtrlFunctDef.cc new file mode 100644 index 0000000..84269f3 --- /dev/null +++ b/library/sbcap/SBC_AP_CodecPort_CtrlFunctDef.cc @@ -0,0 +1,56 @@ +#include "IPL4asp_PortType.hh" +#include "SBC_AP_CodecPort.hh" +#include "IPL4asp_PT.hh" + +namespace SBC__AP__CodecPort__CtrlFunct { + + IPL4asp__Types::Result f__IPL4__listen( + SBC__AP__CodecPort::SBC__AP__CODEC__PT& portRef, + const IPL4asp__Types::HostName& locName, + const IPL4asp__Types::PortNumber& locPort, + const IPL4asp__Types::ProtoTuple& proto, + const IPL4asp__Types::OptionList& options) + { + return f__IPL4__PROVIDER__listen(portRef, locName, locPort, proto, options); + } + + IPL4asp__Types::Result f__IPL4__connect( + SBC__AP__CodecPort::SBC__AP__CODEC__PT& portRef, + const IPL4asp__Types::HostName& remName, + const IPL4asp__Types::PortNumber& remPort, + const IPL4asp__Types::HostName& locName, + const IPL4asp__Types::PortNumber& locPort, + const IPL4asp__Types::ConnectionId& connId, + const IPL4asp__Types::ProtoTuple& proto, + const IPL4asp__Types::OptionList& options) + { + return f__IPL4__PROVIDER__connect(portRef, remName, remPort, + locName, locPort, connId, proto, options); + } + + IPL4asp__Types::Result f__IPL4__close( + SBC__AP__CodecPort::SBC__AP__CODEC__PT& portRef, + const IPL4asp__Types::ConnectionId& connId, + const IPL4asp__Types::ProtoTuple& proto) + { + return f__IPL4__PROVIDER__close(portRef, connId, proto); + } + + IPL4asp__Types::Result f__IPL4__setUserData( + SBC__AP__CodecPort::SBC__AP__CODEC__PT& portRef, + const IPL4asp__Types::ConnectionId& connId, + const IPL4asp__Types::UserData& userData) + { + return f__IPL4__PROVIDER__setUserData(portRef, connId, userData); + } + + IPL4asp__Types::Result f__IPL4__getUserData( + SBC__AP__CodecPort::SBC__AP__CODEC__PT& portRef, + const IPL4asp__Types::ConnectionId& connId, + IPL4asp__Types::UserData& userData) + { + return f__IPL4__PROVIDER__getUserData(portRef, connId, userData); + } + +} + diff --git a/library/sbcap/SBC_AP_CommonDataTypes.asn b/library/sbcap/SBC_AP_CommonDataTypes.asn new file mode 100644 index 0000000..e11f317 --- /dev/null +++ b/library/sbcap/SBC_AP_CommonDataTypes.asn @@ -0,0 +1,35 @@ +-- SBC-AP-CommonDataTypes.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.6 Common Definitions +-- + +-- ************************************************************** +-- +-- Common definitions +-- +-- ************************************************************** + +SBC-AP-CommonDataTypes { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-CommonDataTypes (3)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +Criticality ::= ENUMERATED { reject, ignore, notify } + +Presence ::= ENUMERATED { optional, conditional, mandatory } + +ProcedureCode ::= INTEGER (0..255) + +ProtocolExtensionID ::= INTEGER (0..65535) + +ProtocolIE-ID ::= INTEGER (0..65535) + +TriggeringMessage ::= ENUMERATED {initiating-message, successful-outcome, unsuccessful-outcome, outcome} + +END diff --git a/library/sbcap/SBC_AP_Constants.asn b/library/sbcap/SBC_AP_Constants.asn new file mode 100644 index 0000000..447e1c4 --- /dev/null +++ b/library/sbcap/SBC_AP_Constants.asn @@ -0,0 +1,127 @@ +-- SBC-AP-Constants.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.7 Constant Definitions +-- +-- ************************************************************** +-- +-- Constant definitions +-- +-- ************************************************************** + +SBC-AP-Constants { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-Constants (4)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +-- ************************************************************** +-- +-- Elementary Procedures +-- +-- ************************************************************** + +id-Write-Replace-Warning INTEGER ::= 0 +id-Stop-Warning INTEGER ::= 1 +id-Error-Indication INTEGER ::= 2 +id-Write-Replace-Warning-Indication INTEGER ::= 3 +id-Stop-Warning-Indication INTEGER ::= 4 +id-PWS-Restart-Indication INTEGER ::= 5 +id-PWS-Failure-Indication INTEGER ::= 6 + +-- ************************************************************** +-- +-- IEs +-- +-- ************************************************************** + +id-Broadcast-Message-Content INTEGER ::= 0 +id-Cause INTEGER ::= 1 +id-Criticality-Diagnostics INTEGER ::=2 +id-Data-Coding-Scheme INTEGER ::= 3 +id-Failure-List INTEGER ::= 4 +id-Message-Identifier INTEGER ::= 5 +id-Number-of-Broadcasts-Completed-List INTEGER ::= 6 +id-Number-of-Broadcasts-Requested INTEGER ::= 7 +id-Radio-Resource-Loading-List INTEGER ::= 8 +id-Recovery-Indication INTEGER ::= 9 +id-Repetition-Period INTEGER ::= 10 +id-Serial-Number INTEGER ::= 11 +id-Service-Areas-List INTEGER ::= 12 +id-TypeOfError INTEGER ::= 13 +id-List-of-TAIs INTEGER ::= 14 +id-Warning-Area-List INTEGER ::= 15 +id-Warning-Message-Content INTEGER ::= 16 +id-Warning-Security-Information INTEGER ::= 17 +id-Warning-Type INTEGER ::= 18 +id-Omc-Id INTEGER ::= 19 +id-Concurrent-Warning-Message-Indicator INTEGER ::= 20 +id-Extended-Repetition-Period INTEGER ::= 21 +id-Unknown-Tracking-Area-List INTEGER ::= 22 +id-Broadcast-Scheduled-Area-List INTEGER ::= 23 +id-Send-Write-Replace-Warning-Indication INTEGER ::= 24 +id-Broadcast-Cancelled-Area-List INTEGER ::= 25 +id-Send-Stop-Warning-Indication INTEGER ::= 26 +id-Stop-All-Indicator INTEGER ::= 27 +id-Global-ENB-ID INTEGER ::= 28 +id-Broadcast-Empty-Area-List INTEGER ::= 29 +id-Restarted-Cell-List INTEGER ::= 30 +id-List-of-TAIs-Restart INTEGER ::= 31 +id-List-of-EAIs-Restart INTEGER ::= 32 +id-Failed-Cell-List INTEGER ::= 33 +id-List-of-5GS-TAIs INTEGER ::= 34 +id-Warning-Area-List-5GS INTEGER ::= 35 +id-Global-RAN-Node-ID INTEGER ::= 36 +id-Global-GNB-ID INTEGER ::= 37 +id-RAT-Selector-5GS INTEGER ::= 38 +id-Unknown-5GS-Tracking-Area-List INTEGER ::= 39 +id-Broadcast-Scheduled-Area-List-5GS INTEGER ::= 40 +id-Broadcast-Cancelled-Area-List-5GS INTEGER ::= 41 +id-Broadcast-Empty-Area-List-5GS INTEGER ::= 42 +id-Restarted-Cell-List-NR INTEGER ::= 43 +id-Failed-Cell-List-NR INTEGER ::= 44 +id-List-of-5GS-TAI-for-Restart INTEGER ::= 45 +id-Warning-Area-Coordinates INTEGER ::= 46 + + + +-- ************************************************************** +-- +-- Extension constants +-- +-- ************************************************************** + +-- ************************************************************** +-- +-- Lists +-- +-- ************************************************************** + +maxNrOfErrors INTEGER ::= 256 +maxnoofCellID INTEGER ::= 65535 +maxnoofCellinEAI INTEGER ::= 65535 +maxnoofCellinTAI INTEGER ::= 65535 +maxNrOfTAIs INTEGER ::= 65535 +maxnoofEmergencyAreaID INTEGER ::= 65535 +maxnoofTAIforWarning INTEGER ::= 65535 + +maxProtocolExtensions INTEGER ::= 65535 +maxProtocolIEs INTEGER ::= 65535 +maxnoofeNBIds INTEGER ::= 256 +maxnoofRestartedCells INTEGER ::= 256 +maxnoofRestartTAIs INTEGER ::= 2048 +maxnoofRestartEAIs INTEGER ::= 256 +maxnoofFailedCells INTEGER ::= 256 +maxnoof5GSTAIs INTEGER ::= 2048 +maxnoofCellsingNB INTEGER ::= 16384 +maxnoofCellsin5GS INTEGER ::= 16776960 +maxnoofCellsin5GSTAI INTEGER ::= 65535 +maxnoofRANNodes INTEGER ::= 65535 +maxnoofRestart5GSTAIs INTEGER ::= 2048maxnoofCellsforRestartNR INTEGER ::= 16384 + + +END diff --git a/library/sbcap/SBC_AP_Containers.asn b/library/sbcap/SBC_AP_Containers.asn new file mode 100644 index 0000000..8b71821 --- /dev/null +++ b/library/sbcap/SBC_AP_Containers.asn @@ -0,0 +1,121 @@ +-- SBC-AP-Containers.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.8 Container Definitions +-- + +-- ************************************************************** +-- +-- Container definitions +-- +-- ************************************************************** + +SBC-AP-Containers { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-Containers (5)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +-- ************************************************************** +-- +-- IE parameter types from other modules. +-- +-- ************************************************************** + +IMPORTS + Criticality, + Presence, + ProtocolExtensionID, + ProtocolIE-ID +FROM SBC-AP-CommonDataTypes + + maxProtocolExtensions, + maxProtocolIEs +FROM SBC-AP-Constants; + +-- ************************************************************** +-- +-- Class Definition for Protocol IEs +-- +-- ************************************************************** + +SBC-AP-PROTOCOL-IES ::= CLASS { + &id ProtocolIE-ID UNIQUE, + &criticality Criticality DEFAULT ignore, + &Value, + &presence Presence +} +WITH SYNTAX { + ID &id + CRITICALITY &criticality + TYPE &Value + PRESENCE &presence +} + +-- ************************************************************** +-- +-- Class Definition for Protocol Extensions +-- +-- ************************************************************** + +SBC-AP-PROTOCOL-EXTENSION ::= CLASS { + &id ProtocolExtensionID UNIQUE, + &criticality Criticality DEFAULT ignore, + &Extension, + &presence Presence +} +WITH SYNTAX { + ID &id + CRITICALITY &criticality + EXTENSION &Extension + PRESENCE &presence +} + +-- ************************************************************** +-- +-- Container for Protocol IEs +-- +-- ************************************************************** + +ProtocolIE-Container {SBC-AP-PROTOCOL-IES : IEsSetParam} ::= + SEQUENCE (SIZE (0..maxProtocolIEs)) OF + ProtocolIE-Field {{IEsSetParam}} + +ProtocolIE-Field {SBC-AP-PROTOCOL-IES : IEsSetParam} ::= SEQUENCE { + id SBC-AP-PROTOCOL-IES.&id ({IEsSetParam}), + criticality SBC-AP-PROTOCOL-IES.&criticality ({IEsSetParam}{@id}), + value SBC-AP-PROTOCOL-IES.&Value ({IEsSetParam}{@id}) +} + +-- ************************************************************** +-- +-- Container Lists for Protocol IE Containers +-- +-- ************************************************************** + +ProtocolIE-ContainerList {INTEGER : lowerBound, INTEGER : upperBound, SBC-AP-PROTOCOL-IES : IEsSetParam} ::= + SEQUENCE (SIZE (lowerBound..upperBound)) OF + ProtocolIE-Container {{IEsSetParam}} + +-- ************************************************************** +-- +-- Container for Protocol Extensions +-- +-- ************************************************************** + +ProtocolExtensionContainer {SBC-AP-PROTOCOL-EXTENSION : ExtensionSetParam} ::= + SEQUENCE (SIZE (1..maxProtocolExtensions)) OF + ProtocolExtensionField {{ExtensionSetParam}} + +ProtocolExtensionField {SBC-AP-PROTOCOL-EXTENSION : ExtensionSetParam} ::= SEQUENCE { + id SBC-AP-PROTOCOL-EXTENSION.&id ({ExtensionSetParam}), + criticality SBC-AP-PROTOCOL-EXTENSION.&criticality ({ExtensionSetParam}{@id}), + extensionValue SBC-AP-PROTOCOL-EXTENSION.&Extension ({ExtensionSetParam}{@id}) +} + + +END diff --git a/library/sbcap/SBC_AP_EncDec.cc b/library/sbcap/SBC_AP_EncDec.cc new file mode 100644 index 0000000..08ee75f --- /dev/null +++ b/library/sbcap/SBC_AP_EncDec.cc @@ -0,0 +1,64 @@ + +#include <string.h> +#include <stdarg.h> +#include "SBC_AP_PDU_Descriptions.hh" + +extern "C" { +#include <fftranscode/transcode.h> +} + +namespace SBC__AP__Types { + +TTCN_Module SBC__AP__EncDec("SBC_AP_EncDec", __DATE__, __TIME__); + +OCTETSTRING enc__SBC__AP__PDU(const SBC__AP__PDU__Descriptions::SBC__AP__PDU &pdu) +{ + uint8_t *aper_buf; + int aper_buf_len; + TTCN_Buffer TTCN_buf; + TTCN_buf.clear(); + + /* Encode from abstract data type into BER/DER */ + pdu.encode(SBC__AP__PDU__Descriptions::SBC__AP__PDU_descr_, TTCN_buf, + TTCN_EncDec::CT_BER, BER_ENCODE_DER); + + aper_buf_len = fftranscode_ber2aper(FFTRANSC_T_SBCAP, &aper_buf, TTCN_buf.get_data(), TTCN_buf.get_len()); + if (aper_buf_len < 0) { + TTCN_error("fftranscode failed."); + } + + /* make octetstring from output buffer */ + OCTETSTRING ret_val(aper_buf_len, aper_buf); + + /* release dynamically-allocated output buffer */ + fftranscode_free(aper_buf); + + return ret_val; +} + +SBC__AP__PDU__Descriptions::SBC__AP__PDU dec__SBC__AP__PDU(const OCTETSTRING &stream) +{ + uint8_t *ber_buf; + int ber_buf_len; + + /* First, decode APER + re-encode as BER */ + ber_buf_len = fftranscode_aper2ber(FFTRANSC_T_SBCAP, &ber_buf, (const unsigned char *)stream, stream.lengthof()); + if (ber_buf_len < 0) { + TTCN_error("fftranscode failed."); + } + + /* Then, re-encode from BER to TITAN representation */ + SBC__AP__PDU__Descriptions::SBC__AP__PDU ret_dcc; + TTCN_Buffer TTCN_buf; + TTCN_buf.clear(); + TTCN_buf.put_s(ber_buf_len, ber_buf); + + ret_dcc.decode(SBC__AP__PDU__Descriptions::SBC__AP__PDU_descr_, TTCN_buf, + TTCN_EncDec::CT_BER, BER_ACCEPT_ALL); + + fftranscode_free(ber_buf); + + return ret_dcc; +} + +} diff --git a/library/sbcap/SBC_AP_IEs.asn b/library/sbcap/SBC_AP_IEs.asn new file mode 100644 index 0000000..3cfa847 --- /dev/null +++ b/library/sbcap/SBC_AP_IEs.asn @@ -0,0 +1,650 @@ +-- SBC-AP-IEs.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.5 Information Element Definitions +-- + +-- ************************************************************** +-- +-- Information Element Definitions +-- +-- ************************************************************** + +SBC-AP-IEs { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-IEs (2)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +IMPORTS + maxNrOfErrors, + maxNrOfTAIs, + maxnoofTAIforWarning, + maxnoofCellID, + maxnoofEmergencyAreaID, + + id-TypeOfError, + maxnoofCellinEAI, + maxnoofCellinTAI, + maxnoofeNBIds, + maxnoofRestartTAIs, + maxnoofRestartEAIs, + maxnoofRestartedCells, + maxnoofFailedCells, + maxnoof5GSTAIs, + maxnoofCellsingNB, + maxnoofCellsin5GS, + maxnoofCellsforRestartNR, + maxnoofRANNodes, + maxnoofRestart5GSTAIs, + maxnoofCellsin5GSTAI + +FROM SBC-AP-Constants + + Criticality, + ProcedureCode, + TriggeringMessage, + ProtocolIE-ID +FROM SBC-AP-CommonDataTypes + + ProtocolExtensionContainer{}, + + SBC-AP-PROTOCOL-EXTENSION +FROM SBC-AP-Containers; + + +-- A + +-- B + +Broadcast-Scheduled-Area-List ::= SEQUENCE { + cellId-Broadcast-List CellId-Broadcast-List OPTIONAL, + tAI-Broadcast-List TAI-Broadcast-List OPTIONAL, + emergencyAreaID-Broadcast-List EmergencyAreaID-Broadcast-List OPTIONAL, + iE-Extensions ProtocolExtensionContainer {{Broadcast-Scheduled-Area-List-ExtIEs}} OPTIONAL, + ... +} + +Broadcast-Scheduled-Area-List-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Broadcast-Scheduled-Area-List-5GS ::= SEQUENCE { + cellId-Broadcast-List-5GS CellId-Broadcast-List-5GS OPTIONAL, + tAI-Broadcast-List-5GS TAI-Broadcast-List-5GS OPTIONAL, + emergencyAreaID-Broadcast-List EmergencyAreaID-Broadcast-List OPTIONAL, + iE-Extensions ProtocolExtensionContainer {{Broadcast-Scheduled-Area-List-5GS-ExtIEs}} OPTIONAL, + ... +} + +Broadcast-Scheduled-Area-List-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Broadcast-Cancelled-Area-List ::= SEQUENCE { + cellID-Cancelled-List CellID-Cancelled-List OPTIONAL, + tAI-Cancelled-List TAI-Cancelled-List OPTIONAL, + emergencyAreaID-Cancelled-List EmergencyAreaID-Cancelled-List OPTIONAL, + iE-Extensions ProtocolExtensionContainer {{Broadcast-Cancelled-Area-List-ExtIEs}} OPTIONAL, + ... +} + +Broadcast-Cancelled-Area-List-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Broadcast-Cancelled-Area-List-5GS ::= SEQUENCE { + cellID-Cancelled-List-5GS CellID-Cancelled-List-5GS OPTIONAL, + tAI-Cancelled-List-5GS TAI-Cancelled-List-5GS OPTIONAL, + emergencyAreaID-Cancelled-List EmergencyAreaID-Cancelled-List OPTIONAL, + iE-Extensions ProtocolExtensionContainer {{Broadcast-Cancelled-Area-List-5GS-ExtIEs}} OPTIONAL, + ... +} + +Broadcast-Cancelled-Area-List-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + +Broadcast-Empty-Area-List ::= SEQUENCE (SIZE (1.. maxnoofeNBIds)) OF Global-ENB-ID + +Broadcast-Empty-Area-List-5GS ::= SEQUENCE (SIZE (1.. maxnoofRANNodes)) OF Global-RAN-Node-ID + + +-- C + +CancelledCellinEAI ::= SEQUENCE (SIZE(1..maxnoofCellinEAI)) OF CancelledCellinEAI-Item + +CancelledCellinEAI-Item ::= SEQUENCE { + eCGI EUTRAN-CGI, + numberOfBroadcasts NumberOfBroadcasts, + iE-Extensions ProtocolExtensionContainer { {CancelledCellinEAI-Item-ExtIEs} } OPTIONAL, + ... +} + +CancelledCellinEAI-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} +CancelledCellinTAI ::= SEQUENCE (SIZE(1..maxnoofCellinTAI)) OF CancelledCellinTAI-Item + +CancelledCellinTAI-Item ::= SEQUENCE{ + eCGI EUTRAN-CGI, + numberOfBroadcasts NumberOfBroadcasts, + iE-Extensions ProtocolExtensionContainer { {CancelledCellinTAI-Item-ExtIEs} } OPTIONAL, + ... +} + +CancelledCellinTAI-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +CancelledCellinTAI-5GS ::= SEQUENCE (SIZE(1..maxnoofCellsin5GSTAI)) OF + SEQUENCE{ + nR-CGI NR-CGI, + numberOfBroadcasts NumberOfBroadcasts, + iE-Extensions ProtocolExtensionContainer { {CancelledCellinTAI-5GS-ExtIEs} } OPTIONAL, + ... +} + +CancelledCellinTAI-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Cause ::= INTEGER { + message-accepted (0), + parameter-not-recognised (1), + parameter-value-invalid (2), + valid-message-not-identified (3), + tracking-area-not-valid (4), + unrecognised-message (5), + missing-mandatory-element (6), + mME-capacity-exceeded (7), + mME-memory-exceeded (8), + warning-broadcast-not-supported (9), + warning-broadcast-not-operational (10), + message-reference-already-used (11), + unspecifed-error (12), + transfer-syntax-error (13), + semantic-error (14), + message-not-compatible-with-receiver-state (15), + abstract-syntax-error-reject (16), + abstract-syntax-error-ignore-and-notify (17), + abstract-syntax-error-falsely-constructed-message (18) +} (0..255) + +CellId-Broadcast-List ::= SEQUENCE (SIZE(1..maxnoofCellID)) OF CellId-Broadcast-List-Item + +CellId-Broadcast-List-Item ::= SEQUENCE { + eCGI EUTRAN-CGI, + iE-Extensions ProtocolExtensionContainer { {CellId-Broadcast-List-Item-ExtIEs} } OPTIONAL, + ... +} + +CellId-Broadcast-List-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +CellId-Broadcast-List-5GS ::= SEQUENCE (SIZE(1..maxnoofCellsin5GS)) OF + SEQUENCE { + nR-CGI NR-CGI, + iE-Extensions ProtocolExtensionContainer { {CellId-Broadcast-List-5GS-ExtIEs} } OPTIONAL, + ... +} + +CellId-Broadcast-List-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +CellID-Cancelled-List ::= SEQUENCE (SIZE(1..maxnoofCellID)) OF CellID-Cancelled-Item + +CellID-Cancelled-Item ::= SEQUENCE { + eCGI EUTRAN-CGI, + numberOfBroadcasts NumberOfBroadcasts, + iE-Extensions ProtocolExtensionContainer { {CellID-Cancelled-Item-ExtIEs} } OPTIONAL, + ... +} + +CellID-Cancelled-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +CellID-Cancelled-List-5GS ::= SEQUENCE (SIZE(1..maxnoofCellsin5GS)) OF + SEQUENCE { + nR-CGI NR-CGI, + numberOfBroadcasts NumberOfBroadcasts, + iE-Extensions ProtocolExtensionContainer { {CellID-Cancelled-5GS-ExtIEs} } OPTIONAL, + ... +} + +CellID-Cancelled-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + + +CellIdentity ::= BIT STRING (SIZE (28)) + +Concurrent-Warning-Message-Indicator ::= ENUMERATED {true} + +Criticality-Diagnostics ::= SEQUENCE { + procedureCode ProcedureCode OPTIONAL, + triggeringMessage TriggeringMessage OPTIONAL, + procedureCriticality Criticality OPTIONAL, + iE-CriticalityDiagnostics CriticalityDiagnostics-IE-List OPTIONAL, + iE-Extensions ProtocolExtensionContainer { {CriticalityDiagnostics-ExtIEs} } OPTIONAL, + ... +} + +CriticalityDiagnostics-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +CriticalityDiagnostics-IE-List ::= SEQUENCE (SIZE (1..maxNrOfErrors)) OF + SEQUENCE { + iECriticality Criticality, + iE-ID ProtocolIE-ID, + typeOfError TypeOfError, + iE-Extensions ProtocolExtensionContainer {{CriticalityDiagnostics-IE-Item-ExtIEs}} OPTIONAL, + ... +} + +CriticalityDiagnostics-IE-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + + +-- D + +Data-Coding-Scheme ::= BIT STRING (SIZE (8)) + +-- E + +ECGIList ::= SEQUENCE (SIZE(1..maxnoofCellID)) OF EUTRAN-CGI + +Emergency-Area-ID-List ::= SEQUENCE (SIZE(1..maxnoofEmergencyAreaID)) OF Emergency-Area-ID + +Emergency-Area-ID ::= OCTET STRING (SIZE (3)) + +EmergencyAreaID-Broadcast-List ::= SEQUENCE (SIZE(1..maxnoofEmergencyAreaID)) OF EmergencyAreaID-Broadcast-List-Item + +EmergencyAreaID-Broadcast-List-Item ::= SEQUENCE { + emergencyAreaID Emergency-Area-ID, + scheduledCellinEAI ScheduledCellinEAI, + iE-Extensions ProtocolExtensionContainer { {EmergencyAreaID-Broadcast-List-Item-ExtIEs} } OPTIONAL, + ... +} + +EmergencyAreaID-Broadcast-List-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +EmergencyAreaID-Cancelled-List ::= SEQUENCE (SIZE(1..maxnoofEmergencyAreaID)) OF EmergencyAreaID-Cancelled-Item + +EmergencyAreaID-Cancelled-Item ::= SEQUENCE { + emergencyAreaID Emergency-Area-ID, + cancelledCellinEAI CancelledCellinEAI, + iE-Extensions ProtocolExtensionContainer { {EmergencyAreaID-Cancelled-Item-ExtIEs} } OPTIONAL, + ... +} + +EmergencyAreaID-Cancelled-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +EUTRAN-CGI ::= SEQUENCE { + pLMNidentity PLMNidentity, + cell-ID CellIdentity, + iE-Extensions ProtocolExtensionContainer { {EUTRAN-CGI-ExtIEs} } OPTIONAL, + ... +} + +EUTRAN-CGI-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Extended-Repetition-Period ::= INTEGER (4096..131071) + +ENB-ID ::= CHOICE { + macroENB-ID BIT STRING (SIZE(20)), + homeENB-ID BIT STRING (SIZE(28)), + ..., + short-macroENB-ID BIT STRING (SIZE(18)), + long-macroENB-ID BIT STRING (SIZE(21)) +} + + +-- F + +Failed-Cell-List ::= SEQUENCE (SIZE(1..maxnoofFailedCells)) OF EUTRAN-CGI + +Failed-Cell-List-NR ::= SEQUENCE (SIZE(1..maxnoofCellsingNB)) OF NR-CGI + +-- G + +Global-ENB-ID ::= SEQUENCE { + pLMNidentity PLMNidentity, + eNB-ID ENB-ID, + iE-Extensions ProtocolExtensionContainer { {GlobalENB-ID-ExtIEs} } OPTIONAL, + ... +} + +GlobalENB-ID-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Global-RAN-Node-ID ::= CHOICE { + global-GNB-ID Global-GNB-ID, + global-NgENB-ID Global-NgENB-ID, + ... +} + +Global-GNB-ID ::= SEQUENCE { + pLMNidentity PLMNidentity, + gNB-ID GNB-ID, + iE-Extensions ProtocolExtensionContainer { {Global-GNB-ID-ExtIEs} } OPTIONAL, + ... +} + +Global-GNB-ID-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +GNB-ID ::= CHOICE { + gNB-ID BIT STRING (SIZE(22..32)), + ... +} +Global-NgENB-ID ::= SEQUENCE { + pLMNidentity PLMNidentity, + ngENB-ID ENB-ID, + iE-Extensions ProtocolExtensionContainer { {Global-NgENB-ID-ExtIEs} } OPTIONAL, + ... +} + +Global-NgENB-ID-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + + +-- H + +-- I + +-- J + +-- K + +-- L + +List-of-TAIs ::= SEQUENCE (SIZE (1..maxNrOfTAIs)) OF + SEQUENCE { + tai TAI +} + +List-of-TAIs-Restart ::= SEQUENCE (SIZE (1..maxnoofRestartTAIs)) OF + SEQUENCE { + tai TAI +} + + +List-of-EAIs-Restart ::= SEQUENCE (SIZE(1..maxnoofRestartEAIs)) OF Emergency-Area-ID + +List-of-5GS-TAIs ::= SEQUENCE (SIZE (1..maxnoof5GSTAIs)) OF TAI-5GS + +List-of-5GS-Cells-for-Failure ::= SEQUENCE ( SIZE(1..maxnoofCellsingNB)) OF NR-CGI + +List-of-5GS-TAI-for-Restart ::= SEQUENCE (SIZE (1..maxnoofRestart5GSTAIs)) OF TAI-5GS + + +-- M + +Message-Identifier ::= BIT STRING (SIZE (16)) + +-- N + +Number-of-Broadcasts-Requested ::= INTEGER (0..65535) + +-- For Number-of-Broadcasts-Requested = 0 and Repetition-Period = 0, then eNB action is no broadcast +-- for ETWS Secondary and CMAS. +-- +-- For Number-of-Broadcasts-Requested = 1 and Repetition-Period = 0, then eNB action is broadcast +-- only once for ETWS and CMAS. +-- +-- For Number-of-Broadcasts-Requested = 0 and Repetition-Period > 0, then eNB action is no broadcast +-- for the ETWS Secondary, and broadcast until further notice for the CMAS. +-- +-- For Number-of-Broadcasts-Requested > 0 and Repetition-Period > 0, then eNB action is normal +-- broadcast. +-- All other combinations of Number-of-Broadcasts-Requested and Repetition-Period are considered +-- invalid. + +NumberOfBroadcasts ::= INTEGER (0..65535) + +NR-CGIList ::= SEQUENCE (SIZE(1..maxnoofCellsingNB)) OF NR-CGI + +NR-CGI ::= SEQUENCE { + pLMNidentity PLMNidentity, + nRCellIdentity NRCellIdentity, + iE-Extensions ProtocolExtensionContainer { {NR-CGI-ExtIEs} } OPTIONAL, + ... +} + +NR-CGI-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +NRCellIdentity ::= BIT STRING (SIZE(36)) + +NgENB-ID ::= CHOICE { + macroNgENB-ID BIT STRING (SIZE(20)), + shortMacroNgENB-ID BIT STRING (SIZE(18)), + longMacroNgENB-ID BIT STRING (SIZE(21)), + ... +} + +-- O +Omc-Id ::= OCTET STRING (SIZE (1..20)) + + +-- P +PLMNidentity ::= TBCD-STRING + +-- Q + +-- R + +Repetition-Period ::= INTEGER (0..4096) +-- 1 to 4096: Each unit represents a repetition of one second to a maximum of +-- once per 4096 seconds (~1 hour). +-- 0: no repetition +-- A CBC compliant to this version or later of this specification shall not send a repetition period +-- greater than 4095. +-- For backwards compatibility with a CBC compliant to an earlier version of this specification the +-- maximum value of the repetition period defined in ASN.1 remains at 4096. +-- If the value of the Repetition Period IE received in the WRITE-REPLACE WARNING REQUEST message is +-- set to 4096, the MME shall set the Repetition Period IE to the maximum value 4095 supported on +-- the S1-MME interface as defined in [7] before forwarding to the selected eNBs. + +Restarted-Cell-List ::= SEQUENCE (SIZE(1.. maxnoofRestartedCells)) OF EUTRAN-CGI + +RAT-Selector-5GS ::= ENUMERATED {true} + +Restarted-Cell-List-NR ::= SEQUENCE (SIZE(1.. maxnoofCellsforRestartNR)) OF NR-CGI + + + +-- S + +ScheduledCellinEAI ::= SEQUENCE (SIZE(1..maxnoofCellinEAI)) OF ScheduledCellinEAI-Item + +ScheduledCellinEAI-Item ::= SEQUENCE { + eCGI EUTRAN-CGI, + iE-Extensions ProtocolExtensionContainer { {ScheduledCellinEAI-Item-ExtIEs} } OPTIONAL, + ... +} + +ScheduledCellinEAI-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +ScheduledCellinTAI ::= SEQUENCE (SIZE(1..maxnoofCellinTAI)) OF ScheduledCellinTAI-Item + +ScheduledCellinTAI-Item ::= SEQUENCE{ + eCGI EUTRAN-CGI, + iE-Extensions ProtocolExtensionContainer { {ScheduledCellinTAI-Item-ExtIEs} } OPTIONAL, + ... +} + +ScheduledCellinTAI-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +ScheduledCellinTAI-5GS ::= SEQUENCE (SIZE(1..maxnoofCellsin5GSTAI)) OF + SEQUENCE{ + nR-CGI NR-CGI, + iE-Extensions ProtocolExtensionContainer { {ScheduledCellinTAI-5GS-ExtIEs} } OPTIONAL, + ... +} + +ScheduledCellinTAI-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +Send-Write-Replace-Warning-Indication ::= ENUMERATED {true} + +Send-Stop-Warning-Indication ::= ENUMERATED {true} + +Serial-Number ::= BIT STRING (SIZE (16)) + +Stop-All-Indicator ::= ENUMERATED {true} + +-- T + +TAC ::= OCTET STRING (SIZE (2)) + +TAC-5GS ::= OCTET STRING (SIZE (3)) + +TAI-Broadcast-List ::= SEQUENCE (SIZE(1..maxnoofTAIforWarning)) OF TAI-Broadcast-List-Item + +TAI-Broadcast-List-Item ::= SEQUENCE { + tAI TAI, + scheduledCellinTAI ScheduledCellinTAI, + iE-Extensions ProtocolExtensionContainer { {TAI-Broadcast-List-Item-ExtIEs} } OPTIONAL, + ... +} + +TAI-Broadcast-List-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +TAI-Broadcast-List-5GS ::= SEQUENCE (SIZE(1..maxnoof5GSTAIs)) OF + SEQUENCE { + tAI-5GS TAI-5GS, + scheduledCellinTAI-5GS ScheduledCellinTAI-5GS, + iE-Extensions ProtocolExtensionContainer { {TAI-Broadcast-List-5GS-ExtIEs} } OPTIONAL, + ... +} + +TAI-Broadcast-List-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + +TAI-Cancelled-List ::= SEQUENCE (SIZE(1..maxnoofTAIforWarning)) OF TAI-Cancelled-List-Item + +TAI-Cancelled-List-Item ::= SEQUENCE { + tAI TAI, + cancelledCellinTAI CancelledCellinTAI, + iE-Extensions ProtocolExtensionContainer { {TAI-Cancelled-List-Item-ExtIEs} } OPTIONAL, + ... +} + +TAI-Cancelled-List-Item-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +TAI-Cancelled-List-5GS ::= SEQUENCE (SIZE(1..maxnoof5GSTAIs)) OF + SEQUENCE { + tAI-5GS TAI-5GS, + cancelledCellinTAI-5GS CancelledCellinTAI-5GS, + iE-Extensions ProtocolExtensionContainer { {TAI-Cancelled-List-5GS-ExtIEs} } OPTIONAL, + ... +} + +TAI-Cancelled-List-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +TAI-List-for-Warning ::= SEQUENCE (SIZE(1.. maxnoofTAIforWarning)) OF TAI + +TAI ::= SEQUENCE { + pLMNidentity PLMNidentity, + tAC TAC, + iE-Extensions ProtocolExtensionContainer { {TAI-ExtIEs} } OPTIONAL +} + +TAI-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + +TBCD-STRING ::= OCTET STRING (SIZE (3)) + +TypeOfError ::= ENUMERATED { + not-understood, + missing, + ... +} +TAI-5GS ::= SEQUENCE { + pLMNidentity PLMNidentity, + tAC-5GS TAC-5GS, + iE-Extensions ProtocolExtensionContainer { {TAI-5GS-ExtIEs} } OPTIONAL +} + +TAI-5GS-ExtIEs SBC-AP-PROTOCOL-EXTENSION ::= { + ... +} + + +-- U + +Unknown-Tracking-Area-List ::= SEQUENCE (SIZE(1.. maxNrOfTAIs)) OF TAI + +Unknown-5GS-Tracking-Area-List ::= SEQUENCE (SIZE(1.. maxnoof5GSTAIs)) OF TAI-5GS + + +-- V + +-- W + +Warning-Area-List ::= CHOICE { + cell-ID-List ECGIList, + tracking-Area-List-for-Warning TAI-List-for-Warning, + emergency-Area-ID-List Emergency-Area-ID-List, + ... +} + +Warning-Message-Content ::= OCTET STRING (SIZE (1..9600)) +Warning-Area-Coordinates ::= OCTET STRING (SIZE (1..1024)) +Warning-Security-Information ::= OCTET STRING (SIZE (50)) +Warning-Type ::= OCTET STRING (SIZE (2)) + +Warning-Area-List-5GS ::= CHOICE { + cell-ID-List ECGIList, + nR-CGIList NR-CGIList, + tAIList-5GS TAI-5GS, + emergencyAreaIDList Emergency-Area-ID-List, + ... +} + + + +-- X + +-- Y + +END diff --git a/library/sbcap/SBC_AP_PDU_Contents.asn b/library/sbcap/SBC_AP_PDU_Contents.asn new file mode 100644 index 0000000..1117432 --- /dev/null +++ b/library/sbcap/SBC_AP_PDU_Contents.asn @@ -0,0 +1,374 @@ +-- SBC-AP-PDU-Contents.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.4 PDU Definitions +-- + +-- ************************************************************** +-- +-- PDU definitions for SBC-AP. +-- +-- ************************************************************** + +SBC-AP-PDU-Contents { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-PDU-Contents (1)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +-- ************************************************************** +-- +-- IE parameter types from other modules. +-- +-- ************************************************************** + +IMPORTS + + Cause, + Concurrent-Warning-Message-Indicator, + Criticality-Diagnostics, + Data-Coding-Scheme, + Message-Identifier, + Serial-Number, + List-of-TAIs, + Warning-Area-List, + Omc-Id, + Repetition-Period, + Extended-Repetition-Period, + Number-of-Broadcasts-Requested, + Warning-Type, + Warning-Security-Information, + Warning-Message-Content, + Warning-Area-Coordinates, + Send-Write-Replace-Warning-Indication, + Broadcast-Scheduled-Area-List, + Unknown-Tracking-Area-List, + Send-Stop-Warning-Indication, + Broadcast-Cancelled-Area-List, + Stop-All-Indicator, + Broadcast-Empty-Area-List, + Restarted-Cell-List, + Global-ENB-ID, + List-of-TAIs-Restart, + List-of-EAIs-Restart, + Failed-Cell-List, + List-of-5GS-TAIs, + Warning-Area-List-5GS, + Global-RAN-Node-ID, + Global-GNB-ID, + RAT-Selector-5GS, + Unknown-5GS-Tracking-Area-List, + Broadcast-Scheduled-Area-List-5GS, + Broadcast-Cancelled-Area-List-5GS, + Broadcast-Empty-Area-List-5GS, + Restarted-Cell-List-NR, + Failed-Cell-List-NR, + List-of-5GS-TAI-for-Restart + +FROM SBC-AP-IEs + + ProtocolExtensionContainer{}, + ProtocolIE-Container{}, + SBC-AP-PROTOCOL-EXTENSION, + SBC-AP-PROTOCOL-IES +FROM SBC-AP-Containers + + id-Concurrent-Warning-Message-Indicator, + id-Criticality-Diagnostics, + id-Cause, + id-Data-Coding-Scheme, + id-List-of-TAIs, + id-Message-Identifier, + id-Serial-Number, + id-Number-of-Broadcasts-Requested, + id-Omc-Id, + id-Radio-Resource-Loading-List, + id-Recovery-Indication, + id-Repetition-Period, + id-Extended-Repetition-Period, + id-Warning-Area-List, + id-Warning-Message-Content, + id-Warning-Area-Coordinates, + id-Warning-Security-Information, + id-Warning-Type, + id-Send-Write-Replace-Warning-Indication, + id-Broadcast-Scheduled-Area-List, + id-Unknown-Tracking-Area-List, + id-Send-Stop-Warning-Indication, + id-Broadcast-Cancelled-Area-List, + id-Stop-All-Indicator, + id-Broadcast-Empty-Area-List, + id-Global-ENB-ID, + id-Restarted-Cell-List, + id-List-of-TAIs-Restart, + id-List-of-EAIs-Restart, + id-Failed-Cell-List, + id-List-of-5GS-TAIs, + id-Warning-Area-List-5GS, + id-Global-RAN-Node-ID, + id-Global-GNB-ID, + id-RAT-Selector-5GS, + id-Unknown-5GS-Tracking-Area-List, + id-Broadcast-Scheduled-Area-List-5GS, + id-Broadcast-Cancelled-Area-List-5GS, + id-Broadcast-Empty-Area-List-5GS, + id-Restarted-Cell-List-NR, + id-Failed-Cell-List-NR, + id-List-of-5GS-TAI-for-Restart + +FROM SBC-AP-Constants; + +-- ************************************************************** +-- +-- Write-Replace-Warning-Request +-- +-- ************************************************************** + +Write-Replace-Warning-Request ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Write-Replace-Warning-Request-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Write-Replace-Warning-Request-Extensions} } OPTIONAL, + ... +} + +Write-Replace-Warning-Request-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-List-of-TAIs CRITICALITY reject TYPE List-of-TAIs PRESENCE optional } | + { ID id-Warning-Area-List CRITICALITY ignore TYPE Warning-Area-List PRESENCE optional } | + { ID id-Repetition-Period CRITICALITY reject TYPE Repetition-Period PRESENCE mandatory } | + { ID id-Extended-Repetition-Period CRITICALITY reject TYPE Extended-Repetition-Period PRESENCE optional } | + + { ID id-Number-of-Broadcasts-Requested + CRITICALITY reject TYPE Number-of-Broadcasts-Requested PRESENCE mandatory } | + { ID id-Warning-Type CRITICALITY ignore TYPE Warning-Type PRESENCE optional } | + { ID id-Warning-Security-Information CRITICALITY ignore TYPE Warning-Security-Information PRESENCE optional } | + { ID id-Data-Coding-Scheme CRITICALITY ignore TYPE Data-Coding-Scheme PRESENCE optional } | + { ID id-Warning-Message-Content + CRITICALITY ignore TYPE Warning-Message-Content PRESENCE optional } | + { ID id-Omc-Id CRITICALITY ignore TYPE Omc-Id PRESENCE optional } | + { ID id-Concurrent-Warning-Message-Indicator CRITICALITY reject TYPE Concurrent-Warning-Message-Indicator PRESENCE optional } | + { ID id-Send-Write-Replace-Warning-Indication CRITICALITY ignore TYPE Send-Write-Replace-Warning-Indication PRESENCE optional } | + { ID id-Global-ENB-ID CRITICALITY ignore TYPE Global-ENB-ID PRESENCE optional }, + ... , + {ID id-Warning-Area-Coordinates CRITICALITY ignore TYPE Warning-Area-Coordinates PRESENCE optional} +} + +Write-Replace-Warning-Request-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-List-of-5GS-TAIs CRITICALITY ignore EXTENSION List-of-5GS-TAIs PRESENCE optional }| + { ID id-Warning-Area-List-5GS CRITICALITY ignore EXTENSION Warning-Area-List-5GS PRESENCE optional }| + { ID id-Global-RAN-Node-ID CRITICALITY ignore EXTENSION Global-RAN-Node-ID PRESENCE optional }| + { ID id-RAT-Selector-5GS CRITICALITY ignore EXTENSION RAT-Selector-5GS PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- Write-Replace-Warning-Response +-- +-- ************************************************************** + +Write-Replace-Warning-Response ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Write-Replace-Warning-Response-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Write-Replace-Warning-Response-Extensions} } OPTIONAL, + ... +} + +Write-Replace-Warning-Response-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-Cause CRITICALITY reject TYPE Cause PRESENCE mandatory } | + { ID id-Criticality-Diagnostics CRITICALITY ignore TYPE Criticality-Diagnostics PRESENCE optional } | + { ID id-Unknown-Tracking-Area-List CRITICALITY ignore TYPE List-of-TAIs PRESENCE optional }, + ... +} + +Write-Replace-Warning-Response-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Unknown-5GS-Tracking-Area-List CRITICALITY ignore EXTENSION Unknown-5GS-Tracking-Area-List PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- Stop-Warning-Request +-- +-- ************************************************************** + +Stop-Warning-Request ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Stop-Warning-Request-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Stop-Warning-Request-Extensions} } OPTIONAL, + ... +} + +Stop-Warning-Request-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-List-of-TAIs CRITICALITY reject TYPE List-of-TAIs PRESENCE optional } | + { ID id-Warning-Area-List CRITICALITY ignore TYPE Warning-Area-List PRESENCE optional }| + { ID id-Omc-Id CRITICALITY ignore TYPE Omc-Id PRESENCE optional } | + { ID id-Send-Stop-Warning-Indication CRITICALITY ignore TYPE Send-Stop-Warning-Indication PRESENCE optional } | + { ID id-Stop-All-Indicator CRITICALITY reject TYPE Stop-All-Indicator PRESENCE optional}, + ... +} + +Stop-Warning-Request-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-List-of-5GS-TAIs CRITICALITY ignore EXTENSION List-of-5GS-TAIs PRESENCE optional }| + { ID id-Warning-Area-List-5GS CRITICALITY ignore EXTENSION Warning-Area-List-5GS PRESENCE optional } | { ID id-RAT-Selector-5GS CRITICALITY ignore EXTENSION RAT-Selector-5GS PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- Stop-Warning-Response +-- +-- ************************************************************** + +Stop-Warning-Response ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Stop-Warning-Response-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Stop-Warning-Response-Extensions} } OPTIONAL, + ... +} + +Stop-Warning-Response-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-Cause CRITICALITY reject TYPE Cause PRESENCE mandatory } | + { ID id-Criticality-Diagnostics CRITICALITY ignore TYPE Criticality-Diagnostics PRESENCE optional } | + { ID id-Unknown-Tracking-Area-List CRITICALITY ignore TYPE List-of-TAIs PRESENCE optional }, + ... +} + +Stop-Warning-Response-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Unknown-5GS-Tracking-Area-List CRITICALITY ignore EXTENSION Unknown-5GS-Tracking-Area-List PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- Write-Replace-Warning-Indication +-- +-- ************************************************************** + +Write-Replace-Warning-Indication ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Write-Replace-Warning-Indication-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Write-Replace-Warning-Indication-Extensions} } OPTIONAL, + ... +} + +Write-Replace-Warning-Indication-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-Broadcast-Scheduled-Area-List CRITICALITY reject TYPE Broadcast-Scheduled-Area-List PRESENCE optional }, + ... +} + +Write-Replace-Warning-Indication-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Broadcast-Scheduled-Area-List-5GS CRITICALITY ignore EXTENSION Broadcast-Scheduled-Area-List-5GS PRESENCE optional }, + + ... +} + +-- ************************************************************** +-- +-- Stop-Warning-Indication +-- +-- ************************************************************** + +Stop-Warning-Indication ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {Stop-Warning-Indication-IEs} }, + protocolExtensions ProtocolExtensionContainer { {Stop-Warning-Indication-Extensions} } OPTIONAL, + ... +} + +Stop-Warning-Indication-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Message-Identifier CRITICALITY reject TYPE Message-Identifier PRESENCE mandatory } | + { ID id-Serial-Number CRITICALITY reject TYPE Serial-Number PRESENCE mandatory } | + { ID id-Broadcast-Cancelled-Area-List CRITICALITY reject TYPE Broadcast-Cancelled-Area-List PRESENCE optional }| + { ID id-Broadcast-Empty-Area-List CRITICALITY ignore TYPE Broadcast-Empty-Area-List PRESENCE optional }, + ... +} + +Stop-Warning-Indication-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Broadcast-Cancelled-Area-List-5GS CRITICALITY ignore EXTENSION Broadcast-Cancelled-Area-List-5GS PRESENCE optional }| + { ID id-Broadcast-Empty-Area-List-5GS CRITICALITY ignore EXTENSION Broadcast-Empty-Area-List-5GS PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- PWS-Restart-Indication +-- +-- ************************************************************** + +PWS-Restart-Indication ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {PWS-Restart-Indication-IEs} }, + protocolExtensions ProtocolExtensionContainer { {PWS-Restart-Indication-Extensions} } OPTIONAL, + ... +} + +PWS-Restart-Indication-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Restarted-Cell-List CRITICALITY reject TYPE Restarted-Cell-List PRESENCE mandatory }| + { ID id-Global-ENB-ID CRITICALITY reject TYPE Global-ENB-ID PRESENCE mandatory } | + { ID id-List-of-TAIs-Restart CRITICALITY reject TYPE List-of-TAIs-Restart PRESENCE mandatory } | + { ID id-List-of-EAIs-Restart CRITICALITY reject TYPE List-of-EAIs-Restart PRESENCE optional }, + ... +} + +PWS-Restart-Indication-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Restarted-Cell-List-NR CRITICALITY ignore EXTENSION Restarted-Cell-List-NR PRESENCE optional }| + { ID id-List-of-5GS-TAI-for-Restart CRITICALITY ignore EXTENSION List-of-5GS-TAI-for-Restart PRESENCE optional }| +{ ID id-Global-GNB-ID CRITICALITY ignore EXTENSION Global-GNB-ID PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- PWS-Failure-Indication +-- +-- ************************************************************** + +PWS-Failure-Indication ::= SEQUENCE { + protocolIEs ProtocolIE-Container { {PWS-Failure-Indication-IEs} }, + protocolExtensions ProtocolExtensionContainer { {PWS-Failure-Indication-Extensions} } OPTIONAL, + ... +} + +PWS-Failure-Indication-IEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Failed-Cell-List CRITICALITY reject TYPE Failed-Cell-List PRESENCE mandatory }| + { ID id-Global-ENB-ID CRITICALITY reject TYPE Global-ENB-ID PRESENCE mandatory }, + ... +} + +PWS-Failure-Indication-Extensions SBC-AP-PROTOCOL-EXTENSION ::= { + { ID id-Failed-Cell-List-NR CRITICALITY ignore EXTENSION Failed-Cell-List-NR PRESENCE optional }| + { ID id-Global-GNB-ID CRITICALITY ignore EXTENSION Global-GNB-ID PRESENCE optional }, + ... +} + +-- ************************************************************** +-- +-- ERROR INDICATION ELEMENTARY PROCEDURE +-- +-- ************************************************************** + +-- ************************************************************** +-- +-- Error Indication +-- +-- ************************************************************** + +Error-Indication ::= SEQUENCE { + protocolIEs ProtocolIE-Container {{ErrorIndicationIEs}}, + ... +} + +ErrorIndicationIEs SBC-AP-PROTOCOL-IES ::= { + { ID id-Cause CRITICALITY ignore TYPE Cause PRESENCE optional } | + { ID id-Criticality-Diagnostics CRITICALITY ignore TYPE Criticality-Diagnostics PRESENCE optional } , + ... +} + +END diff --git a/library/sbcap/SBC_AP_PDU_Descriptions.asn b/library/sbcap/SBC_AP_PDU_Descriptions.asn new file mode 100644 index 0000000..fbb80d5 --- /dev/null +++ b/library/sbcap/SBC_AP_PDU_Descriptions.asn @@ -0,0 +1,179 @@ +-- SBC-AP-PDU-Descriptions.asn +-- +-- Taken from 3GPP TS 29.168 V15.1.0 (2018-09) +-- http://www.3gpp.org/ftp/Specs/archive/29_series/29.168/29168-930.zip +-- +-- 4.4.3 Elementary Procedure Definitions +-- + +-- ************************************************************** +-- +-- Elementary Procedure definitions +-- +-- ************************************************************** + +SBC-AP-PDU-Descriptions { +itu-t (0) identified-organization (4) etsi (0) mobileDomain (0) +eps-Access (21) modules (3) sbc-AP (3) version1 (1) sbc-AP-PDU-Descriptions (0)} + +DEFINITIONS AUTOMATIC TAGS ::= + +BEGIN + +-- ************************************************************** +-- +-- IE parameter types from other modules. +-- +-- ************************************************************** + +IMPORTS + Criticality, + ProcedureCode +FROM SBC-AP-CommonDataTypes + + Write-Replace-Warning-Request, + Write-Replace-Warning-Response, + Stop-Warning-Request, + Stop-Warning-Response, + Error-Indication, + Write-Replace-Warning-Indication, + Stop-Warning-Indication, + PWS-Restart-Indication, + PWS-Failure-Indication +FROM SBC-AP-PDU-Contents + + id-Write-Replace-Warning, + id-Stop-Warning, + id-Error-Indication, + id-Write-Replace-Warning-Indication, + id-Stop-Warning-Indication, + id-PWS-Restart-Indication, + id-PWS-Failure-Indication +FROM SBC-AP-Constants; + +-- ************************************************************** +-- +-- Interface Elementary Procedure Class +-- +-- ************************************************************** + +SBC-AP-ELEMENTARY-PROCEDURE ::= CLASS { + &InitiatingMessage , + &SuccessfulOutcome OPTIONAL, + &UnsuccessfulOutcome OPTIONAL, + &procedureCode ProcedureCode UNIQUE, + &criticality Criticality DEFAULT ignore +} +WITH SYNTAX { + INITIATING MESSAGE &InitiatingMessage + [SUCCESSFUL OUTCOME &SuccessfulOutcome] + [UNSUCCESSFUL OUTCOME &UnsuccessfulOutcome] + PROCEDURE CODE &procedureCode + [CRITICALITY &criticality] +} + +-- ************************************************************** +-- +-- Interface PDU Definition +-- +-- ************************************************************** + +SBC-AP-PDU ::= CHOICE { + initiatingMessage InitiatingMessage, + successfulOutcome SuccessfulOutcome, + unsuccessfulOutcome UnsuccessfulOutcome, + ... +} + +InitiatingMessage ::= SEQUENCE { + procedureCode SBC-AP-ELEMENTARY-PROCEDURE.&procedureCode ({SBC-AP-ELEMENTARY-PROCEDURES}), + criticality SBC-AP-ELEMENTARY-PROCEDURE.&criticality ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}), + value SBC-AP-ELEMENTARY-PROCEDURE.&InitiatingMessage ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}) +} + +SuccessfulOutcome ::= SEQUENCE { + procedureCode SBC-AP-ELEMENTARY-PROCEDURE.&procedureCode ({SBC-AP-ELEMENTARY-PROCEDURES}), + criticality SBC-AP-ELEMENTARY-PROCEDURE.&criticality ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}), + value SBC-AP-ELEMENTARY-PROCEDURE.&SuccessfulOutcome ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}) +} + +UnsuccessfulOutcome ::= SEQUENCE { + procedureCode SBC-AP-ELEMENTARY-PROCEDURE.&procedureCode ({SBC-AP-ELEMENTARY-PROCEDURES}), + criticality SBC-AP-ELEMENTARY-PROCEDURE.&criticality ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}), + value SBC-AP-ELEMENTARY-PROCEDURE.&UnsuccessfulOutcome ({SBC-AP-ELEMENTARY-PROCEDURES}{@procedureCode}) +} + +-- ************************************************************** +-- +-- Interface Elementary Procedure List +-- +-- ************************************************************** + +SBC-AP-ELEMENTARY-PROCEDURES SBC-AP-ELEMENTARY-PROCEDURE ::= { + SBC-AP-ELEMENTARY-PROCEDURES-CLASS-1 | + SBC-AP-ELEMENTARY-PROCEDURES-CLASS-2 , + ... +} + +SBC-AP-ELEMENTARY-PROCEDURES-CLASS-1 SBC-AP-ELEMENTARY-PROCEDURE ::= { + write-Replace-Warning | + stop-Warning , + ... +} + +SBC-AP-ELEMENTARY-PROCEDURES-CLASS-2 SBC-AP-ELEMENTARY-PROCEDURE ::= { + error-Indication | + write-Replace-Warning-Indication | + stop-Warning-Indication | + pws-Restart-Indication | + pws-Failure-Indication, + ... + } + +write-Replace-Warning SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE Write-Replace-Warning-Request + SUCCESSFUL OUTCOME Write-Replace-Warning-Response + + PROCEDURE CODE id-Write-Replace-Warning + CRITICALITY reject +} + +stop-Warning SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE Stop-Warning-Request + SUCCESSFUL OUTCOME Stop-Warning-Response + + PROCEDURE CODE id-Stop-Warning + CRITICALITY reject +} + +error-Indication SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE Error-Indication + PROCEDURE CODE id-Error-Indication + CRITICALITY ignore +} + +write-Replace-Warning-Indication SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE Write-Replace-Warning-Indication + PROCEDURE CODE id-Write-Replace-Warning-Indication + CRITICALITY ignore +} + +stop-Warning-Indication SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE Stop-Warning-Indication + PROCEDURE CODE id-Stop-Warning-Indication + CRITICALITY ignore +} + +pws-Restart-Indication SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE PWS-Restart-Indication + PROCEDURE CODE id-PWS-Restart-Indication + CRITICALITY ignore +} + +pws-Failure-Indication SBC-AP-ELEMENTARY-PROCEDURE ::= { + INITIATING MESSAGE PWS-Failure-Indication + PROCEDURE CODE id-PWS-Failure-Indication + CRITICALITY ignore +} + +END diff --git a/library/sbcap/SBC_AP_Templates.ttcn b/library/sbcap/SBC_AP_Templates.ttcn new file mode 100644 index 0000000..c0c0837 --- /dev/null +++ b/library/sbcap/SBC_AP_Templates.ttcn @@ -0,0 +1,276 @@ +module SBC_AP_Templates { + +import from General_Types all; +import from Osmocom_Types all; + +import from SBC_AP_IEs all; +import from SBC_AP_Constants all; +import from SBC_AP_Containers all; +import from SBC_AP_PDU_Contents all; +import from SBC_AP_PDU_Descriptions all; + +import from SBC_AP_Types all; + +template (value) SBC_AP_PDU +ts_SBCAP_PWS_RESTART( + template (value) Restarted_Cell_List restart_cl, + template (value) Global_ENB_ID global_enb_id) := { + initiatingMessage := { + procedureCode := id_PWS_Restart_Indication, + criticality := reject, + value_ := { + PWS_Restart_Indication := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Restarted_Cell_List, + criticality := reject, + value_ := { Restarted_Cell_List := restart_cl } + }, { + id := SBC_AP_Constants.id_Global_ENB_ID, + criticality := reject, + value_ := { Global_ENB_ID := global_enb_id } + } + /* List of TAIs (mandatory) */ + /* List of EAIs (optional) */ + }, + protocolExtensions := omit + } + } + } +} + +template (value) SBC_AP_PDU +ts_SBCAP_PWS_FAILURE( + template (value) Failed_Cell_List fail_cl, + template (value) Global_ENB_ID global_enb_id) := { + initiatingMessage := { + procedureCode := id_PWS_Failure_Indication, + criticality := reject, + value_ := { + PWS_Failure_Indication := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Failed_Cell_List, + criticality := reject, + value_ := { Failed_Cell_List := fail_cl } + }, { + id := SBC_AP_Constants.id_Global_ENB_ID, + criticality := reject, + value_ := { Global_ENB_ID := global_enb_id } + } + }, + protocolExtensions := omit + } + } + } +} + +/* 4.3.4.2.1 WRITE-REPLACE WARNING REQUEST */ +template (value) SBC_AP_PDU +ts_SBCAP_WRITE_WARNING(template (value) BIT16 p_msg_id, template (value) BIT16 p_ser_nr, + template (value) uint12_t p_rep_per, template (value) uint16_t p_num_bcast, + template (value) OCT2 p_w_type, OCT1 p_dcs, + template (value) octetstring p_msg_content) := { + initiatingMessage := { + procedureCode := id_Write_Replace_Warning, + criticality := reject, + value_ := { + write_Replace_Warning_Request := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Message_Identifier, + criticality := reject, + value_ := { Message_Identifier := p_msg_id } + }, { + id := SBC_AP_Constants.id_Serial_Number, + criticality := reject, + value_ := { Serial_Number := p_ser_nr } + /* List of TAIs */ + /* Warning Area List */ + }, { + id := SBC_AP_Constants.id_Repetition_Period, + criticality := reject, + value_ := { Repetition_Period := p_rep_per } + /* Extended Repetition Period */ + }, { + id := SBC_AP_Constants.id_Number_of_Broadcasts_Requested, + criticality := reject, + value_ := { Number_of_Broadcasts_Requested := p_num_bcast } + }, { + id := SBC_AP_Constants.id_Warning_Type, + criticality := ignore, + value_ := { Warning_Type := p_w_type } + }, { + /* Warning Security Info */ + /* Data Coding Scheme */ + id := SBC_AP_Constants.id_Data_Coding_Scheme, + criticality := ignore, + value_ := { Data_Coding_Scheme := oct2bit(p_dcs) } + }, { + /* Warning Message Content */ + id := SBC_AP_Constants.id_Warning_Message_Content, + criticality := ignore, + value_ := { Warning_Message_Content := p_msg_content } + } + /* OMC ID */ + /* Concurrent Warning Message Indicator */ + /* Send Write Replace Warning Indication */ + /* Global eNB ID */ + /* Warning Area Coordinates */ + }, + protocolExtensions := omit + } + } + } +} + +template (present) SBC_AP_PDU +tr_SBCAP_WRITE_WARNING(template (present) BIT16 p_msg_id, template (present) BIT16 p_ser_nr, + template (present) uint12_t p_rep_per, + template (present) uint16_t p_num_bcast, + template (present) BIT8 dcs := ?, + template (present) octetstring p_msg_content := ? + ) := { + initiatingMessage := { + procedureCode := id_Write_Replace_Warning, + criticality := reject, + value_ := { + write_Replace_Warning_Request := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Message_Identifier, + criticality := reject, + value_ := { Message_Identifier := p_msg_id } + }, { + id := SBC_AP_Constants.id_Serial_Number, + criticality := reject, + value_ := { Serial_Number := p_ser_nr } + /* List of TAIs */ + /* Warning Area List */ + }, { + id := SBC_AP_Constants.id_Repetition_Period, + criticality := reject, + value_ := { Repetition_Period := p_rep_per } + /* Extended Repetition Period */ + }, { + id := SBC_AP_Constants.id_Number_of_Broadcasts_Requested, + criticality := reject, + value_ := { Number_of_Broadcasts_Requested := p_num_bcast } + }/*, { + id := SBC_AP_Constants.id_Warning_Type, + criticality := ignore, + value_ := { Warning_Type := warn_type } + }, { + id := SBC_AP_Constants.id_Warning_Security_Information, + criticality := reject, + value_ := { Warning_Security_Information := ? } + }*/, { + id := SBC_AP_Constants.id_Data_Coding_Scheme, + criticality := ignore, + value_ := { Data_Coding_Scheme := dcs } + }, { + /* Warning Message Content */ + id := SBC_AP_Constants.id_Warning_Message_Content, + criticality := ignore, + value_ := { Warning_Message_Content := p_msg_content } + } + /* Warning Message Content */ + /* OMC ID */ + /* Concurrent Warning Message Indicator */ + /* Send Write Replace Warning Indication */ + /* Global eNB ID */ + /* Warning Area Coordinates */ + }, + protocolExtensions := omit + } + } + } +} + +/* 4.3.4.2.3 STOP WARNING REQUEST */ +template (value) SBC_AP_PDU +ts_SBCAP_WRITE_WARNING_RESP(template (value) BIT16 p_msg_id, template (value) BIT16 p_ser_nr, + template (value) SBC_AP_Cause cause := SBC_AP_Cause_message_accepted) := { + successfulOutcome := { + procedureCode := id_Write_Replace_Warning, + criticality := reject, + value_ := { + write_Replace_Warning_Response := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Message_Identifier, + criticality := reject, + value_ := { Message_Identifier := p_msg_id } + }, { + id := SBC_AP_Constants.id_Serial_Number, + criticality := reject, + value_ := { Serial_Number := p_ser_nr } + }, { + id := SBC_AP_Constants.id_Cause, + criticality := reject, + value_ := { Cause := enum2int(valueof(cause)) } + } + }, + protocolExtensions := omit + } + } + } +} + +template (present) SBC_AP_PDU +tr_SBCAP_STOP_WARNING(template (present) BIT16 p_msg_id, template (present) BIT16 p_ser_nr) := { + initiatingMessage := { + procedureCode := id_Stop_Warning, + criticality := reject, + value_ := { + stop_Warning_Request := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Message_Identifier, + criticality := reject, + value_ := { Message_Identifier := p_msg_id } + }, { + id := SBC_AP_Constants.id_Serial_Number, + criticality := reject, + value_ := { Serial_Number := p_ser_nr } + /* List of TAIs */ + /* Warning Area List */ + } + }, + protocolExtensions := omit + } + } + } +} + +/* 4.3.4.2.4 STOP WARNING RESPONSE */ +template (value) SBC_AP_PDU +ts_SBCAP_STOP_WARNING_RESP(template (value) BIT16 p_msg_id, template (value) BIT16 p_ser_nr, + template (value) SBC_AP_Cause cause := SBC_AP_Cause_message_accepted) := { + successfulOutcome := { + procedureCode := id_Stop_Warning, + criticality := reject, + value_ := { + stop_Warning_Response := { + protocolIEs := { + { + id := SBC_AP_Constants.id_Message_Identifier, + criticality := reject, + value_ := { Message_Identifier := p_msg_id } + }, { + id := SBC_AP_Constants.id_Serial_Number, + criticality := reject, + value_ := { Serial_Number := p_ser_nr } + }, { + id := SBC_AP_Constants.id_Cause, + criticality := reject, + value_ := { Cause := enum2int(valueof(cause)) } + } + }, + protocolExtensions := omit + } + } + } +} + +} diff --git a/library/sbcap/SBC_AP_Types.ttcn b/library/sbcap/SBC_AP_Types.ttcn new file mode 100644 index 0000000..cfb043d --- /dev/null +++ b/library/sbcap/SBC_AP_Types.ttcn @@ -0,0 +1,15 @@ +module SBC_AP_Types { + + import from SBC_AP_PDU_Descriptions language "ASN.1:1997" all; + + external function enc_SBC_AP_PDU(in SBC_AP_PDU pdu) return octetstring; + external function dec_SBC_AP_PDU(in octetstring stream) return SBC_AP_PDU; + + const integer c_SBC_AP_PPID := 24; + const integer c_SBC_AP_PORT := 29168; + + /* 3GPP TS 29.168 4.3.4.3.2 Cause */ + type enumerated SBC_AP_Cause { + SBC_AP_Cause_message_accepted ('00'O) + } +} diff --git a/library/sbcap/regen_makefile.sh b/library/sbcap/regen_makefile.sh new file mode 100755 index 0000000..0cd6083 --- /dev/null +++ b/library/sbcap/regen_makefile.sh @@ -0,0 +1,9 @@ +#!/bin/sh + +FILES="*.asn *.ttcn SBC_AP_EncDec.cc" + +../../regen-makefile.sh $FILES + +sed -i -e '/^CPPFLAGS/ s/$/ `pkg-config --cflags libfftranscode`/' Makefile +sed -i -e '/^LDFLAGS/ s/$/ `pkg-config --libs libfftranscode`/' Makefile +sed -i -e '/^LINUX_LIBS/ s/$/ `pkg-config --libs libfftranscode`/' Makefile -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/28603 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: Ia6743e0a3e7974a5f2dd3ecf74ec331f646f6bc2 Gerrit-Change-Number: 28603 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newchange

2 years, 11 months

Change in osmo-cbc[master]: Add initial SBc-AP support to osmo-cbc

by pespin

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-cbc/+/28602 ) Change subject: Add initial SBc-AP support to osmo-cbc ...................................................................... Add initial SBc-AP support to osmo-cbc This patch makes use of the newly introduced sbcap library, and introduces new code (and extends existing one) to handle all the aspects of MME peers talking SBc-AP and its underlaying SCTP connection. This commit doesn't aim to implement all the SBc-AP features, but to implement a minimal subset of features already available for CBSP in osmo-cbc, in order to have similar support level for both 2G and 4G networks. Related: OS#4945 Change-Id: Ib278bc1d1a74459814016fef7a8fe21cc29d46c9 --- M configure.ac M debian/control M doc/examples/osmo-cbc/osmo-cbc.cfg M include/osmocom/cbc/Makefile.am M include/osmocom/cbc/cbc_data.h M include/osmocom/cbc/internal.h A include/osmocom/cbc/sbcap_msg.h A include/osmocom/cbc/sbcap_server.h M src/Makefile.am M src/cbc_data.c M src/cbc_main.c M src/cbc_vty.c M src/message_handling.c A src/sbcap_msg.c A src/sbcap_server.c A src/sbcap_server_fsm.c M src/smscb_message_fsm.c M src/smscb_peer_fsm.c 18 files changed, 1,319 insertions(+), 54 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-cbc refs/changes/02/28602/1 diff --git a/configure.ac b/configure.ac index c104f2c..aa312bf 100644 --- a/configure.ac +++ b/configure.ac @@ -48,6 +48,18 @@ AC_SUBST([ASN1C_BIN_PATH]) AC_SUBST([ASN_MODULE_CFLAGS]) +AC_CHECK_HEADERS(netinet/sctp.h,,AC_MSG_ERROR(netinet/sctp.h not found)) +old_LIBS=$LIBS +AC_SEARCH_LIBS([sctp_recvmsg], [sctp], [ + AC_DEFINE(HAVE_LIBSCTP, 1, [Define 1 to enable SCTP support]) + AC_SUBST(HAVE_LIBSCTP, [1]) + if test -n "$ac_lib"; then + AC_SUBST(LIBSCTP_LIBS, [-l$ac_lib]) + fi + ], [ + AC_MSG_ERROR([sctp_recvmsg not found in searched libs])]) +LIBS=$old_LIBS + AC_ARG_ENABLE(sanitize, [AS_HELP_STRING( [--enable-sanitize], diff --git a/debian/control b/debian/control index f971922..87b43ad 100644 --- a/debian/control +++ b/debian/control @@ -15,6 +15,7 @@ libosmo-netif-dev (>= 1.2.0), libulfius-dev, libjansson-dev, + libsctp-dev, osmo-gsm-manuals-dev Standards-Version: 3.9.8 Vcs-Git: https://gitea.osmocom.org/cellular-infrastructure/osmo-cbc diff --git a/doc/examples/osmo-cbc/osmo-cbc.cfg b/doc/examples/osmo-cbc/osmo-cbc.cfg index 0b66996..b2bce58 100644 --- a/doc/examples/osmo-cbc/osmo-cbc.cfg +++ b/doc/examples/osmo-cbc/osmo-cbc.cfg @@ -9,3 +9,7 @@ ecbe local-ip 127.0.0.1 local-port 12345 + sbcap + local-ip 127.0.0.1 + local-ip ::1 + local-port 6789 diff --git a/include/osmocom/cbc/Makefile.am b/include/osmocom/cbc/Makefile.am index 1135800..d1cc46e 100644 --- a/include/osmocom/cbc/Makefile.am +++ b/include/osmocom/cbc/Makefile.am @@ -3,5 +3,7 @@ cbsp_server.h \ charset.h \ internal.h \ + sbcap_msg.h \ + sbcap_server.h \ rest_it_op.h \ $(NULL) diff --git a/include/osmocom/cbc/cbc_data.h b/include/osmocom/cbc/cbc_data.h index d6fc3d2..a90ff66 100644 --- a/include/osmocom/cbc/cbc_data.h +++ b/include/osmocom/cbc/cbc_data.h @@ -11,6 +11,8 @@ struct osmo_sabp_cbc_client; struct rest_it_op; +#define CBC_MAX_ADDRS 8 + /********************************************************************************* * CBC Peer *********************************************************************************/ @@ -18,13 +20,15 @@ enum cbc_peer_protocol { CBC_PEER_PROTO_CBSP, CBC_PEER_PROTO_SABP, + CBC_PEER_PROTO_SBcAP }; struct cbc_peer { struct llist_head list; /* linked to cbc.peers */ const char *name; - char *remote_host; /* remote IP address in string format */ + char *remote_host[CBC_MAX_ADDRS]; /* remote IP address in string format */ + unsigned int num_remote_host; /* number of addresses present in remote_host */ int remote_port; /* remote port number or -1 for random */ bool unknown_dynamic_peer; /* dynamic/unknown peer; not saved in VTY */ @@ -32,6 +36,7 @@ union { struct osmo_cbsp_cbc_client *cbsp; struct osmo_sabp_cbc_client *sabp; + struct osmo_sbcap_cbc_client *sbcap; } client; }; @@ -171,6 +176,11 @@ int local_port; } cbsp; struct { + char *local_host[CBC_MAX_ADDRS]; + unsigned int num_local_host; + int local_port; + } sbcap; + struct { char *local_host; int local_port; } ecbe; @@ -197,4 +207,3 @@ enum cbc_peer_protocol proto); struct cbc_peer *cbc_peer_create(const char *name, enum cbc_peer_protocol proto); void cbc_peer_remove(struct cbc_peer *peer); - diff --git a/include/osmocom/cbc/internal.h b/include/osmocom/cbc/internal.h index e3521bd..044387a 100644 --- a/include/osmocom/cbc/internal.h +++ b/include/osmocom/cbc/internal.h @@ -4,11 +4,13 @@ #include <osmocom/core/logging.h> #include <osmocom/core/fsm.h> +#include <osmocom/vty/command.h> #include <osmocom/cbc/cbc_data.h> enum { DCBSP, + DSBcAP, DREST, }; @@ -23,12 +25,30 @@ CBSP_SRV_E_CMD_CLOSE, /* CLOSE command from CBC */ }; +extern struct osmo_fsm sbcap_server_fsm; + +enum sbcap_server_event { + SBcAP_SRV_E_RX_RST_COMPL, /* reset complete received */ + SBcAP_SRV_E_RX_RST_FAIL, /* reset failure received */ + SBcAP_SRV_E_RX_KA_COMPL, /* keep-alive complete received */ + SBcAP_SRV_E_RX_RESTART, /* restart received */ + SBcAP_SRV_E_CMD_RESET, /* RESET command from CBC */ + SBcAP_SRV_E_CMD_CLOSE, /* CLOSE command from CBC */ +}; + /* rest_api.c */ int rest_api_init(void *ctx, const char *bind_addr, uint16_t port); void rest_api_fin(void); /* cbc_vty.c */ +enum cbc_vty_node { + CBC_NODE = _LAST_OSMOVTY_NODE + 1, + PEER_NODE, + CBSP_NODE, + SBcAP_NODE, + ECBE_NODE, +}; void cbc_vty_init(void); /* message_handling.c */ @@ -65,6 +85,12 @@ /* CBSP peer confirms status query */ SMSCB_E_CBSP_STATUS_ACK, SMSCB_E_CBSP_STATUS_NACK, + /* SBc-AP peer confirms write */ + SMSCB_E_SBCAP_WRITE_ACK, + SMSCB_E_SBCAP_WRITE_NACK, + /* SBc-AP peer confirms delete */ + SMSCB_E_SBCAP_DELETE_ACK, + SMSCB_E_SBCAP_DELETE_NACK, }; enum smscb_fsm_state { diff --git a/include/osmocom/cbc/sbcap_msg.h b/include/osmocom/cbc/sbcap_msg.h new file mode 100644 index 0000000..784938d --- /dev/null +++ b/include/osmocom/cbc/sbcap_msg.h @@ -0,0 +1,11 @@ +#pragma once +#include <osmocom/core/linuxlist.h> +#include <osmocom/netif/stream.h> + +#include "cbc_data.h" + +struct cbc_message; +typedef struct SBcAP_SBC_AP_PDU SBcAP_SBC_AP_PDU_t; + +SBcAP_SBC_AP_PDU_t *cbcmsg_to_sbcap(void *ctx, const struct cbc_message *cbcmsg); +SBcAP_SBC_AP_PDU_t *sbcap_gen_stop_warning_req(void *ctx, const struct cbc_message *cbcmsg); diff --git a/include/osmocom/cbc/sbcap_server.h b/include/osmocom/cbc/sbcap_server.h new file mode 100644 index 0000000..74e6c48 --- /dev/null +++ b/include/osmocom/cbc/sbcap_server.h @@ -0,0 +1,48 @@ +#pragma once +#include <osmocom/core/linuxlist.h> +//#include <osmocom/gsm/sbcap.h> +#include <osmocom/netif/stream.h> + +#include <osmocom/sbcap/sbcap_common.h> + +#include "cbc_data.h" + +#define SBcAP_SCTP_PORT 29168 +typedef struct SBcAP_SBC_AP_PDU SBcAP_SBC_AP_PDU_t; +#define LOGPSBCAPC(client, level, fmt, args...) \ + LOGP(DSBcAP, level, "%s: " fmt, sbcap_cbc_client_name(client), ## args) + +struct osmo_sbcap_cbc_client; +struct osmo_fsm_inst; + +/* a CBC server */ +struct osmo_sbcap_cbc { + /* libosmo-netif stream server */ + struct osmo_stream_srv_link *link; + + /* MMEs / clients connected to this CBC */ + struct llist_head clients; + + /* receive call-back; called for every received message */ + int (*rx_cb)(struct osmo_sbcap_cbc_client *client, SBcAP_SBC_AP_PDU_t *pdu); +}; +struct osmo_sbcap_cbc *sbcap_cbc_create(void *ctx); + +/* a single (remote) client connected to the (local) CBC server */ +struct osmo_sbcap_cbc_client { + /* entry in osmo_sbcap_cbc.clients */ + struct llist_head list; + /* stream server connection for this client */ + struct osmo_stream_srv *conn; + /* partially received sbcap message (rx completion pending) */ + struct msgb *rx_msg; + + struct osmo_fsm_inst *fi; + + struct cbc_peer *peer; +}; + +const char *sbcap_cbc_client_name(const struct osmo_sbcap_cbc_client *client); +void sbcap_cbc_client_tx(struct osmo_sbcap_cbc_client *client, SBcAP_SBC_AP_PDU_t *pdu); +void sbcap_cbc_client_close(struct osmo_sbcap_cbc_client *client); +int sbcap_cbc_client_rx_cb(struct osmo_sbcap_cbc_client *client, SBcAP_SBC_AP_PDU_t *pdu); diff --git a/src/Makefile.am b/src/Makefile.am index cc88962..5805fd7 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -4,7 +4,7 @@ AM_CFLAGS=-Wall -g $(LIBOSMOCORE_CFLAGS) $(LIBOSMOGSM_CFLAGS) $(LIBOSMOVTY_CFLAGS) \ $(LIBOSMONETIF_CFLAGS) \ $(ULFIUS_CFLAGS) $(JANSSON_CFLAGS) $(ORCANIA_CFLAGS) \ - $(COVERAGE_CFLAGS) + $(COVERAGE_CFLAGS) $(ASN_MODULE_CFLAGS) AM_LDFLAGS=$(COVERAGE_LDFLAGS) bin_PROGRAMS = osmo-cbc @@ -19,13 +19,16 @@ charset.c \ message_handling.c \ rest_it_op.c \ + sbcap_msg.c \ + sbcap_server.c \ + sbcap_server_fsm.c \ smscb_peer_fsm.c \ smscb_message_fsm.c \ $(NULL) osmo_cbc_LDADD = $(LIBOSMOCORE_LIBS) $(LIBOSMOGSM_LIBS) $(LIBOSMOVTY_LIBS) \ $(LIBOSMONETIF_LIBS) \ - $(ULFIUS_LIBS) $(JANSSON_LIBS) $(ORCANIA_LIBS) \ + $(ULFIUS_LIBS) $(JANSSON_LIBS) $(ORCANIA_LIBS) $(LIBSCTP_LIBS) \ sbcap/libosmo-sbcap.la regen: diff --git a/src/cbc_data.c b/src/cbc_data.c index 4b2c831..9e5902c 100644 --- a/src/cbc_data.c +++ b/src/cbc_data.c @@ -34,6 +34,7 @@ const struct value_string cbc_peer_proto_name[] = { { CBC_PEER_PROTO_CBSP, "CBSP" }, { CBC_PEER_PROTO_SABP, "SABP" }, + { CBC_PEER_PROTO_SBcAP, "SBc-AP" }, { 0, NULL } }; @@ -97,15 +98,19 @@ enum cbc_peer_protocol proto) { struct cbc_peer *peer; + unsigned int i; llist_for_each_entry(peer, &g_cbc->peers, list) { - if (!peer->remote_host) - continue; - if (!strcasecmp(remote_host, peer->remote_host)) { - if (peer->remote_port == -1) - return peer; - else if (remote_port == peer->remote_port) - return peer; + + for (i = 0; i < peer->num_remote_host; i++) { + if (peer->proto != proto) + continue; + if (!strcasecmp(remote_host, peer->remote_host[i])) { + if (peer->remote_port == -1) + return peer; + else if (remote_port == peer->remote_port) + return peer; + } } } return NULL; diff --git a/src/cbc_main.c b/src/cbc_main.c index c49514b3..6d6c79e 100644 --- a/src/cbc_main.c +++ b/src/cbc_main.c @@ -46,6 +46,7 @@ #include <osmocom/cbc/internal.h> #include <osmocom/cbc/cbsp_server.h> +#include <osmocom/cbc/sbcap_server.h> #include <osmocom/cbc/cbc_data.h> static void *tall_cbc_ctx; @@ -59,10 +60,17 @@ .enabled = 1, .loglevel = LOGL_NOTICE, }, + [DSBcAP] = { + .name = "DSBcAP", + .description = "SBc Application Part (CBC-MME)", + .color = "\033[1;32m", + .enabled = 1, + .loglevel = LOGL_NOTICE, + }, [DREST] = { .name = "DREST", .description = "REST interface", - .color = "\033[1;32m", + .color = "\033[1;33m", .enabled = 1, .loglevel = LOGL_NOTICE, }, @@ -73,6 +81,27 @@ .num_cat = ARRAY_SIZE(log_info_cat), }; +static int cbc_vty_go_parent(struct vty *vty) +{ + switch (vty->node) { + case SBcAP_NODE: + /* If no local addr set, add a default one: */ + if (g_cbc->config.sbcap.num_local_host) { + g_cbc->config.sbcap.local_host[0] = talloc_strdup(g_cbc, "127.0.0.1"); + g_cbc->config.sbcap.num_local_host = 1; + } + vty->node = CONFIG_NODE; + vty->index = NULL; + break; + default: + vty->node = CONFIG_NODE; + vty->index = NULL; + break; + } + + return vty->node; +} + static const char cbc_copyright[] = "Copyright (C) 2019-2021 by Harald Welte <laforge(a)gnumonks.org>\r\n" "License AGPLv3+: GNU Affero GPL Version 3 or later <http://gnu.org/licenses/agpl-3.0.html>\r\n" @@ -83,6 +112,7 @@ static struct vty_app_info vty_info = { .name = "OsmoCBC", .copyright = cbc_copyright, + .go_parent_cb = cbc_vty_go_parent, .version = PACKAGE_VERSION, .go_parent_cb = NULL, .is_config_node = NULL, @@ -201,8 +231,6 @@ } } -extern int cbc_client_rx_cb(struct osmo_cbsp_cbc_client *client, struct osmo_cbsp_decoded *dec); - int main(int argc, char **argv) { void *tall_rest_ctx; @@ -222,6 +250,8 @@ INIT_LLIST_HEAD(&g_cbc->expired_messages); g_cbc->config.cbsp.local_host = talloc_strdup(g_cbc, "127.0.0.1"); g_cbc->config.cbsp.local_port = CBSP_TCP_PORT; + /* g_cbc->config.sbcap local_host set up during VTY (and vty_go_parent) */ + g_cbc->config.sbcap.local_port = SBcAP_SCTP_PORT; g_cbc->config.ecbe.local_host = talloc_strdup(g_cbc, "127.0.0.1"); g_cbc->config.ecbe.local_port = 12345; @@ -250,6 +280,11 @@ exit(1); } + if (sbcap_cbc_create(tall_cbc_ctx) == NULL) { + perror("Error binidng CBSP port\n"); + exit(1); + } + rc = rest_api_init(tall_rest_ctx, g_cbc->config.ecbe.local_host, g_cbc->config.ecbe.local_port); if (rc < 0) { perror("Error binding ECBE port"); diff --git a/src/cbc_vty.c b/src/cbc_vty.c index b07bf70..a50d067 100644 --- a/src/cbc_vty.c +++ b/src/cbc_vty.c @@ -33,10 +33,14 @@ #include <osmocom/cbc/cbc_data.h> #include <osmocom/cbc/internal.h> #include <osmocom/cbc/cbsp_server.h> +#include <osmocom/cbc/sbcap_server.h> static void dump_one_cbc_peer(struct vty *vty, const struct cbc_peer *peer) { const char *state = "<disconnected>"; + char rem_addrs[1024] = "<unset>"; + struct osmo_strbuf sb = { .buf = rem_addrs, .len = sizeof(rem_addrs) }; + unsigned int i; switch (peer->proto) { case CBC_PEER_PROTO_CBSP: @@ -45,11 +49,21 @@ break; case CBC_PEER_PROTO_SABP: break; + case CBC_PEER_PROTO_SBcAP: + if (peer->client.sbcap) + state = osmo_fsm_inst_state_name(peer->client.sbcap->fi); + break; + } + + for (i = 0; i < peer->num_remote_host; i++) { + if (i > 0) + OSMO_STRBUF_PRINTF(sb, ","); + OSMO_STRBUF_PRINTF(sb, peer->remote_host[i]); } vty_out(vty, "|%-20s| %-15s| %-5d| %-6s| %-20s|%s", peer->name ? peer->name : "<unnamed>", - peer->remote_host ? peer->remote_host : "<unset>", peer->remote_port, + rem_addrs, peer->remote_port, get_value_string(cbc_peer_proto_name, peer->proto), state, VTY_NEWLINE); } @@ -265,13 +279,6 @@ /* TODO: Re-send all messages to one peer / all peers? */ /* TODO: Completed / Load status */ -enum cbc_vty_node { - CBC_NODE = _LAST_OSMOVTY_NODE + 1, - PEER_NODE, - CBSP_NODE, - ECBE_NODE, -}; - static struct cmd_node cbc_node = { CBC_NODE, "%s(config-cbc)# ", @@ -321,6 +328,14 @@ return CMD_SUCCESS; } +DEFUN(cfg_sbcap, cfg_sbcap_cmd, + "sbcap", + "SBc Application Part\n") +{ + vty->node = SBcAP_NODE; + return CMD_SUCCESS; +} + DEFUN(cfg_ecbe, cfg_ecbe_cmd, "ecbe", "External CBS Entity (REST Interface)\n") @@ -402,6 +417,87 @@ return CMD_SUCCESS; } +/* SBc-AP */ + +static struct cmd_node sbcap_node = { + SBcAP_NODE, + "%s(config-sbcap)# ", + 1, +}; + +static int config_write_sbcap(struct vty *vty) +{ + unsigned int i; + + vty_out(vty, " sbcap%s", VTY_NEWLINE); + for (i = 0; i < g_cbc->config.sbcap.num_local_host; i++) + vty_out(vty, " local-ip %s%s", g_cbc->config.sbcap.local_host[i], VTY_NEWLINE); + vty_out(vty, " local-port %u%s", g_cbc->config.sbcap.local_port, VTY_NEWLINE); + + return CMD_SUCCESS; +} + +DEFUN(cfg_sbcap_local_ip, cfg_sbcap_local_ip_cmd, + "local-ip " VTY_IPV46_CMD, + "Local IP address for SBc-AP\n" + "Local IPv4 address for SBc-AP Interface\n" + "Local IPv6 address for SBc-AP Interface\n") +{ + unsigned int i; + const char *newaddr = argv[0]; + + if (g_cbc->config.sbcap.num_local_host >= ARRAY_SIZE(g_cbc->config.sbcap.local_host)) { + vty_out(vty, "%% Only up to %zu addresses allowed%s", + ARRAY_SIZE(g_cbc->config.sbcap.local_host), VTY_NEWLINE); + return CMD_WARNING; + } + + /* Check for repeated entries: */ + for (i = 0; i < g_cbc->config.sbcap.num_local_host; i++) { + if (strcmp(g_cbc->config.sbcap.local_host[i], newaddr) == 0) { + vty_out(vty, "%% IP address %s already in list%s", newaddr, VTY_NEWLINE); + return CMD_WARNING; + } + } + osmo_talloc_replace_string(g_cbc, + &g_cbc->config.sbcap.local_host[g_cbc->config.sbcap.num_local_host], newaddr); + g_cbc->config.sbcap.num_local_host++; + return CMD_SUCCESS; +} + +DEFUN(cfg_sbcap_no_local_ip, cfg_sbcap_no_local_ip_cmd, + "no local-ip " VTY_IPV46_CMD, + NO_STR "Local IP address for SBc-AP\n" + "Local IPv4 address for SBc-AP Interface\n" + "Local IPv6 address for SBc-AP Interface\n") +{ + unsigned int i, j; + const char *rmaddr = argv[0]; + + for (i = 0; i < g_cbc->config.sbcap.num_local_host; i++) { + if (strcmp(g_cbc->config.sbcap.local_host[i], rmaddr) == 0) { + talloc_free(g_cbc->config.sbcap.local_host[i]); + g_cbc->config.sbcap.num_local_host--; + for (j = i; j < g_cbc->config.sbcap.num_local_host; j++) { + g_cbc->config.sbcap.local_host[j] = g_cbc->config.sbcap.local_host[j + 1]; + } + g_cbc->config.sbcap.local_host[j] = NULL; + return CMD_SUCCESS; + } + } + vty_out(vty, "%% IP address %s not in list%s", rmaddr, VTY_NEWLINE); + return CMD_WARNING; +} + +DEFUN(cfg_sbcap_local_port, cfg_sbcap_local_port_cmd, + "local-port <0-65535>", + "Local TCP port for SBc-AP Interface\n" + "Local TCP port for SBc-AP Interface\n") +{ + g_cbc->config.sbcap.local_port = atoi(argv[0]); + return CMD_SUCCESS; +} + /* PEER */ @@ -440,13 +536,16 @@ } -DEFUN(cfg_peer_proto, cfg_peer_proto_cmd, - "protocol (cbsp)", +DEFUN_DEPRECATED(cfg_peer_proto, cfg_peer_proto_cmd, + "protocol (cbsp|sbcap)", "Configure Protocol of Peer\n" "Cell Broadcast Service Protocol (GSM)\n") { struct cbc_peer *peer = (struct cbc_peer *) vty->index; - peer->proto = CBC_PEER_PROTO_CBSP; + if (strcmp(argv[0], "cbsp") == 0) + peer->proto = CBC_PEER_PROTO_CBSP; + else + peer->proto = CBC_PEER_PROTO_SBcAP; return CMD_SUCCESS; } @@ -477,22 +576,69 @@ "IPv4 address of peer\n" "IPv6 address of peer\n") { struct cbc_peer *peer = (struct cbc_peer *) vty->index; - osmo_talloc_replace_string(peer, &peer->remote_host, argv[0]); + unsigned int allowed_address; + unsigned int i; + const char *newaddr = argv[0]; + + if (peer->proto == CBC_PEER_PROTO_SBcAP) + allowed_address = ARRAY_SIZE(peer->remote_host); + else + allowed_address = 1; + + if (peer->num_remote_host >= allowed_address) { + vty_out(vty, "%% Only up to %u addresses allowed%s", + allowed_address, VTY_NEWLINE); + return CMD_WARNING; + } + + /* Check for repeated entries: */ + for (i = 0; i < peer->num_remote_host; i++) { + if (strcmp(peer->remote_host[i], newaddr) == 0) { + vty_out(vty, "%% IP address %s already in list%s", newaddr, VTY_NEWLINE); + return CMD_WARNING; + } + } + osmo_talloc_replace_string(peer, &peer->remote_host[peer->num_remote_host], newaddr); + peer->num_remote_host++; + return CMD_SUCCESS; } +DEFUN(cfg_peer_no_remote_ip, cfg_peer_no_remote_ip_cmd, + "no remote-ip " VTY_IPV46_CMD, + NO_STR "Keep remote IP of peer\n" + "IPv4 address of peer\n" "IPv6 address of peer\n") +{ + struct cbc_peer *peer = (struct cbc_peer *) vty->index; + unsigned int i, j; + const char *rmaddr = argv[0]; + for (i = 0; i < peer->num_remote_host; i++) { + if (strcmp(peer->remote_host[i], rmaddr) == 0) { + talloc_free(peer->remote_host[i]); + peer->num_remote_host--; + for (j = i; j < peer->num_remote_host; j++) { + peer->remote_host[j] = peer->remote_host[j + 1]; + } + peer->remote_host[j] = NULL; + return CMD_SUCCESS; + } + } + vty_out(vty, "%% IP address %s not in list%s", rmaddr, VTY_NEWLINE); + return CMD_WARNING; +} static void write_one_peer(struct vty *vty, struct cbc_peer *peer) { + unsigned int i; vty_out(vty, " peer %s%s", peer->name, VTY_NEWLINE); vty_out(vty, " protocol cbsp%s", VTY_NEWLINE); if (peer->remote_port == -1) vty_out(vty, " no remote-port%s", VTY_NEWLINE); else vty_out(vty, " remote-port %d%s", peer->remote_port, VTY_NEWLINE); - if (peer->remote_host) - vty_out(vty, " remote-ip %s%s", peer->remote_host, VTY_NEWLINE); + for (i = 0; i < peer->num_remote_host; i++) + vty_out(vty, " remote-ip %s%s", peer->remote_host[i], VTY_NEWLINE); } static int config_write_peer(struct vty *vty) @@ -528,6 +674,12 @@ install_lib_element(ECBE_NODE, &cfg_ecbe_local_ip_cmd); install_lib_element(ECBE_NODE, &cfg_ecbe_local_port_cmd); + install_lib_element(CBC_NODE, &cfg_sbcap_cmd); + install_node(&sbcap_node, config_write_sbcap); + install_lib_element(SBcAP_NODE, &cfg_sbcap_local_ip_cmd); + install_lib_element(SBcAP_NODE, &cfg_sbcap_no_local_ip_cmd); + install_lib_element(SBcAP_NODE, &cfg_sbcap_local_port_cmd); + install_lib_element(CBC_NODE, &cfg_cbc_peer_cmd); install_lib_element(CBC_NODE, &cfg_cbc_no_peer_cmd); install_node(&peer_node, config_write_peer); @@ -535,5 +687,6 @@ install_lib_element(PEER_NODE, &cfg_peer_remote_port_cmd); install_lib_element(PEER_NODE, &cfg_peer_no_remote_port_cmd); install_lib_element(PEER_NODE, &cfg_peer_remote_ip_cmd); + install_lib_element(PEER_NODE, &cfg_peer_no_remote_ip_cmd); } diff --git a/src/message_handling.c b/src/message_handling.c index 41b854a..6c87a24 100644 --- a/src/message_handling.c +++ b/src/message_handling.c @@ -29,6 +29,8 @@ #include <osmocom/cbc/cbc_data.h> #include <osmocom/cbc/cbsp_server.h> +#include <osmocom/cbc/sbcap_server.h> +#include <osmocom/cbc/sbcap_msg.h> #include <osmocom/cbc/rest_it_op.h> #include <osmocom/cbc/internal.h> @@ -128,6 +130,7 @@ int peer_new_cbc_message(struct cbc_peer *peer, struct cbc_message *cbcmsg) { struct osmo_cbsp_decoded *cbsp; + SBcAP_SBC_AP_PDU_t *sbcap; switch (peer->proto) { case CBC_PEER_PROTO_CBSP: @@ -144,6 +147,24 @@ } cbsp_cbc_client_tx(peer->client.cbsp, cbsp); break; + case CBC_PEER_PROTO_SBcAP: + /* skip peers without any current CBSP connection */ + if (!peer->client.sbcap) { + LOGP(DSBcAP, LOGL_NOTICE, "[%s] Tx SBc-AP: not connected\n", + peer->name); + return -ENOTCONN; + } + if (!(sbcap = cbcmsg_to_sbcap(peer, cbcmsg))) { + LOGP(DSBcAP, LOGL_ERROR, "[%s] Tx SBc-AP: msg gen failed\n", + peer->name); + return -EINVAL; + } + sbcap_cbc_client_tx(peer->client.sbcap, sbcap); + break; + case CBC_PEER_PROTO_SABP: + LOGP(DLGLOBAL, LOGL_ERROR, "Sending message to peer proto %s not implemented!\n", + get_value_string(cbc_peer_proto_name, peer->proto)); + return -1; default: OSMO_ASSERT(0); } diff --git a/src/sbcap_msg.c b/src/sbcap_msg.c new file mode 100644 index 0000000..8da43b2 --- /dev/null +++ b/src/sbcap_msg.c @@ -0,0 +1,269 @@ +/* Osmocom CBC (Cell Broacast Centre) */ + +/* (C) 2019 by Harald Welte <laforge(a)gnumonks.org> + * All Rights Reserved + * + * SPDX-License-Identifier: AGPL-3.0+ + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as published by + * the Free Software Foundation; either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see <http://www.gnu.org/licenses/>. + * + */ + + +#include <string.h> +#include <errno.h> + +#include <osmocom/core/linuxlist.h> +#include <osmocom/core/talloc.h> +#include <osmocom/core/utils.h> + +#include <osmocom/sbcap/sbcap_common.h> + +#include <osmocom/cbc/cbc_data.h> +#include <osmocom/cbc/sbcap_server.h> +#include <osmocom/cbc/internal.h> + +/* 3GPP TS 36.413 9.2.1.53 */ +#define SBCAP_WARN_MSG_CONTENTS_IE_MAX_LEN 9600 + +#if 0 +static void msgb_put_sbcap_cell_list(const struct cbc_message *cbcmsg, void * void_li) +{ + static uint8_t ie_plm_id0[] = {0x05, 0xf5, 0x32}; + static uint8_t ie_cell_id0[] = {0xa0, 0x00, 0x00, 0x10}; + static uint8_t ie_cell_id1[] = {0xa0, 0x00, 0x00, 0x20}; + SBcAP_EUTRAN_CGI_t *ecgi; + + A_SEQUENCE_OF(void) *li = void_li; + ecgi = CALLOC(1, sizeof(*ecgi)); + *ecgi = (SBcAP_EUTRAN_CGI_t) { + .pLMNidentity = { + .buf = ie_plm_id0, + .size = sizeof(ie_plm_id0), + }, + .cell_ID = { /* SBcAP_CellIdentity_t*/ + .buf = ie_cell_id0, + .size = sizeof(ie_cell_id0), + .bits_unused = 4, + } + }; + ASN_SEQUENCE_ADD(li, ecgi); + + ecgi = CALLOC(1, sizeof(*ecgi)); + *ecgi = (SBcAP_EUTRAN_CGI_t) { + .pLMNidentity = { + .buf = ie_plm_id0, + .size = sizeof(ie_plm_id0), + }, + .cell_ID = { /* SBcAP_CellIdentity_t*/ + .buf = ie_cell_id1, + .size = sizeof(ie_cell_id1), + .bits_unused = 4, + } + }; + ASN_SEQUENCE_ADD(li, ecgi); + +} +#endif + +/* generate a SBc-AP WRITE-REPLACE WARNING REQUEST from our internal representation */ +SBcAP_SBC_AP_PDU_t *cbcmsg_to_sbcap(void *ctx, const struct cbc_message *cbcmsg) +{ + const struct smscb_message *smscb = &cbcmsg->msg; + SBcAP_SBC_AP_PDU_t *pdu; + SBcAP_Write_Replace_Warning_Request_IEs_t *ie; + uint16_t ie_warning_type; + unsigned int i; + uint8_t *ptr; +#if 0 + A_SEQUENCE_OF(void) *as_warn_area_ecgi = NULL; +#endif + + pdu = sbcap_pdu_alloc(); + if (!pdu) + return NULL; + pdu->present = SBcAP_SBC_AP_PDU_PR_initiatingMessage; + pdu->choice.initiatingMessage.procedureCode = SBcAP_ProcedureId_Write_Replace_Warning; + pdu->choice.initiatingMessage.criticality = SBcAP_Criticality_reject; + pdu->choice.initiatingMessage.value.present = SBcAP_InitiatingMessage__value_PR_Write_Replace_Warning_Request; + + A_SEQUENCE_OF(void) *as_pdu = (void*)&pdu->choice.initiatingMessage.value.choice.Write_Replace_Warning_Request.protocolIEs.list; + + /* static const long asn_VAL_1_SBcAP_id_Message_Identifier = 5; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(5, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Message_Identifier); + ie->value.choice.Message_Identifier.buf = MALLOC(sizeof(uint16_t)); + ie->value.choice.Message_Identifier.size = sizeof(uint16_t); + ie->value.choice.Message_Identifier.bits_unused = 0; + osmo_store16be(smscb->message_id, ie->value.choice.Message_Identifier.buf); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_2_SBcAP_id_Serial_Number = 11; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(11, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Serial_Number); + ie->value.choice.Serial_Number.buf = MALLOC(sizeof(uint16_t)); + ie->value.choice.Serial_Number.size = sizeof(uint16_t); + ie->value.choice.Serial_Number.bits_unused = 0; + osmo_store16be(smscb->serial_nr, ie->value.choice.Serial_Number.buf); + ASN_SEQUENCE_ADD(as_pdu, ie); + + switch (cbcmsg->scope) { + case CBC_MSG_SCOPE_PLMN: + break; /* Nothing to be done :*/ +#if 0 + case CBC_MSG_SCOPE_EUTRAN_CGI: + /* static const long asn_VAL_25_SBcAP_id_Warning_Area_List = 15; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(15, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Area_List); + ASN_SEQUENCE_ADD(as_pdu, ie); + as_warn_area_ecgi = (void*)ie->value.choice.Warning_Area_List.choice.cell_ID_List.list; + msgb_put_sbcap_cell_list(cbcmsg, as_warn_area_ecgi); + break; +#endif + default: + OSMO_ASSERT(0); + } + + /* static const long asn_VAL_5_SBcAP_id_Repetition_Period = 10; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(10, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Repetition_Period); + ie->value.choice.Repetition_Period = cbcmsg->rep_period; /*seconds */ + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_7_SBcAP_id_Number_of_Broadcasts_Requested = 7; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(7, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Number_of_Broadcasts_Requested); + ie->value.choice.Number_of_Broadcasts_Requested = cbcmsg->num_bcast; + ASN_SEQUENCE_ADD(as_pdu, ie); + + if (smscb->is_etws) { + /* Warning Type, 3GPP TS 36.413 sec 9.2.1.50: */ + ie_warning_type = smscb->etws.warning_type; + if (smscb->etws.user_alert) + ie_warning_type |= 0x0100; + if (smscb->etws.popup_on_display) + ie_warning_type |= 0x0080; + /* static const long asn_VAL_8_SBcAP_id_Warning_Type = 18; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(18, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Type); + ie->value.choice.Warning_Type.buf = MALLOC(sizeof(ie_warning_type)); + ie->value.choice.Warning_Type.size = sizeof(ie_warning_type); + memcpy(ie->value.choice.Warning_Type.buf, &ie_warning_type, sizeof(ie_warning_type)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* Warning Security Information, 3GPP TS 36.413 sec 9.2.1.51: */ + /*static const long asn_VAL_9_SBcAP_id_Warning_Security_Information = 17 */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(17, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Security_Information); + ie->value.choice.Warning_Security_Information.buf = MALLOC(sizeof(smscb->etws.warning_sec_info)); + ie->value.choice.Warning_Security_Information.size = sizeof(smscb->etws.warning_sec_info); + memcpy(ie->value.choice.Warning_Security_Information.buf, + smscb->etws.warning_sec_info, sizeof(smscb->etws.warning_sec_info)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + } else { + /* static const long asn_VAL_10_SBcAP_id_Data_Coding_Scheme = 3; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(3, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Data_Coding_Scheme); + ie->value.choice.Data_Coding_Scheme.buf = MALLOC(1); + ie->value.choice.Data_Coding_Scheme.size = 1; + ie->value.choice.Data_Coding_Scheme.bits_unused = 0; + *ie->value.choice.Data_Coding_Scheme.buf = smscb->cbs.dcs; + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* 3GPP TS 36.413 9.2.1.53 Warning Message Contents. Encoded as in S1AP. */ + /* static const long asn_VAL_11_SBcAP_id_Warning_Message_Content = 16; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(16, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Message_Content); + ie->value.choice.Warning_Message_Content.buf = MALLOC(1 + smscb->cbs.num_pages * (SMSCB_RAW_PAGE_LEN+1)); + ie->value.choice.Warning_Message_Content.size = 1 + smscb->cbs.num_pages * (SMSCB_RAW_PAGE_LEN+1); + ptr = &ie->value.choice.Warning_Message_Content.buf[0]; + *ptr = (uint8_t)smscb->cbs.num_pages; + ptr++; + for (i = 0; i < smscb->cbs.num_pages; i++) { + unsigned len = 0; + if (i == smscb->cbs.num_pages - 1) + len = smscb->cbs.data_user_len - (i * SMSCB_RAW_PAGE_LEN); + else + len = SMSCB_RAW_PAGE_LEN; + if (len > 0) { + memcpy(ptr, smscb->cbs.data[i], SMSCB_RAW_PAGE_LEN); + ptr += SMSCB_RAW_PAGE_LEN; + } + *ptr = (uint8_t)len; + ptr++; + } + ASN_SEQUENCE_ADD(as_pdu, ie); + } + + return pdu; +} + +/* generate a SBc-AP WRITE-REPLACE WARNING REQUEST from our internal representation */ +SBcAP_SBC_AP_PDU_t *sbcap_gen_stop_warning_req(void *ctx, const struct cbc_message *cbcmsg) +{ + const struct smscb_message *smscb = &cbcmsg->msg; + SBcAP_SBC_AP_PDU_t *pdu; + SBcAP_Stop_Warning_Request_IEs_t *ie; +#if 0 + A_SEQUENCE_OF(void) *as_warn_area_ecgi = NULL; +#endif + + pdu = sbcap_pdu_alloc(); + if (!pdu) + return NULL; + pdu->present = SBcAP_SBC_AP_PDU_PR_initiatingMessage; + pdu->choice.initiatingMessage.procedureCode = SBcAP_ProcedureId_Stop_Warning; + pdu->choice.initiatingMessage.criticality = SBcAP_Criticality_reject; + pdu->choice.initiatingMessage.value.present = SBcAP_InitiatingMessage__value_PR_Stop_Warning_Request; + + A_SEQUENCE_OF(void) *as_pdu = (void*)&pdu->choice.initiatingMessage.value.choice.Stop_Warning_Request.protocolIEs.list; + + /* static const long asn_VAL_1_SBcAP_id_Message_Identifier = 5; */ + ie = sbcap_alloc_Stop_Warning_Request_IE(5, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Message_Identifier); + ie->value.choice.Message_Identifier.buf = MALLOC(sizeof(uint16_t)); + ie->value.choice.Message_Identifier.size = sizeof(uint16_t); + ie->value.choice.Message_Identifier.bits_unused = 0; + osmo_store16be(smscb->message_id, ie->value.choice.Message_Identifier.buf); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_2_SBcAP_id_Serial_Number = 11; */ + ie = sbcap_alloc_Stop_Warning_Request_IE(11, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Serial_Number); + ie->value.choice.Serial_Number.buf = MALLOC(sizeof(uint16_t)); + ie->value.choice.Serial_Number.size = sizeof(uint16_t); + ie->value.choice.Serial_Number.bits_unused = 0; + osmo_store16be(smscb->serial_nr, ie->value.choice.Serial_Number.buf); + ASN_SEQUENCE_ADD(as_pdu, ie); + + switch (cbcmsg->scope) { + case CBC_MSG_SCOPE_PLMN: + break; /* Nothing to be done :*/ +#if 0 + case CBC_MSG_SCOPE_EUTRAN_CGI: + /* static const long asn_VAL_25_SBcAP_id_Warning_Area_List = 15; */ + ie = sbcap_alloc_Stop_Warning_Request_IE(15, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Area_List); + ASN_SEQUENCE_ADD(as_pdu, ie); + as_warn_area_ecgi = (void*)ie->value.choice.Warning_Area_List.choice.cell_ID_List.list; + msgb_put_sbcap_cell_list(cbcmsg, as_warn_area_ecgi); + break; +#endif + default: + OSMO_ASSERT(0); + } + + return pdu; +} diff --git a/src/sbcap_server.c b/src/sbcap_server.c new file mode 100644 index 0000000..f33d3a5 --- /dev/null +++ b/src/sbcap_server.c @@ -0,0 +1,251 @@ +/* (C) 2019 by Harald Welte <laforge(a)gnumonks.org> + * All Rights Reserved + * + * SPDX-License-Identifier: AGPL-3.0+ + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as published by + * the Free Software Foundation; either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see <http://www.gnu.org/licenses/>. + * + */ + +#include <errno.h> +#include <sys/types.h> +#include <sys/socket.h> +#include <netdb.h> +#include <netinet/in.h> +#include <netinet/sctp.h> + +#include <osmocom/core/talloc.h> +#include <osmocom/core/select.h> +#include <osmocom/core/socket.h> +#include <osmocom/core/msgb.h> +#include <osmocom/core/logging.h> +//#include <osmocom/gsm/sbcap.h> +//#include <osmocom/gsm/protocol/gsm_48_049.h> +#include <osmocom/netif/sctp.h> +#include <osmocom/netif/stream.h> + +#include <osmocom/sbcap/sbcap_common.h> + +#include <osmocom/cbc/internal.h> +#include <osmocom/cbc/sbcap_server.h> + +const char *sbcap_cbc_client_name(const struct osmo_sbcap_cbc_client *client) +{ + OSMO_ASSERT(client); + + if (client->peer && client->peer->name) { + return client->peer->name; + } else { + struct osmo_fd *ofd = osmo_stream_srv_get_ofd(client->conn); + return osmo_sock_get_name2(ofd->fd); + } +} + +/* data from MME has arrived at CBC */ +static int sbcap_cbc_read_cb(struct osmo_stream_srv *conn) +{ + struct osmo_stream_srv_link *link = osmo_stream_srv_get_master(conn); + struct osmo_sbcap_cbc_client *client = osmo_stream_srv_get_data(conn); + struct osmo_sbcap_cbc *cbc = osmo_stream_srv_link_get_data(link); + struct osmo_fd *ofd = osmo_stream_srv_get_ofd(conn); + SBcAP_SBC_AP_PDU_t *pdu; + struct msgb *msg = msgb_alloc(1500, "SBcAP-rx"); //TODO: pass talloc ctx + struct sctp_sndrcvinfo sinfo; + int flags = 0; + int rc; + + /* read SBc-AP message from socket and process it */ + rc = sctp_recvmsg(ofd->fd, msgb_data(msg), msgb_tailroom(msg), + NULL, NULL, &sinfo, &flags); + LOGPSBCAPC(client, LOGL_DEBUG, "%s(): sctp_recvmsg() returned %d (flags=0x%x)\n", + __func__, rc, flags); + if (rc < 0) { + osmo_stream_srv_destroy(conn); + goto out; + } else if (rc == 0) { + osmo_stream_srv_destroy(conn); + } else { + msgb_put(msg, rc); + } + + if (flags & MSG_NOTIFICATION) { + union sctp_notification *notif = (union sctp_notification *) msgb_data(msg); + LOGPSBCAPC(client, LOGL_DEBUG, "Rx sctp notif %s\n", + osmo_sctp_sn_type_str(notif->sn_header.sn_type)); + switch (notif->sn_header.sn_type) { + case SCTP_SHUTDOWN_EVENT: + osmo_stream_srv_destroy(conn); + break; + case SCTP_ASSOC_CHANGE: + LOGPSBCAPC(client, LOGL_DEBUG, "Rx sctp notif SCTP_ASSOC_CHANGE: %s\n", + osmo_sctp_assoc_chg_str(notif->sn_assoc_change.sac_state)); + default: + break; + } + rc = 0; + goto out; + } + + if (rc == 0) + goto out; + + LOGPSBCAPC(client, LOGL_DEBUG, "Received SBc-AP %s\n", msgb_hexdump(msg)); + + /* decode + dispatch message */ + pdu = sbcap_decode(msg); + if (pdu) { + LOGPSBCAPC(client, LOGL_INFO, "Received SBc-AP %d\n", + pdu->present); + cbc->rx_cb(client, pdu); + } else { + LOGPSBCAPC(client, LOGL_ERROR, "Unable to decode %s\n", msgb_hexdump(msg)); + } +out: + msgb_free(msg); + return rc; +} + +/* connection from MME to CBC has been closed */ +static int sbcap_cbc_closed_cb(struct osmo_stream_srv *conn) +{ + struct osmo_sbcap_cbc_client *client = osmo_stream_srv_get_data(conn); + LOGPSBCAPC(client, LOGL_NOTICE, "connection closed\n"); + + if (client->peer) + client->peer->client.sbcap = NULL; + client->conn = NULL; + if (client->fi) + osmo_fsm_inst_dispatch(client->fi, SBcAP_SRV_E_CMD_CLOSE, NULL); + + return 0; +} + +/* new connection from MME has arrived at CBC */ +static int sbcap_cbc_accept_cb(struct osmo_stream_srv_link *link, int fd) +{ + struct osmo_sbcap_cbc *cbc = osmo_stream_srv_link_get_data(link); + struct osmo_sbcap_cbc_client *client = talloc_zero(cbc, struct osmo_sbcap_cbc_client); + char remote_ip[INET6_ADDRSTRLEN], portbuf[6]; + int remote_port; + OSMO_ASSERT(client); + + remote_ip[0] = '\0'; + portbuf[0] = '\0'; + osmo_sock_get_ip_and_port(fd, remote_ip, sizeof(remote_ip), portbuf, sizeof(portbuf), false); + remote_port = atoi(portbuf); + + LOGP(DSBcAP, LOGL_NOTICE, "New SBc-AP client connection from %s:%u\n", remote_ip, remote_port); + + client->conn = osmo_stream_srv_create(link, link, fd, sbcap_cbc_read_cb, sbcap_cbc_closed_cb, client); + if (!client->conn) { + LOGP(DSBcAP, LOGL_ERROR, "Unable to create stream server for %s:%d\n", + remote_ip, remote_port); + talloc_free(client); + return -1; + } + client->fi = osmo_fsm_inst_alloc(&sbcap_server_fsm, client, client, LOGL_DEBUG, NULL); + if (!client->fi) { + LOGPSBCAPC(client, LOGL_ERROR, "Unable to allocate FSM\n"); + osmo_stream_srv_destroy(client->conn); + talloc_free(client); + return -1; + } + llist_add_tail(&client->list, &cbc->clients); + + /* Match client to peer */ + client->peer = cbc_peer_by_addr_proto(remote_ip, remote_port, CBC_PEER_PROTO_SBcAP); + if (!client->peer) { + if (g_cbc->config.permit_unknown_peers) { + LOGPSBCAPC(client, LOGL_NOTICE, "Accepting unknown SBc-AP peer %s:%d\n", + remote_ip, remote_port); + client->peer = cbc_peer_create(NULL, CBC_PEER_PROTO_SBcAP); + OSMO_ASSERT(client->peer); + client->peer->unknown_dynamic_peer = true; + } else { + LOGPSBCAPC(client, LOGL_NOTICE, "Rejecting unknown SBc-AP peer %s:%d (not permitted)\n", + remote_ip, remote_port); + osmo_stream_srv_destroy(client->conn); + return -1; + } + } else { + if (client->peer->client.sbcap) { + LOGPSBCAPC(client, LOGL_ERROR, "We already have a connection for peer %s\n", + client->peer->name); + /* FIXME */ + } + client->peer->client.sbcap = client; + } + + osmo_fsm_inst_dispatch(client->fi, SBcAP_SRV_E_CMD_RESET, NULL); + return 0; +} + +void sbcap_cbc_client_tx(struct osmo_sbcap_cbc_client *client, SBcAP_SBC_AP_PDU_t *pdu) +{ + struct msgb *msg; + + if (!pdu) { + LOGP(DSBcAP, LOGL_NOTICE, "Cannot transmit msg: no pdu\n"); + return ; + } + + if (!client) { + LOGP(DSBcAP, LOGL_NOTICE, "Cannot transmit msg: no connection\n"); + return ; + } + + LOGPSBCAPC(client, LOGL_INFO, "Transmitting msg\n"); + OSMO_ASSERT(client->conn); + msg = sbcap_encode(pdu); + if (!msg) + goto ret_free; + LOGPSBCAPC(client, LOGL_DEBUG, "Encoded message: %s\n", msgb_hexdump(msg)); + osmo_stream_srv_send(client->conn, msg); +ret_free: + sbcap_pdu_free(pdu); +} + +void sbcap_cbc_client_close(struct osmo_sbcap_cbc_client *client) +{ + osmo_stream_srv_destroy(client->conn); +} + +/* initialize the CBC-side SBc-AP server */ +struct osmo_sbcap_cbc *sbcap_cbc_create(void *ctx) +{ + struct osmo_sbcap_cbc *cbc = talloc_zero(ctx, struct osmo_sbcap_cbc); + int rc; + int bind_port = g_cbc->config.sbcap.local_port; + + if (bind_port == -1) + bind_port = SBcAP_SCTP_PORT; + + OSMO_ASSERT(cbc); + cbc->rx_cb = sbcap_cbc_client_rx_cb; + INIT_LLIST_HEAD(&cbc->clients); + cbc->link = osmo_stream_srv_link_create(cbc); + osmo_stream_srv_link_set_proto(cbc->link, IPPROTO_SCTP); + osmo_stream_srv_link_set_data(cbc->link, cbc); + osmo_stream_srv_link_set_nodelay(cbc->link, true); + osmo_stream_srv_link_set_port(cbc->link, bind_port); + osmo_stream_srv_link_set_addrs(cbc->link, (const char **)g_cbc->config.sbcap.local_host, + g_cbc->config.sbcap.num_local_host); + osmo_stream_srv_link_set_accept_cb(cbc->link, sbcap_cbc_accept_cb); + rc = osmo_stream_srv_link_open(cbc->link); + OSMO_ASSERT(rc == 0); + LOGP(DSBcAP, LOGL_NOTICE, "Listening for SBc-AP at %s\n", + osmo_stream_srv_link_get_sockname(cbc->link)); + + return cbc; +} diff --git a/src/sbcap_server_fsm.c b/src/sbcap_server_fsm.c new file mode 100644 index 0000000..4cfb2c8 --- /dev/null +++ b/src/sbcap_server_fsm.c @@ -0,0 +1,330 @@ +/* (C) 2019 by Harald Welte <laforge(a)gnumonks.org> + * All Rights Reserved + * + * SPDX-License-Identifier: AGPL-3.0+ + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as published by + * the Free Software Foundation; either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see <http://www.gnu.org/licenses/>. + * + */ + +#include <errno.h> + +#include <osmocom/core/fsm.h> + +//#include <osmocom/gsm/sbcap.h> + +#include <osmocom/sbcap/sbcap_common.h> + +#include <osmocom/cbc/sbcap_server.h> +#include <osmocom/cbc/internal.h> + +#define S(x) (1 << (x)) + +enum sbcap_server_state { + /* initial state after client SCTP connection established */ + SBcAP_SRV_S_INIT, + /* normal operation (idle) */ + SBcAP_SRV_S_IDLE, +}; + +static const struct value_string sbcap_server_event_names[] = { + { SBcAP_SRV_E_RX_RST_COMPL, "Rx Reset Complete" }, + { SBcAP_SRV_E_RX_RST_FAIL, "Rx Reset Failure" }, + { SBcAP_SRV_E_RX_KA_COMPL, "Rx Keep-Alive Complete" }, + { SBcAP_SRV_E_RX_RESTART, "Rx Restart" }, + { SBcAP_SRV_E_CMD_RESET, "RESET.cmd" }, + { SBcAP_SRV_E_CMD_CLOSE, "CLOSE.cmd" }, + { 0, NULL } +}; + +static void sbcap_server_s_init(struct osmo_fsm_inst *fi, uint32_t event, void *data) +{ + switch (event) { + case SBcAP_SRV_E_CMD_RESET: + osmo_fsm_inst_state_chg(fi, SBcAP_SRV_S_IDLE, 0, 0); + break; + default: + OSMO_ASSERT(0); + } +} + +static void sbcap_server_s_idle(struct osmo_fsm_inst *fi, uint32_t event, void *data) +{ + switch (event) { + default: + OSMO_ASSERT(0); + } +} + +static void sbcap_server_fsm_allstate(struct osmo_fsm_inst *fi, uint32_t event, void *data) +{ + struct osmo_sbcap_cbc_client *client = (struct osmo_sbcap_cbc_client *) fi->priv; + //SBcAP_SBC_AP_PDU_t *pdu; + + switch (event) { + case SBcAP_SRV_E_CMD_CLOSE: + osmo_fsm_inst_term(fi, OSMO_FSM_TERM_REQUEST, NULL); + break; + case SBcAP_SRV_E_RX_RESTART: + //pdu = data; + /* TODO: delete any CBS state we have for this peer */ + /* TODO: re-send messages we have matching the scope of the peer */ + LOGPSBCAPC(client, LOGL_NOTICE, "RESTART but re-sending not implemented yet\n"); + break; + default: + OSMO_ASSERT(0); + } +} + +static void sbcap_server_fsm_cleanup(struct osmo_fsm_inst *fi, enum osmo_fsm_term_cause cause) +{ + struct osmo_sbcap_cbc_client *client = (struct osmo_sbcap_cbc_client *) fi->priv; + + if (client->conn) + osmo_stream_srv_destroy(client->conn); + llist_del(&client->list); + client->fi = NULL; + + /* reparent the fsm_inst to the cbc as we're about to free() it's talloc + * parent 'client' */ + talloc_steal(g_cbc, fi); + talloc_free(client); +} + +static const struct osmo_fsm_state sbcap_server_fsm_states[] = { + [SBcAP_SRV_S_INIT] = { + .name = "INIT", + .in_event_mask = S(SBcAP_SRV_E_CMD_RESET), + .out_state_mask = S(SBcAP_SRV_S_IDLE), + .action = sbcap_server_s_init, + }, + [SBcAP_SRV_S_IDLE] = { + .name = "IDLE", + .in_event_mask = 0, + .out_state_mask = 0, + .action = sbcap_server_s_idle, + }, +}; + +struct osmo_fsm sbcap_server_fsm = { + .name = "SBcAP-SERVER", + .states = sbcap_server_fsm_states, + .num_states = ARRAY_SIZE(sbcap_server_fsm_states), + .allstate_event_mask = S(SBcAP_SRV_E_CMD_CLOSE) | + S(SBcAP_SRV_E_RX_RESTART), + .allstate_action = sbcap_server_fsm_allstate, + .log_subsys = DSBcAP, + .event_names = sbcap_server_event_names, + .cleanup = sbcap_server_fsm_cleanup, +}; + +static void *sbcap_as_find_ie(void *void_list, SBcAP_ProtocolIE_ID_t ie_id) +{ + A_SEQUENCE_OF(SBcAP_ProtocolIE_ID_t) *li = (void*)void_list; + int i; + for (i = 0; i < li->count; i++) { + /* "SBcAP_ProtocolIE_ID_t id" is first element in all *_IEs struct */ + SBcAP_ProtocolIE_ID_t *cur_ie_id = li->array[i]; + if (*cur_ie_id == ie_id) { + return cur_ie_id; + } + } + return NULL; +} + +static SBcAP_Message_Identifier_t* get_msg_id_ie(struct osmo_sbcap_cbc_client *client, const SBcAP_SBC_AP_PDU_t *pdu) +{ + A_SEQUENCE_OF(void) *as_pdu = NULL; + /* static const long asn_VAL_1_SBcAP_id_Message_Identifier = 5; */ + const SBcAP_ProtocolIE_ID_t msg_id_ie = 5; + void *ie; + + switch (pdu->present) { + case SBcAP_SBC_AP_PDU_PR_initiatingMessage: + switch (pdu->choice.initiatingMessage.procedureCode) { + case SBcAP_ProcedureId_Write_Replace_Warning_Indication: + as_pdu = (void*)&pdu->choice.initiatingMessage.value.choice.Write_Replace_Warning_Indication.protocolIEs.list; + if (!(ie = sbcap_as_find_ie(as_pdu, msg_id_ie))) + return NULL; + return &((SBcAP_Write_Replace_Warning_Indication_IEs_t*)ie)->value.choice.Message_Identifier; + case SBcAP_ProcedureId_Stop_Warning_Indication: + as_pdu = (void*)&pdu->choice.initiatingMessage.value.choice.Stop_Warning_Indication.protocolIEs.list; + if (!(ie = sbcap_as_find_ie(as_pdu, msg_id_ie))) + return NULL; + return &((SBcAP_Stop_Warning_Indication_IEs_t*)ie)->value.choice.Message_Identifier; + default: + LOGPSBCAPC(client, LOGL_ERROR, "get_msg_id initiatingMessage procedure=%ld not implemented\n", + pdu->choice.unsuccessfulOutcome.procedureCode); + return NULL; + } + break; + case SBcAP_SBC_AP_PDU_PR_successfulOutcome: + switch (pdu->choice.successfulOutcome.procedureCode) { + case SBcAP_ProcedureId_Write_Replace_Warning: + as_pdu = (void*)&pdu->choice.successfulOutcome.value.choice.Write_Replace_Warning_Response.protocolIEs.list; + if (!(ie = sbcap_as_find_ie(as_pdu, msg_id_ie))) + return NULL; + return &((SBcAP_Write_Replace_Warning_Response_IEs_t*)ie)->value.choice.Message_Identifier; + case SBcAP_ProcedureId_Stop_Warning: + as_pdu = (void*)&pdu->choice.successfulOutcome.value.choice.Stop_Warning_Response.protocolIEs.list; + if (!(ie = sbcap_as_find_ie(as_pdu, msg_id_ie))) + return NULL; + return &((SBcAP_Stop_Warning_Response_IEs_t*)ie)->value.choice.Message_Identifier; + default: + LOGPSBCAPC(client, LOGL_ERROR, "get_msg_id successfulOutcome procedure=%ld not implemented\n", + pdu->choice.unsuccessfulOutcome.procedureCode); + return NULL; + } + break; + case SBcAP_SBC_AP_PDU_PR_unsuccessfulOutcome: + switch (pdu->choice.unsuccessfulOutcome.procedureCode) { + default: + LOGPSBCAPC(client, LOGL_ERROR, "get_msg_id unsuccessfulOutcome procedure=%ld not implemented\n", + pdu->choice.unsuccessfulOutcome.procedureCode); + return NULL; + } + break; + default: + return NULL; + } +} + +static int get_msg_id(struct osmo_sbcap_cbc_client *client, const SBcAP_SBC_AP_PDU_t *pdu) +{ + SBcAP_Message_Identifier_t *ie = get_msg_id_ie(client, pdu); + if (!ie) + return -1; + if (ie->size != 2) { + LOGPSBCAPC(client, LOGL_ERROR, "get_msg_id wrong size %ld\n", ie->size); + return -1; + } + return osmo_load16be(ie->buf); +} + +/* message was received from remote SBcAP peer (BSC) */ +int sbcap_cbc_client_rx_cb(struct osmo_sbcap_cbc_client *client, SBcAP_SBC_AP_PDU_t *pdu) +{ + struct cbc_message *smscb; + struct cbc_message_peer *mp; + int msg_id; + + /* messages without reference to a specific SMSCB message */ + switch (pdu->present) { + case SBcAP_SBC_AP_PDU_PR_initiatingMessage: + switch (pdu->choice.initiatingMessage.procedureCode) { + case SBcAP_ProcedureId_Write_Replace_Warning: + case SBcAP_ProcedureId_Stop_Warning: + LOGPSBCAPC(client, LOGL_ERROR, + "SBcAP initiatingMessage procedure=%ld MME->CBC not xpected\n", + pdu->choice.initiatingMessage.procedureCode); + return -EINVAL; + case SBcAP_ProcedureId_PWS_Restart_Indication: + return osmo_fsm_inst_dispatch(client->fi, SBcAP_SRV_E_RX_RESTART, pdu); + case SBcAP_ProcedureId_Stop_Warning_Indication: + case SBcAP_ProcedureId_Write_Replace_Warning_Indication: + break; /* Handle msg id below */ + case SBcAP_ProcedureId_Error_Indication: + case SBcAP_ProcedureId_PWS_Failure_Indication: + default: + LOGPSBCAPC(client, LOGL_ERROR, "SBcAP initiatingMessage procedure=%ld not implemented?\n", + pdu->choice.initiatingMessage.procedureCode); + return 0; + } + break; + case SBcAP_SBC_AP_PDU_PR_successfulOutcome: + switch (pdu->choice.successfulOutcome.procedureCode) { + default: + LOGPSBCAPC(client, LOGL_INFO, "SBcAP SuccessfulOutcome procedure=%ld\n", + pdu->choice.successfulOutcome.procedureCode); + break; + } + break; + case SBcAP_SBC_AP_PDU_PR_unsuccessfulOutcome: + switch (pdu->choice.unsuccessfulOutcome.procedureCode) { + default: + LOGPSBCAPC(client, LOGL_ERROR, "SBcAP UnsuccessfulOutcome procedure=%ld\n", + pdu->choice.unsuccessfulOutcome.procedureCode); + break; + } + break; + case SBcAP_SBC_AP_PDU_PR_NOTHING: + default: + LOGPSBCAPC(client, LOGL_ERROR, "Rx SBc-AP unexpected message type %d\n", + pdu->present); + return 0; + } + + + /* messages with reference to a specific SMSCB message handled below*/ + msg_id = get_msg_id(client, pdu); + OSMO_ASSERT(msg_id >= 0); + + /* look-up smscb_message */ + smscb = cbc_message_by_id(msg_id); + if (!smscb) { + LOGPSBCAPC(client, LOGL_ERROR, "Rx SBc-AP msg for unknown message-id 0x%04x\n", + msg_id); + /* TODO: inform peer? */ + return 0; + } + + /* look-up smscb_message_peer */ + mp = cbc_message_peer_get(smscb, client->peer); + if (!mp) { + LOGPSBCAPC(client, LOGL_ERROR, "Rx SBc-AP msg for message-id 0x%04x without peer %s\n", + msg_id, client->peer->name); + /* TODO: inform peer? */ + return 0; + } + + /* dispatch event to smscp_p_fms instance */ + switch (pdu->present) { + case SBcAP_SBC_AP_PDU_PR_initiatingMessage: + switch (pdu->choice.initiatingMessage.procedureCode) { + default: + break; + } + break; + case SBcAP_SBC_AP_PDU_PR_successfulOutcome: + switch (pdu->choice.successfulOutcome.procedureCode) { + case SBcAP_ProcedureId_Write_Replace_Warning: + //if (dec->u.write_replace_compl.old_serial_nr) + // return osmo_fsm_inst_dispatch(mp->fi, SMSCB_E_SBcAP_REPLACE_ACK, dec); + //else + return osmo_fsm_inst_dispatch(mp->fi, SMSCB_E_SBCAP_WRITE_ACK, pdu); + case SBcAP_ProcedureId_Stop_Warning: + return osmo_fsm_inst_dispatch(mp->fi, SMSCB_E_SBCAP_DELETE_ACK, pdu); + default: + break; + } + break; + case SBcAP_SBC_AP_PDU_PR_unsuccessfulOutcome: + switch (pdu->choice.unsuccessfulOutcome.procedureCode) { + case SBcAP_ProcedureId_Stop_Warning: + return osmo_fsm_inst_dispatch(mp->fi, SMSCB_E_SBCAP_DELETE_NACK, pdu); + default: + break; + } + break; + case SBcAP_SBC_AP_PDU_PR_NOTHING: + default: + OSMO_ASSERT(0); + } + return 0; +} + +static __attribute__((constructor)) void on_dso_load_sbcap_srv_fsm(void) +{ + OSMO_ASSERT(osmo_fsm_register(&sbcap_server_fsm) == 0); +} diff --git a/src/smscb_message_fsm.c b/src/smscb_message_fsm.c index 04b0718..4cb0c05 100644 --- a/src/smscb_message_fsm.c +++ b/src/smscb_message_fsm.c @@ -62,6 +62,8 @@ switch (event) { case SMSCB_E_CBSP_WRITE_ACK: case SMSCB_E_CBSP_WRITE_NACK: + case SMSCB_E_SBCAP_WRITE_ACK: + case SMSCB_E_SBCAP_WRITE_NACK: /* check if any per-peer children have not yet received the ACK or * timed out */ llist_for_each_entry(peer_fi, &fi->proc.children, proc.child) { @@ -179,6 +181,8 @@ switch (event) { case SMSCB_E_CBSP_DELETE_ACK: case SMSCB_E_CBSP_DELETE_NACK: + case SMSCB_E_SBCAP_DELETE_ACK: + case SMSCB_E_SBCAP_DELETE_NACK: llist_for_each_entry(peer_fi, &fi->proc.children, proc.child) { if (peer_fi->state != SMSCB_S_DELETED) return; @@ -225,7 +229,9 @@ [SMSCB_S_WAIT_WRITE_ACK] = { .name = "WAIT_WRITE_ACK", .in_event_mask = S(SMSCB_E_CBSP_WRITE_ACK) | - S(SMSCB_E_CBSP_WRITE_NACK), + S(SMSCB_E_CBSP_WRITE_NACK) | + S(SMSCB_E_SBCAP_WRITE_ACK) | + S(SMSCB_E_SBCAP_WRITE_NACK), .out_state_mask = S(SMSCB_S_ACTIVE), .action = smscb_fsm_wait_write_ack, .onleave = smscb_fsm_wait_write_ack_onleave, @@ -260,7 +266,9 @@ [SMSCB_S_WAIT_DELETE_ACK] = { .name = "WAIT_DELETE_ACK", .in_event_mask = S(SMSCB_E_CBSP_DELETE_ACK) | - S(SMSCB_E_CBSP_DELETE_NACK), + S(SMSCB_E_CBSP_DELETE_NACK) | + S(SMSCB_E_SBCAP_DELETE_ACK) | + S(SMSCB_E_SBCAP_DELETE_NACK), .out_state_mask = S(SMSCB_S_DELETED), .action = smscb_fsm_wait_delete_ack, .onleave = smscb_fsm_wait_delete_ack_onleave, diff --git a/src/smscb_peer_fsm.c b/src/smscb_peer_fsm.c index cc91e39..9662785 100644 --- a/src/smscb_peer_fsm.c +++ b/src/smscb_peer_fsm.c @@ -32,8 +32,12 @@ #include <osmocom/gsm/gsm0808_utils.h> #include <osmocom/gsm/cbsp.h> +#include <osmocom/sbcap/sbcap_common.h> + #include <osmocom/cbc/cbc_data.h> #include <osmocom/cbc/cbsp_server.h> +#include <osmocom/cbc/sbcap_server.h> +#include <osmocom/cbc/sbcap_msg.h> #include <osmocom/cbc/internal.h> #define S(x) (1 << (x)) @@ -44,14 +48,18 @@ { SMSCB_E_REPLACE, "REPLACE" }, { SMSCB_E_STATUS, "STATUS" }, { SMSCB_E_DELETE, "DELETE" }, - { SMSCB_E_CBSP_WRITE_ACK, "WRITE_ACK" }, - { SMSCB_E_CBSP_WRITE_NACK, "WRITE_NACK" }, - { SMSCB_E_CBSP_REPLACE_ACK, "REPLACE_ACK" }, - { SMSCB_E_CBSP_REPLACE_NACK, "REPLACE_NACK" }, - { SMSCB_E_CBSP_DELETE_ACK, "DELETE_ACK" }, - { SMSCB_E_CBSP_DELETE_NACK, "DELETE_NACK" }, - { SMSCB_E_CBSP_STATUS_ACK, "STATUS_ACK" }, - { SMSCB_E_CBSP_STATUS_NACK, "STATUS_NACK" }, + { SMSCB_E_CBSP_WRITE_ACK, "CBSP_WRITE_ACK" }, + { SMSCB_E_CBSP_WRITE_NACK, "CBSP_WRITE_NACK" }, + { SMSCB_E_CBSP_REPLACE_ACK, "CBSP_REPLACE_ACK" }, + { SMSCB_E_CBSP_REPLACE_NACK, "CBSP_REPLACE_NACK" }, + { SMSCB_E_CBSP_DELETE_ACK, "CBSP_DELETE_ACK" }, + { SMSCB_E_CBSP_DELETE_NACK, "CBSP_DELETE_NACK" }, + { SMSCB_E_CBSP_STATUS_ACK, "CBSP_STATUS_ACK" }, + { SMSCB_E_CBSP_STATUS_NACK, "CBSP_STATUS_NACK" }, + { SMSCB_E_SBCAP_WRITE_ACK, "SBcAP_WRITE_ACK" }, + { SMSCB_E_SBCAP_WRITE_NACK, "SBcAP_WRITE_NACK" }, + { SMSCB_E_SBCAP_DELETE_ACK, "SBcAP_DELETE_ACK" }, + { SMSCB_E_SBCAP_DELETE_NACK, "SBcAP_DELETE_NACK" }, { 0, NULL } }; @@ -300,6 +308,7 @@ { struct cbc_message_peer *mp = (struct cbc_message_peer *) fi->priv; struct osmo_cbsp_decoded *dec = NULL; + //SBcAP_SBC_AP_PDU_t *pdu = NULL; switch (event) { case SMSCB_E_CBSP_WRITE_ACK: @@ -319,6 +328,18 @@ /* Signal parent fsm about completion */ osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_CBSP_WRITE_NACK, mp); break; + case SMSCB_E_SBCAP_WRITE_ACK: + //pdu = data; + osmo_fsm_inst_state_chg(fi, SMSCB_S_ACTIVE, 0, 0); + /* Signal parent fsm about completion */ + osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_SBCAP_WRITE_ACK, mp); + break; + case SMSCB_E_SBCAP_WRITE_NACK: + //pdu = data; + osmo_fsm_inst_state_chg(fi, SMSCB_S_ACTIVE, 0, 0); + /* Signal parent fsm about completion */ + osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_SBCAP_WRITE_NACK, mp); + break; default: OSMO_ASSERT(0); } @@ -416,6 +437,7 @@ { struct cbc_message_peer *mp = (struct cbc_message_peer *) fi->priv; struct osmo_cbsp_decoded *dec = NULL; + //SBcAP_SBC_AP_PDU_t *pdu = NULL; switch (event) { case SMSCB_E_CBSP_DELETE_ACK: @@ -437,6 +459,18 @@ /* Signal parent fsm about completion */ osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_CBSP_DELETE_NACK, mp); break; + case SMSCB_E_SBCAP_DELETE_ACK: + //pdu = data; + osmo_fsm_inst_state_chg(fi, SMSCB_S_DELETED, 0, 0); + /* Signal parent fsm about completion */ + osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_SBCAP_DELETE_ACK, mp); + break; + case SMSCB_E_SBCAP_DELETE_NACK: + //pdu = data; + osmo_fsm_inst_state_chg(fi, SMSCB_S_DELETED, 0, 0); + /* Signal parent fsm about completion */ + osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_SBCAP_DELETE_NACK, mp); + break; default: OSMO_ASSERT(0); } @@ -446,10 +480,22 @@ static int smscb_p_fsm_timer_cb(struct osmo_fsm_inst *fi) { + struct cbc_message_peer *mp = (struct cbc_message_peer *) fi->priv; + int ev; switch (fi->T) { case T_WAIT_WRITE_ACK: osmo_fsm_inst_state_chg(fi, SMSCB_S_ACTIVE, 0, 0); - osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_CBSP_WRITE_NACK, NULL); + switch (mp->peer->proto) { + case CBC_PEER_PROTO_CBSP: + ev = SMSCB_E_CBSP_WRITE_NACK; + break; + case CBC_PEER_PROTO_SBcAP: + ev = SMSCB_E_SBCAP_WRITE_NACK; + break; + default: + OSMO_ASSERT(0); + } + osmo_fsm_inst_dispatch(fi->proc.parent, ev, NULL); break; case T_WAIT_REPLACE_ACK: osmo_fsm_inst_state_chg(fi, SMSCB_S_ACTIVE, 0, 0); @@ -461,7 +507,17 @@ break; case T_WAIT_DELETE_ACK: osmo_fsm_inst_state_chg(fi, SMSCB_S_DELETED, 0, 0); - osmo_fsm_inst_dispatch(fi->proc.parent, SMSCB_E_CBSP_DELETE_NACK, NULL); + switch (mp->peer->proto) { + case CBC_PEER_PROTO_CBSP: + ev = SMSCB_E_CBSP_DELETE_NACK; + break; + case CBC_PEER_PROTO_SBcAP: + ev = SMSCB_E_SBCAP_DELETE_NACK; + break; + default: + OSMO_ASSERT(0); + } + osmo_fsm_inst_dispatch(fi->proc.parent, ev, NULL); break; default: OSMO_ASSERT(0); @@ -473,6 +529,7 @@ { struct cbc_message_peer *mp = (struct cbc_message_peer *) fi->priv; struct osmo_cbsp_decoded *cbsp; + SBcAP_SBC_AP_PDU_t *sbcap; switch (event) { case SMSCB_E_DELETE: /* send KILL to BSC */ @@ -485,19 +542,35 @@ default: break; } - cbsp = osmo_cbsp_decoded_alloc(mp->peer, CBSP_MSGT_KILL); - OSMO_ASSERT(cbsp); - cbsp->u.kill.msg_id = mp->cbcmsg->msg.message_id; - cbsp->u.kill.old_serial_nr = mp->cbcmsg->msg.serial_nr; - /* TODO: we assume that the delete will always affect all original cells */ - cbsp_append_cell_list(&cbsp->u.kill.cell_list, cbsp, mp); - if (!mp->cbcmsg->msg.is_etws) { - /* Channel Indication IE is only present in CBS, not in ETWS! */ - cbsp->u.kill.channel_ind = talloc_zero(cbsp, enum cbsp_channel_ind); - OSMO_ASSERT(cbsp->u.kill.channel_ind); - *(cbsp->u.kill.channel_ind) = CBSP_CHAN_IND_BASIC; + switch (mp->peer->proto) { + case CBC_PEER_PROTO_CBSP: + cbsp = osmo_cbsp_decoded_alloc(mp->peer, CBSP_MSGT_KILL); + OSMO_ASSERT(cbsp); + cbsp->u.kill.msg_id = mp->cbcmsg->msg.message_id; + cbsp->u.kill.old_serial_nr = mp->cbcmsg->msg.serial_nr; + /* TODO: we assume that the delete will always affect all original cells */ + cbsp_append_cell_list(&cbsp->u.kill.cell_list, cbsp, mp); + if (!mp->cbcmsg->msg.is_etws) { + /* Channel Indication IE is only present in CBS, not in ETWS! */ + cbsp->u.kill.channel_ind = talloc_zero(cbsp, enum cbsp_channel_ind); + OSMO_ASSERT(cbsp->u.kill.channel_ind); + *(cbsp->u.kill.channel_ind) = CBSP_CHAN_IND_BASIC; + } + cbsp_cbc_client_tx(mp->peer->client.cbsp, cbsp); + break; + case CBC_PEER_PROTO_SBcAP: + if ((sbcap = sbcap_gen_stop_warning_req(mp->peer, mp->cbcmsg))) { + sbcap_cbc_client_tx(mp->peer->client.sbcap, sbcap); + } else { + LOGP(DSBcAP, LOGL_ERROR, + "[%s] Tx SBc-AP Stop-Warning-Request: msg gen failed\n", + mp->peer->name); + } + break; + case CBC_PEER_PROTO_SABP: + default: + osmo_panic("SMSCB_E_DELETE not implemented for proto %u", mp->peer->proto); } - cbsp_cbc_client_tx(mp->peer->client.cbsp, cbsp); osmo_fsm_inst_state_chg(fi, SMSCB_S_WAIT_DELETE_ACK, 10, T_WAIT_DELETE_ACK); break; default: @@ -522,7 +595,9 @@ [SMSCB_S_WAIT_WRITE_ACK] = { .name = "WAIT_WRITE_ACK", .in_event_mask = S(SMSCB_E_CBSP_WRITE_ACK) | - S(SMSCB_E_CBSP_WRITE_NACK), + S(SMSCB_E_CBSP_WRITE_NACK) | + S(SMSCB_E_SBCAP_WRITE_ACK) | + S(SMSCB_E_SBCAP_WRITE_NACK), .out_state_mask = S(SMSCB_S_ACTIVE) | S(SMSCB_S_WAIT_DELETE_ACK), .action = smscb_p_fsm_wait_write_ack, @@ -555,7 +630,9 @@ [SMSCB_S_WAIT_DELETE_ACK] = { .name = "WAIT_DELETE_ACK", .in_event_mask = S(SMSCB_E_CBSP_DELETE_ACK) | - S(SMSCB_E_CBSP_DELETE_NACK), + S(SMSCB_E_CBSP_DELETE_NACK) | + S(SMSCB_E_SBCAP_DELETE_ACK) | + S(SMSCB_E_SBCAP_DELETE_NACK), .out_state_mask = S(SMSCB_S_DELETED), .action = smscb_p_fsm_wait_delete_ack, }, -- To view, visit https://gerrit.osmocom.org/c/osmo-cbc/+/28602 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-cbc Gerrit-Branch: master Gerrit-Change-Id: Ib278bc1d1a74459814016fef7a8fe21cc29d46c9 Gerrit-Change-Number: 28602 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newchange

2 years, 11 months

Change in osmo-cbc[master]: Add sbcap library

by pespin

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-cbc/+/28600 ) Change subject: Add sbcap library ...................................................................... Add sbcap library This commit adds initial support to encode/decode SBc-AP messages in the form of a library, under src/sbcap/ (includes in include/osmocom/sbcap/). asn1c is used to generate all suport code and structures for ASN.1 APER encoding/decoding, based on asn files obtained from 3GPP TS 29.168 and stored under src/sbcap/asn1/. Currently, mainstream asn1c doesn't yet support ASN.1 APER encoding/decoding, hence mouse07410 's fork is used [1]. Furthermore, several encdoing/decoding bugs where found during the process and fixed, which means asn1.c git >= 30219de2d3da888b4f1eea0dd79f2a505000401a must be used to generate proper code. A new "make -C src/ gen" target is added which can be used to regenerate all C code from the available ASN.1 files in src/sbcap/asn1/*.asn (after properly setting configure.ac ASN_* variables if needed). [1] https://github.com/mouse07410/asn1c Related: OS#4945 Change-Id: If76f8619a9b2d46af6d94b8ae49348b8514e53aa --- M configure.ac M include/osmocom/Makefile.am A include/osmocom/sbcap/Makefile.am A include/osmocom/sbcap/SBcAP_Broadcast-Cancelled-Area-List-5GS.h A include/osmocom/sbcap/SBcAP_Broadcast-Cancelled-Area-List.h A include/osmocom/sbcap/SBcAP_Broadcast-Empty-Area-List-5GS.h A include/osmocom/sbcap/SBcAP_Broadcast-Empty-Area-List.h A include/osmocom/sbcap/SBcAP_Broadcast-Scheduled-Area-List-5GS.h A include/osmocom/sbcap/SBcAP_Broadcast-Scheduled-Area-List.h A include/osmocom/sbcap/SBcAP_CancelledCellinEAI-Item.h A include/osmocom/sbcap/SBcAP_CancelledCellinEAI.h A include/osmocom/sbcap/SBcAP_CancelledCellinTAI-5GS.h A include/osmocom/sbcap/SBcAP_CancelledCellinTAI-Item.h A include/osmocom/sbcap/SBcAP_CancelledCellinTAI.h A include/osmocom/sbcap/SBcAP_Cause.h A include/osmocom/sbcap/SBcAP_CellID-Cancelled-Item.h A include/osmocom/sbcap/SBcAP_CellID-Cancelled-List-5GS.h A include/osmocom/sbcap/SBcAP_CellID-Cancelled-List.h A include/osmocom/sbcap/SBcAP_CellId-Broadcast-List-5GS.h A include/osmocom/sbcap/SBcAP_CellId-Broadcast-List-Item.h A include/osmocom/sbcap/SBcAP_CellId-Broadcast-List.h A include/osmocom/sbcap/SBcAP_CellIdentity.h A include/osmocom/sbcap/SBcAP_Concurrent-Warning-Message-Indicator.h A include/osmocom/sbcap/SBcAP_Criticality-Diagnostics.h A include/osmocom/sbcap/SBcAP_Criticality.h A include/osmocom/sbcap/SBcAP_CriticalityDiagnostics-IE-List.h A include/osmocom/sbcap/SBcAP_Data-Coding-Scheme.h A include/osmocom/sbcap/SBcAP_ECGIList.h A include/osmocom/sbcap/SBcAP_ENB-ID.h A include/osmocom/sbcap/SBcAP_EUTRAN-CGI.h A include/osmocom/sbcap/SBcAP_EXTERNAL.h A include/osmocom/sbcap/SBcAP_Emergency-Area-ID-List.h A include/osmocom/sbcap/SBcAP_Emergency-Area-ID.h A include/osmocom/sbcap/SBcAP_EmergencyAreaID-Broadcast-List-Item.h A include/osmocom/sbcap/SBcAP_EmergencyAreaID-Broadcast-List.h A include/osmocom/sbcap/SBcAP_EmergencyAreaID-Cancelled-Item.h A include/osmocom/sbcap/SBcAP_EmergencyAreaID-Cancelled-List.h A include/osmocom/sbcap/SBcAP_Error-Indication.h A include/osmocom/sbcap/SBcAP_Extended-Repetition-Period.h A include/osmocom/sbcap/SBcAP_Failed-Cell-List-NR.h A include/osmocom/sbcap/SBcAP_Failed-Cell-List.h A include/osmocom/sbcap/SBcAP_GNB-ID.h A include/osmocom/sbcap/SBcAP_Global-ENB-ID.h A include/osmocom/sbcap/SBcAP_Global-GNB-ID.h A include/osmocom/sbcap/SBcAP_Global-NgENB-ID.h A include/osmocom/sbcap/SBcAP_Global-RAN-Node-ID.h A include/osmocom/sbcap/SBcAP_InitiatingMessage.h A include/osmocom/sbcap/SBcAP_List-of-5GS-Cells-for-Failure.h A include/osmocom/sbcap/SBcAP_List-of-5GS-TAI-for-Restart.h A include/osmocom/sbcap/SBcAP_List-of-5GS-TAIs.h A include/osmocom/sbcap/SBcAP_List-of-EAIs-Restart.h A include/osmocom/sbcap/SBcAP_List-of-TAIs-Restart.h A include/osmocom/sbcap/SBcAP_List-of-TAIs.h A include/osmocom/sbcap/SBcAP_Message-Identifier.h A include/osmocom/sbcap/SBcAP_NR-CGI.h A include/osmocom/sbcap/SBcAP_NR-CGIList.h A include/osmocom/sbcap/SBcAP_NRCellIdentity.h A include/osmocom/sbcap/SBcAP_NgENB-ID.h A include/osmocom/sbcap/SBcAP_Number-of-Broadcasts-Requested.h A include/osmocom/sbcap/SBcAP_NumberOfBroadcasts.h A include/osmocom/sbcap/SBcAP_Omc-Id.h A include/osmocom/sbcap/SBcAP_PLMNidentity.h A include/osmocom/sbcap/SBcAP_PWS-Failure-Indication.h A include/osmocom/sbcap/SBcAP_PWS-Restart-Indication.h A include/osmocom/sbcap/SBcAP_Presence.h A include/osmocom/sbcap/SBcAP_ProcedureCode.h A include/osmocom/sbcap/SBcAP_ProtocolExtensionContainer.h A include/osmocom/sbcap/SBcAP_ProtocolExtensionField.h A include/osmocom/sbcap/SBcAP_ProtocolExtensionID.h A include/osmocom/sbcap/SBcAP_ProtocolIE-Container.h A include/osmocom/sbcap/SBcAP_ProtocolIE-ContainerList.h A include/osmocom/sbcap/SBcAP_ProtocolIE-Field.h A include/osmocom/sbcap/SBcAP_ProtocolIE-ID.h A include/osmocom/sbcap/SBcAP_RAT-Selector-5GS.h A include/osmocom/sbcap/SBcAP_Repetition-Period.h A include/osmocom/sbcap/SBcAP_Restarted-Cell-List-NR.h A include/osmocom/sbcap/SBcAP_Restarted-Cell-List.h A include/osmocom/sbcap/SBcAP_SBC-AP-PDU.h A include/osmocom/sbcap/SBcAP_ScheduledCellinEAI-Item.h A include/osmocom/sbcap/SBcAP_ScheduledCellinEAI.h A include/osmocom/sbcap/SBcAP_ScheduledCellinTAI-5GS.h A include/osmocom/sbcap/SBcAP_ScheduledCellinTAI-Item.h A include/osmocom/sbcap/SBcAP_ScheduledCellinTAI.h A include/osmocom/sbcap/SBcAP_Send-Stop-Warning-Indication.h A include/osmocom/sbcap/SBcAP_Send-Write-Replace-Warning-Indication.h A include/osmocom/sbcap/SBcAP_Serial-Number.h A include/osmocom/sbcap/SBcAP_Stop-All-Indicator.h A include/osmocom/sbcap/SBcAP_Stop-Warning-Indication.h A include/osmocom/sbcap/SBcAP_Stop-Warning-Request.h A include/osmocom/sbcap/SBcAP_Stop-Warning-Response.h A include/osmocom/sbcap/SBcAP_SuccessfulOutcome.h A include/osmocom/sbcap/SBcAP_TAC-5GS.h A include/osmocom/sbcap/SBcAP_TAC.h A include/osmocom/sbcap/SBcAP_TAI-5GS.h A include/osmocom/sbcap/SBcAP_TAI-Broadcast-List-5GS.h A include/osmocom/sbcap/SBcAP_TAI-Broadcast-List-Item.h A include/osmocom/sbcap/SBcAP_TAI-Broadcast-List.h A include/osmocom/sbcap/SBcAP_TAI-Cancelled-List-5GS.h A include/osmocom/sbcap/SBcAP_TAI-Cancelled-List-Item.h A include/osmocom/sbcap/SBcAP_TAI-Cancelled-List.h A include/osmocom/sbcap/SBcAP_TAI-List-for-Warning.h A include/osmocom/sbcap/SBcAP_TAI.h A include/osmocom/sbcap/SBcAP_TBCD-STRING.h A include/osmocom/sbcap/SBcAP_TriggeringMessage.h A include/osmocom/sbcap/SBcAP_TypeOfError.h A include/osmocom/sbcap/SBcAP_Unknown-5GS-Tracking-Area-List.h A include/osmocom/sbcap/SBcAP_Unknown-Tracking-Area-List.h A include/osmocom/sbcap/SBcAP_UnsuccessfulOutcome.h A include/osmocom/sbcap/SBcAP_Warning-Area-Coordinates.h A include/osmocom/sbcap/SBcAP_Warning-Area-List-5GS.h A include/osmocom/sbcap/SBcAP_Warning-Area-List.h A include/osmocom/sbcap/SBcAP_Warning-Message-Content.h A include/osmocom/sbcap/SBcAP_Warning-Security-Information.h A include/osmocom/sbcap/SBcAP_Warning-Type.h A include/osmocom/sbcap/SBcAP_Write-Replace-Warning-Indication.h A include/osmocom/sbcap/SBcAP_Write-Replace-Warning-Request.h A include/osmocom/sbcap/SBcAP_Write-Replace-Warning-Response.h A include/osmocom/sbcap/sbcap_common.h A include/osmocom/sbcap/sbcap_internal.h A move-asn1-header-files.sh M src/Makefile.am A src/sbcap/Makefile.am A src/sbcap/asn1/SBC_AP_CommonDataTypes.asn A src/sbcap/asn1/SBC_AP_Constants.asn A src/sbcap/asn1/SBC_AP_Containers.asn A src/sbcap/asn1/SBC_AP_IEs.asn A src/sbcap/asn1/SBC_AP_PDU_Contents.asn A src/sbcap/asn1/SBC_AP_PDU_Descriptions.asn A src/sbcap/gen/ANY.c A src/sbcap/gen/ANY_aper.c A src/sbcap/gen/BIT_STRING.c A src/sbcap/gen/BIT_STRING_print.c A src/sbcap/gen/BIT_STRING_rfill.c A src/sbcap/gen/GraphicString.c A src/sbcap/gen/INTEGER.c A src/sbcap/gen/INTEGER_aper.c A src/sbcap/gen/INTEGER_print.c A src/sbcap/gen/INTEGER_rfill.c A src/sbcap/gen/NativeEnumerated.c A src/sbcap/gen/NativeEnumerated_aper.c A src/sbcap/gen/NativeInteger.c A src/sbcap/gen/NativeInteger_aper.c A src/sbcap/gen/NativeInteger_print.c A src/sbcap/gen/NativeInteger_rfill.c A src/sbcap/gen/OBJECT_IDENTIFIER.c A src/sbcap/gen/OBJECT_IDENTIFIER_print.c A src/sbcap/gen/OBJECT_IDENTIFIER_rfill.c A src/sbcap/gen/OCTET_STRING.c A src/sbcap/gen/OCTET_STRING_aper.c A src/sbcap/gen/OCTET_STRING_print.c A src/sbcap/gen/OCTET_STRING_rfill.c A src/sbcap/gen/OPEN_TYPE.c A src/sbcap/gen/OPEN_TYPE_aper.c A src/sbcap/gen/ObjectDescriptor.c A src/sbcap/gen/SBcAP_Broadcast-Cancelled-Area-List-5GS.c A src/sbcap/gen/SBcAP_Broadcast-Cancelled-Area-List.c A src/sbcap/gen/SBcAP_Broadcast-Empty-Area-List-5GS.c A src/sbcap/gen/SBcAP_Broadcast-Empty-Area-List.c A src/sbcap/gen/SBcAP_Broadcast-Scheduled-Area-List-5GS.c A src/sbcap/gen/SBcAP_Broadcast-Scheduled-Area-List.c A src/sbcap/gen/SBcAP_CancelledCellinEAI-Item.c A src/sbcap/gen/SBcAP_CancelledCellinEAI.c A src/sbcap/gen/SBcAP_CancelledCellinTAI-5GS.c A src/sbcap/gen/SBcAP_CancelledCellinTAI-Item.c A src/sbcap/gen/SBcAP_CancelledCellinTAI.c A src/sbcap/gen/SBcAP_Cause.c A src/sbcap/gen/SBcAP_CellID-Cancelled-Item.c A src/sbcap/gen/SBcAP_CellID-Cancelled-List-5GS.c A src/sbcap/gen/SBcAP_CellID-Cancelled-List.c A src/sbcap/gen/SBcAP_CellId-Broadcast-List-5GS.c A src/sbcap/gen/SBcAP_CellId-Broadcast-List-Item.c A src/sbcap/gen/SBcAP_CellId-Broadcast-List.c A src/sbcap/gen/SBcAP_CellIdentity.c A src/sbcap/gen/SBcAP_Concurrent-Warning-Message-Indicator.c A src/sbcap/gen/SBcAP_Criticality-Diagnostics.c A src/sbcap/gen/SBcAP_Criticality.c A src/sbcap/gen/SBcAP_CriticalityDiagnostics-IE-List.c A src/sbcap/gen/SBcAP_Data-Coding-Scheme.c A src/sbcap/gen/SBcAP_ECGIList.c A src/sbcap/gen/SBcAP_ENB-ID.c A src/sbcap/gen/SBcAP_EUTRAN-CGI.c A src/sbcap/gen/SBcAP_EXTERNAL.c A src/sbcap/gen/SBcAP_Emergency-Area-ID-List.c A src/sbcap/gen/SBcAP_Emergency-Area-ID.c A src/sbcap/gen/SBcAP_EmergencyAreaID-Broadcast-List-Item.c A src/sbcap/gen/SBcAP_EmergencyAreaID-Broadcast-List.c A src/sbcap/gen/SBcAP_EmergencyAreaID-Cancelled-Item.c A src/sbcap/gen/SBcAP_EmergencyAreaID-Cancelled-List.c A src/sbcap/gen/SBcAP_Error-Indication.c A src/sbcap/gen/SBcAP_Extended-Repetition-Period.c A src/sbcap/gen/SBcAP_Failed-Cell-List-NR.c A src/sbcap/gen/SBcAP_Failed-Cell-List.c A src/sbcap/gen/SBcAP_GNB-ID.c A src/sbcap/gen/SBcAP_Global-ENB-ID.c A src/sbcap/gen/SBcAP_Global-GNB-ID.c A src/sbcap/gen/SBcAP_Global-NgENB-ID.c A src/sbcap/gen/SBcAP_Global-RAN-Node-ID.c A src/sbcap/gen/SBcAP_InitiatingMessage.c A src/sbcap/gen/SBcAP_List-of-5GS-Cells-for-Failure.c A src/sbcap/gen/SBcAP_List-of-5GS-TAI-for-Restart.c A src/sbcap/gen/SBcAP_List-of-5GS-TAIs.c A src/sbcap/gen/SBcAP_List-of-EAIs-Restart.c A src/sbcap/gen/SBcAP_List-of-TAIs-Restart.c A src/sbcap/gen/SBcAP_List-of-TAIs.c A src/sbcap/gen/SBcAP_Message-Identifier.c A src/sbcap/gen/SBcAP_NR-CGI.c A src/sbcap/gen/SBcAP_NR-CGIList.c A src/sbcap/gen/SBcAP_NRCellIdentity.c A src/sbcap/gen/SBcAP_NgENB-ID.c A src/sbcap/gen/SBcAP_Number-of-Broadcasts-Requested.c A src/sbcap/gen/SBcAP_NumberOfBroadcasts.c A src/sbcap/gen/SBcAP_Omc-Id.c A src/sbcap/gen/SBcAP_PLMNidentity.c A src/sbcap/gen/SBcAP_PWS-Failure-Indication.c A src/sbcap/gen/SBcAP_PWS-Restart-Indication.c A src/sbcap/gen/SBcAP_Presence.c A src/sbcap/gen/SBcAP_ProcedureCode.c A src/sbcap/gen/SBcAP_ProtocolExtensionContainer.c A src/sbcap/gen/SBcAP_ProtocolExtensionField.c A src/sbcap/gen/SBcAP_ProtocolExtensionID.c A src/sbcap/gen/SBcAP_ProtocolIE-Container.c A src/sbcap/gen/SBcAP_ProtocolIE-ContainerList.c A src/sbcap/gen/SBcAP_ProtocolIE-Field.c A src/sbcap/gen/SBcAP_ProtocolIE-ID.c A src/sbcap/gen/SBcAP_RAT-Selector-5GS.c A src/sbcap/gen/SBcAP_Repetition-Period.c A src/sbcap/gen/SBcAP_Restarted-Cell-List-NR.c A src/sbcap/gen/SBcAP_Restarted-Cell-List.c A src/sbcap/gen/SBcAP_SBC-AP-PDU.c A src/sbcap/gen/SBcAP_ScheduledCellinEAI-Item.c A src/sbcap/gen/SBcAP_ScheduledCellinEAI.c A src/sbcap/gen/SBcAP_ScheduledCellinTAI-5GS.c A src/sbcap/gen/SBcAP_ScheduledCellinTAI-Item.c A src/sbcap/gen/SBcAP_ScheduledCellinTAI.c A src/sbcap/gen/SBcAP_Send-Stop-Warning-Indication.c A src/sbcap/gen/SBcAP_Send-Write-Replace-Warning-Indication.c A src/sbcap/gen/SBcAP_Serial-Number.c A src/sbcap/gen/SBcAP_Stop-All-Indicator.c A src/sbcap/gen/SBcAP_Stop-Warning-Indication.c A src/sbcap/gen/SBcAP_Stop-Warning-Request.c A src/sbcap/gen/SBcAP_Stop-Warning-Response.c A src/sbcap/gen/SBcAP_SuccessfulOutcome.c A src/sbcap/gen/SBcAP_TAC-5GS.c A src/sbcap/gen/SBcAP_TAC.c A src/sbcap/gen/SBcAP_TAI-5GS.c A src/sbcap/gen/SBcAP_TAI-Broadcast-List-5GS.c A src/sbcap/gen/SBcAP_TAI-Broadcast-List-Item.c A src/sbcap/gen/SBcAP_TAI-Broadcast-List.c A src/sbcap/gen/SBcAP_TAI-Cancelled-List-5GS.c A src/sbcap/gen/SBcAP_TAI-Cancelled-List-Item.c A src/sbcap/gen/SBcAP_TAI-Cancelled-List.c A src/sbcap/gen/SBcAP_TAI-List-for-Warning.c A src/sbcap/gen/SBcAP_TAI.c A src/sbcap/gen/SBcAP_TBCD-STRING.c A src/sbcap/gen/SBcAP_TriggeringMessage.c A src/sbcap/gen/SBcAP_TypeOfError.c A src/sbcap/gen/SBcAP_Unknown-5GS-Tracking-Area-List.c A src/sbcap/gen/SBcAP_Unknown-Tracking-Area-List.c A src/sbcap/gen/SBcAP_UnsuccessfulOutcome.c A src/sbcap/gen/SBcAP_Warning-Area-Coordinates.c A src/sbcap/gen/SBcAP_Warning-Area-List-5GS.c A src/sbcap/gen/SBcAP_Warning-Area-List.c A src/sbcap/gen/SBcAP_Warning-Message-Content.c A src/sbcap/gen/SBcAP_Warning-Security-Information.c A src/sbcap/gen/SBcAP_Warning-Type.c A src/sbcap/gen/SBcAP_Write-Replace-Warning-Indication.c A src/sbcap/gen/SBcAP_Write-Replace-Warning-Request.c A src/sbcap/gen/SBcAP_Write-Replace-Warning-Response.c A src/sbcap/gen/aper_decoder.c A src/sbcap/gen/aper_encoder.c A src/sbcap/gen/aper_opentype.c A src/sbcap/gen/aper_support.c A src/sbcap/gen/asn_SEQUENCE_OF.c A src/sbcap/gen/asn_SET_OF.c A src/sbcap/gen/asn_application.c A src/sbcap/gen/asn_bit_data.c A src/sbcap/gen/asn_codecs_prim.c A src/sbcap/gen/asn_internal.c A src/sbcap/gen/asn_random_fill.c A src/sbcap/gen/ber_tlv_length.c A src/sbcap/gen/ber_tlv_tag.c A src/sbcap/gen/constr_CHOICE.c A src/sbcap/gen/constr_CHOICE_aper.c A src/sbcap/gen/constr_CHOICE_print.c A src/sbcap/gen/constr_CHOICE_rfill.c A src/sbcap/gen/constr_SEQUENCE.c A src/sbcap/gen/constr_SEQUENCE_OF.c A src/sbcap/gen/constr_SEQUENCE_OF_aper.c A src/sbcap/gen/constr_SEQUENCE_aper.c A src/sbcap/gen/constr_SEQUENCE_print.c A src/sbcap/gen/constr_SEQUENCE_rfill.c A src/sbcap/gen/constr_SET_OF.c A src/sbcap/gen/constr_SET_OF_aper.c A src/sbcap/gen/constr_SET_OF_print.c A src/sbcap/gen/constr_SET_OF_rfill.c A src/sbcap/gen/constr_TYPE.c A src/sbcap/gen/constraints.c A src/sbcap/gen/per_decoder.c A src/sbcap/gen/per_encoder.c A src/sbcap/gen/per_opentype.c A src/sbcap/gen/per_support.c A src/sbcap/sbcap_common.c A src/sbcap/skel/ANY.h A src/sbcap/skel/BIT_STRING.h A src/sbcap/skel/BMPString.h A src/sbcap/skel/BOOLEAN.h A src/sbcap/skel/ENUMERATED.h A src/sbcap/skel/GeneralString.h A src/sbcap/skel/GeneralizedTime.h A src/sbcap/skel/GraphicString.h A src/sbcap/skel/IA5String.h A src/sbcap/skel/INTEGER.h A src/sbcap/skel/ISO646String.h A src/sbcap/skel/NULL.h A src/sbcap/skel/NativeEnumerated.h A src/sbcap/skel/NativeInteger.h A src/sbcap/skel/NativeReal.h A src/sbcap/skel/NumericString.h A src/sbcap/skel/OBJECT_IDENTIFIER.h A src/sbcap/skel/OCTET_STRING.h A src/sbcap/skel/OPEN_TYPE.h A src/sbcap/skel/ObjectDescriptor.h A src/sbcap/skel/PrintableString.h A src/sbcap/skel/REAL.h A src/sbcap/skel/RELATIVE-OID.h A src/sbcap/skel/T61String.h A src/sbcap/skel/TeletexString.h A src/sbcap/skel/UTCTime.h A src/sbcap/skel/UTF8String.h A src/sbcap/skel/UniversalString.h A src/sbcap/skel/VideotexString.h A src/sbcap/skel/VisibleString.h A src/sbcap/skel/aper_decoder.h A src/sbcap/skel/aper_encoder.h A src/sbcap/skel/aper_opentype.h A src/sbcap/skel/aper_support.h A src/sbcap/skel/asn_SEQUENCE_OF.h A src/sbcap/skel/asn_SET_OF.h A src/sbcap/skel/asn_application.h A src/sbcap/skel/asn_bit_data.h A src/sbcap/skel/asn_codecs.h A src/sbcap/skel/asn_codecs_prim.h A src/sbcap/skel/asn_config.h A src/sbcap/skel/asn_internal.h A src/sbcap/skel/asn_ioc.h A src/sbcap/skel/asn_random_fill.h A src/sbcap/skel/asn_system.h A src/sbcap/skel/ber_decoder.h A src/sbcap/skel/ber_tlv_length.h A src/sbcap/skel/ber_tlv_tag.h A src/sbcap/skel/constr_CHOICE.h A src/sbcap/skel/constr_SEQUENCE.h A src/sbcap/skel/constr_SEQUENCE_OF.h A src/sbcap/skel/constr_SET.h A src/sbcap/skel/constr_SET_OF.h A src/sbcap/skel/constr_TYPE.h A src/sbcap/skel/constraints.h A src/sbcap/skel/der_encoder.h A src/sbcap/skel/jer_encoder.h A src/sbcap/skel/oer_decoder.h A src/sbcap/skel/oer_encoder.h A src/sbcap/skel/oer_support.h A src/sbcap/skel/per_decoder.h A src/sbcap/skel/per_encoder.h A src/sbcap/skel/per_opentype.h A src/sbcap/skel/per_support.h A src/sbcap/skel/uper_decoder.h A src/sbcap/skel/uper_encoder.h A src/sbcap/skel/uper_opentype.h A src/sbcap/skel/uper_support.h A src/sbcap/skel/xer_decoder.h A src/sbcap/skel/xer_encoder.h A src/sbcap/skel/xer_support.h 373 files changed, 50,366 insertions(+), 4 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-cbc refs/changes/00/28600/1 -- To view, visit https://gerrit.osmocom.org/c/osmo-cbc/+/28600 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-cbc Gerrit-Branch: master Gerrit-Change-Id: If76f8619a9b2d46af6d94b8ae49348b8514e53aa Gerrit-Change-Number: 28600 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newchange

2 years, 11 months

Change in osmo-cbc[master]: Add unit tests for sbcap

by pespin

pespin has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-cbc/+/28601 ) Change subject: Add unit tests for sbcap ...................................................................... Add unit tests for sbcap This commit adds some minimum unit tests to validate encoding and decoding of SBc-AP ASN.1 APER format is working properly. Related: OS#4945 Change-Id: I5a26d008b7282da637c3781ae77435c6a69cf65d --- M configure.ac M tests/Makefile.am A tests/sbcap/Makefile.am A tests/sbcap/sbcap_test.c A tests/sbcap/sbcap_test.ok A tests/testsuite.at 6 files changed, 346 insertions(+), 0 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-cbc refs/changes/01/28601/1 diff --git a/configure.ac b/configure.ac index 0cd3d32..c104f2c 100644 --- a/configure.ac +++ b/configure.ac @@ -186,6 +186,7 @@ contrib/Makefile contrib/osmo-cbc.spec tests/Makefile + tests/sbcap/Makefile doc/Makefile doc/examples/Makefile doc/manuals/Makefile diff --git a/tests/Makefile.am b/tests/Makefile.am index a77bd66..cad72df 100644 --- a/tests/Makefile.am +++ b/tests/Makefile.am @@ -1,5 +1,50 @@ +SUBDIRS = \ + sbcap \ + $(NULL) +# The `:;' works around a Bash 3.2 bug when the output is not writeable. +$(srcdir)/package.m4: $(top_srcdir)/configure.ac + :;{ \ + echo '# Signature of the current package.' && \ + echo 'm4_define([AT_PACKAGE_NAME],' && \ + echo ' [$(PACKAGE_NAME)])' && \ + echo 'm4_define([AT_PACKAGE_TARNAME],' && \ + echo ' [$(PACKAGE_TARNAME)])' && \ + echo 'm4_define([AT_PACKAGE_VERSION],' && \ + echo ' [$(PACKAGE_VERSION)])' && \ + echo 'm4_define([AT_PACKAGE_STRING],' && \ + echo ' [$(PACKAGE_STRING)])' && \ + echo 'm4_define([AT_PACKAGE_BUGREPORT],' && \ + echo ' [$(PACKAGE_BUGREPORT)])'; \ + echo 'm4_define([AT_PACKAGE_URL],' && \ + echo ' [$(PACKAGE_URL)])'; \ + } >'$(srcdir)/package.m4' + +EXTRA_DIST = \ + testsuite.at \ + $(srcdir)/package.m4 \ + $(TESTSUITE) \ + $(NULL) + +TESTSUITE = $(srcdir)/testsuite DISTCLEANFILES = \ atconfig \ $(NULL) + +check-local: atconfig $(TESTSUITE) + $(SHELL) '$(TESTSUITE)' $(TESTSUITEFLAGS) + +installcheck-local: atconfig $(TESTSUITE) + $(SHELL) '$(TESTSUITE)' AUTOTEST_PATH='$(bindir)' \ + $(TESTSUITEFLAGS) + +clean-local: + test ! -f '$(TESTSUITE)' || \ + $(SHELL) '$(TESTSUITE)' --clean + +AUTOM4TE = $(SHELL) $(top_srcdir)/missing --run autom4te +AUTOTEST = $(AUTOM4TE) --language=autotest +$(TESTSUITE): $(srcdir)/testsuite.at $(srcdir)/package.m4 + $(AUTOTEST) -I '$(srcdir)' -o $@.tmp $@.at + mv $@.tmp $@ diff --git a/tests/sbcap/Makefile.am b/tests/sbcap/Makefile.am new file mode 100644 index 0000000..844b4b0 --- /dev/null +++ b/tests/sbcap/Makefile.am @@ -0,0 +1,46 @@ +AM_CPPFLAGS = \ + $(all_includes) \ + -I$(top_srcdir)/include \ + -I$(top_srcdir)/src/sbcap/skel \ + $(NULL) + +AM_CFLAGS = \ + -Wall \ + -ggdb3 \ + $(LIBOSMOCORE_CFLAGS) \ + $(LIBOSMOVTY_CFLAGS) \ + $(LIBOSMOGSM_CFLAGS) \ + $(COVERAGE_CFLAGS) \ + $(ULFIUS_CFLAGS) \ + $(JANSSON_CFLAGS) \ + $(ORCANIA_CFLAGS) \ + $(ASN_MODULE_CFLAGS) \ + $(NULL) + +AM_LDFLAGS = \ + $(COVERAGE_LDFLAGS) \ + $(NULL) + +EXTRA_DIST = \ + sbcap_test.ok \ + $(NULL) + +check_PROGRAMS = \ + sbcap_test \ + $(NULL) + +sbcap_test_SOURCES = \ + sbcap_test.c \ + $(NULL) + +sbcap_test_LDADD = \ + $(LIBOSMOCORE_LIBS) \ + $(LIBOSMOGSM_LIBS) \ + $(LIBOSMOVTY_LIBS) \ + $(LIBOSMONETIF_LIBS) \ + $(ULFIUS_LIBS) \ + $(JANSSON_LIBS) \ + $(ORCANIA_LIBS) \ + $(LIBSCTP_LIBS) \ + $(top_builddir)/src/sbcap/libosmo-sbcap.la \ + $(NULL) diff --git a/tests/sbcap/sbcap_test.c b/tests/sbcap/sbcap_test.c new file mode 100644 index 0000000..7ae08c8 --- /dev/null +++ b/tests/sbcap/sbcap_test.c @@ -0,0 +1,240 @@ +#include <osmocom/core/application.h> +#include <osmocom/core/linuxlist.h> +#include <osmocom/core/talloc.h> +#include <osmocom/core/utils.h> +#include <osmocom/core/msgb.h> + +#include <osmocom/sbcap/sbcap_common.h> + +/* 3GPP TS 36.413 9.2.1.53 */ +#define SBCAP_WARN_MSG_CONTENTS_IE_MAX_LEN 9600 + +void test_asn1c_enc(void) +{ + struct msgb *msg; + SBcAP_SBC_AP_PDU_t *pdu; + SBcAP_Write_Replace_Warning_Request_IEs_t *ie; + uint16_t ie_warning_type = 0x01; + uint8_t ie_dcs = 2; + uint8_t ie_warning_sec_info[50] = {0x30, 0x40, 0x12, 0x23, 0x45}; + uint8_t ie_warning_msg_content[SBCAP_WARN_MSG_CONTENTS_IE_MAX_LEN] = {0x30, 0x40, 0x12, 0x23, 0x45}; + + static uint8_t ie_message_identifier[] = {0xab, 0x01}; + static uint8_t ie_serial_number[] = {0xab, 0xcd}; + + printf("==== %s ====\n", __FUNCTION__); + + pdu = sbcap_pdu_alloc(); + pdu->present = SBcAP_SBC_AP_PDU_PR_initiatingMessage; + pdu->choice.initiatingMessage.procedureCode = SBcAP_ProcedureId_Write_Replace_Warning; + pdu->choice.initiatingMessage.criticality = SBcAP_Criticality_reject; + pdu->choice.initiatingMessage.value.present = SBcAP_InitiatingMessage__value_PR_Write_Replace_Warning_Request; + + A_SEQUENCE_OF(void) *as_pdu = (void*)&pdu->choice.initiatingMessage.value.choice.Write_Replace_Warning_Request.protocolIEs.list; + + /* static const long asn_VAL_1_SBcAP_id_Message_Identifier = 5; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(5, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Message_Identifier); + ie->value.choice.Message_Identifier.buf = MALLOC(sizeof(ie_message_identifier)); + ie->value.choice.Message_Identifier.size = sizeof(ie_message_identifier); + ie->value.choice.Message_Identifier.bits_unused = 0; + memcpy(ie->value.choice.Message_Identifier.buf, ie_message_identifier, sizeof(ie_message_identifier)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_2_SBcAP_id_Serial_Number = 11; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(11, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Serial_Number); + ie->value.choice.Serial_Number.buf = MALLOC(sizeof(ie_serial_number)); + ie->value.choice.Serial_Number.size = sizeof(ie_serial_number); + ie->value.choice.Serial_Number.bits_unused = 0; + memcpy(ie->value.choice.Serial_Number.buf, ie_serial_number, sizeof(ie_serial_number)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_5_SBcAP_id_Repetition_Period = 10; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(10, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Repetition_Period); + ie->value.choice.Repetition_Period = 30; /*seconds */ + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* static const long asn_VAL_7_SBcAP_id_Number_of_Broadcasts_Requested = 7; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(7, SBcAP_Criticality_reject, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Number_of_Broadcasts_Requested); + ie->value.choice.Number_of_Broadcasts_Requested = 89; + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* Warning Type, 3GPP TS 36.413 sec 9.2.1.50: */ + /* static const long asn_VAL_8_SBcAP_id_Warning_Type = 18; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(18, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Type); + ie->value.choice.Warning_Type.buf = MALLOC(sizeof(ie_warning_type)); + ie->value.choice.Warning_Type.size = sizeof(ie_warning_type); + ie_warning_type |= 0x0100; + ie_warning_type |= 0x0080; + memcpy(ie->value.choice.Warning_Type.buf, &ie_warning_type, sizeof(ie_warning_type)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* Warning Security Information, 3GPP TS 36.413 sec 9.2.1.51: */ + /*static const long asn_VAL_9_SBcAP_id_Warning_Security_Information = 17 */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(17, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Security_Information); + ie->value.choice.Warning_Security_Information.buf = MALLOC(sizeof(ie_warning_sec_info)); + ie->value.choice.Warning_Security_Information.size = sizeof(ie_warning_sec_info); + memcpy(ie->value.choice.Warning_Security_Information.buf, ie_warning_sec_info, sizeof(ie_warning_sec_info)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + + /* static const long asn_VAL_10_SBcAP_id_Data_Coding_Scheme = 3; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(3, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Data_Coding_Scheme); + ie->value.choice.Data_Coding_Scheme.buf = MALLOC(sizeof(ie_dcs)); + ie->value.choice.Data_Coding_Scheme.size = sizeof(ie_dcs); + ie->value.choice.Data_Coding_Scheme.bits_unused = 0; + memcpy(ie->value.choice.Data_Coding_Scheme.buf, &ie_dcs, sizeof(ie_dcs)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + /* 3GPP TS 36.413 9.2.1.53 Warning Message Contents */ + /* static const long asn_VAL_11_SBcAP_id_Warning_Message_Content = 16; */ + ie = sbcap_alloc_Write_Replace_Warning_Request_IE(16, SBcAP_Criticality_ignore, + SBcAP_Write_Replace_Warning_Request_IEs__value_PR_Warning_Message_Content); + ie->value.choice.Warning_Message_Content.buf = MALLOC(sizeof(ie_warning_msg_content)); + ie->value.choice.Warning_Message_Content.size = 20; + memcpy(ie->value.choice.Warning_Message_Content.buf, ie_warning_msg_content, sizeof(ie_warning_msg_content)); + ASN_SEQUENCE_ADD(as_pdu, ie); + + msg = sbcap_encode(pdu); + ASN_STRUCT_FREE(asn_DEF_SBcAP_SBC_AP_PDU, pdu); + OSMO_ASSERT(msg); + + printf("Encoded message: %s\n", msgb_hexdump(msg)); + + msgb_free(msg); +} + +static void test_asn1c_dec(void) +{ + asn_dec_rval_t rval; + SBcAP_SBC_AP_PDU_t *pdu = sbcap_pdu_alloc(); + SBcAP_Write_Replace_Warning_Response_IEs_t* ie; + SBcAP_Message_Identifier_t* msg_id_ie; + SBcAP_Serial_Number_t* serial_nr_ie; + + printf("==== %s ====\n", __FUNCTION__); +/* +SBc Application Part + SBC-AP-PDU: successfulOutcome (1) + successfulOutcome + procedureCode: id-Write-Replace-Warning (0) + criticality: reject (0) + value + Write-Replace-Warning-Response + protocolIEs: 3 items + Item 0: id-Message-Identifier + ProtocolIE-Field + id: id-Message-Identifier (5) + criticality: reject (0) + value + Message-Identifier: Unknown (43) + Item 1: id-Serial-Number + ProtocolIE-Field + id: id-Serial-Number (11) + criticality: reject (0) + value + Serial-Number: 4170 [bit length 16, 0100 0001 0111 0000 decimal value 16752] + 01.. .... .... .... = Geographical Scope: Display mode normal, PLMN wide (1) + ..00 0001 0111 .... = Message Code: 23 + .... .... .... 0000 = Update Number: 0 + Item 2: id-Cause + ProtocolIE-Field + id: id-Cause (1) + criticality: reject (0) + value + Cause: message-accepted (0) +*/ + uint8_t write_replace_warning_resp[] = { + 0x20, 0x00, 0x00, 0x14, 0x00, 0x00, 0x03, 0x00, 0x05, 0x00, 0x02, 0x00, + 0x2b, 0x00, 0x0b, 0x00, 0x02, 0x41, 0x70, 0x00, 0x01, 0x00, 0x01, 0x00 + }; + printf("Decoding message: %s\n", + osmo_hexdump(write_replace_warning_resp, sizeof(write_replace_warning_resp))); + rval = aper_decode_complete(NULL, &asn_DEF_SBcAP_SBC_AP_PDU, + (void**)&pdu, write_replace_warning_resp, sizeof(write_replace_warning_resp)); + OSMO_ASSERT(rval.code == RC_OK); + OSMO_ASSERT(pdu); + + OSMO_ASSERT(pdu->present = SBcAP_SBC_AP_PDU_PR_successfulOutcome); + OSMO_ASSERT(pdu->choice.successfulOutcome.procedureCode == SBcAP_ProcedureId_Write_Replace_Warning); + OSMO_ASSERT(pdu->choice.successfulOutcome.criticality == SBcAP_Criticality_reject); + + A_SEQUENCE_OF(void) *as_pdu = NULL; + as_pdu = (void*)&pdu->choice.successfulOutcome.value.choice.Write_Replace_Warning_Response.protocolIEs.list; + OSMO_ASSERT(as_pdu); + OSMO_ASSERT(as_pdu->count == 3); + + /* Message-Identifier: */ + ie = ((SBcAP_Write_Replace_Warning_Response_IEs_t*)(as_pdu->array[0])); + OSMO_ASSERT(ie); + OSMO_ASSERT(ie->id == 5); + OSMO_ASSERT(ie->criticality == 0); + OSMO_ASSERT(ie->value.present == SBcAP_Write_Replace_Warning_Response_IEs__value_PR_Message_Identifier); + msg_id_ie = &ie->value.choice.Message_Identifier; + OSMO_ASSERT(msg_id_ie->size == 2); + OSMO_ASSERT(osmo_load16be(msg_id_ie->buf) == 43); + + /* Serial-Number: */ + ie = ((SBcAP_Write_Replace_Warning_Response_IEs_t*)(as_pdu->array[1])); + OSMO_ASSERT(ie); + OSMO_ASSERT(ie->id == 11); + OSMO_ASSERT(ie->criticality == 0); + OSMO_ASSERT(ie->value.present == SBcAP_Write_Replace_Warning_Response_IEs__value_PR_Serial_Number); + serial_nr_ie = &ie->value.choice.Serial_Number; + OSMO_ASSERT(serial_nr_ie->size == 2); + OSMO_ASSERT(serial_nr_ie->buf[0] == 0x41 && serial_nr_ie->buf[1] == 0x70); + + /* Cause: */ + ie = ((SBcAP_Write_Replace_Warning_Response_IEs_t*)(as_pdu->array[2])); + OSMO_ASSERT(ie); + OSMO_ASSERT(ie->id == 1); + OSMO_ASSERT(ie->criticality == 0); + OSMO_ASSERT(ie->value.present == SBcAP_Write_Replace_Warning_Response_IEs__value_PR_Cause); + OSMO_ASSERT(ie->value.choice.Cause == 0); + + sbcap_pdu_free(pdu); + printf("Decoded message successfuly\n"); +} + +static const struct log_info_cat log_categories[] = { + [0] = { + .name = "DSBcAP", + .description = "SBc Application Part (CBC-MME)", + .color = "\033[1;32m", + .enabled = 1, + .loglevel = LOGL_DEBUG, + }, +}; + +const struct log_info log_info = { + .cat = log_categories, + .num_cat = ARRAY_SIZE(log_categories), +}; + +int main(int argc, char **argv) +{ + void *ctx = talloc_named_const(NULL, 0, "mgcp_test"); + void *msgb_ctx = msgb_talloc_ctx_init(ctx, 0); + osmo_init_logging2(ctx, &log_info); + sbcap_set_log_area(0); + log_set_log_level(osmo_stderr_target, LOGL_DEBUG); + log_set_print_category_hex(osmo_stderr_target, 0); + log_set_print_category(osmo_stderr_target, 0); + log_set_print_filename2(osmo_stderr_target, LOG_FILENAME_NONE); + log_set_use_color(osmo_stderr_target, 0); + + test_asn1c_enc(); + test_asn1c_dec(); + + OSMO_ASSERT(talloc_total_size(msgb_ctx) == 0); + OSMO_ASSERT(talloc_total_blocks(msgb_ctx) == 1); + talloc_free(msgb_ctx); + printf("Done\n"); + return EXIT_SUCCESS; +} diff --git a/tests/sbcap/sbcap_test.ok b/tests/sbcap/sbcap_test.ok new file mode 100644 index 0000000..ee319ac --- /dev/null +++ b/tests/sbcap/sbcap_test.ok @@ -0,0 +1,6 @@ +==== test_asn1c_enc ==== +Encoded message: 00 00 00 76 00 00 08 00 05 00 02 ab 01 00 0b 00 02 ab cd 00 0a 00 02 00 1e 00 07 00 02 00 59 00 12 40 02 81 01 00 11 40 32 30 40 12 23 45 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 03 40 01 02 00 10 40 16 00 13 30 40 12 23 45 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 +==== test_asn1c_dec ==== +Decoding message: 20 00 00 14 00 00 03 00 05 00 02 00 2b 00 0b 00 02 41 70 00 01 00 01 00 +Decoded message successfuly +Done diff --git a/tests/testsuite.at b/tests/testsuite.at new file mode 100644 index 0000000..8484980 --- /dev/null +++ b/tests/testsuite.at @@ -0,0 +1,8 @@ +AT_INIT +AT_BANNER([Regression tests.]) + +AT_SETUP([sbcap]) +AT_KEYWORDS([sbcap]) +cat $abs_srcdir/sbcap/sbcap_test.ok > expout +AT_CHECK([$abs_top_builddir/tests/sbcap/sbcap_test], [], [expout], [ignore]) +AT_CLEANUP -- To view, visit https://gerrit.osmocom.org/c/osmo-cbc/+/28601 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-cbc Gerrit-Branch: master Gerrit-Change-Id: I5a26d008b7282da637c3781ae77435c6a69cf65d Gerrit-Change-Number: 28601 Gerrit-PatchSet: 1 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newchange

2 years, 11 months

Change in pysim[master]: pySim/ts_102_222.py: remove ununsed imports from 'cmd2'

by pespin

Attention is currently required from: fixeria. pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/pysim/+/28599 ) Change subject: pySim/ts_102_222.py: remove ununsed imports from 'cmd2' ...................................................................... Patch Set 1: Code-Review+1 -- To view, visit https://gerrit.osmocom.org/c/pysim/+/28599 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: pysim Gerrit-Branch: master Gerrit-Change-Id: If6c686c8248cd0ad4edb68b84886a6f5f558d0f7 Gerrit-Change-Number: 28599 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-CC: Jenkins Builder Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Comment-Date: Thu, 14 Jul 2022 12:16:08 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes Gerrit-MessageType: comment

2 years, 11 months

Change in pysim[master]: pySim-shell.py: remove unused imports of 'bg' from 'cmd2'

by pespin

Attention is currently required from: fixeria. pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/pysim/+/28598 ) Change subject: pySim-shell.py: remove unused imports of 'bg' from 'cmd2' ...................................................................... Patch Set 3: Code-Review+1 -- To view, visit https://gerrit.osmocom.org/c/pysim/+/28598 To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: pysim Gerrit-Branch: master Gerrit-Change-Id: Ic2a73a98f322be391e54215bc5fc3358776da0ae Gerrit-Change-Number: 28598 Gerrit-PatchSet: 3 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Comment-Date: Thu, 14 Jul 2022 12:16:05 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes Gerrit-MessageType: comment

2 years, 11 months

Jump to page:

2025

2024

2023

2022

gerrit-log July 2022