++

Author: Zainullin Damir

include/ipfixprobe/outputPlugin/outputStorage/b2OutputStorage.hpp

@@ -112,6 +112,10 @@ class B2OutputStorage : public BOutputStorage<ElementType> {
 		typename BOutputStorage<ElementType>::ReaderData& readerData
 			= this->m_readersData[readerIndex].get();
 		if (readerData.bucketAllocation.containersLeft()) {
+			__builtin_prefetch(
+				&this->getNextElement(readerData.bucketAllocation).getData() + 1,
+				PrefetchMode::Read,
+				Locality::High);
 			return &this->getNextElement(readerData.bucketAllocation).getData();
 		}
 
@@ -120,7 +124,10 @@ class B2OutputStorage : public BOutputStorage<ElementType> {
 		BackoffScheme backoffScheme(0, std::numeric_limits<std::size_t>::max());
 		do {
 			const bool overflowed = readerData.shift(this->m_expectedReadersCount, readerIndex);
-
+			__builtin_prefetch(
+				&this->m_buckets[readerData.readPosition + this->m_expectedReadersCount],
+				PrefetchMode::Write,
+				Locality::Medium);
 			if (overflowed) {
 				if (!this->writersPresent()) {
 					readerData.generation.fetch_add(1, std::memory_order_release);

include/ipfixprobe/outputPlugin/outputStorage/outputStorage.hpp

@@ -19,6 +19,10 @@
 
 namespace ipxp::output {
 
+enum class PrefetchMode : int { Read = 0, Write = 1 };
+
+enum class Locality : int { None = 0, Low = 1, Medium = 2, High = 3 };
+
 constexpr std::size_t remap(const std::size_t index) noexcept
 {
 	/*if (index > std::numeric_limits<uint16_t>::max()) {