++

Zainullin Damir · Zainullin Damir · commit acd842812338 · 2026-02-19T17:24:53.000+01:00
diff --git a/include/ipfixprobe/outputPlugin/outputStorage/mq2OutputStorage.hpp b/include/ipfixprobe/outputPlugin/outputStorage/mq2OutputStorage.hpp
@@ -51,7 +51,7 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {
 	{
 		const size_t tries
 			= this->m_totalWritersCount / this->m_readerGroupSizes[readerGroupIndex] + 1;
-		BackoffScheme backoff(3, 5);
+		BackoffScheme backoff(3, std::numeric_limits<std::size_t>::max());
 		for (const auto _ : std::views::iota(0U, tries)) {
 			const uint8_t sequenceIndex = this->m_readersData[globalReaderIndex]->sequenceIndex++;
 			const uint8_t queueIndex

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,7 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {`
`51`	`51`	`{`
`52`	`52`	`const size_t tries`
`53`	`53`	`= this->m_totalWritersCount / this->m_readerGroupSizes[readerGroupIndex] + 1;`
`54`		`- BackoffScheme backoff(3, 5);`
	`54`	`+ BackoffScheme backoff(3, std::numeric_limits<std::size_t>::max());`
`55`	`55`	`for (const auto _ : std::views::iota(0U, tries)) {`
`56`	`56`	`const uint8_t sequenceIndex = this->m_readersData[globalReaderIndex]->sequenceIndex++;`
`57`	`57`	`const uint8_t queueIndex`