Index: remoting/protocol/transport_context.cc |
diff --git a/remoting/protocol/transport_context.cc b/remoting/protocol/transport_context.cc |
index b8ed300a111673cfe91b4d0c455b9ea7743e0404..d75e403e26134b4c7f0c05d19d8d21d42a14231c 100644 |
--- a/remoting/protocol/transport_context.cc |
+++ b/remoting/protocol/transport_context.cc |
@@ -11,6 +11,7 @@ |
#include "base/single_thread_task_runner.h" |
#include "base/thread_task_runner_handle.h" |
#include "remoting/base/url_request.h" |
+#include "remoting/protocol/jingle_info_request.h" |
#include "remoting/protocol/port_allocator_factory.h" |
#include "third_party/webrtc/base/socketaddress.h" |
@@ -23,9 +24,6 @@ |
namespace remoting { |
namespace protocol { |
-// Get fresh STUN/Relay configuration every hour. |
-static const int kJingleInfoUpdatePeriodSeconds = 3600; |
- |
#if !defined(OS_NACL) |
// static |
scoped_refptr<TransportContext> TransportContext::ForTests(TransportRole role) { |
@@ -56,21 +54,21 @@ void TransportContext::Prepare() { |
EnsureFreshJingleInfo(); |
} |
-void TransportContext::GetJingleInfo(const GetJingleInfoCallback& callback) { |
+void TransportContext::GetIceConfig(const GetIceConfigCallback& callback) { |
EnsureFreshJingleInfo(); |
- // If there is a pending |jingle_info_request_| delay the callback until the |
+ // If there is a pending |ice_config_request_| delay the callback until the |
// request is finished. |
- if (jingle_info_request_) { |
- pending_jingle_info_callbacks_.push_back(callback); |
+ if (ice_config_request_) { |
+ pending_ice_config_callbacks_.push_back(callback); |
} else { |
- callback.Run(stun_hosts_, relay_hosts_, relay_token_); |
+ callback.Run(ice_config_); |
} |
} |
void TransportContext::EnsureFreshJingleInfo() { |
// Check if request is already pending. |
- if (jingle_info_request_) |
+ if (ice_config_request_) |
return; |
// Don't need to make jingleinfo request if both STUN and Relay are disabled. |
@@ -79,31 +77,21 @@ void TransportContext::EnsureFreshJingleInfo() { |
return; |
} |
- if (last_jingle_info_update_time_.is_null() || |
- base::TimeTicks::Now() - last_jingle_info_update_time_ > |
- base::TimeDelta::FromSeconds(kJingleInfoUpdatePeriodSeconds)) { |
- jingle_info_request_.reset(new JingleInfoRequest(signal_strategy_)); |
- jingle_info_request_->Send(base::Bind( |
- &TransportContext::OnJingleInfo, base::Unretained(this))); |
+ if (ice_config_.is_null() || |
+ base::Time::Now() > ice_config_.expiration_time) { |
+ ice_config_request_.reset(new JingleInfoRequest(signal_strategy_)); |
+ ice_config_request_->Send(base::Bind( |
+ &TransportContext::OnIceConfig, base::Unretained(this))); |
} |
} |
-void TransportContext::OnJingleInfo( |
- const std::string& relay_token, |
- const std::vector<std::string>& relay_hosts, |
- const std::vector<rtc::SocketAddress>& stun_hosts) { |
- relay_token_ = relay_token; |
- relay_hosts_ = relay_hosts; |
- stun_hosts_ = stun_hosts; |
- |
- jingle_info_request_.reset(); |
- if ((!relay_token.empty() && !relay_hosts.empty()) || !stun_hosts.empty()) |
- last_jingle_info_update_time_ = base::TimeTicks::Now(); |
- |
- while (!pending_jingle_info_callbacks_.empty()) { |
- pending_jingle_info_callbacks_.begin()->Run(stun_hosts_, relay_hosts_, |
- relay_token_); |
- pending_jingle_info_callbacks_.pop_front(); |
+void TransportContext::OnIceConfig(const IceConfig& ice_config) { |
+ ice_config_ = ice_config; |
+ ice_config_request_.reset(); |
+ |
+ while (!pending_ice_config_callbacks_.empty()) { |
+ pending_ice_config_callbacks_.begin()->Run(ice_config_); |
+ pending_ice_config_callbacks_.pop_front(); |
} |
} |