| Index: media/blink/buffered_data_source.h
|
| diff --git a/media/blink/buffered_data_source.h b/media/blink/buffered_data_source.h
|
| deleted file mode 100644
|
| index 0971983f40cedfbe716e81bb408d66d2d7abbe2a..0000000000000000000000000000000000000000
|
| --- a/media/blink/buffered_data_source.h
|
| +++ /dev/null
|
| @@ -1,348 +0,0 @@
|
| -// Copyright 2013 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#ifndef MEDIA_BLINK_BUFFERED_DATA_SOURCE_H_
|
| -#define MEDIA_BLINK_BUFFERED_DATA_SOURCE_H_
|
| -
|
| -#include <stdint.h>
|
| -
|
| -#include <memory>
|
| -#include <string>
|
| -#include <vector>
|
| -
|
| -#include "base/callback.h"
|
| -#include "base/macros.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "base/synchronization/lock.h"
|
| -#include "media/base/data_source.h"
|
| -#include "media/base/ranges.h"
|
| -#include "media/blink/buffered_resource_loader.h"
|
| -#include "media/blink/media_blink_export.h"
|
| -#include "url/gurl.h"
|
| -
|
| -namespace base {
|
| -class SingleThreadTaskRunner;
|
| -}
|
| -
|
| -namespace media {
|
| -class MediaLog;
|
| -
|
| -class MEDIA_BLINK_EXPORT BufferedDataSourceHost {
|
| - public:
|
| - // Notify the host of the total size of the media file.
|
| - virtual void SetTotalBytes(int64_t total_bytes) = 0;
|
| -
|
| - // Notify the host that byte range [start,end] has been buffered.
|
| - // TODO(fischman): remove this method when demuxing is push-based instead of
|
| - // pull-based. http://crbug.com/131444
|
| - virtual void AddBufferedByteRange(int64_t start, int64_t end) = 0;
|
| -
|
| - protected:
|
| - virtual ~BufferedDataSourceHost() {}
|
| -};
|
| -
|
| -// This interface is temporary and will go away once MultibufferDataSource
|
| -// has been fully evaluated.
|
| -class BufferedDataSourceInterface : public DataSource {
|
| - public:
|
| - // Used to specify video preload states. They are "hints" to the browser about
|
| - // how aggressively the browser should load and buffer data.
|
| - // Please see the HTML5 spec for the descriptions of these values:
|
| - // http://www.w3.org/TR/html5/video.html#attr-media-preload
|
| - //
|
| - // Enum values must match the values in blink::WebMediaPlayer::Preload and
|
| - // there will be assertions at compile time if they do not match.
|
| - enum Preload {
|
| - NONE,
|
| - METADATA,
|
| - AUTO,
|
| - };
|
| -
|
| - // Enum values must match the values in
|
| - // blink::WebMediaPlayer::BufferingStrategy and there will be assertions at
|
| - // compile time if they do not match.
|
| - enum BufferingStrategy {
|
| - BUFFERING_STRATEGY_NORMAL,
|
| - BUFFERING_STRATEGY_AGGRESSIVE,
|
| - };
|
| -
|
| - // Executes |init_cb| with the result of initialization when it has completed.
|
| - //
|
| - // Method called on the render thread.
|
| - typedef base::Callback<void(bool)> InitializeCB;
|
| - virtual void Initialize(const InitializeCB& init_cb) = 0;
|
| -
|
| - // Adjusts the buffering algorithm based on the given preload value.
|
| - virtual void SetPreload(Preload preload) = 0;
|
| -
|
| - // Adjusts the buffering algorithm based on the given buffering strategy
|
| - // value.
|
| - virtual void SetBufferingStrategy(BufferingStrategy buffering_strategy) = 0;
|
| -
|
| - // Returns true if the media resource has a single origin, false otherwise.
|
| - // Only valid to call after Initialize() has completed.
|
| - //
|
| - // Method called on the render thread.
|
| - virtual bool HasSingleOrigin() = 0;
|
| -
|
| - // Returns true if the media resource passed a CORS access control check.
|
| - virtual bool DidPassCORSAccessCheck() const = 0;
|
| -
|
| - // Cancels initialization, any pending loaders, and any pending read calls
|
| - // from the demuxer. The caller is expected to release its reference to this
|
| - // object and never call it again.
|
| - //
|
| - // Method called on the render thread.
|
| - virtual void Abort() = 0;
|
| -
|
| - // Notifies changes in playback state for controlling media buffering
|
| - // behavior.
|
| - virtual void MediaPlaybackRateChanged(double playback_rate) = 0;
|
| - virtual void MediaIsPlaying() = 0;
|
| - virtual bool media_has_played() const = 0;
|
| -
|
| - // Returns true if the resource is local.
|
| - virtual bool assume_fully_buffered() = 0;
|
| -
|
| - // Cancels any open network connections once reaching the deferred state. If
|
| - // |always_cancel| is false this is done only for preload=metadata, non-
|
| - // streaming resources that have not started playback. If |always_cancel| is
|
| - // true, all resource types will have their connections canceled. If already
|
| - // deferred, connections will be immediately closed.
|
| - virtual void OnBufferingHaveEnough(bool always_cancel) = 0;
|
| -
|
| - // Returns an estimate of the number of bytes held by the data source.
|
| - virtual int64_t GetMemoryUsage() const = 0;
|
| -
|
| - // Returns the post-Initialize() URL after redirects have been followed; this
|
| - // value may change at a later time.
|
| - virtual GURL GetUrlAfterRedirects() const = 0;
|
| -};
|
| -
|
| -// A data source capable of loading URLs and buffering the data using an
|
| -// in-memory sliding window.
|
| -//
|
| -// BufferedDataSource must be created and destroyed on the thread associated
|
| -// with the |task_runner| passed in the constructor.
|
| -class MEDIA_BLINK_EXPORT BufferedDataSource
|
| - : NON_EXPORTED_BASE(public BufferedDataSourceInterface) {
|
| - public:
|
| - // Number of cache misses or read failures we allow for a single Read() before
|
| - // signaling an error.
|
| - enum { kLoaderRetries = 30 };
|
| - typedef base::Callback<void(bool)> DownloadingCB;
|
| -
|
| - // |url| and |cors_mode| are passed to the object. Buffered byte range changes
|
| - // will be reported to |host|. |downloading_cb| will be called whenever the
|
| - // downloading/paused state of the source changes.
|
| - BufferedDataSource(
|
| - const GURL& url,
|
| - BufferedResourceLoader::CORSMode cors_mode,
|
| - const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
|
| - blink::WebFrame* frame,
|
| - MediaLog* media_log,
|
| - BufferedDataSourceHost* host,
|
| - const DownloadingCB& downloading_cb);
|
| - ~BufferedDataSource() override;
|
| -
|
| - // Executes |init_cb| with the result of initialization when it has completed.
|
| - //
|
| - // Method called on the render thread.
|
| - typedef base::Callback<void(bool)> InitializeCB;
|
| - void Initialize(const InitializeCB& init_cb) override;
|
| -
|
| - // Adjusts the buffering algorithm based on the given preload value.
|
| - void SetPreload(Preload preload) override;
|
| -
|
| - // Adjusts the buffering algorithm based on the given buffering strategy
|
| - // value.
|
| - void SetBufferingStrategy(BufferingStrategy buffering_strategy) override;
|
| -
|
| - // Returns true if the media resource has a single origin, false otherwise.
|
| - // Only valid to call after Initialize() has completed.
|
| - //
|
| - // Method called on the render thread.
|
| - bool HasSingleOrigin() override;
|
| -
|
| - // Returns true if the media resource passed a CORS access control check.
|
| - bool DidPassCORSAccessCheck() const override;
|
| -
|
| - // Cancels initialization, any pending loaders, and any pending read calls
|
| - // from the demuxer. The caller is expected to release its reference to this
|
| - // object and never call it again.
|
| - //
|
| - // Method called on the render thread.
|
| - void Abort() override;
|
| -
|
| - // Notifies changes in playback state for controlling media buffering
|
| - // behavior.
|
| - void MediaPlaybackRateChanged(double playback_rate) override;
|
| - void MediaIsPlaying() override;
|
| - bool media_has_played() const override;
|
| -
|
| - // Returns true if the resource is local.
|
| - bool assume_fully_buffered() override;
|
| -
|
| - // Cancels any open network connections once reaching the deferred state. If
|
| - // |always_cancel| is false this is done only for preload=metadata, non-
|
| - // streaming resources that have not started playback. If |always_cancel| is
|
| - // true, all resource types will have their connections canceled. If already
|
| - // deferred, connections will be immediately closed.
|
| - void OnBufferingHaveEnough(bool always_cancel) override;
|
| -
|
| - // Returns an estimate of the number of bytes held by the data source.
|
| - int64_t GetMemoryUsage() const override;
|
| -
|
| - GURL GetUrlAfterRedirects() const override;
|
| -
|
| - // DataSource implementation.
|
| - // Called from demuxer thread.
|
| - void Stop() override;
|
| -
|
| - void Read(int64_t position,
|
| - int size,
|
| - uint8_t* data,
|
| - const DataSource::ReadCB& read_cb) override;
|
| - bool GetSize(int64_t* size_out) override;
|
| - bool IsStreaming() override;
|
| - void SetBitrate(int bitrate) override;
|
| -
|
| - protected:
|
| - // A factory method to create a BufferedResourceLoader based on the read
|
| - // parameters. We can override this file to object a mock
|
| - // BufferedResourceLoader for testing.
|
| - virtual BufferedResourceLoader* CreateResourceLoader(
|
| - int64_t first_byte_position,
|
| - int64_t last_byte_position);
|
| -
|
| - private:
|
| - friend class BufferedDataSourceTest;
|
| -
|
| - // Task posted to perform actual reading on the render thread.
|
| - void ReadTask();
|
| -
|
| - // Cancels oustanding callbacks and sets |stop_signal_received_|. Safe to call
|
| - // from any thread.
|
| - void StopInternal_Locked();
|
| -
|
| - // Stops |loader_| if present. Used by Abort() and Stop().
|
| - void StopLoader();
|
| -
|
| - // Tells |loader_| the bitrate of the media.
|
| - void SetBitrateTask(int bitrate);
|
| -
|
| - // The method that performs actual read. This method can only be executed on
|
| - // the render thread.
|
| - void ReadInternal();
|
| -
|
| - // BufferedResourceLoader::Start() callback for initial load.
|
| - void StartCallback(BufferedResourceLoader::Status status);
|
| -
|
| - // BufferedResourceLoader::Start() callback for subsequent loads (i.e.,
|
| - // when accessing ranges that are outside initial buffered region).
|
| - void PartialReadStartCallback(BufferedResourceLoader::Status status);
|
| -
|
| - // Returns true if we can accept the new partial response.
|
| - bool CheckPartialResponseURL(const GURL& partial_response_original_url) const;
|
| -
|
| - // BufferedResourceLoader callbacks.
|
| - void ReadCallback(BufferedResourceLoader::Status status, int bytes_read);
|
| - void LoadingStateChangedCallback(BufferedResourceLoader::LoadingState state);
|
| - void ProgressCallback(int64_t position);
|
| -
|
| - // Update |loader_|'s deferring strategy.
|
| - void UpdateDeferStrategy();
|
| -
|
| - // URL of the resource requested.
|
| - GURL url_;
|
| - // crossorigin attribute on the corresponding HTML media element, if any.
|
| - BufferedResourceLoader::CORSMode cors_mode_;
|
| -
|
| - // The total size of the resource. Set during StartCallback() if the size is
|
| - // known, otherwise it will remain kPositionNotSpecified until the size is
|
| - // determined by reaching EOF.
|
| - int64_t total_bytes_;
|
| -
|
| - // This value will be true if this data source can only support streaming.
|
| - // i.e. range request is not supported.
|
| - bool streaming_;
|
| -
|
| - // A webframe for loading.
|
| - blink::WebFrame* frame_;
|
| -
|
| - // A resource loader for the media resource.
|
| - std::unique_ptr<BufferedResourceLoader> loader_;
|
| -
|
| - // Callback method from the pipeline for initialization.
|
| - InitializeCB init_cb_;
|
| -
|
| - // Read parameters received from the Read() method call. Must be accessed
|
| - // under |lock_|.
|
| - class ReadOperation;
|
| - std::unique_ptr<ReadOperation> read_op_;
|
| -
|
| - // This buffer is intermediate, we use it for BufferedResourceLoader to write
|
| - // to. And when read in BufferedResourceLoader is done, we copy data from
|
| - // this buffer to |read_buffer_|. The reason for an additional copy is that
|
| - // we don't own |read_buffer_|. But since the read operation is asynchronous,
|
| - // |read_buffer| can be destroyed at any time, so we only copy into
|
| - // |read_buffer| in the final step when it is safe.
|
| - // Memory is allocated for this member during initialization of this object
|
| - // because we want buffer to be passed into BufferedResourceLoader to be
|
| - // always non-null. And by initializing this member with a default size we can
|
| - // avoid creating zero-sized buffered if the first read has zero size.
|
| - std::vector<uint8_t> intermediate_read_buffer_;
|
| -
|
| - // The task runner of the render thread.
|
| - const scoped_refptr<base::SingleThreadTaskRunner> render_task_runner_;
|
| -
|
| - // Protects |stop_signal_received_| and |read_op_|.
|
| - base::Lock lock_;
|
| -
|
| - // Whether we've been told to stop via Abort() or Stop().
|
| - bool stop_signal_received_;
|
| -
|
| - // This variable is true when the user has requested the video to play at
|
| - // least once.
|
| - bool media_has_played_;
|
| -
|
| - // Buffering strategy as configured by SetBufferingStrategy().
|
| - BufferingStrategy buffering_strategy_;
|
| -
|
| - // This variable holds the value of the preload attribute for the video
|
| - // element.
|
| - Preload preload_;
|
| -
|
| - // Bitrate of the content, 0 if unknown.
|
| - int bitrate_;
|
| -
|
| - // Current playback rate.
|
| - double playback_rate_;
|
| -
|
| - scoped_refptr<MediaLog> media_log_;
|
| -
|
| - // Host object to report buffered byte range changes to.
|
| - BufferedDataSourceHost* host_;
|
| -
|
| - DownloadingCB downloading_cb_;
|
| -
|
| - // The original URL of the first response. If the request is redirected to
|
| - // another URL it is the URL after redirected. If the response is generated in
|
| - // a Service Worker this URL is empty. BufferedDataSource checks the original
|
| - // URL of each successive response. If the origin URL of it is different from
|
| - // the original URL of the first response, it is treated as an error.
|
| - GURL response_original_url_;
|
| -
|
| - // Disallow rebinding WeakReference ownership to a different thread by keeping
|
| - // a persistent reference. This avoids problems with the thread-safety of
|
| - // reaching into this class from multiple threads to attain a WeakPtr.
|
| - base::WeakPtr<BufferedDataSource> weak_ptr_;
|
| - base::WeakPtrFactory<BufferedDataSource> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(BufferedDataSource);
|
| -};
|
| -
|
| -} // namespace media
|
| -
|
| -#endif // MEDIA_BLINK_BUFFERED_DATA_SOURCE_H_
|
|
|