Skip to content

Commit bca3070

Browse files
committed
DPL: use new indices methods to navigate through InputRecord in output-proxy
1 parent 9e8f22b commit bca3070

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

Framework/Core/src/ExternalFairMQDeviceProxy.cxx

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1027,16 +1027,19 @@ DataProcessorSpec specifyFairMQDeviceOutputProxy(char const* name,
10271027
callbacks.set<CallbackService::Id::EndOfStream>(forwardEos);
10281028

10291029
return adaptStateless([lastDataProcessingHeader](InputRecord& inputs) {
1030-
for (size_t ii = 0; ii != inputs.size(); ++ii) {
1031-
for (size_t pi = 0; pi < inputs.getNofParts(ii); ++pi) {
1032-
auto part = inputs.getByPos(ii, pi);
1030+
for (auto it = inputs.begin(); it != inputs.end(); it++) {
1031+
auto indices = it.initialIndices();
1032+
while (indices != it.endIndices()) {
1033+
LOGP(info, "headerIdx:payloadIdx {}:{}", indices.headerIdx, indices.payloadIdx);
1034+
auto part = it.getAtIndices(indices);
10331035
const auto* dph = o2::header::get<DataProcessingHeader*>(part.header);
10341036
if (dph) {
10351037
// FIXME: should we implement an assignment operator for DataProcessingHeader?
10361038
lastDataProcessingHeader->startTime = dph->startTime;
10371039
lastDataProcessingHeader->duration = dph->duration;
10381040
lastDataProcessingHeader->creation = dph->creation;
10391041
}
1042+
indices = it.nextIndices(indices)
10401043
}
10411044
}
10421045
});

0 commit comments

Comments
 (0)