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
|
#ifndef __include_lib_dvb_pvrparse_h
#define __include_lib_dvb_pvrparse_h
#include <lib/dvb/idvb.h>
#include <map>
#include <set>
/* This module parses TS data and collects valuable information */
/* about it, like PTS<->offset correlations and sequence starts. */
/* At first, we define the collector class: */
class eMPEGStreamInformation
{
public:
/* we order by off_t here, since the timestamp may */
/* wrap around. */
/* we only record sequence start's pts values here. */
std::map<off_t, pts_t> m_access_points;
/* timestampDelta is in fact the difference between */
/* the PTS in the stream and a real PTS from 0..max */
std::map<off_t, pts_t> m_timestamp_deltas;
int save(const char *filename);
int load(const char *filename);
/* recalculates timestampDeltas */
void fixupDiscontinuties();
/* get delta at specific offset */
pts_t getDelta(off_t offset);
/* fixup timestamp near offset, i.e. convert to zero-based */
int fixupPTS(const off_t &offset, pts_t &ts);
/* get PTS before offset */
int getPTS(off_t &offset, pts_t &pts);
/* inter/extrapolate timestamp from offset */
pts_t getInterpolated(off_t offset);
off_t getAccessPoint(pts_t ts);
int getNextAccessPoint(pts_t &ts, const pts_t &start, int direction);
bool empty();
};
/* Now we define the parser's state: */
class eMPEGStreamParserTS
{
public:
eMPEGStreamParserTS(eMPEGStreamInformation &streaminfo);
void parseData(off_t offset, const void *data, unsigned int len);
void setPid(int pid);
private:
eMPEGStreamInformation &m_streaminfo;
unsigned char m_pkt[188];
int m_pktptr;
int processPacket(const unsigned char *pkt, off_t offset);
inline int wantPacket(const unsigned char *hdr) const;
int m_pid;
int m_need_next_packet;
int m_skip;
};
#endif
|
