vdr-plugin-streamdev/remux/ts2es.c

147 lines
2.9 KiB
C
Raw Normal View History

2004-12-30 23:43:55 +01:00
#include "remux/ts2es.h"
2005-02-11 17:44:14 +01:00
#include "server/streamer.h"
2004-12-30 23:43:55 +01:00
#include "common.h"
2005-11-06 17:43:58 +01:00
#include <vdr/device.h>
2004-12-30 23:43:55 +01:00
// from VDR's remux.c
#define MAXNONUSEFULDATA (10*1024*1024)
namespace Streamdev {
2004-12-30 23:43:55 +01:00
class cTS2ES: public ipack {
friend void PutES(uint8_t *Buffer, int Size, void *Data);
private:
2005-02-11 17:44:14 +01:00
cRingBufferLinear *m_ResultBuffer;
2004-12-30 23:43:55 +01:00
public:
2005-02-11 17:44:14 +01:00
cTS2ES(cRingBufferLinear *ResultBuffer);
2004-12-30 23:43:55 +01:00
~cTS2ES();
void PutTSPacket(const uint8_t *Buffer);
};
2005-02-11 17:44:14 +01:00
void PutES(uint8_t *Buffer, int Size, void *Data)
{
2004-12-30 23:43:55 +01:00
cTS2ES *This = (cTS2ES*)Data;
uint8_t payl = Buffer[8] + 9 + This->start - 1;
int count = Size - payl;
2005-02-11 17:44:14 +01:00
int n = This->m_ResultBuffer->Put(Buffer + payl, count);
if (n != count)
esyslog("ERROR: result buffer overflow, dropped %d out of %d byte", count - n, count);
2004-12-30 23:43:55 +01:00
This->start = 1;
}
} // namespace Streamdev
using namespace Streamdev;
2005-02-11 17:44:14 +01:00
cTS2ES::cTS2ES(cRingBufferLinear *ResultBuffer)
{
2004-12-30 23:43:55 +01:00
m_ResultBuffer = ResultBuffer;
init_ipack(this, IPACKS, PutES, 0);
data = (void*)this;
}
2005-02-11 17:44:14 +01:00
cTS2ES::~cTS2ES()
{
free_ipack(this);
2004-12-30 23:43:55 +01:00
}
void cTS2ES::PutTSPacket(const uint8_t *Buffer) {
if (!Buffer)
return;
if (Buffer[1] & 0x80) { // ts error
// TODO
}
if (Buffer[1] & 0x40) { // payload start
if (plength == MMAX_PLENGTH - 6) {
plength = found - 6;
found = 0;
send_ipack(this);
reset_ipack(this);
}
}
uint8_t off = 0;
if (Buffer[3] & 0x20) { // adaptation field?
off = Buffer[4] + 1;
if (off + 4 > TS_SIZE - 1)
return;
}
instant_repack((uint8_t*)(Buffer + 4 + off), TS_SIZE - 4 - off, this);
}
cTS2ESRemux::cTS2ESRemux(int Pid):
2005-02-11 17:44:14 +01:00
m_Pid(Pid),
m_ResultBuffer(new cStreamdevBuffer(WRITERBUFSIZE, IPACKS)),
2005-02-11 17:44:14 +01:00
m_Remux(new cTS2ES(m_ResultBuffer))
{
m_ResultBuffer->SetTimeouts(100, 100);
2004-12-30 23:43:55 +01:00
}
2005-02-11 17:44:14 +01:00
cTS2ESRemux::~cTS2ESRemux()
{
2004-12-30 23:43:55 +01:00
delete m_Remux;
2005-02-11 17:44:14 +01:00
delete m_ResultBuffer;
2004-12-30 23:43:55 +01:00
}
2005-02-11 17:44:14 +01:00
int cTS2ESRemux::Put(const uchar *Data, int Count)
{
int used = 0;
// Make sure we are looking at a TS packet:
while (Count > TS_SIZE) {
if (Data[0] == TS_SYNC_BYTE && Data[TS_SIZE] == TS_SYNC_BYTE)
break;
Data++;
Count--;
used++;
}
if (used)
esyslog("ERROR: skipped %d byte to sync on TS packet", used);
// Convert incoming TS data into ES:
for (int i = 0; i < Count; i += TS_SIZE) {
if (Count - i < TS_SIZE)
break;
if (Data[i] != TS_SYNC_BYTE)
break;
if (m_ResultBuffer->Free() < 2 * IPACKS) {
m_ResultBuffer->WaitForPut();
2005-02-11 17:44:14 +01:00
break; // A cTS2ES might write one full packet and also a small rest
}
2005-02-11 17:44:14 +01:00
int pid = cTSRemux::GetPid(Data + i + 1);
if (Data[i + 3] & 0x10) { // got payload
if (m_Pid == pid)
m_Remux->PutTSPacket(Data + i);
}
used += TS_SIZE;
}
/*
// Check if we're getting anywhere here:
if (!synced && skipped >= 0) {
if (skipped > MAXNONUSEFULDATA) {
esyslog("ERROR: no useful data seen within %d byte of video stream", skipped);
skipped = -1;
if (exitOnFailure)
cThread::EmergencyExit(true);
}
else
skipped += used;
}
*/
return used;
2004-12-30 23:43:55 +01:00
}