dunedaq::utilities Namespace Reference

Classes
class	Named
	A Named is a DAQ object (Queue or DAQModule) which has an instance name. More...
class	NamedObject
	Implements the Named interface. More...
class	ReusableThread
class	TimestampEstimatorBase
	TimestampEstimatorBase is the base class for timestamp-based logic in test systems where the current timestamp must be estimated somehow (eg, because there is no hardware timing system). More...
class	TimestampEstimatorSystem
	TimestampEstimatorSystem is an implementation of TimestampEstimatorBase that uses the system clock to give the current timestamp. More...
class	TimestampEstimatorTimeSync
	TimestampEstimatorTimeSync is an implementation of TimestampEstimatorBase that uses TimeSync messages from an input queue to estimate the current timestamp. More...
class	WorkerThread
	WorkerThread contains a thread which runs the do_work() function. More...
struct	ZmqUri

Enumerations
enum	{ TLVL_TIME_SYNC_PROPERTIES = 17 , TLVL_TIME_SYNC_NOTES = 18 , TLVL_TIME_SYNC_NEW_ESTIMATE = 19 }

Functions
std::vector< std::string >	get_hostname_ips (std::string hostname)
std::string	get_interface_ip (std::string eth_device_name, bool throw_if_missing=false)

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
TLVL_TIME_SYNC_PROPERTIES
TLVL_TIME_SYNC_NOTES
TLVL_TIME_SYNC_NEW_ESTIMATE

Definition at line 24 of file TimestampEstimatorTimeSync.hpp.

{
  TLVL_TIME_SYNC_PROPERTIES = 17,
  TLVL_TIME_SYNC_NOTES = 18,
  TLVL_TIME_SYNC_NEW_ESTIMATE = 19,
};

Function Documentation

get_hostname_ips()

std::vector< std::string > dunedaq::utilities::get_hostname_ips ( std::string hostname )

inline

Definition at line 31 of file get_ips.hpp.

{
  std::vector<std::string> output;
 
  TLOG_DEBUG(12) << "Name is " << hostname;
 
  struct addrinfo* addrinfo = nullptr;
  auto s = getaddrinfo(hostname.c_str(), nullptr, nullptr, &addrinfo);
 
  if (s != 0) {
    ers::error(NameNotFound(ERS_HERE, hostname, std::string(gai_strerror(s))));
    return output;
  }
 
  for (auto rp = addrinfo; rp != nullptr; rp = rp->ai_next) {
    char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV]; // NOLINT
 
    // Let's skip all the IPv6 here
    if (rp->ai_family == AF_INET6)
      continue;
 
    getnameinfo(rp->ai_addr, rp->ai_addrlen, hbuf, sizeof(hbuf), sbuf, sizeof(sbuf), NI_NUMERICHOST | NI_NUMERICSERV);
    auto ipaddr = std::string(hbuf);
    bool duplicate = false;
    for (auto& ip : output) {
      if (ip == ipaddr) {
        duplicate = true;
        break;
      }
    }
    if (!duplicate) {
      TLOG_DEBUG(13) << "Found address " << ipaddr << " for hostname " << hostname;
      output.push_back(ipaddr);
    }
  }
 
  freeaddrinfo(addrinfo);
 
  return output;
}

get_interface_ip()

std::string dunedaq::utilities::get_interface_ip ( std::string eth_device_name, bool throw_if_missing = false )

inline

Definition at line 73 of file get_ips.hpp.

{
  std::string ipaddr = "0.0.0.0";
  char hostname[NI_MAXHOST]; // NOLINT This is a char array for interfacing with the C networking API
  if (gethostname(&hostname[0], NI_MAXHOST) == 0) {
    ipaddr = std::string(hostname);
  }
  bool eth_found = false;
  if (eth_device_name != "") {
    // Work out which ip address goes with this device
    struct ifaddrs* ifaddr = nullptr;
    getifaddrs(&ifaddr);
 
    for (auto ifa = ifaddr; ifa != nullptr; ifa = ifa->ifa_next) {
      if (ifa->ifa_addr == nullptr || std::string(ifa->ifa_name) != eth_device_name) {
        continue;
      }
 
      char ip[NI_MAXHOST]; // NOLINT This is a char array for interfacing with the C networking API
      int status = getnameinfo(ifa->ifa_addr, sizeof(struct sockaddr_in), ip, NI_MAXHOST, nullptr, 0, NI_NUMERICHOST);
      if (status != 0) {
        continue;
      }
      eth_found = true;
      ipaddr = std::string(ip);
      break;
    }
    freeifaddrs(ifaddr);
 
    if (!eth_found) {
      auto err = InterfaceNotFound(ERS_HERE, eth_device_name);
 
      if (throw_if_missing)
        throw err;
      else
        ers::warning(err);
    }
  }
 
  return ipaddr;
}