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

[M] Change in osmo-ttcn3-hacks[master]: sgsn: TC_sgsn_context_req_in: match PDP Context IE

by fixeria

fixeria has uploaded this change for review. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36601?usp=email ) Change subject: sgsn: TC_sgsn_context_req_in: match PDP Context IE ...................................................................... sgsn: TC_sgsn_context_req_in: match PDP Context IE Change-Id: I965c0200ea380c55dc0cd8d3f8e5110883ce2646 Related: SYS#6603, OS#6294 --- M library/GTPv1C_Templates.ttcn M sgsn/SGSN_Tests.ttcn 2 files changed, 82 insertions(+), 7 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/01/36601/1 diff --git a/library/GTPv1C_Templates.ttcn b/library/GTPv1C_Templates.ttcn index 2eb1d7e..ecc84ad 100644 --- a/library/GTPv1C_Templates.ttcn +++ b/library/GTPv1C_Templates.ttcn @@ -464,6 +464,51 @@ pdp_addresslength2 := omit, pdp_Address2 := omit } + template (present) PDP_Context_GTPC tr_PDP_Context_GTPC(template (present) octetstring pdp_addr := ?, + template (present) octetstring ggsn_gsn_addr := ?, + template (present) octetstring apn := ?, + template (present) OCT4 ggsn_teic := ?, + template (present) OCT4 ggsn_teid := ?) := { + type_gtpc := '82'O, + lengthf := ?, /* overwritten */ + nsapi := ?, + order := ?, + asi := ?, + vaa := ?, + ea := ?, + sapi := ?, + spare1 := ?, + qos_subLength := ?, /* overwritten */ + qos_sub := ?, + qos_reqLength := ?, /* overwritten */ + qos_req := ?, + qos_negLength := ?, /* overwritten */ + qos_neg := ?, + snd := ?, + snu := ?, + sendNPDUnum := ?, + receiveNPDUnum := ?, + uteidControlPlane := ggsn_teic, + uteidData1 := ggsn_teid, + pdpcontext := ?, + pdp_typeorg := ?, + spare2 := ?, + pdp_typenum := ?, + pdp_addressLength := ?, /* overwritten */ + pdp_address := pdp_addr, + ggsn_addressControlPlaneLength := ?, /* overwritten */ + ggsn_addressControlPlane := ggsn_gsn_addr, + ggsn_addressUserPlaneLength := ?, /* overwritten */ + ggsn_addressUserPlane := ggsn_gsn_addr, + apnLength := ?, /* overwritten */ + apn := apn, + transactionId := ?, + spare3 := ?, + transactionID_cont := ?, + pdp_typenum2 := *, + pdp_addresslength2 := *, + pdp_Address2 := * + } /* template matching reception of GTP-C unit-data */ @@ -1280,7 +1325,9 @@ /* SGSN Context Response - 7.5.4 */ template (present) GTPC_PDUs tr_SGSNContextRespPDU(template (present) GTP_Cause cause := ?, - template hexstring imsi := *) := { + template hexstring imsi := *, + template MM_Context mm_context := *, + template PDP_Context_GTPC_List pdp_ctx_list := *) := { sgsn_ContextResponse := { cause := tr_Cause_gtpc(cause), imsi := f_tr_Imsi(imsi), @@ -1290,8 +1337,8 @@ radioPriority := *, packetFlowID := *, charging_char := *, - mm_Context := *, - pdp_Context := *, + mm_Context := mm_context, + pdp_Context := pdp_ctx_list, sgsn_addr_controlPlane := *, pdpContextPriorization := *, radioPriority_LCS := *, diff --git a/sgsn/SGSN_Tests.ttcn b/sgsn/SGSN_Tests.ttcn index da1511b..6d7079e 100644 --- a/sgsn/SGSN_Tests.ttcn +++ b/sgsn/SGSN_Tests.ttcn @@ -3730,6 +3730,7 @@ /* SGSN terminated SGSN Context Request procedure (we request, SGSN responds) * 3GPP TS 23.401, Figure D.3.6-1: "Gn/Gp SGSN to MME Tracking Area Update procedure" */ private function f_TC_sgsn_context_req_in(charstring id) runs on BSSGP_ConnHdlr { + var PdpActPars apars := valueof(t_PdpActPars(mp_ggsn_ip)); var integer seq_nr := f_rnd_int(65535); var Gtp1cUnitdata gtpc_ud; timer T; @@ -3742,6 +3743,8 @@ /* The MS attaches to GERAN/UTRAN and enjoys the service */ f_gmm_attach(false, false); + /* The MS activates a PDP context */ + f_pdp_ctx_act(apars); /* The MS switches to an LTE cell and performs Tracking Area Update Request there. * The MME requests information about the MS by sending SGSN Context Request. */ @@ -3753,14 +3756,25 @@ ptmsi_sig := ts_PTMSI_sig('010203'O)); GTP.send(ts_GTPC_SGSNContextReq(peer, seq_nr, ctx_req)); + /* Expected PDP Context parameters */ + var template (present) PDP_Context_GTPC pdp_ctx; + pdp_ctx := tr_PDP_Context_GTPC(ggsn_gsn_addr := f_inet_addr(mp_ggsn_ip), + apn := ''O); + pdp_ctx.pdp_typeorg := apars.addr.pdpTypeOrg; + pdp_ctx.pdp_typenum := apars.addr.pdpTypeNum; + pdp_ctx.pdp_address := ''O; /* omit in t_AddrIPv4dyn */ + pdp_ctx.nsapi := apars.nsapi; + pdp_ctx.sapi := apars.sapi; + /* The SGSN responds with subscriber's IMSI */ var template (present) GTPC_PDUs ctx_rsp; ctx_rsp := tr_SGSNContextRespPDU(cause := GTP_CAUSE_REQUEST_ACCEPTED, - imsi := g_pars.imsi); + imsi := g_pars.imsi, + pdp_ctx_list := { pdp_ctx }); /* SGSN Address for Control Plane */ var octetstring sgsn_addr := f_inet_addr(mp_sgsn_gtp_ip); - ctx_rsp.sgsn_ContextResponse.sgsn_addr_controlPlane := tr_GsnAddr(mp_sgsn_gtp_ip); + ctx_rsp.sgsn_ContextResponse.sgsn_addr_controlPlane := tr_GsnAddr(sgsn_addr); /* Match MM Context */ if (ispresent(g_pars.vec)) { @@ -3772,8 +3786,6 @@ * See also 3GPP TS 29.060, section 7.7.28 and Table 47A */ } - /* TODO: match PDP Context */ - T.start(2.0); alt { [] GTP.receive(tr_GTPC_SGSNContextResp(?, ?, ctx_rsp)) -> value gtpc_ud { @@ -3793,6 +3805,12 @@ /* HLR/HSS tells SGSN to forget this MS/UE */ GSUP.send(ts_GSUP_CL_REQ(g_pars.imsi, OSMO_GSUP_CANCEL_TYPE_UPDATE)); GSUP.receive(tr_GSUP_CL_RES(g_pars.imsi)); + + /* SGSN deletes the PDP context at GGSN */ + GTP.receive(tr_GTPC_MsgType(?, deletePDPContextRequest, apars.ggsn_tei_c)) -> value gtpc_ud { + seq_nr := oct2int(gtpc_ud.gtpc.opt_part.sequenceNumber); + GTP.send(ts_GTPC_DeletePdpResp(gtpc_ud.peer, seq_nr, apars.sgsn_tei_c, '7F'O)); + } } testcase TC_sgsn_context_req_in() runs on test_CT { var BSSGP_ConnHdlr vc_conn; -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36601?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I965c0200ea380c55dc0cd8d3f8e5110883ce2646 Gerrit-Change-Number: 36601 Gerrit-PatchSet: 1 Gerrit-Owner: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-MessageType: newchange

1 year, 2 months

1
0
0 0

[S] Change in osmo-ttcn3-hacks[master]: SIP_Templates: Make tag collisions harder

by pespin

Attention is currently required from: pespin. Hello Jenkins Builder, I'd like you to reexamine a change. Please visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36597?usp=email to look at the new patch set (#3). The following approvals got outdated and were removed: Verified-1 by Jenkins Builder Change subject: SIP_Templates: Make tag collisions harder ...................................................................... SIP_Templates: Make tag collisions harder It was spotted during some test runs that the same tag was assigned to 2 different components. Let's make this way more difficult by adding some time to it. Asterisk uses longer strings for instance, since 32bits is the minimum. Change-Id: Iba26259fd48da1c2558451fe5f7014151d4935c8 --- M asterisk/gen_links.sh M asterisk/regen_makefile.sh M library/SIP_Templates.ttcn M sip/gen_links.sh M sip/regen_makefile.sh 5 files changed, 23 insertions(+), 2 deletions(-) git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/97/36597/3 -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36597?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: Iba26259fd48da1c2558451fe5f7014151d4935c8 Gerrit-Change-Number: 36597 Gerrit-PatchSet: 3 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: newpatchset

1 year, 2 months

1
0
0 0

[S] Change in docker-playground[master]: ttcn3-hnbgw: Apply latest changes to 'with-pfcp' scenario

by fixeria

