summaryrefslogtreecommitdiffstats
path: root/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval
diff options
context:
space:
mode:
authorMarco Platania <platania@research.att.com>2017-05-18 11:09:08 -0400
committerMarco Platania <platania@research.att.com>2017-05-18 11:09:08 -0400
commitfee6de844f9d4c3aad87733734d35df50117b6b0 (patch)
tree3f42567107ac4a10795c8e80c42b479c4502cbda /VES5.0/evel/evel-library/code/evel_training/14-measurement-interval
parentf3fe765461685a753c0f5b061c5c47383c75829f (diff)
Change location of VES5.0 code
Change-Id: If8a1173813eb4d5c14c04b132269696a748505e7 Signed-off-by: Marco Platania <platania@research.att.com>
Diffstat (limited to 'VES5.0/evel/evel-library/code/evel_training/14-measurement-interval')
-rw-r--r--VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/Makefile35
-rw-r--r--VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/hello_evel_world.c293
2 files changed, 0 insertions, 328 deletions
diff --git a/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/Makefile b/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/Makefile
deleted file mode 100644
index ee8c3461..00000000
--- a/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/Makefile
+++ /dev/null
@@ -1,35 +0,0 @@
-CC=gcc
-
-ARCH=$(shell getconf LONG_BIT)
-CODE_ROOT=$(CURDIR)/../../..
-LIBS_DIR=$(CODE_ROOT)/libs/x86_$(ARCH)
-INCLUDE_DIR=$(CODE_ROOT)/code/evel_library
-EVEL_DEMO=$(CURDIR)/../../evel_demo
-TEST_CONTROL=$(EVEL_DEMO)/evel_test_control.c
-
-#******************************************************************************
-# Standard compiler flags. *
-#******************************************************************************
-CPPFLAGS=
-CFLAGS=-Wall -g -fPIC
-
-all: hello_evel_world
-
-hello_evel_world: hello_evel_world.c $(TEST_CONTROL)
- $(CC) $(CPPFLAGS) $(CFLAGS) -o hello_evel_world \
- -L $(LIBS_DIR) \
- -I $(INCLUDE_DIR) \
- -I $(EVEL_DEMO) \
- hello_evel_world.c \
- $(TEST_CONTROL) \
- -lpthread \
- -level \
- -lcurl
-
-#******************************************************************************
-# Configure the vel_username and vel_password to
-# vel_username = username
-# vel_password = password
-#******************************************************************************
-run: all
- ./hello_evel_world 127.0.0.1 30000 username password
diff --git a/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/hello_evel_world.c b/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/hello_evel_world.c
deleted file mode 100644
index 269262aa..00000000
--- a/VES5.0/evel/evel-library/code/evel_training/14-measurement-interval/hello_evel_world.c
+++ /dev/null
@@ -1,293 +0,0 @@
-#include <stdio.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <sys/time.h>
-
-#include "evel.h"
-#include "evel_test_control.h"
-
-/*****************************************************************************/
-/* Local prototypes. */
-/*****************************************************************************/
-static void demo_heartbeat();
-static void demo_measurement(const int interval);
-
-unsigned long long epoch_start = 0;
-
-int main(int argc, char ** argv)
-{
- printf("\nHello AT&T Vendor Event world!\n");
- fflush(stdout);
-
- if (argc != 5)
- {
- fprintf(stderr,
- "Usage: %s <FQDN>|<IP address> <port> "
- "<username> <password>\n", argv[0]);
- exit(-1);
- }
-
- char * api_fqdn = argv[1];
- int api_port = atoi(argv[2]);
- int api_secure = 0;
-
- /***************************************************************************/
- /* Initialize */
- /***************************************************************************/
- if (evel_initialize(api_fqdn, /* FQDN */
- api_port, /* Port */
- NULL, /* optional path */
- NULL, /* optional topic */
- api_secure, /* HTTPS? */
- argv[3], /* Username */
- argv[4], /* Password */
- EVEL_SOURCE_VIRTUAL_MACHINE, /* Source type */
- "EVEL training demo", /* Role */
- 0)) /* Verbosity */
- {
- fprintf(stderr, "\nFailed to initialize the EVEL library!!!\n");
- exit(-1);
- }
- else
- {
- printf("\nInitialization completed\n");
- }
-
- /***************************************************************************/
- /* Work out a start time for measurements, and sleep for initial period. */
- /***************************************************************************/
- int sleep_time = 1;
- struct timeval tv_start;
- gettimeofday(&tv_start, NULL);
- epoch_start = tv_start.tv_usec + 1000000 * tv_start.tv_sec;
- sleep(sleep_time);
-
- int index;
- for (index = 0; index < 10; index++)
- {
- /*************************************************************************/
- /* On the second and fifth iteration, get the test_collector to change */
- /* the interval. */
- /*************************************************************************/
- if (index == 2)
- {
- printf("TestControl: measurement interval -> 2s\n");
- evel_test_control_meas_interval(2, api_secure, api_fqdn, api_port);
- }
- if (index == 5)
- {
- printf("TestControl: measurement interval -> 5s\n");
- evel_test_control_meas_interval(5, api_secure, api_fqdn, api_port);
- }
-
- /*************************************************************************/
- /* Heartbeat to pick up the suppression change. */
- /*************************************************************************/
- demo_heartbeat();
-
- /*************************************************************************/
- /* Raise a measurement and sleep. */
- /*************************************************************************/
- printf("Report measurements\n");
- fflush(stdout);
- demo_measurement(sleep_time);
- printf("Sleeping for %ds\n", sleep_time);
- fflush(stdout);
- sleep(sleep_time);
-
- /*************************************************************************/
- /* Update measurement interval. */
- /*************************************************************************/
- int measurement_interval;
- measurement_interval = evel_get_measurement_interval();
- if (measurement_interval == EVEL_MEASUREMENT_INTERVAL_UKNOWN)
- {
- sleep_time = 1;
- }
- else
- {
- sleep_time = measurement_interval;
- }
- printf("EVEL measurement interval = %d\n\n", measurement_interval);
- }
-
- /***************************************************************************/
- /* Terminate */
- /***************************************************************************/
- sleep(1);
- evel_terminate();
- printf("Terminated\n");
-
- return 0;
-}
-
-/**************************************************************************//**
- * Create and send a heatbeat.
- *****************************************************************************/
-void demo_heartbeat()
-{
- EVENT_HEADER * heartbeat = NULL;
- EVEL_ERR_CODES evel_rc = EVEL_SUCCESS;
-
- heartbeat = evel_new_heartbeat();
- if (heartbeat != NULL)
- {
- evel_rc = evel_post_event(heartbeat);
- if (evel_rc != EVEL_SUCCESS)
- {
- printf("Post failed %d (%s)", evel_rc, evel_error_string());
- }
- }
- else
- {
- printf("New heartbeat failed");
- }
-}
-
-/**************************************************************************//**
- * Create and send a measurement event.
- *****************************************************************************/
-void demo_measurement(const int interval)
-{
- EVENT_MEASUREMENT * measurement = NULL;
- MEASUREMENT_LATENCY_BUCKET * bucket = NULL;
- MEASUREMENT_VNIC_PERFORMANCE * vnic_performance = NULL;
- EVEL_ERR_CODES evel_rc = EVEL_SUCCESS;
- MEASUREMENT_CPU_USE *cpu_use;
-
- /***************************************************************************/
- /* Measurement */
- /***************************************************************************/
- measurement = evel_new_measurement(interval);
- if (measurement != NULL)
- {
- printf("New measurement created...\n");
- 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, 6);
-
- 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);
-
- bucket = evel_new_meas_latency_bucket(20);
- evel_meas_latency_bucket_low_end_set(bucket, 0.0);
- evel_meas_latency_bucket_high_end_set(bucket, 10.0);
- 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_performance = evel_measurement_new_vnic_performance("eth0", "true");
-
- evel_vnic_performance_rx_bcast_pkt_acc_set(vnic_performance, 1000000.023);
- evel_vnic_performance_rx_bcast_pkt_delta_set(vnic_performance,1234.767346);
- evel_vnic_performance_rx_discard_pkt_acc_set(vnic_performance, 127146784.234738587);
- evel_vnic_performance_rx_discard_pkt_delta_set(vnic_performance, 123445);
- evel_vnic_performance_rx_error_pkt_acc_set(vnic_performance, 2736448376);
- evel_vnic_performance_rx_error_pkt_delta_set(vnic_performance, 3474438764);
- evel_vnic_performance_rx_mcast_pkt_acc_set(vnic_performance, 42464676);
- evel_vnic_performance_rx_mcast_pkt_delta_set(vnic_performance, 42678657654);
- evel_vnic_performance_rx_octets_acc_set(vnic_performance, 47658745);
- evel_vnic_performance_rx_octets_delta_set(vnic_performance, 47656465465);
- evel_vnic_performance_rx_total_pkt_acc_set(vnic_performance, 4765764654444);
- evel_vnic_performance_rx_total_pkt_delta_set(vnic_performance, 4545665656);
- evel_vnic_performance_rx_ucast_pkt_acc_set(vnic_performance, 4765745546.);
- evel_vnic_performance_rx_ucast_pkt_delta_set(vnic_performance, 4768765.78347856);
- evel_vnic_performance_tx_bcast_pkt_acc_set(vnic_performance, 747665.347647);
- evel_vnic_performance_tx_bcast_pkt_delta_set(vnic_performance, 3468765.4774);
- evel_vnic_performance_tx_discarded_pkt_acc_set(vnic_performance, 53625345.53);
- evel_vnic_performance_tx_discarded_pkt_delta_set(vnic_performance, 5465345.72455);
- evel_vnic_performance_tx_error_pkt_acc_set(vnic_performance, 7632754.754);
- evel_vnic_performance_tx_error_pkt_delta_set(vnic_performance, 34646875444.);
- evel_vnic_performance_tx_mcast_pkt_acc_set(vnic_performance, 2734875.5534);
- evel_vnic_performance_tx_mcast_pkt_delta_set(vnic_performance, 562346534.654);
- evel_vnic_performance_tx_octets_acc_set(vnic_performance, 2785845.76874);
- evel_meas_vnic_performance_add(measurement, vnic_performance);
-
- vnic_performance = evel_measurement_new_vnic_performance("eth1", "false");
- evel_vnic_performance_rx_mcast_pkt_delta_set(vnic_performance, 42678657654);
- evel_vnic_performance_rx_octets_acc_set(vnic_performance, 47658745);
- evel_vnic_performance_rx_octets_delta_set(vnic_performance, 47656465465);
- evel_vnic_performance_rx_total_pkt_acc_set(vnic_performance, 4765764654444);
- evel_vnic_performance_rx_total_pkt_delta_set(vnic_performance, 4545665656);
- evel_vnic_performance_rx_ucast_pkt_acc_set(vnic_performance, 4765745546.);
- evel_vnic_performance_rx_ucast_pkt_delta_set(vnic_performance, 4768765.78347856);
- evel_vnic_performance_tx_bcast_pkt_acc_set(vnic_performance, 747665.347647);
- evel_vnic_performance_tx_bcast_pkt_delta_set(vnic_performance, 3468765.4774);
- evel_vnic_performance_tx_discarded_pkt_acc_set(vnic_performance, 53625345.53);
- evel_meas_vnic_performance_add(measurement, vnic_performance);
-
- 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");
-
- /*************************************************************************/
- /* Work out the time, to use as end of measurement period. */
- /*************************************************************************/
- struct timeval tv_now;
- gettimeofday(&tv_now, NULL);
- unsigned long long epoch_now = tv_now.tv_usec + 1000000 * tv_now.tv_sec;
- evel_start_epoch_set(&measurement->header, epoch_start);
- evel_last_epoch_set(&measurement->header, epoch_now);
- epoch_start = epoch_now;
- evel_reporting_entity_name_set(&measurement->header, "measurer");
- evel_reporting_entity_id_set(&measurement->header, "measurer_id");
-
- evel_rc = evel_post_event((EVENT_HEADER *)measurement);
- if (evel_rc == EVEL_SUCCESS)
- {
- printf("Post OK!\n");
- }
- else
- {
- printf("Post Failed %d (%s)\n", evel_rc, evel_error_string());
- }
- }
- else
- {
- printf("Failed to create event (%s)\n", evel_error_string());
- }
-
- printf(" Processed Measurement\n");
-}