git.cweiske.de
/
enigma2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
WirelessLan/Wlan.py: properly kill still running iwconfig console callbacks. fixes...
[enigma2.git]
/
lib
/
dvb
/
decoder.cpp
diff --git
a/lib/dvb/decoder.cpp
b/lib/dvb/decoder.cpp
index a4cffb77cc77e3c6629ae0597ca100c8b8faaa75..a89f72bbb69b021f890edabaf0ab1a03b3820bf6 100644
(file)
--- a/
lib/dvb/decoder.cpp
+++ b/
lib/dvb/decoder.cpp
@@
-12,8
+12,12
@@
#define dmxPesFilterParams dmx_pes_filter_params
#define DMX_PES_VIDEO0 DMX_PES_VIDEO
#define DMX_PES_AUDIO0 DMX_PES_AUDIO
#define dmxPesFilterParams dmx_pes_filter_params
#define DMX_PES_VIDEO0 DMX_PES_VIDEO
#define DMX_PES_AUDIO0 DMX_PES_AUDIO
+#define DMX_PES_PCR0 DMX_PES_PCR
+#define DMX_PES_TELETEXT0 DMX_PES_TELETEXT
#define DMX_PES_VIDEO1 DMX_PES_VIDEO
#define DMX_PES_AUDIO1 DMX_PES_AUDIO
#define DMX_PES_VIDEO1 DMX_PES_VIDEO
#define DMX_PES_AUDIO1 DMX_PES_AUDIO
+#define DMX_PES_PCR1 DMX_PES_PCR
+#define DMX_PES_TELETEXT1 DMX_PES_TELETEXT
#include <ost/dmx.h>
#include <ost/video.h>
#include <ost/audio.h>
#include <ost/dmx.h>
#include <ost/video.h>
#include <ost/audio.h>
@@
-196,6
+200,12
@@
int eDVBAudio::startPid(int pid, int type)
case aAACHE:
bypass = 9;
break;
case aAACHE:
bypass = 9;
break;
+ case aLPCM:
+ bypass = 6;
+ break;
+ case aDTSHD:
+ bypass = 0x10;
+ break;
}
eDebugNoNewLine("AUDIO_SET_BYPASS(%d) - ", bypass);
}
eDebugNoNewLine("AUDIO_SET_BYPASS(%d) - ", bypass);
@@
-203,8
+213,7
@@
int eDVBAudio::startPid(int pid, int type)
eDebug("failed (%m)");
else
eDebug("ok");
eDebug("failed (%m)");
else
eDebug("ok");
- freeze();
-
+ freeze(); // why freeze here?!? this is a problem when only a pid change is requested... because of the unfreeze logic in Decoder::setState
eDebugNoNewLine("AUDIO_PLAY - ");
if (::ioctl(m_fd, AUDIO_PLAY) < 0)
eDebug("failed (%m)");
eDebugNoNewLine("AUDIO_PLAY - ");
if (::ioctl(m_fd, AUDIO_PLAY) < 0)
eDebug("failed (%m)");
@@
-216,9
+225,6
@@
int eDVBAudio::startPid(int pid, int type)
void eDVBAudio::stop()
{
void eDVBAudio::stop()
{
-#if HAVE_DVB_API_VERSION > 2
- flush();
-#endif
eDebugNoNewLine("AUDIO_STOP - ");
if (::ioctl(m_fd, AUDIO_STOP) < 0)
eDebug("failed (%m)");
eDebugNoNewLine("AUDIO_STOP - ");
if (::ioctl(m_fd, AUDIO_STOP) < 0)
eDebug("failed (%m)");
@@
-285,7
+291,7
@@
int eDVBAudio::getPTS(pts_t &now)
eDVBAudio::~eDVBAudio()
{
eDVBAudio::~eDVBAudio()
{
- unfreeze();
+ unfreeze();
// why unfreeze here... but not unfreeze video in ~eDVBVideo ?!?
if (m_fd >= 0)
::close(m_fd);
if (m_fd_demux >= 0)
if (m_fd >= 0)
::close(m_fd);
if (m_fd_demux >= 0)
@@
-448,7
+454,7
@@
int eDVBVideo::startPid(int pid, int type)
return -errno;
}
eDebug("ok");
return -errno;
}
eDebug("ok");
- freeze();
+ freeze();
// why freeze here?!? this is a problem when only a pid change is requested... because of the unfreeze logic in Decoder::setState
eDebugNoNewLine("VIDEO_PLAY - ");
if (::ioctl(m_fd, VIDEO_PLAY) < 0)
eDebug("failed (%m)");
eDebugNoNewLine("VIDEO_PLAY - ");
if (::ioctl(m_fd, VIDEO_PLAY) < 0)
eDebug("failed (%m)");
@@
-598,7
+604,7
@@
RESULT eDVBVideo::connectEvent(const Slot1<void, struct iTSMPEGDecoder::videoEve
return 0;
}
return 0;
}
-static int readMpegProc(char *str, int decoder)
+static int readMpegProc(c
onst c
har *str, int decoder)
{
int val = -1;
char tmp[64];
{
int val = -1;
char tmp[64];
@@
-687,7
+693,7
@@
int eDVBVideo::getFrameRate()
DEFINE_REF(eDVBPCR);
DEFINE_REF(eDVBPCR);
-eDVBPCR::eDVBPCR(eDVBDemux *demux
): m_demux(demux
)
+eDVBPCR::eDVBPCR(eDVBDemux *demux
, int dev): m_demux(demux), m_dev(dev
)
{
char filename[128];
#if HAVE_DVB_API_VERSION < 3
{
char filename[128];
#if HAVE_DVB_API_VERSION < 3
@@
-746,7
+752,7
@@
int eDVBPCR::startPid(int pid)
pes.pid = pid;
pes.input = DMX_IN_FRONTEND;
pes.output = DMX_OUT_DECODER;
pes.pid = pid;
pes.input = DMX_IN_FRONTEND;
pes.output = DMX_OUT_DECODER;
- pes.pes_type =
DMX_PES_PCR;
+ pes.pes_type =
m_dev ? DMX_PES_PCR1 : DMX_PES_PCR0; /* FIXME */
pes.flags = 0;
eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - pcr - ", pid);
if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
pes.flags = 0;
eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - pcr - ", pid);
if (::ioctl(m_fd_demux, DMX_SET_PES_FILTER, &pes) < 0)
@@
-783,7
+789,8
@@
eDVBPCR::~eDVBPCR()
DEFINE_REF(eDVBTText);
DEFINE_REF(eDVBTText);
-eDVBTText::eDVBTText(eDVBDemux *demux): m_demux(demux)
+eDVBTText::eDVBTText(eDVBDemux *demux, int dev)
+ :m_demux(demux), m_dev(dev)
{
char filename[128];
#if HAVE_DVB_API_VERSION < 3
{
char filename[128];
#if HAVE_DVB_API_VERSION < 3
@@
-805,7
+812,7
@@
int eDVBTText::startPid(int pid)
pes.pid = pid;
pes.input = DMX_IN_FRONTEND;
pes.output = DMX_OUT_DECODER;
pes.pid = pid;
pes.input = DMX_IN_FRONTEND;
pes.output = DMX_OUT_DECODER;
- pes.pes_type =
DMX_PES_TELETEXT;
+ pes.pes_type =
m_dev ? DMX_PES_TELETEXT1 : DMX_PES_TELETEXT0; // FIXME
pes.flags = 0;
eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - ttx - ", pid);
pes.flags = 0;
eDebugNoNewLine("DMX_SET_PES_FILTER(0x%02x) - ttx - ", pid);
@@
-815,7
+822,7
@@
int eDVBTText::startPid(int pid)
return -errno;
}
eDebug("ok");
return -errno;
}
eDebug("ok");
- eDebugNoNewLine("DEMUX_START -
pcr
- ");
+ eDebugNoNewLine("DEMUX_START -
ttx
- ");
if (::ioctl(m_fd_demux, DMX_START) < 0)
{
eDebug("failed(%m)");
if (::ioctl(m_fd_demux, DMX_START) < 0)
{
eDebug("failed(%m)");
@@
-855,7
+862,10
@@
int eTSMPEGDecoder::setState()
if ((nott && m_text) || (!m_text && !nott))
m_changed |= changeText | changeState;
if ((nott && m_text) || (!m_text && !nott))
m_changed |= changeText | changeState;
- bool changed = !!m_changed;
+ const char *decoder_states[] = {"stop", "pause", "play", "decoderfastforward", "trickmode", "slowmotion"};
+ eDebug("decoder state: %s, vpid=%d, apid=%d", decoder_states[m_state], m_vpid, m_apid);
+
+ int changed = m_changed;
#if HAVE_DVB_API_VERSION < 3
bool checkAVSync = m_changed & (changeAudio|changeVideo|changePCR);
if (m_changed & changeAudio && m_audio)
#if HAVE_DVB_API_VERSION < 3
bool checkAVSync = m_changed & (changeAudio|changeVideo|changePCR);
if (m_changed & changeAudio && m_audio)
@@
-893,7
+903,7
@@
int eTSMPEGDecoder::setState()
}
if (m_changed & changePCR)
{
}
if (m_changed & changePCR)
{
- m_pcr = new eDVBPCR(m_demux);
+ m_pcr = new eDVBPCR(m_demux
, m_decoder
);
if (m_pcr->setPid(m_pcrpid))
res = -1;
}
if (m_pcr->setPid(m_pcrpid))
res = -1;
}
@@
-958,7
+968,7
@@
int eTSMPEGDecoder::setState()
{
if ((m_pcrpid >= 0) && (m_pcrpid < 0x1FFF))
{
{
if ((m_pcrpid >= 0) && (m_pcrpid < 0x1FFF))
{
- m_pcr = new eDVBPCR(m_demux);
+ m_pcr = new eDVBPCR(m_demux
, m_decoder
);
if (m_pcr->startPid(m_pcrpid))
res = -1;
}
if (m_pcr->startPid(m_pcrpid))
res = -1;
}
@@
-989,7
+999,7
@@
int eTSMPEGDecoder::setState()
{
if ((m_textpid >= 0) && (m_textpid < 0x1FFF) && !nott)
{
{
if ((m_textpid >= 0) && (m_textpid < 0x1FFF) && !nott)
{
- m_text = new eDVBTText(m_demux);
+ m_text = new eDVBTText(m_demux
, m_decoder
);
if (m_text->startPid(m_textpid))
res = -1;
}
if (m_text->startPid(m_textpid))
res = -1;
}
@@
-997,7
+1007,7
@@
int eTSMPEGDecoder::setState()
}
#endif
}
#endif
- if (
m_changed & changeState
)
+ if (
changed & (changeState|changeVideo|changeAudio)
)
{
/* play, slowmotion, fast-forward */
int state_table[6][4] =
{
/* play, slowmotion, fast-forward */
int state_table[6][4] =
@@
-1010,7
+1020,7
@@
int eTSMPEGDecoder::setState()
/* [stateSlowMotion] = */ {1, m_ff_sm_ratio, 0}
};
int *s = state_table[m_state];
/* [stateSlowMotion] = */ {1, m_ff_sm_ratio, 0}
};
int *s = state_table[m_state];
- if (m_video)
+ if (
changed & (changeState|changeVideo) &&
m_video)
{
m_video->setSlowMotion(s[1]);
m_video->setFastForward(s[2]);
{
m_video->setSlowMotion(s[1]);
m_video->setFastForward(s[2]);
@@
-1019,7
+1029,7
@@
int eTSMPEGDecoder::setState()
else
m_video->freeze();
}
else
m_video->freeze();
}
- if (m_audio)
+ if (
changed & (changeState|changeAudio) &&
m_audio)
{
if (s[0])
m_audio->unfreeze();
{
if (s[0])
m_audio->unfreeze();
@@
-1038,9
+1048,9
@@
int eTSMPEGDecoder::setState()
int eTSMPEGDecoder::m_pcm_delay=-1,
eTSMPEGDecoder::m_ac3_delay=-1;
int eTSMPEGDecoder::m_pcm_delay=-1,
eTSMPEGDecoder::m_ac3_delay=-1;
-RESULT eTSMPEGDecoder::setPCMDelay(int delay)
+RESULT eTSMPEGDecoder::set
Hw
PCMDelay(int delay)
{
{
- if (
m_decoder == 0 &&
delay != m_pcm_delay )
+ if (delay != m_pcm_delay )
{
FILE *fp = fopen("/proc/stb/audio/audio_delay_pcm", "w");
if (fp)
{
FILE *fp = fopen("/proc/stb/audio/audio_delay_pcm", "w");
if (fp)
@@
-1054,9
+1064,9
@@
RESULT eTSMPEGDecoder::setPCMDelay(int delay)
return -1;
}
return -1;
}
-RESULT eTSMPEGDecoder::setAC3Delay(int delay)
+RESULT eTSMPEGDecoder::set
Hw
AC3Delay(int delay)
{
{
- if (
m_decoder == 0 &&
delay != m_ac3_delay )
+ if ( delay != m_ac3_delay )
{
FILE *fp = fopen("/proc/stb/audio/audio_delay_bitstream", "w");
if (fp)
{
FILE *fp = fopen("/proc/stb/audio/audio_delay_bitstream", "w");
if (fp)
@@
-1070,6
+1080,17
@@
RESULT eTSMPEGDecoder::setAC3Delay(int delay)
return -1;
}
return -1;
}
+
+RESULT eTSMPEGDecoder::setPCMDelay(int delay)
+{
+ return m_decoder == 0 ? setHwPCMDelay(delay) : -1;
+}
+
+RESULT eTSMPEGDecoder::setAC3Delay(int delay)
+{
+ return m_decoder == 0 ? setHwAC3Delay(delay) : -1;
+}
+
eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder)
: m_demux(demux),
m_vpid(-1), m_vtype(-1), m_apid(-1), m_atype(-1), m_pcrpid(-1), m_textpid(-1),
eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder)
: m_demux(demux),
m_vpid(-1), m_vtype(-1), m_apid(-1), m_atype(-1), m_pcrpid(-1), m_textpid(-1),
@@
-1090,7
+1111,7
@@
eTSMPEGDecoder::~eTSMPEGDecoder()
RESULT eTSMPEGDecoder::setVideoPID(int vpid, int type)
{
RESULT eTSMPEGDecoder::setVideoPID(int vpid, int type)
{
- if (
m_vpid != vpid
)
+ if (
(m_vpid != vpid) || (m_vtype != type)
)
{
m_changed |= changeVideo;
m_vpid = vpid;
{
m_changed |= changeVideo;
m_vpid = vpid;
@@
-1167,9
+1188,14
@@
RESULT eTSMPEGDecoder::set()
RESULT eTSMPEGDecoder::play()
{
if (m_state == statePlay)
RESULT eTSMPEGDecoder::play()
{
if (m_state == statePlay)
- return 0;
- m_state = statePlay;
- m_changed |= changeState;
+ {
+ if (!m_changed)
+ return 0;
+ } else
+ {
+ m_state = statePlay;
+ m_changed |= changeState;
+ }
return setState();
}
return setState();
}
@@
-1276,9
+1302,10
@@
RESULT eTSMPEGDecoder::showSinglePic(const char *filename)
if (f >= 0)
{
struct stat s;
if (f >= 0)
{
struct stat s;
+ size_t written=0;
fstat(f, &s);
if (m_video_clip_fd == -1)
fstat(f, &s);
if (m_video_clip_fd == -1)
- m_video_clip_fd = open("/dev/dvb/adapter0/video0", O_WRONLY
|O_NONBLOCK
);
+ m_video_clip_fd = open("/dev/dvb/adapter0/video0", O_WRONLY);
if (m_video_clip_fd >= 0)
{
bool seq_end_avail = false;
if (m_video_clip_fd >= 0)
{
bool seq_end_avail = false;
@@
-1287,15
+1314,18
@@
RESULT eTSMPEGDecoder::showSinglePic(const char *filename)
unsigned char seq_end[] = { 0x00, 0x00, 0x01, 0xB7 };
unsigned char iframe[s.st_size];
unsigned char stuffing[8192];
unsigned char seq_end[] = { 0x00, 0x00, 0x01, 0xB7 };
unsigned char iframe[s.st_size];
unsigned char stuffing[8192];
+ int streamtype = VIDEO_STREAMTYPE_MPEG2;
memset(stuffing, 0, 8192);
read(f, iframe, s.st_size);
if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0)
eDebug("VIDEO_SELECT_SOURCE MEMORY failed (%m)");
memset(stuffing, 0, 8192);
read(f, iframe, s.st_size);
if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0)
eDebug("VIDEO_SELECT_SOURCE MEMORY failed (%m)");
+ if (ioctl(m_video_clip_fd, VIDEO_SET_STREAMTYPE, streamtype) < 0)
+ eDebug("VIDEO_SET_STREAMTYPE failed(%m)");
if (ioctl(m_video_clip_fd, VIDEO_PLAY) < 0)
eDebug("VIDEO_PLAY failed (%m)");
if (ioctl(m_video_clip_fd, VIDEO_PLAY) < 0)
eDebug("VIDEO_PLAY failed (%m)");
- if (
::
ioctl(m_video_clip_fd, VIDEO_CONTINUE) < 0)
+ if (ioctl(m_video_clip_fd, VIDEO_CONTINUE) < 0)
eDebug("video: VIDEO_CONTINUE: %m");
eDebug("video: VIDEO_CONTINUE: %m");
- if (
::
ioctl(m_video_clip_fd, VIDEO_CLEAR_BUFFER) < 0)
+ if (ioctl(m_video_clip_fd, VIDEO_CLEAR_BUFFER) < 0)
eDebug("video: VIDEO_CLEAR_BUFFER: %m");
while(pos <= (s.st_size-4) && !(seq_end_avail = (!iframe[pos] && !iframe[pos+1] && iframe[pos+2] == 1 && iframe[pos+3] == 0xB7)))
++pos;
eDebug("video: VIDEO_CLEAR_BUFFER: %m");
while(pos <= (s.st_size-4) && !(seq_end_avail = (!iframe[pos] && !iframe[pos+1] && iframe[pos+2] == 1 && iframe[pos+3] == 0xB7)))
++pos;