vdr  2.0.5
remux.h
Go to the documentation of this file.
1 /*
2  * remux.h: Tools for detecting frames and handling PAT/PMT
3  *
4  * See the main source file 'vdr.c' for copyright information and
5  * how to reach the author.
6  *
7  * $Id: remux.h 2.37 2013/01/20 11:43:59 kls Exp $
8  */
9 
10 #ifndef __REMUX_H
11 #define __REMUX_H
12 
13 #include "channels.h"
14 #include "tools.h"
15 
16 enum ePesHeader {
18  phInvalid = 0,
19  phMPEG1 = 1,
20  phMPEG2 = 2
21  };
22 
23 ePesHeader AnalyzePesHeader(const uchar *Data, int Count, int &PesPayloadOffset, bool *ContinuationHeader = NULL);
24 
25 class cRemux {
26 public:
27  static void SetBrokenLink(uchar *Data, int Length);
28  };
29 
30 // Some TS handling tools.
31 // The following functions all take a pointer to one complete TS packet.
32 
33 #define TS_SYNC_BYTE 0x47
34 #define TS_SIZE 188
35 #define TS_ERROR 0x80
36 #define TS_PAYLOAD_START 0x40
37 #define TS_TRANSPORT_PRIORITY 0x20
38 #define TS_PID_MASK_HI 0x1F
39 #define TS_SCRAMBLING_CONTROL 0xC0
40 #define TS_ADAPT_FIELD_EXISTS 0x20
41 #define TS_PAYLOAD_EXISTS 0x10
42 #define TS_CONT_CNT_MASK 0x0F
43 #define TS_ADAPT_DISCONT 0x80
44 #define TS_ADAPT_RANDOM_ACC 0x40 // would be perfect for detecting independent frames, but unfortunately not used by all broadcasters
45 #define TS_ADAPT_ELEM_PRIO 0x20
46 #define TS_ADAPT_PCR 0x10
47 #define TS_ADAPT_OPCR 0x08
48 #define TS_ADAPT_SPLICING 0x04
49 #define TS_ADAPT_TP_PRIVATE 0x02
50 #define TS_ADAPT_EXTENSION 0x01
51 
52 #define PATPID 0x0000 // PAT PID (constant 0)
53 #define MAXPID 0x2000 // for arrays that use a PID as the index
54 
55 #define PTSTICKS 90000 // number of PTS ticks per second
56 #define PCRFACTOR 300 // conversion from 27MHz PCR extension to 90kHz PCR base
57 #define MAX33BIT 0x00000001FFFFFFFFLL // max. possible value with 33 bit
58 #define MAX27MHZ ((MAX33BIT + 1) * PCRFACTOR - 1) // max. possible PCR value
59 
60 inline bool TsHasPayload(const uchar *p)
61 {
62  return p[3] & TS_PAYLOAD_EXISTS;
63 }
64 
65 inline bool TsSetPayload(const uchar *p)
66 {
67  return p[3] & TS_PAYLOAD_EXISTS;
68 }
69 
70 inline bool TsHasAdaptationField(const uchar *p)
71 {
72  return p[3] & TS_ADAPT_FIELD_EXISTS;
73 }
74 
75 inline bool TsPayloadStart(const uchar *p)
76 {
77  return p[1] & TS_PAYLOAD_START;
78 }
79 
80 inline bool TsError(const uchar *p)
81 {
82  return p[1] & TS_ERROR;
83 }
84 
85 inline int TsPid(const uchar *p)
86 {
87  return (p[1] & TS_PID_MASK_HI) * 256 + p[2];
88 }
89 
90 inline bool TsIsScrambled(const uchar *p)
91 {
92  return p[3] & TS_SCRAMBLING_CONTROL;
93 }
94 
96 {
97  return p[3] & TS_CONT_CNT_MASK;
98 }
99 
100 inline void TsSetContinuityCounter(uchar *p, uchar Counter)
101 {
102  p[3] = (p[3] & ~TS_CONT_CNT_MASK) | (Counter & TS_CONT_CNT_MASK);
103 }
104 
105 inline int TsPayloadOffset(const uchar *p)
106 {
107  int o = TsHasAdaptationField(p) ? p[4] + 5 : 4;
108  return o <= TS_SIZE ? o : TS_SIZE;
109 }
110 
111 inline int TsGetPayload(const uchar **p)
112 {
113  if (TsHasPayload(*p)) {
114  int o = TsPayloadOffset(*p);
115  *p += o;
116  return TS_SIZE - o;
117  }
118  return 0;
119 }
120 
121 inline int TsContinuityCounter(const uchar *p)
122 {
123  return p[3] & TS_CONT_CNT_MASK;
124 }
125 
126 inline int64_t TsGetPcr(const uchar *p)
127 {
128  if (TsHasAdaptationField(p)) {
129  if (p[4] >= 7 && (p[5] & TS_ADAPT_PCR)) {
130  return ((((int64_t)p[ 6]) << 25) |
131  (((int64_t)p[ 7]) << 17) |
132  (((int64_t)p[ 8]) << 9) |
133  (((int64_t)p[ 9]) << 1) |
134  (((int64_t)p[10]) >> 7)) * PCRFACTOR +
135  (((((int)p[10]) & 0x01) << 8) |
136  ( ((int)p[11])));
137  }
138  }
139  return -1;
140 }
141 
142 void TsHidePayload(uchar *p);
143 void TsSetPcr(uchar *p, int64_t Pcr);
144 
145 // The following functions all take a pointer to a sequence of complete TS packets.
146 
147 int64_t TsGetPts(const uchar *p, int l);
148 int64_t TsGetDts(const uchar *p, int l);
149 void TsSetPts(uchar *p, int l, int64_t Pts);
150 void TsSetDts(uchar *p, int l, int64_t Dts);
151 void TsExtendAdaptionField(unsigned char *Packet, int ToLength);
152 
153 // Some PES handling tools:
154 // The following functions that take a pointer to PES data all assume that
155 // there is enough data so that PesLongEnough() returns true.
156 
157 inline bool PesLongEnough(int Length)
158 {
159  return Length >= 6;
160 }
161 
162 inline bool PesHasLength(const uchar *p)
163 {
164  return p[4] | p[5];
165 }
166 
167 inline int PesLength(const uchar *p)
168 {
169  return 6 + p[4] * 256 + p[5];
170 }
171 
172 inline int PesPayloadOffset(const uchar *p)
173 {
174  return 9 + p[8];
175 }
176 
177 inline bool PesHasPts(const uchar *p)
178 {
179  return (p[7] & 0x80) && p[8] >= 5;
180 }
181 
182 inline bool PesHasDts(const uchar *p)
183 {
184  return (p[7] & 0x40) && p[8] >= 10;
185 }
186 
187 inline int64_t PesGetPts(const uchar *p)
188 {
189  return ((((int64_t)p[ 9]) & 0x0E) << 29) |
190  (( (int64_t)p[10]) << 22) |
191  ((((int64_t)p[11]) & 0xFE) << 14) |
192  (( (int64_t)p[12]) << 7) |
193  ((((int64_t)p[13]) & 0xFE) >> 1);
194 }
195 
196 inline int64_t PesGetDts(const uchar *p)
197 {
198  return ((((int64_t)p[14]) & 0x0E) << 29) |
199  (( (int64_t)p[15]) << 22) |
200  ((((int64_t)p[16]) & 0xFE) << 14) |
201  (( (int64_t)p[17]) << 7) |
202  ((((int64_t)p[18]) & 0xFE) >> 1);
203 }
204 
205 void PesSetPts(uchar *p, int64_t Pts);
206 void PesSetDts(uchar *p, int64_t Dts);
207 
208 // PTS handling:
209 
210 inline int64_t PtsAdd(int64_t Pts1, int64_t Pts2) { return (Pts1 + Pts2) & MAX33BIT; }
212 int64_t PtsDiff(int64_t Pts1, int64_t Pts2);
217 
218 // A transprent TS payload handler:
219 
220 class cTsPayload {
221 private:
223  int length;
224  int pid;
225  int index; // points to the next byte to process
226 protected:
227  void Reset(void) { index = 0; }
228 public:
229  cTsPayload(void);
230  cTsPayload(uchar *Data, int Length, int Pid = -1);
232  void Setup(uchar *Data, int Length, int Pid = -1);
240  bool AtTsStart(void) { return index < length && (index % TS_SIZE) == 0; }
243  bool AtPayloadStart(void) { return AtTsStart() && TsPayloadStart(data + index); }
246  int Available(void) { return length - index; }
249  int Used(void) { return (index + TS_SIZE - 1) / TS_SIZE * TS_SIZE; }
253  bool Eof(void) const { return index >= length; }
255  uchar GetByte(void);
257  bool SkipBytes(int Bytes);
260  bool SkipPesHeader(void);
262  int GetLastIndex(void);
265  void SetByte(uchar Byte, int Index);
270  bool Find(uint32_t Code);
278  };
279 
280 // PAT/PMT Generator:
281 
282 #define MAX_SECTION_SIZE 4096 // maximum size of an SI section
283 #define MAX_PMT_TS (MAX_SECTION_SIZE / TS_SIZE + 1)
284 
286 private:
287  uchar pat[TS_SIZE]; // the PAT always fits into a single TS packet
288  uchar pmt[MAX_PMT_TS][TS_SIZE]; // the PMT may well extend over several TS packets
294  int pmtPid;
296  void IncCounter(int &Counter, uchar *TsPacket);
297  void IncVersion(int &Version);
298  void IncEsInfoLength(int Length);
299 protected:
300  int MakeStream(uchar *Target, uchar Type, int Pid);
301  int MakeAC3Descriptor(uchar *Target, uchar Type);
302  int MakeSubtitlingDescriptor(uchar *Target, const char *Language, uchar SubtitlingType, uint16_t CompositionPageId, uint16_t AncillaryPageId);
303  int MakeTeletextDescriptor(uchar *Target, const tTeletextSubtitlePage *pages, int pageCount);
304  int MakeLanguageDescriptor(uchar *Target, const char *Language);
305  int MakeCRC(uchar *Target, const uchar *Data, int Length);
306  void GeneratePmtPid(const cChannel *Channel);
309  void GeneratePat(void);
311  void GeneratePmt(const cChannel *Channel);
314 public:
315  cPatPmtGenerator(const cChannel *Channel = NULL);
316  void SetVersions(int PatVersion, int PmtVersion);
325  void SetChannel(const cChannel *Channel);
327  uchar *GetPat(void);
330  uchar *GetPmt(int &Index);
335  };
336 
337 // PAT/PMT Parser:
338 
339 #define MAX_PMT_PIDS 32
340 
342 private:
344  int pmtSize;
347  int pmtPids[MAX_PMT_PIDS + 1]; // list is zero-terminated
348  int vpid;
349  int ppid;
350  int vtype;
351  int tpid;
352  int apids[MAXAPIDS + 1]; // list is zero-terminated
353  int atypes[MAXAPIDS + 1]; // list is zero-terminated
355  int dpids[MAXDPIDS + 1]; // list is zero-terminated
356  int dtypes[MAXDPIDS + 1]; // list is zero-terminated
358  int spids[MAXSPIDS + 1]; // list is zero-terminated
366 protected:
367  int SectionLength(const uchar *Data, int Length) { return (Length >= 3) ? ((int(Data[1]) & 0x0F) << 8)| Data[2] : 0; }
368 public:
369  cPatPmtParser(bool UpdatePrimaryDevice = false);
370  void Reset(void);
373  void ParsePat(const uchar *Data, int Length);
376  void ParsePmt(const uchar *Data, int Length);
383  bool ParsePatPmt(const uchar *Data, int Length);
387  bool GetVersions(int &PatVersion, int &PmtVersion) const;
390  bool IsPmtPid(int Pid) const { for (int i = 0; pmtPids[i]; i++) if (pmtPids[i] == Pid) return true; return false; }
393  int Vpid(void) const { return vpid; }
396  int Ppid(void) const { return ppid; }
399  int Vtype(void) const { return vtype; }
402  int Tpid(void) { return tpid; }
405  const int *Apids(void) const { return apids; }
406  const int *Dpids(void) const { return dpids; }
407  const int *Spids(void) const { return spids; }
408  int Apid(int i) const { return (0 <= i && i < MAXAPIDS) ? apids[i] : 0; }
409  int Dpid(int i) const { return (0 <= i && i < MAXDPIDS) ? dpids[i] : 0; }
410  int Spid(int i) const { return (0 <= i && i < MAXSPIDS) ? spids[i] : 0; }
411  int Atype(int i) const { return (0 <= i && i < MAXAPIDS) ? atypes[i] : 0; }
412  int Dtype(int i) const { return (0 <= i && i < MAXDPIDS) ? dtypes[i] : 0; }
413  const char *Alang(int i) const { return (0 <= i && i < MAXAPIDS) ? alangs[i] : ""; }
414  const char *Dlang(int i) const { return (0 <= i && i < MAXDPIDS) ? dlangs[i] : ""; }
415  const char *Slang(int i) const { return (0 <= i && i < MAXSPIDS) ? slangs[i] : ""; }
416  uchar SubtitlingType(int i) const { return (0 <= i && i < MAXSPIDS) ? subtitlingTypes[i] : uchar(0); }
417  uint16_t CompositionPageId(int i) const { return (0 <= i && i < MAXSPIDS) ? compositionPageIds[i] : uint16_t(0); }
418  uint16_t AncillaryPageId(int i) const { return (0 <= i && i < MAXSPIDS) ? ancillaryPageIds[i] : uint16_t(0); }
421  };
422 
423 // TS to PES converter:
424 // Puts together the payload of several TS packets that form one PES
425 // packet.
426 
427 class cTsToPes {
428 private:
430  int size;
431  int length;
432  int offset;
436 public:
437  cTsToPes(void);
438  ~cTsToPes();
439  void PutTs(const uchar *Data, int Length);
449  const uchar *GetPes(int &Length);
463  void SetRepeatLast(void);
466  void Reset(void);
470  };
471 
472 // Some helper functions for debugging:
473 
474 void BlockDump(const char *Name, const u_char *Data, int Length);
475 void TsDump(const char *Name, const u_char *Data, int Length);
476 void PesDump(const char *Name, const u_char *Data, int Length);
477 
478 // Frame detector:
479 
480 #define MIN_TS_PACKETS_FOR_FRAME_DETECTOR 5
481 
482 class cFrameParser;
483 
485 private:
486  enum { MaxPtsValues = 150 };
487  int pid;
488  int type;
489  bool synced;
490  bool newFrame;
492  uint32_t ptsValues[MaxPtsValues]; // 32 bit is enough - we only need the delta
496  bool isVideo;
499  int framesPerPayloadUnit; // Some broadcasters send one frame per payload unit (== 1),
500  // while others put an entire GOP into one payload unit (> 1).
501  bool scanning;
503 public:
504  cFrameDetector(int Pid = 0, int Type = 0);
508  void SetPid(int Pid, int Type);
510  int Analyze(const uchar *Data, int Length);
516  bool Synced(void) { return synced; }
518  bool NewFrame(void) { return newFrame; }
521  bool IndependentFrame(void) { return independentFrame; }
525  double FramesPerSecond(void) { return framesPerSecond; }
528  };
529 
530 
531 #define PATCH_NALUDUMP 100
532 
533 class cNaluDumper {
534  unsigned int History;
535 
539 
541 
542  int PesId;
544 
546 
548  NALU_NONE=0, // currently not NALU fill stream
549  NALU_FILL, // Within NALU fill stream, 0xff bytes and NALU start code in byte 0
550  NALU_TERM, // Within NALU fill stream, read 0x80 terminating byte
551  NALU_END // Beyond end of NALU fill stream, expecting 0x00 0x00 0x01 now
552  };
553 
555 
556  struct sPayloadInfo {
560  };
561 
562 public:
563  cNaluDumper();
564 
565  void reset();
566 
567  // Single packet interface:
568  bool ProcessTSPacket(unsigned char *Packet);
569 
570 private:
571  void ProcessPayload(unsigned char *Payload, int size, bool PayloadStart, sPayloadInfo &Info);
572 };
573 
575  //Buffer stream interface:
576  int vpid;
578  int length;
584 
585  long long int TotalPackets;
586  long long int DroppedPackets;
587 public:
589 
590  void SetPid(int VPid) { vpid = VPid; }
591  void SetPatPmtParser(cPatPmtParser *_pPatPmtParser) { pPatPmtParser = _pPatPmtParser; }
592  // Set either a PID or set a pointer to an PatPmtParser that will detect _one_ PID
593 
594  void PutBuffer(uchar *Data, int Length);
595  // Add new data to be processed. Data must be valid until Get() returns NULL.
596  uchar* GetBuffer(int &OutLength);
597  // Returns filtered data, or NULL/0 to indicate that all data from Put() was processed
598  // or buffered.
599 
600  long long int GetTotalPackets() { return TotalPackets; }
601  long long int GetDroppedPackets() { return DroppedPackets; }
602 };
603 
604 #endif // __REMUX_H
int framesInPayloadUnit
Definition: remux.h:498
bool ParsePatPmt(const uchar *Data, int Length)
Parses the given Data (which may consist of several TS packets, typically an entire frame) and extrac...
Definition: remux.c:926
unsigned char uchar
Definition: tools.h:30
void ParsePat(const uchar *Data, int Length)
Parses the PAT data from the single TS packet in Data.
Definition: remux.c:647
int64_t PtsAdd(int64_t Pts1, int64_t Pts2)
Adds the given PTS values, taking into account the 33bit wrap around.
Definition: remux.h:210
uchar * data
Definition: remux.h:222
int Used(void)
Returns the number of raw bytes that have already been used (e.g.
Definition: remux.h:249
uchar GetByte(void)
Gets the next byte of the TS payload, skipping any intermediate TS header data.
Definition: remux.c:250
bool repeatLast
Definition: remux.h:435
int vpid
Definition: remux.h:348
int index
Definition: remux.h:225
int pid
Definition: remux.h:224
uchar subtitlingTypes[MAXSPIDS]
Definition: remux.h:360
void SetVersions(int PatVersion, int PmtVersion)
Sets the version numbers for the generated PAT and PMT, in case this generator is used to...
Definition: remux.c:599
const char * Alang(int i) const
Definition: remux.h:413
bool TsError(const uchar *p)
Definition: remux.h:80
void SetPid(int Pid, int Type)
Sets the Pid and stream Type to detect frames for.
Definition: remux.c:1457
int PesPayloadOffset(const uchar *p)
Definition: remux.h:172
void IncCounter(int &Counter, uchar *TsPacket)
Definition: remux.c:363
bool SkipBytes(int Bytes)
Skips the given number of bytes in the payload and returns true if there is still data left to read...
Definition: remux.c:279
bool TsHasAdaptationField(const uchar *p)
Definition: remux.h:70
void ParsePmt(const uchar *Data, int Length)
Parses the PMT data from the single TS packet in Data.
Definition: remux.c:679
uint16_t ancillaryPageIds[MAXSPIDS]
Definition: remux.h:362
bool IsPmtPid(int Pid) const
Returns true if Pid the one of the PMT pids as defined by the current PAT.
Definition: remux.h:390
int framesPerPayloadUnit
Definition: remux.h:499
int pmtSize
Definition: remux.h:344
char alangs[MAXAPIDS][MAXLANGCODE2]
Definition: remux.h:354
cNaluDumper NaluDumper
Definition: remux.h:583
#define MAX33BIT
Definition: remux.h:57
int LastContinuityInput
Definition: remux.h:536
void SetPid(int VPid)
Definition: remux.h:590
bool TsPayloadStart(const uchar *p)
Definition: remux.h:75
int64_t TsGetDts(const uchar *p, int l)
Definition: remux.c:156
void TsExtendAdaptionField(unsigned char *Packet, int ToLength)
Definition: remux.c:315
int MakeLanguageDescriptor(uchar *Target, const char *Language)
Definition: remux.c:447
int Spid(int i) const
Definition: remux.h:410
uchar SubtitlingType(int i) const
Definition: remux.h:416
void GeneratePmtPid(const cChannel *Channel)
Generates a PMT pid that doesn't collide with any of the actual pids of the Channel.
Definition: remux.c:481
int64_t PesGetPts(const uchar *p)
Definition: remux.h:187
int NaluOffset
Definition: remux.h:545
int Analyze(const uchar *Data, int Length)
Analyzes the TS packets pointed to by Data.
Definition: remux.c:1474
uchar pat[TS_SIZE]
Definition: remux.h:287
long long int GetDroppedPackets()
Definition: remux.h:601
bool TsHasPayload(const uchar *p)
Definition: remux.h:60
bool DropAllPayload
Definition: remux.h:540
void TsHidePayload(uchar *p)
Definition: remux.c:117
uint32_t ptsValues[MaxPtsValues]
Definition: remux.h:492
#define TS_ERROR
Definition: remux.h:35
char slangs[MAXSPIDS][MAXLANGCODE2]
Definition: remux.h:359
#define TS_SCRAMBLING_CONTROL
Definition: remux.h:39
#define TS_ADAPT_FIELD_EXISTS
Definition: remux.h:40
void IncEsInfoLength(int Length)
Definition: remux.c:376
int MakeCRC(uchar *Target, const uchar *Data, int Length)
Definition: remux.c:466
int Vpid(void) const
Returns the video pid as defined by the current PMT, or 0 if no video pid has been detected...
Definition: remux.h:393
int MakeTeletextDescriptor(uchar *Target, const tTeletextSubtitlePage *pages, int pageCount)
Definition: remux.c:424
int numFrames
Definition: remux.h:494
int Tpid(void)
Returns the teletext pid as defined by the current PMT, or 0 if no teletext pid has been detected...
Definition: remux.h:402
#define MAXTXTPAGES
Definition: channels.h:38
void BlockDump(const char *Name, const u_char *Data, int Length)
Definition: remux.c:1058
void SetChannel(const cChannel *Channel)
Sets the Channel for which the PAT/PMT shall be generated.
Definition: remux.c:605
void TsSetDts(uchar *p, int l, int64_t Dts)
Definition: remux.c:183
bool AtPayloadStart(void)
Returns true if this payload handler is currently pointing to the first byte of a TS packet that star...
Definition: remux.h:243
bool PesHasPts(const uchar *p)
Definition: remux.h:177
cPatPmtGenerator(const cChannel *Channel=NULL)
Definition: remux.c:353
int MakeSubtitlingDescriptor(uchar *Target, const char *Language, uchar SubtitlingType, uint16_t CompositionPageId, uint16_t AncillaryPageId)
Definition: remux.c:407
int length
Definition: remux.h:431
void Setup(uchar *Data, int Length, int Pid=-1)
Sets up this TS payload handler with the given Data, which points to a sequence of Length bytes of co...
Definition: remux.c:242
int PesOffset
Definition: remux.h:543
bool isVideo
Definition: remux.h:496
int pmtVersion
Definition: remux.h:346
int numPtsValues
Definition: remux.h:493
cPatPmtParser * pPatPmtParser
Definition: remux.h:582
bool independentFrame
Definition: remux.h:491
int lastLength
Definition: remux.h:434
int MakeAC3Descriptor(uchar *Target, uchar Type)
Definition: remux.c:397
tTeletextSubtitlePage teletextSubtitlePages[MAXTXTPAGES]
Definition: remux.h:365
void GeneratePat(void)
Generates a PAT section for later use with GetPat().
Definition: remux.c:496
bool Find(uint32_t Code)
Searches for the four byte sequence given in Code and returns true if it was found within the payload...
Definition: remux.c:302
int SectionLength(const uchar *Data, int Length)
Definition: remux.h:367
int Available(void)
Returns the number of raw bytes (including any TS headers) still available in the TS payload handler...
Definition: remux.h:246
int MakeStream(uchar *Target, uchar Type, int Pid)
Definition: remux.c:385
int patCounter
Definition: remux.h:290
bool Eof(void) const
Returns true if all available bytes of the TS payload have been processed.
Definition: remux.h:253
uchar pmt[MAX_PMT_TS][TS_SIZE]
Definition: remux.h:288
uchar * lastData
Definition: remux.h:433
bool TsSetPayload(const uchar *p)
Definition: remux.h:65
bool Synced(void)
Returns true if the frame detector has synced on the data stream.
Definition: remux.h:516
bool PesLongEnough(int Length)
Definition: remux.h:157
long long int GetTotalPackets()
Definition: remux.h:600
int64_t TsGetPts(const uchar *p, int l)
Definition: remux.c:143
#define MAX_SECTION_SIZE
Definition: remux.h:282
int TsPid(const uchar *p)
Definition: remux.h:85
const char * Slang(int i) const
Definition: remux.h:415
long long int DroppedPackets
Definition: remux.h:586
cFrameDetector(int Pid=0, int Type=0)
Sets up a frame detector for the given Pid and stream Type.
Definition: remux.c:1437
double framesPerSecond
Definition: remux.h:497
int TotalTeletextSubtitlePages() const
Definition: remux.h:420
#define TS_PAYLOAD_EXISTS
Definition: remux.h:41
int PesLength(const uchar *p)
Definition: remux.h:167
void TsSetPcr(uchar *p, int64_t Pcr)
Definition: remux.c:127
void PesDump(const char *Name, const u_char *Data, int Length)
Definition: remux.c:1084
Definition: remux.h:20
int Vtype(void) const
Returns the video stream type as defined by the current PMT, or 0 if no video stream type has been de...
Definition: remux.h:399
int ppid
Definition: remux.h:349
int TsContinuityCounter(const uchar *p)
Definition: remux.h:121
const int * Spids(void) const
Definition: remux.h:407
char dlangs[MAXDPIDS][MAXLANGCODE2]
Definition: remux.h:357
void Reset(void)
Resets the converter.
Definition: remux.c:1048
int ContinuityOffset
Definition: remux.h:538
bool synced
Definition: remux.h:489
uchar TsGetContinuityCounter(const uchar *p)
Definition: remux.h:95
bool PesHasDts(const uchar *p)
Definition: remux.h:182
void TsDump(const char *Name, const u_char *Data, int Length)
Definition: remux.c:1069
cPatPmtParser(bool UpdatePrimaryDevice=false)
Definition: remux.c:631
int GetLastIndex(void)
Returns the index into the TS data of the payload byte that has most recently been read...
Definition: remux.c:291
int PesId
Definition: remux.h:542
cTsPayload(void)
Definition: remux.c:229
int dtypes[MAXDPIDS+1]
Definition: remux.h:356
int dpids[MAXDPIDS+1]
Definition: remux.h:355
void PesSetDts(uchar *p, int64_t Dts)
Definition: remux.c:208
const int * Dpids(void) const
Definition: remux.h:406
void PutTs(const uchar *Data, int Length)
Puts the payload data of the single TS packet at Data into the converter.
Definition: remux.c:966
int Apid(int i) const
Definition: remux.h:408
int atypes[MAXAPIDS+1]
Definition: remux.h:353
unsigned int History
Definition: remux.h:534
uchar * GetPmt(int &Index)
Returns a pointer to the Index'th TS packet of the PMT section.
Definition: remux.c:620
void TsSetContinuityCounter(uchar *p, uchar Counter)
Definition: remux.h:100
int numPmtPackets
Definition: remux.h:289
int Dpid(int i) const
Definition: remux.h:409
void reset()
Definition: remux.c:1594
void ProcessPayload(unsigned char *Payload, int size, bool PayloadStart, sPayloadInfo &Info)
Definition: remux.c:1606
~cTsToPes()
Definition: remux.c:961
int TsGetPayload(const uchar **p)
Definition: remux.h:111
int pmtCounter
Definition: remux.h:291
int LastContinuityOutput
Definition: remux.h:537
long long int TotalPackets
Definition: remux.h:585
void GeneratePmt(const cChannel *Channel)
Generates a PMT section for the given Channel, for later use with GetPmt().
Definition: remux.c:525
uchar pmt[MAX_SECTION_SIZE]
Definition: remux.h:343
Definition: remux.h:25
int Dtype(int i) const
Definition: remux.h:412
int length
Definition: remux.h:223
#define TS_CONT_CNT_MASK
Definition: remux.h:42
uint16_t compositionPageIds[MAXSPIDS]
Definition: remux.h:361
void PesSetPts(uchar *p, int64_t Pts)
Definition: remux.c:199
#define MAXLANGCODE2
Definition: channels.h:41
int pmtPids[MAX_PMT_PIDS+1]
Definition: remux.h:347
const int * Apids(void) const
Definition: remux.h:405
static void SetBrokenLink(uchar *Data, int Length)
Definition: remux.c:98
int64_t TsGetPcr(const uchar *p)
Definition: remux.h:126
int patVersion
Definition: remux.h:292
cFrameParser * parser
Definition: remux.h:502
void TsSetPts(uchar *p, int l, int64_t Pts)
Definition: remux.c:169
bool ProcessTSPacket(unsigned char *Packet)
Definition: remux.c:1693
#define MAXDPIDS
Definition: channels.h:35
int spids[MAXSPIDS+1]
Definition: remux.h:358
#define MAX_PMT_TS
Definition: remux.h:283
int size
Definition: remux.h:430
#define PCRFACTOR
Definition: remux.h:56
#define MAX_PMT_PIDS
Definition: remux.h:339
bool PesHasLength(const uchar *p)
Definition: remux.h:162
uint16_t CompositionPageId(int i) const
Definition: remux.h:417
bool NewFrame(void)
Returns true if the data given to the last call to Analyze() started a new frame. ...
Definition: remux.h:518
bool IndependentFrame(void)
Returns true if a new frame was detected and this is an independent frame (i.e.
Definition: remux.h:521
unsigned char u_char
Definition: headers.h:24
int totalTtxtSubtitlePages
Definition: remux.h:364
bool TsIsScrambled(const uchar *p)
Definition: remux.h:90
bool GetVersions(int &PatVersion, int &PmtVersion) const
Returns true if a valid PAT/PMT has been parsed and stores the current version numbers in the given v...
Definition: remux.c:945
int64_t PesGetDts(const uchar *p)
Definition: remux.h:196
ePesHeader
Definition: remux.h:16
void SetByte(uchar Byte, int Index)
Sets the TS data byte at the given Index to the value Byte.
Definition: remux.c:296
int tpid
Definition: remux.h:351
cNaluDumper()
Definition: remux.c:1588
uchar * esInfoLength
Definition: remux.h:295
const char * Dlang(int i) const
Definition: remux.h:414
#define TS_PAYLOAD_START
Definition: remux.h:36
bool updatePrimaryDevice
Definition: remux.h:363
void Reset(void)
Definition: remux.h:227
double FramesPerSecond(void)
Returns the number of frames per second, or 0 if this information is not available.
Definition: remux.h:525
#define MAXSPIDS
Definition: channels.h:36
eNaluFillState NaluFillState
Definition: remux.h:554
bool newFrame
Definition: remux.h:490
#define TS_SIZE
Definition: remux.h:34
Definition: remux.h:19
void IncVersion(int &Version)
Definition: remux.c:370
const uchar * GetPes(int &Length)
Gets a pointer to the complete PES packet, or NULL if the packet is not complete yet.
Definition: remux.c:995
uint16_t AncillaryPageId(int i) const
Definition: remux.h:418
int TsPayloadOffset(const uchar *p)
Definition: remux.h:105
bool scanning
Definition: remux.h:501
int offset
Definition: remux.h:432
#define TS_ADAPT_PCR
Definition: remux.h:46
int numIFrames
Definition: remux.h:495
void SetRepeatLast(void)
Makes the next call to GetPes() return exactly the same data as the last one (provided there was no c...
Definition: remux.c:1043
int Ppid(void) const
Returns the PCR pid as defined by the current PMT, or 0 if no PCR pid has been detected, yet.
Definition: remux.h:396
bool AtTsStart(void)
Returns true if this payload handler is currently pointing to first byte of a TS packet.
Definition: remux.h:240
#define TS_PID_MASK_HI
Definition: remux.h:38
eNaluFillState
Definition: remux.h:547
int Atype(int i) const
Definition: remux.h:411
int64_t PtsDiff(int64_t Pts1, int64_t Pts2)
Returns the difference between two PTS values.
Definition: remux.c:217
void SetPatPmtParser(cPatPmtParser *_pPatPmtParser)
Definition: remux.h:591
void PutBuffer(uchar *Data, int Length)
Definition: remux.c:1786
void Reset(void)
Resets the parser.
Definition: remux.c:637
uchar * data
Definition: remux.h:429
ePesHeader AnalyzePesHeader(const uchar *Data, int Count, int &PesPayloadOffset, bool *ContinuationHeader=NULL)
Definition: remux.c:28
uchar * GetPat(void)
Returns a pointer to the PAT section, which consists of exactly one TS packet.
Definition: remux.c:614
uchar * GetBuffer(int &OutLength)
Definition: remux.c:1795
int patVersion
Definition: remux.h:345
int vtype
Definition: remux.h:350
const tTeletextSubtitlePage * TeletextSubtitlePages() const
Definition: remux.h:419
int pmtVersion
Definition: remux.h:293
bool SkipPesHeader(void)
Skips all bytes belonging to the PES header of the payload.
Definition: remux.c:286
cTsToPes(void)
Definition: remux.c:954
int apids[MAXAPIDS+1]
Definition: remux.h:352
#define MAXAPIDS
Definition: channels.h:34
uchar tempBuffer[TS_SIZE]
Definition: remux.h:579
bool tempLengthAtEnd
Definition: remux.h:581