#include "channels.h"
#include "tools.h"

Classes
class	cRemux

class	cTsPayload

class	cPatPmtGenerator

class	cPatPmtParser

class	cEitGenerator

class	cTsToPes

class	cFrameDetector

Macros
#define	TS_SYNC_BYTE 0x47

#define	TS_SIZE 188

#define	TS_ERROR 0x80

#define	TS_PAYLOAD_START 0x40

#define	TS_TRANSPORT_PRIORITY 0x20

#define	TS_PID_MASK_HI 0x1F

#define	TS_SCRAMBLING_CONTROL 0xC0

#define	TS_ADAPT_FIELD_EXISTS 0x20

#define	TS_PAYLOAD_EXISTS 0x10

#define	TS_CONT_CNT_MASK 0x0F

#define	TS_ADAPT_DISCONT 0x80

#define	TS_ADAPT_RANDOM_ACC 0x40

#define	TS_ADAPT_ELEM_PRIO 0x20

#define	TS_ADAPT_PCR 0x10

#define	TS_ADAPT_OPCR 0x08

#define	TS_ADAPT_SPLICING 0x04

#define	TS_ADAPT_TP_PRIVATE 0x02

#define	TS_ADAPT_EXTENSION 0x01

#define	PATPID 0x0000

#define	CATPID 0x0001

#define	EITPID 0x0012

#define	MAXPID 0x2000

#define	PTSTICKS 90000

#define	PCRFACTOR 300

#define	MAX33BIT 0x00000001FFFFFFFFLL

#define	MAX27MHZ ((MAX33BIT + 1) * PCRFACTOR - 1)

#define	TS_SYNC(Data, Length) (*Data == TS_SYNC_BYTE ? 0 : TsSync(Data, Length, __FILE__, __FUNCTION__, __LINE__))

#define	MAX_SECTION_SIZE 4096

#define	MAX_PMT_TS (MAX_SECTION_SIZE / TS_SIZE + 1)

#define	MAX_PMT_PIDS 32

#define	MIN_TS_PACKETS_FOR_FRAME_DETECTOR 100

Enumerations
enum	ePesHeader { phNeedMoreData = -1 , phInvalid = 0 , phMPEG1 = 1 , phMPEG2 = 2 , phNeedMoreData = -1 , phInvalid = 0 , phMPEG1 = 1 , phMPEG2 = 2 }

Functions
ePesHeader	AnalyzePesHeader (const uchar Data, int Count, int &PesPayloadOffset, bool ContinuationHeader=NULL)

bool	TsHasPayload (const uchar *p)

bool	TsHasAdaptationField (const uchar *p)

bool	TsPayloadStart (const uchar *p)

bool	TsError (const uchar *p)

int	TsPid (const uchar *p)

void	TsSetPid (uchar *p, int Pid)

bool	TsIsScrambled (const uchar *p)

uchar	TsContinuityCounter (const uchar *p)

void	TsSetContinuityCounter (uchar *p, uchar Counter)

int	TsPayloadOffset (const uchar *p)

int	TsGetPayload (const uchar **p)

int64_t	TsGetPcr (const uchar *p)

void	TsHidePayload (uchar *p)

void	TsSetPcr (uchar *p, int64_t Pcr)

int	TsSync (const uchar Data, int Length, const char File=NULL, const char *Function=NULL, int Line=0)

int64_t	TsGetPts (const uchar *p, int l)

int64_t	TsGetDts (const uchar *p, int l)

void	TsSetPts (uchar *p, int l, int64_t Pts)

void	TsSetDts (uchar *p, int l, int64_t Dts)

bool	PesLongEnough (int Length)

bool	PesHasLength (const uchar *p)

int	PesLength (const uchar *p)

int	PesPayloadOffset (const uchar *p)

bool	PesHasPts (const uchar *p)

bool	PesHasDts (const uchar *p)

int64_t	PesGetPts (const uchar *p)

int64_t	PesGetDts (const uchar *p)

void	PesSetPts (uchar *p, int64_t Pts)

void	PesSetDts (uchar *p, int64_t Dts)

int64_t	PtsAdd (int64_t Pts1, int64_t Pts2)

int64_t	PtsDiff (int64_t Pts1, int64_t Pts2)

void	BlockDump (const char Name, const u_char Data, int Length)

void	TsDump (const char Name, const u_char Data, int Length)

void	PesDump (const char Name, const u_char Data, int Length)

Macro Definition Documentation

