Chromium Code Reviews| 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/memory/ref_counted.h" | 7 #include "base/memory/ref_counted.h" |
| 8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "content/common/media/media_stream_messages.h" | 10 #include "content/common/media/media_stream_messages.h" |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 83 | 83 |
| 84 DISALLOW_COPY_AND_ASSIGN(MockMediaStreamDispatcherEventHandler); | 84 DISALLOW_COPY_AND_ASSIGN(MockMediaStreamDispatcherEventHandler); |
| 85 }; | 85 }; |
| 86 | 86 |
| 87 } // namespace | 87 } // namespace |
| 88 | 88 |
| 89 TEST(MediaStreamDispatcherTest, BasicStream) { | 89 TEST(MediaStreamDispatcherTest, BasicStream) { |
| 90 scoped_ptr<MediaStreamDispatcher> dispatcher(new MediaStreamDispatcher(NULL)); | 90 scoped_ptr<MediaStreamDispatcher> dispatcher(new MediaStreamDispatcher(NULL)); |
| 91 scoped_ptr<MockMediaStreamDispatcherEventHandler> | 91 scoped_ptr<MockMediaStreamDispatcherEventHandler> |
| 92 handler(new MockMediaStreamDispatcherEventHandler); | 92 handler(new MockMediaStreamDispatcherEventHandler); |
| 93 media_stream::StreamOptions components( | 93 media_stream::StreamOptions components( |
|
scherkus (not reviewing)
2012/04/27 17:52:40
nit: this can fit on one line
| |
| 94 true, media_stream::StreamOptions::kFacingUser); | 94 true, true); |
| 95 std::string security_origin; | 95 std::string security_origin; |
| 96 | 96 |
| 97 int ipc_request_id1 = dispatcher->next_ipc_id_; | 97 int ipc_request_id1 = dispatcher->next_ipc_id_; |
| 98 dispatcher->GenerateStream(kRequestId1, handler.get()->AsWeakPtr(), | 98 dispatcher->GenerateStream(kRequestId1, handler.get()->AsWeakPtr(), |
| 99 components, security_origin); | 99 components, security_origin); |
| 100 int ipc_request_id2 = dispatcher->next_ipc_id_; | 100 int ipc_request_id2 = dispatcher->next_ipc_id_; |
| 101 EXPECT_NE(ipc_request_id1, ipc_request_id2); | 101 EXPECT_NE(ipc_request_id1, ipc_request_id2); |
| 102 dispatcher->GenerateStream(kRequestId2, handler.get()->AsWeakPtr(), | 102 dispatcher->GenerateStream(kRequestId2, handler.get()->AsWeakPtr(), |
| 103 components, security_origin); | 103 components, security_origin); |
| 104 EXPECT_EQ(dispatcher->requests_.size(), size_t(2)); | 104 EXPECT_EQ(dispatcher->requests_.size(), size_t(2)); |
| (...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 246 | 246 |
| 247 // Verify that the request have been completed. | 247 // Verify that the request have been completed. |
| 248 EXPECT_EQ(dispatcher->label_stream_map_.size(), size_t(0)); | 248 EXPECT_EQ(dispatcher->label_stream_map_.size(), size_t(0)); |
| 249 EXPECT_EQ(dispatcher->requests_.size(), size_t(0)); | 249 EXPECT_EQ(dispatcher->requests_.size(), size_t(0)); |
| 250 } | 250 } |
| 251 | 251 |
| 252 TEST(MediaStreamDispatcherTest, TestFailure) { | 252 TEST(MediaStreamDispatcherTest, TestFailure) { |
| 253 scoped_ptr<MediaStreamDispatcher> dispatcher(new MediaStreamDispatcher(NULL)); | 253 scoped_ptr<MediaStreamDispatcher> dispatcher(new MediaStreamDispatcher(NULL)); |
| 254 scoped_ptr<MockMediaStreamDispatcherEventHandler> | 254 scoped_ptr<MockMediaStreamDispatcherEventHandler> |
| 255 handler(new MockMediaStreamDispatcherEventHandler); | 255 handler(new MockMediaStreamDispatcherEventHandler); |
| 256 media_stream::StreamOptions components( | 256 media_stream::StreamOptions components( |
|
scherkus (not reviewing)
2012/04/27 17:52:40
nit: this can fit on one line
| |
| 257 true, media_stream::StreamOptions::kFacingUser); | 257 true, true); |
| 258 std::string security_origin; | 258 std::string security_origin; |
| 259 | 259 |
| 260 // Test failure when creating a stream. | 260 // Test failure when creating a stream. |
| 261 int ipc_request_id1 = dispatcher->next_ipc_id_; | 261 int ipc_request_id1 = dispatcher->next_ipc_id_; |
| 262 dispatcher->GenerateStream(kRequestId1, handler.get()->AsWeakPtr(), | 262 dispatcher->GenerateStream(kRequestId1, handler.get()->AsWeakPtr(), |
| 263 components, security_origin); | 263 components, security_origin); |
| 264 dispatcher->OnMessageReceived(MediaStreamMsg_StreamGenerationFailed( | 264 dispatcher->OnMessageReceived(MediaStreamMsg_StreamGenerationFailed( |
| 265 kRouteId, ipc_request_id1)); | 265 kRouteId, ipc_request_id1)); |
| 266 | 266 |
| 267 // Verify that the request have been completed. | 267 // Verify that the request have been completed. |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 308 | 308 |
| 309 // Test failure of the audio device. | 309 // Test failure of the audio device. |
| 310 dispatcher->OnMessageReceived( | 310 dispatcher->OnMessageReceived( |
| 311 MediaStreamHostMsg_AudioDeviceFailed(kRouteId, stream_label1, 0)); | 311 MediaStreamHostMsg_AudioDeviceFailed(kRouteId, stream_label1, 0)); |
| 312 EXPECT_EQ(handler->audio_failed, true); | 312 EXPECT_EQ(handler->audio_failed, true); |
| 313 | 313 |
| 314 // Stop stream1. | 314 // Stop stream1. |
| 315 dispatcher->StopStream(stream_label1); | 315 dispatcher->StopStream(stream_label1); |
| 316 EXPECT_EQ(dispatcher->label_stream_map_.size(), size_t(0)); | 316 EXPECT_EQ(dispatcher->label_stream_map_.size(), size_t(0)); |
| 317 } | 317 } |
| OLD | NEW |