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	TimestampEstimator
	TimestampEstimator is an implementation of TimestampEstimatorBase that uses TimeSync messages from an input queue to estimate the current timestamp. More...
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...
struct	ZmqUri

Functions
std::vector< std::string >	get_ips_from_hostname (std::string hostname)
std::vector< std::string >	resolve_uri_hostname (std::string connection_string)
ZmqUri	parse_connection_string (std::string connection_string)

Function Documentation

get_ips_from_hostname()

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

(

std::string

hostname

)

Definition at line 13 of file Resolver.cpp.

{
  std::vector<std::string> output;
 
  TLOG_DEBUG(12) << "Name is " << hostname;
 
  struct addrinfo* result;
  auto s = getaddrinfo(hostname.c_str(), nullptr, nullptr, &result);
 
  if (s != 0) {
    ers::error(NameNotFound(ERS_HERE, hostname, std::string(gai_strerror(s))));
    return output;
  }
 
  for (auto rp = result; rp != nullptr; rp = rp->ai_next) {
    char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];
 
    // 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 result = std::string(hbuf);
    bool duplicate = false;
    for (auto& res : output) {
      if (res == result) {
        duplicate = true;
        break;
      }
    }
    if (!duplicate) {
      TLOG_DEBUG(13) << "Found address " << result << " for hostname " << hostname;
      output.push_back(result);
    }
  }
 
  freeaddrinfo(result);
 
  return output;
}

parse_connection_string()

dunedaq::utilities::ZmqUri dunedaq::utilities::parse_connection_string

(

std::string

connection_string

)

Definition at line 72 of file Resolver.cpp.

{
  // ZMQ URIs are formatted as follows: tcp://{host}:{port}
  ZmqUri output;
 
  if (connection_string.find("://") == std::string::npos) {
    throw InvalidUri(ERS_HERE, connection_string);
  }
 
  output.scheme = connection_string.substr(0, connection_string.find("://"));
  connection_string = connection_string.substr(connection_string.find("://") + 3);
 
  if (connection_string.find(":") != std::string::npos) {
    output.port = connection_string.substr(connection_string.find(":") + 1);
    connection_string = connection_string.substr(0, connection_string.find(":"));
  }
  output.host = connection_string;
 
  return output;
}

resolve_uri_hostname()

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

(

std::string

connection_string

)

Definition at line 55 of file Resolver.cpp.

{
  auto uri = parse_connection_string(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 }; 
  }
}