Benchmarks changes required for monitoring tests (#14)

Author: awegrzyn

CMakeLists.txt

@@ -163,6 +163,7 @@ set(EXAMPLES
         examples/4-RateDerivedMetric.cxx
         examples/5-Benchmark.cxx
         examples/6-DedicatedInstance.cxx
+        examples/7-Latency.cxx
         )
 
 foreach (example ${EXAMPLES})

examples/5-Benchmark.cxx

@@ -11,25 +11,20 @@ using Monitoring = AliceO2::Monitoring::MonitoringFactory;
 
 int main(int argc, char *argv[]) {
   int sleep = 1000000;
-  std::string stringMetric = "stringMetric";
-  std::string doubleMetric = "doubleMetric";
-  std::string intMetric = "intMetric";
+  int count = 0;
 
   std::random_device rd;
   std::mt19937 mt(rd());
 
   std::uniform_real_distribution<double> doubleDist(1.0, 100.0);
   std::uniform_int_distribution<> intDist(1, 100);
 
-  double doubleValue = doubleDist(mt);
-  std::string stringValue = "sampleString" + std::to_string(intDist(mt));
-  int intValue = intDist(mt);
-
   boost::program_options::options_description desc("Allowed options");
   desc.add_options()
     ("sleep", boost::program_options::value<int>(), "Thread sleep in microseconds")
     ("config", boost::program_options::value<std::string>()->required(), "Config file path")
     ("id", boost::program_options::value<std::string>(), "Instance ID")
+    ("count", boost::program_options::value<int>(), "Number of metric bunches (x3)")
   ;
 
   boost::program_options::variables_map vm;
@@ -40,17 +35,27 @@ int main(int argc, char *argv[]) {
     sleep = vm["sleep"].as<int>();
   }
 
+  if (vm.count("count")) {
+    count = vm["count"].as<int>();
+  }
+
   try {
     Monitoring::Configure("file://" + vm["config"].as<std::string>());
   } catch (std::string &e) {
     std::cout << "Configuration file not found.\n" << e << std::endl;
     std::exit(EXIT_FAILURE);
-  }  
+  }
+
+  int add = 0;
+  if (count != 0) {
+    count--;
+    add = 1;
+  }
 
-  for (;;) {
-    Monitoring::Get().send(stringValue, stringMetric);
-    Monitoring::Get().send(doubleValue, doubleMetric);
-    Monitoring::Get().send(intValue, intMetric);
+  for (int i = 0; i <= count; i += add) {
+    Monitoring::Get().send({"string" + std::to_string(intDist(mt)), "stringMetric"});
+    Monitoring::Get().send({doubleDist(mt), "doubleMetric"});
+    Monitoring::Get().send({intDist(mt), "intMetric"});
     std::this_thread::sleep_for(std::chrono::microseconds(sleep));
   }
-}	
+}

examples/7-Latency.cxx

@@ -0,0 +1,49 @@
+///
+/// \file 7-Latency.cxx
+/// \author Adam Wegrzynek <[email protected]>
+///
+
+#include "Monitoring/MonitoringFactory.h"
+#include "ExampleBoilerplate.cxx"
+#include <boost/program_options.hpp>
+#include <random>
+
+using Monitoring = AliceO2::Monitoring::MonitoringFactory;
+using namespace AliceO2::Monitoring;
+
+int main(int argc, char *argv[]) {
+  int sleep = 10000;
+  boost::program_options::options_description desc("Allowed options");
+  desc.add_options()
+    ("sleep", boost::program_options::value<int>(), "Thread sleep in microseconds")
+    ("config", boost::program_options::value<std::string>()->required(), "Config file path")
+  ;
+
+  boost::program_options::variables_map vm;
+  boost::program_options::store(boost::program_options::parse_command_line(argc, argv, desc), vm);
+  boost::program_options::notify(vm);
+
+  if (vm.count("sleep")) {
+    sleep = vm["sleep"].as<int>();
+  }
+
+  try {
+    Monitoring::Configure("file://" + vm["config"].as<std::string>());
+  } catch (std::string &e) {
+    std::cout << "Configuration file not found.\n" << e << std::endl;
+    std::exit(EXIT_FAILURE);
+  }
+
+  auto timestamp = std::chrono::system_clock::now();
+  
+  for (;;) {
+    Monitoring::Get().send(
+      Metric{999, "latencyTestMetric"}.addTags(
+        {{"libraryTimestamp", std::to_string(
+          std::chrono::duration_cast <std::chrono::nanoseconds>(timestamp.time_since_epoch()).count()
+        )}}
+      )
+    );
+    std::this_thread::sleep_for(std::chrono::microseconds(sleep));
+  }
+}