4 friend void PutPES(uint8_t *Buffer, int Size, void *Data);
8 uint8_t *m_ResultBuffer;
12 cTS2PS(uint8_t *ResultBuffer, int *ResultCount, uint8_t AudioCid = 0x00,
16 void PutTSPacket(const uint8_t *Buffer);
19 void PutPES(uint8_t *Buffer, int Size, void *Data) {
20 cTS2PS *This = (cTS2PS*)Data;
21 if (Size <= 0 || !Buffer || !This ) {
22 esyslog("ERROR: negative size or null pointers");
25 if (*This->m_ResultCount + Size > RESULTBUFFERSIZE) {
26 esyslog("ERROR: result buffer overflow (%d + %d > %d)",
27 *This->m_ResultCount, Size, RESULTBUFFERSIZE);
28 Size = RESULTBUFFERSIZE - *This->m_ResultCount;
30 memcpy(This->m_ResultBuffer + *This->m_ResultCount, Buffer, Size);
31 *This->m_ResultCount += Size;
34 cTS2PS::cTS2PS(uint8_t *ResultBuffer, int *ResultCount, uint8_t AudioCid,
36 m_ResultBuffer = ResultBuffer;
37 m_ResultCount = ResultCount;
39 init_ipack(&m_Ipack, IPACKS, PutPES, PS);
40 m_Ipack.cid = AudioCid;
41 m_Ipack.data = (void*)this;
47 void cTS2PS::PutTSPacket(const uint8_t *Buffer) {
51 if (Buffer[1] & 0x80) { // ts error
55 if (Buffer[1] & 0x40) { // payload start
56 if (m_Ipack.plength == MMAX_PLENGTH - 6 && m_Ipack.found > 6) {
57 m_Ipack.plength = m_Ipack.found - 6;
60 reset_ipack(&m_Ipack);
66 if (Buffer[3] & 0x20) { // adaptation field?
68 if (off + 4 > TS_SIZE - 1)
72 instant_repack((uint8_t*)(Buffer + 4 + off), TS_SIZE - 4 - off, &m_Ipack);
75 cTS2PSRemux::cTS2PSRemux(int VPid, int APid1, int APid2, int DPid1,
82 m_VRemux = new cTS2PS(m_ResultBuffer, &m_ResultCount, 0x00, PS);
83 m_ARemux1 = new cTS2PS(m_ResultBuffer, &m_ResultCount, 0xC0, PS);
84 m_ARemux2 = APid2 ? new cTS2PS(m_ResultBuffer, &m_ResultCount, 0xC1, PS)
86 m_DRemux1 = DPid1 ? new cTS2PS(m_ResultBuffer, &m_ResultCount, 0x00, PS)
88 //XXX don't yet know how to tell apart primary and secondary DD data...
89 m_DRemux2 = /*XXX m_DPid2 ? new cTS2PS(m_ResultBuffer, &m_ResultCount,
90 0x00, PS) : XXX*/ NULL;
93 cTS2PSRemux::~cTS2PSRemux() {
94 if (m_DRemux2) delete m_DRemux2;
95 if (m_DRemux1) delete m_DRemux1;
96 if (m_ARemux2) delete m_ARemux2;
101 void cTS2PSRemux::PutTSPacket(int Pid, const uint8_t *Data) {
102 if (Pid == m_VPid) m_VRemux->PutTSPacket(Data);
103 else if (Pid == m_APid1) m_ARemux1->PutTSPacket(Data);
104 else if (Pid == m_APid2 && m_ARemux2) m_ARemux2->PutTSPacket(Data);
105 else if (Pid == m_DPid1 && m_DRemux1) m_DRemux1->PutTSPacket(Data);
106 else if (Pid == m_DPid2 && m_DRemux2) m_DRemux2->PutTSPacket(Data);