Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/renderer/media/buffered_data_source.h" | 5 #include "content/renderer/media/buffered_data_source.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/callback_helpers.h" | 8 #include "base/callback_helpers.h" |
| 9 #include "base/message_loop/message_loop_proxy.h" | 9 #include "base/message_loop/message_loop_proxy.h" |
| 10 #include "content/public/common/url_constants.h" | 10 #include "content/public/common/url_constants.h" |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 72 DCHECK(callback_.is_null()); | 72 DCHECK(callback_.is_null()); |
| 73 } | 73 } |
| 74 | 74 |
| 75 // static | 75 // static |
| 76 void BufferedDataSource::ReadOperation::Run( | 76 void BufferedDataSource::ReadOperation::Run( |
| 77 scoped_ptr<ReadOperation> read_op, int result) { | 77 scoped_ptr<ReadOperation> read_op, int result) { |
| 78 base::ResetAndReturn(&read_op->callback_).Run(result); | 78 base::ResetAndReturn(&read_op->callback_).Run(result); |
| 79 } | 79 } |
| 80 | 80 |
| 81 BufferedDataSource::BufferedDataSource( | 81 BufferedDataSource::BufferedDataSource( |
| 82 const GURL& url, | |
| 83 BufferedResourceLoader::CORSMode cors_mode, | |
| 82 const scoped_refptr<base::MessageLoopProxy>& render_loop, | 84 const scoped_refptr<base::MessageLoopProxy>& render_loop, |
| 83 WebFrame* frame, | 85 WebFrame* frame, |
| 84 media::MediaLog* media_log, | 86 media::MediaLog* media_log, |
| 85 BufferedDataSourceHost* host, | 87 BufferedDataSourceHost* host, |
| 86 const DownloadingCB& downloading_cb) | 88 const DownloadingCB& downloading_cb) |
| 87 : cors_mode_(BufferedResourceLoader::kUnspecified), | 89 : url_(url), |
| 90 cors_mode_(cors_mode), | |
| 88 total_bytes_(kPositionNotSpecified), | 91 total_bytes_(kPositionNotSpecified), |
| 89 assume_fully_buffered_(false), | 92 assume_fully_buffered_(false), |
| 90 streaming_(false), | 93 streaming_(false), |
| 91 frame_(frame), | 94 frame_(frame), |
| 92 intermediate_read_buffer_(new uint8[kInitialReadBufferSize]), | 95 intermediate_read_buffer_(new uint8[kInitialReadBufferSize]), |
| 93 intermediate_read_buffer_size_(kInitialReadBufferSize), | 96 intermediate_read_buffer_size_(kInitialReadBufferSize), |
| 94 render_loop_(render_loop), | 97 render_loop_(render_loop), |
| 95 stop_signal_received_(false), | 98 stop_signal_received_(false), |
| 96 media_has_played_(false), | 99 media_has_played_(false), |
| 97 preload_(AUTO), | 100 preload_(AUTO), |
| (...skipping 23 matching lines...) Expand all Loading... | |
| 121 return new BufferedResourceLoader(url_, | 124 return new BufferedResourceLoader(url_, |
| 122 cors_mode_, | 125 cors_mode_, |
| 123 first_byte_position, | 126 first_byte_position, |
| 124 last_byte_position, | 127 last_byte_position, |
| 125 strategy, | 128 strategy, |
| 126 bitrate_, | 129 bitrate_, |
| 127 playback_rate_, | 130 playback_rate_, |
| 128 media_log_.get()); | 131 media_log_.get()); |
| 129 } | 132 } |
| 130 | 133 |
| 131 void BufferedDataSource::Initialize( | 134 void BufferedDataSource::Initialize(const InitializeCB& init_cb) { |
| 132 const GURL& url, | |
| 133 BufferedResourceLoader::CORSMode cors_mode, | |
| 134 const InitializeCB& init_cb) { | |
| 135 DCHECK(render_loop_->BelongsToCurrentThread()); | 135 DCHECK(render_loop_->BelongsToCurrentThread()); |
| 136 DCHECK(!init_cb.is_null()); | 136 DCHECK(!init_cb.is_null()); |
| 137 DCHECK(!loader_.get()); | 137 DCHECK(!loader_.get()); |
| 138 url_ = url; | |
| 139 cors_mode_ = cors_mode; | |
| 140 | 138 |
| 141 init_cb_ = init_cb; | 139 init_cb_ = init_cb; |
| 142 | 140 |
| 143 if (url_.SchemeIs(url::kHttpScheme) || url_.SchemeIs(url::kHttpsScheme)) { | 141 if (url_.SchemeIsHTTPOrHTTPS()) { |
| 144 // Do an unbounded range request starting at the beginning. If the server | 142 // Do an unbounded range request starting at the beginning. If the server |
| 145 // responds with 200 instead of 206 we'll fall back into a streaming mode. | 143 // responds with 200 instead of 206 we'll fall back into a streaming mode. |
| 146 loader_.reset(CreateResourceLoader(0, kPositionNotSpecified)); | 144 loader_.reset(CreateResourceLoader(0, kPositionNotSpecified)); |
| 147 } else { | 145 } else { |
| 148 // For all other protocols, assume they support range request. We fetch | 146 // For all other protocols, assume they support range request. We fetch |
| 149 // the full range of the resource to obtain the instance size because | 147 // the full range of the resource to obtain the instance size because |
| 150 // we won't be served HTTP headers. | 148 // we won't be served HTTP headers. |
| 151 loader_.reset(CreateResourceLoader(kPositionNotSpecified, | 149 loader_.reset(CreateResourceLoader(kPositionNotSpecified, |
| 152 kPositionNotSpecified)); | 150 kPositionNotSpecified)); |
| 153 assume_fully_buffered_ = true; | 151 assume_fully_buffered_ = true; |
|
scherkus (not reviewing)
2014/05/30 20:45:14
this boolean isn't needed -- it's essentially a du
amogh.bihani
2014/06/02 06:11:01
Done.
| |
| 154 } | 152 } |
| 155 | 153 |
| 156 base::WeakPtr<BufferedDataSource> weak_this = weak_factory_.GetWeakPtr(); | 154 base::WeakPtr<BufferedDataSource> weak_this = weak_factory_.GetWeakPtr(); |
| 157 loader_->Start( | 155 loader_->Start( |
| 158 base::Bind(&BufferedDataSource::StartCallback, weak_this), | 156 base::Bind(&BufferedDataSource::StartCallback, weak_this), |
| 159 base::Bind(&BufferedDataSource::LoadingStateChangedCallback, weak_this), | 157 base::Bind(&BufferedDataSource::LoadingStateChangedCallback, weak_this), |
| 160 base::Bind(&BufferedDataSource::ProgressCallback, weak_this), | 158 base::Bind(&BufferedDataSource::ProgressCallback, weak_this), |
| 161 frame_); | 159 frame_); |
| 162 } | 160 } |
| 163 | 161 |
| (...skipping 367 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 531 return; | 529 return; |
| 532 } | 530 } |
| 533 | 531 |
| 534 // If media is currently playing or the page indicated preload=auto, | 532 // If media is currently playing or the page indicated preload=auto, |
| 535 // use threshold strategy to enable/disable deferring when the buffer | 533 // use threshold strategy to enable/disable deferring when the buffer |
| 536 // is full/depleted. | 534 // is full/depleted. |
| 537 loader_->UpdateDeferStrategy(BufferedResourceLoader::kCapacityDefer); | 535 loader_->UpdateDeferStrategy(BufferedResourceLoader::kCapacityDefer); |
| 538 } | 536 } |
| 539 | 537 |
| 540 } // namespace content | 538 } // namespace content |
| OLD | NEW |