Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "chrome/browser/net/utility_process_mojo_proxy_resolver_factory.h" | |
| 6 | |
| 7 #include "base/logging.h" | |
| 8 #include "base/memory/singleton.h" | |
| 9 #include "content/public/browser/browser_thread.h" | |
| 10 #include "content/public/browser/utility_process_host.h" | |
| 11 #include "content/public/browser/utility_process_host_client.h" | |
| 12 #include "content/public/common/service_registry.h" | |
| 13 #include "net/proxy/mojo_proxy_resolver_factory.h" | |
| 14 | |
| 15 namespace chrome_browser_net { | |
| 16 | |
| 17 // static | |
| 18 UtilityProcessMojoProxyResolverFactory* | |
| 19 UtilityProcessMojoProxyResolverFactory::GetInstance() { | |
| 20 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | |
| 21 return Singleton< | |
| 22 UtilityProcessMojoProxyResolverFactory, | |
| 23 LeakySingletonTraits<UtilityProcessMojoProxyResolverFactory>>::get(); | |
| 24 } | |
| 25 | |
| 26 UtilityProcessMojoProxyResolverFactory:: | |
| 27 UtilityProcessMojoProxyResolverFactory() { | |
| 28 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | |
| 29 } | |
| 30 | |
| 31 UtilityProcessMojoProxyResolverFactory:: | |
| 32 ~UtilityProcessMojoProxyResolverFactory() { | |
| 33 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | |
| 34 } | |
| 35 | |
| 36 void UtilityProcessMojoProxyResolverFactory::CreateProcessAndConnect() { | |
| 37 DVLOG(1) << "Attempting to create utility process for proxy resolver"; | |
| 38 content::UtilityProcessHost* utility_process_host = | |
| 39 content::UtilityProcessHost::Create( | |
|
eroman
2015/03/06 05:48:21
What is the lifetime of this process? It seems lik
Anand Mistry (off Chromium)
2015/03/10 07:24:23
Yes, for now. For other Mojo services, I'm plannin
eroman
2015/03/11 18:48:35
One way we could solve this is to make ProxyServic
| |
| 40 scoped_refptr<content::UtilityProcessHostClient>(), | |
| 41 base::MessageLoopProxy::current().get()); | |
| 42 bool process_started = utility_process_host->StartMojoMode(); | |
| 43 if (process_started) { | |
| 44 content::ServiceRegistry* service_registry = | |
| 45 utility_process_host->GetServiceRegistry(); | |
| 46 service_registry->ConnectToRemoteService(&resolver_factory_); | |
| 47 resolver_factory_.set_error_handler(this); | |
| 48 } else { | |
| 49 LOG(ERROR) << "Unable to connect to utility process"; | |
| 50 } | |
| 51 } | |
| 52 | |
| 53 void UtilityProcessMojoProxyResolverFactory::Create( | |
| 54 mojo::InterfaceRequest<net::interfaces::ProxyResolver> req, | |
| 55 net::interfaces::HostResolverPtr host_resolver) { | |
| 56 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | |
| 57 if (!resolver_factory_) | |
| 58 CreateProcessAndConnect(); | |
| 59 | |
| 60 if (!resolver_factory_) { | |
| 61 // If there's still no factory, then utility process creation failed so | |
| 62 // close |req|'s message pipe, which should cause a connection error. | |
| 63 req = nullptr; | |
| 64 return; | |
| 65 } | |
| 66 resolver_factory_->CreateResolver(req.Pass(), host_resolver.Pass()); | |
| 67 } | |
| 68 | |
| 69 void UtilityProcessMojoProxyResolverFactory::OnConnectionError() { | |
| 70 DVLOG(1) << "Disconnection from utility process detected"; | |
| 71 resolver_factory_.reset(); | |
| 72 } | |
| 73 | |
| 74 } // namespace chrome_browser_net | |
| OLD | NEW |