Index: media/blink/multibuffer_reader.h |
diff --git a/media/blink/multibuffer_reader.h b/media/blink/multibuffer_reader.h |
deleted file mode 100644 |
index 44f14f996ee3ebd83e74ac2fc7dca0634fb28444..0000000000000000000000000000000000000000 |
--- a/media/blink/multibuffer_reader.h |
+++ /dev/null |
@@ -1,158 +0,0 @@ |
-// Copyright 2015 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_MULTIBUFFER_READER_H_ |
-#define MEDIA_BLINK_MULTIBUFFER_READER_H_ |
- |
-#include <stdint.h> |
- |
-#include <limits> |
-#include <map> |
-#include <set> |
- |
-#include "base/callback.h" |
-#include "base/memory/weak_ptr.h" |
-#include "media/blink/media_blink_export.h" |
-#include "media/blink/multibuffer.h" |
- |
-namespace media { |
- |
-// Wrapper for MultiBuffer that offers a simple byte-reading |
-// interface with prefetch. |
-class MEDIA_BLINK_EXPORT MultiBufferReader |
- : NON_EXPORTED_BASE(public MultiBuffer::Reader) { |
- public: |
- // Note that |progress_callback| is guaranteed to be called if |
- // a redirect happens and the url_data is updated. Otherwise |
- // origin checks will become insecure. |
- // Users probably want to call SetMaxBuffer & SetPreload after |
- // creating the a MultiBufferReader. |
- // The progress callback will be called when the "available range" |
- // changes. (The number of bytes available for reading before and |
- // after the current position.) The arguments for the progress |
- // callback is the first byte available (from beginning of file) |
- // and the last byte available + 1. Note that there may be other |
- // regions of available data in the cache as well. |
- // If |end| is not known, use -1. |
- MultiBufferReader( |
- MultiBuffer* multibuffer, |
- int64_t start, |
- int64_t end, |
- const base::Callback<void(int64_t, int64_t)>& progress_callback); |
- |
- ~MultiBufferReader() override; |
- |
- // Returns number of bytes available for reading. When the rest of the file |
- // is available, the number returned will be greater than the number |
- // or readable bytes. If an error occurs, -1 is returned. |
- int64_t Available() const; |
- |
- // Seek to a different position. |
- // If there is a pending Wait(), it will be cancelled. |
- void Seek(int64_t pos); |
- |
- // Returns the current position. |
- int64_t Tell() const { return pos_; } |
- |
- // Tries to read |len| bytes and advance position. |
- // Returns number of bytes read. |
- // If there is a pending Wait(), it will be cancelled. |
- int64_t TryRead(uint8_t* data, int64_t len); |
- |
- // Wait until |len| bytes are available for reading. |
- // Returns net::OK if |len| bytes are already available, otherwise it will |
- // return net::ERR_IO_PENDING and call |cb| at some point later. |
- // |len| must be smaller or equal to max_buffer_forward. |
- int Wait(int64_t len, const base::Closure& cb); |
- |
- // Set how much data we try to preload into the cache ahead of our current |
- // location. Normally, we preload until we have preload_high bytes, then |
- // stop until we fall below preload_low bytes. Note that preload can be |
- // set higher than max_buffer_forward, but the result is usually that |
- // some blocks will be freed between the current position and the preload |
- // position. |
- void SetPreload(int64_t preload_high, int64_t preload_low); |
- |
- // Change how much data we pin to the cache. |
- // The range [current_position - backward ... current_position + forward) |
- // will be locked in the cache. Calling Wait() or TryRead() with values |
- // larger than |forward| is not supported. |
- void SetMaxBuffer(int64_t backward, int64_t forward); |
- |
- // Returns true if we are currently loading data. |
- bool IsLoading() const; |
- |
- // Reader implementation. |
- void NotifyAvailableRange(const Interval<MultiBufferBlockId>& range) override; |
- |
- // Getters |
- int64_t preload_high() const { return preload_high_; } |
- int64_t preload_low() const { return preload_low_; } |
- |
- private: |
- // Returns the block for a particular byte position. |
- MultiBufferBlockId block(int64_t byte_pos) const { |
- return byte_pos >> multibuffer_->block_size_shift(); |
- } |
- |
- // Returns the block for a particular byte position, rounding up. |
- MultiBufferBlockId block_ceil(int64_t byte_pos) const { |
- return block(byte_pos + (1LL << multibuffer_->block_size_shift()) - 1); |
- } |
- |
- // Check if wait operation can complete now. |
- void CheckWait(); |
- |
- // Recalculate preload_pos_ and update our entry in the multibuffer |
- // reader index. Also call CheckWait(). This function is basically |
- // called anything changes, like when we get more data or seek to |
- // a new position. |
- void UpdateInternalState(); |
- |
- // Indirection function used to call callbacks. When we post a callback |
- // we indirect it through a weak_ptr and this function to make sure we |
- // don't call any callbacks after this object has been destroyed. |
- void Call(const base::Closure& cb) const; |
- |
- // The multibuffer we're wrapping, not owned. |
- MultiBuffer* multibuffer_; |
- |
- // We're not interested in reading past this position. |
- int64_t end_; |
- |
- // Defer reading once we have this much data. |
- int64_t preload_high_; |
- // Stop deferring once we have this much data. |
- int64_t preload_low_; |
- |
- // Pin this much data in the cache from the current position. |
- int64_t max_buffer_forward_; |
- int64_t max_buffer_backward_; |
- |
- // Current position in bytes. |
- int64_t pos_; |
- |
- // [block(pos_)..preload_pos_) are known to be in the cache. |
- // preload_pos_ is only allowed to point to a filled |
- // cache position if it is equal to end_ or pos_+preload_. |
- // This is a pointer to a slot in the cache, so the unit is |
- // blocks. |
- MultiBufferBlockId preload_pos_; |
- |
- // True if we've requested data from the cache by calling WaitFor(). |
- bool loading_; |
- |
- // When Available() > current_wait_size_ we call cb_. |
- int64_t current_wait_size_; |
- base::Closure cb_; |
- |
- // Progress callback. |
- base::Callback<void(int64_t, int64_t)> progress_callback_; |
- |
- base::WeakPtrFactory<MultiBufferReader> weak_factory_; |
-}; |
- |
-} // namespace media |
- |
-#endif // MEDIA_BLINK_MULTIBUFFER_READER_H_ |