Skip to content

Commit dc53fd6

Browse files
committed
DPL: drop get number of pairs
1 parent 6a6a559 commit dc53fd6

File tree

2 files changed

+2
-8
lines changed

2 files changed

+2
-8
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 header-payload pairs
78-
[[nodiscard]] size_t getNumberOfPairs() const
79-
{
80-
return messages | count_payloads{};
81-
}
82-
8377
/// get number of payloads for an in-flight message
8478
[[nodiscard]] size_t getNumberOfPayloads(size_t mi) const
8579
{

Framework/Core/src/DataProcessingDevice.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2133,7 +2133,7 @@ bool DataProcessingDevice::tryDispatchComputation(ServiceRegistryRef ref, std::v
21332133
currentSetOfInputs = relayer.consumeExistingInputsForTimeslice(slot);
21342134
}
21352135
auto getter = [&currentSetOfInputs](size_t i, size_t partindex) -> DataRef {
2136-
if (currentSetOfInputs[i].getNumberOfPairs() > partindex) {
2136+
if ((currentSetOfInputs[i].messages | count_payloads{}) > partindex) {
21372137
const char* headerptr = nullptr;
21382138
const char* payloadptr = nullptr;
21392139
size_t payloadSize = 0;
@@ -2153,7 +2153,7 @@ bool DataProcessingDevice::tryDispatchComputation(ServiceRegistryRef ref, std::v
21532153
return DataRef{};
21542154
};
21552155
auto nofPartsGetter = [&currentSetOfInputs](size_t i) -> size_t {
2156-
return currentSetOfInputs[i].getNumberOfPairs();
2156+
return (currentSetOfInputs[i].messages | count_payloads{});
21572157
};
21582158
auto refCountGetter = [&currentSetOfInputs](size_t idx) -> int {
21592159
auto& header = static_cast<const fair::mq::shmem::Message&>(*(currentSetOfInputs[idx].messages | get_header{0}));

0 commit comments

Comments
 (0)