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 "media/audio/null_audio_sink.h" | 5 #include "media/audio/null_audio_sink.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/stringprintf.h" | 8 #include "base/stringprintf.h" |
9 #include "base/sys_byteorder.h" | 9 #include "base/sys_byteorder.h" |
10 #include "base/threading/platform_thread.h" | 10 #include "base/threading/platform_thread.h" |
11 | 11 |
12 namespace media { | 12 namespace media { |
13 | 13 |
14 NullAudioSink::NullAudioSink() | 14 NullAudioSink::NullAudioSink() |
15 : initialized_(false), | 15 : initialized_(false), |
16 playback_rate_(0.0), | |
17 playing_(false), | 16 playing_(false), |
18 callback_(NULL), | 17 callback_(NULL), |
19 thread_("NullAudioThread"), | 18 thread_("NullAudioThread"), |
20 hash_audio_for_testing_(false) { | 19 hash_audio_for_testing_(false) { |
21 } | 20 } |
22 | 21 |
23 void NullAudioSink::Initialize(const AudioParameters& params, | 22 void NullAudioSink::Initialize(const AudioParameters& params, |
24 RenderCallback* callback) { | 23 RenderCallback* callback) { |
25 DCHECK(!initialized_); | 24 DCHECK(!initialized_); |
26 params_ = params; | 25 params_ = params; |
(...skipping 28 matching lines...) Expand all Loading... |
55 } | 54 } |
56 | 55 |
57 void NullAudioSink::Play() { | 56 void NullAudioSink::Play() { |
58 SetPlaying(true); | 57 SetPlaying(true); |
59 } | 58 } |
60 | 59 |
61 void NullAudioSink::Pause(bool /* flush */) { | 60 void NullAudioSink::Pause(bool /* flush */) { |
62 SetPlaying(false); | 61 SetPlaying(false); |
63 } | 62 } |
64 | 63 |
65 void NullAudioSink::SetPlaybackRate(float rate) { | |
66 base::AutoLock auto_lock(lock_); | |
67 playback_rate_ = rate; | |
68 } | |
69 | |
70 bool NullAudioSink::SetVolume(double volume) { | 64 bool NullAudioSink::SetVolume(double volume) { |
71 // Audio is always muted. | 65 // Audio is always muted. |
72 return volume == 0.0; | 66 return volume == 0.0; |
73 } | 67 } |
74 | 68 |
75 void NullAudioSink::SetPlaying(bool is_playing) { | 69 void NullAudioSink::SetPlaying(bool is_playing) { |
76 base::AutoLock auto_lock(lock_); | 70 base::AutoLock auto_lock(lock_); |
77 playing_ = is_playing; | 71 playing_ = is_playing; |
78 } | 72 } |
79 | 73 |
80 NullAudioSink::~NullAudioSink() { | 74 NullAudioSink::~NullAudioSink() { |
81 DCHECK(!thread_.IsRunning()); | 75 DCHECK(!thread_.IsRunning()); |
82 for (size_t i = 0; i < audio_data_.size(); ++i) | 76 for (size_t i = 0; i < audio_data_.size(); ++i) |
83 delete [] audio_data_[i]; | 77 delete [] audio_data_[i]; |
84 } | 78 } |
85 | 79 |
86 void NullAudioSink::FillBufferTask() { | 80 void NullAudioSink::FillBufferTask() { |
87 base::AutoLock auto_lock(lock_); | 81 base::AutoLock auto_lock(lock_); |
88 | 82 |
89 base::TimeDelta delay; | 83 base::TimeDelta delay; |
90 // Only consume buffers when actually playing. | 84 // Only consume buffers when actually playing. |
91 if (playing_) { | 85 if (playing_) { |
92 DCHECK_GT(playback_rate_, 0.0f); | |
93 int requested_frames = params_.frames_per_buffer(); | 86 int requested_frames = params_.frames_per_buffer(); |
94 int frames_received = callback_->Render(audio_data_, requested_frames, 0); | 87 int frames_received = callback_->Render(audio_data_, requested_frames, 0); |
95 int frames_per_millisecond = | 88 int frames_per_millisecond = |
96 params_.sample_rate() / base::Time::kMillisecondsPerSecond; | 89 params_.sample_rate() / base::Time::kMillisecondsPerSecond; |
97 | 90 |
98 if (hash_audio_for_testing_ && frames_received > 0) { | 91 if (hash_audio_for_testing_ && frames_received > 0) { |
99 DCHECK_EQ(sizeof(float), sizeof(uint32)); | 92 DCHECK_EQ(sizeof(float), sizeof(uint32)); |
100 int channels = audio_data_.size(); | 93 int channels = audio_data_.size(); |
101 for (int channel_idx = 0; channel_idx < channels; ++channel_idx) { | 94 for (int channel_idx = 0; channel_idx < channels; ++channel_idx) { |
102 float* channel = audio_data_[channel_idx]; | 95 float* channel = audio_data_[channel_idx]; |
103 for (int frame_idx = 0; frame_idx < frames_received; frame_idx++) { | 96 for (int frame_idx = 0; frame_idx < frames_received; frame_idx++) { |
104 // Convert float to uint32 w/o conversion loss. | 97 // Convert float to uint32 w/o conversion loss. |
105 uint32 frame = base::ByteSwapToLE32( | 98 uint32 frame = base::ByteSwapToLE32( |
106 bit_cast<uint32>(channel[frame_idx])); | 99 bit_cast<uint32>(channel[frame_idx])); |
107 base::MD5Update( | 100 base::MD5Update( |
108 &md5_channel_contexts_[channel_idx], base::StringPiece( | 101 &md5_channel_contexts_[channel_idx], base::StringPiece( |
109 reinterpret_cast<char*>(&frame), sizeof(frame))); | 102 reinterpret_cast<char*>(&frame), sizeof(frame))); |
110 } | 103 } |
111 } | 104 } |
112 } | 105 } |
113 | 106 |
114 // Calculate our sleep duration, taking playback rate into consideration. | 107 // Calculate our sleep duration. |
115 delay = base::TimeDelta::FromMilliseconds( | 108 delay = base::TimeDelta::FromMilliseconds( |
116 frames_received / (frames_per_millisecond * playback_rate_)); | 109 frames_received / frames_per_millisecond); |
117 } else { | 110 } else { |
118 // If paused, sleep for 10 milliseconds before polling again. | 111 // If paused, sleep for 10 milliseconds before polling again. |
119 delay = base::TimeDelta::FromMilliseconds(10); | 112 delay = base::TimeDelta::FromMilliseconds(10); |
120 } | 113 } |
121 | 114 |
122 // Sleep for at least one millisecond so we don't spin the CPU. | 115 // Sleep for at least one millisecond so we don't spin the CPU. |
123 MessageLoop::current()->PostDelayedTask( | 116 MessageLoop::current()->PostDelayedTask( |
124 FROM_HERE, | 117 FROM_HERE, |
125 base::Bind(&NullAudioSink::FillBufferTask, this), | 118 base::Bind(&NullAudioSink::FillBufferTask, this), |
126 std::max(delay, base::TimeDelta::FromMilliseconds(1))); | 119 std::max(delay, base::TimeDelta::FromMilliseconds(1))); |
(...skipping 19 matching lines...) Expand all Loading... |
146 base::MD5Final(&digest, &md5_channel_contexts_[i]); | 139 base::MD5Final(&digest, &md5_channel_contexts_[i]); |
147 base::MD5Update(&md5_channel_contexts_[0], base::StringPiece( | 140 base::MD5Update(&md5_channel_contexts_[0], base::StringPiece( |
148 reinterpret_cast<char*>(&digest), sizeof(base::MD5Digest))); | 141 reinterpret_cast<char*>(&digest), sizeof(base::MD5Digest))); |
149 } | 142 } |
150 | 143 |
151 base::MD5Final(&digest, &md5_channel_contexts_[0]); | 144 base::MD5Final(&digest, &md5_channel_contexts_[0]); |
152 return base::MD5DigestToBase16(digest); | 145 return base::MD5DigestToBase16(digest); |
153 } | 146 } |
154 | 147 |
155 } // namespace media | 148 } // namespace media |
OLD | NEW |