diff options
Diffstat (limited to 'lib/dvb/decoder.cpp')
| -rw-r--r-- | lib/dvb/decoder.cpp | 245 |
1 files changed, 245 insertions, 0 deletions
diff --git a/lib/dvb/decoder.cpp b/lib/dvb/decoder.cpp new file mode 100644 index 00000000..e21e4567 --- /dev/null +++ b/lib/dvb/decoder.cpp @@ -0,0 +1,245 @@ +#include <lib/dvb/decoder.h> +#include <linux/dvb/audio.h> +#include <linux/dvb/video.h> +#include <linux/dvb/dmx.h> + +#include <unistd.h> +#include <fcntl.h> +#include <sys/ioctl.h> +#include <errno.h> + +DEFINE_REF(eDVBAudio); + +eDVBAudio::eDVBAudio(eDVBDemux *demux, int dev): ref(0), m_demux(demux) +{ + char filename[128]; + sprintf(filename, "/dev/dvb/adapter%d/audio%d", demux->adapter, dev); + m_fd = ::open(filename, O_RDWR); + if (m_fd < 0) + eWarning("%s: %m", filename); + sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux); + m_fd_demux = ::open(filename, O_RDWR); + if (m_fd_demux < 0) + eWarning("%s: %m", filename); +} + +int eDVBAudio::startPid(int pid) +{ + eDebug("setting audio pid to %x", pid); + if ((m_fd < 0) || (m_fd_demux < 0)) + return -1; + dmx_pes_filter_params pes; + + pes.pid = pid; + pes.input = DMX_IN_FRONTEND; + pes.output = DMX_OUT_DECODER; + pes.pes_type = DMX_PES_AUDIO0; + pes.flags = 0; + if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0) + { + eWarning("audio: DMX_SET_PES_FILTER: %m"); + return -errno; + } + if (::ioctl(m_fd_demux, DMX_START, &pes) < 0) + { + eWarning("audio: DMX_START: %m"); + return -errno; + } + + if (::ioctl(m_fd, AUDIO_PLAY) < 0) + eWarning("audio: AUDIO_PLAY: %m"); + return 0; +} + +void eDVBAudio::stop() +{ + if (::ioctl(m_fd, AUDIO_STOP) < 0) + eWarning("audio: AUDIO_STOP: %m"); + if (::ioctl(m_fd_demux, DMX_STOP) < 0) + eWarning("audio: DMX_STOP: %m"); +} + +eDVBAudio::~eDVBAudio() +{ + if (m_fd >= 0) + ::close(m_fd); + if (m_fd_demux >= 0) + ::close(m_fd_demux); +} + +DEFINE_REF(eDVBVideo); + +eDVBVideo::eDVBVideo(eDVBDemux *demux, int dev): ref(0), m_demux(demux) +{ + char filename[128]; + sprintf(filename, "/dev/dvb/adapter%d/video%d", demux->adapter, dev); + m_fd = ::open(filename, O_RDWR); + if (m_fd < 0) + eWarning("%s: %m", filename); + sprintf(filename, "/dev/dvb/adapter%d/demux%d", demux->adapter, demux->demux); + m_fd_demux = ::open(filename, O_RDWR); + if (m_fd_demux < 0) + eWarning("%s: %m", filename); +} + +int eDVBVideo::startPid(int pid) +{ + if ((m_fd < 0) || (m_fd_demux < 0)) + return -1; + dmx_pes_filter_params pes; + + pes.pid = pid; + pes.input = DMX_IN_FRONTEND; + pes.output = DMX_OUT_DECODER; + pes.pes_type = DMX_PES_VIDEO0; + pes.flags = 0; + if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0) + { + eWarning("video: DMX_SET_PES_FILTER: %m"); + return -errno; + } + if (::ioctl(m_fd_demux, DMX_START, &pes) < 0) + { + eWarning("video: DMX_START: %m"); + return -errno; + } + + if (::ioctl(m_fd, VIDEO_PLAY) < 0) + eWarning("video: VIDEO_PLAY: %m"); + else + eDebug("video ok"); + return 0; +} + +void eDVBVideo::stop() +{ + if (::ioctl(m_fd, VIDEO_STOP) < 0) + eWarning("video: VIDEO_STOP: %m"); + if (::ioctl(m_fd_demux, DMX_STOP) < 0) + eWarning("video: DMX_STOP: %m"); +} + +eDVBVideo::~eDVBVideo() +{ + if (m_fd >= 0) + ::close(m_fd); + if (m_fd_demux >= 0) + ::close(m_fd_demux); +} + +DEFINE_REF(eTSMPEGDecoder); + +int eTSMPEGDecoder::setState() +{ + int res = 0; + eDebug("changed %x", m_changed); + if (m_changed & changeAudio) + { + if (m_audio) + m_audio->stop(); + m_audio = 0; + m_audio = new eDVBAudio(m_demux, 0); + if (m_audio->startPid(m_apid)) + { + eWarning("audio: startpid failed!"); + res = -1; + } + m_changed &= ~changeAudio; + } + if (m_changed & changeVideo) + { + if (m_video) + m_video->stop(); + m_video = 0; + m_video = new eDVBVideo(m_demux, 0); + if (m_video->startPid(m_vpid)) + { + eWarning("video: startpid failed!"); + res = -1; + } + m_changed &= ~changeVideo; + } + return res; +} + +eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder): m_demux(demux) +{ +} + +eTSMPEGDecoder::~eTSMPEGDecoder() +{ + m_vpid = m_apid = m_pcrpid = pidNone; + m_changed = -1; + setState(); +} + +RESULT eTSMPEGDecoder::setVideoPID(int vpid) +{ + if (m_vpid != vpid) + { + m_changed |= changeVideo; + m_vpid = vpid; + } + return 0; +} + +RESULT eTSMPEGDecoder::setAudioPID(int apid, int type) +{ + if ((m_apid != apid) || (m_atype != type)) + { + m_changed |= changeAudio; + m_atype = type; + m_apid = apid; + } + return 0; +} + +RESULT eTSMPEGDecoder::setSyncPCR(int pcrpid) +{ + if (m_pcrpid != pcrpid) + { + m_changed |= changeAudio; + m_pcrpid = pcrpid; + } + return -1; +} + +RESULT eTSMPEGDecoder::setSyncMaster(int who) +{ + return -1; +} + +RESULT eTSMPEGDecoder::start() +{ + return setState(); +} + +RESULT eTSMPEGDecoder::freeze(int cont) +{ + return -1; +} + +RESULT eTSMPEGDecoder::unfreeze() +{ + return -1; +} + +RESULT eTSMPEGDecoder::setSinglePictureMode(int when) +{ + return -1; +} + +RESULT eTSMPEGDecoder::setPictureSkipMode(int what) +{ + return -1; +} + +RESULT eTSMPEGDecoder::setSlowMotion(int repeat) +{ + return -1; +} + +RESULT eTSMPEGDecoder::setZoom(int what) +{ + return -1; +} |