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
|
#ifndef __lib_dvb_dvbmid_h
#define __lib_dvb_dvbmid_h
#include <map>
#include <lib/dvb/idvb.h>
#include <lib/dvb/dvb.h>
#include <lib/dvb/idemux.h>
#include <lib/dvb/esection.h>
#include <dvbsi++/program_map_section.h>
#include <dvbsi++/program_association_section.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/un.h>
#include <unistd.h>
#include <fcntl.h>
class eDVBServicePMTHandler;
typedef std::map<eServiceReferenceDVB, eDVBCAService*> CAServiceMap;
class eDVBCAService: public Object
{
eServiceReferenceDVB m_service;
uint8_t m_used_demux[10];
unsigned int m_prev_build_hash;
int m_sock, m_clilen;
struct sockaddr_un m_servaddr;
unsigned int m_sendstate;
unsigned char m_capmt[2048];
eTimer m_retryTimer;
void sendCAPMT();
void Connect();
static CAServiceMap exist;
eDVBCAService();
~eDVBCAService();
public:
static RESULT register_service( const eServiceReferenceDVB &ref, int demux_num, eDVBCAService *&caservice );
static RESULT unregister_service( const eServiceReferenceDVB &ref, int demux_num, eTable<ProgramMapSection> *ptr );
void buildCAPMT(eTable<ProgramMapSection> *ptr);
};
class eDVBServicePMTHandler: public Object
{
friend class eDVBCAService;
eServiceReferenceDVB m_reference;
ePtr<eDVBService> m_service;
int m_last_channel_state;
eDVBCAService *m_ca_servicePtr;
eAUTable<eTable<ProgramMapSection> > m_PMT;
eAUTable<eTable<ProgramAssociationSection> > m_PAT;
eUsePtr<iDVBChannel> m_channel;
eUsePtr<iDVBPVRChannel> m_pvr_channel;
ePtr<eDVBResourceManager> m_resourceManager;
ePtr<iDVBDemux> m_demux;
void channelStateChanged(iDVBChannel *);
ePtr<eConnection> m_channelStateChanged_connection;
void PMTready(int error);
void PATready(int error);
int m_record;
public:
eDVBServicePMTHandler(int record);
~eDVBServicePMTHandler();
enum
{
eventNoResources, // a requested resource couldn't be allocated
eventTuneFailed, // tune failed
eventNoPAT, // no pat could be received (timeout)
eventNoPATEntry, // no pat entry for the corresponding SID could be found
eventNoPMT, // no pmt could be received (timeout)
eventNewProgramInfo, // we just received a PMT
eventTuned // a channel was sucessfully (re-)tuned in, you may start additional filters now
};
Signal1<void,int> serviceEvent;
struct videoStream
{
int pid;
int component_tag;
};
struct audioStream
{
int pid;
enum { atMPEG, atAC3, atDTS };
int type; // mpeg2, ac3, dts, ...
int component_tag;
std::string language_code; /* iso-639, if available. */
};
struct program
{
std::vector<videoStream> videoStreams;
std::vector<audioStream> audioStreams;
// ca info
int pcrPid;
int pmtPid;
bool isCrypted;
};
int getProgramInfo(struct program &program);
int getDemux(ePtr<iDVBDemux> &demux);
int getPVRChannel(ePtr<iDVBPVRChannel> &pvr_channel);
int getService(eServiceReferenceDVB &service) { service = m_reference; return 0; }
int getPMT(ePtr<eTable<ProgramMapSection> > &ptr) { return m_PMT.getCurrent(ptr); }
int getChannel(eUsePtr<iDVBChannel> &channel);
int tune(eServiceReferenceDVB &ref);
};
#endif
|
