MediaPlayerPrivateGStreamerMSE.h [plain text]
#pragma once
#if ENABLE(VIDEO) && USE(GSTREAMER) && ENABLE(MEDIA_SOURCE)
#include "GRefPtrGStreamer.h"
#include "MediaPlayerPrivateGStreamer.h"
#include "MediaSample.h"
#include "MediaSourceGStreamer.h"
#include "PlaybackPipeline.h"
#include "WebKitMediaSourceGStreamer.h"
namespace WebCore {
class MediaSourceClientGStreamerMSE;
class AppendPipeline;
class PlaybackPipeline;
class MediaPlayerPrivateGStreamerMSE : public MediaPlayerPrivateGStreamer {
WTF_MAKE_NONCOPYABLE(MediaPlayerPrivateGStreamerMSE); WTF_MAKE_FAST_ALLOCATED;
friend class MediaSourceClientGStreamerMSE;
public:
explicit MediaPlayerPrivateGStreamerMSE(MediaPlayer*);
virtual ~MediaPlayerPrivateGStreamerMSE();
static void registerMediaEngine(MediaEngineRegistrar);
void load(const String&) override;
void load(const String&, MediaSourcePrivateClient*) override;
void setDownloadBuffering() override { };
bool isLiveStream() const override { return false; }
MediaTime currentMediaTime() const override;
void pause() override;
bool seeking() const override;
void seek(float) override;
void configurePlaySink() override;
bool changePipelineState(GstState) override;
void durationChanged() override;
MediaTime durationMediaTime() const override;
void setRate(float) override;
std::unique_ptr<PlatformTimeRanges> buffered() const override;
float maxTimeSeekable() const override;
void sourceChanged() override;
void setReadyState(MediaPlayer::ReadyState);
void waitForSeekCompleted();
void seekCompleted();
MediaSourcePrivateClient* mediaSourcePrivateClient() { return m_mediaSource.get(); }
void markEndOfStream(MediaSourcePrivate::EndOfStreamStatus);
void trackDetected(RefPtr<AppendPipeline>, RefPtr<WebCore::TrackPrivateBase> oldTrack, RefPtr<WebCore::TrackPrivateBase> newTrack);
void notifySeekNeedsDataForTime(const MediaTime&);
static bool supportsCodecs(const String& codecs);
private:
static void getSupportedTypes(HashSet<String, ASCIICaseInsensitiveHash>&);
static MediaPlayer::SupportsType supportsType(const MediaEngineSupportParameters&);
static bool isAvailable();
void updateStates() override;
bool doSeek(gint64, float, GstSeekFlags) override;
bool doSeek();
void maybeFinishSeek();
void updatePlaybackRate() override;
void asyncStateChangeDone() override;
unsigned long totalVideoFrames() override { return 0; }
unsigned long droppedVideoFrames() override { return 0; }
unsigned long corruptedVideoFrames() override { return 0; }
MediaTime totalFrameDelay() override { return MediaTime::zeroTime(); }
bool isTimeBuffered(const MediaTime&) const;
bool isMediaSource() const override { return true; }
void setMediaSourceClient(Ref<MediaSourceClientGStreamerMSE>);
RefPtr<MediaSourceClientGStreamerMSE> mediaSourceClient();
HashMap<RefPtr<SourceBufferPrivateGStreamer>, RefPtr<AppendPipeline>> m_appendPipelinesMap;
bool m_eosMarked = false;
mutable bool m_eosPending = false;
bool m_gstSeekCompleted = true;
RefPtr<MediaSourcePrivateClient> m_mediaSource;
RefPtr<MediaSourceClientGStreamerMSE> m_mediaSourceClient;
MediaTime m_mediaTimeDuration;
bool m_mseSeekCompleted = true;
RefPtr<PlaybackPipeline> m_playbackPipeline;
};
}
#endif // USE(GSTREAMER)