Skip to content

Commit 617bd67

Browse files
committed
DPL: drop get number of pairs
1 parent 86f78a1 commit 617bd67

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
@@ -2131,7 +2131,7 @@ bool DataProcessingDevice::tryDispatchComputation(ServiceRegistryRef ref, std::v
21312131
currentSetOfInputs = relayer.consumeExistingInputsForTimeslice(slot);
21322132
}
21332133
auto getter = [&currentSetOfInputs](size_t i, size_t partindex) -> DataRef {
2134-
if (currentSetOfInputs[i].getNumberOfPairs() > partindex) {
2134+
if ((currentSetOfInputs[i].messages | count_payloads{}) > partindex) {
21352135
const char* headerptr = nullptr;
21362136
const char* payloadptr = nullptr;
21372137
size_t payloadSize = 0;
@@ -2151,7 +2151,7 @@ bool DataProcessingDevice::tryDispatchComputation(ServiceRegistryRef ref, std::v
21512151
return DataRef{};
21522152
};
21532153
auto nofPartsGetter = [&currentSetOfInputs](size_t i) -> size_t {
2154-
return currentSetOfInputs[i].getNumberOfPairs();
2154+
return (currentSetOfInputs[i].messages | count_payloads{});
21552155
};
21562156
auto refCountGetter = [&currentSetOfInputs](size_t idx) -> int {
21572157
auto& header = static_cast<const fair::mq::shmem::Message&>(*(currentSetOfInputs[idx].messages | get_header{0}));

0 commit comments

Comments
 (0)