diff options
Diffstat (limited to 'VES5.0/evel/evel-library/code/evel_unit/evel_unit.c')
| -rw-r--r-- | VES5.0/evel/evel-library/code/evel_unit/evel_unit.c | 3498 |
1 files changed, 3498 insertions, 0 deletions
diff --git a/VES5.0/evel/evel-library/code/evel_unit/evel_unit.c b/VES5.0/evel/evel-library/code/evel_unit/evel_unit.c new file mode 100644 index 00000000..ba4739b0 --- /dev/null +++ b/VES5.0/evel/evel-library/code/evel_unit/evel_unit.c @@ -0,0 +1,3498 @@ +/**************************************************************************//** + * @file + * Unit tests for JSON encoding and throttling. + * + * This software is intended to show the essential elements of the library's + * use. + * + * License + * ------- + * + * Copyright(c) <2016>, AT&T Intellectual Property. All other rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright notice, + * this list of conditions and the following disclaimer in the documentation + * and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: This product includes software + * developed by the AT&T. + * 4. Neither the name of AT&T nor the names of its contributors may be used to + * endorse or promote products derived from this software without specific + * prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY AT&T INTELLECTUAL PROPERTY ''AS IS'' AND ANY + * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE + * DISCLAIMED. IN NO EVENT SHALL AT&T INTELLECTUAL PROPERTY BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES + * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; + * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND + * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + *****************************************************************************/ + +#include <stdio.h> +#include <string.h> +#include <assert.h> +#include <stdlib.h> +#include <sys/time.h> + +#include "evel.h" +#include "evel_internal.h" +#include "evel_throttle.h" +#include "metadata.h" + +typedef enum { + SERVICE_NONE, + SERVICE_CODEC, + SERVICE_TRANSCODING, + SERVICE_RTCP, + SERVICE_EOC_VQM, + SERVICE_MARKER +} SERVICE_TEST; + +/*****************************************************************************/ +/* Local prototypes. */ +/*****************************************************************************/ +static void test_encode_heartbeat(); +static void test_encode_header_overrides(); +static void test_encode_fault(); +static void test_encode_fault_with_escaping(); +static void test_encode_measurement(); +static void test_encode_mobile_mand(); +static void test_encode_mobile_opts(); +static void test_encode_other(); +static void test_encode_report(); +static void test_encode_service(); +static void test_encode_service_subset(const SERVICE_TEST service_test); +static void test_encode_signaling(); +static void test_encode_state_change(); +static void test_encode_syslog(); +static void test_json_response_junk(); +static void test_json_provide_throttle_state(); +static void test_json_measurement_interval(); +static void test_json_throttle_spec_field(); +static void test_json_throttle_spec_nv_pair(); +static void test_json_throttle_spec_two_domains(); +static void test_json_throttle_spec_bad_command_type(); +static void test_encode_fault_throttled(); +static void test_encode_measurement_throttled(); +static void test_encode_mobile_throttled(); +static void test_encode_other_throttled(); +static void test_encode_report_throttled(); +static void test_encode_service_throttled(); +static void test_encode_signaling_throttled(); +static void test_encode_state_change_throttled(); +static void test_encode_syslog_throttled(); +static void compare_strings(char * expected, + char * actual, + int max_size, + char * description); + +/**************************************************************************//** + * Main function. + * + * Runs all unit test cases, and fails hard on the first failure. + * + * @param[in] argc Argument count. + * @param[in] argv Argument vector - for usage see usage_text. + *****************************************************************************/ +int main(int argc, char ** argv) +{ + assert(argc >= 0); + assert(argv != NULL); + + /***************************************************************************/ + /* Fix our timezone to UTC. */ + /***************************************************************************/ + putenv("TZ=UTC"); + + /***************************************************************************/ + /* Initialize metadata. */ + /***************************************************************************/ + openstack_metadata_initialize(); + + /***************************************************************************/ + /* Minimal initialisation to exercise the encoders. */ + /***************************************************************************/ + functional_role = "UNIT TEST"; + log_initialize(EVEL_LOG_DEBUG, "EVEL"); + + /***************************************************************************/ + /* Test each encoder. */ + /***************************************************************************/ + test_encode_heartbeat(); + test_encode_header_overrides(); + test_encode_fault(); + test_encode_measurement(); + test_encode_mobile_mand(); + test_encode_mobile_opts(); + test_encode_other(); + test_encode_report(); + test_encode_service(); + test_encode_signaling(); + test_encode_state_change(); + test_encode_syslog(); + + /***************************************************************************/ + /* Test JSON Throttle. */ + /***************************************************************************/ + test_json_response_junk(); + test_json_provide_throttle_state(); + test_json_measurement_interval(); + test_json_throttle_spec_field(); + test_json_throttle_spec_nv_pair(); + test_json_throttle_spec_two_domains(); + test_json_throttle_spec_bad_command_type(); + + /***************************************************************************/ + /* Test each encoder with throttling applied. */ + /***************************************************************************/ + test_encode_fault_throttled(); + test_encode_measurement_throttled(); + test_encode_mobile_throttled(); + test_encode_other_throttled(); + test_encode_report_throttled(); + test_encode_service_throttled(); + test_encode_signaling_throttled(); + test_encode_state_change_throttled(); + test_encode_syslog_throttled(); + + /***************************************************************************/ + /* Test character escaping. */ + /***************************************************************************/ + test_encode_fault_with_escaping(); + + printf ("\nAll Tests Passed\n"); + + return 0; +} + +/*****************************************************************************/ +/* We link with this gettimeofday so that we get a fixed result */ +/*****************************************************************************/ +int gettimeofday(struct timeval *tv, + struct timezone *tz __attribute__((unused))) +{ + tv->tv_sec = 1; + tv->tv_usec = 2; + return 0; +} + +void test_encode_heartbeat() +{ + char * expected = + "{\"event\": {" + "\"commonEventHeader\": {" + "\"domain\": \"heartbeat\", " + "\"eventId\": \"121\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 121, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Autonomous heartbeat\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + + /***************************************************************************/ + /* Test the VM name/uuid once. */ + /***************************************************************************/ + evel_set_next_event_sequence(121); + + EVENT_HEADER * heartbeat = evel_new_heartbeat(); + assert(heartbeat != NULL); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) heartbeat); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Heartbeat"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(heartbeat); +} + +void test_encode_header_overrides() +{ + char * expected = + "{\"event\": {" + "\"commonEventHeader\": {" + "\"domain\": \"heartbeat\", " + "\"eventId\": \"121\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"entity_name_override\", " + "\"sequence\": 121, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1001, " + "\"version\": 1.2, " + "\"eventType\": \"Autonomous heartbeat\", " + "\"reportingEntityId\": \"entity_id_override\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + + /***************************************************************************/ + /* Test the VM name/uuid once. */ + /***************************************************************************/ + evel_set_next_event_sequence(121); + + EVENT_HEADER * heartbeat = evel_new_heartbeat(); + assert(heartbeat != NULL); + + evel_start_epoch_set(heartbeat, 1001); + evel_last_epoch_set(heartbeat, 1000); + evel_reporting_entity_name_set(heartbeat, "entity_name_override"); + evel_reporting_entity_id_set(heartbeat, "entity_id_override"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) heartbeat); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Heartbeat"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(heartbeat); +} + +void test_encode_fault() +{ + char * expected = + "{\"event\": {" + "\"commonEventHeader\": {" + "\"domain\": \"fault\", " + "\"eventId\": \"122\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 122, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Bad things happen...\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"faultFields\": {" + "\"alarmCondition\": \"My alarm condition\", " + "\"eventSeverity\": \"MAJOR\", " + "\"eventSourceType\": \"other\", " + "\"specificProblem\": \"It broke very badly\", " + "\"eventCategory\": \"link\", " + "\"vfStatus\": \"Active\", " + "\"faultFieldsVersion\": 1.1, " + "\"alarmAdditionalInformation\": [" + "{\"name\": \"name1\", " + "\"value\": \"value1\"}, " + "{\"name\": \"name2\", " + "\"value\": \"value2\"}], " + "\"alarmInterfaceA\": \"My Interface Card\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + evel_set_next_event_sequence(122); + EVENT_FAULT * fault = evel_new_fault("My alarm condition", + "It broke very badly", + EVEL_PRIORITY_NORMAL, + EVEL_SEVERITY_MAJOR, + EVEL_SOURCE_HOST, + EVEL_VF_STATUS_PREP_TERMINATE); + assert(fault != NULL); + evel_fault_type_set(fault, "Bad things happen..."); + evel_fault_interface_set(fault, "My Interface Card"); + evel_fault_addl_info_add(fault, "name1", "value1"); + evel_fault_addl_info_add(fault, "name2", "value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) fault); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Fault"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(fault); +} + +void test_encode_measurement() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"measurementsForVfScaling\", " + "\"eventId\": \"123\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 3000, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"entity_name\", " + "\"sequence\": 123, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 2000, " + "\"version\": 1.2, " + "\"eventType\": \"Perf management...\", " + "\"reportingEntityId\": \"entity_id\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"measurementsForVfScalingFields\": " + "{" + "\"measurementInterval\": 5.500000, " + "\"concurrentSessions\": 1, " + "\"configuredEntities\": 2, " + "\"cpuUsageArray\": [" + "{\"cpuIdentifier\": \"cpu1\", " + "\"percentUsage\": 11.110000}, " + "{\"cpuIdentifier\": \"cpu2\", " + "\"percentUsage\": 22.220000}], " + "\"filesystemUsageArray\": [" + "{\"blockConfigured\": 100.110000, " + "\"blockIops\": 33, " + "\"blockUsed\": 100.220000, " + "\"ephemeralConfigured\": 100.110000, " + "\"ephemeralIops\": 44, " + "\"ephemeralUsed\": 200.220000, " + "\"filesystemName\": \"00-11-22\"}, " + "{\"blockConfigured\": 300.110000, " + "\"blockIops\": 55, " + "\"blockUsed\": 300.220000, " + "\"ephemeralConfigured\": 300.110000, " + "\"ephemeralIops\": 66, " + "\"ephemeralUsed\": 400.220000, " + "\"filesystemName\": \"33-44-55\"}], " + "\"latencyDistribution\": [" + "{\"countsInTheBucket\": 20}, " + "{\"lowEndOfLatencyBucket\": 10.000000, " + "\"highEndOfLatencyBucket\": 20.000000, " + "\"countsInTheBucket\": 30}], " + "\"meanRequestLatency\": 4.400000, " + "\"memoryConfigured\": 6.600000, " + "\"memoryUsed\": 3.300000, " + "\"requestRate\": 7, " + "\"vNicUsageArray\": [" + "{" + "\"bytesIn\": 3, " + "\"bytesOut\": 4, " + "\"packetsIn\": 100, " + "\"packetsOut\": 200, " + "\"vNicIdentifier\": \"eth0\"" + "}, " + "{" + "\"bytesIn\": 13, " + "\"bytesOut\": 14, " + "\"packetsIn\": 110, " + "\"packetsOut\": 240, " + "\"vNicIdentifier\": \"eth1\", " + "\"broadcastPacketsIn\": 11, " + "\"broadcastPacketsOut\": 12, " + "\"multicastPacketsIn\": 15, " + "\"multicastPacketsOut\": 16, " + "\"unicastPacketsIn\": 17, " + "\"unicastPacketsOut\": 18" + "}" + "], " + "\"aggregateCpuUsage\": 8.800000, " + "\"numberOfMediaPortsInUse\": 1234, " + "\"vnfcScalingMetric\": 1234.567800, " + "\"errors\": {" + "\"receiveDiscards\": 1, " + "\"receiveErrors\": 0, " + "\"transmitDiscards\": 2, " + "\"transmitErrors\": 1}, " + "\"featureUsageArray\": [" + "{\"featureIdentifier\": \"FeatureA\", " + "\"featureUtilization\": 123}, " + "{\"featureIdentifier\": \"FeatureB\", " + "\"featureUtilization\": 567}], " + "\"codecUsageArray\": [" + "{\"codecIdentifier\": \"G711a\", " + "\"numberInUse\": 91}, " + "{\"codecIdentifier\": \"G729ab\", " + "\"numberInUse\": 92}], " + "\"additionalMeasurements\": [" + "{\"name\": \"Group1\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}]}, " + "{\"name\": \"Group2\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}, " + "{\"name\": \"Name2\", " + "\"value\": \"Value2\"}]}], " + "\"measurementsForVfScalingVersion\": 1.1}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_MEASUREMENT * measurement = NULL; + MEASUREMENT_LATENCY_BUCKET * bucket = NULL; + MEASUREMENT_VNIC_PERFORMANCE * vnic_use = NULL; + MEASUREMENT_CPU_USE *cpu_use; + + /***************************************************************************/ + /* Measurement. */ + /***************************************************************************/ + evel_set_next_event_sequence(123); + measurement = evel_new_measurement(5.5); + assert(measurement != NULL); + evel_measurement_type_set(measurement, "Perf management..."); + evel_measurement_conc_sess_set(measurement, 1); + evel_measurement_cfg_ents_set(measurement, 2); + evel_measurement_mean_req_lat_set(measurement, 4.4); + evel_measurement_request_rate_set(measurement, 7); + + cpu_use = evel_measurement_new_cpu_use_add(measurement, "cpu1", 11.11); + evel_measurement_cpu_use_idle_set(cpu_use,22.22); + evel_measurement_cpu_use_interrupt_set(cpu_use,33.33); + evel_measurement_cpu_use_nice_set(cpu_use,44.44); + evel_measurement_cpu_use_softirq_set(cpu_use,55.55); + evel_measurement_cpu_use_steal_set(cpu_use,66.66); + evel_measurement_cpu_use_system_set(cpu_use,77.77); + evel_measurement_cpu_use_usageuser_set(cpu_use,88.88); + evel_measurement_cpu_use_wait_set(cpu_use,99.99); + + cpu_use = evel_measurement_new_cpu_use_add(measurement, "cpu2", 22.22); + evel_measurement_cpu_use_idle_set(cpu_use,12.22); + evel_measurement_cpu_use_interrupt_set(cpu_use,33.33); + evel_measurement_cpu_use_nice_set(cpu_use,44.44); + evel_measurement_cpu_use_softirq_set(cpu_use,55.55); + evel_measurement_cpu_use_steal_set(cpu_use,66.66); + evel_measurement_cpu_use_system_set(cpu_use,77.77); + evel_measurement_cpu_use_usageuser_set(cpu_use,88.88); + evel_measurement_cpu_use_wait_set(cpu_use,19.99); + + + evel_measurement_fsys_use_add(measurement,"00-11-22",100.11, 100.22, 33, + 200.11, 200.22, 44); + evel_measurement_fsys_use_add(measurement,"33-44-55",300.11, 300.22, 55, + 400.11, 400.22, 66); + evel_start_epoch_set(&measurement->header, 2000); + evel_last_epoch_set(&measurement->header, 3000); + evel_reporting_entity_name_set(&measurement->header, "entity_name"); + evel_reporting_entity_id_set(&measurement->header, "entity_id"); + + /***************************************************************************/ + /* Latency Bucket with no optional parameters. */ + /***************************************************************************/ + bucket = evel_new_meas_latency_bucket(20); + evel_meas_latency_bucket_add(measurement, bucket); + + /***************************************************************************/ + /* Latency Bucket with all optional parameters. */ + /***************************************************************************/ + bucket = evel_new_meas_latency_bucket(30); + evel_meas_latency_bucket_low_end_set(bucket, 10.0); + evel_meas_latency_bucket_high_end_set(bucket, 20.0); + evel_meas_latency_bucket_add(measurement, bucket); + + /***************************************************************************/ + /* vNIC Use with no optional parameters. */ + /***************************************************************************/ + vnic_use = evel_new_measurement_vnic_use("eth0", 100, 200, 3, 4); + evel_meas_vnic_use_add(measurement, vnic_use); + + /***************************************************************************/ + /* vNIC Use with all optional parameters. */ + /***************************************************************************/ + vnic_use = evel_new_measurement_vnic_use("eth1", 110, 240, 13, 14); + evel_vnic_use_bcast_pkt_in_set(vnic_use, 11); + evel_vnic_use_bcast_pkt_out_set(vnic_use, 12); + evel_vnic_use_mcast_pkt_in_set(vnic_use, 15); + evel_vnic_use_mcast_pkt_out_set(vnic_use, 16); + evel_vnic_use_ucast_pkt_in_set(vnic_use, 17); + evel_vnic_use_ucast_pkt_out_set(vnic_use, 18); + evel_meas_vnic_use_add(measurement, vnic_use); + + evel_measurement_errors_set(measurement, 1, 0, 2, 1); + + evel_measurement_feature_use_add(measurement, "FeatureA", 123); + evel_measurement_feature_use_add(measurement, "FeatureB", 567); + + evel_measurement_codec_use_add(measurement, "G711a", 91); + evel_measurement_codec_use_add(measurement, "G729ab", 92); + + evel_measurement_media_port_use_set(measurement, 1234); + + evel_measurement_vnfc_scaling_metric_set(measurement, 1234.5678); + + evel_measurement_custom_measurement_add(measurement, + "Group1", "Name1", "Value1"); + evel_measurement_custom_measurement_add(measurement, + "Group2", "Name1", "Value1"); + evel_measurement_custom_measurement_add(measurement, + "Group2", "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) measurement); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Measurement"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(measurement); +} + +void test_encode_mobile_mand() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"mobileFlow\", " + "\"eventId\": \"1241\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 1241, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"mobileFlowFields\": {" + "\"flowDirection\": \"Outbound\", " + "\"gtpPerFlowMetrics\": {" + "\"avgBitErrorRate\": 12.300000, " + "\"avgPacketDelayVariation\": 3.120000, " + "\"avgPacketLatency\": 100, " + "\"avgReceiveThroughput\": 2100, " + "\"avgTransmitThroughput\": 500, " + "\"flowActivationEpoch\": 1470409421, " + "\"flowActivationMicrosec\": 987, " + "\"flowDeactivationEpoch\": 1470409431, " + "\"flowDeactivationMicrosec\": 11, " + "\"flowDeactivationTime\": \"Fri, 05 Aug 2016 15:03:51 +0000\", " + "\"flowStatus\": \"Working\", " + "\"maxPacketDelayVariation\": 87, " + "\"numActivationFailures\": 3, " + "\"numBitErrors\": 17, " + "\"numBytesReceived\": 123654, " + "\"numBytesTransmitted\": 4561, " + "\"numDroppedPackets\": 0, " + "\"numL7BytesReceived\": 12, " + "\"numL7BytesTransmitted\": 10, " + "\"numLostPackets\": 1, " + "\"numOutOfOrderPackets\": 3, " + "\"numPacketErrors\": 7, " + "\"numPacketsReceivedExclRetrans\": 899, " + "\"numPacketsReceivedInclRetrans\": 901, " + "\"numPacketsTransmittedInclRetrans\": 302, " + "\"numRetries\": 6, " + "\"numTimeouts\": 2, " + "\"numTunneledL7BytesReceived\": 0, " + "\"roundTripTime\": 110, " + "\"timeToFirstByte\": 225" + "}, " + "\"ipProtocolType\": \"TCP\", " + "\"ipVersion\": \"IPv4\", " + "\"otherEndpointIpAddress\": \"2.3.4.1\", " + "\"otherEndpointPort\": 2341, " + "\"reportingEndpointIpAddr\": \"4.2.3.1\", " + "\"reportingEndpointPort\": 4321" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + MOBILE_GTP_PER_FLOW_METRICS * metrics = NULL; + EVENT_MOBILE_FLOW * mobile_flow = NULL; + + /***************************************************************************/ + /* Mobile. */ + /***************************************************************************/ + evel_set_next_event_sequence(1241); + + metrics = evel_new_mobile_gtp_flow_metrics(12.3, + 3.12, + 100, + 2100, + 500, + 1470409421, + 987, + 1470409431, + 11, + (time_t)1470409431, + "Working", + 87, + 3, + 17, + 123654, + 4561, + 0, + 12, + 10, + 1, + 3, + 7, + 899, + 901, + 302, + 6, + 2, + 0, + 110, + 225); + assert(metrics != NULL); + mobile_flow = evel_new_mobile_flow("Outbound", + metrics, + "TCP", + "IPv4", + "2.3.4.1", + 2341, + "4.2.3.1", + 4321); + assert(mobile_flow != NULL); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) mobile_flow); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Mobile"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(mobile_flow); +} + +void test_encode_mobile_opts() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"mobileFlow\", " + "\"eventId\": \"1242\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 1242, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Mobile flow...\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"mobileFlowFields\": {" + "\"flowDirection\": \"Inbound\", " + "\"gtpPerFlowMetrics\": {" + "\"avgBitErrorRate\": 132.000100, " + "\"avgPacketDelayVariation\": 31.200000, " + "\"avgPacketLatency\": 101, " + "\"avgReceiveThroughput\": 2101, " + "\"avgTransmitThroughput\": 501, " + "\"flowActivationEpoch\": 1470409422, " + "\"flowActivationMicrosec\": 988, " + "\"flowDeactivationEpoch\": 1470409432, " + "\"flowDeactivationMicrosec\": 12, " + "\"flowDeactivationTime\": \"Fri, 05 Aug 2016 15:03:52 +0000\", " + "\"flowStatus\": \"Inactive\", " + "\"maxPacketDelayVariation\": 88, " + "\"numActivationFailures\": 4, " + "\"numBitErrors\": 18, " + "\"numBytesReceived\": 123655, " + "\"numBytesTransmitted\": 4562, " + "\"numDroppedPackets\": 1, " + "\"numL7BytesReceived\": 13, " + "\"numL7BytesTransmitted\": 11, " + "\"numLostPackets\": 2, " + "\"numOutOfOrderPackets\": 4, " + "\"numPacketErrors\": 8, " + "\"numPacketsReceivedExclRetrans\": 900, " + "\"numPacketsReceivedInclRetrans\": 902, " + "\"numPacketsTransmittedInclRetrans\": 303, " + "\"numRetries\": 7, " + "\"numTimeouts\": 3, " + "\"numTunneledL7BytesReceived\": 1, " + "\"roundTripTime\": 111, " + "\"timeToFirstByte\": 226, " + "\"ipTosCountList\": [" + "[\"1\", 13], " + "[\"4\", 99], " + "[\"17\", 1]], " + "\"ipTosList\": [\"1\", \"4\", \"17\"], " + "\"tcpFlagList\": [\"CWR\", \"URG\"], " + "\"tcpFlagCountList\": [[\"CWR\", 10], [\"URG\", 121]], " + "\"mobileQciCosList\": [\"conversational\", \"65\"], " + "\"mobileQciCosCountList\": [[\"conversational\", 11], [\"65\", 122]], " + "\"durConnectionFailedStatus\": 12, " + "\"durTunnelFailedStatus\": 13, " + "\"flowActivatedBy\": \"Remote\", " + "\"flowActivationTime\": \"Fri, 05 Aug 2016 15:03:43 +0000\", " + "\"flowDeactivatedBy\": \"Remote\", " + "\"gtpConnectionStatus\": \"Connected\", " + "\"gtpTunnelStatus\": \"Not tunneling\", " + "\"largePacketRtt\": 80, " + "\"largePacketThreshold\": 600.000000, " + "\"maxReceiveBitRate\": 1357924680, " + "\"maxTransmitBitRate\": 235711, " + "\"numGtpEchoFailures\": 1, " + "\"numGtpTunnelErrors\": 4, " + "\"numHttpErrors\": 2" + "}, " + "\"ipProtocolType\": \"UDP\", " + "\"ipVersion\": \"IPv6\", " + "\"otherEndpointIpAddress\": \"2.3.4.2\", " + "\"otherEndpointPort\": 2342, " + "\"reportingEndpointIpAddr\": \"4.2.3.2\", " + "\"reportingEndpointPort\": 4322, " + "\"applicationType\": \"Demo application\", " + "\"appProtocolType\": \"GSM\", " + "\"appProtocolVersion\": \"1\", " + "\"cid\": \"65535\", " + "\"connectionType\": \"S1-U\", " + "\"ecgi\": \"e65535\", " + "\"gtpProtocolType\": \"GTP-U\", " + "\"gtpVersion\": \"1\", " + "\"httpHeader\": \"http://www.something.com\", " + "\"imei\": \"209917614823\", " + "\"imsi\": \"355251/05/850925/8\", " + "\"lac\": \"1\", " + "\"mcc\": \"410\", " + "\"mnc\": \"04\", " + "\"msisdn\": \"6017123456789\", " + "\"otherFunctionalRole\": \"MME\", " + "\"rac\": \"514\", " + "\"radioAccessTechnology\": \"LTE\", " + "\"sac\": \"1\", " + "\"samplingAlgorithm\": 1, " + "\"tac\": \"2099\", " + "\"tunnelId\": \"Tunnel 1\", " + "\"vlanId\": \"15\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + MOBILE_GTP_PER_FLOW_METRICS * metrics = NULL; + EVENT_MOBILE_FLOW * mobile_flow = NULL; + + /***************************************************************************/ + /* Mobile. */ + /***************************************************************************/ + evel_set_next_event_sequence(1242); + + metrics = evel_new_mobile_gtp_flow_metrics(132.0001, + 31.2, + 101, + 2101, + 501, + 1470409422, + 988, + 1470409432, + 12, + (time_t)1470409432, + "Inactive", + 88, + 4, + 18, + 123655, + 4562, + 1, + 13, + 11, + 2, + 4, + 8, + 900, + 902, + 303, + 7, + 3, + 1, + 111, + 226); + assert(metrics != NULL); + + evel_mobile_gtp_metrics_dur_con_fail_set(metrics, 12); + evel_mobile_gtp_metrics_dur_tun_fail_set(metrics, 13); + evel_mobile_gtp_metrics_act_by_set(metrics, "Remote"); + evel_mobile_gtp_metrics_act_time_set(metrics, (time_t)1470409423); + evel_mobile_gtp_metrics_deact_by_set(metrics, "Remote"); + evel_mobile_gtp_metrics_con_status_set(metrics, "Connected"); + evel_mobile_gtp_metrics_tun_status_set(metrics, "Not tunneling"); + evel_mobile_gtp_metrics_iptos_set(metrics, 1, 13); + evel_mobile_gtp_metrics_iptos_set(metrics, 17, 1); + evel_mobile_gtp_metrics_iptos_set(metrics, 4, 99); + evel_mobile_gtp_metrics_large_pkt_rtt_set(metrics, 80); + evel_mobile_gtp_metrics_large_pkt_thresh_set(metrics, 600.0); + evel_mobile_gtp_metrics_max_rcv_bit_rate_set(metrics, 1357924680); + evel_mobile_gtp_metrics_max_trx_bit_rate_set(metrics, 235711); + evel_mobile_gtp_metrics_num_echo_fail_set(metrics, 1); + evel_mobile_gtp_metrics_num_tun_fail_set(metrics, 4); + evel_mobile_gtp_metrics_num_http_errors_set(metrics, 2); + evel_mobile_gtp_metrics_tcp_flag_count_add(metrics, EVEL_TCP_CWR, 10); + evel_mobile_gtp_metrics_tcp_flag_count_add(metrics, EVEL_TCP_URG, 121); + evel_mobile_gtp_metrics_qci_cos_count_add( + metrics, EVEL_QCI_COS_UMTS_CONVERSATIONAL, 11); + evel_mobile_gtp_metrics_qci_cos_count_add( + metrics, EVEL_QCI_COS_LTE_65, 122); + + mobile_flow = evel_new_mobile_flow("Inbound", + metrics, + "UDP", + "IPv6", + "2.3.4.2", + 2342, + "4.2.3.2", + 4322); + assert(mobile_flow != NULL); + + evel_mobile_flow_type_set(mobile_flow, "Mobile flow..."); + evel_mobile_flow_app_type_set(mobile_flow, "Demo application"); + evel_mobile_flow_app_prot_type_set(mobile_flow, "GSM"); + evel_mobile_flow_app_prot_ver_set(mobile_flow, "1"); + evel_mobile_flow_cid_set(mobile_flow, "65535"); + evel_mobile_flow_con_type_set(mobile_flow, "S1-U"); + evel_mobile_flow_ecgi_set(mobile_flow, "e65535"); + evel_mobile_flow_gtp_prot_type_set(mobile_flow, "GTP-U"); + evel_mobile_flow_gtp_prot_ver_set(mobile_flow, "1"); + evel_mobile_flow_http_header_set(mobile_flow, + "http://www.something.com"); + evel_mobile_flow_imei_set(mobile_flow, "209917614823"); + evel_mobile_flow_imsi_set(mobile_flow, "355251/05/850925/8"); + evel_mobile_flow_lac_set(mobile_flow, "1"); + evel_mobile_flow_mcc_set(mobile_flow, "410"); + evel_mobile_flow_mnc_set(mobile_flow, "04"); + evel_mobile_flow_msisdn_set(mobile_flow, "6017123456789"); + evel_mobile_flow_other_func_role_set(mobile_flow, "MME"); + evel_mobile_flow_rac_set(mobile_flow, "514"); + evel_mobile_flow_radio_acc_tech_set(mobile_flow, "LTE"); + evel_mobile_flow_sac_set(mobile_flow, "1"); + evel_mobile_flow_samp_alg_set(mobile_flow, 1); + evel_mobile_flow_tac_set(mobile_flow, "2099"); + evel_mobile_flow_tunnel_id_set(mobile_flow, "Tunnel 1"); + evel_mobile_flow_vlan_id_set(mobile_flow, "15"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) mobile_flow); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Mobile"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(mobile_flow); +} + +void test_encode_report() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"measurementsForVfReporting\", " + "\"eventId\": \"125\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 125, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Perf reporting...\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"measurementsForVfReportingFields\": " + "{\"measurementInterval\": 1.100000, " + "\"featureUsageArray\": [" + "{\"featureIdentifier\": \"FeatureA\", " + "\"featureUtilization\": 123}, " + "{\"featureIdentifier\": \"FeatureB\", " + "\"featureUtilization\": 567}], " + "\"additionalMeasurements\": [" + "{\"name\": \"Group1\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}]}, " + "{\"name\": \"Group2\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}, " + "{\"name\": \"Name2\", " + "\"value\": \"Value2\"}]}], " + "\"measurementFieldsVersion\": 1.1}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_REPORT * report = NULL; + + /***************************************************************************/ + /* Report. */ + /***************************************************************************/ + evel_set_next_event_sequence(125); + report = evel_new_report(1.1); + assert(report != NULL); + evel_report_type_set(report, "Perf reporting..."); + evel_report_feature_use_add(report, "FeatureA", 123); + evel_report_feature_use_add(report, "FeatureB", 567); + evel_report_custom_measurement_add(report, "Group1", "Name1", "Value1"); + evel_report_custom_measurement_add(report, "Group2", "Name1", "Value1"); + evel_report_custom_measurement_add(report, "Group2", "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) report); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Report"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(report); +} + +void test_encode_service() +{ + test_encode_service_subset(SERVICE_NONE); + test_encode_service_subset(SERVICE_CODEC); + test_encode_service_subset(SERVICE_TRANSCODING); + test_encode_service_subset(SERVICE_RTCP); + test_encode_service_subset(SERVICE_EOC_VQM); + test_encode_service_subset(SERVICE_MARKER); +} + +void test_encode_service_subset(const SERVICE_TEST service_test) +{ + char * expected_start = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"serviceEvents\", " + "\"eventId\": \"2000\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 2000, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Service Event\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"serviceEventsFields\": {" + "\"eventInstanceIdentifier\": " + "{" + "\"vendorId\": \"vendor_x_id\", " + "\"eventId\": \"vendor_x_event_id\", " + "\"productId\": \"vendor_x_product_id\", " + "\"subsystemId\": \"vendor_x_subsystem_id\", " + "\"eventFriendlyName\": \"vendor_x_frieldly_name\"" + "}, " + "\"serviceEventsFieldsVersion\": 1.1, " + "\"correlator\": \"vendor_x_correlator\", " + "\"additionalFields\": [" + "{\"name\": \"Name1\", \"value\": \"Value1\"}, " + "{\"name\": \"Name2\", \"value\": \"Value2\"}, " + "{\"name\": \"Name3\", \"value\": \"Value3\"}, " + "{\"name\": \"Name4\", \"value\": \"Value4\"}]"; + char * expected_codec = + ", " + "\"codecSelected\": {" + "\"codec\": \"PCMA\"" + "}"; + char * expected_transcoding = + ", " + "\"codecSelectedTranscoding\": {" + "\"calleeSideCodec\": \"PCMA\", " + "\"callerSideCodec\": \"G729A\"" + "}"; + char * expected_rtcp = + ", " + "\"midCallRtcp\": {" + "\"rtcpData\": \"some_rtcp_data\"" + "}"; + char * expected_eoc_vqm = + ", " + "\"endOfCallVqmSummaries\": {" + "\"adjacencyName\": \"vendor_x_adjacency\", " + "\"endpointDescription\": \"Caller\", " + "\"endpointJitter\": 66, " + "\"endpointRtpOctetsDiscarded\": 100, " + "\"endpointRtpOctetsReceived\": 200, " + "\"endpointRtpOctetsSent\": 300, " + "\"endpointRtpPacketsDiscarded\": 400, " + "\"endpointRtpPacketsReceived\": 500, " + "\"endpointRtpPacketsSent\": 600, " + "\"localJitter\": 99, " + "\"localRtpOctetsDiscarded\": 150, " + "\"localRtpOctetsReceived\": 250, " + "\"localRtpOctetsSent\": 350, " + "\"localRtpPacketsDiscarded\": 450, " + "\"localRtpPacketsReceived\": 550, " + "\"localRtpPacketsSent\": 650, " + "\"mosCqe\": 12.255000, " + "\"packetsLost\": 157, " + "\"packetLossPercent\": 0.232000, " + "\"rFactor\": 11, " + "\"roundTripDelay\": 15" + "}"; + char * expected_marker = + ", " + "\"marker\": {" + "\"phoneNumber\": \"0888888888\"" + "}"; + char * expected_end = + "}}}"; + + char * expected_middle = NULL; + switch (service_test) + { + case SERVICE_NONE: + expected_middle = ""; + break; + case SERVICE_CODEC: + expected_middle = expected_codec; + break; + case SERVICE_TRANSCODING: + expected_middle = expected_transcoding; + break; + case SERVICE_RTCP: + expected_middle = expected_rtcp; + break; + case SERVICE_EOC_VQM: + expected_middle = expected_eoc_vqm; + break; + case SERVICE_MARKER: + expected_middle = expected_marker; + break; + } + assert(expected_middle != NULL); + + int offset = 0; + char expected[EVEL_MAX_JSON_BODY]; + offset = snprintf(expected + offset, + EVEL_MAX_JSON_BODY - offset, + "%s%s%s", + expected_start, + expected_middle, + expected_end); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SGNALING * event = NULL; + evel_set_next_event_sequence(2000); + event = evel_new_signaling("vendor_x_id", + "correlator", "1.0.3.1", "1234", "192.168.1.3","3456"); + assert(event != NULL); + evel_signaling_type_set(event, "Signaling"); + evel_signaling_correlator_set(event, "vendor_x_correlator"); + evel_signaling_vnfmodule_name_set(event, "vendor_x_module"); + evel_signaling_vnfname_set(event, "vendor_x_vnf"); + + switch (service_test) + { + case SERVICE_NONE: + break; + case SERVICE_CODEC: + evel_signaling_addl_info_add(event, "codec", "PCMA"); + break; + case SERVICE_TRANSCODING: + evel_signaling_addl_info_add(event, "calleecodec", "PCMA"); + evel_signaling_addl_info_add(event, "callercodec", "G729A"); + break; + case SERVICE_RTCP: + evel_signaling_addl_info_add(event, "rtcpdata", "abcdefgh"); + break; + case SERVICE_EOC_VQM: + evel_signaling_addl_info_add(event, "adjacency", "vendor_x"); + /*evel_service_adjacency_name_set(event, "vendor_x_adjacency"); + evel_service_endpoint_desc_set(event, EVEL_SERVICE_ENDPOINT_CALLER); + evel_service_endpoint_jitter_set(event, 66); + evel_service_endpoint_rtp_oct_disc_set(event, 100); + evel_service_endpoint_rtp_oct_recv_set(event, 200); + evel_service_endpoint_rtp_oct_sent_set(event, 300); + evel_service_endpoint_rtp_pkt_disc_set(event, 400); + evel_service_endpoint_rtp_pkt_recv_set(event, 500); + evel_service_endpoint_rtp_pkt_sent_set(event, 600); + evel_service_local_jitter_set(event, 99); + evel_service_local_rtp_oct_disc_set(event, 150); + evel_service_local_rtp_oct_recv_set(event, 250); + evel_service_local_rtp_oct_sent_set(event, 350); + evel_service_local_rtp_pkt_disc_set(event, 450); + evel_service_local_rtp_pkt_recv_set(event, 550); + evel_service_local_rtp_pkt_sent_set(event, 650); + evel_service_mos_cqe_set(event, 12.255); + evel_service_packets_lost_set(event, 157); + evel_service_packet_loss_percent_set(event, 0.232); + evel_service_r_factor_set(event, 11); + evel_service_round_trip_delay_set(event, 15);*/ + break; + case SERVICE_MARKER: + evel_signaling_addl_info_add(event, "service_phone", "0888888888"); + break; + } + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) event); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Service"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(event); +} + +void test_encode_signaling() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"signaling\", " + "\"eventId\": \"2001\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 2001, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Signaling\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"signalingFields\": {" + "\"eventInstanceIdentifier\": " + "{" + "\"vendorId\": \"vendor_x_id\", " + "\"eventId\": \"vendor_x_event_id\", " + "\"productId\": \"vendor_x_product_id\", " + "\"subsystemId\": \"vendor_x_subsystem_id\", " + "\"eventFriendlyName\": \"vendor_x_frieldly_name\"" + "}, " + "\"signalingFieldsVersion\": 1.1, " + "\"correlator\": \"vendor_x_correlator\", " + "\"localIpAddress\": \"1.0.3.1\", " + "\"localPort\": \"1031\", " + "\"remoteIpAddress\": \"5.3.3.0\", " + "\"remotePort\": \"5330\", " + "\"compressedSip\": \"compressed_sip\", " + "\"summarySip\": \"summary_sip\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SIGNALING * event = NULL; + evel_set_next_event_sequence(2001); + event = evel_new_signaling("vendor_x_id", + "correlator", "1.0.3.1", "1234", "192.168.1.3","3456"); + assert(event != NULL); + evel_signaling_vnfmodule_name_set(event, "vendor_x_module"); + evel_signaling_vnfname_set(event, "vendor_x_vnf"); + evel_signaling_type_set(event, "Signaling"); + evel_signaling_product_id_set(event, "vendor_x_product_id"); + evel_signaling_subsystem_id_set(event, "vendor_x_subsystem_id"); + evel_signaling_friendly_name_set(event, "vendor_x_frieldly_name"); + evel_signaling_correlator_set(event, "vendor_x_correlator"); + evel_signaling_local_ip_address_set(event, "1.0.3.1"); + evel_signaling_local_port_set(event, "1031"); + evel_signaling_remote_ip_address_set(event, "5.3.3.0"); + evel_signaling_remote_port_set(event, "5330"); + evel_signaling_compressed_sip_set(event, "compressed_sip"); + evel_signaling_summary_sip_set(event, "summary_sip"); + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) event); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Signaling"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(event); +} + +void test_encode_state_change() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"stateChange\", " + "\"eventId\": \"128\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 128, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"SC Type\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"stateChangeFields\": {" + "\"newState\": \"inService\", " + "\"oldState\": \"outOfService\", " + "\"stateInterface\": \"An Interface\", " + "\"additionalFields\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}, " + "{\"name\": \"Name2\", " + "\"value\": \"Value2\"}" + "], " + "\"stateChangeFieldsVersion\": 1.1" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_STATE_CHANGE * state_change = NULL; + evel_set_next_event_sequence(128); + state_change = evel_new_state_change(EVEL_ENTITY_STATE_IN_SERVICE, + EVEL_ENTITY_STATE_OUT_OF_SERVICE, + "An Interface"); + assert(state_change != NULL); + evel_state_change_type_set(state_change, "SC Type"); + evel_state_change_addl_field_add(state_change, "Name1", "Value1"); + evel_state_change_addl_field_add(state_change, "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) state_change); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "StateChange"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(state_change); +} + +void test_encode_syslog() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"syslog\", " + "\"eventId\": \"126\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 126, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"SL Type\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"syslogFields\": {" + "\"eventSourceType\": \"virtualNetworkFunction\", " + "\"syslogMsg\": \"SL Message\", " + "\"syslogTag\": \"SL Tag\", " + "\"syslogFieldsVersion\": 1.1, " + "\"eventSourceHost\": \"SL Host\", " + "\"syslogFacility\": 6, " + "\"syslogProc\": \"SL Proc\", " + "\"syslogProcId\": 2, " + "\"syslogSData\": \"SL SDATA\", " + "\"syslogVer\": 1" + "}}}"; + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SYSLOG * syslog = NULL; + evel_set_next_event_sequence(126); + syslog = evel_new_syslog(EVEL_SOURCE_VIRTUAL_NETWORK_FUNCTION, + "SL Message", + "SL Tag"); + assert(syslog != NULL); + evel_syslog_type_set(syslog, "SL Type"); + evel_syslog_event_source_host_set(syslog, "SL Host"); + evel_syslog_facility_set(syslog, EVEL_SYSLOG_FACILITY_LINE_PRINTER); + evel_syslog_proc_set(syslog, "SL Proc"); + evel_syslog_proc_id_set(syslog, 2); + evel_syslog_version_set(syslog, 1); + evel_syslog_s_data_set(syslog, "SL SDATA"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) syslog); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Syslog"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(syslog); +} + +void test_encode_other() +{ + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"other\", " + "\"eventId\": \"129\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 129, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Other Type\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"otherFields\": [" + "{\"name\": \"Other field 1\", " + "\"value\": \"Other value 1\"}, " + "{\"name\": \"Other field 2\", " + "\"value\": \"Other value 2\"}" + "]" + "}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_OTHER * other = NULL; + evel_set_next_event_sequence(129); + other = evel_new_other(); + assert(other != NULL); + evel_other_type_set(other, "Other Type"); + evel_other_field_add(other, + "Other field 1", + "Other value 1"); + evel_other_field_add(other, + "Other field 2", + "Other value 2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) other); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Other"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(other); +} + +void compare_strings(char * expected, + char * actual, + int max_size, + char * description) +{ + if (strncmp(expected, actual, max_size) != 0) + { + int diff = 0; + while (diff < max_size) + { + if (expected[diff] != actual[diff]) + { + break; + } + diff++; + } + + printf("Comparison Failure at Offset %d\n\n", diff); + printf("Expected:\n%s\n", expected); + printf("Actual:\n%s\n", actual); + printf("Description: %s\n", description); + assert(0); + } +} + +/**************************************************************************//** + * Copy a json string to a ::MEMORY_CHUNK for testing. + * + * @param chunk The memory chunk. + * @param string The json string. + *****************************************************************************/ +void copy_string_to_chunk(MEMORY_CHUNK * chunk, char * string) +{ + int mem_size; + + /***************************************************************************/ + /* Check preconditions. */ + /***************************************************************************/ + assert(chunk != NULL); + assert(string != NULL); + + mem_size = strlen(string) + 1; + chunk->memory = malloc(mem_size); + memcpy(chunk->memory, string, mem_size); + chunk->size = mem_size; +} + +/**************************************************************************//** + * Copy a json string to a ::MEMORY_CHUNK for testing. + * + * @param json The JSON string. + * @param post Memory chunk to post a response. + *****************************************************************************/ +void handle_json_response(char * json, MEMORY_CHUNK * post) +{ + MEMORY_CHUNK chunk; + post->memory = NULL; + post->size = 0; + copy_string_to_chunk(&chunk, json); + evel_handle_event_response(&chunk, post); + free(chunk.memory); +} + +/**************************************************************************//** + * Test that a non-"commandList" JSON buffer leaves the throttle state off. + *****************************************************************************/ +void test_json_response_junk() +{ + MEMORY_CHUNK post; + int domain; + char * json_junk = + "{" + "\"junk1\": [" + "\"1\", \"2\", \"3\"], " + "\"junk2\": [" + "\"1\", \"2\", \"3\"]" + "}"; + + evel_throttle_initialize(); + handle_json_response(json_junk, &post); + + /***************************************************************************/ + /* Check that all domains are not throttled. */ + /***************************************************************************/ + for (domain = EVEL_DOMAIN_FAULT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + + /***************************************************************************/ + /* Check that we generated no post. */ + /***************************************************************************/ + assert(post.memory == NULL); + + evel_throttle_terminate(); +} + +char * json_command_list_provide = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"provideThrottlingState\"" + "}" + "}" + "]" + "}"; + +char * json_command_list_fault_clear = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\"" + "}" + "}" + "}" + "]" + "}"; + +char * json_command_list_syslog_clear = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"syslog\"" + "}" + "}" + "}" + "]" + "}"; + +char * expected_throttle_state_normal = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"normal\"}" + "}"; + +/**************************************************************************//** + * Test that we can return the default throttling state. + *****************************************************************************/ +void test_json_provide_throttle_state() +{ + MEMORY_CHUNK post; + int domain; + + char * expected_post = expected_throttle_state_normal; + + evel_throttle_initialize(); + handle_json_response(json_command_list_provide, &post); + + /***************************************************************************/ + /* Check that all domains are not throttled. */ + /***************************************************************************/ + for (domain = EVEL_DOMAIN_FAULT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + + /***************************************************************************/ + /* Check that we generated a throttling specification post. */ + /***************************************************************************/ + assert(post.memory != NULL); + compare_strings(expected_post, post.memory, strlen(expected_post), + "Throttle State Normal"); + free(post.memory); + + evel_throttle_terminate(); +} + +/**************************************************************************//** + * Test the measurement interval handling and API. + *****************************************************************************/ +void test_json_measurement_interval() +{ + MEMORY_CHUNK post; + char * json_command_list_interval_only = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"measurementInterval\": 60" + "}" + "}" + "]" + "}"; + + char * json_command_list_interval_first = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"measurementInterval\": 30, " + "\"commandType\": \"measurementIntervalChange\"" + "}" + "}" + "]" + "}"; + + char * json_command_list_command_first = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"measurementIntervalChange\", " + "\"measurementInterval\": 60" + "}" + "}" + "]" + "}"; + + evel_throttle_initialize(); + assert(evel_get_measurement_interval() == EVEL_MEASUREMENT_INTERVAL_UKNOWN); + + /***************************************************************************/ + /* Check that we're not handling stuff when we shouldn't. */ + /***************************************************************************/ + handle_json_response(json_command_list_interval_only, &post); + assert(post.memory == NULL); + assert(evel_get_measurement_interval() == EVEL_MEASUREMENT_INTERVAL_UKNOWN); + + /***************************************************************************/ + /* Check that we're OK with the interval coming first. */ + /***************************************************************************/ + handle_json_response(json_command_list_interval_first, &post); + assert(post.memory == NULL); + assert(evel_get_measurement_interval() == 30); + + /***************************************************************************/ + /* Check that we're OK with the command type coming first. */ + /***************************************************************************/ + handle_json_response(json_command_list_command_first, &post); + assert(post.memory == NULL); + assert(evel_get_measurement_interval() == 60); + + evel_throttle_terminate(); +} + +/**************************************************************************//** + * Test a single domain, single field suppression. + *****************************************************************************/ +void test_json_throttle_spec_field() +{ + MEMORY_CHUNK post; + int domain; + + char * json_command_list_fault_single = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"]" + "}" + "}" + "}" + "]" + "}"; + + char * json_command_list_fault_double = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [" + "\"alarmInterfaceA\", \"alarmAdditionalInformation\"]" + "}" + "}" + "}" + "]" + "}"; + + char * expected_post_fault_single = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"]" + "}" + "]" + "}" + "}"; + + char * expected_post_fault_double = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [" + "\"alarmInterfaceA\", \"alarmAdditionalInformation\"]" + "}" + "]" + "}" + "}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list_fault_single, &post); + + /***************************************************************************/ + /* Check that the FAULT domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + if (domain != EVEL_DOMAIN_FAULT) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + } + assert(post.memory == NULL); + + /***************************************************************************/ + /* Request and verify the throttling state. */ + /***************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_post_fault_single, + post.memory, + strlen(expected_post_fault_single), + "Fault - Single Field"); + free(post.memory); + post.memory = NULL; + + /***************************************************************************/ + /* Update a specification with two faults suppressed. */ + /***************************************************************************/ + handle_json_response(json_command_list_fault_double, &post); + + /***************************************************************************/ + /* Check that the FAULT domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + if (domain != EVEL_DOMAIN_FAULT) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + } + assert(post.memory == NULL); + + /***************************************************************************/ + /* Request and verify the throttling state. */ + /***************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_post_fault_double, + post.memory, + strlen(expected_post_fault_double), + "Fault - Double Field"); + free(post.memory); + post.memory = NULL; + + /***************************************************************************/ + /* Now clear the FAULT domain. */ + /***************************************************************************/ + handle_json_response(json_command_list_fault_clear, &post); + for (domain = EVEL_DOMAIN_FAULT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + + evel_throttle_terminate(); +} + +/**************************************************************************//** + * Test a single domain, nv_pair suppression. + *****************************************************************************/ +void test_json_throttle_spec_nv_pair() +{ + MEMORY_CHUNK post; + int domain; + + char * json_command_list_fault_pair_single = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}" + "]" + "}" + "}" + "}" + "]" + "}"; + + char * json_command_list_fault_pair_double = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\", \"name2\"]" + "}" + "]" + "}" + "}" + "}" + "]" + "}"; + + char * expected_post_fault_pair_single = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}" + "]" + "}" + "]" + "}" + "}"; + + char * expected_post_fault_pair_double = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\", \"name2\"]" + "}" + "]" + "}" + "]" + "}" + "}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single nvpair with a */ + /* single sub-field suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list_fault_pair_single, &post); + + /***************************************************************************/ + /* Check that the FAULT domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + if (domain != EVEL_DOMAIN_FAULT) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + } + assert(post.memory == NULL); + + /***************************************************************************/ + /* Request and verify the throttling state. */ + /***************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_post_fault_pair_single, + post.memory, + strlen(expected_post_fault_pair_single), + "Fault - Single Pair, Single Field"); + free(post.memory); + post.memory = NULL; + + /***************************************************************************/ + /* Update a specification with a single nvpair with two sub-fields */ + /* suppressed. */ + /***************************************************************************/ + handle_json_response(json_command_list_fault_pair_double, &post); + + /***************************************************************************/ + /* Check that the FAULT domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + if (domain != EVEL_DOMAIN_FAULT) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + } + assert(post.memory == NULL); + + /***************************************************************************/ + /* Request and verify the throttling state. */ + /***************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_post_fault_pair_double, + post.memory, + strlen(expected_post_fault_pair_double), + "Fault - Double Field"); + free(post.memory); + post.memory = NULL; + + /***************************************************************************/ + /* Now clear the FAULT domain. */ + /***************************************************************************/ + handle_json_response(json_command_list_fault_clear, &post); + for (domain = EVEL_DOMAIN_FAULT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + + evel_throttle_terminate(); +} + +/**************************************************************************//** + * Test two domains, nv_pair suppression. + *****************************************************************************/ +void test_json_throttle_spec_two_domains() +{ + MEMORY_CHUNK post; + int domain; + + char * json_command_list_two_domains = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}, " + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"syslog\", " + "\"suppressedFieldNames\": [\"syslogProcId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"additionalFields\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * expected_post_two_domains = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}, " + "{" + "\"eventDomain\": \"syslog\", " + "\"suppressedFieldNames\": [\"syslogProcId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"additionalFields\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}" + "]" + "}" + "}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single nvpair with a */ + /* single sub-field suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list_two_domains, &post); + + /***************************************************************************/ + /* Check that the FAULT and SYSLOG domains are throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + assert(evel_get_throttle_spec(EVEL_DOMAIN_SYSLOG) != NULL); + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + if ((domain != EVEL_DOMAIN_FAULT) && (domain != EVEL_DOMAIN_SYSLOG)) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + } + assert(post.memory == NULL); + + /***************************************************************************/ + /* Request and verify the throttling state. */ + /***************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_post_two_domains, + post.memory, + strlen(expected_post_two_domains), + "Fault - Two Domains"); + free(post.memory); + post.memory = NULL; + + /***************************************************************************/ + /* Now clear the FAULT and SYSLOG domains. */ + /***************************************************************************/ + handle_json_response(json_command_list_fault_clear, &post); + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) == NULL); + assert(evel_get_throttle_spec(EVEL_DOMAIN_SYSLOG) != NULL); + handle_json_response(json_command_list_syslog_clear, &post); + for (domain = EVEL_DOMAIN_FAULT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + + evel_throttle_terminate(); +} + +/**************************************************************************//** + * Test bad command type. + *****************************************************************************/ +void test_json_throttle_spec_bad_command_type() +{ + MEMORY_CHUNK post; + int domain; + + /***************************************************************************/ + /* Search for "dodgy" in the JSON, and you will see the dodgy bits we're */ + /* handling in these tests. */ + /***************************************************************************/ + #define NUM_BAD_COMMANDS 8 + char * json_command_list_dodgy_command = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"dodgyCommand\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_spec = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"dodgyEventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_event_domain_key = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"dodgyEventDomainKey\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_event_domain = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"dodgyEventDomain\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_field_names_key = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_pair_names_list_key = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"dodgySuppressedNvPairsListKey\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_pair_field_name_key = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"dodgyNvPairFieldNameKey\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_pair_names_key = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"dodgySuppressedNvPairNamesKey\": [\"name1\"]" + "}]}}}" + "]" + "}"; + + char * json_command_list_dodgy_depth = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"dodgySuppressedNvPairNamesKey\": " + "[\"name1\", [[[[[[[[]]]]]]]]]" + "}]}}}" + "]" + "}"; + + char * expected_throttle_state_dodgy_field_names_key = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name1\"]" + "}]}" + "]" + "}" + "}"; + + char * expected_throttle_state_dodgy_pair_names_list_key = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"]" + "}" + "]" + "}" + "}"; + + char * expected_throttle_state_dodgy_pair_field_name_key = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"]" + "}" + "]" + "}" + "}"; + + char * expected_throttle_state_dodgy_pair_names_key = + "{" + "\"eventThrottlingState\": {" + "\"eventThrottlingMode\": \"throttled\", " + "\"eventDomainThrottleSpecificationList\": [" + "{" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [\"alarmInterfaceA\"]" + "}" + "]" + "}" + "}"; + + char * json_command_lists[] = { + json_command_list_dodgy_command, + json_command_list_dodgy_spec, + json_command_list_dodgy_event_domain_key, + json_command_list_dodgy_event_domain, + json_command_list_dodgy_depth, + json_command_list_dodgy_field_names_key, + json_command_list_dodgy_pair_names_list_key, + json_command_list_dodgy_pair_field_name_key, + json_command_list_dodgy_pair_names_key + }; + + char * expected_posts[] = { + expected_throttle_state_normal, + expected_throttle_state_normal, + expected_throttle_state_normal, + expected_throttle_state_normal, + expected_throttle_state_normal, + expected_throttle_state_dodgy_field_names_key, + expected_throttle_state_dodgy_pair_names_list_key, + expected_throttle_state_dodgy_pair_field_name_key, + expected_throttle_state_dodgy_pair_names_key + }; + + const int num_commands = + sizeof(json_command_lists) / sizeof(json_command_lists[0]); + const int num_posts = + sizeof(expected_posts) / sizeof(expected_posts[0]); + assert(num_commands == num_posts); + + /***************************************************************************/ + /* Initialize and provide a specification with a single nvpair with a */ + /* single sub-field suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + + int ii; + for (ii = 0; ii < num_commands; ii++) + { + EVEL_DEBUG("Testing commandList[%d] = %s\n", ii, json_command_lists[ii]); + handle_json_response(json_command_lists[ii], &post); + + /*************************************************************************/ + /* Check that throttling is in a normal state - because we ignored the */ + /* command / ..... */ + /*************************************************************************/ + for (domain = EVEL_DOMAIN_MEASUREMENT; domain < EVEL_MAX_DOMAINS; domain++) + { + assert(evel_get_throttle_spec(domain) == NULL); + } + if (expected_posts[ii] == expected_throttle_state_normal) + { + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) == NULL); + } + else + { + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + } + assert(post.memory == NULL); + + /*************************************************************************/ + /* Request and verify the throttling state. */ + /*************************************************************************/ + handle_json_response(json_command_list_provide, &post); + assert(post.memory != NULL); + compare_strings(expected_posts[ii], + post.memory, + strlen(expected_posts[ii]), + "Throttle State Normal"); + free(post.memory); + post.memory = NULL; + } + + evel_throttle_terminate(); +} + +void test_encode_fault_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"fault\", " + "\"suppressedFieldNames\": [" + "\"alarmInterfaceA\", " + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"alarmAdditionalInformation\", " + "\"suppressedNvPairNames\": [\"name3\", \"name4\"]" + "}]}}}" + "]" + "}"; + + char * expected = + "{\"event\": {" + "\"commonEventHeader\": {" + "\"domain\": \"fault\", " + "\"eventId\": \"122\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 122, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"faultFields\": {" + "\"alarmCondition\": \"My alarm condition\", " + "\"eventSeverity\": \"MAJOR\", " + "\"eventSourceType\": \"other\", " + "\"specificProblem\": \"It broke very badly\", " + "\"vfStatus\": \"Active\", " + "\"faultFieldsVersion\": 1.1, " + "\"alarmAdditionalInformation\": [" + "{\"name\": \"name1\", " + "\"value\": \"value1\"}, " + "{\"name\": \"name2\", " + "\"value\": \"value2\"}]" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_FAULT) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + evel_set_next_event_sequence(122); + EVENT_FAULT * fault = evel_new_fault("My alarm condition", + "It broke very badly", + EVEL_PRIORITY_NORMAL, + EVEL_SEVERITY_MAJOR, + EVEL_SOURCE_HOST, + EVEL_VF_STATUS_PREP_TERMINATE); + assert(fault != NULL); + evel_fault_type_set(fault, "Bad things happen..."); + evel_fault_addl_info_add(fault, "name1", "value1"); + evel_fault_addl_info_add(fault, "name2", "value2"); + + /***************************************************************************/ + /* Suppressed fields. */ + /***************************************************************************/ + evel_fault_interface_set(fault, "My Interface Card"); + evel_fault_addl_info_add(fault, "name3", "value3"); + evel_fault_addl_info_add(fault, "name4", "value4"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) fault); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Fault"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(fault); + evel_throttle_terminate(); +} + +void test_encode_measurement_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"measurementsForVfScaling\", " + "\"suppressedFieldNames\": [" + "\"errors\", " + "\"vnfcScalingMetric\", " + "\"numberOfMediaPortsInUse\", " + "\"aggregateCpuUsage\", " + "\"requestRate\", " + "\"memoryUsed\", " + "\"memoryConfigured\", " + "\"meanRequestLatency\", " + "\"latencyDistribution\", " + "\"concurrentSessions\", " + "\"configuredEntities\", " + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"cpuUsageArray\", " + "\"suppressedNvPairNames\": [\"cpu3\", \"cpu4\"]" + "}, " + "{" + "\"nvPairFieldName\": \"filesystemUsageArray\", " + "\"suppressedNvPairNames\": [\"00-11-22\", \"33-44-55\"]" + "}, " + "{" + "\"nvPairFieldName\": \"vNicUsageArray\", " + "\"suppressedNvPairNames\": [\"eth1\", \"eth0\"]" + "}, " + "{" + "\"nvPairFieldName\": \"featureUsageArray\", " + "\"suppressedNvPairNames\": [\"FeatureB\", \"FeatureC\"]" + "}," + "{" + "\"nvPairFieldName\": \"codecUsageArray\", " + "\"suppressedNvPairNames\": [\"G729ab\"]" + "}," + "{" + "\"nvPairFieldName\": \"additionalMeasurements\", " + "\"suppressedNvPairNames\": [\"Group2\"]" + "}" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"measurementsForVfScaling\", " + "\"eventId\": \"123\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 123, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"measurementsForVfScalingFields\": " + "{" + "\"measurementInterval\": 5.500000, " + "\"cpuUsageArray\": [" + "{\"cpuIdentifier\": \"cpu1\", " + "\"percentUsage\": 11.110000}, " + "{\"cpuIdentifier\": \"cpu2\", " + "\"percentUsage\": 22.220000}], " + "\"filesystemUsageArray\": [" + "{\"blockConfigured\": 500.110000, " + "\"blockIops\": 77, " + "\"blockUsed\": 500.220000, " + "\"ephemeralConfigured\": 500.110000, " + "\"ephemeralIops\": 88, " + "\"ephemeralUsed\": 600.220000, " + "\"filesystemName\": \"66-77-88\"}], " + "\"featureUsageArray\": [" + "{\"featureIdentifier\": \"FeatureA\", " + "\"featureUtilization\": 123}], " + "\"codecUsageArray\": [" + "{\"codecIdentifier\": \"G711a\", " + "\"numberInUse\": 91}], " + "\"additionalMeasurements\": [" + "{\"name\": \"Group1\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}]}], " + "\"measurementsForVfScalingVersion\": 1.1}}}"; + MEASUREMENT_CPU_USE *cpu_use; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_MEASUREMENT) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + evel_set_next_event_sequence(123); + EVENT_MEASUREMENT * measurement = evel_new_measurement(5.5); + MEASUREMENT_LATENCY_BUCKET * bucket = NULL; + MEASUREMENT_VNIC_PERFORMANCE * vnic_use = NULL; + assert(measurement != NULL); + + evel_measurement_type_set(measurement, "Perf management..."); + evel_measurement_conc_sess_set(measurement, 1); + evel_measurement_cfg_ents_set(measurement, 2); + evel_measurement_mean_req_lat_set(measurement, 4.4); + evel_measurement_mem_cfg_set(measurement, 6.6); + evel_measurement_mem_used_set(measurement, 3.3); + evel_measurement_request_rate_set(measurement, 7); + + cpu_use = evel_measurement_new_cpu_use_add(measurement, "cpu1", 11.11); + evel_measurement_cpu_use_idle_set(cpu_use,22.22); + evel_measurement_cpu_use_interrupt_set(cpu_use,33.33); + evel_measurement_cpu_use_nice_set(cpu_use,44.44); + evel_measurement_cpu_use_softirq_set(cpu_use,55.55); + evel_measurement_cpu_use_steal_set(cpu_use,66.66); + evel_measurement_cpu_use_system_set(cpu_use,77.77); + evel_measurement_cpu_use_usageuser_set(cpu_use,88.88); + evel_measurement_cpu_use_wait_set(cpu_use,99.99); + + cpu_use = evel_measurement_new_cpu_use_add(measurement, "cpu2", 22.22); + evel_measurement_cpu_use_idle_set(cpu_use,12.22); + evel_measurement_cpu_use_interrupt_set(cpu_use,33.33); + evel_measurement_cpu_use_nice_set(cpu_use,44.44); + evel_measurement_cpu_use_softirq_set(cpu_use,55.55); + evel_measurement_cpu_use_steal_set(cpu_use,66.66); + evel_measurement_cpu_use_system_set(cpu_use,77.77); + evel_measurement_cpu_use_usageuser_set(cpu_use,88.88); + evel_measurement_cpu_use_wait_set(cpu_use,19.99); + + evel_measurement_fsys_use_add(measurement, "00-11-22", + 100.11, 100.22, 33, + 200.11, 200.22, 44); + evel_measurement_fsys_use_add(measurement, "33-44-55", + 300.11, 300.22, 55, + 400.11, 400.22, 66); + evel_measurement_fsys_use_add(measurement, "66-77-88", + 500.11, 500.22, 77, + 600.11, 600.22, 88); + + bucket = evel_new_meas_latency_bucket(20); + evel_meas_latency_bucket_add(measurement, bucket); + + bucket = evel_new_meas_latency_bucket(30); + evel_meas_latency_bucket_low_end_set(bucket, 10.0); + evel_meas_latency_bucket_high_end_set(bucket, 20.0); + evel_meas_latency_bucket_add(measurement, bucket); + + vnic_use = evel_new_measurement_vnic_use("eth0", 100, 200, 3, 4); + evel_vnic_use_bcast_pkt_in_set(vnic_use, 1); + evel_vnic_use_bcast_pkt_out_set(vnic_use, 2); + evel_vnic_use_mcast_pkt_in_set(vnic_use, 5); + evel_vnic_use_mcast_pkt_out_set(vnic_use, 6); + evel_vnic_use_ucast_pkt_in_set(vnic_use, 7); + evel_vnic_use_ucast_pkt_out_set(vnic_use, 8); + evel_meas_vnic_use_add(measurement, vnic_use); + + vnic_use = evel_new_measurement_vnic_use("eth1", 110, 240, 13, 14); + evel_vnic_use_bcast_pkt_in_set(vnic_use, 11); + evel_vnic_use_bcast_pkt_out_set(vnic_use, 12); + evel_vnic_use_mcast_pkt_in_set(vnic_use, 15); + evel_vnic_use_mcast_pkt_out_set(vnic_use, 16); + evel_vnic_use_ucast_pkt_in_set(vnic_use, 17); + evel_vnic_use_ucast_pkt_out_set(vnic_use, 18); + evel_meas_vnic_use_add(measurement, vnic_use); + + evel_measurement_errors_set(measurement, 1, 0, 2, 1); + evel_measurement_feature_use_add(measurement, "FeatureA", 123); + evel_measurement_feature_use_add(measurement, "FeatureB", 567); + evel_measurement_codec_use_add(measurement, "G711a", 91); + evel_measurement_codec_use_add(measurement, "G729ab", 92); + evel_measurement_media_port_use_set(measurement, 1234); + evel_measurement_vnfc_scaling_metric_set(measurement, 1234.5678); + evel_measurement_custom_measurement_add(measurement, + "Group1", "Name1", "Value1"); + evel_measurement_custom_measurement_add(measurement, + "Group2", "Name1", "Value1"); + evel_measurement_custom_measurement_add(measurement, + "Group2", "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) measurement); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Measurement"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(measurement); + evel_throttle_terminate(); +} + +void test_encode_mobile_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"mobileFlow\", " + "\"suppressedFieldNames\": [" + "\"applicationType\", " + "\"appProtocolType\", " + "\"appProtocolVersion\", " + "\"cid\", " + "\"connectionType\", " + "\"ecgi\", " + "\"gtpProtocolType\", " + "\"gtpVersion\", " + "\"httpHeader\", " + "\"imei\", " + "\"imsi\", " + "\"lac\", " + "\"mcc\", " + "\"mnc\", " + "\"msisdn\", " + "\"otherFunctionalRole\", " + "\"rac\", " + "\"radioAccessTechnology\", " + "\"sac\", " + "\"samplingAlgorithm\", " + "\"tac\", " + "\"tunnelId\", " + "\"vlanId\", " + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"mobileFlow\", " + "\"eventId\": \"1242\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 1242, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"mobileFlowFields\": {" + "\"flowDirection\": \"Inbound\", " + "\"gtpPerFlowMetrics\": {" + "\"avgBitErrorRate\": 132.000100, " + "\"avgPacketDelayVariation\": 31.200000, " + "\"avgPacketLatency\": 101, " + "\"avgReceiveThroughput\": 2101, " + "\"avgTransmitThroughput\": 501, " + "\"flowActivationEpoch\": 1470409422, " + "\"flowActivationMicrosec\": 988, " + "\"flowDeactivationEpoch\": 1470409432, " + "\"flowDeactivationMicrosec\": 12, " + "\"flowDeactivationTime\": \"Fri, 05 Aug 2016 15:03:52 +0000\", " + "\"flowStatus\": \"Inactive\", " + "\"maxPacketDelayVariation\": 88, " + "\"numActivationFailures\": 4, " + "\"numBitErrors\": 18, " + "\"numBytesReceived\": 123655, " + "\"numBytesTransmitted\": 4562, " + "\"numDroppedPackets\": 1, " + "\"numL7BytesReceived\": 13, " + "\"numL7BytesTransmitted\": 11, " + "\"numLostPackets\": 2, " + "\"numOutOfOrderPackets\": 4, " + "\"numPacketErrors\": 8, " + "\"numPacketsReceivedExclRetrans\": 900, " + "\"numPacketsReceivedInclRetrans\": 902, " + "\"numPacketsTransmittedInclRetrans\": 303, " + "\"numRetries\": 7, " + "\"numTimeouts\": 3, " + "\"numTunneledL7BytesReceived\": 1, " + "\"roundTripTime\": 111, " + "\"timeToFirstByte\": 226, " + "\"ipTosCountList\": [" + "[\"1\", 13], " + "[\"4\", 99], " + "[\"17\", 1]], " + "\"ipTosList\": [\"1\", \"4\", \"17\"], " + "\"tcpFlagList\": [\"CWR\", \"URG\"], " + "\"tcpFlagCountList\": [[\"CWR\", 10], [\"URG\", 121]], " + "\"mobileQciCosList\": [\"conversational\", \"65\"], " + "\"mobileQciCosCountList\": [[\"conversational\", 11], [\"65\", 122]], " + "\"durConnectionFailedStatus\": 12, " + "\"durTunnelFailedStatus\": 13, " + "\"flowActivatedBy\": \"Remote\", " + "\"flowActivationTime\": \"Fri, 05 Aug 2016 15:03:43 +0000\", " + "\"flowDeactivatedBy\": \"Remote\", " + "\"gtpConnectionStatus\": \"Connected\", " + "\"gtpTunnelStatus\": \"Not tunneling\", " + "\"largePacketRtt\": 80, " + "\"largePacketThreshold\": 600.000000, " + "\"maxReceiveBitRate\": 1357924680, " + "\"maxTransmitBitRate\": 235711, " + "\"numGtpEchoFailures\": 1, " + "\"numGtpTunnelErrors\": 4, " + "\"numHttpErrors\": 2" + "}, " + "\"ipProtocolType\": \"UDP\", " + "\"ipVersion\": \"IPv6\", " + "\"otherEndpointIpAddress\": \"2.3.4.2\", " + "\"otherEndpointPort\": 2342, " + "\"reportingEndpointIpAddr\": \"4.2.3.2\", " + "\"reportingEndpointPort\": 4322" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_MOBILE_FLOW) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + MOBILE_GTP_PER_FLOW_METRICS * metrics = NULL; + EVENT_MOBILE_FLOW * mobile_flow = NULL; + + /***************************************************************************/ + /* Mobile. */ + /***************************************************************************/ + evel_set_next_event_sequence(1242); + + metrics = evel_new_mobile_gtp_flow_metrics(132.0001, + 31.2, + 101, + 2101, + 501, + 1470409422, + 988, + 1470409432, + 12, + (time_t)1470409432, + "Inactive", + 88, + 4, + 18, + 123655, + 4562, + 1, + 13, + 11, + 2, + 4, + 8, + 900, + 902, + 303, + 7, + 3, + 1, + 111, + 226); + assert(metrics != NULL); + + evel_mobile_gtp_metrics_dur_con_fail_set(metrics, 12); + evel_mobile_gtp_metrics_dur_tun_fail_set(metrics, 13); + evel_mobile_gtp_metrics_act_by_set(metrics, "Remote"); + evel_mobile_gtp_metrics_act_time_set(metrics, (time_t)1470409423); + evel_mobile_gtp_metrics_deact_by_set(metrics, "Remote"); + evel_mobile_gtp_metrics_con_status_set(metrics, "Connected"); + evel_mobile_gtp_metrics_tun_status_set(metrics, "Not tunneling"); + evel_mobile_gtp_metrics_iptos_set(metrics, 1, 13); + evel_mobile_gtp_metrics_iptos_set(metrics, 17, 1); + evel_mobile_gtp_metrics_iptos_set(metrics, 4, 99); + evel_mobile_gtp_metrics_large_pkt_rtt_set(metrics, 80); + evel_mobile_gtp_metrics_large_pkt_thresh_set(metrics, 600.0); + evel_mobile_gtp_metrics_max_rcv_bit_rate_set(metrics, 1357924680); + evel_mobile_gtp_metrics_max_trx_bit_rate_set(metrics, 235711); + evel_mobile_gtp_metrics_num_echo_fail_set(metrics, 1); + evel_mobile_gtp_metrics_num_tun_fail_set(metrics, 4); + evel_mobile_gtp_metrics_num_http_errors_set(metrics, 2); + evel_mobile_gtp_metrics_tcp_flag_count_add(metrics, EVEL_TCP_CWR, 10); + evel_mobile_gtp_metrics_tcp_flag_count_add(metrics, EVEL_TCP_URG, 121); + evel_mobile_gtp_metrics_qci_cos_count_add( + metrics, EVEL_QCI_COS_UMTS_CONVERSATIONAL, 11); + evel_mobile_gtp_metrics_qci_cos_count_add( + metrics, EVEL_QCI_COS_LTE_65, 122); + + mobile_flow = evel_new_mobile_flow("Inbound", + metrics, + "UDP", + "IPv6", + "2.3.4.2", + 2342, + "4.2.3.2", + 4322); + assert(mobile_flow != NULL); + + evel_mobile_flow_type_set(mobile_flow, "Mobile flow..."); + evel_mobile_flow_app_type_set(mobile_flow, "Demo application"); + evel_mobile_flow_app_prot_type_set(mobile_flow, "GSM"); + evel_mobile_flow_app_prot_ver_set(mobile_flow, "1"); + evel_mobile_flow_cid_set(mobile_flow, "65535"); + evel_mobile_flow_con_type_set(mobile_flow, "S1-U"); + evel_mobile_flow_ecgi_set(mobile_flow, "e65535"); + evel_mobile_flow_gtp_prot_type_set(mobile_flow, "GTP-U"); + evel_mobile_flow_gtp_prot_ver_set(mobile_flow, "1"); + evel_mobile_flow_http_header_set(mobile_flow, + "http://www.something.com"); + evel_mobile_flow_imei_set(mobile_flow, "209917614823"); + evel_mobile_flow_imsi_set(mobile_flow, "355251/05/850925/8"); + evel_mobile_flow_lac_set(mobile_flow, "1"); + evel_mobile_flow_mcc_set(mobile_flow, "410"); + evel_mobile_flow_mnc_set(mobile_flow, "04"); + evel_mobile_flow_msisdn_set(mobile_flow, "6017123456789"); + evel_mobile_flow_other_func_role_set(mobile_flow, "MME"); + evel_mobile_flow_rac_set(mobile_flow, "514"); + evel_mobile_flow_radio_acc_tech_set(mobile_flow, "LTE"); + evel_mobile_flow_sac_set(mobile_flow, "1"); + evel_mobile_flow_samp_alg_set(mobile_flow, 1); + evel_mobile_flow_tac_set(mobile_flow, "2099"); + evel_mobile_flow_tunnel_id_set(mobile_flow, "Tunnel 1"); + evel_mobile_flow_vlan_id_set(mobile_flow, "15"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) mobile_flow); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Mobile"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(mobile_flow); + evel_throttle_terminate(); +} + +void test_encode_other_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"other\", " + "\"suppressedFieldNames\": [" + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"other\", " + "\"eventId\": \"129\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 129, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"otherFields\": [" + "{\"name\": \"Other field 1\", " + "\"value\": \"Other value 1\"}, " + "{\"name\": \"Other field 2\", " + "\"value\": \"Other value 2\"}" + "]" + "}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_OTHER) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_OTHER * other = NULL; + evel_set_next_event_sequence(129); + other = evel_new_other(); + assert(other != NULL); + evel_other_type_set(other, "Other Type"); + evel_other_field_add(other, + "Other field 1", + "Other value 1"); + evel_other_field_add(other, + "Other field 2", + "Other value 2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) other); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Other"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(other); + evel_throttle_terminate(); +} + +void test_encode_report_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"report\", " + "\"suppressedFieldNames\": [" + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"featureUsageArray\", " + "\"suppressedNvPairNames\": [\"FeatureB\", \"FeatureC\"]" + "}," + "{" + "\"nvPairFieldName\": \"additionalMeasurements\", " + "\"suppressedNvPairNames\": [\"Group2\"]" + "}" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"measurementsForVfReporting\", " + "\"eventId\": \"125\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 125, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"measurementsForVfReportingFields\": " + "{\"measurementInterval\": 1.100000, " + "\"featureUsageArray\": [" + "{\"featureIdentifier\": \"FeatureA\", " + "\"featureUtilization\": 123}], " + "\"additionalMeasurements\": [" + "{\"name\": \"Group1\", " + "\"measurements\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}]}], " + "\"measurementFieldsVersion\": 1.1}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_REPORT) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_REPORT * report = NULL; + + /***************************************************************************/ + /* Report. */ + /***************************************************************************/ + evel_set_next_event_sequence(125); + report = evel_new_report(1.1); + assert(report != NULL); + evel_report_type_set(report, "Perf reporting..."); + evel_report_feature_use_add(report, "FeatureA", 123); + evel_report_feature_use_add(report, "FeatureB", 567); + evel_report_custom_measurement_add(report, "Group1", "Name1", "Value1"); + evel_report_custom_measurement_add(report, "Group2", "Name1", "Value1"); + evel_report_custom_measurement_add(report, "Group2", "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) report); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Report"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(report); + evel_throttle_terminate(); +} + +void test_encode_service_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"serviceEvents\", " + "\"suppressedFieldNames\": [" + "\"eventType\", " + "\"correlator\", " + "\"codecSelected\", " + "\"codecSelectedTranscoding\", " + "\"endOfCallVqmSummaries\", " + "\"midCallRtcp\", " + "\"marker\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"additionalFields\", " + "\"suppressedNvPairNames\": [\"Name1\", \"Name3\"]" + "}" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"serviceEvents\", " + "\"eventId\": \"2000\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 2000, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"serviceEventsFields\": {" + "\"eventInstanceIdentifier\": " + "{" + "\"vendorId\": \"vendor_x_id\", " + "\"eventId\": \"vendor_x_event_id\", " + "\"productId\": \"vendor_x_product_id\", " + "\"subsystemId\": \"vendor_x_subsystem_id\", " + "\"eventFriendlyName\": \"vendor_x_frieldly_name\"" + "}, " + "\"serviceEventsFieldsVersion\": 1.1, " + "\"additionalFields\": [" + "{\"name\": \"Name2\", \"value\": \"Value2\"}, " + "{\"name\": \"Name4\", \"value\": \"Value4\"}]" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_SERVICE) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SERVICE * event = NULL; + evel_set_next_event_sequence(2000); + event = evel_new_service("vendor_x_id", "vendor_x_event_id"); + assert(event != NULL); + evel_service_type_set(event, "Service Event"); + evel_service_product_id_set(event, "vendor_x_product_id"); + evel_service_subsystem_id_set(event, "vendor_x_subsystem_id"); + evel_service_friendly_name_set(event, "vendor_x_frieldly_name"); + evel_service_correlator_set(event, "vendor_x_correlator"); + evel_service_codec_set(event, "PCMA"); + evel_service_codec_set(event, "PCMA"); + evel_service_callee_codec_set(event, "PCMA"); + evel_service_caller_codec_set(event, "G729A"); + evel_service_rtcp_data_set(event, "some_rtcp_data"); + evel_service_adjacency_name_set(event, "vendor_x_adjacency"); + evel_service_endpoint_desc_set(event, EVEL_SERVICE_ENDPOINT_CALLER); + evel_service_endpoint_jitter_set(event, 66); + evel_service_endpoint_rtp_oct_disc_set(event, 100); + evel_service_endpoint_rtp_oct_recv_set(event, 200); + evel_service_endpoint_rtp_oct_sent_set(event, 300); + evel_service_endpoint_rtp_pkt_disc_set(event, 400); + evel_service_endpoint_rtp_pkt_recv_set(event, 500); + evel_service_endpoint_rtp_pkt_sent_set(event, 600); + evel_service_local_jitter_set(event, 99); + evel_service_local_rtp_oct_disc_set(event, 150); + evel_service_local_rtp_oct_recv_set(event, 250); + evel_service_local_rtp_oct_sent_set(event, 350); + evel_service_local_rtp_pkt_disc_set(event, 450); + evel_service_local_rtp_pkt_recv_set(event, 550); + evel_service_local_rtp_pkt_sent_set(event, 650); + evel_service_mos_cqe_set(event, 12.255); + evel_service_packets_lost_set(event, 157); + evel_service_packet_loss_percent_set(event, 0.232); + evel_service_r_factor_set(event, 11); + evel_service_round_trip_delay_set(event, 15); + evel_service_phone_number_set(event, "0888888888"); + evel_service_addl_field_add(event, "Name1", "Value1"); + evel_service_addl_field_add(event, "Name2", "Value2"); + evel_service_addl_field_add(event, "Name3", "Value3"); + evel_service_addl_field_add(event, "Name4", "Value4"); + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) event); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Service"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(event); + evel_throttle_terminate(); +} + +void test_encode_signaling_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"signaling\", " + "\"suppressedFieldNames\": [" + "\"correlator\", " + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\", " + "\"localIpAddress\", " + "\"localPort\", " + "\"remoteIpAddress\", " + "\"remotePort\", " + "\"compressedSip\", " + "\"summarySip\"], " + "\"suppressedNvPairsList\": [" + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"signaling\", " + "\"eventId\": \"2001\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 2001, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"signalingFields\": {" + "\"eventInstanceIdentifier\": " + "{" + "\"vendorId\": \"vendor_x_id\", " + "\"eventId\": \"vendor_x_event_id\", " + "\"productId\": \"vendor_x_product_id\", " + "\"subsystemId\": \"vendor_x_subsystem_id\", " + "\"eventFriendlyName\": \"vendor_x_frieldly_name\"" + "}, " + "\"signalingFieldsVersion\": 1.1" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_SIGNALING) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SIGNALING * event = NULL; + evel_set_next_event_sequence(2001); + event = evel_new_signaling("vendor_x_id", + "correlator", "1.0.3.1", "1234", "192.168.1.3","3456"); + assert(event != NULL); + evel_signaling_vnfmodule_name_set(event, "vendor_x_module"); + evel_signaling_vnfname_set(event, "vendor_x_vnf"); + evel_signaling_type_set(event, "Signaling"); + evel_signaling_product_id_set(event, "vendor_x_product_id"); + evel_signaling_subsystem_id_set(event, "vendor_x_subsystem_id"); + evel_signaling_friendly_name_set(event, "vendor_x_frieldly_name"); + evel_signaling_correlator_set(event, "vendor_x_correlator"); + evel_signaling_local_ip_address_set(event, "1.0.3.1"); + evel_signaling_local_port_set(event, "1031"); + evel_signaling_remote_ip_address_set(event, "5.3.3.0"); + evel_signaling_remote_port_set(event, "5330"); + evel_signaling_compressed_sip_set(event, "compressed_sip"); + evel_signaling_summary_sip_set(event, "summary_sip"); + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) event); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Signaling"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(event); + evel_throttle_terminate(); +} + +void test_encode_state_change_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"stateChange\", " + "\"suppressedFieldNames\": [" + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"additionalFields\", " + "\"suppressedNvPairNames\": [\"Name1\"]" + "}," + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"stateChange\", " + "\"eventId\": \"128\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 128, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"stateChangeFields\": {" + "\"newState\": \"inService\", " + "\"oldState\": \"outOfService\", " + "\"stateInterface\": \"An Interface\", " + "\"additionalFields\": [" + "{\"name\": \"Name2\", " + "\"value\": \"Value2\"}" + "], " + "\"stateChangeFieldsVersion\": 1.1" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_STATE_CHANGE) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_STATE_CHANGE * state_change = NULL; + evel_set_next_event_sequence(128); + state_change = evel_new_state_change(EVEL_ENTITY_STATE_IN_SERVICE, + EVEL_ENTITY_STATE_OUT_OF_SERVICE, + "An Interface"); + assert(state_change != NULL); + evel_state_change_type_set(state_change, "SC Type"); + evel_state_change_addl_field_add(state_change, "Name1", "Value1"); + evel_state_change_addl_field_add(state_change, "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) state_change); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "StateChange"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(state_change); + evel_throttle_terminate(); +} + +void test_encode_syslog_throttled() +{ + MEMORY_CHUNK post; + + /***************************************************************************/ + /* We also test suppression of the event header parameters here. */ + /***************************************************************************/ + char * json_command_list = + "{" + "\"commandList\": [" + "{" + "\"command\": {" + "\"commandType\": \"throttlingSpecification\", " + "\"eventDomainThrottleSpecification\": {" + "\"eventDomain\": \"syslog\", " + "\"suppressedFieldNames\": [" + "\"eventSourceHost\", " + "\"syslogFacility\", " + "\"syslogProc\", " + "\"syslogProcId\", " + "\"syslogSData\", " + "\"syslogVer\", " + "\"eventType\", " + "\"reportingEntityId\", " + "\"sourceId\"], " + "\"suppressedNvPairsList\": [" + "{" + "\"nvPairFieldName\": \"additionalFields\", " + "\"suppressedNvPairNames\": [\"Name2\"]" + "}," + "]}}}" + "]" + "}"; + + char * expected = + "{\"event\": " + "{\"commonEventHeader\": {" + "\"domain\": \"syslog\", " + "\"eventId\": \"126\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 126, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2" + "}, " + "\"syslogFields\": {" + "\"eventSourceType\": \"virtualNetworkFunction\", " + "\"syslogMsg\": \"SL Message\", " + "\"syslogTag\": \"SL Tag\", " + "\"syslogFieldsVersion\": 1.1, " + "\"additionalFields\": [" + "{\"name\": \"Name1\", " + "\"value\": \"Value1\"}" + "]" + "}}}"; + + /***************************************************************************/ + /* Initialize and provide a specification with a single fault suppressed. */ + /***************************************************************************/ + evel_throttle_initialize(); + handle_json_response(json_command_list, &post); + + /***************************************************************************/ + /* Check that the domain is throttled. */ + /***************************************************************************/ + assert(evel_get_throttle_spec(EVEL_DOMAIN_SYSLOG) != NULL); + assert(post.memory == NULL); + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + EVENT_SYSLOG * syslog = NULL; + evel_set_next_event_sequence(126); + syslog = evel_new_syslog(EVEL_SOURCE_VIRTUAL_NETWORK_FUNCTION, + "SL Message", + "SL Tag"); + assert(syslog != NULL); + evel_syslog_type_set(syslog, "SL Type"); + evel_syslog_event_source_host_set(syslog, "SL Host"); + evel_syslog_facility_set(syslog, EVEL_SYSLOG_FACILITY_LINE_PRINTER); + evel_syslog_proc_set(syslog, "SL Proc"); + evel_syslog_proc_id_set(syslog, 2); + evel_syslog_version_set(syslog, 1); + evel_syslog_s_data_set(syslog, "SL SDATA"); + evel_syslog_addl_field_add(syslog, "Name1", "Value1"); + evel_syslog_addl_field_add(syslog, "Name2", "Value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) syslog); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Syslog"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(syslog); + evel_throttle_terminate(); +} + +void test_encode_fault_with_escaping() +{ + char * expected = + "{\"event\": {" + "\"commonEventHeader\": {" + "\"domain\": \"fault\", " + "\"eventId\": \"122\", " + "\"functionalRole\": \"UNIT TEST\", " + "\"lastEpochMicrosec\": 1000002, " + "\"priority\": \"Normal\", " + "\"reportingEntityName\": \"Dummy VM name - No Metadata available\", " + "\"sequence\": 122, " + "\"sourceName\": \"Dummy VM name - No Metadata available\", " + "\"startEpochMicrosec\": 1000002, " + "\"version\": 1.2, " + "\"eventType\": \"Bad things happen...\\\\\", " + "\"reportingEntityId\": \"Dummy VM UUID - No Metadata available\", " + "\"sourceId\": \"Dummy VM UUID - No Metadata available\"" + "}, " + "\"faultFields\": {" + "\"alarmCondition\": \"My alarm condition\", " + "\"eventSeverity\": \"MAJOR\", " + "\"eventSourceType\": \"other\", " + "\"specificProblem\": \"It broke \\\"very\\\" badly\", " + "\"vfStatus\": \"Active\", " + "\"faultFieldsVersion\": 1.1, " + "\"alarmAdditionalInformation\": [" + "{\"name\": \"name1\", " + "\"value\": \"value1\"}, " + "{\"name\": \"name2\", " + "\"value\": \"value2\"}], " + "\"alarmInterfaceA\": \"My Interface Card\"" + "}}}"; + + size_t json_size = 0; + char json_body[EVEL_MAX_JSON_BODY]; + evel_set_next_event_sequence(122); + EVENT_FAULT * fault = evel_new_fault("My alarm condition", + "It broke \"very\" badly", + EVEL_PRIORITY_NORMAL, + EVEL_SEVERITY_MAJOR, + EVEL_SOURCE_HOST, + EVEL_VF_STATUS_PREP_TERMINATE); + assert(fault != NULL); + evel_fault_type_set(fault, "Bad things happen...\\"); + evel_fault_interface_set(fault, "My Interface Card"); + evel_fault_addl_info_add(fault, "name1", "value1"); + evel_fault_addl_info_add(fault, "name2", "value2"); + + json_size = evel_json_encode_event( + json_body, EVEL_MAX_JSON_BODY, (EVENT_HEADER *) fault); + compare_strings(expected, json_body, EVEL_MAX_JSON_BODY, "Fault"); + assert((json_size == strlen(json_body)) && "Bad size returned"); + + evel_free_event(fault); +} |