◆ CATPID

#define CATPID 0x0001

Definition at line 53 of file remux.h.

◆ EITPID

#define EITPID 0x0012

Definition at line 54 of file remux.h.

◆ MAX27MHZ

#define MAX27MHZ ((MAX33BIT + 1) * PCRFACTOR - 1)

Definition at line 60 of file remux.h.

◆ MAX33BIT

#define MAX33BIT 0x00000001FFFFFFFFLL

Definition at line 59 of file remux.h.

◆ MAX_PMT_PIDS

#define MAX_PMT_PIDS 32

Definition at line 351 of file remux.h.

◆ MAX_PMT_TS

#define MAX_PMT_TS (MAX_SECTION_SIZE / TS_SIZE + 1)

Definition at line 296 of file remux.h.

◆ MAX_SECTION_SIZE

#define MAX_SECTION_SIZE 4096

Definition at line 295 of file remux.h.

◆ MAXPID

#define MAXPID 0x2000

Definition at line 55 of file remux.h.

◆ MIN_TS_PACKETS_FOR_FRAME_DETECTOR

#define MIN_TS_PACKETS_FOR_FRAME_DETECTOR 100

Definition at line 503 of file remux.h.

◆ PATPID

#define PATPID 0x0000

Definition at line 52 of file remux.h.

◆ PCRFACTOR

#define PCRFACTOR 300

Definition at line 58 of file remux.h.

◆ PTSTICKS

#define PTSTICKS 90000

Definition at line 57 of file remux.h.

◆ TS_ADAPT_DISCONT

#define TS_ADAPT_DISCONT 0x80

Definition at line 43 of file remux.h.

◆ TS_ADAPT_ELEM_PRIO

#define TS_ADAPT_ELEM_PRIO 0x20

Definition at line 45 of file remux.h.

◆ TS_ADAPT_EXTENSION

#define TS_ADAPT_EXTENSION 0x01

Definition at line 50 of file remux.h.

◆ TS_ADAPT_FIELD_EXISTS

#define TS_ADAPT_FIELD_EXISTS 0x20

Definition at line 40 of file remux.h.

◆ TS_ADAPT_OPCR

#define TS_ADAPT_OPCR 0x08

Definition at line 47 of file remux.h.

◆ TS_ADAPT_PCR

#define TS_ADAPT_PCR 0x10

Definition at line 46 of file remux.h.

◆ TS_ADAPT_RANDOM_ACC

#define TS_ADAPT_RANDOM_ACC 0x40

Definition at line 44 of file remux.h.

◆ TS_ADAPT_SPLICING

#define TS_ADAPT_SPLICING 0x04

Definition at line 48 of file remux.h.

◆ TS_ADAPT_TP_PRIVATE

#define TS_ADAPT_TP_PRIVATE 0x02

Definition at line 49 of file remux.h.

◆ TS_CONT_CNT_MASK

#define TS_CONT_CNT_MASK 0x0F

Definition at line 42 of file remux.h.

◆ TS_ERROR

#define TS_ERROR 0x80

Definition at line 35 of file remux.h.

◆ TS_PAYLOAD_EXISTS

#define TS_PAYLOAD_EXISTS 0x10

Definition at line 41 of file remux.h.

◆ TS_PAYLOAD_START

#define TS_PAYLOAD_START 0x40

Definition at line 36 of file remux.h.

◆ TS_PID_MASK_HI

#define TS_PID_MASK_HI 0x1F

Definition at line 38 of file remux.h.

◆ TS_SCRAMBLING_CONTROL

#define TS_SCRAMBLING_CONTROL 0xC0

Definition at line 39 of file remux.h.

◆ TS_SIZE

#define TS_SIZE 188

Definition at line 34 of file remux.h.

◆ TS_SYNC

#define TS_SYNC	(	Data,
		Length
	)	(*Data == TS_SYNC_BYTE ? 0 : TsSync(Data, Length, __FILE__, __FUNCTION__, __LINE__))

Definition at line 149 of file remux.h.

◆ TS_SYNC_BYTE

#define TS_SYNC_BYTE 0x47

Definition at line 33 of file remux.h.

◆ TS_TRANSPORT_PRIORITY

#define TS_TRANSPORT_PRIORITY 0x20

Definition at line 37 of file remux.h.

Enumeration Type Documentation

◆ ePesHeader

enum ePesHeader

Enumerator
phNeedMoreData
phInvalid
phMPEG1
phMPEG2
phNeedMoreData
phInvalid
phMPEG1
phMPEG2

