1 #include <lib/base/ebase.h>
2 #include <lib/base/eerror.h>
3 #include <lib/dvb/decoder.h>
4 #if HAVE_DVB_API_VERSION < 3
5 #define audioStatus audio_status
6 #define videoStatus video_status
7 #define pesType pes_type
8 #define playState play_state
9 #define audioStreamSource_t audio_stream_source_t
10 #define videoStreamSource_t video_stream_source_t
11 #define streamSource stream_source
12 #define dmxPesFilterParams dmx_pes_filter_params
13 #define DMX_PES_VIDEO0 DMX_PES_VIDEO
14 #define DMX_PES_AUDIO0 DMX_PES_AUDIO
15 #define DMX_PES_VIDEO1 DMX_PES_VIDEO
16 #define DMX_PES_AUDIO1 DMX_PES_AUDIO
18 #include <ost/video.h>
19 #include <ost/audio.h>
21 #include <linux/dvb/audio.h>
22 #include <linux/dvb/video.h>
23 #include <linux/dvb/dmx.h>
28 #include <sys/ioctl.h>
31 /* these are quite new... */
33 #define AUDIO_GET_PTS _IOR('o', 19, __u64)
34 #define VIDEO_GET_PTS _IOR('o', 57, __u64)
37 DEFINE_REF(eDVBAudio);
39 eDVBAudio::eDVBAudio(eDVBDemux *demux, int dev): m_demux(demux), m_dev(dev)
42 #if HAVE_DVB_API_VERSION < 3
43 sprintf(filename, "/dev/dvb/card%d/audio%d", demux->adapter, dev);
45 sprintf(filename, "/dev/dvb/adapter%d/audio%d", demux->adapter, dev);
47 m_fd = ::open(filename, O_RDWR);
49 eWarning("%s: %m", filename);
50 #if HAVE_DVB_API_VERSION < 3
51 sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
53 sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
55 m_fd_demux = ::open(filename, O_RDWR);
57 eWarning("%s: %m", filename);
60 int eDVBAudio::startPid(int pid, int type)
62 if ((m_fd < 0) || (m_fd_demux < 0))
64 dmx_pes_filter_params pes;
67 pes.input = DMX_IN_FRONTEND;
68 pes.output = DMX_OUT_DECODER;
69 pes.pes_type = m_dev ? DMX_PES_AUDIO1 : DMX_PES_AUDIO0; /* FIXME */
71 if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
73 eWarning("audio: DMX_SET_PES_FILTER: %m");
76 if (::ioctl(m_fd_demux, DMX_START) < 0)
78 eWarning("audio: DMX_START: %m");
99 if (::ioctl(m_fd, AUDIO_SET_BYPASS_MODE, bypass) < 0)
100 eWarning("audio: AUDIO_SET_BYPASS_MODE: %m");
104 if (::ioctl(m_fd, AUDIO_PLAY) < 0)
105 eWarning("audio: AUDIO_PLAY: %m");
109 void eDVBAudio::stop()
112 if (::ioctl(m_fd, AUDIO_STOP) < 0)
113 eWarning("audio: AUDIO_STOP: %m");
114 #if HAVE_DVB_API_VERSION > 2
115 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
116 eWarning("audio: DMX_STOP: %m");
120 #if HAVE_DVB_API_VERSION < 3
121 void eDVBAudio::stopPid()
123 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
124 eWarning("audio: DMX_STOP: %m");
128 void eDVBAudio::flush()
130 if (::ioctl(m_fd, AUDIO_CLEAR_BUFFER) < 0)
131 eDebug("audio: AUDIO_CLEAR_BUFFER: %m");
134 void eDVBAudio::freeze()
136 if (::ioctl(m_fd, AUDIO_PAUSE) < 0)
137 eDebug("video: AUDIO_PAUSE: %m");
140 void eDVBAudio::unfreeze()
142 if (::ioctl(m_fd, AUDIO_CONTINUE) < 0)
143 eDebug("video: AUDIO_CONTINUE: %m");
146 void eDVBAudio::setChannel(int channel)
148 int val = AUDIO_STEREO;
151 case aMonoLeft: val = AUDIO_MONO_LEFT; break;
152 case aMonoRight: val = AUDIO_MONO_RIGHT; break;
155 if (::ioctl(m_fd, AUDIO_CHANNEL_SELECT, val) < 0)
156 eDebug("video: AUDIO_CHANNEL_SELECT: %m");
159 int eDVBAudio::getPTS(pts_t &now)
161 return ::ioctl(m_fd, AUDIO_GET_PTS, &now);
164 eDVBAudio::~eDVBAudio()
173 DEFINE_REF(eDVBVideo);
175 eDVBVideo::eDVBVideo(eDVBDemux *demux, int dev): m_demux(demux), m_dev(dev)
178 #if HAVE_DVB_API_VERSION < 3
179 sprintf(filename, "/dev/dvb/card%d/video%d", demux->adapter, dev);
181 sprintf(filename, "/dev/dvb/adapter%d/video%d", demux->adapter, dev);
183 m_fd = ::open(filename, O_RDWR);
185 eWarning("%s: %m", filename);
188 m_sn = new eSocketNotifier(eApp, m_fd, eSocketNotifier::Priority);
189 CONNECT(m_sn->activated, eDVBVideo::video_event);
191 eDebug("Video Device: %s", filename);
192 #if HAVE_DVB_API_VERSION < 3
193 sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
195 sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
197 m_fd_demux = ::open(filename, O_RDWR);
199 eWarning("%s: %m", filename);
200 eDebug("demux device: %s", filename);
203 // not finally values i think.. !!
204 #define VIDEO_STREAMTYPE_MPEG2 0
205 #define VIDEO_STREAMTYPE_MPEG4_H264 1
207 int eDVBVideo::startPid(int pid, int type)
209 if ((m_fd < 0) || (m_fd_demux < 0))
211 dmx_pes_filter_params pes;
213 if (::ioctl(m_fd, VIDEO_SET_STREAMTYPE,
214 type == MPEG4_H264 ? VIDEO_STREAMTYPE_MPEG4_H264 : VIDEO_STREAMTYPE_MPEG2) < 0)
215 eWarning("video: VIDEO_SET_STREAMTYPE: %m");
218 pes.input = DMX_IN_FRONTEND;
219 pes.output = DMX_OUT_DECODER;
220 pes.pes_type = m_dev ? DMX_PES_VIDEO1 : DMX_PES_VIDEO0; /* FIXME */
222 if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
224 eWarning("video: DMX_SET_PES_FILTER: %m");
227 if (::ioctl(m_fd_demux, DMX_START) < 0)
229 eWarning("video: DMX_START: %m");
236 if (::ioctl(m_fd, VIDEO_PLAY) < 0)
237 eWarning("video: VIDEO_PLAY: %m");
241 void eDVBVideo::stop()
243 #if HAVE_DVB_API_VERSION > 2
244 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
245 eWarning("video: DMX_STOP: %m");
247 eDebug("VIDEO_STOP");
248 if (::ioctl(m_fd, VIDEO_STOP, 1) < 0)
249 eWarning("video: VIDEO_STOP: %m");
252 #if HAVE_DVB_API_VERSION < 3
253 void eDVBVideo::stopPid()
255 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
256 eWarning("video: DMX_STOP: %m");
260 void eDVBVideo::flush()
262 if (::ioctl(m_fd, VIDEO_CLEAR_BUFFER) < 0)
263 eDebug("video: VIDEO_CLEAR_BUFFER: %m");
266 void eDVBVideo::freeze()
268 eDebug("VIDEO_FREEZE");
269 if (::ioctl(m_fd, VIDEO_FREEZE) < 0)
270 eDebug("video: VIDEO_FREEZE: %m");
273 void eDVBVideo::unfreeze()
275 eDebug("VIDEO_CONTINUE");
276 if (::ioctl(m_fd, VIDEO_CONTINUE) < 0)
277 eDebug("video: VIDEO_CONTINUE: %m");
280 int eDVBVideo::setSlowMotion(int repeat)
282 m_is_slow_motion = repeat;
283 return ::ioctl(m_fd, VIDEO_SLOWMOTION, repeat);
286 int eDVBVideo::setFastForward(int skip)
288 m_is_fast_forward = skip;
289 return ::ioctl(m_fd, VIDEO_FAST_FORWARD, skip);
292 int eDVBVideo::getPTS(pts_t &now)
294 return ::ioctl(m_fd, VIDEO_GET_PTS, &now);
297 eDVBVideo::~eDVBVideo()
301 if (m_is_slow_motion)
303 if (m_is_fast_forward)
312 void eDVBVideo::video_event(int)
314 #if HAVE_DVB_API_VERSION >= 3
315 struct video_event evt;
316 if (::ioctl(m_fd, VIDEO_GET_EVENT, &evt) < 0)
317 eDebug("VIDEO_GET_EVENT failed(%m)");
320 if (evt.type == VIDEO_EVENT_SIZE_CHANGED)
322 struct iTSMPEGDecoder::videoEvent event;
323 event.type = iTSMPEGDecoder::videoEvent::eventSizeChanged;
324 event.aspect = evt.u.size.aspect_ratio;
325 event.height = evt.u.size.h;
326 event.width = evt.u.size.w;
327 /* emit */ m_event(event);
330 eDebug("unhandled DVBAPI Video Event %d", evt.type);
333 #warning "FIXMEE!! Video Events not implemented for old api"
337 RESULT eDVBVideo::connectEvent(const Slot1<void, struct iTSMPEGDecoder::videoEvent> &event, ePtr<eConnection> &conn)
339 conn = new eConnection(this, m_event.connect(event));
345 eDVBPCR::eDVBPCR(eDVBDemux *demux): m_demux(demux)
348 #if HAVE_DVB_API_VERSION < 3
349 sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
351 sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
353 m_fd_demux = ::open(filename, O_RDWR);
355 eWarning("%s: %m", filename);
358 int eDVBPCR::startPid(int pid)
362 dmx_pes_filter_params pes;
365 pes.input = DMX_IN_FRONTEND;
366 pes.output = DMX_OUT_DECODER;
367 pes.pes_type = DMX_PES_PCR;
369 if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
371 eWarning("video: DMX_SET_PES_FILTER: %m");
374 if (::ioctl(m_fd_demux, DMX_START) < 0)
376 eWarning("video: DMX_START: %m");
384 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
385 eWarning("video: DMX_STOP: %m");
394 DEFINE_REF(eDVBTText);
396 eDVBTText::eDVBTText(eDVBDemux *demux): m_demux(demux)
399 #if HAVE_DVB_API_VERSION < 3
400 sprintf(filename, "/dev/dvb/card%d/demux%d", demux->adapter, demux->demux);
402 sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux);
404 m_fd_demux = ::open(filename, O_RDWR);
406 eWarning("%s: %m", filename);
409 int eDVBTText::startPid(int pid)
413 dmx_pes_filter_params pes;
416 pes.input = DMX_IN_FRONTEND;
417 pes.output = DMX_OUT_DECODER;
418 pes.pes_type = DMX_PES_TELETEXT;
420 if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
422 eWarning("video: DMX_SET_PES_FILTER: %m");
425 if (::ioctl(m_fd_demux, DMX_START) < 0)
427 eWarning("video: DMX_START: %m");
433 void eDVBTText::stop()
435 if (::ioctl(m_fd_demux, DMX_STOP) < 0)
436 eWarning("video: DMX_STOP: %m");
439 eDVBTText::~eDVBTText()
445 DEFINE_REF(eTSMPEGDecoder);
447 int eTSMPEGDecoder::setState()
451 int noaudio = m_is_sm || m_is_ff || m_is_trickmode;
452 int nott = noaudio; /* actually same conditions */
454 if ((noaudio && m_audio) || (!m_audio && !noaudio))
455 m_changed |= changeAudio;
457 if ((nott && m_text) || (!m_text && !nott))
458 m_changed |= changeText;
460 bool changed = !!m_changed;
461 #if HAVE_DVB_API_VERSION < 3
462 if (m_changed & changeAudio && m_audio)
464 if (m_changed & changeVideo && m_video)
466 if (m_changed & changePCR && m_pcr)
471 if (m_changed & changeAudio && m_audio)
476 if (m_changed & changeVideo && m_video)
480 m_video_event_conn=0;
482 if (m_changed & changePCR)
484 m_pcr = new eDVBPCR(m_demux);
485 if (m_pcr->startPid(m_pcrpid))
487 eWarning("pcr: startpid failed!");
490 m_changed &= ~changePCR;
492 if (m_changed & changeVideo)
494 m_video = new eDVBVideo(m_demux, m_decoder);
495 m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
496 if (m_video->startPid(m_vpid))
498 eWarning("video: startpid failed!");
501 m_changed &= ~changeVideo;
503 if (m_changed & changeAudio)
505 m_audio = new eDVBAudio(m_demux, m_decoder);
506 if (m_audio->startPid(m_apid, m_atype))
508 eWarning("audio: startpid failed!");
511 m_changed &= ~changeAudio;
514 if (m_changed & changePCR)
519 if ((m_pcrpid >= 0) && (m_pcrpid < 0x1FFF))
521 m_pcr = new eDVBPCR(m_demux);
522 if (m_pcr->startPid(m_pcrpid))
524 eWarning("pcr: startpid failed!");
528 m_changed &= ~changePCR;
530 if (m_changed & changeVideo)
532 eDebug("VIDEO CHANGED (to %04x)", m_vpid);
538 m_video_event_conn = 0;
540 if ((m_vpid >= 0) && (m_vpid < 0x1FFF))
543 m_video = new eDVBVideo(m_demux, m_decoder);
544 m_video->connectEvent(slot(*this, &eTSMPEGDecoder::video_event), m_video_event_conn);
545 if (m_video->startPid(m_vpid, m_vtype))
547 eWarning("video: startpid failed!");
551 m_changed &= ~changeVideo;
553 if (m_changed & changeAudio)
558 if ((m_apid >= 0) && (m_apid < 0x1FFF) && !noaudio)
560 m_audio = new eDVBAudio(m_demux, m_decoder);
561 if (m_audio->startPid(m_apid, m_atype))
563 eWarning("audio: startpid failed!");
567 m_changed &= ~changeAudio;
569 if (m_changed & changeText)
574 if ((m_textpid >= 0) && (m_textpid < 0x1FFF) && !nott)
576 m_text = new eDVBTText(m_demux);
577 if (m_text->startPid(m_textpid))
579 eWarning("text: startpid failed!");
583 m_changed &= ~changeText;
586 if (changed && !m_video && m_audio && m_radio_pic.length())
587 showSinglePic(m_radio_pic.c_str());
592 int eTSMPEGDecoder::m_pcm_delay=-1,
593 eTSMPEGDecoder::m_ac3_delay=-1;
595 RESULT eTSMPEGDecoder::setPCMDelay(int delay)
597 if (m_decoder == 0 && delay != m_pcm_delay )
599 FILE *fp = fopen("/proc/stb/audio/audio_delay_pcm", "w");
602 fprintf(fp, "%x", delay*90);
611 RESULT eTSMPEGDecoder::setAC3Delay(int delay)
613 if ( m_decoder == 0 && delay != m_ac3_delay )
615 FILE *fp = fopen("/proc/stb/audio/audio_delay_bitstream", "w");
618 fprintf(fp, "%x", delay*90);
627 eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder): m_demux(demux), m_changed(0), m_decoder(decoder)
629 demux->connectEvent(slot(*this, &eTSMPEGDecoder::demux_event), m_demux_event_conn);
630 m_is_ff = m_is_sm = m_is_trickmode = 0;
633 eTSMPEGDecoder::~eTSMPEGDecoder()
635 m_vpid = m_apid = m_pcrpid = pidNone;
640 RESULT eTSMPEGDecoder::setVideoPID(int vpid, int type)
644 m_changed |= changeVideo;
651 RESULT eTSMPEGDecoder::setAudioPID(int apid, int type)
653 if ((m_apid != apid) || (m_atype != type))
655 m_changed |= changeAudio;
662 int eTSMPEGDecoder::m_audio_channel = -1;
664 RESULT eTSMPEGDecoder::setAudioChannel(int channel)
668 if (m_decoder == 0 && m_audio_channel != channel)
672 m_audio->setChannel(channel);
673 m_audio_channel=channel;
676 eDebug("eTSMPEGDecoder::setAudioChannel but no audio decoder exist");
681 int eTSMPEGDecoder::getAudioChannel()
683 return m_audio_channel == -1 ? ac_stereo : m_audio_channel;
686 RESULT eTSMPEGDecoder::setSyncPCR(int pcrpid)
688 if (m_pcrpid != pcrpid)
690 m_changed |= changePCR;
696 RESULT eTSMPEGDecoder::setTextPID(int textpid)
698 if (m_textpid != textpid)
700 m_changed |= changeText;
706 RESULT eTSMPEGDecoder::setSyncMaster(int who)
711 RESULT eTSMPEGDecoder::start()
720 /* preroll is start in freezed mode. */
721 RESULT eTSMPEGDecoder::preroll()
726 RESULT eTSMPEGDecoder::freeze(int cont)
737 RESULT eTSMPEGDecoder::unfreeze()
748 RESULT eTSMPEGDecoder::setSinglePictureMode(int when)
753 RESULT eTSMPEGDecoder::setPictureSkipMode(int what)
758 RESULT eTSMPEGDecoder::setFastForward(int frames_to_skip)
760 m_is_ff = frames_to_skip != 0;
765 return m_video->setFastForward(frames_to_skip);
770 RESULT eTSMPEGDecoder::setSlowMotion(int repeat)
772 m_is_sm = repeat != 0;
777 return m_video->setSlowMotion(repeat);
782 RESULT eTSMPEGDecoder::setZoom(int what)
787 RESULT eTSMPEGDecoder::flush()
796 void eTSMPEGDecoder::demux_event(int event)
800 case eDVBDemux::evtFlush:
808 RESULT eTSMPEGDecoder::setTrickmode(int what)
810 m_is_trickmode = what;
815 RESULT eTSMPEGDecoder::getPTS(int what, pts_t &pts)
817 if (what == 0) /* auto */
818 what = m_video ? 1 : 2;
820 if (what == 1) /* video */
823 return m_video->getPTS(pts);
828 if (what == 2) /* audio */
831 return m_audio->getPTS(pts);
839 RESULT eTSMPEGDecoder::setRadioPic(const std::string &filename)
841 m_radio_pic = filename;
845 RESULT eTSMPEGDecoder::showSinglePic(const char *filename)
849 FILE *f = fopen(filename, "r");
852 int vfd = open("/dev/dvb/adapter0/video0", O_RDWR);
855 fseek(f, 0, SEEK_END);
856 int length = ftell(f);
857 unsigned char *buffer = new unsigned char[length*2+9];
858 if (ioctl(vfd, VIDEO_FAST_FORWARD, 1) < 0)
859 eDebug("VIDEO_FAST_FORWARD failed (%m)");
860 if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0)
861 eDebug("VIDEO_SELECT_SOURCE MEMORY failed (%m)");
862 if (ioctl(vfd, VIDEO_PLAY) < 0)
863 eDebug("VIDEO_PLAY failed (%m)");
864 if (::ioctl(vfd, VIDEO_CONTINUE) < 0)
865 eDebug("video: VIDEO_CONTINUE: %m");
871 fseek(f, 0, SEEK_SET);
878 buffer[pos++]=(length*2)>>8;
879 buffer[pos++]=(length*2)&0xFF;
886 rd = fread(buffer+pos, 1, length, f);
894 write(vfd, buffer, pos);
895 usleep(75000); // i dont like this.. but i dont have a better solution :(
896 if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0)
897 eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)");
898 if (ioctl(vfd, VIDEO_FAST_FORWARD, 0) < 0)
899 eDebug("VIDEO_FAST_FORWARD failed (%m)");
907 eDebug("couldnt open %s", filename);
913 eDebug("only show single pics on first decoder");
919 RESULT eTSMPEGDecoder::connectVideoEvent(const Slot1<void, struct videoEvent> &event, ePtr<eConnection> &conn)
921 conn = new eConnection(this, m_video_event.connect(event));
925 void eTSMPEGDecoder::video_event(struct videoEvent event)
927 /* emit */ m_video_event(event);