update monitoring metrics (#349)

* update monitoring metrics

* block->message, unify naming of monitoring metrics

Author: Barthelemy

Framework/include/QualityControl/TaskRunner.h

@@ -138,9 +138,9 @@ class TaskRunner : public framework::Task
   int mCycleNumber = 0;
 
   // stats
-  int mNumberBlocks = 0;
+  int mNumberMessages = 0;
   int mNumberObjectsPublishedInCycle = 0;
-  int mTotalNumberObjectsPublished = 0;
+  int mTotalNumberObjectsPublished = 0; // over a run
   double mLastPublicationDuration = 0;
   AliceO2::Common::Timer mTimerTotalDurationActivity;
   AliceO2::Common::Timer mTimerDurationCycle;

Framework/src/TaskRunner.cxx

@@ -101,7 +101,7 @@ void TaskRunner::run(ProcessingContext& pCtx)
 
   if (dataReady) {
     mTask->monitorData(pCtx);
-    mNumberBlocks++;
+    mNumberMessages++;
   }
 
   if (timerReady) {
@@ -324,7 +324,10 @@ std::string TaskRunner::validateDetectorName(std::string name)
 
 void TaskRunner::startOfActivity()
 {
+  // stats
   mTimerTotalDurationActivity.reset();
+  mTotalNumberObjectsPublished = 0;
+
   Activity activity(mConfigFile->get<int>("qc.config.Activity.number"),
                     mConfigFile->get<int>("qc.config.Activity.type"));
   mTask->startOfActivity(activity);
@@ -346,7 +349,7 @@ void TaskRunner::startCycle()
 {
   QcInfoLogger::GetInstance() << "cycle " << mCycleNumber << " in " << mTaskConfig.taskName << AliceO2::InfoLogger::InfoLogger::endm;
   mTask->startOfCycle();
-  mNumberBlocks = 0;
+  mNumberMessages = 0;
   mNumberObjectsPublishedInCycle = 0;
   mTimerDurationCycle.reset();
   mCycleOn = true;
@@ -379,14 +382,14 @@ void TaskRunner::publishCycleStats()
   double totalDurationActivity = mTimerTotalDurationActivity.getTime();
 
   // monitoring metrics
-  mCollector->send({ mNumberBlocks, "QC_task_Numberofblocks_in_cycle" });
-  mCollector->send({ cycleDuration, "QC_task_Module_cycle_duration" });
-  mCollector->send({ mLastPublicationDuration, "QC_task_Publication_duration" });
-  mCollector->send({ mNumberObjectsPublishedInCycle, "QC_task_Number_objects_published_in_cycle" });
-  mCollector->send({ rate, "QC_task_Rate_objects_published_per_second" });
-  mCollector->send({ mTotalNumberObjectsPublished, "QC_task_Total_objects_published_whole_run" });
-  mCollector->send({ totalDurationActivity, "QC_task_Total_duration_activity_whole_run" });
-  mCollector->send({ wholeRunRate, "QC_task_Rate_objects_published_per_second_whole_run" });
+  mCollector->send({ mNumberMessages, "QC_task_number_messages_received_in_cycle" });
+  mCollector->send({ cycleDuration, "QC_task_module_cycle_duration" });
+  mCollector->send({ mLastPublicationDuration, "QC_task_publication_duration" });
+  mCollector->send({ mNumberObjectsPublishedInCycle, "QC_task_number_objects_published_in_cycle" });
+  mCollector->send({ rate, "QC_task_rate_objects_published_per_second" });
+  mCollector->send({ mTotalNumberObjectsPublished, "QC_task_total_objects_published_whole_run" });
+  mCollector->send({ totalDurationActivity, "QC_task_total_duration_activity_whole_run" });
+  mCollector->send({ wholeRunRate, "QC_task_rate_objects_published_per_second_whole_run" });
 }
 
 int TaskRunner::publish(DataAllocator& outputs)