RemoteSourceBufferProxy.h [plain text]
#pragma once
#if ENABLE(GPU_PROCESS) && ENABLE(MEDIA_SOURCE)
#include "DataReference.h"
#include "GPUConnectionToWebProcess.h"
#include "MessageReceiver.h"
#include "RemoteSourceBufferIdentifier.h"
#include "TrackPrivateRemoteIdentifier.h"
#include <WebCore/MediaDescription.h>
#include <WebCore/SourceBufferPrivate.h>
#include <WebCore/SourceBufferPrivateClient.h>
#include <wtf/Ref.h>
#include <wtf/text/AtomString.h>
namespace IPC {
class Connection;
class Decoder;
}
namespace WebCore {
class MediaSample;
class PlatformTimeRanges;
}
namespace WebKit {
struct MediaDescriptionInfo;
class RemoteMediaPlayerProxy;
class RemoteSourceBufferProxy final
: public RefCounted<RemoteSourceBufferProxy>
, public WebCore::SourceBufferPrivateClient
, private IPC::MessageReceiver {
WTF_MAKE_FAST_ALLOCATED;
public:
static Ref<RemoteSourceBufferProxy> create(GPUConnectionToWebProcess&, RemoteSourceBufferIdentifier, Ref<WebCore::SourceBufferPrivate>&&, RemoteMediaPlayerProxy&);
virtual ~RemoteSourceBufferProxy();
private:
RemoteSourceBufferProxy(GPUConnectionToWebProcess&, RemoteSourceBufferIdentifier, Ref<WebCore::SourceBufferPrivate>&&, RemoteMediaPlayerProxy&);
void sourceBufferPrivateDidReceiveInitializationSegment(InitializationSegment&&, CompletionHandler<void()>&&) final;
void sourceBufferPrivateStreamEndedWithDecodeError() final;
void sourceBufferPrivateAppendError(bool decodeError) final;
void sourceBufferPrivateAppendComplete(WebCore::SourceBufferPrivateClient::AppendResult) final;
void sourceBufferPrivateHighestPresentationTimestampChanged(const MediaTime&) final;
void sourceBufferPrivateDurationChanged(const MediaTime&) final;
void sourceBufferPrivateDidParseSample(double sampleDuration) final;
void sourceBufferPrivateDidDropSample() final;
void sourceBufferPrivateBufferedDirtyChanged(bool) final;
void sourceBufferPrivateBufferedRangesChanged(const WebCore::PlatformTimeRanges&) final;
void sourceBufferPrivateDidReceiveRenderingError(int64_t errorCode) final;
void sourceBufferPrivateReportExtraMemoryCost(uint64_t extraMemory) final;
void didReceiveMessage(IPC::Connection&, IPC::Decoder&) final;
void setActive(bool);
void setMode(WebCore::SourceBufferAppendMode);
void append(const IPC::DataReference&);
void abort();
void resetParserState();
void removedFromMediaSource();
void setMediaSourceEnded(bool);
void setReadyState(WebCore::MediaPlayer::ReadyState);
void startChangingType();
void updateBufferedFromTrackBuffers(bool sourceIsEnded);
void removeCodedFrames(const MediaTime& start, const MediaTime& end, const MediaTime& currentTime, bool isEnded, CompletionHandler<void()>&&);
void evictCodedFrames(uint64_t newDataSize, uint64_t pendingAppendDataCapacity, uint64_t maximumBufferSize, const MediaTime& currentTime, const MediaTime& duration, bool isEnded);
void addTrackBuffer(TrackPrivateRemoteIdentifier);
void resetTrackBuffers();
void clearTrackBuffers();
void setAllTrackBuffersNeedRandomAccess();
void reenqueueMediaIfNeeded(const MediaTime& currentMediaTime, uint64_t pendingAppendDataCapacity, uint64_t maximumBufferSize);
void setGroupStartTimestamp(const MediaTime&);
void setGroupStartTimestampToEndTimestamp();
void setShouldGenerateTimestamps(bool);
void resetTimestampOffsetInTrackBuffers();
void setTimestampOffset(const MediaTime&);
void setAppendWindowStart(const MediaTime&);
void setAppendWindowEnd(const MediaTime&);
void seekToTime(const MediaTime&);
void updateTrackIds(Vector<std::pair<TrackPrivateRemoteIdentifier, TrackPrivateRemoteIdentifier>>&&);
void bufferedSamplesForTrackId(TrackPrivateRemoteIdentifier, CompletionHandler<void(Vector<String>&&)>&&);
GPUConnectionToWebProcess& m_connectionToWebProcess;
RemoteSourceBufferIdentifier m_identifier;
Ref<WebCore::SourceBufferPrivate> m_sourceBufferPrivate;
WeakPtr<RemoteMediaPlayerProxy> m_remoteMediaPlayerProxy;
HashMap<TrackPrivateRemoteIdentifier, AtomString> m_trackIds;
HashMap<TrackPrivateRemoteIdentifier, Ref<WebCore::MediaDescription>> m_mediaDescriptions;
};
}
#endif // ENABLE(GPU_PROCESS) && ENABLE(MEDIA_SOURCE)