msgpack Namespace Reference

Functions
	MSGPACK_API_VERSION_NAMESPACE (MSGPACK_DEFAULT_API_NS)

Function Documentation

MSGPACK_API_VERSION_NAMESPACE()

msgpack::MSGPACK_API_VERSION_NAMESPACE

(

MSGPACK_DEFAULT_API_NS

)

Definition at line 23 of file Fragment_serialization.hpp.

{
  namespace adaptor {
 
  template<>
  struct pack<dunedaq::daqdataformats::Fragment>
  {
    template<typename Stream>
    packer<Stream>& operator()(msgpack::packer<Stream>& o, dunedaq::daqdataformats::Fragment const& frag) const
    {
      o.pack_bin(frag.get_size());                                                             // pack header and size
      o.pack_bin_body(static_cast<const char*>(frag.get_storage_location()), frag.get_size()); // pack payload
      return o;
    }
  };
 
  // Typically we use convert<> for deserialization, but Fragment 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::Fragment>
  {
    dunedaq::daqdataformats::Fragment operator()(msgpack::object const& o) const
    {
      // The second argument to the Fragment ctor is whether to copy
      // the data array into the Fragment's own storage. Putting false
      // here would be faster, but we have to copy, since the returned
      // Fragment might outlast the msgpack::object which owns/points
      // to the underlying data.
      return dunedaq::daqdataformats::Fragment(const_cast<char*>(o.via.bin.ptr),
                                               dunedaq::daqdataformats::Fragment::BufferAdoptionMode::kCopyFromBuffer);
    }
  };
 
  template<>
  struct pack<std::unique_ptr<dunedaq::daqdataformats::Fragment>>
  {
    template<typename Stream>
    packer<Stream>& operator()(msgpack::packer<Stream>& o,
                               std::unique_ptr<dunedaq::daqdataformats::Fragment> const& frag) const
    {
      o.pack_bin(frag->get_size());                                                              // pack header and size
      o.pack_bin_body(static_cast<const char*>(frag->get_storage_location()), frag->get_size()); // pack payload
      return o;
    }
  };
 
  // Typically we use convert<> for deserialization, but Fragment 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<std::unique_ptr<dunedaq::daqdataformats::Fragment>>
  {
    std::unique_ptr<dunedaq::daqdataformats::Fragment> operator()(msgpack::object const& o) const
    {
      // The second argument to the Fragment ctor is whether to copy
      // the data array into the Fragment's own storage. Putting false
      // here would be faster, but we have to copy, since the returned
      // Fragment might outlast the msgpack::object which owns/points
      // to the underlying data.
      return std::make_unique<dunedaq::daqdataformats::Fragment>(
        const_cast<char*>(o.via.bin.ptr), dunedaq::daqdataformats::Fragment::BufferAdoptionMode::kCopyFromBuffer);
    }
  };
  } // namespace adaptor
} // namespace MSGPACK_DEFAULT_API_NS