Chromium Code Reviews| 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 "mojo/shell/application_manager.h" | 5 #include "mojo/shell/application_manager.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 66 TerminateShellConnections(); | 66 TerminateShellConnections(); |
| 67 STLDeleteValues(&url_to_loader_); | 67 STLDeleteValues(&url_to_loader_); |
| 68 } | 68 } |
| 69 | 69 |
| 70 void ApplicationManager::TerminateShellConnections() { | 70 void ApplicationManager::TerminateShellConnections() { |
| 71 STLDeleteValues(&identity_to_instance_); | 71 STLDeleteValues(&identity_to_instance_); |
| 72 } | 72 } |
| 73 | 73 |
| 74 void ApplicationManager::ConnectToApplication( | 74 void ApplicationManager::ConnectToApplication( |
| 75 scoped_ptr<ConnectToApplicationParams> params) { | 75 scoped_ptr<ConnectToApplicationParams> params) { |
| 76 GURL original_url = params->app_url(); | |
| 77 URLRequestPtr original_url_request = params->TakeAppURLRequest(); | |
| 78 | |
| 79 TRACE_EVENT_INSTANT1("mojo_shell", "ApplicationManager::ConnectToApplication", | 76 TRACE_EVENT_INSTANT1("mojo_shell", "ApplicationManager::ConnectToApplication", |
| 80 TRACE_EVENT_SCOPE_THREAD, "original_url", | 77 TRACE_EVENT_SCOPE_THREAD, "original_url", |
| 81 original_url.spec()); | 78 params->app_url().spec()); |
| 82 DCHECK(original_url.is_valid()); | 79 DCHECK(params->app_url().is_valid()); |
| 83 DCHECK(original_url_request); | |
| 84 | 80 |
| 85 // We need to look for running instances based on both the unresolved and | 81 // Connect to an existing matching instance, if possible. |
| 86 // resolved urls. | |
| 87 if (ConnectToRunningApplication(¶ms)) | 82 if (ConnectToRunningApplication(¶ms)) |
| 88 return; | 83 return; |
| 89 | 84 |
| 90 GURL resolved_url = package_manager_->ResolveURL(original_url); | |
| 91 params->SetURLInfo(resolved_url); | |
| 92 if (ConnectToRunningApplication(¶ms)) | |
| 93 return; | |
| 94 | |
| 95 // The application is not running, let's compute the parameters. | |
| 96 // NOTE: Set URL info using |original_url_request| instead of |original_url| | 85 // NOTE: Set URL info using |original_url_request| instead of |original_url| |
|
yzshen1
2015/09/17 22:38:11
Please remove this comment.
| |
| 97 // because it may contain more information (e.g., it is a POST request). | 86 // because it may contain more information (e.g., it is a POST request). |
| 98 params->SetURLInfo(original_url_request.Pass()); | 87 ApplicationLoader* loader = GetLoaderForURL(params->app_url()); |
| 99 ApplicationLoader* loader = GetLoaderForURL(resolved_url); | |
| 100 if (loader) { | 88 if (loader) { |
| 101 ConnectToApplicationWithLoader(¶ms, resolved_url, loader); | 89 GURL url = params->app_url(); |
| 90 loader->Load(url, CreateInstance(params.Pass(), nullptr)); | |
| 102 return; | 91 return; |
| 103 } | 92 } |
| 104 | 93 |
| 105 original_url_request = params->TakeAppURLRequest(); | 94 URLRequestPtr original_url_request = params->TakeAppURLRequest(); |
| 106 auto callback = | 95 auto callback = |
| 107 base::Bind(&ApplicationManager::HandleFetchCallback, | 96 base::Bind(&ApplicationManager::HandleFetchCallback, |
| 108 weak_ptr_factory_.GetWeakPtr(), base::Passed(¶ms)); | 97 weak_ptr_factory_.GetWeakPtr(), base::Passed(¶ms)); |
| 109 package_manager_->FetchRequest(original_url_request.Pass(), callback); | 98 package_manager_->FetchRequest(original_url_request.Pass(), callback); |
| 110 } | 99 } |
| 111 | 100 |
| 112 bool ApplicationManager::ConnectToRunningApplication( | 101 bool ApplicationManager::ConnectToRunningApplication( |
| 113 scoped_ptr<ConnectToApplicationParams>* params) { | 102 scoped_ptr<ConnectToApplicationParams>* params) { |
| 114 ApplicationInstance* instance = GetApplicationInstance( | 103 ApplicationInstance* instance = GetApplicationInstance( |
| 115 Identity((*params)->app_url(), (*params)->qualifier())); | 104 Identity((*params)->app_url(), (*params)->qualifier())); |
| 116 if (!instance) | 105 if (!instance) |
| 117 return false; | 106 return false; |
| 118 | 107 |
| 119 instance->ConnectToClient(params->Pass()); | 108 instance->ConnectToClient(params->Pass()); |
| 120 return true; | 109 return true; |
| 121 } | 110 } |
| 122 | 111 |
| 123 void ApplicationManager::ConnectToApplicationWithLoader( | |
| 124 scoped_ptr<ConnectToApplicationParams>* params, | |
| 125 const GURL& resolved_url, | |
| 126 ApplicationLoader* loader) { | |
| 127 if (!(*params)->app_url().SchemeIs("mojo")) | |
| 128 (*params)->SetURLInfo(resolved_url); | |
| 129 | |
| 130 loader->Load(resolved_url, CreateInstance(params->Pass(), nullptr)); | |
| 131 } | |
| 132 | |
| 133 InterfaceRequest<Application> ApplicationManager::CreateInstance( | 112 InterfaceRequest<Application> ApplicationManager::CreateInstance( |
| 134 scoped_ptr<ConnectToApplicationParams> params, | 113 scoped_ptr<ConnectToApplicationParams> params, |
| 135 ApplicationInstance** resulting_instance) { | 114 ApplicationInstance** resulting_instance) { |
| 136 Identity app_identity(params->app_url(), params->qualifier()); | 115 Identity app_identity(params->app_url(), params->qualifier()); |
| 137 | 116 |
| 138 ApplicationPtr application; | 117 ApplicationPtr application; |
| 139 InterfaceRequest<Application> application_request = GetProxy(&application); | 118 InterfaceRequest<Application> application_request = GetProxy(&application); |
| 140 ApplicationInstance* instance = new ApplicationInstance( | 119 ApplicationInstance* instance = new ApplicationInstance( |
| 141 application.Pass(), this, params->originator_identity(), app_identity, | 120 application.Pass(), this, params->originator_identity(), app_identity, |
| 142 params->filter(), Shell::kInvalidContentHandlerID, | 121 params->filter(), Shell::kInvalidContentHandlerID, |
| 143 params->on_application_end()); | 122 params->on_application_end()); |
| 144 DCHECK(identity_to_instance_.find(app_identity) == | 123 DCHECK(identity_to_instance_.find(app_identity) == |
| 145 identity_to_instance_.end()); | 124 identity_to_instance_.end()); |
| 146 identity_to_instance_[app_identity] = instance; | 125 identity_to_instance_[app_identity] = instance; |
| 147 instance->InitializeApplication(); | 126 instance->InitializeApplication(); |
| 148 instance->ConnectToClient(params.Pass()); | 127 instance->ConnectToClient(params.Pass()); |
| 149 if (resulting_instance) | 128 if (resulting_instance) |
| 150 *resulting_instance = instance; | 129 *resulting_instance = instance; |
| 151 return application_request.Pass(); | 130 return application_request.Pass(); |
| 152 } | 131 } |
| 153 | 132 |
| 154 ApplicationInstance* ApplicationManager::GetApplicationInstance( | 133 ApplicationInstance* ApplicationManager::GetApplicationInstance( |
| 155 const Identity& identity) const { | 134 const Identity& identity) const { |
| 156 const auto& instance_it = identity_to_instance_.find(identity); | 135 const auto& it = identity_to_instance_.find(identity); |
| 157 if (instance_it != identity_to_instance_.end()) | 136 return it != identity_to_instance_.end() ? it->second : nullptr; |
| 158 return instance_it->second; | |
| 159 return nullptr; | |
| 160 } | 137 } |
| 161 | 138 |
| 162 void ApplicationManager::HandleFetchCallback( | 139 void ApplicationManager::HandleFetchCallback( |
| 163 scoped_ptr<ConnectToApplicationParams> params, | 140 scoped_ptr<ConnectToApplicationParams> params, |
| 164 scoped_ptr<Fetcher> fetcher) { | 141 scoped_ptr<Fetcher> fetcher) { |
| 165 if (!fetcher) { | 142 if (!fetcher) { |
| 166 // Network error. Drop |params| to tell the requestor. | 143 // Network error. Drop |params| to tell the requestor. |
| 167 params->connect_callback().Run(Shell::kInvalidContentHandlerID); | 144 params->connect_callback().Run(Shell::kInvalidContentHandlerID); |
| 168 return; | 145 return; |
| 169 } | 146 } |
| (...skipping 10 matching lines...) Expand all Loading... | |
| 180 new_request->headers.push_back(header.Pass()); | 157 new_request->headers.push_back(header.Pass()); |
| 181 params->SetURLInfo(new_request.Pass()); | 158 params->SetURLInfo(new_request.Pass()); |
| 182 ConnectToApplication(params.Pass()); | 159 ConnectToApplication(params.Pass()); |
| 183 return; | 160 return; |
| 184 } | 161 } |
| 185 | 162 |
| 186 // We already checked if the application was running before we fetched it, but | 163 // We already checked if the application was running before we fetched it, but |
| 187 // it might have started while the fetch was outstanding. We don't want to | 164 // it might have started while the fetch was outstanding. We don't want to |
| 188 // have two copies of the app running, so check again. | 165 // have two copies of the app running, so check again. |
| 189 // | 166 // |
| 190 // Also, it's possible the original URL was redirected to an app that is | 167 // Also, it's possible the original URL was redirected to an app that is |
|
yzshen1
2015/09/17 22:38:10
This part of comment could be removed -- the redir
| |
| 191 // already running. | 168 // already running. |
| 192 if (ConnectToRunningApplication(¶ms)) | 169 if (ConnectToRunningApplication(¶ms)) |
| 193 return; | 170 return; |
| 194 | 171 |
| 195 if (params->app_url().scheme() != "mojo") | |
| 196 params->SetURLInfo(fetcher->GetURL()); | |
| 197 | |
| 198 Identity originator_identity = params->originator_identity(); | 172 Identity originator_identity = params->originator_identity(); |
| 199 CapabilityFilter originator_filter = params->originator_filter(); | 173 CapabilityFilter originator_filter = params->originator_filter(); |
| 200 CapabilityFilter filter = params->filter(); | 174 CapabilityFilter filter = params->filter(); |
| 201 GURL app_url = params->app_url(); | 175 GURL app_url = params->app_url(); |
| 202 std::string qualifier = params->qualifier(); | 176 std::string qualifier = params->qualifier(); |
| 203 Shell::ConnectToApplicationCallback connect_callback = | 177 Shell::ConnectToApplicationCallback connect_callback = |
| 204 params->connect_callback(); | 178 params->connect_callback(); |
| 205 params->set_connect_callback(EmptyConnectCallback()); | 179 params->set_connect_callback(EmptyConnectCallback()); |
| 206 ApplicationInstance* app = nullptr; | 180 ApplicationInstance* app = nullptr; |
| 207 InterfaceRequest<Application> request(CreateInstance(params.Pass(), &app)); | 181 InterfaceRequest<Application> request(CreateInstance(params.Pass(), &app)); |
| (...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 341 native_runners_.erase( | 315 native_runners_.erase( |
| 342 std::find(native_runners_.begin(), native_runners_.end(), runner)); | 316 std::find(native_runners_.begin(), native_runners_.end(), runner)); |
| 343 } | 317 } |
| 344 | 318 |
| 345 Shell::ConnectToApplicationCallback EmptyConnectCallback() { | 319 Shell::ConnectToApplicationCallback EmptyConnectCallback() { |
| 346 return base::Bind(&OnEmptyOnConnectCallback); | 320 return base::Bind(&OnEmptyOnConnectCallback); |
| 347 } | 321 } |
| 348 | 322 |
| 349 } // namespace shell | 323 } // namespace shell |
| 350 } // namespace mojo | 324 } // namespace mojo |
| OLD | NEW |