sdlplayer.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/atomic.h>
#include <promeki/audiodesc.h>
#include <promeki/basicthread.h>
#include <promeki/dedicatedthreadmediaio.h>
#include <promeki/framerate.h>
#include <promeki/framesync.h>
#include <promeki/mediaio.h>
#include <promeki/mutex.h>
#include <promeki/namespace.h>
#include <promeki/sdl/sdlaudioclock.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class SDLPlayerWidget;
class SDLAudioOutput;
class Clock;
 
class SDLPlayerMediaIO : public DedicatedThreadMediaIO {
                PROMEKI_OBJECT(SDLPlayerMediaIO, DedicatedThreadMediaIO)
                friend class SDLPlayerWidget;
 
        public:
                using UPtr = UniquePtr<SDLPlayerMediaIO>;
 
                ~SDLPlayerMediaIO() override;
 
                SDLPlayerWidget *widget() const { return _widget; }
 
                SDLAudioOutput *audioOutput() const { return _audioOutput; }
 
                bool useAudioClock() const { return _useAudioClock; }
 
                void pause();
 
                void resume();
 
                void togglePause();
 
                bool isPaused() const;
 
        public:
                Error describe(MediaIODescription *out) const override;
                Error proposeInput(const MediaDesc &offered, MediaDesc *preferred) const override;
 
                // MediaIO::close(false) (the watchdog's forced-close
                // path) calls this from a thread that's NOT the
                // worker — we're typically deadlocked with the
                // worker blocked inside FrameSync::pushFrame on
                // queue backpressure while the submitted CmdClose
                // sits behind it in the worker queue.  Interrupting
                // FrameSync unblocks the pending pushFrame so the
                // worker can drain to CmdClose.
                void cancelBlockingWork() override;
 
        protected:
                Error executeCmd(MediaIOCommandOpen &cmd) override;
                Error executeCmd(MediaIOCommandClose &cmd) override;
                Error executeCmd(MediaIOCommandWrite &cmd) override;
 
        private:
                SDLPlayerMediaIO(SDLPlayerWidget *widget, SDLAudioOutput *audio, bool useAudioClock);
 
                PixelFormat pickNativePixelFormat(const PixelFormat &offered) const;
 
                // Spawns the pull thread.  Caller must hold
                // @ref _clockMutex and guarantee no thread is already
                // running (i.e. @ref _pullThread is not joinable).
                void startPullThread();
 
                // Sets the running flag false, interrupts FrameSync,
                // and joins the pull thread if any.  Caller must hold
                // @ref _clockMutex.
                void stopPullThread();
 
                void pullLoop();
 
                // Owner back-pointer.  The widget outlives the task
                // (widget owns the MediaIO which owns us) so this
                // pointer is always valid for the task's lifetime.
                SDLPlayerWidget *_widget = nullptr;
                SDLAudioOutput  *_audioOutput = nullptr;
 
                bool _useAudioClock = true;
 
                // Per-open state.
                bool          _audioConfigured = false;
                FrameRate     _frameRate;
                AudioDesc     _audioDesc;
                Clock::Ptr    _clock;
                mutable Mutex _clockMutex; 
                FrameSync     _sync;
 
                // Pull-thread state.
                BasicThread  _pullThread;
                Atomic<bool> _pullRunning;
                int          _instanceId = 0; 
};
 
PROMEKI_NAMESPACE_END