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

Unified Diff: mojo/shell/standalone/context.cc

Issue 1877753003: Move mojo\shell to services\shell (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@62scan
Patch Set: . Created 4 years, 8 months 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/standalone/context.h ('k') | mojo/shell/standalone/desktop/launcher_process.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/shell/standalone/context.cc
diff --git a/mojo/shell/standalone/context.cc b/mojo/shell/standalone/context.cc
deleted file mode 100644
index 4a5512e9762c27c2ba521603e11819a023b4c02b..0000000000000000000000000000000000000000
--- a/mojo/shell/standalone/context.cc
+++ /dev/null
@@ -1,265 +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/standalone/context.h"
-
-#include <stddef.h>
-#include <stdint.h>
-
-#include <utility>
-#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/path_service.h"
-#include "base/process/process_info.h"
-#include "base/run_loop.h"
-#include "base/strings/string_number_conversions.h"
-#include "base/strings/string_split.h"
-#include "base/strings/string_util.h"
-#include "base/strings/utf_string_conversions.h"
-#include "base/threading/sequenced_worker_pool.h"
-#include "base/trace_event/trace_event.h"
-#include "build/build_config.h"
-#include "components/tracing/tracing_switches.h"
-#include "mojo/edk/embedder/embedder.h"
-#include "mojo/public/cpp/bindings/strong_binding.h"
-#include "mojo/services/catalog/factory.h"
-#include "mojo/services/catalog/store.h"
-#include "mojo/services/tracing/public/cpp/switches.h"
-#include "mojo/services/tracing/public/cpp/trace_provider_impl.h"
-#include "mojo/services/tracing/public/cpp/tracing_impl.h"
-#include "mojo/services/tracing/public/interfaces/tracing.mojom.h"
-#include "mojo/shell/connect_params.h"
-#include "mojo/shell/public/cpp/names.h"
-#include "mojo/shell/runner/host/in_process_native_runner.h"
-#include "mojo/shell/runner/host/out_of_process_native_runner.h"
-#include "mojo/shell/standalone/tracer.h"
-#include "mojo/shell/switches.h"
-#include "mojo/util/filename_util.h"
-
-#if defined(OS_MACOSX)
-#include "mojo/shell/runner/host/mach_broker.h"
-#endif
-
-namespace mojo {
-namespace shell {
-namespace {
-
-// Used to ensure we only init once.
-class Setup {
- public:
- Setup() { edk::Init(); }
-
- ~Setup() {}
-
- private:
- DISALLOW_COPY_AND_ASSIGN(Setup);
-};
-
-class TracingInterfaceProvider : public shell::mojom::InterfaceProvider {
- public:
- TracingInterfaceProvider(Tracer* tracer,
- shell::mojom::InterfaceProviderRequest request)
- : tracer_(tracer), binding_(this, std::move(request)) {}
- ~TracingInterfaceProvider() override {}
-
- // shell::mojom::InterfaceProvider:
- void GetInterface(const mojo::String& interface_name,
- ScopedMessagePipeHandle client_handle) override {
- if (tracer_ && interface_name == tracing::TraceProvider::Name_) {
- tracer_->ConnectToProvider(
- MakeRequest<tracing::TraceProvider>(std::move(client_handle)));
- }
- }
-
- private:
- Tracer* tracer_;
- StrongBinding<shell::mojom::InterfaceProvider> binding_;
-
- DISALLOW_COPY_AND_ASSIGN(TracingInterfaceProvider);
-};
-
-const size_t kMaxBlockingPoolThreads = 3;
-
-scoped_ptr<base::Thread> CreateIOThread(const char* name) {
- scoped_ptr<base::Thread> thread(new base::Thread(name));
- base::Thread::Options options;
- options.message_loop_type = base::MessageLoop::TYPE_IO;
- thread->StartWithOptions(options);
- return thread;
-}
-
-void OnInstanceQuit(const std::string& name, const Identity& identity) {
- if (name == identity.name())
- base::MessageLoop::current()->QuitWhenIdle();
-}
-
-} // namespace
-
-Context::InitParams::InitParams() {}
-Context::InitParams::~InitParams() {}
-
-Context::Context()
- : io_thread_(CreateIOThread("io_thread")),
- main_entry_time_(base::Time::Now()) {}
-
-Context::~Context() {
- DCHECK(!base::MessageLoop::current());
- blocking_pool_->Shutdown();
-}
-
-// static
-void Context::EnsureEmbedderIsInitialized() {
- static base::LazyInstance<Setup>::Leaky setup = LAZY_INSTANCE_INITIALIZER;
- setup.Get();
-}
-
-void Context::Init(scoped_ptr<InitParams> init_params) {
- TRACE_EVENT0("mojo_shell", "Context::Init");
- const base::CommandLine& command_line =
- *base::CommandLine::ForCurrentProcess();
-
- bool trace_startup = command_line.HasSwitch(::switches::kTraceStartup);
- if (trace_startup) {
- tracer_.Start(
- command_line.GetSwitchValueASCII(::switches::kTraceStartup),
- command_line.GetSwitchValueASCII(::switches::kTraceStartupDuration),
- "mojo_runner.trace");
- }
-
- if (!init_params || init_params->init_edk)
- EnsureEmbedderIsInitialized();
-
- shell_runner_ = base::MessageLoop::current()->task_runner();
- blocking_pool_ =
- new base::SequencedWorkerPool(kMaxBlockingPoolThreads, "blocking_pool");
-
- init_edk_ = !init_params || init_params->init_edk;
- if (init_edk_) {
- edk::InitIPCSupport(this, io_thread_->task_runner().get());
-#if defined(OS_MACOSX)
- edk::SetMachPortProvider(MachBroker::GetInstance()->port_provider());
-#endif
- }
-
- scoped_ptr<NativeRunnerFactory> runner_factory;
- if (command_line.HasSwitch(switches::kSingleProcess)) {
-#if defined(COMPONENT_BUILD)
- LOG(ERROR) << "Running Mojo in single process component build, which isn't "
- << "supported because statics in apps interact. Use static build"
- << " or don't pass --single-process.";
-#endif
- runner_factory.reset(
- new InProcessNativeRunnerFactory(blocking_pool_.get()));
- } else {
- NativeRunnerDelegate* native_runner_delegate = init_params ?
- init_params->native_runner_delegate : nullptr;
- runner_factory.reset(new OutOfProcessNativeRunnerFactory(
- blocking_pool_.get(), native_runner_delegate));
- }
- scoped_ptr<catalog::Store> store;
- if (init_params)
- store = std::move(init_params->catalog_store);
- catalog_.reset(
- new catalog::Factory(blocking_pool_.get(), std::move(store), nullptr));
- shell_.reset(new Shell(std::move(runner_factory),
- catalog_->TakeShellClient()));
-
- shell::mojom::InterfaceProviderPtr tracing_remote_interfaces;
- shell::mojom::InterfaceProviderPtr tracing_local_interfaces;
- new TracingInterfaceProvider(&tracer_, GetProxy(&tracing_local_interfaces));
-
- scoped_ptr<ConnectParams> params(new ConnectParams);
- params->set_source(CreateShellIdentity());
- params->set_target(Identity("mojo:tracing", mojom::kRootUserID));
- params->set_remote_interfaces(GetProxy(&tracing_remote_interfaces));
- params->set_local_interfaces(std::move(tracing_local_interfaces));
- shell_->Connect(std::move(params));
-
- if (command_line.HasSwitch(tracing::kTraceStartup)) {
- tracing::TraceCollectorPtr coordinator;
- auto coordinator_request = GetProxy(&coordinator);
- tracing_remote_interfaces->GetInterface(
- tracing::TraceCollector::Name_, coordinator_request.PassMessagePipe());
- tracer_.StartCollectingFromTracingService(std::move(coordinator));
- }
-
- // Record the shell startup metrics used for performance testing.
- if (base::CommandLine::ForCurrentProcess()->HasSwitch(
- tracing::kEnableStatsCollectionBindings)) {
- tracing::StartupPerformanceDataCollectorPtr collector;
- tracing_remote_interfaces->GetInterface(
- tracing::StartupPerformanceDataCollector::Name_,
- GetProxy(&collector).PassMessagePipe());
-#if defined(OS_MACOSX) || defined(OS_WIN) || defined(OS_LINUX)
- // CurrentProcessInfo::CreationTime is only defined on some platforms.
- const base::Time creation_time = base::CurrentProcessInfo::CreationTime();
- collector->SetShellProcessCreationTime(creation_time.ToInternalValue());
-#endif
- collector->SetShellMainEntryPointTime(main_entry_time_.ToInternalValue());
- }
-}
-
-void Context::Shutdown() {
- // Actions triggered by Shell's destructor may require a current message loop,
- // so we should destruct it explicitly now as ~Context() occurs post message
- // loop shutdown.
- shell_.reset();
-
- DCHECK_EQ(base::MessageLoop::current()->task_runner(), shell_runner_);
-
- // If we didn't initialize the edk we should not shut it down.
- if (!init_edk_)
- return;
-
- TRACE_EVENT0("mojo_shell", "Context::Shutdown");
- // Post a task in case OnShutdownComplete is called synchronously.
- base::MessageLoop::current()->PostTask(FROM_HERE,
- base::Bind(edk::ShutdownIPCSupport));
- // We'll quit when we get OnShutdownComplete().
- base::MessageLoop::current()->Run();
-}
-
-void Context::OnShutdownComplete() {
- DCHECK_EQ(base::MessageLoop::current()->task_runner(), shell_runner_);
- base::MessageLoop::current()->QuitWhenIdle();
-}
-
-void Context::RunCommandLineApplication() {
- base::CommandLine* command_line = base::CommandLine::ForCurrentProcess();
- base::CommandLine::StringVector args = command_line->GetArgs();
- for (size_t i = 0; i < args.size(); ++i) {
-#if defined(OS_WIN)
- std::string possible_app = base::WideToUTF8(args[i]);
-#else
- std::string possible_app = args[i];
-#endif
- if (GetNameType(possible_app) == "mojo") {
- Run(possible_app);
- break;
- }
- }
-}
-
-void Context::Run(const std::string& name) {
- shell_->SetInstanceQuitCallback(base::Bind(&OnInstanceQuit, name));
-
- shell::mojom::InterfaceProviderPtr remote_interfaces;
- shell::mojom::InterfaceProviderPtr local_interfaces;
-
- scoped_ptr<ConnectParams> params(new ConnectParams);
- params->set_source(CreateShellIdentity());
- params->set_target(Identity(name, mojom::kRootUserID));
- params->set_remote_interfaces(GetProxy(&remote_interfaces));
- params->set_local_interfaces(std::move(local_interfaces));
- shell_->Connect(std::move(params));
-}
-
-} // namespace shell
-} // namespace mojo
« no previous file with comments | « mojo/shell/standalone/context.h ('k') | mojo/shell/standalone/desktop/launcher_process.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698