pespin has uploaded this change for review.
pgw: SPlit PGW_Session_CT into its own file
Similar to what's already done in most testsuites.
Change-Id: I1b0d7be9e9655d407576bbaa905d9360840c5c21
---
A pgw/PGW_Session_CT.ttcn
M pgw/PGW_Tests.ttcn
2 files changed, 570 insertions(+), 537 deletions(-)
git pull ssh://gerrit.osmocom.org:29418/osmo-ttcn3-hacks refs/changes/96/43296/1
diff --git a/pgw/PGW_Session_CT.ttcn b/pgw/PGW_Session_CT.ttcn
new file mode 100644
index 0000000..d45cad2
--- /dev/null
+++ b/pgw/PGW_Session_CT.ttcn
@@ -0,0 +1,568 @@
+module PGW_Session_CT {
+
+import from TCCEncoding_Functions all;
+
+import from General_Types all;
+import from Osmocom_Types all;
+import from Native_Functions all;
+import from Misc_Helpers all;
+
+import from GTPv1U_Emulation all;
+
+import from GTPv2_Types all;
+import from GTPv2_Templates all;
+import from GTPv2_Emulation all;
+
+import from UECUPS_Types all;
+
+import from DNS_Helpers all;
+
+
+import from DIAMETER_Types all;
+import from DIAMETER_Templates all;
+import from DIAMETER_ts29_212_Templates all;
+import from DIAMETER_ts29_272_Templates all;
+import from DIAMETER_ts29_273_Templates all;
+import from DIAMETER_ts32_299_Templates all;
+import from DIAMETER_Emulation all;
+
+import from PGW_Tests all;
+
+const integer DIA_Gx := 0;
+const integer DIA_Gy := 1;
+const integer DIA_S6b := 2;
+
+/* per-session component; we typically have 1..N per testcase */
+type component PGW_Session_CT extends GTP2_ConnHdlr, GTP1U_ConnHdlr, DIAMETER_ConnHdlr {
+ var SessionPars g_pars;
+
+ /* GTP-U IPv4 address remote sie */
+ var OCT4 g_gtpu4_remote;
+ var OCT16 g_gtpu6_remote;
+
+ /* Address allocation */
+ var OCT4 g_ip4_addr;
+ var OCT8 g_ip6_interface_id;
+ var OCT16 g_ip6_addr;
+
+ /* Store last received Gy message */
+ var PDU_DIAMETER g_rx_gy;
+
+ /* number of programs started, used as identifier. */
+ var integer g_start_prog_count := 0;
+}
+
+type record BearerConfig {
+ /* EPS Bearer ID */
+ uint4_t ebi optional,
+ /* TEI (Data) local side */
+ OCT4 teid_local optional,
+ /* TEI (Data) remote side */
+ OCT4 teid_remote optional
+};
+
+type record SessionParsGy {
+ /* In seconds. 0 => disabled, !0 => grant over CC-Time period */
+ integer validity_time,
+
+ /* Result-Code to use when sending Gy CCA, usually DIAMETER_SUCCESS */
+ DIAMETER_Resultcode cca_res_code
+};
+
+/* configuration data for a given Session */
+type record SessionPars {
+ hexstring imsi,
+ hexstring msisdn optional,
+ // serving network
+ GTP2C_RAT_Type rat_type,
+ // flags?
+ charstring apn,
+ /* Apn subscribed or non-subscribed */
+ boolean selection_mode,
+ GTP2C_PDN_Type pdn_type,
+ /* PAA */
+ /* Max APN Restriction */
+ /* APN-AMBR */
+ octetstring pco optional,
+ octetstring epco optional,
+
+ /* TEI (Control) local side */
+ OCT4 teic_local,
+ /* TEI (Control) remote side */
+ OCT4 teic_remote optional,
+ /* Bearer Contexts to be created */
+ BearerConfig bearer optional,
+
+ charstring tun_dev_name,
+ charstring tun_netns_name optional,
+
+ SessionParsGy gy
+}
+
+template (value) SessionPars
+t_SessionPars(hexstring imsi,
+ charstring tundev,
+ template (omit) hexstring msisdn := '1234'H,
+ GTP2C_RAT_Type rat_type := GTP2C_RAT_EUTRAN,
+ charstring apn := "internet",
+ boolean selection_mode := false,
+ GTP2C_PDN_Type pdn_type := GTP2C_PDN_IPv4) := {
+ imsi := imsi,
+ msisdn := msisdn,
+ rat_type := rat_type,
+ apn := apn,
+ selection_mode := selection_mode,
+ pdn_type := pdn_type,
+ pco := omit,
+ epco := omit,
+ teic_local := '00000000'O,
+ teic_remote := omit,
+ bearer := {
+ ebi := 5,
+ teid_local := omit,
+ teid_remote := omit
+ },
+ tun_dev_name := tundev,
+ tun_netns_name := tundev,
+ gy := {
+ validity_time := 0,
+ cca_res_code := DIAMETER_SUCCESS
+ }
+}
+
+
+type function void_fn() runs on PGW_Session_CT;
+
+function f_handler_init(void_fn fn, SessionPars pars)
+runs on PGW_Session_CT {
+ g_pars := valueof(pars);
+
+ if (DIAMETER_PROC[DIA_Gx].checkstate("Connected")) {
+ f_diameter_expect_imsi(g_pars.imsi, idx := DIA_Gx);
+ }
+
+ if (DIAMETER_PROC[DIA_Gy].checkstate("Connected")) {
+ f_diameter_expect_imsi(g_pars.imsi, idx := DIA_Gy);
+ }
+
+ if (DIAMETER_PROC[DIA_S6b].checkstate("Connected")) {
+ f_diameter_expect_imsi(g_pars.imsi, idx := DIA_S6b);
+ }
+
+ /* allocate + register TEI{C,D} on local side */
+ g_pars.teic_local := f_gtp2_allocate_teic();
+ g_pars.bearer.teid_local := f_gtp1u_allocate_teid();
+ fn.apply();
+}
+
+/* S6b emulation (AAA-Server) */
+private altstep as_DIA_S6b_AAR() runs on PGW_Session_CT {
+ var PDU_DIAMETER rx_dia;
+ [] DIAMETER[DIA_S6b].receive(tr_DIA_S6b_AAR()) -> value rx_dia {
+ var template (value) PDU_DIAMETER tx_dia;
+ tx_dia := f_ts_DIA_S6b_AAA(rx_dia,
+ "aaa." & mp_diam_realm,
+ mp_diam_realm,
+ mp_diam_realm);
+ DIAMETER[DIA_S6b].send(tx_dia);
+ setverdict(pass);
+ }
+ [] DIAMETER[DIA_S6b].receive(PDU_DIAMETER:?) -> value rx_dia {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Received unexpected DIAMETER ", rx_dia));
+ }
+}
+
+/* Gx emulation (PCRF)*/
+altstep as_DIA_Gx_CCR(DCC_NONE_CC_Request_Type req_type) runs on PGW_Session_CT {
+ var PDU_DIAMETER rx_dia;
+ [] DIAMETER[DIA_Gx].receive(tr_DIA_Gx_CCR(req_type := req_type)) -> value rx_dia {
+ var template (value) PDU_DIAMETER tx_dia := f_ts_DIA_Gx_CCA(rx_dia);
+ DIAMETER[DIA_Gx].send(tx_dia);
+ }
+ [] DIAMETER[DIA_Gx].receive(PDU_DIAMETER:?) -> value rx_dia {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Received unexpected DIAMETER ", rx_dia));
+ }
+}
+
+/* Gy emulation (OCS) */
+private function f_tr_DIA_Gy_CCR_sess(DCC_NONE_CC_Request_Type req_type)
+runs on PGW_Session_CT return template (present) PDU_DIAMETER
+{
+ var octetstring imsi := char2oct(f_dec_TBCD(imsi_hex2oct(g_pars.imsi)));
+ var octetstring rat_type := int2oct(enum2int(g_pars.rat_type), 1);
+ var OCT1 nsapi := int2oct(g_pars.bearer.ebi, 1);
+ var OCT4 charging_char := char2oct(oct2str('0000'O)); // f_s5s8_create_session() uses hardcoded chg_car := '0000'O
+ var template (present) octetstring msisdn := ?;
+ var charstring smf_origin_host := "smf." & mp_diam_realm;
+ var octetstring sgsn_addr := f_inet_addr(mp_pcrf_local_ip);
+ var octetstring ggsn_addr := f_inet_addr(mp_pgw_hostname);
+
+ return DIAMETER_ts32_299_Templates.f_tr_DIA_Gy_CCR(req_type,
+ imsi,
+ msisdn,
+ rat_type,
+ nsapi,
+ charging_char,
+ smf_origin_host,
+ mp_diam_realm,
+ sgsn_addr,
+ ggsn_addr);
+
+}
+
+altstep as_DIA_Gy_CCR(DCC_NONE_CC_Request_Type req_type)
+runs on PGW_Session_CT {
+ [] DIAMETER[DIA_Gy].receive(f_tr_DIA_Gy_CCR_sess(req_type := req_type)) -> value g_rx_gy {
+ var template (value) PDU_DIAMETER tx_dia;
+ var template (omit) integer validity_time := omit;
+ if (g_pars.gy.validity_time > 0) {
+ validity_time := g_pars.gy.validity_time;
+ }
+ tx_dia := DIAMETER_ts32_299_Templates.f_ts_DIA_Gy_CCA(g_rx_gy, g_pars.gy.cca_res_code, validity_time);
+ DIAMETER[DIA_Gy].send(tx_dia);
+ }
+ [] DIAMETER[DIA_Gy].receive(PDU_DIAMETER:?) -> value g_rx_gy {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Received unexpected DIAMETER Gy", g_rx_gy));
+ }
+}
+
+/* GTPv2C */
+private function is_s2b_iface() runs on PGW_Session_CT return boolean {
+ return (g_pars.rat_type == GTP2C_RAT_WLAN or g_pars.rat_type == GTP2C_RAT_Virtual);
+}
+
+/* find TEID of given interface type (and optionally instance) */
+private function f_find_teid(FullyQualifiedTEID_List list,
+ template (present) integer if_type,
+ template (present) BIT4 instance := ?)
+return template (omit) FullyQualifiedTEID
+{
+ var integer i;
+ for (i := 0; i < lengthof(list); i := i+1) {
+ if (match(list[i].interfaceType, if_type) and
+ match(list[i].instance, instance)) {
+ return list[i];
+ }
+ }
+ return omit;
+}
+
+private function f_create_sess_tun() runs on PGW_Session_CT
+{
+ var template (value) UECUPS_AddrType user_addr_type;
+ var template (value) OCT4_20n user_addr;
+
+ select (g_pars.pdn_type) {
+ case (GTP2C_PDN_IPv4) {
+ user_addr_type := IPV4;
+ user_addr := g_ip4_addr;
+ }
+ case (GTP2C_PDN_IPv6) {
+ user_addr_type := IPV6;
+ user_addr := g_ip6_addr;
+ }
+ case (GTP2C_PDN_IPv4v6) {
+ user_addr_type := IPV4V6;
+ user_addr := g_ip4_addr & g_ip6_addr;
+ }
+ }
+
+ var template (value) UECUPS_CreateTun uecups_create := ts_UECUPS_CreateTun(
+ tx_teid := oct2int(g_pars.bearer.teid_remote),
+ rx_teid := oct2int(g_pars.bearer.teid_local),
+ user_addr_type := user_addr_type,
+ user_addr := user_addr,
+ local_gtp_ep := ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u)),
+ remote_gtp_ep := ts_UECUPS_SockAddr(g_gtpu4_remote),
+ tun_dev_name := g_pars.tun_dev_name,
+ tun_netns_name := g_pars.tun_netns_name
+ );
+
+ /* create tunnel in daemon */
+ f_gtp1u_create_tunnel(uecups_create);
+}
+
+private function f_perform_ipv6_slaac() runs on PGW_Session_CT
+{
+ var UECUPS_IPv6SLAACInd ipv6slaac_ind;
+ var template (value) UECUPS_IPv6SLAAC ipv6slaac;
+ ipv6slaac := ts_UECUPS_IPv6SLAAC(
+ local_gtp_ep := ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u)),
+ rx_teid := oct2int(g_pars.bearer.teid_local)
+ );
+ f_gtp1u_ipv6_slaac(ipv6slaac);
+ GTP1U[0].receive(UECUPS_IPv6SLAACInd:?) -> value ipv6slaac_ind;
+ log("5GC assigned IPv6 global prefix: ", ipv6slaac_ind.ipv6_prefix, " -> ", f_inet6_ntoa(ipv6slaac_ind.ipv6_prefix & '0000000000000000'O));
+
+ /* Use the first global IPv6 address in the IPv6 prefix picked by osmo-uecups: */
+ g_ip6_addr := ipv6slaac_ind.ipv6_user_addr;
+ log("Using IPv6 global address: ", g_ip6_addr);
+}
+
+/* process one to-be-created bearer context */
+private function process_bctx_create(BearerContextGrouped bctx) runs on PGW_Session_CT
+{
+ g_pars.bearer.ebi := bctx.bearerContextIEs.ePS_Bearer_ID.ePS_Bearer_ID_Value;
+ /* FIXME: Cause */
+
+ var integer exp_fteid_if_type;
+ var BIT4 exp_fteid_instance;
+ if (is_s2b_iface()) {
+ exp_fteid_if_type := 33;
+ exp_fteid_instance := '0100'B;
+ } else {
+ exp_fteid_if_type := 5;
+ exp_fteid_instance := '0010'B;
+ }
+
+ /* find F-TEID of the P-GW U side */
+ var FullyQualifiedTEID rx_fteid;
+ rx_fteid := valueof(f_find_teid(bctx.bearerContextIEs.fullyQualifiedTEID,
+ exp_fteid_if_type, exp_fteid_instance));
+ g_pars.bearer.teid_remote := rx_fteid.tEID_GRE_Key;
+ if (rx_fteid.v4_Flag == '1'B) {
+ g_gtpu4_remote := rx_fteid.iPv4_Address;
+ }
+ if (rx_fteid.v6_Flag == '1'B) {
+ g_gtpu6_remote := rx_fteid.iPv6_Address;
+ }
+
+ f_create_sess_tun();
+ if (g_pars.pdn_type == GTP2C_PDN_IPv6 or
+ g_pars.pdn_type == GTP2C_PDN_IPv4v6) {
+ f_perform_ipv6_slaac();
+ }
+}
+
+/* create a session on the PGW */
+private function f_create_session(template (value) FullyQualifiedTEID fteid_c_ie,
+ template (value) FullyQualifiedTEID fteid_u_ie,
+ template (omit) UserLocationInfo uli_ie := omit,
+ template (omit) APCO apco := omit,
+ template APCO exp_apco := *) runs on PGW_Session_CT {
+ var PDU_GTPCv2 rx;
+
+ /* Defaults used for s5/s8: */
+ var boolean do_s6b := false;
+ var template APN_Restriction apn_restriction := ?;
+ /* Change behavior when on S2b: */
+ if (is_s2b_iface()) {
+ do_s6b := true;
+ apn_restriction := omit;
+ }
+
+ var template (value) PDU_GTPCv2 g2c :=
+ ts_GTP2C_CreateSessionReq(imsi := g_pars.imsi,
+ msisdn := g_pars.msisdn,
+ rat_type := enum2int(g_pars.rat_type),
+ sender_fteid := fteid_c_ie,
+ apn := f_enc_dns_hostname(g_pars.apn),
+ pdn_type := int2bit(enum2int(g_pars.pdn_type), 3),
+ teid_list := { fteid_u_ie },
+ chg_car := '0000'O,
+ bearer_id := g_pars.bearer.ebi,
+ uli := uli_ie,
+ apco := apco);
+ g2c.gtpcv2_pdu.createSessionRequest.servingNetwork := ts_GTP2C_ServingNetwork('001'H, '01F'H);
+
+ GTP2.send(g2c);
+ if (do_s6b and DIAMETER[DIA_S6b].checkstate("Connected")) {
+ as_DIA_S6b_AAR();
+ }
+ if (DIAMETER[DIA_Gx].checkstate("Connected")) {
+ as_DIA_Gx_CCR(INITIAL_REQUEST);
+ }
+ /* FIXME: When on S2b interface, SMF is not using the Gy interface, unknown reason. */
+ if (DIAMETER[DIA_Gy].checkstate("Connected")) {
+ as_DIA_Gy_CCR(INITIAL_REQUEST);
+ }
+ alt {
+ [] GTP2.receive(tr_GTP2C_CreateSessionResp(d_teid := g_pars.teic_local,
+ cause := Request_accepted,
+ apn_restriction := apn_restriction,
+ exp_apco := exp_apco)) -> value rx {
+ /* extract TEIDs */
+ var CreateSessionResponse resp := rx.gtpcv2_pdu.createSessionResponse;
+ g_pars.teic_remote := resp.fullyQualifiedTEID[0].tEID_GRE_Key;
+
+ /* extract allocated address[es] */
+ var PDN_Address_and_Prefix paa := resp.pDN_AddressAllocation.pDN_Address_and_Prefix;
+ if (ischosen(paa.iPv4_Address)) {
+ g_ip4_addr := paa.iPv4_Address;
+ log("PGW assigned UE IPv4 address: ", f_inet_ntoa(g_ip4_addr));
+ } else if (ischosen(paa.iPv6_Address)) {
+ if (paa.iPv6_Address.prefixLength != 64) {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Got IPv6 Prefix Length ",
+ paa.iPv6_Address.prefixLength, " vs exp 64"));
+ }
+ g_ip6_interface_id := substr(paa.iPv6_Address.iPv6_Address, 8, 8);
+ log("PGW assigned IPv6 Interface Id: ", g_ip6_interface_id);
+ g_ip6_addr := 'FE80000000000000'O & g_ip6_interface_id;
+ log("PGW assigned IPv6 link-local Address: ", f_inet6_ntoa(g_ip6_addr));
+ } else if (ischosen(paa.iPv4_IPv6)) {
+ if (paa.iPv4_IPv6.prefixLength != 64) {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Got IPv6 Prefix Length ",
+ paa.iPv4_IPv6.prefixLength, " vs exp 64"));
+ }
+ g_ip4_addr := paa.iPv4_IPv6.iPv4_Address;
+ log("PGW assigned UE IPv4 address: ", f_inet_ntoa(g_ip4_addr));
+ g_ip6_interface_id := substr(paa.iPv4_IPv6.iPv6_Address, 8, 8);
+ log("PGW assigned IPv6 Interface Id: ", g_ip6_interface_id);
+ g_ip6_addr := 'FE80000000000000'O & g_ip6_interface_id;
+ log("PGW assigned IPv6 link-local Address: ", f_inet6_ntoa(g_ip6_addr));
+ }
+ var integer i;
+ for (i := 0; i < lengthof(resp.bearerContextGrouped); i := i+1) {
+ var BearerContextGrouped bctx := resp.bearerContextGrouped[i];
+ select (bctx.instance) {
+ case ('0000'B) { // created
+ process_bctx_create(bctx);
+ }
+ case ('0001'B) { // removed
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ "We don't expect removed bearer contexts yet");
+ }
+ }
+ }
+ }
+ [] GTP2.receive(tr_GTP2C_CreateSessionResp(d_teid:=g_pars.teic_local, cause:=?)) -> value rx {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ log2str("Unexpected CreateSessionResp(cause=",
+ rx.gtpcv2_pdu.createSessionResponse.cause.causeValue, ")"));
+ }
+ [] GTP2.receive {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ "Unexpected GTPv2 while waiting for CreateSessionResp");
+ }
+ }
+
+}
+
+/* create a session on the PGW on a S5/S8 interface (from SGW )*/
+function f_s5s8_create_session() runs on PGW_Session_CT {
+ var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
+ var template (value) UserLocationInfo uli_ie;
+
+ fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPC, g_pars.teic_local, 0,
+ f_inet_addr(mp_local_hostname_c), omit);
+ fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPU, g_pars.bearer.teid_local, 2,
+ f_inet_addr(mp_local_hostname_u), omit);
+
+
+ /* open5gs up to 1.2.3 won't accept it without ULI, despite not mandatory */
+ var template (value) TAI tai := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0001'O };
+ var template (value) ECGI ecgi := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0'H, 23 };
+ uli_ie := ts_GTP2C_UserLocInfo(tai := tai, ecgi := ecgi);
+
+ f_create_session(fteid_c_ie, fteid_u_ie, uli_ie);
+
+}
+
+/* create a session on the PGW on a S2b interface (from ePDG)*/
+function f_s2b_create_session(template (omit) APCO apco := omit,
+ template APCO exp_apco := *) runs on PGW_Session_CT {
+ var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
+ var template (value) UserLocationInfo uli_ie;
+
+ fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_ePDG_GTPC, g_pars.teic_local, 0,
+ f_inet_addr(mp_local_hostname_c), omit);
+ fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_ePDG_GTPU, g_pars.bearer.teid_local, 5,
+ f_inet_addr(mp_local_hostname_u), omit);
+
+ var template (value) TAI tai := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0001'O };
+ var template (value) ECGI ecgi := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0'H, 23 };
+ uli_ie := ts_GTP2C_UserLocInfo(tai := tai, ecgi := ecgi);
+
+ f_create_session(fteid_c_ie, fteid_u_ie, uli_ie := uli_ie, apco := apco, exp_apco := exp_apco);
+
+}
+
+/* delete the session from the PGW */
+function f_delete_session(template (omit) GTP2C_Cause tx_cause := omit,
+ template (present) GTP2C_Cause exp_cause,
+ boolean expect_diameter := true) runs on PGW_Session_CT {
+ var template (value) FullyQualifiedTEID fteid_c_ie
+ fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPC, g_pars.teic_local, 0,
+ f_inet_addr(mp_local_hostname_c), omit);
+ var template PDU_GTPCv2 g2c :=
+ ts_GTP2C_DeleteSessionReq(d_teid := g_pars.teic_remote, cause := tx_cause,
+ sender_fteid := fteid_c_ie,
+ teid_list := {}, bearer_id := g_pars.bearer.ebi);
+
+ GTP2.send(g2c);
+ if (DIAMETER[DIA_Gx].checkstate("Connected") and expect_diameter) {
+ as_DIA_Gx_CCR(TERMINATION_REQUEST);
+ }
+ if (DIAMETER[DIA_Gy].checkstate("Connected") and expect_diameter) {
+ as_DIA_Gy_CCR(TERMINATION_REQUEST);
+ }
+ alt {
+ [] GTP2.receive(tr_GTP2C_DeleteSessionResp(d_teid := g_pars.teic_local, cause := exp_cause)) {
+ setverdict(pass);
+ }
+ [] GTP2.receive(tr_GTP2C_DeleteSessionResp(?, ?)) {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ "Unexpected DeleteSessionResp");
+ }
+ [] GTP2.receive {
+ Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
+ "Unexpected GTPv2 while waiting for DeleteSessionResp");
+ }
+ }
+
+ /* destroy tunnel in daemon */
+ if (isbound(g_pars.bearer.teid_local)) {
+ var template (value) UECUPS_DestroyTun uecups_destroy;
+ uecups_destroy := ts_UECUPS_DestroyTun(
+ local_gtp_ep := valueof(ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u))),
+ rx_teid := oct2int(g_pars.bearer.teid_local)
+ );
+ /* FIXME: what about IPv4/IPv6 differentiation? */
+ f_gtp1u_destroy_tunnel(uecups_destroy);
+ }
+}
+
+
+private function f_run_prog_init(charstring command) runs on PGW_Session_CT return UECUPS_StartProgram
+{
+ var template (value) UECUPS_StartProgram sprog := ts_UECUPS_StartProgram(
+ command := command,
+ environment := {},
+ run_as_user := mp_run_prog_as_user,
+ tun_netns_name := g_pars.tun_netns_name
+ );
+ return valueof(sprog);
+}
+
+private function f_run_prog_unique_log_path() runs on PGW_Session_CT return charstring
+{
+ var charstring id := testcasename() & "-" & hex2str(g_pars.imsi) & "-" & int2str(g_start_prog_count);
+ var charstring prefix := mp_run_prog_log_path & "/" & id;
+ g_start_prog_count := g_start_prog_count + 1;
+ return prefix;
+}
+
+/* execute ping command and wait for result */
+function f_ping(charstring host, integer interval := 1, integer count := 10) runs on PGW_Session_CT
+{
+ /* command will be filled in by f_gtp1u_ping4() below: */
+ var UECUPS_StartProgram sprog := f_run_prog_init("");
+ var charstring bind_addr;
+
+ if (f_addr_is_ipv6(host)) {
+ bind_addr := f_inet6_ntoa(g_ip6_addr);
+ } else {
+ bind_addr := f_inet_ntoa(g_ip4_addr);
+ }
+
+ f_gtp1u_ping(sprog, host, interval, count, bind_addr,
+ redirect_output := true,
+ redirect_output_path_prefix := f_run_prog_unique_log_path());
+}
+
+}
diff --git a/pgw/PGW_Tests.ttcn b/pgw/PGW_Tests.ttcn
index 0c214fe..bd95090 100644
--- a/pgw/PGW_Tests.ttcn
+++ b/pgw/PGW_Tests.ttcn
@@ -26,6 +26,8 @@
import from DIAMETER_ts32_299_Templates all;
import from DIAMETER_Emulation all;
+import from PGW_Session_CT all;
+
modulepar {
charstring mp_pgw_hostname := "127.0.0.4";
charstring mp_local_hostname_c := "127.0.0.1";
@@ -48,10 +50,6 @@
charstring mp_diam_realm := "localdomain";
}
-const integer DIA_Gx := 0;
-const integer DIA_Gy := 1;
-const integer DIA_S6b := 2;
-
/* main component, we typically have one per testcase */
type component PGW_Test_CT extends GTP2_ConnHdlr, GTP1U_ConnHdlr {
var GTPv2_Emulation_CT vc_GTP2;
@@ -83,107 +81,6 @@
}
}
-/* per-session component; we typically have 1..N per testcase */
-type component PGW_Session_CT extends GTP2_ConnHdlr, GTP1U_ConnHdlr, DIAMETER_ConnHdlr {
- var SessionPars g_pars;
-
- /* GTP-U IPv4 address remote sie */
- var OCT4 g_gtpu4_remote;
- var OCT16 g_gtpu6_remote;
-
- /* Address allocation */
- var OCT4 g_ip4_addr;
- var OCT8 g_ip6_interface_id;
- var OCT16 g_ip6_addr;
-
- /* Store last received Gy message */
- var PDU_DIAMETER g_rx_gy;
-
- /* number of programs started, used as identifier. */
- var integer g_start_prog_count := 0;
-}
-
-type record BearerConfig {
- /* EPS Bearer ID */
- uint4_t ebi optional,
- /* TEI (Data) local side */
- OCT4 teid_local optional,
- /* TEI (Data) remote side */
- OCT4 teid_remote optional
-};
-
-type record SessionParsGy {
- /* In seconds. 0 => disabled, !0 => grant over CC-Time period */
- integer validity_time,
-
- /* Result-Code to use when sending Gy CCA, usually DIAMETER_SUCCESS */
- DIAMETER_Resultcode cca_res_code
-};
-
-/* configuration data for a given Session */
-type record SessionPars {
- hexstring imsi,
- hexstring msisdn optional,
- // serving network
- GTP2C_RAT_Type rat_type,
- // flags?
- charstring apn,
- /* Apn subscribed or non-subscribed */
- boolean selection_mode,
- GTP2C_PDN_Type pdn_type,
- /* PAA */
- /* Max APN Restriction */
- /* APN-AMBR */
- octetstring pco optional,
- octetstring epco optional,
-
- /* TEI (Control) local side */
- OCT4 teic_local,
- /* TEI (Control) remote side */
- OCT4 teic_remote optional,
- /* Bearer Contexts to be created */
- BearerConfig bearer optional,
-
- charstring tun_dev_name,
- charstring tun_netns_name optional,
-
- SessionParsGy gy
-}
-
-template (value) SessionPars
-t_SessionPars(hexstring imsi,
- charstring tundev,
- template (omit) hexstring msisdn := '1234'H,
- GTP2C_RAT_Type rat_type := GTP2C_RAT_EUTRAN,
- charstring apn := "internet",
- boolean selection_mode := false,
- GTP2C_PDN_Type pdn_type := GTP2C_PDN_IPv4) := {
- imsi := imsi,
- msisdn := msisdn,
- rat_type := rat_type,
- apn := apn,
- selection_mode := selection_mode,
- pdn_type := pdn_type,
- pco := omit,
- epco := omit,
- teic_local := '00000000'O,
- teic_remote := omit,
- bearer := {
- ebi := 5,
- teid_local := omit,
- teid_remote := omit
- },
- tun_dev_name := tundev,
- tun_netns_name := tundev,
- gy := {
- validity_time := 0,
- cca_res_code := DIAMETER_SUCCESS
- }
-}
-
-
-type function void_fn() runs on PGW_Session_CT;
-
friend function DiameterForwardUnitdataCallback(PDU_DIAMETER msg)
runs on DIAMETER_Emulation_CT return template PDU_DIAMETER {
DIAMETER_UNIT.send(msg);
@@ -341,438 +238,6 @@
return vc_conn;
}
-private function f_handler_init(void_fn fn, SessionPars pars)
-runs on PGW_Session_CT {
- g_pars := valueof(pars);
-
- if (DIAMETER_PROC[DIA_Gx].checkstate("Connected")) {
- f_diameter_expect_imsi(g_pars.imsi, idx := DIA_Gx);
- }
-
- if (DIAMETER_PROC[DIA_Gy].checkstate("Connected")) {
- f_diameter_expect_imsi(g_pars.imsi, idx := DIA_Gy);
- }
-
- if (DIAMETER_PROC[DIA_S6b].checkstate("Connected")) {
- f_diameter_expect_imsi(g_pars.imsi, idx := DIA_S6b);
- }
-
- /* allocate + register TEI{C,D} on local side */
- g_pars.teic_local := f_gtp2_allocate_teic();
- g_pars.bearer.teid_local := f_gtp1u_allocate_teid();
- fn.apply();
-}
-
-/* S6b emulation (AAA-Server) */
-private altstep as_DIA_S6b_AAR() runs on PGW_Session_CT {
- var PDU_DIAMETER rx_dia;
- [] DIAMETER[DIA_S6b].receive(tr_DIA_S6b_AAR()) -> value rx_dia {
- var template (value) PDU_DIAMETER tx_dia;
- tx_dia := f_ts_DIA_S6b_AAA(rx_dia,
- "aaa." & mp_diam_realm,
- mp_diam_realm,
- mp_diam_realm);
- DIAMETER[DIA_S6b].send(tx_dia);
- setverdict(pass);
- }
- [] DIAMETER[DIA_S6b].receive(PDU_DIAMETER:?) -> value rx_dia {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Received unexpected DIAMETER ", rx_dia));
- }
-}
-
-/* Gx emulation (PCRF)*/
-private altstep as_DIA_Gx_CCR(DCC_NONE_CC_Request_Type req_type) runs on PGW_Session_CT {
- var PDU_DIAMETER rx_dia;
- [] DIAMETER[DIA_Gx].receive(tr_DIA_Gx_CCR(req_type := req_type)) -> value rx_dia {
- var template (value) PDU_DIAMETER tx_dia := f_ts_DIA_Gx_CCA(rx_dia);
- DIAMETER[DIA_Gx].send(tx_dia);
- }
- [] DIAMETER[DIA_Gx].receive(PDU_DIAMETER:?) -> value rx_dia {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Received unexpected DIAMETER ", rx_dia));
- }
-}
-
-/* Gy emulation (OCS) */
-function f_tr_DIA_Gy_CCR(DCC_NONE_CC_Request_Type req_type)
-runs on PGW_Session_CT return template (present) PDU_DIAMETER
-{
- var octetstring imsi := char2oct(f_dec_TBCD(imsi_hex2oct(g_pars.imsi)));
- var octetstring rat_type := int2oct(enum2int(g_pars.rat_type), 1);
- var OCT1 nsapi := int2oct(g_pars.bearer.ebi, 1);
- var OCT4 charging_char := char2oct(oct2str('0000'O)); // f_s5s8_create_session() uses hardcoded chg_car := '0000'O
- var template (present) octetstring msisdn := ?;
- var charstring smf_origin_host := "smf." & mp_diam_realm;
- var octetstring sgsn_addr := f_inet_addr(mp_pcrf_local_ip);
- var octetstring ggsn_addr := f_inet_addr(mp_pgw_hostname);
-
- return DIAMETER_ts32_299_Templates.f_tr_DIA_Gy_CCR(req_type,
- imsi,
- msisdn,
- rat_type,
- nsapi,
- charging_char,
- smf_origin_host,
- mp_diam_realm,
- sgsn_addr,
- ggsn_addr);
-
-}
-
-private altstep as_DIA_Gy_CCR(DCC_NONE_CC_Request_Type req_type)
-runs on PGW_Session_CT {
- [] DIAMETER[DIA_Gy].receive(f_tr_DIA_Gy_CCR(req_type := req_type)) -> value g_rx_gy {
- var template (value) PDU_DIAMETER tx_dia;
- var template (omit) integer validity_time := omit;
- if (g_pars.gy.validity_time > 0) {
- validity_time := g_pars.gy.validity_time;
- }
- tx_dia := DIAMETER_ts32_299_Templates.f_ts_DIA_Gy_CCA(g_rx_gy, g_pars.gy.cca_res_code, validity_time);
- DIAMETER[DIA_Gy].send(tx_dia);
- }
- [] DIAMETER[DIA_Gy].receive(PDU_DIAMETER:?) -> value g_rx_gy {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Received unexpected DIAMETER Gy", g_rx_gy));
- }
-}
-
-/* GTPv2C */
-private function is_s2b_iface() runs on PGW_Session_CT return boolean {
- return (g_pars.rat_type == GTP2C_RAT_WLAN or g_pars.rat_type == GTP2C_RAT_Virtual);
-}
-
-/* find TEID of given interface type (and optionally instance) */
-private function f_find_teid(FullyQualifiedTEID_List list,
- template (present) integer if_type,
- template (present) BIT4 instance := ?)
-return template (omit) FullyQualifiedTEID
-{
- var integer i;
- for (i := 0; i < lengthof(list); i := i+1) {
- if (match(list[i].interfaceType, if_type) and
- match(list[i].instance, instance)) {
- return list[i];
- }
- }
- return omit;
-}
-
-private function f_create_sess_tun() runs on PGW_Session_CT
-{
- var template (value) UECUPS_AddrType user_addr_type;
- var template (value) OCT4_20n user_addr;
-
- select (g_pars.pdn_type) {
- case (GTP2C_PDN_IPv4) {
- user_addr_type := IPV4;
- user_addr := g_ip4_addr;
- }
- case (GTP2C_PDN_IPv6) {
- user_addr_type := IPV6;
- user_addr := g_ip6_addr;
- }
- case (GTP2C_PDN_IPv4v6) {
- user_addr_type := IPV4V6;
- user_addr := g_ip4_addr & g_ip6_addr;
- }
- }
-
- var template (value) UECUPS_CreateTun uecups_create := ts_UECUPS_CreateTun(
- tx_teid := oct2int(g_pars.bearer.teid_remote),
- rx_teid := oct2int(g_pars.bearer.teid_local),
- user_addr_type := user_addr_type,
- user_addr := user_addr,
- local_gtp_ep := ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u)),
- remote_gtp_ep := ts_UECUPS_SockAddr(g_gtpu4_remote),
- tun_dev_name := g_pars.tun_dev_name,
- tun_netns_name := g_pars.tun_netns_name
- );
-
- /* create tunnel in daemon */
- f_gtp1u_create_tunnel(uecups_create);
-}
-
-private function f_perform_ipv6_slaac() runs on PGW_Session_CT
-{
- var UECUPS_IPv6SLAACInd ipv6slaac_ind;
- var template (value) UECUPS_IPv6SLAAC ipv6slaac;
- ipv6slaac := ts_UECUPS_IPv6SLAAC(
- local_gtp_ep := ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u)),
- rx_teid := oct2int(g_pars.bearer.teid_local)
- );
- f_gtp1u_ipv6_slaac(ipv6slaac);
- GTP1U[0].receive(UECUPS_IPv6SLAACInd:?) -> value ipv6slaac_ind;
- log("5GC assigned IPv6 global prefix: ", ipv6slaac_ind.ipv6_prefix, " -> ", f_inet6_ntoa(ipv6slaac_ind.ipv6_prefix & '0000000000000000'O));
-
- /* Use the first global IPv6 address in the IPv6 prefix picked by osmo-uecups: */
- g_ip6_addr := ipv6slaac_ind.ipv6_user_addr;
- log("Using IPv6 global address: ", g_ip6_addr);
-}
-
-/* process one to-be-created bearer context */
-private function process_bctx_create(BearerContextGrouped bctx) runs on PGW_Session_CT
-{
- g_pars.bearer.ebi := bctx.bearerContextIEs.ePS_Bearer_ID.ePS_Bearer_ID_Value;
- /* FIXME: Cause */
-
- var integer exp_fteid_if_type;
- var BIT4 exp_fteid_instance;
- if (is_s2b_iface()) {
- exp_fteid_if_type := 33;
- exp_fteid_instance := '0100'B;
- } else {
- exp_fteid_if_type := 5;
- exp_fteid_instance := '0010'B;
- }
-
- /* find F-TEID of the P-GW U side */
- var FullyQualifiedTEID rx_fteid;
- rx_fteid := valueof(f_find_teid(bctx.bearerContextIEs.fullyQualifiedTEID,
- exp_fteid_if_type, exp_fteid_instance));
- g_pars.bearer.teid_remote := rx_fteid.tEID_GRE_Key;
- if (rx_fteid.v4_Flag == '1'B) {
- g_gtpu4_remote := rx_fteid.iPv4_Address;
- }
- if (rx_fteid.v6_Flag == '1'B) {
- g_gtpu6_remote := rx_fteid.iPv6_Address;
- }
-
- f_create_sess_tun();
- if (g_pars.pdn_type == GTP2C_PDN_IPv6 or
- g_pars.pdn_type == GTP2C_PDN_IPv4v6) {
- f_perform_ipv6_slaac();
- }
-}
-
-/* create a session on the PGW */
-private function f_create_session(template (value) FullyQualifiedTEID fteid_c_ie,
- template (value) FullyQualifiedTEID fteid_u_ie,
- template (omit) UserLocationInfo uli_ie := omit,
- template (omit) APCO apco := omit,
- template APCO exp_apco := *) runs on PGW_Session_CT {
- var PDU_GTPCv2 rx;
-
- /* Defaults used for s5/s8: */
- var boolean do_s6b := false;
- var template APN_Restriction apn_restriction := ?;
- /* Change behavior when on S2b: */
- if (is_s2b_iface()) {
- do_s6b := true;
- apn_restriction := omit;
- }
-
- var template (value) PDU_GTPCv2 g2c :=
- ts_GTP2C_CreateSessionReq(imsi := g_pars.imsi,
- msisdn := g_pars.msisdn,
- rat_type := enum2int(g_pars.rat_type),
- sender_fteid := fteid_c_ie,
- apn := f_enc_dns_hostname(g_pars.apn),
- pdn_type := int2bit(enum2int(g_pars.pdn_type), 3),
- teid_list := { fteid_u_ie },
- chg_car := '0000'O,
- bearer_id := g_pars.bearer.ebi,
- uli := uli_ie,
- apco := apco);
- g2c.gtpcv2_pdu.createSessionRequest.servingNetwork := ts_GTP2C_ServingNetwork('001'H, '01F'H);
-
- GTP2.send(g2c);
- if (do_s6b and DIAMETER[DIA_S6b].checkstate("Connected")) {
- as_DIA_S6b_AAR();
- }
- if (DIAMETER[DIA_Gx].checkstate("Connected")) {
- as_DIA_Gx_CCR(INITIAL_REQUEST);
- }
- /* FIXME: When on S2b interface, SMF is not using the Gy interface, unknown reason. */
- if (DIAMETER[DIA_Gy].checkstate("Connected")) {
- as_DIA_Gy_CCR(INITIAL_REQUEST);
- }
- alt {
- [] GTP2.receive(tr_GTP2C_CreateSessionResp(d_teid := g_pars.teic_local,
- cause := Request_accepted,
- apn_restriction := apn_restriction,
- exp_apco := exp_apco)) -> value rx {
- /* extract TEIDs */
- var CreateSessionResponse resp := rx.gtpcv2_pdu.createSessionResponse;
- g_pars.teic_remote := resp.fullyQualifiedTEID[0].tEID_GRE_Key;
-
- /* extract allocated address[es] */
- var PDN_Address_and_Prefix paa := resp.pDN_AddressAllocation.pDN_Address_and_Prefix;
- if (ischosen(paa.iPv4_Address)) {
- g_ip4_addr := paa.iPv4_Address;
- log("PGW assigned UE IPv4 address: ", f_inet_ntoa(g_ip4_addr));
- } else if (ischosen(paa.iPv6_Address)) {
- if (paa.iPv6_Address.prefixLength != 64) {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Got IPv6 Prefix Length ",
- paa.iPv6_Address.prefixLength, " vs exp 64"));
- }
- g_ip6_interface_id := substr(paa.iPv6_Address.iPv6_Address, 8, 8);
- log("PGW assigned IPv6 Interface Id: ", g_ip6_interface_id);
- g_ip6_addr := 'FE80000000000000'O & g_ip6_interface_id;
- log("PGW assigned IPv6 link-local Address: ", f_inet6_ntoa(g_ip6_addr));
- } else if (ischosen(paa.iPv4_IPv6)) {
- if (paa.iPv4_IPv6.prefixLength != 64) {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Got IPv6 Prefix Length ",
- paa.iPv4_IPv6.prefixLength, " vs exp 64"));
- }
- g_ip4_addr := paa.iPv4_IPv6.iPv4_Address;
- log("PGW assigned UE IPv4 address: ", f_inet_ntoa(g_ip4_addr));
- g_ip6_interface_id := substr(paa.iPv4_IPv6.iPv6_Address, 8, 8);
- log("PGW assigned IPv6 Interface Id: ", g_ip6_interface_id);
- g_ip6_addr := 'FE80000000000000'O & g_ip6_interface_id;
- log("PGW assigned IPv6 link-local Address: ", f_inet6_ntoa(g_ip6_addr));
- }
- var integer i;
- for (i := 0; i < lengthof(resp.bearerContextGrouped); i := i+1) {
- var BearerContextGrouped bctx := resp.bearerContextGrouped[i];
- select (bctx.instance) {
- case ('0000'B) { // created
- process_bctx_create(bctx);
- }
- case ('0001'B) { // removed
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- "We don't expect removed bearer contexts yet");
- }
- }
- }
- }
- [] GTP2.receive(tr_GTP2C_CreateSessionResp(d_teid:=g_pars.teic_local, cause:=?)) -> value rx {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- log2str("Unexpected CreateSessionResp(cause=",
- rx.gtpcv2_pdu.createSessionResponse.cause.causeValue, ")"));
- }
- [] GTP2.receive {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- "Unexpected GTPv2 while waiting for CreateSessionResp");
- }
- }
-
-}
-
-/* create a session on the PGW on a S5/S8 interface (from SGW )*/
-private function f_s5s8_create_session() runs on PGW_Session_CT {
- var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
- var template (value) UserLocationInfo uli_ie;
-
- fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPC, g_pars.teic_local, 0,
- f_inet_addr(mp_local_hostname_c), omit);
- fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPU, g_pars.bearer.teid_local, 2,
- f_inet_addr(mp_local_hostname_u), omit);
-
-
- /* open5gs up to 1.2.3 won't accept it without ULI, despite not mandatory */
- var template (value) TAI tai := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0001'O };
- var template (value) ECGI ecgi := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0'H, 23 };
- uli_ie := ts_GTP2C_UserLocInfo(tai := tai, ecgi := ecgi);
-
- f_create_session(fteid_c_ie, fteid_u_ie, uli_ie);
-
-}
-
-/* create a session on the PGW on a S2b interface (from ePDG)*/
-private function f_s2b_create_session(template (omit) APCO apco := omit,
- template APCO exp_apco := *) runs on PGW_Session_CT {
- var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
- var template (value) UserLocationInfo uli_ie;
-
- fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_ePDG_GTPC, g_pars.teic_local, 0,
- f_inet_addr(mp_local_hostname_c), omit);
- fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_ePDG_GTPU, g_pars.bearer.teid_local, 5,
- f_inet_addr(mp_local_hostname_u), omit);
-
- var template (value) TAI tai := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0001'O };
- var template (value) ECGI ecgi := { '0'H, '0'H, '1'H, 'F'H, '0'H, '1'H, '0'H, 23 };
- uli_ie := ts_GTP2C_UserLocInfo(tai := tai, ecgi := ecgi);
-
- f_create_session(fteid_c_ie, fteid_u_ie, uli_ie := uli_ie, apco := apco, exp_apco := exp_apco);
-
-}
-
-/* delete the session from the PGW */
-private function f_delete_session(template (omit) GTP2C_Cause tx_cause := omit,
- template (present) GTP2C_Cause exp_cause,
- boolean expect_diameter := true) runs on PGW_Session_CT {
- var template (value) FullyQualifiedTEID fteid_c_ie
- fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S5S8_SGW_GTPC, g_pars.teic_local, 0,
- f_inet_addr(mp_local_hostname_c), omit);
- var template PDU_GTPCv2 g2c :=
- ts_GTP2C_DeleteSessionReq(d_teid := g_pars.teic_remote, cause := tx_cause,
- sender_fteid := fteid_c_ie,
- teid_list := {}, bearer_id := g_pars.bearer.ebi);
-
- GTP2.send(g2c);
- if (DIAMETER[DIA_Gx].checkstate("Connected") and expect_diameter) {
- as_DIA_Gx_CCR(TERMINATION_REQUEST);
- }
- if (DIAMETER[DIA_Gy].checkstate("Connected") and expect_diameter) {
- as_DIA_Gy_CCR(TERMINATION_REQUEST);
- }
- alt {
- [] GTP2.receive(tr_GTP2C_DeleteSessionResp(d_teid := g_pars.teic_local, cause := exp_cause)) {
- setverdict(pass);
- }
- [] GTP2.receive(tr_GTP2C_DeleteSessionResp(?, ?)) {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- "Unexpected DeleteSessionResp");
- }
- [] GTP2.receive {
- Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail,
- "Unexpected GTPv2 while waiting for DeleteSessionResp");
- }
- }
-
- /* destroy tunnel in daemon */
- if (isbound(g_pars.bearer.teid_local)) {
- var template (value) UECUPS_DestroyTun uecups_destroy;
- uecups_destroy := ts_UECUPS_DestroyTun(
- local_gtp_ep := valueof(ts_UECUPS_SockAddr(f_inet_addr(mp_local_hostname_u))),
- rx_teid := oct2int(g_pars.bearer.teid_local)
- );
- /* FIXME: what about IPv4/IPv6 differentiation? */
- f_gtp1u_destroy_tunnel(uecups_destroy);
- }
-}
-
-
-private function f_run_prog_init(charstring command) runs on PGW_Session_CT return UECUPS_StartProgram
-{
- var template (value) UECUPS_StartProgram sprog := ts_UECUPS_StartProgram(
- command := command,
- environment := {},
- run_as_user := mp_run_prog_as_user,
- tun_netns_name := g_pars.tun_netns_name
- );
- return valueof(sprog);
-}
-
-private function f_run_prog_unique_log_path() runs on PGW_Session_CT return charstring
-{
- var charstring id := testcasename() & "-" & hex2str(g_pars.imsi) & "-" & int2str(g_start_prog_count);
- var charstring prefix := mp_run_prog_log_path & "/" & id;
- g_start_prog_count := g_start_prog_count + 1;
- return prefix;
-}
-
-/* execute ping command and wait for result */
-private function f_ping(charstring host, integer interval := 1, integer count := 10) runs on PGW_Session_CT
-{
- /* command will be filled in by f_gtp1u_ping4() below: */
- var UECUPS_StartProgram sprog := f_run_prog_init("");
- var charstring bind_addr;
-
- if (f_addr_is_ipv6(host)) {
- bind_addr := f_inet6_ntoa(g_ip6_addr);
- } else {
- bind_addr := f_inet_ntoa(g_ip4_addr);
- }
-
- f_gtp1u_ping(sprog, host, interval, count, bind_addr,
- redirect_output := true,
- redirect_output_path_prefix := f_run_prog_unique_log_path());
-}
-
/* send echo request; expect response */
testcase TC_tx_echo() runs on PGW_Test_CT {
timer T := 5.0;
To view, visit change 43296. To unsubscribe, or for help writing mail filters, visit settings.