diff options
author | mikari <mikari@yandex-team.ru> | 2022-02-10 16:48:47 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:47 +0300 |
commit | f821ddfc9200113ec259d8d35b7cf3833372abc9 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/logger | |
parent | 2e0ed5ad2d70bf924ccd3cbbfab508784ab36325 (diff) | |
download | ydb-f821ddfc9200113ec259d8d35b7cf3833372abc9.tar.gz |
Restoring authorship annotation for <mikari@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/logger')
-rw-r--r-- | library/cpp/logger/global/global.cpp | 4 | ||||
-rw-r--r-- | library/cpp/logger/global/global.h | 12 | ||||
-rw-r--r-- | library/cpp/logger/log.cpp | 20 | ||||
-rw-r--r-- | library/cpp/logger/log.h | 6 | ||||
-rw-r--r-- | library/cpp/logger/thread.cpp | 20 | ||||
-rw-r--r-- | library/cpp/logger/thread.h | 10 |
6 files changed, 36 insertions, 36 deletions
diff --git a/library/cpp/logger/global/global.cpp b/library/cpp/logger/global/global.cpp index 4998e24ee9..9fbd10f666 100644 --- a/library/cpp/logger/global/global.cpp +++ b/library/cpp/logger/global/global.cpp @@ -16,8 +16,8 @@ void DoInitGlobalLog(const TString& logType, const int logLevel, const bool rota (ELogPriority)logLevel, threaded)), std::move(formatter)); -} - +} + void DoInitGlobalLog(THolder<TLogBackend> backend, THolder<ILoggerFormatter> formatter) { DoInitGlobalLog(THolder(new TGlobalLog(std::move(backend))), std::move(formatter)); } diff --git a/library/cpp/logger/global/global.h b/library/cpp/logger/global/global.h index e020f68099..cbe71b16ea 100644 --- a/library/cpp/logger/global/global.h +++ b/library/cpp/logger/global/global.h @@ -23,11 +23,11 @@ public: : TLog(logType, priority) { } - + TGlobalLog(THolder<TLogBackend> backend) : TLog(std::move(backend)) - { - } + { + } }; template <> @@ -39,11 +39,11 @@ public: : TLog(logType, priority) { } - + TNullLog(THolder<TLogBackend> backend) : TLog(std::move(backend)) - { - } + { + } }; template <> diff --git a/library/cpp/logger/log.cpp b/library/cpp/logger/log.cpp index 01e299b3e4..e1d70cc3d2 100644 --- a/library/cpp/logger/log.cpp +++ b/library/cpp/logger/log.cpp @@ -3,7 +3,7 @@ #include "filter.h" #include "null.h" #include "stream.h" -#include "thread.h" +#include "thread.h" #include <util/string/cast.h> #include <util/stream/printf.h> @@ -16,8 +16,8 @@ THolder<TLogBackend> CreateLogBackend(const TString& fname, ELogPriority priorit TLogBackendCreatorUninitialized creator; creator.InitCustom(fname, priority, threaded); return creator.CreateLogBackend(); -} - +} + THolder<TLogBackend> CreateFilteredOwningThreadedLogBackend(const TString& fname, ELogPriority priority, size_t queueLen) { return MakeHolder<TFilteredLogBackend>(CreateOwningThreadedLogBackend(fname, queueLen), priority); } @@ -230,9 +230,9 @@ void TLog::Write(ELogPriority priority, const char* data, size_t len) const { if (Formatter_) { const auto formated = Formatter_(priority, TStringBuf{data, len}); Impl_->WriteData(priority, formated.data(), formated.size()); - } else { - Impl_->WriteData(priority, data, len); - } + } else { + Impl_->WriteData(priority, data, len); + } } void TLog::Write(ELogPriority priority, const TStringBuf data) const { @@ -240,12 +240,12 @@ void TLog::Write(ELogPriority priority, const TStringBuf data) const { } void TLog::Write(const char* data, size_t len) const { - Write(Impl_->DefaultPriority(), data, len); + Write(Impl_->DefaultPriority(), data, len); } - -void TLog::SetFormatter(TLogFormatter formatter) noexcept { + +void TLog::SetFormatter(TLogFormatter formatter) noexcept { Formatter_ = std::move(formatter); -} +} size_t TLog::BackEndQueueSize() const { return Impl_->BackEndQueueSize(); diff --git a/library/cpp/logger/log.h b/library/cpp/logger/log.h index edb861c8f3..8be984ccc8 100644 --- a/library/cpp/logger/log.h +++ b/library/cpp/logger/log.h @@ -9,11 +9,11 @@ #include <util/generic/fwd.h> #include <util/generic/ptr.h> -#include <functional> +#include <functional> #include <cstdarg> using TLogFormatter = std::function<TString(ELogPriority priority, TStringBuf)>; - + // Logging facilities interface. // // ```cpp @@ -109,7 +109,7 @@ private: TIntrusivePtr<TImpl> Impl_; TLogFormatter Formatter_; }; - + THolder<TLogBackend> CreateLogBackend(const TString& fname, ELogPriority priority = LOG_MAX_PRIORITY, bool threaded = false); THolder<TLogBackend> CreateFilteredOwningThreadedLogBackend(const TString& fname, ELogPriority priority = LOG_MAX_PRIORITY, size_t queueLen = 0); THolder<TOwningThreadedLogBackend> CreateOwningThreadedLogBackend(const TString& fname, size_t queueLen = 0); diff --git a/library/cpp/logger/thread.cpp b/library/cpp/logger/thread.cpp index 8ef91bf45e..0ccf9e374b 100644 --- a/library/cpp/logger/thread.cpp +++ b/library/cpp/logger/thread.cpp @@ -144,22 +144,22 @@ void TThreadedLogBackend::ReopenLogNoFlush() { void TThreadedLogBackend::WriteEmergencyData(const TLogRecord& rec) { Impl_->WriteEmergencyData(rec); } - + size_t TThreadedLogBackend::QueueSize() const { return Impl_->QueueSize(); } -TOwningThreadedLogBackend::TOwningThreadedLogBackend(TLogBackend* slave) +TOwningThreadedLogBackend::TOwningThreadedLogBackend(TLogBackend* slave) : THolder<TLogBackend>(slave) , TThreadedLogBackend(Get()) -{ -} - +{ +} + TOwningThreadedLogBackend::TOwningThreadedLogBackend(TLogBackend* slave, size_t queuelen, std::function<void()> queueOverflowCallback) : THolder<TLogBackend>(slave) , TThreadedLogBackend(Get(), queuelen, std::move(queueOverflowCallback)) -{ -} - -TOwningThreadedLogBackend::~TOwningThreadedLogBackend() { -} +{ +} + +TOwningThreadedLogBackend::~TOwningThreadedLogBackend() { +} diff --git a/library/cpp/logger/thread.h b/library/cpp/logger/thread.h index ce4d334e7c..65f7a88e87 100644 --- a/library/cpp/logger/thread.h +++ b/library/cpp/logger/thread.h @@ -25,10 +25,10 @@ private: class TImpl; THolder<TImpl> Impl_; }; - + class TOwningThreadedLogBackend: private THolder<TLogBackend>, public TThreadedLogBackend { -public: - TOwningThreadedLogBackend(TLogBackend* slave); +public: + TOwningThreadedLogBackend(TLogBackend* slave); TOwningThreadedLogBackend(TLogBackend* slave, size_t queuelen, std::function<void()> queueOverflowCallback = {}); - ~TOwningThreadedLogBackend() override; -}; + ~TOwningThreadedLogBackend() override; +}; |