trigger_record.cpp

Go to the documentation of this file.

 
#include "daqdataformats/TriggerRecord.hpp"
#include "daqdataformats/TriggerRecordHeader.hpp"
 
#include <pybind11/pybind11.h>
#include <pybind11/stl.h>
 
#include <memory>
#include <vector>
 
namespace py = pybind11;
 
namespace dunedaq::daqdataformats::python {
 
void
register_trigger_record(py::module& m)
{
  py::class_<TriggerRecordHeader>(m, "TriggerRecordHeader", pybind11::buffer_protocol())
    .def(py::init<std::vector<ComponentRequest> const&>())
    .def(py::init([](py::capsule capsule, bool copy_from_buffer) {
      return std::make_unique<TriggerRecordHeader>(capsule.get_pointer(), copy_from_buffer);
    }))
    .def(py::init<TriggerRecordHeader const&>())
    .def("get_header", &TriggerRecordHeader::get_header)
    .def("get_trigger_number", &TriggerRecordHeader::get_trigger_number)
    //.def("set_trigger_number", &TriggerRecordHeader::set_trigger_number)
    .def("get_trigger_timestamp", &TriggerRecordHeader::get_trigger_timestamp)
    //.def("set_trigger_timestamp", &TriggerRecordHeader::set_trigger_timestamp)
    .def("get_num_requested_components", &TriggerRecordHeader::get_num_requested_components)
    .def("get_run_number", &TriggerRecordHeader::get_run_number)
    //.def("set_run_number", &TriggerRecordHeader::set_run_number)
    .def("get_status_bits", &TriggerRecordHeader::get_status_bits)
    //.def("set_status_bits", &TriggerRecordHeader::set_status_bits)
    .def("get_status_bit", &TriggerRecordHeader::get_status_bit)
    //.def("set_status_bit", &TriggerRecordHeader::set_status_bit)
    .def("get_trigger_type", &TriggerRecordHeader::get_trigger_type)
    //.def("set_trigger_type", &TriggerRecordHeader::set_trigger_type)
    .def("get_sequence_number", &TriggerRecordHeader::get_sequence_number)
    //.def("set_sequence_number", &TriggerRecordHeader::set_sequence_number)
    .def("get_max_sequence_number", &TriggerRecordHeader::get_max_sequence_number)
    //.def("set_max_sequence_number", &TriggerRecordHeader::set_max_sequence_number)
    .def("get_total_size_bytes", &TriggerRecordHeader::get_total_size_bytes)
    .def(
      "get_storage_location", &TriggerRecordHeader::get_storage_location, py::return_value_policy::reference_internal)
    .def("at", &TriggerRecordHeader::at)
    .def("__getitem__", &TriggerRecordHeader::operator[], py::return_value_policy::reference_internal);
 
  py::class_<TriggerRecordHeaderData>(m, "TriggerRecordHeaderData")
    .def_property_readonly_static("s_trigger_record_header_magic",
                                  [](const TriggerRecordHeaderData& self) -> uint32_t { // NOLINT(build/unsigned)
                                    return self.s_trigger_record_header_magic;
                                  })
    .def_property_readonly_static("s_trigger_record_header_version",
                                  [](const TriggerRecordHeaderData& self) -> uint32_t { // NOLINT(build/unsigned)
                                    return self.s_trigger_record_header_version;
                                  })
    .def_property_readonly_static("s_invalid_number_components",
                                  [](const TriggerRecordHeaderData& self) -> uint64_t { // NOLINT(build/unsigned)
                                    return self.s_invalid_number_components;
                                  })
    .def_property_readonly_static("s_default_status_bits",
                                  [](const TriggerRecordHeaderData& self) -> uint32_t { // NOLINT(build/unsigned)
                                    return self.s_default_status_bits;
                                  })
    .def_property_readonly("trigger_record_header_marker",
                           [](const TriggerRecordHeaderData& self) -> uint32_t { // NOLINT(build/unsigned)
                             return self.trigger_record_header_marker;
                           })
    .def_property_readonly(
      "version", [](const TriggerRecordHeaderData& self) -> uint32_t { return self.version; }) // NOLINT(build/unsigned)
    .def_property_readonly("trigger_number",
                           [](const TriggerRecordHeaderData& self) -> trigger_number_t { return self.trigger_number; })
    .def_property_readonly("trigger_timestamp",
                           [](const TriggerRecordHeaderData& self) -> timestamp_t { return self.trigger_timestamp; })
    .def_property_readonly("num_requested_components",
                           [](const TriggerRecordHeaderData& self) -> uint64_t { // NOLINT(build/unsigned)
                             return self.num_requested_components;
                           })
    .def_property_readonly("run_number",
                           [](const TriggerRecordHeaderData& self) -> run_number_t { return self.run_number; })
    .def_property_readonly(
      "status_bits",
      [](const TriggerRecordHeaderData& self) -> uint32_t { return self.status_bits; }) // NOLINT(build/unsigned)
    .def_property_readonly("trigger_type",
                           [](const TriggerRecordHeaderData& self) -> trigger_type_t { return self.trigger_type; })
    .def_property_readonly(
      "sequence_number", [](const TriggerRecordHeaderData& self) -> sequence_number_t { return self.sequence_number; })
    .def_property_readonly("max_sequence_number", [](const TriggerRecordHeaderData& self) -> sequence_number_t {
      return self.max_sequence_number;
    });
 
  py::enum_<TriggerRecordStatusBits>(m, "TriggerRecordStatusBits")
    .value("kIncomplete", TriggerRecordStatusBits::kIncomplete)
    .value("kMismatch", TriggerRecordStatusBits::kMismatch)
    .value("kUnassigned2", TriggerRecordStatusBits::kUnassigned2)
    .value("kUnassigned3", TriggerRecordStatusBits::kUnassigned3)
    .value("kUnassigned4", TriggerRecordStatusBits::kUnassigned4)
    .value("kUnassigned5", TriggerRecordStatusBits::kUnassigned5)
    .value("kUnassigned6", TriggerRecordStatusBits::kUnassigned6)
    .value("kUnassigned7", TriggerRecordStatusBits::kUnassigned7)
    .value("kUnassigned8", TriggerRecordStatusBits::kUnassigned8)
    .value("kUnassigned9", TriggerRecordStatusBits::kUnassigned9)
    .value("kUnassigned10", TriggerRecordStatusBits::kUnassigned10)
    .value("kUnassigned11", TriggerRecordStatusBits::kUnassigned11)
    .value("kUnassigned12", TriggerRecordStatusBits::kUnassigned12)
    .value("kUnassigned13", TriggerRecordStatusBits::kUnassigned13)
    .value("kUnassigned14", TriggerRecordStatusBits::kUnassigned14)
    .value("kUnassigned15", TriggerRecordStatusBits::kUnassigned15)
    .value("kUnassigned16", TriggerRecordStatusBits::kUnassigned16)
    .value("kUnassigned17", TriggerRecordStatusBits::kUnassigned17)
    .value("kUnassigned18", TriggerRecordStatusBits::kUnassigned18)
    .value("kUnassigned19", TriggerRecordStatusBits::kUnassigned19)
    .value("kUnassigned20", TriggerRecordStatusBits::kUnassigned20)
    .value("kUnassigned21", TriggerRecordStatusBits::kUnassigned21)
    .value("kUnassigned22", TriggerRecordStatusBits::kUnassigned22)
    .value("kUnassigned23", TriggerRecordStatusBits::kUnassigned23)
    .value("kUnassigned24", TriggerRecordStatusBits::kUnassigned24)
    .value("kUnassigned25", TriggerRecordStatusBits::kUnassigned25)
    .value("kUnassigned26", TriggerRecordStatusBits::kUnassigned26)
    .value("kUnassigned27", TriggerRecordStatusBits::kUnassigned27)
    .value("kUnassigned28", TriggerRecordStatusBits::kUnassigned28)
    .value("kUnassigned29", TriggerRecordStatusBits::kUnassigned29)
    .value("kUnassigned30", TriggerRecordStatusBits::kUnassigned30)
    .value("kUnassigned31", TriggerRecordStatusBits::kUnassigned31)
    .value("kInvalid", TriggerRecordStatusBits::kInvalid);
 
  py::class_<TriggerRecord> py_trigger_record(m, "TriggerRecord", pybind11::buffer_protocol());
  py_trigger_record.def(py::init<TriggerRecordHeader const&>())
    .def(py::init<std::vector<ComponentRequest> const&>())
    .def(
      "get_header_ref",
      [](TriggerRecord& self) { return self.get_header_ref(); },
      py::return_value_policy::reference_internal)
    //    .def("set_header", &TriggerRecord::set_header)
    .def("get_header_data", &TriggerRecord::get_header_data)
    .def(
      "get_fragments_ref",
      [](TriggerRecord& self) {
        auto fragments = py::list();
        for (auto& fragment : self.get_fragments_ref()) {
          auto py_fragment = py::cast(*fragment, py::return_value_policy::reference);
          fragments.append(py_fragment);
        }
        return fragments;
      },
      py::return_value_policy::reference_internal)
    .def("get_total_size_bytes", &TriggerRecord::get_total_size_bytes)
    .def("get_sum_of_fragment_payload_sizes", &TriggerRecord::get_sum_of_fragment_payload_sizes);
} // NOLINT
 
} // namespace dunedaq::daqdataformats::python