| 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(¶ms);
|
| - }
|
| -
|
| - 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
|
|
|