Skip to content

Commit 88491fd

Browse files
committed
DPL: fix how many forwarded parts are needed
In principle this is not fatal because the number of routes is always larger / equal than the number of channels by construction. Better safe than sorry.
1 parent e2f3588 commit 88491fd

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

Framework/Core/src/DataProcessingHelpers.cxx

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -343,9 +343,7 @@ auto DataProcessingHelpers::routeForwardedMessageSet(FairMQDeviceProxy& proxy,
343343
const bool copyByDefault, bool consume) -> std::vector<fair::mq::Parts>
344344
{
345345
// we collect all messages per forward in a map and send them together
346-
std::vector<fair::mq::Parts> forwardedParts;
347-
forwardedParts.resize(proxy.getNumForwards());
348-
std::vector<ChannelIndex> forwardingChoices{};
346+
std::vector<fair::mq::Parts> forwardedParts(proxy.getNumForwardChannels());
349347

350348
for (size_t ii = 0, ie = currentSetOfInputs.size(); ii < ie; ++ii) {
351349
auto span = std::span<fair::mq::MessagePtr>(currentSetOfInputs[ii].messages);

0 commit comments

Comments
 (0)