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" | |
13 #include "base/lazy_instance.h" | 12 #include "base/lazy_instance.h" |
14 #include "base/macros.h" | 13 #include "base/macros.h" |
15 #include "base/memory/ptr_util.h" | 14 #include "base/memory/ptr_util.h" |
16 #include "base/single_thread_task_runner.h" | 15 #include "base/single_thread_task_runner.h" |
17 #include "content/browser/gpu/gpu_process_host.h" | 16 #include "content/browser/gpu/gpu_process_host.h" |
18 #include "content/browser/mojo/merge_dictionary.h" | 17 #include "content/common/mojo/constants.h" |
19 #include "content/common/mojo/mojo_shell_connection_impl.h" | 18 #include "content/common/mojo/mojo_shell_connection_impl.h" |
20 #include "content/grit/content_resources.h" | 19 #include "content/grit/content_resources.h" |
21 #include "content/public/browser/browser_thread.h" | 20 #include "content/public/browser/browser_thread.h" |
22 #include "content/public/browser/content_browser_client.h" | 21 #include "content/public/browser/content_browser_client.h" |
23 #include "content/public/browser/utility_process_host.h" | 22 #include "content/public/browser/utility_process_host.h" |
24 #include "content/public/browser/utility_process_host_client.h" | 23 #include "content/public/browser/utility_process_host_client.h" |
25 #include "content/public/common/content_client.h" | 24 #include "content/public/common/content_client.h" |
26 #include "content/public/common/mojo_shell_connection.h" | 25 #include "content/public/common/mojo_shell_connection.h" |
27 #include "content/public/common/service_names.h" | |
28 #include "mojo/edk/embedder/embedder.h" | 26 #include "mojo/edk/embedder/embedder.h" |
29 #include "services/catalog/catalog.h" | 27 #include "services/catalog/catalog.h" |
30 #include "services/catalog/manifest_provider.h" | 28 #include "services/catalog/manifest_provider.h" |
31 #include "services/catalog/store.h" | 29 #include "services/catalog/store.h" |
32 #include "services/file/public/cpp/constants.h" | 30 #include "services/file/public/cpp/constants.h" |
33 #include "services/shell/connect_params.h" | 31 #include "services/shell/connect_params.h" |
34 #include "services/shell/native_runner.h" | 32 #include "services/shell/native_runner.h" |
35 #include "services/shell/public/cpp/connector.h" | 33 #include "services/shell/public/cpp/connector.h" |
36 #include "services/shell/public/cpp/service.h" | 34 #include "services/shell/public/cpp/service.h" |
37 #include "services/shell/public/interfaces/service.mojom.h" | 35 #include "services/shell/public/interfaces/service.mojom.h" |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 shell::mojom::ServiceFactoryPtr service_factory; | 94 shell::mojom::ServiceFactoryPtr service_factory; |
97 BrowserThread::PostTask( | 95 BrowserThread::PostTask( |
98 BrowserThread::IO, FROM_HERE, | 96 BrowserThread::IO, FROM_HERE, |
99 base::Bind(&RequestGpuServiceFactory, | 97 base::Bind(&RequestGpuServiceFactory, |
100 base::Passed(GetProxy(&service_factory)))); | 98 base::Passed(GetProxy(&service_factory)))); |
101 service_factory->CreateService(std::move(request), service_name); | 99 service_factory->CreateService(std::move(request), service_name); |
102 } | 100 } |
103 | 101 |
104 #endif // ENABLE_MOJO_MEDIA_IN_GPU_PROCESS | 102 #endif // ENABLE_MOJO_MEDIA_IN_GPU_PROCESS |
105 | 103 |
106 void MergeDictionary(base::DictionaryValue* target, | |
107 const base::DictionaryValue* source) { | |
108 for (base::DictionaryValue::Iterator it(*source); !it.IsAtEnd(); | |
109 it.Advance()) { | |
110 const base::Value* merge_value = &it.value(); | |
111 // Check whether we have to merge dictionaries. | |
112 if (merge_value->IsType(base::Value::TYPE_DICTIONARY)) { | |
113 base::DictionaryValue* sub_dict; | |
114 if (target->GetDictionaryWithoutPathExpansion(it.key(), &sub_dict)) { | |
115 MergeDictionary( | |
116 sub_dict, | |
117 static_cast<const base::DictionaryValue*>(merge_value)); | |
118 continue; | |
119 } | |
120 } | |
121 if (merge_value->IsType(base::Value::TYPE_LIST)) { | |
122 const base::ListValue* merge_list = nullptr; | |
123 if (merge_value->GetAsList(&merge_list)) { | |
124 base::ListValue* target_list = nullptr; | |
125 DCHECK(target->GetListWithoutPathExpansion(it.key(), &target_list)); | |
126 for (size_t i = 0; i < merge_list->GetSize(); ++i) { | |
127 std::string value; | |
128 DCHECK(merge_list->GetString(i, &value)); | |
129 target_list->AppendString(value); | |
130 } | |
131 } | |
132 } else { | |
133 // All other cases: Make a copy and hook it up. | |
134 target->SetWithoutPathExpansion(it.key(), merge_value->DeepCopy()); | |
135 } | |
136 } | |
137 } | |
138 | |
139 // A ManifestProvider which resolves application names to builtin manifest | 104 // A ManifestProvider which resolves application names to builtin manifest |
140 // resources for the catalog service to consume. | 105 // resources for the catalog service to consume. |
141 class BuiltinManifestProvider : public catalog::ManifestProvider { | 106 class BuiltinManifestProvider : public catalog::ManifestProvider { |
142 public: | 107 public: |
143 BuiltinManifestProvider() {} | 108 BuiltinManifestProvider() {} |
144 ~BuiltinManifestProvider() override {} | 109 ~BuiltinManifestProvider() override {} |
145 | 110 |
146 void AddManifests(std::unique_ptr< | 111 void AddManifests(std::unique_ptr< |
147 ContentBrowserClient::MojoApplicationManifestMap> manifests) { | 112 ContentBrowserClient::MojoApplicationManifestMap> manifests) { |
148 DCHECK(!manifests_); | 113 DCHECK(!manifests_); |
149 manifests_ = std::move(manifests); | 114 manifests_ = std::move(manifests); |
150 } | 115 } |
151 | 116 |
152 void AddManifestResource(const std::string& name, int resource_id) { | 117 void AddManifestResource(const std::string& name, int resource_id) { |
153 std::string contents = GetContentClient()->GetDataResource( | 118 std::string contents = GetContentClient()->GetDataResource( |
154 resource_id, ui::ScaleFactor::SCALE_FACTOR_NONE).as_string(); | 119 resource_id, ui::ScaleFactor::SCALE_FACTOR_NONE).as_string(); |
155 DCHECK(!contents.empty()); | 120 DCHECK(!contents.empty()); |
156 | 121 |
157 DCHECK(manifests_); | 122 DCHECK(manifests_); |
158 auto result = manifests_->insert(std::make_pair(name, contents)); | 123 auto result = manifests_->insert(std::make_pair(name, contents)); |
159 DCHECK(result.second) << "Duplicate manifest entry: " << name; | 124 DCHECK(result.second) << "Duplicate manifest entry: " << name; |
160 } | 125 } |
161 | 126 |
162 private: | 127 private: |
163 // catalog::ManifestProvider: | 128 // catalog::ManifestProvider: |
164 std::unique_ptr<base::Value> GetManifest(const std::string& name) override { | 129 bool GetApplicationManifest(const base::StringPiece& name, |
165 auto manifest_it = manifests_->find(name); | 130 std::string* manifest_contents) override { |
166 std::unique_ptr<base::Value> manifest_root; | 131 auto manifest_it = manifests_->find(name.as_string()); |
167 if (manifest_it != manifests_->end()) | 132 if (manifest_it != manifests_->end()) { |
168 manifest_root = base::JSONReader::Read(manifest_it->second); | 133 *manifest_contents = manifest_it->second; |
169 | 134 DCHECK(!manifest_contents->empty()); |
170 base::DictionaryValue* manifest_dictionary = nullptr; | 135 return true; |
171 if (manifest_root && !manifest_root->GetAsDictionary(&manifest_dictionary)) | |
172 return nullptr; | |
173 | |
174 std::unique_ptr<base::Value> overlay_root = | |
175 GetContentClient()->browser()->GetServiceManifestOverlay(name); | |
176 if (overlay_root) { | |
177 if (!manifest_root) { | |
178 manifest_root = std::move(overlay_root); | |
179 } else { | |
180 base::DictionaryValue* overlay_dictionary = nullptr; | |
181 if (overlay_root->GetAsDictionary(&overlay_dictionary)) | |
182 MergeDictionary(manifest_dictionary, overlay_dictionary); | |
183 } | |
184 } | 136 } |
185 return manifest_root; | 137 return false; |
186 } | 138 } |
187 | 139 |
188 std::unique_ptr<ContentBrowserClient::MojoApplicationManifestMap> manifests_; | 140 std::unique_ptr<ContentBrowserClient::MojoApplicationManifestMap> manifests_; |
189 | 141 |
190 DISALLOW_COPY_AND_ASSIGN(BuiltinManifestProvider); | 142 DISALLOW_COPY_AND_ASSIGN(BuiltinManifestProvider); |
191 }; | 143 }; |
192 | 144 |
193 } // namespace | 145 } // namespace |
194 | 146 |
195 // State which lives on the IO thread and drives the ServiceManager. | 147 // State which lives on the IO thread and drives the ServiceManager. |
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
344 in_process_context_->ShutDown(); | 296 in_process_context_->ShutDown(); |
345 } | 297 } |
346 | 298 |
347 // static | 299 // static |
348 shell::Connector* MojoShellContext::GetConnectorForIOThread() { | 300 shell::Connector* MojoShellContext::GetConnectorForIOThread() { |
349 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 301 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
350 return g_io_thread_connector.Get().get(); | 302 return g_io_thread_connector.Get().get(); |
351 } | 303 } |
352 | 304 |
353 } // namespace content | 305 } // namespace content |
OLD | NEW |