intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 34 insertions, 0 deletions

diff --git a/library/cpp/logger/thread.h b/library/cpp/logger/thread.h
new file mode 100644
index 0000000000..65f7a88e87
--- /dev/null
+++ b/library/cpp/logger/thread.h
@@ -0,0 +1,34 @@
+#pragma once
+
+#include "backend.h"
+
+#include <util/generic/ptr.h>
+
+#include <functional>
+
+class TThreadedLogBackend: public TLogBackend {
+public:
+    TThreadedLogBackend(TLogBackend* slave);
+    TThreadedLogBackend(TLogBackend* slave, size_t queuelen, std::function<void()> queueOverflowCallback = {});
+    ~TThreadedLogBackend() override;
+
+    void WriteData(const TLogRecord& rec) override;
+    void ReopenLog() override;
+    void ReopenLogNoFlush() override;
+    size_t QueueSize() const override;
+
+    // Write an emergency message when the memory allocator is corrupted.
+    // The TThreadedLogBackend object can't be used after this method is called.
+    void WriteEmergencyData(const TLogRecord& rec);
+
+private:
+    class TImpl;
+    THolder<TImpl> Impl_;
+};
+
+class TOwningThreadedLogBackend: private THolder<TLogBackend>, public TThreadedLogBackend {
+public:
+    TOwningThreadedLogBackend(TLogBackend* slave);
+    TOwningThreadedLogBackend(TLogBackend* slave, size_t queuelen, std::function<void()> queueOverflowCallback = {});
+    ~TOwningThreadedLogBackend() override;
+};