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

#include "connection-destroyer.h"

#include <inttypes.h>

#include "../shared/log.h"
#include "device-controller-connection.h"
#include "proxy-iostate.h"
#include "zx-device.h"

namespace devmgr {

zx_status_t ConnectionDestroyer::QueueProxyConnection(async_dispatcher_t* dispatcher,
                                                      ProxyIostate* conn) {
  zx_packet_user_t pkt = {};
  pkt.u64[0] = static_cast<uint64_t>(Type::Proxy);
  pkt.u64[1] = reinterpret_cast<uintptr_t>(conn);
  return receiver_.QueuePacket(dispatcher, &pkt);
}

zx_status_t ConnectionDestroyer::QueueDeviceControllerConnection(async_dispatcher_t* dispatcher,
                                                                 DeviceControllerConnection* conn) {
  zx_packet_user_t pkt = {};
  pkt.u64[0] = static_cast<uint64_t>(Type::DeviceController);
  pkt.u64[1] = reinterpret_cast<uintptr_t>(conn);
  return receiver_.QueuePacket(dispatcher, &pkt);
}

void ConnectionDestroyer::Handler(async_dispatcher_t* dispatcher, async::Receiver* receiver,
                                  zx_status_t status, const zx_packet_user_t* data) {
  Type type = static_cast<Type>(data->u64[0]);
  uintptr_t ptr = data->u64[1];

  switch (type) {
    case Type::DeviceController: {
      auto conn = reinterpret_cast<DeviceControllerConnection*>(ptr);
      log(TRACE, "devhost: destroying devcoord conn '%p'\n", conn);
      delete conn;
      break;
    }
    case Type::Proxy: {
      auto conn = reinterpret_cast<ProxyIostate*>(ptr);
      log(TRACE, "devhost: destroying proxy conn '%p'\n", conn);
      delete conn;
      break;
    }
    default:
      ZX_ASSERT_MSG(false, "Unknown IosDestructionType %" PRIu64 "\n", data->u64[0]);
  }
}

}  // namespace devmgr