| 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/filters/ffmpeg_audio_decoder.h" | 5 #include "media/filters/ffmpeg_audio_decoder.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "media/base/audio_decoder_config.h" | 8 #include "media/base/audio_decoder_config.h" |
| 9 #include "media/base/data_buffer.h" | 9 #include "media/base/data_buffer.h" |
| 10 #include "media/base/demuxer.h" | 10 #include "media/base/demuxer.h" |
| (...skipping 232 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 243 } | 243 } |
| 244 | 244 |
| 245 void FFmpegAudioDecoder::ReadFromDemuxerStream() { | 245 void FFmpegAudioDecoder::ReadFromDemuxerStream() { |
| 246 DCHECK(!output_buffers_.empty()) | 246 DCHECK(!output_buffers_.empty()) |
| 247 << "Reads should only occur if there are output buffers."; | 247 << "Reads should only occur if there are output buffers."; |
| 248 | 248 |
| 249 pending_reads_++; | 249 pending_reads_++; |
| 250 demuxer_stream_->Read(base::Bind(&FFmpegAudioDecoder::DecodeBuffer, this)); | 250 demuxer_stream_->Read(base::Bind(&FFmpegAudioDecoder::DecodeBuffer, this)); |
| 251 } | 251 } |
| 252 | 252 |
| 253 void FFmpegAudioDecoder::DecodeBuffer(Buffer* buffer) { | 253 void FFmpegAudioDecoder::DecodeBuffer(const scoped_refptr<Buffer>& buffer) { |
| 254 // TODO(scherkus): change DemuxerStream::Read() to use scoped_refptr<> for | |
| 255 // callback. | |
| 256 scoped_refptr<Buffer> ref_buffer(buffer); | |
| 257 message_loop_->PostTask( | 254 message_loop_->PostTask( |
| 258 FROM_HERE, | 255 FROM_HERE, |
| 259 base::Bind(&FFmpegAudioDecoder::DoDecodeBuffer, this, ref_buffer)); | 256 base::Bind(&FFmpegAudioDecoder::DoDecodeBuffer, this, buffer)); |
| 260 } | 257 } |
| 261 | 258 |
| 262 void FFmpegAudioDecoder::UpdateDurationAndTimestamp( | 259 void FFmpegAudioDecoder::UpdateDurationAndTimestamp( |
| 263 const Buffer* input, | 260 const Buffer* input, |
| 264 DataBuffer* output) { | 261 DataBuffer* output) { |
| 265 // Always calculate duration based on the actual number of samples decoded. | 262 // Always calculate duration based on the actual number of samples decoded. |
| 266 base::TimeDelta duration = CalculateDuration(output->GetDataSize()); | 263 base::TimeDelta duration = CalculateDuration(output->GetDataSize()); |
| 267 output->SetDuration(duration); | 264 output->SetDuration(duration); |
| 268 | 265 |
| 269 // Use the incoming timestamp if it's valid. | 266 // Use the incoming timestamp if it's valid. |
| (...skipping 13 matching lines...) Expand all Loading... |
| 283 | 280 |
| 284 base::TimeDelta FFmpegAudioDecoder::CalculateDuration(int size) { | 281 base::TimeDelta FFmpegAudioDecoder::CalculateDuration(int size) { |
| 285 int64 denominator = ChannelLayoutToChannelCount(channel_layout_) * | 282 int64 denominator = ChannelLayoutToChannelCount(channel_layout_) * |
| 286 bits_per_channel_ / 8 * samples_per_second_; | 283 bits_per_channel_ / 8 * samples_per_second_; |
| 287 double microseconds = size / | 284 double microseconds = size / |
| 288 (denominator / static_cast<double>(base::Time::kMicrosecondsPerSecond)); | 285 (denominator / static_cast<double>(base::Time::kMicrosecondsPerSecond)); |
| 289 return base::TimeDelta::FromMicroseconds(static_cast<int64>(microseconds)); | 286 return base::TimeDelta::FromMicroseconds(static_cast<int64>(microseconds)); |
| 290 } | 287 } |
| 291 | 288 |
| 292 } // namespace media | 289 } // namespace media |
| OLD | NEW |