Definition at line 16 of file remux.h.

Function Documentation

◆ AnalyzePesHeader()

ePesHeader AnalyzePesHeader	(	const uchar *	Data,
		int	Count,
		int &	PesPayloadOffset,
		bool *	ContinuationHeader = `NULL`
	)

Definition at line 32 of file remux.c.

Referenced by cRemux::SetBrokenLink().

◆ BlockDump()

void BlockDump	(	const char *	Name,
		const u_char *	Data,
		int	Length
	)

Definition at line 1138 of file remux.c.

◆ PesDump()

void PesDump	(	const char *	Name,
		const u_char *	Data,
		int	Length
	)

Definition at line 1164 of file remux.c.

◆ PesGetDts()

int64_t PesGetDts ( const uchar * p )

inline

Definition at line 202 of file remux.h.

◆ PesGetPts()

int64_t PesGetPts ( const uchar * p )

inline

Definition at line 193 of file remux.h.

◆ PesHasDts()

bool PesHasDts ( const uchar * p )

inline

Definition at line 188 of file remux.h.

◆ PesHasLength()

bool PesHasLength ( const uchar * p )

inline

Definition at line 168 of file remux.h.

◆ PesHasPts()

bool PesHasPts ( const uchar * p )

inline

Definition at line 183 of file remux.h.

◆ PesLength()

int PesLength ( const uchar * p )

inline

Definition at line 173 of file remux.h.

◆ PesLongEnough()

bool PesLongEnough ( int Length )

inline

Definition at line 163 of file remux.h.

◆ PesPayloadOffset()

int PesPayloadOffset ( const uchar * p )

inline

Definition at line 178 of file remux.h.

◆ PesSetDts()

void PesSetDts	(	uchar *	p,
		int64_t	Dts
	)

Definition at line 225 of file remux.c.

Referenced by TsSetDts().

◆ PesSetPts()

void PesSetPts	(	uchar *	p,
		int64_t	Pts
	)

Definition at line 216 of file remux.c.

Referenced by TsSetPts().

◆ PtsAdd()

int64_t PtsAdd	(	int64_t	Pts1,
		int64_t	Pts2
	)

inline

Adds the given PTS values, taking into account the 33bit wrap around.

Definition at line 216 of file remux.h.

References MAX33BIT.

◆ PtsDiff()

int64_t PtsDiff	(	int64_t	Pts1,
		int64_t	Pts2
	)

Returns the difference between two PTS values.

The result of Pts2 - Pts1 is the actual number of 90kHz time ticks that pass from Pts1 to Pts2, properly taking into account the 33bit wrap around. If Pts2 is "before" Pts1, the result is negative.

Definition at line 234 of file remux.c.

◆ TsContinuityCounter()

uchar TsContinuityCounter ( const uchar * p )

inline

Definition at line 98 of file remux.h.

References TS_CONT_CNT_MASK.

◆ TsDump()

void TsDump	(	const char *	Name,
		const u_char *	Data,
		int	Length
	)

Definition at line 1149 of file remux.c.

Referenced by PesDump().

◆ TsError()

bool TsError ( const uchar * p )

inline

Definition at line 77 of file remux.h.

References TS_ERROR.

◆ TsGetDts()

int64_t TsGetDts	(	const uchar *	p,
		int	l
	)

Definition at line 173 of file remux.c.

◆ TsGetPayload()

int TsGetPayload ( const uchar ** p )

inline

Definition at line 114 of file remux.h.

References TS_SIZE, TsHasPayload(), and TsPayloadOffset().

◆ TsGetPcr()

int64_t TsGetPcr ( const uchar * p )

inline

Definition at line 124 of file remux.h.

References PCRFACTOR, TS_ADAPT_PCR, and TsHasAdaptationField().

◆ TsGetPts()

int64_t TsGetPts	(	const uchar *	p,
		int	l
	)

Definition at line 160 of file remux.c.

◆ TsHasAdaptationField()

bool TsHasAdaptationField ( const uchar * p )

inline

Definition at line 67 of file remux.h.

References TS_ADAPT_FIELD_EXISTS.

Referenced by TsGetPcr(), and TsPayloadOffset().

◆ TsHasPayload()

bool TsHasPayload ( const uchar * p )

inline

Definition at line 62 of file remux.h.

References TS_PAYLOAD_EXISTS.

Referenced by TsGetPayload().

◆ TsHidePayload()

