Skip to content

Commit 2b4a9bc

Browse files
ktfktf
committed
DPL: move to new CallbackService API
1 parent 89b53eb commit 2b4a9bc

73 files changed

Lines changed: 166 additions & 169 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎Detectors/HMPID/workflow/src/ReadRawFileSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ void RawFileReaderTask::init(framework::InitContext& ic)
6262
LOG(info) << "stop file reader"; // close the input file
6363
this->mInputFile.close();
6464
};
65-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
65+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
6666

6767
mExTimer.start();
6868
return;

‎Detectors/MUON/Common/src/dcs-processor-workflow.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ void processDataPoints(o2::framework::ProcessingContext& pc,
304304
o2::framework::AlgorithmSpec::ProcessCallback createProcessFunction(o2::framework::InitContext& ic)
305305
{
306306
auto& callbacks = ic.services().get<o2::framework::CallbackService>();
307-
callbacks.set(o2::framework::CallbackService::Id::EndOfStream, endOfStream);
307+
callbacks.set<o2::framework::CallbackService::Id::EndOfStream>(endOfStream);
308308

309309
// the aliases arrays contain all the names of the MCH or MID data points
310310
// we are interested to transit to the CCDB

‎Detectors/MUON/MCH/Calibration/src/pedestal-decoding-workflow.cxx‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,8 +153,8 @@ class PedestalsTask
153153
<< mTimeDecoderMax->count() << ", mean=" << mTimeDecoder.count() / mTFcount;
154154
}
155155
};
156-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
157-
ic.services().get<CallbackService>().set(CallbackService::Id::Reset, [this]() { reset(); });
156+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
157+
ic.services().get<CallbackService>().set<CallbackService::Id::Reset>([this]() { reset(); });
158158
}
159159

160160
//_________________________________________________________________________________________________

‎Detectors/MUON/MCH/PreClustering/src/PreClusterFinderSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ class PreClusterFinderTask
8686
LOGP(warning, error.asString());
8787
});
8888
};
89-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
89+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
9090

9191
auto checkNoLeftoverDigits = ic.options().get<std::string>("check-no-leftover-digits");
9292
if (checkNoLeftoverDigits == "quiet") {

‎Detectors/MUON/MCH/TimeClustering/src/TimeClusterFinderSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ class TimeClusterFinderTask
9898
LOGP(info, "\nduration = {} us / TF\n", mTimeProcess.count() * 1000 / mTFcount);
9999
}
100100
};
101-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
101+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
102102
}
103103

104104
ROFFilter createRandomRejectionFilter(float rejectionFraction)

‎Detectors/MUON/MCH/Tracking/src/TrackFinderSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ class TrackFinderTask
108108
LOGP(warning, error.asString());
109109
});
110110
};
111-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
111+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
112112
}
113113

114114
//_________________________________________________________________________________________________

‎Detectors/MUON/MCH/Workflow/src/ClusterFinderGEMSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ class ClusterFinderGEMTask
157157
// Inv ??? LOG(info) << "GG = lowestPadCharge = " << ClusterizerParam::Instance().lowestPadCharge;
158158

159159
/// Print the timer and clear the clusterizer when the processing is over
160-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, [this]() {
160+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>([this]() {
161161
LOG(info) << "cluster finder duration = " << mTimeClusterFinder.count() << " s";
162162
if (isActive(DoOriginal)) {
163163
this->mClusterFinderOriginal.deinit();

‎Detectors/MUON/MCH/Workflow/src/ClusterFinderOriginalSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ class ClusterFinderOriginalTask
7070
mAttachInitalPrecluster = ic.options().get<bool>("attach-initial-precluster");
7171

7272
/// Print the timer and clear the clusterizer when the processing is over
73-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, [this]() {
73+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>([this]() {
7474
LOG(info) << "cluster finder duration = " << mTimeClusterFinder.count() << " s";
7575
mErrorMap.forEach([](Error error) {
7676
LOGP(warning, error.asString());

‎Detectors/MUON/MCH/Workflow/src/DataDecoderSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ class DataDecoderTask
102102
LOG(info) << "mch-data-decoder: decoding duration = " << mTimeDecoding.count() * 1000 / mTFcount << " us / TF";
103103
LOG(info) << "mch-data-decoder: ROF finder duration = " << mTimeROFFinder.count() * 1000 / mTFcount << " us / TF";
104104
};
105-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
105+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
106106
}
107107

108108
//_________________________________________________________________________________________________

‎Detectors/MUON/MCH/Workflow/src/EventFinderSpec.cxx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ class EventFinderTask
6464
auto stop = [this]() {
6565
LOG(info) << "event finder duration = " << mElapsedTime.count() << " s";
6666
};
67-
ic.services().get<CallbackService>().set(CallbackService::Id::Stop, stop);
67+
ic.services().get<CallbackService>().set<CallbackService::Id::Stop>(stop);
6868
}
6969

7070
//_________________________________________________________________________________________________

0 commit comments

Comments
 (0)