MPEG_TS_encode.h

#pragma once
 
#include "Base.h"
#include "IVideoDecoder.h"
 
#include <functional>
 
namespace Cogs::Core{
 
typedef std::function<void(uint8_t *data, size_t size)> TSEncodeCallback;
 
struct MPEGTransportStreamEncoder{
  void COGSCORE_DLL_API SendNullPacket();
  void COGSCORE_DLL_API SendProgramAssociationTable();
  void COGSCORE_DLL_API SendProgramMapTable(Codec codec);
  void COGSCORE_DLL_API SendPES(const uint8_t* dat, size_t size, size_t &written, uint64_t timestamp, bool use_timestamp, bool is_idr);
 
  void COGSCORE_DLL_API Write(const void* buffer, size_t size, uint64_t timestamp, bool is_idr);
 
  void WriteBuffer(uint8_t *data, uint32_t size);
  void FlushBuffer();
 
  uint8_t buffer[2048] = {};
  uint32_t buffer_size = 1500; // UDP packet size
  uint32_t used = 0;
 
  TSEncodeCallback callback;
 
  uint32_t continuity_counter = 0;
};
 
}// namespace ...