mirror of
https://projects.vdr-developer.org/git/vdr-plugin-streamdev.git
synced 2023-10-10 19:16:51 +02:00
412c6982b6
- increased WRITERBUFSIZE - buffer was too small for high bandwidth content - removed cStreamdevStreamer::m_Running - eliminated potential busy waits in remuxers - updated cTSRemux static helpers to code of their VDR 1.6.0 counterparts - use a copy of VDR 1.6.0's cRemux for TS to PES remuxing. - make sure that only complete TS packets are written to ringbuffers - use signaling instead of sleeps when writing to ringbuffers - optimized cStreamdevPatFilter PAT packet initialization - fixed cStreamdevPatFilter not processing PATs with length > TS_SIZE - 5 - use a small ringbuffer for cStreamdevPatFilter instead of writing to cStreamdevStreamers SendBuffer as two threads mustn't write to the same ringbuffer Modified Files: Tag: v0_4 CONTRIBUTORS HISTORY Makefile streamdev-server.c libdvbmpeg/transform.h remux/extern.c remux/extern.h remux/ts2es.c remux/ts2es.h remux/ts2ps.c remux/ts2ps.h remux/tsremux.c remux/tsremux.h server/livestreamer.c server/livestreamer.h server/streamer.c server/streamer.h Added Files: Tag: v0_4 remux/ts2pes.c remux/ts2pes.h
103 lines
2.4 KiB
C++
103 lines
2.4 KiB
C++
/*
|
|
* $Id: streamer.h,v 1.8.2.3 2009/06/29 06:25:30 schmirl Exp $
|
|
*/
|
|
|
|
#ifndef VDR_STREAMDEV_STREAMER_H
|
|
#define VDR_STREAMDEV_STREAMER_H
|
|
|
|
#include <vdr/thread.h>
|
|
#include <vdr/ringbuffer.h>
|
|
#include <vdr/tools.h>
|
|
|
|
class cTBSocket;
|
|
class cStreamdevStreamer;
|
|
|
|
#ifndef TS_SIZE
|
|
#define TS_SIZE 188
|
|
#endif
|
|
|
|
#define STREAMERBUFSIZE (20000 * TS_SIZE)
|
|
#define WRITERBUFSIZE (5000 * TS_SIZE)
|
|
|
|
// --- cStreamdevBuffer -------------------------------------------------------
|
|
|
|
class cStreamdevBuffer: public cRingBufferLinear {
|
|
public:
|
|
// make public
|
|
void WaitForPut(void) { cRingBuffer::WaitForPut(); }
|
|
// Always write complete TS packets
|
|
// (assumes Count is a multiple of TS_SIZE)
|
|
int PutTS(const uchar *Data, int Count);
|
|
cStreamdevBuffer(int Size, int Margin = 0, bool Statistics = false, const char *Description = NULL);
|
|
};
|
|
|
|
inline int cStreamdevBuffer::PutTS(const uchar *Data, int Count)
|
|
{
|
|
int free = Free();
|
|
if (free < Count)
|
|
Count = free;
|
|
|
|
Count -= Count % TS_SIZE;
|
|
if (Count)
|
|
Count = Put(Data, Count);
|
|
else
|
|
WaitForPut();
|
|
return Count;
|
|
}
|
|
|
|
// --- cStreamdevWriter -------------------------------------------------------
|
|
|
|
class cStreamdevWriter: public cThread {
|
|
private:
|
|
cStreamdevStreamer *m_Streamer;
|
|
cTBSocket *m_Socket;
|
|
|
|
protected:
|
|
virtual void Action(void);
|
|
|
|
public:
|
|
cStreamdevWriter(cTBSocket *Socket, cStreamdevStreamer *Streamer);
|
|
virtual ~cStreamdevWriter();
|
|
};
|
|
|
|
// --- cStreamdevStreamer -----------------------------------------------------
|
|
|
|
class cStreamdevStreamer: public cThread {
|
|
private:
|
|
cStreamdevWriter *m_Writer;
|
|
cStreamdevBuffer *m_RingBuffer;
|
|
cStreamdevBuffer *m_SendBuffer;
|
|
|
|
protected:
|
|
virtual void Action(void);
|
|
|
|
bool IsRunning(void) const { return m_Writer; }
|
|
|
|
public:
|
|
cStreamdevStreamer(const char *Name);
|
|
virtual ~cStreamdevStreamer();
|
|
|
|
virtual void Start(cTBSocket *Socket);
|
|
virtual void Stop(void);
|
|
bool Abort(void);
|
|
|
|
void Activate(bool On);
|
|
int Receive(uchar *Data, int Length) { return m_RingBuffer->PutTS(Data, Length); }
|
|
void ReportOverflow(int Bytes) { m_RingBuffer->ReportOverflow(Bytes); }
|
|
|
|
virtual int Put(const uchar *Data, int Count) { return m_SendBuffer->PutTS(Data, Count); }
|
|
virtual uchar *Get(int &Count) { return m_SendBuffer->Get(Count); }
|
|
virtual void Del(int Count) { m_SendBuffer->Del(Count); }
|
|
|
|
virtual void Detach(void) {}
|
|
virtual void Attach(void) {}
|
|
};
|
|
|
|
inline bool cStreamdevStreamer::Abort(void)
|
|
{
|
|
return Active() && !m_Writer->Active();
|
|
}
|
|
|
|
#endif // VDR_STREAMDEV_STREAMER_H
|
|
|