| 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 <string> | 5 #include <string> |
| 6 #include <queue> | 6 #include <queue> |
| 7 | 7 |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
| 10 #include "base/message_loop/message_loop.h" | 10 #include "base/message_loop/message_loop.h" |
| 11 #include "base/run_loop.h" | 11 #include "base/run_loop.h" |
| 12 #include "content/browser/browser_thread_impl.h" | 12 #include "content/browser/browser_thread_impl.h" |
| 13 #include "content/browser/renderer_host/media/media_stream_dispatcher_host.h" | 13 #include "content/browser/renderer_host/media/media_stream_dispatcher_host.h" |
| 14 #include "content/browser/renderer_host/media/media_stream_manager.h" | 14 #include "content/browser/renderer_host/media/media_stream_manager.h" |
| 15 #include "content/browser/renderer_host/media/media_stream_ui_proxy.h" | 15 #include "content/browser/renderer_host/media/media_stream_ui_proxy.h" |
| 16 #include "content/common/media/media_stream_messages.h" | 16 #include "content/common/media/media_stream_messages.h" |
| 17 #include "content/common/media/media_stream_options.h" | 17 #include "content/common/media/media_stream_options.h" |
| 18 #include "content/public/browser/media_device_id.h" | 18 #include "content/public/browser/media_device_id.h" |
| 19 #include "content/public/test/mock_resource_context.h" | 19 #include "content/public/test/mock_resource_context.h" |
| 20 #include "content/public/test/test_browser_context.h" |
| 20 #include "content/public/test/test_browser_thread_bundle.h" | 21 #include "content/public/test/test_browser_thread_bundle.h" |
| 21 #include "content/test/test_content_browser_client.h" | 22 #include "content/test/test_content_browser_client.h" |
| 22 #include "content/test/test_content_client.h" | 23 #include "content/test/test_content_client.h" |
| 23 #include "ipc/ipc_message_macros.h" | 24 #include "ipc/ipc_message_macros.h" |
| 24 #include "media/audio/mock_audio_manager.h" | 25 #include "media/audio/mock_audio_manager.h" |
| 25 #include "media/video/capture/fake_video_capture_device.h" | 26 #include "media/video/capture/fake_video_capture_device.h" |
| 26 #include "net/url_request/url_request_context.h" | 27 #include "net/url_request/url_request_context.h" |
| 27 #include "testing/gmock/include/gmock/gmock.h" | 28 #include "testing/gmock/include/gmock/gmock.h" |
| 28 #include "testing/gtest/include/gtest/gtest.h" | 29 #include "testing/gtest/include/gtest/gtest.h" |
| 29 | 30 |
| 30 using ::testing::_; | 31 using ::testing::_; |
| 31 using ::testing::DeleteArg; | 32 using ::testing::DeleteArg; |
| 32 using ::testing::DoAll; | 33 using ::testing::DoAll; |
| 33 using ::testing::Return; | 34 using ::testing::Return; |
| 34 using ::testing::SaveArg; | 35 using ::testing::SaveArg; |
| 35 | 36 |
| 36 const int kProcessId = 5; | 37 const int kProcessId = 5; |
| 37 const int kRenderId = 6; | 38 const int kRenderId = 6; |
| 38 const int kPageRequestId = 7; | 39 const int kPageRequestId = 7; |
| 39 | 40 |
| 40 namespace content { | 41 namespace content { |
| 41 | 42 |
| 42 class MockMediaStreamDispatcherHost : public MediaStreamDispatcherHost, | 43 class MockMediaStreamDispatcherHost : public MediaStreamDispatcherHost, |
| 43 public TestContentBrowserClient { | 44 public TestContentBrowserClient { |
| 44 public: | 45 public: |
| 45 MockMediaStreamDispatcherHost( | 46 MockMediaStreamDispatcherHost( |
| 47 ResourceContext* resource_context, |
| 46 const scoped_refptr<base::MessageLoopProxy>& message_loop, | 48 const scoped_refptr<base::MessageLoopProxy>& message_loop, |
| 47 MediaStreamManager* manager) | 49 MediaStreamManager* manager) |
| 48 : MediaStreamDispatcherHost(kProcessId, manager), | 50 : MediaStreamDispatcherHost(kProcessId, resource_context, manager), |
| 49 message_loop_(message_loop) {} | 51 message_loop_(message_loop) {} |
| 50 | 52 |
| 51 // A list of mock methods. | 53 // A list of mock methods. |
| 52 MOCK_METHOD4(OnStreamGenerated, | 54 MOCK_METHOD4(OnStreamGenerated, |
| 53 void(int routing_id, int request_id, int audio_array_size, | 55 void(int routing_id, int request_id, int audio_array_size, |
| 54 int video_array_size)); | 56 int video_array_size)); |
| 55 MOCK_METHOD2(OnStreamGenerationFailed, void(int routing_id, int request_id)); | 57 MOCK_METHOD2(OnStreamGenerationFailed, void(int routing_id, int request_id)); |
| 56 MOCK_METHOD1(OnStopGeneratedStreamFromBrowser, | 58 MOCK_METHOD1(OnStopGeneratedStreamFromBrowser, |
| 57 void(int routing_id)); | 59 void(int routing_id)); |
| 58 MOCK_METHOD2(OnDeviceOpened, | 60 MOCK_METHOD2(OnDeviceOpened, |
| (...skipping 151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 210 : old_browser_client_(NULL), | 212 : old_browser_client_(NULL), |
| 211 thread_bundle_(content::TestBrowserThreadBundle::IO_MAINLOOP), | 213 thread_bundle_(content::TestBrowserThreadBundle::IO_MAINLOOP), |
| 212 origin_("https://test.com") { | 214 origin_("https://test.com") { |
| 213 audio_manager_.reset( | 215 audio_manager_.reset( |
| 214 new media::MockAudioManager(base::MessageLoopProxy::current())); | 216 new media::MockAudioManager(base::MessageLoopProxy::current())); |
| 215 // Create our own MediaStreamManager. | 217 // Create our own MediaStreamManager. |
| 216 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); | 218 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); |
| 217 // Make sure we use fake devices to avoid long delays. | 219 // Make sure we use fake devices to avoid long delays. |
| 218 media_stream_manager_->UseFakeDevice(); | 220 media_stream_manager_->UseFakeDevice(); |
| 219 | 221 |
| 220 host_ = new MockMediaStreamDispatcherHost(base::MessageLoopProxy::current(), | 222 host_ = new MockMediaStreamDispatcherHost( |
| 221 media_stream_manager_.get()); | 223 browser_context_.GetResourceContext(), |
| 224 base::MessageLoopProxy::current(), |
| 225 media_stream_manager_.get()); |
| 222 | 226 |
| 223 // Use the fake content client and browser. | 227 // Use the fake content client and browser. |
| 224 content_client_.reset(new TestContentClient()); | 228 content_client_.reset(new TestContentClient()); |
| 225 SetContentClient(content_client_.get()); | 229 SetContentClient(content_client_.get()); |
| 226 old_browser_client_ = SetBrowserClientForTesting(host_.get()); | 230 old_browser_client_ = SetBrowserClientForTesting(host_.get()); |
| 227 } | 231 } |
| 228 | 232 |
| 229 virtual ~MediaStreamDispatcherHostTest() { | 233 virtual ~MediaStreamDispatcherHostTest() { |
| 230 } | 234 } |
| 231 | 235 |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 345 } | 349 } |
| 346 | 350 |
| 347 bool DoesEveryDeviceMapToRawId(const StreamDeviceInfoArray& devices, | 351 bool DoesEveryDeviceMapToRawId(const StreamDeviceInfoArray& devices, |
| 348 const GURL& origin) { | 352 const GURL& origin) { |
| 349 for (size_t i = 0; i < devices.size(); ++i) { | 353 for (size_t i = 0; i < devices.size(); ++i) { |
| 350 bool found_match = false; | 354 bool found_match = false; |
| 351 media::AudioDeviceNames::const_iterator audio_it = | 355 media::AudioDeviceNames::const_iterator audio_it = |
| 352 physical_audio_devices_.begin(); | 356 physical_audio_devices_.begin(); |
| 353 for (; audio_it != physical_audio_devices_.end(); ++audio_it) { | 357 for (; audio_it != physical_audio_devices_.end(); ++audio_it) { |
| 354 if (content::DoesMediaDeviceIDMatchHMAC( | 358 if (content::DoesMediaDeviceIDMatchHMAC( |
| 359 browser_context_.GetResourceContext(), |
| 355 origin, | 360 origin, |
| 356 devices[i].device.id, | 361 devices[i].device.id, |
| 357 audio_it->unique_id)) { | 362 audio_it->unique_id)) { |
| 358 EXPECT_FALSE(found_match); | 363 EXPECT_FALSE(found_match); |
| 359 found_match = true; | 364 found_match = true; |
| 360 } | 365 } |
| 361 } | 366 } |
| 362 media::VideoCaptureDevice::Names::const_iterator video_it = | 367 media::VideoCaptureDevice::Names::const_iterator video_it = |
| 363 physical_video_devices_.begin(); | 368 physical_video_devices_.begin(); |
| 364 for (; video_it != physical_video_devices_.end(); ++video_it) { | 369 for (; video_it != physical_video_devices_.end(); ++video_it) { |
| 365 if (content::DoesMediaDeviceIDMatchHMAC( | 370 if (content::DoesMediaDeviceIDMatchHMAC( |
| 371 browser_context_.GetResourceContext(), |
| 366 origin, | 372 origin, |
| 367 devices[i].device.id, | 373 devices[i].device.id, |
| 368 video_it->id())) { | 374 video_it->id())) { |
| 369 EXPECT_FALSE(found_match); | 375 EXPECT_FALSE(found_match); |
| 370 found_match = true; | 376 found_match = true; |
| 371 } | 377 } |
| 372 } | 378 } |
| 373 if (!found_match) | 379 if (!found_match) |
| 374 return false; | 380 return false; |
| 375 } | 381 } |
| 376 return true; | 382 return true; |
| 377 } | 383 } |
| 378 | 384 |
| 379 scoped_refptr<MockMediaStreamDispatcherHost> host_; | 385 scoped_refptr<MockMediaStreamDispatcherHost> host_; |
| 380 scoped_ptr<media::AudioManager> audio_manager_; | 386 scoped_ptr<media::AudioManager> audio_manager_; |
| 381 scoped_ptr<MediaStreamManager> media_stream_manager_; | 387 scoped_ptr<MediaStreamManager> media_stream_manager_; |
| 382 ContentBrowserClient* old_browser_client_; | 388 ContentBrowserClient* old_browser_client_; |
| 383 scoped_ptr<ContentClient> content_client_; | 389 scoped_ptr<ContentClient> content_client_; |
| 384 content::TestBrowserThreadBundle thread_bundle_; | 390 content::TestBrowserThreadBundle thread_bundle_; |
| 391 content::TestBrowserContext browser_context_; |
| 385 media::AudioDeviceNames physical_audio_devices_; | 392 media::AudioDeviceNames physical_audio_devices_; |
| 386 media::VideoCaptureDevice::Names physical_video_devices_; | 393 media::VideoCaptureDevice::Names physical_video_devices_; |
| 387 GURL origin_; | 394 GURL origin_; |
| 388 }; | 395 }; |
| 389 | 396 |
| 390 TEST_F(MediaStreamDispatcherHostTest, GenerateStreamWithVideoOnly) { | 397 TEST_F(MediaStreamDispatcherHostTest, GenerateStreamWithVideoOnly) { |
| 391 StreamOptions options(MEDIA_NO_SERVICE, MEDIA_DEVICE_VIDEO_CAPTURE); | 398 StreamOptions options(MEDIA_NO_SERVICE, MEDIA_DEVICE_VIDEO_CAPTURE); |
| 392 | 399 |
| 393 SetupFakeUI(true); | 400 SetupFakeUI(true); |
| 394 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); | 401 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); |
| (...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 527 TEST_F(MediaStreamDispatcherHostTest, GenerateStreamsWithSourceId) { | 534 TEST_F(MediaStreamDispatcherHostTest, GenerateStreamsWithSourceId) { |
| 528 ASSERT_GE(physical_audio_devices_.size(), 1u); | 535 ASSERT_GE(physical_audio_devices_.size(), 1u); |
| 529 ASSERT_GE(physical_video_devices_.size(), 1u); | 536 ASSERT_GE(physical_video_devices_.size(), 1u); |
| 530 | 537 |
| 531 media::AudioDeviceNames::const_iterator audio_it = | 538 media::AudioDeviceNames::const_iterator audio_it = |
| 532 physical_audio_devices_.begin(); | 539 physical_audio_devices_.begin(); |
| 533 for (; audio_it != physical_audio_devices_.end(); ++audio_it) { | 540 for (; audio_it != physical_audio_devices_.end(); ++audio_it) { |
| 534 StreamOptions options(MEDIA_DEVICE_AUDIO_CAPTURE, | 541 StreamOptions options(MEDIA_DEVICE_AUDIO_CAPTURE, |
| 535 MEDIA_DEVICE_VIDEO_CAPTURE); | 542 MEDIA_DEVICE_VIDEO_CAPTURE); |
| 536 options.audio_device_id = content::GetHMACForMediaDeviceID( | 543 options.audio_device_id = content::GetHMACForMediaDeviceID( |
| 544 browser_context_.GetResourceContext(), |
| 537 origin_, | 545 origin_, |
| 538 audio_it->unique_id); | 546 audio_it->unique_id); |
| 539 ASSERT_FALSE(options.audio_device_id.empty()); | 547 ASSERT_FALSE(options.audio_device_id.empty()); |
| 540 | 548 |
| 541 // Generate first stream. | 549 // Generate first stream. |
| 542 SetupFakeUI(true); | 550 SetupFakeUI(true); |
| 543 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); | 551 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); |
| 544 EXPECT_EQ(host_->audio_devices_[0].device.id, options.audio_device_id); | 552 EXPECT_EQ(host_->audio_devices_[0].device.id, options.audio_device_id); |
| 545 } | 553 } |
| 546 | 554 |
| 547 media::VideoCaptureDevice::Names::const_iterator video_it = | 555 media::VideoCaptureDevice::Names::const_iterator video_it = |
| 548 physical_video_devices_.begin(); | 556 physical_video_devices_.begin(); |
| 549 for (; video_it != physical_video_devices_.end(); ++video_it) { | 557 for (; video_it != physical_video_devices_.end(); ++video_it) { |
| 550 StreamOptions options(MEDIA_DEVICE_AUDIO_CAPTURE, | 558 StreamOptions options(MEDIA_DEVICE_AUDIO_CAPTURE, |
| 551 MEDIA_DEVICE_VIDEO_CAPTURE); | 559 MEDIA_DEVICE_VIDEO_CAPTURE); |
| 552 options.video_device_id = content::GetHMACForMediaDeviceID( | 560 options.video_device_id = content::GetHMACForMediaDeviceID( |
| 553 origin_, | 561 browser_context_.GetResourceContext(), |
| 554 video_it->id()); | 562 origin_, |
| 563 video_it->id()); |
| 555 ASSERT_FALSE(options.video_device_id.empty()); | 564 ASSERT_FALSE(options.video_device_id.empty()); |
| 556 | 565 |
| 557 // Generate first stream. | 566 // Generate first stream. |
| 558 SetupFakeUI(true); | 567 SetupFakeUI(true); |
| 559 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); | 568 GenerateStreamAndWaitForResult(kRenderId, kPageRequestId, options); |
| 560 EXPECT_EQ(host_->video_devices_[0].device.id, options.video_device_id); | 569 EXPECT_EQ(host_->video_devices_[0].device.id, options.video_device_id); |
| 561 } | 570 } |
| 562 } | 571 } |
| 563 | 572 |
| 564 // Test that generating a stream with an invalid video source id fail. | 573 // Test that generating a stream with an invalid video source id fail. |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 661 MEDIA_DEVICE_AUDIO_CAPTURE); | 670 MEDIA_DEVICE_AUDIO_CAPTURE); |
| 662 } | 671 } |
| 663 | 672 |
| 664 TEST_F(MediaStreamDispatcherHostTest, EnumerateVideoDevices) { | 673 TEST_F(MediaStreamDispatcherHostTest, EnumerateVideoDevices) { |
| 665 EnumerateDevicesAndWaitForResult(kRenderId, kPageRequestId, | 674 EnumerateDevicesAndWaitForResult(kRenderId, kPageRequestId, |
| 666 MEDIA_DEVICE_VIDEO_CAPTURE); | 675 MEDIA_DEVICE_VIDEO_CAPTURE); |
| 667 } | 676 } |
| 668 | 677 |
| 669 | 678 |
| 670 }; // namespace content | 679 }; // namespace content |
| OLD | NEW |