diff options
Diffstat (limited to 'implementation/logger/src/message.cpp')
| -rw-r--r-- | implementation/logger/src/message.cpp | 157 |
1 files changed, 157 insertions, 0 deletions
diff --git a/implementation/logger/src/message.cpp b/implementation/logger/src/message.cpp new file mode 100644 index 0000000..363db37 --- /dev/null +++ b/implementation/logger/src/message.cpp @@ -0,0 +1,157 @@ +// Copyright (C) 2020 Bayerische Motoren Werke Aktiengesellschaft (BMW AG) +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <chrono> +#include <ctime> +#include <fstream> +#include <iomanip> +#include <iostream> + +#ifdef ANDROID +#include <utils/Log.h> +#endif + +#include <vsomeip/internal/logger.hpp> + +#include "../include/logger_impl.hpp" +#include "../../configuration/include/configuration.hpp" + +namespace vsomeip_v3 { +namespace logger { + +std::mutex message::mutex__; + +message::message(level_e _level) + : std::ostream(&buffer_), + level_(_level) { + + when_ = std::chrono::system_clock::now(); +} + +message::~message() { + std::lock_guard<std::mutex> its_lock(mutex__); + auto its_logger = logger_impl::get(); + auto its_configuration = its_logger->get_configuration(); + + if (!its_configuration) + return; + + if (level_ > its_configuration->get_loglevel()) + return; + + if (its_configuration->has_console_log() + || its_configuration->has_file_log()) { + + // Prepare log level + const char *its_level; + switch (level_) { + case level_e::LL_FATAL: + its_level = "fatal"; + break; + case level_e::LL_ERROR: + its_level = "error"; + break; + case level_e::LL_WARNING: + its_level = "warning"; + break; + case level_e::LL_INFO: + its_level = "info"; + break; + case level_e::LL_DEBUG: + its_level = "debug"; + break; + case level_e::LL_VERBOSE: + its_level = "verbose"; + break; + default: + its_level = "none"; + }; + + // Prepare time stamp + auto its_time_t = std::chrono::system_clock::to_time_t(when_); + auto its_time = std::localtime(&its_time_t); + auto its_ms = (when_.time_since_epoch().count() / 100) % 1000000; + + if (its_configuration->has_console_log()) { +#ifndef ANDROID + std::cout + << std::dec << std::setw(4) << its_time->tm_year + 1900 << "-" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_mon << "-" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_mday << " " + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_hour << ":" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_min << ":" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_sec << "." + << std::dec << std::setw(6) << std::setfill('0') << its_ms << " [" + << its_level << "] " + << buffer_.data_.str() + << std::endl; +#else + switch (level_) { + case level_e::LL_FATAL: + ALOGE(buffer_.data_.str()); + break; + case level_e::LL_ERROR: + ALOGE(buffer_.data_.str()); + break; + case level_e::LL_WARNING: + ALOGW(buffer_.data_.str()); + break; + case level_e::LL_INFO: + ALOGI(buffer_.data_.str()); + break; + case level_e::LL_DEBUG: + ALOGD(buffer_.data_.str()); + break; + case level_e::LL_VERBOSE: + ALOGV(buffer_.data_.str()); + break; + default: + ALOGI(buffer_.data_.str()); + }; +#endif // !ANDROID + } + + if (its_configuration->has_file_log()) { + std::ofstream its_logfile( + its_configuration->get_logfile(), + std::ios_base::app); + if (its_logfile.is_open()) { + its_logfile + << std::dec << std::setw(4) << its_time->tm_year + 1900 << "-" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_mon << "-" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_mday << " " + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_hour << ":" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_min << ":" + << std::dec << std::setw(2) << std::setfill('0') << its_time->tm_sec << "." + << std::dec << std::setw(6) << std::setfill('0') << its_ms << " [" + << its_level << "] " + << buffer_.data_.str() + << std::endl; + } + } + } else if (its_configuration->has_dlt_log()) { +#ifdef USE_DLT + its_logger->log(level_, buffer_.data_.str().c_str()); +#endif // USE_DLT + } +} + +std::streambuf::int_type +message::buffer::overflow(std::streambuf::int_type c) { + if (c != EOF) { + data_ << (char)c; + } + + return (c); +} + +std::streamsize +message::buffer::xsputn(const char *s, std::streamsize n) { + data_.write(s, n); + return (n); +} + +} // namespace logger +} // namespace vsomeip_v3 |