blob: 367a007b51d0a73d3bf3e5b5f2afdaf04e6f1caa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
/*
* ts2pkt.h: A program for the Video Disk Recorder
*
* See the README file for copyright information and how to reach the author.
*
*/
#ifndef __ts2pkt_h_
#define __ts2pkt_h_
#ifndef TS_SIZE
#define TS_SIZE 188
#endif
#ifndef uchar
typedef unsigned char uchar;
#endif
#include "global.h"
#include "queue.h"
class cMarkAdTS2Pkt
{
private:
struct TSHDR
{
unsigned Sync:
8;
unsigned PidH:
5;
unsigned Priority:
1;
unsigned PayloadStart:
1;
unsigned TError:
1;
unsigned PidL:
8;
unsigned Counter:
4;
unsigned AFC:
2;
unsigned TSC:
2;
};
struct TSADAPT
{
unsigned Len:
8;
unsigned Discontinuity_indicator:
1;
unsigned Random_access_indicator:
1;
unsigned Elementary_stream_priority_indicator:
1;
unsigned PCR_flag:
1;
unsigned OPCR_flag:
1;
unsigned Splicing_point_flag:
1;
unsigned Transport_private_data_flag:
1;
unsigned Adaption_field_extension_flag:
1;
uint64_t PCR_base:
33;
unsigned reserved:
6;
unsigned PCR_ext:
9;
};
struct PESHDR
{
uchar Sync1;
uchar Sync2;
uchar Sync3;
uchar StreamID;
uchar LenH;
uchar LenL;
};
#pragma pack(1)
struct PESHDROPT
{
unsigned OOC:
1;
unsigned CY:
1;
unsigned DAI:
1;
unsigned PESP:
1;
unsigned PESSC:
2;
unsigned MarkerBits:
2;
unsigned EXT:
1;
unsigned CRC:
1;
unsigned ACI:
1;
unsigned TM:
1;
unsigned RATE:
1;
unsigned ESCR:
1;
unsigned TSF:
2;
unsigned Length:
8;
};
#pragma pack()
int counter;
bool sync;
cMarkAdPaketQueue *queue;
#define MA_ERR_STARTUP 0
#define MA_ERR_TSSIZE 1
#define MA_ERR_NOSYNC 2
#define MA_ERR_SEQ 3
#define MA_ERR_AFC 4
#define MA_ERR_TOBIG 5
#define MA_ERR_NEG 6
bool Reset(int ErrIndex=MA_ERR_STARTUP);
public:
cMarkAdTS2Pkt(const char *QueueName="TS2Pkt", int QueueSize=32768);
~cMarkAdTS2Pkt();
void Clear();
bool Process(MarkAdPid Pid,uchar *TSData, int TSSize, MarkAdPacket *Pkt);
bool InjectVideoPES(uchar *PESData, int PESSize);
};
#endif
|
