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 "content/test/webrtc_audio_device_test.h" | 5 #include "content/test/webrtc_audio_device_test.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/file_util.h" | 10 #include "base/file_util.h" |
(...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
173 // whole thing to be torn down before we finally uninitialize the io thread. | 173 // whole thing to be torn down before we finally uninitialize the io thread. |
174 WaitForAudioManagerCompletion(); | 174 WaitForAudioManagerCompletion(); |
175 | 175 |
176 ChildProcess::current()->io_message_loop()->PostTask(FROM_HERE, | 176 ChildProcess::current()->io_message_loop()->PostTask(FROM_HERE, |
177 base::Bind(&WebRTCAudioDeviceTest::UninitializeIOThread, | 177 base::Bind(&WebRTCAudioDeviceTest::UninitializeIOThread, |
178 base::Unretained((this)))); | 178 base::Unretained((this)))); |
179 WaitForIOThreadCompletion(); | 179 WaitForIOThreadCompletion(); |
180 mock_process_.reset(); | 180 mock_process_.reset(); |
181 media_stream_manager_.reset(); | 181 media_stream_manager_.reset(); |
182 mirroring_manager_.reset(); | 182 mirroring_manager_.reset(); |
| 183 key_press_monitor_.reset(); |
183 RendererWebKitPlatformSupportImpl::SetSandboxEnabledForTesting( | 184 RendererWebKitPlatformSupportImpl::SetSandboxEnabledForTesting( |
184 sandbox_was_enabled_); | 185 sandbox_was_enabled_); |
185 } | 186 } |
186 | 187 |
187 bool WebRTCAudioDeviceTest::Send(IPC::Message* message) { | 188 bool WebRTCAudioDeviceTest::Send(IPC::Message* message) { |
188 return channel_->Send(message); | 189 return channel_->Send(message); |
189 } | 190 } |
190 | 191 |
191 void WebRTCAudioDeviceTest::SetAudioHardwareConfig( | 192 void WebRTCAudioDeviceTest::SetAudioHardwareConfig( |
192 media::AudioHardwareConfig* hardware_config) { | 193 media::AudioHardwareConfig* hardware_config) { |
(...skipping 15 matching lines...) Expand all Loading... |
208 test_request_context_.reset(new net::TestURLRequestContext()); | 209 test_request_context_.reset(new net::TestURLRequestContext()); |
209 MockRTCResourceContext* resource_context = | 210 MockRTCResourceContext* resource_context = |
210 static_cast<MockRTCResourceContext*>(resource_context_.get()); | 211 static_cast<MockRTCResourceContext*>(resource_context_.get()); |
211 resource_context->set_request_context(test_request_context_.get()); | 212 resource_context->set_request_context(test_request_context_.get()); |
212 media_internals_.reset(new MockMediaInternals()); | 213 media_internals_.reset(new MockMediaInternals()); |
213 | 214 |
214 // Create our own AudioManager, AudioMirroringManager and MediaStreamManager. | 215 // Create our own AudioManager, AudioMirroringManager and MediaStreamManager. |
215 audio_manager_.reset(media::AudioManager::Create()); | 216 audio_manager_.reset(media::AudioManager::Create()); |
216 mirroring_manager_.reset(new AudioMirroringManager()); | 217 mirroring_manager_.reset(new AudioMirroringManager()); |
217 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); | 218 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); |
| 219 key_press_monitor_.reset(new media::KeyPressMonitor()); |
218 | 220 |
219 has_input_devices_ = audio_manager_->HasAudioInputDevices(); | 221 has_input_devices_ = audio_manager_->HasAudioInputDevices(); |
220 has_output_devices_ = audio_manager_->HasAudioOutputDevices(); | 222 has_output_devices_ = audio_manager_->HasAudioOutputDevices(); |
221 | 223 |
222 // Create an IPC channel that handles incoming messages on the IO thread. | 224 // Create an IPC channel that handles incoming messages on the IO thread. |
223 CreateChannel(thread_name); | 225 CreateChannel(thread_name); |
224 } | 226 } |
225 | 227 |
226 void WebRTCAudioDeviceTest::UninitializeIOThread() { | 228 void WebRTCAudioDeviceTest::UninitializeIOThread() { |
227 resource_context_.reset(); | 229 resource_context_.reset(); |
228 | 230 |
229 test_request_context_.reset(); | 231 test_request_context_.reset(); |
230 | 232 |
231 #if defined(OS_WIN) | 233 #if defined(OS_WIN) |
232 initialize_com_.reset(); | 234 initialize_com_.reset(); |
233 #endif | 235 #endif |
234 | 236 |
235 audio_manager_.reset(); | 237 audio_manager_.reset(); |
236 } | 238 } |
237 | 239 |
238 void WebRTCAudioDeviceTest::CreateChannel(const char* name) { | 240 void WebRTCAudioDeviceTest::CreateChannel(const char* name) { |
239 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 241 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
240 | 242 |
241 static const int kRenderProcessId = 1; | 243 static const int kRenderProcessId = 1; |
242 audio_render_host_ = new AudioRendererHost( | 244 audio_render_host_ = new AudioRendererHost( |
243 kRenderProcessId, audio_manager_.get(), mirroring_manager_.get(), | 245 kRenderProcessId, audio_manager_.get(), mirroring_manager_.get(), |
244 media_internals_.get(), media_stream_manager_.get()); | 246 media_internals_.get(), media_stream_manager_.get()); |
245 audio_render_host_->OnChannelConnected(base::GetCurrentProcId()); | 247 audio_render_host_->OnChannelConnected(base::GetCurrentProcId()); |
246 | 248 |
247 audio_input_renderer_host_ = new AudioInputRendererHost( | 249 audio_input_renderer_host_ = |
248 audio_manager_.get(), media_stream_manager_.get(), | 250 new AudioInputRendererHost(audio_manager_.get(), |
249 mirroring_manager_.get()); | 251 media_stream_manager_.get(), |
| 252 mirroring_manager_.get(), |
| 253 key_press_monitor_.get()); |
250 audio_input_renderer_host_->OnChannelConnected(base::GetCurrentProcId()); | 254 audio_input_renderer_host_->OnChannelConnected(base::GetCurrentProcId()); |
251 | 255 |
252 channel_.reset(new IPC::Channel(name, IPC::Channel::MODE_SERVER, this)); | 256 channel_.reset(new IPC::Channel(name, IPC::Channel::MODE_SERVER, this)); |
253 ASSERT_TRUE(channel_->Connect()); | 257 ASSERT_TRUE(channel_->Connect()); |
254 | 258 |
255 audio_render_host_->OnFilterAdded(channel_.get()); | 259 audio_render_host_->OnFilterAdded(channel_.get()); |
256 audio_input_renderer_host_->OnFilterAdded(channel_.get()); | 260 audio_input_renderer_host_->OnFilterAdded(channel_.get()); |
257 } | 261 } |
258 | 262 |
259 void WebRTCAudioDeviceTest::DestroyChannel() { | 263 void WebRTCAudioDeviceTest::DestroyChannel() { |
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
359 int WebRTCTransportImpl::SendPacket(int channel, const void* data, int len) { | 363 int WebRTCTransportImpl::SendPacket(int channel, const void* data, int len) { |
360 return network_->ReceivedRTPPacket(channel, data, len); | 364 return network_->ReceivedRTPPacket(channel, data, len); |
361 } | 365 } |
362 | 366 |
363 int WebRTCTransportImpl::SendRTCPPacket(int channel, const void* data, | 367 int WebRTCTransportImpl::SendRTCPPacket(int channel, const void* data, |
364 int len) { | 368 int len) { |
365 return network_->ReceivedRTCPPacket(channel, data, len); | 369 return network_->ReceivedRTCPPacket(channel, data, len); |
366 } | 370 } |
367 | 371 |
368 } // namespace content | 372 } // namespace content |
OLD | NEW |