| 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 // Unit test for VideoCaptureManager. | 5 // Unit test for VideoCaptureManager. |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
| 11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 12 #include "base/message_loop.h" | 12 #include "base/message_loop.h" |
| 13 #include "base/process_util.h" | 13 #include "base/process_util.h" |
| 14 #include "content/browser/browser_thread_impl.h" | 14 #include "content/browser/browser_thread_impl.h" |
| 15 #include "content/browser/renderer_host/media/media_stream_provider.h" | 15 #include "content/browser/renderer_host/media/media_stream_provider.h" |
| 16 #include "content/browser/renderer_host/media/video_capture_manager.h" | 16 #include "content/browser/renderer_host/media/video_capture_manager.h" |
| 17 #include "content/common/media/media_stream_options.h" | 17 #include "content/common/media/media_stream_options.h" |
| 18 #include "content/public/common/media_stream_request.h" |
| 18 #include "media/video/capture/video_capture_device.h" | 19 #include "media/video/capture/video_capture_device.h" |
| 19 #include "testing/gmock/include/gmock/gmock.h" | 20 #include "testing/gmock/include/gmock/gmock.h" |
| 20 #include "testing/gtest/include/gtest/gtest.h" | 21 #include "testing/gtest/include/gtest/gtest.h" |
| 21 | 22 |
| 22 using ::testing::_; | 23 using ::testing::_; |
| 23 using ::testing::AnyNumber; | 24 using ::testing::AnyNumber; |
| 24 using ::testing::InSequence; | 25 using ::testing::InSequence; |
| 25 using ::testing::Return; | 26 using ::testing::Return; |
| 26 using content::BrowserThread; | 27 using content::BrowserThread; |
| 27 | 28 |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 76 public: | 77 public: |
| 77 VideoCaptureManagerTest() {} | 78 VideoCaptureManagerTest() {} |
| 78 virtual ~VideoCaptureManagerTest() {} | 79 virtual ~VideoCaptureManagerTest() {} |
| 79 | 80 |
| 80 protected: | 81 protected: |
| 81 virtual void SetUp() OVERRIDE { | 82 virtual void SetUp() OVERRIDE { |
| 82 listener_.reset(new media_stream::MockMediaStreamProviderListener()); | 83 listener_.reset(new media_stream::MockMediaStreamProviderListener()); |
| 83 message_loop_.reset(new MessageLoop(MessageLoop::TYPE_IO)); | 84 message_loop_.reset(new MessageLoop(MessageLoop::TYPE_IO)); |
| 84 io_thread_.reset(new BrowserThreadImpl(BrowserThread::IO, | 85 io_thread_.reset(new BrowserThreadImpl(BrowserThread::IO, |
| 85 message_loop_.get())); | 86 message_loop_.get())); |
| 86 vcm_ = new media_stream::VideoCaptureManager(); | 87 vcm_ = new media_stream::VideoCaptureManager( |
| 88 content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE); |
| 87 vcm_->UseFakeDevice(); | 89 vcm_->UseFakeDevice(); |
| 88 vcm_->Register(listener_.get(), message_loop_->message_loop_proxy()); | 90 vcm_->Register(listener_.get(), message_loop_->message_loop_proxy()); |
| 89 frame_observer_.reset(new MockFrameObserver()); | 91 frame_observer_.reset(new MockFrameObserver()); |
| 90 } | 92 } |
| 91 | 93 |
| 92 virtual void TearDown() OVERRIDE {} | 94 virtual void TearDown() OVERRIDE {} |
| 93 | 95 |
| 94 scoped_refptr<media_stream::VideoCaptureManager> vcm_; | 96 scoped_refptr<media_stream::VideoCaptureManager> vcm_; |
| 95 scoped_ptr<media_stream::MockMediaStreamProviderListener> listener_; | 97 scoped_ptr<media_stream::MockMediaStreamProviderListener> listener_; |
| 96 scoped_ptr<MessageLoop> message_loop_; | 98 scoped_ptr<MessageLoop> message_loop_; |
| 97 scoped_ptr<BrowserThreadImpl> io_thread_; | 99 scoped_ptr<BrowserThreadImpl> io_thread_; |
| 98 scoped_ptr<MockFrameObserver> frame_observer_; | 100 scoped_ptr<MockFrameObserver> frame_observer_; |
| 99 | 101 |
| 100 private: | 102 private: |
| 101 DISALLOW_COPY_AND_ASSIGN(VideoCaptureManagerTest); | 103 DISALLOW_COPY_AND_ASSIGN(VideoCaptureManagerTest); |
| 102 }; | 104 }; |
| 103 | 105 |
| 104 // Test cases | 106 // Test cases |
| 105 | 107 |
| 106 // Try to open, start, stop and close a device. | 108 // Try to open, start, stop and close a device. |
| 107 TEST_F(VideoCaptureManagerTest, CreateAndClose) { | 109 TEST_F(VideoCaptureManagerTest, CreateAndClose) { |
| 108 InSequence s; | 110 InSequence s; |
| 109 EXPECT_CALL(*listener_, DevicesEnumerated(_)) | 111 EXPECT_CALL(*listener_, DevicesEnumerated(_)) |
| 110 .Times(1); | 112 .Times(1); |
| 111 EXPECT_CALL(*listener_, | 113 EXPECT_CALL(*listener_, |
| 112 Opened(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 114 Opened(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 113 .Times(1); | 115 .Times(1); |
| 114 EXPECT_CALL(*listener_, | 116 EXPECT_CALL(*listener_, |
| 115 Closed(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 117 Closed(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 116 .Times(1); | 118 .Times(1); |
| 117 | 119 |
| 118 vcm_->EnumerateDevices(); | 120 vcm_->EnumerateDevices(); |
| 119 | 121 |
| 120 // Wait to get device callback. | 122 // Wait to get device callback. |
| 121 message_loop_->RunAllPending(); | 123 message_loop_->RunAllPending(); |
| 122 | 124 |
| 123 int video_session_id = vcm_->Open(listener_->devices_.front()); | 125 int video_session_id = vcm_->Open(listener_->devices_.front()); |
| 124 | 126 |
| 125 media::VideoCaptureParams capture_params; | 127 media::VideoCaptureParams capture_params; |
| (...skipping 10 matching lines...) Expand all Loading... |
| 136 message_loop_->RunAllPending(); | 138 message_loop_->RunAllPending(); |
| 137 vcm_->Unregister(); | 139 vcm_->Unregister(); |
| 138 } | 140 } |
| 139 | 141 |
| 140 // Open the same device twice. | 142 // Open the same device twice. |
| 141 TEST_F(VideoCaptureManagerTest, OpenTwice) { | 143 TEST_F(VideoCaptureManagerTest, OpenTwice) { |
| 142 InSequence s; | 144 InSequence s; |
| 143 EXPECT_CALL(*listener_, DevicesEnumerated(_)) | 145 EXPECT_CALL(*listener_, DevicesEnumerated(_)) |
| 144 .Times(1); | 146 .Times(1); |
| 145 EXPECT_CALL(*listener_, | 147 EXPECT_CALL(*listener_, |
| 146 Opened(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 148 Opened(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 147 .Times(2); | 149 .Times(2); |
| 148 EXPECT_CALL(*listener_, | 150 EXPECT_CALL(*listener_, |
| 149 Closed(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 151 Closed(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 150 .Times(2); | 152 .Times(2); |
| 151 | 153 |
| 152 vcm_->EnumerateDevices(); | 154 vcm_->EnumerateDevices(); |
| 153 | 155 |
| 154 // Wait to get device callback. | 156 // Wait to get device callback. |
| 155 message_loop_->RunAllPending(); | 157 message_loop_->RunAllPending(); |
| 156 | 158 |
| 157 int video_session_id_first = vcm_->Open(listener_->devices_.front()); | 159 int video_session_id_first = vcm_->Open(listener_->devices_.front()); |
| 158 | 160 |
| 159 // This should trigger an error callback with error code | 161 // This should trigger an error callback with error code |
| 160 // 'kDeviceAlreadyInUse'. | 162 // 'kDeviceAlreadyInUse'. |
| 161 int video_session_id_second = vcm_->Open(listener_->devices_.front()); | 163 int video_session_id_second = vcm_->Open(listener_->devices_.front()); |
| 162 EXPECT_NE(video_session_id_first, video_session_id_second); | 164 EXPECT_NE(video_session_id_first, video_session_id_second); |
| 163 | 165 |
| 164 vcm_->Close(video_session_id_first); | 166 vcm_->Close(video_session_id_first); |
| 165 vcm_->Close(video_session_id_second); | 167 vcm_->Close(video_session_id_second); |
| 166 | 168 |
| 167 // Wait to check callbacks before removing the listener. | 169 // Wait to check callbacks before removing the listener. |
| 168 message_loop_->RunAllPending(); | 170 message_loop_->RunAllPending(); |
| 169 vcm_->Unregister(); | 171 vcm_->Unregister(); |
| 170 } | 172 } |
| 171 | 173 |
| 172 // Open two different devices. | 174 // Open two different devices. |
| 173 TEST_F(VideoCaptureManagerTest, OpenTwo) { | 175 TEST_F(VideoCaptureManagerTest, OpenTwo) { |
| 174 InSequence s; | 176 InSequence s; |
| 175 EXPECT_CALL(*listener_, DevicesEnumerated(_)) | 177 EXPECT_CALL(*listener_, DevicesEnumerated(_)) |
| 176 .Times(1); | 178 .Times(1); |
| 177 EXPECT_CALL(*listener_, | 179 EXPECT_CALL(*listener_, |
| 178 Opened(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 180 Opened(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 179 .Times(2); | 181 .Times(2); |
| 180 EXPECT_CALL(*listener_, | 182 EXPECT_CALL(*listener_, |
| 181 Closed(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 183 Closed(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 182 .Times(2); | 184 .Times(2); |
| 183 | 185 |
| 184 vcm_->EnumerateDevices(); | 186 vcm_->EnumerateDevices(); |
| 185 | 187 |
| 186 // Wait to get device callback. | 188 // Wait to get device callback. |
| 187 message_loop_->RunAllPending(); | 189 message_loop_->RunAllPending(); |
| 188 | 190 |
| 189 media_stream::StreamDeviceInfoArray::iterator it = | 191 media_stream::StreamDeviceInfoArray::iterator it = |
| 190 listener_->devices_.begin(); | 192 listener_->devices_.begin(); |
| 191 | 193 |
| 192 int video_session_id_first = vcm_->Open(*it); | 194 int video_session_id_first = vcm_->Open(*it); |
| 193 ++it; | 195 ++it; |
| 194 int video_session_id_second = vcm_->Open(*it); | 196 int video_session_id_second = vcm_->Open(*it); |
| 195 | 197 |
| 196 vcm_->Close(video_session_id_first); | 198 vcm_->Close(video_session_id_first); |
| 197 vcm_->Close(video_session_id_second); | 199 vcm_->Close(video_session_id_second); |
| 198 | 200 |
| 199 // Wait to check callbacks before removing the listener. | 201 // Wait to check callbacks before removing the listener. |
| 200 message_loop_->RunAllPending(); | 202 message_loop_->RunAllPending(); |
| 201 vcm_->Unregister(); | 203 vcm_->Unregister(); |
| 202 } | 204 } |
| 203 | 205 |
| 204 // Try open a non-existing device. | 206 // Try open a non-existing device. |
| 205 TEST_F(VideoCaptureManagerTest, OpenNotExisting) { | 207 TEST_F(VideoCaptureManagerTest, OpenNotExisting) { |
| 206 InSequence s; | 208 InSequence s; |
| 207 EXPECT_CALL(*listener_, DevicesEnumerated(_)) | 209 EXPECT_CALL(*listener_, DevicesEnumerated(_)) |
| 208 .Times(1); | 210 .Times(1); |
| 209 EXPECT_CALL(*listener_, Error(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, | 211 EXPECT_CALL(*listener_, |
| 210 _, media_stream::kDeviceNotAvailable)) | 212 Error(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, |
| 213 _, media_stream::kDeviceNotAvailable)) |
| 211 .Times(1); | 214 .Times(1); |
| 212 | 215 |
| 213 vcm_->EnumerateDevices(); | 216 vcm_->EnumerateDevices(); |
| 214 | 217 |
| 215 // Wait to get device callback. | 218 // Wait to get device callback. |
| 216 message_loop_->RunAllPending(); | 219 message_loop_->RunAllPending(); |
| 217 | 220 |
| 218 media_stream::MediaStreamType stream_type = | 221 media_stream::MediaStreamType stream_type = |
| 219 content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE; | 222 content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE; |
| 220 std::string device_name("device_doesnt_exist"); | 223 std::string device_name("device_doesnt_exist"); |
| 221 std::string device_id("id_doesnt_exist"); | 224 std::string device_id("id_doesnt_exist"); |
| 222 media_stream::StreamDeviceInfo dummy_device(stream_type, device_name, | 225 media_stream::StreamDeviceInfo dummy_device(stream_type, device_name, |
| 223 device_id, false); | 226 device_id, false); |
| 224 | 227 |
| 225 // This should fail with error code 'kDeviceNotAvailable'. | 228 // This should fail with error code 'kDeviceNotAvailable'. |
| 226 vcm_->Open(dummy_device); | 229 vcm_->Open(dummy_device); |
| 227 | 230 |
| 228 // Wait to check callbacks before removing the listener. | 231 // Wait to check callbacks before removing the listener. |
| 229 message_loop_->RunAllPending(); | 232 message_loop_->RunAllPending(); |
| 230 vcm_->Unregister(); | 233 vcm_->Unregister(); |
| 231 } | 234 } |
| 232 | 235 |
| 233 // Start a device using "magic" id, i.e. call Start without calling Open. | 236 // Start a device using "magic" id, i.e. call Start without calling Open. |
| 234 TEST_F(VideoCaptureManagerTest, StartUsingId) { | 237 TEST_F(VideoCaptureManagerTest, StartUsingId) { |
| 235 InSequence s; | 238 InSequence s; |
| 236 EXPECT_CALL(*listener_, | 239 EXPECT_CALL(*listener_, |
| 237 Opened(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 240 Opened(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 238 .Times(1); | 241 .Times(1); |
| 239 EXPECT_CALL(*listener_, | 242 EXPECT_CALL(*listener_, |
| 240 Closed(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 243 Closed(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 241 .Times(1); | 244 .Times(1); |
| 242 | 245 |
| 243 media::VideoCaptureParams capture_params; | 246 media::VideoCaptureParams capture_params; |
| 244 capture_params.session_id = | 247 capture_params.session_id = |
| 245 media_stream::VideoCaptureManager::kStartOpenSessionId; | 248 media_stream::VideoCaptureManager::kStartOpenSessionId; |
| 246 capture_params.width = 320; | 249 capture_params.width = 320; |
| 247 capture_params.height = 240; | 250 capture_params.height = 240; |
| 248 capture_params.frame_per_second = 30; | 251 capture_params.frame_per_second = 30; |
| 249 | 252 |
| 250 // Start shall trigger the Open callback. | 253 // Start shall trigger the Open callback. |
| 251 vcm_->Start(capture_params, frame_observer_.get()); | 254 vcm_->Start(capture_params, frame_observer_.get()); |
| 252 | 255 |
| 253 // Stop shall trigger the Close callback | 256 // Stop shall trigger the Close callback |
| 254 vcm_->Stop(media_stream::VideoCaptureManager::kStartOpenSessionId, | 257 vcm_->Stop(media_stream::VideoCaptureManager::kStartOpenSessionId, |
| 255 base::Closure()); | 258 base::Closure()); |
| 256 | 259 |
| 257 // Wait to check callbacks before removing the listener. | 260 // Wait to check callbacks before removing the listener. |
| 258 message_loop_->RunAllPending(); | 261 message_loop_->RunAllPending(); |
| 259 vcm_->Unregister(); | 262 vcm_->Unregister(); |
| 260 } | 263 } |
| 261 | 264 |
| 262 // Open and start a device, close it before calling Stop. | 265 // Open and start a device, close it before calling Stop. |
| 263 TEST_F(VideoCaptureManagerTest, CloseWithoutStop) { | 266 TEST_F(VideoCaptureManagerTest, CloseWithoutStop) { |
| 264 InSequence s; | 267 InSequence s; |
| 265 EXPECT_CALL(*listener_, DevicesEnumerated(_)) | 268 EXPECT_CALL(*listener_, DevicesEnumerated(_)) |
| 266 .Times(1); | 269 .Times(1); |
| 267 EXPECT_CALL(*listener_, | 270 EXPECT_CALL(*listener_, |
| 268 Opened(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 271 Opened(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 269 .Times(1); | 272 .Times(1); |
| 270 EXPECT_CALL(*listener_, | 273 EXPECT_CALL(*listener_, |
| 271 Closed(content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE, _)) | 274 Closed(content::MEDIA_STREAM_DEVICE_TYPE_USER_VIDEO_CAPTURE, _)) |
| 272 .Times(1); | 275 .Times(1); |
| 273 | 276 |
| 274 vcm_->EnumerateDevices(); | 277 vcm_->EnumerateDevices(); |
| 275 | 278 |
| 276 // Wait to get device callback. | 279 // Wait to get device callback. |
| 277 message_loop_->RunAllPending(); | 280 message_loop_->RunAllPending(); |
| 278 | 281 |
| 279 int video_session_id = vcm_->Open(listener_->devices_.front()); | 282 int video_session_id = vcm_->Open(listener_->devices_.front()); |
| 280 | 283 |
| 281 media::VideoCaptureParams capture_params; | 284 media::VideoCaptureParams capture_params; |
| 282 capture_params.session_id = video_session_id; | 285 capture_params.session_id = video_session_id; |
| 283 capture_params.width = 320; | 286 capture_params.width = 320; |
| 284 capture_params.height = 240; | 287 capture_params.height = 240; |
| 285 capture_params.frame_per_second = 30; | 288 capture_params.frame_per_second = 30; |
| 286 vcm_->Start(capture_params, frame_observer_.get()); | 289 vcm_->Start(capture_params, frame_observer_.get()); |
| 287 | 290 |
| 288 // Close will stop the running device, an assert will be triggered in | 291 // Close will stop the running device, an assert will be triggered in |
| 289 // VideoCaptureManager destructor otherwise. | 292 // VideoCaptureManager destructor otherwise. |
| 290 vcm_->Close(video_session_id); | 293 vcm_->Close(video_session_id); |
| 291 vcm_->Stop(video_session_id, base::Closure()); | 294 vcm_->Stop(video_session_id, base::Closure()); |
| 292 | 295 |
| 293 // Wait to check callbacks before removing the listener | 296 // Wait to check callbacks before removing the listener |
| 294 message_loop_->RunAllPending(); | 297 message_loop_->RunAllPending(); |
| 295 vcm_->Unregister(); | 298 vcm_->Unregister(); |
| 296 } | 299 } |
| 297 | 300 |
| 298 } // namespace | 301 } // namespace |
| OLD | NEW |