++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/allocationBuffer3.hpp

@@ -37,8 +37,6 @@ class AllocationBuffer3 : public AllocationBufferBase<ElementType> {
 		WriterData& writerData = m_writersData[writerIndex].get();
 		while (true) {
 			writerData.queueIndex = (writerData.queueIndex + 1) % m_queues.size();
-			const uint64_t nextQueueIndex = (writerData.queueIndex + 1) % m_queues.size();
-			m_queues[nextQueueIndex]->prefetch();
 			ElementType* res = m_queues[writerData.queueIndex]->tryPop();
 			if (res) {
 				return res;
@@ -51,8 +49,6 @@ class AllocationBuffer3 : public AllocationBufferBase<ElementType> {
 		WriterData& writerData = m_writersData[writerIndex].get();
 		while (true) {
 			writerData.queueIndex = (writerData.queueIndex + 1) % m_queues.size();
-			const uint64_t nextQueueIndex = (writerData.queueIndex + 1) % m_queues.size();
-			m_queues[nextQueueIndex]->prefetch();
 			if (m_queues[writerData.queueIndex]->tryPush(element)) {
 				return;
 			}

include/ipfixprobe/outputPlugin/outputStorage/outputStorage.hpp

@@ -28,10 +28,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(index);
 }
 
 template<typename ElementType>