#include "content/renderer/p2p/port_allocator.h"
-#include "base/bind.h"
-#include "base/command_line.h"
-#include "base/strings/string_number_conversions.h"
-#include "base/strings/string_split.h"
-#include "base/strings/string_util.h"
-#include "content/public/common/content_switches.h"
-#include "net/base/escape.h"
-#include "net/base/ip_endpoint.h"
-#include "third_party/WebKit/public/platform/WebURLError.h"
-#include "third_party/WebKit/public/platform/WebURLLoader.h"
-#include "third_party/WebKit/public/platform/WebURLRequest.h"
-#include "third_party/WebKit/public/platform/WebURLResponse.h"
-#include "third_party/WebKit/public/web/WebFrame.h"
-#include "third_party/WebKit/public/web/WebURLLoaderOptions.h"
-
-using blink::WebString;
-using blink::WebURL;
-using blink::WebURLLoader;
-using blink::WebURLLoaderOptions;
-using blink::WebURLRequest;
-using blink::WebURLResponse;
-
namespace content {
-namespace {
-
-// URL used to create a relay session.
-const char kCreateRelaySessionURL[] = "/create_session";
-
-// Number of times we will try to request relay session.
-const int kRelaySessionRetries = 3;
-
-// Manimum relay server size we would try to parse.
-const int kMaximumRelayResponseSize = 102400;
-
-bool ParsePortNumber(
- const std::string& string, int* value) {
- if (!base::StringToInt(string, value) || *value <= 0 || *value >= 65536) {
- LOG(ERROR) << "Received invalid port number from relay server: " << string;
- return false;
- }
- return true;
-}
-
-} // namespace
-
P2PPortAllocator::Config::Config()
- : legacy_relay(true),
- disable_tcp_transport(false) {
+ : disable_tcp_transport(false) {
}
P2PPortAllocator::Config::~Config() {
}
P2PPortAllocator::P2PPortAllocator(
- blink::WebFrame* web_frame,
P2PSocketDispatcher* socket_dispatcher,
rtc::NetworkManager* network_manager,
rtc::PacketSocketFactory* socket_factory,
const Config& config)
: cricket::BasicPortAllocator(network_manager, socket_factory),
- web_frame_(web_frame),
socket_dispatcher_(socket_dispatcher),
config_(config) {
uint32 flags = 0;
int component,
const std::string& ice_username_fragment,
const std::string& ice_password)
- : cricket::BasicPortAllocatorSession(
- allocator, content_name, component,
- ice_username_fragment, ice_password),
- allocator_(allocator),
- relay_session_attempts_(0),
- relay_udp_port_(0),
- relay_tcp_port_(0),
- relay_ssltcp_port_(0),
- pending_relay_requests_(0) {
+ : cricket::BasicPortAllocatorSession(allocator,
+ content_name,
+ component,
+ ice_username_fragment,
+ ice_password),
+ allocator_(allocator) {
}
P2PPortAllocatorSession::~P2PPortAllocatorSession() {
}
-void P2PPortAllocatorSession::didReceiveData(
- WebURLLoader* loader, const char* data,
- int data_length, int encoded_data_length) {
- DCHECK_EQ(loader, relay_session_request_.get());
- if (static_cast<int>(relay_session_response_.size()) + data_length >
- kMaximumRelayResponseSize) {
- LOG(ERROR) << "Response received from the server is too big.";
- loader->cancel();
- return;
- }
- relay_session_response_.append(data, data + data_length);
-}
-
-void P2PPortAllocatorSession::didFinishLoading(
- WebURLLoader* loader, double finish_time,
- int64_t total_encoded_data_length) {
- ParseRelayResponse();
-}
-
-void P2PPortAllocatorSession::didFail(blink::WebURLLoader* loader,
- const blink::WebURLError& error) {
- DCHECK_EQ(loader, relay_session_request_.get());
- DCHECK_NE(error.reason, 0);
-
- LOG(ERROR) << "Relay session request failed.";
-
- // Retry the request.
- AllocateLegacyRelaySession();
-}
-
void P2PPortAllocatorSession::GetPortConfigurations() {
- if (allocator_->config_.legacy_relay) {
- AllocateLegacyRelaySession();
- }
- AddConfig();
-}
-
-void P2PPortAllocatorSession::AllocateLegacyRelaySession() {
- if (allocator_->config_.relays.empty())
- return;
- // If we are using legacy relay, we will have only one entry in relay server
- // list.
- P2PPortAllocator::Config::RelayServerConfig relay_config =
- allocator_->config_.relays[0];
-
- if (relay_session_attempts_ > kRelaySessionRetries)
- return;
- relay_session_attempts_++;
-
- relay_session_response_.clear();
-
- WebURLLoaderOptions options;
- options.allowCredentials = false;
-
- options.crossOriginRequestPolicy =
- WebURLLoaderOptions::CrossOriginRequestPolicyUseAccessControl;
-
- relay_session_request_.reset(
- allocator_->web_frame_->createAssociatedURLLoader(options));
- if (!relay_session_request_) {
- LOG(ERROR) << "Failed to create URL loader.";
- return;
- }
-
- std::string url = "https://" + relay_config.server_address +
- kCreateRelaySessionURL +
- "?username=" + net::EscapeUrlEncodedData(username(), true) +
- "&password=" + net::EscapeUrlEncodedData(password(), true);
-
- WebURLRequest request;
- request.initialize();
- request.setURL(WebURL(GURL(url)));
- request.setAllowStoredCredentials(false);
- request.setCachePolicy(WebURLRequest::ReloadIgnoringCacheData);
- request.setHTTPMethod("GET");
- request.addHTTPHeaderField(
- WebString::fromUTF8("X-Talk-Google-Relay-Auth"),
- WebString::fromUTF8(relay_config.password));
- request.addHTTPHeaderField(
- WebString::fromUTF8("X-Google-Relay-Auth"),
- WebString::fromUTF8(relay_config.username));
- request.addHTTPHeaderField(WebString::fromUTF8("X-Stream-Type"),
- WebString::fromUTF8("chromoting"));
-
- relay_session_request_->loadAsynchronously(request, this);
-}
-
-void P2PPortAllocatorSession::ParseRelayResponse() {
- base::StringPairs value_pairs;
- if (!base::SplitStringIntoKeyValuePairs(relay_session_response_, '=', '\n',
- &value_pairs)) {
- LOG(ERROR) << "Received invalid response from relay server";
- return;
- }
-
- relay_ip_.Clear();
- relay_udp_port_ = 0;
- relay_tcp_port_ = 0;
- relay_ssltcp_port_ = 0;
-
- for (base::StringPairs::iterator it = value_pairs.begin();
- it != value_pairs.end(); ++it) {
- std::string key;
- std::string value;
- base::TrimWhitespaceASCII(it->first, base::TRIM_ALL, &key);
- base::TrimWhitespaceASCII(it->second, base::TRIM_ALL, &value);
-
- if (key == "username") {
- if (value != username()) {
- LOG(ERROR) << "When creating relay session received user name "
- " that was different from the value specified in the query.";
- return;
- }
- } else if (key == "password") {
- if (value != password()) {
- LOG(ERROR) << "When creating relay session received password "
- "that was different from the value specified in the query.";
- return;
- }
- } else if (key == "relay.ip") {
- relay_ip_.SetIP(value);
- if (relay_ip_.ip() == 0) {
- LOG(ERROR) << "Received unresolved relay server address: " << value;
- return;
- }
- } else if (key == "relay.udp_port") {
- if (!ParsePortNumber(value, &relay_udp_port_))
- return;
- } else if (key == "relay.tcp_port") {
- if (!ParsePortNumber(value, &relay_tcp_port_))
- return;
- } else if (key == "relay.ssltcp_port") {
- if (!ParsePortNumber(value, &relay_ssltcp_port_))
- return;
- }
- }
-
- AddConfig();
-}
-
-void P2PPortAllocatorSession::AddConfig() {
const P2PPortAllocator::Config& config = allocator_->config_;
cricket::PortConfiguration* port_config = new cricket::PortConfiguration(
config.stun_servers, std::string(), std::string());
projects / platform / framework / web / crosswalk.git / blobdiff