File tree Expand file tree Collapse file tree
include/ipfixprobe/outputPlugin/outputStorage Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -42,11 +42,9 @@ class LFNBOutputStorage : public OutputStorage<ElementType> {
4242 bool write (ElementType* element, [[maybe_unused]] const uint8_t writerId) noexcept override
4343 {
4444 const uint64_t sequentialWritePosition = m_nextWritePos++;
45- const uint64_t writePosition = sequentialWritePosition % this ->m_storage .size ();
46- /* const bool rightCircle
47- = m_writersFinished[writePosition / BUCKET_SIZE].load(std::memory_order_acquire)
48- / BUCKET_SIZE
49- != sequentialWritePosition / ALLOCATION_BUFFER_CAPACITY;*/
45+ const uint64_t writePosition
46+ = sequentialWritePosition % OutputStorage<ElementType>::ALLOCATION_BUFFER_CAPACITY ;
47+
5048 while (m_writersFinished[writePosition / BUCKET_SIZE ].load (std::memory_order_acquire)
5149 / BUCKET_SIZE
5250 != sequentialWritePosition
You can’t perform that action at this time.
0 commit comments