pes.h

Go to the documentation of this file.

 
#ifndef __SOFTHDDEVICE_PES_H
#define __SOFTHDDEVICE_PES_H
 
#include <cstdint>
#include <map>
#include <vector>
 
extern "C"
{
#include <libavcodec/avcodec.h>
}
 
class cPes
{
public:
    cPes(const uint8_t *, int);
    bool IsValid();
    bool HasPts();
    int64_t GetPts();
    const uint8_t *GetPayload();
    int GetPayloadSize();
    int GetPacketLength();
    uint8_t GetStreamId() { return m_data[3]; }
 
protected:
    virtual bool IsStreamIdValid() = 0;
    void Init();
    bool IsHeaderValid();
 
    bool m_valid = false;      
    const uint8_t *m_data;     
    int m_size;                
 
    // According to H.222.0 03/2017 Table 2-21 ("PES packet") packet_start_code_prefix
    // And also according to H.264/HEVC payload
    static constexpr uint32_t PES_PACKET_START_CODE_PREFIX = 0x00'0001;
    static constexpr uint32_t PES_PACKET_START_CODE_PREFIX_LEN = 3;
};
 
class cPesVideo : public cPes {
public:
    cPesVideo(const uint8_t *data, int size) : cPes(data, size) { cPes::Init(); }
private:
    bool IsStreamIdValid() override { return (GetStreamId() & 0xF0) == 0xE0; } // Video stream IDs are in the range 0xE0-0xEF
};
 
class cPesAudio : public cPes {
public:
    cPesAudio(const uint8_t *data, int size) : cPes(data, size) { cPes::Init(); }
    bool IsAudioStreamId() { return (GetStreamId() & 0xF0) == 0xC0; } // Audio stream IDs are in the range 0xC0-0xCF
private:
    bool IsStreamIdValid() override { return IsAudioStreamId() || IsPrivateStreamId(); }
    bool IsPrivateStreamId() { return GetStreamId() == 0xBD; }
};
 
class cPtsTrackingBuffer {
public:
    cPtsTrackingBuffer(const char *identifier) : m_identifier(identifier) {}
    void Push(const uint8_t *, int, int64_t);
    void Erase(size_t);
    int64_t GetPts();
    const uint8_t *Peek() { return &m_data[0]; }
    void Reset() { m_data.clear(); m_pts.clear(); }
    int GetSize() { return m_data.size(); }
    const char *GetIdentifier() { return m_identifier; }
private:
    const char *m_identifier;
    std::map<size_t, int64_t> m_pts;     
    std::vector<uint8_t> m_data;         
};
 
class cReassemblyBuffer {
public:
    virtual void Push(const uint8_t *data, int size, int64_t pts) { m_buffer.Push(data, size, pts); }
    virtual AVPacket *PopAvPacket() = 0;
    bool IsEmpty() { return m_buffer.GetSize() == 0; }
    size_t GetSize() { return m_buffer.GetSize(); }
    void Reset();
    AVCodecID GetCodec() { return m_codec; }
protected:
    cReassemblyBuffer(const char *identifier) : m_buffer(identifier) {}
    AVPacket *PopAvPacket(int);
    AVCodecID m_codec = AV_CODEC_ID_NONE;          
    cPtsTrackingBuffer m_buffer;                   
    int64_t m_lastPoppedPts = AV_NOPTS_VALUE;      
};
 
class cReassemblyBufferVideo : public cReassemblyBuffer {
public:
    cReassemblyBufferVideo() : cReassemblyBuffer("vid") {}
    AVPacket *PopAvPacket() override { return cReassemblyBuffer::PopAvPacket(m_buffer.GetSize()); }
    bool ParseCodecHeader(const uint8_t *, int);
    bool HasLeadingZero(const uint8_t *, int);
private:
    static constexpr uint32_t VIDEO_FRAME_START_CODE = 0x00'0001;
    static constexpr int VIDEO_FRAME_START_CODE_LEN = 3;
 
    static constexpr uint8_t MPEG2_STREAM_TYPE = 0xB3;
    static constexpr uint8_t H264_STREAM_TYPE = 0x09;
    static constexpr uint8_t HEVC_STREAM_TYPE = 0x46;
};
 
struct SyncWordInfo {
    AVCodecID codecId;     
    int pos;               
};
 
class cReassemblyBufferAudio : public cReassemblyBuffer {
public:
    cReassemblyBufferAudio() : cReassemblyBuffer("AUDIO") {}
    AVPacket *PopAvPacket() override;
    AVCodecID TruncateBufferUntilFirstValidData();
    SyncWordInfo FindSyncWord(const uint8_t *, int );
    AVCodecID DetectCodecFromSyncWord(const uint8_t *, int);
    int GetFrameSizeForCodec(AVCodecID, const uint8_t *);
private:
    SyncWordInfo FindTwoConsecutiveFramesWithSameSyncWord();
    static constexpr int MAX_HEADER_SIZE = 6;
    bool m_ptsInvalid = false;   
};
 
#endif