OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "shell/application_manager/application_manager.h" | 5 #include "shell/application_manager/application_manager.h" |
6 | 6 |
7 #include <stdio.h> | 7 #include <stdio.h> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/lazy_instance.h" | 10 #include "base/lazy_instance.h" |
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
110 STLDeleteValues(&url_to_shell_impl_); | 110 STLDeleteValues(&url_to_shell_impl_); |
111 } | 111 } |
112 | 112 |
113 void ApplicationManager::ConnectToApplication( | 113 void ApplicationManager::ConnectToApplication( |
114 const GURL& requested_url, | 114 const GURL& requested_url, |
115 const GURL& requestor_url, | 115 const GURL& requestor_url, |
116 InterfaceRequest<ServiceProvider> services, | 116 InterfaceRequest<ServiceProvider> services, |
117 ServiceProviderPtr exposed_services) { | 117 ServiceProviderPtr exposed_services) { |
118 DCHECK(requested_url.is_valid()); | 118 DCHECK(requested_url.is_valid()); |
119 GURL mapped_url = delegate_->ResolveMappings(requested_url); | 119 GURL mapped_url = delegate_->ResolveMappings(requested_url); |
| 120 |
| 121 // We check both the mapped and resolved urls for existing shell_impls because |
| 122 // external applications can be registered for the unresolved mojo:foo urls. |
| 123 ShellImpl* shell_impl = GetShellImpl(mapped_url); |
| 124 if (shell_impl) { |
| 125 ConnectToClient(shell_impl, mapped_url, requestor_url, services.Pass(), |
| 126 exposed_services.Pass()); |
| 127 return; |
| 128 } |
| 129 |
| 130 GURL resolved_url = delegate_->ResolveURL(mapped_url); |
| 131 shell_impl = GetShellImpl(resolved_url); |
| 132 if (shell_impl) { |
| 133 ConnectToClient(shell_impl, resolved_url, requestor_url, services.Pass(), |
| 134 exposed_services.Pass()); |
| 135 return; |
| 136 } |
| 137 |
120 ApplicationLoader* loader = | 138 ApplicationLoader* loader = |
121 GetLoaderForURL(mapped_url, DONT_INCLUDE_DEFAULT_LOADER); | 139 GetLoaderForURL(mapped_url, DONT_INCLUDE_DEFAULT_LOADER); |
122 if (loader) { | 140 if (loader) { |
123 ConnectToApplicationImpl(requested_url, mapped_url, requestor_url, | 141 ConnectToApplicationImpl(requested_url, mapped_url, requestor_url, |
124 services.Pass(), exposed_services.Pass(), loader); | 142 services.Pass(), exposed_services.Pass(), loader); |
125 return; | 143 return; |
126 } | 144 } |
127 | 145 |
128 GURL resolved_url = delegate_->ResolveURL(mapped_url); | |
129 loader = GetLoaderForURL(resolved_url, INCLUDE_DEFAULT_LOADER); | 146 loader = GetLoaderForURL(resolved_url, INCLUDE_DEFAULT_LOADER); |
130 if (loader) { | 147 if (loader) { |
131 ConnectToApplicationImpl(requested_url, resolved_url, requestor_url, | 148 ConnectToApplicationImpl(requested_url, resolved_url, requestor_url, |
132 services.Pass(), exposed_services.Pass(), loader); | 149 services.Pass(), exposed_services.Pass(), loader); |
133 return; | 150 return; |
134 } | 151 } |
135 | 152 |
136 LOG(WARNING) << "Could not find loader to load application: " | 153 LOG(WARNING) << "Could not find loader to load application: " |
137 << requested_url.spec(); | 154 << requested_url.spec(); |
138 } | 155 } |
139 | 156 |
140 void ApplicationManager::ConnectToApplicationImpl( | 157 void ApplicationManager::ConnectToApplicationImpl( |
141 const GURL& requested_url, | 158 const GURL& requested_url, |
142 const GURL& resolved_url, | 159 const GURL& resolved_url, |
143 const GURL& requestor_url, | 160 const GURL& requestor_url, |
144 InterfaceRequest<ServiceProvider> services, | 161 InterfaceRequest<ServiceProvider> services, |
145 ServiceProviderPtr exposed_services, | 162 ServiceProviderPtr exposed_services, |
146 ApplicationLoader* loader) { | 163 ApplicationLoader* loader) { |
147 ShellImpl* shell = nullptr; | 164 MessagePipe pipe; |
148 URLToShellImplMap::const_iterator shell_it = | 165 ShellImpl* shell = |
149 url_to_shell_impl_.find(resolved_url); | 166 new ShellImpl(pipe.handle0.Pass(), this, requested_url, resolved_url); |
150 if (shell_it != url_to_shell_impl_.end()) { | 167 url_to_shell_impl_[resolved_url] = shell; |
151 shell = shell_it->second; | 168 shell->client()->Initialize(GetArgsForURL(requested_url)); |
152 } else { | |
153 MessagePipe pipe; | |
154 shell = | |
155 new ShellImpl(pipe.handle0.Pass(), this, requested_url, resolved_url); | |
156 url_to_shell_impl_[resolved_url] = shell; | |
157 shell->client()->Initialize(GetArgsForURL(requested_url)); | |
158 | 169 |
159 loader->Load(this, resolved_url, pipe.handle1.Pass(), | 170 loader->Load(this, resolved_url, pipe.handle1.Pass(), |
160 base::Bind(&ApplicationManager::LoadWithContentHandler, | 171 base::Bind(&ApplicationManager::LoadWithContentHandler, |
161 weak_ptr_factory_.GetWeakPtr())); | 172 weak_ptr_factory_.GetWeakPtr())); |
162 } | |
163 ConnectToClient(shell, resolved_url, requestor_url, services.Pass(), | 173 ConnectToClient(shell, resolved_url, requestor_url, services.Pass(), |
164 exposed_services.Pass()); | 174 exposed_services.Pass()); |
165 } | 175 } |
166 | 176 |
| 177 ShellImpl* ApplicationManager::GetShellImpl(const GURL& url) { |
| 178 const auto& shell_it = url_to_shell_impl_.find(url); |
| 179 if (shell_it != url_to_shell_impl_.end()) |
| 180 return shell_it->second; |
| 181 return nullptr; |
| 182 } |
| 183 |
167 void ApplicationManager::ConnectToClient( | 184 void ApplicationManager::ConnectToClient( |
168 ShellImpl* shell_impl, | 185 ShellImpl* shell_impl, |
169 const GURL& url, | 186 const GURL& url, |
170 const GURL& requestor_url, | 187 const GURL& requestor_url, |
171 InterfaceRequest<ServiceProvider> services, | 188 InterfaceRequest<ServiceProvider> services, |
172 ServiceProviderPtr exposed_services) { | 189 ServiceProviderPtr exposed_services) { |
173 shell_impl->ConnectToClient(requestor_url, services.Pass(), | 190 shell_impl->ConnectToClient(requestor_url, services.Pass(), |
174 exposed_services.Pass()); | 191 exposed_services.Pass()); |
175 } | 192 } |
176 | 193 |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
271 return pipe.handle0.Pass(); | 288 return pipe.handle0.Pass(); |
272 } | 289 } |
273 | 290 |
274 Array<String> ApplicationManager::GetArgsForURL(const GURL& url) { | 291 Array<String> ApplicationManager::GetArgsForURL(const GURL& url) { |
275 URLToArgsMap::const_iterator args_it = url_to_args_.find(url); | 292 URLToArgsMap::const_iterator args_it = url_to_args_.find(url); |
276 if (args_it != url_to_args_.end()) | 293 if (args_it != url_to_args_.end()) |
277 return Array<String>::From(args_it->second); | 294 return Array<String>::From(args_it->second); |
278 return Array<String>(); | 295 return Array<String>(); |
279 } | 296 } |
280 } // namespace mojo | 297 } // namespace mojo |
OLD | NEW |