Skip to content

Commit 95cc804

Browse files
authored
Fix chaining of expendable devices (#13405)
Obviously for forward channels we need to get the correct channel information. This probably addresses https://its.cern.ch/jira/browse/O2-5018
1 parent 682335a commit 95cc804

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

Framework/Core/include/Framework/ChannelInfo.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -97,6 +97,7 @@ struct ForwardChannelInfo {
9797

9898
struct ForwardChannelState {
9999
TimesliceId oldestForChannel = {0};
100+
int64_t droppedMessages = 0;
100101
};
101102

102103
} // namespace o2::framework

Framework/Core/src/SendingPolicy.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ std::vector<ForwardingPolicy> ForwardingPolicy::createDefaultPolicies()
174174
.forward = [](fair::mq::Parts& parts, ChannelIndex channelIndex, ServiceRegistryRef registry) {
175175
auto &proxy = registry.get<FairMQDeviceProxy>();
176176
auto *channel = proxy.getForwardChannel(channelIndex);
177-
OutputChannelState& state = proxy.getOutputChannelState(channelIndex);
177+
ForwardChannelState& state = proxy.getForwardChannelState(channelIndex);
178178
auto timeout = 1000;
179179
if (state.droppedMessages > 0) {
180180
timeout = 0;

0 commit comments

Comments
 (0)