add library/PFCP_*, deps/PFCP
Will soon be used by new subdir 'upf' (test osmo-upf),
and by 'hnbgw' (test GTP mapping via UPF).
Related: SYS#5599
Change-Id: I0723b931b3f755ea291bffa2f27c34ba446c2f2f
diff --git a/deps/Makefile b/deps/Makefile
index 2a906eb..f284f69 100644
--- a/deps/Makefile
+++ b/deps/Makefile
@@ -47,6 +47,7 @@
titan.ProtocolModules.NS_v7.3.0 \
titan.ProtocolModules.SGsAP_13.2.0 \
titan.ProtocolModules.SNDCP_v7.0.0 \
+ titan.ProtocolModules.PFCP_v15.1.0 \
titan.TestPorts.Common_Components.Socket-API \
titan.TestPorts.Common_Components.Abstract_Socket \
titan.TestPorts.HTTPmsg \
@@ -111,6 +112,7 @@
titan.ProtocolModules.SUA_commit= R.5.A-5-gcf1137a
titan.ProtocolModules.TCP_commit= R.3.A-5-g39e5f45
titan.ProtocolModules.UDP_commit= R.4.A-5-geea8aa3
+titan.ProtocolModules.PFCP_v15.1.0_commit= d550ad9ddb6f9c823c9a555254cd76cf0e738d18
titan.TestPorts.AF_PACKET_commit= 0.1-5-g89ebea6
titan.TestPorts.Common_Components.Socket-API_commit= R.6.A-6-gf4380d0
titan.TestPorts.Common_Components.Abstract_Socket_commit= R.9.B-4-gbd41994
diff --git a/library/General_Types.ttcn b/library/General_Types.ttcn
index 9a8489f..c818313 100644
--- a/library/General_Types.ttcn
+++ b/library/General_Types.ttcn
@@ -286,6 +286,7 @@
type integer LIN2_BO_LAST (0..65535) with { variant "FIELDLENGTH(16), COMP(nosign), BYTEORDER(last)" };
type integer LIN3_BO_LAST (0..16777215) with { variant "FIELDLENGTH(24), COMP(nosign), BYTEORDER(last)" };
type integer LIN4_BO_LAST (0..4294967295) with { variant "FIELDLENGTH(32), COMP(nosign), BYTEORDER(last)" };
+ type integer LIN8_BO_LAST (0..18446744073709551616) with { variant "FIELDLENGTH(64), COMP(nosign), BYTEORDER(last)" };
//integer with fixed bit number
type integer INT1b (0..1) with { variant "FIELDLENGTH(1)" };
diff --git a/library/PFCP_CodecPort.ttcn b/library/PFCP_CodecPort.ttcn
new file mode 100644
index 0000000..8d4078d
--- /dev/null
+++ b/library/PFCP_CodecPort.ttcn
@@ -0,0 +1,56 @@
+/* dual-faced port sitting on top of IPL4_asp UDP to encode/decode PFCP
+ *
+ * (C) 2022 sysmocom - s.f.m.c. GmbH <info@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 PFCP_CodecPort {
+
+import from IPL4asp_PortType all;
+import from IPL4asp_Types all;
+import from PFCP_Types all;
+
+/* identifies a remote peer (sender or receiver) */
+type record PFCP_Peer {
+ ConnectionId conn_id,
+ HostName remote_name,
+ PortNumber remote_port
+}
+
+type record PFCP_Unitdata {
+ PFCP_Peer peer,
+ PDU_PFCP pdu
+}
+
+/* Translation port on top of IPL4asp; ASP_Event passed through transparently */
+type port PFCP_PT message {
+ out PFCP_Unitdata;
+ in PFCP_Unitdata,
+ ASP_ConnId_ReadyToRelease,
+ ASP_Event;
+} with { extension "user IPL4asp_PT
+ out(PFCP_Unitdata -> ASP_SendTo: function(f_enc_pfcp_unitdata))
+ in(ASP_RecvFrom -> PFCP_Unitdata: function(f_dec_pfcp_unitdata);
+ ASP_ConnId_ReadyToRelease -> ASP_ConnId_ReadyToRelease: simple;
+ ASP_Event -> ASP_Event: simple)" }
+
+private function f_enc_pfcp_unitdata(in PFCP_Unitdata in_ud, out ASP_SendTo out_ud) {
+ out_ud.connId := in_ud.peer.conn_id;
+ out_ud.remName := in_ud.peer.remote_name;
+ out_ud.remPort := in_ud.peer.remote_port;
+ out_ud.proto := { udp := {} };
+ out_ud.msg := enc_PDU_PFCP(in_ud.pdu);
+} with { extension "prototype(fast)" };
+
+private function f_dec_pfcp_unitdata(in ASP_RecvFrom in_ud, out PFCP_Unitdata out_ud) {
+ out_ud.peer.conn_id := in_ud.connId;
+ out_ud.peer.remote_name := in_ud.remName;
+ out_ud.peer.remote_port := in_ud.remPort;
+ out_ud.pdu := dec_PDU_PFCP(in_ud.msg);
+} with { extension "prototype(fast)" };
+
+}
diff --git a/library/PFCP_CodecPort_CtrlFunct.ttcn b/library/PFCP_CodecPort_CtrlFunct.ttcn
new file mode 100644
index 0000000..bd6af4b
--- /dev/null
+++ b/library/PFCP_CodecPort_CtrlFunct.ttcn
@@ -0,0 +1,43 @@
+module PFCP_CodecPort_CtrlFunct {
+
+import from PFCP_CodecPort all;
+import from IPL4asp_Types all;
+
+external function f_IPL4_listen(
+ inout PFCP_PT portRef,
+ in HostName locName,
+ in PortNumber locPort,
+ in ProtoTuple proto,
+ in OptionList options := {}
+ ) return Result;
+
+external function f_IPL4_connect(
+ inout PFCP_PT portRef,
+ in HostName remName,
+ in PortNumber remPort,
+ in HostName locName,
+ in PortNumber locPort,
+ in ConnectionId connId,
+ in ProtoTuple proto,
+ in OptionList options := {}
+ ) return Result;
+
+external function f_IPL4_close(
+ inout PFCP_PT portRef,
+ in ConnectionId id,
+ in ProtoTuple proto := { unspecified := {} }
+ ) return Result;
+
+external function f_IPL4_setUserData(
+ inout PFCP_PT portRef,
+ in ConnectionId id,
+ in UserData userData
+ ) return Result;
+
+external function f_IPL4_getUserData(
+ inout PFCP_PT portRef,
+ in ConnectionId id,
+ out UserData userData
+ ) return Result;
+
+}
diff --git a/library/PFCP_CodecPort_CtrlFunctDef.cc b/library/PFCP_CodecPort_CtrlFunctDef.cc
new file mode 100644
index 0000000..1b51633
--- /dev/null
+++ b/library/PFCP_CodecPort_CtrlFunctDef.cc
@@ -0,0 +1,55 @@
+#include "IPL4asp_PortType.hh"
+#include "IPL4asp_PT.hh"
+#include "PFCP_CodecPort.hh"
+
+namespace PFCP__CodecPort__CtrlFunct {
+
+ IPL4asp__Types::Result f__IPL4__listen(
+ PFCP__CodecPort::PFCP__PT& portRef,
+ const IPL4asp__Types::HostName& locName,
+ const IPL4asp__Types::PortNumber& locPort,
+ const IPL4asp__Types::ProtoTuple& proto,
+ const IPL4asp__Types::OptionList& options)
+ {
+ return f__IPL4__PROVIDER__listen(portRef, locName, locPort, proto, options);
+ }
+
+ IPL4asp__Types::Result f__IPL4__connect(
+ PFCP__CodecPort::PFCP__PT& portRef,
+ const IPL4asp__Types::HostName& remName,
+ const IPL4asp__Types::PortNumber& remPort,
+ const IPL4asp__Types::HostName& locName,
+ const IPL4asp__Types::PortNumber& locPort,
+ const IPL4asp__Types::ConnectionId& connId,
+ const IPL4asp__Types::ProtoTuple& proto,
+ const IPL4asp__Types::OptionList& options)
+ {
+ return f__IPL4__PROVIDER__connect(portRef, remName, remPort,
+ locName, locPort, connId, proto, options);
+ }
+
+ IPL4asp__Types::Result f__IPL4__close(
+ PFCP__CodecPort::PFCP__PT& portRef,
+ const IPL4asp__Types::ConnectionId& connId,
+ const IPL4asp__Types::ProtoTuple& proto)
+ {
+ return f__IPL4__PROVIDER__close(portRef, connId, proto);
+ }
+
+ IPL4asp__Types::Result f__IPL4__setUserData(
+ PFCP__CodecPort::PFCP__PT& portRef,
+ const IPL4asp__Types::ConnectionId& connId,
+ const IPL4asp__Types::UserData& userData)
+ {
+ return f__IPL4__PROVIDER__setUserData(portRef, connId, userData);
+ }
+
+ IPL4asp__Types::Result f__IPL4__getUserData(
+ PFCP__CodecPort::PFCP__PT& portRef,
+ const IPL4asp__Types::ConnectionId& connId,
+ IPL4asp__Types::UserData& userData)
+ {
+ return f__IPL4__PROVIDER__getUserData(portRef, connId, userData);
+ }
+
+}
diff --git a/library/PFCP_Emulation.ttcn b/library/PFCP_Emulation.ttcn
new file mode 100644
index 0000000..05a07b1
--- /dev/null
+++ b/library/PFCP_Emulation.ttcn
@@ -0,0 +1,202 @@
+/* PFCP Emulation in TTCN-3
+ *
+ * (C) 2022 sysmocom - s.f.m.c. GmbH <info@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 PFCP_Emulation {
+
+import from IPL4asp_Types all;
+import from General_Types all;
+import from Osmocom_Types all;
+import from PFCP_Types all;
+import from PFCP_CodecPort all;
+import from PFCP_CodecPort_CtrlFunct all;
+
+/***********************************************************************
+ * Main Emulation Component
+ ***********************************************************************/
+
+const integer PFCP_PORT := 8805;
+
+type enumerated PFCP_Role {
+ CPF,
+ UPF
+};
+
+type record PFCP_Emulation_Cfg {
+ HostName pfcp_bind_ip,
+ PortNumber pfcp_bind_port,
+ HostName pfcp_remote_ip,
+ PortNumber pfcp_remote_port,
+ PFCP_Role role
+};
+
+type component PFCP_Emulation_CT {
+ /* Communication with underlying PFCP CodecPort */
+ port PFCP_PT PFCP;
+
+ /* Communication with Clients */
+ port PFCPEM_PT CLIENT;
+ port PFCPEM_PROC_PT CLIENT_PROC;
+
+ /* Configuration by the user */
+ var PFCP_Emulation_Cfg g_pfcp_cfg;
+
+ /* State */
+ var integer g_pfcp_conn_id;
+ var integer g_recovery_timestamp;
+
+ var PFCPEM_conns g_conns;
+
+ var integer g_next_sequence_nr_state;
+};
+
+private function f_PFCPEM_next_sequence_nr() runs on PFCP_Emulation_CT return integer {
+ g_next_sequence_nr_state := g_next_sequence_nr_state + 1;
+ if (g_next_sequence_nr_state > 16777215) {
+ g_next_sequence_nr_state := 1;
+ }
+ return g_next_sequence_nr_state;
+}
+
+type record PFCPEM_conn {
+ PFCP_ConnHdlr vc_conn,
+ OCT8 seid optional,
+ LIN3_BO_LAST pfcp_msg_sequence_number optional
+};
+
+type record of PFCPEM_conn PFCPEM_conns;
+
+private function f_PFCPEM_conn_by_seid_or_seqnr(OCT8 seid, LIN3_BO_LAST seqnr) runs on PFCP_Emulation_CT return PFCP_ConnHdlr {
+ log("looking for seid ", seid, " seqnr ", seqnr, " in conns ", g_conns);
+ for (var integer i := 0; i < lengthof(g_conns); i := i + 1) {
+ if (isbound(g_conns[i].pfcp_msg_sequence_number)
+ and seqnr == g_conns[i].pfcp_msg_sequence_number) {
+ return g_conns[i].vc_conn;
+ }
+ if (isbound(g_conns[i].seid)
+ and seid == g_conns[i].seid) {
+ return g_conns[i].vc_conn;
+ }
+ }
+ return null;
+};
+
+private function f_PFCPEM_add_conn(PFCP_ConnHdlr vc_conn) runs on PFCP_Emulation_CT {
+ for (var integer i := 0; i < lengthof(g_conns); i := i + 1) {
+ if (g_conns[i].vc_conn == vc_conn) {
+ return;
+ }
+ }
+ /* Not in the list yet, add. */
+ var PFCPEM_conn conn := { vc_conn := vc_conn };
+ g_conns := g_conns & { conn };
+}
+
+private function f_init(PFCP_Emulation_Cfg cfg) runs on PFCP_Emulation_CT {
+ var Result res;
+
+ map(self:PFCP, system:PFCP);
+ res := PFCP_CodecPort_CtrlFunct.f_IPL4_listen(PFCP, cfg.pfcp_bind_ip, cfg.pfcp_bind_port, {udp:={}});
+ g_pfcp_conn_id := res.connId;
+
+ g_recovery_timestamp := f_rnd_int(4294967296);
+ g_pfcp_cfg := cfg;
+
+ g_conns := {};
+
+ g_next_sequence_nr_state := (1 + f_rnd_int(1000)) * 10000;
+}
+
+function main(PFCP_Emulation_Cfg cfg) runs on PFCP_Emulation_CT {
+ var PFCP_ConnHdlr vc_conn;
+ var PFCP_Unitdata ud;
+ var PDU_PFCP pdu;
+
+ f_init(cfg);
+
+ while (true) {
+ alt {
+ [] PFCP.receive(PFCP_Unitdata:?) -> value ud {
+ log("PFCP_Emulation main() PFCP.receive: ", ud);
+ vc_conn := null;
+ if (ud.pdu.s_flag == '1'B) {
+ /* There is a SEID */
+ vc_conn := f_PFCPEM_conn_by_seid_or_seqnr(ud.pdu.seid, ud.pdu.sequence_number);
+ }
+ if (vc_conn != null) {
+ log("found destination ", vc_conn);
+ CLIENT.send(ud.pdu) to vc_conn;
+ } else {
+ log("sending to all conns: ", g_conns);
+ for (var integer i := 0; i < lengthof(g_conns); i := i + 1) {
+ CLIENT.send(ud.pdu) to g_conns[i].vc_conn;
+ }
+ }
+ }
+
+ [] CLIENT.receive(PDU_PFCP:?) -> value pdu sender vc_conn {
+ log("PFCP_Emulation main() CLIENT.receive from ", vc_conn, ": ", pdu);
+ if (pdu.sequence_number == 0) {
+ pdu.sequence_number := f_PFCPEM_next_sequence_nr();
+ }
+ ud := {
+ peer := {
+ conn_id := g_pfcp_conn_id,
+ remote_name := g_pfcp_cfg.pfcp_remote_ip,
+ remote_port := g_pfcp_cfg.pfcp_remote_port
+ },
+ pdu := pdu
+ };
+
+ f_PFCPEM_add_conn(vc_conn);
+
+ PFCP.send(ud);
+ }
+
+ [] CLIENT_PROC.getcall(PFCPEM_register:{}) -> sender vc_conn {
+ log("PFCP_Emulation main() CLIENT_PROC.getcall(PFCPEM_register)");
+ f_PFCPEM_add_conn(vc_conn);
+ CLIENT_PROC.reply(PFCPEM_register:{}) to vc_conn;
+ }
+ }
+ }
+}
+
+
+/***********************************************************************
+ * Interaction between Main and Client Components
+ ***********************************************************************/
+type port PFCPEM_PT message {
+ inout PDU_PFCP;
+} with { extension "internal" };
+
+signature PFCPEM_register();
+
+type port PFCPEM_PROC_PT procedure {
+ inout PFCPEM_register;
+} with { extension "internal" };
+
+/***********************************************************************
+ * Client Compoennt
+ ***********************************************************************/
+
+type component PFCP_ConnHdlr {
+ port PFCPEM_PT PFCP;
+ port PFCPEM_PROC_PT PFCP_PROC;
+ var PFCP_Emulation_CT vc_PFCP;
+};
+
+function f_pfcp_register() runs on PFCP_ConnHdlr {
+ PFCP_PROC.call(PFCPEM_register:{}) {
+ [] PFCP_PROC.getreply(PFCPEM_register:{});
+ }
+}
+
+}
diff --git a/library/PFCP_Templates.ttcn b/library/PFCP_Templates.ttcn
new file mode 100644
index 0000000..d0e8b67
--- /dev/null
+++ b/library/PFCP_Templates.ttcn
@@ -0,0 +1,567 @@
+/* PFCP Templates in TTCN-3
+ * (C) 2022 sysmocom - s.f.m.c. GmbH <info@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 PFCP_Templates {
+
+import from General_Types all;
+import from Native_Functions all;
+import from Osmocom_Types all;
+import from PFCP_Types all;
+
+type enumerated e_PFCP_Cause {
+ RESERVED (0),
+ REQUEST_ACCEPTED (1),
+ MORE_USAGE_REPORT_TO_SEND (2),
+ REQUEST_REJECTED (64),
+ SESSION_CTX_NOT_FOUND (65),
+ MANDATORY_IE_MISSING (66),
+ CONDITIONAL_IE_MISSING (67),
+ INVALID_LENGTH (68),
+ MANDATORY_IE_INCORRECT (69),
+ INVALID_FORW_POLICY (70),
+ INVALID_F_TEID_ALLOC_OPTION (71),
+ NO_ESTABLISHED_PFCP_ASSOC (72),
+ RULE_CREATION_MOD_FAILURE (73),
+ PFCP_ENTITY_IN_CONGESTION (74),
+ NO_RESOURCES_AVAILABLE (75),
+ SERVICE_NOT_SUPPORTED (76),
+ SYSTEM_FAILURE (77),
+ REDIRECTION_REQUESTED (78),
+ ALL_DYNAMIC_ADDRESSES_ARE_OCCUPIED (79)
+};
+
+template (value) Cause ts_PFCP_Cause(e_PFCP_Cause cause) := {
+ elementIdentifier := 19,
+ lengthIndicator := 0,
+ causeValue := int2oct(enum2int(cause), 1)
+};
+
+template (present) Cause tr_PFCP_Cause(e_PFCP_Cause cause) := {
+ elementIdentifier := 19,
+ lengthIndicator := ?,
+ causeValue := int2oct(enum2int(cause), 1)
+};
+
+const INT4b PFCP_Node_ID_IPv4 := 0;
+const INT4b PFCP_Node_ID_IPv6 := 1;
+const INT4b PFCP_Node_ID_FQDN := 2;
+
+template (value) Node_ID ts_PFCP_Node_ID(INT4b id_type, octetstring id_value) := {
+ elementIdentifier := 60,
+ lengthIndicator := 0,
+ node_id_type := id_type,
+ spare := '0000'B,
+ node_id_value := id_value
+};
+
+template (present) Node_ID tr_PFCP_Node_ID(template (present) INT4b id_type := ?,
+ template (present) octetstring id_value := ?) := {
+ elementIdentifier := 60,
+ lengthIndicator := ?,
+ node_id_type := id_type,
+ spare := ?,
+ node_id_value := id_value
+};
+
+/* t_PFCP_Node_ID_IPv4(f_inet_addr("127.0.0.1")) */
+template (value) Node_ID ts_PFCP_Node_ID_ipv4(OCT4 ip_value) := ts_PFCP_Node_ID(PFCP_Node_ID_IPv4, ip_value);
+template (value) Node_ID ts_PFCP_Node_ID_fqdn(charstring fqdn) := ts_PFCP_Node_ID(PFCP_Node_ID_FQDN, char2oct(fqdn));
+
+template (value) Recovery_Time_Stamp ts_PFCP_Recovery_Timestamp(LIN4_BO_LAST time_value) := {
+ elementIdentifier := 96,
+ lengthIndicator := 0,
+ time_value := time_value
+};
+
+template (present) Recovery_Time_Stamp tr_PFCP_Recovery_Timestamp(template (present) LIN4_BO_LAST time_value := ?) := {
+ elementIdentifier := 96,
+ lengthIndicator := ?,
+ time_value := time_value
+};
+
+template (value) PDU_PFCP ts_PDU_PFCP_ := {
+ s_flag := '0'B,
+ mp := '0'B,
+ spare := '000'B,
+ version := 1,
+ message_type := 0,
+ lengthIndicator := 0,
+ seid := omit,
+ sequence_number := 0,
+ spare2 := '0000'B,
+ mp_or_spare := '0000'B,
+ message_body := -
+};
+
+template (present) PDU_PFCP tr_PDU_PFCP_ := {
+ s_flag := ?,
+ mp := ?,
+ spare := ?,
+ version := 1,
+ message_type := ?,
+ lengthIndicator := ?,
+ seid := *,
+ sequence_number := ?,
+ spare2 := ?,
+ mp_or_spare := ?,
+ message_body := ?
+};
+
+template (value) PDU_PFCP ts_PDU_PFCP(LIN3_BO_LAST sequence_number := 0, template (omit) OCT8 seid := omit)
+modifies ts_PDU_PFCP_ := {
+ seid := seid,
+ sequence_number := sequence_number
+};
+
+template (present) PDU_PFCP tr_PDU_PFCP(template OCT8 seid := *)
+modifies tr_PDU_PFCP_ := {
+ seid := seid
+};
+
+template (value) PDU_PFCP ts_PFCP_Assoc_Setup_Req(template (value) Node_ID node_id, LIN4_BO_LAST recovery_timestamp)
+modifies ts_PDU_PFCP_ := {
+ message_body := {
+ pfcp_association_setup_request := {
+ node_id := node_id,
+ time_stamp := ts_PFCP_Recovery_Timestamp(recovery_timestamp),
+ up_function_features := omit,
+ cp_function_features := omit,
+ UP_IP_resource_list := omit
+ }
+ }
+};
+
+function tr_PFCP_Assoc_Setup_Req(template (present) Node_ID node_id := ?) return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP();
+ t.message_body := {
+ pfcp_association_setup_request := {
+ node_id := node_id,
+ time_stamp := ?,
+ up_function_features := *,
+ cp_function_features := *,
+ UP_IP_resource_list := *
+ }
+ };
+ return t;
+};
+
+template (value) PDU_PFCP ts_PFCP_Assoc_Setup_Resp(LIN3_BO_LAST sequence_number,
+ template (value) Node_ID node_id,
+ template (value) Cause cause,
+ LIN4_BO_LAST recovery_timestamp)
+modifies ts_PDU_PFCP_ := {
+ sequence_number := sequence_number,
+ message_body := {
+ pfcp_association_setup_response := {
+ node_id := node_id,
+ cause := cause,
+ time_stamp := ts_PFCP_Recovery_Timestamp(recovery_timestamp),
+ up_function_features := omit,
+ cp_function_features := omit,
+ UP_IP_resource_list := omit
+ }
+ }
+};
+
+function tr_PFCP_Assoc_Setup_Resp(template (present) Node_ID node_id := ?,
+ template (present) Cause cause := ?) return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP();
+ t.message_body := {
+ pfcp_association_setup_response := {
+ node_id := node_id,
+ cause := cause,
+ time_stamp := ?,
+ up_function_features := *,
+ cp_function_features := *,
+ UP_IP_resource_list := *
+ }
+ };
+ return t;
+};
+
+function ts_PFCP_Assoc_Release_Req(template (value) Node_ID node_id) return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP();
+
+ t.message_body := {
+ pfcp_association_release_request := {
+ node_id := node_id
+ }
+ };
+ return t;
+};
+
+function tr_PFCP_Assoc_Release_Resp(template (present) Node_ID node_id := ?, template (present) Cause cause := ?)
+ return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP();
+ t.message_body := {
+ pfcp_association_release_response := {
+ node_id := node_id,
+ cause := cause
+ }
+ };
+ return t;
+};
+
+template (value) F_SEID ts_PFCP_F_SEID_ipv4(charstring addr_v4, OCT8 seid) := {
+ elementIdentifier := 57,
+ lengthIndicator := 0,
+ v6 := '0'B,
+ v4 := '1'B,
+ spare := '000000'B,
+ seid := seid,
+ ipv4_address := f_inet_addr(addr_v4),
+ ipv6_address := omit
+}
+
+type enumerated e_PFCP_Src_Iface {
+ ACCESS (0),
+ CORE (1),
+ SGI_LAN_N6_LAN (2),
+ CP_FUNCTION (3),
+ x_5G_VN_INTERNAL (4)
+};
+
+template (value) Source_Interface ts_PFCP_Src_Iface(e_PFCP_Src_Iface iface) := {
+ elementIdentifier := 20,
+ lengthIndicator := 0,
+ interfacevalue := enum2int(iface),
+ spare := '0000'B
+}
+
+template (value) UE_IP_Address ts_PFCP_UE_IP_Address_v4(charstring addr_v4, boolean is_destination := true) := {
+ elementIdentifier := 93,
+ lengthIndicator := 0,
+ v6 := '0'B,
+ v4 := '1'B,
+ sd := bool2bit(is_destination),
+ spare := '00000'B,
+ ipv4_address := f_inet_addr(addr_v4),
+ ipv6_address := omit
+}
+
+template (value) F_TEID ts_PFCP_F_TEID_ipv4(OCT4 teid, charstring addr_v4) := {
+ elementIdentifier := 21,
+ lengthIndicator := 0,
+ v4 := '1'B,
+ v6 := '0'B,
+ ch := '0'B,
+ chid := '0'B,
+ spare := '0000'B,
+ teid := teid,
+ ipv4_address := f_inet_addr(addr_v4),
+ ipv6_address := omit,
+ choose_id := omit
+}
+
+template (value) F_TEID ts_PFCP_F_TEID_choose_v4(template (omit) OCT1 choose_id := omit) := {
+ elementIdentifier := 21,
+ lengthIndicator := 0,
+ v4 := '1'B,
+ v6 := '0'B,
+ ch := '1'B,
+ chid := '0'B,
+ spare := '0000'B,
+ teid := omit,
+ ipv4_address := omit,
+ ipv6_address := omit,
+ choose_id := choose_id
+}
+
+template (value) PDI_IE ts_PFCP_PDI(e_PFCP_Src_Iface src_iface,
+ template (omit) F_TEID local_F_TEID := omit,
+ template (omit) UE_IP_Address ue_addr_v4 := omit) := {
+ elementIdentifier := 2,
+ lengthIndicator := 0,
+ grouped_ie := {
+ source_interface := ts_PFCP_Src_Iface(src_iface),
+ local_F_TEID := local_F_TEID,
+ pdn_instance := omit,
+ ue_ip_address := ue_addr_v4,
+ traffic_endpoint_id := omit,
+ sdf_filter_list := omit,
+ application_id := omit,
+ ethernet_packet_filter_list := omit,
+ qfi_list := omit
+ }
+}
+
+template (value) Apply_Action ts_PFCP_Apply_Action(BIT1 forw := '0'B, BIT1 drop := '0'B, BIT1 buff := '0'B) := {
+ elementIdentifier := 44,
+ lengthIndicator := 0,
+ drop := drop,
+ forw := forw,
+ buff := buff,
+ nocp := '0'B,
+ dupl := '0'B,
+ spare := '000'B
+}
+
+function ts_PFCP_Apply_Action_FORW() return template (value) Apply_Action {
+ return ts_PFCP_Apply_Action(forw := '1'B);
+}
+template (value) Apply_Action ts_PFCP_Apply_Action_DROP := ts_PFCP_Apply_Action(drop := '1'B);
+template (value) Apply_Action ts_PFCP_Apply_Action_BUFF := ts_PFCP_Apply_Action(buff := '1'B);
+
+type enumerated e_PFCP_Dest_Iface {
+ ACCESS (0),
+ CORE (1),
+ SGI_LAN_N6_LAN (2),
+ CP_FUNCTION (3),
+ LI_FUNCTION (4),
+ x_5G_VN_INTERNAL (5)
+};
+
+template (value) Destination_Interface ts_PFCP_Destination_Interface(e_PFCP_Dest_Iface di) := {
+ elementIdentifier := 42,
+ lengthIndicator := 0,
+ interface_value := enum2int(di),
+ spare := '0000'B
+}
+
+template (value) Outer_Header_Creation ts_PFCP_Outer_Header_Creation_GTP_ipv4(OCT4 remote_teid, charstring remote_addr_v4) := {
+ elementIdentifier := 84,
+ lengthIndicator := 0,
+ ohc_description_oct5 := '00000001'B,
+ ohc_description_oct6 := '00000000'B,
+ teid := remote_teid,
+ ipv4 := f_inet_addr(remote_addr_v4),
+ ipv6 := omit,
+ udp_port := omit
+}
+
+type enumerated e_PFCP_Outer_Header_Removal {
+ GTP_U_UDP_IPV4 (0),
+ GTP_U_UDP_IPV6 (1),
+ UDP_IPV4 (2),
+ UDP_IPV6 (3),
+ IPV4 (4),
+ IPV6 (5),
+ GTP_U_UDP_IP (6),
+ VLAN_S_TAG (7),
+ S_TAG_AND_C_TAG (8)
+};
+
+template (value) Outer_Header_Removal ts_PFCP_Outer_Header_Removal(e_PFCP_Outer_Header_Removal ohr) := {
+ elementIdentifier := 95,
+ lengthIndicator := 0,
+ ohc_description := enum2int(ohr)
+}
+
+template (value) Forwarding_Parameters ts_PFCP_Forwarding_Parameters(
+ e_PFCP_Dest_Iface dest_iface,
+ template (omit) Outer_Header_Creation outer_header_creation := omit
+ ) := {
+ elementIdentifier := 4,
+ lengthIndicator := 0,
+ grouped_ie := {
+ destination_interface := ts_PFCP_Destination_Interface(dest_iface),
+ pdn_Instance := omit,
+ redirect_information := omit,
+ outer_header_creation := outer_header_creation,
+ transport_level_marking := omit,
+ forwarding_policy := omit,
+ header_enrichment := omit,
+ traffic_endpoint_ID := omit
+ }
+}
+
+template (value) FAR_ID ts_PFCP_FAR_ID(LIN4_BO_LAST far_id) := {
+ elementIdentifier := 108,
+ lengthIndicator := 0,
+ id_value := far_id
+}
+
+template (value) Create_FAR ts_PFCP_Create_FAR(LIN4_BO_LAST far_id, template (value) Apply_Action aa, Forwarding_Parameters fp) := {
+ elementIdentifier := 3,
+ lengthIndicator := 0,
+ grouped_ie := {
+ far_id := ts_PFCP_FAR_ID(far_id),
+ apply_action := aa,
+ forwarding_parameters := fp,
+ duplicating_parameters := omit,
+ bar_id := omit
+ }
+}
+
+template (value) PDR_ID ts_PFCP_PDR_ID(OCT2 pdr_id) := {
+ elementIdentifier := 56,
+ lengthIndicator := 0,
+ rule_id := pdr_id
+}
+
+template (value) Precedence ts_PFCP_Precedence(LIN4_BO_LAST val) := {
+ elementIdentifier := 29,
+ lengthIndicator := 0,
+ precedence_value := val
+}
+
+template (value) Create_PDR ts_PFCP_Create_PDR(integer pdr_id, template (value) PDI_IE pdi,
+ template (omit) Outer_Header_Removal outer_header_removal := omit,
+ LIN4_BO_LAST far_id) := {
+ elementIdentifier := 1,
+ lengthIndicator := 0,
+ grouped_ie := {
+ pdr_id := ts_PFCP_PDR_ID(int2oct(pdr_id, 2)),
+ precedence := ts_PFCP_Precedence(0),
+ pdi := pdi,
+ outer_header_removal := outer_header_removal,
+ FAR_ID_list := { ts_PFCP_FAR_ID(far_id) },
+ uRR_ID_list := omit,
+ qER_ID_list := omit,
+ activate_predefined_rules := omit
+ }
+}
+
+function ts_PFCP_Session_Est_Req(charstring node_id, OCT8 cp_seid, Create_PDR_list create_pdr, Create_FAR_list create_far)
+ return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP();
+ t.message_body := {
+ pfcp_session_establishment_request := {
+ node_id := ts_PFCP_Node_ID_ipv4(f_inet_addr(node_id)),
+ CP_F_SEID := ts_PFCP_F_SEID_ipv4(node_id, cp_seid),
+ create_PDR_list := create_pdr,
+ create_FAR_list := create_far,
+ create_URR_list := omit,
+ create_QER_list := omit,
+ create_BAR := omit,
+ create_traffic_endpoint_list := omit,
+ pdn_type := omit,
+ node_list := omit,
+ up_inactivity_timer := omit
+ }
+ };
+ return t;
+}
+
+function tr_PFCP_Session_Est_Req() return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP(?);
+ t.message_body := {
+ pfcp_session_establishment_request := {
+ node_id := ?
+ }
+ };
+ return t;
+}
+
+template (value) Created_PDR ts_PFCP_Created_PDR(PDR_ID pdr_id, template (value) F_TEID local_F_TEID) := {
+ elementIdentifier := 8,
+ lengthIndicator := 0,
+ grouped_ie := {
+ pdr_id := pdr_id,
+ local_F_TEID := local_F_TEID
+ }
+}
+
+function ts_PFCP_Session_Est_Resp(LIN3_BO_LAST seq_nr, template (value) Node_ID node_id, OCT8 seid)
+ return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP(seq_nr, seid);
+ t.sequence_number := seq_nr;
+ t.message_body := {
+ pfcp_session_establishment_response := {
+ node_id := node_id,
+ cause := ts_PFCP_Cause(REQUEST_ACCEPTED)
+ }
+ };
+ return t;
+}
+
+function tr_PFCP_Session_Est_Resp(template (present) OCT8 hdr_seid := ?) return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP(hdr_seid);
+ t.message_body := {
+ pfcp_session_establishment_response := {
+ node_id := ?,
+ cause := tr_PFCP_Cause(REQUEST_ACCEPTED),
+ offending_ie := *,
+ UP_F_SEID := ?,
+ created_PDR_list := ?,
+ load_control_information := *,
+ overload_control_information := *,
+ node_list := *,
+ failed_rule_id := *,
+ created_traffic_endpoint_list := *
+ }
+ };
+ return t;
+}
+
+function tr_PFCP_Session_Mod_Req(template (present) OCT8 seid := ?) return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP(seid);
+ t.message_body := {
+ pfcp_session_modification_request := ?
+ };
+ return t;
+}
+
+function ts_PFCP_Session_Mod_Resp(LIN3_BO_LAST seq_nr, OCT8 seid) return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP(seq_nr, seid);
+ t.message_body := {
+ pfcp_session_modification_response := {
+ cause := ts_PFCP_Cause(REQUEST_ACCEPTED),
+ offending_IE := omit,
+ created_PDR := omit,
+ load_control_information := omit,
+ overload_control_information := omit,
+ usage_report := omit,
+ failed_rule_id := omit,
+ additional_usage_reports_information := omit,
+ created_updated_traffic_endpoint := omit
+ }
+ };
+ return t;
+}
+
+function ts_PFCP_Session_Del_Req(OCT8 seid) return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP(seid := seid);
+ t.message_body := {
+ pfcp_session_deletion_request := { }
+ };
+ return t;
+}
+
+function tr_PFCP_Session_Del_Req(template (present) OCT8 seid := ?) return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP(seid);
+ t.message_body := {
+ pfcp_session_deletion_request := ?
+ };
+ return t;
+}
+
+function ts_PFCP_Session_Del_Resp(LIN3_BO_LAST seq_nr, OCT8 seid, e_PFCP_Cause cause := REQUEST_ACCEPTED)
+ return template (value) PDU_PFCP {
+ var template (value) PDU_PFCP t := ts_PDU_PFCP(seq_nr, seid);
+ t.message_body := {
+ pfcp_session_deletion_response := {
+ cause := ts_PFCP_Cause(cause),
+ offending_IE := omit,
+ load_control_information := omit,
+ overload_control_information := omit,
+ usage_report := omit
+ }
+ };
+ return t;
+}
+
+function tr_PFCP_Session_Del_Resp(template (present) OCT8 seid := ?,
+ template (present) Cause cause := tr_PFCP_Cause(REQUEST_ACCEPTED))
+ return template (present) PDU_PFCP {
+ var template PDU_PFCP t := tr_PDU_PFCP(seid);
+ t.message_body := {
+ pfcp_session_deletion_response := {
+ cause := cause,
+ offending_IE := *,
+ load_control_information := *,
+ overload_control_information := *,
+ usage_report := *
+ }
+ };
+ return t;
+}
+
+}