Disruptor.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorBarriers.h"
#include "DisruptorElement.h"
#include "catapult/model/Block.h"
#include "catapult/model/EntityRange.h"
#include "catapult/utils/CircularBuffer.h"
#include "catapult/utils/NonCopyable.h"
#include <vector>
 
namespace catapult { namespace disruptor {
 
    class Disruptor : utils::NonCopyable {
    public:
        explicit Disruptor(size_t disruptorSize, size_t elementTraceInterval = 1);
 
    public:
        DisruptorElementId add(ConsumerInput&& input, const ProcessingCompleteFunc& processingComplete);
 
        void markSkipped(PositionType position, CompletionCode code);
 
        bool isSkipped(PositionType position) const;
 
        inline DisruptorElement& elementAt(PositionType position) {
            return m_container[position];
        }
 
        inline size_t size() const {
            return m_container.size();
        }
 
        inline size_t capacity() const {
            return m_container.capacity();
        }
 
        inline uint64_t added() const {
            return m_allElementsCount;
        }
 
    private:
        size_t m_elementTraceInterval;
        utils::CircularBuffer<DisruptorElement> m_container;
        std::atomic<uint64_t> m_allElementsCount;
    };
}}