++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/mq2OutputStorage.hpp

@@ -52,7 +52,7 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {
 		const size_t tries
 			= this->m_totalWritersCount / this->m_readerGroupSizes[readerGroupIndex] + 1;
 		BackoffScheme backoff(3, std::numeric_limits<std::size_t>::max());
-		for (const auto _ : std::views::iota(0U, std::numeric_limits<std::size_t>::max())) {
+		while (true) {
 			const uint8_t sequenceIndex = this->m_readersData[globalReaderIndex]->sequenceIndex++;
 			const uint8_t queueIndex
 				= this->m_readersData[globalReaderIndex]->queueJumpSequence
@@ -63,8 +63,10 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {
 			}
 			// std::this_thread::yield();
 			backoff.backoff();
+			if (finished(readerGroupIndex)) {
+				return nullptr;
+			}
 		}
-		return nullptr;
 	}
 
 	bool finished(const std::size_t readerGroupIndex) noexcept override