Streamer.hpp

Go to the documentation of this file.

#pragma once
 
#include <FAST/ProcessObject.hpp>
#include "FAST/Data/DataTypes.hpp"
#include "FAST/Exception.hpp"
#include <thread>
 
namespace fast {
 
 
class FAST_EXPORT  NoMoreFramesException : public Exception {
    public:
        explicit NoMoreFramesException(std::string message) : Exception(message) {};
};
 
class FAST_EXPORT Streamer : public ProcessObject {
    public:
        typedef std::shared_ptr<Streamer> pointer;
        Streamer();
        virtual ~Streamer() {};
        static std::string getStaticNameOfClass() {
            return "Streamer";
        }
        virtual std::string getNameOfClass() const = 0;
 
        virtual void stop();
 
        virtual void setMaximumNrOfFrames(int maximumNrOfFrames);
    protected:
        virtual void waitForFirstFrame();
 
        virtual void startStream();
 
        virtual void frameAdded();
 
        virtual void generateStream() = 0;
 
        bool m_firstFrameIsInserted = false;
        bool m_streamIsStarted = false;
        bool m_stop = false;
 
        std::mutex m_firstFrameMutex;
        std::mutex m_stopMutex;
        std::unique_ptr<std::thread> m_thread;
        std::condition_variable m_firstFrameCondition;
 
 
};
 
} // end namespace fast