| 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 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
| 9 #include "content/browser/browser_thread_impl.h" | 9 #include "content/browser/browser_thread_impl.h" |
| 10 #include "content/browser/renderer_host/media/media_stream_manager.h" | 10 #include "content/browser/renderer_host/media/media_stream_manager.h" |
| 11 #include "content/browser/renderer_host/media/media_stream_ui_proxy.h" |
| 11 #include "content/common/media/media_stream_options.h" | 12 #include "content/common/media/media_stream_options.h" |
| 12 #include "media/audio/audio_manager_base.h" | 13 #include "media/audio/audio_manager_base.h" |
| 13 #if defined(OS_ANDROID) | 14 #if defined(OS_ANDROID) |
| 14 #include "media/audio/android/audio_manager_android.h" | 15 #include "media/audio/android/audio_manager_android.h" |
| 15 #elif defined(OS_LINUX) || defined(OS_OPENBSD) | 16 #elif defined(OS_LINUX) || defined(OS_OPENBSD) |
| 16 #include "media/audio/linux/audio_manager_linux.h" | 17 #include "media/audio/linux/audio_manager_linux.h" |
| 17 #elif defined(OS_MACOSX) | 18 #elif defined(OS_MACOSX) |
| 18 #include "media/audio/mac/audio_manager_mac.h" | 19 #include "media/audio/mac/audio_manager_mac.h" |
| 19 #elif defined(OS_WIN) | 20 #elif defined(OS_WIN) |
| 20 #include "media/audio/win/audio_manager_win.h" | 21 #include "media/audio/win/audio_manager_win.h" |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 56 } | 57 } |
| 57 | 58 |
| 58 private: | 59 private: |
| 59 DISALLOW_COPY_AND_ASSIGN(MockAudioManager); | 60 DISALLOW_COPY_AND_ASSIGN(MockAudioManager); |
| 60 }; | 61 }; |
| 61 | 62 |
| 62 class MediaStreamManagerTest : public ::testing::Test { | 63 class MediaStreamManagerTest : public ::testing::Test { |
| 63 public: | 64 public: |
| 64 MediaStreamManagerTest() {} | 65 MediaStreamManagerTest() {} |
| 65 | 66 |
| 66 MOCK_METHOD1(Response, void(const std::string&)); | 67 MOCK_METHOD1(Response, void(int index)); |
| 67 void ResponseCallback(const std::string& label, | 68 void ResponseCallback(int index, |
| 68 const MediaStreamDevices& devices) { | 69 const MediaStreamDevices& devices, |
| 69 Response(label); | 70 scoped_ptr<MediaStreamUIProxy> ui_proxy) { |
| 71 Response(index); |
| 70 message_loop_->PostTask(FROM_HERE, base::MessageLoop::QuitClosure()); | 72 message_loop_->PostTask(FROM_HERE, base::MessageLoop::QuitClosure()); |
| 71 } | 73 } |
| 72 | 74 |
| 73 void WaitForResult() { message_loop_->Run(); } | 75 void WaitForResult() { message_loop_->Run(); } |
| 74 | 76 |
| 75 protected: | 77 protected: |
| 76 virtual void SetUp() { | 78 virtual void SetUp() { |
| 77 message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_IO)); | 79 message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_IO)); |
| 78 ui_thread_.reset(new BrowserThreadImpl(BrowserThread::UI, | 80 ui_thread_.reset(new BrowserThreadImpl(BrowserThread::UI, |
| 79 message_loop_.get())); | 81 message_loop_.get())); |
| 80 io_thread_.reset(new BrowserThreadImpl(BrowserThread::IO, | 82 io_thread_.reset(new BrowserThreadImpl(BrowserThread::IO, |
| 81 message_loop_.get())); | 83 message_loop_.get())); |
| 82 | 84 |
| 83 // Create our own MediaStreamManager. | 85 // Create our own MediaStreamManager. |
| 84 audio_manager_.reset(new MockAudioManager()); | 86 audio_manager_.reset(new MockAudioManager()); |
| 85 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); | 87 media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get())); |
| 86 | 88 |
| 87 // Use fake devices in order to run on the bots. | 89 // Use fake devices in order to run on the bots. |
| 88 media_stream_manager_->UseFakeDevice(); | 90 media_stream_manager_->UseFakeDevice(); |
| 89 } | 91 } |
| 90 | 92 |
| 91 virtual void TearDown() { | 93 virtual void TearDown() { |
| 92 message_loop_->RunUntilIdle(); | 94 message_loop_->RunUntilIdle(); |
| 93 | 95 |
| 94 // Delete the IO message loop to clean up the MediaStreamManager. | 96 // Delete the IO message loop to clean up the MediaStreamManager. |
| 95 message_loop_.reset(); | 97 message_loop_.reset(); |
| 96 } | 98 } |
| 97 | 99 |
| 98 std::string MakeMediaAccessRequest() { | 100 std::string MakeMediaAccessRequest(int index) { |
| 99 const int render_process_id = 1; | 101 const int render_process_id = 1; |
| 100 const int render_view_id = 1; | 102 const int render_view_id = 1; |
| 101 StreamOptions components(MEDIA_DEVICE_AUDIO_CAPTURE, | 103 StreamOptions components(MEDIA_DEVICE_AUDIO_CAPTURE, |
| 102 MEDIA_DEVICE_VIDEO_CAPTURE); | 104 MEDIA_DEVICE_VIDEO_CAPTURE); |
| 103 const GURL security_origin; | 105 const GURL security_origin; |
| 104 MediaRequestResponseCallback callback = | 106 MediaStreamManager::MediaRequestResponseCallback callback = |
| 105 base::Bind(&MediaStreamManagerTest::ResponseCallback, | 107 base::Bind(&MediaStreamManagerTest::ResponseCallback, |
| 106 base::Unretained(this)); | 108 base::Unretained(this), index); |
| 107 return media_stream_manager_->MakeMediaAccessRequest(render_process_id, | 109 return media_stream_manager_->MakeMediaAccessRequest(render_process_id, |
| 108 render_view_id, | 110 render_view_id, |
| 109 components, | 111 components, |
| 110 security_origin, | 112 security_origin, |
| 111 callback); | 113 callback); |
| 112 } | 114 } |
| 113 | 115 |
| 114 scoped_ptr<base::MessageLoop> message_loop_; | 116 scoped_ptr<base::MessageLoop> message_loop_; |
| 115 scoped_ptr<BrowserThreadImpl> ui_thread_; | 117 scoped_ptr<BrowserThreadImpl> ui_thread_; |
| 116 scoped_ptr<BrowserThreadImpl> io_thread_; | 118 scoped_ptr<BrowserThreadImpl> io_thread_; |
| 117 scoped_ptr<media::AudioManager> audio_manager_; | 119 scoped_ptr<media::AudioManager> audio_manager_; |
| 118 scoped_ptr<MediaStreamManager> media_stream_manager_; | 120 scoped_ptr<MediaStreamManager> media_stream_manager_; |
| 119 | 121 |
| 120 private: | 122 private: |
| 121 DISALLOW_COPY_AND_ASSIGN(MediaStreamManagerTest); | 123 DISALLOW_COPY_AND_ASSIGN(MediaStreamManagerTest); |
| 122 }; | 124 }; |
| 123 | 125 |
| 124 TEST_F(MediaStreamManagerTest, MakeMediaAccessRequest) { | 126 TEST_F(MediaStreamManagerTest, MakeMediaAccessRequest) { |
| 125 std::string label = MakeMediaAccessRequest(); | 127 MakeMediaAccessRequest(0); |
| 126 | 128 |
| 127 // Expecting the callback will be triggered and quit the test. | 129 // Expecting the callback will be triggered and quit the test. |
| 128 EXPECT_CALL(*this, Response(label)); | 130 EXPECT_CALL(*this, Response(0)); |
| 129 WaitForResult(); | 131 WaitForResult(); |
| 130 } | 132 } |
| 131 | 133 |
| 132 TEST_F(MediaStreamManagerTest, MakeAndCancelMediaAccessRequest) { | 134 TEST_F(MediaStreamManagerTest, MakeAndCancelMediaAccessRequest) { |
| 133 std::string label = MakeMediaAccessRequest(); | 135 std::string label = MakeMediaAccessRequest(0); |
| 134 // No callback is expected. | 136 // No callback is expected. |
| 135 media_stream_manager_->CancelRequest(label); | 137 media_stream_manager_->CancelRequest(label); |
| 136 } | 138 } |
| 137 | 139 |
| 138 TEST_F(MediaStreamManagerTest, MakeMultipleRequests) { | 140 TEST_F(MediaStreamManagerTest, MakeMultipleRequests) { |
| 139 // First request. | 141 // First request. |
| 140 std::string label1 = MakeMediaAccessRequest(); | 142 std::string label1 = MakeMediaAccessRequest(0); |
| 141 | 143 |
| 142 // Second request. | 144 // Second request. |
| 143 int render_process_id = 2; | 145 int render_process_id = 2; |
| 144 int render_view_id = 2; | 146 int render_view_id = 2; |
| 145 StreamOptions components(MEDIA_DEVICE_AUDIO_CAPTURE, | 147 StreamOptions components(MEDIA_DEVICE_AUDIO_CAPTURE, |
| 146 MEDIA_DEVICE_VIDEO_CAPTURE); | 148 MEDIA_DEVICE_VIDEO_CAPTURE); |
| 147 GURL security_origin; | 149 GURL security_origin; |
| 148 MediaRequestResponseCallback callback = | 150 MediaStreamManager::MediaRequestResponseCallback callback = |
| 149 base::Bind(&MediaStreamManagerTest::ResponseCallback, | 151 base::Bind(&MediaStreamManagerTest::ResponseCallback, |
| 150 base::Unretained(this)); | 152 base::Unretained(this), 1); |
| 151 std::string label2 = media_stream_manager_->MakeMediaAccessRequest( | 153 std::string label2 = media_stream_manager_->MakeMediaAccessRequest( |
| 152 render_process_id, | 154 render_process_id, |
| 153 render_view_id, | 155 render_view_id, |
| 154 components, | 156 components, |
| 155 security_origin, | 157 security_origin, |
| 156 callback); | 158 callback); |
| 157 | 159 |
| 158 // Expecting the callbackS from requests will be triggered and quit the test. | 160 // Expecting the callbackS from requests will be triggered and quit the test. |
| 159 // Note, the callbacks might come in a different order depending on the | 161 // Note, the callbacks might come in a different order depending on the |
| 160 // value of labels. | 162 // value of labels. |
| 161 EXPECT_CALL(*this, Response(_)).Times(2); | 163 EXPECT_CALL(*this, Response(0)); |
| 164 EXPECT_CALL(*this, Response(1)); |
| 162 WaitForResult(); | 165 WaitForResult(); |
| 163 } | 166 } |
| 164 | 167 |
| 165 TEST_F(MediaStreamManagerTest, MakeAndCancelMultipleRequests) { | 168 TEST_F(MediaStreamManagerTest, MakeAndCancelMultipleRequests) { |
| 166 std::string label1 = MakeMediaAccessRequest(); | 169 std::string label1 = MakeMediaAccessRequest(0); |
| 167 std::string label2 = MakeMediaAccessRequest(); | 170 std::string label2 = MakeMediaAccessRequest(1); |
| 168 media_stream_manager_->CancelRequest(label1); | 171 media_stream_manager_->CancelRequest(label1); |
| 169 | 172 |
| 170 // Expecting the callback from the second request will be triggered and | 173 // Expecting the callback from the second request will be triggered and |
| 171 // quit the test. | 174 // quit the test. |
| 172 EXPECT_CALL(*this, Response(label2)); | 175 EXPECT_CALL(*this, Response(1)); |
| 173 WaitForResult(); | 176 WaitForResult(); |
| 174 } | 177 } |
| 175 | 178 |
| 176 } // namespace content | 179 } // namespace content |
| OLD | NEW |