DPL: move MessageContext::schedule out of line

Author: ktf

Framework/Core/include/Framework/MessageContext.h

@@ -444,38 +444,7 @@ class MessageContext
   /// Schedule a context object for sending.
   /// The object is considered complete at this point and is sent directly through the dispatcher callback
   /// of the context if initialized.
-  void schedule(Messages::value_type&& message)
-  {
-    auto const* header = message->header();
-    if (header == nullptr) {
-      throw std::logic_error("No valid header message found");
-    }
-    mScheduledMessages.emplace_back(std::move(message));
-    if (mDispatchControl.dispatch != nullptr) {
-      // send all scheduled messages if there is no trigger callback or its result is true
-      if (mDispatchControl.trigger == nullptr || mDispatchControl.trigger(*header)) {
-        std::vector<fair::mq::Parts> outputsPerChannel;
-        outputsPerChannel.resize(mProxy.getNumOutputChannels());
-        for (auto& message : mScheduledMessages) {
-          fair::mq::Parts parts = message->finalize();
-          assert(message->empty());
-          assert(parts.Size() == 2);
-          for (auto& part : parts) {
-            outputsPerChannel[mProxy.getOutputChannelIndex(message->route()).value].AddPart(std::move(part));
-          }
-        }
-        for (int ci = 0; ci < mProxy.getNumOutputChannels(); ++ci) {
-          auto& parts = outputsPerChannel[ci];
-          if (parts.Size() == 0) {
-            continue;
-          }
-          mDispatchControl.dispatch(std::move(parts), ChannelIndex{ci}, DefaultChannelIndex);
-        }
-        mDidDispatch = mScheduledMessages.empty() == false;
-        mScheduledMessages.clear();
-      }
-    }
-  }
+  void schedule(Messages::value_type&& message);
 
   Messages getMessagesForSending()
   {

Framework/Core/src/MessageContext.cxx

@@ -123,4 +123,37 @@ void MessageContext::pruneFromCache(int64_t id)
   mMessageCache.erase(id);
 }
 
+void MessageContext::schedule(Messages::value_type&& message)
+{
+  auto const* header = message->header();
+  if (header == nullptr) {
+    throw std::logic_error("No valid header message found");
+  }
+  mScheduledMessages.emplace_back(std::move(message));
+  if (mDispatchControl.dispatch != nullptr) {
+    // send all scheduled messages if there is no trigger callback or its result is true
+    if (mDispatchControl.trigger == nullptr || mDispatchControl.trigger(*header)) {
+      std::vector<fair::mq::Parts> outputsPerChannel;
+      outputsPerChannel.resize(mProxy.getNumOutputChannels());
+      for (auto& message : mScheduledMessages) {
+        fair::mq::Parts parts = message->finalize();
+        assert(message->empty());
+        assert(parts.Size() == 2);
+        for (auto& part : parts) {
+          outputsPerChannel[mProxy.getOutputChannelIndex(message->route()).value].AddPart(std::move(part));
+        }
+      }
+      for (int ci = 0; ci < mProxy.getNumOutputChannels(); ++ci) {
+        auto& parts = outputsPerChannel[ci];
+        if (parts.Size() == 0) {
+          continue;
+        }
+        mDispatchControl.dispatch(std::move(parts), ChannelIndex{ci}, DefaultChannelIndex);
+      }
+      mDidDispatch = mScheduledMessages.empty() == false;
+      mScheduledMessages.clear();
+    }
+  }
+}
+
 } // namespace o2::framework