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

Unified Diff: content/common/mojo/mojo_child_connection.cc

Issue 2398783002: Rename a bunch of Mojo Application stuff to reference Services. (Closed)
Patch Set: . Created 4 years, 2 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 | « content/common/mojo/mojo_child_connection.h ('k') | content/common/mojo/mojo_shell_connection_impl.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/common/mojo/mojo_child_connection.cc
diff --git a/content/common/mojo/mojo_child_connection.cc b/content/common/mojo/mojo_child_connection.cc
deleted file mode 100644
index 8616d45f0be17962a17223ba880d73e9eff4d603..0000000000000000000000000000000000000000
--- a/content/common/mojo/mojo_child_connection.cc
+++ /dev/null
@@ -1,153 +0,0 @@
-// Copyright 2015 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 "content/common/mojo/mojo_child_connection.h"
-
-#include <stdint.h>
-#include <utility>
-
-#include "base/macros.h"
-#include "content/public/common/mojo_shell_connection.h"
-#include "mojo/edk/embedder/embedder.h"
-#include "mojo/public/cpp/system/message_pipe.h"
-#include "services/shell/public/cpp/connector.h"
-#include "services/shell/public/cpp/identity.h"
-#include "services/shell/public/cpp/interface_registry.h"
-#include "services/shell/public/interfaces/service.mojom.h"
-
-namespace content {
-
-namespace {
-
-void CallBinderOnTaskRunner(
- const shell::InterfaceRegistry::Binder& binder,
- scoped_refptr<base::SequencedTaskRunner> task_runner,
- const std::string& interface_name,
- mojo::ScopedMessagePipeHandle request_handle) {
- task_runner->PostTask(
- FROM_HERE,
- base::Bind(binder, interface_name, base::Passed(&request_handle)));
-}
-
-} // namespace
-
-class MojoChildConnection::IOThreadContext
- : public base::RefCountedThreadSafe<IOThreadContext> {
- public:
- IOThreadContext() {}
-
- void Initialize(const shell::Identity& child_identity,
- shell::Connector* connector,
- mojo::ScopedMessagePipeHandle service_pipe,
- scoped_refptr<base::SequencedTaskRunner> io_task_runner) {
- DCHECK(!io_task_runner_);
- io_task_runner_ = io_task_runner;
- std::unique_ptr<shell::Connector> io_thread_connector;
- if (connector)
- io_thread_connector = connector->Clone();
- io_task_runner_->PostTask(
- FROM_HERE,
- base::Bind(&IOThreadContext::InitializeOnIOThread, this,
- child_identity,
- base::Passed(&io_thread_connector),
- base::Passed(&service_pipe)));
- }
-
- void ShutDown() {
- if (!io_task_runner_)
- return;
- bool posted = io_task_runner_->PostTask(
- FROM_HERE,
- base::Bind(&IOThreadContext::ShutDownOnIOThread, this));
- DCHECK(posted);
- }
-
- void GetRemoteInterfaceOnIOThread(
- const std::string& interface_name,
- mojo::ScopedMessagePipeHandle request_handle) {
- if (connection_) {
- connection_->GetRemoteInterfaces()->GetInterface(
- interface_name, std::move(request_handle));
- }
- }
-
- void SetProcessHandle(base::ProcessHandle handle) {
- DCHECK(io_task_runner_);
- io_task_runner_->PostTask(
- FROM_HERE,
- base::Bind(&IOThreadContext::SetProcessHandleOnIOThread, this, handle));
- }
-
- private:
- friend class base::RefCountedThreadSafe<IOThreadContext>;
-
- virtual ~IOThreadContext() {}
-
- void InitializeOnIOThread(
- const shell::Identity& child_identity,
- std::unique_ptr<shell::Connector> connector,
- mojo::ScopedMessagePipeHandle service_pipe) {
- shell::mojom::ServicePtr service;
- service.Bind(mojo::InterfacePtrInfo<shell::mojom::Service>(
- std::move(service_pipe), 0u));
- shell::mojom::PIDReceiverRequest pid_receiver_request =
- mojo::GetProxy(&pid_receiver_);
-
- shell::Connector::ConnectParams params(child_identity);
- params.set_client_process_connection(std::move(service),
- std::move(pid_receiver_request));
-
- // In some unit testing scenarios a null connector is passed.
- if (connector)
- connection_ = connector->Connect(&params);
- }
-
- void ShutDownOnIOThread() {
- connection_.reset();
- pid_receiver_.reset();
- }
-
- void SetProcessHandleOnIOThread(base::ProcessHandle handle) {
- DCHECK(pid_receiver_.is_bound());
- pid_receiver_->SetPID(base::GetProcId(handle));
- pid_receiver_.reset();
- }
-
- scoped_refptr<base::SequencedTaskRunner> io_task_runner_;
- std::unique_ptr<shell::Connection> connection_;
- shell::mojom::PIDReceiverPtr pid_receiver_;
-
- DISALLOW_COPY_AND_ASSIGN(IOThreadContext);
-};
-
-MojoChildConnection::MojoChildConnection(
- const std::string& service_name,
- const std::string& instance_id,
- const std::string& child_token,
- shell::Connector* connector,
- scoped_refptr<base::SequencedTaskRunner> io_task_runner)
- : context_(new IOThreadContext),
- child_identity_(service_name, shell::mojom::kInheritUserID, instance_id),
- service_token_(mojo::edk::GenerateRandomToken()),
- weak_factory_(this) {
- mojo::ScopedMessagePipeHandle service_pipe =
- mojo::edk::CreateParentMessagePipe(service_token_, child_token);
-
- context_->Initialize(child_identity_, connector, std::move(service_pipe),
- io_task_runner);
- remote_interfaces_.Forward(
- base::Bind(&CallBinderOnTaskRunner,
- base::Bind(&IOThreadContext::GetRemoteInterfaceOnIOThread,
- context_), io_task_runner));
-}
-
-MojoChildConnection::~MojoChildConnection() {
- context_->ShutDown();
-}
-
-void MojoChildConnection::SetProcessHandle(base::ProcessHandle handle) {
- context_->SetProcessHandle(handle);
-}
-
-} // namespace content
« no previous file with comments | « content/common/mojo/mojo_child_connection.h ('k') | content/common/mojo/mojo_shell_connection_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698