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/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
9 #include "base/utf_string_conversions.h" | 9 #include "base/utf_string_conversions.h" |
10 #include "content/renderer/media/mock_media_stream_dependency_factory.h" | 10 #include "content/renderer/media/mock_media_stream_dependency_factory.h" |
11 #include "content/renderer/media/mock_media_stream_impl.h" | 11 #include "content/renderer/media/mock_media_stream_impl.h" |
12 #include "content/renderer/media/mock_web_peer_connection_handler_client.h" | 12 #include "content/renderer/media/mock_web_peer_connection_handler_client.h" |
13 #include "content/renderer/media/mock_peer_connection_impl.h" | 13 #include "content/renderer/media/mock_peer_connection_impl.h" |
14 #include "content/renderer/media/peer_connection_handler.h" | 14 #include "content/renderer/media/peer_connection_handler.h" |
15 #include "content/renderer/media/rtc_video_decoder.h" | 15 #include "content/renderer/media/rtc_video_decoder.h" |
16 #include "jingle/glue/thread_wrapper.h" | 16 #include "jingle/glue/thread_wrapper.h" |
17 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
18 #include "third_party/libjingle/source/talk/app/webrtcv1/peerconnection.h" | 18 #include "third_party/libjingle/source/talk/app/webrtcv1/peerconnection.h" |
19 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebMediaStre amDescriptor.h" | 19 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebMediaStre amDescriptor.h" |
20 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebMediaStre amSource.h" | 20 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebMediaStre amSource.h" |
21 | 21 |
22 TEST(PeerConnectionHandlerTest, Basic) { | 22 TEST(PeerConnectionHandlerTest, Basic) { |
23 MessageLoop loop; | 23 MessageLoop loop; |
24 | 24 |
25 scoped_ptr<WebKit::MockWebPeerConnectionHandlerClient> mock_client( | 25 scoped_ptr<WebKit::MockWebPeerConnectionHandlerClient> mock_client( |
26 new WebKit::MockWebPeerConnectionHandlerClient()); | 26 new WebKit::MockWebPeerConnectionHandlerClient()); |
27 scoped_refptr<MockMediaStreamImpl> mock_ms_impl(new MockMediaStreamImpl()); | 27 scoped_refptr<MockMediaStreamImpl> mock_ms_impl(new MockMediaStreamImpl()); |
28 scoped_ptr<MockMediaStreamDependencyFactory> mock_dependency_factory( | 28 scoped_ptr<MockMediaStreamDependencyFactory> mock_dependency_factory( |
29 new MockMediaStreamDependencyFactory()); | 29 new MockMediaStreamDependencyFactory()); |
30 mock_dependency_factory->CreatePeerConnectionFactory(NULL, NULL); | 30 mock_dependency_factory->CreatePeerConnectionFactory(NULL, |
31 NULL, | |
32 NULL, | |
33 NULL, | |
34 NULL); | |
31 scoped_ptr<PeerConnectionHandler> pc_handler( | 35 scoped_ptr<PeerConnectionHandler> pc_handler( |
32 new PeerConnectionHandler(mock_client.get(), | 36 new PeerConnectionHandler(mock_client.get(), |
33 mock_ms_impl.get(), | 37 mock_ms_impl.get(), |
34 mock_dependency_factory.get(), | 38 mock_dependency_factory.get())); |
35 NULL, | |
36 NULL, | |
37 NULL, | |
38 NULL)); | |
39 | 39 |
40 WebKit::WebString server_config( | 40 WebKit::WebString server_config( |
41 WebKit::WebString::fromUTF8("STUN stun.l.google.com:19302")); | 41 WebKit::WebString::fromUTF8("STUN stun.l.google.com:19302")); |
42 WebKit::WebSecurityOrigin security_origin; | 42 WebKit::WebSecurityOrigin security_origin; |
43 pc_handler->initialize(server_config, security_origin); | 43 pc_handler->initialize(server_config, security_origin); |
44 EXPECT_TRUE(pc_handler->native_peer_connection_.get()); | 44 EXPECT_TRUE(pc_handler->native_peer_connection_.get()); |
45 webrtc::MockPeerConnectionImpl* mock_peer_connection = | 45 webrtc::MockPeerConnectionImpl* mock_peer_connection = |
46 static_cast<webrtc::MockPeerConnectionImpl*>( | 46 static_cast<webrtc::MockPeerConnectionImpl*>( |
47 pc_handler->native_peer_connection_.get()); | 47 pc_handler->native_peer_connection_.get()); |
48 EXPECT_EQ(static_cast<webrtc::PeerConnectionObserver*>(pc_handler.get()), | |
49 mock_peer_connection->observer()); | |
50 | 48 |
51 std::string label("label"); | 49 std::string label("label"); |
52 WebKit::WebVector<WebKit::WebMediaStreamSource> source_vector( | 50 WebKit::WebVector<WebKit::WebMediaStreamSource> source_vector( |
53 static_cast<size_t>(1)); | 51 static_cast<size_t>(1)); |
54 source_vector[0].initialize(WebKit::WebString::fromUTF8(label), | 52 source_vector[0].initialize(WebKit::WebString::fromUTF8(label), |
55 WebKit::WebMediaStreamSource::TypeVideo, | 53 WebKit::WebMediaStreamSource::TypeVideo, |
56 WebKit::WebString::fromUTF8("RemoteVideo")); | 54 WebKit::WebString::fromUTF8("RemoteVideo")); |
57 WebKit::WebVector<WebKit::WebMediaStreamDescriptor> pendingAddStreams( | 55 WebKit::WebVector<WebKit::WebMediaStreamDescriptor> pendingAddStreams( |
58 static_cast<size_t>(1)); | 56 static_cast<size_t>(1)); |
59 pendingAddStreams[0].initialize(UTF8ToUTF16(label), source_vector); | 57 pendingAddStreams[0].initialize(UTF8ToUTF16(label), source_vector); |
60 pc_handler->produceInitialOffer(pendingAddStreams); | 58 pc_handler->produceInitialOffer(pendingAddStreams); |
61 EXPECT_EQ(label, mock_ms_impl->video_label()); | 59 EXPECT_EQ(label, mock_peer_connection->stream_label()); |
62 EXPECT_EQ(label, mock_peer_connection->stream_id()); | 60 EXPECT_TRUE(mock_peer_connection->stream_changes_committed()); |
63 EXPECT_TRUE(mock_peer_connection->video_stream()); | |
64 EXPECT_TRUE(mock_peer_connection->connected()); | |
65 EXPECT_TRUE(mock_peer_connection->video_capture_set()); | |
66 | 61 |
67 std::string message("message1"); | 62 std::string message("message1"); |
68 pc_handler->handleInitialOffer(WebKit::WebString::fromUTF8(message)); | 63 pc_handler->handleInitialOffer(WebKit::WebString::fromUTF8(message)); |
69 EXPECT_EQ(message, mock_peer_connection->signaling_message()); | 64 EXPECT_EQ(message, mock_peer_connection->signaling_message()); |
70 | 65 |
71 message = "message2"; | 66 message = "message2"; |
72 pc_handler->processSDP(WebKit::WebString::fromUTF8(message)); | 67 pc_handler->processSDP(WebKit::WebString::fromUTF8(message)); |
73 EXPECT_EQ(message, mock_peer_connection->signaling_message()); | 68 EXPECT_EQ(message, mock_peer_connection->signaling_message()); |
74 | 69 |
75 message = "message3"; | 70 message = "message3"; |
76 pc_handler->OnSignalingMessage(message); | 71 pc_handler->OnSignalingMessage(message); |
77 EXPECT_EQ(message, mock_client->sdp()); | 72 EXPECT_EQ(message, mock_client->sdp()); |
78 | 73 |
79 std::string remote_label(label); | 74 std::string remote_label(label); |
80 remote_label.append("-remote"); | 75 remote_label += "-remote"; |
81 pc_handler->OnAddStream(remote_label, true); | 76 talk_base::scoped_refptr<webrtc::LocalMediaStreamInterface> remote_stream( |
77 mock_dependency_factory->CreateLocalMediaStream(remote_label)); | |
78 pc_handler->OnAddStream(remote_stream); | |
82 EXPECT_EQ(remote_label, mock_client->stream_label()); | 79 EXPECT_EQ(remote_label, mock_client->stream_label()); |
83 | 80 |
84 scoped_refptr<RTCVideoDecoder> rtc_video_decoder( | 81 // TODO(grunell): BEFORE COMMIT. Rewrite tests below. |
85 new RTCVideoDecoder(&loop, "")); | |
86 pc_handler->SetVideoRenderer(label, rtc_video_decoder.get()); | |
87 EXPECT_EQ(label, mock_peer_connection->video_renderer_stream_id()); | |
88 | 82 |
89 pc_handler->OnRemoveStream(remote_label, true); | 83 // TODO(grunell): BEFORE COMMIT. Need an object? |
84 pc_handler->SetVideoRenderer(remote_label, NULL); | |
85 // TODO(grunell): BEFORE COMMIT. Check the track instead. | |
86 // EXPECT_EQ(label, mock_peer_connection->video_renderer_stream_id()); | |
tommi (sloooow) - chröme
2012/01/24 15:18:56
remove or fix indent
Henrik Grunell
2012/01/26 13:03:16
Done.
| |
87 | |
88 pc_handler->OnRemoveStream(remote_stream); | |
90 EXPECT_TRUE(mock_client->stream_label().empty()); | 89 EXPECT_TRUE(mock_client->stream_label().empty()); |
91 | 90 |
92 pc_handler->stop(); | 91 pc_handler->stop(); |
93 EXPECT_FALSE(pc_handler->native_peer_connection_.get()); | 92 EXPECT_FALSE(pc_handler->native_peer_connection_.get()); |
94 // PC handler is expected to be deleted when stop calls | 93 // PC handler is expected to be deleted when stop calls |
95 // MediaStreamImpl::ClosePeerConnection. We own and delete it here instead of | 94 // MediaStreamImpl::ClosePeerConnection. We own and delete it here instead of |
96 // in the mock. | 95 // in the mock. |
97 pc_handler.reset(); | 96 pc_handler.reset(); |
98 | 97 |
98 // TODO(grunell): BEFORE COMMIT. Move processPendingStreams test up before | |
99 // stop. | |
100 | |
99 // processPendingStreams must be tested on a new PC handler since removing | 101 // processPendingStreams must be tested on a new PC handler since removing |
100 // streams is currently not supported. | 102 // streams is currently not supported. |
101 pc_handler.reset(new PeerConnectionHandler(mock_client.get(), | 103 pc_handler.reset(new PeerConnectionHandler(mock_client.get(), |
102 mock_ms_impl.get(), | 104 mock_ms_impl.get(), |
103 mock_dependency_factory.get(), | 105 mock_dependency_factory.get())); |
104 NULL, | |
105 NULL, | |
106 NULL, | |
107 NULL)); | |
108 pc_handler->initialize(server_config, security_origin); | 106 pc_handler->initialize(server_config, security_origin); |
109 EXPECT_TRUE(pc_handler->native_peer_connection_.get()); | 107 EXPECT_TRUE(pc_handler->native_peer_connection_.get()); |
110 mock_peer_connection = static_cast<webrtc::MockPeerConnectionImpl*>( | 108 mock_peer_connection = static_cast<webrtc::MockPeerConnectionImpl*>( |
111 pc_handler->native_peer_connection_.get()); | 109 pc_handler->native_peer_connection_.get()); |
112 | 110 |
113 WebKit::WebVector<WebKit::WebMediaStreamDescriptor> pendingRemoveStreams( | 111 WebKit::WebVector<WebKit::WebMediaStreamDescriptor> pendingRemoveStreams( |
114 static_cast<size_t>(0)); | 112 static_cast<size_t>(0)); |
115 pc_handler->processPendingStreams(pendingAddStreams, pendingRemoveStreams); | 113 pc_handler->processPendingStreams(pendingAddStreams, pendingRemoveStreams); |
116 EXPECT_EQ(label, mock_ms_impl->video_label()); | 114 EXPECT_EQ(label, mock_peer_connection->stream_label()); |
117 EXPECT_EQ(label, mock_peer_connection->stream_id()); | 115 EXPECT_TRUE(mock_peer_connection->stream_changes_committed()); |
118 EXPECT_TRUE(mock_peer_connection->video_stream()); | |
119 EXPECT_TRUE(mock_peer_connection->connected()); | |
120 EXPECT_TRUE(mock_peer_connection->video_capture_set()); | |
121 | 116 |
122 pc_handler->stop(); | 117 pc_handler->stop(); |
123 pc_handler.reset(); | 118 pc_handler.reset(); |
124 } | 119 } |
OLD | NEW |