++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/b2OutputStorage.hpp

@@ -151,7 +151,7 @@ class B2OutputStorage : public BOutputStorage<ElementType> {
 				std::memory_order_acquire);
 			// std::atomic_thread_fence(std::memory_order_acquire);
 			cachedBucketIndex = this->m_buckets[readerData.readPosition].bucketIndex;
-			if (cachedGeneration >= readerData.generation.load(std::memory_order_acquire) + 2) {
+			if (cachedGeneration > readerData.generation.load(std::memory_order_acquire)) {
 				readerData.seenValidBucket = true;
 			}
 		} while (cachedGeneration != readerData.generation.load(std::memory_order_acquire)

include/ipfixprobe/outputPlugin/outputStorage/bOutputStorage.hpp

@@ -218,7 +218,7 @@ class BOutputStorage : public OutputStorage<ElementType> {
 			// std::atomic_thread_fence(std::memory_order_acquire);
 			cachedBucketIndex = m_buckets[readerData.readPosition].bucketIndex;
 			// if (cachedGeneration >= readerData.generation + WINDOW_SIZE) {
-			if (cachedGeneration >= readerData.generation.load(std::memory_order_acquire) + 2) {
+			if (cachedGeneration > readerData.generation.load(std::memory_order_acquire)) {
 				// std::cout << "Shto\n";
 				readerData.seenValidBucket = true;
 			}