DataChannel.hpp

Go to the documentation of this file.

#pragma once
 
#include <FAST/Data/DataObject.hpp>
#include <FAST/Data/DataTypes.hpp>
 
namespace fast {
 
class ProcessObject;
 
class FAST_EXPORT DataChannel : public Object {
    public:
        typedef std::shared_ptr<DataChannel> pointer;
 
        virtual void addFrame(DataObject::pointer data) = 0;
 
        template <class T = DataObject>
        std::shared_ptr<T> getNextFrame();
 
        virtual int getSize() = 0;
 
        virtual void setMaximumNumberOfFrames(uint frames) = 0;
 
        virtual void stop() = 0;
 
        // TODO consider removing, it is equal to getSize() > 0 atm
        virtual bool hasCurrentData() = 0;
 
        virtual DataObject::pointer getFrame() = 0;
 
        std::shared_ptr<ProcessObject> getProcessObject() const;
        void setProcessObject(std::shared_ptr<ProcessObject> po);
    protected:
        bool m_stop;
        std::mutex m_mutex;
        std::shared_ptr<ProcessObject> m_processObject;
 
        virtual DataObject::pointer getNextDataFrame() = 0;
        DataChannel();
};
 
// Template specialization when T = DataObject
template <>
FAST_EXPORT std::shared_ptr<DataObject> DataChannel::getNextFrame<DataObject>();
 
template <class T>
std::shared_ptr<T> DataChannel::getNextFrame() {
    auto data = getNextDataFrame();
    auto convertedData = std::dynamic_pointer_cast<T>(data);
    // Check if the conversion went ok
    if(!convertedData)
        throw BadCastException(data->getNameOfClass(), T::getStaticNameOfClass());
    return convertedData;
}
 
}