mirror of
https://github.com/monero-project/monero.git
synced 2024-12-16 13:34:24 -05:00
c0c6102260
8766528
epee: fallback to a counter if gmtime fails when rotating logs (moneromooo-monero)
438 lines
13 KiB
C++
438 lines
13 KiB
C++
// Copyright (c) 2006-2013, Andrey N. Sabelnikov, www.sabelnikov.net
|
|
// All rights reserved.
|
|
//
|
|
// Redistribution and use in source and binary forms, with or without
|
|
// modification, are permitted provided that the following conditions are met:
|
|
// * Redistributions of source code must retain the above copyright
|
|
// notice, this list of conditions and the following disclaimer.
|
|
// * Redistributions in binary form must reproduce the above copyright
|
|
// notice, this list of conditions and the following disclaimer in the
|
|
// documentation and/or other materials provided with the distribution.
|
|
// * Neither the name of the Andrey N. Sabelnikov nor the
|
|
// names of its contributors may be used to endorse or promote products
|
|
// derived from this software without specific prior written permission.
|
|
//
|
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
|
|
// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
|
// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
|
// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER BE LIABLE FOR ANY
|
|
// DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
|
// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
|
// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
|
// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
//
|
|
|
|
|
|
#ifndef _MLOG_H_
|
|
#define _MLOG_H_
|
|
|
|
#include <time.h>
|
|
#include <atomic>
|
|
#include <boost/filesystem.hpp>
|
|
#include <boost/algorithm/string.hpp>
|
|
#include "string_tools.h"
|
|
#include "misc_log_ex.h"
|
|
|
|
#undef MONERO_DEFAULT_LOG_CATEGORY
|
|
#define MONERO_DEFAULT_LOG_CATEGORY "logging"
|
|
|
|
#define MLOG_BASE_FORMAT "%datetime{%Y-%M-%d %H:%m:%s.%g}\t%thread\t%level\t%logger\t%loc\t%msg"
|
|
|
|
#define MLOG_LOG(x) CINFO(el::base::Writer,el::base::DispatchAction::FileOnlyLog,MONERO_DEFAULT_LOG_CATEGORY) << x
|
|
|
|
using namespace epee;
|
|
|
|
static std::string generate_log_filename(const char *base)
|
|
{
|
|
std::string filename(base);
|
|
static unsigned int fallback_counter = 0;
|
|
char tmp[200];
|
|
struct tm tm;
|
|
time_t now = time(NULL);
|
|
if
|
|
#ifdef WIN32
|
|
(!gmtime_s(&tm, &now))
|
|
#else
|
|
(!gmtime_r(&now, &tm))
|
|
#endif
|
|
snprintf(tmp, sizeof(tmp), "part-%u", ++fallback_counter);
|
|
else
|
|
strftime(tmp, sizeof(tmp), "%Y-%m-%d-%H-%M-%S", &tm);
|
|
tmp[sizeof(tmp) - 1] = 0;
|
|
filename += "-";
|
|
filename += tmp;
|
|
return filename;
|
|
}
|
|
|
|
std::string mlog_get_default_log_path(const char *default_filename)
|
|
{
|
|
std::string process_name = epee::string_tools::get_current_module_name();
|
|
std::string default_log_folder = epee::string_tools::get_current_module_folder();
|
|
std::string default_log_file = process_name;
|
|
std::string::size_type a = default_log_file.rfind('.');
|
|
if ( a != std::string::npos )
|
|
default_log_file.erase( a, default_log_file.size());
|
|
if ( ! default_log_file.empty() )
|
|
default_log_file += ".log";
|
|
else
|
|
default_log_file = default_filename;
|
|
|
|
return (boost::filesystem::path(default_log_folder) / boost::filesystem::path(default_log_file)).string();
|
|
}
|
|
|
|
static void mlog_set_common_prefix()
|
|
{
|
|
static const char * const expected_filename = "contrib/epee/src/mlog.cpp";
|
|
const char *path = __FILE__, *expected_ptr = strstr(path, expected_filename);
|
|
if (!expected_ptr)
|
|
return;
|
|
el::Loggers::setFilenameCommonPrefix(std::string(path, expected_ptr - path));
|
|
}
|
|
|
|
static const char *get_default_categories(int level)
|
|
{
|
|
const char *categories = "";
|
|
switch (level)
|
|
{
|
|
case 0:
|
|
categories = "*:WARNING,net:FATAL,net.p2p:FATAL,net.cn:FATAL,global:INFO,verify:FATAL,stacktrace:INFO,logging:INFO,msgwriter:INFO";
|
|
break;
|
|
case 1:
|
|
categories = "*:INFO,global:INFO,stacktrace:INFO,logging:INFO,msgwriter:INFO";
|
|
break;
|
|
case 2:
|
|
categories = "*:DEBUG";
|
|
break;
|
|
case 3:
|
|
categories = "*:TRACE";
|
|
break;
|
|
case 4:
|
|
categories = "*:TRACE";
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
return categories;
|
|
}
|
|
|
|
void mlog_configure(const std::string &filename_base, bool console, const std::size_t max_log_file_size, const std::size_t max_log_files)
|
|
{
|
|
el::Configurations c;
|
|
c.setGlobally(el::ConfigurationType::Filename, filename_base);
|
|
c.setGlobally(el::ConfigurationType::ToFile, "true");
|
|
const char *log_format = getenv("MONERO_LOG_FORMAT");
|
|
if (!log_format)
|
|
log_format = MLOG_BASE_FORMAT;
|
|
c.setGlobally(el::ConfigurationType::Format, log_format);
|
|
c.setGlobally(el::ConfigurationType::ToStandardOutput, console ? "true" : "false");
|
|
c.setGlobally(el::ConfigurationType::MaxLogFileSize, std::to_string(max_log_file_size));
|
|
el::Loggers::setDefaultConfigurations(c, true);
|
|
|
|
el::Loggers::addFlag(el::LoggingFlag::HierarchicalLogging);
|
|
el::Loggers::addFlag(el::LoggingFlag::CreateLoggerAutomatically);
|
|
el::Loggers::addFlag(el::LoggingFlag::DisableApplicationAbortOnFatalLog);
|
|
el::Loggers::addFlag(el::LoggingFlag::ColoredTerminalOutput);
|
|
el::Loggers::addFlag(el::LoggingFlag::StrictLogFileSizeCheck);
|
|
el::Helpers::installPreRollOutCallback([filename_base, max_log_files](const char *name, size_t){
|
|
std::string rname = generate_log_filename(filename_base.c_str());
|
|
rename(name, rname.c_str());
|
|
if (max_log_files != 0)
|
|
{
|
|
std::vector<boost::filesystem::path> found_files;
|
|
const boost::filesystem::directory_iterator end_itr;
|
|
for (boost::filesystem::directory_iterator iter(boost::filesystem::path(filename_base).parent_path()); iter != end_itr; ++iter)
|
|
{
|
|
const std::string filename = iter->path().string();
|
|
if (filename.size() >= filename_base.size() && std::memcmp(filename.data(), filename_base.data(), filename_base.size()) == 0)
|
|
{
|
|
found_files.push_back(iter->path());
|
|
}
|
|
}
|
|
if (found_files.size() >= max_log_files)
|
|
{
|
|
std::sort(found_files.begin(), found_files.end(), [](const boost::filesystem::path &a, const boost::filesystem::path &b) {
|
|
boost::system::error_code ec;
|
|
std::time_t ta = boost::filesystem::last_write_time(boost::filesystem::path(a), ec);
|
|
if (ec)
|
|
{
|
|
MERROR("Failed to get timestamp from " << a << ": " << ec);
|
|
ta = std::time(nullptr);
|
|
}
|
|
std::time_t tb = boost::filesystem::last_write_time(boost::filesystem::path(b), ec);
|
|
if (ec)
|
|
{
|
|
MERROR("Failed to get timestamp from " << b << ": " << ec);
|
|
tb = std::time(nullptr);
|
|
}
|
|
static_assert(std::is_integral<time_t>(), "bad time_t");
|
|
return ta < tb;
|
|
});
|
|
for (size_t i = 0; i <= found_files.size() - max_log_files; ++i)
|
|
{
|
|
try
|
|
{
|
|
boost::system::error_code ec;
|
|
boost::filesystem::remove(found_files[i], ec);
|
|
if (ec)
|
|
{
|
|
MERROR("Failed to remove " << found_files[i] << ": " << ec);
|
|
}
|
|
}
|
|
catch (const std::exception &e)
|
|
{
|
|
MERROR("Failed to remove " << found_files[i] << ": " << e.what());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
});
|
|
mlog_set_common_prefix();
|
|
const char *monero_log = getenv("MONERO_LOGS");
|
|
if (!monero_log)
|
|
{
|
|
monero_log = get_default_categories(0);
|
|
}
|
|
mlog_set_log(monero_log);
|
|
}
|
|
|
|
void mlog_set_categories(const char *categories)
|
|
{
|
|
std::string new_categories;
|
|
if (*categories)
|
|
{
|
|
if (*categories == '+')
|
|
{
|
|
++categories;
|
|
new_categories = mlog_get_categories();
|
|
if (*categories)
|
|
{
|
|
if (!new_categories.empty())
|
|
new_categories += ",";
|
|
new_categories += categories;
|
|
}
|
|
}
|
|
else if (*categories == '-')
|
|
{
|
|
++categories;
|
|
new_categories = mlog_get_categories();
|
|
std::vector<std::string> single_categories;
|
|
boost::split(single_categories, categories, boost::is_any_of(","), boost::token_compress_on);
|
|
for (const std::string &s: single_categories)
|
|
{
|
|
size_t pos = new_categories.find(s);
|
|
if (pos != std::string::npos)
|
|
new_categories = new_categories.erase(pos, s.size());
|
|
}
|
|
}
|
|
else
|
|
{
|
|
new_categories = categories;
|
|
}
|
|
}
|
|
el::Loggers::setCategories(new_categories.c_str(), true);
|
|
MLOG_LOG("New log categories: " << el::Loggers::getCategories());
|
|
}
|
|
|
|
std::string mlog_get_categories()
|
|
{
|
|
return el::Loggers::getCategories();
|
|
}
|
|
|
|
// maps epee style log level to new logging system
|
|
void mlog_set_log_level(int level)
|
|
{
|
|
const char *categories = get_default_categories(level);
|
|
mlog_set_categories(categories);
|
|
}
|
|
|
|
void mlog_set_log(const char *log)
|
|
{
|
|
long level;
|
|
char *ptr = NULL;
|
|
|
|
if (!*log)
|
|
{
|
|
mlog_set_categories(log);
|
|
return;
|
|
}
|
|
level = strtol(log, &ptr, 10);
|
|
if (ptr && *ptr)
|
|
{
|
|
// we can have a default level, eg, 2,foo:ERROR
|
|
if (*ptr == ',') {
|
|
std::string new_categories = std::string(get_default_categories(level)) + ptr;
|
|
mlog_set_categories(new_categories.c_str());
|
|
}
|
|
else {
|
|
mlog_set_categories(log);
|
|
}
|
|
}
|
|
else if (level >= 0 && level <= 4)
|
|
{
|
|
mlog_set_log_level(level);
|
|
}
|
|
else
|
|
{
|
|
MERROR("Invalid numerical log level: " << log);
|
|
}
|
|
}
|
|
|
|
namespace epee
|
|
{
|
|
|
|
bool is_stdout_a_tty()
|
|
{
|
|
static std::atomic<bool> initialized(false);
|
|
static std::atomic<bool> is_a_tty(false);
|
|
|
|
if (!initialized.load(std::memory_order_acquire))
|
|
{
|
|
#if defined(WIN32)
|
|
is_a_tty.store(0 != _isatty(_fileno(stdout)), std::memory_order_relaxed);
|
|
#else
|
|
is_a_tty.store(0 != isatty(fileno(stdout)), std::memory_order_relaxed);
|
|
#endif
|
|
initialized.store(true, std::memory_order_release);
|
|
}
|
|
|
|
return is_a_tty.load(std::memory_order_relaxed);
|
|
}
|
|
|
|
void set_console_color(int color, bool bright)
|
|
{
|
|
if (!is_stdout_a_tty())
|
|
return;
|
|
|
|
switch(color)
|
|
{
|
|
case console_color_default:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_RED | FOREGROUND_GREEN | FOREGROUND_BLUE| (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;37m";
|
|
else
|
|
std::cout << "\033[0m";
|
|
#endif
|
|
}
|
|
break;
|
|
case console_color_white:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_RED | FOREGROUND_GREEN | FOREGROUND_BLUE | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;37m";
|
|
else
|
|
std::cout << "\033[0;37m";
|
|
#endif
|
|
}
|
|
break;
|
|
case console_color_red:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_RED | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;31m";
|
|
else
|
|
std::cout << "\033[0;31m";
|
|
#endif
|
|
}
|
|
break;
|
|
case console_color_green:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_GREEN | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;32m";
|
|
else
|
|
std::cout << "\033[0;32m";
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
case console_color_blue:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_BLUE | FOREGROUND_INTENSITY);//(bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;34m";
|
|
else
|
|
std::cout << "\033[0;34m";
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
case console_color_cyan:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_GREEN | FOREGROUND_BLUE | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;36m";
|
|
else
|
|
std::cout << "\033[0;36m";
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
case console_color_magenta:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_BLUE | FOREGROUND_RED | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;35m";
|
|
else
|
|
std::cout << "\033[0;35m";
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
case console_color_yellow:
|
|
{
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_RED | FOREGROUND_GREEN | (bright ? FOREGROUND_INTENSITY:0));
|
|
#else
|
|
if(bright)
|
|
std::cout << "\033[1;33m";
|
|
else
|
|
std::cout << "\033[0;33m";
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
}
|
|
}
|
|
|
|
void reset_console_color() {
|
|
if (!is_stdout_a_tty())
|
|
return;
|
|
|
|
#ifdef WIN32
|
|
HANDLE h_stdout = GetStdHandle(STD_OUTPUT_HANDLE);
|
|
SetConsoleTextAttribute(h_stdout, FOREGROUND_RED | FOREGROUND_GREEN | FOREGROUND_BLUE);
|
|
#else
|
|
std::cout << "\033[0m";
|
|
std::cout.flush();
|
|
#endif
|
|
}
|
|
|
|
}
|
|
|
|
#endif //_MLOG_H_
|