Revert "YT-19324: move YT provider to ydb/library/yql"

This reverts commit ca272f12fdd0e8d5c3e957fc87939148f1caaf72, reversing
changes made to 49f8acfc8b0b5c0071b804423bcf53fda26c7c12.

1 files changed, 0 insertions, 351 deletions

diff --git a/library/cpp/yt/logging/logger.h b/library/cpp/yt/logging/logger.h
deleted file mode 100644
index cdb5584d296..00000000000
--- a/library/cpp/yt/logging/logger.h
+++ /dev/null
@@ -1,351 +0,0 @@
-#pragma once
-
-#include "public.h"
-
-#include <library/cpp/yt/string/format.h>
-
-#include <library/cpp/yt/memory/ref.h>
-
-#include <library/cpp/yt/cpu_clock/public.h>
-
-#include <library/cpp/yt/yson_string/string.h>
-
-#include <library/cpp/yt/misc/guid.h>
-
-#include <library/cpp/yt/misc/thread_name.h>
-
-#include <library/cpp/yt/memory/leaky_singleton.h>
-
-#include <util/system/src_location.h>
-
-#include <util/generic/size_literals.h>
-
-#include <atomic>
-
-namespace NYT::NLogging {
-
-////////////////////////////////////////////////////////////////////////////////
-
-constexpr double DefaultStructuredValidationSamplingRate = 0.01;
-
-struct TLoggingCategory
-{
-    TString Name;
-    //! This value is used for early dropping of plaintext events in order
-    //! to reduce load on logging thread for events which are definitely going
-    //! to be dropped due to rule setup.
-    //! NB: this optimization is used only for plaintext events since structured
-    //! logging rate is negligible comparing to the plaintext logging rate.
-    std::atomic<ELogLevel> MinPlainTextLevel;
-    std::atomic<int> CurrentVersion;
-    std::atomic<int>* ActualVersion;
-    std::atomic<double> StructuredValidationSamplingRate = DefaultStructuredValidationSamplingRate;
-};
-
-////////////////////////////////////////////////////////////////////////////////
-
-struct TLoggingAnchor
-{
-    std::atomic<bool> Registered = false;
-    ::TSourceLocation SourceLocation = {TStringBuf{}, 0};
-    TString AnchorMessage;
-    TLoggingAnchor* NextAnchor = nullptr;
-
-    std::atomic<int> CurrentVersion = 0;
-    std::atomic<bool> Enabled = false;
-
-    struct TCounter
-    {
-        std::atomic<i64> Current = 0;
-        i64 Previous = 0;
-    };
-
-    TCounter MessageCounter;
-    TCounter ByteCounter;
-};
-
-////////////////////////////////////////////////////////////////////////////////
-// Declare some type aliases to avoid circular dependencies.
-using TThreadId = size_t;
-using TFiberId = size_t;
-using TTraceId = TGuid;
-using TRequestId = TGuid;
-
-////////////////////////////////////////////////////////////////////////////////
-
-DEFINE_ENUM(ELogMessageKind,
-    (Unstructured)
-    (Structured)
-);
-
-struct TLogEvent
-{
-    const TLoggingCategory* Category = nullptr;
-    ELogLevel Level = ELogLevel::Minimum;
-    ELogFamily Family = ELogFamily::PlainText;
-    bool Essential = false;
-
-    ELogMessageKind MessageKind = ELogMessageKind::Unstructured;
-    TSharedRef MessageRef;
-
-    TCpuInstant Instant = 0;
-
-    TThreadId ThreadId = {};
-    TThreadName ThreadName = {};
-
-    TFiberId FiberId = {};
-
-    TTraceId TraceId;
-    TRequestId RequestId;
-
-    TStringBuf SourceFile;
-    int SourceLine = -1;
-};
-
-////////////////////////////////////////////////////////////////////////////////
-
-struct ILogManager
-{
-    virtual ~ILogManager() = default;
-
-    virtual void RegisterStaticAnchor(
-        TLoggingAnchor* position,
-        ::TSourceLocation sourceLocation,
-        TStringBuf anchorMessage) = 0;
-    virtual void UpdateAnchor(TLoggingAnchor* position) = 0;
-
-    virtual void Enqueue(TLogEvent&& event) = 0;
-
-    virtual const TLoggingCategory* GetCategory(TStringBuf categoryName) = 0;
-    virtual void UpdateCategory(TLoggingCategory* category) = 0;
-
-    virtual bool GetAbortOnAlert() const = 0;
-};
-
-ILogManager* GetDefaultLogManager();
-
-////////////////////////////////////////////////////////////////////////////////
-
-struct TLoggingContext
-{
-    TCpuInstant Instant;
-    TThreadId ThreadId;
-    TThreadName ThreadName;
-    TFiberId FiberId;
-    TTraceId TraceId;
-    TRequestId RequestId;
-    TStringBuf TraceLoggingTag;
-};
-
-TLoggingContext GetLoggingContext();
-
-////////////////////////////////////////////////////////////////////////////////
-
-//! Sets the minimum logging level for messages in current thread.
-// NB: In fiber environment, min log level is attached to a fiber,
-// so after context switch thread min log level might change.
-void SetThreadMinLogLevel(ELogLevel minLogLevel);
-ELogLevel GetThreadMinLogLevel();
-
-////////////////////////////////////////////////////////////////////////////////
-
-static constexpr auto NullLoggerMinLevel = ELogLevel::Maximum;
-
-// Min level for non-null logger depends on whether we are in debug or release build.
-// - For release mode default behavior is to omit trace logging,
-//   this is done by setting logger min level to Debug by default.
-// - For debug mode logger min level is set to trace by default, so that trace logging is
-//   allowed by logger, but still may be discarded by category min level.
-#ifdef NDEBUG
-static constexpr auto LoggerDefaultMinLevel = ELogLevel::Debug;
-#else
-static constexpr auto LoggerDefaultMinLevel = ELogLevel::Trace;
-#endif
-
-class TLogger
-{
-public:
-    using TStructuredValidator = std::function<void(const NYson::TYsonString&)>;
-    using TStructuredValidators = std::vector<TStructuredValidator>;
-
-    using TStructuredTag = std::pair<TString, NYson::TYsonString>;
-    // TODO(max42): switch to TCompactVector after YT-15430.
-    using TStructuredTags = std::vector<TStructuredTag>;
-
-    TLogger() = default;
-    TLogger(const TLogger& other) = default;
-    TLogger& operator=(const TLogger& other) = default;
-
-    TLogger(ILogManager* logManager, TStringBuf categoryName);
-    explicit TLogger(TStringBuf categoryName);
-
-    explicit operator bool() const;
-
-    const TLoggingCategory* GetCategory() const;
-
-    //! Validate that level is admitted by logger's own min level
-    //! and by category's min level.
-    bool IsLevelEnabled(ELogLevel level) const;
-
-    bool GetAbortOnAlert() const;
-
-    bool IsEssential() const;
-
-    bool IsAnchorUpToDate(const TLoggingAnchor& anchor) const;
-    void UpdateAnchor(TLoggingAnchor* anchor) const;
-    void RegisterStaticAnchor(TLoggingAnchor* anchor, ::TSourceLocation sourceLocation, TStringBuf message) const;
-
-    void Write(TLogEvent&& event) const;
-
-    void AddRawTag(const TString& tag);
-    template <class... TArgs>
-    void AddTag(const char* format, TArgs&&... args);
-
-    template <class TType>
-    void AddStructuredTag(TStringBuf key, TType value);
-
-    TLogger WithRawTag(const TString& tag) const;
-    template <class... TArgs>
-    TLogger WithTag(const char* format, TArgs&&... args) const;
-
-    template <class TType>
-    TLogger WithStructuredTag(TStringBuf key, TType value) const;
-
-    TLogger WithStructuredValidator(TStructuredValidator validator) const;
-
-    TLogger WithMinLevel(ELogLevel minLevel) const;
-
-    TLogger WithEssential(bool essential = true) const;
-
-    const TString& GetTag() const;
-    const TStructuredTags& GetStructuredTags() const;
-
-    const TStructuredValidators& GetStructuredValidators() const;
-
-protected:
-    // These fields are set only during logger creation, so they are effectively const
-    // and accessing them is thread-safe.
-    ILogManager* LogManager_ = nullptr;
-    const TLoggingCategory* Category_ = nullptr;
-    bool Essential_ = false;
-    ELogLevel MinLevel_ = NullLoggerMinLevel;
-    TString Tag_;
-    TStructuredTags StructuredTags_;
-    TStructuredValidators StructuredValidators_;
-
-private:
-    //! This method checks level against category's min level.
-    //! Refer to comment in TLogger::IsLevelEnabled for more details.
-    bool IsLevelEnabledHeavy(ELogLevel level) const;
-};
-
-////////////////////////////////////////////////////////////////////////////////
-
-void LogStructuredEvent(
-    const TLogger& logger,
-    NYson::TYsonString message,
-    ELogLevel level);
-
-////////////////////////////////////////////////////////////////////////////////
-
-#ifdef YT_ENABLE_TRACE_LOGGING
-#define YT_LOG_TRACE(...)                      YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Trace, __VA_ARGS__)
-#define YT_LOG_TRACE_IF(condition, ...)        if (condition)    YT_LOG_TRACE(__VA_ARGS__)
-#define YT_LOG_TRACE_UNLESS(condition, ...)    if (!(condition)) YT_LOG_TRACE(__VA_ARGS__)
-#else
-#define YT_LOG_UNUSED(...)                     if (true) { } else { YT_LOG_DEBUG(__VA_ARGS__); }
-#define YT_LOG_TRACE(...)                      YT_LOG_UNUSED(__VA_ARGS__)
-#define YT_LOG_TRACE_IF(condition, ...)        YT_LOG_UNUSED(__VA_ARGS__)
-#define YT_LOG_TRACE_UNLESS(condition, ...)    YT_LOG_UNUSED(__VA_ARGS__)
-#endif
-
-#define YT_LOG_DEBUG(...)                      YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Debug, __VA_ARGS__)
-#define YT_LOG_DEBUG_IF(condition, ...)        if (condition)    YT_LOG_DEBUG(__VA_ARGS__)
-#define YT_LOG_DEBUG_UNLESS(condition, ...)    if (!(condition)) YT_LOG_DEBUG(__VA_ARGS__)
-
-#define YT_LOG_INFO(...)                       YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Info, __VA_ARGS__)
-#define YT_LOG_INFO_IF(condition, ...)         if (condition)    YT_LOG_INFO(__VA_ARGS__)
-#define YT_LOG_INFO_UNLESS(condition, ...)     if (!(condition)) YT_LOG_INFO(__VA_ARGS__)
-
-#define YT_LOG_WARNING(...)                    YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Warning, __VA_ARGS__)
-#define YT_LOG_WARNING_IF(condition, ...)      if (condition)    YT_LOG_WARNING(__VA_ARGS__)
-#define YT_LOG_WARNING_UNLESS(condition, ...)  if (!(condition)) YT_LOG_WARNING(__VA_ARGS__)
-
-#define YT_LOG_ERROR(...)                      YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Error, __VA_ARGS__)
-#define YT_LOG_ERROR_IF(condition, ...)        if (condition)    YT_LOG_ERROR(__VA_ARGS__)
-#define YT_LOG_ERROR_UNLESS(condition, ...)    if (!(condition)) YT_LOG_ERROR(__VA_ARGS__)
-
-#define YT_LOG_ALERT(...)                      YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Alert, __VA_ARGS__);
-#define YT_LOG_ALERT_IF(condition, ...)        if (condition)    YT_LOG_ALERT(__VA_ARGS__)
-#define YT_LOG_ALERT_UNLESS(condition, ...)    if (!(condition)) YT_LOG_ALERT(__VA_ARGS__)
-
-#define YT_LOG_FATAL(...) \
-    do { \
-        YT_LOG_EVENT(Logger, ::NYT::NLogging::ELogLevel::Fatal, __VA_ARGS__); \
-        Y_UNREACHABLE(); \
-    } while(false)
-#define YT_LOG_FATAL_IF(condition, ...)        if (Y_UNLIKELY(condition)) YT_LOG_FATAL(__VA_ARGS__)
-#define YT_LOG_FATAL_UNLESS(condition, ...)    if (!Y_LIKELY(condition)) YT_LOG_FATAL(__VA_ARGS__)
-
-#define YT_LOG_EVENT(logger, level, ...) \
-    YT_LOG_EVENT_WITH_ANCHOR(logger, level, nullptr, __VA_ARGS__)
-
-#define YT_LOG_EVENT_WITH_ANCHOR(logger, level, anchor, ...) \
-    do { \
-        const auto& logger__##__LINE__ = (logger); \
-        auto level__##__LINE__ = (level); \
-        \
-        if (!logger__##__LINE__.IsLevelEnabled(level__##__LINE__)) { \
-            break; \
-        } \
-        \
-        auto location__##__LINE__ = __LOCATION__; \
-        \
-        ::NYT::NLogging::TLoggingAnchor* anchor__##__LINE__ = (anchor); \
-        if (!anchor__##__LINE__) { \
-            static ::NYT::TLeakyStorage<::NYT::NLogging::TLoggingAnchor> staticAnchor__##__LINE__; \
-            anchor__##__LINE__ = staticAnchor__##__LINE__.Get(); \
-        } \
-        \
-        bool anchorUpToDate__##__LINE__ = logger__##__LINE__.IsAnchorUpToDate(*anchor__##__LINE__); \
-        if (anchorUpToDate__##__LINE__ && !anchor__##__LINE__->Enabled.load(std::memory_order::relaxed)) { \
-            break; \
-        } \
-        \
-        auto loggingContext__##__LINE__ = ::NYT::NLogging::GetLoggingContext(); \
-        auto message__##__LINE__ = ::NYT::NLogging::NDetail::BuildLogMessage(loggingContext__##__LINE__, logger__##__LINE__, __VA_ARGS__); \
-        \
-        if (!anchorUpToDate__##__LINE__) { \
-            logger__##__LINE__.RegisterStaticAnchor(anchor__##__LINE__, location__##__LINE__, message__##__LINE__.Anchor); \
-            logger__##__LINE__.UpdateAnchor(anchor__##__LINE__); \
-        } \
-        \
-        if (!anchor__##__LINE__->Enabled.load(std::memory_order::relaxed)) { \
-            break; \
-        } \
-        \
-        static thread_local i64 localByteCounter__##__LINE__; \
-        static thread_local ui8 localMessageCounter__##__LINE__; \
-        \
-        localByteCounter__##__LINE__ += message__##__LINE__.MessageRef.Size(); \
-        if (Y_UNLIKELY(++localMessageCounter__##__LINE__ == 0)) { \
-            anchor__##__LINE__->MessageCounter.Current += 256; \
-            anchor__##__LINE__->ByteCounter.Current += localByteCounter__##__LINE__; \
-            localByteCounter__##__LINE__ = 0; \
-        } \
-        \
-        ::NYT::NLogging::NDetail::LogEventImpl( \
-            loggingContext__##__LINE__, \
-            logger__##__LINE__, \
-            level__##__LINE__, \
-            location__##__LINE__, \
-            std::move(message__##__LINE__.MessageRef)); \
-    } while (false)
-
-////////////////////////////////////////////////////////////////////////////////
-
-} // namespace NYT::NLogging
-
-#define LOGGER_INL_H_
-#include "logger-inl.h"
-#undef LOGGER_INL_H_