threads.h

Go to the documentation of this file.

 
#ifndef __THREADS_H
#define __THREADS_H
 
#include <mutex>
#include <functional>
 
#include "vdr/thread.h"
#include "queue.h"
#include "misc.h"
#include "drmbuffer.h"
#include "queue.h"
 
class cSoftHdDevice;
class cVideoStream;
 
class cDecodingThread : public cThread
{
public:
    cDecodingThread(cVideoStream *, const char *);
    virtual ~cDecodingThread(void);
    void Stop(void);
    void Halt(void) { m_mutex.lock(); };
    void Resume(void) { m_mutex.unlock(); };
 
private:
    std::mutex m_mutex;
    cVideoStream *m_pStream;
 
protected:
    virtual void Action(void);
};
 
class cVideoRender;
 
class cDisplayThread : public cThread
{
public:
    cDisplayThread(cVideoRender *);
    virtual ~cDisplayThread(void);
    void Stop(void);
    void Halt(void) { m_mutex.lock(); };
    void Resume(void) { m_mutex.unlock(); };
 
private:
    std::mutex m_mutex;
    cVideoRender *m_pRender;
 
protected:
    virtual void Action(void);
};
 
class cSoftHdAudio;
 
class cAudioThread : public cThread
{
public:
    cAudioThread(cSoftHdAudio *);
    virtual ~cAudioThread(void);
    void Stop(void);
 
private:
    cSoftHdAudio *m_pAudio;
 
protected:
    virtual void Action(void);
};
 
class cFilterThread : public cThread
{
public:
    cFilterThread(cVideoRender *, cQueue<cDrmBuffer> *, const char *, std::function<void(AVFrame *)>);
    virtual ~cFilterThread(void);
    void InitAndStart(const AVCodecContext *, AVFrame *, bool);
    void Stop(void);
    void PushFrame(AVFrame *);
    bool IsInputBufferFull(void) { return m_frames.IsFull(); };
    int GetNumFramesToFilter(void) { return m_numFramesToFilter; };
 
private:
    cVideoRender *m_pRender;
 
    AVFilterGraph *m_pFilterGraph;
    AVFilterContext *m_pBuffersrcCtx;
    AVFilterContext *m_pBuffersinkCtx;
 
    bool m_filterBug;                               
    cQueue<AVFrame> m_frames{VIDEO_SURFACES_MAX};   
    std::function<void(AVFrame *)> m_frameOutput;   
    cQueue<cDrmBuffer> *m_pDrmBufferQueue;          
    int m_numFramesToFilter = 0;                    
 
    void Action(void);
};
 
#endif