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) { | |
36 if (!params.IsValid() || | 34 if (!params.IsValid() || |
scherkus (not reviewing)
2010/11/09 02:28:31
single line
Sergey Ulanov
2010/11/09 22:29:58
Done.
| |
37 (params.channels > kMaxInputChannels) || | 35 (params.channels > kMaxInputChannels)) |
38 (samples_per_packet > kMaxSamplesPerPacket) || (samples_per_packet < 0)) | |
39 return NULL; | 36 return NULL; |
40 | 37 |
41 if (factory_) { | 38 if (factory_) { |
42 return factory_->Create(event_handler, params, samples_per_packet); | 39 return factory_->Create(event_handler, params); |
43 } | 40 } |
44 | 41 |
45 scoped_refptr<AudioInputController> controller(new AudioInputController( | 42 scoped_refptr<AudioInputController> controller(new AudioInputController( |
46 event_handler)); | 43 event_handler)); |
47 | 44 |
48 // Start the thread and post a task to create the audio input stream. | 45 // Start the thread and post a task to create the audio input stream. |
49 controller->thread_.Start(); | 46 controller->thread_.Start(); |
50 controller->thread_.message_loop()->PostTask( | 47 controller->thread_.message_loop()->PostTask( |
51 FROM_HERE, | 48 FROM_HERE, |
52 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, | 49 NewRunnableMethod(controller.get(), &AudioInputController::DoCreate, |
53 params, samples_per_packet)); | 50 params)); |
54 return controller; | 51 return controller; |
55 } | 52 } |
56 | 53 |
57 void AudioInputController::Record() { | 54 void AudioInputController::Record() { |
58 DCHECK(thread_.IsRunning()); | 55 DCHECK(thread_.IsRunning()); |
59 thread_.message_loop()->PostTask( | 56 thread_.message_loop()->PostTask( |
60 FROM_HERE, | 57 FROM_HERE, |
61 NewRunnableMethod(this, &AudioInputController::DoRecord)); | 58 NewRunnableMethod(this, &AudioInputController::DoRecord)); |
62 } | 59 } |
63 | 60 |
64 void AudioInputController::Close() { | 61 void AudioInputController::Close() { |
65 if (!thread_.IsRunning()) { | 62 if (!thread_.IsRunning()) { |
66 // If the thread is not running make sure we are stopped. | 63 // If the thread is not running make sure we are stopped. |
67 DCHECK_EQ(kClosed, state_); | 64 DCHECK_EQ(kClosed, state_); |
68 return; | 65 return; |
69 } | 66 } |
70 | 67 |
71 // Wait for all tasks to complete on the audio thread. | 68 // Wait for all tasks to complete on the audio thread. |
72 thread_.message_loop()->PostTask( | 69 thread_.message_loop()->PostTask( |
73 FROM_HERE, | 70 FROM_HERE, |
74 NewRunnableMethod(this, &AudioInputController::DoClose)); | 71 NewRunnableMethod(this, &AudioInputController::DoClose)); |
75 thread_.Stop(); | 72 thread_.Stop(); |
76 } | 73 } |
77 | 74 |
78 void AudioInputController::DoCreate(AudioParameters params, | 75 void AudioInputController::DoCreate(AudioParameters params) { |
79 uint32 samples_per_packet) { | 76 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream(params); |
80 stream_ = AudioManager::GetAudioManager()->MakeAudioInputStream( | |
81 params, samples_per_packet); | |
82 | 77 |
83 if (!stream_) { | 78 if (!stream_) { |
84 // TODO(satish): Define error types. | 79 // TODO(satish): Define error types. |
85 handler_->OnError(this, 0); | 80 handler_->OnError(this, 0); |
86 return; | 81 return; |
87 } | 82 } |
88 | 83 |
89 if (stream_ && !stream_->Open()) { | 84 if (stream_ && !stream_->Open()) { |
90 stream_->Close(); | 85 stream_->Close(); |
91 stream_ = NULL; | 86 stream_ = NULL; |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
152 } | 147 } |
153 | 148 |
154 void AudioInputController::OnError(AudioInputStream* stream, int code) { | 149 void AudioInputController::OnError(AudioInputStream* stream, int code) { |
155 // Handle error on the audio controller thread. | 150 // Handle error on the audio controller thread. |
156 thread_.message_loop()->PostTask( | 151 thread_.message_loop()->PostTask( |
157 FROM_HERE, | 152 FROM_HERE, |
158 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); | 153 NewRunnableMethod(this, &AudioInputController::DoReportError, code)); |
159 } | 154 } |
160 | 155 |
161 } // namespace media | 156 } // namespace media |
OLD | NEW |