OLD | NEW |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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_controller.h" | 5 #include "media/audio/audio_input_controller.h" |
6 #include "media/base/limits.h" | 6 #include "media/base/limits.h" |
7 | 7 |
8 namespace { | 8 namespace { |
9 | 9 |
10 const int kMaxInputChannels = 2; | 10 const int kMaxInputChannels = 2; |
11 const int kMaxSamplesPerPacket = media::Limits::kMaxSampleRate; | |
12 | 11 |
13 } // namespace | 12 } // namespace |
14 | 13 |
15 namespace media { | 14 namespace media { |
16 | 15 |
17 // static | 16 // static |
18 AudioInputController::Factory* AudioInputController::factory_ = NULL; | 17 AudioInputController::Factory* AudioInputController::factory_ = NULL; |
19 | 18 |
20 AudioInputController::AudioInputController(EventHandler* handler) | 19 AudioInputController::AudioInputController(EventHandler* handler) |
21 : handler_(handler), | 20 : handler_(handler), |
22 stream_(NULL), | 21 stream_(NULL), |
23 state_(kEmpty), | 22 state_(kEmpty), |
24 thread_("AudioInputControllerThread") { | 23 thread_("AudioInputControllerThread") { |
25 } | 24 } |
26 | 25 |
27 AudioInputController::~AudioInputController() { | 26 AudioInputController::~AudioInputController() { |
28 DCHECK(kClosed == state_ || kCreated == state_ || kEmpty == state_); | 27 DCHECK(kClosed == state_ || kCreated == state_ || kEmpty == state_); |
29 } | 28 } |
30 | 29 |
31 // static | 30 // static |
32 scoped_refptr<AudioInputController> AudioInputController::Create( | 31 scoped_refptr<AudioInputController> AudioInputController::Create( |
33 EventHandler* event_handler, | 32 EventHandler* event_handler, |
34 AudioParameters params, | 33 AudioParameters params) { |
35 int samples_per_packet) { | 34 if (!params.IsValid() || (params.channels > kMaxInputChannels)) |
36 if (!params.IsValid() || | |
37 (params.channels > kMaxInputChannels) || | |
38 (samples_per_packet > kMaxSamplesPerPacket) || (samples_per_packet < 0)) | |
39 return NULL; | 35 return NULL; |
40 | 36 |
41 if (factory_) { | 37 if (factory_) { |
42 return factory_->Create(event_handler, params, samples_per_packet); | 38 return factory_->Create(event_handler, params); |
43 } | 39 } |
44 | 40 |
45 scoped_refptr<AudioInputController> controller(new AudioInputController( | 41 scoped_refptr<AudioInputController> controller(new AudioInputController( |
46 event_handler)); | 42 event_handler)); |
47 | 43 |
48 // Start the thread and post a task to create the audio input stream. | 44 // Start the thread and post a task to create the audio input stream. |
49 controller->thread_.Start(); | 45 controller->thread_.Start(); |
50 controller->thread_.message_loop()->PostTask( | 46 controller->thread_.message_loop()->PostTask( |
51 FROM_HERE, | 47 FROM_HERE, |
52 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, | 48 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, |
53 params, samples_per_packet)); | 49 params)); |
54 return controller; | 50 return controller; |
55 } | 51 } |
56 | 52 |
57 void AudioInputController::Record() { | 53 void AudioInputController::Record() { |
58 DCHECK(thread_.IsRunning()); | 54 DCHECK(thread_.IsRunning()); |
59 thread_.message_loop()->PostTask( | 55 thread_.message_loop()->PostTask( |
60 FROM_HERE, | 56 FROM_HERE, |
61 NewRunnableMethod(this, &AudioInputController::DoRecord)); | 57 NewRunnableMethod(this, &AudioInputController::DoRecord)); |
62 } | 58 } |
63 | 59 |
64 void AudioInputController::Close() { | 60 void AudioInputController::Close() { |
65 if (!thread_.IsRunning()) { | 61 if (!thread_.IsRunning()) { |
66 // If the thread is not running make sure we are stopped. | 62 // If the thread is not running make sure we are stopped. |
67 DCHECK_EQ(kClosed, state_); | 63 DCHECK_EQ(kClosed, state_); |
68 return; | 64 return; |
69 } | 65 } |
70 | 66 |
71 // Wait for all tasks to complete on the audio thread. | 67 // Wait for all tasks to complete on the audio thread. |
72 thread_.message_loop()->PostTask( | 68 thread_.message_loop()->PostTask( |
73 FROM_HERE, | 69 FROM_HERE, |
74 NewRunnableMethod(this, &AudioInputController::DoClose)); | 70 NewRunnableMethod(this, &AudioInputController::DoClose)); |
75 thread_.Stop(); | 71 thread_.Stop(); |
76 } | 72 } |
77 | 73 |
78 void AudioInputController::DoCreate(AudioParameters params, | 74 void AudioInputController::DoCreate(AudioParameters params) { |
79 uint32 samples_per_packet) { | 75 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream(params); |
80 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream( | |
81 params, samples_per_packet); | |
82 | 76 |
83 if (!stream_) { | 77 if (!stream_) { |
84 // TODO(satish): Define error types. | 78 // TODO(satish): Define error types. |
85 handler_->OnError(this, 0); | 79 handler_->OnError(this, 0); |
86 return; | 80 return; |
87 } | 81 } |
88 | 82 |
89 if (stream_ && !stream_->Open()) { | 83 if (stream_ && !stream_->Open()) { |
90 stream_->Close(); | 84 stream_->Close(); |
91 stream_ = NULL; | 85 stream_ = NULL; |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
152 } | 146 } |
153 | 147 |
154 void AudioInputController::OnError(AudioInputStream* stream, int code) { | 148 void AudioInputController::OnError(AudioInputStream* stream, int code) { |
155 // Handle error on the audio controller thread. | 149 // Handle error on the audio controller thread. |
156 thread_.message_loop()->PostTask( | 150 thread_.message_loop()->PostTask( |
157 FROM_HERE, | 151 FROM_HERE, |
158 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); | 152 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); |
159 } | 153 } |
160 | 154 |
161 } // namespace media | 155 } // namespace media |
OLD | NEW |