Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(129)

Side by Side Diff: content/test/webrtc_audio_device_test.cc

Issue 21183002: Adding key press detection in the browser process. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 7 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698