MediaServerVdec.hpp

//
// Created by tfh on 2024/01/06.
//
 
#ifndef EMX_MediaServerVdec_HPP
#define EMX_MediaServerVdec_HPP
 
#include "EmxCore.hpp"
#include "MediaServerBase.hpp"
#include "media/common/MediaInfVdec.hpp"
#include "media/common/MediaRingBuffer.hpp"
 
namespace Emx {
    class MediaServerVdecChn : public MediaInfVdec, public MediaServerModuleChnBase {
    public:
        explicit MediaServerVdecChn(int32_t chn) : MediaServerModuleChnBase(MediaModE::Vdec, chn) {}
 
        ~MediaServerVdecChn() override = default;
 
        ErrCodeE LoadParam() override;
 
        ErrCodeE SaveParam() override;
 
        void *GetParam() override { return &m_param; }
 
        void *GetNewParam() override { return &m_paramNew; }
 
        void *GetRunningParam() override { return &m_paramRunning; }
 
        int GetParamSize() override { return sizeof(Param); }
 
        ErrCodeE GetParamDefaultData(std::string &data) override;
 
        ErrCodeE OnRecvReqChn(uint32_t method, const char *data, int32_t size, std::string &out) override;
 
        ErrCodeE OnServerCreate() override;
 
        void OnServerDestroy() override;
 
    protected:
        struct FrameData {
            char *data;
            uint32_t size;
            uint64_t tsInUs;
        };
        virtual ErrCodeE SendFrame(FrameData &data) = 0;
 
        virtual ErrCodeE SendFrameDecode(FrameData &data, FrameData &raw);
 
        virtual uint32_t GetVdecRawSize();
 
        ErrCodeE PushVdecData(FrameData &fData);
 
 
    protected:
        Param m_param;       
        Param m_paramNew;    
        Param m_paramRunning;
 
    public:
        MsgTopicSubscriberAsync m_sub;    
        MediaRingBufferReader m_ring;     
        MediaRingBufferWriter m_ringWrite;
 
    private:
        int m_key;            
        int m_ringBufSize;    
        int m_ringReadBufSize;
        int m_ringBusy;       
    };
 
    class MediaServerVdec : public MediaServerModuleBase {
    public:
        MediaServerVdec() : MediaServerModuleBase(MediaModE::Vdec, "vdec") {}
    };
}// namespace Emx
 
#endif//EMX_MediaServerVdec_HPP