OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/browser/renderer_host/media/audio_output_delegate_impl.h" | 5 #include "content/browser/renderer_host/media/audio_output_delegate_impl.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <utility> | 10 #include <utility> |
(...skipping 258 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
269 DummyAudioOutputStream stream; | 269 DummyAudioOutputStream stream; |
270 { | 270 { |
271 AudioOutputDelegateImpl delegate( | 271 AudioOutputDelegateImpl delegate( |
272 &event_handler_, audio_manager_.get(), | 272 &event_handler_, audio_manager_.get(), |
273 log_factory_.CreateAudioLog( | 273 log_factory_.CreateAudioLog( |
274 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), | 274 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), |
275 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, | 275 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, |
276 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), | 276 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), |
277 kDefaultDeviceId); | 277 kDefaultDeviceId); |
278 | 278 |
279 delegate.GetController()->StartDiverting(&stream); | 279 delegate.GetControllerForTesting()->StartDiverting(&stream); |
280 | 280 |
281 SyncWithAllThreads(); | 281 SyncWithAllThreads(); |
282 | 282 |
283 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); | 283 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); |
284 } | 284 } |
285 SyncWithAllThreads(); | 285 SyncWithAllThreads(); |
286 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); | 286 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); |
287 } | 287 } |
288 | 288 |
289 void CreateDivertPauseTest(base::Closure done) { | 289 void CreateDivertPauseTest(base::Closure done) { |
290 EXPECT_CALL(media_observer_, | 290 EXPECT_CALL(media_observer_, |
291 OnCreatingAudioStream(kRenderProcessId, kRenderFrameId)); | 291 OnCreatingAudioStream(kRenderProcessId, kRenderFrameId)); |
292 EXPECT_CALL(event_handler_, | 292 EXPECT_CALL(event_handler_, |
293 OnStreamCreated(kStreamId, NotNull(), NotNull())); | 293 OnStreamCreated(kStreamId, NotNull(), NotNull())); |
294 EXPECT_CALL(mirroring_manager_, | 294 EXPECT_CALL(mirroring_manager_, |
295 AddDiverter(kRenderProcessId, kRenderFrameId, NotNull())); | 295 AddDiverter(kRenderProcessId, kRenderFrameId, NotNull())); |
296 | 296 |
297 DummyAudioOutputStream stream; | 297 DummyAudioOutputStream stream; |
298 { | 298 { |
299 AudioOutputDelegateImpl delegate( | 299 AudioOutputDelegateImpl delegate( |
300 &event_handler_, audio_manager_.get(), | 300 &event_handler_, audio_manager_.get(), |
301 log_factory_.CreateAudioLog( | 301 log_factory_.CreateAudioLog( |
302 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), | 302 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), |
303 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, | 303 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, |
304 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), | 304 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), |
305 kDefaultDeviceId); | 305 kDefaultDeviceId); |
306 | 306 |
307 delegate.GetController()->StartDiverting(&stream); | 307 delegate.GetControllerForTesting()->StartDiverting(&stream); |
308 | 308 |
309 SyncWithAllThreads(); | 309 SyncWithAllThreads(); |
310 delegate.OnPauseStream(); | 310 delegate.OnPauseStream(); |
311 | 311 |
312 SyncWithAllThreads(); | 312 SyncWithAllThreads(); |
313 | 313 |
314 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); | 314 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); |
315 } | 315 } |
316 SyncWithAllThreads(); | 316 SyncWithAllThreads(); |
317 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); | 317 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); |
(...skipping 11 matching lines...) Expand all Loading... |
329 { | 329 { |
330 AudioOutputDelegateImpl delegate( | 330 AudioOutputDelegateImpl delegate( |
331 &event_handler_, audio_manager_.get(), | 331 &event_handler_, audio_manager_.get(), |
332 log_factory_.CreateAudioLog( | 332 log_factory_.CreateAudioLog( |
333 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), | 333 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), |
334 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, | 334 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, |
335 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), | 335 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), |
336 kDefaultDeviceId); | 336 kDefaultDeviceId); |
337 | 337 |
338 delegate.OnPlayStream(); | 338 delegate.OnPlayStream(); |
339 delegate.GetController()->StartDiverting(&stream); | 339 delegate.GetControllerForTesting()->StartDiverting(&stream); |
340 | 340 |
341 SyncWithAllThreads(); | 341 SyncWithAllThreads(); |
342 | 342 |
343 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); | 343 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); |
344 } | 344 } |
345 SyncWithAllThreads(); | 345 SyncWithAllThreads(); |
346 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); | 346 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); |
347 } | 347 } |
348 | 348 |
349 void ErrorTest(base::Closure done) { | 349 void ErrorTest(base::Closure done) { |
350 EXPECT_CALL(media_observer_, | 350 EXPECT_CALL(media_observer_, |
351 OnCreatingAudioStream(kRenderProcessId, kRenderFrameId)); | 351 OnCreatingAudioStream(kRenderProcessId, kRenderFrameId)); |
352 EXPECT_CALL(event_handler_, | 352 EXPECT_CALL(event_handler_, |
353 OnStreamCreated(kStreamId, NotNull(), NotNull())); | 353 OnStreamCreated(kStreamId, NotNull(), NotNull())); |
354 EXPECT_CALL(event_handler_, OnStreamError(kStreamId)); | 354 EXPECT_CALL(event_handler_, OnStreamError(kStreamId)); |
355 EXPECT_CALL(mirroring_manager_, | 355 EXPECT_CALL(mirroring_manager_, |
356 AddDiverter(kRenderProcessId, kRenderFrameId, NotNull())); | 356 AddDiverter(kRenderProcessId, kRenderFrameId, NotNull())); |
357 | 357 |
358 { | 358 { |
359 AudioOutputDelegateImpl delegate( | 359 AudioOutputDelegateImpl delegate( |
360 &event_handler_, audio_manager_.get(), | 360 &event_handler_, audio_manager_.get(), |
361 log_factory_.CreateAudioLog( | 361 log_factory_.CreateAudioLog( |
362 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), | 362 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), |
363 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, | 363 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, |
364 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), | 364 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), |
365 kDefaultDeviceId); | 365 kDefaultDeviceId); |
366 | 366 |
367 delegate.GetController()->OnError(nullptr); | 367 delegate.GetControllerForTesting()->OnError(nullptr); |
368 | 368 |
369 SyncWithAllThreads(); | 369 SyncWithAllThreads(); |
370 | 370 |
371 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); | 371 EXPECT_CALL(mirroring_manager_, RemoveDiverter(NotNull())); |
372 } | 372 } |
373 SyncWithAllThreads(); | 373 SyncWithAllThreads(); |
374 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); | 374 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); |
375 } | 375 } |
376 | 376 |
377 void CreateAndDestroyTest(base::Closure done) { | 377 void CreateAndDestroyTest(base::Closure done) { |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
432 { | 432 { |
433 AudioOutputDelegateImpl delegate( | 433 AudioOutputDelegateImpl delegate( |
434 &event_handler_, audio_manager_.get(), | 434 &event_handler_, audio_manager_.get(), |
435 log_factory_.CreateAudioLog( | 435 log_factory_.CreateAudioLog( |
436 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), | 436 media::AudioLogFactory::AUDIO_OUTPUT_CONTROLLER), |
437 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, | 437 &mirroring_manager_, &media_observer_, kStreamId, kRenderFrameId, |
438 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), | 438 kRenderProcessId, audio_manager_->GetDefaultOutputStreamParameters(), |
439 kDefaultDeviceId); | 439 kDefaultDeviceId); |
440 SyncWithAllThreads(); | 440 SyncWithAllThreads(); |
441 | 441 |
442 delegate.GetController()->OnError(nullptr); | 442 delegate.GetControllerForTesting()->OnError(nullptr); |
443 } | 443 } |
444 SyncWithAllThreads(); | 444 SyncWithAllThreads(); |
445 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); | 445 BrowserThread::PostTask(BrowserThread::UI, FROM_HERE, done); |
446 } | 446 } |
447 | 447 |
448 protected: | 448 protected: |
449 // MediaStreamManager uses a DestructionObserver, so it must outlive the | 449 // MediaStreamManager uses a DestructionObserver, so it must outlive the |
450 // TestBrowserThreadBundle. | 450 // TestBrowserThreadBundle. |
451 std::unique_ptr<MediaStreamManager> media_stream_manager_; | 451 std::unique_ptr<MediaStreamManager> media_stream_manager_; |
452 std::unique_ptr<TestBrowserThreadBundle> thread_bundle_; | 452 std::unique_ptr<TestBrowserThreadBundle> thread_bundle_; |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
573 TEST_F(AudioOutputDelegateTest, ErrorAndDestroy) { | 573 TEST_F(AudioOutputDelegateTest, ErrorAndDestroy) { |
574 base::RunLoop l; | 574 base::RunLoop l; |
575 BrowserThread::PostTask( | 575 BrowserThread::PostTask( |
576 BrowserThread::IO, FROM_HERE, | 576 BrowserThread::IO, FROM_HERE, |
577 base::Bind(&AudioOutputDelegateTest::PlayAndDestroyTest, | 577 base::Bind(&AudioOutputDelegateTest::PlayAndDestroyTest, |
578 base::Unretained(this), l.QuitClosure())); | 578 base::Unretained(this), l.QuitClosure())); |
579 l.Run(); | 579 l.Run(); |
580 } | 580 } |
581 | 581 |
582 } // namespace content | 582 } // namespace content |
OLD | NEW |