Index: services/shell/standalone/context.cc |
diff --git a/services/shell/standalone/context.cc b/services/shell/standalone/context.cc |
deleted file mode 100644 |
index 0c30797fef1bc70e453e27055e09c2fd6182296e..0000000000000000000000000000000000000000 |
--- a/services/shell/standalone/context.cc |
+++ /dev/null |
@@ -1,295 +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 "services/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/json/json_file_value_serializer.h" |
-#include "base/lazy_instance.h" |
-#include "base/location.h" |
-#include "base/macros.h" |
-#include "base/memory/ptr_util.h" |
-#include "base/path_service.h" |
-#include "base/process/process_info.h" |
-#include "base/run_loop.h" |
-#include "base/single_thread_task_runner.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/threading/thread_task_runner_handle.h" |
-#include "base/trace_event/trace_event.h" |
-#include "build/build_config.h" |
-#include "components/tracing/common/tracing_switches.h" |
-#include "mojo/edk/embedder/embedder.h" |
-#include "mojo/public/cpp/bindings/strong_binding.h" |
-#include "services/catalog/catalog.h" |
-#include "services/catalog/store.h" |
-#include "services/shell/connect_params.h" |
-#include "services/shell/public/cpp/names.h" |
-#include "services/shell/runner/common/switches.h" |
-#include "services/shell/runner/host/in_process_native_runner.h" |
-#include "services/shell/runner/host/out_of_process_native_runner.h" |
-#include "services/shell/standalone/tracer.h" |
-#include "services/shell/switches.h" |
-#include "services/tracing/public/cpp/provider.h" |
-#include "services/tracing/public/cpp/switches.h" |
-#include "services/tracing/public/interfaces/tracing.mojom.h" |
- |
-#if defined(OS_MACOSX) |
-#include "services/shell/runner/host/mach_broker.h" |
-#endif |
- |
-namespace shell { |
-namespace { |
- |
-base::FilePath::StringType GetPathFromCommandLineSwitch( |
- const base::StringPiece& value) { |
-#if defined(OS_POSIX) |
- return value.as_string(); |
-#elif defined(OS_WIN) |
- return base::UTF8ToUTF16(value); |
-#endif // OS_POSIX |
-} |
- |
-// Used to ensure we only init once. |
-class Setup { |
- public: |
- Setup() { mojo::edk::Init(); } |
- |
- ~Setup() {} |
- |
- private: |
- DISALLOW_COPY_AND_ASSIGN(Setup); |
-}; |
- |
-class TracingInterfaceProvider : public mojom::InterfaceProvider { |
- public: |
- explicit TracingInterfaceProvider(Tracer* tracer) : tracer_(tracer) {} |
- ~TracingInterfaceProvider() override {} |
- |
- // mojom::InterfaceProvider: |
- void GetInterface(const std::string& interface_name, |
- mojo::ScopedMessagePipeHandle client_handle) override { |
- if (tracer_ && interface_name == tracing::mojom::Provider::Name_) { |
- tracer_->ConnectToProvider( |
- mojo::MakeRequest<tracing::mojom::Provider>( |
- std::move(client_handle))); |
- } |
- } |
- |
- private: |
- Tracer* tracer_; |
- |
- DISALLOW_COPY_AND_ASSIGN(TracingInterfaceProvider); |
-}; |
- |
-const size_t kMaxBlockingPoolThreads = 3; |
- |
-std::unique_ptr<base::Thread> CreateIOThread(const char* name) { |
- std::unique_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(std::unique_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(); |
- |
- service_manager_runner_ = base::ThreadTaskRunnerHandle::Get(); |
- blocking_pool_ = |
- new base::SequencedWorkerPool(kMaxBlockingPoolThreads, "blocking_pool", |
- base::TaskPriority::USER_VISIBLE); |
- |
- init_edk_ = !init_params || init_params->init_edk; |
- if (init_edk_) { |
- mojo::edk::InitIPCSupport(this, io_thread_->task_runner().get()); |
-#if defined(OS_MACOSX) |
- mojo::edk::SetMachPortProvider(MachBroker::GetInstance()->port_provider()); |
-#endif |
- } |
- |
- std::unique_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)); |
- } |
- std::unique_ptr<catalog::Store> store; |
- if (init_params) |
- store = std::move(init_params->catalog_store); |
- catalog_.reset( |
- new catalog::Catalog(blocking_pool_.get(), std::move(store), nullptr)); |
- service_manager_.reset(new ServiceManager(std::move(runner_factory), |
- catalog_->TakeService())); |
- |
- if (command_line.HasSwitch(::switches::kServiceOverrides)) { |
- base::FilePath overrides_file(GetPathFromCommandLineSwitch( |
- command_line.GetSwitchValueASCII(::switches::kServiceOverrides))); |
- JSONFileValueDeserializer deserializer(overrides_file); |
- int error = 0; |
- std::string message; |
- std::unique_ptr<base::Value> contents = |
- deserializer.Deserialize(&error, &message); |
- if (!contents) { |
- LOG(ERROR) << "Failed to parse service overrides file: " << message; |
- } else { |
- std::unique_ptr<ServiceOverrides> service_overrides = |
- base::MakeUnique<ServiceOverrides>(std::move(contents)); |
- for (const auto& iter : service_overrides->entries()) { |
- if (!iter.second.package_name.empty()) |
- catalog_->OverridePackageName(iter.first, iter.second.package_name); |
- } |
- service_manager_->SetServiceOverrides(std::move(service_overrides)); |
- } |
- } |
- |
- mojom::InterfaceProviderPtr tracing_remote_interfaces; |
- mojom::InterfaceProviderPtr tracing_local_interfaces; |
- mojo::MakeStrongBinding(base::MakeUnique<TracingInterfaceProvider>(&tracer_), |
- mojo::GetProxy(&tracing_local_interfaces)); |
- |
- std::unique_ptr<ConnectParams> params(new ConnectParams); |
- params->set_source(CreateServiceManagerIdentity()); |
- params->set_target(Identity("service:tracing", mojom::kRootUserID)); |
- params->set_remote_interfaces(mojo::GetProxy(&tracing_remote_interfaces)); |
- service_manager_->Connect(std::move(params)); |
- |
- if (command_line.HasSwitch(tracing::kTraceStartup)) { |
- tracing::mojom::CollectorPtr coordinator; |
- auto coordinator_request = GetProxy(&coordinator); |
- tracing_remote_interfaces->GetInterface( |
- tracing::mojom::Collector::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::mojom::StartupPerformanceDataCollectorPtr collector; |
- tracing_remote_interfaces->GetInterface( |
- tracing::mojom::StartupPerformanceDataCollector::Name_, |
- mojo::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. |
- service_manager_.reset(); |
- |
- DCHECK_EQ(base::ThreadTaskRunnerHandle::Get(), service_manager_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::ThreadTaskRunnerHandle::Get()->PostTask( |
- FROM_HERE, base::Bind(mojo::edk::ShutdownIPCSupport)); |
- // We'll quit when we get OnShutdownComplete(). |
- base::RunLoop().Run(); |
-} |
- |
-void Context::OnShutdownComplete() { |
- DCHECK_EQ(base::ThreadTaskRunnerHandle::Get(), service_manager_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) == kNameType_Service) { |
- Run(possible_app); |
- break; |
- } |
- } |
-} |
- |
-void Context::Run(const std::string& name) { |
- service_manager_->SetInstanceQuitCallback(base::Bind(&OnInstanceQuit, name)); |
- |
- mojom::InterfaceProviderPtr remote_interfaces; |
- mojom::InterfaceProviderPtr local_interfaces; |
- |
- std::unique_ptr<ConnectParams> params(new ConnectParams); |
- params->set_source(CreateServiceManagerIdentity()); |
- params->set_target(Identity(name, mojom::kRootUserID)); |
- params->set_remote_interfaces(mojo::GetProxy(&remote_interfaces)); |
- service_manager_->Connect(std::move(params)); |
-} |
- |
-} // namespace shell |