| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "media/base/download_rate_monitor.h" | 5 #include "media/base/download_rate_monitor.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/time.h" | 8 #include "base/time.h" |
| 9 | 9 |
| 10 namespace media { | 10 namespace media { |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 66 void DownloadRateMonitor::Sample::RestartAtEndBufferingPoint() { | 66 void DownloadRateMonitor::Sample::RestartAtEndBufferingPoint() { |
| 67 start_ = end_; | 67 start_ = end_; |
| 68 end_ = BufferingPoint(); | 68 end_ = BufferingPoint(); |
| 69 } | 69 } |
| 70 | 70 |
| 71 DownloadRateMonitor::DownloadRateMonitor() { | 71 DownloadRateMonitor::DownloadRateMonitor() { |
| 72 Reset(); | 72 Reset(); |
| 73 } | 73 } |
| 74 | 74 |
| 75 void DownloadRateMonitor::Start( | 75 void DownloadRateMonitor::Start( |
| 76 const base::Closure& canplaythrough_cb, int media_bitrate) { | 76 const base::Closure& canplaythrough_cb, int media_bitrate, |
| 77 bool streaming, bool local_source) { |
| 77 canplaythrough_cb_ = canplaythrough_cb; | 78 canplaythrough_cb_ = canplaythrough_cb; |
| 79 streaming_ = streaming; |
| 80 local_source_ = local_source; |
| 78 stopped_ = false; | 81 stopped_ = false; |
| 79 bitrate_ = media_bitrate; | 82 bitrate_ = media_bitrate; |
| 80 current_sample_.Reset(); | 83 current_sample_.Reset(); |
| 81 buffered_bytes_ = 0; | 84 buffered_bytes_ = 0; |
| 82 | 85 |
| 83 NotifyCanPlayThroughIfNeeded(); | 86 NotifyCanPlayThroughIfNeeded(); |
| 84 } | 87 } |
| 85 | 88 |
| 86 void DownloadRateMonitor::SetBufferedBytes( | 89 void DownloadRateMonitor::SetBufferedBytes( |
| 87 int64 buffered_bytes, const base::Time& timestamp) { | 90 int64 buffered_bytes, const base::Time& timestamp) { |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 132 } | 135 } |
| 133 | 136 |
| 134 void DownloadRateMonitor::Reset() { | 137 void DownloadRateMonitor::Reset() { |
| 135 canplaythrough_cb_.Reset(); | 138 canplaythrough_cb_.Reset(); |
| 136 has_notified_can_play_through_ = false; | 139 has_notified_can_play_through_ = false; |
| 137 current_sample_.Reset(); | 140 current_sample_.Reset(); |
| 138 sample_window_.clear(); | 141 sample_window_.clear(); |
| 139 is_downloading_data_ = false; | 142 is_downloading_data_ = false; |
| 140 total_bytes_ = -1; | 143 total_bytes_ = -1; |
| 141 buffered_bytes_ = 0; | 144 buffered_bytes_ = 0; |
| 142 loaded_ = false; | 145 local_source_ = false; |
| 143 bitrate_ = 0; | 146 bitrate_ = 0; |
| 144 stopped_ = true; | 147 stopped_ = true; |
| 148 streaming_ = false; |
| 145 } | 149 } |
| 146 | 150 |
| 147 DownloadRateMonitor::~DownloadRateMonitor() { } | 151 DownloadRateMonitor::~DownloadRateMonitor() { } |
| 148 | 152 |
| 149 int64 DownloadRateMonitor::bytes_downloaded_in_window() const { | 153 int64 DownloadRateMonitor::bytes_downloaded_in_window() const { |
| 150 // There are max |kNumberOfSamples| so we might as well recompute each time. | 154 // There are max |kNumberOfSamples| so we might as well recompute each time. |
| 151 int64 total = 0; | 155 int64 total = 0; |
| 152 for (size_t i = 0; i < sample_window_.size(); ++i) | 156 for (size_t i = 0; i < sample_window_.size(); ++i) |
| 153 total += sample_window_[i].bytes_downloaded(); | 157 total += sample_window_[i].bytes_downloaded(); |
| 154 return total; | 158 return total; |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 191 } | 195 } |
| 192 | 196 |
| 193 bool DownloadRateMonitor::ShouldNotifyCanPlayThrough() { | 197 bool DownloadRateMonitor::ShouldNotifyCanPlayThrough() { |
| 194 if (stopped_) | 198 if (stopped_) |
| 195 return false; | 199 return false; |
| 196 | 200 |
| 197 // Only notify CanPlayThrough once for now. | 201 // Only notify CanPlayThrough once for now. |
| 198 if (has_notified_can_play_through_) | 202 if (has_notified_can_play_through_) |
| 199 return false; | 203 return false; |
| 200 | 204 |
| 201 // If the media is from a local file (|loaded_|) or if all bytes are | 205 // Fire CanPlayThrough immediately if the source is local or streaming. |
| 202 // buffered, fire CanPlayThrough. | 206 // |
| 203 if (loaded_ || buffered_bytes_ == total_bytes_) | 207 // NOTE: It is a requirement for CanPlayThrough to fire immediately if the |
| 208 // source is local, but the choice to optimistically fire the event for any |
| 209 // streaming media element is a design decision that may need to be tweaked. |
| 210 if (local_source_ || streaming_) |
| 204 return true; | 211 return true; |
| 205 | 212 |
| 206 // Cannot approximate when the media can play through if bitrate is unknown. | 213 // If all bytes are buffered, fire CanPlayThrough. |
| 214 if (buffered_bytes_ == total_bytes_) |
| 215 return true; |
| 216 |
| 217 // If bitrate is unknown, optimistically fire CanPlayThrough immediately. |
| 218 // This is so a video with an unknown bitrate with the "autoplay" attribute |
| 219 // will not wait until the entire file is downloaded before playback begins. |
| 207 if (bitrate_ <= 0) | 220 if (bitrate_ <= 0) |
| 208 return false; | 221 return true; |
| 209 | 222 |
| 210 float bytes_needed_per_second = bitrate_ / 8; | 223 float bytes_needed_per_second = bitrate_ / 8; |
| 211 float download_rate = ApproximateDownloadByteRate(); | 224 float download_rate = ApproximateDownloadByteRate(); |
| 212 | 225 |
| 213 // If we are downloading at or faster than the media's bitrate, then we can | 226 // If we are downloading at or faster than the media's bitrate, then we can |
| 214 // play through to the end of the media without stopping to buffer. | 227 // play through to the end of the media without stopping to buffer. |
| 215 if (download_rate > 0) | 228 if (download_rate > 0) |
| 216 return download_rate >= bytes_needed_per_second; | 229 return download_rate >= bytes_needed_per_second; |
| 217 | 230 |
| 218 // If download rate is unknown, it may be because the media is being | 231 // If download rate is unknown, it may be because the media is being |
| (...skipping 21 matching lines...) Expand all Loading... |
| 240 } | 253 } |
| 241 | 254 |
| 242 void DownloadRateMonitor::NotifyCanPlayThroughIfNeeded() { | 255 void DownloadRateMonitor::NotifyCanPlayThroughIfNeeded() { |
| 243 if (ShouldNotifyCanPlayThrough() && !canplaythrough_cb_.is_null()) { | 256 if (ShouldNotifyCanPlayThrough() && !canplaythrough_cb_.is_null()) { |
| 244 canplaythrough_cb_.Run(); | 257 canplaythrough_cb_.Run(); |
| 245 has_notified_can_play_through_ = true; | 258 has_notified_can_play_through_ = true; |
| 246 } | 259 } |
| 247 } | 260 } |
| 248 | 261 |
| 249 } // namespace media | 262 } // namespace media |
| OLD | NEW |