MediaStreamTrackPrivate.cpp [plain text]
#include "config.h"
#include "MediaStreamTrackPrivate.h"
#if ENABLE(MEDIA_STREAM)
#include "GraphicsContext.h"
#include "IntRect.h"
#include <wtf/UUID.h>
#if PLATFORM(COCOA)
#include "WebAudioSourceProviderAVFObjC.h"
#else
#include "WebAudioSourceProvider.h"
#endif
namespace WebCore {
Ref<MediaStreamTrackPrivate> MediaStreamTrackPrivate::create(Ref<RealtimeMediaSource>&& source)
{
return create(WTFMove(source), createCanonicalUUIDString());
}
Ref<MediaStreamTrackPrivate> MediaStreamTrackPrivate::create(Ref<RealtimeMediaSource>&& source, String&& id)
{
return adoptRef(*new MediaStreamTrackPrivate(WTFMove(source), WTFMove(id)));
}
MediaStreamTrackPrivate::MediaStreamTrackPrivate(Ref<RealtimeMediaSource>&& source, String&& id)
: m_source(WTFMove(source))
, m_id(WTFMove(id))
{
m_source->addObserver(*this);
}
MediaStreamTrackPrivate::~MediaStreamTrackPrivate()
{
m_source->removeObserver(*this);
}
void MediaStreamTrackPrivate::addObserver(MediaStreamTrackPrivate::Observer& observer)
{
m_observers.append(&observer);
}
void MediaStreamTrackPrivate::removeObserver(MediaStreamTrackPrivate::Observer& observer)
{
size_t pos = m_observers.find(&observer);
if (pos != notFound)
m_observers.remove(pos);
}
const String& MediaStreamTrackPrivate::label() const
{
return m_source->name();
}
bool MediaStreamTrackPrivate::muted() const
{
return m_source->muted();
}
bool MediaStreamTrackPrivate::isCaptureTrack() const
{
return m_source->isCaptureSource();
}
void MediaStreamTrackPrivate::setEnabled(bool enabled)
{
if (m_isEnabled == enabled)
return;
m_isEnabled = enabled;
for (auto& observer : m_observers)
observer->trackEnabledChanged(*this);
}
void MediaStreamTrackPrivate::endTrack()
{
if (m_isEnded)
return;
m_isEnded = true;
updateReadyState();
m_source->requestStop(this);
for (auto& observer : m_observers)
observer->trackEnded(*this);
}
Ref<MediaStreamTrackPrivate> MediaStreamTrackPrivate::clone()
{
auto clonedMediaStreamTrackPrivate = create(m_source.copyRef());
clonedMediaStreamTrackPrivate->m_isEnabled = this->m_isEnabled;
clonedMediaStreamTrackPrivate->m_isEnded = this->m_isEnded;
clonedMediaStreamTrackPrivate->updateReadyState();
return clonedMediaStreamTrackPrivate;
}
RealtimeMediaSource::Type MediaStreamTrackPrivate::type() const
{
return m_source->type();
}
const RealtimeMediaSourceSettings& MediaStreamTrackPrivate::settings() const
{
return m_source->settings();
}
const RealtimeMediaSourceCapabilities& MediaStreamTrackPrivate::capabilities() const
{
return m_source->capabilities();
}
void MediaStreamTrackPrivate::applyConstraints(const MediaConstraints& constraints, RealtimeMediaSource::SuccessHandler&& successHandler, RealtimeMediaSource::FailureHandler&& failureHandler)
{
m_source->applyConstraints(constraints, WTFMove(successHandler), WTFMove(failureHandler));
}
AudioSourceProvider* MediaStreamTrackPrivate::audioSourceProvider()
{
#if PLATFORM(COCOA)
if (!m_audioSourceProvider)
m_audioSourceProvider = WebAudioSourceProviderAVFObjC::create(*this);
#endif
return m_audioSourceProvider.get();
}
void MediaStreamTrackPrivate::sourceStarted()
{
for (auto& observer : m_observers)
observer->trackStarted(*this);
}
void MediaStreamTrackPrivate::sourceStopped()
{
if (m_isEnded)
return;
m_isEnded = true;
updateReadyState();
for (auto& observer : m_observers)
observer->trackEnded(*this);
}
void MediaStreamTrackPrivate::sourceMutedChanged()
{
for (auto& observer : m_observers)
observer->trackMutedChanged(*this);
}
void MediaStreamTrackPrivate::sourceSettingsChanged()
{
for (auto& observer : m_observers)
observer->trackSettingsChanged(*this);
}
bool MediaStreamTrackPrivate::preventSourceFromStopping()
{
return !m_isEnded;
}
void MediaStreamTrackPrivate::videoSampleAvailable(MediaSample& mediaSample)
{
if (!m_haveProducedData) {
m_haveProducedData = true;
updateReadyState();
}
if (!enabled())
return;
mediaSample.setTrackID(id());
for (auto& observer : m_observers)
observer->sampleBufferUpdated(*this, mediaSample);
}
void MediaStreamTrackPrivate::audioSamplesAvailable(const MediaTime& mediaTime, const PlatformAudioData& data, const AudioStreamDescription& description, size_t sampleCount)
{
if (!m_haveProducedData) {
m_haveProducedData = true;
updateReadyState();
}
if (!enabled())
return;
for (auto& observer : m_observers)
observer->audioSamplesAvailable(*this, mediaTime, data, description, sampleCount);
}
void MediaStreamTrackPrivate::updateReadyState()
{
ReadyState state = ReadyState::None;
if (m_isEnded)
state = ReadyState::Ended;
else if (m_haveProducedData)
state = ReadyState::Live;
if (state == m_readyState)
return;
m_readyState = state;
for (auto& observer : m_observers)
observer->readyStateChanged(*this);
}
}
#endif // ENABLE(MEDIA_STREAM)