++

Zainullin Damir · Zainullin Damir · commit c4c39925116c · 2026-02-15T15:01:01.000+01:00
diff --git a/include/ipfixprobe/outputPlugin/outputStorage/ffqOutputStorage.hpp b/include/ipfixprobe/outputPlugin/outputStorage/ffqOutputStorage.hpp
@@ -69,10 +69,9 @@ class FFQOutputStorage : public OutputStorage {
 
 	bool finished(const std::size_t readerGroupIndex) noexcept override
 	{
-		return !writersPresent() &&
-			// m_readRanks[readerGroupIndex].get() % ALLOCATION_BUFFER_CAPACITY
-			//== m_writeRank.load() % ALLOCATION_BUFFER_CAPACITY;
-			m_readRanks[readerGroupIndex].get() > m_writeRank.load();
+		return !writersPresent()
+			&& m_readRanks[readerGroupIndex].get() % ALLOCATION_BUFFER_CAPACITY
+			== m_writeRank.load() % ALLOCATION_BUFFER_CAPACITY;
 	}
 
 protected:

Original file line number	Diff line number	Diff line change
`@@ -69,10 +69,9 @@ class FFQOutputStorage : public OutputStorage {`
`69`	`69`
`70`	`70`	`bool finished(const std::size_t readerGroupIndex) noexcept override`
`71`	`71`	`{`
`72`		`- return !writersPresent() &&`
`73`		`- // m_readRanks[readerGroupIndex].get() % ALLOCATION_BUFFER_CAPACITY`
`74`		`- //== m_writeRank.load() % ALLOCATION_BUFFER_CAPACITY;`
`75`		`- m_readRanks[readerGroupIndex].get() > m_writeRank.load();`
	`72`	`+ return !writersPresent()`
	`73`	`+ && m_readRanks[readerGroupIndex].get() % ALLOCATION_BUFFER_CAPACITY`
	`74`	`+ == m_writeRank.load() % ALLOCATION_BUFFER_CAPACITY;`
`76`	`75`	`}`
`77`	`76`
`78`	`77`	`protected:`