@@ -161,7 +161,7 @@ TEST_CASE("ForwardInputsSingleMessageSingleRouteAtEOS")
161161 TimesliceSlot slot{0 };
162162
163163 auto result = o2::framework::DataProcessingHelpers::routeForwardedMessages (proxy, slot, currentSetOfInputs, oldestTimeslice, copyByDefault, consume);
164- REQUIRE (result.size () == 1 ); // One route
164+ REQUIRE (result.size () == 1 ); // One route
165165 REQUIRE (result[0 ].Size () == 0 ); // FIXME: this is an actual error. It should be 2
166166 // Correct behavior below:
167167 // REQUIRE(result[0].Size() == 2);
@@ -222,7 +222,7 @@ TEST_CASE("ForwardInputsSingleMessageSingleRouteWithOldestPossible")
222222 TimesliceSlot slot{0 };
223223
224224 auto result = o2::framework::DataProcessingHelpers::routeForwardedMessages (proxy, slot, currentSetOfInputs, oldestTimeslice, copyByDefault, consume);
225- REQUIRE (result.size () == 1 ); // One route
225+ REQUIRE (result.size () == 1 ); // One route
226226 REQUIRE (result[0 ].Size () == 0 ); // FIXME: this is actually wrong
227227 // FIXME: actually correct behavior below
228228 // REQUIRE(result[0].Size() == 2); // Two messages
@@ -588,7 +588,7 @@ TEST_CASE("ForwardInputsSplitPayload")
588588 TimesliceSlot slot{0 };
589589
590590 auto result = o2::framework::DataProcessingHelpers::routeForwardedMessages (proxy, slot, currentSetOfInputs, oldestTimeslice, copyByDefault, consume);
591- REQUIRE (result.size () == 2 ); // Two routes
591+ REQUIRE (result.size () == 2 ); // Two routes
592592 CHECK (result[0 ].Size () == 2 ); // No messages on this route
593593 CHECK (result[1 ].Size () == 5 ); // FIXME: Multipart matching has side effects also for the elements
594594 // CHECK(result[1].Size() == 3); // FIXME: the correct forwarding is that only the multipart goes to the same route
0 commit comments