We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7d94766 commit 7f2f550Copy full SHA for 7f2f550
src/ConsumerFMQchannel.cxx
@@ -703,10 +703,12 @@ class ConsumerFMQchannel : public Consumer
703
if (dropEntireTFonError) break;
704
}
705
706
- // ensure end-of-timeframe flag is set for last message
707
- msglist->back().stfHeader->lastTFMessage = 1;
708
// send msg
709
if ((!isError)||(!dropEntireTFonError)) {
+ // ensure end-of-timeframe flag is set for last message
+ if (msglist->size()) {
710
+ msglist->back().stfHeader->lastTFMessage = 1;
711
+ }
712
if (wThreads[thIx].output->push(std::move(msglist))) {
713
isError = 1;
714
} else {
0 commit comments