++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/ffq2OutputStorage.hpp

@@ -69,6 +69,7 @@ class FFQ2OutputStorage : public FFQOutputStorage<ElementType> {
 		while (!this->m_cells[readIndex].state.tryToSetReadingStarted()) {
 			backoffScheme.backoff();
 		}
+
 		// std::atomic_thread_fence(std::memory_order_acquire);
 		this->m_readersData[readerIndex]->lastReadIndex = readIndex;
 		/*if (this->m_storage[readIndex].empty()) {

include/ipfixprobe/outputPlugin/outputStorage/ffqOutputStorage.hpp

@@ -160,8 +160,8 @@ class FFQOutputStorage : public OutputStorage<ElementType> {
 
 		// std::atomic<uint64_t> m_startedState;
 		// std::atomic<uint64_t> m_finishedState;
-		std::atomic<bool> m_readingStarted {false};
-		std::atomic<bool> m_readingFinished {false};
+		std::atomic<bool> m_readingStarted {true};
+		std::atomic<bool> m_readingFinished {true};
 		std::atomic<bool> m_writingStarted {false};
 	};
 
@@ -174,7 +174,7 @@ class FFQOutputStorage : public OutputStorage<ElementType> {
 	};
 
 	struct ReaderData {
-		std::optional<uint16_t> lastReadIndex {0};
+		std::optional<uint16_t> lastReadIndex {};
 	};
 
 	std::array<CacheAlligned<ReaderData>, OutputStorage<ElementType>::MAX_READERS_COUNT>

include/ipfixprobe/outputPlugin/outputStorage/outputStorage.hpp

@@ -70,7 +70,10 @@ class OutputStorage {
 		m_writersCount--;
 	}
 
-	bool writersPresent() const noexcept { return m_writersCount > 0; }
+	bool writersPresent() const noexcept
+	{
+		return m_writersCount.load(std::memory_order_acquire) > 0;
+	}
 
 	virtual bool finished() noexcept = 0;