OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "webkit/media/buffered_data_source.h" | 5 #include "webkit/media/buffered_data_source.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
9 #include "media/base/media_log.h" | 9 #include "media/base/media_log.h" |
10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
(...skipping 24 matching lines...) Expand all Loading... |
35 read_position_(0), | 35 read_position_(0), |
36 read_size_(0), | 36 read_size_(0), |
37 read_buffer_(NULL), | 37 read_buffer_(NULL), |
38 intermediate_read_buffer_(new uint8[kInitialReadBufferSize]), | 38 intermediate_read_buffer_(new uint8[kInitialReadBufferSize]), |
39 intermediate_read_buffer_size_(kInitialReadBufferSize), | 39 intermediate_read_buffer_size_(kInitialReadBufferSize), |
40 render_loop_(render_loop), | 40 render_loop_(render_loop), |
41 stop_signal_received_(false), | 41 stop_signal_received_(false), |
42 stopped_on_render_loop_(false), | 42 stopped_on_render_loop_(false), |
43 media_is_paused_(true), | 43 media_is_paused_(true), |
44 media_has_played_(false), | 44 media_has_played_(false), |
45 preload_(media::AUTO), | 45 preload_(AUTO), |
46 cache_miss_retries_left_(kNumCacheMissRetries), | 46 cache_miss_retries_left_(kNumCacheMissRetries), |
47 bitrate_(0), | 47 bitrate_(0), |
48 playback_rate_(0.0), | 48 playback_rate_(0.0), |
49 media_log_(media_log) { | 49 media_log_(media_log) { |
50 } | 50 } |
51 | 51 |
52 BufferedDataSource::~BufferedDataSource() {} | 52 BufferedDataSource::~BufferedDataSource() {} |
53 | 53 |
54 // A factory method to create BufferedResourceLoader using the read parameters. | 54 // A factory method to create BufferedResourceLoader using the read parameters. |
55 // This method can be overrided to inject mock BufferedResourceLoader object | 55 // This method can be overrided to inject mock BufferedResourceLoader object |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 // the full range of the resource to obtain the instance size because | 101 // the full range of the resource to obtain the instance size because |
102 // we won't be served HTTP headers. | 102 // we won't be served HTTP headers. |
103 loader_.reset(CreateResourceLoader(kPositionNotSpecified, | 103 loader_.reset(CreateResourceLoader(kPositionNotSpecified, |
104 kPositionNotSpecified)); | 104 kPositionNotSpecified)); |
105 loader_->Start( | 105 loader_->Start( |
106 base::Bind(&BufferedDataSource::NonHttpInitialStartCallback, this), | 106 base::Bind(&BufferedDataSource::NonHttpInitialStartCallback, this), |
107 base::Bind(&BufferedDataSource::NetworkEventCallback, this), | 107 base::Bind(&BufferedDataSource::NetworkEventCallback, this), |
108 frame_); | 108 frame_); |
109 } | 109 } |
110 | 110 |
| 111 void BufferedDataSource::SetPreload(Preload preload) { |
| 112 DCHECK(MessageLoop::current() == render_loop_); |
| 113 preload_ = preload; |
| 114 } |
| 115 |
111 bool BufferedDataSource::HasSingleOrigin() { | 116 bool BufferedDataSource::HasSingleOrigin() { |
112 DCHECK(MessageLoop::current() == render_loop_); | 117 DCHECK(MessageLoop::current() == render_loop_); |
113 DCHECK(initialize_cb_.is_null() && loader_.get()) | 118 DCHECK(initialize_cb_.is_null() && loader_.get()) |
114 << "Initialize() must complete before calling HasSingleOrigin()"; | 119 << "Initialize() must complete before calling HasSingleOrigin()"; |
115 return loader_->HasSingleOrigin(); | 120 return loader_->HasSingleOrigin(); |
116 } | 121 } |
117 | 122 |
118 void BufferedDataSource::Abort() { | 123 void BufferedDataSource::Abort() { |
119 DCHECK(MessageLoop::current() == render_loop_); | 124 DCHECK(MessageLoop::current() == render_loop_); |
120 | 125 |
(...skipping 13 matching lines...) Expand all Loading... |
134 | 139 |
135 render_loop_->PostTask(FROM_HERE, | 140 render_loop_->PostTask(FROM_HERE, |
136 base::Bind(&BufferedDataSource::CleanupTask, this)); | 141 base::Bind(&BufferedDataSource::CleanupTask, this)); |
137 } | 142 } |
138 | 143 |
139 void BufferedDataSource::SetPlaybackRate(float playback_rate) { | 144 void BufferedDataSource::SetPlaybackRate(float playback_rate) { |
140 render_loop_->PostTask(FROM_HERE, base::Bind( | 145 render_loop_->PostTask(FROM_HERE, base::Bind( |
141 &BufferedDataSource::SetPlaybackRateTask, this, playback_rate)); | 146 &BufferedDataSource::SetPlaybackRateTask, this, playback_rate)); |
142 } | 147 } |
143 | 148 |
144 void BufferedDataSource::SetPreload(media::Preload preload) { | |
145 render_loop_->PostTask(FROM_HERE, base::Bind( | |
146 &BufferedDataSource::SetPreloadTask, this, preload)); | |
147 } | |
148 | |
149 void BufferedDataSource::SetBitrate(int bitrate) { | 149 void BufferedDataSource::SetBitrate(int bitrate) { |
150 render_loop_->PostTask(FROM_HERE, base::Bind( | 150 render_loop_->PostTask(FROM_HERE, base::Bind( |
151 &BufferedDataSource::SetBitrateTask, this, bitrate)); | 151 &BufferedDataSource::SetBitrateTask, this, bitrate)); |
152 } | 152 } |
153 | 153 |
154 ///////////////////////////////////////////////////////////////////////////// | 154 ///////////////////////////////////////////////////////////////////////////// |
155 // media::DataSource implementation. | 155 // media::DataSource implementation. |
156 void BufferedDataSource::Read( | 156 void BufferedDataSource::Read( |
157 int64 position, int size, uint8* data, | 157 int64 position, int size, uint8* data, |
158 const media::DataSource::ReadCB& read_cb) { | 158 const media::DataSource::ReadCB& read_cb) { |
(...skipping 111 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
270 bool previously_paused = media_is_paused_; | 270 bool previously_paused = media_is_paused_; |
271 media_is_paused_ = (playback_rate == 0.0); | 271 media_is_paused_ = (playback_rate == 0.0); |
272 | 272 |
273 if (!media_has_played_ && previously_paused && !media_is_paused_) | 273 if (!media_has_played_ && previously_paused && !media_is_paused_) |
274 media_has_played_ = true; | 274 media_has_played_ = true; |
275 | 275 |
276 BufferedResourceLoader::DeferStrategy strategy = ChooseDeferStrategy(); | 276 BufferedResourceLoader::DeferStrategy strategy = ChooseDeferStrategy(); |
277 loader_->UpdateDeferStrategy(strategy); | 277 loader_->UpdateDeferStrategy(strategy); |
278 } | 278 } |
279 | 279 |
280 void BufferedDataSource::SetPreloadTask(media::Preload preload) { | |
281 DCHECK(MessageLoop::current() == render_loop_); | |
282 preload_ = preload; | |
283 } | |
284 | |
285 void BufferedDataSource::SetBitrateTask(int bitrate) { | 280 void BufferedDataSource::SetBitrateTask(int bitrate) { |
286 DCHECK(MessageLoop::current() == render_loop_); | 281 DCHECK(MessageLoop::current() == render_loop_); |
287 DCHECK(loader_.get()); | 282 DCHECK(loader_.get()); |
288 | 283 |
289 bitrate_ = bitrate; | 284 bitrate_ = bitrate; |
290 loader_->SetBitrate(bitrate); | 285 loader_->SetBitrate(bitrate); |
291 } | 286 } |
292 | 287 |
293 BufferedResourceLoader::DeferStrategy | 288 BufferedResourceLoader::DeferStrategy |
294 BufferedDataSource::ChooseDeferStrategy() { | 289 BufferedDataSource::ChooseDeferStrategy() { |
295 DCHECK(MessageLoop::current() == render_loop_); | 290 DCHECK(MessageLoop::current() == render_loop_); |
296 // If the page indicated preload=metadata, then load exactly what is needed | 291 // If the page indicated preload=metadata, then load exactly what is needed |
297 // needed for starting playback. | 292 // needed for starting playback. |
298 if (!media_has_played_ && preload_ == media::METADATA) | 293 if (!media_has_played_ && preload_ == METADATA) |
299 return BufferedResourceLoader::kReadThenDefer; | 294 return BufferedResourceLoader::kReadThenDefer; |
300 | 295 |
301 // If the playback has started (at which point the preload value is ignored) | 296 // If the playback has started (at which point the preload value is ignored) |
302 // and we're paused, then try to load as much as possible. | 297 // and we're paused, then try to load as much as possible. |
303 if (media_has_played_ && media_is_paused_) | 298 if (media_has_played_ && media_is_paused_) |
304 return BufferedResourceLoader::kNeverDefer; | 299 return BufferedResourceLoader::kNeverDefer; |
305 | 300 |
306 // If media is currently playing or the page indicated preload=auto, | 301 // If media is currently playing or the page indicated preload=auto, |
307 // use threshold strategy to enable/disable deferring when the buffer | 302 // use threshold strategy to enable/disable deferring when the buffer |
308 // is full/depleted. | 303 // is full/depleted. |
(...skipping 280 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
589 | 584 |
590 if (!host()) | 585 if (!host()) |
591 return; | 586 return; |
592 | 587 |
593 if (total_bytes_ != kPositionNotSpecified) | 588 if (total_bytes_ != kPositionNotSpecified) |
594 host()->SetTotalBytes(total_bytes_); | 589 host()->SetTotalBytes(total_bytes_); |
595 host()->SetBufferedBytes(buffered_bytes_); | 590 host()->SetBufferedBytes(buffered_bytes_); |
596 } | 591 } |
597 | 592 |
598 } // namespace webkit_media | 593 } // namespace webkit_media |
OLD | NEW |