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

Unified Diff: mojo/shell/context.cc

Issue 775343004: Move //mojo/shell to //shell (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 6 years 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/shell/context.h ('k') | mojo/shell/data_pipe_peek.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/shell/context.cc
diff --git a/mojo/shell/context.cc b/mojo/shell/context.cc
deleted file mode 100644
index 0d2c30f8a1fee9d05ceda9d859473b287a4a64b2..0000000000000000000000000000000000000000
--- a/mojo/shell/context.cc
+++ /dev/null
@@ -1,318 +0,0 @@
-// Copyright 2013 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "mojo/shell/context.h"
-
-#include <vector>
-
-#include "base/bind.h"
-#include "base/command_line.h"
-#include "base/files/file_path.h"
-#include "base/lazy_instance.h"
-#include "base/macros.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/memory/scoped_vector.h"
-#include "base/strings/string_split.h"
-#include "build/build_config.h"
-#include "mojo/application_manager/application_loader.h"
-#include "mojo/application_manager/application_manager.h"
-#include "mojo/application_manager/background_shell_application_loader.h"
-#include "mojo/common/tracing_impl.h"
-#include "mojo/edk/embedder/embedder.h"
-#include "mojo/edk/embedder/simple_platform_support.h"
-#include "mojo/public/cpp/application/application_connection.h"
-#include "mojo/public/cpp/application/application_delegate.h"
-#include "mojo/public/cpp/application/application_impl.h"
-#include "mojo/shell/dynamic_application_loader.h"
-#include "mojo/shell/external_application_listener.h"
-#include "mojo/shell/in_process_dynamic_service_runner.h"
-#include "mojo/shell/out_of_process_dynamic_service_runner.h"
-#include "mojo/shell/switches.h"
-#include "mojo/shell/ui_application_loader_android.h"
-#include "mojo/spy/spy.h"
-#include "services/tracing/tracing.mojom.h"
-#include "url/gurl.h"
-
-#if defined(OS_ANDROID)
-#include "mojo/shell/android/android_handler_loader.h"
-#include "mojo/shell/network_application_loader.h"
-#include "services/gles2/gpu_impl.h"
-#include "services/native_viewport/native_viewport_impl.h"
-#endif // defined(OS_ANDROID)
-
-namespace mojo {
-namespace shell {
-namespace {
-
-// These mojo: URLs are loaded directly from the local filesystem. They
-// correspond to shared libraries bundled alongside the mojo_shell.
-const char* kLocalMojoURLs[] = {
- "mojo:network_service",
-};
-
-// Used to ensure we only init once.
-class Setup {
- public:
- Setup() {
- embedder::Init(scoped_ptr<mojo::embedder::PlatformSupport>(
- new mojo::embedder::SimplePlatformSupport()));
- }
-
- ~Setup() {
- }
-
- private:
- DISALLOW_COPY_AND_ASSIGN(Setup);
-};
-
-static base::LazyInstance<Setup>::Leaky setup = LAZY_INSTANCE_INITIALIZER;
-
-void InitContentHandlers(DynamicApplicationLoader* loader,
- base::CommandLine* command_line) {
- // Default content handlers.
- loader->RegisterContentHandler("application/pdf", GURL("mojo:pdf_viewer"));
- loader->RegisterContentHandler("image/png", GURL("mojo:png_viewer"));
- loader->RegisterContentHandler("text/html", GURL("mojo:html_viewer"));
-
- // Command-line-specified content handlers.
- std::string handlers_spec = command_line->GetSwitchValueASCII(
- switches::kContentHandlers);
- if (handlers_spec.empty())
- return;
-
- std::vector<std::string> parts;
- base::SplitString(handlers_spec, ',', &parts);
- if (parts.size() % 2 != 0) {
- LOG(ERROR) << "Invalid value for switch " << switches::kContentHandlers
- << ": must be a comma-separated list of mimetype/url pairs.";
- return;
- }
-
- for (size_t i = 0; i < parts.size(); i += 2) {
- GURL url(parts[i + 1]);
- if (!url.is_valid()) {
- LOG(ERROR) << "Invalid value for switch " << switches::kContentHandlers
- << ": '" << parts[i + 1] << "' is not a valid URL.";
- return;
- }
- loader->RegisterContentHandler(parts[i], url);
- }
-}
-
-class EmptyServiceProvider : public InterfaceImpl<ServiceProvider> {
- private:
- void ConnectToService(const mojo::String& service_name,
- ScopedMessagePipeHandle client_handle) override {}
-};
-
-bool ConfigureURLMappings(const std::string& mappings,
- mojo::shell::MojoURLResolver* resolver) {
- base::StringPairs pairs;
- if (!base::SplitStringIntoKeyValuePairs(mappings, '=', ',', &pairs))
- return false;
- using StringPair = std::pair<std::string, std::string>;
- for (const StringPair& pair : pairs) {
- const GURL from(pair.first);
- const GURL to(pair.second);
- if (!from.is_valid() || !to.is_valid())
- return false;
- resolver->AddCustomMapping(from, to);
- }
- return true;
-}
-
-} // namespace
-
-#if defined(OS_ANDROID)
-class Context::NativeViewportApplicationLoader
- : public ApplicationLoader,
- public ApplicationDelegate,
- public InterfaceFactory<NativeViewport>,
- public InterfaceFactory<Gpu> {
- public:
- NativeViewportApplicationLoader() : gpu_state_(new GpuImpl::State) {}
- virtual ~NativeViewportApplicationLoader() {}
-
- private:
- // ApplicationLoader implementation.
- virtual void Load(ApplicationManager* manager,
- const GURL& url,
- ScopedMessagePipeHandle shell_handle,
- LoadCallback callback) override {
- DCHECK(shell_handle.is_valid());
- app_.reset(new ApplicationImpl(this, shell_handle.Pass()));
- }
-
- virtual void OnApplicationError(ApplicationManager* manager,
- const GURL& url) override {}
-
- // ApplicationDelegate implementation.
- virtual bool ConfigureIncomingConnection(
- mojo::ApplicationConnection* connection) override {
- connection->AddService<NativeViewport>(this);
- connection->AddService<Gpu>(this);
- return true;
- }
-
- // InterfaceFactory<NativeViewport> implementation.
- virtual void Create(ApplicationConnection* connection,
- InterfaceRequest<NativeViewport> request) override {
- BindToRequest(new NativeViewportImpl(app_.get(), false), &request);
- }
-
- // InterfaceFactory<Gpu> implementation.
- virtual void Create(ApplicationConnection* connection,
- InterfaceRequest<Gpu> request) override {
- new GpuImpl(request.Pass(), gpu_state_);
- }
-
- scoped_refptr<GpuImpl::State> gpu_state_;
- scoped_ptr<ApplicationImpl> app_;
- DISALLOW_COPY_AND_ASSIGN(NativeViewportApplicationLoader);
-};
-#endif
-
-Context::Context() : application_manager_(this) {
- DCHECK(!base::MessageLoop::current());
-}
-
-Context::~Context() {
- DCHECK(!base::MessageLoop::current());
-}
-
-void Context::EnsureEmbedderIsInitialized() {
- setup.Get();
-}
-
-bool Context::Init() {
- EnsureEmbedderIsInitialized();
- task_runners_.reset(
- new TaskRunners(base::MessageLoop::current()->message_loop_proxy()));
-
- for (size_t i = 0; i < arraysize(kLocalMojoURLs); ++i)
- mojo_url_resolver_.AddLocalFileMapping(GURL(kLocalMojoURLs[i]));
-
- base::CommandLine* command_line = base::CommandLine::ForCurrentProcess();
-
- if (command_line->HasSwitch(switches::kEnableExternalApplications)) {
- listener_ = ExternalApplicationListener::Create(
- task_runners_->shell_runner(), task_runners_->io_runner());
-
- base::FilePath socket_path =
- command_line->GetSwitchValuePath(switches::kEnableExternalApplications);
- if (socket_path.empty())
- socket_path = ExternalApplicationListener::ConstructDefaultSocketPath();
-
- listener_->ListenInBackground(
- socket_path,
- base::Bind(&ApplicationManager::RegisterExternalApplication,
- base::Unretained(&application_manager_)));
- }
- if (command_line->HasSwitch(switches::kOrigin)) {
- mojo_url_resolver()->SetBaseURL(
- GURL(command_line->GetSwitchValueASCII(switches::kOrigin)));
- }
- if (command_line->HasSwitch(switches::kURLMappings) &&
- !ConfigureURLMappings(
- command_line->GetSwitchValueASCII(switches::kURLMappings),
- mojo_url_resolver())) {
- return false;
- }
-
- scoped_ptr<DynamicServiceRunnerFactory> runner_factory;
- if (command_line->HasSwitch(switches::kEnableMultiprocess))
- runner_factory.reset(new OutOfProcessDynamicServiceRunnerFactory());
- else
- runner_factory.reset(new InProcessDynamicServiceRunnerFactory());
-
- DynamicApplicationLoader* dynamic_application_loader =
- new DynamicApplicationLoader(this, runner_factory.Pass());
- InitContentHandlers(dynamic_application_loader, command_line);
- application_manager_.set_default_loader(
- scoped_ptr<ApplicationLoader>(dynamic_application_loader));
-
- // The native viewport service synchronously waits for certain messages. If we
- // don't run it on its own thread we can easily deadlock. Long term native
- // viewport should run its own process so that this isn't an issue.
-#if defined(OS_ANDROID)
- application_manager_.SetLoaderForURL(
- scoped_ptr<ApplicationLoader>(new UIApplicationLoader(
- scoped_ptr<ApplicationLoader>(new NativeViewportApplicationLoader()),
- this)),
- GURL("mojo:native_viewport_service"));
-#endif
-
- if (command_line->HasSwitch(switches::kSpy)) {
- spy_.reset(
- new mojo::Spy(&application_manager_,
- command_line->GetSwitchValueASCII(switches::kSpy)));
- // TODO(cpu): the spy can snoop, but can't tell anybody until
- // the Spy::WebSocketDelegate is implemented. In the original repo this
- // was implemented by src\mojo\spy\websocket_server.h and .cc.
- }
-
-#if defined(OS_ANDROID)
- // On android, the network service is bundled with the shell because the
- // network stack depends on the android runtime.
- {
- scoped_ptr<BackgroundShellApplicationLoader> loader(
- new BackgroundShellApplicationLoader(
- scoped_ptr<ApplicationLoader>(new NetworkApplicationLoader()),
- "network_service",
- base::MessageLoop::TYPE_IO));
- application_manager_.SetLoaderForURL(loader.Pass(),
- GURL("mojo:network_service"));
- }
- {
- scoped_ptr<BackgroundShellApplicationLoader> loader(
- new BackgroundShellApplicationLoader(
- scoped_ptr<ApplicationLoader>(new AndroidHandlerLoader()),
- "android_handler", base::MessageLoop::TYPE_DEFAULT));
- application_manager_.SetLoaderForURL(loader.Pass(),
- GURL("mojo:android_handler"));
- }
-#endif
-
- tracing::TraceDataCollectorPtr trace_data_collector_ptr;
- application_manager_.ConnectToService(GURL("mojo:tracing"),
- &trace_data_collector_ptr);
- TracingImpl::Create(trace_data_collector_ptr.Pass());
-
- if (listener_)
- listener_->WaitForListening();
-
- return true;
-}
-
-void Context::OnApplicationError(const GURL& url) {
- if (app_urls_.find(url) != app_urls_.end()) {
- app_urls_.erase(url);
- if (app_urls_.empty() && base::MessageLoop::current()->is_running())
- base::MessageLoop::current()->Quit();
- }
-}
-
-GURL Context::ResolveURL(const GURL& url) {
- return mojo_url_resolver_.Resolve(url);
-}
-
-void Context::Run(const GURL& url) {
- EmptyServiceProvider* sp = new EmptyServiceProvider;
- ServiceProviderPtr spp;
- BindToProxy(sp, &spp);
-
- app_urls_.insert(url);
- application_manager_.ConnectToApplication(url, GURL(), spp.Pass());
-}
-
-ScopedMessagePipeHandle Context::ConnectToServiceByName(
- const GURL& application_url,
- const std::string& service_name) {
- app_urls_.insert(application_url);
- return application_manager_.ConnectToServiceByName(
- application_url, service_name).Pass();
-}
-
-} // namespace shell
-} // namespace mojo
« no previous file with comments | « mojo/shell/context.h ('k') | mojo/shell/data_pipe_peek.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698