QueuedDataChannel.hpp

Go to the documentation of this file.

#pragma once
 
#include <FAST/DataChannels/DataChannel.hpp>
#include <queue>
#include <FAST/Semaphore.hpp>
 
namespace fast {
 
class FAST_EXPORT QueuedDataChannel : public DataChannel {
    FAST_OBJECT(QueuedDataChannel)
    public:
        void addFrame(DataObject::pointer data) override;
 
        int getSize() override;
 
        void setMaximumNumberOfFrames(uint frames) override;
 
        void stop() override;
 
        // TODO consider removing, it is equal to getSize() > 0 atm
        bool hasCurrentData() override;
 
        DataObject::pointer getFrame() override;
    protected:
        std::queue<std::shared_ptr<DataObject>> m_queue;
        uint mMaximumNumberOfFrames;
        std::unique_ptr<LightweightSemaphore> m_fillCount;
        std::unique_ptr<LightweightSemaphore> m_emptyCount;
 
        DataObject::pointer getNextDataFrame() override;
        QueuedDataChannel();
 
};
 
}