import of enigma2

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;
+}