| 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
|
|
|