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

Side by Side Diff: trunk/src/remoting/protocol/libjingle_transport_factory.cc

Issue 268483003: Revert 267234 "New policies: enable/disable relay; port range" (Closed) Base URL: svn://svn.chromium.org/chrome/
Patch Set: Created 6 years, 7 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 | Annotate | Revision Log
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/libjingle_transport_factory.h" 5 #include "remoting/protocol/libjingle_transport_factory.h"
6 6
7 #include "base/callback.h" 7 #include "base/callback.h"
8 #include "base/single_thread_task_runner.h" 8 #include "base/single_thread_task_runner.h"
9 #include "base/thread_task_runner_handle.h" 9 #include "base/thread_task_runner_handle.h"
10 #include "base/timer/timer.h" 10 #include "base/timer/timer.h"
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after
198 channel_->SetIceProtocolType(cricket::ICEPROTO_GOOGLE); 198 channel_->SetIceProtocolType(cricket::ICEPROTO_GOOGLE);
199 channel_->SetIceCredentials(ice_username_fragment_, ice_password_); 199 channel_->SetIceCredentials(ice_username_fragment_, ice_password_);
200 channel_->SignalRequestSignaling.connect( 200 channel_->SignalRequestSignaling.connect(
201 this, &LibjingleStreamTransport::OnRequestSignaling); 201 this, &LibjingleStreamTransport::OnRequestSignaling);
202 channel_->SignalCandidateReady.connect( 202 channel_->SignalCandidateReady.connect(
203 this, &LibjingleStreamTransport::OnCandidateReady); 203 this, &LibjingleStreamTransport::OnCandidateReady);
204 channel_->SignalRouteChange.connect( 204 channel_->SignalRouteChange.connect(
205 this, &LibjingleStreamTransport::OnRouteChange); 205 this, &LibjingleStreamTransport::OnRouteChange);
206 channel_->SignalWritableState.connect( 206 channel_->SignalWritableState.connect(
207 this, &LibjingleStreamTransport::OnWritableState); 207 this, &LibjingleStreamTransport::OnWritableState);
208 channel_->set_incoming_only( 208 if (network_settings_.nat_traversal_mode ==
209 !(network_settings_.flags & NetworkSettings::NAT_TRAVERSAL_OUTGOING)); 209 NetworkSettings::NAT_TRAVERSAL_DISABLED) {
210 channel_->set_incoming_only(true);
211 }
210 212
211 channel_->Connect(); 213 channel_->Connect();
212 214
213 --connect_attempts_left_; 215 --connect_attempts_left_;
214 216
215 // Start reconnection timer. 217 // Start reconnection timer.
216 reconnect_timer_.Start( 218 reconnect_timer_.Start(
217 FROM_HERE, base::TimeDelta::FromSeconds(kReconnectDelaySeconds), 219 FROM_HERE, base::TimeDelta::FromSeconds(kReconnectDelaySeconds),
218 this, &LibjingleStreamTransport::TryReconnect); 220 this, &LibjingleStreamTransport::TryReconnect);
219 221
(...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after
443 return result.PassAs<StreamTransport>(); 445 return result.PassAs<StreamTransport>();
444 } 446 }
445 447
446 scoped_ptr<DatagramTransport> 448 scoped_ptr<DatagramTransport>
447 LibjingleTransportFactory::CreateDatagramTransport() { 449 LibjingleTransportFactory::CreateDatagramTransport() {
448 NOTIMPLEMENTED(); 450 NOTIMPLEMENTED();
449 return scoped_ptr<DatagramTransport>(); 451 return scoped_ptr<DatagramTransport>();
450 } 452 }
451 453
452 void LibjingleTransportFactory::EnsureFreshJingleInfo() { 454 void LibjingleTransportFactory::EnsureFreshJingleInfo() {
453 uint32 stun_or_relay_flags = NetworkSettings::NAT_TRAVERSAL_STUN | 455 if (network_settings_.nat_traversal_mode !=
454 NetworkSettings::NAT_TRAVERSAL_RELAY; 456 NetworkSettings::NAT_TRAVERSAL_ENABLED ||
455 if (!(network_settings_.flags & stun_or_relay_flags) ||
456 jingle_info_request_) { 457 jingle_info_request_) {
457 return; 458 return;
458 } 459 }
459 460
460 if (base::TimeTicks::Now() - last_jingle_info_update_time_ > 461 if (base::TimeTicks::Now() - last_jingle_info_update_time_ >
461 base::TimeDelta::FromSeconds(kJingleInfoUpdatePeriodSeconds)) { 462 base::TimeDelta::FromSeconds(kJingleInfoUpdatePeriodSeconds)) {
462 jingle_info_request_.reset(new JingleInfoRequest(signal_strategy_)); 463 jingle_info_request_.reset(new JingleInfoRequest(signal_strategy_));
463 jingle_info_request_->Send(base::Bind( 464 jingle_info_request_->Send(base::Bind(
464 &LibjingleTransportFactory::OnJingleInfo, base::Unretained(this))); 465 &LibjingleTransportFactory::OnJingleInfo, base::Unretained(this)));
465 } 466 }
(...skipping 16 matching lines...) Expand all
482 last_jingle_info_update_time_ = base::TimeTicks::Now(); 483 last_jingle_info_update_time_ = base::TimeTicks::Now();
483 484
484 while (!on_jingle_info_callbacks_.empty()) { 485 while (!on_jingle_info_callbacks_.empty()) {
485 on_jingle_info_callbacks_.begin()->Run(); 486 on_jingle_info_callbacks_.begin()->Run();
486 on_jingle_info_callbacks_.pop_front(); 487 on_jingle_info_callbacks_.pop_front();
487 } 488 }
488 } 489 }
489 490
490 } // namespace protocol 491 } // namespace protocol
491 } // namespace remoting 492 } // namespace remoting
OLDNEW
« no previous file with comments | « trunk/src/remoting/jingle_glue/network_settings_unittest.cc ('k') | trunk/src/remoting/remoting_srcs.gypi » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698