++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/outputStorage.hpp

@@ -24,10 +24,10 @@ constexpr std::size_t remap(const std::size_t index) noexcept
 	/*if (index > std::numeric_limits<uint16_t>::max()) {
 		throw std::runtime_error("ZZZz");
 	}*/
-	// return index;
-	return index * 27644437;
-	//  return ~index;
-	// return std::byteswap(static_cast<uint16_t>(index));
+	return index;
+	// return index * 27644437;
+	//   return ~index;
+	//  return std::byteswap(static_cast<uint16_t>(index));
 }
 
 template<typename ElementType>

include/ipfixprobe/outputPlugin/outputStorage/outputStorageRegistrar.hpp

@@ -26,7 +26,7 @@ class OutputStorageRegistrar {
 		m_storages = std::make_shared<std::shared_ptr<OutputStorage<ElementType>>[]>(
 			OutputStorage<ElementType>::MAX_READER_GROUPS_COUNT);
 		m_allocationBuffer
-			= std::make_shared<AllocationBufferR<ReferenceCounter<OutputContainer<ElementType>>>>(
+			= std::make_shared<AllocationBuffer3<ReferenceCounter<OutputContainer<ElementType>>>>(
 				OutputStorage<ElementType>::STORAGE_CAPACITY
 					* OutputStorage<ElementType>::MAX_READER_GROUPS_COUNT,
 				writersCount);

include/ipfixprobe/outputPlugin/outputStorage/spinlock.hpp

@@ -17,7 +17,7 @@ class Spinlock {
 	{
 		BackoffScheme backoffScheme(20, std::numeric_limits<std::size_t>::max());
 		while (true) {
-			while (flag.test(std::memory_order_relaxed)) {
+			while (flag.test(std::memory_order_acquire)) {
 				backoffScheme.backoff();
 			}
 			if (!flag.test_and_set(std::memory_order_acquire)) {

tests/performance/outputStorage/testOutputStorage.cpp

@@ -294,7 +294,7 @@ TEST(TestOutputStorage, Debug)
 {
 	for (const auto testIndex : std::views::iota(0, 100)) {
 		std::cout << " Debug Loop Iteration " << testIndex << "\n";
-		makeTest<ipxp::output::FFQ2OutputStorage<void*>>(32, {8, 8, 8, 8}, false, 2'000'000);
+		makeTest<ipxp::output::BOutputStorage<void*>>(32, {32}, false, 10'000'000);
 	}
 }