Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(85)

Side by Side Diff: mojo/shell/application_manager.cc

Issue 1346143004: Don't use resolved url for instance identity in ApplicationManager (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: . Created 5 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « mojo/shell/application_manager.h ('k') | mojo/shell/application_manager_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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(&params)) 82 if (ConnectToRunningApplication(&params))
88 return; 83 return;
89 84
90 GURL resolved_url = package_manager_->ResolveURL(original_url);
91 params->SetURLInfo(resolved_url);
92 if (ConnectToRunningApplication(&params))
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(&params, 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(&params)); 97 weak_ptr_factory_.GetWeakPtr(), base::Passed(&params));
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
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(&params)) 169 if (ConnectToRunningApplication(&params))
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
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
OLDNEW
« no previous file with comments | « mojo/shell/application_manager.h ('k') | mojo/shell/application_manager_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698