MediaStreamPrivate.h [plain text]
#ifndef MediaStreamPrivate_h
#define MediaStreamPrivate_h
#if ENABLE(MEDIA_STREAM)
#include "FloatSize.h"
#include "MediaStreamTrack.h"
#include "MediaStreamTrackPrivate.h"
#include <wtf/Function.h>
#include <wtf/HashMap.h>
#include <wtf/MediaTime.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
#include <wtf/UUID.h>
#include <wtf/Vector.h>
#include <wtf/WeakPtr.h>
#if USE(GSTREAMER)
#include "GRefPtrGStreamer.h"
#include <owr/owr_gst_video_renderer.h>
#endif
namespace WebCore {
class MediaStream;
class OrientationNotifier;
class MediaStreamPrivate : public MediaStreamTrackPrivate::Observer, public RefCounted<MediaStreamPrivate> {
public:
class Observer {
public:
virtual ~Observer() { }
virtual void characteristicsChanged() { }
virtual void activeStatusChanged() { }
virtual void didAddTrack(MediaStreamTrackPrivate&) { }
virtual void didRemoveTrack(MediaStreamTrackPrivate&) { }
};
static Ref<MediaStreamPrivate> create(const Vector<Ref<RealtimeMediaSource>>& audioSources, const Vector<Ref<RealtimeMediaSource>>& videoSources);
static Ref<MediaStreamPrivate> create(const MediaStreamTrackPrivateVector& tracks, String&& id = createCanonicalUUIDString()) { return adoptRef(*new MediaStreamPrivate(tracks, WTFMove(id))); }
virtual ~MediaStreamPrivate();
enum class NotifyClientOption { Notify, DontNotify };
void addObserver(Observer&);
void removeObserver(Observer&);
String id() const { return m_id; }
MediaStreamTrackPrivateVector tracks() const;
MediaStreamTrackPrivate* activeVideoTrack() { return m_activeVideoTrack; }
bool active() const { return m_isActive; }
void updateActiveState(NotifyClientOption);
void addTrack(RefPtr<MediaStreamTrackPrivate>&&, NotifyClientOption = NotifyClientOption::Notify);
void removeTrack(MediaStreamTrackPrivate&, NotifyClientOption = NotifyClientOption::Notify);
void startProducingData();
void stopProducingData();
bool isProducingData() const;
void endStream();
bool hasVideo() const;
bool hasAudio() const;
bool muted() const;
bool hasCaptureVideoSource() const;
bool hasCaptureAudioSource() const;
void setCaptureTracksMuted(bool);
FloatSize intrinsicSize() const;
WeakPtr<MediaStreamPrivate> createWeakPtr() { return m_weakPtrFactory.createWeakPtr(); }
void monitorOrientation(OrientationNotifier&);
#if USE(GSTREAMER)
void setVideoRenderer(OwrGstVideoRenderer* renderer, GstElement* sink) { m_gstVideoRenderer = renderer; m_gstVideoSinkElement = sink; }
GRefPtr<GstElement> getVideoSinkElement() const { return m_gstVideoSinkElement; }
GRefPtr<OwrGstVideoRenderer> getVideoRenderer() const { return m_gstVideoRenderer; }
private:
GRefPtr<GstElement> m_gstVideoSinkElement;
GRefPtr<OwrGstVideoRenderer> m_gstVideoRenderer;
#endif
private:
MediaStreamPrivate(const MediaStreamTrackPrivateVector&, String&&);
void trackStarted(MediaStreamTrackPrivate&) override;
void trackEnded(MediaStreamTrackPrivate&) override;
void trackMutedChanged(MediaStreamTrackPrivate&) override;
void trackSettingsChanged(MediaStreamTrackPrivate&) override;
void trackEnabledChanged(MediaStreamTrackPrivate&) override;
void characteristicsChanged();
void updateActiveVideoTrack();
void scheduleDeferredTask(Function<void ()>&&);
WeakPtrFactory<MediaStreamPrivate> m_weakPtrFactory;
Vector<Observer*> m_observers;
String m_id;
MediaStreamTrackPrivate* m_activeVideoTrack { nullptr };
HashMap<String, RefPtr<MediaStreamTrackPrivate>> m_trackSet;
bool m_isActive { false };
};
typedef Vector<RefPtr<MediaStreamPrivate>> MediaStreamPrivateVector;
}
#endif // ENABLE(MEDIA_STREAM)
#endif // MediaStreamPrivate_h