Index: chrome/browser/local_discovery/privet_http_asynchronous_factory_impl.cc |
diff --git a/chrome/browser/local_discovery/privet_http_asynchronous_factory_impl.cc b/chrome/browser/local_discovery/privet_http_asynchronous_factory_impl.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..80d207c99e675ab41be33a55e201fa9e403ba39c |
--- /dev/null |
+++ b/chrome/browser/local_discovery/privet_http_asynchronous_factory_impl.cc |
@@ -0,0 +1,105 @@ |
+// Copyright 2014 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "chrome/browser/local_discovery/privet_http_asynchronous_factory_impl.h" |
+ |
+#include "base/bind.h" |
+#include "base/command_line.h" |
+#include "base/strings/stringprintf.h" |
+#include "chrome/browser/local_discovery/privet_http_impl.h" |
+#include "chrome/common/chrome_switches.h" |
+ |
+namespace local_discovery { |
+ |
+namespace { |
+ |
+std::string IPAddressToHostString(const net::IPAddressNumber& address) { |
+ std::string address_str = net::IPAddressToString(address); |
+ |
+ // IPv6 addresses need to be surrounded by brackets. |
+ if (address.size() == net::kIPv6AddressSize) { |
+ address_str = base::StringPrintf("[%s]", address_str.c_str()); |
+ } |
+ |
+ return address_str; |
+} |
+ |
+} // namespace |
+ |
+PrivetHTTPAsynchronousFactoryImpl::PrivetHTTPAsynchronousFactoryImpl( |
+ ServiceDiscoveryClient* service_discovery_client, |
+ net::URLRequestContextGetter* request_context) |
+ : service_discovery_client_(service_discovery_client), |
+ request_context_(request_context) {} |
+ |
+PrivetHTTPAsynchronousFactoryImpl::~PrivetHTTPAsynchronousFactoryImpl() {} |
+ |
+scoped_ptr<PrivetHTTPResolution> |
+PrivetHTTPAsynchronousFactoryImpl::CreatePrivetHTTP( |
+ const std::string& name, |
+ const net::HostPortPair& address, |
+ const ResultCallback& callback) { |
+ return scoped_ptr<PrivetHTTPResolution>( |
+ new ResolutionImpl(name, |
+ address, |
+ callback, |
+ service_discovery_client_, |
+ request_context_.get())); |
+} |
+ |
+PrivetHTTPAsynchronousFactoryImpl::ResolutionImpl::ResolutionImpl( |
+ const std::string& name, |
+ const net::HostPortPair& address, |
+ const ResultCallback& callback, |
+ ServiceDiscoveryClient* service_discovery_client, |
+ net::URLRequestContextGetter* request_context) |
+ : name_(name), |
+ hostport_(address), |
+ callback_(callback), |
+ request_context_(request_context) { |
+ net::AddressFamily address_family = net::ADDRESS_FAMILY_UNSPECIFIED; |
+ |
+ if (CommandLine::ForCurrentProcess()->HasSwitch(switches::kPrivetIPv6Only)) { |
+ address_family = net::ADDRESS_FAMILY_IPV6; |
+ } |
+ |
+ resolver_ = service_discovery_client->CreateLocalDomainResolver( |
+ address.host(), |
+ address_family, |
+ base::Bind(&ResolutionImpl::ResolveComplete, base::Unretained(this))); |
+} |
+ |
+PrivetHTTPAsynchronousFactoryImpl::ResolutionImpl::~ResolutionImpl() {} |
+ |
+void PrivetHTTPAsynchronousFactoryImpl::ResolutionImpl::Start() { |
+ resolver_->Start(); |
+} |
+ |
+const std::string& |
+PrivetHTTPAsynchronousFactoryImpl::ResolutionImpl::GetName() { |
+ return name_; |
+} |
+ |
+void PrivetHTTPAsynchronousFactoryImpl::ResolutionImpl::ResolveComplete( |
+ bool success, |
+ const net::IPAddressNumber& address_ipv4, |
+ const net::IPAddressNumber& address_ipv6) { |
+ if (!success) { |
+ callback_.Run(scoped_ptr<PrivetHTTPClient>()); |
+ return; |
+ } |
+ |
+ net::IPAddressNumber address = address_ipv4; |
+ if (address.empty()) |
+ address = address_ipv6; |
+ |
+ DCHECK(!address.empty()); |
+ |
+ net::HostPortPair new_address = |
+ net::HostPortPair(IPAddressToHostString(address), hostport_.port()); |
+ callback_.Run(scoped_ptr<PrivetHTTPClient>( |
+ new PrivetHTTPClientImpl(name_, new_address, request_context_.get()))); |
+} |
+ |
+} // namespace local_discovery |