helper to redirect FMQ logs to infologger

Author: sy-c

include/InfoLogger/InfoLoggerFMQ.hxx

@@ -0,0 +1,76 @@
+#include <fairmq/FairMQLogger.h>
+#include <InfoLogger/InfoLogger.hxx>
+
+  
+// This function setup a custom sink for FMQ logs so that they are redirected to infoLogger
+// The infologger context is set when invoked. Corresponding fields are fixed afterwards.
+void setFMQLogsToInfoLogger(AliceO2::InfoLogger::InfoLogger *logPtr=nullptr) {
+  
+  static AliceO2::InfoLogger::InfoLoggerContext ctx;
+  // set facility = FMQ? better to add dedicated "module" field
+  //ctx.setField(AliceO2::InfoLogger::InfoLoggerContext::FieldName::Facility,"FMQ");
+  
+  static AliceO2::InfoLogger::InfoLogger *theLogPtr=logPtr;
+  if (logPtr==nullptr) {
+    static AliceO2::InfoLogger::InfoLogger theLog;
+    logPtr=&theLog;
+  }
+  
+  fair::Logger::SetConsoleSeverity(fair::Severity::nolog);
+  
+  fair::Logger::AddCustomSink(
+      "infoLogger", "trace", [&](const std::string& content, const fair::LogMetaData& metadata)
+    {
+
+      // todo: update context from time to time?
+      // ctx.refresh();
+
+      // translate FMQ metadata
+      AliceO2::InfoLogger::InfoLogger::InfoLogger::Severity severity=AliceO2::InfoLogger::InfoLogger::Severity::Undefined;
+      int level=AliceO2::InfoLogger::InfoLogger::undefinedMessageOption.level;
+      
+      if (metadata.severity_name== fair::Logger::SeverityName(fair::Severity::nolog)) {
+          // discard
+          return;
+      }
+      else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::fatal)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Fatal;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::error)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Error;       
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::warn)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Warning;      
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::state)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Info;
+          level=10;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::info)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Info;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::debug)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::debug1)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;
+          level=10;       
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::debug2)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;
+          level=20;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::debug3)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;
+          level=30;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::debug4)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;
+          level=40;
+      } else if (metadata.severity_name==fair::Logger::SeverityName(fair::Severity::trace)) {
+          severity=AliceO2::InfoLogger::InfoLogger::Severity::Debug;        
+          level=50;        
+      }
+
+      AliceO2::InfoLogger::InfoLogger::InfoLoggerMessageOption opt={
+        severity,
+        level,
+        AliceO2::InfoLogger::InfoLogger::undefinedMessageOption.errorCode,
+        metadata.file.c_str(),
+        atoi(metadata.line.c_str())
+      };
+      theLogPtr->log(opt,ctx,"FMQ: %s",content.c_str());
+    }
+    );
+}