StandardStreamOutput.cpp

Go to the documentation of this file.

/*
 * DUNE DAQ modification notice:
 * This file has been modified from the original ATLAS ers source for the DUNE DAQ project.
 * Fork baseline commit: 8267df82a4f6fe6bf02c4014923eba19eddc4614 (2020-04-14).
 * Renamed since fork: yes (from src/StandardStreamOutput.cxx to src/StandardStreamOutput.cpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
/*
 *  StandardStreamOutput.cxx
 *  ers
 *
 *  Created by Serguei Kolos on 02.08.07.
 *  Copyright 2007 CERN. All rights reserved.
 *
 */
#include <iomanip>
 
#include <ers/Issue.hpp>
#include <ers/Severity.hpp>
#include <ers/StandardStreamOutput.hpp>
#include <ers/internal/Util.hpp>
 
#include <boost/algorithm/string.hpp>
 
#define FIELD_SEPARATOR "\n\t"
 
namespace {
std::function<std::string(const ers::Issue& issue)>
getTimeFormatter()
{
  static std::string format = ers::read_from_environment("DUNEDAQ_ERS_TIMESTAMP_FORMAT", "%Y-%b-%d %H:%M:%S");
 
  static const std::string precision = ers::read_from_environment("DUNEDAQ_ERS_TIMESTAMP_PRECISION", "MILLI");
 
  static const bool isUTC = ::getenv("DUNEDAQ_ERS_TIMESTAMP_UTC");
 
  if (boost::algorithm::ifind_first(precision, "NANO")) {
    return [](const ers::Issue& issue) { return issue.time<std::chrono::nanoseconds>(format, isUTC); };
  }
 
  if (boost::algorithm::ifind_first(precision, "MICRO")) {
    return [](const ers::Issue& issue) { return issue.time<std::chrono::microseconds>(format, isUTC); };
  }
 
  if (boost::algorithm::ifind_first(precision, "MILLI")) {
    return [](const ers::Issue& issue) { return issue.time<std::chrono::milliseconds>(format, isUTC); };
  }
 
  return [](const ers::Issue& issue) { return issue.time(format, isUTC); };
}
 
const auto formatted_time = getTimeFormatter();
}
 
std::ostream&
ers::StandardStreamOutput::println(std::ostream& out, const Issue& issue, int verbosity)
{
  print(out, issue, verbosity);
  out << std::endl;
  return out;
}
 
std::ostream&
ers::StandardStreamOutput::print(std::ostream& out, const Issue& issue, int verbosity)
{
  if (verbosity > -3) {
    out << formatted_time(issue) << " ";
  }
 
  if (verbosity > -2) {
    out << ers::to_string(issue.severity()) << " ";
  }
 
  if (verbosity > -1) {
    out << "[" << issue.context().position(verbosity) << "] ";
  }
 
  out << issue.message();
 
  if (verbosity > 1) {
    out << FIELD_SEPARATOR << "Parameters = ";
    for (ers::string_map::const_iterator it = issue.parameters().begin(); it != issue.parameters().end(); ++it) {
      out << "'" << it->first << "=" << it->second << "' ";
    }
 
    out << FIELD_SEPARATOR << "Qualifiers = ";
    for (std::vector<std::string>::const_iterator it = issue.qualifiers().begin(); it != issue.qualifiers().end();
         ++it) {
      out << "'" << *it << "' ";
    }
  }
 
  if (verbosity > 2) {
    out << FIELD_SEPARATOR << "host = " << issue.context().host_name() << FIELD_SEPARATOR
        << "user = " << issue.context().user_name() << " (" << issue.context().user_id() << ")" << FIELD_SEPARATOR
        << "process id = " << issue.context().process_id() << FIELD_SEPARATOR
        << "thread id = " << issue.context().thread_id() << FIELD_SEPARATOR << "process wd = " << issue.context().cwd();
  }
 
  if (verbosity > 3) {
    std::ios_base::fmtflags flags(out.flags());
 
    out << std::left;
    std::vector<std::string> stack = issue.context().stack();
    out << FIELD_SEPARATOR << "stack trace of the crashing thread:";
    for (size_t i = 0; i < stack.size(); i++) {
      out << FIELD_SEPARATOR << "  #" << std::setw(3) << i << stack[i];
    }
    // restore the original state
    out.flags(flags);
  }
 
  if (issue.cause()) {
    out << FIELD_SEPARATOR << "was caused by: " << *issue.cause();
  }
 
  return out;
}