MediaServer.hpp

//
// Created by xiong on 2020/10/27.
//
 
#ifndef EMX_MEDIASERVER_HPP
#define EMX_MEDIASERVER_HPP
 
#include "EmxCore.hpp"
#include "media/common/MediaTypedef.hpp"
#include "media/server/MediaServerBase.hpp"
namespace Emx {
    class MediaServerCtx;
 
    class MediaFactory;
 
    class MediaServer {
    public:
        MediaServer();
 
        virtual ~MediaServer() {}
 
        using OnCreated = std::function<void()>;
 
        void Create(OnCreated cb, MediaFactory *factory);
 
        void Destroy();
 
    private:
        ErrCodeE OnRecvReq(uint32_t module, uint32_t method, int32_t chn, const char *data, int32_t size,
                std::string &out);
 
    protected:
        virtual ErrCodeE OnRecvReqSub(uint32_t module, uint32_t method, int chn, const char *data, int32_t size,
                std::string &out) {
            return ErrCodeE::OperationNotSupport;
        }
 
    private:
        void RunRpc();
 
        void RunTopic();
 
    private:
        MediaServerCtx *m_ctx;
        MsgRpcRep m_resp;
        OnCreated m_cb;
        EuvTimer m_timer;
    };
}// namespace Emx
 
#endif//EMX_MEDIASERVER_HPP