error.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_common_libdaq
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Contains error related definitions for DAQ
 */
#include <daq/error.hpp>
 
#include <ostream>
 
#include <fmt/format.h>
 
#include <daq/error/report.hpp>
 
namespace daq {
 
std::ostream& operator<<(std::ostream& os, ErrorPolicy policy) {
    switch (policy) {
    case ErrorPolicy::Strict:
        os << "Strict";
        break;
    case ErrorPolicy::Tolerant:
        os << "Tolerant";
        break;
    default:
        os << "n/a";
    }
    return os;
}
 
DaqSourceError::DaqSourceError(std::string request, std::string source, std::string message)
    : m_request(std::move(request)), m_source(std::move(source)), m_message(std::move(message)) {
    m_formatted = fmt::format(
        "Data source error: source={}, request={}, message={}", m_source, m_request, m_message);
}
 
char const* DaqSourceError::what() const noexcept {
    return m_formatted.c_str();
}
 
DaqSourceErrors::DaqSourceErrors(std::vector<std::exception_ptr> errors) {
    std::copy(errors.begin(), errors.end(), std::back_inserter(m_errors));
    Update();
}
 
DaqSourceErrors::DaqSourceErrors(
    std::vector<std::variant<DaqSourceError, std::exception_ptr>> errors)
    : m_errors(std::move(errors)) {
    Update();
}
 
void DaqSourceErrors::Update() {
    for (auto const& e : m_errors) {
        if (auto const* ptr = std::get_if<DaqSourceError>(&e); ptr) {
            m_what += ptr->what();
            m_what += '\n';
        } else if (auto const* ptr = std::get_if<std::exception_ptr>(&e); ptr) {
            m_what += error::FormatException(*ptr);
        }
    }
}
 
char const* DaqSourceErrors::what() const noexcept {
    return m_what.c_str();
}
 
}  // namespace daq