TriggerRecordHeader_serialization.hpp

Go to the documentation of this file.

 
#ifndef DFMESSAGES_INCLUDE_DFMESSAGES_TRIGGERRECORDHEADER_SERIALIZATION_HPP_
#define DFMESSAGES_INCLUDE_DFMESSAGES_TRIGGERRECORDHEADER_SERIALIZATION_HPP_
 
#include "daqdataformats/TriggerRecordHeader.hpp"
#include "serialization/Serialization.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
 
#include <vector>
 
namespace dunedaq {
// Disable coverage collection LCOV_EXCL_START
ERS_DECLARE_ISSUE(dfmessages,
                  CannotDeserializeTriggerRecordHeader,
                  "Cannot deserialize TriggerRecordHeader from JSON due to type mismatch", )
// Re-enable coverage collection LCOV_EXCL_STOP
} // namespace dunedaq
 
// MsgPack serialization functions (which just put the raw bytes of
// the fragment array into a MsgPack message)
namespace msgpack {
MSGPACK_API_VERSION_NAMESPACE(MSGPACK_DEFAULT_API_NS)
{
  namespace adaptor {
 
  template<>
  struct pack<dunedaq::daqdataformats::TriggerRecordHeader>
  {
    template<typename Stream>
    packer<Stream>& operator()(msgpack::packer<Stream>& o,
                               dunedaq::daqdataformats::TriggerRecordHeader const& trh) const
    {
      size_t size = trh.get_total_size_bytes();
      o.pack_bin(size);                                                            // pack header and size
      o.pack_bin_body(static_cast<const char*>(trh.get_storage_location()), size); // pack payload
      return o;
    }
  };
 
  // Typically we use convert<> for deserialization, but TriggerRecordHeader isn't
  // default constructible, so we have to use as<>. See:
  // https://github.com/msgpack/msgpack-c/wiki/v2_0_cpp_adaptor#non-default-constructible-class-support-c11-only-since-120
  template<>
  struct as<dunedaq::daqdataformats::TriggerRecordHeader>
  {
    dunedaq::daqdataformats::TriggerRecordHeader operator()(msgpack::object const& o) const
    {
      return dunedaq::daqdataformats::TriggerRecordHeader(const_cast<char*>(o.via.bin.ptr), true);
    }
  };
 
  } // namespace adaptor
} // namespace MSGPACK_DEFAULT_API_NS
} // namespace msgpack
 
DUNE_DAQ_SERIALIZABLE(dunedaq::daqdataformats::TriggerRecordHeader, "TriggerRecordHeader");
 
#endif // DFMESSAGES_INCLUDE_DFMESSAGES_TRIGGERRECORDHEADER_SERIALIZATION_HPP_