src/graphics/drivers/misc/goldfish/instance.h

// Copyright 2019 The Fuchsia 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 SRC_GRAPHICS_DRIVERS_MISC_GOLDFISH_INSTANCE_H_
#define SRC_GRAPHICS_DRIVERS_MISC_GOLDFISH_INSTANCE_H_

#include <fuchsia/hardware/goldfish/llcpp/fidl.h>
#include <lib/async-loop/cpp/loop.h>
#include <lib/async-loop/default.h>
#include <threads.h>
#include <zircon/types.h>

#include <map>
#include <memory>

#include <ddk/device.h>
#include <ddktl/device.h>
#include <ddktl/protocol/goldfish/pipe.h>

namespace goldfish {

class Pipe;
class Instance;
using InstanceType = ddk::Device<Instance, ddk::Messageable, ddk::Closable>;

// This class implements a pipe instance device. By opening the pipe device,
// an instance of this class will be created to service a new channel
// to the virtual device.
class Instance : public InstanceType,
                 public llcpp::fuchsia::hardware::goldfish::PipeDevice::Interface {
 public:
  explicit Instance(zx_device_t* parent);
  ~Instance();

  zx_status_t Bind();

  // |llcpp::fuchsia::hardware::goldfish::PipeDevice::Interface|
  void OpenPipe(zx::channel pipe_request, OpenPipeCompleter::Sync& completer) override;

  // FIDL interface
  zx_status_t FidlOpenPipe(zx_handle_t pipe_request_handle);

  // Device protocol implementation.
  zx_status_t DdkMessage(fidl_incoming_msg_t* msg, fidl_txn_t* txn);
  zx_status_t DdkClose(uint32_t flags);
  void DdkRelease();

 private:
  int ClientThread();

  thrd_t client_thread_{};
  async::Loop client_loop_;
  using PipeMap = std::map<Pipe*, std::unique_ptr<Pipe>>;
  PipeMap pipes_;

  DISALLOW_COPY_ASSIGN_AND_MOVE(Instance);
};

}  // namespace goldfish

#endif  // SRC_GRAPHICS_DRIVERS_MISC_GOLDFISH_INSTANCE_H_