File tree Expand file tree Collapse file tree
Detectors/TPC/workflow/include/TPCWorkflow Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -129,6 +129,7 @@ class TPCDistributeCMVSpec : public o2::framework::Task
129129
130130 const auto tf = processing_helpers::getCurrentTF (pc);
131131 if (tf == std::numeric_limits<uint32_t >::max ()) {
132+ LOGP (info, " Entering forwardEOSData() after receiving timeframe {}" , tf);
132133 forwardEOSData (pc);
133134 return ;
134135 }
@@ -222,7 +223,11 @@ class TPCDistributeCMVSpec : public o2::framework::Task
222223 }
223224 }
224225
225- void endOfStream (o2::framework::EndOfStreamContext& ec) final { ec.services ().get <o2::framework::ControlService>().readyToQuit (o2::framework::QuitRequest::Me); }
226+ void endOfStream (o2::framework::EndOfStreamContext& ec) final
227+ {
228+ LOGP (info, " Entering endOfStream()" );
229+ ec.services ().get <o2::framework::ControlService>().readyToQuit (o2::framework::QuitRequest::Me);
230+ }
226231
227232 // / Return data description for aggregated CMVs for a given lane
228233 static header::DataDescription getDataDescriptionCMV (const unsigned int lane)
You can’t perform that action at this time.
0 commit comments