services/service_manager/background/background_service_manager.h

// Copyright 2016 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.

#ifndef SERVICES_SERVICE_MANAGER_BACKGROUND_BACKGROUND_SERVICE_MANAGER_H_
#define SERVICES_SERVICE_MANAGER_BACKGROUND_BACKGROUND_SERVICE_MANAGER_H_

#include <memory>

#include "base/callback_forward.h"
#include "base/macros.h"
#include "base/threading/thread.h"
#include "services/service_manager/public/cpp/identity.h"
#include "services/service_manager/public/interfaces/connector.mojom.h"
#include "services/service_manager/public/interfaces/service.mojom.h"
#include "services/service_manager/runner/host/service_process_launcher.h"

namespace base {
class SingleThreadTaskRunner;
class Value;
class WaitableEvent;
}

namespace service_manager {

class Context;
class Identity;
class ServiceManager;

// BackgroundServiceManager runs a Service Manager on a dedicated background
// thread.
class BackgroundServiceManager {
 public:
  BackgroundServiceManager(
      service_manager::ServiceProcessLauncher::Delegate* launcher_delegate,
      std::unique_ptr<base::Value> catalog_contents);
  ~BackgroundServiceManager();

  // Creates a service instance for |identity|. This is intended for use by the
  // Service Manager's embedder to register instances directly, without
  // requiring a Connector.
  //
  // |pid_receiver_request| may be null, in which case the service manager
  // assumes the new service is running in this process.
  void RegisterService(const Identity& identity,
                       mojom::ServicePtr service,
                       mojom::PIDReceiverRequest pid_receiver_request);

  // Provide a callback to be notified whenever a service is destroyed.
  // Typically the creator of BackgroundServiceManager will use this to shut
  // down when some set of services it created is destroyed. The |callback| is
  // called on whichever thread called this function.
  void SetInstanceQuitCallback(base::Callback<void(const Identity&)> callback);

 private:
  void InitializeOnBackgroundThread(
      service_manager::ServiceProcessLauncher::Delegate* launcher_delegate,
      std::unique_ptr<base::Value> catalog_contents);
  void ShutDownOnBackgroundThread(base::WaitableEvent* done_event);
  void RegisterServiceOnBackgroundThread(
      const Identity& identity,
      mojom::ServicePtrInfo service_info,
      mojom::PIDReceiverRequest pid_receiver_request);
  void SetInstanceQuitCallbackOnBackgroundThread(
      const scoped_refptr<base::SingleThreadTaskRunner>& main_task_runner,
      const base::Callback<void(const Identity&)>& callback);
  void OnInstanceQuitOnBackgroundThread(const Identity& identity);

  base::Thread background_thread_;

  // The ServiceManager context. Must only be used on the background thread.
  std::unique_ptr<Context> context_;

  DISALLOW_COPY_AND_ASSIGN(BackgroundServiceManager);
};

}  // namespace service_manager

#endif  // SERVICES_SERVICE_MANAGER_BACKGROUND_BACKGROUND_SERVICE_MANAGER_H_