From 4aaf147f7c30e21aae6ad264e71dab189eb15fd2 Mon Sep 17 00:00:00 2001 From: Andreas Monzner Date: Sat, 3 May 2008 10:38:55 +0000 Subject: [PATCH] showSinglePic is async and works on broadcom based dreamboxes --- lib/dvb/decoder.cpp | 106 ++++++++++++++++++++++++-------------------- lib/dvb/decoder.h | 4 +- 2 files changed, 60 insertions(+), 50 deletions(-) diff --git a/lib/dvb/decoder.cpp b/lib/dvb/decoder.cpp index 919c85a9..f3f9aac8 100644 --- a/lib/dvb/decoder.cpp +++ b/lib/dvb/decoder.cpp @@ -26,6 +26,8 @@ #include #include #include +#include +#include #include /* these are quite new... */ @@ -919,14 +921,25 @@ RESULT eTSMPEGDecoder::setAC3Delay(int delay) return -1; } -eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder): m_demux(demux), m_changed(0), m_decoder(decoder) +eTSMPEGDecoder::eTSMPEGDecoder(eDVBDemux *demux, int decoder) + :m_demux(demux), m_changed(0), m_decoder(decoder), m_video_clip_fd(-1), m_showSinglePicTimer(eApp) { demux->connectEvent(slot(*this, &eTSMPEGDecoder::demux_event), m_demux_event_conn); + CONNECT(m_showSinglePicTimer.timeout, eTSMPEGDecoder::finishShowSinglePic); m_is_ff = m_is_sm = m_is_trickmode = 0; } eTSMPEGDecoder::~eTSMPEGDecoder() { + if (m_video_clip_fd >= 0) + { + if (ioctl(m_video_clip_fd, VIDEO_STOP, 1) < 0) + eDebug("VIDEO_STOP failed (%m)"); + if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0) + eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)"); + close(m_video_clip_fd); + m_video_clip_fd = -1; + } m_vpid = m_apid = m_pcrpid = m_textpid = pidNone; m_changed = -1; setState(); @@ -1141,61 +1154,43 @@ RESULT eTSMPEGDecoder::showSinglePic(const char *filename) { if (m_decoder == 0) { - FILE *f = fopen(filename, "r"); + eDebug("showSinglePic %s", filename); + int f = open(filename, O_RDONLY); if (f) { - int vfd = open("/dev/dvb/adapter0/video0", O_RDWR); - if (vfd > 0) + struct stat s; + fstat(f, &s); + if (m_video_clip_fd == -1) + m_video_clip_fd = open("/dev/dvb/adapter0/video0", O_WRONLY|O_NONBLOCK); + if (m_video_clip_fd >= 0) { - fseek(f, 0, SEEK_END); - int length = ftell(f); - unsigned char *buffer = new unsigned char[length*2+9]; - if (ioctl(vfd, VIDEO_FAST_FORWARD, 1) < 0) - eDebug("VIDEO_FAST_FORWARD failed (%m)"); - if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_MEMORY) < 0) + bool seq_end_avail = false; + size_t pos=0; + unsigned char pes_header[] = { 0x00, 0x00, 0x01, 0xE0, 0x00, 0x00, 0x80, 0x00, 0x00 }; + unsigned char seq_end[] = { 0x00, 0x00, 0x01, 0xB7 }; + unsigned char iframe[s.st_size]; + unsigned char stuffing[8192]; + 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(vfd, VIDEO_PLAY) < 0) + if (ioctl(m_video_clip_fd, VIDEO_PLAY) < 0) eDebug("VIDEO_PLAY failed (%m)"); - if (::ioctl(vfd, VIDEO_CONTINUE) < 0) + if (::ioctl(m_video_clip_fd, VIDEO_CONTINUE) < 0) eDebug("video: VIDEO_CONTINUE: %m"); - int cnt=0; - int pos=0; - while(cnt<2) - { - int rd; - fseek(f, 0, SEEK_SET); - if (!cnt) - { - buffer[pos++]=0; - buffer[pos++]=0; - buffer[pos++]=1; - buffer[pos++]=0xE0; - buffer[pos++]=(length*2)>>8; - buffer[pos++]=(length*2)&0xFF; - buffer[pos++]=0x80; - buffer[pos++]=0; - buffer[pos++]=0; - } - while(1) - { - rd = fread(buffer+pos, 1, length, f); - if (rd > 0) - pos += rd; - else - break; - } - ++cnt; - } - write(vfd, buffer, pos); - usleep(75000); // i dont like this.. but i dont have a better solution :( - if (ioctl(vfd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0) - eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)"); - if (ioctl(vfd, VIDEO_FAST_FORWARD, 0) < 0) - eDebug("VIDEO_FAST_FORWARD failed (%m)"); - close(vfd); - delete [] buffer; + 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; + if ((iframe[3] >> 4) != 0xE) // no pes header + write(m_video_clip_fd, pes_header, sizeof(pes_header)); + write(m_video_clip_fd, iframe, s.st_size); + if (!seq_end_avail) + write(m_video_clip_fd, seq_end, sizeof(seq_end)); + write(m_video_clip_fd, stuffing, 8192); + m_showSinglePicTimer.start(150, true); } - fclose(f); + close(f); } else { @@ -1211,6 +1206,19 @@ RESULT eTSMPEGDecoder::showSinglePic(const char *filename) return 0; } +void eTSMPEGDecoder::finishShowSinglePic() +{ + if (m_video_clip_fd >= 0) + { + if (ioctl(m_video_clip_fd, VIDEO_STOP, 0) < 0) + eDebug("VIDEO_STOP failed (%m)"); + if (ioctl(m_video_clip_fd, VIDEO_SELECT_SOURCE, VIDEO_SOURCE_DEMUX) < 0) + eDebug("VIDEO_SELECT_SOURCE DEMUX failed (%m)"); + close(m_video_clip_fd); + m_video_clip_fd = -1; + } +} + RESULT eTSMPEGDecoder::connectVideoEvent(const Slot1 &event, ePtr &conn) { conn = new eConnection(this, m_video_event.connect(event)); diff --git a/lib/dvb/decoder.h b/lib/dvb/decoder.h index cd59b3d9..409a4421 100644 --- a/lib/dvb/decoder.h +++ b/lib/dvb/decoder.h @@ -107,7 +107,6 @@ class eTSMPEGDecoder: public Object, public iTSMPEGDecoder static int m_audio_channel; DECLARE_REF(eTSMPEGDecoder); std::string m_radio_pic; -private: ePtr m_demux; ePtr m_audio; ePtr m_video; @@ -130,6 +129,9 @@ private: void demux_event(int event); void video_event(struct videoEvent); Signal1 m_video_event; + int m_video_clip_fd; + eTimer m_showSinglePicTimer; + void finishShowSinglePic(); // called by timer public: enum { pidNone = -1 }; eTSMPEGDecoder(eDVBDemux *demux, int decoder); -- 2.30.2