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...
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_ips_from_hostname (std::string hostname)
std::vector< std::string >	resolve_uri_hostname (std::string connection_string)

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_ips_from_hostname()

std::vector< std::string > dunedaq::utilities::get_ips_from_hostname

(

std::string

hostname

)

Definition at line 16 of file Resolver.cpp.

{
  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;
}

resolve_uri_hostname()

std::vector< std::string > dunedaq::utilities::resolve_uri_hostname

(

std::string

connection_string

)

Definition at line 58 of file Resolver.cpp.

{
  ZmqUri uri(connection_string);
 
  if (uri.scheme == "tcp") {
    auto output = get_ips_from_hostname(uri.host);
 
    for (size_t ii = 0; ii < output.size(); ++ii) {
      output[ii] = "tcp://" + output[ii] + ":" + uri.port;
    }
    return output;
  } else {
    return { connection_string };
  }
}