aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Welte <laforge@osmocom.org>2022-05-16 14:40:07 +0200
committerHarald Welte <laforge@osmocom.org>2022-05-17 19:48:15 +0200
commit17f320819502e111403fb9718966a3d26fcd440e (patch)
treeda2e65b7577e8a784dff2e0cce2b0ba990ee7cca
parent535ca2658bc655c5e91075e4766378b71ef5ad99 (diff)
GSUP: Add function to unregister expect; clarify naming
-rw-r--r--library/GSUP_Emulation.ttcn44
1 files changed, 36 insertions, 8 deletions
diff --git a/library/GSUP_Emulation.ttcn b/library/GSUP_Emulation.ttcn
index 09058068..213810e1 100644
--- a/library/GSUP_Emulation.ttcn
+++ b/library/GSUP_Emulation.ttcn
@@ -217,9 +217,14 @@ function main(GsupOps ops, charstring id) runs on GSUP_Emulation_CT {
/* Client -> us: procedure call to register expect */
- [] GSUP_PROC.getcall(GSUPEM_register:{?,?}) -> param(imsi, vc_hdlr) {
+ [] GSUP_PROC.getcall(GSUPEM_register_expect:{?,?}) -> param(imsi, vc_hdlr) {
f_create_expect(imsi, vc_hdlr);
- GSUP_PROC.reply(GSUPEM_register:{imsi, vc_hdlr}) to vc_hdlr;
+ GSUP_PROC.reply(GSUPEM_register_expect:{imsi, vc_hdlr}) to vc_hdlr;
+ }
+ /* Client -> us: procedure call to unregister expect */
+ [] GSUP_PROC.getcall(GSUPEM_unregister_expect:{?,?}) -> param(imsi, vc_hdlr) {
+ f_destroy_expect(imsi, vc_hdlr);
+ GSUP_PROC.reply(GSUPEM_unregister_expect:{imsi, vc_hdlr}) to vc_hdlr;
}
[] GSUP_PROC.getcall(GSUPEM_change_connhdlr:{?,?}) -> param(imsi, vc_hdlr) {
@@ -245,11 +250,12 @@ type record ExpectData {
}
/* procedure based port to register for incoming calls */
-signature GSUPEM_register(in charstring imsi, in GSUP_ConnHdlr hdlr);
+signature GSUPEM_register_expect(in charstring imsi, in GSUP_ConnHdlr hdlr);
+signature GSUPEM_unregister_expect(in charstring imsi, in GSUP_ConnHdlr hdlr);
signature GSUPEM_change_connhdlr(in charstring imsi, in GSUP_ConnHdlr hdlr);
type port GSUPEM_PROC_PT procedure {
- inout GSUPEM_register, GSUPEM_change_connhdlr;
+ inout GSUPEM_register_expect, GSUPEM_unregister_expect, GSUPEM_change_connhdlr;
} with { extension "internal" };
/* CreateCallback that can be used as create_cb and will use the expectation table */
@@ -295,17 +301,39 @@ runs on GSUP_Emulation_CT {
testcase.stop("No space left in GsupExpectTable");
}
+/* server/emulation side function to destroy expect */
+private function f_destroy_expect(charstring imsi, GSUP_ConnHdlr hdlr)
+runs on GSUP_Emulation_CT {
+ var integer i;
+ for (i := 0; i < sizeof(GsupExpectTable); i := i+1) {
+ if (GsupExpectTable[i].imsi == imsi and GsupExpectTable[i].vc_conn == hdlr) {
+ GsupExpectTable[i].imsi := omit;
+ GsupExpectTable[i].vc_conn := null;
+ log("Destroyed GsupExpect[", i, "] for ", imsi, " to be handled at ", hdlr);
+ return;
+ }
+ }
+ testcase.stop("No matching expect found to be destoyed");
+}
+
/* client/conn_hdlr side function to use procedure port to create expect in emulation */
function f_create_gsup_expect(charstring imsi) runs on GSUP_ConnHdlr {
- GSUP_PROC.call(GSUPEM_register:{imsi, self}) {
- [] GSUP_PROC.getreply(GSUPEM_register:{?,?}) {};
+ GSUP_PROC.call(GSUPEM_register_expect:{imsi, self}) {
+ [] GSUP_PROC.getreply(GSUPEM_register_expect:{?,?}) {};
}
}
+function f_destroy_gsup_expect(charstring imsi) runs on GSUP_ConnHdlr {
+ GSUP_PROC.call(GSUPEM_unregister_expect:{imsi, self}) {
+ [] GSUP_PROC.getreply(GSUPEM_unregister_expect:{?,?}) {};
+ }
+}
+
+
/* Same as f_create_gsup_expect, but with explicit addressing. Needed when connecting multiple ports to GSUP_PROC. */
function f_create_gsup_expect_explicit(charstring imsi, GSUP_Emulation_CT ct) runs on GSUP_ConnHdlr {
- GSUP_PROC.call(GSUPEM_register:{imsi, self}) to ct {
- [] GSUP_PROC.getreply(GSUPEM_register:{?,?}) {};
+ GSUP_PROC.call(GSUPEM_register_expect:{imsi, self}) to ct {
+ [] GSUP_PROC.getreply(GSUPEM_register_expect:{?,?}) {};
}
}