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 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
199 | 199 |
200 // Set the current thread as the IO thread. | 200 // Set the current thread as the IO thread. |
201 io_thread_.reset(new TestBrowserThread(BrowserThread::IO, | 201 io_thread_.reset(new TestBrowserThread(BrowserThread::IO, |
202 MessageLoop::current())); | 202 MessageLoop::current())); |
203 | 203 |
204 // Populate our resource context. | 204 // Populate our resource context. |
205 test_request_context_.reset(new net::TestURLRequestContext()); | 205 test_request_context_.reset(new net::TestURLRequestContext()); |
206 MockRTCResourceContext* resource_context = | 206 MockRTCResourceContext* resource_context = |
207 static_cast<MockRTCResourceContext*>(resource_context_.get()); | 207 static_cast<MockRTCResourceContext*>(resource_context_.get()); |
208 resource_context->set_request_context(test_request_context_.get()); | 208 resource_context->set_request_context(test_request_context_.get()); |
209 media_observer_.reset(new MockMediaObserver()); | 209 media_internals_.reset(new MockMediaInternals()); |
scherkus (not reviewing)
2013/02/01 02:05:17
I should ping the folks of this test -- I don't se
| |
210 | 210 |
211 // Create our own AudioManager, AudioMirroringManager and MediaStreamManager. | 211 // Create our own AudioManager, AudioMirroringManager and MediaStreamManager. |
212 audio_manager_.reset(media::AudioManager::Create()); | 212 audio_manager_.reset(media::AudioManager::Create()); |
213 mirroring_manager_.reset(new AudioMirroringManager()); | 213 mirroring_manager_.reset(new AudioMirroringManager()); |
214 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); | 214 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); |
215 | 215 |
216 has_input_devices_ = audio_manager_->HasAudioInputDevices(); | 216 has_input_devices_ = audio_manager_->HasAudioInputDevices(); |
217 has_output_devices_ = audio_manager_->HasAudioOutputDevices(); | 217 has_output_devices_ = audio_manager_->HasAudioOutputDevices(); |
218 | 218 |
219 // Create an IPC channel that handles incoming messages on the IO thread. | 219 // Create an IPC channel that handles incoming messages on the IO thread. |
220 CreateChannel(thread_name); | 220 CreateChannel(thread_name); |
221 } | 221 } |
222 | 222 |
223 void WebRTCAudioDeviceTest::UninitializeIOThread() { | 223 void WebRTCAudioDeviceTest::UninitializeIOThread() { |
224 resource_context_.reset(); | 224 resource_context_.reset(); |
225 | 225 |
226 test_request_context_.reset(); | 226 test_request_context_.reset(); |
227 | 227 |
228 #if defined(OS_WIN) | 228 #if defined(OS_WIN) |
229 initialize_com_.reset(); | 229 initialize_com_.reset(); |
230 #endif | 230 #endif |
231 } | 231 } |
232 | 232 |
233 void WebRTCAudioDeviceTest::CreateChannel(const char* name) { | 233 void WebRTCAudioDeviceTest::CreateChannel(const char* name) { |
234 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 234 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
235 | 235 |
236 static const int kRenderProcessId = 1; | 236 static const int kRenderProcessId = 1; |
237 audio_render_host_ = new AudioRendererHost( | 237 audio_render_host_ = new AudioRendererHost( |
238 kRenderProcessId, audio_manager_.get(), mirroring_manager_.get(), | 238 kRenderProcessId, audio_manager_.get(), mirroring_manager_.get(), |
239 media_observer_.get()); | 239 media_internals_.get()); |
240 audio_render_host_->OnChannelConnected(base::GetCurrentProcId()); | 240 audio_render_host_->OnChannelConnected(base::GetCurrentProcId()); |
241 | 241 |
242 audio_input_renderer_host_ = new AudioInputRendererHost( | 242 audio_input_renderer_host_ = new AudioInputRendererHost( |
243 audio_manager_.get(), media_stream_manager_.get()); | 243 audio_manager_.get(), media_stream_manager_.get()); |
244 audio_input_renderer_host_->OnChannelConnected(base::GetCurrentProcId()); | 244 audio_input_renderer_host_->OnChannelConnected(base::GetCurrentProcId()); |
245 | 245 |
246 channel_.reset(new IPC::Channel(name, IPC::Channel::MODE_SERVER, this)); | 246 channel_.reset(new IPC::Channel(name, IPC::Channel::MODE_SERVER, this)); |
247 ASSERT_TRUE(channel_->Connect()); | 247 ASSERT_TRUE(channel_->Connect()); |
248 | 248 |
249 audio_render_host_->OnFilterAdded(channel_.get()); | 249 audio_render_host_->OnFilterAdded(channel_.get()); |
(...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
371 int WebRTCTransportImpl::SendPacket(int channel, const void* data, int len) { | 371 int WebRTCTransportImpl::SendPacket(int channel, const void* data, int len) { |
372 return network_->ReceivedRTPPacket(channel, data, len); | 372 return network_->ReceivedRTPPacket(channel, data, len); |
373 } | 373 } |
374 | 374 |
375 int WebRTCTransportImpl::SendRTCPPacket(int channel, const void* data, | 375 int WebRTCTransportImpl::SendRTCPPacket(int channel, const void* data, |
376 int len) { | 376 int len) { |
377 return network_->ReceivedRTCPPacket(channel, data, len); | 377 return network_->ReceivedRTCPPacket(channel, data, len); |
378 } | 378 } |
379 | 379 |
380 } // namespace content | 380 } // namespace content |
OLD | NEW |