Skip to content

Commit 1175e89

Browse files
committed
DPL: fix also getNumberOfPayloads
1 parent 4d74d84 commit 1175e89

File tree

2 files changed

+3
-9
lines changed

2 files changed

+3
-9
lines changed

Framework/Core/include/Framework/MessageSet.h

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -74,12 +74,6 @@ struct MessageSet {
7474
return *this;
7575
}
7676

77-
/// get number of payloads for an in-flight message
78-
[[nodiscard]] size_t getNumberOfPayloads(size_t mi) const
79-
{
80-
return messages | get_num_payloads{mi};
81-
}
82-
8377
/// clear the set
8478
void clear()
8579
{

Framework/Core/test/test_DataRelayer.cxx

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -738,7 +738,7 @@ TEST_CASE("DataRelayer")
738738
// payloads
739739
REQUIRE(messageSet.size() == 1);
740740
REQUIRE((messageSet[0].messages | count_parts{}) == nSplitParts);
741-
REQUIRE(messageSet[0].getNumberOfPayloads(0) == 1);
741+
REQUIRE((messageSet[0].messages | get_num_payloads{0}) == 1);
742742
}
743743

744744
SECTION("SplitPayloadSequence")
@@ -803,8 +803,8 @@ TEST_CASE("DataRelayer")
803803
REQUIRE((messageSet[0].messages | count_parts{}) == sequenceSize.size());
804804
size_t counter = 0;
805805
for (size_t seqid = 0; seqid < sequenceSize.size(); ++seqid) {
806-
REQUIRE(messageSet[0].getNumberOfPayloads(seqid) == sequenceSize[seqid]);
807-
for (size_t pi = 0; pi < messageSet[0].getNumberOfPayloads(seqid); ++pi) {
806+
REQUIRE((messageSet[0].messages | get_num_payloads{seqid}) == sequenceSize[seqid]);
807+
for (size_t pi = 0; pi < (messageSet[0].messages | get_num_payloads{seqid}); ++pi) {
808808
REQUIRE((messageSet[0].messages | get_payload{seqid, pi}));
809809
auto const* data = (messageSet[0].messages | get_payload{seqid, pi})->GetData();
810810
REQUIRE(*(reinterpret_cast<size_t const*>(data)) == counter);

0 commit comments

Comments
 (0)