Utils.hpp

Go to the documentation of this file.

#ifndef DPDKLIBS_SRC_UTILS_HPP_
#define DPDKLIBS_SRC_UTILS_HPP_
 
#include "IPV4UDPPacket.hpp"
 
#include "detdataformats/DAQEthHeader.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
 
#include "fmt/core.h"
#include "rte_ether.h"
#include "rte_mbuf.h"
 
#include <cstdint>
#include <iostream>
#include <mutex>
#include <set>
#include <string>
#include <utility>
#include <vector>
 
namespace dunedaq {
 
ERS_DECLARE_ISSUE(dpdklibs, 
  BadPacketHeaderIssue, 
  "BadPacketHeaderIssue: \"" << ers_messg << "\"",
  ((std::string)ers_messg))
 
namespace dpdklibs {
namespace udp {
 
uint16_t
get_payload_size_udp_hdr(struct rte_udp_hdr* udp_hdr);
uint16_t
get_payload_size(struct ipv4_udp_packet_hdr* ipv4_udp_hdr);
 
rte_be32_t
ip_address_dotdecimal_to_binary(uint8_t byte1, uint8_t byte2, uint8_t byte3, uint8_t byte4);
struct ipaddr
ip_address_binary_to_dotdecimal(rte_le32_t binary_ipv4_address);
 
std::string
get_ipv4_decimal_addr_str(struct ipaddr ipv4_address);
 
char*
get_udp_payload(const rte_mbuf* mbuf);
 
// void dump_udp_header(struct ipv4_udp_packet_hdr * pkt);
std::string
get_udp_header_str(struct rte_mbuf* mbuf);
 
std::string
get_udp_packet_str(struct rte_mbuf* mbuf);
 
void
add_file_contents_to_vector(const std::string& filename, std::vector<char>& buffervec);
 
std::vector<std::pair<const void*, int>>
get_ethernet_packets(const std::vector<char>& buffervec);
 
void
set_daqethheader_test_values(detdataformats::DAQEthHeader& daqethheader_obj) noexcept;
 
std::string
get_rte_mbuf_str(const rte_mbuf* mbuf) noexcept;
 
struct StreamUID
{
  uint64_t det_id : 6;
  uint64_t crate_id : 10;
  uint64_t slot_id : 4;
  uint64_t stream_id : 8;
 
  StreamUID() = default;
 
  StreamUID(const detdataformats::DAQEthHeader& daq_hdr)
    : det_id(daq_hdr.det_id)
    , crate_id(daq_hdr.crate_id)
    , slot_id(daq_hdr.slot_id)
    , stream_id(daq_hdr.stream_id){};
 
  bool operator<(const StreamUID& rhs) const { return std::tie(det_id, crate_id, slot_id, stream_id) < std::tie(rhs.det_id, rhs.crate_id, rhs.slot_id, rhs.stream_id); }
 
  bool operator==(const StreamUID& rhs) const { return det_id == rhs.det_id && crate_id == rhs.crate_id && slot_id == rhs.slot_id && stream_id == rhs.stream_id; }
  operator std::string() const { return fmt::format("({}, {}, {}, {})", det_id, crate_id, slot_id, stream_id); }
};
 
} // namespace udp
} // namespace dpdklibs
} // namespace dunedaq
 
#endif // DPDKLIBS_SRC_UTILS_HPP_