++

Zainullin Damir · Zainullin Damir · commit 4556446ee6d9 · 2026-03-15T13:41:48.000+01:00
diff --git a/include/ipfixprobe/outputPlugin/outputStorage/mqOutputStorage.hpp b/include/ipfixprobe/outputPlugin/outputStorage/mqOutputStorage.hpp
@@ -207,7 +207,8 @@ class MQOutputStorage : public OutputStorage<ElementType> {
 
 		bool allReadersFinished() const noexcept
 		{
-			return m_stateBuffer.getCurrentValue().read > m_buffersSize;
+			// TODO changed to >= from >
+			return m_stateBuffer.getCurrentValue().read >= m_buffersSize;
 		}
 
 		std::atomic<bool> m_writerFinished {false};

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,8 @@ class MQOutputStorage : public OutputStorage<ElementType> {`
`207`	`207`
`208`	`208`	`bool allReadersFinished() const noexcept`
`209`	`209`	`{`
`210`		`- return m_stateBuffer.getCurrentValue().read > m_buffersSize;`
	`210`	`+ // TODO changed to >= from >`
	`211`	`+ return m_stateBuffer.getCurrentValue().read >= m_buffersSize;`
`211`	`212`	`}`
`212`	`213`
`213`	`214`	`std::atomic<bool> m_writerFinished {false};`