diff options
Diffstat (limited to 'veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/EvelMobileFlow.java')
| -rw-r--r-- | veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/EvelMobileFlow.java | 2064 |
1 files changed, 2064 insertions, 0 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/EvelMobileFlow.java b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/EvelMobileFlow.java new file mode 100644 index 0000000..339cb90 --- /dev/null +++ b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/EvelMobileFlow.java @@ -0,0 +1,2064 @@ +package evel_javalibrary.att.com;
+/**************************************************************************//**
+ * @file
+ * Evel Mobile Flow class
+ *
+ * This file implements the Evel Mobile Flow Event class which is intended to provide a
+ * simple wrapper around the complexity of AT&T's Vendor Event Listener API so
+ * that VNFs can use it to send Mobile flow events.
+ *
+ * License
+ * -------
+ * Unless otherwise specified, all software contained herein is
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *****************************************************************************/
+
+import java.text.MessageFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+
+import javax.json.Json;
+import javax.json.JsonArrayBuilder;
+import javax.json.JsonObject;
+import javax.json.JsonObjectBuilder;
+
+import org.apache.log4j.Logger;
+
+
+
+public class EvelMobileFlow extends EvelHeader {
+
+ int major_version = 2;
+ int minor_version = 0;
+
+ static int EVEL_TOS_SUPPORTED = 256;
+ /**************************************************************************//**
+ * TCP flags.
+ * JSON equivalent fields: tcpFlagCountList, tcpFlagList
+ *****************************************************************************/
+ public enum EVEL_TCP_FLAGS {
+ EVEL_TCP_NS,
+ EVEL_TCP_CWR,
+ EVEL_TCP_ECE,
+ EVEL_TCP_URG,
+ EVEL_TCP_ACK,
+ EVEL_TCP_PSH,
+ EVEL_TCP_RST,
+ EVEL_TCP_SYN,
+ EVEL_TCP_FIN,
+ EVEL_MAX_TCP_FLAGS
+ }
+ static int EVEL_MAX_TCP_FLAGS = 10;
+ /**************************************************************************//**
+ * Mobile QCI Classes of Service.
+ * JSON equivalent fields: mobileQciCosCountList, mobileQciCosList
+ *****************************************************************************/
+ public enum EVEL_QCI_COS_TYPES {
+
+ /***************************************************************************/
+ /* UMTS Classes of Service. */
+ /***************************************************************************/
+ EVEL_QCI_COS_UMTS_CONVERSATIONAL,
+ EVEL_QCI_COS_UMTS_STREAMING,
+ EVEL_QCI_COS_UMTS_INTERACTIVE,
+ EVEL_QCI_COS_UMTS_BACKGROUND,
+
+ /***************************************************************************/
+ /* LTE Classes of Service. */
+ /***************************************************************************/
+ EVEL_QCI_COS_LTE_1,
+ EVEL_QCI_COS_LTE_2,
+ EVEL_QCI_COS_LTE_3,
+ EVEL_QCI_COS_LTE_4,
+ EVEL_QCI_COS_LTE_65,
+ EVEL_QCI_COS_LTE_66,
+ EVEL_QCI_COS_LTE_5,
+ EVEL_QCI_COS_LTE_6,
+ EVEL_QCI_COS_LTE_7,
+ EVEL_QCI_COS_LTE_8,
+ EVEL_QCI_COS_LTE_9,
+ EVEL_QCI_COS_LTE_69,
+ EVEL_QCI_COS_LTE_70,
+ EVEL_MAX_QCI_COS_TYPES
+ }
+ static int EVEL_MAX_QCI_COS_TYPES = 18;
+
+ private static final Logger LOGGER = Logger.getLogger( EvelMobileFlow.class.getName() );
+
+
+ /*****************************************************************************/
+ /* Array of strings to use when encoding TCP flags. */
+ /*****************************************************************************/
+ static final String[/*EVEL_MAX_TCP_FLAGS*/] evel_tcp_flag_strings = {
+ "NS",
+ "CWR",
+ "ECE",
+ "URG",
+ "ACK",
+ "PSH",
+ "RST",
+ "SYN",
+ "FIN"
+ };
+
+ /*****************************************************************************/
+ /* Array of strings to use when encoding QCI COS. */
+ /*****************************************************************************/
+ static final String[/*EVEL_MAX_QCI_COS_TYPES*/] evel_qci_cos_strings = {
+ "conversational",
+ "streaming",
+ "interactive",
+ "background",
+ "1",
+ "2",
+ "3",
+ "4",
+ "65",
+ "66",
+ "5",
+ "6",
+ "7",
+ "8",
+ "9",
+ "69",
+ "70"
+ };
+
+
+ /**************************************************************************//**
+ * Vendor VNF Name fields.
+ * JSON equivalent field: vendorVnfNameFields
+ *****************************************************************************/
+ /**************************************************************************//**
+ * Mobile GTP Per Flow Metrics.
+ * JSON equivalent field: gtpPerFlowMetrics
+ *****************************************************************************/
+ public class MOBILE_GTP_PER_FLOW_METRICS {
+ double avg_bit_error_rate;
+ double avg_packet_delay_variation;
+ int avg_packet_latency;
+ int avg_receive_throughput;
+ int avg_transmit_throughput;
+
+ int flow_activation_epoch;
+ int flow_activation_microsec;
+
+ int flow_deactivation_epoch;
+ int flow_deactivation_microsec;
+ Date flow_deactivation_time;
+ String flow_status;
+ int max_packet_delay_variation;
+ int num_activation_failures;
+ int num_bit_errors;
+ int num_bytes_received;
+ int num_bytes_transmitted;
+ int num_dropped_packets;
+ int num_l7_bytes_received;
+ int num_l7_bytes_transmitted;
+ int num_lost_packets;
+ int num_out_of_order_packets;
+ int num_packet_errors;
+ int num_packets_received_excl_retrans;
+ int num_packets_received_incl_retrans;
+ int num_packets_transmitted_incl_retrans;
+ int num_retries;
+ int num_timeouts;
+ int num_tunneled_l7_bytes_received;
+ int round_trip_time;
+ int time_to_first_byte;
+
+ /***************************************************************************/
+ /* Optional fields */
+ /***************************************************************************/
+ EvelOptionInt ip_tos_counts[/*EVEL_TOS_SUPPORTED*/];
+ EvelOptionInt tcp_flag_counts[/*EVEL_MAX_TCP_FLAGS*/];
+ EvelOptionInt qci_cos_counts[/*EVEL_MAX_QCI_COS_TYPES*/];
+
+ EvelOptionInt dur_connection_failed_status;
+ EvelOptionInt dur_tunnel_failed_status;
+ EvelOptionString flow_activated_by;
+
+ EvelOptionTime flow_activation_time;
+ EvelOptionString flow_deactivated_by;
+
+ EvelOptionString gtp_connection_status;
+ EvelOptionString gtp_tunnel_status;
+ EvelOptionInt large_packet_rtt;
+ EvelOptionDouble large_packet_threshold;
+ EvelOptionInt max_receive_bit_rate;
+ EvelOptionInt max_transmit_bit_rate;
+ EvelOptionInt num_gtp_echo_failures;
+ EvelOptionInt num_gtp_tunnel_errors;
+ EvelOptionInt num_http_errors;
+
+ /**************************************************************************//**
+ * Create a new Mobile GTP Per Flow Metrics.
+ *
+ * @note The mandatory fields on the Mobile GTP Per Flow Metrics must be
+ * supplied to this factory function and are immutable once set.
+ * Optional fields have explicit setter functions, but again values
+ * may only be set once so that the Mobile GTP Per Flow Metrics has
+ * immutable properties.
+ *
+ * @param avg_bit_error_rate Average bit error rate.
+ * @param avg_packet_delay_variation Average delay or jitter in ms.
+ * @param avg_packet_latency Average delivery latency.
+ * @param avg_receive_throughput Average receive throughput.
+ * @param avg_transmit_throughput Average transmit throughput.
+ * @param flow_activation_epoch Time the connection is activated.
+ * @param flow_activation_microsec Microseconds for the start of the flow
+ * connection.
+ * @param flow_deactivation_epoch Time for the end of the connection.
+ * @param flow_deactivation_microsec Microseconds for the end of the flow
+ * connection.
+ * @param flow_deactivation_time Transmission time of the first packet.
+ * @param flow_status Connection status.
+ * @param max_packet_delay_variation Maximum packet delay or jitter in ms.
+ * @param num_activation_failures Number of failed activation requests.
+ * @param num_bit_errors Number of errored bits.
+ * @param num_bytes_received Number of bytes received.
+ * @param num_bytes_transmitted Number of bytes transmitted.
+ * @param num_dropped_packets Number of received packets dropped.
+ * @param num_l7_bytes_received Number of tunneled Layer 7 bytes
+ * received.
+ * @param num_l7_bytes_transmitted Number of tunneled Layer 7 bytes
+ * transmitted.
+ * @param num_lost_packets Number of lost packets.
+ * @param num_out_of_order_packets Number of out-of-order packets.
+ * @param num_packet_errors Number of errored packets.
+ * @param num_packets_received_excl_retrans Number of packets received,
+ * excluding retransmits.
+ * @param num_packets_received_incl_retrans Number of packets received.
+ * @param num_packets_transmitted_incl_retrans Number of packets
+ * transmitted.
+ * @param num_retries Number of packet retries.
+ * @param num_timeouts Number of packet timeouts.
+ * @param num_tunneled_l7_bytes_received Number of tunneled Layer 7 bytes
+ * received, excluding retransmits.
+ * @param round_trip_time Round trip time.
+ * @param time_to_first_byte Time in ms between connection
+ * activation and first byte received.
+ *
+ * @returns pointer to the newly manufactured ::MOBILE_GTP_PER_FLOW_METRICS.
+ * If the structure is not used it must be released using
+ * ::evel_free_mobile_gtp_flow_metrics.
+ * @retval null Failed to create the event.
+ *****************************************************************************/
+ public MOBILE_GTP_PER_FLOW_METRICS(
+ double tavg_bit_error_rate,
+ double tavg_packet_delay_variation,
+ int tavg_packet_latency,
+ int tavg_receive_throughput,
+ int tavg_transmit_throughput,
+ int tflow_activation_epoch,
+ int tflow_activation_microsec,
+ int tflow_deactivation_epoch,
+ int tflow_deactivation_microsec,
+ Date tflow_deactivation_time,
+ String tflow_status,
+ int tmax_packet_delay_variation,
+ int tnum_activation_failures,
+ int tnum_bit_errors,
+ int tnum_bytes_received,
+ int tnum_bytes_transmitted,
+ int tnum_dropped_packets,
+ int tnum_l7_bytes_received,
+ int tnum_l7_bytes_transmitted,
+ int tnum_lost_packets,
+ int tnum_out_of_order_packets,
+ int tnum_packet_errors,
+ int tnum_packets_received_excl_retrans,
+ int tnum_packets_received_incl_retrans,
+ int tnum_packets_transmitted_incl_retrans,
+ int tnum_retries,
+ int tnum_timeouts,
+ int tnum_tunneled_l7_bytes_received,
+ int tround_trip_time,
+ int ttime_to_first_byte)
+ {
+ int ii;
+
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(tavg_bit_error_rate >= 0.0);
+ assert(tavg_packet_delay_variation >= 0.0);
+ assert(tavg_packet_latency >= 0);
+ assert(tavg_receive_throughput >= 0);
+ assert(tavg_transmit_throughput >= 0);
+ assert(tflow_activation_epoch > 0);
+ assert(tflow_activation_microsec >= 0);
+ assert(tflow_deactivation_epoch > 0);
+ assert(tflow_deactivation_microsec >= 0);
+ assert(tflow_status != null);
+ assert(tmax_packet_delay_variation >= 0);
+ assert(tnum_activation_failures >= 0);
+ assert(tnum_bit_errors >= 0);
+ assert(tnum_bytes_received >= 0);
+ assert(tnum_bytes_transmitted >= 0);
+ assert(tnum_dropped_packets >= 0);
+ assert(tnum_l7_bytes_received >= 0);
+ assert(tnum_l7_bytes_transmitted >= 0);
+ assert(tnum_lost_packets >= 0);
+ assert(tnum_out_of_order_packets >= 0);
+ assert(tnum_packet_errors >= 0);
+ assert(tnum_packets_received_excl_retrans >= 0);
+ assert(tnum_packets_received_incl_retrans >= 0);
+ assert(tnum_packets_transmitted_incl_retrans >= 0);
+ assert(tnum_retries >= 0);
+ assert(tnum_timeouts >= 0);
+ assert(tnum_tunneled_l7_bytes_received >= 0);
+ assert(tround_trip_time >= 0);
+ assert(ttime_to_first_byte >= 0);
+
+ /***************************************************************************/
+ /* Allocate the Mobile Flow GTP Per Flow Metrics. */
+ /***************************************************************************/
+ LOGGER.debug("New Mobile Flow GTP Per Flow Metrics");
+
+ /***************************************************************************/
+ /* Initialize the Mobile Flow GTP Per Flow Metrics fields. Optional */
+ /* string values are uninitialized (null). */
+ /***************************************************************************/
+ avg_bit_error_rate = tavg_bit_error_rate;
+ avg_packet_delay_variation = tavg_packet_delay_variation;
+ avg_packet_latency = tavg_packet_latency;
+ avg_receive_throughput = tavg_receive_throughput;
+ avg_transmit_throughput = tavg_transmit_throughput;
+ flow_activation_epoch = tflow_activation_epoch;
+ flow_activation_microsec = tflow_activation_microsec;
+ flow_deactivation_epoch = tflow_deactivation_epoch;
+ flow_deactivation_microsec = tflow_deactivation_microsec;
+ flow_deactivation_time = tflow_deactivation_time;
+ flow_status = tflow_status;
+ max_packet_delay_variation = tmax_packet_delay_variation;
+ num_activation_failures = tnum_activation_failures;
+ num_bit_errors = tnum_bit_errors;
+ num_bytes_received = tnum_bytes_received;
+ num_bytes_transmitted = tnum_bytes_transmitted;
+ num_dropped_packets = tnum_dropped_packets;
+ num_l7_bytes_received = tnum_l7_bytes_received;
+ num_l7_bytes_transmitted = tnum_l7_bytes_transmitted;
+ num_lost_packets = tnum_lost_packets;
+ num_out_of_order_packets = tnum_out_of_order_packets;
+ num_packet_errors = tnum_packet_errors;
+ num_packets_received_excl_retrans =
+ tnum_packets_received_excl_retrans;
+ num_packets_received_incl_retrans =
+ tnum_packets_received_incl_retrans;
+ num_packets_transmitted_incl_retrans =
+ tnum_packets_transmitted_incl_retrans;
+ num_retries = tnum_retries;
+ num_timeouts = tnum_timeouts;
+ num_tunneled_l7_bytes_received = tnum_tunneled_l7_bytes_received;
+ round_trip_time = tround_trip_time;
+ time_to_first_byte = ttime_to_first_byte;
+ ip_tos_counts = new EvelOptionInt[EVEL_TOS_SUPPORTED];
+ for (ii = 0; ii < EVEL_TOS_SUPPORTED; ii++)
+ {
+ ip_tos_counts[ii] = new EvelOptionInt();
+ }
+ tcp_flag_counts = new EvelOptionInt[EVEL_MAX_TCP_FLAGS];
+ for (ii = 0; ii < EVEL_MAX_TCP_FLAGS; ii++)
+ {
+ tcp_flag_counts[ii] = new EvelOptionInt();
+ }
+ qci_cos_counts = new EvelOptionInt[EVEL_MAX_QCI_COS_TYPES];
+ for (ii = 0; ii < EVEL_MAX_QCI_COS_TYPES; ii++)
+ {
+ qci_cos_counts[ii] = new EvelOptionInt();
+ }
+ dur_connection_failed_status = new EvelOptionInt();
+ dur_tunnel_failed_status = new EvelOptionInt();
+ flow_activated_by = new EvelOptionString();
+ flow_activation_time = new EvelOptionTime();
+ flow_deactivated_by = new EvelOptionString();
+ gtp_connection_status = new EvelOptionString();
+ gtp_tunnel_status = new EvelOptionString();
+ large_packet_rtt = new EvelOptionInt();
+ large_packet_threshold = new EvelOptionDouble();
+ max_receive_bit_rate = new EvelOptionInt();
+ max_transmit_bit_rate = new EvelOptionInt();
+ num_gtp_echo_failures = new EvelOptionInt();
+ num_gtp_tunnel_errors = new EvelOptionInt();
+ num_http_errors = new EvelOptionInt();
+
+ EVEL_EXIT();
+ }
+ }
+
+ /***************************************************************************/
+ /* Mandatory fields */
+ /***************************************************************************/
+ String flow_direction;
+ public MOBILE_GTP_PER_FLOW_METRICS gtp_per_flow_metrics;
+ String ip_protocol_type;
+ String ip_version;
+ String other_endpoint_ip_address;
+ int other_endpoint_port;
+ String reporting_endpoint_ip_addr;
+ int reporting_endpoint_port;
+
+ /***************************************************************************/
+ /* Optional fields */
+ /***************************************************************************/
+ ArrayList<String[]> additional_info;
+ EvelOptionString application_type;
+ EvelOptionString app_protocol_type;
+ EvelOptionString app_protocol_version;
+ EvelOptionString cid;
+ EvelOptionString connection_type;
+ EvelOptionString ecgi;
+ EvelOptionString gtp_protocol_type;
+ EvelOptionString gtp_version;
+ EvelOptionString http_header;
+ EvelOptionString imei;
+ EvelOptionString imsi;
+ EvelOptionString lac;
+ EvelOptionString mcc;
+ EvelOptionString mnc;
+ EvelOptionString msisdn;
+ EvelOptionString other_functional_role;
+ EvelOptionString rac;
+ EvelOptionString radio_access_technology;
+ EvelOptionString sac;
+ EvelOptionInt sampling_algorithm;
+ EvelOptionString tac;
+ EvelOptionString tunnel_id;
+ EvelOptionString vlan_id;
+
+ /***************************************************************************/
+ /* Optional fields */
+ /***************************************************************************/
+
+
+ /*****************************************************************************/
+ /* Local prototypes */
+ /*****************************************************************************/
+
+
+ /**************************************************************************//**
+ * Create a new Mobile Flow event.
+ *
+ * @note The mandatory fields on the Mobile Flow must be supplied to this
+ * factory function and are immutable once set. Optional fields have
+ * explicit setter functions, but again values may only be set once so
+ * that the Mobile Flow has immutable properties.
+ * @param flow_direction Flow direction.
+ * @param gtp_per_flow_metrics GTP per-flow metrics.
+ * @param ip_protocol_type IP protocol type.
+ * @param ip_version IP protocol version.
+ * @param other_endpoint_ip_address IP address of the other endpoint.
+ * @param other_endpoint_port IP port of the other endpoint.
+ * @param reporting_endpoint_ip_addr IP address of the reporting endpoint.
+
+ * @param reporting_endpoint_port IP port of the reporting endpoint.
+ *****************************************************************************/
+ public EvelMobileFlow( String evname, String evid,
+ String flow_dir,
+ MOBILE_GTP_PER_FLOW_METRICS gtp_per_flow_metr,
+ String ip_protocol_typ,
+ String ip_vers,
+ String other_endpoint_ip_addr,
+ int other_endpoint_pt,
+ String reporting_endpoint_ipaddr,
+ int reporting_endpoint_pt)
+ {
+ super(evname,evid);
+
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(flow_dir != null);
+ assert(gtp_per_flow_metr != null);
+ assert(ip_protocol_typ != null);
+ assert(ip_vers != null);
+ assert(other_endpoint_ip_addr != null);
+ assert(other_endpoint_pt > 0);
+ assert(reporting_endpoint_ipaddr != null);
+ assert(reporting_endpoint_pt > 0);
+
+ /***************************************************************************/
+ /* Allocate the Mobile Flow. */
+ /***************************************************************************/
+ LOGGER.debug("New Mobile Flow created");
+
+ /***************************************************************************/
+ /* Initialize the header & the Mobile Flow fields. Optional string values */
+ /* are uninitialized (null). */
+ /***************************************************************************/
+ event_domain = EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW;
+ flow_direction = flow_dir;
+ gtp_per_flow_metrics = gtp_per_flow_metr;
+ ip_protocol_type = ip_protocol_typ;
+ ip_version = ip_vers;
+ other_endpoint_ip_address = other_endpoint_ip_addr;
+ other_endpoint_port = other_endpoint_pt;
+ reporting_endpoint_ip_addr = reporting_endpoint_ipaddr;
+ reporting_endpoint_port = reporting_endpoint_pt;
+
+ application_type = new EvelOptionString();
+ app_protocol_type = new EvelOptionString();
+ app_protocol_version = new EvelOptionString();
+ cid = new EvelOptionString();
+ connection_type = new EvelOptionString();
+ ecgi = new EvelOptionString();
+ gtp_protocol_type = new EvelOptionString();
+ gtp_version = new EvelOptionString();
+ http_header = new EvelOptionString();
+ imei = new EvelOptionString();
+ imsi = new EvelOptionString();
+ lac = new EvelOptionString();
+ mcc = new EvelOptionString();
+ mnc = new EvelOptionString();
+ msisdn = new EvelOptionString();
+ other_functional_role = new EvelOptionString();
+ rac = new EvelOptionString();
+ radio_access_technology = new EvelOptionString();
+ sac = new EvelOptionString();
+ sampling_algorithm = new EvelOptionInt();
+ tac = new EvelOptionString();
+ tunnel_id = new EvelOptionString();
+ vlan_id = new EvelOptionString();
+ additional_info = null;
+
+ EVEL_EXIT();
+
+ }
+
+
+
+ /**************************************************************************//**
+ * Add an additional value name/value pair to the Mobile flow.
+ *
+ * The name and value are null delimited ASCII strings. The library takes
+ * a copy so the caller does not have to preserve values after the function
+ * returns.
+ *
+ * @param name ASCIIZ string with the attribute's name. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ * @param value ASCIIZ string with the attribute's value. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_addl_field_add(String name, String value)
+ {
+ String[] addl_info = null;
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(name != null);
+ assert(value != null);
+
+ if( additional_info == null )
+ {
+ additional_info = new ArrayList<String[]>();
+ }
+
+ LOGGER.debug(MessageFormat.format("Adding name={0} value={1}", name, value));
+ addl_info = new String[2];
+ assert(addl_info != null);
+ addl_info[0] = name;
+ addl_info[1] = value;
+
+ additional_info.add(addl_info);
+
+ EVEL_EXIT();
+ }
+
+
+ /**************************************************************************//**
+ * Set the Event Type property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param type The Event Type to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_type_set(String typ)
+ {
+ EVEL_ENTER();
+ assert(typ != null);
+
+ /***************************************************************************/
+ /* Check preconditions and call evel_header_type_set. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ evel_header_type_set(typ);
+
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Application Type property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param type The Application Type to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_app_type_set(String type)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(type != null);
+
+ application_type.SetValuePr(
+ type,
+ "Application Type");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Application Protocol Type property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param type The Application Protocol Type to be set. ASCIIZ string.
+ * The caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_app_prot_type_set(String type)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(type != null);
+
+ app_protocol_type.SetValuePr(
+ type,
+ "Application Protocol Type");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Application Protocol Version property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param version The Application Protocol Version to be set. ASCIIZ
+ * string. The caller does not need to preserve the value
+ * once the function returns.
+ *****************************************************************************/
+ void evel_mobile_flow_app_prot_ver_set(String version)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(version != null);
+
+ app_protocol_version.SetValuePr(
+ version,
+ "Application Protocol Version");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the CID property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param cid The CID to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_cid_set(String cd)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(cid != null);
+
+ cid.SetValuePr(
+ cd,
+ "CID");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Connection Type property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param type The Connection Type to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_con_type_set(String type)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(type != null);
+
+ connection_type.SetValuePr(
+ type,
+ "Connection Type");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the ECGI property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param ecgi The ECGI to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_ecgi_set(String ecgit)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(ecgit != null);
+
+ ecgi.SetValuePr(
+ ecgit,
+ "ECGI");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the GTP Protocol Type property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param type The GTP Protocol Type to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_gtp_prot_type_set(String type)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(type != null);
+
+ gtp_protocol_type.SetValuePr(
+ type,
+ "GTP Protocol Type");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the GTP Protocol Version property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param version The GTP Protocol Version to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_gtp_prot_ver_set(String version)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(version != null);
+
+ gtp_version.SetValuePr(
+ version,
+ "GTP Protocol Version");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the HTTP Header property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param header The HTTP header to be set. ASCIIZ string. The caller does
+ * not need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_http_header_set(String header)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(header != null);
+
+ http_header.SetValuePr(
+ header,
+ "HTTP Header");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the IMEI property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param imei The IMEI to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_imei_set(String imeit)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(imeit != null);
+
+ imei.SetValuePr(
+ imeit,
+ "IMEI");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the IMSI property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param imsi The IMSI to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_imsi_set(String imsit)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(imsit != null);
+
+ imsi.SetValuePr(
+ imsit,
+ "IMSI");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the LAC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param lac The LAC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_lac_set(String lact)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+ assert(lact != null);
+
+ lac.SetValuePr(
+ lact,
+ "LAC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the MCC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param mcc The MCC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_mcc_set(String mcct)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(mcct != null);
+
+ mcc.SetValuePr(
+ mcct,
+ "MCC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the MNC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param mnc The MNC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_mnc_set(String mnct)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(mnct != null);
+
+ mnc.SetValuePr(
+ mnct,
+ "MNC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the MSISDN property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param msisdn The MSISDN to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_msisdn_set(String msisdnt)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(msisdnt != null);
+
+ msisdn.SetValuePr(
+ msisdnt,
+ "MSISDN");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Other Functional Role property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param role The Other Functional Role to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_other_func_role_set(String role)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(role != null);
+
+ other_functional_role.SetValuePr(
+ role,
+ "Other Functional Role");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the RAC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param rac The RAC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_rac_set(String ract)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(ract != null);
+
+ rac.SetValuePr(
+ ract,
+ "RAC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Radio Access Technology property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param tech The Radio Access Technology to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_radio_acc_tech_set(String tech)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(tech != null);
+
+ radio_access_technology.SetValuePr(
+ tech,
+ "Radio Access Technology");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the SAC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param sac The SAC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_sac_set(String sact)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(sact != null);
+
+ sac.SetValuePr(
+ sact,
+ "SAC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Sampling Algorithm property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param algorithm The Sampling Algorithm to be set.
+ *****************************************************************************/
+ public void evel_mobile_flow_samp_alg_set(
+ int algorithm)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(algorithm >= 0);
+
+ sampling_algorithm.SetValuePr(
+ algorithm,
+ "Sampling Algorithm");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the TAC property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param tac The TAC to be set. ASCIIZ string. The caller does not
+ * need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_tac_set(String tact)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(tact != null);
+
+ tac.SetValuePr(
+ tact,
+ "TAC");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Tunnel ID property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param tunnel_id The Tunnel ID to be set. ASCIIZ string. The caller does
+ * not need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_tunnel_id_set(String tunnel_idt)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(tunnel_idt != null);
+
+ tunnel_id.SetValuePr(
+ tunnel_idt,
+ "Tunnel ID");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the VLAN ID property of the Mobile Flow.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+
+ * @param vlan_id The VLAN ID to be set. ASCIIZ string. The caller does
+ * not need to preserve the value once the function returns.
+ *****************************************************************************/
+ public void evel_mobile_flow_vlan_id_set(String vlan_idt)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ assert(vlan_idt != null);
+
+ vlan_id.SetValuePr(
+ vlan_idt,
+ "VLAN ID");
+ EVEL_EXIT();
+ }
+
+
+
+ /**************************************************************************//**
+ * Set the Duration of Connection Failed Status property of the Mobile GTP Per
+ * Flow Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param duration The Duration of Connection Failed Status to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_dur_con_fail_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int duration)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(duration >= 0);
+
+ metrics.dur_connection_failed_status.SetValuePr(
+ duration,
+ "Duration of Connection Failed Status");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Duration of Tunnel Failed Status property of the Mobile GTP Per Flow
+ * Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param duration The Duration of Tunnel Failed Status to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_dur_tun_fail_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int duration)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(duration >= 0);
+
+ metrics.dur_tunnel_failed_status.SetValuePr(
+ duration,
+ "Duration of Tunnel Failed Status");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Activated By property of the Mobile GTP Per Flow metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param act_by The Activated By to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_act_by_set(MOBILE_GTP_PER_FLOW_METRICS metrics,
+ String act_by)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(act_by != null);
+
+ metrics.flow_activated_by.SetValuePr(
+ act_by,
+ "Activated By");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Activation Time property of the Mobile GTP Per Flow metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param act_time The Activation Time to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_act_time_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ Date act_time)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+
+ metrics.flow_activation_time.SetValuePr(
+ act_time,
+ "Activation Time");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Deactivated By property of the Mobile GTP Per Flow metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param deact_by The Deactivated By to be set. ASCIIZ string. The caller
+ * does not need to preserve the value once the function
+ * returns.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_deact_by_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ String deact_by)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(deact_by != null);
+
+ metrics.flow_deactivated_by.SetValuePr(
+ deact_by,
+ "Deactivated By");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the GTP Connection Status property of the Mobile GTP Per Flow metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param status The GTP Connection Status to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_con_status_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ String status)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(status != null);
+
+ metrics.gtp_connection_status.SetValuePr(
+ status,
+ "GTP Connection Status");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the GTP Tunnel Status property of the Mobile GTP Per Flow metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param status The GTP Tunnel Status to be set. ASCIIZ string. The
+ * caller does not need to preserve the value once the
+ * function returns.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_tun_status_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ String status)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(status != null);
+
+ metrics.gtp_tunnel_status.SetValuePr(
+ status,
+ "GTP Tunnel Status");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set an IP Type-of-Service count property of the Mobile GTP Per Flow metrics.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param index The index of the IP Type-of-Service.
+ * @param count The count.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_iptos_set(MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int index,
+ int count)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(index >= 0);
+ assert(index < EVEL_TOS_SUPPORTED);
+ assert(count >= 0);
+ assert(count <= 255);
+
+ LOGGER.debug("IP Type-of-Service "+index);
+ metrics.ip_tos_counts[index].SetValuePr(
+ count,
+ "IP Type-of-Service");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Large Packet Round-Trip Time property of the Mobile GTP Per Flow
+ * Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param rtt The Large Packet Round-Trip Time to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_large_pkt_rtt_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int rtt)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(rtt >= 0);
+
+ metrics.large_packet_rtt.SetValuePr(
+ rtt,
+ "Large Packet Round-Trip Time");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Large Packet Threshold property of the Mobile GTP Per Flow Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param threshold The Large Packet Threshold to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_large_pkt_thresh_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ double threshold)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(threshold >= 0.0);
+
+ metrics.large_packet_threshold.SetValuePr(
+ threshold,
+ "Large Packet Threshold");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Max Receive Bit Rate property of the Mobile GTP Per Flow Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param rate The Max Receive Bit Rate to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_max_rcv_bit_rate_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int rate)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(rate >= 0);
+
+ metrics.max_receive_bit_rate.SetValuePr(
+ rate,
+ "Max Receive Bit Rate");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Max Transmit Bit Rate property of the Mobile GTP Per Flow Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param rate The Max Transmit Bit Rate to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_max_trx_bit_rate_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int rate)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(rate >= 0);
+
+ metrics.max_transmit_bit_rate.SetValuePr(
+ rate,
+ "Max Transmit Bit Rate");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Number of GTP Echo Failures property of the Mobile GTP Per Flow
+ * Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param num The Number of GTP Echo Failures to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_num_echo_fail_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int num)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(num >= 0);
+
+ metrics.num_gtp_echo_failures.SetValuePr(
+ num,
+ "Number of GTP Echo Failures");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Number of GTP Tunnel Errors property of the Mobile GTP Per Flow
+ * Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param num The Number of GTP Tunnel Errors to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_num_tun_fail_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int num)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(num >= 0);
+
+ metrics.num_gtp_tunnel_errors.SetValuePr(
+ num,
+ "Number of GTP Tunnel Errors");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Set the Number of HTTP Errors property of the Mobile GTP Per Flow Metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param num The Number of HTTP Errors to be set.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_num_http_errors_set(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int num)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(num >= 0);
+
+ metrics.num_http_errors.SetValuePr(
+ num,
+ "Number of HTTP Errors");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Add a TCP flag count to the metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param tcp_flag The TCP flag to be updated.
+ * @param count The associated flag count, which must be nonzero.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_tcp_flag_count_add(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int tcp_flag,
+ int count)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(tcp_flag >= 0 && tcp_flag < EVEL_MAX_TCP_FLAGS);
+ assert(count >= 0);
+
+ LOGGER.debug("TCP Flag: "+tcp_flag);
+ metrics.tcp_flag_counts[tcp_flag].SetValuePr(
+ count,
+ "TCP flag");
+ EVEL_EXIT();
+ }
+
+ /**************************************************************************//**
+ * Add a QCI COS count to the metrics.
+ *
+ * @note The property is treated as immutable: it is only valid to call
+ * the setter once. However, we don't assert if the caller tries to
+ * overwrite, just ignoring the update instead.
+ *
+ * @param metrics Pointer to the Mobile GTP Per Flow Metrics.
+ * @param qci_cos The QCI COS count to be updated.
+ * @param count The associated QCI COS count.
+ *****************************************************************************/
+ public void evel_mobile_gtp_metrics_qci_cos_count_add(
+ MOBILE_GTP_PER_FLOW_METRICS metrics,
+ int qci_cos,
+ int count)
+ {
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(metrics != null);
+ assert(qci_cos >= 0);
+ assert(qci_cos < EVEL_MAX_QCI_COS_TYPES);
+ assert(count >= 0);
+
+ LOGGER.debug("QCI COS: "+ qci_cos);
+ metrics.qci_cos_counts[qci_cos].SetValuePr(
+ count,
+ "QCI COS");
+ EVEL_EXIT();
+ }
+
+
+ /**************************************************************************//**
+ * Encode the GTP Per Flow Object in JSON according to AT&T's schema.
+ *
+ * @retval JsonObjectBuilder of GTP Flow body portion of message
+ *****************************************************************************/
+ JsonObjectBuilder evelGtpPerFlowObject()
+ {
+ int index;
+ boolean found_ip_tos;
+ boolean found_tcp_flag;
+ boolean found_qci_cos;
+
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Mandatory parameters. */
+ /***************************************************************************/
+ MOBILE_GTP_PER_FLOW_METRICS metrics = gtp_per_flow_metrics;
+
+ JsonObjectBuilder obj = Json.createObjectBuilder()
+ .add("avgBitErrorRate", metrics.avg_bit_error_rate)
+ .add("avgPacketDelayVariation", metrics.avg_packet_delay_variation)
+ .add("avgPacketLatency", metrics.avg_packet_latency)
+ .add("avgReceiveThroughput", metrics.avg_receive_throughput)
+ .add("avgTransmitThroughput", metrics.avg_transmit_throughput)
+ .add("flowActivationEpoch", metrics.flow_activation_epoch)
+ .add("flowActivationMicrosec", metrics.flow_activation_microsec)
+ .add("flowDeactivationEpoch", metrics.flow_deactivation_epoch)
+ .add("flowDeactivationMicrosec", metrics.flow_deactivation_microsec)
+ .add("flowDeactivationTime", metrics.flow_deactivation_time.toString())
+ .add("flowStatus", metrics.flow_status)
+ .add("maxPacketDelayVariation", metrics.max_packet_delay_variation)
+ .add("numActivationFailures", metrics.num_activation_failures)
+ .add( "numBitErrors", metrics.num_bit_errors)
+ .add( "numBytesReceived", metrics.num_bytes_received)
+ .add( "numBytesTransmitted", metrics.num_bytes_transmitted)
+ .add( "numDroppedPackets", metrics.num_dropped_packets)
+ .add( "numL7BytesReceived", metrics.num_l7_bytes_received)
+ .add( "numL7BytesTransmitted", metrics.num_l7_bytes_transmitted)
+ .add( "numLostPackets", metrics.num_lost_packets)
+ .add( "numOutOfOrderPackets", metrics.num_out_of_order_packets)
+ .add( "numPacketErrors", metrics.num_packet_errors)
+ .add( "numPacketsReceivedExclRetrans",
+ metrics.num_packets_received_excl_retrans)
+ .add(
+ "numPacketsReceivedInclRetrans",
+ metrics.num_packets_received_incl_retrans)
+ .add(
+ "numPacketsTransmittedInclRetrans",
+ metrics.num_packets_transmitted_incl_retrans)
+ .add( "numRetries", metrics.num_retries)
+ .add( "numTimeouts", metrics.num_timeouts)
+ .add(
+ "numTunneledL7BytesReceived",
+ metrics.num_tunneled_l7_bytes_received)
+ .add( "roundTripTime", metrics.round_trip_time)
+ .add( "timeToFirstByte", metrics.time_to_first_byte);
+
+ /***************************************************************************/
+ /* Optional parameters. */
+ /***************************************************************************/
+ found_ip_tos = false;
+ for (index = 0; index < EVEL_TOS_SUPPORTED; index++)
+ {
+ if (metrics.ip_tos_counts[index].is_set)
+ {
+ found_ip_tos = true;
+ break;
+ }
+ }
+
+ if (found_ip_tos)
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for (index = 0; index < EVEL_TOS_SUPPORTED; index++)
+ {
+ if (metrics.ip_tos_counts[index].is_set)
+ {
+ JsonObjectBuilder obj2 = Json.createObjectBuilder()
+ .add(Integer.toString(index), metrics.ip_tos_counts[index].value);
+ builder.add(obj2);
+ }
+ }
+ obj.add("ipTosCountList", builder);
+ }
+
+
+ /***************************************************************************/
+ /* Make some compile-time assertions about EVEL_TCP_FLAGS. If you update */
+ /* these, make sure you update evel_tcp_flag_strings to match the enum. */
+ /***************************************************************************/
+
+ found_tcp_flag = false;
+ for (index = 0; index < EVEL_MAX_TCP_FLAGS; index++)
+ {
+ if (metrics.tcp_flag_counts[index].is_set)
+ {
+ found_tcp_flag = true;
+ break;
+ }
+ }
+
+ if (found_tcp_flag)
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for (index = 0; index < EVEL_MAX_TCP_FLAGS; index++)
+ {
+ if (metrics.tcp_flag_counts[index].is_set)
+ {
+ JsonObjectBuilder obj2 = Json.createObjectBuilder()
+ .add(Integer.toString(index), evel_tcp_flag_strings[index]);
+ builder.add(obj2);
+ }
+ }
+ obj.add("tcpFlagList", builder);
+ }
+
+ if (found_tcp_flag)
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for (index = 0; index < EVEL_MAX_TCP_FLAGS; index++)
+ {
+ if (metrics.tcp_flag_counts[index].is_set)
+ {
+ JsonObjectBuilder obj2 = Json.createObjectBuilder()
+ .add(evel_tcp_flag_strings[index], metrics.tcp_flag_counts[index].value);
+ builder.add(obj2);
+ }
+ }
+ obj.add("tcpFlagCountList", builder);
+ }
+
+ /***************************************************************************/
+ /* Make some compile-time assertions about EVEL_QCI_COS_TYPES. If you */
+ /* update these, make sure you update evel_qci_cos_strings to match the */
+ /* enum. */
+ /***************************************************************************/
+
+ found_qci_cos = false;
+ for (index = 0; index < EVEL_MAX_QCI_COS_TYPES; index++)
+ {
+ if (metrics.qci_cos_counts[index].is_set)
+ {
+ found_qci_cos = true;
+ break;
+ }
+ }
+
+ if (found_qci_cos)
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for (index = 0; index < EVEL_MAX_QCI_COS_TYPES; index++)
+ {
+ if (metrics.qci_cos_counts[index].is_set)
+ {
+ JsonObjectBuilder obj2 = Json.createObjectBuilder()
+ .add(Integer.toString(index), evel_qci_cos_strings[index]);
+ builder.add(obj2);
+ }
+ }
+ obj.add("mobileQciCosList", builder);
+ }
+
+ if (found_qci_cos)
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for (index = 0; index < EVEL_MAX_QCI_COS_TYPES; index++)
+ {
+ if (metrics.qci_cos_counts[index].is_set)
+ {
+ JsonObjectBuilder obj2 = Json.createObjectBuilder()
+ .add(evel_qci_cos_strings[index], metrics.qci_cos_counts[index].value);
+ builder.add(obj2);
+ }
+ }
+ obj.add("mobileQciCosCountList", builder);
+ }
+
+ metrics.dur_connection_failed_status.encJsonValue(obj, "durConnectionFailedStatus");
+ metrics.dur_tunnel_failed_status.encJsonValue(obj, "durTunnelFailedStatus");
+ metrics.flow_activated_by.encJsonValue(obj, "flowActivatedBy");
+ metrics.flow_activation_time.encJsonValue(obj,"flowActivationTime");
+ metrics.flow_deactivated_by.encJsonValue(obj, "flowDeactivatedBy");
+ metrics.gtp_connection_status.encJsonValue(obj, "gtpConnectionStatus");
+ metrics.gtp_tunnel_status.encJsonValue(obj, "gtpTunnelStatus");
+ metrics.large_packet_rtt.encJsonValue(obj, "largePacketRtt");
+ metrics.large_packet_threshold.encJsonValue(obj, "largePacketThreshold");
+ metrics.max_receive_bit_rate.encJsonValue(obj, "maxReceiveBitRate");
+ metrics.max_transmit_bit_rate.encJsonValue(obj, "maxTransmitBitRate");
+ metrics.num_gtp_echo_failures.encJsonValue(obj, "numGtpEchoFailures");
+ metrics.num_gtp_tunnel_errors.encJsonValue(obj, "numGtpTunnelErrors");
+ metrics.num_http_errors.encJsonValue(obj, "numHttpErrors");
+
+ return obj;
+
+ }
+
+
+ /**************************************************************************//**
+ * Encode Mobile Flow Object according to VES schema
+ *
+ * @retval JSON Object of Mobile Flow event
+ *****************************************************************************/
+ JsonObjectBuilder evelMobileFlowObject()
+ {
+
+ double version = major_version+(double)minor_version/10;
+
+ EVEL_ENTER();
+
+ /***************************************************************************/
+ /* Check preconditions. */
+ /***************************************************************************/
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_MOBILE_FLOW);
+
+ /***************************************************************************/
+ /* Mandatory fields. */
+ /***************************************************************************/
+ JsonObjectBuilder evelmf = Json.createObjectBuilder()
+ .add("flowDirection", flow_direction)
+ .add("ipProtocolType", ip_protocol_type)
+ .add("ipVersion", ip_version)
+ .add("otherEndpointIpAddress", other_endpoint_ip_address)
+ .add("otherEndpointPort", other_endpoint_port)
+ .add("reportingEndpointIpAddr", reporting_endpoint_ip_addr)
+ .add("reportingEndpointPort", reporting_endpoint_port);
+
+ //call gtp per flow object encoding function
+ if(gtp_per_flow_metrics != null)
+ evelmf.add("gtpPerFlowMetrics", evelGtpPerFlowObject());
+
+
+
+ /***************************************************************************/
+ /* Optional fields. */
+ /***************************************************************************/
+ // additional fields
+ if( additional_info != null )
+ {
+ JsonArrayBuilder builder = Json.createArrayBuilder();
+ for(int i=0;i<additional_info.size();i++) {
+ String[] addl_info = additional_info.get(i);
+ JsonObject obj = Json.createObjectBuilder()
+ .add("name", addl_info[0])
+ .add("value", addl_info[1]).build();
+ builder.add(obj);
+ }
+ evelmf.add("additionalFields", builder);
+ }
+
+
+ /***************************************************************************/
+ /* Optional parameters. */
+ /***************************************************************************/
+ application_type.encJsonValue(evelmf, "applicationType");
+ app_protocol_type.encJsonValue(evelmf, "appProtocolType");
+ app_protocol_version.encJsonValue(evelmf, "appProtocolVersion");
+ cid.encJsonValue(evelmf,"cid");
+ connection_type.encJsonValue(evelmf, "connectionType");
+ ecgi.encJsonValue(evelmf, "ecgi");
+ gtp_protocol_type.encJsonValue(evelmf, "gtpProtocolType");
+ gtp_version.encJsonValue(evelmf, "gtpVersion");
+ http_header.encJsonValue(evelmf, "httpHeader");
+ imei.encJsonValue(evelmf, "imei");
+ imsi.encJsonValue(evelmf, "imsi");
+ lac.encJsonValue(evelmf, "lac");
+ mcc.encJsonValue(evelmf, "mcc");
+ mnc.encJsonValue(evelmf, "mnc");
+ msisdn.encJsonValue(evelmf, "msisdn");
+ other_functional_role.encJsonValue(evelmf,"otherFunctionalRole");
+ rac.encJsonValue(evelmf, "rac");
+ radio_access_technology.encJsonValue(evelmf, "radioAccessTechnology");
+ sac.encJsonValue(evelmf, "sac");
+ sampling_algorithm.encJsonValue(evelmf, "samplingAlgorithm");
+ tac.encJsonValue(evelmf, "tac");
+ tunnel_id.encJsonValue(evelmf,"tunnelId");
+ vlan_id.encJsonValue(evelmf,"vlanId");
+
+
+ /***************************************************************************/
+ /* Although optional, we always generate the version. Note that this */
+ /* closes the object, too. */
+ /***************************************************************************/
+ evelmf.add("mobileFlowFieldsVersion", version);
+
+ EVEL_EXIT();
+
+ return evelmf;
+ }
+
+ /**************************************************************************//**
+ * Encode the event as a JSON event object according to AT&T's schema.
+ * retval : String of JSON event message
+ *****************************************************************************/
+ JsonObject evel_json_encode_event()
+ {
+ EVEL_ENTER();
+
+ assert(event_domain == EvelHeader.DOMAINS.EVEL_DOMAIN_STATE_CHANGE);
+ //encode common event header and mobile flow body
+ JsonObject obj = Json.createObjectBuilder()
+ .add("event", Json.createObjectBuilder()
+ .add( "commonEventHeader",eventHeaderObject() )
+ .add( "mobileFlowFields",evelMobileFlowObject() )
+ ).build();
+
+ EVEL_EXIT();
+
+ return obj;
+
+ }
+
+
+}
|