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 be3c029 commit 010ca38Copy full SHA for 010ca38
src/ConsumerFMQchannel.cxx
@@ -707,7 +707,8 @@ class ConsumerFMQchannel : public Consumer
707
if ((!isError)||(!dropEntireTFonError)) {
708
// ensure end-of-timeframe flag is set for last message
709
if (msglist->size()) {
710
- msglist->back().stfHeader->lastTFMessage = 1;
+ // TODO: add a warning + option to force set bit
711
+ //msglist->back().stfHeader->lastTFMessage = 1;
712
}
713
if (wThreads[thIx].output->push(std::move(msglist))) {
714
isError = 1;
0 commit comments