Skip to content

Commit 5ba57fc

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

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

Framework/Core/src/ExternalFairMQDeviceProxy.cxx

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1027,9 +1027,10 @@ 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+
for (auto indices = it.initialIndices(); indices != it.endIndices(); indices = it.nextIndices(indices)) {
1032+
LOGP(info, "headerIdx:payloadIdx {}:{}", indices.headerIdx, indices.payloadIdx);
1033+
auto part = it.getAtIndices(indices);
10331034
const auto* dph = o2::header::get<DataProcessingHeader*>(part.header);
10341035
if (dph) {
10351036
// FIXME: should we implement an assignment operator for DataProcessingHeader?

0 commit comments

Comments
 (0)