fixeria has submitted this change. ( https://gerrit.osmocom.org/c/docker-playground/+/36590?usp=email ) Change subject: ttcn3-hnbgw: Apply latest changes to 'with-pfcp' scenario ...................................................................... ttcn3-hnbgw: Apply latest changes to 'with-pfcp' scenario Recent commits applied changes to the default scenario, but forgot to apply them to the 'with-pfcp' subdir. Fixes: 6de89a5fb529928ce9b7b3320e0ca2e3e568d458 Fixes: 3736d31fc0314cb5d39c707374eecdcfe33241c9 Fixes: 0bdbcd6815358a7b1c4b0bb4575a585c45a01e57 Fixes: 2c22a96355b8e057dbd85ac1922ae84cc63f8b1e Fixes: d3711e67103691171d7ed3e224c050e78c1f5bc4 Change-Id: Ie02a0754a6ca985e60e08f1f171f532b6cc16264 --- M ttcn3-hnbgw-test/with-pfcp/HNBGW_Tests.cfg M ttcn3-hnbgw-test/with-pfcp/osmo-hnbgw.cfg 2 files changed, 35 insertions(+), 4 deletions(-) Approvals: osmith: Looks good to me, but someone else must approve fixeria: Looks good to me, approved Jenkins Builder: Verified diff --git a/ttcn3-hnbgw-test/with-pfcp/HNBGW_Tests.cfg b/ttcn3-hnbgw-test/with-pfcp/HNBGW_Tests.cfg index 16173de..ac6141f 100644 --- a/ttcn3-hnbgw-test/with-pfcp/HNBGW_Tests.cfg +++ b/ttcn3-hnbgw-test/with-pfcp/HNBGW_Tests.cfg @@ -11,11 +11,13 @@ [TESTPORT_PARAMETERS] *.HNBGWVTY.CTRL_HOSTNAME := "172.18.35.20" +*.STATSVTY.CTRL_HOSTNAME := "172.18.35.20" [MODULE_PARAMETERS] HNBGW_Tests.mp_hnodeb_ip := "172.18.35.203"; HNBGW_Tests.mp_hnbgw_ip := "172.18.35.20"; HNBGW_Tests.mp_mgw_ip := "172.18.35.203"; +HNBGW_Tests.mp_local_statsd_ip := "172.18.35.203"; HNBGW_Tests.mp_cn_cfg := { { transport := RANAP_TRANSPORT_IuCS, @@ -114,6 +116,8 @@ HNBGW_Tests.mp_pfcp_ip_local := "172.18.35.203"; HNBGW_Tests.mp_pfcp_ip_remote := "172.18.35.20"; HNBGW_Tests.mp_validate_talloc_asn1 := true; +# keep in sync with osmo-hnbgw.cfg "timer hnbgw x31": +HNBGW_Tests.mp_hnbgw_timer_x31 := 5; [MAIN_CONTROLLER] diff --git a/ttcn3-hnbgw-test/with-pfcp/osmo-hnbgw.cfg b/ttcn3-hnbgw-test/with-pfcp/osmo-hnbgw.cfg index d10ea6d..50ac7bf 100644 --- a/ttcn3-hnbgw-test/with-pfcp/osmo-hnbgw.cfg +++ b/ttcn3-hnbgw-test/with-pfcp/osmo-hnbgw.cfg @@ -8,7 +8,7 @@ ! log stderr logging filter all 1 - logging color 0 + logging color 1 logging print category-hex 0 logging print category 1 logging print level 1 @@ -19,10 +19,20 @@ ! line vty no login - bind 0.0.0.0 + bind 172.18.35.20 ctrl - bind 0.0.0.0 + bind 172.18.35.20 ! +stats interval 0 +stats reporter statsd + prefix TTCN3 + level subscriber + remote-ip 172.18.35.203 + remote-port 8125 + flush-period 1 + mtu 1024 + enable + cs7 instance 0 asp asp-clnt-msc-0 2905 2905 m3ua local-ip 172.18.35.20 @@ -68,7 +78,7 @@ local-ip 172.18.35.20 local-port 29169 hnbap-allow-tmsi 1 - mgcp + mgw 0 mgw local-ip 172.18.35.20 mgw remote-ip 172.18.35.203 # don't spam RANAP RESET messages for up to eight CN links across all tests -- To view, visit https://gerrit.osmocom.org/c/docker-playground/+/36590?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: docker-playground Gerrit-Branch: master Gerrit-Change-Id: Ie02a0754a6ca985e60e08f1f171f532b6cc16264 Gerrit-Change-Number: 36590 Gerrit-PatchSet: 3 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: daniel <daniel(a)totalueberwachung.de> Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: neels <nhofmeyr(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-MessageType: merged

1 year, 2 months

1
0
0 0

[S] Change in docker-playground[master]: ttcn3-hnbgw: Apply latest changes to 'with-pfcp' scenario

by fixeria

Attention is currently required from: daniel, neels, pespin. fixeria has posted comments on this change. ( https://gerrit.osmocom.org/c/docker-playground/+/36590?usp=email ) Change subject: ttcn3-hnbgw: Apply latest changes to 'with-pfcp' scenario ...................................................................... Patch Set 2: Code-Review+2 -- To view, visit https://gerrit.osmocom.org/c/docker-playground/+/36590?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: docker-playground Gerrit-Branch: master Gerrit-Change-Id: Ie02a0754a6ca985e60e08f1f171f532b6cc16264 Gerrit-Change-Number: 36590 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: daniel <daniel(a)totalueberwachung.de> Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: neels <nhofmeyr(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Attention: neels <nhofmeyr(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Attention: daniel <daniel(a)totalueberwachung.de> Gerrit-Comment-Date: Thu, 18 Apr 2024 18:07:15 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes Gerrit-MessageType: comment

1 year, 2 months

1
0
0 0

[M] Change in osmo-bsc[master]: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for...

by fixeria

Attention is currently required from: pespin. fixeria has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email ) Change subject: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for new API param ...................................................................... Patch Set 2: Code-Review+1 -- To view, visit https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-bsc Gerrit-Branch: master Gerrit-Change-Id: I4cce5cb6ca98bc28a67dd6e927e9cdfd2312851a Gerrit-Change-Number: 36576 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Thu, 18 Apr 2024 18:05:50 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes Gerrit-MessageType: comment

1 year, 2 months

1
0
0 0

[M] Change in osmo-bsc[master]: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for...

by pespin

pespin has submitted this change. ( https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email ) Change subject: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for new API param ...................................................................... cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for new API param libosmo-netif (not yet released) stream_{cli,srv} osmo_io read_cb API was updated to provide read result status. Hence, now API users can account for lower layer errors and act properly, like it used to do with the previous ofd backend. This commit partially reverts some error code paths removed in 85687bf176e4b9663f2396a27c28b49221c72fa3 when converting code to use osmo_io osmo_stream backend. Change-Id: I4cce5cb6ca98bc28a67dd6e927e9cdfd2312851a Depends: libosmo-netif.git Change-Id I395c75ff1e9904757ce1d767a9ac2f779593c4c8 --- M src/osmo-bsc/cbsp_link.c 1 file changed, 54 insertions(+), 2 deletions(-) Approvals: Jenkins Builder: Verified pespin: Looks good to me, approved diff --git a/src/osmo-bsc/cbsp_link.c b/src/osmo-bsc/cbsp_link.c index 98f25d3..9e17ef3 100644 --- a/src/osmo-bsc/cbsp_link.c +++ b/src/osmo-bsc/cbsp_link.c @@ -62,11 +62,28 @@ return 0; } -static int cbsp_srv_read_cb(struct osmo_stream_srv *conn, struct msgb *msg) +static int cbsp_srv_read_cb(struct osmo_stream_srv *conn, int res, struct msgb *msg) { struct bsc_cbc_link *cbc = osmo_stream_srv_get_data(conn); struct osmo_cbsp_decoded *decoded; + if (res <= 0) { + if (res == -EAGAIN || res == -EINTR) { + msgb_free(msg); + return 0; + } + /* + if (rc == -EPIPE || rc == -ECONNRESET) { + // lost connection + } else if (rc == 0) { + // connection closed + } */ + msgb_free(msg); + osmo_stream_srv_destroy(conn); + cbc->server.srv = NULL; + return -EBADF; + } + OSMO_ASSERT(msg); decoded = osmo_cbsp_decode(conn, msg); if (decoded) { @@ -148,11 +165,27 @@ return 0; } -static int cbsp_client_read_cb(struct osmo_stream_cli *cli, struct msgb *msg) +static int cbsp_client_read_cb(struct osmo_stream_cli *cli, int res, struct msgb *msg) { struct bsc_cbc_link *cbc = osmo_stream_cli_get_data(cli); struct osmo_cbsp_decoded *decoded; + if (res <= 0) { + if (res == -EAGAIN || res == -EINTR) { + msgb_free(msg); + return 0; + } + /* + if (rc == -EPIPE || rc == -ECONNRESET) { + // lost connection + } else if (rc == 0) { + // connection closed + } */ + msgb_free(msg); + osmo_stream_cli_reconnect(cli); + return -EBADF; + } + OSMO_ASSERT(msg); decoded = osmo_cbsp_decode(cli, msg); if (decoded) { -- To view, visit https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-bsc Gerrit-Branch: master Gerrit-Change-Id: I4cce5cb6ca98bc28a67dd6e927e9cdfd2312851a Gerrit-Change-Number: 36576 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: merged

1 year, 2 months

1
0
0 0

[M] Change in osmo-bsc[master]: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for...

by pespin

Attention is currently required from: fixeria, osmith. pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email ) Change subject: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for new API param ...................................................................... Patch Set 2: Code-Review+2 -- To view, visit https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-bsc Gerrit-Branch: master Gerrit-Change-Id: I4cce5cb6ca98bc28a67dd6e927e9cdfd2312851a Gerrit-Change-Number: 36576 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: osmith <osmith(a)sysmocom.de> Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Comment-Date: Thu, 18 Apr 2024 18:05:33 +0000 Gerrit-HasComments: No Gerrit-Has-Labels: Yes Gerrit-MessageType: comment

1 year, 2 months

1
0
0 0

[M] Change in osmo-bsc[master]: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for...

by pespin

Attention is currently required from: fixeria, osmith. pespin has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email ) Change subject: cbsp_link.c: Update somo_stream read_cb2 functions to accommodate for new API param ...................................................................... Patch Set 2: (1 comment) Patchset: PS2: It seems I somehow forgot to push the new version of the patch here in gerrit. I'm merging it now in order to avoid build failures. Please give it a review and if something's wrong I can fix it. -- To view, visit https://gerrit.osmocom.org/c/osmo-bsc/+/36576?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-bsc Gerrit-Branch: master Gerrit-Change-Id: I4cce5cb6ca98bc28a67dd6e927e9cdfd2312851a Gerrit-Change-Number: 36576 Gerrit-PatchSet: 2 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Attention: osmith <osmith(a)sysmocom.de> Gerrit-Attention: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Comment-Date: Thu, 18 Apr 2024 18:04:43 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: No Gerrit-MessageType: comment

1 year, 2 months

1
0
0 0

[XL] Change in osmo-ttcn3-hacks[master]: asterisk: Split SIPConnHdlr to its own file

by pespin

pespin has submitted this change. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36596?usp=email ) Change subject: asterisk: Split SIPConnHdlr to its own file ...................................................................... asterisk: Split SIPConnHdlr to its own file Change-Id: I168920887bfd05c0a1785c5cb7ac485edaef0df2 --- M asterisk/Asterisk_Tests.ttcn A asterisk/SIP_ConnectionHandler.ttcn 2 files changed, 741 insertions(+), 691 deletions(-) Approvals: Jenkins Builder: Verified fixeria: Looks good to me, approved diff --git a/asterisk/Asterisk_Tests.ttcn b/asterisk/Asterisk_Tests.ttcn index c883bac..b164ee5 100644 --- a/asterisk/Asterisk_Tests.ttcn +++ b/asterisk/Asterisk_Tests.ttcn @@ -26,6 +26,8 @@ import from SIPmsg_Types all; import from SIP_Templates all; +import from SIP_ConnectionHandler all; + modulepar { charstring mp_local_sip_host := "127.0.0.2"; integer mp_local_sip_port := 5060; @@ -37,135 +39,25 @@ charstring mp_ami_secret := "1234"; } -type port Coord_PT message -{ - inout charstring; -} with { extension "internal" }; -private const charstring COORD_CMD_REGISTERED := "COORD_CMD_REGISTERED"; -private const charstring COORD_CMD_START := "COORD_CMD_START"; -private const charstring COORD_CMD_PICKUP := "COORD_CMD_PICKUP"; -private const charstring COORD_CMD_CALL_ESTABLISHED := "COORD_CMD_CALL_ESTABLISHED"; -private const charstring COORD_CMD_CALL_CANCELLED := "COORD_CMD_CALL_CANCELLED"; -private const charstring COORD_CMD_HANGUP := "COORD_CMD_HANGUP"; - type component test_CT { var SIP_Emulation_CT vc_SIP; port TELNETasp_PT AMI; port Coord_PT COORD; } -type component ConnHdlr extends SIP_ConnHdlr { - var charstring g_name; - var ConnHdlrPars g_pars; - timer g_Tguard; - var PDU_SIP_Request g_rx_sip_req; - var PDU_SIP_Response g_rx_sip_resp; - - port Coord_PT COORD; -} -type record of ConnHdlr ConnHdlrList; - const charstring broadcast_sip_extension := "0500"; -type record ConnHdlrPars { - float t_guard, - charstring user, - charstring display_name, - charstring password, - SipUrl registrar_sip_req_uri, - SipAddr registrar_sip_record, - CallidString registrar_sip_call_id, - integer registrar_sip_seq_nr, - Via local_via, - SipUrl local_sip_url_ext, - SipAddr local_sip_record, - Contact local_contact, - CallPars cp optional -} -type record of ConnHdlrPars ConnHdlrParsList; - -template (value) ConnHdlrPars t_Pars(charstring user, - charstring display_name := "Anonymous", - charstring password := "secret", - template (value) CallPars cp := t_CallPars()) := { - t_guard := 30.0, - user := user, - display_name := f_sip_str_quote(display_name), - password := password, - registrar_sip_req_uri := valueof(ts_SipUrlHost(mp_remote_sip_host)), - registrar_sip_record := ts_SipAddr(ts_HostPort(mp_remote_sip_host), - ts_UserInfo(user), - f_sip_str_quote(display_name)), - registrar_sip_call_id := hex2str(f_rnd_hexstring(15)) & "@" & mp_local_sip_host, - registrar_sip_seq_nr := f_sip_rand_seq_nr(), - local_via := ts_Via_from(ts_HostPort(mp_local_sip_host, mp_local_sip_port)), - local_sip_url_ext := ts_SipUrl(ts_HostPort(mp_local_sip_host, mp_local_sip_port), - ts_UserInfo(user)), - local_sip_record := ts_SipAddr(ts_HostPort(mp_local_sip_host), - ts_UserInfo(user)), - local_contact := valueof(ts_Contact({ - ts_ContactAddress( - ts_Addr_Union_SipUrl(ts_SipUrl(ts_HostPort( - mp_local_sip_host, - mp_local_sip_port), - ts_UserInfo(user))), - omit) - })), - cp := cp -} - -function f_init_ConnHdlrPars(integer idx := 1) runs on test_CT return ConnHdlrPars { - var template (value) CallPars cp := t_CallPars(idx := idx); - var template (value) ConnHdlrPars pars := t_Pars("0" & int2str(str2int(broadcast_sip_extension) + idx), - cp := cp); +function f_init_ConnHdlrPars(integer idx := 1) runs on test_CT return SIPConnHdlrPars { + var template (value) CallPars cp := t_CallPars(mp_local_sip_host, 1234 + 2*idx); + var template (value) SIPConnHdlrPars pars := t_Pars(mp_local_sip_host, + mp_local_sip_port, + mp_remote_sip_host, + mp_remote_sip_port, + "0" & int2str(str2int(broadcast_sip_extension) + idx), + cp := cp); return valueof(pars); } -type record CallParsMT { - /* Whether to wait for COORD.receive(COORD_CMD_PICKUP) before accepting the call. */ - boolean wait_coord_cmd_pickup, - /* Whether to expect CANCEL instead of ACK as answer to our OK */ - boolean exp_cancel -} -private template (value) CallParsMT t_CallParsMT := { - wait_coord_cmd_pickup := false, - exp_cancel := false -} - -type record CallPars { - SipAddr calling optional, - SipAddr called optional, - - SipAddr from_addr optional, - SipAddr to_addr optional, - - CallidString sip_call_id, - integer sip_seq_nr, - charstring sip_body optional, - - charstring local_rtp_addr, - uint16_t local_rtp_port, - - SDP_Message peer_sdp optional, - CallParsMT mt -} - -private template (value) CallPars t_CallPars(integer idx := 1, - template (omit) SipAddr calling := omit, - template (omit) SipAddr called := omit) := { - calling := calling, - called := called, - from_addr := omit, - to_addr := omit, - sip_call_id := hex2str(f_rnd_hexstring(15)), - sip_seq_nr := f_sip_rand_seq_nr(), - sip_body := omit, - local_rtp_addr := mp_local_sip_host, - local_rtp_port := 1234 + 2*idx, - peer_sdp := omit, - mt := t_CallParsMT -} - /* Initialize connection towards Asterisk AMI */ private function f_init_ami() runs on test_CT { map(self:AMI, system:AMI); @@ -178,14 +70,12 @@ log("end of f_init"); } -type function void_fn(charstring id) runs on ConnHdlr; - -function f_start_handler(void_fn fn, ConnHdlrPars pars) -runs on test_CT return ConnHdlr { - var ConnHdlr vc_conn; +function f_start_handler(void_fn fn, SIPConnHdlrPars pars) +runs on test_CT return SIPConnHdlr { + var SIPConnHdlr vc_conn; var charstring id := testcasename() & "-ConnHdlr-" & pars.user; - vc_conn := ConnHdlr.create(id) alive; + vc_conn := SIPConnHdlr.create(id) alive; connect(vc_conn:SIP, vc_SIP:CLIENT); connect(vc_conn:SIP_PROC, vc_SIP:CLIENT_PROC); @@ -196,572 +86,16 @@ return vc_conn; } -private altstep as_Tguard() runs on ConnHdlr { - [] g_Tguard.timeout { - setverdict(fail, "Tguard timeout"); - mtc.stop; - } -} - -private function f_handler_init(void_fn fn, charstring id, ConnHdlrPars pars) -runs on ConnHdlr { - g_name := id; - g_pars := pars; - g_Tguard.start(pars.t_guard); - activate(as_Tguard()); - - // Make sure the UA is deregistered before starting the test: - // sends REGISTER with Contact = "*" and Expires = 0 - //f_SIP_deregister(); - - /* call the user-supied test case function */ - fn.apply(id); -} - -private altstep as_SIP_fail_req(charstring exp_msg_str := "") runs on ConnHdlr -{ - var PDU_SIP_Request sip_req; - [] SIP.receive(PDU_SIP_Request:?) -> value sip_req { - Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, - log2str(g_name & ": Received unexpected SIP Req message := ", sip_req, "\nvs exp := ", exp_msg_str)); - } -} - -private altstep as_SIP_fail_resp(charstring exp_msg_str := "") runs on ConnHdlr -{ - var PDU_SIP_Response sip_resp; - [] SIP.receive(PDU_SIP_Response:?) -> value sip_resp { - Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, - log2str(g_name & ": Received unexpected SIP Resp message := ", sip_resp, "\nvs exp := ", exp_msg_str)); - } -} - -altstep as_SIP_expect_req(template (present) PDU_SIP_Request sip_expect, boolean fail_others := true) runs on ConnHdlr -{ - var charstring sip_expect_str := log2str(sip_expect); - [] SIP.receive(sip_expect) -> value g_rx_sip_req; - [fail_others] as_SIP_fail_req(sip_expect_str); - [fail_others] as_SIP_fail_resp(sip_expect_str); -} - -altstep as_SIP_expect_resp(template (present) PDU_SIP_Response sip_expect, boolean fail_others := true) runs on ConnHdlr -{ - var charstring sip_expect_str := log2str(sip_expect); - [] SIP.receive(sip_expect) -> value g_rx_sip_resp; - [fail_others] as_SIP_fail_resp(sip_expect_str); - [fail_others] as_SIP_fail_req(sip_expect_str); -} - -altstep as_SIP_ignore_resp(template PDU_SIP_Response sip_expect := ?) runs on ConnHdlr -{ - [] SIP.receive(sip_expect) -> value g_rx_sip_resp { - log("Ignoring ", g_rx_sip_resp); - repeat; - } -} - -private function f_tr_Via_response(Via via_req) return template (present) Via { - template (present) SemicolonParam_List via_resp_params := ?; - - /*via_resp_params := { - { id := "rport", paramValue := int2str(mp_remote_sip_port) }, - { id := "received", paramValue := mp_remote_sip_host } - }; */ - return tr_Via_from(via_req.viaBody[0].sentBy, - via_resp_params); -} - -private function f_tr_To_response(template (value) SipAddr to_req) return template (present) SipAddr { - return tr_SipAddr_from_val(to_req); -} - -private function f_tr_From(template (value) SipAddr from_req) return template (present) SipAddr { - return tr_SipAddr_from_val(from_req); -} - -private function f_gen_sdp() runs on ConnHdlr return charstring { - var charstring sdp := - "v=0\r\n" & - "o=0502 2390 1824 IN IP4 " & g_pars.cp.local_rtp_addr & "\r\n" & - "s=Talk\r\n" & - "c=IN IP4 " & g_pars.cp.local_rtp_addr & "\r\n" & - "t=0 0\r\n" & - "a=rtcp-xr:rcvr-rtt=all:10000 stat-summary=loss,dup,jitt,TTL voip-metrics\r\n" & - "a=record:off\r\n" & - "m=audio " & int2str(g_pars.cp.local_rtp_port) & " RTP/AVP 96 97 98 0 8 18 99 100 101\r\n" & - "a=rtpmap:96 opus/48000/2\r\n" & - "a=fmtp:96 useinbandfec=1\r\n" & - "a=rtpmap:97 speex/16000\r\n" & - "a=fmtp:97 vbr=on\r\n" & - "a=rtpmap:98 speex/8000\r\n" & - "a=fmtp:98 vbr=on\r\n" & - "a=fmtp:18 annexb=yes\r\n" & - "a=rtpmap:99 telephone-event/48000\r\n" & - "a=rtpmap:100 telephone-event/16000\r\n" & - "a=rtpmap:101 telephone-event/8000\r\n" & - "a=rtcp:" & int2str(g_pars.cp.local_rtp_port + 1) & "\r\n" & - "a=rtcp-fb:* trr-int 1000\r\n" & - "a=rtcp-fb:* ccm tmmbr\r\n"; - return sdp; -} - -private function f_SIP_register() runs on ConnHdlr return PDU_SIP_Response -{ - var template (present) PDU_SIP_Response exp; - var Authorization authorization; - var Via via := g_pars.local_via; - var SipAddr from_sipaddr := g_pars.registrar_sip_record; - var charstring branch_value; - - branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.registrar_sip_record), - f_sip_SipAddr_to_str(g_pars.registrar_sip_record), - g_pars.registrar_sip_call_id, - g_pars.registrar_sip_seq_nr); - - via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); - from_sipaddr.params := f_sip_param_set(from_sipaddr.params, "tag", f_sip_rand_tag()); - SIP.send(ts_SIP_REGISTER(g_pars.registrar_sip_req_uri, - g_pars.registrar_sip_call_id, - from_sipaddr, - g_pars.registrar_sip_record, - via, - g_pars.registrar_sip_seq_nr, - g_pars.local_contact, - ts_Expires("7200"))); - - exp := tr_SIP_Response_Unauthorized( - g_pars.registrar_sip_call_id, - from_sipaddr, - f_tr_To_response(g_pars.registrar_sip_record), - f_tr_Via_response(via), - *, - tr_WwwAuthenticate({tr_Challenge_digestCln(?)}), - g_pars.registrar_sip_seq_nr); - as_SIP_expect_resp(exp); - - /* Digest Auth: RFC 2617 */ - authorization := f_sip_digest_gen_Authorization(g_rx_sip_resp.msgHeader.wwwAuthenticate, - g_pars.user, g_pars.password, - "REGISTER", - f_sip_SipUrl_to_str(g_pars.registrar_sip_req_uri)) - - /* New transaction: */ - g_pars.registrar_sip_seq_nr := g_pars.registrar_sip_seq_nr + 1; - branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.registrar_sip_record), - f_sip_SipAddr_to_str(g_pars.registrar_sip_record), - g_pars.registrar_sip_call_id, - g_pars.registrar_sip_seq_nr); - via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); - - SIP.send(ts_SIP_REGISTER(g_pars.registrar_sip_req_uri, - g_pars.registrar_sip_call_id, - from_sipaddr, - g_pars.registrar_sip_record, - via, - g_pars.registrar_sip_seq_nr, - g_pars.local_contact, - ts_Expires("7200"), - authorization := authorization)); - - /* Wait for OK answer */ - exp := tr_SIP_Response( - g_pars.registrar_sip_call_id, - from_sipaddr, - f_tr_To_response(g_pars.registrar_sip_record), - f_tr_Via_response(via), - *, - "REGISTER", 200, - g_pars.registrar_sip_seq_nr, "OK"); - as_SIP_expect_resp(exp); - - /* Prepare for next use: */ - g_pars.registrar_sip_seq_nr := g_pars.registrar_sip_seq_nr + 1; - return g_rx_sip_resp; -} - -private function f_SIP_mo_call_setup() runs on ConnHdlr -{ - var template (value) PDU_SIP_Request req; - var template (present) PDU_SIP_Response exp; - var Via via; - var charstring tx_sdp := f_gen_sdp(); - var default d_trying, d_ringing; - var charstring branch_value; - - /* RFC 3261 8.1.1.3 From */ - g_pars.cp.from_addr := g_pars.cp.calling; - g_pars.cp.from_addr.params := f_sip_param_set(g_pars.cp.from_addr.params, "tag", f_sip_rand_tag()); - g_pars.cp.to_addr := g_pars.cp.called; - branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.cp.from_addr), - f_sip_SipAddr_to_str(valueof(g_pars.cp.to_addr)), - g_pars.cp.sip_call_id, - g_pars.cp.sip_seq_nr); - via := g_pars.local_via; - via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); - - req := ts_SIP_INVITE(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - via, - g_pars.local_contact, - g_pars.cp.sip_seq_nr, - body := tx_sdp); - - SIP.send(req); - - /* RFC 3261 22.2: */ - exp := tr_SIP_Response_Unauthorized( - g_pars.cp.sip_call_id, - f_tr_From(g_pars.cp.from_addr), - f_tr_To_response(g_pars.cp.to_addr), - f_tr_Via_response(via), - *, - tr_WwwAuthenticate({tr_Challenge_digestCln(?)}), - g_pars.cp.sip_seq_nr, "INVITE"); - as_SIP_expect_resp(exp); - - /* Digest Auth: RFC 2617 */ - req.msgHeader.authorization := f_sip_digest_gen_Authorization( - g_rx_sip_resp.msgHeader.wwwAuthenticate, - g_pars.user, g_pars.password, - "INVITE", - f_sip_SipUrl_to_str(g_pars.registrar_sip_req_uri)) - g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; - f_sip_Request_inc_seq_nr(req); - SIP.send(req); - - /* Conditionally match and accept 100 Trying. */ - exp := tr_SIP_Response_Trying(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - f_tr_To_response(g_pars.cp.to_addr), - f_tr_Via_response(via), - g_pars.cp.sip_seq_nr, "INVITE"); - d_trying := activate(as_SIP_ignore_resp(exp)); - - /* Conditionally match and accept 180 Ringing */ - exp := tr_SIP_Response_Ringing(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - f_tr_To_response(g_pars.cp.to_addr), - f_tr_Via_response(via), - g_pars.cp.sip_seq_nr, "INVITE"); - d_ringing := activate(as_SIP_ignore_resp(exp)); - - /* Wait for OK answer */ - exp := tr_SIP_Response( - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - f_tr_To_response(g_pars.cp.to_addr), - f_tr_Via_response(via), - *, - "INVITE", 200, - g_pars.cp.sip_seq_nr, "OK", - body := ?); - as_SIP_expect_resp(exp, fail_others := false); - - deactivate(d_trying); - deactivate(d_ringing); - - /* Update To with the tags received from peer: */ - g_pars.cp.to_addr := valueof(ts_SipAddr_from_Addr_Union(g_rx_sip_resp.msgHeader.toField.addressField, - g_rx_sip_resp.msgHeader.toField.toParams)); - - /* Transmit ACK */ - g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; - req := ts_SIP_ACK(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - via, - g_pars.cp.sip_seq_nr, - omit); - SIP.send(req); - g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; -} - -private function f_ConnHdlr_parse_initial_SIP_INVITE(PDU_SIP_Request rx_sip_req) runs on ConnHdlr -{ - f_SDP_decodeMessage(rx_sip_req.messageBody, g_pars.cp.peer_sdp); - log("Rx Initial MT INVITE decoded SDP: ", g_pars.cp.peer_sdp); - - /* Obtain params: */ - g_pars.cp.sip_call_id := rx_sip_req.msgHeader.callId.callid; - g_pars.cp.from_addr := valueof(ts_SipAddr_from_Addr_Union(rx_sip_req.msgHeader.fromField.addressField, - rx_sip_req.msgHeader.fromField.fromParams)); - g_pars.cp.to_addr := valueof(ts_SipAddr_from_Addr_Union(rx_sip_req.msgHeader.toField.addressField, - rx_sip_req.msgHeader.toField.toParams)); - g_pars.cp.to_addr.params := f_sip_param_set(g_pars.cp.to_addr.params, "tag", f_sip_rand_tag()); - g_pars.cp.sip_seq_nr := rx_sip_req.msgHeader.cSeq.seqNumber; -} - -/* Peer is calling us, accept it: */ -private altstep as_SIP_mt_call_accept(boolean exp_update_to_direct_rtp := true, - boolean fail_others := true) runs on ConnHdlr -{ - var template (present) PDU_SIP_Request exp_req := - tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - ?, - f_tr_From(g_pars.cp.calling), - g_pars.cp.called, - tr_Via_from(f_tr_HostPort(mp_remote_sip_host, mp_remote_sip_port)), - ?, ?); - var charstring sip_expect_str := log2str(exp_req); - - [] SIP.receive(exp_req) -> value g_rx_sip_req { - var template (value) PDU_SIP_Response tx_resp; - var Via via; - var charstring tx_sdp; - - /* Obtain params: */ - f_ConnHdlr_parse_initial_SIP_INVITE(g_rx_sip_req); - via := g_rx_sip_req.msgHeader.via; - - - /* Tx 180 Ringing */ - tx_resp := ts_SIP_Response_Ringing(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - via, - g_pars.cp.sip_seq_nr); - SIP.send(tx_resp); - - if (g_pars.cp.mt.wait_coord_cmd_pickup) { - COORD.receive(COORD_CMD_PICKUP); - } - - /* Tx 200 OK */ - tx_sdp := f_gen_sdp(); - tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - "INVITE", 200, - g_pars.cp.sip_seq_nr, - "OK", - via, - body := tx_sdp); - SIP.send(tx_resp); - - /* Wait for ACK */ - exp_req := tr_SIP_ACK(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - f_tr_Via_response(via), - g_pars.cp.sip_seq_nr, *); - as_SIP_expect_req(exp_req); - - if (exp_update_to_direct_rtp) { - /* Asterisk will now update the session to connect us to MO directly: */ - /* Via is not kept since anyway "branch" will change upon following INVITE. */ - as_SIP_exp_call_update(g_pars.cp.sip_seq_nr + 1); - } - } - [fail_others] as_SIP_fail_resp(sip_expect_str); - [fail_others] as_SIP_fail_req(sip_expect_str); - -} - -/* Peer is calling us, but cancells it during ringing: */ -private altstep as_SIP_mt_call_cancelled(boolean fail_others := true) runs on ConnHdlr -{ - var template (present) PDU_SIP_Request exp_req := - tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - ?, - f_tr_From(g_pars.cp.calling), - g_pars.cp.called, - tr_Via_from(f_tr_HostPort(mp_remote_sip_host, mp_remote_sip_port)), - ?, ?); - var charstring sip_expect_str := log2str(exp_req); - - [] SIP.receive(exp_req) -> value g_rx_sip_req { - var template (value) PDU_SIP_Response tx_resp; - var Via via; - var template (present) SipAddr exp_to_addr; - var charstring tx_sdp; - - /* Obtain params: */ - f_ConnHdlr_parse_initial_SIP_INVITE(g_rx_sip_req); - via := g_rx_sip_req.msgHeader.via; - - - /* Tx 180 Ringing */ - tx_resp := ts_SIP_Response_Ringing(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - via, - g_pars.cp.sip_seq_nr); - SIP.send(tx_resp); - - if (g_pars.cp.mt.wait_coord_cmd_pickup) { - COORD.receive(COORD_CMD_PICKUP); - } - - /* Wait for CANCEL */ - /* Cancel may come even before we send Ringing, hence To's "tag" - * may not be known by peer, so g_pars.to_addr can't be used here: */ - exp_to_addr := ts_SipAddr_from_Addr_Union(g_rx_sip_req.msgHeader.toField.addressField, - g_rx_sip_req.msgHeader.toField.toParams); - exp_req := tr_SIP_CANCEL(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - exp_to_addr, - f_tr_Via_response(via), - g_pars.cp.sip_seq_nr, *); - as_SIP_expect_req(exp_req); - - /* Tx 200 OK */ - tx_sdp := f_gen_sdp(); - tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - "CANCEL", 200, - g_pars.cp.sip_seq_nr, - "OK", - via, - body := omit); - SIP.send(tx_resp); - } - [fail_others] as_SIP_fail_resp(sip_expect_str); - [fail_others] as_SIP_fail_req(sip_expect_str); - -} - -/* New INVITE arrives after MT call is established. Accept it: */ -private altstep as_SIP_exp_call_update(template (present) integer exp_seq_nr := ?, boolean fail_others := true) runs on ConnHdlr -{ - var template (present) PDU_SIP_Request exp_req := - tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - tr_Via_from(f_tr_HostPort(mp_remote_sip_host, mp_remote_sip_port)), - exp_seq_nr, - ?); - var charstring sip_expect_str := log2str(exp_req); - - [] SIP.receive(exp_req) -> value g_rx_sip_req { - var template (value) PDU_SIP_Response tx_resp; - var charstring tx_sdp; - var Via via; - - f_SDP_decodeMessage(g_rx_sip_req.messageBody, g_pars.cp.peer_sdp); - log("Rx Update MT INVITE decoded SDP: ", g_pars.cp.peer_sdp); - - /* Update parameters: */ - g_pars.cp.sip_seq_nr := g_rx_sip_req.msgHeader.cSeq.seqNumber; - /* "branch" has changed: */ - via := g_rx_sip_req.msgHeader.via; - - /* Tx 200 OK */ - tx_sdp := f_gen_sdp(); - tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - "INVITE", 200, - g_pars.cp.sip_seq_nr, - "OK", - via, - body := tx_sdp); - SIP.send(tx_resp); - - /* Wait for ACK */ - exp_req := tr_SIP_ACK(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - f_tr_Via_response(via), - g_pars.cp.sip_seq_nr, *); - as_SIP_expect_req(exp_req); - } - [fail_others] as_SIP_fail_resp(sip_expect_str); - [fail_others] as_SIP_fail_req(sip_expect_str); -} - -/* Tx BYE: */ -private function f_SIP_do_call_hangup() runs on ConnHdlr -{ - var template (value) PDU_SIP_Request req; - var template (present) PDU_SIP_Response exp_resp; - var Via via; - var charstring branch_value; - - branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.cp.from_addr), - f_sip_SipAddr_to_str(valueof(g_pars.cp.to_addr)), - g_pars.cp.sip_call_id, - g_pars.cp.sip_seq_nr); - - via := g_pars.local_via; - via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); - - /* Transmit ACK */ - req := ts_SIP_BYE(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - via, - g_pars.cp.sip_seq_nr, - omit); - SIP.send(req); - - /* Wait for OK answer */ - exp_resp := tr_SIP_Response( - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - f_tr_To_response(g_pars.cp.to_addr), - f_tr_Via_response(via), - *, - "BYE", 200, - g_pars.cp.sip_seq_nr, "OK"); - as_SIP_expect_resp(exp_resp); - - g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; -} - -/* Call is terminated by peer: */ -private altstep as_SIP_exp_call_hangup(template (present) integer exp_seq_nr := ?, boolean fail_others := true) runs on ConnHdlr -{ - var template (present) PDU_SIP_Request exp_req := - tr_SIP_BYE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), - g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - tr_Via_from(f_tr_HostPort(mp_remote_sip_host, mp_remote_sip_port)), - exp_seq_nr); - var charstring sip_expect_str := log2str(exp_req); - - [] SIP.receive(exp_req) -> value g_rx_sip_req { - var template (value) PDU_SIP_Response tx_resp; - var charstring tx_sdp; - var Via via; - - /* Update parameters: */ - g_pars.cp.sip_seq_nr := g_rx_sip_req.msgHeader.cSeq.seqNumber; - /* "branch" has changed: */ - via := g_rx_sip_req.msgHeader.via; - - /* Tx 200 OK */ - tx_sdp := f_gen_sdp(); - tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, - g_pars.cp.from_addr, - g_pars.cp.to_addr, - "BYE", 200, - g_pars.cp.sip_seq_nr, - "OK", - via, - body := tx_sdp); - SIP.send(tx_resp); - } - [fail_others] as_SIP_fail_resp(sip_expect_str); - [fail_others] as_SIP_fail_req(sip_expect_str); -} - /* Test SIP registration of local clients */ -private function f_TC_internal_registration(charstring id) runs on ConnHdlr { +private function f_TC_internal_registration(charstring id) runs on SIPConnHdlr { f_SIP_register(); // f_SIP_deregister(); setverdict(pass); } testcase TC_internal_registration() runs on test_CT { - var ConnHdlrPars pars; - var ConnHdlr vc_conn; + var SIPConnHdlrPars pars; + var SIPConnHdlr vc_conn; f_init(); pars := f_init_ConnHdlrPars(); vc_conn := f_start_handler(refers(f_TC_internal_registration), pars); @@ -769,7 +103,7 @@ } /* Successful SIP MO-MT Call between local clients: */ -private function f_TC_internal_call_mo(charstring id) runs on ConnHdlr { +private function f_TC_internal_call_mo(charstring id) runs on SIPConnHdlr { f_SIP_register(); COORD.send(COORD_CMD_REGISTERED); @@ -783,7 +117,7 @@ setverdict(pass); } -private function f_TC_internal_call_mt(charstring id) runs on ConnHdlr { +private function f_TC_internal_call_mt(charstring id) runs on SIPConnHdlr { f_create_sip_expect(valueof(ts_SipUrl_from_Addr_Union(g_pars.cp.called.addr))); @@ -807,8 +141,8 @@ setverdict(pass); } testcase TC_internal_call_momt() runs on test_CT { - var ConnHdlrPars pars[2]; - var ConnHdlr vc_conn[2]; + var SIPConnHdlrPars pars[2]; + var SIPConnHdlr vc_conn[2]; f_init(); @@ -850,11 +184,11 @@ * equipments ring (INVITE). The first one to pick up the call (OK 200) gets the * call established (ACK), others get a CANCEL event. */ private function TC_internal_call_all_Nregistered(integer num_conns := 2) runs on test_CT { - var ConnHdlrList vc_conn_list := {}; + var SIPConnHdlrList vc_conn_list := {}; const integer vc_conn_mo_idx := 0; /* Index of MO leg in vc_conn_list */ const integer vc_conn_mt_idx := 1; /* Index of MT leg in vc_conn_list, peer picking up first the call */ var SipAddr broadcast_sip_record; - var ConnHdlrPars pars_mo; + var SIPConnHdlrPars pars_mo; f_init(); @@ -862,8 +196,8 @@ ts_UserInfo(broadcast_sip_extension))); for (var integer i := 0; i < num_conns; i := i + 1) { - var ConnHdlrPars pars; - var ConnHdlr vc_conn; + var SIPConnHdlrPars pars; + var SIPConnHdlr vc_conn; pars := f_init_ConnHdlrPars(idx := i + 1); if (i == vc_conn_mo_idx) { /* MO */ pars.cp.calling := pars.registrar_sip_record; diff --git a/asterisk/SIP_ConnectionHandler.ttcn b/asterisk/SIP_ConnectionHandler.ttcn new file mode 100644 index 0000000..13b5f04 --- /dev/null +++ b/asterisk/SIP_ConnectionHandler.ttcn @@ -0,0 +1,707 @@ +/* Component implementing a SIP UA towards Asterisk + * (C) 2024 by sysmocom - s.f.m.c. GmbH <info(a)sysmocom.de> + * Author: Pau Espin Pedrol <pespin(a)sysmocom.de> + * All rights reserved. + * + * Released under the terms of GNU General Public License, Version 2 or + * (at your option) any later version. + * + * SPDX-License-Identifier: GPL-2.0-or-later + */ +module SIP_ConnectionHandler { + +import from TCCOpenSecurity_Functions all; +import from General_Types all; +import from Osmocom_Types all; +import from Native_Functions all; +import from Misc_Helpers all; + +import from SDP_Types all; +import from SDP_Templates all; + +import from SIP_Emulation all; +import from SIPmsg_Types all; +import from SIP_Templates all; + +type port Coord_PT message +{ + inout charstring; +} with { extension "internal" }; + +const charstring COORD_CMD_REGISTERED := "COORD_CMD_REGISTERED"; +const charstring COORD_CMD_START := "COORD_CMD_START"; +const charstring COORD_CMD_PICKUP := "COORD_CMD_PICKUP"; +const charstring COORD_CMD_CALL_ESTABLISHED := "COORD_CMD_CALL_ESTABLISHED"; +const charstring COORD_CMD_CALL_CANCELLED := "COORD_CMD_CALL_CANCELLED"; +const charstring COORD_CMD_HANGUP := "COORD_CMD_HANGUP"; + +type component SIPConnHdlr extends SIP_ConnHdlr { + var charstring g_name; + var SIPConnHdlrPars g_pars; + timer g_Tguard; + var PDU_SIP_Request g_rx_sip_req; + var PDU_SIP_Response g_rx_sip_resp; + + port Coord_PT COORD; +} +type record of SIPConnHdlr SIPConnHdlrList; + +type record SIPConnHdlrPars { + float t_guard, + charstring remote_sip_host, + uint16_t remote_sip_port, + charstring user, + charstring display_name, + charstring password, + SipUrl registrar_sip_req_uri, + SipAddr registrar_sip_record, + CallidString registrar_sip_call_id, + integer registrar_sip_seq_nr, + Via local_via, + SipUrl local_sip_url_ext, + SipAddr local_sip_record, + Contact local_contact, + CallPars cp optional +} +type record of SIPConnHdlrPars SIPConnHdlrParsList; + +type record CallParsMT { + /* Whether to wait for COORD.receive(COORD_CMD_PICKUP) before accepting the call. */ + boolean wait_coord_cmd_pickup, + /* Whether to expect CANCEL instead of ACK as answer to our OK */ + boolean exp_cancel +} +template (value) CallParsMT t_CallParsMT := { + wait_coord_cmd_pickup := false, + exp_cancel := false +} + +type record CallPars { + SipAddr calling optional, + SipAddr called optional, + + SipAddr from_addr optional, + SipAddr to_addr optional, + + CallidString sip_call_id, + integer sip_seq_nr, + charstring sip_body optional, + + charstring local_rtp_addr, + uint16_t local_rtp_port, + + SDP_Message peer_sdp optional, + CallParsMT mt +} + +template (value) CallPars t_CallPars(charstring local_rtp_addr, + uint16_t local_rtp_port := 0, + template (omit) SipAddr calling := omit, + template (omit) SipAddr called := omit) := { + calling := calling, + called := called, + from_addr := omit, + to_addr := omit, + sip_call_id := hex2str(f_rnd_hexstring(15)), + sip_seq_nr := f_sip_rand_seq_nr(), + sip_body := omit, + local_rtp_addr := local_rtp_addr, + local_rtp_port := local_rtp_port, + peer_sdp := omit, + mt := t_CallParsMT +} + +template (value) SIPConnHdlrPars t_Pars(charstring local_sip_host, + uint16_t local_sip_port, + charstring remote_sip_host, + uint16_t remote_sip_port, + charstring user, + charstring display_name := "Anonymous", + charstring password := "secret", + template (omit) CallPars cp := omit) := { + t_guard := 30.0, + remote_sip_host := remote_sip_host, + remote_sip_port := remote_sip_port, + user := user, + display_name := f_sip_str_quote(display_name), + password := password, + registrar_sip_req_uri := valueof(ts_SipUrlHost(remote_sip_host)), + registrar_sip_record := ts_SipAddr(ts_HostPort(remote_sip_host), + ts_UserInfo(user), + f_sip_str_quote(display_name)), + registrar_sip_call_id := hex2str(f_rnd_hexstring(15)) & "@" & local_sip_host, + registrar_sip_seq_nr := f_sip_rand_seq_nr(), + local_via := ts_Via_from(ts_HostPort(local_sip_host, local_sip_port)), + local_sip_url_ext := ts_SipUrl(ts_HostPort(local_sip_host, local_sip_port), + ts_UserInfo(user)), + local_sip_record := ts_SipAddr(ts_HostPort(local_sip_host), + ts_UserInfo(user)), + local_contact := valueof(ts_Contact({ + ts_ContactAddress( + ts_Addr_Union_SipUrl(ts_SipUrl(ts_HostPort( + local_sip_host, + local_sip_port), + ts_UserInfo(user))), + omit) + })), + cp := cp +} + +private altstep as_Tguard() runs on SIPConnHdlr { + [] g_Tguard.timeout { + setverdict(fail, "Tguard timeout"); + mtc.stop; + } +} + +type function void_fn(charstring id) runs on SIPConnHdlr; +function f_handler_init(void_fn fn, charstring id, SIPConnHdlrPars pars) +runs on SIPConnHdlr { + g_name := id; + g_pars := pars; + g_Tguard.start(pars.t_guard); + activate(as_Tguard()); + + // Make sure the UA is deregistered before starting the test: + // sends REGISTER with Contact = "*" and Expires = 0 + //f_SIP_deregister(); + + /* call the user-supied test case function */ + fn.apply(id); +} + +private function f_tr_Via_response(Via via_req) return template (present) Via { + template (present) SemicolonParam_List via_resp_params := ?; + + /*via_resp_params := { + { id := "rport", paramValue := int2str(g_pars.remote_sip_port) }, + { id := "received", paramValue := g_pars.remote_sip_host } + }; */ + return tr_Via_from(via_req.viaBody[0].sentBy, + via_resp_params); +} + +private function f_tr_To_response(template (value) SipAddr to_req) return template (present) SipAddr { + return tr_SipAddr_from_val(to_req); +} + +private function f_tr_From(template (value) SipAddr from_req) return template (present) SipAddr { + return tr_SipAddr_from_val(from_req); +} + +private altstep as_SIP_fail_req(charstring exp_msg_str := "") runs on SIPConnHdlr +{ + var PDU_SIP_Request sip_req; + [] SIP.receive(PDU_SIP_Request:?) -> value sip_req { + Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, + log2str(g_name & ": Received unexpected SIP Req message := ", sip_req, "\nvs exp := ", exp_msg_str)); + } +} + +private altstep as_SIP_fail_resp(charstring exp_msg_str := "") runs on SIPConnHdlr +{ + var PDU_SIP_Response sip_resp; + [] SIP.receive(PDU_SIP_Response:?) -> value sip_resp { + Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, + log2str(g_name & ": Received unexpected SIP Resp message := ", sip_resp, "\nvs exp := ", exp_msg_str)); + } +} + +altstep as_SIP_expect_req(template (present) PDU_SIP_Request sip_expect, boolean fail_others := true) runs on SIPConnHdlr +{ + var charstring sip_expect_str := log2str(sip_expect); + [] SIP.receive(sip_expect) -> value g_rx_sip_req; + [fail_others] as_SIP_fail_req(sip_expect_str); + [fail_others] as_SIP_fail_resp(sip_expect_str); +} + +altstep as_SIP_expect_resp(template (present) PDU_SIP_Response sip_expect, boolean fail_others := true) runs on SIPConnHdlr +{ + var charstring sip_expect_str := log2str(sip_expect); + [] SIP.receive(sip_expect) -> value g_rx_sip_resp; + [fail_others] as_SIP_fail_resp(sip_expect_str); + [fail_others] as_SIP_fail_req(sip_expect_str); +} + +altstep as_SIP_ignore_resp(template PDU_SIP_Response sip_expect := ?) runs on SIPConnHdlr +{ + [] SIP.receive(sip_expect) -> value g_rx_sip_resp { + log("Ignoring ", g_rx_sip_resp); + repeat; + } +} + +private function f_gen_sdp() runs on SIPConnHdlr return charstring { + var charstring sdp := + "v=0\r\n" & + "o=0502 2390 1824 IN IP4 " & g_pars.cp.local_rtp_addr & "\r\n" & + "s=Talk\r\n" & + "c=IN IP4 " & g_pars.cp.local_rtp_addr & "\r\n" & + "t=0 0\r\n" & + "a=rtcp-xr:rcvr-rtt=all:10000 stat-summary=loss,dup,jitt,TTL voip-metrics\r\n" & + "a=record:off\r\n" & + "m=audio " & int2str(g_pars.cp.local_rtp_port) & " RTP/AVP 96 97 98 0 8 18 99 100 101\r\n" & + "a=rtpmap:96 opus/48000/2\r\n" & + "a=fmtp:96 useinbandfec=1\r\n" & + "a=rtpmap:97 speex/16000\r\n" & + "a=fmtp:97 vbr=on\r\n" & + "a=rtpmap:98 speex/8000\r\n" & + "a=fmtp:98 vbr=on\r\n" & + "a=fmtp:18 annexb=yes\r\n" & + "a=rtpmap:99 telephone-event/48000\r\n" & + "a=rtpmap:100 telephone-event/16000\r\n" & + "a=rtpmap:101 telephone-event/8000\r\n" & + "a=rtcp:" & int2str(g_pars.cp.local_rtp_port + 1) & "\r\n" & + "a=rtcp-fb:* trr-int 1000\r\n" & + "a=rtcp-fb:* ccm tmmbr\r\n"; + return sdp; +} + +function f_SIP_register() runs on SIPConnHdlr return PDU_SIP_Response +{ + var template (present) PDU_SIP_Response exp; + var Authorization authorization; + var Via via := g_pars.local_via; + var SipAddr from_sipaddr := g_pars.registrar_sip_record; + var charstring branch_value; + + branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.registrar_sip_record), + f_sip_SipAddr_to_str(g_pars.registrar_sip_record), + g_pars.registrar_sip_call_id, + g_pars.registrar_sip_seq_nr); + + via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); + from_sipaddr.params := f_sip_param_set(from_sipaddr.params, "tag", f_sip_rand_tag()); + SIP.send(ts_SIP_REGISTER(g_pars.registrar_sip_req_uri, + g_pars.registrar_sip_call_id, + from_sipaddr, + g_pars.registrar_sip_record, + via, + g_pars.registrar_sip_seq_nr, + g_pars.local_contact, + ts_Expires("7200"))); + + exp := tr_SIP_Response_Unauthorized( + g_pars.registrar_sip_call_id, + from_sipaddr, + f_tr_To_response(g_pars.registrar_sip_record), + f_tr_Via_response(via), + *, + tr_WwwAuthenticate({tr_Challenge_digestCln(?)}), + g_pars.registrar_sip_seq_nr); + as_SIP_expect_resp(exp); + + /* Digest Auth: RFC 2617 */ + authorization := f_sip_digest_gen_Authorization(g_rx_sip_resp.msgHeader.wwwAuthenticate, + g_pars.user, g_pars.password, + "REGISTER", + f_sip_SipUrl_to_str(g_pars.registrar_sip_req_uri)) + + /* New transaction: */ + g_pars.registrar_sip_seq_nr := g_pars.registrar_sip_seq_nr + 1; + branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.registrar_sip_record), + f_sip_SipAddr_to_str(g_pars.registrar_sip_record), + g_pars.registrar_sip_call_id, + g_pars.registrar_sip_seq_nr); + via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); + + SIP.send(ts_SIP_REGISTER(g_pars.registrar_sip_req_uri, + g_pars.registrar_sip_call_id, + from_sipaddr, + g_pars.registrar_sip_record, + via, + g_pars.registrar_sip_seq_nr, + g_pars.local_contact, + ts_Expires("7200"), + authorization := authorization)); + + /* Wait for OK answer */ + exp := tr_SIP_Response( + g_pars.registrar_sip_call_id, + from_sipaddr, + f_tr_To_response(g_pars.registrar_sip_record), + f_tr_Via_response(via), + *, + "REGISTER", 200, + g_pars.registrar_sip_seq_nr, "OK"); + as_SIP_expect_resp(exp); + + /* Prepare for next use: */ + g_pars.registrar_sip_seq_nr := g_pars.registrar_sip_seq_nr + 1; + return g_rx_sip_resp; +} + +function f_SIP_mo_call_setup() runs on SIPConnHdlr +{ + var template (value) PDU_SIP_Request req; + var template (present) PDU_SIP_Response exp; + var Via via; + var charstring tx_sdp := f_gen_sdp(); + var default d_trying, d_ringing; + var charstring branch_value; + + /* RFC 3261 8.1.1.3 From */ + g_pars.cp.from_addr := g_pars.cp.calling; + g_pars.cp.from_addr.params := f_sip_param_set(g_pars.cp.from_addr.params, "tag", f_sip_rand_tag()); + g_pars.cp.to_addr := g_pars.cp.called; + branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.cp.from_addr), + f_sip_SipAddr_to_str(valueof(g_pars.cp.to_addr)), + g_pars.cp.sip_call_id, + g_pars.cp.sip_seq_nr); + via := g_pars.local_via; + via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); + + req := ts_SIP_INVITE(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + via, + g_pars.local_contact, + g_pars.cp.sip_seq_nr, + body := tx_sdp); + + SIP.send(req); + + /* RFC 3261 22.2: */ + exp := tr_SIP_Response_Unauthorized( + g_pars.cp.sip_call_id, + f_tr_From(g_pars.cp.from_addr), + f_tr_To_response(g_pars.cp.to_addr), + f_tr_Via_response(via), + *, + tr_WwwAuthenticate({tr_Challenge_digestCln(?)}), + g_pars.cp.sip_seq_nr, "INVITE"); + as_SIP_expect_resp(exp); + + /* Digest Auth: RFC 2617 */ + req.msgHeader.authorization := f_sip_digest_gen_Authorization( + g_rx_sip_resp.msgHeader.wwwAuthenticate, + g_pars.user, g_pars.password, + "INVITE", + f_sip_SipUrl_to_str(g_pars.registrar_sip_req_uri)) + g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; + f_sip_Request_inc_seq_nr(req); + SIP.send(req); + + /* Conditionally match and accept 100 Trying. */ + exp := tr_SIP_Response_Trying(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + f_tr_To_response(g_pars.cp.to_addr), + f_tr_Via_response(via), + g_pars.cp.sip_seq_nr, "INVITE"); + d_trying := activate(as_SIP_ignore_resp(exp)); + + /* Conditionally match and accept 180 Ringing */ + exp := tr_SIP_Response_Ringing(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + f_tr_To_response(g_pars.cp.to_addr), + f_tr_Via_response(via), + g_pars.cp.sip_seq_nr, "INVITE"); + d_ringing := activate(as_SIP_ignore_resp(exp)); + + /* Wait for OK answer */ + exp := tr_SIP_Response( + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + f_tr_To_response(g_pars.cp.to_addr), + f_tr_Via_response(via), + *, + "INVITE", 200, + g_pars.cp.sip_seq_nr, "OK", + body := ?); + as_SIP_expect_resp(exp, fail_others := false); + + deactivate(d_trying); + deactivate(d_ringing); + + /* Update To with the tags received from peer: */ + g_pars.cp.to_addr := valueof(ts_SipAddr_from_Addr_Union(g_rx_sip_resp.msgHeader.toField.addressField, + g_rx_sip_resp.msgHeader.toField.toParams)); + + /* Transmit ACK */ + g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; + req := ts_SIP_ACK(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + via, + g_pars.cp.sip_seq_nr, + omit); + SIP.send(req); + g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; +} + +private function f_ConnHdlr_parse_initial_SIP_INVITE(PDU_SIP_Request rx_sip_req) runs on SIPConnHdlr +{ + f_SDP_decodeMessage(rx_sip_req.messageBody, g_pars.cp.peer_sdp); + log("Rx Initial MT INVITE decoded SDP: ", g_pars.cp.peer_sdp); + + /* Obtain params: */ + g_pars.cp.sip_call_id := rx_sip_req.msgHeader.callId.callid; + g_pars.cp.from_addr := valueof(ts_SipAddr_from_Addr_Union(rx_sip_req.msgHeader.fromField.addressField, + rx_sip_req.msgHeader.fromField.fromParams)); + g_pars.cp.to_addr := valueof(ts_SipAddr_from_Addr_Union(rx_sip_req.msgHeader.toField.addressField, + rx_sip_req.msgHeader.toField.toParams)); + g_pars.cp.to_addr.params := f_sip_param_set(g_pars.cp.to_addr.params, "tag", f_sip_rand_tag()); + g_pars.cp.sip_seq_nr := rx_sip_req.msgHeader.cSeq.seqNumber; +} + +/* Peer is calling us, accept it: */ +altstep as_SIP_mt_call_accept(boolean exp_update_to_direct_rtp := true, + boolean fail_others := true) runs on SIPConnHdlr +{ + var template (present) PDU_SIP_Request exp_req := + tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + ?, + f_tr_From(g_pars.cp.calling), + g_pars.cp.called, + tr_Via_from(f_tr_HostPort(g_pars.remote_sip_host, g_pars.remote_sip_port)), + ?, ?); + var charstring sip_expect_str := log2str(exp_req); + + [] SIP.receive(exp_req) -> value g_rx_sip_req { + var template (value) PDU_SIP_Response tx_resp; + var Via via; + var charstring tx_sdp; + + /* Obtain params: */ + f_ConnHdlr_parse_initial_SIP_INVITE(g_rx_sip_req); + via := g_rx_sip_req.msgHeader.via; + + + /* Tx 180 Ringing */ + tx_resp := ts_SIP_Response_Ringing(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + via, + g_pars.cp.sip_seq_nr); + SIP.send(tx_resp); + + if (g_pars.cp.mt.wait_coord_cmd_pickup) { + COORD.receive(COORD_CMD_PICKUP); + } + + /* Tx 200 OK */ + tx_sdp := f_gen_sdp(); + tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + "INVITE", 200, + g_pars.cp.sip_seq_nr, + "OK", + via, + body := tx_sdp); + SIP.send(tx_resp); + + /* Wait for ACK */ + exp_req := tr_SIP_ACK(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + f_tr_Via_response(via), + g_pars.cp.sip_seq_nr, *); + as_SIP_expect_req(exp_req); + + if (exp_update_to_direct_rtp) { + /* Asterisk will now update the session to connect us to MO directly: */ + /* Via is not kept since anyway "branch" will change upon following INVITE. */ + as_SIP_exp_call_update(g_pars.cp.sip_seq_nr + 1); + } + } + [fail_others] as_SIP_fail_resp(sip_expect_str); + [fail_others] as_SIP_fail_req(sip_expect_str); + +} + +/* Peer is calling us, but cancells it during ringing: */ +altstep as_SIP_mt_call_cancelled(boolean fail_others := true) runs on SIPConnHdlr +{ + var template (present) PDU_SIP_Request exp_req := + tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + ?, + f_tr_From(g_pars.cp.calling), + g_pars.cp.called, + tr_Via_from(f_tr_HostPort(g_pars.remote_sip_host, g_pars.remote_sip_port)), + ?, ?); + var charstring sip_expect_str := log2str(exp_req); + + [] SIP.receive(exp_req) -> value g_rx_sip_req { + var template (value) PDU_SIP_Response tx_resp; + var Via via; + var template (present) SipAddr exp_to_addr; + var charstring tx_sdp; + + /* Obtain params: */ + f_ConnHdlr_parse_initial_SIP_INVITE(g_rx_sip_req); + via := g_rx_sip_req.msgHeader.via; + + + /* Tx 180 Ringing */ + tx_resp := ts_SIP_Response_Ringing(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + via, + g_pars.cp.sip_seq_nr); + SIP.send(tx_resp); + + if (g_pars.cp.mt.wait_coord_cmd_pickup) { + COORD.receive(COORD_CMD_PICKUP); + } + + /* Wait for CANCEL */ + /* Cancel may come even before we send Ringing, hence To's "tag" + * may not be known by peer, so g_pars.to_addr can't be used here: */ + exp_to_addr := ts_SipAddr_from_Addr_Union(g_rx_sip_req.msgHeader.toField.addressField, + g_rx_sip_req.msgHeader.toField.toParams); + exp_req := tr_SIP_CANCEL(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + exp_to_addr, + f_tr_Via_response(via), + g_pars.cp.sip_seq_nr, *); + as_SIP_expect_req(exp_req); + + /* Tx 200 OK */ + tx_sdp := f_gen_sdp(); + tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + "CANCEL", 200, + g_pars.cp.sip_seq_nr, + "OK", + via, + body := omit); + SIP.send(tx_resp); + } + [fail_others] as_SIP_fail_resp(sip_expect_str); + [fail_others] as_SIP_fail_req(sip_expect_str); + +} + +/* New INVITE arrives after MT call is established. Accept it: */ +altstep as_SIP_exp_call_update(template (present) integer exp_seq_nr := ?, boolean fail_others := true) runs on SIPConnHdlr +{ + var template (present) PDU_SIP_Request exp_req := + tr_SIP_INVITE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + tr_Via_from(f_tr_HostPort(g_pars.remote_sip_host, g_pars.remote_sip_port)), + exp_seq_nr, + ?); + var charstring sip_expect_str := log2str(exp_req); + + [] SIP.receive(exp_req) -> value g_rx_sip_req { + var template (value) PDU_SIP_Response tx_resp; + var charstring tx_sdp; + var Via via; + + f_SDP_decodeMessage(g_rx_sip_req.messageBody, g_pars.cp.peer_sdp); + log("Rx Update MT INVITE decoded SDP: ", g_pars.cp.peer_sdp); + + /* Update parameters: */ + g_pars.cp.sip_seq_nr := g_rx_sip_req.msgHeader.cSeq.seqNumber; + /* "branch" has changed: */ + via := g_rx_sip_req.msgHeader.via; + + /* Tx 200 OK */ + tx_sdp := f_gen_sdp(); + tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + "INVITE", 200, + g_pars.cp.sip_seq_nr, + "OK", + via, + body := tx_sdp); + SIP.send(tx_resp); + + /* Wait for ACK */ + exp_req := tr_SIP_ACK(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + f_tr_Via_response(via), + g_pars.cp.sip_seq_nr, *); + as_SIP_expect_req(exp_req); + } + [fail_others] as_SIP_fail_resp(sip_expect_str); + [fail_others] as_SIP_fail_req(sip_expect_str); +} + +/* Tx BYE: */ +function f_SIP_do_call_hangup() runs on SIPConnHdlr +{ + var template (value) PDU_SIP_Request req; + var template (present) PDU_SIP_Response exp_resp; + var Via via; + var charstring branch_value; + + branch_value := f_sip_gen_branch(f_sip_SipAddr_to_str(g_pars.cp.from_addr), + f_sip_SipAddr_to_str(valueof(g_pars.cp.to_addr)), + g_pars.cp.sip_call_id, + g_pars.cp.sip_seq_nr); + + via := g_pars.local_via; + via.viaBody[0].viaParams := f_sip_param_set(via.viaBody[0].viaParams, "branch", branch_value); + + /* Transmit ACK */ + req := ts_SIP_BYE(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + via, + g_pars.cp.sip_seq_nr, + omit); + SIP.send(req); + + /* Wait for OK answer */ + exp_resp := tr_SIP_Response( + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + f_tr_To_response(g_pars.cp.to_addr), + f_tr_Via_response(via), + *, + "BYE", 200, + g_pars.cp.sip_seq_nr, "OK"); + as_SIP_expect_resp(exp_resp); + + g_pars.cp.sip_seq_nr := g_pars.cp.sip_seq_nr + 1; +} + +/* Call is terminated by peer: */ +altstep as_SIP_exp_call_hangup(template (present) integer exp_seq_nr := ?, boolean fail_others := true) runs on SIPConnHdlr +{ + var template (present) PDU_SIP_Request exp_req := + tr_SIP_BYE(f_tr_SipUrl_opt_defport(g_pars.local_sip_url_ext), + g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + tr_Via_from(f_tr_HostPort(g_pars.remote_sip_host, g_pars.remote_sip_port)), + exp_seq_nr); + var charstring sip_expect_str := log2str(exp_req); + + [] SIP.receive(exp_req) -> value g_rx_sip_req { + var template (value) PDU_SIP_Response tx_resp; + var charstring tx_sdp; + var Via via; + + /* Update parameters: */ + g_pars.cp.sip_seq_nr := g_rx_sip_req.msgHeader.cSeq.seqNumber; + /* "branch" has changed: */ + via := g_rx_sip_req.msgHeader.via; + + /* Tx 200 OK */ + tx_sdp := f_gen_sdp(); + tx_resp := ts_SIP_Response(g_pars.cp.sip_call_id, + g_pars.cp.from_addr, + g_pars.cp.to_addr, + "BYE", 200, + g_pars.cp.sip_seq_nr, + "OK", + via, + body := tx_sdp); + SIP.send(tx_resp); + } + [fail_others] as_SIP_fail_resp(sip_expect_str); + [fail_others] as_SIP_fail_req(sip_expect_str); +} + +} -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36596?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I168920887bfd05c0a1785c5cb7ac485edaef0df2 Gerrit-Change-Number: 36596 Gerrit-PatchSet: 3 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-MessageType: merged

1 year, 2 months

1
0
0 0

[XL] Change in osmo-ttcn3-hacks[master]: asterisk: Split SIPConnHdlr to its own file

by fixeria

Attention is currently required from: osmith, pespin. fixeria has posted comments on this change. ( https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36596?usp=email ) Change subject: asterisk: Split SIPConnHdlr to its own file ...................................................................... Patch Set 3: Code-Review+2 (1 comment) File asterisk/SIP_ConnectionHandler.ttcn: https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36596/comment/1cc172a9_f30d… PS2, Line 707: } > `No newline at end of right file. […] Done -- To view, visit https://gerrit.osmocom.org/c/osmo-ttcn3-hacks/+/36596?usp=email To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings Gerrit-Project: osmo-ttcn3-hacks Gerrit-Branch: master Gerrit-Change-Id: I168920887bfd05c0a1785c5cb7ac485edaef0df2 Gerrit-Change-Number: 36596 Gerrit-PatchSet: 3 Gerrit-Owner: pespin <pespin(a)sysmocom.de> Gerrit-Reviewer: Jenkins Builder Gerrit-Reviewer: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-Reviewer: osmith <osmith(a)sysmocom.de> Gerrit-Reviewer: pespin <pespin(a)sysmocom.de> Gerrit-Attention: osmith <osmith(a)sysmocom.de> Gerrit-Attention: pespin <pespin(a)sysmocom.de> Gerrit-Comment-Date: Thu, 18 Apr 2024 17:57:58 +0000 Gerrit-HasComments: Yes Gerrit-Has-Labels: Yes Comment-In-Reply-To: fixeria <vyanitskiy(a)sysmocom.de> Gerrit-MessageType: comment

1 year, 2 months

1
0
0 0

2025

2024

2023

2022

gerrit-log April 2024