++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/mq2OutputStorage.hpp

@@ -37,7 +37,7 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {
 		const Reference<OutputContainer<ElementType>>& container,
 		const uint8_t writerIndex) noexcept override
 	{
-		BackoffScheme backoff(3, std::numeric_limits<std::size_t>::max());
+		BackoffScheme backoff(30, std::numeric_limits<std::size_t>::max());
 		while (!this->m_queues[writerIndex].tryWrite(
 			container,
 			*this->m_allocationBuffer,
@@ -50,7 +50,7 @@ class MQ2OutputStorage : public MQOutputStorage<ElementType> {
 
 	OutputContainer<ElementType>* read(const uint8_t readerIndex) noexcept override
 	{
-		BackoffScheme backoff(3, std::numeric_limits<std::size_t>::max());
+		BackoffScheme backoff(30, std::numeric_limits<std::size_t>::max());
 		while (true) {
 			const uint8_t sequenceIndex = this->m_readersData[readerIndex]->sequenceIndex++;
 			const uint8_t queueIndex

include/ipfixprobe/outputPlugin/outputStorage/mqOutputStorage.hpp

@@ -102,7 +102,7 @@ class MQOutputStorage : public OutputStorage<ElementType> {
 	OutputContainer<ElementType>* read(const uint8_t readerIndex) noexcept override
 	{
 		const size_t tries = this->m_expectedWritersCount / this->m_expectedReadersCount + 1;
-		BackoffScheme backoff(3, 5);
+		BackoffScheme backoff(30, 3);
 		for (const auto _ : std::views::iota(0U, tries)) {
 			const uint8_t sequenceIndex = m_readersData[readerIndex]->sequenceIndex++;
 			const uint8_t queueIndex
@@ -160,7 +160,7 @@ class MQOutputStorage : public OutputStorage<ElementType> {
 			State* currentState = &m_stateBuffer.getCurrentValue();
 
 			if (currentState->written == m_buffersSize) {
-				BackoffScheme backoff(7, longBackoffTries);
+				BackoffScheme backoff(30, longBackoffTries);
 				while (!allReadersFinished()) {
 					if (!backoff.backoff()) {
 						// origin.deallocate(container, writerId);