dunedaq::dpdklibs::ifaceutils Namespace Reference

Functions
int	get_num_available_ifaces ()
void	iface_conf_rss_mode (struct rte_eth_conf &iface_conf, bool mode=false, bool offload=false)
int	iface_promiscuous_mode (std::uint16_t iface, bool mode=false)
bool	iface_valid (uint16_t iface)
void	hex_digits_to_stream (std::ostringstream &ostrs, int value, char separator=' ', char fill='0', int digits=2)
std::string	get_iface_mac_str (uint16_t iface)
std::string	get_iface_pci_str (uint16_t iface)
int	iface_reset (uint16_t iface)

Variables
static volatile uint8_t	dpdk_quit_signal
static const struct rte_eth_conf	iface_conf_default

Function Documentation

get_iface_mac_str()

std::string dunedaq::dpdklibs::ifaceutils::get_iface_mac_str ( uint16_t iface )

inline

Definition at line 107 of file RTEIfaceSetup.hpp.

{
  int retval = -1;
  struct rte_ether_addr mac_addr;
  retval = rte_eth_macaddr_get(iface, &mac_addr);
  if (retval != 0) {
    TLOG() << "Failed to get MAC address of interface! Err id: " << retval;
    return std::string("");
  } else {
    std::ostringstream ostrs;
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[0], ':');
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[1], ':');
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[2], ':');
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[3], ':');
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[4], ':');
    hex_digits_to_stream(ostrs, (int)mac_addr.addr_bytes[5]);
    std::string mac_str = ostrs.str();
    mac_str.erase(std::remove(mac_str.begin(), mac_str.end(), ' '), mac_str.end());  
    return mac_str;
  }
}

get_iface_pci_str()

std::string dunedaq::dpdklibs::ifaceutils::get_iface_pci_str ( uint16_t iface )

inline

Definition at line 130 of file RTEIfaceSetup.hpp.

{
  std::string iface_pci_addr_str;
  int retval = -1;
  struct rte_eth_dev_info dev_info;
  // Get interface info
  retval = rte_eth_dev_info_get(iface, &dev_info);
  if (retval != 0) {
    TLOG() << "Error during getting device (iface " << iface << ") retval: " << retval;
  } else if (dev_info.device) {
    auto dev_name = rte_dev_name(dev_info.device);
    iface_pci_addr_str = dev_name;
    //TLOG() << "Dev name: " << dev_name;
    //const auto bus = rte_dev_bus(dev_info.device);
    //const auto bus_info = rte_dev_bus_info(dev_info.device);
    //const auto dev_driver = rte_dev_driver(dev_info.device);
  }
  return iface_pci_addr_str;
}

get_num_available_ifaces()

int dunedaq::dpdklibs::ifaceutils::get_num_available_ifaces ( )

inline

Definition at line 53 of file RTEIfaceSetup.hpp.

                           {
  unsigned nb_ifaces = rte_eth_dev_count_avail();
  TLOG() << "Available interfaces: " << nb_ifaces;
  return nb_ifaces;
}

hex_digits_to_stream()

void dunedaq::dpdklibs::ifaceutils::hex_digits_to_stream ( std::ostringstream & ostrs, int value, char separator = ' ', char fill = '0', int digits = 2 )

inline

Definition at line 101 of file RTEIfaceSetup.hpp.

                                                                                                          {
  ostrs << std::setfill(fill) << std::setw(digits) << std::hex << value << std::dec << separator;
}

iface_conf_rss_mode()

void dunedaq::dpdklibs::ifaceutils::iface_conf_rss_mode ( struct rte_eth_conf & iface_conf, bool mode = false, bool offload = false )

inline

Definition at line 61 of file RTEIfaceSetup.hpp.

{
  if (mode) {
    iface_conf.rxmode.mq_mode = RTE_ETH_MQ_RX_RSS;
    if (offload) {
      iface_conf.rxmode.offloads |= RTE_ETH_RX_OFFLOAD_RSS_HASH;
    }
  } else {
    iface_conf.rxmode.mq_mode = RTE_ETH_MQ_RX_NONE;
  }
}

iface_promiscuous_mode()

int dunedaq::dpdklibs::ifaceutils::iface_promiscuous_mode ( std::uint16_t iface, bool mode = false )

inline

Definition at line 75 of file RTEIfaceSetup.hpp.

{
  int retval = -1;
  retval = rte_eth_promiscuous_get(iface);
  TLOG() << "Before modification attempt, promiscuous mode is: " << retval;
  if (mode) {
    retval = rte_eth_promiscuous_enable(iface);
  } else {
    retval = rte_eth_promiscuous_disable(iface); 
  }
  if (retval != 0) {
    TLOG() << "Couldn't modify promiscuous mode of iface[" << iface << "]! Error code: " << retval;
  }
  retval = rte_eth_promiscuous_get(iface);
  TLOG() << "New promiscuous mode of iface[" << iface << "] is: " << retval;
  return retval; 
}

iface_reset()

int dunedaq::dpdklibs::ifaceutils::iface_reset ( uint16_t iface )

inline

Definition at line 151 of file RTEIfaceSetup.hpp.

{
  int retval = -1;
  struct rte_eth_dev_info dev_info;
 
  // Get interface validity
  if (!rte_eth_dev_is_valid_port(iface)) {
    TLOG() << "Specified interface " << iface << " is not valid in EAL!";
    return retval;
  }
 
  // Carry out a reset of the interface
  retval = rte_eth_dev_reset(iface);
  if (retval != 0) {
    TLOG() << "Error during resetting device (iface " << iface << ") retval: " << retval;
    return retval;
  }
 
  return retval;
}

iface_valid()

bool dunedaq::dpdklibs::ifaceutils::iface_valid ( uint16_t iface )

inline

Definition at line 95 of file RTEIfaceSetup.hpp.

{
  return rte_eth_dev_is_valid_port(iface);
}

Variable Documentation

dpdk_quit_signal

volatile uint8_t dunedaq::dpdklibs::ifaceutils::dpdk_quit_signal

static

Definition at line 34 of file RTEIfaceSetup.hpp.

iface_conf_default

const struct rte_eth_conf dunedaq::dpdklibs::ifaceutils::iface_conf_default

static

Initial value:

                               = {
  .rxmode = {
    .mtu = 9000,
    .max_lro_pkt_size = 9000,
    
    .offloads = (RTE_ETH_RX_OFFLOAD_TIMESTAMP 
               | RTE_ETH_RX_OFFLOAD_IPV4_CKSUM
               | RTE_ETH_RX_OFFLOAD_UDP_CKSUM),
  },
 
  .txmode = {
    .offloads = (RTE_ETH_TX_OFFLOAD_MULTI_SEGS),
  },
}

Definition at line 36 of file RTEIfaceSetup.hpp.

                                                    {
  .rxmode = {
    .mtu = 9000,
    .max_lro_pkt_size = 9000,
    //.split_hdr_size = 0, // Deprecated in dpdk@22.11
    .offloads = (RTE_ETH_RX_OFFLOAD_TIMESTAMP 
               | RTE_ETH_RX_OFFLOAD_IPV4_CKSUM
               | RTE_ETH_RX_OFFLOAD_UDP_CKSUM),
  },
 
  .txmode = {
    .offloads = (RTE_ETH_TX_OFFLOAD_MULTI_SEGS),
  },
};