void TsHidePayload ( uchar * p )

Definition at line 121 of file remux.c.

◆ TsIsScrambled()

bool TsIsScrambled ( const uchar * p )

inline

Definition at line 93 of file remux.h.

References TS_SCRAMBLING_CONTROL.

◆ TsPayloadOffset()

int TsPayloadOffset ( const uchar * p )

inline

Definition at line 108 of file remux.h.

References TS_SIZE, and TsHasAdaptationField().

Referenced by TsGetPayload().

◆ TsPayloadStart()

bool TsPayloadStart ( const uchar * p )

inline

Definition at line 72 of file remux.h.

References TS_PAYLOAD_START.

Referenced by cTsPayload::AtPayloadStart().

◆ TsPid()

int TsPid ( const uchar * p )

inline

Definition at line 82 of file remux.h.

References TS_PID_MASK_HI.

Referenced by cTsPayload::AtPayloadStart().

◆ TsSetContinuityCounter()

void TsSetContinuityCounter	(	uchar *	p,
		uchar	Counter
	)

inline

Definition at line 103 of file remux.h.

References TS_CONT_CNT_MASK.

◆ TsSetDts()

void TsSetDts	(	uchar *	p,
		int	l,
		int64_t	Dts
	)

Definition at line 200 of file remux.c.

◆ TsSetPcr()

void TsSetPcr	(	uchar *	p,
		int64_t	Pcr
	)

Definition at line 131 of file remux.c.

◆ TsSetPid()

void TsSetPid	(	uchar *	p,
		int	Pid
	)

inline

Definition at line 87 of file remux.h.

References TS_PID_MASK_HI.

◆ TsSetPts()

void TsSetPts	(	uchar *	p,
		int	l,
		int64_t	Pts
	)

Definition at line 186 of file remux.c.

◆ TsSync()

int TsSync	(	const uchar *	Data,
		int	Length,
		const char *	File = `NULL`,
		const char *	Function = `NULL`,
		int	Line = `0`
	)

Definition at line 147 of file remux.c.

Classes

Macros

Enumerations

Functions

Macro Definition Documentation

◆ CATPID

◆ EITPID

◆ MAX27MHZ

◆ MAX33BIT

◆ MAX_PMT_PIDS

◆ MAX_PMT_TS

◆ MAX_SECTION_SIZE

◆ MAXPID

◆ MIN_TS_PACKETS_FOR_FRAME_DETECTOR

◆ PATPID

◆ PCRFACTOR

◆ PTSTICKS

◆ TS_ADAPT_DISCONT

◆ TS_ADAPT_ELEM_PRIO

◆ TS_ADAPT_EXTENSION

◆ TS_ADAPT_FIELD_EXISTS

◆ TS_ADAPT_OPCR

◆ TS_ADAPT_PCR

◆ TS_ADAPT_RANDOM_ACC

◆ TS_ADAPT_SPLICING

◆ TS_ADAPT_TP_PRIVATE

◆ TS_CONT_CNT_MASK

◆ TS_ERROR

◆ TS_PAYLOAD_EXISTS

◆ TS_PAYLOAD_START

◆ TS_PID_MASK_HI

◆ TS_SCRAMBLING_CONTROL

◆ TS_SIZE

◆ TS_SYNC

◆ TS_SYNC_BYTE

◆ TS_TRANSPORT_PRIORITY

Enumeration Type Documentation

◆ ePesHeader

Function Documentation

◆ AnalyzePesHeader()

◆ BlockDump()

◆ PesDump()

◆ PesGetDts()

◆ PesGetPts()

◆ PesHasDts()

◆ PesHasLength()

◆ PesHasPts()

◆ PesLength()

◆ PesLongEnough()

◆ PesPayloadOffset()

◆ PesSetDts()

◆ PesSetPts()

◆ PtsAdd()

◆ PtsDiff()

◆ TsContinuityCounter()

◆ TsDump()

◆ TsError()

◆ TsGetDts()

◆ TsGetPayload()

◆ TsGetPcr()

◆ TsGetPts()

◆ TsHasAdaptationField()

◆ TsHasPayload()

◆ TsHidePayload()

◆ TsIsScrambled()

◆ TsPayloadOffset()

◆ TsPayloadStart()

◆ TsPid()

◆ TsSetContinuityCounter()

◆ TsSetDts()

◆ TsSetPcr()

◆ TsSetPid()

◆ TsSetPts()

◆ TsSync()