esiCppAccel.cpp

Go to the documentation of this file.

//===- esiaccel.cpp - ESI runtime python bindings ---------------*- C++ -*-===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//
//
// Simply wrap the C++ API into a Python module called 'esiaccel'.
//
//===----------------------------------------------------------------------===//
 
#include "esi/Accelerator.h"
#include "esi/Services.h"
 
#include "esi/backends/Cosim.h"
 
#include <sstream>
 
// pybind11 includes
#include <pybind11/pybind11.h>
namespace py = pybind11;
 
#include <pybind11/stl.h>
 
using namespace esi;
using namespace esi::services;
 
namespace pybind11 {
/// Pybind11 needs a little help downcasting with non-bound instances.
template <>
struct polymorphic_type_hook<ChannelPort> {
  static const void *get(const ChannelPort *port, const std::type_info *&type) {
    if (auto p = dynamic_cast<const WriteChannelPort *>(port)) {
      type = &typeid(WriteChannelPort);
      return p;
    }
    if (auto p = dynamic_cast<const ReadChannelPort *>(port)) {
      type = &typeid(ReadChannelPort);
      return p;
    }
    return port;
  }
};
} // namespace pybind11
 
// NOLINTNEXTLINE(readability-identifier-naming)
PYBIND11_MODULE(esiCppAccel, m) {
  py::class_<Type>(m, "Type")
      .def_property_readonly("id", &Type::getID)
      .def("__repr__", [](Type &t) { return "<" + t.getID() + ">"; });
  py::class_<ChannelType, Type>(m, "ChannelType")
      .def_property_readonly("inner", &ChannelType::getInner,
                             py::return_value_policy::reference);
  py::enum_<BundleType::Direction>(m, "Direction")
      .value("To", BundleType::Direction::To)
      .value("From", BundleType::Direction::From)
      .export_values();
  py::class_<BundleType, Type>(m, "BundleType")
      .def_property_readonly("channels", &BundleType::getChannels,
                             py::return_value_policy::reference);
  py::class_<VoidType, Type>(m, "VoidType");
  py::class_<AnyType, Type>(m, "AnyType");
  py::class_<BitVectorType, Type>(m, "BitVectorType")
      .def_property_readonly("width", &BitVectorType::getWidth);
  py::class_<BitsType, BitVectorType>(m, "BitsType");
  py::class_<IntegerType, BitVectorType>(m, "IntegerType");
  py::class_<SIntType, IntegerType>(m, "SIntType");
  py::class_<UIntType, IntegerType>(m, "UIntType");
  py::class_<StructType, Type>(m, "StructType")
      .def_property_readonly("fields", &StructType::getFields,
                             py::return_value_policy::reference);
  py::class_<ArrayType, Type>(m, "ArrayType")
      .def_property_readonly("element", &ArrayType::getElementType,
                             py::return_value_policy::reference)
      .def_property_readonly("size", &ArrayType::getSize);
 
  py::class_<Context>(m, "Context")
      .def(py::init<>())
      .def("connect", &Context::connect);
 
  py::class_<ModuleInfo>(m, "ModuleInfo")
      .def_property_readonly("name", [](ModuleInfo &info) { return info.name; })
      .def_property_readonly("summary",
                             [](ModuleInfo &info) { return info.summary; })
      .def_property_readonly("version",
                             [](ModuleInfo &info) { return info.version; })
      .def_property_readonly("repo", [](ModuleInfo &info) { return info.repo; })
      .def_property_readonly("commit_hash",
                             [](ModuleInfo &info) { return info.commitHash; })
      // TODO: "extra" field.
      .def("__repr__", [](ModuleInfo &info) {
        std::string ret;
        std::stringstream os(ret);
        os << info;
        return os.str();
      });
 
  py::class_<SysInfo>(m, "SysInfo")
      .def("esi_version", &SysInfo::getEsiVersion)
      .def("json_manifest", &SysInfo::getJsonManifest);
 
  py::class_<services::MMIO>(m, "MMIO")
      .def("read", &services::MMIO::read)
      .def("write", &services::MMIO::write);
 
  py::class_<AppID>(m, "AppID")
      .def(py::init<std::string, std::optional<uint32_t>>(), py::arg("name"),
           py::arg("idx") = std::nullopt)
      .def_property_readonly("name", [](AppID &id) { return id.name; })
      .def_property_readonly("idx",
                             [](AppID &id) -> py::object {
                               if (id.idx)
                                 return py::cast(id.idx);
                               return py::none();
                             })
      .def("__repr__",
           [](AppID &id) {
             std::string ret = "<" + id.name;
             if (id.idx)
               ret = ret + "[" + std::to_string(*id.idx) + "]";
             ret = ret + ">";
             return ret;
           })
      .def("__eq__", [](AppID &a, AppID &b) { return a == b; })
      .def("__hash__", [](AppID &id) {
        // TODO: This is a bad hash function. Replace it.
        return std::hash<std::string>{}(id.name) ^
               (std::hash<uint32_t>{}(id.idx.value_or(-1)) << 1);
      });
 
  py::class_<std::future<MessageData>>(m, "MessageDataFuture")
      .def("valid", &std::future<MessageData>::valid)
      .def("wait", &std::future<MessageData>::wait)
      .def("get", [](std::future<MessageData> &f) {
        MessageData data = f.get();
        return py::bytearray((const char *)data.getBytes(), data.getSize());
      });
 
  py::class_<ChannelPort>(m, "ChannelPort")
      .def("connect", &ChannelPort::connect)
      .def_property_readonly("type", &ChannelPort::getType,
                             py::return_value_policy::reference);
 
  py::class_<WriteChannelPort, ChannelPort>(m, "WriteChannelPort")
      .def("write", [](WriteChannelPort &p, py::bytearray &data) {
        py::buffer_info info(py::buffer(data).request());
        std::vector<uint8_t> dataVec((uint8_t *)info.ptr,
                                     (uint8_t *)info.ptr + info.size);
        p.write(dataVec);
      });
  py::class_<ReadChannelPort, ChannelPort>(m, "ReadChannelPort")
      .def("read",
           [](ReadChannelPort &p) -> py::object {
             MessageData data;
             if (!p.read(data))
               return py::none();
             return py::bytearray((const char *)data.getBytes(),
                                  data.getSize());
           })
      .def("read_async", &ReadChannelPort::readAsync);
 
  py::class_<BundlePort>(m, "BundlePort")
      .def_property_readonly("id", &BundlePort::getID)
      .def_property_readonly("channels", &BundlePort::getChannels,
                             py::return_value_policy::reference)
      .def("getWrite", &BundlePort::getRawWrite,
           py::return_value_policy::reference)
      .def("getRead", &BundlePort::getRawRead,
           py::return_value_policy::reference);
 
  py::class_<ServicePort, BundlePort>(m, "ServicePort");
  py::class_<FuncService::Function, ServicePort>(m, "Function")
      .def(
          "call",
          [](FuncService::Function &self,
             py::bytearray msg) -> std::future<MessageData> {
            py::buffer_info info(py::buffer(msg).request());
            std::vector<uint8_t> dataVec((uint8_t *)info.ptr,
                                         (uint8_t *)info.ptr + info.size);
            MessageData data(dataVec);
            return self.call(data);
          },
          py::return_value_policy::take_ownership)
      .def("connect", &FuncService::Function::connect);
 
  // Store this variable (not commonly done) as the "children" method needs for
  // "Instance" to be defined first.
  auto hwmodule =
      py::class_<HWModule>(m, "HWModule")
          .def_property_readonly("info", &HWModule::getInfo)
          .def_property_readonly("ports", &HWModule::getPorts,
                                 py::return_value_policy::reference);
 
  // In order to inherit methods from "HWModule", it needs to be defined first.
  py::class_<Instance, HWModule>(m, "Instance")
      .def_property_readonly("id", &Instance::getID);
 
  py::class_<Accelerator, HWModule>(m, "Accelerator");
 
  // Since this returns a vector of Instance*, we need to define Instance first
  // or else pybind11-stubgen complains.
  hwmodule.def_property_readonly("children", &HWModule::getChildren,
                                 py::return_value_policy::reference);
 
  auto accConn = py::class_<AcceleratorConnection>(m, "AcceleratorConnection")
                     .def(py::init(&registry::connect))
                     .def(
                         "sysinfo",
                         [](AcceleratorConnection &acc) {
                           return acc.getService<services::SysInfo>({});
                         },
                         py::return_value_policy::reference)
                     .def(
                         "get_service_mmio",
                         [](AcceleratorConnection &acc) {
                           return acc.getService<services::MMIO>({});
                         },
                         py::return_value_policy::reference);
 
// Only include this cosim-only feature if cosim is enabled.It's a bit of a hack
// to test both styles of manifest retrieval for cosim. Come up with a more
// generic way to set accelerator-specific properties/configurations.
#ifdef ESI_COSIM
  py::enum_<backends::cosim::CosimAccelerator::ManifestMethod>(
      m, "CosimManifestMethod")
      .value("ManifestCosim",
             backends::cosim::CosimAccelerator::ManifestMethod::Cosim)
      .value("ManifestMMIO",
             backends::cosim::CosimAccelerator::ManifestMethod::MMIO)
      .export_values();
 
  accConn.def(
      "set_manifest_method",
      [](AcceleratorConnection &acc,
         backends::cosim::CosimAccelerator::ManifestMethod method) {
        auto cosim = dynamic_cast<backends::cosim::CosimAccelerator *>(&acc);
        if (!cosim)
          throw std::runtime_error(
              "set_manifest_method only supported for cosim connections");
        cosim->setManifestMethod(method);
      });
#endif // ESI_COSIM
 
  py::class_<Manifest>(m, "Manifest")
      .def(py::init<Context &, std::string>())
      .def_property_readonly("api_version", &Manifest::getApiVersion)
      .def("build_accelerator", &Manifest::buildAccelerator,
           py::return_value_policy::take_ownership)
      .def_property_readonly("type_table", &Manifest::getTypeTable)
      .def_property_readonly("module_infos", &Manifest::getModuleInfos);
}