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 |