diff options
author | Matt A. Tobin <mattatobin@localhost.localdomain> | 2018-02-02 04:16:08 -0500 |
---|---|---|
committer | Matt A. Tobin <mattatobin@localhost.localdomain> | 2018-02-02 04:16:08 -0500 |
commit | 5f8de423f190bbb79a62f804151bc24824fa32d8 (patch) | |
tree | 10027f336435511475e392454359edea8e25895d /dom/media/mediasource/SourceBufferResource.h | |
parent | 49ee0794b5d912db1f95dce6eb52d781dc210db5 (diff) | |
download | UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.gz UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.lz UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.xz UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.zip |
Add m-esr52 at 52.6.0
Diffstat (limited to 'dom/media/mediasource/SourceBufferResource.h')
-rw-r--r-- | dom/media/mediasource/SourceBufferResource.h | 161 |
1 files changed, 161 insertions, 0 deletions
diff --git a/dom/media/mediasource/SourceBufferResource.h b/dom/media/mediasource/SourceBufferResource.h new file mode 100644 index 000000000..26ed74602 --- /dev/null +++ b/dom/media/mediasource/SourceBufferResource.h @@ -0,0 +1,161 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* vim: set ts=8 sts=2 et sw=2 tw=80: */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +#ifndef MOZILLA_SOURCEBUFFERRESOURCE_H_ +#define MOZILLA_SOURCEBUFFERRESOURCE_H_ + +#include "MediaCache.h" +#include "MediaResource.h" +#include "ResourceQueue.h" +#include "mozilla/Attributes.h" +#include "mozilla/ReentrantMonitor.h" +#include "nsCOMPtr.h" +#include "nsError.h" +#include "nsIPrincipal.h" +#include "nsString.h" +#include "nsTArray.h" +#include "nscore.h" +#include "mozilla/Logging.h" + +#define UNIMPLEMENTED() { /* Logging this is too spammy to do by default */ } + +class nsIStreamListener; + +namespace mozilla { + +class MediaDecoder; +class MediaByteBuffer; + +namespace dom { + +class SourceBuffer; + +} // namespace dom + +class SourceBufferResource final : public MediaResource +{ +public: + explicit SourceBufferResource(const nsACString& aType); + nsresult Close() override; + void Suspend(bool aCloseImmediately) override { UNIMPLEMENTED(); } + void Resume() override { UNIMPLEMENTED(); } + already_AddRefed<nsIPrincipal> GetCurrentPrincipal() override { UNIMPLEMENTED(); return nullptr; } + already_AddRefed<MediaResource> CloneData(MediaResourceCallback*) override { UNIMPLEMENTED(); return nullptr; } + void SetReadMode(MediaCacheStream::ReadMode aMode) override { UNIMPLEMENTED(); } + void SetPlaybackRate(uint32_t aBytesPerSecond) override { UNIMPLEMENTED(); } + nsresult ReadAt(int64_t aOffset, char* aBuffer, uint32_t aCount, uint32_t* aBytes) override; + int64_t Tell() override { return mOffset; } + void Pin() override { UNIMPLEMENTED(); } + void Unpin() override { UNIMPLEMENTED(); } + double GetDownloadRate(bool* aIsReliable) override { UNIMPLEMENTED(); *aIsReliable = false; return 0; } + int64_t GetLength() override { return mInputBuffer.GetLength(); } + int64_t GetNextCachedData(int64_t aOffset) override { + ReentrantMonitorAutoEnter mon(mMonitor); + MOZ_ASSERT(aOffset >= 0); + if (uint64_t(aOffset) < mInputBuffer.GetOffset()) { + return mInputBuffer.GetOffset(); + } else if (aOffset == GetLength()) { + return -1; + } + return aOffset; + } + int64_t GetCachedDataEnd(int64_t aOffset) override { UNIMPLEMENTED(); return -1; } + bool IsDataCachedToEndOfResource(int64_t aOffset) override { return false; } + bool IsSuspendedByCache() override { UNIMPLEMENTED(); return false; } + bool IsSuspended() override { UNIMPLEMENTED(); return false; } + nsresult ReadFromCache(char* aBuffer, int64_t aOffset, uint32_t aCount) override; + bool IsTransportSeekable() override { UNIMPLEMENTED(); return true; } + nsresult Open(nsIStreamListener** aStreamListener) override { UNIMPLEMENTED(); return NS_ERROR_FAILURE; } + + nsresult GetCachedRanges(MediaByteRangeSet& aRanges) override + { + ReentrantMonitorAutoEnter mon(mMonitor); + if (mInputBuffer.GetLength()) { + aRanges += MediaByteRange(mInputBuffer.GetOffset(), + mInputBuffer.GetLength()); + } + return NS_OK; + } + + const nsCString& GetContentType() const override { return mType; } + + size_t SizeOfExcludingThis(MallocSizeOf aMallocSizeOf) const override + { + ReentrantMonitorAutoEnter mon(mMonitor); + + size_t size = MediaResource::SizeOfExcludingThis(aMallocSizeOf); + size += mType.SizeOfExcludingThisIfUnshared(aMallocSizeOf); + size += mInputBuffer.SizeOfExcludingThis(aMallocSizeOf); + + return size; + } + + size_t SizeOfIncludingThis(MallocSizeOf aMallocSizeOf) const override + { + return aMallocSizeOf(this) + SizeOfExcludingThis(aMallocSizeOf); + } + + bool IsExpectingMoreData() override + { + return false; + } + + // Used by SourceBuffer. + void AppendData(MediaByteBuffer* aData); + void Ended(); + bool IsEnded() + { + ReentrantMonitorAutoEnter mon(mMonitor); + return mEnded; + } + // Remove data from resource if it holds more than the threshold reduced by + // the given number of bytes. Returns amount evicted. + uint32_t EvictData(uint64_t aPlaybackOffset, int64_t aThresholdReduct, + ErrorResult& aRv); + + // Remove data from resource before the given offset. + void EvictBefore(uint64_t aOffset, ErrorResult& aRv); + + // Remove all data from the resource + uint32_t EvictAll(); + + // Returns the amount of data currently retained by this resource. + int64_t GetSize() { + ReentrantMonitorAutoEnter mon(mMonitor); + return mInputBuffer.GetLength() - mInputBuffer.GetOffset(); + } + +#if defined(DEBUG) + void Dump(const char* aPath) { + mInputBuffer.Dump(aPath); + } +#endif + +private: + virtual ~SourceBufferResource(); + nsresult ReadAtInternal(int64_t aOffset, char* aBuffer, uint32_t aCount, uint32_t* aBytes, bool aMayBlock); + + const nsCString mType; + + // Provides synchronization between SourceBuffers and InputAdapters. + // Protects all of the member variables below. Read() will await a + // Notify() (from Seek, AppendData, Ended, or Close) when insufficient + // data is available in mData. + mutable ReentrantMonitor mMonitor; + + // The buffer holding resource data. + ResourceQueue mInputBuffer; + + uint64_t mOffset; + bool mClosed; + bool mEnded; +}; + +} // namespace mozilla + +#undef UNIMPLEMENTED + +#endif /* MOZILLA_SOURCEBUFFERRESOURCE_H_ */ |