| 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 |