Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(47)

Side by Side Diff: remoting/protocol/jingle_session_unittest.cc

Issue 1099203005: Revert of Use standard ICE in Chromoting. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « remoting/protocol/jingle_session.cc ('k') | remoting/protocol/libjingle_transport_factory.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 "remoting/protocol/jingle_session.h" 5 #include "remoting/protocol/jingle_session.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/message_loop/message_loop.h" 8 #include "base/message_loop/message_loop.h"
9 #include "base/run_loop.h" 9 #include "base/run_loop.h"
10 #include "base/test/test_timeouts.h" 10 #include "base/test/test_timeouts.h"
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
98 message_loop_.reset(new base::MessageLoopForIO()); 98 message_loop_.reset(new base::MessageLoopForIO());
99 jingle_glue::JingleThreadWrapper::EnsureForCurrentMessageLoop(); 99 jingle_glue::JingleThreadWrapper::EnsureForCurrentMessageLoop();
100 } 100 }
101 101
102 // Helper method that handles OnIncomingSession(). 102 // Helper method that handles OnIncomingSession().
103 void SetHostSession(Session* session) { 103 void SetHostSession(Session* session) {
104 DCHECK(session); 104 DCHECK(session);
105 host_session_.reset(session); 105 host_session_.reset(session);
106 host_session_->SetEventHandler(&host_session_event_handler_); 106 host_session_->SetEventHandler(&host_session_event_handler_);
107 107
108 session->set_config(standard_ice_ ? SessionConfig::ForTest() 108 session->set_config(SessionConfig::ForTest());
109 : SessionConfig::WithLegacyIceForTest());
110 } 109 }
111 110
112 void DeleteSession() { 111 void DeleteSession() {
113 host_session_.reset(); 112 host_session_.reset();
114 } 113 }
115 114
116 void OnClientChannelCreated(scoped_ptr<net::StreamSocket> socket) { 115 void OnClientChannelCreated(scoped_ptr<net::StreamSocket> socket) {
117 client_channel_callback_.OnDone(socket.get()); 116 client_channel_callback_.OnDone(socket.get());
118 client_socket_ = socket.Pass(); 117 client_socket_ = socket.Pass();
119 } 118 }
(...skipping 27 matching lines...) Expand all
147 client_signal_strategy_.get()); 146 client_signal_strategy_.get());
148 147
149 EXPECT_CALL(host_server_listener_, OnSessionManagerReady()) 148 EXPECT_CALL(host_server_listener_, OnSessionManagerReady())
150 .Times(1); 149 .Times(1);
151 150
152 NetworkSettings network_settings(NetworkSettings::NAT_TRAVERSAL_OUTGOING); 151 NetworkSettings network_settings(NetworkSettings::NAT_TRAVERSAL_OUTGOING);
153 152
154 scoped_ptr<TransportFactory> host_transport(new LibjingleTransportFactory( 153 scoped_ptr<TransportFactory> host_transport(new LibjingleTransportFactory(
155 nullptr, 154 nullptr,
156 ChromiumPortAllocator::Create(nullptr, network_settings).Pass(), 155 ChromiumPortAllocator::Create(nullptr, network_settings).Pass(),
157 network_settings, TransportRole::SERVER)); 156 network_settings));
158 host_server_.reset(new JingleSessionManager(host_transport.Pass())); 157 host_server_.reset(new JingleSessionManager(host_transport.Pass()));
159 host_server_->Init(host_signal_strategy_.get(), &host_server_listener_); 158 host_server_->Init(host_signal_strategy_.get(), &host_server_listener_);
160 159
161 scoped_ptr<AuthenticatorFactory> factory( 160 scoped_ptr<AuthenticatorFactory> factory(
162 new FakeHostAuthenticatorFactory(auth_round_trips, 161 new FakeHostAuthenticatorFactory(auth_round_trips,
163 messages_till_start, auth_action, true)); 162 messages_till_start, auth_action, true));
164 host_server_->set_authenticator_factory(factory.Pass()); 163 host_server_->set_authenticator_factory(factory.Pass());
165 164
166 EXPECT_CALL(client_server_listener_, OnSessionManagerReady()) 165 EXPECT_CALL(client_server_listener_, OnSessionManagerReady())
167 .Times(1); 166 .Times(1);
168 scoped_ptr<TransportFactory> client_transport(new LibjingleTransportFactory( 167 scoped_ptr<TransportFactory> client_transport(new LibjingleTransportFactory(
169 nullptr, 168 nullptr,
170 ChromiumPortAllocator::Create(nullptr, network_settings).Pass(), 169 ChromiumPortAllocator::Create(nullptr, network_settings).Pass(),
171 network_settings, TransportRole::CLIENT)); 170 network_settings));
172 client_server_.reset( 171 client_server_.reset(
173 new JingleSessionManager(client_transport.Pass())); 172 new JingleSessionManager(client_transport.Pass()));
174 client_server_->Init(client_signal_strategy_.get(), 173 client_server_->Init(client_signal_strategy_.get(),
175 &client_server_listener_); 174 &client_server_listener_);
176 } 175 }
177 176
178 void CreateSessionManagers(int auth_round_trips, 177 void CreateSessionManagers(int auth_round_trips,
179 FakeAuthenticator::Action auth_action) { 178 FakeAuthenticator::Action auth_action) {
180 CreateSessionManagers(auth_round_trips, 0, auth_action); 179 CreateSessionManagers(auth_round_trips, 0, auth_action);
181 } 180 }
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after
284 EXPECT_CALL(host_session_event_handler_, 283 EXPECT_CALL(host_session_event_handler_,
285 OnSessionRouteChange(channel_name, _)) 284 OnSessionRouteChange(channel_name, _))
286 .Times(AtLeast(1)); 285 .Times(AtLeast(1));
287 EXPECT_CALL(client_session_event_handler_, 286 EXPECT_CALL(client_session_event_handler_,
288 OnSessionRouteChange(channel_name, _)) 287 OnSessionRouteChange(channel_name, _))
289 .Times(AtLeast(1)); 288 .Times(AtLeast(1));
290 } 289 }
291 290
292 scoped_ptr<base::MessageLoopForIO> message_loop_; 291 scoped_ptr<base::MessageLoopForIO> message_loop_;
293 292
294 bool standard_ice_ = true;
295
296 scoped_ptr<FakeSignalStrategy> host_signal_strategy_; 293 scoped_ptr<FakeSignalStrategy> host_signal_strategy_;
297 scoped_ptr<FakeSignalStrategy> client_signal_strategy_; 294 scoped_ptr<FakeSignalStrategy> client_signal_strategy_;
298 295
299 scoped_ptr<JingleSessionManager> host_server_; 296 scoped_ptr<JingleSessionManager> host_server_;
300 MockSessionManagerListener host_server_listener_; 297 MockSessionManagerListener host_server_listener_;
301 scoped_ptr<JingleSessionManager> client_server_; 298 scoped_ptr<JingleSessionManager> client_server_;
302 MockSessionManagerListener client_server_listener_; 299 MockSessionManagerListener client_server_listener_;
303 300
304 scoped_ptr<Session> host_session_; 301 scoped_ptr<Session> host_session_;
305 MockSessionEventHandler host_session_event_handler_; 302 MockSessionEventHandler host_session_event_handler_;
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
348 // Verify that we can connect two endpoints with single-step authentication. 345 // Verify that we can connect two endpoints with single-step authentication.
349 TEST_F(JingleSessionTest, Connect) { 346 TEST_F(JingleSessionTest, Connect) {
350 CreateSessionManagers(1, FakeAuthenticator::ACCEPT); 347 CreateSessionManagers(1, FakeAuthenticator::ACCEPT);
351 InitiateConnection(1, FakeAuthenticator::ACCEPT, false); 348 InitiateConnection(1, FakeAuthenticator::ACCEPT, false);
352 349
353 // Verify that the client specified correct initiator value. 350 // Verify that the client specified correct initiator value.
354 ASSERT_GT(host_signal_strategy_->received_messages().size(), 0U); 351 ASSERT_GT(host_signal_strategy_->received_messages().size(), 0U);
355 const buzz::XmlElement* initiate_xml = 352 const buzz::XmlElement* initiate_xml =
356 host_signal_strategy_->received_messages().front(); 353 host_signal_strategy_->received_messages().front();
357 const buzz::XmlElement* jingle_element = 354 const buzz::XmlElement* jingle_element =
358 initiate_xml->FirstNamed(buzz::QName("urn:xmpp:jingle:1", "jingle")); 355 initiate_xml->FirstNamed(buzz::QName(kJingleNamespace, "jingle"));
359 ASSERT_TRUE(jingle_element); 356 ASSERT_TRUE(jingle_element);
360 ASSERT_EQ(kClientJid, 357 ASSERT_EQ(kClientJid,
361 jingle_element->Attr(buzz::QName(std::string(), "initiator"))); 358 jingle_element->Attr(buzz::QName(std::string(), "initiator")));
362 } 359 }
363 360
364 // Verify that we can connect two endpoints with multi-step authentication. 361 // Verify that we can connect two endpoints with multi-step authentication.
365 TEST_F(JingleSessionTest, ConnectWithMultistep) { 362 TEST_F(JingleSessionTest, ConnectWithMultistep) {
366 CreateSessionManagers(3, FakeAuthenticator::ACCEPT); 363 CreateSessionManagers(3, FakeAuthenticator::ACCEPT);
367 InitiateConnection(3, FakeAuthenticator::ACCEPT, false); 364 InitiateConnection(3, FakeAuthenticator::ACCEPT, false);
368 } 365 }
369 366
370 // Verify that connection is terminated when single-step auth fails. 367 // Verify that connection is terminated when single-step auth fails.
371 TEST_F(JingleSessionTest, ConnectWithBadAuth) { 368 TEST_F(JingleSessionTest, ConnectWithBadAuth) {
372 CreateSessionManagers(1, FakeAuthenticator::REJECT); 369 CreateSessionManagers(1, FakeAuthenticator::REJECT);
373 InitiateConnection(1, FakeAuthenticator::ACCEPT, true); 370 InitiateConnection(1, FakeAuthenticator::ACCEPT, true);
374 } 371 }
375 372
376 // Verify that connection is terminated when multi-step auth fails. 373 // Verify that connection is terminated when multi-step auth fails.
377 TEST_F(JingleSessionTest, ConnectWithBadMultistepAuth) { 374 TEST_F(JingleSessionTest, ConnectWithBadMultistepAuth) {
378 CreateSessionManagers(3, FakeAuthenticator::REJECT); 375 CreateSessionManagers(3, FakeAuthenticator::REJECT);
379 InitiateConnection(3, FakeAuthenticator::ACCEPT, true); 376 InitiateConnection(3, FakeAuthenticator::ACCEPT, true);
380 } 377 }
381 378
382 // Verify that data can be sent over stream channel. 379 // Verify that data can be sent over stream channel.
383 TEST_F(JingleSessionTest, TestStreamChannel) { 380 TEST_F(JingleSessionTest, TestStreamChannel) {
384 CreateSessionManagers(1, FakeAuthenticator::ACCEPT); 381 CreateSessionManagers(1, FakeAuthenticator::ACCEPT);
385 ASSERT_NO_FATAL_FAILURE( 382 ASSERT_NO_FATAL_FAILURE(
386 InitiateConnection(1, FakeAuthenticator::ACCEPT, false)); 383 InitiateConnection(1, FakeAuthenticator::ACCEPT, false));
387
388 ASSERT_NO_FATAL_FAILURE(CreateChannel());
389
390 StreamConnectionTester tester(host_socket_.get(), client_socket_.get(),
391 kMessageSize, kMessages);
392 tester.Start();
393 message_loop_->Run();
394 tester.CheckResults();
395 }
396
397 // Verify that we can still connect using legacy GICE transport.
398 TEST_F(JingleSessionTest, TestLegacyIceConnection) {
399 standard_ice_ = false;
400
401 CreateSessionManagers(1, FakeAuthenticator::ACCEPT);
402 ASSERT_NO_FATAL_FAILURE(
403 InitiateConnection(1, FakeAuthenticator::ACCEPT, false));
404 384
405 ASSERT_NO_FATAL_FAILURE(CreateChannel()); 385 ASSERT_NO_FATAL_FAILURE(CreateChannel());
406 386
407 StreamConnectionTester tester(host_socket_.get(), client_socket_.get(), 387 StreamConnectionTester tester(host_socket_.get(), client_socket_.get(),
408 kMessageSize, kMessages); 388 kMessageSize, kMessages);
409 tester.Start(); 389 tester.Start();
410 message_loop_->Run(); 390 message_loop_->Run();
411 tester.CheckResults(); 391 tester.CheckResults();
412 } 392 }
413 393
(...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after
566 546
567 StreamConnectionTester tester(host_socket_.get(), client_socket_.get(), 547 StreamConnectionTester tester(host_socket_.get(), client_socket_.get(),
568 kMessageSize, 1); 548 kMessageSize, 1);
569 tester.Start(); 549 tester.Start();
570 message_loop_->Run(); 550 message_loop_->Run();
571 tester.CheckResults(); 551 tester.CheckResults();
572 } 552 }
573 553
574 } // namespace protocol 554 } // namespace protocol
575 } // namespace remoting 555 } // namespace remoting
OLDNEW
« no previous file with comments | « remoting/protocol/jingle_session.cc ('k') | remoting/protocol/libjingle_transport_factory.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698