OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 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 "content/browser/mojo/mojo_shell_context.h" | 5 #include "content/browser/mojo/mojo_shell_context.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <string> | 8 #include <string> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
11 #include "base/bind.h" | 11 #include "base/bind.h" |
| 12 #include "base/json/json_reader.h" |
12 #include "base/lazy_instance.h" | 13 #include "base/lazy_instance.h" |
13 #include "base/macros.h" | 14 #include "base/macros.h" |
14 #include "base/memory/ptr_util.h" | 15 #include "base/memory/ptr_util.h" |
15 #include "base/single_thread_task_runner.h" | 16 #include "base/single_thread_task_runner.h" |
16 #include "content/browser/gpu/gpu_process_host.h" | 17 #include "content/browser/gpu/gpu_process_host.h" |
17 #include "content/common/mojo/constants.h" | 18 #include "content/browser/mojo/merge_dictionary.h" |
18 #include "content/common/mojo/mojo_shell_connection_impl.h" | 19 #include "content/common/mojo/mojo_shell_connection_impl.h" |
19 #include "content/grit/content_resources.h" | 20 #include "content/grit/content_resources.h" |
20 #include "content/public/browser/browser_thread.h" | 21 #include "content/public/browser/browser_thread.h" |
21 #include "content/public/browser/content_browser_client.h" | 22 #include "content/public/browser/content_browser_client.h" |
22 #include "content/public/browser/utility_process_host.h" | 23 #include "content/public/browser/utility_process_host.h" |
23 #include "content/public/browser/utility_process_host_client.h" | 24 #include "content/public/browser/utility_process_host_client.h" |
24 #include "content/public/common/content_client.h" | 25 #include "content/public/common/content_client.h" |
25 #include "content/public/common/mojo_shell_connection.h" | 26 #include "content/public/common/mojo_shell_connection.h" |
| 27 #include "content/public/common/service_names.h" |
26 #include "mojo/edk/embedder/embedder.h" | 28 #include "mojo/edk/embedder/embedder.h" |
27 #include "services/catalog/catalog.h" | 29 #include "services/catalog/catalog.h" |
28 #include "services/catalog/manifest_provider.h" | 30 #include "services/catalog/manifest_provider.h" |
29 #include "services/catalog/store.h" | 31 #include "services/catalog/store.h" |
30 #include "services/file/public/cpp/constants.h" | 32 #include "services/file/public/cpp/constants.h" |
31 #include "services/shell/connect_params.h" | 33 #include "services/shell/connect_params.h" |
32 #include "services/shell/native_runner.h" | 34 #include "services/shell/native_runner.h" |
33 #include "services/shell/public/cpp/connector.h" | 35 #include "services/shell/public/cpp/connector.h" |
34 #include "services/shell/public/cpp/service.h" | 36 #include "services/shell/public/cpp/service.h" |
35 #include "services/shell/public/interfaces/service.mojom.h" | 37 #include "services/shell/public/interfaces/service.mojom.h" |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 | 103 |
102 #endif // ENABLE_MOJO_MEDIA_IN_GPU_PROCESS | 104 #endif // ENABLE_MOJO_MEDIA_IN_GPU_PROCESS |
103 | 105 |
104 // A ManifestProvider which resolves application names to builtin manifest | 106 // A ManifestProvider which resolves application names to builtin manifest |
105 // resources for the catalog service to consume. | 107 // resources for the catalog service to consume. |
106 class BuiltinManifestProvider : public catalog::ManifestProvider { | 108 class BuiltinManifestProvider : public catalog::ManifestProvider { |
107 public: | 109 public: |
108 BuiltinManifestProvider() {} | 110 BuiltinManifestProvider() {} |
109 ~BuiltinManifestProvider() override {} | 111 ~BuiltinManifestProvider() override {} |
110 | 112 |
111 void AddManifests(std::unique_ptr< | 113 void AddManifestValue(const std::string& name, |
112 ContentBrowserClient::MojoApplicationManifestMap> manifests) { | 114 std::unique_ptr<base::Value> manifest_contents) { |
113 DCHECK(!manifests_); | 115 auto result = manifests_.insert( |
114 manifests_ = std::move(manifests); | 116 std::make_pair(name, std::move(manifest_contents))); |
115 } | |
116 | |
117 void AddManifestResource(const std::string& name, int resource_id) { | |
118 std::string contents = GetContentClient()->GetDataResource( | |
119 resource_id, ui::ScaleFactor::SCALE_FACTOR_NONE).as_string(); | |
120 DCHECK(!contents.empty()); | |
121 | |
122 DCHECK(manifests_); | |
123 auto result = manifests_->insert(std::make_pair(name, contents)); | |
124 DCHECK(result.second) << "Duplicate manifest entry: " << name; | 117 DCHECK(result.second) << "Duplicate manifest entry: " << name; |
125 } | 118 } |
126 | 119 |
127 private: | 120 private: |
128 // catalog::ManifestProvider: | 121 // catalog::ManifestProvider: |
129 bool GetApplicationManifest(const base::StringPiece& name, | 122 std::unique_ptr<base::Value> GetManifest(const std::string& name) override { |
130 std::string* manifest_contents) override { | 123 auto it = manifests_.find(name); |
131 auto manifest_it = manifests_->find(name.as_string()); | 124 return it != manifests_.end() ? it->second->CreateDeepCopy() : nullptr; |
132 if (manifest_it != manifests_->end()) { | |
133 *manifest_contents = manifest_it->second; | |
134 DCHECK(!manifest_contents->empty()); | |
135 return true; | |
136 } | |
137 return false; | |
138 } | 125 } |
139 | 126 |
140 std::unique_ptr<ContentBrowserClient::MojoApplicationManifestMap> manifests_; | 127 std::map<std::string, std::unique_ptr<base::Value>> manifests_; |
141 | 128 |
142 DISALLOW_COPY_AND_ASSIGN(BuiltinManifestProvider); | 129 DISALLOW_COPY_AND_ASSIGN(BuiltinManifestProvider); |
143 }; | 130 }; |
144 | 131 |
145 } // namespace | 132 } // namespace |
146 | 133 |
147 // State which lives on the IO thread and drives the ServiceManager. | 134 // State which lives on the IO thread and drives the ServiceManager. |
148 class MojoShellContext::InProcessServiceManagerContext | 135 class MojoShellContext::InProcessServiceManagerContext |
149 : public base::RefCountedThreadSafe<InProcessServiceManagerContext> { | 136 : public base::RefCountedThreadSafe<InProcessServiceManagerContext> { |
150 public: | 137 public: |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 | 194 |
208 DISALLOW_COPY_AND_ASSIGN(InProcessServiceManagerContext); | 195 DISALLOW_COPY_AND_ASSIGN(InProcessServiceManagerContext); |
209 }; | 196 }; |
210 | 197 |
211 MojoShellContext::MojoShellContext() { | 198 MojoShellContext::MojoShellContext() { |
212 shell::mojom::ServiceRequest request; | 199 shell::mojom::ServiceRequest request; |
213 if (shell::ShellIsRemote()) { | 200 if (shell::ShellIsRemote()) { |
214 mojo::edk::SetParentPipeHandleFromCommandLine(); | 201 mojo::edk::SetParentPipeHandleFromCommandLine(); |
215 request = shell::GetServiceRequestFromCommandLine(); | 202 request = shell::GetServiceRequestFromCommandLine(); |
216 } else { | 203 } else { |
217 // Allow the embedder to register additional Mojo application manifests | |
218 // beyond the default ones below. | |
219 std::unique_ptr<ContentBrowserClient::MojoApplicationManifestMap> manifests( | |
220 new ContentBrowserClient::MojoApplicationManifestMap); | |
221 GetContentClient()->browser()->RegisterMojoApplicationManifests( | |
222 manifests.get()); | |
223 std::unique_ptr<BuiltinManifestProvider> manifest_provider = | 204 std::unique_ptr<BuiltinManifestProvider> manifest_provider = |
224 base::MakeUnique<BuiltinManifestProvider>(); | 205 base::MakeUnique<BuiltinManifestProvider>(); |
225 manifest_provider->AddManifests(std::move(manifests)); | |
226 manifest_provider->AddManifestResource(kBrowserMojoApplicationName, | |
227 IDR_MOJO_CONTENT_BROWSER_MANIFEST); | |
228 manifest_provider->AddManifestResource(kGpuMojoApplicationName, | |
229 IDR_MOJO_CONTENT_GPU_MANIFEST); | |
230 manifest_provider->AddManifestResource(kPluginMojoApplicationName, | |
231 IDR_MOJO_CONTENT_PLUGIN_MANIFEST); | |
232 manifest_provider->AddManifestResource(kRendererMojoApplicationName, | |
233 IDR_MOJO_CONTENT_RENDERER_MANIFEST); | |
234 manifest_provider->AddManifestResource(kUtilityMojoApplicationName, | |
235 IDR_MOJO_CONTENT_UTILITY_MANIFEST); | |
236 manifest_provider->AddManifestResource("mojo:catalog", | |
237 IDR_MOJO_CATALOG_MANIFEST); | |
238 manifest_provider->AddManifestResource(file::kFileServiceName, | |
239 IDR_MOJO_FILE_MANIFEST); | |
240 | 206 |
| 207 static const struct ManifestInfo { |
| 208 const char* name; |
| 209 int resource_id; |
| 210 } kManifests[] = { |
| 211 { kBrowserMojoApplicationName, IDR_MOJO_CONTENT_BROWSER_MANIFEST }, |
| 212 { kGpuMojoApplicationName, IDR_MOJO_CONTENT_GPU_MANIFEST }, |
| 213 { kPluginMojoApplicationName, IDR_MOJO_CONTENT_PLUGIN_MANIFEST }, |
| 214 { kRendererMojoApplicationName, IDR_MOJO_CONTENT_RENDERER_MANIFEST }, |
| 215 { kUtilityMojoApplicationName, IDR_MOJO_CONTENT_UTILITY_MANIFEST }, |
| 216 { "mojo:catalog", IDR_MOJO_CATALOG_MANIFEST }, |
| 217 { file::kFileServiceName, IDR_MOJO_FILE_MANIFEST } |
| 218 }; |
| 219 |
| 220 for (size_t i = 0; i < arraysize(kManifests); ++i) { |
| 221 std::string contents = GetContentClient()->GetDataResource( |
| 222 kManifests[i].resource_id, |
| 223 ui::ScaleFactor::SCALE_FACTOR_NONE).as_string(); |
| 224 DCHECK(!contents.empty()); |
| 225 std::unique_ptr<base::Value> manifest_value = |
| 226 base::JSONReader::Read(contents); |
| 227 std::unique_ptr<base::Value> overlay_value = |
| 228 GetContentClient()->browser()->GetServiceManifestOverlay( |
| 229 kManifests[i].name); |
| 230 if (overlay_value) { |
| 231 base::DictionaryValue* manifest_dictionary = nullptr; |
| 232 CHECK(manifest_value->GetAsDictionary(&manifest_dictionary)); |
| 233 base::DictionaryValue* overlay_dictionary = nullptr; |
| 234 CHECK(overlay_value->GetAsDictionary(&overlay_dictionary)); |
| 235 MergeDictionary(manifest_dictionary, overlay_dictionary); |
| 236 } |
| 237 manifest_provider->AddManifestValue(kManifests[i].name, |
| 238 std::move(manifest_value)); |
| 239 } |
241 in_process_context_ = new InProcessServiceManagerContext; | 240 in_process_context_ = new InProcessServiceManagerContext; |
242 request = in_process_context_->Start(std::move(manifest_provider)); | 241 request = in_process_context_->Start(std::move(manifest_provider)); |
243 } | 242 } |
244 MojoShellConnection::SetForProcess(MojoShellConnection::Create( | 243 MojoShellConnection::SetForProcess(MojoShellConnection::Create( |
245 std::move(request), | 244 std::move(request), |
246 BrowserThread::GetTaskRunnerForThread(BrowserThread::IO))); | 245 BrowserThread::GetTaskRunnerForThread(BrowserThread::IO))); |
247 | 246 |
248 ContentBrowserClient::StaticMojoApplicationMap apps; | 247 ContentBrowserClient::StaticMojoApplicationMap apps; |
249 GetContentClient()->browser()->RegisterInProcessMojoApplications(&apps); | 248 GetContentClient()->browser()->RegisterInProcessMojoApplications(&apps); |
250 for (const auto& entry : apps) { | 249 for (const auto& entry : apps) { |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
296 in_process_context_->ShutDown(); | 295 in_process_context_->ShutDown(); |
297 } | 296 } |
298 | 297 |
299 // static | 298 // static |
300 shell::Connector* MojoShellContext::GetConnectorForIOThread() { | 299 shell::Connector* MojoShellContext::GetConnectorForIOThread() { |
301 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 300 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
302 return g_io_thread_connector.Get().get(); | 301 return g_io_thread_connector.Get().get(); |
303 } | 302 } |
304 | 303 |
305 } // namespace content | 304 } // namespace content |
OLD | NEW |