DPL: use detail level for messages which come during initialisation (#8806)

They should be minimal and non repetitive, so it simplifies debugging to
not exclude them.

Author: ktf

Framework/Core/src/DataProcessingDevice.cxx

@@ -455,17 +455,17 @@ void DataProcessingDevice::initPollers()
           (channelName.rfind("from_internal-dpl-aod", 0) != 0) &&
           (channelName.rfind("from_internal-dpl-ccdb-backend", 0) != 0) &&
           (channelName.rfind("from_internal-dpl-injected", 0)) != 0) {
-        LOGP(debug, "{} is an internal channel. Skipping as no input will come from there.", channelName);
+        LOGP(detail, "{} is an internal channel. Skipping as no input will come from there.", channelName);
         continue;
       }
       // We only watch receiving sockets.
       if (channelName.rfind("from_" + mSpec.name + "_", 0) == 0) {
-        LOGP(debug, "{} is to send data. Not polling.", channelName);
+        LOGP(detail, "{} is to send data. Not polling.", channelName);
         continue;
       }
 
       if (channelName.rfind("from_") != 0) {
-        LOGP(info, "{} is not a DPL socket. Not polling.", channelName);
+        LOGP(detail, "{} is not a DPL socket. Not polling.", channelName);
         continue;
       }
 
@@ -479,7 +479,7 @@ void DataProcessingDevice::initPollers()
         LOG(error) << "Cannot get file descriptor for channel." << channelName;
         continue;
       }
-      LOGP(debug, "Polling socket for {}", channelName);
+      LOGP(detail, "Polling socket for {}", channelName);
       auto* pCtx = (PollerContext*)malloc(sizeof(PollerContext));
       pCtx->name = strdup(channelName.c_str());
       pCtx->loop = mState.loop;
@@ -493,7 +493,7 @@ void DataProcessingDevice::initPollers()
       poller->data = pCtx;
       uv_poll_init(mState.loop, poller, zmq_fd);
       if (channelName.rfind("from_") != 0) {
-        LOGP(debug, "{} is an out of band channel.", channelName);
+        LOGP(detail, "{} is an out of band channel.", channelName);
         mState.activeOutOfBandPollers.push_back(poller);
       } else {
         mState.activeInputPollers.push_back(poller);
@@ -509,11 +509,11 @@ void DataProcessingDevice::initPollers()
       mDeviceContext.exitTransitionTimeout = 0;
       for (auto& [channelName, channel] : fChannels) {
         if (channelName.rfind(mSpec.channelPrefix + "from_internal-dpl", 0) == 0) {
-          LOGP(debug, "{} is an internal channel. Not polling.", channelName);
+          LOGP(detail, "{} is an internal channel. Not polling.", channelName);
           continue;
         }
         if (channelName.rfind(mSpec.channelPrefix + "from_" + mSpec.name + "_", 0) == 0) {
-          LOGP(debug, "{} is an out of band channel. Not polling for output.", channelName);
+          LOGP(detail, "{} is an out of band channel. Not polling for output.", channelName);
           continue;
         }
         // We assume there is always a ZeroMQ socket behind.
@@ -526,7 +526,7 @@ void DataProcessingDevice::initPollers()
           LOGP(error, "Cannot get file descriptor for channel {}", channelName);
           continue;
         }
-        LOG(debug) << "Polling socket for " << channel[0].GetName();
+        LOG(detail) << "Polling socket for " << channel[0].GetName();
         // FIXME: leak
         auto* pCtx = (PollerContext*)malloc(sizeof(PollerContext));
         pCtx->name = strdup(channelName.c_str());
@@ -573,12 +573,15 @@ void DataProcessingDevice::startPollers()
 
 void DataProcessingDevice::stopPollers()
 {
+  LOGP(detail, "Stopping {} input pollers", mState.activeInputPollers.size());
   for (auto& poller : mState.activeInputPollers) {
     uv_poll_stop(poller);
   }
+  LOGP(detail, "Stopping {} out of band pollers", mState.activeOutOfBandPollers.size());
   for (auto& poller : mState.activeOutOfBandPollers) {
     uv_poll_stop(poller);
   }
+  LOGP(detail, "Stopping {} output pollers", mState.activeOutOfBandPollers.size());
   for (auto& poller : mState.activeOutputPollers) {
     uv_poll_stop(poller);
   }
@@ -623,11 +626,11 @@ void DataProcessingDevice::InitTask()
                                                                &pendingRegionInfos = mPendingRegionInfos,
                                                                &regionInfoMutex = mRegionInfoMutex](FairMQRegionInfo info) {
       std::lock_guard<std::mutex> lock(regionInfoMutex);
-      LOG(debug) << ">>> Region info event" << info.event;
-      LOG(debug) << "id: " << info.id;
-      LOG(debug) << "ptr: " << info.ptr;
-      LOG(debug) << "size: " << info.size;
-      LOG(debug) << "flags: " << info.flags;
+      LOG(detail) << ">>> Region info event" << info.event;
+      LOG(detail) << "id: " << info.id;
+      LOG(detail) << "ptr: " << info.ptr;
+      LOG(detail) << "size: " << info.size;
+      LOG(detail) << "flags: " << info.flags;
       context.expectedRegionCallbacks -= 1;
       pendingRegionInfos.push_back(info);
       // We always want to handle these on the main loop