1 #ifndef __lib_dvb_dvbmid_h
2 #define __lib_dvb_dvbmid_h
6 #include <lib/base/buffer.h>
7 #include <lib/dvb/idvb.h>
8 #include <lib/dvb/dvb.h>
9 #include <lib/dvb/idemux.h>
10 #include <lib/dvb/esection.h>
11 #include <lib/python/python.h>
12 #include <lib/python/connections.h>
13 #include <dvbsi++/program_map_section.h>
14 #include <dvbsi++/program_association_section.h>
16 #include <sys/socket.h>
17 #include <sys/types.h>
25 #include <dvbsi++/application_information_section.h>
26 class OCSection : public LongCrcSection
32 OCSection(const uint8_t * const buffer)
33 : LongCrcSection(buffer)
35 data = malloc(getSectionLength());
36 memcpy(data, buffer, getSectionLength());
42 void *getData() { return data; }
45 struct channel_data: public Object
47 ePtr<eDVBChannel> m_channel;
48 ePtr<eConnection> m_stateChangedConn;
49 int m_prevChannelState;
53 // TODO .. put all static stuff into a 'eDVBCAServiceHandler class'
55 typedef std::map<eServiceReferenceDVB, eDVBCAService*> CAServiceMap;
56 typedef std::map<iDVBChannel*, channel_data*> ChannelMap;
58 class eDVBCAService: public Object
61 ePtr<eSocketNotifier> m_sn;
62 eServiceReferenceDVB m_service;
63 uint8_t m_used_demux[32];
64 unsigned int m_prev_build_hash;
67 struct sockaddr_un m_servaddr;
68 unsigned int m_sendstate;
69 unsigned char m_capmt[2048];
70 ePtr<eTimer> m_retryTimer;
73 void socketCB(int what);
75 static void DVBChannelAdded(eDVBChannel*);
76 static void DVBChannelStateChanged(iDVBChannel*);
77 static CAServiceMap exist;
78 static ChannelMap exist_channels;
79 static ePtr<eConnection> m_chanAddedConn;
80 static channel_data *getChannelData(eDVBChannelID &chid);
85 static void registerChannelCallback(eDVBResourceManager *res_mgr);
86 static RESULT register_service( const eServiceReferenceDVB &ref, int demux_nums[2], eDVBCAService *&caservice );
87 static RESULT unregister_service( const eServiceReferenceDVB &ref, int demux_nums[2], eTable<ProgramMapSection> *ptr );
88 void buildCAPMT(eTable<ProgramMapSection> *ptr);
95 class HbbTVApplicationInfo
102 std::string m_HbbTVUrl;
103 std::string m_ApplicationName;
105 HbbTVApplicationInfo(int controlCode, int orgid, int appid, std::string hbbtvUrl, std::string applicationName, int profileCode)
106 : m_ControlCode(controlCode), m_HbbTVUrl(hbbtvUrl), m_ApplicationName(applicationName), m_OrgId(orgid),
107 m_AppId(appid), m_ProfileCode(profileCode)
110 typedef std::list<HbbTVApplicationInfo *> HbbTVApplicationInfoList;
111 typedef HbbTVApplicationInfoList::iterator HbbTVApplicationInfoListIterator;
112 typedef HbbTVApplicationInfoList::const_iterator HbbTVApplicationInfoListConstIterator;
114 class eDVBServicePMTHandler: public Object
117 friend class eDVBCAService;
118 eServiceReferenceDVB m_reference;
119 ePtr<eDVBService> m_service;
121 int m_last_channel_state;
122 eDVBCAService *m_ca_servicePtr;
123 ePtr<eDVBScan> m_dvb_scan; // for sdt scan
125 eAUTable<eTable<ProgramMapSection> > m_PMT;
126 eAUTable<eTable<ProgramAssociationSection> > m_PAT;
128 eUsePtr<iDVBChannel> m_channel;
129 eUsePtr<iDVBPVRChannel> m_pvr_channel;
130 ePtr<eDVBResourceManager> m_resourceManager;
131 ePtr<iDVBDemux> m_demux, m_pvr_demux_tmp;
133 void channelStateChanged(iDVBChannel *);
134 ePtr<eConnection> m_channelStateChanged_connection;
135 void channelEvent(iDVBChannel *, int event);
136 ePtr<eConnection> m_channelEvent_connection;
137 void SDTScanEvent(int);
138 ePtr<eConnection> m_scan_event_connection;
140 eAUTable<eTable<ApplicationInformationSection> > m_AIT;
141 eAUTable<eTable<OCSection> > m_OC;
143 void registerCAService();
144 void PMTready(int error);
145 void PATready(int error);
149 void AITready(int error);
150 void OCready(int error);
153 HbbTVApplicationInfoList m_HbbTVApplications;
154 std::string m_HBBTVUrl;
155 std::string m_ApplicationName;
156 unsigned char m_AITData[4096];
158 int m_use_decode_demux;
159 uint8_t m_decode_demux_num;
160 ePtr<eTimer> m_no_pat_entry_delay;
166 eDVBServicePMTHandler();
167 ~eDVBServicePMTHandler();
172 eDVBServicePMTHandler();
178 eventNoResources, // a requested resource couldn't be allocated
179 eventTuneFailed, // tune failed
180 eventNoPAT, // no pat could be received (timeout)
181 eventNoPATEntry, // no pat entry for the corresponding SID could be found
182 eventNoPMT, // no pmt could be received (timeout)
183 eventNewProgramInfo, // we just received a PMT
184 eventTuned, // a channel was sucessfully (re-)tuned in, you may start additional filters now
186 eventPreStart, // before start filepush thread
187 eventSOF, // seek pre start
188 eventEOF, // a file playback did end
190 eventHBBTVInfo, /* HBBTV information was detected in the AIT */
192 eventMisconfiguration, // a channel was not found in any list, or no frontend was found which could provide this channel
193 eventNoDiskSpace, // no disk space available
194 eventStartPvrDescramble, // start PVR Descramble Convert
195 eventChannelAllocated,
198 Signal1<void,int> serviceEvent;
204 enum { vtMPEG2, vtMPEG4_H264, vtMPEG1, vtMPEG4_Part2, vtVC1, vtVC1_SM, vtH265_HEVC };
211 rdsPid; // hack for some radio services which transmit radiotext on different pid (i.e. harmony fm, HIT RADIO FFH, ...)
212 enum { atMPEG, atAC3, atDTS, atAAC, atAACHE, atLPCM, atDTSHD, atDDP };
213 int type; // mpeg2, ac3, dts, ...
216 std::string language_code; /* iso-639, if available. */
219 struct subtitleStream
222 int subtitling_type; /* see ETSI EN 300 468 table 26 component_type
223 when stream_content is 0x03
224 0x10..0x13, 0x20..0x23 is used for dvb subtitles
225 0x01 is used for teletext subtitles */
228 int composition_page_id; // used for dvb subtitles
229 int teletext_page_number; // used for teletext subtitles
233 int ancillary_page_id; // used for dvb subtitles
234 int teletext_magazine_number; // used for teletext subtitles
236 std::string language_code;
237 bool operator<(const subtitleStream &s) const
241 if (teletext_page_number != s.teletext_page_number)
242 return teletext_page_number < s.teletext_page_number;
243 return teletext_magazine_number < s.teletext_magazine_number;
253 bool operator< (const struct capid_pair &t) const { return t.caid < caid; }
255 std::vector<videoStream> videoStreams;
256 std::vector<audioStream> audioStreams;
257 int defaultAudioStream;
258 std::vector<subtitleStream> subtitleStreams;
259 std::list<capid_pair> caids;
266 bool isCrypted() { return !caids.empty(); }
267 PyObject *createPythonObject();
270 int getProgramInfo(program &program);
271 int getDataDemux(ePtr<iDVBDemux> &demux);
272 int getDecodeDemux(ePtr<iDVBDemux> &demux);
273 PyObject *getCaIds(bool pair=false); // caid / ecmpid pair
274 PyObject *getHbbTVApplications(void);
276 int getPVRChannel(ePtr<iDVBPVRChannel> &pvr_channel);
277 int getServiceReference(eServiceReferenceDVB &service) { service = m_reference; return 0; }
278 int getService(ePtr<eDVBService> &service) { service = m_service; return 0; }
279 int getPMT(ePtr<eTable<ProgramMapSection> > &ptr) { return m_PMT.getCurrent(ptr); }
280 int getChannel(eUsePtr<iDVBChannel> &channel);
281 void resetCachedProgram() { m_have_cached_program = false; }
282 void sendEventNoPatEntry();
284 void getHBBTVUrl(std::string &ret) { ret = m_HBBTVUrl; }
285 void getDemuxID(int &id) { id = mDemuxId; }
286 void setCaDisable(bool disable) { m_ca_disabled = disable; }
292 scrambled_recording = 2,
294 timeshift_recording = 4,
295 scrambled_timeshift_recording = 5,
296 timeshift_playback = 6,
298 scrambled_streamserver = 8,
304 /* deprecated interface */
305 int tune(eServiceReferenceDVB &ref, int use_decode_demux, eCueSheet *sg=0, bool simulate=false, eDVBService *service = 0, serviceType type = livetv, bool descramble = true);
308 int tuneExt(eServiceReferenceDVB &ref, int use_decode_demux, ePtr<iTsSource> &, const char *streaminfo_file, eCueSheet *sg=0, bool simulate=false, eDVBService *service = 0, serviceType type = livetv, bool descramble=true);
312 void removeCaHandler();
313 bool isCiConnected();
314 bool isPmtReady() { return m_pmt_ready; }
316 bool m_have_cached_program;
317 program m_cached_program;
319 serviceType m_service_type;