2018-12-31 20:04:05 +01:00
|
|
|
//
|
2020-01-01 02:23:48 +01:00
|
|
|
// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2020
|
2018-12-31 20:04:05 +01:00
|
|
|
//
|
|
|
|
// Distributed under the Boost Software License, Version 1.0. (See accompanying
|
|
|
|
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
|
|
|
//
|
|
|
|
#include "td/utils/logging.h"
|
|
|
|
|
|
|
|
#include "td/utils/port/Clocks.h"
|
2018-08-17 15:41:51 +02:00
|
|
|
#include "td/utils/port/StdStreams.h"
|
2018-12-31 20:04:05 +01:00
|
|
|
#include "td/utils/port/thread_local.h"
|
|
|
|
#include "td/utils/Slice.h"
|
|
|
|
#include "td/utils/Time.h"
|
|
|
|
|
2020-09-05 15:36:26 +02:00
|
|
|
#ifndef _WIN32
|
2020-09-02 01:11:38 +02:00
|
|
|
#include "td/utils/death_handler.h"
|
2020-09-05 15:36:26 +02:00
|
|
|
#endif
|
2020-09-02 01:11:38 +02:00
|
|
|
|
2018-12-31 20:04:05 +01:00
|
|
|
#include <atomic>
|
|
|
|
#include <cstdlib>
|
2020-06-26 01:24:13 +02:00
|
|
|
#include <limits>
|
2020-06-24 13:47:36 +02:00
|
|
|
#include <mutex>
|
2020-09-02 01:11:38 +02:00
|
|
|
#include <csignal>
|
2018-12-31 20:04:05 +01:00
|
|
|
|
|
|
|
#if TD_ANDROID
|
|
|
|
#include <android/log.h>
|
|
|
|
#define ALOG_TAG "DLTD"
|
|
|
|
#elif TD_TIZEN
|
|
|
|
#include <dlog.h>
|
|
|
|
#define DLOG_TAG "DLTD"
|
|
|
|
#elif TD_EMSCRIPTEN
|
|
|
|
#include <emscripten.h>
|
|
|
|
#endif
|
|
|
|
|
|
|
|
namespace td {
|
|
|
|
|
|
|
|
int VERBOSITY_NAME(net_query) = VERBOSITY_NAME(INFO);
|
|
|
|
int VERBOSITY_NAME(td_requests) = VERBOSITY_NAME(INFO);
|
|
|
|
int VERBOSITY_NAME(dc) = VERBOSITY_NAME(DEBUG) + 2;
|
|
|
|
int VERBOSITY_NAME(files) = VERBOSITY_NAME(DEBUG) + 2;
|
|
|
|
int VERBOSITY_NAME(mtproto) = VERBOSITY_NAME(DEBUG) + 7;
|
|
|
|
int VERBOSITY_NAME(raw_mtproto) = VERBOSITY_NAME(DEBUG) + 10;
|
|
|
|
int VERBOSITY_NAME(fd) = VERBOSITY_NAME(DEBUG) + 9;
|
|
|
|
int VERBOSITY_NAME(actor) = VERBOSITY_NAME(DEBUG) + 10;
|
|
|
|
int VERBOSITY_NAME(sqlite) = VERBOSITY_NAME(DEBUG) + 10;
|
|
|
|
|
2018-08-13 19:15:09 +02:00
|
|
|
LogOptions log_options;
|
|
|
|
|
2018-12-31 20:04:05 +01:00
|
|
|
TD_THREAD_LOCAL const char *Logger::tag_ = nullptr;
|
|
|
|
TD_THREAD_LOCAL const char *Logger::tag2_ = nullptr;
|
|
|
|
|
2018-08-13 19:15:09 +02:00
|
|
|
Logger::Logger(LogInterface &log, const LogOptions &options, int log_level, Slice file_name, int line_num,
|
|
|
|
Slice comment)
|
|
|
|
: Logger(log, options, log_level) {
|
2020-06-17 04:51:36 +02:00
|
|
|
if (log_level == VERBOSITY_NAME(PLAIN) && &options == &log_options) {
|
|
|
|
return;
|
|
|
|
}
|
2018-08-13 19:15:09 +02:00
|
|
|
if (!options_.add_info) {
|
2018-12-31 20:04:05 +01:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-08-13 19:15:09 +02:00
|
|
|
// log level
|
2018-06-05 01:34:51 +02:00
|
|
|
sb_ << '[';
|
2020-08-04 00:07:49 +02:00
|
|
|
if (static_cast<unsigned int>(log_level) < 10) {
|
|
|
|
sb_ << ' ' << static_cast<char>('0' + log_level);
|
|
|
|
} else {
|
|
|
|
sb_ << log_level;
|
2018-02-11 15:07:16 +01:00
|
|
|
}
|
2020-08-04 00:07:49 +02:00
|
|
|
sb_ << ']';
|
2018-08-13 19:15:09 +02:00
|
|
|
|
|
|
|
// thread id
|
|
|
|
auto thread_id = get_thread_id();
|
|
|
|
sb_ << "[t";
|
2020-08-04 00:07:49 +02:00
|
|
|
if (static_cast<unsigned int>(thread_id) < 10) {
|
|
|
|
sb_ << ' ' << static_cast<char>('0' + thread_id);
|
|
|
|
} else {
|
|
|
|
sb_ << thread_id;
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
2020-08-04 00:07:49 +02:00
|
|
|
sb_ << ']';
|
2018-08-13 19:15:09 +02:00
|
|
|
|
|
|
|
// timestamp
|
2020-08-03 22:38:28 +02:00
|
|
|
auto time = Clocks::system();
|
2020-08-04 00:39:52 +02:00
|
|
|
auto unix_time = static_cast<uint32>(time);
|
|
|
|
auto nanoseconds = static_cast<uint32>((time - unix_time) * 1e9);
|
2020-08-03 22:38:28 +02:00
|
|
|
sb_ << '[' << unix_time << '.';
|
2020-08-04 00:39:52 +02:00
|
|
|
uint32 limit = 100000000;
|
2020-08-03 22:38:28 +02:00
|
|
|
while (nanoseconds < limit && limit > 1) {
|
|
|
|
sb_ << '0';
|
|
|
|
limit /= 10;
|
|
|
|
}
|
|
|
|
sb_ << nanoseconds << ']';
|
2018-08-13 19:15:09 +02:00
|
|
|
|
|
|
|
// file : line
|
|
|
|
if (!file_name.empty()) {
|
|
|
|
auto last_slash_ = static_cast<int32>(file_name.size()) - 1;
|
|
|
|
while (last_slash_ >= 0 && file_name[last_slash_] != '/' && file_name[last_slash_] != '\\') {
|
|
|
|
last_slash_--;
|
|
|
|
}
|
|
|
|
file_name = file_name.substr(last_slash_ + 1);
|
2020-08-04 00:39:52 +02:00
|
|
|
sb_ << '[' << file_name << ':' << static_cast<unsigned int>(line_num) << ']';
|
2018-08-13 19:15:09 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
// context from tag_
|
2018-12-31 20:04:05 +01:00
|
|
|
if (tag_ != nullptr && *tag_) {
|
2018-06-05 01:34:51 +02:00
|
|
|
sb_ << "[#" << Slice(tag_) << ']';
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
2018-08-13 19:15:09 +02:00
|
|
|
|
|
|
|
// context from tag2_
|
2018-12-31 20:04:05 +01:00
|
|
|
if (tag2_ != nullptr && *tag2_) {
|
2018-06-05 01:34:51 +02:00
|
|
|
sb_ << "[!" << Slice(tag2_) << ']';
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
2018-08-13 19:15:09 +02:00
|
|
|
|
|
|
|
// comment (e.g. condition in LOG_IF)
|
2018-12-31 20:04:05 +01:00
|
|
|
if (!comment.empty()) {
|
2018-06-05 01:34:51 +02:00
|
|
|
sb_ << "[&" << comment << ']';
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
2018-08-13 19:15:09 +02:00
|
|
|
|
2018-06-05 01:34:51 +02:00
|
|
|
sb_ << '\t';
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
Logger::~Logger() {
|
2018-08-13 19:15:09 +02:00
|
|
|
if (options_.fix_newlines) {
|
2018-12-31 20:04:05 +01:00
|
|
|
sb_ << '\n';
|
|
|
|
auto slice = as_cslice();
|
|
|
|
if (slice.back() != '\n') {
|
|
|
|
slice.back() = '\n';
|
|
|
|
}
|
2018-08-13 19:15:09 +02:00
|
|
|
while (slice.size() > 1 && slice[slice.size() - 2] == '\n') {
|
2018-09-07 02:41:21 +02:00
|
|
|
slice.back() = '\0';
|
2018-08-13 19:15:09 +02:00
|
|
|
slice = MutableCSlice(slice.begin(), slice.begin() + slice.size() - 1);
|
|
|
|
}
|
|
|
|
log_.append(slice, log_level_);
|
|
|
|
} else {
|
|
|
|
log_.append(as_cslice(), log_level_);
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
TsCerr::TsCerr() {
|
|
|
|
enterCritical();
|
|
|
|
}
|
|
|
|
TsCerr::~TsCerr() {
|
|
|
|
exitCritical();
|
|
|
|
}
|
|
|
|
TsCerr &TsCerr::operator<<(Slice slice) {
|
2018-08-13 19:15:09 +02:00
|
|
|
auto &fd = Stderr();
|
2018-12-31 20:04:05 +01:00
|
|
|
if (fd.empty()) {
|
|
|
|
return *this;
|
|
|
|
}
|
|
|
|
double end_time = 0;
|
|
|
|
while (!slice.empty()) {
|
|
|
|
auto res = fd.write(slice);
|
|
|
|
if (res.is_error()) {
|
|
|
|
if (res.error().code() == EPIPE) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
// Resource temporary unavailable
|
|
|
|
if (end_time == 0) {
|
|
|
|
end_time = Time::now() + 0.01;
|
|
|
|
} else if (Time::now() > end_time) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
slice.remove_prefix(res.ok());
|
|
|
|
}
|
|
|
|
return *this;
|
|
|
|
}
|
|
|
|
|
|
|
|
void TsCerr::enterCritical() {
|
|
|
|
while (lock_.test_and_set(std::memory_order_acquire)) {
|
|
|
|
// spin
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void TsCerr::exitCritical() {
|
|
|
|
lock_.clear(std::memory_order_release);
|
|
|
|
}
|
|
|
|
TsCerr::Lock TsCerr::lock_ = ATOMIC_FLAG_INIT;
|
|
|
|
|
|
|
|
class DefaultLog : public LogInterface {
|
|
|
|
public:
|
|
|
|
void append(CSlice slice, int log_level) override {
|
|
|
|
#if TD_ANDROID
|
|
|
|
switch (log_level) {
|
|
|
|
case VERBOSITY_NAME(FATAL):
|
|
|
|
__android_log_write(ANDROID_LOG_FATAL, ALOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(ERROR):
|
|
|
|
__android_log_write(ANDROID_LOG_ERROR, ALOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(WARNING):
|
|
|
|
__android_log_write(ANDROID_LOG_WARN, ALOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(INFO):
|
|
|
|
__android_log_write(ANDROID_LOG_INFO, ALOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
__android_log_write(ANDROID_LOG_DEBUG, ALOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
#elif TD_TIZEN
|
|
|
|
switch (log_level) {
|
|
|
|
case VERBOSITY_NAME(FATAL):
|
|
|
|
dlog_print(DLOG_ERROR, DLOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(ERROR):
|
|
|
|
dlog_print(DLOG_ERROR, DLOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(WARNING):
|
|
|
|
dlog_print(DLOG_WARN, DLOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(INFO):
|
|
|
|
dlog_print(DLOG_INFO, DLOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
dlog_print(DLOG_DEBUG, DLOG_TAG, slice.c_str());
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
#elif TD_EMSCRIPTEN
|
|
|
|
switch (log_level) {
|
|
|
|
case VERBOSITY_NAME(FATAL):
|
|
|
|
emscripten_log(
|
|
|
|
EM_LOG_ERROR | EM_LOG_CONSOLE | EM_LOG_C_STACK | EM_LOG_JS_STACK | EM_LOG_DEMANGLE | EM_LOG_FUNC_PARAMS,
|
|
|
|
"%s", slice.c_str());
|
2018-03-06 12:43:46 +01:00
|
|
|
EM_ASM(throw(UTF8ToString($0)), slice.c_str());
|
2018-12-31 20:04:05 +01:00
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(ERROR):
|
|
|
|
emscripten_log(EM_LOG_ERROR | EM_LOG_CONSOLE, "%s", slice.c_str());
|
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(WARNING):
|
|
|
|
emscripten_log(EM_LOG_WARN | EM_LOG_CONSOLE, "%s", slice.c_str());
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
emscripten_log(EM_LOG_CONSOLE, "%s", slice.c_str());
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
#elif !TD_WINDOWS
|
|
|
|
Slice color;
|
|
|
|
switch (log_level) {
|
|
|
|
case VERBOSITY_NAME(FATAL):
|
|
|
|
case VERBOSITY_NAME(ERROR):
|
2019-02-13 00:29:52 +01:00
|
|
|
color = Slice(TC_RED);
|
2018-12-31 20:04:05 +01:00
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(WARNING):
|
2019-02-13 00:29:52 +01:00
|
|
|
color = Slice(TC_YELLOW);
|
2018-12-31 20:04:05 +01:00
|
|
|
break;
|
|
|
|
case VERBOSITY_NAME(INFO):
|
2019-02-13 00:29:52 +01:00
|
|
|
color = Slice(TC_CYAN);
|
2018-12-31 20:04:05 +01:00
|
|
|
break;
|
|
|
|
}
|
2019-07-06 13:29:15 +02:00
|
|
|
if (!slice.empty() && slice.back() == '\n') {
|
2019-07-21 20:07:07 +02:00
|
|
|
TsCerr() << color << slice.substr(0, slice.size() - 1) << TC_EMPTY "\n";
|
2019-07-06 13:29:15 +02:00
|
|
|
} else {
|
|
|
|
TsCerr() << color << slice << TC_EMPTY;
|
|
|
|
}
|
2018-12-31 20:04:05 +01:00
|
|
|
#else
|
|
|
|
// TODO: color
|
|
|
|
TsCerr() << slice;
|
|
|
|
#endif
|
|
|
|
if (log_level == VERBOSITY_NAME(FATAL)) {
|
2018-01-24 16:45:57 +01:00
|
|
|
process_fatal_error(slice);
|
2018-12-31 20:04:05 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
void rotate() override {
|
|
|
|
}
|
|
|
|
};
|
|
|
|
static DefaultLog default_log;
|
|
|
|
|
|
|
|
LogInterface *const default_log_interface = &default_log;
|
|
|
|
LogInterface *log_interface = default_log_interface;
|
2018-01-24 16:45:57 +01:00
|
|
|
|
|
|
|
static OnFatalErrorCallback on_fatal_error_callback = nullptr;
|
|
|
|
|
|
|
|
void set_log_fatal_error_callback(OnFatalErrorCallback callback) {
|
|
|
|
on_fatal_error_callback = callback;
|
|
|
|
}
|
|
|
|
|
|
|
|
void process_fatal_error(CSlice message) {
|
|
|
|
auto callback = on_fatal_error_callback;
|
|
|
|
if (callback) {
|
|
|
|
callback(message);
|
|
|
|
}
|
2020-09-05 15:36:26 +02:00
|
|
|
#ifndef _WIN32
|
|
|
|
#if TD_THREAD_UNSUPPORTED || TD_EVENTFD_UNSUPPORTED
|
|
|
|
std::abort();
|
|
|
|
#else
|
|
|
|
struct sigaction sa{};
|
|
|
|
Debug::DeathHandler::HandleSignal(SIGABRT, &sa, nullptr);
|
|
|
|
#endif
|
2020-09-02 01:44:17 +02:00
|
|
|
#else
|
2020-09-05 15:36:26 +02:00
|
|
|
std::abort();
|
2020-09-02 01:44:17 +02:00
|
|
|
#endif
|
2018-01-24 16:45:57 +01:00
|
|
|
}
|
2018-12-31 20:04:05 +01:00
|
|
|
|
2020-06-24 13:47:36 +02:00
|
|
|
namespace {
|
|
|
|
std::mutex sdl_mutex;
|
|
|
|
int sdl_cnt = 0;
|
|
|
|
int sdl_verbosity = 0;
|
|
|
|
} // namespace
|
2020-06-26 01:24:13 +02:00
|
|
|
|
2020-06-24 13:47:36 +02:00
|
|
|
ScopedDisableLog::ScopedDisableLog() {
|
|
|
|
std::unique_lock<std::mutex> guard(sdl_mutex);
|
|
|
|
if (sdl_cnt == 0) {
|
|
|
|
sdl_verbosity = set_verbosity_level(std::numeric_limits<int>::min());
|
|
|
|
}
|
|
|
|
sdl_cnt++;
|
|
|
|
}
|
|
|
|
|
|
|
|
ScopedDisableLog::~ScopedDisableLog() {
|
|
|
|
std::unique_lock<std::mutex> guard(sdl_mutex);
|
|
|
|
sdl_cnt--;
|
|
|
|
if (sdl_cnt == 0) {
|
|
|
|
set_verbosity_level(sdl_verbosity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-12-31 20:04:05 +01:00
|
|
|
} // namespace td
|