MediaAdec.hpp

//
// Created by xiong on 2020/11/23.
//
 
#ifndef EMX_MEDIAADEC_HPP
#define EMX_MEDIAADEC_HPP
 
#include "media/common/MediaInfAdec.hpp"
#include "MediaParamCBase.hpp"
#include "core/EmxUtils.hpp"
namespace Emx {
    class MediaAdec : public MediaInfAdec, public MediaParamCBase<MediaInfAdec::Param> {
    public:
        explicit MediaAdec(int32_t chn) : MediaParamCBase(MediaModE::Adec, chn) {}
 
        ErrCodeE SetVolume(int32_t volume) override;
 
        ErrCodeE SetVolumeTemp(int32_t volume) override;
 
        PlayStatusE GetPlayStatus() override;
    };
 
    class MediaAdecStreamSync {
    public:
        static ErrCodeE PushFrame(int32_t chn, MediaAdec::Frame &frame, int32_t timeoutMs = 1000);
 
        static ErrCodeE PushRawPcm(int32_t chn, MediaAdec::Frame &frame, int32_t timeoutMs = 1000);
 
        static ErrCodeE PlayFile(int32_t chn, const char *path, int32_t timeoutMs = 1000);
 
        static ErrCodeE PlayFileWithVolume(int32_t chn, const char *path, int32_t volume, int32_t timeoutMs = 1000);
 
        static ErrCodeE PlayCtrlQuit(int32_t chn, bool fullInterrupt = true, int32_t timeoutMs = 1000);
    };
 
    class MediaAdecStreamSync2 {
    public:
        ErrCodeE Create() { return m_pub.Create(); }
        void Destroy() { m_pub.Destroy(); }
        ErrCodeE PushFrame(int32_t chn, MediaAdec::Frame &frame, int32_t timeoutMs = 1000);
 
        ErrCodeE PushRawPcm(int32_t chn, MediaAdec::Frame &frame, int32_t timeoutMs = 1000);
 
        ErrCodeE PlayFile(int32_t chn, const char *path, int32_t timeoutMs = 1000);
 
        ErrCodeE PlayFileWithVolume(int32_t chn, const char *path, int32_t volume, int32_t timeoutMs = 1000);
 
        ErrCodeE PlayCtrlQuit(int32_t chn, bool fullInterrupt = true, int32_t timeoutMs = 1000);
 
    private:
        MsgTopicPublisherSync2 m_pub;
    };
 
    class MediaAdecStreamAsync {
    public:
        ErrCodeE Create(EuvLoop &loop, uint32_t buffSize);
 
        ErrCodeE PushFrame(int32_t chn, MediaAdec::Frame &frame);
        ErrCodeE PushRawPcm(int32_t chn, MediaAdec::Frame &frame);
 
        void Destroy();
 
    private:
        ErrCodeE PushData(uint32_t topic, MediaAdec::Frame &frame);
 
    private:
        MsgTopicPublisherAsync m_pub;
        int m_chn;                   
        uint8_t *m_buffer;           
        uint32_t m_bufferSize;       
        uint32_t m_userSize;         
    };
}// namespace Emx
 
#endif//EMX_MEDIAADEC_HPP