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/audio_input_device.h" | 5 #include "media/audio/audio_input_device.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/memory/scoped_vector.h" | 8 #include "base/memory/scoped_vector.h" |
9 #include "base/strings/stringprintf.h" | 9 #include "base/strings/stringprintf.h" |
10 #include "base/threading/thread_restrictions.h" | 10 #include "base/threading/thread_restrictions.h" |
(...skipping 20 matching lines...) Expand all Loading... |
31 int memory_length, | 31 int memory_length, |
32 int total_segments, | 32 int total_segments, |
33 CaptureCallback* capture_callback); | 33 CaptureCallback* capture_callback); |
34 ~AudioThreadCallback() override; | 34 ~AudioThreadCallback() override; |
35 | 35 |
36 void MapSharedMemory() override; | 36 void MapSharedMemory() override; |
37 | 37 |
38 // Called whenever we receive notifications about pending data. | 38 // Called whenever we receive notifications about pending data. |
39 void Process(uint32 pending_data) override; | 39 void Process(uint32 pending_data) override; |
40 | 40 |
| 41 void FramesSkipped(uint32_t frames_skipped) override; |
| 42 |
41 private: | 43 private: |
42 int current_segment_id_; | 44 int current_segment_id_; |
43 uint32 last_buffer_id_; | 45 uint32 last_buffer_id_; |
44 ScopedVector<media::AudioBus> audio_buses_; | 46 ScopedVector<media::AudioBus> audio_buses_; |
45 CaptureCallback* capture_callback_; | 47 CaptureCallback* capture_callback_; |
46 | 48 |
47 DISALLOW_COPY_AND_ASSIGN(AudioThreadCallback); | 49 DISALLOW_COPY_AND_ASSIGN(AudioThreadCallback); |
48 }; | 50 }; |
49 | 51 |
50 AudioInputDevice::AudioInputDevice( | 52 AudioInputDevice::AudioInputDevice( |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
134 base::AutoLock auto_lock(audio_thread_lock_); | 136 base::AutoLock auto_lock(audio_thread_lock_); |
135 // TODO(miu): See TODO in OnStreamCreated method for AudioOutputDevice. | 137 // TODO(miu): See TODO in OnStreamCreated method for AudioOutputDevice. |
136 // Interface changes need to be made; likely, after AudioInputDevice is merged | 138 // Interface changes need to be made; likely, after AudioInputDevice is merged |
137 // into AudioOutputDevice (http://crbug.com/179597). | 139 // into AudioOutputDevice (http://crbug.com/179597). |
138 if (stopping_hack_) | 140 if (stopping_hack_) |
139 return; | 141 return; |
140 | 142 |
141 DCHECK(audio_thread_.IsStopped()); | 143 DCHECK(audio_thread_.IsStopped()); |
142 audio_callback_.reset(new AudioInputDevice::AudioThreadCallback( | 144 audio_callback_.reset(new AudioInputDevice::AudioThreadCallback( |
143 audio_parameters_, handle, length, total_segments, callback_)); | 145 audio_parameters_, handle, length, total_segments, callback_)); |
144 audio_thread_.Start( | 146 audio_thread_.Start(audio_callback_.get(), socket_handle, "AudioInputDevice", |
145 audio_callback_.get(), socket_handle, "AudioInputDevice", true); | 147 true, true); |
146 | 148 |
147 state_ = RECORDING; | 149 state_ = RECORDING; |
148 ipc_->RecordStream(); | 150 ipc_->RecordStream(); |
149 } | 151 } |
150 | 152 |
151 void AudioInputDevice::OnVolume(double volume) { | 153 void AudioInputDevice::OnVolume(double volume) { |
152 NOTIMPLEMENTED(); | 154 NOTIMPLEMENTED(); |
153 } | 155 } |
154 | 156 |
155 void AudioInputDevice::OnStateChanged( | 157 void AudioInputDevice::OnStateChanged( |
(...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
335 capture_callback_->Capture( | 337 capture_callback_->Capture( |
336 audio_bus, | 338 audio_bus, |
337 buffer->params.hardware_delay_bytes / bytes_per_ms_, // Delay in ms | 339 buffer->params.hardware_delay_bytes / bytes_per_ms_, // Delay in ms |
338 buffer->params.volume, | 340 buffer->params.volume, |
339 buffer->params.key_pressed); | 341 buffer->params.key_pressed); |
340 | 342 |
341 if (++current_segment_id_ >= total_segments_) | 343 if (++current_segment_id_ >= total_segments_) |
342 current_segment_id_ = 0; | 344 current_segment_id_ = 0; |
343 } | 345 } |
344 | 346 |
| 347 void AudioInputDevice::AudioThreadCallback::FramesSkipped( |
| 348 uint32_t frames_skipped) { |
| 349 // Should not be called for input. |
| 350 NOTREACHED(); |
| 351 } |
| 352 |
345 } // namespace media | 353 } // namespace media |
OLD | NEW |