MediaSourceGStreamer.cpp [plain text]
#include "config.h"
#include "MediaSourceGStreamer.h"
#if ENABLE(MEDIA_SOURCE) && USE(GSTREAMER)
#include "ContentType.h"
#include "MediaPlayerPrivateGStreamer.h"
#include "MediaPlayerPrivateGStreamerMSE.h"
#include "MediaSourceClientGStreamerMSE.h"
#include "NotImplemented.h"
#include "SourceBufferPrivateGStreamer.h"
#include "TimeRanges.h"
#include "WebKitMediaSourceGStreamer.h"
#include <wtf/PassRefPtr.h>
#include <wtf/glib/GRefPtr.h>
namespace WebCore {
void MediaSourceGStreamer::open(MediaSourcePrivateClient& mediaSource, MediaPlayerPrivateGStreamerMSE& playerPrivate)
{
mediaSource.setPrivateAndOpen(adoptRef(*new MediaSourceGStreamer(mediaSource, playerPrivate)));
}
MediaSourceGStreamer::MediaSourceGStreamer(MediaSourcePrivateClient& mediaSource, MediaPlayerPrivateGStreamerMSE& playerPrivate)
: MediaSourcePrivate()
, m_client(MediaSourceClientGStreamerMSE::create(playerPrivate))
, m_mediaSource(mediaSource)
, m_playerPrivate(playerPrivate)
{
}
MediaSourceGStreamer::~MediaSourceGStreamer()
{
for (auto& sourceBufferPrivate : m_sourceBuffers)
sourceBufferPrivate->clearMediaSource();
}
MediaSourceGStreamer::AddStatus MediaSourceGStreamer::addSourceBuffer(const ContentType& contentType, RefPtr<SourceBufferPrivate>& sourceBufferPrivate)
{
sourceBufferPrivate = SourceBufferPrivateGStreamer::create(this, m_client.get(), contentType);
RefPtr<SourceBufferPrivateGStreamer> sourceBufferPrivateGStreamer = static_cast<SourceBufferPrivateGStreamer*>(sourceBufferPrivate.get());
m_sourceBuffers.add(sourceBufferPrivateGStreamer);
return m_client->addSourceBuffer(sourceBufferPrivateGStreamer, contentType);
}
void MediaSourceGStreamer::removeSourceBuffer(SourceBufferPrivate* sourceBufferPrivate)
{
RefPtr<SourceBufferPrivateGStreamer> sourceBufferPrivateGStreamer = static_cast<SourceBufferPrivateGStreamer*>(sourceBufferPrivate);
ASSERT(m_sourceBuffers.contains(sourceBufferPrivateGStreamer));
sourceBufferPrivateGStreamer->clearMediaSource();
m_sourceBuffers.remove(sourceBufferPrivateGStreamer);
m_activeSourceBuffers.remove(sourceBufferPrivateGStreamer.get());
}
void MediaSourceGStreamer::durationChanged()
{
m_client->durationChanged(m_mediaSource->duration());
}
void MediaSourceGStreamer::markEndOfStream(EndOfStreamStatus status)
{
m_client->markEndOfStream(status);
}
void MediaSourceGStreamer::unmarkEndOfStream()
{
notImplemented();
}
MediaPlayer::ReadyState MediaSourceGStreamer::readyState() const
{
return m_playerPrivate.readyState();
}
void MediaSourceGStreamer::setReadyState(MediaPlayer::ReadyState state)
{
m_playerPrivate.setReadyState(state);
}
void MediaSourceGStreamer::waitForSeekCompleted()
{
m_playerPrivate.waitForSeekCompleted();
}
void MediaSourceGStreamer::seekCompleted()
{
m_playerPrivate.seekCompleted();
}
void MediaSourceGStreamer::sourceBufferPrivateDidChangeActiveState(SourceBufferPrivateGStreamer* sourceBufferPrivate, bool isActive)
{
if (!isActive)
m_activeSourceBuffers.remove(sourceBufferPrivate);
else if (!m_activeSourceBuffers.contains(sourceBufferPrivate))
m_activeSourceBuffers.add(sourceBufferPrivate);
}
std::unique_ptr<PlatformTimeRanges> MediaSourceGStreamer::buffered()
{
return m_mediaSource->buffered();
}
}
#endif