MediaRingBuffer.hpp

//
// Created by xiong on 2021/7/30.
//
 
#ifndef EMX_MediaRingBuffer_HPP
#define EMX_MediaRingBuffer_HPP
 
#include <string>
#include "core/EmxUtils.hpp"
 
namespace Emx {
    class MediaRingBufferWriter {
    public:
        ErrCodeE Create(int32_t key, int32_t size = 0);
 
        void Destroy() { m_shm.Destroy(); }
 
        int32_t Push(char *data, int32_t size, uint32_t magicId);
 
        int32_t GetFreeBuffer(int32_t size, uint32_t magicId, char **data);
 
    private:
        Shm m_shm;
        char *m_buffer;
        int32_t m_bufferSize;
        int32_t m_off = 0;
    };
 
    class MediaRingBufferReader {
    public:
        ErrCodeE Create(int32_t key, int32_t size);
 
        void Create(int32_t key){Create(key,0);}
 
        void Destroy() { m_shm.Destroy(); }
 
        ErrCodeE Pop(int32_t off, int32_t size, uint32_t magicId, std::string &data);
 
        using OnGetBuffer = std::function<ErrCodeE(ErrCodeE e, const uint8_t *buffer, void *usr,
                                                   int32_t off, int32_t size, uint32_t magicId)>;
 
        ErrCodeE PopDirect(int32_t off, int32_t size, uint32_t magicId, OnGetBuffer cb, void *usr);
 
        bool CheckBufferIsDirty(int32_t off, int32_t size, uint32_t magicId);
 
    private:
        int32_t m_key;
        Shm m_shm;
        char *m_buffer;
        int32_t m_bufferSize;
    };
}
 
#endif //EMX_MediaRingBuffer_HPP