Skip to content

Commit d9d3835

Browse files
committed
Do not quit after processing one TF in event loop
1 parent fced477 commit d9d3835

2 files changed

Lines changed: 0 additions & 3 deletions

File tree

Detectors/CPV/workflow/src/ClusterizerSpec.cxx

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,6 @@ void ClusterizerSpec::run(framework::ProcessingContext& ctx)
5151
ctx.outputs().snapshot(o2::framework::Output{"CPV", "CLUSTERTRUEMC", 0, o2::framework::Lifetime::Timeframe}, mOutputTruthCont);
5252
}
5353
LOG(INFO) << "Finished, wrote " << mOutputClusters.size() << " clusters, " << mOutputClusterTrigRecs.size() << "TR and " << mOutputTruthCont.getIndexedSize() << " Labels";
54-
ctx.services().get<o2::framework::ControlService>().endOfStream();
55-
ctx.services().get<o2::framework::ControlService>().readyToQuit(framework::QuitRequest::Me);
5654
}
5755
o2::framework::DataProcessorSpec o2::cpv::reco_workflow::getClusterizerSpec(bool propagateMC)
5856
{

Detectors/TOF/workflow/src/EntropyEncoderSpec.cxx

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ void EntropyEncoderSpec::run(ProcessingContext& pc)
5454
// eeb->print();
5555
mTimer.Stop();
5656
LOG(INFO) << "Created encoded data of size " << eeb->size() << " for TOF in " << mTimer.CpuTime() - cput << " s";
57-
// pc.services().get<ControlService>().endOfStream();
5857
}
5958

6059
void EntropyEncoderSpec::endOfStream(EndOfStreamContext& ec)

0 commit comments

Comments
 (0)