intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 87 insertions, 0 deletions

diff --git a/library/cpp/logger/system.cpp b/library/cpp/logger/system.cpp
new file mode 100644
index 0000000000..42233f63d2
--- /dev/null
+++ b/library/cpp/logger/system.cpp
@@ -0,0 +1,87 @@
+#include <util/stream/output.h>
+#include <util/stream/null.h>
+#include <util/system/compat.h>
+#include <util/system/yassert.h>
+#include <util/system/defaults.h>
+#include <util/generic/singleton.h>
+#include <util/generic/utility.h>
+
+#if defined(_unix_)
+#include <syslog.h>
+#endif
+
+#include "system.h"
+#include "record.h"
+#include "stream.h"
+
+TSysLogBackend::TSysLogBackend(const char* ident, EFacility facility, int flags)
+    : Ident(ident)
+    , Facility(facility)
+    , Flags(flags)
+{
+#if defined(_unix_)
+    Y_ASSERT(TSYSLOG_LOCAL0 <= facility && facility <= TSYSLOG_LOCAL7);
+
+    static const int f2sf[] = {
+        LOG_LOCAL0,
+        LOG_LOCAL1,
+        LOG_LOCAL2,
+        LOG_LOCAL3,
+        LOG_LOCAL4,
+        LOG_LOCAL5,
+        LOG_LOCAL6,
+        LOG_LOCAL7};
+
+    int sysflags = LOG_NDELAY | LOG_PID;
+
+    if (flags & LogPerror) {
+        sysflags |= LOG_PERROR;
+    }
+
+    if (flags & LogCons) {
+        sysflags |= LOG_CONS;
+    }
+
+    openlog(Ident.data(), sysflags, f2sf[(size_t)facility]);
+#endif
+}
+
+TSysLogBackend::~TSysLogBackend() {
+#if defined(_unix_)
+    closelog();
+#endif
+}
+
+void TSysLogBackend::WriteData(const TLogRecord& rec) {
+#if defined(_unix_)
+    syslog(ELogPriority2SyslogPriority(rec.Priority), "%.*s", (int)rec.Len, rec.Data);
+#else
+    Y_UNUSED(rec);
+#endif
+}
+
+void TSysLogBackend::ReopenLog() {
+}
+
+int TSysLogBackend::ELogPriority2SyslogPriority(ELogPriority priority) {
+#if defined(_unix_)
+     return Min(int(priority), (int)LOG_PRIMASK);
+#else
+    // trivial conversion
+    return int(priority);
+#endif
+}
+
+namespace {
+    class TSysLogInstance: public TLog {
+    public:
+        inline TSysLogInstance()
+            : TLog(MakeHolder<TStreamLogBackend>(&Cnull))
+        {
+        }
+    };
+}
+
+TLog& SysLogInstance() {
+    return *Singleton<TSysLogInstance>();
+}