Ticket #843: pipplayer.diff

libs/libmythtv/NuppelVideoPlayer.cpp

@@ -204 +204 @@
       audio_samplerate(44100),      audio_stretchfactor(1.0f),
       // Picture-in-Picture
       pipplayer(NULL), setpipplayer(NULL), needsetpipplayer(false),
+      ispip(false), softwareScalingPIP(false),
       // Preview window support
       argb_buf(NULL),               argb_size(0,0),
       yuv2argb_conv(yuv2rgb_init_mmx(32, MODE_RGB)),
@@ -294 +295 @@
 
     if (m_playbackinfo)
     {
-        m_playbackinfo->MarkAsInUse(false);
+        if (!ispip)
+            m_playbackinfo->MarkAsInUse(false);
         delete m_playbackinfo;
     }
 
@@ -494 +496 @@
 bool NuppelVideoPlayer::InitVideo(void)
 {
     InitFilters();
+
+    PIPType piptype = kPIPOff;
+
     if (using_null_videoout)
     {
         videoOutput = new VideoOutputNull();
+        if (ispip)
+        {
+            if (m_tv)
+            {
+                if (livetv)
+                    piptype = kPIPOnLiveTV;
+                else
+                    piptype = kPIPOnTV;
+            }
+            else
+                piptype = kPIPOn;
+
+            videoOutput->SetAsPIP(piptype);
+        }
+    
+           
         if (!videoOutput->Init(video_width, video_height, video_aspect,
                                0, 0, 0, 0, 0, 0))
         {
@@ -540 +561 @@
             return false;
         }
 
+        if (ispip)
+        {
+            if (m_tv)
+                piptype = kPIPOnTV;
+            else
+                piptype = kPIPOn;
+            
+            videoOutput->SetAsPIP(piptype);
+        }
+
         if (!videoOutput->Init(video_width, video_height, video_aspect,
                                widget->winId(), 0, 0, widget->width(),
                                widget->height(), 0))
         {
             errored = true;
+        }
+        
+        if (errored && ispip)
+        {
+            softwareScalingPIP = true;
+            delete videoOutput;
+            videoOutput = NULL;
+            errored = true;
             return false;
         }
 
@@ -636 +675 @@
 {
     QString errMsg = QString::null;
 
-    if ((audio_bits <= 0) || (audio_channels <= 0) || (audio_samplerate <= 0))
+    if (ispip || (audio_bits <= 0) || (audio_channels <= 0) || (audio_samplerate <= 0))
     {
         VERBOSE(VB_IMPORTANT, LOC +
                 QString("Disabling Audio, params(%1,%2,%3)")
@@ -756 +795 @@
 
 void NuppelVideoPlayer::AutoDeint(VideoFrame *frame)
 {
-    if (!frame || m_scan_locked)
+    if (!frame || m_scan_locked || ispip)
         return;
 
     if (frame->interlaced_frame) 
@@ -798 +837 @@
 {
     QMutexLocker locker(&videofiltersLock);
 
-    if (!videoOutput || !videosync)
+    if (!videoOutput || !videosync || ispip)
         return; // hopefully this will be called again later...
 
     m_scan_locked = (scan != kScan_Detect);
@@ -1059 +1098 @@
 
 void NuppelVideoPlayer::InitFilters(void)
 {
+    if (ispip)
+        return;
+
     VideoFrameType itmp = FMT_YV12;
     VideoFrameType otmp = FMT_YV12;
     int btmp;
@@ -2078 +2120 @@
 {
     float diverge = 0.0f;
 
+    if (ispip && framesPlayed % 2)
+    {
+        videosync->AdvanceTrigger();
+        framesPlayed++;
+        if (!using_null_videoout)
+            videoOutput->SetFramesPlayed(framesPlayed + 1);
+        return;
+    } 
+
     VideoFrame *buffer = videoOutput->GetLastShownFrame();
     if (!buffer)
     {
@@ -2553 +2604 @@
     else if (videoOutput)
     {
         // Set up deinterlacing in the video output method
-        m_double_framerate =
-            (videoOutput->SetupDeinterlace(true) &&
-             videoOutput->NeedsDoubleFramerate());
-
+        if (ispip)
+        {
+            m_double_framerate = false;
+            videoOutput->SetupDeinterlace(true, "onefield");
+        }
+        else
+        {
+            m_double_framerate =
+                (videoOutput->SetupDeinterlace(true) &&
+                videoOutput->NeedsDoubleFramerate());
+        }
+        
         videosync = VideoSync::BestMethod(
             videoOutput, fr_int, rf_int, m_double_framerate);
 
@@ -2589 +2648 @@
         {
             pipplayer = setpipplayer;
             needsetpipplayer = false;
+            if (m_tv)
+                m_tv->PIPPlayerWake();
         }
 
         if (ringBuffer->isDVD())
@@ -3049 +3110 @@
 
     if (!InitVideo())
     {
-        qApp->lock();
-        DialogBox *dialog = new DialogBox(gContext->GetMainWindow(),
+        if (!ispip)
+        {
+            qApp->lock();
+            DialogBox *dialog = new DialogBox(gContext->GetMainWindow(),
                                    QObject::tr("Unable to initialize video."));
-        dialog->AddButton(QObject::tr("Return to menu."));
-        dialog->exec();
-        delete dialog;
+            dialog->AddButton(QObject::tr("Return to menu."));
+            dialog->exec();
+            delete dialog;
+            qApp->unlock();
+        }
 
-        qApp->unlock();
-
         if (audioOutput)
         {
             delete audioOutput;
@@ -3656 +3719 @@
     int numFrames = totalFrames;
 
     if (m_playbackinfo->GetTranscodedStatus() != TRANSCODING_COMPLETE)
-        numFrames = (m_playbackinfo->endts.toTime_t() -
-                    m_playbackinfo->recstartts.toTime_t()) * video_frame_rate;
+        numFrames = (int)((m_playbackinfo->endts.toTime_t() -
+                    m_playbackinfo->recstartts.toTime_t()) * video_frame_rate);
 
     int offset = (int) round(0.14 * (numFrames / video_frame_rate));
 
@@ -3680 +3743 @@
 
 void NuppelVideoPlayer::SetBookmark(void)
 {
-    if (!m_playbackinfo || !osd)
+    if (!m_playbackinfo)
         return;
 
     m_playbackinfo->SetBookmark(framesPlayed);
-    osd->SetSettingsText(QObject::tr("Position Saved"), 1);
+    if (osd)
+    {
+        osd->SetSettingsText(QObject::tr("Position Saved"), 1);
 
-    struct StatusPosInfo posInfo;
-    calcSliderPos(posInfo);
-    osd->ShowStatus(posInfo, false, QObject::tr("Position"), 2);
+        struct StatusPosInfo posInfo;
+        calcSliderPos(posInfo);
+        osd->ShowStatus(posInfo, false, QObject::tr("Position"), 2);
+    }
 }
 
 void NuppelVideoPlayer::ClearBookmark(void)

libs/libmythtv/libmythtv.pro

@@ -216 +216 @@
 
     # Video playback
     HEADERS += tv_play.h                NuppelVideoPlayer.h
-    HEADERS += DVDRingBuffer.h
+    HEADERS += DVDRingBuffer.h          pipplayer.h
     SOURCES += tv_play.cpp              NuppelVideoPlayer.cpp
-    SOURCES += DVDRingBuffer.cpp
+    SOURCES += DVDRingBuffer.cpp        pipplayer.cpp
 
     # Text subtitle parser
     HEADERS += textsubtitleparser.h     xine_demux_sputext.h

libs/libmythtv/tv_play.h

@@ -33 +33 @@
 class OSDListTreeType;
 class OSDGenericTree;
 class LiveTVChain;
+class PIPPlayer;
 
 typedef QValueVector<QString>    str_vec_t;
 typedef QMap<QString,QString>    InfoMap;
@@ -126 +127 @@
     void ShowNoRecorderDialog(void);
     void FinishRecording(void);
     void AskAllowRecording(const QStringList&, int, bool);
+    void PIPPlayerWake(void) { pipplayerCond.wakeAll(); }
     void PromptStopWatchingRecording(void);
     void PromptDeleteRecording(QString title);
     
-
     // Boolean queries
 
     /// Returns true if we are playing back a non-LiveTV recording.
@@ -161 +162 @@
     bool IsErrored(void)         const { return errored; }
     /// true if dialog is either videoplayexit, playexit or askdelete dialog
     bool IsVideoExitDialog(void);
+    /// true if PIP is active NVP
+    bool IsPIPActiveNVP(void);
     
     // Other queries
     int GetLastRecorderNum(void) const;
@@ -320 +323 @@
 
     void SetupPlayer(bool isWatchingRecording);
     void TeardownPlayer(void);
-    void SetupPipPlayer(void);
-    void TeardownPipPlayer(void);
     
     void HandleStateChange(void);
     bool InStateChange(void) const;
@@ -331 +332 @@
     void TogglePIPView(void);
     void ToggleActiveWindow(void);
     void SwapPIP(void);
+    TVState GetPIPState(PIPPlayer *pip);
     void SwapPIPSoon(void) { needToSwapPIP = true; }
-
+    
     void ToggleAutoExpire(void);
 
     void BrowseStart(void);
@@ -529 +531 @@
 
     // Video Players
     NuppelVideoPlayer *nvp;
-    NuppelVideoPlayer *pipnvp;
+    PIPPlayer  *pipplayer; 
     NuppelVideoPlayer *activenvp;  ///< Player to which LiveTV events are sent
 
+    //PIP Stuff
+    QWaitCondition pipplayerCond;
+
     // Remote Encoders
     /// Main recorder
     RemoteEncoder *recorder;
-    /// Picture-in-Picture recorder
-    RemoteEncoder *piprecorder;
     /// Recorder to which LiveTV events are being sent
     RemoteEncoder *activerecorder;
     /// Main recorder to use after a successful SwitchCards() call.
@@ -546 +549 @@
 
     // LiveTVChain
     LiveTVChain *tvchain;
-    LiveTVChain *piptvchain;
     QStringList tvchainUpdate;
     QMutex tvchainUpdateLock;
 
     // RingBuffers
     RingBuffer *prbuffer;
-    RingBuffer *piprbuffer;
     RingBuffer *activerbuffer; ///< Ringbuffer to which LiveTV events are sent
 
     // OSD info
@@ -589 +590 @@
     pthread_t event;
     /// Video decoder thread, runs nvp's NuppelVideoPlayer::StartPlaying().
     pthread_t decode;
-    /// Picture-in-Picture video decoder thread,
-    /// runs pipnvp's NuppelVideoPlayer::StartPlaying().
-    pthread_t pipdecode;
 
     /// Condition to signal that the Event thread is up and running
     QWaitCondition mainLoopCond;

libs/libmythtv/pipplayer.h

@@ +1 @@
+#ifndef PIPPLAYER_H
+#define PIPPLAYER_H
+
+#include <qpainter.h>
+#include "NuppelVideoPlayer.h"
+#include "RingBuffer.h"
+#include "programinfo.h"
+#include "livetvchain.h"
+#include "remoteencoder.h"
+
+class RingBuffer;
+class ProgramInfo;
+class LiveTVChain;
+class RemoteEncoder;
+class NuppelVideoPlayer;
+class TV;
+
+class PIPPlayer
+{
+    public:
+        PIPPlayer(void);
+        ~PIPPlayer(void);
+        static PIPPlayer *Create(const QRect &rect);
+        static PIPPlayer * Create(NuppelVideoPlayer *parentnvp, int location);
+        bool StartPlaying(ProgramInfo *rec = NULL, 
+                            bool piptype = false,
+                            bool nullvideo = false,
+                            TV *parent = NULL);
+        void StopPlaying();
+        bool IsPlaying(void) { return (pipnvp && pipnvp->IsPlaying()); }
+        bool IsSameProgram(ProgramInfo *rec);
+        RingBuffer          *GetRingBuffer(void) { return piprbuffer; }
+        RemoteEncoder       *GetRecorder(void) { return piprecorder; }
+        LiveTVChain         *GetLiveTVChain(void) { return piptvchain; }
+        NuppelVideoPlayer   *GetNVP(void) { return pipnvp; }
+        ProgramInfo         *GetProgramInfo(void) { return piprecinfo; }
+        void SetRingBuffer(RingBuffer *rbuffer);
+        void SetLiveTVChain(LiveTVChain *tvchain);
+        void SetRecorder(RemoteEncoder  *recorder);
+        void SetProgramInfo(ProgramInfo *pginfo);
+        void SetReinit(bool change) { reinit = change; }
+        bool IsLiveTV(void) { return islivetv; }
+        bool IsHidden(void);
+        void Hide(void);
+        void Show(void);
+        bool UsingNullVideo(void) { return using_nullvideo; }
+        void GetARGBFrame(void);
+        QSize GetVideoDimensions(void) 
+                { return QSize(video_width, video_height); }
+        bool IsPaused(void) { return paused; }
+        void Pause(void);
+        void Play(float speed = 1.0);
+        
+
+    private:
+        bool StartRecorder(RemoteEncoder *rec, int maxWait);
+        void Reinitialize(void);
+        void Init(QRect rect, QString name);
+
+    private:
+        RemoteEncoder *piprecorder;
+        RingBuffer *piprbuffer;
+        LiveTVChain  *piptvchain;
+        ProgramInfo *piprecinfo;
+        NuppelVideoPlayer *pipnvp;
+        pthread_t videoThread;
+        pthread_t pipdecode;
+        QWidget *pipWindow;
+        bool islivetv;
+        bool reinit;
+        bool using_nullvideo;
+        int video_width;
+        int video_height;
+        bool paused;
+};
+
+#endif
+#ifndef PIPPLAYER_H
+#define PIPPLAYER_H
+
+#include <qpainter.h>
+#include "NuppelVideoPlayer.h"
+#include "RingBuffer.h"
+#include "programinfo.h"
+#include "livetvchain.h"
+#include "remoteencoder.h"
+
+class RingBuffer;
+class ProgramInfo;
+class LiveTVChain;
+class RemoteEncoder;
+class NuppelVideoPlayer;
+
+class PIPPlayer
+{
+    public:
+        PIPPlayer(void);
+        ~PIPPlayer(void);
+        static PIPPlayer *Create(const QRect &rect);
+        static PIPPlayer * Create(NuppelVideoPlayer *parentnvp, int location);
+        bool StartPlaying(ProgramInfo *rec = NULL, 
+                            bool piptype = false,
+                            bool nullvideo = false);
+        void StopPlaying();
+        bool IsPlaying(void) { return (pipnvp && pipnvp->IsPlaying()); }
+        void SetFrameRate(double fps);
+        bool IsSameProgram(ProgramInfo *rec);
+        RingBuffer          *GetRingBuffer(void) { return piprbuffer; }
+        RemoteEncoder       *GetRecorder(void) { return piprecorder; }
+        LiveTVChain         *GetLiveTVChain(void) { return piptvchain; }
+        NuppelVideoPlayer   *GetNVP(void) { return pipnvp; }
+        ProgramInfo         *GetProgramInfo(void) { return piprecinfo; }
+        void SetRingBuffer(RingBuffer *rbuffer);
+        void SetLiveTVChain(LiveTVChain *tvchain);
+        void SetRecorder(RemoteEncoder  *recorder);
+        void SetProgramInfo(ProgramInfo *pginfo);
+        void SetReinit(bool change) { reinit = change; }
+        bool IsLiveTV(void) { return islivetv; }
+        bool IsHidden(void);
+        void Hide(void);
+        void Show(void);
+        bool UsingNullVideo(void) { return using_nullvideo; }
+        void DisplaySoftwareScaledImage(void);
+        
+
+    private:
+        bool StartRecorder(RemoteEncoder *rec, int maxWait);
+        void Reinitialize(void);
+        void Init(QRect rect, QString name);
+
+    private:
+        RemoteEncoder *piprecorder;
+        RingBuffer *piprbuffer;
+        LiveTVChain  *piptvchain;
+        ProgramInfo *piprecinfo;
+        NuppelVideoPlayer *pipnvp;
+        pthread_t videoThread;
+        pthread_t pipdecode;
+        QWidget *pipWindow;
+        bool islivetv;
+        bool reinit;
+        bool using_nullvideo;
+};
+
+#endif

libs/libmythtv/NuppelVideoPlayer.h

@@ -128 +128 @@
 
     // Sets
     void SetParentWidget(QWidget *widget)     { parentWidget = widget; }
-    void SetAsPIP(void)                       { SetNoAudio(); SetNullVideo(); }
+    void SetAsPIP(bool setNullVideo)         
+        { if (setNullVideo) SetNullVideo(); ispip = true; }
     void SetNullVideo(void)                   { using_null_videoout = true; }
     void SetFileName(QString lfilename)       { filename = lfilename; }
     void SetExactSeeks(bool exact)            { exactseeks = exact; }
@@ -140 +141 @@
     void SetVideoFilters(QString &filters)    { videoFilterList = filters; }
     void SetFramesPlayed(long long played)    { framesPlayed = played; }
     void SetEof(void)                         { eof = true; }
-    void SetPipPlayer(NuppelVideoPlayer *pip)
+    void SetPIPPlayer(NuppelVideoPlayer *pip)
         { setpipplayer = pip; needsetpipplayer = true; }
     void SetRecorder(RemoteEncoder *recorder);
     void SetParentPlayer(TV *tv)             { m_tv = tv; }
@@ -193 +194 @@
     bool    GetRawAudioState(void) const;
     bool    GetLimitKeyRepeat(void) const     { return limitKeyRepeat; }
     bool    GetEof(void) const                { return eof; }
-    bool    PipPlayerSet(void) const          { return !needsetpipplayer; }
+    bool    PIPPlayerSet(void) const          { return !needsetpipplayer; }
+    bool    HasPIPPlayer(void) const          { return (pipplayer != NULL); }
     bool    IsErrored(void) const             { return errored; }
     bool    IsPlaying(void) const             { return playing; }
     bool    AtNormalSpeed(void) const         { return next_normal_speed; }
@@ -203 +205 @@
     bool    PlayingSlowForPrebuffer(void) const { return m_playing_slower; }
     bool    HasAudioIn(void) const            { return !no_audio_in; }
     bool    HasAudioOut(void) const           { return !no_audio_out; }
+    bool    PIPSoftwareScaling(void)          { return softwareScalingPIP; }
 
     // Complicated gets
     long long CalcMaxFFTime(long long ff, bool setjump = true) const;
@@ -670 +673 @@
     NuppelVideoPlayer *pipplayer;
     NuppelVideoPlayer *setpipplayer;
     bool needsetpipplayer;
+    bool ispip;
+    bool softwareScalingPIP;
 
     // Preview window support
     unsigned char      *argb_buf;

libs/libmythtv/tv_play.cpp

@@ -39 +39 @@
 #include "DVDRingBuffer.h"
 #include "datadirect.h"
 #include "sourceutil.h"
+#include "pipplayer.h"
 
 #ifndef HAVE_ROUND
 #define round(x) ((int) ((x) + 0.5))
@@ -462 +463 @@
       lastProgram(NULL), jumpToProgram(false),
       inPlaylist(false), underNetworkControl(false),
       // Video Players
-      nvp(NULL), pipnvp(NULL), activenvp(NULL),
+      nvp(NULL), pipplayer(NULL), activenvp(NULL),
       // Remote Encoders
-      recorder(NULL), piprecorder(NULL), activerecorder(NULL),
+      recorder(NULL), activerecorder(NULL),
       switchToRec(NULL), lastrecordernum(-1),
       // LiveTVChain
-      tvchain(NULL), piptvchain(NULL),
+      tvchain(NULL),
       // RingBuffers
-      prbuffer(NULL), piprbuffer(NULL), activerbuffer(NULL),
+      prbuffer(NULL), activerbuffer(NULL),
       // OSD info
       dialogname(""), treeMenu(NULL), udpnotify(NULL), osdlock(true),
       // LCD Info
@@ -679 +680 @@
         delete tvchain;
     }
 
-    if (piptvchain)
-    {
-        VERBOSE(VB_IMPORTANT, LOC + "Deleting PiP TV Chain in destructor");
-        piptvchain->DestroyChain();
-        delete piptvchain;
-    }    
-
     if (ddMapLoaderRunning)
     {
         pthread_join(ddMapLoader, NULL);
@@ -1379 +1373 @@
             prbuffer->Pause();
             prbuffer->WaitForPause();
         }
-
-        if (piprbuffer)
-        {
-            piprbuffer->StopReads();
-            piprbuffer->Pause();
-            piprbuffer->WaitForPause();
-        }
     }
 
     if (stopPlayers)
@@ -1393 +1380 @@
         VERBOSE(VB_PLAYBACK, LOC + "StopStuff(): stopping player[s] (1/2)");
         if (nvp)
             nvp->StopPlaying();
-
-        if (pipnvp)
-            pipnvp->StopPlaying();
     }
 
     if (stopRecorders)
@@ -1403 +1387 @@
         VERBOSE(VB_PLAYBACK, LOC + "StopStuff(): stopping recorder[s]");
         if (recorder)
             recorder->StopLiveTV();
-
-        if (piprecorder)
-            piprecorder->StopLiveTV();
     }
 
     if (stopPlayers)
@@ -1413 +1394 @@
         VERBOSE(VB_PLAYBACK, LOC + "StopStuff(): stopping player[s] (2/2)");
         if (nvp)
             TeardownPlayer();
-
-        if (pipnvp)
-            TeardownPipPlayer();
+        if (pipplayer)
+        {
+            delete pipplayer;
+            pipplayer = NULL;
+        }
     }
     VERBOSE(VB_PLAYBACK, LOC + "StopStuff() -- end");
 }
@@ -1497 +1480 @@
     return filters;
 }
 
-void TV::SetupPipPlayer(void)
-{
-    if (pipnvp)
-    {
-        VERBOSE(VB_IMPORTANT, LOC_ERR +
-                "Attempting to setup a PiP player, but it already exists.");
-        return;
-    }
-
-    pipnvp = new NuppelVideoPlayer("PIP player");
-    pipnvp->SetAsPIP();
-    pipnvp->SetRingBuffer(piprbuffer);
-    pipnvp->SetRecorder(piprecorder);
-    pipnvp->SetAudioInfo(gContext->GetSetting("AudioOutputDevice"),
-                         gContext->GetSetting("PassThruOutputDevice"),
-                         gContext->GetNumSetting("AudioSampleRate", 44100));
-    pipnvp->SetExactSeeks(gContext->GetNumSetting("ExactSeeking", 0));
-    pipnvp->SetLiveTVChain(piptvchain);
-
-    pipnvp->SetLength(playbackLen);
-}
-
 void TV::TeardownPlayer(void)
 {
     if (nvp)
@@ -1568 +1529 @@
         prbuffer = activerbuffer = NULL;
     }
 
-    if (piprbuffer)
-    {
-        delete piprbuffer;
-        piprbuffer = NULL;
-    }
-
     if (tvchain)
     {
         tvchain->DestroyChain();
@@ -1582 +1537 @@
     }
 }
 
-void TV::TeardownPipPlayer(void)
-{
-    if (pipnvp)
-    {
-        if (activerecorder == piprecorder)
-            ToggleActiveWindow();
-
-        osdlock.lock(); // prevent UpdateOSDSignal from using osd...
-        NuppelVideoPlayer *xnvp = pipnvp;
-        pthread_t          xdec = pipdecode;
-        pipnvp = NULL;
-        osdlock.unlock();
-
-        // NVP may try to get qapp lock if there is an error,
-        // so we need to do this outside of the osdlock.
-        pthread_join(xdec, NULL);
-        delete xnvp;
-    }
-
-    if (piprecorder)
-    {
-        delete piprecorder;
-        piprecorder = NULL;
-    }
-
-    if (piprbuffer)
-    {
-        delete piprbuffer;
-        piprbuffer = NULL;
-    }
-
-    if (piptvchain)
-    {
-        piptvchain->DestroyChain();
-        delete piptvchain;
-        piptvchain = NULL;
-    }
-}
-
 void *TV::EventThread(void *param)
 {
     TV *thetv = (TV *)param;
@@ -1686 +1602 @@
                         if (nvp->GetTVChain())
                             nvp->CheckTVChain();
                     }
-                    if (piptvchain && pipnvp && *it == piptvchain->GetID())
+                    if (pipplayer && pipplayer->IsLiveTV()
+                            && *it == pipplayer->GetLiveTVChain()->GetID())
                     {
+                        LiveTVChain *piptvchain = pipplayer->GetLiveTVChain();
                         piptvchain->ReloadAll();
-                        if (pipnvp->GetTVChain())
-                            pipnvp->CheckTVChain();
+                        if (pipplayer->GetNVP()->GetTVChain())
+                            pipplayer->GetNVP()->CheckTVChain();
                     }
                 }
                 tvchainUpdate.clear();
@@ -1752 +1670 @@
             wantsToQuit = true;
         }
 
+        if (pipplayer && !pipplayer->IsPlaying())
+            TogglePIPView();
+
         if (StateIsPlaying(internalState))
         {
 #ifdef USING_VALGRIND
@@ -1859 +1780 @@
             prevChan = tmp;
             pseudoLiveTVState[i] = kPseudoRecording;
 
-            if (i && pipnvp)
+            if (i && pipplayer)
                 TogglePIPView();
         }
 
@@ -1884 +1805 @@
         if (++updatecheck >= 100)
         {
             OSDSet *oset;
-            if (GetOSD() && (oset = GetOSD()->GetSet("status")) &&
+            if (activenvp && GetOSD() && 
+                (oset = GetOSD()->GetSet("status")) &&
                 oset->Displaying() && update_osd_pos &&
                 (StateIsLiveTV(internalState) ||
                  StateIsPlaying(internalState)))
             {
                 struct StatusPosInfo posInfo;
-                nvp->calcSliderPos(posInfo);
+                activenvp->calcSliderPos(posInfo);
                 GetOSD()->UpdateStatus(posInfo);
             }
 
@@ -1932 +1854 @@
             if (activenvp)
             {
                 struct StatusPosInfo posInfo;
-                nvp->calcSliderPos(posInfo);
+                activenvp->calcSliderPos(posInfo);
                 progress = (float)posInfo.position / 1000;
             }
             lcd->setChannelProgress(progress);
@@ -1976 +1898 @@
         {
             if (nvp)
                 nvp->ExposeEvent();
+            if (pipplayer && pipplayer->GetNVP())
+                pipplayer->GetNVP()->ExposeEvent();
             return true;
         }
         case MythEvent::MythEventMessage:
@@ -2558 +2482 @@
             DoQueueTranscode("Low Quality");
         else if (action == "PLAY")
             DoPlay();
+        else if (action == "TOGGLEPIPMODE")
+            TogglePIPView();
+        else if (action == "TOGGLEPIPWINDOW")
+            ToggleActiveWindow();
+        else if (action == "SWAPPIP")
+            SwapPIPSoon();
         else if (action == "PAUSE") 
             DoPause();
         else if (action == "SPEEDINC" && !activerbuffer->InDVDMenuOrStillFrame())
@@ -2926 +2856 @@
                 SwitchCards();
             else if (action == "GUIDE")
                 EditSchedule(kScheduleProgramGuide);
-            else if (action == "TOGGLEPIPMODE")
-                TogglePIPView();
-            else if (action == "TOGGLEPIPWINDOW")
-                ToggleActiveWindow();
-            else if (action == "SWAPPIP")
-                SwapPIPSoon();
             else if (action == "TOGGLEBROWSE")
                 BrowseStart();
             else if (action == "PREVCHAN")
@@ -3213 +3137 @@
     }
 }
 
+bool TV::IsPIPActiveNVP(void)
+{
+    if (pipplayer && pipplayer->GetNVP())
+        return (pipplayer->GetNVP() == activenvp);
+    return false;
+}
+
 void TV::TogglePIPView(void)
 {
-    if (!pipnvp)
+    if (!pipplayer) 
     {
-        RemoteEncoder *testrec = RemoteRequestRecorder();
-        
-        if (!testrec || !testrec->IsValidRecorder())
+        int pip_location = gContext->GetNumSetting("PIPLocation", 0);
+        QRect rect = activenvp->getVideoOutput()->GetPIPRect(pip_location, NULL);
+        pipplayer = PIPPlayer::Create(rect);
+        if (!pipplayer)
+            return;
+        pipplayer->StartPlaying(NULL, true, false, this);
+        if (pipplayer->IsPlaying())
         {
-            VERBOSE(VB_IMPORTANT, LOC_ERR + "PiP failed to locate recorder");
-            if (testrec)
-                delete testrec;
+            pipplayer->Show();
+            pipplayer->GetNVP()->DiscardVideoFrames(true);
             return;
         }
-
-        testrec->Setup();
-
-        piptvchain = new LiveTVChain();
-        piptvchain->InitializeNewChain("PIP"+gContext->GetHostName());
-        testrec->SpawnLiveTV(piptvchain->GetID(), true);
-        piptvchain->ReloadAll();
-        playbackinfo = piptvchain->GetProgramAt(-1);
-        if (!playbackinfo)
-        {
-            VERBOSE(VB_IMPORTANT, LOC_ERR + "PiP not successfully started");
-            delete testrec;
-            piptvchain->DestroyChain();
-            delete piptvchain;
-            piptvchain = NULL;
-        }
         else
         {
-            QString playbackURL = playbackinfo->GetPlaybackURL();
-
-            piptvchain->SetProgram(playbackinfo);
-            piprbuffer = new RingBuffer(playbackURL, false);
-            piprbuffer->SetLiveMode(piptvchain);
-        }
-
-        piprecorder = testrec;
-
-        if (StartRecorder(piprecorder, -1))
-        {
-            SetupPipPlayer();
-            VERBOSE(VB_PLAYBACK, "PiP Waiting for NVP");
-            pthread_create(&pipdecode, NULL, SpawnDecode, pipnvp);
-            while (!pipnvp->IsPlaying() && pipnvp->IsDecoderThreadAlive())
+            QSize pipdim = pipplayer->GetVideoDimensions();
+            VideoOutput *vid = nvp->getVideoOutput();
+            if (vid && 
+                vid->IsResolutionSupported(pipdim.width(), pipdim.height()))
             {
-                piptvchain->ReloadAll();
-                usleep(5000);
+                if (pipplayer->GetNVP() &&
+                    pipplayer->GetNVP()->PIPSoftwareScaling() &&
+                    nvp->getVideoOutput() &&
+                    nvp->getVideoOutput()->hasXVAcceleration())
+                {
+                    pipplayer->StartPlaying(NULL, true, true, this);
+                    if (pipplayer->IsPlaying())
+                    {
+                        pipplayer->Hide();
+                        activenvp->SetPIPPlayer(pipplayer->GetNVP());
+                        pipplayerCond.wait();
+                        pipplayer->GetNVP()->DiscardVideoFrames(true);
+                        return;
+                    }
+                } 
             }
-            VERBOSE(VB_PLAYBACK, "PiP NVP Started");
-
-            if (pipnvp->IsDecoderThreadAlive())
-                nvp->SetPipPlayer(pipnvp);
-            else
-            {
-                VERBOSE(VB_IMPORTANT, LOC_ERR + "PiP player failed to start");
-                osdlock.lock();
-                delete pipnvp;
-                pipnvp = NULL;
-                osdlock.unlock();
-                TeardownPipPlayer();
-            }
         }
-        else
-        {
-            VERBOSE(VB_IMPORTANT, LOC_ERR + "PiP recorder failed to start");
-            TeardownPipPlayer();
-        }
+        if (GetOSD())
+            GetOSD()->SetSettingsText(tr("PIP Failed to Start"), 3);
     }
-    else
+   
+    if (IsPIPActiveNVP())
+        ToggleActiveWindow();
+
+    if (nvp->HasPIPPlayer())
     {
-        if (activenvp != nvp)
-            ToggleActiveWindow();
-
-        nvp->SetPipPlayer(NULL);
-        while (!nvp->PipPlayerSet())
-            usleep(50);
-
-        piprbuffer->StopReads();
-        piprbuffer->Pause();
-        while (!piprbuffer->isPaused())
-            usleep(50);
-
-        pipnvp->StopPlaying();
-
-        piprecorder->StopLiveTV();
-
-        TeardownPipPlayer();
-
-        SetPseudoLiveTV(1, NULL, kPseudoNormalLiveTV);
+        activenvp->SetPIPPlayer(NULL);
+        pipplayerCond.wait();
     }
+  
+    if (pipplayer->IsPlaying() &&
+        !pipplayer->IsLiveTV())
+    {
+        pipplayer->GetNVP()->SetBookmark();
+    }
+    
+    delete pipplayer;
+    pipplayer = NULL;
 }
 
 void TV::ToggleActiveWindow(void)
 {
-    if (!pipnvp)
+    // toggleactivewindow works only if the main window is live tv.
+    // problem is playbackinfo and internalstate management.
+    if (!pipplayer  || !pipplayer->GetNVP() ||
+        (!IsPIPActiveNVP() && StateIsPlaying(internalState)))
+    {
+        if (GetOSD())
+            GetOSD()->SetSettingsText("Toggle PIP Not Allowed", 3);
         return;
-
+    }
+    
     lockTimerOn = false;
-    if (activenvp == nvp)
+    LiveTVChain *piptvchain = NULL;
+  
+    if (!IsPIPActiveNVP())
     {
-        activenvp = pipnvp;
-        activerbuffer = piprbuffer;
-        activerecorder = piprecorder;
+       
+        activenvp      = pipplayer->GetNVP();
+        activerbuffer  = pipplayer->GetRingBuffer();
+        activerecorder = pipplayer->GetRecorder();
+        piptvchain     = pipplayer->GetLiveTVChain();
+        internalState  = GetPIPState(pipplayer);
+        if (pipplayer->GetProgramInfo() && !pipplayer->IsLiveTV())
+            SetCurrentlyPlaying(pipplayer->GetProgramInfo());
+        if (GetOSD())
+            GetOSD()->SetSettingsText("Toggle Active Window: PIP", 3);
     }
     else
     {
-        activenvp = nvp;
-        activerbuffer = prbuffer;
+        activenvp      = nvp;
+        activerbuffer  = prbuffer;
         activerecorder = recorder;
+        internalState  = kState_WatchingLiveTV;
+        if (GetOSD())
+            GetOSD()->SetSettingsText("Toggle Active Window: Main", 3);
     }
-    LiveTVChain *chain = (activenvp == nvp) ? tvchain : piptvchain;
-    ProgramInfo *pginfo = chain->GetProgramAt(-1);
-    if (pginfo)
-    {
-        SetCurrentlyPlaying(pginfo);
-        delete pginfo;
-    }
+
+   if (activerecorder)
+   {
+        LiveTVChain *chain  = (activenvp == nvp) ? tvchain : piptvchain;
+        ProgramInfo *pginfo = chain->GetProgramAt(-1);
+        if (pginfo)
+        {
+            SetCurrentlyPlaying(pginfo);
+            delete pginfo;
+        }
+   }
 }
 
+
 struct pip_info
 {
     RingBuffer    *buffer;
     RemoteEncoder *recorder;
     LiveTVChain   *chain;
     long long      frame;
+    ProgramInfo   *pginfo;
 };
 
 void TV::SwapPIP(void)
 {
-    if (!pipnvp || !piptvchain || !tvchain) 
+    if (!pipplayer)
+    {
+        if (GetOSD())
+            GetOSD()->SetSettingsText("PIP Not Present", 3);
         return;
+    }
+    if (IsPIPActiveNVP())
+        ToggleActiveWindow();
+    
+    bool use_nullvideo = pipplayer->UsingNullVideo();
+    bool pipislivetv = StateIsLiveTV(internalState);
+    
+    if (paused)
+        DoPause();
+    StopFFRew();
+    NormalSpeed();
 
-    lockTimerOn = false;
-
+   if (playbackinfo)
+       playbackinfo->setIgnoreBookmark(false);
+   if (pipplayer->GetProgramInfo())
+       pipplayer->GetProgramInfo()->setIgnoreBookmark(false);
+   
+   // set the bookmark
+    activenvp->SetBookmark();
+    pipplayer->GetNVP()->SetBookmark();
+    
     struct pip_info main, pip;
-    main.buffer   = prbuffer;
-    main.recorder = recorder;
-    main.chain    = tvchain;
-    main.frame    = nvp->GetFramesPlayed();
-    pip.buffer    = piprbuffer;
-    pip.recorder  = piprecorder;
-    pip.chain     = piptvchain;
-    pip.frame     = pipnvp->GetFramesPlayed();
-
+    main.buffer      = prbuffer;
+    main.recorder    = recorder;
+    main.chain       = tvchain;
+    main.frame       = nvp->GetFramesPlayed(); 
+    if (StateIsPlaying(internalState))
+        main.pginfo = new ProgramInfo(*playbackinfo);
+    else
+        main.pginfo = NULL;
+    
+    pip.buffer       = pipplayer->GetRingBuffer();
+    pip.recorder     = pipplayer->GetRecorder();
+    pip.chain        = pipplayer->GetLiveTVChain();
+    pip.frame        = pipplayer->GetNVP()->GetFramesPlayed();
+    if (!pipplayer->IsLiveTV())
+        pip.pginfo   = new ProgramInfo(*pipplayer->GetProgramInfo());
+    else
+        pip.pginfo   = NULL;
+  
+    pipplayer->Hide();
+    if (use_nullvideo)
+    {
+        activenvp->SetPIPPlayer(NULL);
+        pipplayerCond.wait();
+    }
+    pipplayer->SetReinit(false);
+    pipplayer->StopPlaying();
+    
     prbuffer->Pause();
     prbuffer->WaitForPause();
 
-    piprbuffer->Pause();
-    piprbuffer->WaitForPause();
+    nvp->StopPlaying();
 
-    nvp->StopPlaying();
-    pipnvp->StopPlaying();
     {
-        QMutexLocker locker(&osdlock); // prevent UpdateOSDSignal using osd...
+        QMutexLocker locker(&osdlock); // prevent UpdateOSDSignal using osd..
         pthread_join(decode, NULL);
         delete nvp;
         nvp = NULL;
-        pthread_join(pipdecode, NULL);
-        delete pipnvp;
-        pipnvp = NULL;
     }
 
+    if (playbackinfo)
+        delete playbackinfo;
+   
     activerbuffer  = prbuffer = pip.buffer;
     activerecorder = recorder = pip.recorder;
     tvchain                   = pip.chain;
+    playbackinfo              = pip.pginfo;
+    internalState             = GetPIPState(pipplayer);
 
-    piprbuffer  = main.buffer;
-    piprecorder = main.recorder;
-    piptvchain  = main.chain;
-
+    pipplayer->SetRingBuffer(main.buffer);
+    pipplayer->SetRecorder(main.recorder);
+    pipplayer->SetLiveTVChain(main.chain);
+    pipplayer->SetProgramInfo(main.pginfo);
+    
+    VERBOSE(VB_PLAYBACK, QString("TV SwapPIP: New InternalState is %1")
+            .arg(StateToString(internalState)));
+    
     prbuffer->Seek(0, SEEK_SET);
     prbuffer->Unpause();
-    StartPlayer(false);
+
+    if (internalState == kState_WatchingRecording)
+        StartPlayer(true);
+    else
+        StartPlayer(false);
+
     activenvp = nvp;
-    nvp->FastForward(pip.frame/recorder->GetFrameRate());
+    usleep(10000);
+    if (tvchain)
+    {
+        nvp->FastForward(pip.frame/recorder->GetFrameRate());
+        nvp->DiscardVideoFrames(true);
+    }
+    
+    pipplayer->GetRingBuffer()->Seek(0, SEEK_SET);
+    pipplayer->GetRingBuffer()->Unpause();
+  
+    if (use_nullvideo)
+    {
+        pipplayer->StartPlaying(main.pginfo, pipislivetv, true, this);
+        if (pipplayer->IsPlaying())
+            activenvp->SetPIPPlayer(pipplayer->GetNVP());
+    }
+    else
+        pipplayer->StartPlaying(main.pginfo, pipislivetv, this);
 
-    piprbuffer->Seek(0, SEEK_SET);
-    piprbuffer->Unpause();
-    SetupPipPlayer();
-    VERBOSE(VB_PLAYBACK, "PiP Waiting for NVP -- restart");
-    pthread_create(&pipdecode, NULL, SpawnDecode, pipnvp);
-    while (!pipnvp->IsPlaying() && pipnvp->IsDecoderThreadAlive())
+    if (pipplayer->IsPlaying())
     {
-        piptvchain->ReloadAll();
-        usleep(5000);
+        if (!use_nullvideo)
+            pipplayer->Show();
+        if (pipplayer->GetLiveTVChain())
+        {
+            pipplayer->GetLiveTVChain()->ReloadAll();
+            usleep(5000);
+        }
     }
-    VERBOSE(VB_PLAYBACK, "PiP NVP Started -- restart");
-    pipnvp->FastForward(pip.frame/piprecorder->GetFrameRate());
 
-    if (pipnvp->IsDecoderThreadAlive())
-        nvp->SetPipPlayer(pipnvp);
-    else
+    if (internalState == kState_WatchingLiveTV)
+        SetPseudoLiveTV(0, NULL, kPseudoNormalLiveTV);
+
+    if (pipplayer->IsLiveTV())
+        SetPseudoLiveTV(1, NULL, kPseudoNormalLiveTV);
+
+    if (pipplayer->GetLiveTVChain())
     {
-        VERBOSE(VB_IMPORTANT, LOC_ERR + "PiP player failed to start");
-        TeardownPipPlayer();
+        NuppelVideoPlayer *pipnvp = pipplayer->GetNVP();
+        float pipframerate = pipplayer->GetRecorder()->GetFrameRate();
+        pipnvp->FastForward(main.frame/pipframerate);
+        pipnvp->DiscardVideoFrames(true);
     }
 
-    ProgramInfo *pginfo = tvchain->GetProgramAt(-1);
-    if (pginfo)
+    if (tvchain)
     {
-        SetCurrentlyPlaying(pginfo);
-        delete pginfo;
+        ProgramInfo *pginfo = tvchain->GetProgramAt(-1);
+        if (pginfo)
+        {
+            SetCurrentlyPlaying(pginfo);
+            delete pginfo;
+        }
     }
+    pipplayer->SetReinit(true);
 }
 
+TVState TV::GetPIPState(PIPPlayer *player)
+{
+    if (player->IsLiveTV())
+        return kState_WatchingLiveTV;
+    else if (RemoteGetRecordingStatus(player->GetProgramInfo(),0,0))
+        return kState_WatchingRecording;
+    else
+        return kState_WatchingPreRecorded;
+}
+
 void TV::DoPlay(void)
 {
     float time = 0.0;
@@ -3467 +3474 @@
 
 void TV::DoPause(bool showOSD)
 {
+    QMutexLocker locker(&stateLock);
     if (activerbuffer->InDVDMenuOrStillFrame())
         return;
 
+    if (IsPIPActiveNVP())
+    {
+        if (pipplayer->IsPaused())
+            pipplayer->Play();
+        else
+            pipplayer->Pause();
+        return;
+    }
+    
     speed_index = 0;
     float time = 0.0;
 
     if (paused)
+    {
         activenvp->Play(normal_speed, true);
+        if (pipplayer)
+            pipplayer->Play(normal_speed);
+    }
     else 
     {
         if (doing_ff_rew)
@@ -3485 +3506 @@
         }
         
         activenvp->Pause();
+        if (pipplayer)
+            pipplayer->Pause();
     }
 
     paused = !paused;
@@ -3849 +3872 @@
 
     RemoteEncoder *testrec = NULL;
 
-    if (!StateIsLiveTV(GetState()) || (activenvp != nvp) || pipnvp)
+    if (!StateIsLiveTV(GetState()) || (activenvp != nvp) || pipplayer)
         return;
 
     if (/*chanid || */!channum.isEmpty())
@@ -4529 +4552 @@
     if (showStatus)
     {
         osd->HideAll();
-        if (nvp)
+        if (activenvp)
         {
             struct StatusPosInfo posInfo;
-            nvp->calcSliderPos(posInfo);
+            activenvp->calcSliderPos(posInfo);
             osd->ShowStatus(posInfo, false, tr("Position"),
                               osd_prog_info_timeout);
             update_osd_pos = true;
@@ -4567 +4590 @@
 
 void TV::UpdateOSDSeekMessage(const QString &mesg, int disptime)
 {
-    if (activenvp != nvp)
+    if (activenvp != nvp || !prbuffer)
         return;
 
     struct StatusPosInfo posInfo;
@@ -4967 +4990 @@
     {
         bool stayPaused = paused;
         if (!paused)
-            DoPause();
+            DoPause(false);
 
         switch (editType)
         {
@@ -5002 +5025 @@
         }
 
         if (!stayPaused)
-            DoPause();
+            DoPause(false);
     }
 
     // Resize the window back to the MythTV Player size
@@ -5369 +5392 @@
                 menurunning = false;
                 AskAllowRecording(me->ExtraDataList(), timeuntil, hasrec);
             }
-            else if (piprecorder &&
-                     cardnum == piprecorder->GetRecorderNumber())
+            else if (pipplayer && pipplayer->GetRecorder() &&
+                     cardnum == pipplayer->GetRecorder()->GetRecorderNumber())
             {
                 VERBOSE(VB_GENERAL, LOC + "Disabling PiP for recording");
                 TogglePIPView();
@@ -5388 +5411 @@
                 wantsToQuit = false;
                 exitPlayer = true;
             }
-            else if (piprecorder &&
-                     cardnum == piprecorder->GetRecorderNumber())
+            else if (pipplayer && pipplayer->GetRecorder() &&
+                     cardnum == pipplayer->GetRecorder()->GetRecorderNumber())
             {
                 VERBOSE(VB_GENERAL, LOC + "Disabling PiP for QUIT_LIVETV");
                 TogglePIPView();
@@ -5405 +5428 @@
             uint s = (cardnum == recorder->GetRecorderNumber()) ? 0 : 1;
 
             if ((recorder    && cardnum == recorder->GetRecorderNumber()) ||
-                (piprecorder && cardnum == piprecorder->GetRecorderNumber()))
+                (pipplayer && pipplayer->GetRecorder() && 
+                 cardnum == pipplayer->GetRecorder()->GetRecorderNumber()))
             {
                 if (watch)
                 {
@@ -5414 +5438 @@
                     if (pi.FromStringList(list, 0))
                         SetPseudoLiveTV(s, &pi, kPseudoChangeChannel);
 
-                    if (!s && pipnvp)
+                    if (!s && pipplayer)
                         TogglePIPView();
                 }
                 else
@@ -6408 +6432 @@
 
 void TV::ShowOSDTreeMenu(void)
 {
+    if (IsPIPActiveNVP())
+        return;
+
     BuildOSDTreeMenu();
 
     if (GetOSD())
@@ -6436 +6463 @@
 
     if (StateIsLiveTV(GetState()))
     {
-        bool freeRecorders = (pipnvp != NULL);
+        bool freeRecorders = (pipplayer != NULL);
         if (!freeRecorders)
             freeRecorders = RemoteGetFreeRecorderCount();
 
@@ -7076 +7103 @@
 {
     VERBOSE(VB_PLAYBACK, LOC + "UnpauseLiveTV()");
 
+    LiveTVChain *piptvchain = NULL;
+    if (pipplayer)
+        piptvchain = pipplayer->GetLiveTVChain();
+
     LiveTVChain *chain = (activenvp == nvp) ? tvchain : piptvchain;
 
     if (activenvp && chain)

libs/libmythtv/videoout_null.cpp

@@ -88 +88 @@
     if ((width <= 0) || (height <= 0))
         return false;
 
+    int prebufferframes;
+    if (piptype == kPIPOnLiveTV)
+        prebufferframes = 20;
+    else
+        prebufferframes = kPrebufferFramesSmall;
+   
     vbuffers.Init(kNumBuffers, true, kNeedFreeFrames, 
                   kPrebufferFramesNormal, kPrebufferFramesSmall, 
-                  kKeepPrebuffer);
+                  prebufferframes);
     VideoOutput::Init(width, height, aspect, winid,
                       winx, winy, winw, winh, embedid);
 

libs/libmythtv/videooutbase.cpp

@@ -171 +171 @@
     pip_desired_display_size(160,128),  pip_display_size(0,0),
     pip_video_size(0,0),
     pip_tmp_buf(NULL),                  pip_scaling_context(NULL),
+    piptype(kPIPOff),
 
     // Video resizing (for ITV)
     vsz_enabled(false),
@@ -253 +254 @@
 
     db_vdisp_profile->SetInput(video_dim);
 
-    letterbox  = db_letterbox;
+    if (piptype == kPIPOff)
+        letterbox  = db_letterbox;
 
     VideoAspectRatioChanged(aspect); // apply aspect ratio and letterbox mode
 
@@ -525 +527 @@
     visible = GetVisibleOSDBounds(visible_aspect, font_scaling);
 }
 
+bool VideoOutput::IsResolutionSupported(int width, int height)
+{
+    (void)width;
+    (void)height;
+    return true;
+}
+
 static float sq(float a) { return a*a; }
 //static float lerp(float r, float a, float b)
 //    { return ((1.0f - r) * a) + (r * b); }
@@ -1044 +1053 @@
 
     db_pict_attr[attributeType] = newValue;
 }
+/*
+ * \brief Determines PIP Window size and Position.
+ */
+QRect VideoOutput::GetPIPRect(int location, NuppelVideoPlayer *pipplayer)
+{
+    
+    int tmph;
+    int tmpw;
+    int letterXadj  = 0;
+    int letterYadj  = 0;
+    float letterAdj = 1.0f;
+    int xpos = 0;
+    int ypos = 0;
+    int frame_height;
+    int frame_width;
+   
+    if (pipplayer)
+    {
+        frame_height = video_dim.height();
+        frame_width  = video_dim.width();
+    }
+    else
+    {
+        frame_height = display_visible_rect.height();
+        frame_width  = display_visible_rect.width();
+    }
+    float pipVideoAspect;
+    uint pipVideoWidth;
+    uint pipVideoHeight;
+    
+    if (pipplayer)
+    {
+        pipVideoAspect = pipplayer->GetVideoAspect();
+        pipVideoWidth  = pipplayer->GetVideoWidth();
+        pipVideoHeight = pipplayer->GetVideoHeight();
+    }
+    
+    if  (pipplayer && letterbox != kLetterbox_Off)
+    {
+        letterXadj = max(-display_video_rect.left(), 0);
+        float xadj = (float) video_rect.width() / display_visible_rect.width();
+        letterXadj = (int) (letterXadj * xadj);
 
+        float yadj = (float)video_rect.height() / display_visible_rect.height();
+        letterYadj = max(-display_video_rect.top(), 0);
+        letterYadj = (int) (letterYadj * yadj);
+        if (!pipplayer)
+        {
+            if (location == kPIPTopLeft || location == kPIPTopRight)
+                ypos = display_video_rect.y();
+            else
+                ypos = -(display_video_rect.y());
+        }
+        
+        letterAdj = video_aspect / letterboxed_video_aspect;
+
+    }
+   
+    // set height
+    tmph = (frame_height * db_pip_size) / 100;
+
+    float dispPixelAdj = video_dim.width() / video_dim.height();
+   
+    tmpw = (int)(tmph * letterAdj * dispPixelAdj);
+   
+    switch (location)
+    {
+        default:
+        case kPIPTopLeft:
+            xpos = 30 + letterXadj;
+            ypos += 40 + letterYadj;
+            break;
+        case kPIPBottomLeft:
+            xpos = 30 + letterXadj;
+            ypos += frame_height - tmph - 40 - letterYadj;
+            break;
+        case kPIPTopRight:
+            xpos = frame_width  - tmpw - 30 - letterXadj;
+            ypos += 40 + letterXadj;
+            break;
+        case kPIPBottomRight:
+            xpos = frame_width  - tmpw - 30 - letterXadj;
+            ypos += frame_height - tmph - 40 - letterYadj; 
+            break;
+    }
+    return QRect(xpos, ypos, tmpw, tmph);
+}
+
 /**
  * \fn VideoOutput::DoPipResize(int,int)
  * \brief Sets up Picture in Picture image resampler.
@@ -1111 +1207 @@
     int pipw, piph;
 
     VideoFrame *pipimage = pipplayer->GetCurrentFrame(pipw, piph);
+
     float pipVideoAspect = pipplayer->GetVideoAspect();
-    uint  pipVideoWidth  = pipplayer->GetVideoWidth();
-    uint  pipVideoHeight = pipplayer->GetVideoHeight();
 
     // If PiP is not initialized to values we like, silently ignore the frame.
     if ((video_aspect <= 0) || (pipVideoAspect <= 0) || 
@@ -1123 +1218 @@
         pipplayer->ReleaseCurrentFrame(pipimage);
         return;
     }
+    
+    QRect piprect = GetPIPRect(db_pip_location, pipplayer);
 
-    // set height
-    int tmph = (frame->height * db_pip_size) / 100;
-    pip_desired_display_size.setHeight((tmph >> 1) << 1);
-
-    // adjust for letterbox modes...
-    int letterXadj = 0;
-    int letterYadj = 0;
-    float letterAdj = 1.0f;
-    if (letterbox != kLetterbox_Off)
-    {
-        letterXadj = max(-display_video_rect.left(), 0);
-        float xadj = (float) video_rect.width() / display_visible_rect.width();
-        letterXadj = (int) (letterXadj * xadj);
-
-        float yadj = (float)video_rect.height() /display_visible_rect.height();
-        letterYadj = max(-display_video_rect.top(), 0);
-        letterYadj = (int) (letterYadj * yadj);
-
-        letterAdj  = video_aspect / letterboxed_video_aspect;
-    }
-
-    // adjust for non-square pixels on screen
-    float dispPixelAdj = (GetDisplayAspect() * video_dim.height()) /
-        video_dim.width();
-
-    // adjust for non-square pixels in video
-    float vidPixelAdj  = pipVideoWidth / (pipVideoAspect * pipVideoHeight);
-
-    // set width
-    int tmpw = (int) (pip_desired_display_size.height() * pipVideoAspect *
-                      vidPixelAdj * dispPixelAdj * letterAdj);
-    pip_desired_display_size.setWidth((tmpw >> 1) << 1);
-
+    pip_desired_display_size.setWidth((piprect.width() >> 1 ) << 1);
+    pip_desired_display_size.setHeight((piprect.height() >> 1) << 1);
+   
+    
     // Scale the image if we have to...
     unsigned char *pipbuf = pipimage->buf;
     if (pipw != pip_desired_display_size.width() ||
@@ -1186 +1254 @@
 
 
     // Figure out where to put the Picture-in-Picture window
-    int xoff = 0;
-    int yoff = 0;
-    switch (db_pip_location)
-    {
-        default:
-        case kPIPTopLeft:
-                xoff = 30 + letterXadj;
-                yoff = 40 + letterYadj;
-                break;
-        case kPIPBottomLeft:
-                xoff = 30 + letterXadj;
-                yoff = frame->height - piph - 40 - letterYadj;
-                break;
-        case kPIPTopRight:
-                xoff = frame->width  - pipw - 30 - letterXadj;
-                yoff = 40 + letterYadj;
-                break;
-        case kPIPBottomRight:
-                xoff = frame->width  - pipw - 30 - letterXadj;
-                yoff = frame->height - piph - 40 - letterYadj;
-                break;
-    }
+    int xoff = piprect.x();
+    int yoff = piprect.y();
 
     // Copy Y (intensity values)
     for (int i = 0; i < piph; i++)

libs/libmythtv/pipplayer.cpp

@@ +1 @@
+#include <math.h>
+#include "pipplayer.h"
+#include "remoteutil.h"
+
+#define LOC QString("PIPPlayer: ")
+#define LOC_ERR QString("PIPPlayer Error: ")
+
+static void *SpawnPIPVideoThread(void *param)
+{   
+    NuppelVideoPlayer *nvp = (NuppelVideoPlayer *)param;
+    nvp->StartPlaying();
+    nvp->StopPlaying();
+    return NULL;
+}
+ 
+PIPPlayer::PIPPlayer(void)
+    :   piprecorder(NULL), piprbuffer(NULL),
+        piptvchain(NULL), piprecinfo(NULL),
+        pipnvp(NULL), pipWindow(NULL),
+        islivetv(false), 
+        reinit(true), using_nullvideo(false),
+        video_width(0), video_height(0),
+        paused(false)
+{
+};
+
+PIPPlayer::~PIPPlayer(void)
+{
+    StopPlaying();
+    if (pipWindow)
+        pipWindow->deleteLater();
+};
+
+PIPPlayer * PIPPlayer::Create(NuppelVideoPlayer *parentnvp, int location)
+{
+    PIPPlayer *tmppip = new PIPPlayer();
+    if (parentnvp)
+    {
+        QRect rect = parentnvp->getVideoOutput()->GetPIPRect(location, NULL);
+        tmppip->Init(rect, QString("pip player %1").arg((int)location));
+        return tmppip;
+    }
+    delete tmppip;
+    return NULL;
+}
+
+PIPPlayer * PIPPlayer::Create(const QRect &rect)
+{
+    PIPPlayer *tmppip = new PIPPlayer();
+    tmppip->Init(rect, "pip player");
+    return tmppip;
+}
+
+void PIPPlayer::Init(QRect rect, QString name)
+{
+    QRect piprect = QRect(rect);
+    MythDialog *window = new MythDialog(gContext->GetMainWindow(), name);
+    window->setNoErase();
+    window->setGeometry(piprect);
+    window->setFixedSize(piprect.size());
+    window->show();
+    window->setBackgroundColor(Qt::black);
+    gContext->GetMainWindow()->detach(window);
+    pipWindow = window;
+}
+
+void PIPPlayer::Reinitialize(void)
+{
+    if (pipnvp)
+        delete pipnvp;
+
+    pipnvp = NULL;
+    
+    if (piprbuffer)
+        delete piprbuffer;
+    piprbuffer = NULL;
+    
+    if (piprecinfo)
+        delete piprecinfo;
+    piprecinfo = NULL;
+    
+    if (piprecorder)
+        delete piprecorder;
+    piprecorder = NULL;
+    
+    if (piptvchain)
+    {
+        piptvchain->DestroyChain();
+        delete piptvchain;
+    }
+    piptvchain = NULL;
+}
+
+/*
+ * \brief Setup pip and start playing it.
+ * \param piptype: set to true, if pip should open a tuner
+ * \returns true if setup is complete
+ */
+bool PIPPlayer::StartPlaying(ProgramInfo *rec, 
+                        bool piptype, bool nullvideo,
+                        TV *parent)
+{
+
+    using_nullvideo = nullvideo;
+    islivetv = piptype;
+  
+    if (reinit)
+        Reinitialize();
+
+    RemoteEncoder *testrec = NULL;
+    
+    VERBOSE(VB_PLAYBACK, LOC + 
+            QString("PIP is for %1").arg((islivetv) ? "live tv":"a recording"));
+
+    if (islivetv)
+    {
+        if (!(piprecorder && piprbuffer && piptvchain))
+        {
+            testrec = RemoteRequestRecorder();
+
+            if (!testrec || !testrec->IsValidRecorder())
+            {
+                VERBOSE(VB_IMPORTANT, LOC_ERR + "PIP failed to locate recorder");
+                if (testrec)
+                    delete testrec;
+                return false;
+            }
+
+            testrec->Setup();
+
+            piptvchain = new LiveTVChain();
+            piptvchain->InitializeNewChain("PIP"+gContext->GetHostName());
+            testrec->SpawnLiveTV(piptvchain->GetID(), true);
+            piptvchain->ReloadAll();
+            piprecinfo = piptvchain->GetProgramAt(-1);
+            if (!piprecinfo)
+            {
+                VERBOSE(VB_IMPORTANT, LOC_ERR + 
+                        "PIP cannot find live tv programinfo. Exiting");
+                delete testrec;
+                piptvchain->DestroyChain();
+                delete piptvchain;
+                return false;
+            }
+            else
+            {
+                QString playbackURL = piprecinfo->GetPlaybackURL();
+                piptvchain->SetProgram(piprecinfo);
+                piprbuffer = new RingBuffer(playbackURL, false);
+                piprbuffer->SetLiveMode(piptvchain);
+            }
+
+            piprecorder = testrec;
+        
+            if (!StartRecorder(piprecorder, -1))
+            {
+                VERBOSE(VB_IMPORTANT, LOC_ERR + "PIP recorder failed to start");
+                return false;
+            }
+        }
+    }
+    else // pip is not Live TV
+    {
+        if (!piprecinfo)
+            piprecinfo = new ProgramInfo(*rec);
+        if (!piprbuffer)
+            piprbuffer = new RingBuffer(piprecinfo->pathname, false, false, 1);
+        if (!piprbuffer->IsOpen())
+        {
+            VERBOSE(VB_IMPORTANT, LOC_ERR + 
+                QString("Failed to open Ringbuffer %1")
+                .arg(piprecinfo->pathname));
+            return false;
+        }
+    }
+
+    // when starting pipplayer for the first time, always start
+    // from the beginning
+    if (reinit && piprecinfo)
+        piprecinfo->setIgnoreBookmark(true);
+        
+    pipnvp = new NuppelVideoPlayer("pip player", piprecinfo);
+    pipnvp->SetParentWidget(pipWindow);
+    pipnvp->SetRingBuffer(piprbuffer);
+    if (parent)
+        pipnvp->SetParentPlayer(parent);
+    if (islivetv)
+    {
+        pipnvp->SetRecorder(piprecorder);
+        pipnvp->SetLiveTVChain(piptvchain);
+    }
+    else
+        pipnvp->SetLength(piprecinfo->CalculateLength());
+        
+
+    // setAsPIP is true if null video output is used
+    // PIP will be embedded in XV
+    if (using_nullvideo)
+    {
+        pipnvp->SetAsPIP(true);
+    }
+    else
+        pipnvp->SetAsPIP(false);
+
+    VERBOSE(VB_PLAYBACK, "PIP Waiting for NVP");
+    pthread_create(&pipdecode, NULL, SpawnPIPVideoThread, pipnvp);
+    int maxWait = 10000;
+    MythTimer t;
+    t.start();
+    while (!pipnvp->IsPlaying() && pipnvp->IsDecoderThreadAlive() &&
+            t.elapsed() < maxWait)
+    {
+        usleep(5000);
+    }
+   
+    video_width = pipnvp->GetVideoWidth();
+    video_height = pipnvp->GetVideoHeight();
+    
+    if (!pipnvp->IsPlaying())
+    {
+        VERBOSE(VB_PLAYBACK, LOC_ERR + "PIP NVP Failed to Start");
+        return false;
+    }
+   
+    VERBOSE(VB_PLAYBACK, LOC + "PIP NVP Started");
+    return true;
+} 
+
+void PIPPlayer::StopPlaying(void)
+{
+    
+    if (!pipnvp)
+        return;
+
+    if (pipnvp->IsPlaying())
+    {
+        if (reinit)
+            piprbuffer->StopReads();
+        piprbuffer->Pause();
+        piprbuffer->WaitForPause();
+        pipnvp->StopPlaying();
+    }
+    
+    VERBOSE(VB_PLAYBACK, LOC + "KillPlayer(): Stopped Playing");
+    {
+        pthread_join(pipdecode, NULL);
+        delete pipnvp;
+        pipnvp = NULL;
+    }
+
+    if (reinit)
+    {
+        if (islivetv && piprecorder ) 
+            piprecorder->StopLiveTV();
+    
+        Reinitialize();
+    }
+    
+    VERBOSE(VB_PLAYBACK, LOC + "KillPlayer(): NVP deleted");
+}
+
+/*
+ * \brief set pip ringbuffer if pip is not playing
+ */
+void PIPPlayer::SetRingBuffer(RingBuffer *rbuffer)
+{
+    if (!IsPlaying())
+        piprbuffer = rbuffer;
+}
+
+/*
+ * \brief set pip tvchain if pip is not playing
+ */
+void PIPPlayer::SetLiveTVChain(LiveTVChain *tvchain)
+{
+    if (!IsPlaying())
+        piptvchain = tvchain;
+}
+
+/*
+ * \brief set pip recorder if pip is not playing
+ */
+void PIPPlayer::SetRecorder(RemoteEncoder  *recorder)
+{
+    if (!IsPlaying())
+        piprecorder = recorder;
+}
+
+void PIPPlayer::SetProgramInfo(ProgramInfo *pginfo)
+{
+    if (!IsPlaying())
+    {
+        if (piprecinfo)
+            delete piprecinfo;
+        piprecinfo = pginfo;
+    }
+}
+
+bool PIPPlayer::IsSameProgram(ProgramInfo *rec)
+{
+    if (!rec || !piprecinfo)
+        return false;
+
+    if (piprecinfo->IsSameProgram(*rec))
+        return true;
+    
+    return false;
+}
+
+bool PIPPlayer::StartRecorder(RemoteEncoder *rec, int maxWait)
+{
+    maxWait = (maxWait <= 0) ? 20000 : maxWait;
+    MythTimer t;
+    t.start();
+    while (rec && !rec->IsRecording() && t.elapsed() < maxWait)
+        usleep(5000);
+    if (rec && !rec->IsRecording())
+    {
+        VERBOSE(VB_IMPORTANT, LOC_ERR + "recorder startup failed. Timed out");
+        return false;
+    }
+    return true;
+}
+
+void PIPPlayer::Hide(void)
+{
+    if (pipWindow && pipWindow->isVisible())
+        pipWindow->hide();
+}
+
+void PIPPlayer::Show(void)
+{   
+    if (pipWindow && pipWindow->isHidden())
+        pipWindow->show();
+}
+
+bool PIPPlayer::IsHidden(void)
+{
+    if (pipWindow && pipWindow->isHidden())
+        return true;
+    return false;
+}
+
+void PIPPlayer::GetARGBFrame(void)
+{
+    if (!using_nullvideo)
+        return;
+   
+    QPainter p(pipWindow);
+    QSize size = pipWindow->size();
+    float saspect = ((float)size.width())/ ((float)size.height());
+    float vaspect = pipnvp->GetVideoAspect();
+    size.setHeight((int) ceil(size.height() * (saspect / vaspect)));
+    size.setHeight(((size.height() + 7) / 8) * 8);
+    size.setWidth( ((size.width()  + 7) / 8) * 8);
+    const QImage &img = pipnvp->GetARGBFrame(size);
+    p.drawImage(0, 0, img); 
+}
+
+void PIPPlayer::Pause(void)
+{
+    if (IsPlaying() && !paused)
+    {
+        pipnvp->Pause();
+        paused = true;
+    }
+}
+
+void PIPPlayer::Play(float speed)
+{
+    if (IsPlaying() && paused)
+    {
+        pipnvp->Play(speed);
+        paused = false;
+    }
+}
+

libs/libmythtv/videoout_xv.h

@@ -88 +88 @@
         { return XVideoIDCT <= VideoOutputSubType(); }
     virtual bool hasVLDAcceleration(void) const
         { return XVideoVLD == VideoOutputSubType(); }
+    virtual bool hasXVAcceleration(void) const
+        { return VideoOutputSubType() == XVideo; }
 
     void CheckFrameStates(void);
+    bool IsResolutionSupported(int width, int height);
 
     static MythCodecID GetBestSupportedCodec(uint width, uint height,
                                              uint osd_width, uint osd_height,

libs/libmythtv/videoout_xv.cpp

@@ -1218 +1218 @@
         db_vdisp_profile->SetVideoRenderer(renderer);
     }
 
+    const QString osdrenderer = db_vdisp_profile->GetOSDRenderer();
+    if (piptype >= kPIPOnTV  &&
+            (osdrenderer != "opengl" || osdrenderer != "composite"))
+    {
+        VERBOSE(VB_IMPORTANT, LOC + 
+                QString("XV PIP not supported with blended OSD. "
+                "Using software scaled PIP."));
+        return false;
+    }
     // Initialize the OSD, if we need to
-    InitOSD(db_vdisp_profile->GetOSDRenderer());
+    if (piptype == kPIPOff)
+        InitOSD(osdrenderer);
 
     // Create video buffers
     bool use_xv  = (renderer.left(2) == "xv");
@@ -1259 +1269 @@
 {
     needrepaint = true;
 
+    // for PIP use software scaled image if width or height <= 64
+    if (piptype > kPIPOff &&
+        (width <= 64 || height <= 64))
+    {
+        VERBOSE(VB_IMPORTANT, LOC_ERR +
+                QString("PIP Video Init Failed. Dimensions less then 64 "
+                        "Video width %1, Video height %2")
+                .arg(width).arg(height));
+        return false;
+    }
+        
     XV_INIT_FATAL_ERROR_TEST(winid <= 0, "Invalid Window ID.");
 
     XJ_disp = MythXOpenDisplay();
@@ -3267 +3288 @@
 #endif // USING_XVMC
 }
 
+bool VideoOutputXv::IsResolutionSupported(int width, int height)
+{
+    if (width == 0 || height == 0)
+        return false;
+
+    if (xv_port >= 0 && xv_chroma)
+    {
+        int size = 0;
+        int desiredsize = 0;
+        XvImage *img = NULL;
+        XShmSegmentInfo *info = new XShmSegmentInfo;
+        X11S(img = XvShmCreateImage(XJ_disp, xv_port, xv_chroma, 0,
+                width, height, info));
+        size = img->data_size + 64;
+        desiredsize =  width * height * 3 / 2;
+        if (img && size < desiredsize)
+        {
+            VERBOSE(VB_IMPORTANT, LOC_ERR + QString("IsResolutionSupported(): "
+                    "WxH %1x%2 not supported on this Xv Surface")
+                    .arg(width).arg(height));
+            XFree(img);
+            delete info;
+            return false;
+        }
+
+        return true;
+    }
+    return false;
+}
+        
 bool VideoOutputXv::IsDisplaying(VideoFrame* frame)
 {
     (void)frame;

libs/libmythtv/videooutbase.h

@@ -79 +79 @@
     kPIPBottomRight
 };
 
+enum PIPType
+{
+    kPIPOff = 0,
+    kPIPOn, // PIP but not for TV
+    kPIPOnTV, // PIP used in TV mode
+    kPIPOnLiveTV // Live TV used in TV Mode
+};
+
 enum ZoomDirections
 {
     kZoomHome = 0,
@@ -190 +198 @@
     virtual void GetOSDBounds(QRect &visible, QRect &total,
                               float &pixelAspect, float &fontScale) const;
 
+    virtual bool IsResolutionSupported(int width, int height);
+
     /// \brief Returns current display's frame refresh period in microseconds.
     ///        e.g. 1000000 / frame_rate_in_Hz
     virtual int GetRefreshRate(void) = 0;
@@ -225 +235 @@
     bool AllowPreviewEPG(void) { return allowpreviewepg; }
 
     /// \brief Returns true iff Motion Compensation acceleration is available.
-    virtual bool hasMCAcceleration() const { return false; }
+    virtual bool hasMCAcceleration(void) const { return false; }
     /// \brief Returns true iff Inverse Discrete Cosine Transform acceleration
     ///        is available.
-    virtual bool hasIDCTAcceleration() const { return false; }
+    virtual bool hasIDCTAcceleration(void) const { return false; }
     /// \brief Returns true iff VLD acceleration is available.
-    virtual bool hasVLDAcceleration() const { return false; }
+    virtual bool hasVLDAcceleration(void) const { return false; }
+    /// \brief Returns true if XV acceleration is available.
+    virtual bool hasXVAcceleration(void) const { return false; }
 
     /// \brief Sets the number of frames played
     virtual void SetFramesPlayed(long long fp) { framesPlayed = fp; };
@@ -308 +320 @@
     /// \brief Tells the player to resize the video frame (used for ITV)
     void SetVideoResize(const QRect &videoRect);
 
+    /// \brief returns QRect of PIP based on PIPLocation
+    virtual QRect GetPIPRect(int location, NuppelVideoPlayer *pipplayer = NULL);
+
+    /// set PIP Type
+    void SetAsPIP(PIPType setting) { piptype = setting; }
+        
+
   protected:
     void InitBuffers(int numdecode, bool extra_for_pause, int need_free,
                      int needprebuffer_normal, int needprebuffer_small,
@@ -384 +403 @@
     QSize   pip_video_size;
     unsigned char      *pip_tmp_buf;
     ImgReSampleContext *pip_scaling_context;
+    PIPType    piptype;
 
     // Video resizing (for ITV)
     bool    vsz_enabled;

programs/mythfrontend/playbackbox.cpp

@@ -38 +38 @@
 #include "remoteutil.h"
 #include "lcddevice.h"
 #include "previewgenerator.h"
+#include "pipplayer.h"
 #include "playgroup.h"
 #include "customedit.h"
 
@@ -262 +263 @@
       // Volatile drawing variables
       paintSkipCount(0),                paintSkipUpdate(false),
       // Preview Video Variables
-      previewVideoNVP(NULL),            previewVideoRingBuf(NULL),
+      previewPlayer(NULL), previewVideoStartTimer(new QTimer(this)),
       previewVideoRefreshTimer(new QTimer(this)),
-      previewVideoBrokenRecId(0),       previewVideoState(kStopped),
-      previewVideoStartTimerOn(false),  previewVideoEnabled(false),
-      previewVideoPlaying(false),       previewVideoThreadRunning(false),
-      previewVideoKillState(kDone),
+      previewVideoStopTimer(new QTimer(this)),
+      previewVideoEnabled(false),
+      previewTimeout(2000), software_scaled(false),
       // Preview Image Variables
       previewPixmapEnabled(false),      previewPixmap(NULL),
       previewSuspend(false),            previewChanid(""),
@@ -369 +369 @@
     connected = FillList();
 
     // connect up timers...
-    connect(previewVideoRefreshTimer, SIGNAL(timeout()),
+    connect(previewVideoStartTimer,        SIGNAL(timeout()),
             this,                     SLOT(timeout()));
+    connect(previewVideoRefreshTimer,       SIGNAL(timeout()),
+            this,                     SLOT(refreshVideo()));
+    connect(previewVideoStopTimer,          SIGNAL(timeout()),
+            this,                     SLOT(stopPlayer()));
     connect(freeSpaceTimer,           SIGNAL(timeout()),
             this,                     SLOT(setUpdateFreeSpace()));
     connect(fillListTimer,            SIGNAL(timeout()),
             this,                     SLOT(listChanged()));
 
     // preview video & preview pixmap init
-    previewVideoRefreshTimer->start(500);
     previewStartts = QDateTime::currentDateTime();
-
     // misc setup
     updateBackground();
     setNoErase();
@@ -398 +400 @@
     gContext->removeListener(this);
     gContext->removeCurrentLocation();
 
-    if (!m_player)
-        killPlayerSafe();
+    killPlayer();
+    
+    if (previewVideoStartTimer)
+    {
+        previewVideoStartTimer->disconnect(this);
+        previewVideoStartTimer->deleteLater();
+        previewVideoStartTimer = NULL;
+    }
 
     if (previewVideoRefreshTimer)
     {
@@ -408 +416 @@
         previewVideoRefreshTimer = NULL;
     }
 
+    if (previewVideoStopTimer)
+    {
+        previewVideoStopTimer->disconnect(this);
+        previewVideoStopTimer->deleteLater();
+        previewVideoStopTimer = NULL;
+    }
+
     if (fillListTimer)
     {
         fillListTimer->disconnect(this);
@@ -464 +479 @@
         delete previewPixmap;
         previewPixmap = NULL;
     }
-}
 
-/* blocks until playing has stopped */
-void PlaybackBox::killPlayerSafe(void)
-{
-    QMutexLocker locker(&previewVideoKillLock);
-
-    // Don't process any keys while we are trying to make the nvp stop.
-    // Qt's setEnabled(false) doesn't work, because of LIRC events...
-    ignoreKeyPressEvents = true;
-
-    while (previewVideoState != kKilled && previewVideoState != kStopped &&
-           previewVideoThreadRunning)
-    {
-        /* ensure that key events don't mess up our previewVideoStates */
-        previewVideoState = (previewVideoState == kKilled) ?
-            kKilled :  kKilling;
-
-        /* NOTE: need unlock/process/lock here because we need
-           to allow updateVideo() to run to handle changes in
-           previewVideoStates */
-        qApp->unlock();
-        qApp->processEvents();
-        usleep(500);
-        qApp->lock();
-    }
-    previewVideoState = kStopped;
-
-    ignoreKeyPressEvents = false;
 }
 
 void PlaybackBox::LoadWindow(QDomElement &element)
@@ -523 +510 @@
             }
         }
     }
+
+    if (previewVideoEnabled)
+    {
+        previewPlayer = PIPPlayer::Create(drawVideoBounds);
+        if (previewPlayer)
+            previewPlayer->Hide();
+        previewPixmapEnabled = true;
+    }
 }
 
 void PlaybackBox::parseContainer(QDomElement &element)
@@ -596 +591 @@
 
 void PlaybackBox::exitWin()
 {
+    killPlayer();
     if (m_player)
     {
         if (curitem)
@@ -603 +599 @@
         curitem = NULL;
         pbbIsVisibleCond.wakeAll();
     }
-    else
-        killPlayerSafe();
-
     accept();
 }
 
@@ -785 +778 @@
     QMap<QString, QString> infoMap;
     QPainter tmp(&pix);
         
-    if (previewVideoPlaying)
-        previewVideoState = kChanging;
 
     LayerSet *container = NULL;
     if (type != Delete)
@@ -799 +790 @@
         if (curitem)
             curitem->ToMap(infoMap);
         
-        if ((previewVideoEnabled == 0) &&
-            (previewPixmapEnabled == 0))
+        if (previewPixmapEnabled == 0)
             container->UseAlternateArea(true);
 
         container->ClearAllText();
@@ -845 +835 @@
     tmp.end();
     p->drawPixmap(pr.topLeft(), pix);
 
-    previewVideoStartTimer.start();
-    previewVideoStartTimerOn = true;
 }
 
 void PlaybackBox::updateInfo(QPainter *p)
@@ -883 +871 @@
     // If we're displaying group info don't update the video.
     if (inTitle && haveGroupInfoSet)
         return;
-
+    
     /* show a still frame if the user doesn't want a video preview or nvp 
      * hasn't started playing the video preview yet */
-    if (curitem && !playingSomething &&
-        (!previewVideoEnabled             ||
-         !previewVideoPlaying             ||
-         (previewVideoState == kStarting) || 
-         (previewVideoState == kChanging)))
+    if ((curitem && previewPixmapEnabled && !previewPlayer) ||
+         (curitem && previewPlayer && previewPlayer->IsHidden()))
     {
         QPixmap temp = getPixmap(curitem);
         if (temp.width() > 0)
             p->drawPixmap(drawVideoBounds.x(), drawVideoBounds.y(), temp);
     }
-
-    /* keep calling killPlayer() to handle nvp cleanup */
-    /* until killPlayer() is done */
-    if (previewVideoKillState != kDone && !killPlayer())
-        return;
-
-    /* if we aren't supposed to have a preview playing then always go */
-    /* to the stopping previewVideoState */
-    if (!previewVideoEnabled &&
-        (previewVideoState != kKilling) && (previewVideoState != kKilled))
+    
+    if (curitem && previewVideoEnabled && previewPlayer && 
+            !previewPlayer->IsHidden())
     {
-        previewVideoState = kStopping;
-    }
-
-    /* if we have no nvp and aren't playing yet */
-    /* if we have an item we should start playing */
-    if (!previewVideoNVP   && previewVideoEnabled  &&
-        curitem            && !previewVideoPlaying &&
-        (previewVideoState != kKilling) &&
-        (previewVideoState != kKilled)  &&
-        (previewVideoState != kStarting))
-    {
-        ProgramInfo *rec = curitem;
-
-        if (fileExists(rec) == false)
-        {
-            VERBOSE(VB_IMPORTANT, QString("Error: File '%1' missing.")
-                    .arg(rec->pathname));
-
-            previewVideoState = kStopping;
-
-            ProgramInfo *tmpItem = findMatchingProg(rec);
-            if (tmpItem)
-                tmpItem->availableStatus = asFileNotFound;
-
-            return;
-        }
-        previewVideoState = kStarting;
-    }
-
-    if (previewVideoState == kChanging)
-    {
-        if (previewVideoNVP)
-        {
-            killPlayer(); /* start killing the player */
-            return;
-        }
-
-        previewVideoState = kStarting;
-    }
-
-    if ((previewVideoState == kStarting) && 
-        (!previewVideoStartTimerOn ||
-         (previewVideoStartTimer.elapsed() > 500)))
-    {
-        previewVideoStartTimerOn = false;
-
-        if (!previewVideoNVP)
-            startPlayer(curitem);
-
-        if (previewVideoNVP)
-        {
-            if (previewVideoNVP->IsPlaying())
-                previewVideoState = kPlaying;
-        }
+        if (!previewPlayer->IsSameProgram(curitem))
+            stopPlayer();
         else
-        {
-            // already dead, so clean up
-            killPlayer();
-            return;
-        }
+            previewPlayer->GetNVP()->ExposeEvent();
     }
-
-    if ((previewVideoState == kStopping) || (previewVideoState == kKilling))
-    {
-        if (previewVideoNVP)
-        {
-            killPlayer(); /* start killing the player and exit */
-            return;
-        }
-
-        if (previewVideoState == kKilling)
-            previewVideoState = kKilled;
-        else
-            previewVideoState = kStopped;
-    }
-
-    /* if we are playing and nvp is running, then grab a new video frame */
-    if ((previewVideoState == kPlaying) && previewVideoNVP->IsPlaying() &&
-        !playingSomething)
-    {
-        QSize size = drawVideoBounds.size();
-        float saspect = ((float)size.width()) / ((float)size.height());
-        float vaspect = previewVideoNVP->GetVideoAspect();
-        size.setHeight((int) ceil(size.height() * (saspect / vaspect)));
-        size.setHeight(((size.height() + 7) / 8) * 8);
-        size.setWidth( ((size.width()  + 7) / 8) * 8);
-        const QImage &img = previewVideoNVP->GetARGBFrame(size);
-        p->drawImage(drawVideoBounds.x(), drawVideoBounds.y(), img);
-    }
-
-    /* have we timed out waiting for nvp to start? */
-    if ((previewVideoState == kPlaying) && !previewVideoNVP->IsPlaying())
-    {
-        if (previewVideoPlayingTimer.elapsed() > 2000)
-        {
-            previewVideoState = kStarting;
-            killPlayer();
-            return;
-        }
-    }
+   
+    previewVideoStartTimer->start(previewTimeout);
 }
 
 void PlaybackBox::updateUsage(QPainter *p)
@@ -1360 +1245 @@
     if (!inTitle)
     {
         if (haveGroupInfoSet)
-            killPlayerSafe();
+            killPlayer();
         
         inTitle = true;
         paintSkipUpdate = false;
@@ -1964 +1849 @@
     return (progCache != NULL);
 }
 
-static void *SpawnPreviewVideoThread(void *param)
+void PlaybackBox::killPlayer(void)
 {
-    NuppelVideoPlayer *nvp = (NuppelVideoPlayer *)param;
-    nvp->StartPlaying();
-    return NULL;
-}
-
-bool PlaybackBox::killPlayer(void)
-{
-    QMutexLocker locker(&previewVideoUnsafeKillLock);
-
-    previewVideoPlaying = false;
-
-    /* if we don't have nvp to deal with then we are done */
-    if (!previewVideoNVP)
+    if (previewPlayer)
     {
-        previewVideoKillState = kDone;
-        return true;
+        stopPlayer();
+        delete previewPlayer;
+        previewPlayer = NULL;
     }
-
-    if (previewVideoKillState == kDone)
-    {
-        previewVideoKillState = kNvpToPlay;
-        previewVideoKillTimeout.start();
-    }
- 
-    if (previewVideoKillState == kNvpToPlay)
-    {
-        if (previewVideoNVP->IsPlaying() ||
-            (previewVideoKillTimeout.elapsed() > 2000))
-        {
-            previewVideoKillState = kNvpToStop;
-
-            previewVideoRingBuf->Pause();
-            previewVideoNVP->StopPlaying();
-        }
-        else /* return false status since we aren't done yet */
-            return false;
-    }
-
-    if (previewVideoKillState == kNvpToStop)
-    {
-        if (!previewVideoNVP->IsPlaying() ||
-            (previewVideoKillTimeout.elapsed() > 2000))
-        {
-            pthread_join(previewVideoThread, NULL);
-            previewVideoThreadRunning = true;
-            delete previewVideoNVP;
-            delete previewVideoRingBuf;
-
-            previewVideoNVP = NULL;
-            previewVideoRingBuf = NULL;
-            previewVideoKillState = kDone;
-        }
-        else /* return false status since we aren't done yet */
-            return false;
-    }
-
-    return true;
 }        
 
 void PlaybackBox::startPlayer(ProgramInfo *rec)
 {
-    previewVideoPlaying = true;
-
-    if (rec != NULL)
+    ignoreKeyPressEvents = true; 
+    QMutexLocker locker(&previewVideoLock);
+    previewVideoStartTimer->start(previewTimeout);
+    previewVideoStopTimer->start(30000);
+    if (rec != NULL && previewPlayer)
     {
-        // Don't keep trying to open broken files when just sitting on entry
-        if (previewVideoBrokenRecId &&
-            previewVideoBrokenRecId == rec->recordid)
+        previewPlayer->Show();
+        if (!software_scaled)
+            previewPlayer->StartPlaying(rec, false);
+        if (!previewPlayer->IsPlaying())
         {
-            return;
+            previewVideoRefreshTimer->start(50);
+            software_scaled = true;
+            previewPlayer->StartPlaying(rec, false, true);
         }
+    }
+    ignoreKeyPressEvents = false;
+}
 
-        if (previewVideoRingBuf || previewVideoNVP)
-        {
-            VERBOSE(VB_IMPORTANT,
-                    "PlaybackBox::startPlayer(): Error, last preview window "
-                    "didn't clean up. Not starting a new preview.");
-            return;
-        }
-
-        previewVideoRingBuf = new RingBuffer(rec->pathname, false, false, 1);
-        if (!previewVideoRingBuf->IsOpen())
-        {
-            VERBOSE(VB_IMPORTANT, LOC_ERR +
-                    "Could not open file for preview video.");
-            delete previewVideoRingBuf;
-            previewVideoRingBuf = NULL;
-            previewVideoBrokenRecId = rec->recordid;
-            return;
-        }
-        previewVideoBrokenRecId = 0;
-
-        previewVideoNVP = new NuppelVideoPlayer("preview player");
-        previewVideoNVP->SetRingBuffer(previewVideoRingBuf);
-        previewVideoNVP->SetAsPIP();
-        QString filters = "";
-        previewVideoNVP->SetVideoFilters(filters);
-
-        previewVideoThreadRunning = true;
-        pthread_create(&previewVideoThread, NULL,
-                       SpawnPreviewVideoThread, previewVideoNVP);
-
-        previewVideoPlayingTimer.start();
-
-        previewVideoState = kStarting;
-
-        int previewRate = 30;
-        if (gContext->GetNumSetting("PlaybackPreviewLowCPU", 0))
-        {
-            previewRate = 12;
-        }
-        
-        previewVideoRefreshTimer->start(1000 / previewRate); 
+void PlaybackBox::stopPlayer(void)
+{
+    ignoreKeyPressEvents = true;
+    QMutexLocker locker(&previewVideoLock);
+    if (previewPlayer)
+    {
+        previewVideoRefreshTimer->stop();
+        previewPlayer->StopPlaying();
+        previewPlayer->Hide();
     }
+    ignoreKeyPressEvents = false;
 }
 
 void PlaybackBox::playSelectedPlaylist(bool random)
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2115 +1925 @@
 
 void PlaybackBox::playSelected()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2137 +1946 @@
 
 void PlaybackBox::stopSelected()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2147 +1955 @@
 
 void PlaybackBox::deleteSelected()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2161 +1968 @@
 
 void PlaybackBox::upcoming()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2180 +1986 @@
 
 void PlaybackBox::customEdit()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2203 +2008 @@
 
 void PlaybackBox::details()
 {
-    previewVideoState = kStopping;
 
     if (!curitem)
         return;
@@ -2216 +2020 @@
 
 void PlaybackBox::selected()
 {
-    previewVideoState = kStopping;
 
     if (inTitle && haveGroupInfoSet)
     {
@@ -2236 +2039 @@
 
 void PlaybackBox::showMenu()
 {
-    killPlayerSafe();
+    stopPlayer();
 
     popup = new MythPopupBox(gContext->GetMainWindow(), drawPopupSolid,
                              drawPopupFgColor, drawPopupBgColor,
@@ -2299 +2102 @@
 
 bool PlaybackBox::play(ProgramInfo *rec, bool inPlaylist)
 {
+    killPlayer(); 
+
     bool playCompleted = false;
 
     if (!rec)
@@ -2327 +2132 @@
     ProgramInfo *tvrec = new ProgramInfo(*rec);
 
     setEnabled(false);
-    previewVideoState = kKilling; // stop preview playback and don't restart it
     playingSomething = true;
 
     playCompleted = TV::StartTV(tvrec, false, inPlaylist, underNetworkControl);
@@ -2335 +2139 @@
     playingSomething = false;
     setEnabled(true);
 
-
-    previewVideoState = kStarting; // restart playback preview
-
     delete tvrec;
 
     connected = FillList();
 
+    if (previewVideoEnabled && !previewPlayer)
+    {
+        previewPlayer = PIPPlayer::Create(drawVideoBounds);
+        if (previewPlayer)
+            previewPlayer->Hide();
+    }
+
     return playCompleted;
 }
 
@@ -2353 +2161 @@
 bool PlaybackBox::doRemove(ProgramInfo *rec, bool forgetHistory,
                            bool forceMetadataDelete)
 {
-    previewVideoBrokenRecId = rec->recordid;
-    killPlayerSafe();
+    stopPlayer();
 
     if (playList.grep(rec->MakeUniqueKey()).count())
         togglePlayListItem(rec);
@@ -2367 +2174 @@
 
 void PlaybackBox::remove(ProgramInfo *toDel)
 {
-    previewVideoState = kStopping;
 
     if (delitem)
         delete delitem;
@@ -2378 +2184 @@
 
 void PlaybackBox::showActions(ProgramInfo *toExp)
 {
-    killPlayer();
+    stopPlayer();
 
     if (delitem)
         delete delitem;
@@ -3041 +2847 @@
 void PlaybackBox::initPopup(MythPopupBox *popup, ProgramInfo *program,
                             QString message, QString message2)
 {
-    killPlayerSafe();
+    stopPlayer();
 
     QDateTime recstartts = program->recstartts;
     QDateTime recendts = program->recendts;
@@ -3150 +2956 @@
 
     cancelPopup();
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 }
 
 void PlaybackBox::doStop(void)
@@ -3164 +2968 @@
 
     stop(delitem);
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 }
 
 void PlaybackBox::showProgramDetails()
@@ -3316 +3118 @@
 
     cancelPopup();
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 }
 
 void PlaybackBox::doPlaylistDelete(void)
@@ -3362 +3162 @@
 
     bool result = doRemove(delitem, false, false);
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 
     if (result)
     {
@@ -3397 +3195 @@
 
     doRemove(delitem, true, true);
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 }
 
 void PlaybackBox::doDeleteForgetHistory(void)
@@ -3422 +3218 @@
 
     bool result = doRemove(delitem, true, false);
 
-    previewVideoState = kChanging;
 
-    previewVideoRefreshTimer->start(500);
 
     if (result)
     {
@@ -3499 +3293 @@
     delete delitem;
     delitem = NULL;
 
-    previewVideoState = kChanging;
-
     connected = FillList();      
     update(drawListBounds);
 }
@@ -3521 +3313 @@
     delete delitem;
     delitem = NULL;
 
-    previewVideoState = kChanging;
 
     connected = FillList();      
     update(drawListBounds);
@@ -3570 +3361 @@
 
     cancelPopup();
 
-    previewVideoState = kChanging;
 }
 
 void PlaybackBox::toggleView(ViewMask itemMask, bool setOn)
@@ -3590 +3380 @@
     if (!rec)
         return;
 
-    previewVideoState = kStopping;
-
     if (!rec)
         return;
 
@@ -3688 +3476 @@
     update(drawListBounds);
 }
 
+void PlaybackBox::refreshVideo(void)
+{
+    if (previewPlayer &&
+        previewPlayer->IsPlaying() &&
+        previewPlayer->UsingNullVideo())
+    {
+        QMutexLocker locker(&previewVideoLock);
+        previewPlayer->GetARGBFrame();
+    }
+}
+
 void PlaybackBox::timeout(void)
 {
     if (titleList.count() <= 1)
         return;
 
-    if (previewVideoEnabled)
-        update(drawVideoBounds);
+    if (previewPlayer)
+    {
+        if (expectingPopup ||
+            !(this == gContext->GetMainWindow()->currentWidget()))
+        {
+            return;
+        }
+        else if (previewPlayer->GetNVP() == NULL)
+            startPlayer(curitem);
+        else if (!previewPlayer->IsPlaying())
+            stopPlayer();
+    }       
 }
 
+
 void PlaybackBox::processNetworkControlCommands(void)
 {
     int commands = 0;
@@ -4286 +4096 @@
         return;
     }
 
-    killPlayerSafe();
-
     iconhelp->addLayout(grid);
 
     QButton *button = iconhelp->addButton(tr("Ok"));
@@ -4297 +4105 @@
 
     delete iconhelp;
 
-    previewVideoState = kChanging;
 
     paintSkipUpdate = false;
     paintSkipCount = 2;
@@ -4317 +4124 @@
     QLabel *label = recGroupPopup->addLabel(title, MythPopupBox::Large, false);
     label->setAlignment(Qt::AlignCenter);
 
-    killPlayerSafe();
+    stopPlayer();
 
 }
 
@@ -4342 +4149 @@
     paintSkipUpdate = false;
     paintSkipCount = 2;
 
-    previewVideoState = kChanging;
-
     setActiveWindow();
 
     if (delitem)

programs/mythfrontend/globalsettings.cpp

@@ -1839 +1839 @@
     return gc;
 }
 
-static HostCheckBox *PlaybackPreviewLowCPU()
-{
-    HostCheckBox *gc = new HostCheckBox("PlaybackPreviewLowCPU");
-    gc->setLabel(QObject::tr("CPU friendly preview of recordings"));
-    gc->setValue(false);
-    gc->setHelpText(QObject::tr("When enabled, recording previews "
-                    "will play with reduced FPS to save CPU."));
-    return gc;
-}
-
 static HostCheckBox *PlayBoxTransparency()
 {
     HostCheckBox *gc = new HostCheckBox("PlayBoxTransparency");
@@ -4187 +4177 @@
     pbox->addChild(PreviewPixmapOffset());
     pbox->addChild(PreviewFromBookmark());
     pbox->addChild(PlaybackPreview());
-    pbox->addChild(PlaybackPreviewLowCPU());
     pbox->addChild(PBBStartInTitle());
     pbox->addChild(PBBShowGroupSummary());
     addChild(pbox);

programs/mythfrontend/playbackbox.h

@@ -26 +26 @@
 class QTimer;
 class ProgramInfo;
 class PreviewGenerator;
+class PIPPlayer;
 
 class LayerSet;
 
@@ -108 +109 @@
     
   protected slots:
     void timeout(void);
+    void refreshVideo(void);
 
     void cursorLeft();
     void cursorRight();
@@ -228 +230 @@
 
     void previewThreadDone(const QString &fn, bool &success);
     void previewReady(const ProgramInfo *pginfo);
+    void stopPlayer(void);
 
   protected:
     void paintEvent(QPaintEvent *);
@@ -267 +270 @@
     ProgramInfo *findMatchingProg(QString key);
     ProgramInfo *findMatchingProg(QString chanid, QString recstartts);
 
-    bool killPlayer(void);
-    void killPlayerSafe(void);
+    void killPlayer(void);
     void startPlayer(ProgramInfo *rec);
 
     bool doRemove(ProgramInfo *, bool forgetHistory, bool forceMetadataDelete);
@@ -420 +422 @@
     QPixmap             paintBackgroundPixmap;
 
     // Preview Video Variables ////////////////////////////////////////////////
-    NuppelVideoPlayer  *previewVideoNVP;
-    RingBuffer         *previewVideoRingBuf;
-    QTimer             *previewVideoRefreshTimer;
-    MythTimer           previewVideoStartTimer;
-    MythTimer           previewVideoPlayingTimer;  
-    int                 previewVideoBrokenRecId;
-    playerStateType     previewVideoState;
-    bool                previewVideoStartTimerOn;
-    bool                previewVideoEnabled;
-    bool                previewVideoPlaying;
-    bool                previewVideoThreadRunning;
-    pthread_t           previewVideoThread;
 
-    mutable QMutex      previewVideoKillLock;
-    mutable QMutex      previewVideoUnsafeKillLock;
-    killStateType       previewVideoKillState;
-    MythTimer           previewVideoKillTimeout;
+    PIPPlayer *previewPlayer;
+    QTimer *previewVideoStartTimer; // if this elapses start the PIP.
+    QTimer *previewVideoRefreshTimer; // refresh software scaled PIP
+    QTimer *previewVideoStopTimer; // if this elapses restart the PIP
+    bool previewVideoEnabled;
+    QMutex previewVideoLock;
+    int previewTimeout;
+    bool software_scaled; // pip is software scaled.
 
     // Preview Pixmap Variables ///////////////////////////////////////////////
     bool                previewPixmapEnabled;