diagnostics/diagnosticsd/diagnosticsd_core_delegate_impl.cc

// Copyright 2018 The Chromium OS 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 "diagnostics/diagnosticsd/diagnosticsd_core_delegate_impl.h"

#include <utility>

#include <base/logging.h>
#include <dbus/diagnosticsd/dbus-constants.h>
#include <mojo/edk/embedder/embedder.h>
#include <mojo/edk/embedder/platform_handle.h>
#include <mojo/edk/embedder/scoped_platform_handle.h>

#include "mojo/diagnosticsd.mojom.h"

namespace diagnostics {

using MojomDiagnosticsdServiceFactory =
    chromeos::diagnosticsd::mojom::DiagnosticsdServiceFactory;

DiagnosticsdCoreDelegateImpl::DiagnosticsdCoreDelegateImpl(
    brillo::Daemon* daemon)
    : daemon_(daemon) {
  DCHECK(daemon_);
}

DiagnosticsdCoreDelegateImpl::~DiagnosticsdCoreDelegateImpl() = default;

std::unique_ptr<mojo::Binding<MojomDiagnosticsdServiceFactory>>
DiagnosticsdCoreDelegateImpl::BindDiagnosticsdMojoServiceFactory(
    MojomDiagnosticsdServiceFactory* mojo_service_factory,
    base::ScopedFD mojo_pipe_fd) {
  DCHECK(mojo_pipe_fd.is_valid());

  mojo::edk::SetParentPipeHandle(mojo::edk::ScopedPlatformHandle(
      mojo::edk::PlatformHandle(mojo_pipe_fd.release())));

  mojo::ScopedMessagePipeHandle mojo_pipe_handle =
      mojo::edk::CreateChildMessagePipe(
          kDiagnosticsdMojoConnectionChannelToken);
  if (!mojo_pipe_handle.is_valid()) {
    LOG(ERROR) << "Failed to create Mojo child message pipe";
    return nullptr;
  }

  return std::make_unique<mojo::Binding<MojomDiagnosticsdServiceFactory>>(
      mojo_service_factory, std::move(mojo_pipe_handle));
}

void DiagnosticsdCoreDelegateImpl::BeginDaemonShutdown() {
  daemon_->Quit();
}

}  // namespace diagnostics