mediapipeline.h

Go to the documentation of this file.

 
#pragma once
 
#include <atomic>
#include <promeki/core/namespace.h>
#include <promeki/core/objectbase.h>
#include <promeki/core/error.h>
#include <promeki/core/threadpool.h>
#include <promeki/proav/mediagraph.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MediaPipeline : public ObjectBase {
        PROMEKI_OBJECT(MediaPipeline, ObjectBase)
        public:
                enum State {
                        Stopped,        
                        Starting,       
                        Running,        
                        Paused,         
                        Stopping,       
                        ErrorState      
                };
 
                MediaPipeline(ObjectBase *parent = nullptr);
 
                virtual ~MediaPipeline();
 
                MediaGraph *graph() { return &_graph; }
 
                const MediaGraph *graph() const { return &_graph; }
 
                ThreadPool *threadPool() { return _threadPool; }
 
                void setThreadPool(ThreadPool *pool) { _threadPool = pool; return; }
 
                Error start();
 
                Error stop();
 
                Error pause();
 
                Error resume();
 
                State state() const { return _state; }
 
                PROMEKI_SIGNAL(stateChanged, State);
 
                PROMEKI_SIGNAL(errorOccurred, Error);
 
                PROMEKI_SIGNAL(started);
 
                PROMEKI_SIGNAL(stopped);
 
        private:
                MediaGraph              _graph;
                ThreadPool              *_threadPool = nullptr;
                ThreadPool              *_ownedPool = nullptr;
                std::atomic<State>      _state{Stopped};
                std::atomic<bool>       _running{false};
                std::atomic<bool>       _paused{false};
 
                void setState(State state);
};
 
PROMEKI_NAMESPACE_END